|
@@ -204,6 +204,8 @@ public class DataReaderListenerImpl extends DDS._DataReaderListenerLocalBase {
|
|
|
|
|
|
}
|
|
|
if(mh.value.subject.equals("4")){
|
|
|
+ this.coopTeamMap.clear();
|
|
|
+ messageStatusMap.values().forEach(status1 -> status1.setGroupID(""));
|
|
|
//收到网络分组信息
|
|
|
String message = mh.value.text;
|
|
|
String[] messageList = message.split("\n");
|
|
@@ -215,6 +217,10 @@ public class DataReaderListenerImpl extends DDS._DataReaderListenerLocalBase {
|
|
|
List<String> list = new ArrayList<>();
|
|
|
for(int j=2;j<s.length;j++){
|
|
|
list.add(s[j]);
|
|
|
+ if (messageStatusMap.get(s[j]) == null){
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ messageStatusMap.get(s[j]).setGroupID(coopID);
|
|
|
}
|
|
|
coopTeamMap.put(coopID,list);
|
|
|
}
|