From 843ad1df68939a637c02c79965d74c4b723e42b7 Mon Sep 17 00:00:00 2001 From: dongyukun <1208714201@qq.com> Date: 星期三, 23 四月 2025 14:11:39 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java | 22 +++++++++++++++------- 1 files changed, 15 insertions(+), 7 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..5d4cac4 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 @@ -160,6 +160,7 @@ } public void saveTraceSuggest(Map<String, Object> tMap,JSONObject result) { + List<CokingTraceSuggestEntity> entityList = new ArrayList<>(); for(int i=1;i<=2;i++){ String steamTotal = result.get("steamTotal"+i).toString(); if(StringUtils.isNotBlank(steamTotal)){ @@ -170,9 +171,10 @@ suggestEntity.setClock(tMap.get("clock").toString()); suggestEntity.setContent(steamTotal); suggestEntity.setCreateDate(new Date()); - cokingTraceSuggestService.save(suggestEntity); + entityList.add(suggestEntity); } } + cokingTraceSuggestService.insert(entityList); } public void saveTraceDeviation(Map<String, Object> tMap,JSONObject result) { @@ -182,6 +184,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,15 +196,16 @@ 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); } } for(int i=0;i<=5;i++){ 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,8 +217,9 @@ 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 +227,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,8 +236,9 @@ analyIndEntity.setAnalyClass(tMap.get("analyClass").toString()); analyIndEntity.setAnalyContent(analyContent[i]); analyIndEntity.setSort(i+1); - cokingAnalyIndService.save(analyIndEntity); + entityList.add(analyIndEntity); } + cokingAnalyIndService.save(entityList); } public void saveTraceInd(Map<String, Object> tMap,JSONObject result) { @@ -242,6 +249,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,8 +285,8 @@ cokingTraceIndEntity.setIndName(conf.getIndName()); cokingTraceIndEntity.setIndValue(value); cokingTraceIndEntity.setIndUnit(conf.getIndUnit()); - cokingTraceIndService.save(cokingTraceIndEntity); - + entityList.add(cokingTraceIndEntity); } + cokingTraceIndService.save(entityList); } } \ No newline at end of file -- Gitblit v1.9.3