From 80d5a608f4543a68a30bab5842d9f793702d6b53 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期三, 23 四月 2025 13:36:47 +0800
Subject: [PATCH] 焦化 异常数据建议生成
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java | 17 ++++++++++++-----
1 files changed, 12 insertions(+), 5 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java
index 74fadb1..3b62568 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java
@@ -182,6 +182,7 @@
String steamFirstColoum = result.get("steamFirstColoum"+i).toString();
if(StringUtils.isNotBlank(steamFirstColoum)){
JSONArray responseArr = JSON.parseArray(steamFirstColoum);
+ List<CokingTraceDeviationEntity> entityList = new ArrayList<>();
for (int j = 0; j < responseArr.size(); j++) {
JSONArray element = JSON.parseArray(responseArr.get(j).toString());
CokingTraceDeviationEntity deviationEntity = new CokingTraceDeviationEntity();
@@ -193,7 +194,8 @@
deviationEntity.setIndName(steamIndexMaps.get(element.get(0).toString()));
deviationEntity.setIndValue(element.get(1).toString());
deviationEntity.setCreateDate(new Date());
- cokingTraceDeviationService.save(deviationEntity);
+ entityList.add(deviationEntity);
+ cokingTraceDeviationService.save(entityList);
}
}
}
@@ -201,7 +203,7 @@
String steamSecondColoum = result.get("steamSecondColoum"+i).toString();
if(StringUtils.isNotBlank(steamSecondColoum)){
JSONArray responseArr = JSON.parseArray(steamSecondColoum);
-
+ List<CokingTraceDeviationEntity> entityList = new ArrayList<>();
for (int j = 0; j < responseArr.size(); j++) {
JSONArray element = JSON.parseArray(responseArr.get(j).toString());
CokingTraceDeviationEntity deviationEntity = new CokingTraceDeviationEntity();
@@ -213,7 +215,8 @@
deviationEntity.setIndName(steamIndexMaps.get(element.get(0).toString()));
deviationEntity.setIndValue(element.get(1).toString());
deviationEntity.setCreateDate(new Date());
- cokingTraceDeviationService.save(deviationEntity);
+ entityList.add(deviationEntity);
+ cokingTraceDeviationService.save(entityList);
}
}
}
@@ -222,6 +225,7 @@
public void saveAnalyInd(Map<String, Object> tMap,JSONObject result) {
String[] analyContent = tMap.get("analyContent").toString().split(";");
+ List<CokingAnalyIndEntity> entityList = new ArrayList<>();
for(int i=0;i<analyContent.length;i++){
CokingAnalyIndEntity analyIndEntity = new CokingAnalyIndEntity();
analyIndEntity.setRelId(tMap.get("relId").toString());
@@ -230,7 +234,8 @@
analyIndEntity.setAnalyClass(tMap.get("analyClass").toString());
analyIndEntity.setAnalyContent(analyContent[i]);
analyIndEntity.setSort(i+1);
- cokingAnalyIndService.save(analyIndEntity);
+ entityList.add(analyIndEntity);
+ cokingAnalyIndService.save(entityList);
}
}
@@ -242,6 +247,7 @@
logger.info("ConfLis is Empty");
return;
}
+ List<CokingTraceIndEntity> entityList = new ArrayList<>();
for (CokingTraceConfEntity conf : list) {
if (StringUtils.isBlank(conf.getDataType())) {
logger.info("DataType is Empty");
@@ -277,7 +283,8 @@
cokingTraceIndEntity.setIndName(conf.getIndName());
cokingTraceIndEntity.setIndValue(value);
cokingTraceIndEntity.setIndUnit(conf.getIndUnit());
- cokingTraceIndService.save(cokingTraceIndEntity);
+ entityList.add(cokingTraceIndEntity);
+ cokingTraceIndService.save(entityList);
}
}
--
Gitblit v1.9.3