From e9ab59ccd258f8935b4160c7a4b38386c68bb295 Mon Sep 17 00:00:00 2001
From: liriming <1343021927@qq.com>
Date: 星期二, 01 四月 2025 13:29:41 +0800
Subject: [PATCH] 新增主工序指标与修改建议状态接口
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java | 72 ++++++++++++++++++++++++++++++------
1 files changed, 60 insertions(+), 12 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java
index 6aaace5..dac1073 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java
@@ -3,6 +3,8 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.framework.common.util.object.ConvertUtils;
+import com.iailab.module.ansteel.api.dao.MainProcessIndexDayDao;
+import com.iailab.module.ansteel.api.dao.MainProcessIndexTeamDao;
import com.iailab.module.ansteel.api.dao.PowerRunStateDao;
import com.iailab.module.ansteel.api.dto.*;
import com.iailab.module.ansteel.api.service.DataApi;
@@ -41,6 +43,12 @@
@Autowired
private PowerRunStateDao powerRunStateDao;
+ @Autowired
+ private MainProcessIndexDayDao mainProcessIndexDayDao;
+
+ @Autowired
+ private MainProcessIndexTeamDao mainProcessIndexTeamDao;
+
@Override
public List<PowerRunStateDTO> getPowerRunState() {
List<PowerRunStateDTO> list = ConvertUtils.sourceToTarget(powerRunStateDao.selectList(new QueryWrapper<>()), PowerRunStateDTO.class);
@@ -77,6 +85,42 @@
}).collect(Collectors.toList());
}
return list;
+ }
+
+ @Override
+ public List<MainProcessIndexDTO> getIndexList(Map<String, Object> params) {
+ List<MainProcessIndexDTO> list = new ArrayList<>();
+ if("day".equals(params.get("type"))) {
+ list = ConvertUtils.sourceToTarget(mainProcessIndexDayDao.selectList(new QueryWrapper<>()), MainProcessIndexDTO.class);
+ }else if("team".equals(params.get("type"))){
+ list = ConvertUtils.sourceToTarget(mainProcessIndexTeamDao.selectList(new QueryWrapper<>()), MainProcessIndexDTO.class);
+ }
+ if (!CollectionUtils.isEmpty(list)) {
+ list.stream().map(item -> {
+ StringBuffer sb = new StringBuffer();
+ sb.append(item.getHisAvg());
+ sb.append(",");
+ sb.append(item.getTheory());
+ sb.append(",");
+ sb.append(item.getActual());
+ sb.append(",");
+ sb.append(item.getRealData());
+ String[] arr = sb.toString().split(",");
+ Map<String, Object> adjValue = dataPointApi.queryPointsRealValue(Arrays.asList(arr));
+ item.setHisAvg(ObjectUtils.isEmpty(adjValue.get(arr[0])) ? "0" : new BigDecimal(adjValue.get(arr[0]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+ item.setTheory(ObjectUtils.isEmpty(adjValue.get(arr[1])) ? "0" : new BigDecimal(adjValue.get(arr[1]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+ item.setActual(ObjectUtils.isEmpty(adjValue.get(arr[2])) ? "0" : new BigDecimal(adjValue.get(arr[2]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+ item.setRealData(ObjectUtils.isEmpty(adjValue.get(arr[3])) ? "0" : new BigDecimal(adjValue.get(arr[3]).toString()).setScale(2, BigDecimal.ROUND_HALF_UP).toString());
+
+ return item;
+ }).collect(Collectors.toList());
+ }
+ return list;
+ }
+
+ @Override
+ public Boolean updateSuggestStatus(StAlarmAndSuggestReqVO ReqVO) {
+ return mcsApi.updateSuggestStatus(ReqVO);
}
@Override
@@ -185,6 +229,7 @@
result[2] = endTime;
return result;
}
+
/**
* 查询原始计划、修正计划数据
*/
@@ -199,30 +244,33 @@
list.forEach(item -> {
tMap.put(item.getParamCode(), item.getParamValue());
});
- String planCode = tMap.get(CommonConstant.PLAN_CODE);
- if (planCode == null) {
- return null;
- }
- Date startTime = DateUtils.parse(reqVO.getStartTime(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
- Date endTime = DateUtils.parse(reqVO.getEndTime(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
- Date predictTime = DateUtils.parse(reqVO.getPredictTime(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND);
+ PreDataSingleChartReqVO queryDto = new PreDataSingleChartReqVO();
+ queryDto.setChartCode(reqVO.getChartCode());
+ PreDataSingleChartRespVO chartData = mcsApi.getPreDataSingleChart(queryDto);
+
+ Date predictTime = chartData.getPredictTime();
+ Date startTime = chartData.getStartTime();
+ Date endTime = chartData.getEndTime();
+
// 原始计划数据
- LinkedHashMap<String, List<String[]>> planData = getRealPlanData(planCode, startTime, endTime, predictTime);
+ LinkedHashMap<String, List<String[]>> planData = getRealPlanData(reqVO.getPlanCodes(), startTime, endTime, predictTime);
// 修正计划数据
LinkedHashMap<String, List<String[]>> predData = new LinkedHashMap<>();
- predData.put(reqVO.getChartCode(), getPrePlanData(reqVO.getChartCode(), predictTime, endTime));
+ for (int i = 0; i < reqVO.getPlanCodes().size(); i++) {
+ predData.put(reqVO.getPlanCodes().get(i), getPrePlanData(reqVO.getPlanPreds().get(i), predictTime, endTime));
+ }
result.put("planData", planData);
result.put("predData", predData);
return result;
}
//原始计划
- public LinkedHashMap<String, List<String[]>> getRealPlanData(String planCode, Date startTime, Date endTime, Date predictTime) {
+ public LinkedHashMap<String, List<String[]>> getRealPlanData(List<String> planCodes, Date startTime, Date endTime, Date predictTime) {
LinkedHashMap<String, List<String[]>> result = new LinkedHashMap<>();
ApiDataQueryDTO apiDataQueryDTO = new ApiDataQueryDTO();
- apiDataQueryDTO.setItemNo(planCode);
+ apiDataQueryDTO.setItemNos(planCodes);
apiDataQueryDTO.setStart(startTime);
apiDataQueryDTO.setEnd(endTime);
LinkedHashMap<String, List<ApiPlanDataDTO>> planData = planItemApi.queryPlanItemRecordValue(apiDataQueryDTO);
@@ -251,7 +299,7 @@
PreDataSingleChartReqVO queryDto = new PreDataSingleChartReqVO();
queryDto.setChartCode(charCode);
queryDto.setStartTime(startTime);
- queryDto.setEndTime(startTime);
+ queryDto.setEndTime(endTime);
PreDataSingleChartRespVO chartData = mcsApi.getPreDataSingleChart(queryDto);
if (CollectionUtils.isEmpty(chartData.getDataView().getPreDataN())) {
return result;
--
Gitblit v1.9.3