数据分次提交改成一次性提交

ems-admin/src/main/java/com/xzzn/web/controller/ems/MqttMessageController.java

@@ -89,7 +89,7 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
         System.out.println("[DEVICE] data: " + payload);
         try {
             // 业务处理逻辑
-//            handleFxData(payload);
+            handleFxData(payload);
 
             EmsMqttMessage mqttMessage = new EmsMqttMessage();
             mqttMessage.setMqttTopic(topic);
@@ -148,7 +148,7 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
                 log.info("BMS data:"+ jsonData);
 
                 Map<String, Map<String, Object>> records = processData(JSON.parseObject(jsonData, new TypeReference<Map<String, Object>>() {}));
-
+                List<EmsBatteryData> list = new ArrayList<>();
                 //单体电池
                 for (Map.Entry<String, Map<String, Object>> record : records.entrySet()) {
                     String recordId = record.getKey();
@@ -172,8 +172,10 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
                     data.setSiteId(("021"));
                     data.setClusterDeviceId(("021"));
 
-
+                    list.add(data);
-                    emsBatteryDataService.insertEmsBatteryData(data);
+                }
+                if (list.size() > 0 ) {
+                    emsBatteryDataService.insertEmsBatteryDataList(list);
                 }
             } else if (deviceId.contains("PCS")) {
                 log.info("====================");

ems-system/src/main/java/com/xzzn/ems/mapper/EmsBatteryDataMapper.java

@@ -86,4 +86,7 @@ public interface EmsBatteryDataMapper
      * @return
      */
     public List<Map<String, Object>> getDataIdsMap(BatteryClusterDataDetailVo dataVo);
+
+
+    int insertEmsBatteryDataList(List<EmsBatteryData> emsBatteryDataList);
 }

ems-system/src/main/java/com/xzzn/ems/service/IEmsBatteryDataService.java

@@ -59,4 +59,13 @@ public interface IEmsBatteryDataService
      * @return 结果
      */
     public int deleteEmsBatteryDataById(Long id);
+
+    /**
+     * 新增单体电池实时数据
+     *
+     * @param emsBatteryDataList 单体电池实时数据
+     * @return 结果
+     */
+    public int insertEmsBatteryDataList(List<EmsBatteryData> emsBatteryDataList);
+
 }

ems-system/src/main/java/com/xzzn/ems/service/impl/EmsBatteryDataServiceImpl.java

@@ -93,4 +93,12 @@ public class EmsBatteryDataServiceImpl implements IEmsBatteryDataService
     {
         return emsBatteryDataMapper.deleteEmsBatteryDataById(id);
     }
+
+    @Override
+    public int insertEmsBatteryDataList(List<EmsBatteryData> emsBatteryDataList) {
+        for (EmsBatteryData data : emsBatteryDataList) {
+            data.setCreateTime(DateUtils.getNowDate());
+        }
+        return emsBatteryDataMapper.insertEmsBatteryDataList(emsBatteryDataList);
+    }
 }

ems-system/src/main/resources/mapper/ems/EmsBatteryDataMapper.xml

@@ -176,4 +176,21 @@
         </if>
         SELECT NULL AS type, NULL AS device_id FROM DUAL WHERE 1=0
     </select>
+
+    <insert id="insertEmsBatteryDataList" parameterType="java.util.List">
+        INSERT INTO ems_battery_data (
+        battery_pack, battery_cluster, battery_cell_id,
+        voltage, temperature, soc, soh, data_timestamp,
+        create_by, create_time, update_by, update_time,
+        remark, site_id, device_id, cluster_device_id
+        ) VALUES
+        <foreach collection="list" item="item" separator=",">
+            (
+            #{item.batteryPack}, #{item.batteryCluster}, #{item.batteryCellId},
+            #{item.voltage}, #{item.temperature}, #{item.soc}, #{item.soh}, #{item.dataTimestamp},
+            #{item.createBy}, #{item.createTime}, #{item.updateBy}, #{item.updateTime},
+            #{item.remark}, #{item.siteId}, #{item.deviceId}, #{item.clusterDeviceId}
+            )
+        </foreach>
+    </insert>
 </mapper>