sx/map
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

das接口修改

Browse Source
This commit is contained in:
chenhaojie 2024-08-09 08:53:49 +08:00
parent 9456f07f4c
commit 05b9559e62
3 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
das/src/main/java/com/das/modules/node/service/TDEngineService.java
View File

@ -105,9 +105,11 @@ public class TDEngineService {
sb.setLength(0);
sb.append("insert into ");
for (RTData dv : list) {
sb.append(iotModelCode);
sb.append("d");
sb.append(dv.getDeviceId());
sb.append(" using analog tags (");
sb.append(" using " );
sb.append(iotModelCode);
sb.append(" tags (");
sb.append(dv.getDeviceId());
sb.append(",");
sb.append(1L);
@ -137,9 +139,11 @@ public class TDEngineService {
sb.setLength(0);
sb.append("insert into ");
for (RTData dv : list) {
sb.append(iotModelCode);
sb.append("d");
sb.append(dv.getDeviceId());
sb.append(" using analog tags (");
sb.append(" using " );
sb.append(iotModelCode);
sb.append(" tags (");
sb.append(dv.getDeviceId());
sb.append(",");
sb.append(1L);

12
das/src/main/java/com/das/modules/node/service/impl/DataServiceImpl.java
View File

@ -124,6 +124,13 @@ public class DataServiceImpl implements DataService {
} else {
info.setParams(equipObjectMapper.readTree(info.getParams().toString()));
}
if (("138").equals(info.getType())) {
info.setType("yc");
} else if (("139").equals(info.getType())) {
info.setType("ym");
} else if (("140").equals(info.getType())) {
info.setType("yx");
}
newIotModelFieldList.add(info);
}
}
@ -135,6 +142,11 @@ public class DataServiceImpl implements DataService {
}else {
info.setParams(equipObjectMapper.readTree(info.getParams().toString()));
}
if (("146").equals(info.getType())) {
info.setType("yt");
} else if (("147").equals(info.getType())) {
info.setType("yk");
}
newIotModelServiceList.add(info);
}
}

1
das/src/main/java/com/das/modules/node/service/impl/SysNodeServiceImpl.java
View File

@ -75,6 +75,7 @@ public class SysNodeServiceImpl implements SysNodeService {
@Autowired
private SysIotModelMapper sysIotModelMapper;
@Autowired
TerminalMessageEventHandler terminalMessageEventHandler;
@Override