From f25bd904560faada2a00e93fbd8abab6be238f9c Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期二, 15 四月 2025 15:44:31 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/MobileController.java |  306 ++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 276 insertions(+), 30 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java
index e0ce184..42d7241 100644
--- a/src/main/java/com/zy/asrs/controller/MobileController.java
+++ b/src/main/java/com/zy/asrs/controller/MobileController.java
@@ -1,23 +1,26 @@
 package com.zy.asrs.controller;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.mapper.Wrapper;
 import com.core.annotations.ManagerAuth;
+import com.core.common.BaseRes;
 import com.core.common.Cools;
 import com.core.common.R;
 import com.core.exception.CoolException;
 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.*;
 import com.zy.asrs.entity.result.MobileAdjustResult;
+import com.zy.asrs.mapper.ManLocDetlMapper;
 import com.zy.asrs.service.*;
+import com.zy.asrs.utils.OrderInAndOutUtil;
+import com.zy.common.model.WrkDto;
 import com.zy.common.web.BaseController;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Resource;
 import java.util.*;
 
 /**
@@ -35,8 +38,6 @@
     @Autowired
     private LocDetlService locDetlService;
     @Autowired
-    private OrderService orderService;
-    @Autowired
     private DocTypeService docTypeService;
     @Autowired
     private WrkMastService wrkMastService;
@@ -46,39 +47,196 @@
     private BasDevpService basDevpService;
     @Autowired
     private PackService packService;
+    @Autowired
+    private ManLocDetlMapper manLocDetlMapper;
+    @Autowired
+    private WrkDetlLogService wrkDetlLogService;
 
-    // 缁勬墭 ----------------------------------------------------------------------------------------------------
+    @Resource
+    private StaDescService staDescService;
 
-    /**
-     * 鏍规嵁鍗曞彿妫�绱㈠崟鎹暟鎹�
-     * http://localhost:8081/jkwms/mobile/order/serach/orderNo/auth?orderNo=123123
-     */
+    @RequestMapping("/pda/WarehouseOut/v1")
+    @ManagerAuth(memo = "骞舵澘閫斾腑鎷f枡-鍙傝�冨康鍒�")
+    public R WarehouseOutV1(@RequestBody CombParam combParam) {
+        return mobileService.WarehouseOutV1(combParam, getHostId(), getUserId());
+    }
+
+    @RequestMapping("/pda/WarehouseOutPickMerge/v1")
+    @ManagerAuth(memo = "鎷f枡閫斾腑骞舵澘")
+    public R WarehouseOutPickMergeV1(@RequestBody WarehouseOutPickMergeParam param) {
+        if (Cools.isEmpty(param,param.getLocNo(),param.getBarcode(),param.getCombMats())) {
+            return R.parse("鍙傛暟涓嶈兘涓虹┖锛�");
+        }
+        return mobileService.WarehouseOutPickMergeV1(param, getHostId(), getUserId());
+    }
+
+    @RequestMapping("/pick/in")
+    @ManagerAuth(memo = "骞舵澘鍏ュ簱")
+    public R pickConfirm(@RequestBody PickConfirmParam param) {
+
+        if(Cools.isEmpty(param,param.getList(),param.getLocNo(),param.getStaNo())) {
+            return R.parse("鍙傛暟涓嶅畬鏁�");
+        }
+        return mobileService.pickConfirm(param, getUserId());
+    }
+
+    @RequestMapping("/barcode/list/all")
+    @ManagerAuth(memo = "骞舵澘鍏ュ簱閫斾腑鎷f枡鍑哄簱鑾峰彇浠诲姟淇℃伅")
+    public R orderOutListOrder(@RequestParam(required = false) String barcode) {
+        return mobileService.orderOutListOrder(barcode, getUserId());
+    }
+
+    @RequestMapping("/barcode/list/pick")
+    @ManagerAuth(memo = "鎷f枡鍏ュ簱閫斾腑骞舵澘鑾峰彇浠诲姟淇℃伅")
+    public R orderOutListOrderPick(@RequestParam(required = false) String barcode) {
+        return mobileService.orderOutListOrderPick(barcode, getUserId());
+    }
+
+    @RequestMapping("/loc/f/list")
+    @ManagerAuth(memo = "鑾峰彇鍦ㄥ簱搴撲綅")
+    public R locNoF(@RequestParam(required = false) String locNo) {
+        Wrapper<LocMast> wrapper = new EntityWrapper<LocMast>()
+                .eq("loc_sts", "F");
+        if (!Cools.isEmpty(locNo)) {
+            wrapper.like("loc_no", locNo);
+        }
+        List<LocMast> list = locMastService.selectList(wrapper);
+        return R.ok().add(list);
+    }
+
+    @RequestMapping("/pick/sta/list")
+    @ManagerAuth(memo = "鑾峰彇骞舵澘绔�")
+    public R pickSta() {
+        List<StaDesc> list = staDescService.selectList(new EntityWrapper<StaDesc>()
+                .eq("type_no", 104));
+        return R.ok().add(list);
+    }
+
+    @RequestMapping("/pick/mat/list")
+    @ManagerAuth(memo = "鑾峰彇骞舵澘鐗╂枡")
+    public R pickMats(@RequestParam(required = false) String matnr, @RequestParam(required = false) String orderNo) {
+        return mobileService.pickMats(matnr, orderNo);
+    }
+
+    // 鍟嗗搧涓婃灦
+    @RequestMapping("/mat/onSale/auth")
+    @ManagerAuth
+    public R matOnSale(@RequestBody CombParam combParam){
+        mobileService.onSale(combParam);
+        return R.ok("涓婃灦鎴愬姛");
+    }
+    // 鍟嗗搧涓嬫灦
+    @RequestMapping("/mat/offSale/auth")
+    //@ManagerAuth
+    public R matOffSale(@RequestBody OffSaleParam offSaleParam){
+        mobileService.offSale(offSaleParam);
+        return R.ok("涓嬫灦鎴愬姛");
+    }
+
     @RequestMapping("/order/search/orderNo/auth")
     @ManagerAuth
     public R orderSearchByBarcode(@RequestParam String orderNo){
-        Order order = orderService.selectByNo(orderNo);
-        if (order == null) {
+        if (Cools.isEmpty(orderNo)){
+            orderNo=null;
+        }
+//        List<Order> orders = orderService.selectorderNoL(orderNo);
+        List<Order> orders = OrderInAndOutUtil.selectOrderNoL(null, orderNo);
+        if (Cools.isEmpty(orders)){
             return R.ok();
         }
-        DocType docType = docTypeService.selectById(order.getDocType());
-        if (docType.getPakin() == null || docType.getPakin() != 1) {
-            return R.ok();
+        LinkedList<CombParam> combParams = new LinkedList<>();
+        if (!Cools.isEmpty(orders)){
+            for (Order order:orders){
+                CombParam combParam=new CombParam();
+                if (order == null) {
+                    continue;
+                }
+                DocType docType = docTypeService.selectById(order.getDocType());
+                if (docType.getPakin() == null || docType.getPakin() != 1) {
+                    continue;
+                }
+                if (order.getSettle() > 2) {
+                    continue;
+                }
+//                List<OrderDetl> orderDetls = orderService.selectWorkingDetls(order.getId());
+                List<OrderDetl> orderDetls = OrderInAndOutUtil.selectWorkingDetls(order.getPakinPakoutStatus$(), order.getId());
+                if (!Cools.isEmpty(orderDetls)) {
+                    LinkedList<CombParam.CombMat> combMats = new LinkedList<>();
+                    for (OrderDetl orderDetl:orderDetls){
+                        CombParam.CombMat combMat = new CombParam.CombMat();
+                        combMat.setMatnr(orderDetl.getMatnr());
+                        combMat.setBatch(orderDetl.getBatch());
+                        combMat.setAnfme(orderDetl.getAnfme()-orderDetl.getWorkQty());
+                        combMat.setMaktx(orderDetl.getMaktx());
+                        combMat.setSpecs(orderDetl.getSpecs());
+                        combMat.setBrand(orderDetl.getBrand());
+                        combMat.setSku(orderDetl.getSku());
+                        combMat.setMemo(orderDetl.getMemo());
+                        combMat.setBoxType1(orderDetl.getBoxType1());
+                        combMat.setBoxType2(orderDetl.getBoxType2());
+                        combMat.setBoxType3(orderDetl.getBoxType3());
+                        combMat.setStandby1(orderDetl.getStandby1());
+                        combMat.setStandby2(orderDetl.getStandby2());
+                        combMat.setStandby3(orderDetl.getStandby3());
+                        combMats.add(combMat);
+                    }
+                    combParam.setCombMats(combMats);
+                }
+                combParam.setOrderNo(order.getOrderNo());
+                return R.ok().add(combParam);
+
+//                combParams.add(combParam);
+            }
         }
-        if (order.getSettle() > 2) {
-            return R.ok();
-        }
-        List<OrderDetl> orderDetls = orderService.selectWorkingDetls(order.getId());
-        if (Cools.isEmpty(orderDetls)) {
-            return R.ok();
-        }
-        return R.ok().add(orderDetls);
+        return R.ok().add(combParams);
     }
 
     @RequestMapping("/comb/auth")
     @ManagerAuth(memo = "缁勬墭")
     public R comb(@RequestBody CombParam combParam){
+//        mobileService.comb(combParam, getUserId());
         mobileService.comb(combParam, getUserId());
         return R.ok("缁勬墭鎴愬姛");
+    }
+
+    @RequestMapping("/kitting/query/auth")
+    @ManagerAuth(memo = "榻愬鍏ュ簱鏌ヨ")
+    public R kittingQuery(@RequestBody CombParam combParam){
+        try {
+            return mobileService.kittingQuery(combParam, getUserId());
+        } catch (Exception e){
+
+        }
+//        return R.ok("榻愬鍏ュ簱鏌ヨ鎴愬姛");
+        return R.error("榻愬鍏ュ簱鏌ヨ澶辫触");
+    }
+
+    @RequestMapping("/kitting/call/auth")
+    @ManagerAuth(memo = "榻愬鍏ュ簱鍛煎彨")
+    public R kittingCall(@RequestParam("locNo") String locNo){
+        mobileService.kittingCall(locNo, getUserId());
+        return R.ok("榻愬鍏ュ簱鍛煎彨鎴愬姛");
+    }
+
+    @RequestMapping("/kitting/call/all/auth")//瀵�  鍓嶇鏀逛笉浜嗕竴鐐�
+    @ManagerAuth(memo = "榻愬鍏ュ簱鍛煎彨")
+    public R kittingCall(@RequestBody CombParam combParam){
+        List<CombParam.CombMat> combMats = combParam.getCombMats();
+        for (CombParam.CombMat locDetl : combMats) {
+            mobileService.kittingCall(locDetl.getMemo(), getUserId());
+        }
+        return R.ok("榻愬鍏ュ簱鍛煎彨鎴愬姛");
+    }
+    @RequestMapping("/loc/origin/query/auth")
+    @ManagerAuth(memo = "搴撳瓨鏌ヨ")
+    public R locOriginQuery(@RequestParam("barcode") String barcode){
+        List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("zpallet", barcode));
+        return R.ok("鍦ㄥ簱鏍囪淇敼鎴愬姛").add(locDetlList);
+    }
+    @RequestMapping("/loc/origin/in/out/auth")
+    @ManagerAuth(memo = "鍦ㄥ簱鏍囪淇敼")
+    public R locOriginInOut(@RequestBody LocDetl locDetl){
+        return mobileService.locOriginInOut(locDetl, getUserId());
     }
 
     @RequestMapping("/pack/get/auth")
@@ -141,10 +299,55 @@
         if (wrkMast != null) {
             List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());
             // 鍘婚櫎宸插嚭搴撶‘璁ょ殑鏄庣粏
-            wrkDetls.removeIf(wrkDetl -> wrkDetl.getInspect() == 1);
+            wrkDetls.removeIf(wrkDetl -> wrkDetl.getInspect() != null && wrkDetl.getInspect() != 0);
             return R.ok().add(Cools.add("wrkNo", wrkMast.getWrkNo()).add("ioType", wrkMast.getIoType()).add("list", wrkDetls));
         }
         return R.ok();
