From 596bc41976f6c7ab2f5d49bd9bcd3a0c0b4e5469 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 06 五月 2025 17:26:21 +0800
Subject: [PATCH] limitH

---
 ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/CokingController.java |   79 +++++++++++++++++++++++++++++++++++++++
 1 files changed, 78 insertions(+), 1 deletions(-)

diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/CokingController.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/CokingController.java
index 48672bc..1666392 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/CokingController.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/controller/admin/CokingController.java
@@ -12,6 +12,7 @@
 import com.iailab.module.ansteel.coking.entity.*;
 import com.iailab.module.ansteel.coking.service.*;
 import com.iailab.module.ansteel.common.enums.ProcessConfDataTypeEnum;
+import com.iailab.module.ansteel.common.enums.TraceProcessTypeEnum;
 import com.iailab.module.data.api.ind.IndItemApi;
 import com.iailab.module.data.api.ind.dto.ApiIndItemQueryDTO;
 import com.iailab.module.data.api.ind.dto.ApiIndItemValueDTO;
@@ -63,6 +64,8 @@
 
     @Autowired
     private CokingOverviewService cokingOverviewService;
+    @Autowired
+    private CokingOverviewIndService cokingOverviewIndService;
 
     @Autowired
     private CokingTraceSuggestService cokingTraceSuggestService;
@@ -88,6 +91,28 @@
     @GetMapping("/analy-ind/list")
     @Operation(summary = "焦化总图-指标分析")
     public CommonResult<List<CokingAnalyIndDTO>> getCokingAnalyIndList(@RequestParam Map<String, Object> params) {
+        String analyDate = (String) params.get("analyDate");
+        if (StringUtils.isBlank(analyDate)) {
+            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 analyClass = "";
+            if (hour >= 8 && hour < 16) {
+                analyDate = DateUtils.format(calendar.getTime());
+                analyClass = "甲班";
+            } else if (hour >= 16 && hour < 24) {
+                analyDate = DateUtils.format(calendar.getTime());
+                analyClass = "乙班";
+            } else if (hour >= 0 && hour < 8) {
+                calendar.add(Calendar.DAY_OF_YEAR, -1);
+                analyDate = DateUtils.format(calendar.getTime());
+                analyClass = "丙班";
+            }
+            params.put("analyDate", analyDate);
+            params.put("analyClass", analyClass);
+        }
         List<CokingAnalyIndEntity> list = cokingAnalyIndService.list(params);
         return success(ConvertUtils.sourceToTarget(list, CokingAnalyIndDTO.class));
     }
@@ -137,10 +162,17 @@
 
 
     @GetMapping("/overview/list")
-    @Operation(summary = "各工序-概况数据")
+    @Operation(summary = "各工序-概况-整体数据")
     public CommonResult<Map<String,List<CokingOverviewDTO>>> getOverviewList(@RequestParam Map<String, Object> params) {
         Map<String,List<CokingOverviewDTO>> result = cokingOverviewService.list(params);
         return success(result);
+    }
+
+    @GetMapping("/overview/indList")
+    @Operation(summary = "各工序-概况-能流图指标数据")
+    public CommonResult<List<CokingOverviewIndEntity>> getOverviewIndList(@RequestParam Map<String, Object> params) {
+        List<CokingOverviewIndEntity> list = cokingOverviewIndService.list(params);
+        return success(list);
     }
 
     @GetMapping("/overview/abnormal-data")
@@ -165,6 +197,21 @@
     @GetMapping("/trace-suggest/list")
     @Operation(summary = "焦化工序-异常溯源及优化建议")
     public CommonResult<List<CokingTraceSuggestDTO>> getTraceSuggestList(@RequestParam Map<String, Object> params) {
+        String relId = (String) params.get("relId");
+        String processType = (String) params.get("processType");
+        if (StringUtils.isBlank(relId) && StringUtils.isNotBlank(processType)) {
+            // 查找最新的relId
+            Calendar calendar = Calendar.getInstance();
+            calendar.add(Calendar.DAY_OF_YEAR, -1);
+            String clock = DateUtils.format(calendar.getTime(), "yyyy-MM-dd");
+            CokingAnalyIndEntity analyInd = cokingAnalyIndService.get(TraceProcessTypeEnum.getEumByCode(processType).getProcess(), clock);
+            if (analyInd != null) {
+                relId = analyInd.getRelId();
+                params.put("relId", relId);
+            } else {
+                return success(new ArrayList<>());
+            }
+        }
         List<CokingTraceSuggestEntity> list = cokingTraceSuggestService.list(params);
         return success(ConvertUtils.sourceToTarget(list, CokingTraceSuggestDTO.class));
     }
@@ -172,6 +219,21 @@
     @GetMapping("/trace-ind/list")
     @Operation(summary = "焦化工序-异常溯源指标")
     public CommonResult<List<CokingTraceIndDTO>> getTraceIndList(@RequestParam Map<String, Object> params) {
+        String relId = (String) params.get("relId");
+        String processType = (String) params.get("processType");
+        if (StringUtils.isBlank(relId) && StringUtils.isNotBlank(processType)) {
+            // 查找最新的relId
+            Calendar calendar = Calendar.getInstance();
+            calendar.add(Calendar.DAY_OF_YEAR, -1);
+            String clock = DateUtils.format(calendar.getTime(), "yyyy-MM-dd");
+            CokingAnalyIndEntity analyInd = cokingAnalyIndService.get(TraceProcessTypeEnum.getEumByCode(processType).getProcess(), clock);
+            if (analyInd != null) {
+                relId = analyInd.getRelId();
+                params.put("relId", relId);
+            } else {
+                return success(new ArrayList<>());
+            }
+        }
         List<CokingTraceIndEntity> list = cokingTraceIndService.list(params);
         return success(ConvertUtils.sourceToTarget(list, CokingTraceIndDTO.class));
     }
@@ -179,6 +241,21 @@
     @GetMapping("/trace-deviation/list")
     @Operation(summary = "焦化工序-异常溯源影响因素偏差值")
     public CommonResult<List<CokingTraceDeviationDTO>> getTraceDeviationList(@RequestParam Map<String, Object> params) {
+        String relId = (String) params.get("relId");
+        String processType = (String) params.get("processType");
+        if (StringUtils.isBlank(relId) && StringUtils.isNotBlank(processType)) {
+            // 查找最新的relId
+            Calendar calendar = Calendar.getInstance();
+            calendar.add(Calendar.DAY_OF_YEAR, -1);
+            String clock = DateUtils.format(calendar.getTime(), "yyyy-MM-dd");
+            CokingAnalyIndEntity analyInd = cokingAnalyIndService.get(TraceProcessTypeEnum.getEumByCode(processType).getProcess(), clock);
+            if (analyInd != null) {
+                relId = analyInd.getRelId();
+                params.put("relId", relId);
+            } else {
+                return success(new ArrayList<>());
+            }
+        }
         List<CokingTraceDeviationEntity> list = cokingTraceDeviationService.list(params);
         return success(ConvertUtils.sourceToTarget(list, CokingTraceDeviationDTO.class));
     }

--
Gitblit v1.9.3