From 1f27b82b5de1bfb7767c2fc0b8bbc37eb3acfa77 Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期二, 13 五月 2025 18:01:19 +0800
Subject: [PATCH] 单据对接

---
 src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java |   90 ++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 84 insertions(+), 6 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 f7b25ce..ccca2e0 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,103 @@
 package com.zy.nc.task.handler;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.zy.asrs.entity.param.OpenOrderPakoutParam;
+import com.zy.asrs.service.OpenService;
 import com.zy.asrs.task.AbstractHandler;
 import com.zy.asrs.task.core.ReturnT;
-import com.zy.nc.entity.NccSaleXsckmx;
-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;
 
-    public ReturnT<String> start() {
-        NccSaleXsckmx nccSaleXsckmx = nccSaleXsckmxMapper.selectById("1001A1100000000H9KKJ");
-        log.info("shuju:{}", JSONObject.toJSON(nccSaleXsckmx));
+    @Autowired
+    private NccScZkmxbWmsService nccScZkmxbWmsService;
+
+    @Autowired
+    private OpenService openService;
+
+    /**
+     * 鍙戣揣
+     *
+     * @return
+     */
+    public ReturnT<String> start1() {
+        List<String> Ids = nccSaleXsfhmxWmsService.selectXsfh();
+        for (String id : Ids) {
+            List<NccSaleXsfhmxWms> wmsFlag = nccSaleXsfhmxWmsService.selectList(new EntityWrapper<NccSaleXsfhmxWms>().eq("vbillcode", id).ne("wms_flag", 1).eq("fstatusflag", 2));
+            OpenOrderPakoutParam param = new OpenOrderPakoutParam();
+            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);
+                    detlDto.setRemark(JSONObject.toJSONString(nccSaleXsfhmxWms));
+                    orderDetails.add(detlDto);
+                    log.info("NccSaleXsfhmxWms鏁版嵁:{}", JSONObject.toJSON(nccSaleXsfhmxWms));
+                    i++;
+                }
+                nccSaleXsfhmxWms.setWmsFlag(1);
+            }
+            param.setOrderNo(id);
+            param.setOrderDetails(orderDetails);
+            openService.pakoutOrderCreate(param);
+            nccSaleXsfhmxWmsService.updateBatchById(wmsFlag);
+        }
         return SUCCESS;
     }
 
+    /**
+     * 杞簱
+     *
+     * @return
+     */
+    public ReturnT<String> start2() {
+        List<String> strings = nccScZkmxbWmsService.selectZk();
+        for (String string : strings) {
+            OpenOrderPakoutParam param = new OpenOrderPakoutParam();
+            param.setOrderType("杞簱");
+            DetlDto detlDto;
+            List<DetlDto> orderDetails = new ArrayList<>();
+            long i = 1;
+            List<NccScZkmxbWms> wmsFlag = nccScZkmxbWmsService.selectList(new EntityWrapper<NccScZkmxbWms>().eq("vbillcode", 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);
+                    orderDetails.add(detlDto);
+                    i++;
+                }
+                nccScZkmxbWms.setWmsFlag(1);
+            }
+            param.setOrderNo(string);
+            param.setOrderDetails(orderDetails);
+            openService.pakoutOrderCreate(param);
+            nccScZkmxbWmsService.updateBatchById(wmsFlag);
+        }
+        return SUCCESS;
+    }
 }

--
Gitblit v1.9.1