From 32a905fbf1daeac74cbd573e5b841709c44955c2 Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期四, 08 五月 2025 17:01:27 +0800
Subject: [PATCH] 代码编写

---
 src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java |   77 +++++++++++++++++++++++++++++++++-----
 1 files changed, 66 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java b/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java
index de0c5a5..3f2c0c3 100644
--- a/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java
+++ b/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java
@@ -1,25 +1,35 @@
 package com.zy.nc.task.handler;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.zy.asrs.entity.param.OpenOrderPakinParam;
+import com.zy.asrs.service.OpenService;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
-import com.zy.nc.entity.NccSaleDbckmxb;
-import com.zy.nc.entity.NccSaleXsckmx;
-import com.zy.nc.mapper.NccSaleDbckmxbMapper;
-import com.zy.nc.mapper.NccSaleXsckmxMapper;
+import com.zy.common.model.DetlDto;
+import com.zy.nc.entity.NccSaleXsfhmxWms;
+import com.zy.nc.entity.NccScZkmxbWms;
+import com.zy.nc.service.NccSaleXsfhmxWmsService;
+import com.zy.nc.service.NccScZkmxbWmsService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
 
 @Service
 @Slf4j
 public class PlanOrderHandler extends AbstractHandler<String> {
 
     @Autowired
-    private NccSaleXsckmxMapper nccSaleXsckmxMapper;
+    private NccSaleXsfhmxWmsService nccSaleXsfhmxWmsService;
 
     @Autowired
-    private NccSaleDbckmxbMapper nccSaleDbckmxbMapper;
+    private NccScZkmxbWmsService nccScZkmxbWmsService;
+
+    @Autowired
+    private OpenService openService;
 
     /**
      * 鍙戣揣
@@ -27,19 +37,64 @@
      * @return
      */
     public ReturnT<String> start1() {
-        NccSaleXsckmx nccSaleXsckmx = nccSaleXsckmxMapper.selectById("1001A1100000000H9KKJ");
-        log.info("shuju:{}", JSONObject.toJSON(nccSaleXsckmx));
+        List<String> Ids = nccSaleXsfhmxWmsService.selectXsfh();
+        for (String id : Ids) {
+            List<NccSaleXsfhmxWms> wmsFlag = nccSaleXsfhmxWmsService.selectList(new EntityWrapper<NccSaleXsfhmxWms>().eq("cdeliveryid", id).ne("wms_flag", 1).eq("fstatusflag", 2));
+            OpenOrderPakinParam param = new OpenOrderPakinParam();
+            param.setOrderType("閿�鍞彂璐�");
+            DetlDto detlDto;
+            List<DetlDto> orderDetails = new ArrayList<>();
+            long i = 1;
+            for (NccSaleXsfhmxWms nccSaleXsfhmxWms : wmsFlag) {
+                if (nccSaleXsfhmxWms.getFstatusflag() == 2 && nccSaleXsfhmxWms.getBdr() == 0 && nccSaleXsfhmxWms.getHdr() == 0) {
+                    detlDto = new DetlDto();
+                    detlDto.setMatnr(nccSaleXsfhmxWms.getWlbm());
+                    detlDto.setAnfme(nccSaleXsfhmxWms.getNastnum());
+                    detlDto.setLineNumber(i);
+                    nccSaleXsfhmxWms.setWmsFlag(1);
+                    orderDetails.add(detlDto);
+                    log.info("NccSaleXsfhmxWms鏁版嵁:{}", JSONObject.toJSON(nccSaleXsfhmxWms));
+                    i++;
+                }
+            }
+            param.setOrderDetails(orderDetails);
+            openService.pakinOrderCreate(param);
+            nccSaleXsfhmxWmsService.updateBatchById(wmsFlag);
+        }
         return SUCCESS;
     }
 
     /**
-     * 璋冩嫧
+     * 杞簱
      *
      * @return
      */
     public ReturnT<String> start2() {
-        NccSaleDbckmxb nccSaleDbckmxb = nccSaleDbckmxbMapper.selectById("1001A1100000000H9KKJ");
-        log.info("shuju:{}", JSONObject.toJSON(nccSaleDbckmxb));
+        List<String> strings = nccScZkmxbWmsService.selectZk();
+        for (String string : strings) {
+            OpenOrderPakinParam param = new OpenOrderPakinParam();
+            param.setOrderType("杞簱");
+            DetlDto detlDto;
+            List<DetlDto> orderDetails = new ArrayList<>();
+            long i = 1;
+            List<NccScZkmxbWms> wmsFlag = nccScZkmxbWmsService.selectList(new EntityWrapper<NccScZkmxbWms>().eq("cdeliveryid", string).ne("wms_flag", 1));
+            for (NccScZkmxbWms nccScZkmxbWms : wmsFlag) {
+                log.info("NccScZkmxbWms鏁版嵁:{}", JSONObject.toJSON(nccScZkmxbWms));
+                if (nccScZkmxbWms.getDjzt() == 2 && nccScZkmxbWms.getBdr() == 0 && nccScZkmxbWms.getDr() == 0) {
+                    detlDto = new DetlDto();
+                    detlDto.setMatnr(nccScZkmxbWms.getWlbm());
+                    detlDto.setAnfme(nccScZkmxbWms.getYingzzsl());
+                    detlDto.setBatch(nccScZkmxbWms.getVbatchcode());
+                    detlDto.setLineNumber(i);
+                    nccScZkmxbWms.setWmsFlag(1);
+                    orderDetails.add(detlDto);
+                    i++;
+                }
+            }
+            param.setOrderDetails(orderDetails);
+            openService.pakinOrderCreate(param);
+            nccScZkmxbWmsService.updateBatchById(wmsFlag);
+        }
         return SUCCESS;
     }
 }

--
Gitblit v1.9.1