回复消息 bug修改

src/main/java/com/cn/esermis/dpld/business/MonitorBusiness.java

@@ -345,7 +345,7 @@ public class MonitorBusiness {
                 }
             }
         } catch (Exception e) {
-//            throw new RuntimeException(e);
+            throw new RuntimeException(e);
 //            log.error("插入数据库异常："+e);
         }
     }

src/main/java/com/cn/esermis/utils/HJ212MsgUtils.java

@@ -5,9 +5,8 @@ import com.cn.esermis.coding.PollutionGas;
 import com.cn.esermis.constant.Constant;
 import lombok.extern.slf4j.Slf4j;
 
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * @author DaHuaJia
@@ -103,7 +102,23 @@ public class HJ212MsgUtils {
                     cp.add(jsonObject);
                 }
             }
-            data.put("CP", cp);
+            // 处理有相同因子 值不同的数据
+            Set<JSONObject> cpNew = new HashSet<>();
+            for (JSONObject jsonObject : cp) {
+                JSONObject cpd = new JSONObject();
+                List<JSONObject> collect = cp.stream().filter(d -> d.getString("factor").equals(jsonObject.getString("factor"))).collect(Collectors.toList());
+//                System.out.println(collect);
+                for (JSONObject object : collect) {
+                    cpd.putAll(object);
+                }
+                cpNew.add(cpd);
+            }
+
+
+
+            data.put("CP", cpNew);
+
+
             // 保存消息尾数据，主要是CRC校验和包结束符
             data.put("End", subMsg[2]);