From 93052fb8b5680f2b40e1fc649b987f2428a33f2c Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期四, 24 四月 2025 16:31:17 +0800 Subject: [PATCH] 备煤工序异常溯源定时修改 --- ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java | 214 +++++++++++++++++++++++++++++++---------------------- 1 files changed, 125 insertions(+), 89 deletions(-) diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java index 3472167..a45f2c6 100644 --- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java +++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelBMTask.java @@ -32,7 +32,7 @@ * @createTime 2025年04月22日 */ @Component("runCokingTraceModelBMTask") -public class RunCokingTraceModelBMTask implements ITask{ +public class RunCokingTraceModelBMTask implements ITask { private Logger logger = LoggerFactory.getLogger(getClass()); @Autowired @@ -65,6 +65,14 @@ @Autowired private IndItemApi indItemApi; + private final static String process = "备煤工序"; + + private final static String reportName = "备煤工序异常溯源"; + + private final static String SugObj = "BM"; + + private final static String indType = "备煤工序异常溯源"; + private static final HashMap<String, Object> coalColoumMap = new HashMap<String, Object>() {{ put("coalColoum0", "一级指标-偏差值"); put("coalColoum1", "二级指标-偏差值"); @@ -72,10 +80,10 @@ }}; private static final HashMap<String, Object> historyPointMap = new HashMap<String, Object>() {{ - put("BMSY001", "备煤耗电"); + put("F0000101008", "备煤耗电"); }}; - private static final String jsonStr="{\n" + + private static final String jsonStr = "{\n" + " \"result\": {\n" + " \"coalPrepElec\":[1600.8,1613.5], \n" + " \"coalPrepElecIndex\":[[0.8,0.73],[723,608],[1782,1782],[752,743],[729,783]],\n" + @@ -98,46 +106,65 @@ Calendar calendar = Calendar.getInstance(); calendar.set(Calendar.MILLISECOND, 0); calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MINUTE,0); - calendar.add(Calendar.DAY_OF_YEAR, -1); - String yesterday = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY); + calendar.set(Calendar.MINUTE, 0); int hour = calendar.get(Calendar.HOUR_OF_DAY); Date startDate = calendar.getTime(); - calendar.add(Calendar.HOUR, 8); Date endDate = calendar.getTime(); String clock = ""; String analyClass = ""; - if (hour == 0) { - clock = yesterday.concat("-").concat("A"); + if (hour >= 8 && hour < 16) { + calendar.set(Calendar.HOUR_OF_DAY, 0); + startDate = calendar.getTime(); + calendar.add(Calendar.HOUR_OF_DAY, 8); + endDate = calendar.getTime(); + clock = DateUtils.format(startDate).concat("-").concat("A"); analyClass = "甲班"; - } else if (hour == 8) { - clock = yesterday.concat("-").concat("B"); + } else if (hour >= 16 && hour < 24) { + calendar.set(Calendar.HOUR_OF_DAY, 8); + startDate = calendar.getTime(); + calendar.add(Calendar.HOUR_OF_DAY, 8); + endDate = calendar.getTime(); + clock = DateUtils.format(startDate).concat("-").concat("B"); analyClass = "乙班"; - } else if (hour == 16) { - clock = yesterday.concat("-").concat("C"); + } else if (hour >= 0 && hour < 8) { + calendar.add(Calendar.DAY_OF_YEAR, -1); + calendar.set(Calendar.HOUR_OF_DAY, 16); + startDate = calendar.getTime(); + calendar.add(Calendar.HOUR_OF_DAY, 8); + endDate = calendar.getTime(); + clock = DateUtils.format(startDate).concat("-").concat("B"); analyClass = "丙班"; } - Map<String, Object> tMap = new HashMap<>(); - tMap.put("relId", UUID.randomUUID().toString()); - tMap.put("process", "备煤工序"); - tMap.put("reportName", "备煤工序"); - tMap.put("analyDate", yesterday); - tMap.put("analyClass", analyClass); - tMap.put("clock", clock); - tMap.put("analyContent", "备煤耗电异常"); - tMap.put("startDate", startDate); - tMap.put("endDate", endDate); - JSONObject jsonObject= JSONObject.parseObject(jsonStr); + // 调用模型 + JSONObject jsonObject = JSONObject.parseObject(jsonStr); JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result")); - if(!Objects.isNull(result)){ - saveTraceReport(tMap,result); - saveTraceSuggest(tMap,result); - saveTraceDeviation(tMap,result); - saveAnalyInd(tMap,result); - saveTraceInd(tMap,result); - saveTraceChart(tMap,result,startDate,endDate); + + if (Objects.isNull(result)) { + logger.info("模型结果为空"); + return; } + + // 保存报告 + String analyDate = DateUtils.format(startDate); + String analyContent = result.getString("coalIndexInfo"); + String relId = cokingTraceReportService.save(process, reportName, analyDate, analyClass, clock, analyContent); + + // 保存一级分析指标 + this.saveAnalyInd(relId, process, analyDate, analyClass, analyContent); + + // 保存优化建议 + this.saveTraceSuggest(relId, process, clock, result); + + // 保存偏差值 + this.saveTraceDeviation(relId, process, clock, result); + + // 保存溯源指标 + this.saveTraceInd(relId, result); + + // 保存溯源折线图 + this.saveTraceChart(relId, clock, startDate, endDate); + } catch (Exception ex) { logger.error("RunCokingTraceModelBMTask运行异常"); ex.printStackTrace(); @@ -145,80 +172,77 @@ logger.info("RunCokingTraceModelBMTask运行完成"); } - public void saveTraceReport(Map<String, Object> tMap,JSONObject result) { - CokingTraceReportEntity reportEntity = new CokingTraceReportEntity(); - reportEntity.setId(tMap.get("relId").toString()); - reportEntity.setProcess(tMap.get("process").toString()); - reportEntity.setReportName(tMap.get("reportName").toString()); - reportEntity.setAnalyDate(tMap.get("analyDate").toString()); - reportEntity.setAnalyClass(tMap.get("analyClass").toString()); - reportEntity.setClock(tMap.get("clock").toString()); - reportEntity.setAnalyContent(tMap.get("analyContent").toString()); - reportEntity.setCreateDate(new Date()); - cokingTraceReportService.save(reportEntity); - } - public void saveTraceSuggest(Map<String, Object> tMap,JSONObject result) { - String coalTotal = result.get("coalPrepElecTotal1").toString(); - if(StringUtils.isNotBlank(coalTotal)){ - CokingTraceSuggestEntity suggestEntity = new CokingTraceSuggestEntity(); - suggestEntity.setRelId(tMap.get("relId").toString()); - suggestEntity.setProcess(tMap.get("process").toString()); - suggestEntity.setSugObj("BM"); - suggestEntity.setClock(tMap.get("clock").toString()); - suggestEntity.setContent(coalTotal); - suggestEntity.setCreateDate(new Date()); - cokingTraceSuggestService.save(suggestEntity); - } + public void saveTraceSuggest(String relId, String process, String clock, JSONObject result) { + String coalTotal = result.get("coalPrepElecTotal1").toString(); + if (StringUtils.isBlank(coalTotal)) { + logger.info("coalPrepElecTotal1 is null"); + } + CokingTraceSuggestEntity suggestEntity = new CokingTraceSuggestEntity(); + suggestEntity.setRelId(relId); + suggestEntity.setProcess(process); + suggestEntity.setSugObj(SugObj); + suggestEntity.setClock(clock); + suggestEntity.setContent(coalTotal); + suggestEntity.setCreateDate(new Date()); + cokingTraceSuggestService.save(suggestEntity); } @Transactional - public void saveTraceDeviation(Map<String, Object> tMap,JSONObject result) { + public void saveTraceDeviation(String relId, String process, String clock, JSONObject result) { List<ChartParamDTO> list = mcsApi.getChartParamList(CommonConstant.COAL_INDEX_CHARTCODE); Map<String, String> steamIndexMaps = list.stream().collect(Collectors.toMap(ChartParamDTO::getParamCode, e -> e.getParamName())); - for(int i=0;i<=2;i++){ - String coalColoum = result.get("coalColoum"+i).toString(); - if(StringUtils.isNotBlank(coalColoum)){ + for (int i = 0; i <= 2; i++) { + 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(); - deviationEntity.setRelId(tMap.get("relId").toString()); - deviationEntity.setProcess(tMap.get("process").toString()); - deviationEntity.setClock(tMap.get("clock").toString()); - deviationEntity.setSugObj("BM"); - deviationEntity.setGroupName(coalColoumMap.get("coalColoum"+i).toString()); + deviationEntity.setRelId(relId); + deviationEntity.setProcess(process); + deviationEntity.setClock(clock); + deviationEntity.setSugObj(SugObj); + deviationEntity.setGroupName(coalColoumMap.get("coalColoum" + i).toString()); 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(";"); - for(int i=0;i<analyContent.length;i++){ - CokingAnalyIndEntity analyIndEntity = new CokingAnalyIndEntity(); - analyIndEntity.setRelId(tMap.get("relId").toString()); - analyIndEntity.setAnalyType(tMap.get("process").toString()); - analyIndEntity.setAnalyDate(tMap.get("analyDate").toString()); - analyIndEntity.setAnalyClass(tMap.get("analyClass").toString()); - analyIndEntity.setAnalyContent(analyContent[i]); - analyIndEntity.setSort(i+1); - cokingAnalyIndService.save(analyIndEntity); + public void saveAnalyInd(String relId, String process, String analyDate, String analyClass, String analyContent) { + if (StringUtils.isBlank(analyContent)) { + logger.info("analyContent is null"); } + String[] analyContentArr = analyContent.split(";"); + List<CokingAnalyIndEntity> entityList = new ArrayList<>(); + for (int i = 0; i < analyContentArr.length; i++) { + CokingAnalyIndEntity analyIndEntity = new CokingAnalyIndEntity(); + analyIndEntity.setRelId(relId); + analyIndEntity.setAnalyType(process); + analyIndEntity.setAnalyDate(analyDate); + analyIndEntity.setAnalyClass(analyClass); + analyIndEntity.setAnalyContent(analyContentArr[i]); + analyIndEntity.setSort(i + 1); + entityList.add(analyIndEntity); + } + cokingAnalyIndService.save(entityList); } - public void saveTraceInd(Map<String, Object> tMap,JSONObject result) { - Map<String,Object> map = new HashMap<>(); - map.put("indType","备煤工序异常溯源"); + public void saveTraceInd(String relId, JSONObject result) { + Map<String, Object> map = new HashMap<>(); + map.put("indType", indType); List<CokingTraceConfEntity> list = cokingTraceConfService.list(map); if (CollectionUtils.isEmpty(list)) { 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"); @@ -246,29 +270,41 @@ break; } CokingTraceIndEntity cokingTraceIndEntity = new CokingTraceIndEntity(); - cokingTraceIndEntity.setRelId(tMap.get("relId").toString()); + cokingTraceIndEntity.setRelId(relId); cokingTraceIndEntity.setTitle(conf.getIndType()); - cokingTraceIndEntity.setClock(tMap.get("clock").toString()); + cokingTraceIndEntity.setClock(relId); cokingTraceIndEntity.setIndCode(conf.getIndCode()); 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) { - historyPointMap.forEach((key,value) ->{ + public void saveTraceChart(String relId, String clock, Date startDate, Date endDate) { + // 查询需要保存chart的配置 + Map<String, Object> map = new HashMap<>(); + map.put("indType", indType); + map.put("ext1", "chart"); + List<CokingTraceConfEntity> list = cokingTraceConfService.list(map); + if (CollectionUtils.isEmpty(list)) { + logger.info("TraceChartConfLis is Empty"); + } + + List<CokingTraceChartEntity> entityList = new ArrayList<>(); + list.forEach(value -> { CokingTraceChartEntity cokingTraceChartEntity = new CokingTraceChartEntity(); - cokingTraceChartEntity.setRelId(tMap.get("relId").toString()); + cokingTraceChartEntity.setRelId(relId); cokingTraceChartEntity.setName(value.toString()); - cokingTraceChartEntity.setClock(tMap.get("clock").toString()); - cokingTraceChartEntity.setDataNo(key); - cokingTraceChartEntity.setDataType("DATAPOINT"); + cokingTraceChartEntity.setClock(clock); + cokingTraceChartEntity.setDataType(value.getDataType()); + cokingTraceChartEntity.setDataNo(value.getPointNo()); cokingTraceChartEntity.setStartTime(startDate); cokingTraceChartEntity.setEndTime(endDate); cokingTraceChartEntity.setCreateDate(new Date()); - cokingTraceChartService.save(cokingTraceChartEntity); + entityList.add(cokingTraceChartEntity); }); + cokingTraceChartService.insert(entityList); } } \ No newline at end of file -- Gitblit v1.9.3