From c14c261181c9afb2e0d07c714e06c81a6417c8cd Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期四, 05 六月 2025 16:10:51 +0800
Subject: [PATCH] 对接mes物料信息

---
 src/main/java/com/zy/asrs/controller/MobileController.java |  171 +++++++++++++++++++++++++++++++++++++++-----------------
 1 files changed, 119 insertions(+), 52 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java
index 027c0fd..639e1d4 100644
--- a/src/main/java/com/zy/asrs/controller/MobileController.java
+++ b/src/main/java/com/zy/asrs/controller/MobileController.java
@@ -10,11 +10,12 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.CombParam;
+import com.zy.asrs.entity.param.GDYKConfirmGoodsParam;
 import com.zy.asrs.entity.param.MobileAdjustParam;
+import com.zy.asrs.entity.param.OffSaleParam;
 import com.zy.asrs.entity.result.MobileAdjustResult;
+import com.zy.asrs.mapper.ManLocDetlMapper;
 import com.zy.asrs.service.*;
-import com.zy.common.model.LocDto;
-import com.zy.common.model.TaskDto;
 import com.zy.common.model.WrkDto;
 import com.zy.common.web.BaseController;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -22,6 +23,7 @@
 import org.springframework.web.bind.annotation.*;
 
 import java.util.*;
+import java.util.List;
 
 /**
  * 绉诲姩绔帴鍙f帶鍒跺櫒
@@ -51,6 +53,28 @@
     private BasDevpService basDevpService;
     @Autowired
     private PackService packService;
+    @Autowired
+    private ManLocDetlMapper manLocDetlMapper;
+    @Autowired
+    private WrkDetlLogService wrkDetlLogService;
+
+
+    // 鍟嗗搧涓婃灦
+    @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("涓嬫灦鎴愬姛");
+    }
+
+
 
     // 缁勬墭 ----------------------------------------------------------------------------------------------------
 
@@ -58,25 +82,69 @@
      * 鏍规嵁鍗曞彿妫�绱㈠崟鎹暟鎹�
      * http://localhost:8081/jkwms/mobile/order/serach/orderNo/auth?orderNo=123123
      */
+//    @RequestMapping("/order/search/orderNo/auth")
+//    @ManagerAuth
+//    public R orderSearchByBarcode(@RequestParam String orderNo){
+//        Order order = orderService.selectByNo(orderNo);
+//        if (order == null) {
+//            return R.ok();
+//        }
+//        DocType docType = docTypeService.selectById(order.getDocType());
+//        if (docType.getPakin() == null || docType.getPakin() != 1) {
+//            return R.ok();
+//        }
+//        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);
+//    }
     @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);
+        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());
+                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());
+                        combMats.add(combMat);
+                    }
+                    combParam.setCombMats(combMats);
+                }
+                combParam.setOrderNo(order.getOrderNo());
+                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")
@@ -150,6 +218,41 @@
             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()));
+        if (Cools.isEmpty(orderDetl)){
+            return R.error("鏈煡鍒版暟鎹�");
+        }
+        if (!orderDetl.getQty$().equals("宸插畬鎴�")){
+            return R.error("浠诲姟鏈畬鎴�");
+        }
+        //澶嶆牳鏁�
+        orderDetl.setSource(1);
+        orderDetlService.updateById(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));
     }
 
     /**
@@ -299,49 +402,13 @@
     }
 
     @PostMapping("/order/out/pakout/auth")
-//    @ManagerAuth(memo = "鏍规嵁璁㈠崟鍑哄簱")
+    @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("鍑哄簱鎴愬姛");
-
-//        if (Cools.isEmpty(locDtos)) {
-//            return R.parse(BaseRes.PARAM);
-//        }
-//        boolean lack = true;
-//        for (LocDto locDto : locDtos) {
-//            if (!locDto.isLack()) {
-//                lack = false;
-//                break;
-//            }
-//        }
-//        if (lack) {
-//            return R.error("搴撳瓨涓嶈冻");
-//        }
-//
-//        Thread.sleep(1000L);
-//
-//        List<TaskDto> taskDtos = new ArrayList<>();
-//        // 鏍规嵁 锛堝簱浣� & 鍑哄簱绔欙級 鍒嗙粍锛� 鐞嗘兂鐘舵�侊細涓�缁勪负涓�娆″嚭搴撲换鍔�
-//        for (LocDto locDto : locDtos) {
-//            if (locDto.isLack()) { continue; }
-//            TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getStaNo(), locDto);
-//            if (TaskDto.has(taskDtos, taskDto)) {
-//                TaskDto dto = TaskDto.find(taskDtos, taskDto);
-//                assert dto != null;
-//                dto.getLocDtos().addAll(taskDto.getLocDtos());
-//            } else {
-//                taskDtos.add(taskDto);
-//            }
-//        }
-//        // -----------------------------------------------------------------------------------------------
-//        for (TaskDto taskDto : taskDtos) {
-//            BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
-//            workService.stockOut(staNo, taskDto, getUserId());
-//        }
-//        return R.ok();
     }
 
 }

--
Gitblit v1.9.1