From e2c1c1cff8ad419f7ed7c8fa301488a7ee7ca869 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期日, 29 三月 2026 21:00:47 +0800
Subject: [PATCH] 优化
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java | 62 ++++++++++++++++++++++++-------
1 files changed, 48 insertions(+), 14 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java
index 1c8fe5c..a8a5a69 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/PakinSchedules.java
@@ -3,10 +3,13 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.vincent.rsf.framework.exception.CoolException;
+import com.vincent.rsf.server.common.utils.QuantityUtils;
import com.vincent.rsf.server.manager.entity.*;
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;
@@ -18,6 +21,8 @@
@Component
public class PakinSchedules {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(PakinSchedules.class);
@Autowired
private WaitPakinService waitPakinService;
@@ -65,25 +70,54 @@
if (pakinItems.isEmpty()) {
throw new CoolException("缁勬嫋鏄庣粏涓虹┖锛侊紒");
}
- List<String> pkinItems = pakinItems.stream().map(WaitPakinItem::getAsnCode).collect(Collectors.toList());
+ // 杩囨护鎺塧snCode涓簄ull鎴栫┖瀛楃涓茬殑鎯呭喌锛堟棤ASN鍗曞彿鐨勭粍鎵樻槑缁嗕笉闇�瑕佸鐞嗗崟鎹姸鎬侊級
+ List<String> pkinItems = pakinItems.stream()
+ .map(WaitPakinItem::getAsnCode)
+ .filter(Objects::nonNull)
+ .filter(code -> !code.trim().isEmpty())
+ .distinct()
+ .collect(Collectors.toList());
- pkinItems.forEach(item -> {
- List<WkOrderItem> wkOrders = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderCode, item));
- if (wkOrders.isEmpty()) {
- throw new CoolException("鏁版嵁閿欒锛屽師鍗曟嵁涓嶅瓨鍦ㄦ垨宸蹭涪澶憋紒锛�");
+ pkinItems.forEach(asnCode -> {
+ List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderCode, asnCode));
+ if (orderItems.isEmpty()) {
+// LOGGER.warn("pakinLog 璺宠繃 ASN锛氬師鍗曟嵁涓嶅瓨鍦ㄦ垨宸蹭涪澶憋紝asnCode={}", asnCode);
+ return;
}
- Set<Long> orderIds = wkOrders.stream().map(WkOrderItem::getOrderId).collect(Collectors.toSet());
- orderIds.forEach(itemId -> {
- WkOrder wkOrder = asnOrderService.getById(itemId);
+ Set<Long> orderIds = orderItems.stream().map(WkOrderItem::getOrderId).collect(Collectors.toSet());
+ // 璇ヨ鍗曚笅鎸夋槑缁嗘眹鎬荤殑宸茬粍鎵樻暟閲忥紙鎵�鏈夌粍鎵樻。涓� asnCode 瀵瑰簲鐨� anfme 鎸� asnItemId 姹囨�伙級
+ List<WaitPakinItem> allPakinItemsForOrder = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>()
+ .eq(WaitPakinItem::getAsnCode, asnCode));
+ Map<Long, Double> palletizedByItemId = allPakinItemsForOrder.stream()
+ .filter(p -> p.getAsnItemId() != null)
+ .collect(Collectors.groupingBy(WaitPakinItem::getAsnItemId,
+ Collectors.summingDouble(p -> p.getAnfme() != null ? p.getAnfme() : 0.0)));
+
+ orderIds.forEach(orderId -> {
+ WkOrder wkOrder = asnOrderService.getById(orderId);
if (Objects.isNull(wkOrder)) {
- throw new CoolException("鏁版嵁閿欒锛屽師鍗曟嵁涓嶅瓨鍦ㄦ垨宸蹭涪澶憋紒锛�");
+ // throw new CoolException("鏁版嵁閿欒锛屽師鍗曟嵁涓嶅瓨鍦ㄦ垨宸蹭涪澶憋紒锛�");
+// LOGGER.warn("pakinLog 璺宠繃璁㈠崟锛氬師鍗曟嵁涓嶅瓨鍦ㄦ垨宸蹭涪澶憋紝orderId={}", orderId);
+ return;
}
- if (wkOrder.getAnfme().compareTo(wkOrder.getQty()) == 0) {
- if (!asnOrderService.update(new LambdaUpdateWrapper<WkOrder>()
- .eq(WkOrder::getId, itemId)
- .set(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val))) {
- throw new CoolException("鍗曟嵁淇敼澶辫触锛侊紒");
+ List<WkOrderItem> items = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, orderId));
+ if (items.isEmpty()) {
+ return;
+ }
+ // 浠呭綋鍏ㄩ儴鏄庣粏鍧囧凡缁勬墭瀹屾瘯涓斿凡鍏ュ簱瀹屾垚锛坬ty>=璁″垝锛夛紝鎵嶅皢鍏ュ簱鍗曠疆涓哄凡瀹屾垚
+ boolean allLinesDone = items.stream().allMatch(oi -> {
+ double plan = oi.getAnfme() != null ? oi.getAnfme() : 0.0;
+ if (QuantityUtils.compare(plan, 0.0) <= 0) {
+ return true;
}
+ double palletized = palletizedByItemId.getOrDefault(oi.getId(), 0.0);
+ double received = oi.getQty() != null ? oi.getQty() : 0.0;
+ return QuantityUtils.compare(palletized, plan) >= 0 && QuantityUtils.compare(received, plan) >= 0;
+ });
+ if (allLinesDone && !asnOrderService.update(new LambdaUpdateWrapper<WkOrder>()
+ .eq(WkOrder::getId, orderId)
+ .set(WkOrder::getExceStatus, AsnExceStatus.ASN_EXCE_STATUS_TASK_DONE.val))) {
+ throw new CoolException("鍗曟嵁淇敼澶辫触锛侊紒");
}
});
--
Gitblit v1.9.1