From d360bba38d918e2f586d27c5aeb8b1174a612630 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期二, 07 五月 2024 13:04:38 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/PlaServiceImpl.java |  172 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 172 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/PlaServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/PlaServiceImpl.java
index 84df296..b00b121 100644
--- a/src/main/java/com/zy/asrs/service/impl/PlaServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/PlaServiceImpl.java
@@ -1,12 +1,184 @@
 package com.zy.asrs.service.impl;
 
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.plugins.Page;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.core.common.Cools;
+import com.core.common.DateUtils;
+import com.core.exception.CoolException;
+import com.zy.asrs.entity.OrderDetl;
 import com.zy.asrs.entity.Pla;
+import com.zy.asrs.entity.PlaQty;
+import com.zy.asrs.entity.param.GlobleParameter;
 import com.zy.asrs.mapper.PlaMapper;
+import com.zy.asrs.service.PlaQtyService;
 import com.zy.asrs.service.PlaService;
+import com.zy.asrs.utils.SaasUtils;
+import com.zy.asrs.utils.Utils;
+import com.zy.system.entity.User;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
+import java.util.List;
 
 @Service("plaService")
 public class PlaServiceImpl extends ServiceImpl<PlaMapper, Pla> implements PlaService {
+    @Autowired
+    private PlaQtyService plaQtyService;
 
+    public Pla selectByBatchAndPackageNo(String batch, Integer packageNo, String brand) {
+        return this.selectOne(new EntityWrapper<Pla>().eq("batch",batch).eq("package_no",packageNo).eq("brand",brand).eq(false,"status","鍏ㄩ儴鍑哄簱"));
+    }
+
+    @Override
+    @Transactional
+    public void queryStock(OrderDetl orderDetl, List<PlaQty> plaQties) {
+
+        //绛涢�夋潯浠� 鎵瑰彿銆佸寘濂姐�佺啍鐐广�佺啍鎸囥�侀粍搴︺�佷笉閫忔槑搴�
+        Wrapper<Pla> wrapper = new EntityWrapper<Pla>();
+        if(!Cools.isEmpty(orderDetl.getBatch())){
+            wrapper.eq("batch",orderDetl.getBatch());
+        }
+        if(!Cools.isEmpty(orderDetl.getBrand())){
+            wrapper.eq("package_no",orderDetl.getBrand());
+        }
+        wrapper.eq("status", GlobleParameter.PLA_STATUS_1);
+        wrapper.ge("finger_melting", orderDetl.getFingerMeltingMin()).le("finger_melting", orderDetl.getFingerMeltingMax());
+        wrapper.ge("fusing_point", orderDetl.getFusingPointMin()).le("fusing_point", orderDetl.getFusingPointMax());
+        wrapper.ge("yellowness", orderDetl.getYellownessMin()).le("yellowness", orderDetl.getYellownessMax());
+        wrapper.ge("opacity", orderDetl.getOpacityMin()).le("opacity", orderDetl.getOpacityMax());
+        wrapper.orderBy("pakin_time");
+
+        List<Pla> plas = this.selectList(wrapper);
+        //鎬诲叡鐨勫嚭搴撶殑鏁伴噺(鎬昏鍑哄簱鏁伴噺-浣滀笟鏁伴噺)
+        if(Cools.isEmpty(orderDetl.getWorkQty())){
+            orderDetl.setWorkQty(0.0);
+        }
+        Double anfme = orderDetl.getAnfme() - orderDetl.getWorkQty();
+
+        for (Pla pla : plas){
+            //搴撳瓨鏁伴噺(鍓╀綑閲嶉噺-搴撳瓨浣滀笟鏁伴噺)
+            Double weightAnfme = pla.getWeightAnfme() - pla.getQtyAnfme();
+            if(weightAnfme <= 0){
+                continue;
+            }
+            //闇�瑕佸噺鍘绘娆″嚭搴撻瑙堝叾浠栬鍗曢渶鍑哄簱鐨勬暟閲�
+            for (PlaQty plaQty : plaQties){
+                if(Cools.eq(plaQty.getBatch(),pla.getBatch()) && plaQty.getPackageNo() == pla.getPackageNo()){
+                    weightAnfme -= plaQty.getQtyAnfme();
+                }
+            }
+
+            if(weightAnfme > anfme){
+                //濡傛灉璇ユ壒娆″寘鍙峰墿浣欓噸閲忓ぇ浜庤鍗曟槑缁嗘暟閲忥紝鍒欒繑鍥瀙laQties
+                PlaQty plaQty = new PlaQty(pla.getBatch(),pla.getPackageNo(),orderDetl.getId(),orderDetl.getOrderId(),orderDetl.getOrderNo(),anfme,pla.getLocNo(),new Date());
+                anfme = 0.0;
+                plaQties.add(plaQty);
+                break;
+            }else {
+                PlaQty plaQty = new PlaQty(pla.getBatch(),pla.getPackageNo(),orderDetl.getId(),orderDetl.getOrderId(),orderDetl.getOrderNo(),weightAnfme,pla.getLocNo(),new Date());
+                anfme -= weightAnfme;
+                plaQties.add(plaQty);
+            }
+        }
+
+        if(anfme > 0){
+            PlaQty plaQty = new PlaQty(orderDetl.getBatch(),Integer.parseInt(orderDetl.getBrand()),orderDetl.getId(),orderDetl.getOrderId(),orderDetl.getOrderNo(),anfme,null,new Date());
+            plaQties.add(plaQty);
+        }
+
+    }
+
+    //閫�鍥�
+    public void returned(List<PlaQty> plaQties, User user) {
+        plaQties.forEach(plaQty -> {
+            PlaQty plaQtyOut = plaQtyService.selectById(plaQty.getId());
+            if(Cools.isEmpty(plaQtyOut.getReturned())){
+                plaQtyOut.setReturned(plaQty.getOrderWeight());
+            }else {
+                plaQtyOut.setReturned(plaQty.getOrderWeight()+plaQtyOut.getReturned());
+            }
+            plaQtyService.updateById(plaQtyOut);
+
+            PlaQty plaQtyReturned = new PlaQty();
+            plaQtyReturned.setBatch(plaQtyOut.getBatch());
+            plaQtyReturned.setPackageNo(plaQtyOut.getPackageNo());
+            plaQtyReturned.setCreateTime(new Date());
+            plaQtyReturned.setLocNo(plaQtyOut.getLocNo());
+            plaQtyReturned.setOrderNo(plaQtyOut.getOrderNo());
+            plaQtyReturned.setPakoutTime(Utils.getDateStr(new Date()));
+            plaQtyReturned.setOrderWeight(plaQty.getOrderWeight());
+            plaQtyReturned.setTransfer("閫�鍥炲叆搴�");
+            plaQtyReturned.setHandlerBy(user.getUsername());
+            plaQtyReturned.setCustomer(plaQtyOut.getCustomer());
+            plaQtyReturned.setMemo(plaQty.getMemo());
+            plaQtyService.insert(plaQtyReturned);
+
+            //鐩存帴鏇存柊pla鐨勫簱瀛�
+            Pla pla = this.selectByBatchAndPackageNo(plaQty.getBatch(), plaQty.getPackageNo(),plaQty.getBrand());
+            //pla.setStatus(GlobleParameter.PLA_STATUS_0);
+            pla.setModifyTime(new Date());
+
+            pla.setWeightAnfme(pla.getWeightAnfme() + plaQty.getOrderWeight());
+            pla.setStatus(GlobleParameter.PLA_STATUS_1);
+            this.updateById(pla);
+
+            SaasUtils.insertLog(0,pla.getLocNo(),pla.getBrand(),plaQty.getOrderWeight(),user.getUsername(),
+                    null,pla.getBatch(),pla.getPackageNo(),pla.getOwner(),pla.getWorkshop());
+
+        });
+    }
+
+    @Override
+    @Transactional
+    public void viladate(List<Pla> plas, User user) {
+        plas.forEach(pla -> {
+            if(!pla.getStatus().equals(GlobleParameter.PLA_STATUS_00)){
+               throw new CoolException("閫変腑鐨勬暟鎹笉鏄殏鍏ュ簱鐘舵�侊紝璇锋牳瀵圭姸鎬�");
+            }
+            pla = this.selectById(pla.getId());
+            pla.setModifyTime(new Date());
+            pla.setStatus(GlobleParameter.PLA_STATUS_0);
+            this.updateById(pla);
+        });
+    }
+
+    @Override
+    public List<Pla> selectToHistory() {
+        return this.selectList(new EntityWrapper<Pla>().eq("status",GlobleParameter.PLA_STATUS_4));
+    }
+
+    @Override
+    public Page<Pla> getStockStatisAll(Page<Pla> page) {
+
+        List<Pla> plaList;
+        Date stime = null;
+        Date etime = null;
+        Object create_time = page.getCondition().get("create_time");
+        Object brand = page.getCondition().get("brand");
+        Object status = page.getCondition().get("status");
+        String createTime = create_time == null ? null : create_time.toString();
+        if(!Cools.isEmpty(createTime)){
+            String[] dates = createTime.split(" - ");
+            stime = DateUtils.convert(dates[0]);
+            etime = DateUtils.convert(dates[1]);
+        }
+        plaList=baseMapper.getStockStatisAll(brand == null ? null:brand.toString(), status == null ? null:status.toString(),  stime,etime);
+
+        double weightSum = plaList.stream().mapToDouble(Pla::getWeight).sum();
+
+        // 鏈�鍚庝竴鏉¤褰曚粎渚涘悎璁¢噸閲忎俊鎭睍绀�
+        Pla pla = new Pla();
+        pla.setBrand("鍚堣");
+        pla.setMatnr("");
+        pla.setWeight(weightSum);
+        plaList.add(pla);
+
+        page.setRecords(plaList);
+        page.setTotal(0);
+        return page;
+    }
 }

--
Gitblit v1.9.1