From d8c9b9afb41c368a08d7e05d0f624c98bf72042a Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期五, 06 六月 2025 11:18:56 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/OpenController.java |   96 ++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 92 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 8ebafbe..6cdf87b 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -1,21 +1,31 @@
 package com.zy.asrs.controller;
 
 import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.annotations.AppAuth;
-import com.core.common.*;
+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.LocMast;
 import com.zy.asrs.entity.param.*;
+import com.zy.asrs.service.LocDetlService;
+import com.zy.asrs.service.LocMastService;
 import com.zy.asrs.service.OpenService;
-import com.zy.common.model.DetlDto;
 import com.zy.common.web.BaseController;
+import com.zy.system.entity.Config;
+import com.zy.system.service.ConfigService;
+import lombok.Synchronized;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import java.math.BigDecimal;
 import java.util.ArrayList;
-import java.util.Date;
+import java.util.Arrays;
 import java.util.List;
+import java.util.Map;
 
 /**
  * Created by vincent on 2022/4/8
@@ -33,11 +43,70 @@
     @Autowired
     private OpenService openService;
 
+    @Autowired
+    private ConfigService configService;
+
+    @Autowired
+    private LocMastService locMastService;
+
+    @Deprecated
+    @PostMapping("/grouping")
+    @AppAuth(memo = "AGV缁勬墭璋冪敤")
+    public synchronized R grouping(@RequestHeader(required = false) String appkey,
+                                   @RequestBody(required = false) AgvGroupingParam param,
+                                   HttpServletRequest request) {
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param.getOrderNo())) {
+            param.setOrderNo(param.getBillNo());
+        }
+        List<AgvGroupingParam.CombMat> combMats = param.getCombMats();
+        combMats.forEach(elem -> {
+            if (Cools.isEmpty(elem.getBatch())) {
+                elem.setBatch(elem.getItemBatch());
+            }
+        });
+
+        return openService.grouping(param);
+    }
+
+    @PostMapping("/barcodeVerificatio")
+    @AppAuth(memo = "AGV璋冪敤鏍¢獙鏉$爜")
+    public synchronized R barcodeVerificatio(@RequestHeader(required = false) String appkey,
+                                             @RequestBody(required = false) Map<String, String> param,
+                                             HttpServletRequest request) {
+        auth(appkey, param, request);
+
+        // 鎵樼洏鏉$爜
+        String barcode = param.get("barcode");
+        if (Cools.isEmpty(barcode)) {
+            return R.parse("鏉$爜涓嶈兘涓虹┖");
+        }
+
+        return openService.barcodeVerificatio(barcode);
+    }
+
+    @PostMapping("/outbound")
+    @AppAuth(memo = "MES璋冪敤鍑哄簱")
+    public synchronized R outbound(@RequestHeader(required = false) String appkey,
+                                   @RequestBody(required = false) OutBoundParam param,
+                                   HttpServletRequest request) {
+        Config mesAuto = configService.selectConfigByCode("CLOSE_OUTBOUND");
+        if (mesAuto != null && mesAuto.getValue().equals("0")) {
+            return R.parse("鍏抽棴鑷姩鍑哄簱");
+        }
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param.getEndLocation(), param.getBarcode(), param.getOrderNo())) {
+            return R.parse(BaseRes.PARAM);
+        }
+
+        return openService.outbound(param);
+    }
+
     @PostMapping("/order/matSync/default/v1")
     @AppAuth(memo = "鍟嗗搧淇℃伅鍚屾鎺ュ彛")
     public synchronized R syncMatInfo(@RequestHeader(required = false) String appkey,
                                       @RequestBody(required = false) MatSyncParam param,
-                                      HttpServletRequest request){
+                                      HttpServletRequest request) {
         auth(appkey, param, request);
         if (Cools.isEmpty(param)) {
             return R.parse(BaseRes.PARAM);
@@ -151,6 +220,25 @@
         return R.ok().add(openService.queryStock());
     }
 
+
+    /**
+     * 杩斿洖搴撳瓨鍒╃敤鐜�
+     */
+    @Synchronized
+    @PostMapping("/stock/used/v1")
+    public R getRate(@RequestHeader(required = false) String appkey,
+                     @RequestBody(required = false) OpenOrderCompleteParam param,
+                     HttpServletRequest request) {
+        auth(appkey, param, request);
+        int i = locMastService.selectCount(new EntityWrapper<LocMast>().in("loc_sts", "O"));
+        int i1 = locMastService.selectCount(new EntityWrapper<LocMast>().in("loc_sts", Arrays.asList("D", "F", "P", "Q", "R", "S")));
+        BigDecimal dividend = new BigDecimal(i1 - i);
+        BigDecimal divisor = new BigDecimal(i1);
+        BigDecimal quotient = dividend.divide(divisor,4, BigDecimal.ROUND_HALF_UP);
+        return R.ok().add(quotient);
+    }
+
+
     private void auth(String appkey, Object obj, HttpServletRequest request) {
         log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj));
         request.setAttribute("cache", obj);

--
Gitblit v1.9.1