转历史单优化

cl

5 天以前 400881f9103218313c552b254c8312b54a24f563

 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java

@@ -994,8 +994,11 @@
        if (!taskService.updateById(task)) {
            throw new CoolException("任务状态修改失败！！");
        }
        // 9.1 入/出库结果上报：拣料再入库/盘点再入库完成后通知云仓（与定时任务闭环一致）
        reportInOutResultToCloud(task, loc, taskItems, null, true);
        // 盘点再入库上报云仓入库完成；拣料再入库跳过（入库侧 qty 取 anfme 为托盘余量；云仓出库实发在出库完成侧）
        // reportInOutResultToCloud(task, loc, taskItems, null, true);
        if (!TaskType.TASK_TYPE_PICK_IN.type.equals(task.getTaskType())) {
            reportInOutResultToCloud(task, loc, taskItems, null, true);
        }
    }

    /**
@@ -1477,6 +1480,7 @@
                        log.debug("[拣料入库] 计算后 pickedQty={}, minQty(剩余)={}, 将更新 taskItem.anfme={}, taskItem.qty={}",
                                pickedQty, minQty, minQty, pickedQty);
                        if (QuantityUtils.isNonNegative(minQty)) {
                            enqueueCloudWmsOutNotifyLogEarly(task, taskItem, QuantityUtils.toScaledBigDecimal(pickedQty));
                            taskItem.setAnfme(minQty);
                            taskItem.setQty(pickedQty);
                            if (!taskItemService.updateById(taskItem)) {
@@ -1612,6 +1616,8 @@
        if (allItems.isEmpty()) {
            throw new CoolException("任务明细为空");
        }
        List<Long> allItemIds = allItems.stream().map(TaskItem::getId).filter(Objects::nonNull).collect(Collectors.toList());
        Map<Long, BigDecimal> preQtyByItem = cloudWmsNotifyLogService.mapOutQtyFromInOutNotifyLogByTaskItemIds(allItemIds);
        Long loginUserId = SystemAuthUtils.getLoginUserId();
        if (loginUserId == null) {
            loginUserId = 1L;
@@ -1628,7 +1634,15 @@
        Map<String, Double> remainderByKey = new LinkedHashMap<>();
        for (Map.Entry<String, List<TaskItem>> e : byKey.entrySet()) {
            List<TaskItem> group = e.getValue();
            double totalQty = group.stream().mapToDouble(ti -> ti.getQty() != null && ti.getQty() > 0 ? ti.getQty() : (ti.getAnfme() != null ? ti.getAnfme() : 0)).sum();
            BigDecimal totalBd = BigDecimal.ZERO;
            for (TaskItem ti : group) {
                BigDecimal q = preQtyByItem.get(ti.getId());
                if (q == null) {
                    throw new CoolException("云仓待办无出库数量，taskItemId=" + ti.getId());
                }
                totalBd = totalBd.add(q);
            }
            double totalQty = totalBd.setScale(6, RoundingMode.HALF_UP).doubleValue();
            TaskItem rep = group.get(0);
            TaskItem forDeduct = new TaskItem();
            forDeduct.setMatnrId(rep.getMatnrId()).setBatch(rep.getBatch()).setFieldsIndex(rep.getFieldsIndex()).setQty(totalQty);
@@ -1694,10 +1708,16 @@
                if (group == null || group.isEmpty()) continue;
                TaskItem rep = group.get(0);
                TaskItem ti = new TaskItem();
                ti.setTaskId(pickInTask.getId());
                ti.setMatnrId(rep.getMatnrId()).setMaktx(rep.getMaktx()).setMatnrCode(rep.getMatnrCode());
                ti.setBatch(rep.getBatch()).setFieldsIndex(rep.getFieldsIndex()).setUnit(rep.getUnit()).setSpec(rep.getSpec()).setModel(rep.getModel());
                ti.setAnfme(rem).setQty(0.0);
                BeanUtils.copyProperties(rep, ti);
                ti.setId(null)
                        .setTaskId(pickInTask.getId())
                        .setAnfme(rem)
                        .setQty(0.0)
                        .setWorkQty(0.0)
                        .setCreateBy(loginUserId)
                        .setUpdateBy(loginUserId)
                        .setCreateTime(new Date())
                        .setUpdateTime(new Date());
                taskItemService.save(ti);
                LocItemWorking w = new LocItemWorking();
                w.setTaskId(pickInTask.getId());
@@ -1970,7 +1990,18 @@
        if (StringUtils.isBlank(ruleCode)) {
            throw new CoolException("当前业务：" + SerialRuleCode.SYS_STOCK_CODE + "，编码规则不存在！！");
        }
        Double sum = taskItems.stream().mapToDouble(TaskItem::getAnfme).sum();
        List<Long> itemIds = taskItems.stream().map(TaskItem::getId).filter(Objects::nonNull).collect(Collectors.toList());
        Map<Long, BigDecimal> preMap = cloudWmsNotifyLogService.mapOutQtyFromInOutNotifyLogByTaskItemIds(itemIds);
        BigDecimal sumBd = BigDecimal.ZERO;
        for (TaskItem ti : taskItems) {
            BigDecimal q = preMap.get(ti.getId());
            if (q == null) {
                throw new CoolException("云仓待办无出库数量，taskItemId=" + ti.getId());
            }
            sumBd = sumBd.add(q);
        }
        sumBd = sumBd.setScale(6, RoundingMode.HALF_UP);
        Double sum = sumBd.doubleValue();
        stock.setCode(ruleCode)
                .setUpdateBy(loginUserId)
                .setUpdateTime(new Date())
@@ -1983,22 +2014,26 @@
                WkOrder wkOrder = asnOrderService.getById(orderId);
                if (wkOrder != null) {
                    Double curQty = wkOrder.getQty() != null ? wkOrder.getQty() : 0.0;
                    Double newQty = QuantityUtils.roundToScale(curQty + sum);
                    wkOrder.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_WORKING.val).setQty(newQty);
                    BigDecimal newQtyBd = BigDecimal.valueOf(curQty).add(sumBd).setScale(6, RoundingMode.HALF_UP);
                    wkOrder.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_WORKING.val).setQty(newQtyBd.doubleValue());
                    if (!asnOrderService.updateById(wkOrder)) {
                        throw new CoolException("出库单完成数量更新失败！！");
                    }
                }
                // 按出库单明细汇总本次任务数量，更新各明细 workQty
                Map<Long, Double> sumByOrderItemId = taskItems.stream()
                        .filter(ti -> ti.getOrderItemId() != null)
                        .collect(Collectors.groupingBy(TaskItem::getOrderItemId,
                                Collectors.summingDouble(ti -> ti.getAnfme() != null ? ti.getAnfme() : 0.0)));
                for (Map.Entry<Long, Double> e : sumByOrderItemId.entrySet()) {
                Map<Long, BigDecimal> sumByOrderItemId = new HashMap<>();
                for (TaskItem ti : taskItems) {
                    if (ti.getOrderItemId() == null) {
                        continue;
                    }
                    BigDecimal q = preMap.get(ti.getId());
                    sumByOrderItemId.merge(ti.getOrderItemId(), q, BigDecimal::add);
                }
                for (Map.Entry<Long, BigDecimal> e : sumByOrderItemId.entrySet()) {
                    WkOrderItem oi = outStockItemService.getById(e.getKey());
                    if (oi != null) {
                        Double wq = oi.getWorkQty() != null ? oi.getWorkQty() : 0.0;
                        oi.setWorkQty(QuantityUtils.roundToScale(wq + e.getValue()));
                        BigDecimal nwq = BigDecimal.valueOf(wq).add(e.getValue()).setScale(6, RoundingMode.HALF_UP);
                        oi.setWorkQty(nwq.doubleValue());
                        if (!outStockItemService.updateById(oi)) {
                            throw new CoolException("出库单明细执行数量更新失败！！");
                        }
@@ -2007,7 +2042,8 @@
            }
        } else if (!Objects.isNull(orderItem) && StringUtils.isNotBlank(orderItem.getId() + "")) {
            WkOrder wkOrder = asnOrderService.getById(orderItem.getOrderId());
            Double qty = Math.round((wkOrder.getQty() + sum) * 1000000) / 1000000.0;
            double curHeaderQty = wkOrder.getQty() != null ? wkOrder.getQty() : 0.0;
            Double qty = QuantityUtils.roundToScale(QuantityUtils.add(curHeaderQty, sum));
            wkOrder.setExceStatus(AsnExceStatus.OUT_STOCK_STATUS_TASK_WORKING.val)
                    .setQty(qty);
            if (!asnOrderService.updateById(wkOrder)) {
@@ -2031,6 +2067,7 @@
            /**通过任务明细中的taskId查询,获取TASK的目标库位信息*/
            StockItem stockItem = new StockItem();
            BeanUtils.copyProperties(item, stockItem);
            stockItem.setAnfme(QuantityUtils.roundToScale(preMap.get(item.getId())));
            stockItem.setSourceItemId(item.getOrderItemId())
                    .setUpdateBy(loginUserId)
                    .setUpdateTime(new Date())
