数据库迁移到质量数据库的ip

iec集成service module

platform-iec/src/main/java/com/ydl/iec/util/MySqlUtil.java

@@ -79,13 +79,15 @@ public class MySqlUtil {
         List<MessageInfo> updateMessage = new ArrayList<>();
         for (int i = 0; i < ruleDetail104.getMeasgLength(); i++) {
             MessageInfo messageInfo = ruleDetail104.getMessages().get(i);
-            log.info("数据点位：" + messageInfo.getMessageAddress());
+
             if (messageInfo.getMessageAddress() >= remote_config_degree_min && messageInfo.getMessageAddress() <= remote_config_degree_max) {
+                log.info("电度点位：" + messageInfo.getMessageAddress());
                 addMessage.add(messageInfo);
             } else if (messageInfo.getMessageAddress() >= remote_config_measure_min && messageInfo.getMessageAddress() <= remote_config_measure_max) {
+                log.info("遥测点位：" + messageInfo.getMessageAddress());
                 updateMessage.add(messageInfo);
             } else {
-                log.info("数据点位不在采集范围内，不处理" + messageInfo.getMessageAddress());
+               // log.info("数据点位不在采集范围内，不处理" + messageInfo.getMessageAddress());
             }
         }
         // 新增电度数据
@@ -117,6 +119,7 @@ public class MySqlUtil {
                         "', update_time='" + DateUtils.dateToString(time, DateUtils.PATTERN_YMD_HMS) +
                         "', info='" + JSON.toJSONString(messageInfo) +
                         "' where position_num = " + messageInfo.getMessageAddress();
+                log.info("updateSql: " + updateSql);
                 stmt.addBatch(updateSql);
             }
             // 获取总条数