From 9b14697f5146ade2e81db8269824f79c9bc6ac62 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期三, 27 十二月 2023 12:47:01 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |   63 +++++++++++++++++++++++++++----
 1 files changed, 55 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 5a46d16..ee02c94 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -1,8 +1,7 @@
 package com.zy.asrs.service.impl;
 
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.plugins.Page;
 import com.core.common.Cools;
 import com.core.common.DateUtils;
 import com.core.common.R;
@@ -11,15 +10,14 @@
 import com.zy.asrs.entity.*;
 import com.zy.asrs.entity.param.*;
 import com.zy.asrs.entity.result.InOutCountDto;
-import com.zy.asrs.entity.result.OpenOrderCompeteResult;
+import com.zy.asrs.entity.result.LocDetlAll;
 import com.zy.asrs.entity.result.StockVo;
+import com.zy.asrs.mapper.ReportQueryMapper;
 import com.zy.asrs.mapper.TagMapper;
 import com.zy.asrs.service.*;
 import com.zy.asrs.utils.MatUtils;
-import com.zy.asrs.utils.Utils;
 import com.zy.common.model.DetlDto;
 import com.zy.common.utils.NodeUtils;
-import com.zy.common.utils.Synchro;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -64,6 +62,8 @@
     private ManPakOutService manPakOutService;
     @Autowired
     private LocOwnerService locOwnerService;
+    @Autowired
+    private ReportQueryMapper reportQueryMapper;
 
     @Override
     @Transactional
@@ -81,6 +81,7 @@
                 if (Cools.isEmpty(locOwner)){
                     LocOwner locOwner1 = new LocOwner();
                     locOwner1.setOwner(detlDto.getOwnerName());
+                    locOwnerService.insert(locOwner1);
                 }
             }
         }
@@ -130,7 +131,8 @@
         List<DetlDto> list = new ArrayList<>();
         List<DetlDto> orderDetails = param.getOrderDetails();
         for (DetlDto detail : orderDetails) {
-            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme());
+            DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getOwnerName(),detail.getPayment());
+            dto.setBeBatch(detail.getBeBatch());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -171,6 +173,7 @@
             orderDetl.setPayment(detlDto.getPayment());
             orderDetl.setStatus(1);
             orderDetl.setQty(0.0D);
+            orderDetl.setBeBatch(detlDto.getBeBatch());
             orderDetl.setWeight(detlDto.getWeight());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
@@ -236,6 +239,7 @@
         List<DetlDto> orderDetails = param.getOrderDetails();
         for (DetlDto detail : orderDetails) {
             DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme());
+            dto.setBeBatch(detail.getBeBatch());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -262,6 +266,7 @@
             orderDetl.setUpdateTime(now);
             orderDetl.setStatus(1);
             orderDetl.setQty(0.0D);
+            orderDetl.setBeBatch(detlDto.getBeBatch());
             orderDetl.setWeight(detlDto.getWeight());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
@@ -410,7 +415,7 @@
                 Long tagId;
                 // 涓�绾у垎绫�
                 if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) {
-                    Tag priTag = tagService.selectByName(matParam.getGroupCode(), 2);
+                    Tag priTag = tagService.selectByName(matParam.getGroupCode(), 1);
                     if (priTag == null) {
                         Tag top = tagService.getTop();
                         NodeUtils nodeUtils = new NodeUtils();
@@ -441,7 +446,7 @@
                         }
                     }
                     // 浜岀骇鍒嗙被
-                    Tag secTag = tagService.selectByName(matParam.getGroupName(), 3);
+                    Tag secTag = tagService.selectByName(matParam.getGroupName(), 2);
                     if (secTag == null) {
                         NodeUtils nodeUtils = new NodeUtils();
                         nodeUtils.executePath(priTag.getId());
@@ -508,4 +513,46 @@
         return R.ok().add(top100);
     }
 
+    /*
+    * 閫熻吘鏁板瓧瀛敓璋冪敤鎺ュ彛
+    * */
+    @Override
+    public DigitalTwin inventoryQuantity() {
+        DigitalTwin digitalTwin = new DigitalTwin();
+        LocChartPie locUseRate = reportQueryMapper.getLocUseRate();
+        LocChartPie locUseRateL = reportQueryMapper.getLocUseRateL();
+        LocChartPie locUseRateP = reportQueryMapper.getLocUseRateP();
+        if(locUseRate!=null) {
+            digitalTwin.setCount(locUseRate.getOqty()+locUseRate.getFqty()+locUseRate.getUqty()+locUseRate.getXqty());
+            digitalTwin.setOqty(locUseRate.getOqty());
+            digitalTwin.setFqty(locUseRate.getFqty());
+            digitalTwin.setUqty(locUseRate.getUqty());
+            digitalTwin.setXqty(locUseRate.getXqty());
+        }
+        if(locUseRateL!=null) {
+            digitalTwin.setCountL(locUseRateL.getOqty()+locUseRateL.getFqty()+locUseRateL.getUqty()+locUseRateL.getXqty());
+            digitalTwin.setOqtyL(locUseRateL.getOqty());
+            digitalTwin.setFqtyL(locUseRateL.getFqty());
+            digitalTwin.setUqtyL(locUseRateL.getUqty());
+            digitalTwin.setXqtyL(locUseRateL.getXqty());
+        }
+        if (locUseRateP!=null){
+            digitalTwin.setCountP(locUseRateP.getOqty()+locUseRateP.getFqty()+locUseRateP.getUqty()+locUseRateP.getXqty());
+            digitalTwin.setOqtyP(locUseRateP.getOqty());
+            digitalTwin.setFqtyP(locUseRateP.getFqty());
+            digitalTwin.setUqtyP(locUseRateP.getUqty());
+            digitalTwin.setXqtyP(locUseRateP.getXqty());
+        }
+        return digitalTwin;
+    }
+
+    /*
+     * 閫熻吘鏁板瓧瀛敓璋冪敤鎺ュ彛
+     * */
+    @Override
+    public synchronized R ownerAllNumber() {
+        List<LocDetlAll> locDetlAlls = locDetlService.selectOwnerAllAnfme();
+        return R.ok(locDetlAlls);
+    }
+
 }

--
Gitblit v1.9.1