diff --git a/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java b/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java index 8a5724f..6cff81c 100644 --- a/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java +++ b/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java @@ -137,7 +137,6 @@ System.out.println("功率修改成功"); } else if (bh == 3) { //添加标签读取回调 - ScanTagParameter param = new ScanTagParameter(); param.antenna = 0x01; param.isLoop = true; diff --git a/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java b/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java index 8a5724f..6cff81c 100644 --- a/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java +++ b/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java @@ -137,7 +137,6 @@ System.out.println("功率修改成功"); } else if (bh == 3) { //添加标签读取回调 - ScanTagParameter param = new ScanTagParameter(); param.antenna = 0x01; param.isLoop = true; diff --git a/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java b/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java index 172becf..c381155 100644 --- a/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java +++ b/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java @@ -320,6 +320,9 @@ } else { log.info("EPC、TID标签停止读取失败"); } + for (String tId : tIds) { + webSocket.sendAllMessage(tId); + } return tIds; } diff --git a/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java b/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java index 8a5724f..6cff81c 100644 --- a/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java +++ b/src/main/java/com/casic/missiles/cotroller/BusinessReadWriterController.java @@ -137,7 +137,6 @@ System.out.println("功率修改成功"); } else if (bh == 3) { //添加标签读取回调 - ScanTagParameter param = new ScanTagParameter(); param.antenna = 0x01; param.isLoop = true; diff --git a/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java b/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java index 172becf..c381155 100644 --- a/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java +++ b/src/main/java/com/casic/missiles/service/impl/BusinessReadWriterServiceImpl.java @@ -320,6 +320,9 @@ } else { log.info("EPC、TID标签停止读取失败"); } + for (String tId : tIds) { + webSocket.sendAllMessage(tId); + } return tIds; } diff --git a/src/main/java/com/casic/missiles/utils/WebSocket.java b/src/main/java/com/casic/missiles/utils/WebSocket.java index 7a4fef0..7633655 100644 --- a/src/main/java/com/casic/missiles/utils/WebSocket.java +++ b/src/main/java/com/casic/missiles/utils/WebSocket.java @@ -38,6 +38,7 @@ log.info(userId + "【websocket消息】有新的连接,总数为:" + webSockets.size()); log.info("websocket receive connect size:" + webSockets.size()); IBusinessReadWriterService readWriterService = SpringContextUtil.getBean("readWriterServiceBean"); + log.info("开始执行调用读写器..........."); readWriterService.tIdAndMiniAndGunReadList(); // System.out.println(userId + "【websocket消息】有新的连接,总数为:" + webSockets.size()); }