From 62696f3297b6d740f89f7a318eb1af0c7d6b7158 Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期三, 07 五月 2025 16:09:56 +0800 Subject: [PATCH] Merge branch 'master' of http://dlindusit.com:53929/r/ansteel --- ansteel-biz/src/main/java/com/iailab/module/ansteel/api/service/impl/DataServiceImpl.java | 44 ++++++++++++++++++++++++++++++++------------ 1 files changed, 32 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 ae19b06..7b41ea8 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 @@ -113,9 +113,9 @@ @Override public List<MainProcessIndexDTO> getIndexList(Map<String, Object> params) { List<MainProcessIndexDTO> list = new ArrayList<>(); - if("day".equals(params.get("type"))) { + if ("day".equals(params.get("type"))) { list = ConvertUtils.sourceToTarget(mainProcessIndexDayDao.selectList(new QueryWrapper<>()), MainProcessIndexDTO.class); - }else if("team".equals(params.get("type"))){ + } else if ("team".equals(params.get("type"))) { list = ConvertUtils.sourceToTarget(mainProcessIndexTeamDao.selectList(new QueryWrapper<>()), MainProcessIndexDTO.class); } if (!CollectionUtils.isEmpty(list)) { @@ -188,9 +188,12 @@ PreDataSingleChartRespVO resultOld = mcsApi.getPreDataSingleChart(reqVO); PreDataChartRespVO result = ConvertUtils.sourceToTarget(resultOld, PreDataChartRespVO.class); PreDataViewDTO preDataView = ConvertUtils.sourceToTarget(resultOld.getDataView(), PreDataViewDTO.class); - if(trendsDataH != null) { + if (StringUtils.isNotBlank(trendsDataH)) { + // 动态上限 ApiPointValueQueryDTO pointValueQueryDTO = new ApiPointValueQueryDTO(); pointValueQueryDTO.setPointNo(trendsDataH); + pointValueQueryDTO.setStart(startTime); + pointValueQueryDTO.setEnd(endTime); List<ApiPointValueDTO> trendsDataHList = ConvertUtils.sourceToTarget(dataPointApi.queryPointHistoryValue(pointValueQueryDTO), ApiPointValueDTO.class); List<Object[]> newList = new ArrayList<>(); trendsDataHList.forEach(item -> { @@ -201,9 +204,12 @@ }); preDataView.setTrendsDataH(newList); } - if(trendsDataL != null) { + if (StringUtils.isNotBlank(trendsDataL)) { + // 动态下限 ApiPointValueQueryDTO pointValueQueryDTO = new ApiPointValueQueryDTO(); pointValueQueryDTO.setPointNo(trendsDataL); + pointValueQueryDTO.setStart(startTime); + pointValueQueryDTO.setEnd(endTime); List<ApiPointValueDTO> trendsDataLList = ConvertUtils.sourceToTarget(dataPointApi.queryPointHistoryValue(pointValueQueryDTO), ApiPointValueDTO.class); List<Object[]> newList = new ArrayList<>(); trendsDataLList.forEach(item -> { @@ -216,7 +222,6 @@ } preDataView.setPreData(resultOld.getDataView().getPreDataL()); - result.setPreDataView(preDataView); return result; } @@ -252,7 +257,7 @@ } /** - * 查询原始计划、修正计划数据 + * 查询原始计划、修正计划数据 */ @Override public Map<String, Object> getPlanDataChart(PlanDataChartReqVO reqVO) { @@ -393,16 +398,16 @@ Date endTime = null; Calendar calendar = Calendar.getInstance(); calendar.set(Calendar.MILLISECOND, 0); - if (params.containsKey("endTime")) { - endTime = DateUtils.parse(params.get("endTime").toString(),DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND); - }else { + if (!params.containsKey("endTime") || StringUtils.isBlank(params.get("endTime").toString())) { endTime = calendar.getTime(); + } else { + endTime = DateUtils.parse(params.get("endTime").toString(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND); } - if (params.containsKey("startTime")) { - startTime = DateUtils.parse(params.get("startTime").toString(),DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND); - }else { + if (!params.containsKey("startTime") || StringUtils.isBlank(params.get("startTime").toString())) { calendar.add(Calendar.DAY_OF_YEAR, -1); startTime = calendar.getTime(); + } else { + startTime = DateUtils.parse(params.get("startTime").toString(), DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND); } switch (ProcessConfDataTypeEnum.getEumByCode(dataType)) { @@ -438,4 +443,19 @@ } return dataList; } + + @Override + public List<PreDataViewSimpleDTO> getPreDataByOutIds(PreDataBarLineReqVO reqVO) { + PreDataBarLineRespVO preDataBarLineRespVO = mcsApi.getPreDataCharts(reqVO); + List<PreDataViewSimpleDTO> preDataViewSimpleDTOList = new ArrayList<>(); + preDataBarLineRespVO.getDataViewList().forEach(item -> { + PreDataViewSimpleDTO preDataViewSimpleDTO = new PreDataViewSimpleDTO(); + preDataViewSimpleDTO.setItemName(item.getResultName()); + preDataViewSimpleDTO.setPredictTime(preDataBarLineRespVO.getPredictTime()); + preDataViewSimpleDTO.setCurData(item.getCurData()); + preDataViewSimpleDTO.setRealData(item.getRealData()); + preDataViewSimpleDTOList.add(preDataViewSimpleDTO); + }); + return preDataViewSimpleDTOList; + } } \ No newline at end of file -- Gitblit v1.9.3