Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码优化

Browse Source
This commit is contained in:
xy
2025-01-09 14:37:28 +08:00
parent f0a22192fb
commit 2ec0024d0f
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDeviceServiceImpl.java
View File

@@ -439,21 +439,21 @@ public class CsDeviceServiceImpl implements ICsDeviceService {
csDevModelRelationAddParm.setDid(modelList.get(0).getDid());
csDevModelRelationService.addDevModelRelation(csDevModelRelationAddParm);
//5.发起自动接入请求
Thread.sleep(2000);
Thread.sleep(5000);
devAccessAskTemplate(nDid,version,1);
//6.修改流程,便携式设备接入成功即为实际环境
csEquipmentDeliveryService.updateProcessBynDid(nDid,4);
//7.存储日志
csLogsFeignClient.addUserLog(logDto);
//8.存储设备调试日志表
CsEquipmentProcessPO csEquipmentProcess = new CsEquipmentProcessPO();
csEquipmentProcess.setDevId(nDid);
csEquipmentProcess.setOperator(RequestUtil.getUserIndex());
csEquipmentProcess.setStartTime(LocalDateTime.now());
csEquipmentProcess.setEndTime(LocalDateTime.now());
csEquipmentProcess.setProcess(4);
csEquipmentProcess.setStatus(1);
processFeignClient.add(csEquipmentProcess);
//CsEquipmentProcessPO csEquipmentProcess = new CsEquipmentProcessPO();
//csEquipmentProcess.setDevId(nDid);
//csEquipmentProcess.setOperator(RequestUtil.getUserIndex());
//csEquipmentProcess.setStartTime(LocalDateTime.now());
//csEquipmentProcess.setEndTime(LocalDateTime.now());
//csEquipmentProcess.setProcess(4);
//csEquipmentProcess.setStatus(1);
//processFeignClient.add(csEquipmentProcess);
//9.删除redis监测点模板信息
redisUtil.delete(AppRedisKey.MODEL + nDid);
redisUtil.delete(AppRedisKey.LINE + nDid);

2
iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
View File

@@ -59,7 +59,7 @@ public class AppAutoDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDa
rtFeignClient.analysis(appAutoDataMessage);
break;
case 2:
log.info(appAutoDataMessage.getKey() + "分发至统计数据");
log.info("{}分发至统计数据", appAutoDataMessage.getKey());
statFeignClient.analysis(appAutoDataMessage);
break;
default: