From 77b8a87b6f2d39c38db276e42e030362b9df4000 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期四, 14 九月 2023 13:00:13 +0800
Subject: [PATCH] #上架时判断小数给price字段插入1,不是小数插入2,订单出库优先出小数

---
 src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java |  182 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 179 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java
index d4192a1..60e9268 100644
--- a/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OrderServiceImpl.java
@@ -2,22 +2,41 @@
 
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
-import com.zy.asrs.entity.OrderDetl;
+import com.core.common.DateUtils;
+import com.core.common.SnowflakeIdWorker;
+import com.core.exception.CoolException;
+import com.zy.asrs.entity.*;
+import com.zy.asrs.entity.param.OpenOrderPakinParam;
+import com.zy.asrs.entity.param.OpenOrderPakoutParam;
 import com.zy.asrs.mapper.OrderDetlMapper;
 import com.zy.asrs.mapper.OrderMapper;
-import com.zy.asrs.entity.Order;
-import com.zy.asrs.service.OrderService;
+import com.zy.asrs.service.*;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.zy.common.model.DetlDto;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 
+@Slf4j
 @Service("orderService")
 public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {
 
     @Autowired
     private OrderDetlMapper orderDetlMapper;
+    @Autowired
+    private OpenService openService;
+    @Autowired
+    private SnowflakeIdWorker snowflakeIdWorker;
+    @Autowired
+    private OrderDetlService orderDetlService;
+    @Autowired
+    private DocTypeService docTypeService;
+    @Autowired
+    private WrkDetlService wrkDetlService;
 
     @Override
     public Order selectByNo(String orderNo) {
@@ -38,4 +57,161 @@
         return this.baseMapper.updateSettle(orderId, settle, userId) > 0;
     }
 
+    @Override
+    public void checkComplete(String orderNo) {
+        Order order = this.selectByNo(orderNo);
+        if (Cools.isEmpty(order) || order.getSettle() >= 4L) {
+            return;
+        }
+        List<OrderDetl> orderDetls = orderDetlMapper.selectList(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()));
+        boolean complete = true;
+        for (OrderDetl orderDetl : orderDetls) {
+            if (orderDetl.getAnfme() > orderDetl.getQty()) {
+                complete = false;
+                break;
+            }
+        }
+        if (complete) {
+            for (OrderDetl orderDetl : orderDetls) {
+                if (Cools.isEmpty(orderDetl.getBatch())){
+                    orderDetlService.updateById(orderDetl);
+                }else if (orderDetl.getBatch().equals("")){//鐢熸垚鍗曟嵁鍜屽叆搴撻�氱煡妗f椂锛岀粰batch涓虹┖鐨勬槑缁嗚祴浜嗕竴涓� =""锛� 鐜板湪鏀逛负null锛屽洖浼犵敤
+                    orderDetl.setBatch(null);
+                    orderDetlService.updateById(orderDetl);
+                }
+            }
+            if (!this.updateSettle(order.getId(), 4L, null)) {
+                throw new CoolException("淇敼璁㈠崟銆恛rderNo = " + order.getOrderNo() + "銆戠姸鎬佷负宸插畬鎴愬け璐�");
+            }
+        }
+
+    }
+
+    @Override
+    public boolean saveHandlerOrder(Boolean pakin, WrkMast wrkMast, List<WrkDetl> wrkDetls) {
+        try {
+            List<DetlDto> detlDtos = new ArrayList<>();
+            wrkDetls.forEach(wrkDetl -> {
+                detlDtos.add(new DetlDto(wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme()));
+            });
+            String orderNo = "HAND" + snowflakeIdWorker.nextId();
+            if (pakin) {
+                // 鐢熸垚鍏ュ簱鍗曟嵁
+                OpenOrderPakinParam openParam = new OpenOrderPakinParam();
+                openParam.setOrderNo(orderNo);
+                openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime()));
+                openParam.setOrderType("鎵嬪姩鍏ュ簱鍗�");
+                openParam.setOrderDetails(detlDtos);
+                openService.pakinOrderCreate(openParam);
+            } else {
+                // 鐢熸垚鍑哄簱鍗曟嵁
+                OpenOrderPakoutParam openParam = new OpenOrderPakoutParam();
+                openParam.setOrderNo(orderNo);
+                openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime()));
+                openParam.setOrderType("鎵嬪姩鍑哄簱鍗�");
+                openParam.setOrderDetails(detlDtos);
+                openService.pakoutOrderCreate(openParam);
+            }
+
+            Order order = this.selectByNo(orderNo);
+            if (null == order) {
+                throw new CoolException("鐢熸垚鍗曟嵁澶辫触");
+            }
+            if (!this.updateSettle(order.getId(), 4L, null)) {
+                throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�");
+            }
+            for (DetlDto detlDto : detlDtos) {
+                // 淇敼璁㈠崟鏄庣粏鏁伴噺
+                if (!orderDetlService.increase(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) {
+                    throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触");
+                }
+                // 淇敼璁㈠崟浣滀笟鏁伴噺
+                if (!orderDetlService.increaseWorkQty(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) {
+                    throw new CoolException("淇敼鍗曟嵁浣滀笟鏁伴噺澶辫触");
+                }
+            }
+        } catch (Exception e) {
+            log.error("saveHandlerOrder===>>", e);
+            return false;
+        }
+        return true;
+    }
+
+    @Override
+    public void remove(Long orderId) {
+        if (!this.deleteById(orderId)) {
+            throw new CoolException("鍒犻櫎鍗曟嵁澶辫触");
+        }
+        orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_id", orderId));
+    }
+
+    @Override
+    public List<Order> selectComplete() {
+        return this.baseMapper.selectComplete();
+    }
+
+    @Override
+    public boolean addToLogTable(Order order) {
+        return this.baseMapper.addToLogTable(order) > 0;
+    }
+
+    /**
+     *
+     * @param orderNo
+     *
+     */
+    @Override
+    public void BackToInit(String orderNo) {
+        Integer count = this.baseMapper.checkDetlWorkQtyLess0(orderNo);
+        //濡傛灉鎵�鏈夋槑缁嗙殑宸ヤ綔鏁伴噺鍜屽畬鎴愰噺閮藉皬浜庣瓑浜�0锛� 閭d箞灏嗕富妗f洿鏂颁负鈥滃緟澶勭悊鈥濈姸鎬�
+        if (count == 0 ){
+            this.baseMapper.updateSettleTo1(orderNo);
+        }
+    }
+
+    @Override
+    public List<Order> selectInOrOutOrders(boolean inOrders) {
+        if (inOrders) {
+            return this.baseMapper.selectInOrOutOrders(1);
+
+        }else {
+            return this.baseMapper.selectInOrOutOrders(0);
+
+        }
+    }
+
+    @Override
+    public void checkSettleUpdate(Long orderId) {
+        long settle = 1;
+        Integer count = 0;
+        List<OrderDetl> orderNo1 = orderDetlService.selectList(new EntityWrapper<OrderDetl>()
+                .eq("order_id", orderId));
+        for (int i = 0; i < orderNo1.size(); i++) {
+            OrderDetl orderDetl = orderNo1.get(i);
+            if (orderDetl.getQty() > 0){
+                settle = 2;
+
+            }
+            if (Objects.equals(orderDetl.getAnfme(), orderDetl.getQty())){
+                count++;
+            }
+
+        }
+        if (count == orderNo1.size()){
+            settle = 4;
+        }
+        updateSettle(orderId,settle,1L);
+    }
+
+    @Override
+    public List<Order> selectToBeHistoryOrder(boolean isERP) {
+        int settle = isERP ? 6 : 4;
+        return this.baseMapper.selectToBeHistoryOrder(settle);
+    }
+
+    @Override
+    public List<OrderListDTO> selectAllorderNo() {
+        return this.baseMapper.selectAllorderNo();
+    }
+
 }

--
Gitblit v1.9.1