ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java
@@ -180,6 +180,7 @@ String coalColoum = result.get("coalColoum"+i).toString(); if(StringUtils.isNotBlank(coalColoum)){ JSONArray responseArr = JSON.parseArray(coalColoum); 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(); @@ -191,14 +192,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); } } } 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()); @@ -207,8 +210,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) { @@ -219,6 +223,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"); @@ -253,11 +258,13 @@ cokingTraceIndEntity.setIndName(conf.getIndName()); cokingTraceIndEntity.setIndValue(value); cokingTraceIndEntity.setIndUnit(conf.getIndUnit()); cokingTraceIndService.save(cokingTraceIndEntity); entityList.add(cokingTraceIndEntity); } cokingTraceIndService.save(entityList); } public void saveTraceChart(Map<String, Object> tMap, JSONObject result,Date startDate,Date endDate) { List<CokingTraceChartEntity> entityList = new ArrayList<>(); historyPointMap.forEach((key,value) ->{ CokingTraceChartEntity cokingTraceChartEntity = new CokingTraceChartEntity(); cokingTraceChartEntity.setRelId(tMap.get("relId").toString()); @@ -268,7 +275,8 @@ cokingTraceChartEntity.setStartTime(startDate); cokingTraceChartEntity.setEndTime(endDate); cokingTraceChartEntity.setCreateDate(new Date()); cokingTraceChartService.save(cokingTraceChartEntity); entityList.add(cokingTraceChartEntity); }); cokingTraceChartService.insert(entityList); } } ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelLJTask.java
@@ -186,6 +186,7 @@ String cokeColoum = result.get("cokeColoum"+i).toString(); if(StringUtils.isNotBlank(cokeColoum)){ JSONArray responseArr = JSON.parseArray(cokeColoum); 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(); @@ -197,14 +198,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); } } } 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()); @@ -213,8 +216,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) { @@ -225,6 +229,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"); @@ -259,11 +264,13 @@ cokingTraceIndEntity.setIndName(conf.getIndName()); cokingTraceIndEntity.setIndValue(value); cokingTraceIndEntity.setIndUnit(conf.getIndUnit()); cokingTraceIndService.save(cokingTraceIndEntity); entityList.add(cokingTraceIndEntity); } cokingTraceIndService.save(entityList); } public void saveTraceChart(Map<String, Object> tMap, JSONObject result,Date startDate,Date endDate) { List<CokingTraceChartEntity> entityList = new ArrayList<>(); historyPointMap.forEach((key,value) ->{ CokingTraceChartEntity cokingTraceChartEntity = new CokingTraceChartEntity(); cokingTraceChartEntity.setRelId(tMap.get("relId").toString()); @@ -274,7 +281,8 @@ cokingTraceChartEntity.setStartTime(startDate); cokingTraceChartEntity.setEndTime(endDate); cokingTraceChartEntity.setCreateDate(new Date()); cokingTraceChartService.save(cokingTraceChartEntity); entityList.add(cokingTraceChartEntity); }); cokingTraceChartService.insert(entityList); } }
