From 901dfbf8d57ffb54f9154e6d7db6899b9b4dcc92 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期四, 28 十二月 2023 16:56:13 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  400 +++++++++++++++++++++++++++-----------------------------
 1 files changed, 194 insertions(+), 206 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 7c0de39..f06bbaa 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;
@@ -60,6 +58,12 @@
     private NodeService nodeService;
     @Autowired
     private ManLocDetlService manLocDetlService;
+    @Autowired
+    private ManPakOutService manPakOutService;
+    @Autowired
+    private LocOwnerService locOwnerService;
+    @Autowired
+    private ReportQueryMapper reportQueryMapper;
 
     @Override
     @Transactional
@@ -67,6 +71,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();
@@ -114,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;
@@ -122,6 +140,7 @@
             } else {
                 list.add(dto);
             }
+            dto.setWeight(detail.getWeight());
         }
         for (DetlDto detlDto : list) {
             Mat mat = matService.selectByMatnr(detlDto.getMatnr());
@@ -145,59 +164,22 @@
             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.setBeBatch(detlDto.getBeBatch());
+            orderDetl.setWeight(detlDto.getWeight());
             if (!orderDetlService.insert(orderDetl)) {
                 throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
         }
     }
-
-//    @Override
-//    @Transactional
-//    public List<OpenOrderCompeteResult> pakinOrderComplete(OpenOrderCompleteParam param) {
-//        List<OpenOrderCompeteResult> results = new ArrayList<>();
-//        if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) {
-//            // 鎸囧畾璁㈠崟
-//            Order order = orderService.selectByNo(param.getOrderNo());
-//            if (null != order) {
-//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-//                results.add(result);
-//                result.setOrderNo(order.getOrderNo());
-//                result.setOrderTime(order.getOrderTime());
-//                result.setOrderType(order.getDocType$());
-//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-//                for (OrderDetl orderDetl : orderDetls) {
-//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-//                }
-//                if (order.getSettle() == 4L) {
-//                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-//                    if (!orderService.updateSettle(order.getId(), 6L, null)) {
-//                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-//                    }
-//                }
-//            }
-//        } else {
-//            // 鎵�鏈夎鍗�
-//            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
-//            for (Order order : orders) {
-//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-//                results.add(result);
-//                result.setOrderNo(order.getOrderNo());
-//                result.setOrderTime(order.getOrderTime());
-//                result.setOrderType(order.getDocType$());
-//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-//                for (OrderDetl orderDetl : orderDetls) {
-//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-//                }
-//                // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-//                if (!orderService.updateSettle(order.getId(), 6L, null)) {
-//                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-//                }
-//            }
-//        }
-//        return results;
-//    }
 
     @Override
     @Transactional
@@ -257,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;
@@ -264,6 +247,7 @@
             } else {
                 list.add(dto);
             }
+            dto.setWeight(detail.getWeight());
         }
         for (DetlDto detlDto : list) {
             Mat mat = matService.selectByMatnr(detlDto.getMatnr());
@@ -282,61 +266,134 @@
             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("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
             }
         }
     }
 
