From 78a59eda850857e1bfeb48541f0c64d442877a4d Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期二, 08 四月 2025 11:17:10 +0800
Subject: [PATCH] #实现pda简单入库出库操作

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |  411 +++++++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 360 insertions(+), 51 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index c644d71..a5fcd61 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -1,40 +1,73 @@
 package com.zy.asrs.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.BaseRes;
 import com.core.common.Cools;
+import com.core.common.DateUtils;
+import com.core.common.SnowflakeIdWorker;
 import com.core.exception.CoolException;
-import com.zy.asrs.entity.MatCode;
-import com.zy.asrs.entity.Order;
-import com.zy.asrs.entity.OrderDetl;
-import com.zy.asrs.entity.WaitPakin;
+import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.CombParam;
+import com.zy.asrs.entity.param.MobileAdjustParam;
+import com.zy.asrs.entity.param.OpenOrderPakinParam;
 import com.zy.asrs.service.*;
-import com.zy.asrs.utils.VersionUtils;
+import com.zy.asrs.task.core.ReturnT;
+import com.zy.asrs.task.handler.WorkLogHandler;
+import com.zy.asrs.utils.MatUtils;
+import com.zy.common.constant.MesConstant;
+import com.zy.common.entity.Parameter;
 import com.zy.common.model.DetlDto;
+import com.zy.common.model.MesCombParam;
+import com.zy.common.service.CommonService;
+import com.zy.common.utils.HttpHandler;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.Iterator;
 import java.util.List;
 
 /**
  * 绉诲姩绔湇鍔℃牳蹇冪被
  * Created by vincent on 2020/6/28
  */
+@Slf4j
 @Service
 public class MobileServiceImpl implements MobileService {
 
     @Autowired
-    private MatCodeService matCodeService;
+    private MatService matService;
     @Autowired
     private WaitPakinService waitPakinService;
     @Autowired
     private OrderService orderService;
     @Autowired
     private OrderDetlService orderDetlService;
+    @Autowired
+    private BasDevpService basDevpService;
+    @Autowired
+    private WrkMastService wrkMastService;
+    @Autowired
+    private WrkDetlService wrkDetlService;
+    @Autowired
+    private PackService packService;
+    @Autowired
+    private OpenService openService;
+    @Autowired
+    private SnowflakeIdWorker snowflakeIdWorker;
+    @Autowired
+    private ApiLogService apiLogService;
+    @Autowired
+    private WorkLogHandler workLogHandler;
+    @Autowired
+    private CommonService commonService;
+    @Autowired
+    private LocMastService locMastService;
 
     @Override
     @Transactional
@@ -45,45 +78,23 @@
         // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
         if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
                 eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) {
-            throw new CoolException("鏉$爜鏁版嵁宸插瓨鍦�");
+            throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱");
         }
+
+        // todo: 涓嶄笅绾块噸鏂板叆搴�
+        WrkMast wrkMast18 = wrkMastService.selectByBarcode(param.getBarcode());
+        if (wrkMast18 != null && wrkMast18.getWrkSts() == 18) {
+            ReturnT<String> start = workLogHandler.start(wrkMast18);
+            if (!start.isSuccess()) {
+                log.error("宸ヤ綔妗workNo={}]鍘嗗彶妗e鐞嗗け璐�", wrkMast18.getWrkNo());
+            }
+        }
+
         Date now = new Date();
 
         // 鏃犲崟缁勬墭
         if (Cools.isEmpty(param.getOrderNo())) {
 
-            // 鐢熸垚鍏ュ簱閫氱煡妗�
-            List<DetlDto> detlDtos = new ArrayList<>();
-            param.getCombMats().forEach(elem -> {
-                DetlDto detlDto = new DetlDto(elem.getMatNo(), elem.getBatch(), elem.getCount());
-                if (DetlDto.has(detlDtos, detlDto)) {
-                    DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch());
-                    assert one != null;
-                    one.setAnfme(one.getAnfme() + detlDto.getAnfme());
-                } else {
-                    detlDtos.add(detlDto);
-                }
-            });
-
-            for (DetlDto detlDto : detlDtos) {
-                MatCode matCode = matCodeService.selectById(detlDto.getMatnr());
-                if (Cools.isEmpty(matCode)) {
-                    throw new CoolException("鐗╂枡鏁版嵁閿欒");
-                }
-                WaitPakin waitPakin = new WaitPakin();
-                waitPakin.setZpallet(param.getBarcode());   // 鎵樼洏鐮�
-                waitPakin.setIoStatus("N");     // 鍏ュ嚭鐘舵��
-                waitPakin.setAnfme(detlDto.getAnfme());  // 鏁伴噺
-                waitPakin.setStatus("Y");    // 鐘舵��
-                waitPakin.setAppeUser(userId);
-                waitPakin.setAppeTime(now);
-                waitPakin.setModiUser(userId);
-                waitPakin.setModiTime(now);
-                VersionUtils.setWaitPakIn(waitPakin, matCode);
-                if (!waitPakinService.insert(waitPakin)) {
-                    throw new CoolException("淇濆瓨鏁版嵁澶辫触");
-                }
-            }
         // 鍏宠仈缁勬墭
         } else {
             Order order = orderService.selectByNo(param.getOrderNo());
@@ -95,16 +106,16 @@
             param.getCombMats().forEach(elem -> {
 
                 // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙
-                OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), elem.getMatNo(), elem.getBatch());
-                if (elem.getCount() > orderDetl.getEnableQty()) {
+                OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), elem.getMatnr(), elem.getBatch());
+                if (elem.getAnfme() > orderDetl.getEnableQty()) {
                     throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�");
                 }
                 // 淇敼璁㈠崟鏄庣粏鏁伴噺
