RFID修正

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

@@ -32,6 +32,8 @@ public class DeJuRFIDService implements IService {
 
     private final Map<String, GClient> clientMap = new ConcurrentHashMap<>();
 
+    private boolean isAlerm=false;
+
     private final ScheduledExecutorService scheduledExecutorService= SpringUtils.getBean("scheduledExecutorService");
 
     @Override
@@ -143,15 +145,6 @@ public class DeJuRFIDService implements IService {
     }
 
     private void changeGpo(int state, GClient client,int delayTime) {
-        MsgAppGetGpiState msgAppGetGpiState=new MsgAppGetGpiState();
-        client.sendSynMsg(msgAppGetGpiState);
-        if (0 == msgAppGetGpiState.getRtCode()) {
-            HashMap<Integer, Integer> gpiState = msgAppGetGpiState.getHpGpiState();
-            log.info("GpiState epc {} successful.",gpiState.get(1));
-        } else {
-            log.error("GpiState epc error.");
-        }
-
         MsgAppSetGpo msgAppSetGpo=new MsgAppSetGpo();
         msgAppSetGpo.setGpo1(state);
         msgAppSetGpo.setGpo2(state);
@@ -161,7 +154,10 @@ public class DeJuRFIDService implements IService {
         if (0 == msgAppSetGpo.getRtCode()) {
             log.info("Gpo epc {} successful.",status);
             if (state==1){
+                isAlerm=true;
                 stopGpo(client,delayTime);
+            }else {
+                isAlerm=false;
             }
         } else {
             log.error("Gpo epc {} error.",status);
@@ -187,7 +183,9 @@ public class DeJuRFIDService implements IService {
             if (logBaseEpcInfo.getResult() == 0) {
                 log.info("===========》{}",logBaseEpcInfo.getbEpc());
                 //灯带设置
-                changeGpo(1, client,10);
+                if (!isAlerm){
+                    changeGpo(1, client,10);
+                }
                 InventoryTag tag = new InventoryTag();
                 BeanUtils.copyProperties(logBaseEpcInfo, tag);
                 sendService.send(tag);