-//    @Override
-//    public List<OpenOrderCompeteResult> pakoutOrderComplete(OpenOrderCompleteParam param) {
-//        List<OpenOrderCompeteResult> results = new ArrayList<>();
-//        if (!Cools.isEmpty(param) && !Cools.isEmpty(param.getOrderNo())) {
-//            // 鎸囧畾璁㈠崟
-//            Order order = orderService.selectByNo(param.getOrderNo());
-//            if (null != order) {
-//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-//                results.add(result);
-//                result.setOrderNo(order.getOrderNo());
-//                result.setOrderTime(order.getOrderTime());
-//                result.setOrderType(order.getDocType$());
-//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-//                for (OrderDetl orderDetl : orderDetls) {
-//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-//                }
-//                if (order.getSettle() == 4L) {
-//                    // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-//                    if (!orderService.updateSettle(order.getId(), 6L, null)) {
-//                        throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-//                    }
-//                }
-//            }
-//        } else {
-//            // 鎵�鏈夎鍗�
-//            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L));
-//            for (Order order : orders) {
-//                OpenOrderCompeteResult result = new OpenOrderCompeteResult();
-//                results.add(result);
-//                result.setOrderNo(order.getOrderNo());
-//                result.setOrderTime(order.getOrderTime());
-//                result.setOrderType(order.getDocType$());
-//                List<OrderDetl> orderDetls = orderDetlService.selectByOrderId(order.getId());
-//                for (OrderDetl orderDetl : orderDetls) {
-//                    result.getOrderDetails().add(new DetlDto(orderDetl.getOrderNo(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getQty()));
-//                }
-//                // 淇敼璁㈠崟鐘舵�� 4.瀹屾垚 ===>> 6.宸蹭笂鎶�
-//                if (!orderService.updateSettle(order.getId(), 6L, null)) {
-//                    throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
-//                }
-//            }
-//        }
-//        return results;
-//    }
+    @Override
+    @Transactional
+    public void pakmoveOrderCreate(OpenOrderPakmoveParam param) {
+        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();
+        // 鍗曟嵁涓绘。
+        order = new Order(
+                String.valueOf(snowflakeIdWorker.nextId()),    // 缂栧彿[闈炵┖]
+                param.getOrderNo(),    // 璁㈠崟缂栧彿
+                DateUtils.convert(now),    // 鍗曟嵁鏃ユ湡
+                docType.getDocId(),    // 鍗曟嵁绫诲瀷
+                null,    // 椤圭洰缂栧彿
+                null,    //
+                null,    // 璋冩嫧椤圭洰缂栧彿
+                null,    // 鍒濆绁ㄦ嵁鍙�
+                null,    // 绁ㄦ嵁鍙�
+                null,    // 瀹㈡埛缂栧彿
+                null,    // 瀹㈡埛
+                null,    // 鑱旂郴鏂瑰紡
+                null,    // 鎿嶄綔浜哄憳
+                null,    // 鍚堣閲戦
+                null,    // 浼樻儬鐜�
+                null,    // 浼樻儬閲戦
+                null,    // 閿�鍞垨閲囪喘璐圭敤鍚堣
+                null,    // 瀹炰粯閲戦
+                null,    // 浠樻绫诲瀷
+                null,    // 涓氬姟鍛�
+                null,    // 缁撶畻澶╂暟
+                null,    // 閭垂鏀粯绫诲瀷
+                null,    // 閭垂
+                null,    // 浠樻鏃堕棿
+                null,    // 鍙戣揣鏃堕棿
+                null,    // 鐗╂祦鍚嶇О
+                null,    // 鐗╂祦鍗曞彿
+                1L,    // 璁㈠崟鐘舵��
+                1,    // 鐘舵��
+                9527L,    // 娣诲姞浜哄憳
+                now,    // 娣诲姞鏃堕棿
+                9527L,    // 淇敼浜哄憳
+                now,    // 淇敼鏃堕棿
+                null    // 澶囨敞
+        );
+        if (!orderService.insert(order)) {
+            throw new CoolException("鐢熸垚鍗曟嵁涓绘。澶辫触锛岃鑱旂郴绠$悊鍛�");
+        }
+        // 鍗曟嵁鏄庣粏妗�
+        List<DetlDto> list = new ArrayList<>();
+        List<DetlDto> orderDetails = param.getOrderDetails();
+        for (DetlDto detail : orderDetails) {
+            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;
+                detlDto.setAnfme(detlDto.getAnfme() + detail.getAnfme());
+            } else {
+                list.add(dto);
+            }
+            dto.setWeight(detail.getWeight());
+        }
+        for (DetlDto detlDto : list) {
+            Mat mat = matService.selectByMatnr(detlDto.getMatnr());
+            if (Cools.isEmpty(mat)) {
+                throw new CoolException(detlDto.getMatnr() + "缂栧彿鍟嗗搧妫�绱㈠け璐ワ紝璇峰厛娣诲姞鍟嗗搧");
+            }
+            OrderDetl orderDetl = new OrderDetl();
+            orderDetl.sync(mat);
+
+            //鎵瑰彿涓虹┖浼氬嚭鐜伴棶棰橈紝璁剧疆涓�涓粯璁ゅ��
+            if (detlDto.getBatch() == null) {
+                orderDetl.setBatch("");
+            } else {
+                orderDetl.setBatch(detlDto.getBatch());
+
+            }
+            orderDetl.setAnfme(detlDto.getAnfme());
+            orderDetl.setOrderId(order.getId());
+            orderDetl.setOrderNo(order.getOrderNo());
+            orderDetl.setCreateBy(9527L);
+            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());
+            }
+            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("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�");
+            }
+        }
+    }
 
     @Override
     @Transactional
