xzzn/sipaiis_datacollector
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

场外点位（定制化）

Browse Source
This commit is contained in:
Timer
2026-03-07 23:43:49 +08:00
parent 2f46cb817e
commit ba387a493b
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java
View File

@ -149,11 +149,15 @@ public class MqttServiceImpl implements MqttService {
// 处理ES数据 // 处理ES数据
MPointES esPoint = buildEsPoint(mPoint, value, date); MPointES esPoint = buildEsPoint(mPoint, value, date);
redisList.add(esPoint); redisList.add(esPoint);
String tableName = "tb_mp_" + key;
if ("SSLL".equals(key) || "LJLL".equals(key)) {
// 场外点位（定制化）
tableName = "tb_mp_" + device + "_" + key;
}
MPointHistory mPointHistory = new MPointHistory(); MPointHistory mPointHistory = new MPointHistory();
mPointHistory.setMeasuredt(date); mPointHistory.setMeasuredt(date);
mPointHistory.setParmvalue(value); mPointHistory.setParmvalue(value);
mPointHistory.setTbName("tb_mp_" + device + "_" + key); mPointHistory.setTbName(tableName);
mPointHistory.setUserid(deviceName); mPointHistory.setUserid(deviceName);
mPointHistory.setInsdt(new Date()); mPointHistory.setInsdt(new Date());
insertInsert(mPointHistory); insertInsert(mPointHistory);