hecheng преди 3 години
родител
ревизия
9b6b53e666
променени са 1 файла, в които са добавени 6 реда и са изтрити 5 реда
  1. 6 5
      zd-modules/zd-netty/src/main/java/com/zd/netty/sdk/DeJuRFIDServiceImpl.java

+ 6 - 5
zd-modules/zd-netty/src/main/java/com/zd/netty/sdk/DeJuRFIDServiceImpl.java

@@ -58,32 +58,33 @@ public class DeJuRFIDServiceImpl implements IService {
             CLIENT_MAP.put(ipAddress, client);
         }
         if (client.openTcp(ipAddress + HTTP_SEPARATOR + PORT, TIME_OUT)) {
-            // 订阅标签上报事件
-            subscribeHandler(client, hardware);
+            stopMsg(client);
             // 功率配置, 将4个天线功率都设置为30dBm.
             MsgBaseSetPower msgBaseSetPower = setPower(hardware, client);
             if (0 != msgBaseSetPower.getRtCode()) {
                 log.error("Power configuration error.");
-                reset(client);
                 close(hardware);
                 open(hardware);
+                return;
             }
             //天线读卡, 读取EPC数据区以及TID数据区
             MsgBaseInventoryEpc msgBaseInventoryEpc = setInventory(hardware, client);
             if (0 != msgBaseInventoryEpc.getRtCode()) {
                 log.error("Inventory epc error.");
-                reset(client);
                 close(hardware);
                 open(hardware);
+                return;
             }
 
             MsgBaseSetBaseband msgBaseSetBaseband = setSession(hardware, client);
             if (0 != msgBaseSetBaseband.getRtCode()) {
                 log.error("Session epc error.");
-                reset(client);
                 close(hardware);
                 open(hardware);
+                return;
             }
+            // 订阅标签上报事件
+            subscribeHandler(client, hardware);
         } else {
             throw new ServiceException("Connect failure.");
         }