@@ -2853,6 +2890,32 @@
        }
    }

    @Override
    public void enqueueCloudWmsOutNotifyLogEarly(Task task, TaskItem taskItem, BigDecimal outQty) {
        if (task == null || taskItem == null || outQty == null) {
            return;
        }
        try {
            Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, task.getOrgLoc()));
            if (loc == null) {
                return;
            }
            CloudInOutReportContext ctx = loadCloudInOutReportContext(task, loc, Collections.singletonList(taskItem), null, false);
            if (ctx == null) {
                return;
            }
            InOutResultReportParam param = buildInOutParamForItem(task, taskItem, false, outQty, ctx);
            if (param == null) {
                return;
            }
            String mode = resolveCloudWmsInoutReportMode();
            boolean sendHold = CloudWmsInoutReportMode.MANUAL.equals(mode) || CloudWmsInoutReportMode.WAIT_ORDER.equals(mode);
            cloudWmsNotifyLogService.saveOrUpdateInOutNotifyEarly(param, task.getId(), taskItem.getId(), sendHold, taskItem.getTenantId());
        } catch (Exception e) {
            log.warn("云仓9.1早Enqueue失败 taskId={} taskItemId={}：{}", task.getId(), taskItem.getId(), e.getMessage());
        }
    }

    /**
     * 9.1 入/出库结果上报待办
     * @param isInbound true 入库完成，false 出库完成
@@ -2860,141 +2923,56 @@
     */
    private void reportInOutResultToCloud(Task task, Loc loc, List<TaskItem> taskItems, Set<Long> pkinItemIds, boolean isInbound) {
        try {
            String locId = isInbound ? task.getTargLoc() : task.getOrgLoc();
            String wareHouseId = null;
            if (loc.getWarehouseId() != null) {
                Warehouse wh = warehouseService.getById(loc.getWarehouseId());
                if (wh != null) {
                    wareHouseId = wh.getCode();
                }
            }
            if (wareHouseId == null) {
                log.warn("入/出库结果上报待办跳过：仓库编码为空，taskId={}", task.getId());
            CloudInOutReportContext ctx = loadCloudInOutReportContext(task, loc, taskItems, pkinItemIds, isInbound);
            if (ctx == null) {
                return;
            }
            Map<Long, String> sourceToOrderNo = new HashMap<>();
            if (isInbound && pkinItemIds != null && !pkinItemIds.isEmpty()) {
                List<WaitPakinItem> pakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().in(WaitPakinItem::getId, pkinItemIds));
                for (WaitPakinItem p : pakinItems) {
                    if (p.getAsnCode() != null) {
                        sourceToOrderNo.put(p.getId(), p.getAsnCode());
                    }
                }
            }
            // 入库组托场景允许按 WaitPakinItem.asnCode 兜底识别云仓来源，避免 plat* 为空时误跳过
            boolean hasCloudSource = taskItems.stream().anyMatch(this::hasCloudOrderRef)
                    || (isInbound && !sourceToOrderNo.isEmpty());
            if (!hasCloudSource) {
                log.info("入/出库结果上报待办跳过：无云仓来源单据，taskId={}", task.getId());
                return;
            }
            Set<Long> orderIdSet = taskItems.stream()
                    .filter(Objects::nonNull)
                    .map(TaskItem::getOrderId)
                    .filter(Objects::nonNull)
                    .collect(Collectors.toSet());
            Map<Long, WkOrder> orderById = new HashMap<>();
            if (!orderIdSet.isEmpty()) {
                for (WkOrder o : asnOrderService.listByIds(orderIdSet)) {
                    if (o != null && o.getId() != null) {
                        orderById.put(o.getId(), o);
                    }
                }
            }
            Set<String> orderCodeSet = new HashSet<>();
            for (TaskItem ti : taskItems) {
                if (ti == null) {
                    continue;
                }
                String on = isInbound && ti.getSource() != null
                        ? sourceToOrderNo.get(ti.getSource())
                        : (ti.getPlatOrderCode() != null ? ti.getPlatOrderCode() : ti.getPlatWorkCode());
                if (on == null && isInbound) {
                    on = ti.getPlatOrderCode() != null ? ti.getPlatOrderCode() : ti.getPlatWorkCode();
                }
                if (StringUtils.isNotBlank(on)) {
                    orderCodeSet.add(on);
                }
            }
            Map<String, WkOrder> orderByCode = new HashMap<>();
            if (!orderCodeSet.isEmpty()) {
                for (WkOrder o : asnOrderService.list(new LambdaQueryWrapper<WkOrder>().in(WkOrder::getCode, orderCodeSet))) {
                    if (o != null && StringUtils.isNotBlank(o.getCode())) {
                        orderByCode.put(o.getCode(), o);
                    }
                }
            }
            List<Long> reportItemIds = taskItems.stream().map(TaskItem::getId).filter(Objects::nonNull).collect(Collectors.toList());
            Map<Long, BigDecimal> outQtyByItem = isInbound ? Collections.emptyMap()
                    : cloudWmsNotifyLogService.mapOutQtyFromInOutNotifyLogByTaskItemIds(reportItemIds);
            ObjectMapper om = new ObjectMapper();
            Date now = new Date();
            Map<String, List<InOutResultReportParam>> byOrder = new LinkedHashMap<>();
            for (TaskItem item : taskItems) {
                if (item == null) {
                    continue;
                }
                boolean hasTaskItemCloudRef = hasCloudOrderRef(item);
                boolean hasInboundAsnFallbackRef = isInbound
                        && item.getSource() != null
                        && StringUtils.isNotBlank(sourceToOrderNo.get(item.getSource()));
                if (!hasTaskItemCloudRef && !hasInboundAsnFallbackRef) {
                    continue;
                }
                String orderNo = isInbound ? sourceToOrderNo.get(item.getSource()) : (item.getPlatOrderCode() != null ? item.getPlatOrderCode() : item.getPlatWorkCode());
                if (orderNo == null && isInbound) {
                    orderNo = item.getPlatOrderCode() != null ? item.getPlatOrderCode() : item.getPlatWorkCode();
                }
                if (orderNo == null || item.getMatnrCode() == null) {
                    continue;
                }
                WkOrder asnOrder = null;
                if (item.getOrderId() != null) {
                    asnOrder = orderById.get(item.getOrderId());
                }
                if (asnOrder == null) {
                    asnOrder = orderByCode.get(orderNo);
                }
                InOutResultReportParam param = new InOutResultReportParam()
                        .setOrderNo(orderNo)
                        .setPlanNo(item.getPlatWorkCode())
                        .setWkType(item.getWkType())
                        .setUnitNo(item.getUnit())
                        .setLineId(item.getPlatItemId())
                        .setWareHouseId(wareHouseId)
                        .setDocWarehouseNo(asnOrder != null ? asnOrder.getDocTaskWarehouseNo() : null)
                        .setOrgNo(asnOrder != null ? asnOrder.getDocOrgNo() : null)
                        .setInWarehouseNo(isInbound && asnOrder != null ? asnOrder.getDocInWarehouseNo() : null)
                        .setOutWarehouseNo(!isInbound && asnOrder != null ? asnOrder.getDocOutWarehouseNo() : null)
                        .setLocId(locId)
                        .setMatNr(item.getMatnrCode())
                        .setQty(item.getAnfme() != null ? String.valueOf(item.getAnfme()) : "0")
                        .setBatch(item.getBatch())
                        .setInbound(isInbound)
                        .setBarcode(task.getBarcode());
                byOrder.computeIfAbsent(orderNo, k -> new ArrayList<>()).add(param);
            }
            String mode = resolveCloudWmsInoutReportMode();
            boolean sendHold = CloudWmsInoutReportMode.MANUAL.equals(mode) || CloudWmsInoutReportMode.WAIT_ORDER.equals(mode);
            for (Map.Entry<String, List<InOutResultReportParam>> e : byOrder.entrySet()) {
                String orderNo = e.getKey();
                for (InOutResultReportParam param : e.getValue()) {
                    try {
                        String requestBody = om.writeValueAsString(param);
                        CloudWmsNotifyLog notifyLog = new CloudWmsNotifyLog()
                                .setReportType(cloudWmsNotifyLogService.getReportTypeInOutResult())
                                .setRequestBody(requestBody)
                                .setRetryCount(0)
                                .setBizRef("taskId=" + task.getId() + ",orderNo=" + orderNo)
                                .setCreateTime(now)
                                .setUpdateTime(now)
                                .setSourceOrderNo(orderNo)
                                .setInboundFlag(isInbound ? 1 : 0)
                                .setWareHouseCode(wareHouseId)
                                .setSendHold(sendHold ? 1 : 0)
                                .setSending(0);
                        cloudWmsNotifyLogService.fillFromConfig(notifyLog);
                        cloudWmsNotifyLogService.save(notifyLog);
                    } catch (JsonProcessingException ex) {
                        log.warn("入/出库结果上报待办落库失败（不影响主流程），taskId={}，orderNo={}：{}", task.getId(), orderNo, ex.getMessage());
                    }
            for (TaskItem item : taskItems) {
                if (item == null || item.getId() == null) {
                    continue;
                }
                BigDecimal outboundQty = isInbound ? null : outQtyByItem.get(item.getId());
                if (!isInbound && outboundQty == null) {
                    log.warn("云仓9.1跳过：待办无出库数量，taskId={}，taskItemId={}", task.getId(), item.getId());
                    continue;
                }
                InOutResultReportParam param = buildInOutParamForItem(task, item, isInbound, outboundQty, ctx);
                if (param == null) {
                    continue;
                }
                if (!isInbound && cloudWmsNotifyLogService.hasInOutNotifyRowForTaskItem(item.getId(), false)) {
                    continue;
                }
                if (isInbound && cloudWmsNotifyLogService.hasInOutNotifyRowForTaskItem(item.getId(), true)) {
                    continue;
                }
                String orderNo = param.getOrderNo();
                try {
                    String requestBody = om.writeValueAsString(param);
                    String bizRef = "taskId=" + task.getId() + ",taskItemId=" + item.getId() + ",orderNo=" + orderNo;
                    CloudWmsNotifyLog notifyLog = new CloudWmsNotifyLog()
                            .setReportType(cloudWmsNotifyLogService.getReportTypeInOutResult())
                            .setRequestBody(requestBody)
                            .setRetryCount(0)
                            .setBizRef(bizRef)
                            .setCreateTime(now)
                            .setUpdateTime(now)
                            .setSourceOrderNo(orderNo)
                            .setInboundFlag(isInbound ? 1 : 0)
                            .setWareHouseCode(ctx.wareHouseId)
                            .setSendHold(sendHold ? 1 : 0)
                            .setSending(0);
                    cloudWmsNotifyLogService.fillFromConfig(notifyLog);
                    cloudWmsNotifyLogService.save(notifyLog);
                } catch (JsonProcessingException ex) {
                    log.warn("入/出库结果上报待办落库失败（不影响主流程），taskId={}，orderNo={}：{}", task.getId(), orderNo, ex.getMessage());
                }
            }
        } catch (Exception e) {
@@ -3002,6 +2980,165 @@
        }
    }

    private CloudInOutReportContext loadCloudInOutReportContext(Task task, Loc loc, List<TaskItem> taskItems, Set<Long> pkinItemIds, boolean isInbound) {
        if (task == null || loc == null || taskItems == null || taskItems.isEmpty()) {
            return null;
        }
        String locId = isInbound ? task.getTargLoc() : task.getOrgLoc();
        String wareHouseId = null;
        if (loc.getWarehouseId() != null) {
            Warehouse wh = warehouseService.getById(loc.getWarehouseId());
            if (wh != null) {
                wareHouseId = wh.getCode();
            }
        }
        if (wareHouseId == null) {
            log.warn("入/出库结果上报待办跳过：仓库编码为空，taskId={}", task.getId());
            return null;
        }
        Map<Long, String> sourceToOrderNo = new HashMap<>();
        if (isInbound && pkinItemIds != null && !pkinItemIds.isEmpty()) {
            List<WaitPakinItem> pakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().in(WaitPakinItem::getId, pkinItemIds));
            for (WaitPakinItem p : pakinItems) {
                if (p.getAsnCode() != null) {
                    sourceToOrderNo.put(p.getId(), p.getAsnCode());
                }
            }
        }
        boolean hasOutboundCloudLine = !isInbound && taskItems.stream().anyMatch(ti ->
                ti != null && ti.getOrderId() != null && StringUtils.isNotBlank(ti.getPlatItemId()));
        boolean hasCloudSource = taskItems.stream().anyMatch(this::hasCloudOrderRef)
                || (isInbound && !sourceToOrderNo.isEmpty())
                || hasOutboundCloudLine;
        if (!hasCloudSource) {
            log.info("入/出库结果上报待办跳过：无云仓来源单据，taskId={}", task.getId());
            return null;
        }
        Set<Long> orderIdSet = taskItems.stream()
                .filter(Objects::nonNull)
                .map(TaskItem::getOrderId)
                .filter(Objects::nonNull)
                .collect(Collectors.toSet());
        Map<Long, WkOrder> orderById = new HashMap<>();
        if (!orderIdSet.isEmpty()) {
            for (WkOrder o : asnOrderService.listByIds(orderIdSet)) {
                if (o != null && o.getId() != null) {
                    orderById.put(o.getId(), o);
                }
            }
        }
        Set<String> orderCodeSet = new HashSet<>();
        for (TaskItem ti : taskItems) {
            if (ti == null) {
                continue;
            }
            String on = isInbound && ti.getSource() != null
                    ? sourceToOrderNo.get(ti.getSource())
                    : (ti.getPlatOrderCode() != null ? ti.getPlatOrderCode() : ti.getPlatWorkCode());
            if (on == null && isInbound) {
                on = ti.getPlatOrderCode() != null ? ti.getPlatOrderCode() : ti.getPlatWorkCode();
            }
            if (on == null && !isInbound && ti.getOrderId() != null) {
                WkOrder o = orderById.get(ti.getOrderId());
                if (o != null) {
                    on = StringUtils.isNotBlank(o.getPoCode()) ? o.getPoCode() : o.getCode();
                }
            }
            if (StringUtils.isNotBlank(on)) {
                orderCodeSet.add(on);
            }
        }
        Map<String, WkOrder> orderByCode = new HashMap<>();
        if (!orderCodeSet.isEmpty()) {
            for (WkOrder o : asnOrderService.list(new LambdaQueryWrapper<WkOrder>().in(WkOrder::getCode, orderCodeSet))) {
                if (o != null && StringUtils.isNotBlank(o.getCode())) {
                    orderByCode.put(o.getCode(), o);
                }
            }
            for (WkOrder o : asnOrderService.list(new LambdaQueryWrapper<WkOrder>().in(WkOrder::getPoCode, orderCodeSet))) {
                if (o != null && StringUtils.isNotBlank(o.getPoCode())) {
                    orderByCode.putIfAbsent(o.getPoCode(), o);
                }
            }
        }
        return new CloudInOutReportContext(wareHouseId, locId, sourceToOrderNo, orderById, orderByCode);
    }

    private InOutResultReportParam buildInOutParamForItem(Task task, TaskItem item, boolean isInbound,
            BigDecimal outboundQtyResolved, CloudInOutReportContext ctx) {
        if (task == null || item == null || ctx == null) {
            return null;
        }
        boolean hasTaskItemCloudRef = hasCloudOrderRef(item);
        boolean hasInboundAsnFallbackRef = isInbound
                && item.getSource() != null
                && StringUtils.isNotBlank(ctx.sourceToOrderNo.get(item.getSource()));
        boolean hasOutboundCloudLineRef = !isInbound && item.getOrderId() != null && StringUtils.isNotBlank(item.getPlatItemId());
        if (!hasTaskItemCloudRef && !hasInboundAsnFallbackRef && !hasOutboundCloudLineRef) {
            return null;
        }
        WkOrder asnOrder = null;
        if (item.getOrderId() != null) {
            asnOrder = ctx.orderById.get(item.getOrderId());
        }
        String orderNo = isInbound ? ctx.sourceToOrderNo.get(item.getSource()) : (item.getPlatOrderCode() != null ? item.getPlatOrderCode() : item.getPlatWorkCode());
        if (orderNo == null && isInbound) {
            orderNo = item.getPlatOrderCode() != null ? item.getPlatOrderCode() : item.getPlatWorkCode();
        }
        if (orderNo == null && !isInbound && asnOrder != null) {
            orderNo = StringUtils.isNotBlank(asnOrder.getPoCode()) ? asnOrder.getPoCode() : asnOrder.getCode();
        }
        if (orderNo == null || item.getMatnrCode() == null) {
            return null;
        }
        if (!isInbound && outboundQtyResolved == null) {
            return null;
        }
        if (asnOrder == null) {
            asnOrder = ctx.orderByCode.get(orderNo);
        }
        String qtyStr;
        if (isInbound) {
            qtyStr = item.getAnfme() != null ? QuantityUtils.toPlainQtyString(QuantityUtils.toScaledBigDecimal(item.getAnfme())) : "0";
        } else {
            qtyStr = QuantityUtils.toPlainQtyString(outboundQtyResolved);
        }
        return new InOutResultReportParam()
                .setOrderNo(orderNo)
                .setPlanNo(item.getPlatWorkCode())
                .setWkType(item.getWkType())
                .setUnitNo(item.getUnit())
                .setLineId(item.getPlatItemId())
                .setWareHouseId(ctx.wareHouseId)
                .setDocWarehouseNo(asnOrder != null ? asnOrder.getDocTaskWarehouseNo() : null)
                .setOrgNo(asnOrder != null ? asnOrder.getDocOrgNo() : null)
                .setInWarehouseNo(isInbound && asnOrder != null ? asnOrder.getDocInWarehouseNo() : null)
                .setOutWarehouseNo(!isInbound && asnOrder != null ? asnOrder.getDocOutWarehouseNo() : null)
                .setLocId(ctx.locId)
                .setMatNr(item.getMatnrCode())
                .setQty(qtyStr)
                .setBatch(item.getBatch())
                .setInbound(isInbound)
                .setBarcode(task.getBarcode());
    }

    private static final class CloudInOutReportContext {
        final String wareHouseId;
        final String locId;
        final Map<Long, String> sourceToOrderNo;
        final Map<Long, WkOrder> orderById;
        final Map<String, WkOrder> orderByCode;

        private CloudInOutReportContext(String wareHouseId, String locId, Map<Long, String> sourceToOrderNo,
                Map<Long, WkOrder> orderById, Map<String, WkOrder> orderByCode) {
            this.wareHouseId = wareHouseId;
            this.locId = locId;
            this.sourceToOrderNo = sourceToOrderNo;
            this.orderById = orderById;
            this.orderByCode = orderByCode;
        }
    }

    private boolean hasCloudOrderRef(TaskItem item) {
        if (item == null) {
            return false;