瀏覽代碼

恢复最新状态

lloyd 2 月之前
父節點
當前提交
f3c0a488ed
共有 3 個文件被更改,包括 7 次插入5 次删除
  1. 2 1
      .gitignore
  2. 二進制
      data/gtcvr.db
  3. 5 4
      src/main/java/com/gct/edge/service/excutor/ModbusReadService.java

+ 2 - 1
.gitignore

@@ -12,4 +12,5 @@ target
12 12
 
13 13
 logs
14 14
 !**/nacos/target
15
-data/gtcvr.db
15
+data/gtcvr.db
16
+/data/

二進制
data/gtcvr.db


+ 5 - 4
src/main/java/com/gct/edge/service/excutor/ModbusReadService.java

@@ -65,7 +65,8 @@ public class ModbusReadService {
65 65
                 List<List<Double>> sgt = readBody.card;
66 66
                 Double s = readBody.s;
67 67
                 Double n = readBody.n;
68
-                String prodTime = readBody.prodTime;
68
+                String prodTime = LocalDateTime.now().format(df);
69
+                String checkTime = readBody.prodTime;
69 70
                 if (Objects.isNull(sgt) || Objects.isNull(s) || Objects.isNull(n) ||Objects.isNull(prodTime) || s < 1e-6 || n < 1e-6) {
70 71
                     log.error("read Rtu modbus failed, sgt: {},s: {},n: {},prodTime: {}", sgt, s, n, prodTime);
71 72
                     continue;
@@ -76,12 +77,12 @@ public class ModbusReadService {
76 77
                 if (Objects.isNull(lastDumpRecord)){
77 78
                     lastDumpRecord = new DumpRecord();
78 79
                     lastDumpRecord.setTableName(aoidConfigData.getJh());
79
-                    lastDumpRecord.setDumpTime(prodTime);
80
+                    lastDumpRecord.setDumpTime(checkTime);
80 81
                     dumpRecordService.save(lastDumpRecord);
81 82
                 }else {
82
-                    if (lastDumpRecord.getDumpTime().equals(prodTime))continue;
83
+                    if (lastDumpRecord.getDumpTime().equals(checkTime))continue;
83 84
                     else {
84
-                        lastDumpRecord.setDumpTime(prodTime);
85
+                        lastDumpRecord.setDumpTime(checkTime);
85 86
                         dumpRecordService.update(lastDumpRecord,new QueryWrapper<DumpRecord>().eq("table_name", aoidConfigData.getJh()));
86 87
                     }
87 88
                 }