zhoupeng 2 年之前
父節點
當前提交
fc580d3100

+ 8 - 2
chaunyi_opc/opc_da/src/main/java/com/example/opc_da/task/OpcAsyncTask.java

@@ -296,7 +296,7 @@ public class OpcAsyncTask {
         ReportTable reportTable = reportTableDao.getReportTableById(tableReportId);
         String reportTableData = reportTable.getReportTableData();
         JSONObject jsonObject = JSONObject.parseObject(reportTableData);
-        JSONArray objects = jsonObject.getJSONArray("tables");
+        JSONArray objects = new JSONArray();
         if (Blank.isNotEmpty(itemList)) {
             for (int i = 0; i < itemList.size(); i++) {
                 List<RawData> rawDataList = rawDataDao.getEventRawDataList(itemList.get(i), dataSourceId, sqlCurrentYmdh);
@@ -325,6 +325,9 @@ public class OpcAsyncTask {
                                 dataList.add(JSON.parseObject(rawData1.getDataValue(), BigDecimal.class));
                                 dataTimeList.add(rawData1.getDataValueTime());
                             }
+                            jsonObject1.put("itemGroupId", rawData.getItemGroupId());
+                            jsonObject1.put("itemName", itemList.get(i).getItemName());
+                            jsonObject1.put("describe", itemList.get(i).getDescribe());
                             jsonObject1.put("dataList", dataList);
                             jsonObject1.put("dataTimeList", dataTimeList);
                             objects.set(i, jsonObject1);
@@ -335,6 +338,9 @@ public class OpcAsyncTask {
                                 dataList.add(rawData1.getDataValue());
                                 dataTimeList.add(rawData1.getDataValueTime());
                             }
+                            jsonObject1.put("itemGroupId", rawData.getItemGroupId());
+                            jsonObject1.put("itemName", itemList.get(i).getItemName());
+                            jsonObject1.put("describe", itemList.get(i).getDescribe());
                             jsonObject1.put("dataList", dataList);
                             jsonObject1.put("dataTimeList", dataTimeList);
                             objects.set(i, jsonObject1);
@@ -344,7 +350,7 @@ public class OpcAsyncTask {
                 rawDataDao.delEventRawDataList(itemList.get(i), dataSourceId, sqlCurrentYmdh);
             }
         }
-        jsonObject.put("tables", objects);
+        jsonObject.put("eventTables", objects);
         ReportTable reportTable1 = new ReportTable();
         reportTable1.setTableTemplateId(reportTable.getTableTemplateId());
         reportTable1.setUserId(reportTable.getUserId());

+ 1 - 1
chaunyi_opc/opc_da/src/main/resources/application-dev.yml

@@ -30,4 +30,4 @@ spring:
 mybatis:
   configuration:
     #开启sql日志文件
-    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

+ 8 - 2
chaunyi_opc/opc_ua/src/main/java/com/example/opc_ua/task/OpcAsyncTask.java

@@ -240,7 +240,7 @@ public class OpcAsyncTask {
         ReportTable reportTable = reportTableDao.getReportTableById(tableReportId);
         String reportTableData = reportTable.getReportTableData();
         JSONObject jsonObject = JSONObject.parseObject(reportTableData);
-        JSONArray objects = jsonObject.getJSONArray("tables");
+        JSONArray objects = new JSONArray();
         if (Blank.isNotEmpty(itemList)) {
             for (int i = 0; i < itemList.size(); i++) {
                 List<RawData> rawDataList = rawDataDao.getEventRawDataList(itemList.get(i), dataSourceId, sqlCurrentYmdh);
@@ -269,6 +269,9 @@ public class OpcAsyncTask {
                                 dataList.add(JSON.parseObject(rawData1.getDataValue(), BigDecimal.class));
                                 dataTimeList.add(rawData1.getDataValueTime());
                             }
+                            jsonObject1.put("itemGroupId", rawData.getItemGroupId());
+                            jsonObject1.put("itemName", itemList.get(i).getItemName());
+                            jsonObject1.put("describe", itemList.get(i).getDescribe());
                             jsonObject1.put("dataList", dataList);
                             jsonObject1.put("dataTimeList", dataTimeList);
                             objects.set(i, jsonObject1);
@@ -279,6 +282,9 @@ public class OpcAsyncTask {
                                 dataList.add(rawData1.getDataValue());
                                 dataTimeList.add(rawData1.getDataValueTime());
                             }
+                            jsonObject1.put("itemGroupId", rawData.getItemGroupId());
+                            jsonObject1.put("itemName", itemList.get(i).getItemName());
+                            jsonObject1.put("describe", itemList.get(i).getDescribe());
                             jsonObject1.put("dataList", dataList);
                             jsonObject1.put("dataTimeList", dataTimeList);
                             objects.set(i, jsonObject1);
@@ -288,7 +294,7 @@ public class OpcAsyncTask {
                 rawDataDao.delEventRawDataList(itemList.get(i), dataSourceId, sqlCurrentYmdh);
             }
         }
-        jsonObject.put("tables", objects);
+        jsonObject.put("eventTables", objects);
         ReportTable reportTable1 = new ReportTable();
         reportTable1.setTableTemplateId(reportTable.getTableTemplateId());
         reportTable1.setUserId(reportTable.getUserId());