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

添加装置信息

Browse Source
This commit is contained in:
xy
2024-07-31 15:35:35 +08:00
parent b67e55a4ac
commit 08c8e4374d
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -229,6 +229,7 @@ public class CsDeviceServiceImpl implements ICsDeviceService {
CsLedgerParam param = new CsLedgerParam();
AppLineTopologyDiagramPO appLineTopologyDiagramPo = new AppLineTopologyDiagramPO();
po.setName(item.getName());
po.setDeviceId(vo.getId());
po.setPosition(item.getPosition());
po.setClDid(0);
if (Objects.equals(DicDataEnum.GRID_SIDE.getCode(),location)){
@@ -529,7 +530,7 @@ public class CsDeviceServiceImpl implements ICsDeviceService {
reqAndResParam.setPri(AccessEnum.FIRST_CHANNEL.getCode());
reqAndResParam.setType(Integer.parseInt(TypeEnum.TYPE_1.getCode()));
reqAndResParam.setExpire(-1);
logger.info("询问主题报文为:" + new Gson().toJson(reqAndResParam));
logger.info("询问主题报文为:{}", new Gson().toJson(reqAndResParam));
publisher.send("/Pfm/DevTopic/"+nDid, new Gson().toJson(reqAndResParam),1,false);
}
@@ -549,7 +550,7 @@ public class CsDeviceServiceImpl implements ICsDeviceService {
accessDto.setNdid(nDid);
accessDto.setDevType(devType);
reqAndResParam.setMsg(accessDto);
logger.info("注册报文为:" + new Gson().toJson(reqAndResParam));
logger.info("注册报文为:{}", new Gson().toJson(reqAndResParam));
publisher.send("/Pfm/DevReg/"+nDid, new Gson().toJson(reqAndResParam),1,false);
}