| | |
| | | @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)) { |
| | |
| | | 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 -> { |
| | |
| | | }); |
| | | 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 -> { |
| | |
| | | } |
| | | |
| | | preDataView.setPreData(resultOld.getDataView().getPreDataL()); |
| | | |
| | | result.setPreDataView(preDataView); |
| | | return result; |
| | | } |
| | |
| | | } |
| | | |
| | | /** |
| | | * 查询原始计划、修正计划数据 |
| | | * 查询原始计划、修正计划数据 |
| | | */ |
| | | @Override |
| | | public Map<String, Object> getPlanDataChart(PlanDataChartReqVO reqVO) { |
| | |
| | | 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(); |
| | | } |
| | | if (params.containsKey("startTime")) { |
| | | startTime = DateUtils.parse(params.get("startTime").toString(),DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND); |
| | | }else { |
| | | endTime = DateUtils.parse(params.get("endTime").toString(),DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND); |
| | | } |
| | | 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)) { |