소스 검색

rfid日志打印

hanzhiwei 3 년 전
부모
커밋
6b3c263f52

+ 3 - 0
zd-modules/zd-algorithm/src/main/java/com/zd/alg/rfid/sdk/RfidClientImpl.java

@@ -155,14 +155,17 @@ public class RfidClientImpl implements IService {
                     int antId = logBaseEpcInfo.getAntId();
                     String epc = logBaseEpcInfo.getEpc();
                     if (Boolean.FALSE.equals(redisTemplate.hasKey(logBaseEpcInfo.getEpc() + antId))) {
+                        log.info("打印进入日志!");
                         //不存在缓存,设置间隔30s调用
                         redisTemplate.opsForValue().set(logBaseEpcInfo.getEpc() + antId, hardwareRfid, 30, TimeUnit.SECONDS);
                         scheduledExecutorService.execute(() -> {
+                            log.info("打印日志发送前日志");
                             InventoryTag tag = new InventoryTag();
                             BeanUtils.copyProperties(logBaseEpcInfo, tag);
                             HardwareRfidDto hardwareRfidDto = new HardwareRfidDto();
                             BeanUtils.copyProperties(hardwareRfid, hardwareRfidDto);
                             tag.setHardwareRfidDto(hardwareRfidDto);
+                            log.info("调用发送方法!发送内容 tag = {}",tag.toString());
                             sendService.send(tag);
                         });
                     } else {

+ 11 - 0
zd-modules/zd-algorithm/src/main/java/com/zd/alg/rfid/service/impl/SendServiceImpl.java

@@ -40,6 +40,7 @@ public class SendServiceImpl implements ISendService {
     public boolean send(InventoryTag tag) {
         HardwareRfidDto hardwareRfidDto = tag.getHardwareRfidDto();
         if (hardwareRfidDto != null) {
+            log.info("进入方法!");
             int antId = tag.getAntId();
             String uniformPower = hardwareRfidDto.getUniformPower();
             String[] uniformPowers = uniformPower.split(",");
@@ -51,14 +52,18 @@ public class SendServiceImpl implements ISendService {
 
     private boolean handleTag(InventoryTag tag, int antId, String[] uniformPowers) {
         // 判断有设备配置和触发的天线编码等与配置天线编号
+        log.info("进入方法handleTag");
         if (uniformPowers.length > 0) {
+            log.info("判断进入");
             String tempUniformPower = uniformPowers[antId - 1];
             if (StringUtils.hasLength(tempUniformPower)) {
                 String[] tempUniformPowers = tempUniformPower.split(":");
                 if (tempUniformPowers.length > 1) {
                     String temp = tempUniformPowers[1];
+                    log.info("发送调用1");
                     return sendTag(tag, temp);
                 } else {
+                    log.info("发送调用2");
                     return sendTag(tag, null);
                 }
             }
@@ -68,23 +73,29 @@ public class SendServiceImpl implements ISendService {
 
     private boolean sendTag(InventoryTag tag, String temp) {
         if (temp == null) {
+            log.info("调用气瓶");
             boolean b = sendBottle(tag);
             if (b) {
                 return true;
             }
+            log.info("调用化学品");
             return sendStock(tag);
         }
         if (ALL_TYPE.equals(temp)) {
+            log.info("调用气瓶1");
             boolean b = sendBottle(tag);
             if (b) {
                 return true;
             }
+            log.info("调用化学品1");
             return sendStock(tag);
         }
         if (BOTTLE_TYPE.equals(temp)) {
+            log.info("调用气瓶2");
             return sendBottle(tag);
         }
         if (CHEMICAL_TYPE.equals(temp)) {
+            log.info("调用化学品2");
             return sendStock(tag);
         }
         return false;