Преглед изворни кода

东北大学屏蔽RFID门禁机功能

hanzhiwei пре 2 година
родитељ
комит
c1c9867d20

+ 10 - 10
zd-modules/zd-algorithm/src/main/java/com/zd/alg/rfid/init/RfidStartListener.java

@@ -37,15 +37,15 @@ public class RfidStartListener implements ApplicationRunner {
 
     @Override
     public void run(ApplicationArguments args) {
-        List<HardwareRfid> list = hardwareRfidService.list(new LambdaQueryWrapper<HardwareRfid>().eq(HardwareRfid::getOnOff, DeviceOnOffEnum.ON.getCode()));
-        synchronized (this) {
-            if (!list.isEmpty()) {
-                try {
-                    list.stream().filter(u -> StringUtils.hasLength(u.getIpAddress())).forEach(u -> rfidService.start(u));
-                } catch (Exception e) {
-                    log.error("启动操作失败!{}", e);
-                }
-            }
-        }
+//        List<HardwareRfid> list = hardwareRfidService.list(new LambdaQueryWrapper<HardwareRfid>().eq(HardwareRfid::getOnOff, DeviceOnOffEnum.ON.getCode()));
+//        synchronized (this) {
+//            if (!list.isEmpty()) {
+//                try {
+//                    list.stream().filter(u -> StringUtils.hasLength(u.getIpAddress())).forEach(u -> rfidService.start(u));
+//                } catch (Exception e) {
+//                    log.error("启动操作失败!{}", e);
+//                }
+//            }
+//        }
     }
 }

+ 8 - 8
zd-modules/zd-algorithm/src/main/java/com/zd/alg/rfid/service/impl/RfidServiceImpl.java

@@ -27,14 +27,14 @@ public class RfidServiceImpl implements IRfidService {
 
     @Override
     public void start(HardwareRfid hardwareRfid) {
-        synchronized (this){
-            taskExecutor.execute(() -> {
-                rfidService(hardwareRfid.getManufacturerType()).start(hardwareRfid);
-                log.info("===============thread name:{}===============", Thread.currentThread().getName());
-                threadMap.computeIfAbsent(hardwareRfid.getIpAddress(), f -> Thread.currentThread());
-                log.info("==============>线程数量:{}",threadMap.size());
-            });
-        }
+//        synchronized (this){
+//            taskExecutor.execute(() -> {
+//                rfidService(hardwareRfid.getManufacturerType()).start(hardwareRfid);
+//                log.info("===============thread name:{}===============", Thread.currentThread().getName());
+//                threadMap.computeIfAbsent(hardwareRfid.getIpAddress(), f -> Thread.currentThread());
+//                log.info("==============>线程数量:{}",threadMap.size());
+//            });
+//        }
     }
 
     @Override