From ba4e5ac7bd44e0d24f480b44a94cfe8d256a86e9 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期二, 10 十月 2023 14:09:20 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java |   89 ++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 81 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
index 736601e..68a127c 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvLocDetlServiceImpl.java
@@ -2,6 +2,7 @@
 
 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.zy.asrs.entity.AgvLocDetl;
@@ -13,6 +14,7 @@
 import com.zy.asrs.service.AgvLocMastService;
 import com.zy.asrs.service.AgvWrkDetlService;
 import com.zy.common.model.LocDto;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -22,6 +24,7 @@
 import java.util.stream.Collectors;
 
 @Service
+@Slf4j
 public class AgvLocDetlServiceImpl extends ServiceImpl<AgvLocDetlMapper, AgvLocDetl> implements AgvLocDetlService {
 
     @Autowired
@@ -33,8 +36,9 @@
 
     public void addLocDetlInfo(String locNo, int taskCode) {
         List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", taskCode));
-        List<AgvLocDetl> agvLocDetlList = agvWrkDetls.stream().map(agvWrkDetl -> {
+        agvWrkDetls.stream().map(agvWrkDetl -> {
             AgvLocDetl agvLocDetl = new AgvLocDetl();
+            log.info("agvWrkDetl: " + agvLocDetl.getBarcode());
             BeanUtils.copyProperties(agvWrkDetl, agvLocDetl);
             agvLocDetl.setLocNo(locNo);
             this.insert(agvLocDetl);
@@ -43,14 +47,14 @@
 
     }
 
-    public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued) {
+    public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq) {
         //鏍规嵁鐗╂枡鍙峰拰鎵规鎵惧埌瀵瑰簲鐨勫簱瀛橈紝骞朵笖鎸夌収淇敼鏃堕棿鎺掑簭
         Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).orderBy("modi_time");
-        if(Cools.isEmpty(batch)){
-            wrapper.isNull("batch");
-        }else {
-            wrapper.eq("batch",batch);
-        }
+
+        wapperSetCondition(wrapper,"batch",batch);
+        wapperSetCondition(wrapper,"three_code",csocode);
+        wapperSetCondition(wrapper,"dead_time",isoseq);
+
         List<AgvLocDetl> agvLocDetls = this.selectList(wrapper);
 
         for (AgvLocDetl agvLocDetl: agvLocDetls) {
@@ -66,7 +70,9 @@
                 //int ioType = anfme > issued ? 101 : 103;
                 anfme = anfme > issued ? issued : anfme;
                 LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNo, anfme);
-
+                locDto.setCsocode(csocode);
+                locDto.setIsoseq(isoseq);
+                locDto.setContainerCode(agvLocDetl.getSuppCode());
                 //褰撳墠搴撲綅鎵�澶勬ゼ灞�
                 int floor = Integer.parseInt(agvLocDetl.getLocNo().split("@")[1]);
                 locDto.setAgvStaNos(queryAgvStaNosByFloor(floor));
@@ -78,6 +84,64 @@
 
         return issued;
 
+    }
+
+    /*
+    鏇存柊搴撳瓨鏄庣粏
+     */
+    public void updateStock(String sourceLoc, String targetLoc) {
+        this.baseMapper.updateStock(sourceLoc,targetLoc);
+    }
+
+    public Page<AgvLocDetl> getStockStatis(Page<AgvLocDetl> page) {
+        page.setRecords(baseMapper.getStockStatis(page.getCondition()));
+        page.setTotal(baseMapper.getStockStatisCount(page.getCondition()));
+        return page;
+    }
+
+    /*
+    鑾峰彇搴撳瓨鎬绘暟
+     */
+    public Integer sum() {
+        return this.baseMapper.sum();
+    }
+
+    public List<AgvLocDetl> getStockStatisExcel(){
+        return this.baseMapper.getStockStatisExcel();
+    }
+
+    public List<AgvLocDetl> searchByLike(String orderNo, String matnr, String maktx, String specs, String locNo) {
+        if (Cools.isEmpty(orderNo) && Cools.isEmpty(matnr) && Cools.isEmpty(maktx) && Cools.isEmpty(specs) && Cools.isEmpty(locNo)) {
+            return new ArrayList<AgvLocDetl>();
+        }
+        EntityWrapper<AgvLocDetl> wrapper = new EntityWrapper<>();
+        if(Cools.isEmpty(orderNo)){
+            wrapper.like("order_no",orderNo);
+        }
+        if(Cools.isEmpty(matnr)){
+            wrapper.like("matnr",matnr);
+        }
+        if(Cools.isEmpty(maktx)){
+            wrapper.like("maktx",maktx);
+        }
+        if(Cools.isEmpty(specs)){
+            wrapper.like("specs",specs);
+        }
+        if(Cools.isEmpty()){
+            wrapper.like("loc_no",locNo);
+        }
+        return this.selectList(wrapper);
+    }
+
+    public boolean updateAnfme(Double anfme, String locNo, String matnr, String batch) {
+        if (anfme <= 0) {
+            return this.delete(new EntityWrapper<AgvLocDetl>().eq("matnr", matnr).eq("loc_no", locNo));
+        } else {
+            AgvLocDetl agvLocDetl = this.selectOne(new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("matnr", matnr));
+            agvLocDetl.setAnfme(anfme);
+            return this.update(agvLocDetl,new EntityWrapper<AgvLocDetl>().eq("loc_no", locNo).eq("matnr", matnr));
+            //return baseMapper.updateAnfme(anfme, locNo, matnr, batch) > 0;
+        }
     }
 
     private List<String> queryAgvStaNosByFloor(int floor){
@@ -93,4 +157,13 @@
 
         return agvStaNos;
     }
+
+    private void wapperSetCondition(Wrapper wrapper,String column, String condition){
+        if(Cools.isEmpty(condition)){
+            wrapper.andNew().eq(column,"").or().isNull(column);
+            //wrapper.isNull(column);
+        }else {
+            wrapper.eq(column,condition);
+        }
+    }
 }

--
Gitblit v1.9.1