| | |
| | | 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; |
| | |
| | | |
| | | @Autowired |
| | | private CokingOverviewService cokingOverviewService; |
| | | @Autowired |
| | | private CokingOverviewIndService cokingOverviewIndService; |
| | | |
| | | @Autowired |
| | | private CokingTraceSuggestService cokingTraceSuggestService; |
| | |
| | | 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 = "甲班"; |
| | | } |
| | | calendar.add(Calendar.DAY_OF_YEAR, -1); |
| | | analyDate = DateUtils.format(calendar.getTime()); |
| | | params.put("analyDate", analyDate); |
| | | params.put("analyClass", analyClass); |
| | | } |
| | | List<CokingAnalyIndEntity> list = cokingAnalyIndService.list(params); |
| | | return success(ConvertUtils.sourceToTarget(list, CokingAnalyIndDTO.class)); |
| | |
| | | |
| | | |
| | | @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") |
| | |
| | | @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)); |
| | | } |
| | |
| | | @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)); |
| | | } |
| | |
| | | @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)); |
| | | } |