From 8a984617b478a0a424c7fd033c7bb8c88bac5d85 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 13 九月 2023 10:41:45 +0800
Subject: [PATCH] #pda盘点

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |   65 +++++++++++++++++++++++++++++---
 1 files changed, 59 insertions(+), 6 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 858d596..09473ad 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -1,7 +1,5 @@
 package com.zy.asrs.service.impl;
 
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
 import com.core.common.DateUtils;
@@ -11,15 +9,13 @@
 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.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;
@@ -62,6 +58,10 @@
     private ManLocDetlService manLocDetlService;
     @Autowired
     private ManPakOutService manPakOutService;
+    @Autowired
+    private LocOwnerService locOwnerService;
+    @Autowired
+    private ReportQueryMapper reportQueryMapper;
 
     @Override
     @Transactional
@@ -69,6 +69,19 @@
         Order order = orderService.selectByNo(param.getOrderNo());
         if (!Cools.isEmpty(order)) {
             throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦");
+        }
+
+        for (DetlDto detlDto : param.getOrderDetails()){
+            if (Cools.isEmpty(detlDto) || Cools.isEmpty(detlDto.getOwnerName(),detlDto.getPayment())){
+                throw new CoolException(param.getOrderNo() + "缂哄皯璐т富鎴栬揣鐗╁舰鎬�");
+            }else {
+                LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName()));
+                if (Cools.isEmpty(locOwner)){
+                    LocOwner locOwner1 = new LocOwner();
+                    locOwner1.setOwner(detlDto.getOwnerName());
+                    locOwnerService.insert(locOwner1);
+                }
+            }
         }
         DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE);
         Date now = new Date();
@@ -116,7 +129,7 @@
         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());
             if (DetlDto.has(list, dto)) {
                 DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());
                 assert detlDto != null;
@@ -148,6 +161,13 @@
             orderDetl.setCreateTime(now);
             orderDetl.setUpdateBy(9527L);
             orderDetl.setUpdateTime(now);
+            LocOwner locOwner = locOwnerService.selectOne(new EntityWrapper<LocOwner>().eq("owner", detlDto.getOwnerName()));
+            if (Cools.isEmpty(locOwner)){
+                throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+            }else {
+                orderDetl.setOwner(locOwner.getId().intValue());
+            }
+            orderDetl.setPayment(detlDto.getPayment());
             orderDetl.setStatus(1);
             orderDetl.setQty(0.0D);
             orderDetl.setWeight(detlDto.getWeight());
@@ -487,4 +507,37 @@
         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;
+    }
+
 }

--
Gitblit v1.9.1