-    public List<StockVo> queryStock() {
-        return locDetlService.queryStockTotal();
+    public List<StockVo> queryStock(StockVo stockVo) {
+        return locDetlService.queryStockTotal(stockVo);
     }
 
     @Override
@@ -474,7 +531,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();
@@ -505,7 +562,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());
@@ -548,6 +605,9 @@
                 mat.setStatus(1);
                 mat.setCreateTime(now);
                 mat.setUpdateTime(now);
+                if (Cools.isEmpty(matParam.getLength()) || matParam.getLength() == 0) {
+                    mat.setLength(null);
+                }
                 if (!matService.insert(mat)) {
                     throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
                 } else {
@@ -569,118 +629,46 @@
         return R.ok().add(top100);
     }
 
-    @Transactional
+    /*
+    * 閫熻吘鏁板瓧瀛敓璋冪敤鎺ュ彛
+    * */
     @Override
-    public R manDetlIn(JSONObject json) {
-        Date date = new Date();
-        String jsonLocNo = (String) json.get("locNo");
-        Node node = nodeService.selectOne(new EntityWrapper<Node>()
-                .eq("name", jsonLocNo));
-
-        String jsonOrderNo = (String) json.get("orderNo");
-        Order order = orderService.selectOne(new EntityWrapper<Order>()
-                .eq("order_no", jsonOrderNo));
-        if (Cools.isEmpty(node, order)) {
-            return R.error("鍙傛暟涓虹┖");
+    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());
         }
-
-        JSONArray combMats = json.getJSONArray("combMats");
-        for (int i = 0; i < combMats.size(); i++) {
-            OrderDetl jsonOrderDetl = combMats.getObject(i, OrderDetl.class);
-            OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>()
-                    .eq("order_no", jsonOrderNo));
-            if (Cools.isEmpty(orderDetl)) {
-                return R.error("鍗曟嵁鏄庣粏鏈夎,璇锋鏌�");
-            }
-            if (orderDetl.getAnfme() - (jsonOrderDetl.getAnfme() + orderDetl.getQty()) < 0) {
-                return R.error("鍏ュ簱鏁伴噺澶т簬鍙叆鏁伴噺");
-            }
-            ManLocDetl checkManLocDetl = manLocDetlService.selectOne(new EntityWrapper<ManLocDetl>()
-                    .eq("loc_no", jsonLocNo)
-                    .eq("matnr", orderDetl.getMatnr()));
-            if (checkManLocDetl == null) {
-                ManLocDetl manLocDetl = new ManLocDetl();
-                Synchro.Copy(orderDetl, manLocDetl);
-                manLocDetl.setLocNo(node.getName());
-                manLocDetl.setNodeId(node.getId());
-                manLocDetl.setMatnr(orderDetl.getMatnr());
-                manLocDetl.setMaktx(orderDetl.getMaktx());
-                manLocDetl.setAnfme(orderDetl.getAnfme());
-                manLocDetl.setModiTime(date);
-                manLocDetl.setCreateTime(date);
-                manLocDetlService.insert(manLocDetl);
-            } else {
-                checkManLocDetl.setAnfme(checkManLocDetl.getAnfme() + orderDetl.getAnfme());
-                checkManLocDetl.setModiTime(date);
-                manLocDetlService.update(checkManLocDetl, new EntityWrapper<ManLocDetl>()
-                        .eq("loc_no", jsonLocNo)
-                        .eq("matnr", orderDetl.getMatnr()));
-            }
-
-            orderDetl.setQty(orderDetl.getQty() + jsonOrderDetl.getAnfme());
-            orderDetl.setUpdateTime(date);
-            orderDetlService.updateById(orderDetl);
-
+        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());
         }
