From 0f5aea119cec6b6dda0457cdc2aea59e4d20ac92 Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期三, 23 四月 2025 13:33:05 +0800
Subject: [PATCH] 批量插入
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java | 17 ++++++++++++-----
ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java | 2 +-
ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java | 2 +-
ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java | 4 ++--
ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceDeviationServiceImpl.java | 4 ++--
ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceDeviationService.java | 2 +-
ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java | 4 ++--
7 files changed, 21 insertions(+), 14 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java
index 731d453..82054f9 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingAnalyIndService.java
@@ -14,5 +14,5 @@
List<CokingAnalyIndEntity> list(Map<String, Object> params);
- void save(CokingAnalyIndEntity analyIndEntity);
+ void save(List<CokingAnalyIndEntity> entityList);
}
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceDeviationService.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceDeviationService.java
index 179c843..d71ae54 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceDeviationService.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceDeviationService.java
@@ -15,5 +15,5 @@
public interface CokingTraceDeviationService {
List<CokingTraceDeviationEntity> list(Map<String, Object> params);
- void save(CokingTraceDeviationEntity deviationEntity);
+ void save(List<CokingTraceDeviationEntity> entityList);
}
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java
index d8f5b77..e27c72b 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/CokingTraceIndService.java
@@ -14,5 +14,5 @@
List<CokingTraceIndEntity> list(Map<String, Object> params);
- void save(CokingTraceIndEntity cokingTraceIndEntity);
+ void save(List<CokingTraceIndEntity> entityList);
}
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java
index 3aa3f6a..31bca99 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingAnalyIndServiceImpl.java
@@ -31,7 +31,7 @@
}
@Override
- public void save(CokingAnalyIndEntity analyIndEntity) {
- cokingAnalyIndDao.insert(analyIndEntity);
+ public void save(List<CokingAnalyIndEntity> entityList) {
+ cokingAnalyIndDao.insert(entityList);
}
}
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceDeviationServiceImpl.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceDeviationServiceImpl.java
index d4f6f27..3e7ecf0 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceDeviationServiceImpl.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceDeviationServiceImpl.java
@@ -35,7 +35,7 @@
}
@Override
- public void save(CokingTraceDeviationEntity deviationEntity) {
- cokingTraceDeviationDao.insert(deviationEntity);
+ public void save(List<CokingTraceDeviationEntity> entityList) {
+ cokingTraceDeviationDao.insert(entityList);
}
}
\ No newline at end of file
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java
index 1e58708..e46c477 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/coking/service/impl/CokingTraceIndServiceImpl.java
@@ -31,7 +31,7 @@
}
@Override
- public void save(CokingTraceIndEntity cokingTraceIndEntity) {
- cokingTraceIndDao.insert(cokingTraceIndEntity);
+ public void save(List<CokingTraceIndEntity> entityList) {
+ cokingTraceIndDao.insert(entityList);
}
}
\ No newline at end of file
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