yangys
2024-05-07 9b677ea5c6978788d135fc15da3d78c5a93789c2
smart-man-boot/src/main/java/com/qianwen/smartman/modules/fms/service/impl/FmsDeviceAnalysisServiceImpl.java
@@ -68,7 +68,6 @@
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;
@@ -100,7 +99,7 @@
        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();
@@ -180,7 +179,7 @@
                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<>();
@@ -243,7 +242,7 @@
        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)) {
@@ -268,7 +267,7 @@
        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;
@@ -283,16 +282,13 @@
        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());
            }