-        orderService.checkComplete(order.getOrderNo());
-
-
-        return R.ok("涓婃灦瀹屾垚");
+        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;
     }
 
-    @Transactional
+    /*
+     * 閫熻吘鏁板瓧瀛敓璋冪敤鎺ュ彛
+     * */
     @Override
-    public R manDetlOut(JSONObject json) {
-        Date date = new Date();
-        String jsonLocNo = (String) json.get("locNo");
-        Node node = nodeService.selectOne(new EntityWrapper<Node>()
-                .eq("name", jsonLocNo));
-        String jsonOrderNo = (String) json.get("orderNo");
-        Order order = orderService.selectOne(new EntityWrapper<Order>()
-                .eq("order_no", jsonOrderNo));
-        if (Cools.isEmpty(node, order)) {
-            return R.error("鍙傛暟涓虹┖");
-        }
-
-        JSONArray combMats = json.getJSONArray("combMats");
-        for (int i = 0; i < combMats.size(); i++) {
-            OrderDetl jsonOrderDetl = combMats.getObject(i, OrderDetl.class);
-            OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>()
-                    .eq("order_no", jsonOrderNo));
-            if (Cools.isEmpty(orderDetl)) {
-                return R.error("鍗曟嵁鏄庣粏鏈夎,璇锋鏌�");
-            }
-            if (jsonOrderDetl.getAnfme() > (orderDetl.getAnfme() - orderDetl.getQty())) {
-                return R.error("鍑哄簱鏁伴噺澶т簬鍗曟嵁鍙嚭鏁伴噺");
-            }
-            ManLocDetl manLocDetl = manLocDetlService.selectOne(new EntityWrapper<ManLocDetl>()
-                    .eq("loc_no", jsonLocNo)
-                    .eq("matnr", orderDetl.getMatnr()));
-            if (manLocDetl == null) {
-                return R.error("璇ュ簱浣嶆病鏈夊嚭搴撶殑鐗╂枡淇℃伅");
-            }
-            if (jsonOrderDetl.getAnfme() > manLocDetl.getAnfme()) {
-                return R.error("鍑哄簱鏁伴噺澶т簬鍙嚭鏁伴噺");
-            }
-            Double finalQty = manLocDetl.getAnfme() - jsonOrderDetl.getAnfme();
-            if (finalQty <= 0){
-                manLocDetlService.delete(new EntityWrapper<ManLocDetl>()
-                        .eq("loc_no", jsonLocNo)
-                        .eq("matnr", orderDetl.getMatnr()));
-            }else {
-                manLocDetl.setAnfme(finalQty);
-                manLocDetl.setModiTime(date);
-                manLocDetlService.update(manLocDetl,new EntityWrapper<ManLocDetl>()
-                        .eq("loc_no", jsonLocNo)
-                        .eq("matnr", orderDetl.getMatnr()));
-            }
-            orderDetl.setQty(orderDetl.getQty() + jsonOrderDetl.getAnfme());
-            orderDetl.setUpdateTime(date);
-            orderDetlService.updateById(orderDetl);
-
-            orderService.checkComplete(order.getOrderNo());
-        }
-        return R.ok("涓嬫灦瀹屾垚");
+    public synchronized R ownerAllNumber() {
+        List<LocDetlAll> locDetlAlls = locDetlService.selectOwnerAllAnfme();
+        return R.ok(locDetlAlls);
     }
 
 }

--
Gitblit v1.9.1