From 5e804c8e97fff19f04c73dbab416308f03fc8ad7 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期二, 11 三月 2025 17:08:48 +0800
Subject: [PATCH] #修改 1. 优化标准收货 2. 添加动态扩展字段功能

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java |   22 +++++++++++++++++++---
 1 files changed, 19 insertions(+), 3 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java
index c9bedbf..9ab4fb3 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java
@@ -3,6 +3,7 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.vincent.rsf.framework.exception.CoolException;
 import com.vincent.rsf.server.common.config.SysStockProperties;
+import com.vincent.rsf.server.common.utils.CommonUtil;
 import com.vincent.rsf.server.common.utils.DateUtils;
 import com.vincent.rsf.server.manager.entity.*;
 import com.vincent.rsf.server.manager.service.*;
@@ -52,7 +53,8 @@
      * @return
      * @time 2025/3/3 15:44
      */
-    @Scheduled(cron = "0 0/30 * * * ?  ")
+    @Scheduled(cron = "0 0/05 * * * ?  ")
+//    @Scheduled(cron = "0/5 * * * * ?")
     @Transactional(rollbackFor = Exception.class)
     public void genAsnOrder() {
         //鍒ゆ柇鏄惁寮�鍚嚜鍔ㄧ敓鎴怉SN鍗曟嵁
@@ -90,21 +92,35 @@
                 throw new CoolException("ASN鍗曟嵁淇濆瓨澶辫触锛侊紒");
             }
             List<AsnOrderItem> orderItems = new ArrayList<>();
+            String uuid16 = CommonUtil.randomUUID16();
             items.forEach(item -> {
                 AsnOrderItem orderItem = new AsnOrderItem();
-                Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getId, item.getMatnrCode()));
+                Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, item.getMatnrCode()));
+                if (Objects.isNull(matnr)) {
+                    throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶇墿鏂欎笉瀛樺湪!!");
+                }
+                //TODO barcode鐢熸垚绛栫暐
+                String barcode = code + matnr.getCode();
                 orderItem.setAnfme(item.getAnfme())
                         .setAsnId(order.getId())
                         .setQty(item.getQty())
                         .setSplrName(item.getSplrName())
+                        .setAsnCode(code)
                         .setSplrCode(item.getSplrCode())
                         .setMatnk(item.getMatnrName())
                         .setPoDetlId(item.getId())
+                        .setBarcode(barcode)
                         .setPoCode(purchase.getCode())
                         .setPurQty(item.getAnfme())
                         .setPurUnit(item.getUnit())
                         .setMatnk(matnr.getName())
                         .setMatnrId(matnr.getId() + "");
+                //鍒ゆ柇PO鍗曟槸鍚﹀凡璁剧疆鍔ㄦ�佸瓧娈电储寮�
+                if (Objects.isNull(item.getFieldsIndex())) {
+                    orderItem.setFieldsIndex(uuid16);
+                } else {
+                    orderItem.setFieldsIndex(item.getFieldsIndex());
+                }
                 orderItems.add(orderItem);
             });
             if (!asnOrderItemService.saveBatch(orderItems)) {
@@ -114,7 +130,7 @@
             //浠诲姟鎵ц瀹屾垚锛屼慨鏀瑰凡瀹屾垚鏁伴噺鍜孭O鍗曟墽琛岀姸鎬�
             purchase.setQty(purchase.getAnfme()).setStatus(1);
 
-            if (!purchaseService.save(purchase)) {
+            if (!purchaseService.saveOrUpdate(purchase)) {
                 throw new CoolException("PO鍗曟墽琛屽畬鎴愬悗锛屼繚瀛樺け璐ワ紒锛�");
             }
 

--
Gitblit v1.9.1