+    }
+
+    /**
+     * 鍑哄簱纭 - 鎵揣鐗�  骞垮痉瀹滅鐗�
+     * 1.鍏ㄦ澘 杩斿洖 101
+     * 2.鎷f枡 杩斿洖 103
+     */
+    @RequestMapping("/pakout/confirm/goods/auth")       //寰呭畬鍠�  鍘熷洜锛堝鎴锋湭缁欏嚭璇︾粏淇℃伅锛�
+    @ManagerAuth
+    public R pakoutQueryByGoods(@RequestBody GDYKConfirmGoodsParam combParam){
+        if (Cools.isEmpty(combParam)) {
+            return R.ok();
+        }
+//        List<Order> orders = orderService.selectorderNoL(batch);
+//        OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("matnr", combParam.getMatnr()).eq("batch", combParam.getBatch()).eq("order_no",combParam.getOrderNo()));
+        Order order = OrderInAndOutUtil.selectByNo(Boolean.FALSE, combParam.getOrderNo());
+        List<OrderDetl> orderDetlList = OrderInAndOutUtil.selectByOrderId(Boolean.FALSE, order.getId());
+        OrderDetl orderDetl = null;
+        for (OrderDetl orderDetl1 : orderDetlList){
+            if (combParam.getMatnr().equals(orderDetl1.getMatnr()) && combParam.getBatch().equals(orderDetl1.getBatch())){
+                orderDetl = orderDetl1;
+                break;
+            }
+        }
+        if (Cools.isEmpty(orderDetl)){
+            return R.error("鏈煡鍒版暟鎹�");
+        }
+        if (!orderDetl.getQty$().equals("宸插畬鎴�")){
+            return R.error("浠诲姟鏈畬鎴�");
+        }
+        //澶嶆牳鏁�
+        orderDetl.setSource(1);
+//        orderDetlService.updateById(orderDetl);
+        OrderInAndOutUtil.updateOrderDetl(Boolean.FALSE,order,orderDetl);
+        return R.ok();
+    }
+
+    // 鏍规嵁搴撲綅鐮佸拰鍟嗗搧鐮佹悳绱㈠晢鍝�
+    @RequestMapping("/mat/find/auth")
+    public R find(@RequestParam(required = false) String locNo
+            , @RequestParam(required = false) String matnr){
+        //List<ManLocDetl> manLocDetls = manLocDetlMapper.selectItem0(locNo, matnr);
+        ManLocDetl manLocDetl = manLocDetlMapper.selectLocNo0(locNo, matnr);
+        return R.ok(manLocDetl);
+        //return R.ok(manLocDetlMapper.selectItem0(locNo, matnr));
     }
 
     /**
@@ -197,12 +400,46 @@
         if (Cools.isEmpty(list)) {
             return R.ok();
         }
-        // todo:luxiaotao 鎷f枡鍑哄簱鍙慨鏀瑰伐浣滄。鏄庣粏
         Set<Integer> wrkNos = new HashSet<>();
+        List<WrkDto> dtos = new ArrayList<>();
         for (WrkDetl wrkDetl : list) {
-            wrkNos.add(wrkDetl.getWrkNo());
-            wrkDetlService.updateInspect(wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch());
+            if (wrkNos.contains(wrkDetl.getWrkNo())) {
+                for (WrkDto dto : dtos) {
+                    if (dto.getWrkNo().equals(wrkDetl.getWrkNo())) {
+                        dto.getWrkDetls().add(wrkDetl);
+                        break;
+                    }
+                }
+            } else {
+                wrkNos.add(wrkDetl.getWrkNo());
+                dtos.add(new WrkDto(wrkDetl.getWrkNo(), wrkDetl));
+            }
         }
+
+        for (WrkDto dto : dtos) {
+            WrkMast wrkMast = wrkMastService.selectById(dto.getWrkNo());
+            if (wrkMast != null) {
+                // 101
+                if (wrkMast.getIoType() == 101) {
+                    for (WrkDetl wrkDetl : dto.getWrkDetls()) {
+                        wrkDetlService.updateInspect(wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch());
+                    }
+                }
+                // 103
+                if (wrkMast.getIoType() == 103) {
+                    if (!wrkDetlService.delete(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()))) {
+                        throw new CoolException("鎷f枡鍑哄簱纭澶辫触");
+                    }
+                    for (WrkDetl wrkDetl : dto.getWrkDetls()) {
+                        wrkDetl.setInspect(1);
+                        if (!wrkDetlService.insert(wrkDetl)) {
+                            throw new CoolException("鎷f枡鍑哄簱纭澶辫触");
+                        }
+                    }
+                }
+            }
+        }
+
         for (Integer wrkNo : wrkNos) {
             WrkMast wrkMast = wrkMastService.selectById(wrkNo);
             if (wrkMast.getWrkSts() == 14 && (Cools.isEmpty(wrkMast.getInvWh()) || wrkMast.getInvWh().equals("N"))) {
@@ -259,5 +496,14 @@
         return R.ok("鐩樼偣鎴愬姛");
     }
 
+    @PostMapping("/order/out/pakout/auth")
+    @ManagerAuth(memo = "璁㈠崟鍑哄簱")
+    public synchronized R pakoutByOrder(@RequestBody JSONObject param) {
+        if(!param.containsKey("staNo") || !param.containsKey("orderNo")){
+            return R.parse(BaseRes.PARAM);
+        }
+        mobileService.pakoutByOrder(param,getUserId());
+        return R.ok("鍑哄簱鎴愬姛");
+    }
 
 }

--
Gitblit v1.9.1