回复消息 bug修改

src/main/java/com/cn/esermis/netty/BootNettyChannelInboundHandlerAdapter.java

@@ -95,8 +95,8 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                             String CN = jsonObject.getString("CN");
                             String MN = jsonObject.getString("MN");
                             String dataTime = jsonObject.getString("DataTime");
-                            if (!adapter.redisQueueService.isElementExist(CN + MN + dataTime, dataTime)){
-                                adapter.redisQueueService.addElementWithExpire(CN+MN+dataTime, dataTime, 1, TimeUnit.HOURS);
+                            if (!adapter.redisQueueService.isElementExist(MN +":"+ CN +":"+ dataTime, dataTime)){
+                                adapter.redisQueueService.addElementWithExpire(MN +":"+ CN +":"+ dataTime, dataTime, 1, TimeUnit.HOURS);
                                 adapter.redisQueueService.sendMessage(Constant.SERVER, jsonObject);
                             }
                         }
@@ -112,8 +112,8 @@ public class BootNettyChannelInboundHandlerAdapter extends ChannelInboundHandler
                                 String CN = jsonObject.getString("CN");
                                 String MN = jsonObject.getString("MN");
                                 String dataTime = jsonObject.getString("DataTime");
-                                if (!adapter.redisQueueService.isElementExist(CN + MN + dataTime, dataTime)){
-                                    adapter.redisQueueService.addElementWithExpire(CN+MN+dataTime, dataTime, 1, TimeUnit.HOURS);
+                                if (!adapter.redisQueueService.isElementExist(MN +":"+ CN +":"+ dataTime, dataTime)){
+                                    adapter.redisQueueService.addElementWithExpire(MN +":"+ CN +":"+ dataTime, dataTime, 1, TimeUnit.HOURS);
                                     adapter.redisQueueService.sendMessage(Constant.SERVER, jsonObject);
                                 }
                             }