-                if (!orderDetlService.increase(order.getId(), elem.getMatNo(), elem.getBatch(), elem.getCount())) {
+                if (!orderDetlService.increase(order.getId(), elem.getMatnr(), elem.getBatch(), elem.getAnfme())) {
                     throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触");
                 }
 
-                DetlDto detlDto = new DetlDto(elem.getMatNo(), elem.getBatch(), elem.getCount());
+                DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme());
                 if (DetlDto.has(detlDtos, detlDto)) {
                     DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch());
                     assert one != null;
@@ -113,14 +124,306 @@
                     detlDtos.add(detlDto);
                 }
             });
+
+            orderService.updateSettle(order.getId(), 2L, userId);
+        }
+
+        LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O"));
+        if (Cools.isEmpty(locMast1)) {
+            throw new CoolException("鏈壘鍒版纭殑搴撲綅淇℃伅");
+        }
+
+        int workNo = commonService.getWorkNo(0);
+
+        // 鐢熸垚宸ヤ綔妗�
+        WrkMast wrkMast = new WrkMast();
+        wrkMast.setWrkNo(workNo);
+        wrkMast.setIoTime(new Date());
+        wrkMast.setWrkSts(9L); // 宸ヤ綔鐘舵�侊細鐢熸垚鍏ュ簱ID
+        wrkMast.setIoType(1); // 鍏ュ嚭搴撶姸鎬侊細1.鍏ュ簱
+        Double ioPri = wrkMastService.getIoPri(1, locMast1.getLocNo());
+        wrkMast.setIoPri(ioPri); // 浼樺厛绾�
+        wrkMast.setCrnNo(locMast1.getCrnNo());
+        wrkMast.setOutMost(locMastService.isOutMost(locMast1.getLocNo(), true)?1:0);;
+        wrkMast.setSourceStaNo(null);
+        wrkMast.setStaNo(null);
+        wrkMast.setLocNo(locMast1.getLocNo());
+        wrkMast.setBarcode(param.getBarcode()); // 鎵樼洏鐮�
+        wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+        wrkMast.setPicking("N"); // 鎷f枡
+        wrkMast.setExitMk("N"); // 閫�鍑�
+        wrkMast.setEmptyMk("N"); // 绌烘澘
+        wrkMast.setLinkMis("Y");
+        wrkMast.setCtnType(null); // 瀹瑰櫒绫诲瀷
+        // 鎿嶄綔浜哄憳鏁版嵁
+        wrkMast.setAppeTime(now);
+        wrkMast.setModiTime(now);
+        boolean res = wrkMastService.insert(wrkMast);
+        if (!res) {
+            throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�");
+        }
+
+
+        for (CombParam.CombMat paramMat : param.getCombMats() )
+        {
+            Mat mat = matService.selectByMatnr(paramMat.getMatnr());
+            if (Cools.isEmpty(mat)) {
+                throw new CoolException(paramMat.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�");
+            }
+
+            // 鐢熸垚宸ヤ綔妗f槑缁�
+            WrkDetl wrkDetl = new WrkDetl();
+            wrkDetl.sync(mat);
+            wrkDetl.setAnfme(paramMat.getAnfme());
+            wrkDetl.setZpallet(param.getBarcode());
+//        wrkDetl.setAnfme(1.0D);
+            wrkDetl.setWrkNo(wrkMast.getWrkNo());
+            wrkDetl.setIoTime(wrkMast.getIoTime());
+            wrkDetl.setAppeTime(now);
+            wrkDetl.setModiTime(now);
+            if (!wrkDetlService.insert(wrkDetl)) {
+                throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触");
+            }
+        }
+
+//        // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ===>> Y
+//        Wrapper<WaitPakin> wrapper = new EntityWrapper<WaitPakin>()
+//                .eq("zpallet", barcode);
+//        WaitPakin setParam = new WaitPakin();
+//        setParam.setIoStatus("Y");
+//        setParam.setModiTime(now);
+//        if (!waitPakinService.update(setParam, wrapper)) {
+//            throw new CoolException("鏇存柊閫氱煡妗eけ璐�");
+//        }
+
+
+        // 鏇存柊鐩爣搴撲綅鐘舵��
+
+        if (locMast1.getLocSts().equals("O")){
+            locMast1.setLocSts("S"); // S.鍏ュ簱棰勭害
+            locMast1.setModiTime(now);
+            if (!locMastService.updateById(locMast1)){
+                throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�");
+            }
+        } else {
+            throw new CoolException(locMast1.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤");
+        }
+
+
+
+    }
+
+    @Override
+    @Transactional
+    public void adjust(MobileAdjustParam param, Long userId) {
+        BasDevp basDevp = basDevpService.selectById(param.getStaNo());
+        if (null == basDevp || basDevp.getWrkNo() == null) {
+            throw new CoolException(param.getStaNo() + "鐩樼偣绔欐棤鏁�");
+        }
+        if (!param.getWrkNo().equals(basDevp.getWrkNo())) {
+            throw new CoolException(param.getStaNo() + "鐩樼偣绔欐洿鏂帮紝璇烽噸鏂版绱�");
+        }
+        WrkMast wrkMast = wrkMastService.selectById(param.getWrkNo());
+        if (wrkMast.getWrkSts() < 10) {
+            throw new CoolException("鐩樼偣鏃犳晥锛屼换鍔″凡鐩樼偣鍐嶅叆搴�");
+        }
+        Date now = new Date();
+        List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
+
+        List<WrkDetl> list = param.getWrkDetls();
+
+        // 淇敼鏁伴噺
+        Iterator<WrkDetl> iterator = wrkDetls.iterator();
+        while (iterator.hasNext()) {
+            WrkDetl wrkDetl = iterator.next();
+            Iterator<WrkDetl> iterator1 = list.iterator();
+            while (iterator1.hasNext()) {
+                WrkDetl wrkDetl1 = iterator1.next();
+                if (wrkDetl1.getAnfme() == 0) {
+                    iterator1.remove();
+                }
+                if (wrkDetl.getMatnr().equals(wrkDetl1.getMatnr()) && Cools.eq(wrkDetl.getBatch(), wrkDetl1.getBatch())) {
+                    if (!wrkDetl.getAnfme().equals(wrkDetl1.getAnfme())) {
+                        // todo 鐩樼偣璁板綍銆佷繚瀛樿皟鏁磋褰�
+                        // 淇敼鏄庣粏
+                        if (!wrkDetlService.updateAnfme(wrkDetl1.getAnfme(), wrkMast.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) {
+                            throw new CoolException(wrkMast.getWrkNo() + "鐩樼偣浠诲姟锛�" + wrkDetl.getMatnr() + "鍟嗗搧锛�" + wrkDetl.getBatch() + "搴忓垪鐮佷慨鏀规暟閲忓け璐�");
+                        }
+                    }
+                    iterator.remove();
+                    iterator1.remove();
+                }
+            }
+        }
+
+        // 鍒犻櫎鏄庣粏
+        for (WrkDetl wrkDetl : wrkDetls) {
+            // todo 鐩樼偣璁板綍銆佷繚瀛樿皟鏁磋褰�
+            if (!wrkDetlService.updateAnfme(-1.0D, wrkMast.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) {
+                throw new CoolException("鍒犻櫎" + wrkMast.getWrkNo() + "鐩樼偣浠诲姟锛�" + wrkDetl.getMatnr() + "鍟嗗搧锛�" + wrkDetl.getBatch() + "搴忓垪鐮佷换鍔℃槑缁嗗け璐�");
+            }
+        }
+
+        // 娣诲姞鏄庣粏
+        for (WrkDetl wrkDetl : list) {
+            if (wrkDetl.getAnfme() == 0.0D) { continue; }
+            // todo 鐩樼偣璁板綍銆佷繚瀛樿皟鏁磋褰�
+            String orderNo = wrkDetl.getOrderNo();
+            Mat mat = matService.selectByMatnr(wrkDetl.getMatnr());
+            wrkDetl.sync(mat);
+            wrkDetl.setOrderNo(orderNo);
+            wrkDetl.setModiTime(now);
+            wrkDetl.setModiUser(userId);
+            wrkDetl.setAppeTime(now);
+            wrkDetl.setAppeUser(userId);
+            if (!wrkDetlService.insert(wrkDetl)) {
+                throw new CoolException("娣诲姞" + wrkMast.getWrkNo() + "鐩樼偣浠诲姟锛�" + wrkDetl.getMatnr() + "鍟嗗搧锛�" + wrkDetl.getBatch() + "搴忓垪鐮佷换鍔℃槑缁嗗け璐�");
+            }
+        }
+
+        // 淇敼鐩樼偣浠诲姟涓绘。鐘舵��
+        wrkMast.setFullPlt(wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()).size() != 0?"Y":"N");
+        wrkMast.setModiTime(now);
+        wrkMast.setModiUser(userId);
+        if (!wrkMastService.updateById(wrkMast)) {
+            throw new CoolException("淇敼鐩樼偣浠诲姟涓绘。澶辫触");
+        }
+
+    }
+
+    @Override
+    @Transactional
+    public void packComb(CombParam param, Long userId) {
+        if (Cools.isEmpty(param.getBarcode(), param.getCombMats())) {
+            throw new CoolException(BaseRes.PARAM);
+        }
+        // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁
+        if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>().
+                eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) {
+            throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱");
+        }
+        Date now = new Date();
+
+        boolean packDown = Parameter.get().getPackDown().equals("true");
+
+        // 鏃犲崟缁勬墭
+        if (Cools.isEmpty(param.getOrderNo())) {
+
+            // 鐢熸垚鍏ュ簱閫氱煡妗�
+            List<DetlDto> detlDtos = new ArrayList<>();
+            param.getCombMats().forEach(elem -> {
+                // 鎵撳寘涓婄嚎鏁版嵁鏍¢獙
+                if (packDown) {
+                    Pack pack = packService.selectByBarcode(elem.getMatnr());
+                    if (pack == null) {
+                        throw new CoolException(elem.getMatnr() + "鏉$爜鍐椾綑锛岃妫�鏌ワ紒");
+                    }
+                    if (pack.getSettle() != 1) {
+                        throw new CoolException(elem.getMatnr() + "鏉$爜宸蹭笅绾匡紝璇锋鏌ワ紒");
+                    }
+                }
+                Mat analyse = MatUtils.analyseMat(elem.getMatnr());
+                // 鏉$爜銆佺墿鏂欎唬鐮併�佸簭鍒楀彿銆佹暟閲�
+                DetlDto detlDto = new DetlDto(elem.getMatnr(), analyse.getMatnr(), analyse.getBarcode(), elem.getAnfme());
+//                DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme());
+                if (DetlDto.has(detlDtos, detlDto)) {
+                    DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch());
+                    assert one != null;
+                    one.setAnfme(one.getAnfme() + detlDto.getAnfme());
+                } else {
+                    detlDtos.add(detlDto);
+                }
+            });
+
+            if (packDown) {
+                MesCombParam mesCombParam = new MesCombParam();
+                mesCombParam.setZpallet(param.getBarcode());
+                mesCombParam.setPakinTime(DateUtils.convert(now));
+                mesCombParam.setLgort("5008");
+                mesCombParam.setPlantCode("5000");
+                mesCombParam.setFromCode("5012-20");
+                mesCombParam.setStationCode("JJQ-PFZPDB-XX");
+                for (DetlDto detlDto : detlDtos) {
+                    mesCombParam.getList().add(new MesCombParam.Detl(detlDto.getOrderNo(), detlDto.getAnfme()));
+                }
+                String response = "";
+                boolean success = false;
+                try {
+                    response = new HttpHandler.Builder()
+                            .setUri(MesConstant.URL)
+                            .setPath(MesConstant.PACK_DOWN_URL)
+                            .setJson(JSON.toJSONString(mesCombParam))
+                            .build()
+                            .doPost();
+                    JSONObject jsonObject = JSON.parseObject(response);
+                    if (jsonObject.getInteger("code").equals(200)) {
+                        success = true;
+                    } else if (jsonObject.getInteger("code").equals(500)) {
+                        log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response);
+                        throw new CoolException(jsonObject.getString("msg"));
+                    } else {
+                        log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response);
+                        throw new CoolException("涓婃姤mes绯荤粺澶辫触");
+                    }
+                } catch (Exception e) {
+                    log.error("fail", e);
+                    throw new CoolException(e.getMessage());
+                } finally {
+                    try {
+                        // 淇濆瓨鎺ュ彛鏃ュ織
+                        apiLogService.save(
+                                "鎵撳寘涓嬬嚎甯墭涓婃姤",
+                                MesConstant.URL + MesConstant.PACK_DOWN_URL,
+                                null,
+                                "127.0.0.1",
+                                JSON.toJSONString(mesCombParam),
+                                response,
+                                success
+                        );
+                    } catch (Exception e) { log.error("", e); }
+                }
+
+            }
+
+            // 鐢熸垚鍏ュ簱鍗曟嵁
+            String orderNo = "PACK" + snowflakeIdWorker.nextId();
+            OpenOrderPakinParam openParam = new OpenOrderPakinParam();
+            openParam.setOrderNo(orderNo);
+            openParam.setOrderTime(DateUtils.convert(now));
+            openParam.setOrderType("鎵撳寘鍏ュ簱鍗�");
+            openParam.setOrderDetails(detlDtos);
+            openService.pakinOrderCreate(openParam);
+            Order order = orderService.selectByNo(orderNo);
+            if (null == order) {
+                throw new CoolException("鐢熸垚鍗曟嵁澶辫触");
+            }
+            if (!orderService.updateSettle(order.getId(), 2L, userId)) {
+                throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�");
+            }
+
+            // 鐢熸垚鍏ュ簱閫氱煡妗�
             for (DetlDto detlDto : detlDtos) {
-                MatCode matCode = matCodeService.selectById(detlDto.getMatnr());
-                if (Cools.isEmpty(matCode)) {
-                    throw new CoolException("鐗╂枡鏁版嵁閿欒");
+
+                // 淇敼浣滀笟鏁伴噺 ----------------------------------------
+                // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙
+                OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), detlDto.getMatnr(), detlDto.getBatch());
+                if (detlDto.getAnfme() > orderDetl.getEnableQty()) {
+                    throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�");
+                }
+                // 淇敼璁㈠崟鏄庣粏鏁伴噺
+                if (!orderDetlService.increase(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) {
+                    throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触");
+                }
+
+                // 淇濆瓨鍏ュ簱閫氱煡妗�
+                Mat mat = matService.selectByMatnr(detlDto.getMatnr());
+                if (Cools.isEmpty(mat)) {
+                    throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�");
                 }
                 WaitPakin waitPakin = new WaitPakin();
-                waitPakin.setOrderNo(order.getOrderNo());   // 鍗曟嵁缂栧彿
-                waitPakin.setBatch(detlDto.getBatch());     // 鎵瑰彿
+                waitPakin.sync(mat);
+                waitPakin.setOrderNo(orderNo);
+                waitPakin.setBatch(detlDto.getBatch());
                 waitPakin.setZpallet(param.getBarcode());   // 鎵樼洏鐮�
                 waitPakin.setIoStatus("N");     // 鍏ュ嚭鐘舵��
                 waitPakin.setAnfme(detlDto.getAnfme());  // 鏁伴噺
@@ -129,14 +432,20 @@
                 waitPakin.setAppeTime(now);
                 waitPakin.setModiUser(userId);
                 waitPakin.setModiTime(now);
-                VersionUtils.setWaitPakIn(waitPakin, matCode);
                 if (!waitPakinService.insert(waitPakin)) {
-                    throw new CoolException("淇濆瓨鏁版嵁澶辫触");
+                    throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
+                }
+                // 淇敼鎵撳寘鏁版嵁鐘舵��
+                Pack pack = packService.selectByBarcode(detlDto.getOrderNo());
+                pack.setSettle(2L);
+                pack.setUpdateTime(now);
+                pack.setUpdateBy(userId);
+                if (!packService.updateById(pack)) {
+                    throw new CoolException("淇敼鎵撳寘鏁版嵁寮傚父");
                 }
             }
 
         }
-
     }
 
 }

--
Gitblit v1.9.1