| | |
| | | import com.qianwen.smartman.common.constant.ShiftConstant; |
| | | import com.qianwen.smartman.common.utils.LocalDateTimeUtils; |
| | | import com.qianwen.smartman.common.utils.MessageUtils; |
| | | import com.qianwen.smartman.modules.cps.convert.WorkstationConvert; |
| | | import com.qianwen.smartman.modules.cps.dto.ShiftInfoDTO; |
| | | import com.qianwen.smartman.modules.cps.entity.Workstation; |
| | | import com.qianwen.smartman.modules.cps.enums.WorkstationTypeEnum; |
| | | import com.qianwen.smartman.modules.cps.mapper.WorkstationMapper; |
| | | import com.qianwen.smartman.modules.cps.service.IShiftDetailService; |
| | | import com.qianwen.smartman.modules.cps.service.IWorkstationService; |
| | | import com.qianwen.smartman.modules.cps.vo.WorkstationVO; |
| | | import com.qianwen.smartman.modules.smis.convert.WorkstationConvert; |
| | | import com.qianwen.smartman.modules.smis.dto.ShiftInfoDTO; |
| | | import com.qianwen.smartman.modules.smis.entity.Workstation; |
| | | import com.qianwen.smartman.modules.smis.enums.WorkstationTypeEnum; |
| | | import com.qianwen.smartman.modules.smis.mapper.WorkstationMapper; |
| | | import com.qianwen.smartman.modules.smis.service.IShiftDetailService; |
| | | import com.qianwen.smartman.modules.smis.service.IWorkstationService; |
| | | import com.qianwen.smartman.modules.smis.vo.WorkstationVO; |
| | | import com.qianwen.smartman.modules.mdc.dto.IntervalDateDto; |
| | | import com.qianwen.smartman.modules.mdc.dto.StatisticsWrapperDto; |
| | | import com.qianwen.smartman.modules.mdc.entity.SuperAggregate; |
| | |
| | | List<String> workStationIdList = statisticsAnalysisQueryVO.getWorkStationIdList(); |
| | | if (Func.isEmpty(workStationIdList)) { |
| | | workStationIdList = this.workstationService.list(Wrappers.<Workstation>lambdaQuery().eq(Workstation::getType, WorkstationTypeEnum.MACHINE.getCode()) |
| | | .eq(Workstation::getStatus, CommonConstant.ENABLE)).stream().map(s -> Func.toStr(s.getId())).collect(Collectors.toList()); |
| | | /* |
| | | workStationIdList = (List) this.workstationService.list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getType(); |
| | | }, WorkstationTypeEnum.MACHINE.getCode())).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, CommonConstant.ENABLE)).stream().map(s -> { |
| | | return Func.toStr(s.getId()); |
| | | }).collect(Collectors.toList());*/ |
| | | .eq(Workstation::getStatus, CommonConstant.ENABLE)).stream().map(s -> Func.toStr(s.getId())).collect(Collectors.toList()); |
| | | } |
| | | IPage<WorkstationVO> workstationVOPage = this.workstationMapper.queryWorkstationAndGroup(Condition.getPage(query), Func.toLongList(workStationIdList)); |
| | | IPage<Workstation> workstationPage = WorkstationConvert.INSTANCE.convert(workstationVOPage); |
| | |
| | | |
| | | List<SuperAggregateOutput> superAggregateList = FilterOffUtils.filterOffDay(superAggregateOutputByNaturalDate, OpenTypeEnums.OUT_PUT); |
| | | StatisticsWrapperDto statisticsWrapperDto = new StatisticsWrapperDto(superAggregateList, statisticsAnalysisQueryVO, intervalDates, workstationPage, MdcConstant.OUTPUT); |
| | | return this.wrapper.entityVO(statisticsWrapperDto); |
| | | |
| | | StatisticsVO result = this.wrapper.entityVO(statisticsWrapperDto); |
| | | return result; |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public BladeFile export(StatisticsAnalysisQueryVO analysisQueryVO) { |
| | | StatisticalMethodEnum statisticalMethod = analysisQueryVO.getStatisticalMethod(); |
| | | List<String> workStationIdList = analysisQueryVO.getWorkStationIdList(); |