From bd0f24fb70621ea26dc6fd4c41b391620ab583dd Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期四, 24 四月 2025 15:02:27 +0800 Subject: [PATCH] 焦化溯源时间修改 --- ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java | 40 ++++++++++++++++++++++++++++------------ 1 files changed, 28 insertions(+), 12 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 5d4cac4..70664be 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 @@ -18,7 +18,6 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import java.util.*; @@ -106,25 +105,42 @@ logger.info("RunCokingTraceModelGXJTask,参数为:{}", params); try { Calendar calendar = Calendar.getInstance(); + calendar.set(Calendar.MILLISECOND, 0); + calendar.set(Calendar.SECOND, 0); + calendar.set(Calendar.MINUTE, 0); int hour = calendar.get(Calendar.HOUR_OF_DAY); - String yesterday = DateUtils.format(DateUtils.addDateDays(new Date(), -1), DateUtils.FORMAT_YEAR_MONTH_DAY); + Date startDate = calendar.getTime(); + 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("analyDate", DateUtils.format(startDate)); tMap.put("analyClass", analyClass); tMap.put("clock", clock); tMap.put("analyContent", "干熄焦产蒸汽量异常"); @@ -167,7 +183,7 @@ CokingTraceSuggestEntity suggestEntity = new CokingTraceSuggestEntity(); suggestEntity.setRelId(tMap.get("relId").toString()); suggestEntity.setProcess(tMap.get("process").toString()); - suggestEntity.setSugObj("GXJ"); + suggestEntity.setSugObj(i+"#"); suggestEntity.setClock(tMap.get("clock").toString()); suggestEntity.setContent(steamTotal); suggestEntity.setCreateDate(new Date()); @@ -191,7 +207,7 @@ deviationEntity.setRelId(tMap.get("relId").toString()); deviationEntity.setProcess(tMap.get("process").toString()); deviationEntity.setClock(tMap.get("clock").toString()); - deviationEntity.setSugObj("GXJ"); + deviationEntity.setSugObj("1#"); deviationEntity.setGroupName(steamFirstColoumMap.get("steamFirstColoum"+i).toString()); deviationEntity.setIndName(steamIndexMaps.get(element.get(0).toString())); deviationEntity.setIndValue(element.get(1).toString()); @@ -212,7 +228,7 @@ deviationEntity.setRelId(tMap.get("relId").toString()); deviationEntity.setProcess(tMap.get("process").toString()); deviationEntity.setClock(tMap.get("clock").toString()); - deviationEntity.setSugObj("GXJ"); + deviationEntity.setSugObj("2#"); deviationEntity.setGroupName(steamSecondColoumMap.get("steamSecondColoum" + i).toString()); deviationEntity.setIndName(steamIndexMaps.get(element.get(0).toString())); deviationEntity.setIndValue(element.get(1).toString()); -- Gitblit v1.9.3