diff --git a/review_repo/src/main/java/com/zcloud/Kafka/KafkaMessageListener.java b/review_repo/src/main/java/com/zcloud/Kafka/KafkaMessageListener.java index 675838c..2483072 100644 --- a/review_repo/src/main/java/com/zcloud/Kafka/KafkaMessageListener.java +++ b/review_repo/src/main/java/com/zcloud/Kafka/KafkaMessageListener.java @@ -50,7 +50,13 @@ public class KafkaMessageListener { combinedMap.putAll(subMap); } if(combinedMap.containsKey(terminalNo)) { - jsonObject.put("MAP_POINT_NAME", combinedMap.get(terminalNo)); + String[] userAndStaffNo = combinedMap.get(terminalNo).split("@"); + jsonObject.put("MAP_POINT_NAME", userAndStaffNo[0]); + jsonObject.put("staffNo", userAndStaffNo[1]); + jsonObject.put("orgName", userAndStaffNo[2]); + jsonObject.put("name", userAndStaffNo[3]); + }else { + return; } // 根据 terminalNo 设备号 找到redis里存在的 如果不存在 直接追加 // 如果存在 比对时间 以时间新的为准 更新redis @@ -64,11 +70,11 @@ public class KafkaMessageListener { Long b = Long.parseLong(str3); if(a