diff --git a/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java b/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java index a0df572..0baf699 100644 --- a/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java +++ b/src/main/java/com/sipai/service/mqtt/impl/MqttServiceImpl.java @@ -149,11 +149,15 @@ public class MqttServiceImpl implements MqttService { // 处理ES数据 MPointES esPoint = buildEsPoint(mPoint, value, date); 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.setMeasuredt(date); mPointHistory.setParmvalue(value); - mPointHistory.setTbName("tb_mp_" + device + "_" + key); + mPointHistory.setTbName(tableName); mPointHistory.setUserid(deviceName); mPointHistory.setInsdt(new Date()); insertInsert(mPointHistory);