menglu 3 years ago
parent
commit
f709f9aa3b

+ 3 - 1
ibms-data-sdk/src/main/java/com/persagy/ibms/data/sdk/service/websocket/server/WebSocketUtil.java

@@ -34,6 +34,8 @@ public class WebSocketUtil {
 	public static Map<String, Map<String, Boolean>> id2objInfoIdList = new ConcurrentHashMap<String, Map<String, Boolean>>();
 
 	public static synchronized void ProcessConnected(String id, Object ContentJSON) {
+		ProcessDisconnected(id);
+		
 		idMap.put(id, ContentJSON);
 		Map<String, Boolean> objIdList = new ConcurrentHashMap<String, Boolean>();
 		id2objIdList.put(id, objIdList);
@@ -187,7 +189,7 @@ public class WebSocketUtil {
 									List<ObjectInfo> ObjectInfoList = Repository.point2ObjectInfoList.get(point);
 									for (ObjectInfo ObjectInfo : ObjectInfoList) {
 										if (objIdList.containsKey(ObjectInfo.objId)
-												|| objInfoIdList.containsKey(ObjectInfo.objId + "" + ObjectInfo.infoCode)) {
+												|| objInfoIdList.containsKey(ObjectInfo.objId + "-" + ObjectInfo.infoCode)) {
 											if (!sendObj.containsKey(ObjectInfo.objId)) {
 												sendObj.put(ObjectInfo.objId, new JSONObject());
 											}