| | |
| | | import com.qianwen.smartman.modules.mdc.mapper.SuperAlarmMapper; |
| | | |
| | | @Service |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/fms/service/impl/FmsDeviceAnalysisServiceImpl.class */ |
| | | public class FmsDeviceAnalysisServiceImpl implements IFmsDeviceAnalysisService { |
| | | private static final Logger log = LoggerFactory.getLogger(FmsDeviceAnalysisServiceImpl.class); |
| | | private final TrayMapper trayMapper; |
| | |
| | | this.workbenchService = workbenchService; |
| | | } |
| | | |
| | | @Override // org.springblade.modules.fms.service.IFmsDeviceAnalysisService |
| | | @Override |
| | | public FMSWorkbenchInfoVO listFMSWorkbenchInfo(Long workstationId) { |
| | | Workstation workstation = (Workstation) this.workstationService.getById(workstationId); |
| | | String avatar = workstation.getAvatar(); |
| | |
| | | return v0.getId(); |
| | | }, orderIds));*/ |
| | | fmsOrders.forEach(item3 -> { |
| | | FmsOrder fmsOrder = (FmsOrder) orderMap.put(item3.getId(), item3); |
| | | FmsOrder fmsOrder = orderMap.put(item3.getId(), item3); |
| | | }); |
| | | } |
| | | Map<Long, FmsOrderProcess> orderProcessMap = new HashMap<>(); |
| | |
| | | return fmsWorkbenchInfoVO; |
| | | } |
| | | |
| | | @Override // org.springblade.modules.fms.service.IFmsDeviceAnalysisService |
| | | @Override |
| | | public IPage<FmsAlarmVO> pageFmsAlarm(Long workstationId, Query query) { |
| | | IPage<FmsAlarmVO> page = Condition.getPage(query); |
| | | if (Func.isEmpty(workstationId)) { |
| | |
| | | return page; |
| | | } |
| | | |
| | | @Override // org.springblade.modules.fms.service.IFmsDeviceAnalysisService |
| | | @Override |
| | | public IPage<FmsWarehouseAreaTrayVO> pageTrayInfoList(Long areaId, Query query) { |
| | | if (CommonGroupConstant.WARE_ROOT.equals(areaId)) { |
| | | areaId = null; |
| | |
| | | return result; |
| | | } |
| | | |
| | | @Override // org.springblade.modules.fms.service.IFmsDeviceAnalysisService |
| | | @Override |
| | | @Transactional |
| | | public Boolean reduction(Long areaId, String areaCode) { |
| | | List<TrayWarehouseAreaDTO> result = this.trayMapper.getWarehouseAreaTray(); |
| | | if (Func.isNotEmpty(result)) { |
| | | Map<String, List<String>> areaMap = result.stream().collect(Collectors.groupingBy((v0) -> { |
| | | return v0.getAreaCode(); |
| | | }, Collectors.mapping((v0) -> { |
| | | return v0.getTrayCode(); |
| | | }, Collectors.toList()))); |
| | | Map<String, List<String>> areaMap = result.stream().collect(Collectors.groupingBy(TrayWarehouseAreaDTO::getAreaCode, Collectors.mapping(TrayWarehouseAreaDTO::getTrayCode, Collectors.toList()))); |
| | | |
| | | for (Map.Entry<String, List<String>> stringListEntry : areaMap.entrySet()) { |
| | | this.fmsRealTimeTrayMapper.updateReduction(stringListEntry.getValue(), stringListEntry.getKey()); |
| | | } |