| | |
| | | import com.qianwen.smartman.common.constant.DateConstant; |
| | | import com.qianwen.smartman.common.enums.GlobalWcsTypeEnum; |
| | | import com.qianwen.smartman.common.utils.LocalDateTimeUtils; |
| | | import com.qianwen.smartman.modules.cps.dto.WorkstationWcsDmpDTO; |
| | | import com.qianwen.smartman.modules.cps.entity.GlobalWcs; |
| | | import com.qianwen.smartman.modules.cps.entity.Workstation; |
| | | import com.qianwen.smartman.modules.cps.enums.TrayEnum; |
| | | import com.qianwen.smartman.modules.cps.enums.WorkstationTypeEnum; |
| | | import com.qianwen.smartman.modules.cps.mapper.WorkstationMapper; |
| | | import com.qianwen.smartman.modules.cps.message.dto.TelemetryDataResponseDTO; |
| | | import com.qianwen.smartman.modules.cps.service.IGlobalWcsService; |
| | | import com.qianwen.smartman.modules.cps.service.IWorkstationService; |
| | | import com.qianwen.smartman.modules.smis.dto.WorkstationWcsDmpDTO; |
| | | import com.qianwen.smartman.modules.smis.entity.GlobalWcs; |
| | | import com.qianwen.smartman.modules.smis.entity.Workstation; |
| | | import com.qianwen.smartman.modules.smis.enums.TrayEnum; |
| | | import com.qianwen.smartman.modules.smis.enums.WorkstationTypeEnum; |
| | | import com.qianwen.smartman.modules.smis.mapper.WorkstationMapper; |
| | | import com.qianwen.smartman.modules.smis.message.dto.TelemetryDataResponseDTO; |
| | | import com.qianwen.smartman.modules.smis.service.IGlobalWcsService; |
| | | import com.qianwen.smartman.modules.smis.service.IWorkstationService; |
| | | import com.qianwen.smartman.modules.mdc.entity.WorkstationCollectData; |
| | | import com.qianwen.smartman.modules.mdc.mapper.SuperAggregateStateMapper; |
| | | import com.qianwen.smartman.modules.mdc.mapper.SuperAlarmMapper; |
| | |
| | | List<Workstation> workstationList = this.workstationService.list(Wrappers.<Workstation>lambdaQuery() |
| | | .eq(Workstation::getType, WorkstationTypeEnum.MACHINE.getCode()) |
| | | .eq(Workstation::getStatus, TrayEnum.StatusEnum.ACTIVATING.getStatus())); |
| | | /* |
| | | List<Workstation> workstationList = this.workstationService.list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> { |
| | | return v0.getType(); |
| | | }, WorkstationTypeEnum.MACHINE.getCode())).eq((v0) -> { |
| | | return v0.getStatus(); |
| | | }, TrayEnum.StatusEnum.ACTIVATING.getStatus()));*/ |
| | | |
| | | if (Func.isEmpty(workstationList)) { |
| | | return wcsList.stream().map(c -> { |
| | | return DeviceStatusStatisticsVO.builder().status(c.getCode()).statusName(c.getName()).deviceNum(0L).build(); |
| | |
| | | |
| | | Set<String> wIds = workstationList.stream().map(Workstation::getId).map(String::valueOf).collect(Collectors.toSet()); |
| | | |
| | | //下面是查询设备的最新状态值 |
| | | //deviceMap key为wcs的code值,value是设备数量(该状态的) |
| | | Map<String, Long> deviceMap = wIds.stream().map(wId -> { |
| | | |