cl
1 天以前 e2c1c1cff8ad419f7ed7c8fa301488a7ee7ca869
优化
1个文件已修改
11 ■■■■ 已修改文件
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java
@@ -8,6 +8,8 @@
import com.vincent.rsf.server.manager.enums.AsnExceStatus;
import com.vincent.rsf.server.manager.enums.PakinIOStatus;
import com.vincent.rsf.server.manager.service.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
@@ -19,6 +21,8 @@
@Component
public class PakinSchedules {
    private static final Logger LOGGER = LoggerFactory.getLogger(PakinSchedules.class);
    @Autowired
    private WaitPakinService waitPakinService;
@@ -77,7 +81,8 @@
            pkinItems.forEach(asnCode -> {
                List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderCode, asnCode));
                if (orderItems.isEmpty()) {
                    throw new CoolException("数据错误,原单据不存在或已丢失!!");
//                    LOGGER.warn("pakinLog 跳过 ASN:原单据不存在或已丢失,asnCode={}", asnCode);
                    return;
                }
                Set<Long> orderIds = orderItems.stream().map(WkOrderItem::getOrderId).collect(Collectors.toSet());
                // 该订单下按明细汇总的已组托数量(所有组托档中 asnCode 对应的 anfme 按 asnItemId 汇总)
@@ -91,7 +96,9 @@
                orderIds.forEach(orderId -> {
                    WkOrder wkOrder = asnOrderService.getById(orderId);
                    if (Objects.isNull(wkOrder)) {
                        throw new CoolException("数据错误,原单据不存在或已丢失!!");
                        // throw new CoolException("数据错误,原单据不存在或已丢失!!");
//                        LOGGER.warn("pakinLog 跳过订单:原单据不存在或已丢失,orderId={}", orderId);
                        return;
                    }
                    List<WkOrderItem> items = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, orderId));
                    if (items.isEmpty()) {