RFID修正

zd-modules/zd-netty/src/main/java/com/zd/netty/sdk/DeJuRFIDService.java

@@ -139,26 +139,23 @@ public class DeJuRFIDService implements IService {
      */
     private void subscribeHandler(GClient client) {
         client.onTagEpcLog = (s, logBaseEpcInfo) -> {
-            //灯带设置
-            MsgAppSetGpo msgAppSetGpo=new MsgAppSetGpo();
-            msgAppSetGpo.setGpo1(1);
-            msgAppSetGpo.setGpo2(1);
-            msgAppSetGpo.setGpo3(1);
-            msgAppSetGpo.setGpo4(1);
-            msgAppSetGpo.setGpo5(1);
-            msgAppSetGpo.setGpo6(1);
-            msgAppSetGpo.setGpo7(1);
-            msgAppSetGpo.setGpo8(1);
-            client.sendSynMsg(msgAppSetGpo);
-            if (0 == msgAppSetGpo.getRtCode()) {
-                log.info("Gpo epc successful.");
-            } else {
-                log.error("Gpo epc error.");
-            }
             if (logBaseEpcInfo.getResult() == 0) {
-                InventoryTag tag = new InventoryTag();
-                BeanUtils.copyProperties(logBaseEpcInfo, tag);
-                sendService.send(tag);
+                //灯带设置
+                MsgAppSetGpo msgAppSetGpo=new MsgAppSetGpo();
+                msgAppSetGpo.setGpo1(1);
+                msgAppSetGpo.setGpo2(1);
+                msgAppSetGpo.setGpo3(1);
+                msgAppSetGpo.setGpo4(1);
+                msgAppSetGpo.setGpo5(1);
+                msgAppSetGpo.setGpo6(1);
+                msgAppSetGpo.setGpo7(1);
+                msgAppSetGpo.setGpo8(1);
+                client.sendSynMsg(msgAppSetGpo);
+                if (0 == msgAppSetGpo.getRtCode()) {
+                    log.info("Gpo epc successful.");
+                } else {
+                    log.error("Gpo epc error.");
+                }
                 threadPoolTaskConfig.getAsyncExecutor().execute(() -> {
                     msgAppSetGpo.setGpo1(0);
                     msgAppSetGpo.setGpo2(0);
@@ -174,7 +171,10 @@ public class DeJuRFIDService implements IService {
                     } else {
                         log.error("Gpo epc stop error.");
                     }
-                },10000);
+                },8*1000);
+                InventoryTag tag = new InventoryTag();
+                BeanUtils.copyProperties(logBaseEpcInfo, tag);
+                sendService.send(tag);
             }
         };