diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/runner/AccessApplicationRunner.java b/iot-access/access-boot/src/main/java/com/njcn/access/runner/AccessApplicationRunner.java index 4ddd8ff..2d53b76 100644 --- a/iot-access/access-boot/src/main/java/com/njcn/access/runner/AccessApplicationRunner.java +++ b/iot-access/access-boot/src/main/java/com/njcn/access/runner/AccessApplicationRunner.java @@ -45,7 +45,7 @@ public class AccessApplicationRunner implements ApplicationRunner { public void run(ApplicationArguments args) { //项目启动60s后发起自动接入 Runnable task = () -> { - log.info("系统重启,所有符合条件的装置全部接入!"); + log.info("系统重启,所有符合条件的装置发起接入!"); List list = csEquipmentDeliveryService.getOnlineDev(); if (CollUtil.isNotEmpty(list)) { ExecutorService executor = Executors.newFixedThreadPool(10); diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java b/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java index 9763659..870ca66 100644 --- a/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java +++ b/iot-access/access-boot/src/main/java/com/njcn/access/runner/AutoAccessTimer.java @@ -83,7 +83,7 @@ public class AutoAccessTimer implements ApplicationRunner { public void accessDev(List list) { list.forEach(item->{ - System.out.println(Thread.currentThread().getName() + ": reboot : nDid : " + item.getNdid()); + System.out.println(Thread.currentThread().getName() + ": auto : nDid : " + item.getNdid()); String version = csTopicService.getVersion(item.getNdid()); if (!Objects.isNull(version)){ //判断设备类型 便携式设备需要特殊处理 未注册的要先注册、再接入;已注册的直接重新接入 diff --git a/iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDataSetServiceImpl.java b/iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDataSetServiceImpl.java index 6adf400..5c37b12 100644 --- a/iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDataSetServiceImpl.java +++ b/iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDataSetServiceImpl.java @@ -33,6 +33,7 @@ public class CsDataSetServiceImpl extends ServiceImpl getDataSetData(String modelId) { return this.lambdaQuery() .eq(CsDataSet::getPid, modelId) + .and(item->item.eq(CsDataSet::getConType,1).or().isNull(CsDataSet::getConType)) .and(item->item.eq(CsDataSet::getDataType,"Stat").or().isNull(CsDataSet::getDataType)) .list(); } diff --git a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/EventServiceImpl.java b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/EventServiceImpl.java index 66592ab..53bf629 100644 --- a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/EventServiceImpl.java +++ b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/EventServiceImpl.java @@ -208,7 +208,7 @@ public class EventServiceImpl implements IEventService { //新项目入库 WlRecord wlRecord = new WlRecord(); wlRecord.setId(IdUtil.simpleUUID()); - wlRecord.setItemName("基础数据"); + wlRecord.setItemName("在线监测"); wlRecord.setGcName(item.getPrjName()); wlRecord.setDevId(vo.getId()); wlRecord.setLineId(appEventMessage.getId() + item.getClDid().toString()); diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java index 3fca3f6..842ad6d 100644 --- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java +++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java @@ -46,8 +46,6 @@ public class AppAutoDataConsumer extends EnhanceConsumerMessageHandler