Browse Source

refactor(environment-hj212-service): 重构 PsMonitorSz 实体类并优化数据处理逻辑- 重命名 PsMonitorSz 类中的字段以提高可读性和一致性
- 移除未使用的字段 reporUnit 和 reportDate
- 将 cn 和 st 字段类型从 Double 改为 String,以适应更多数据类型
- 新增 dataTag 字段用于存储数据标记信息
- 更新 PsMonitorSzServiceImpl 中的数据处理逻辑,以适应新的字段结构

林仔 1 year ago
parent
commit
3aebee1887

+ 8 - 13
environment-hj212-service/src/main/java/com/zksy/environmentHJ212/domain/po/PsMonitorSz.java

@@ -56,23 +56,13 @@ public class PsMonitorSz extends Model<PsMonitorSz> {
     /**
      * 数据标记
      */
-    private String flag;
+    private String dataTag;
 
     /**
      * 数据获取时间
      */
     private LocalDateTime recordTime;
 
-    /**
-     * 填报单位
-     */
-    private String reporUnit;
-
-    /**
-     * 填报日期
-     */
-    private LocalDateTime reportDate;
-
     /**
      * 备注
      */
@@ -81,18 +71,23 @@ public class PsMonitorSz extends Model<PsMonitorSz> {
     /**
      * 命令编码
      */
-    private Double cn;
+    private String cn;
 
     /**
      * 系统编码
      */
-    private Double st;
+    private String st;
 
     /**
      * 设备唯一标志
      */
     private String mn;
 
+    /**
+     * 拆分包及应答标志
+     */
+    private String flag;
+
     /**
      * 发送数据的IP
      */

+ 7 - 1
environment-hj212-service/src/main/java/com/zksy/environmentHJ212/service/impl/PsMonitorSzServiceImpl.java

@@ -67,7 +67,7 @@ public class PsMonitorSzServiceImpl extends ServiceImpl<PsMonitorSzMapper, PsMon
                             psMonitorSz.setRealTime(new BigDecimal(split1[1]));
                         }
                         if (parameters.startsWith(substring + "-Flag=")) {
-                            psMonitorSz.setFlag(split1[1]);
+                            psMonitorSz.setDataTag(split1[1]);
                         }
                         psMonitorSz.setRecordTime(LocalDateTime.now());
                         psMonitorSz.setId(UUID.randomUUID().toString().replace("-", ""));
@@ -91,6 +91,12 @@ public class PsMonitorSzServiceImpl extends ServiceImpl<PsMonitorSzMapper, PsMon
                             if (paraname.equals("Flag")) {
                                 psMonitorSz.setFlag(value);
                             }
+                            if (paraname.equals("CN")) {
+                                psMonitorSz.setCn(value);
+                            }
+                            if (paraname.equals("ST")) {
+                                psMonitorSz.setSt(value);
+                            }
                         }
                     }
                     psMonitorSz.setIpport(ipPort);