From 97c6a268766387d9c6834c23c9da3fdf63f3dc3f Mon Sep 17 00:00:00 2001
From: tzsk <Administrator@qq.com>
Date: 星期三, 07 二月 2024 11:26:48 +0800
Subject: [PATCH] Changes

---
 src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java |  114 ++++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 96 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java
index 9c4db97..85f1aad 100644
--- a/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/AgvBasDevpServiceImpl.java
@@ -40,7 +40,7 @@
         //鍒濆鍖�1妤肩紦瀛樿揣鏋剁珯鐐� 2鎺�5鍒�3灞�
         this.insertBatch(getCacheBasDevpList(1,2,1,5,1,3,1));
         //鍒濆鍖�3妤肩紦瀛樿揣鏋剁珯鐐� 3鎺�5鍒�3灞�
-        this.insertBatch(getCacheBasDevpList(5,7,1,5,1,3,3));
+        this.insertBatch(getCacheBasDevpList(5,9,1,5,1,3,3));
         //鍒濆鍖�3妤艰緭閫佺嚎宸ヤ綔绔欑偣 4涓珯鐐�
         this.insertBatch(getLineBasDevpList());
 
@@ -100,8 +100,11 @@
                     .eq("station_code", stationCode)
                     .like("dev_no", "0" + i + "@");
 
-            if("CS-305".equals(stationCode) || "CS-306".equals(stationCode) || "CS-307".equals(stationCode)){
-                wrapper.orderBy("dev_no",false);
+            List<String> list = this.selectCacheShelvesStationCodeByFloor(3);
+            if(list.contains(stationCode)){
+                if(Cools.eq(stationCode,"CS-305") || Cools.eq(stationCode,"CS-306") || Cools.eq(stationCode,"CS-307")){
+                    wrapper.orderBy("dev_no",false);
+                }
             }
 
             List<AgvBasDevp> agvBasDevpList = this.selectList(wrapper);
@@ -117,33 +120,68 @@
                     return agvBasDevpDto;
                 }
 
-                AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>()
+                //涓�涓伐浣滀綅鍙兘浼氬搴斿涓伐浣滄。锛屾樉绀哄伐浣滅姸鎬佹渶澶х殑宸ヤ綔妗�
+                List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                         .eq("loc_no", agvBasDevpDto.getDevNo())
                         .or().eq("source_loc_no",agvBasDevpDto.getDevNo()));
+
+                AgvWrkMast agvWrkMast = null;
+                for (AgvWrkMast wrkMast : agvWrkMasts){
+                    if(Cools.isEmpty(agvWrkMast)){
+                        agvWrkMast = wrkMast;
+                    }else {
+                        if(agvWrkMast.getWrkSts() < wrkMast.getWrkSts()){
+                            agvWrkMast = wrkMast;
+                        }
+                    }
+                }
 
                 agvBasDevpDto.setAgvWrkMast(agvWrkMast);
 
                 if("F".equals(agvBasDevpDto.getLocSts()) || "R".equals(agvBasDevpDto.getLocSts())){
-                    AgvWaitPakin agvWaitPakin = agvWaitPakinService.selectOne(new EntityWrapper<AgvWaitPakin>()
+                    //AgvWaitPakin agvWaitPakin = agvWaitPakinService.selectOne(new EntityWrapper<AgvWaitPakin>().eq("supp_code", agvBasDevpDto.getBarcode()));
+                    List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>()
                             .eq("supp_code", agvBasDevpDto.getBarcode()));
 
-                    agvBasDevpDto.setAgvWaitPakin(agvWaitPakin);
+                    //濡傛灉鏈夊叆搴撻�氱煡妗o紝鍒欒宸ヤ綔浣嶄负鍏ュ簱浣滀笟
+                    if(!Cools.isEmpty(agvWaitPakinList)){
+                        //鐢ㄤ簬鐢佃鏈烘樉绀�
+                        agvBasDevpDto.setAgvWaitPakins(agvWaitPakinList);
+                        //鐢ㄤ簬鍙鍖栫珯鐐规樉绀�
+                        agvBasDevpDto.setAgvWaitPakin(agvWaitPakinList.get(0));
+                    }
 
-                    if(Cools.isEmpty(agvWaitPakin)){
-                        AgvWrkDetl agvWrkDetl = agvWrkDetlService.selectOne(new EntityWrapper<AgvWrkDetl>().
-                                eq("wrk_no",agvWrkMast.getWrkNo()));
+                    //濡傛灉娌℃湁鍏ュ簱閫氱煡妗o紝鍒欒宸ヤ綔浣嶄负鍑哄簱浣滀笟
+                    if(Cools.isEmpty(agvWaitPakinList)){
+                        List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", agvWrkMast.getWrkNo()));
+
                         //agv绔欑偣鍙鍖栫鐞嗕腑鐨勭粨浣欐暟閲忔樉绀�
-                        agvWrkDetl.setVolume(0.0);
-                        if(agvWrkMast.getIoType() == 103){
-                            AgvLocDetl agvLocDetl = agvLocDetlService.selectByLocNo(agvWrkMast.getSourceLocNo());
-                            agvWrkDetl.setVolume(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());
+                        for(AgvWrkDetl agvWrkDetl : agvWrkDetlList){
+                            agvWrkDetl.setVolume(0.0);
+                            if(agvWrkMast.getIoType() == 103){
+                                //瀵绘壘鏄惁鏈夌浉鍚岀墿鏂欑殑宸ヤ綔妗f槑缁嗭紝骞惰繑鍥炴暟閲忎箣鍜�
+                                double anfme = getAllAnfmeInAgvWrkDetlList(agvWrkDetlList,agvWrkDetl);
+                                AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getSourceLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime());
+                                //鐢ㄤ簬缁撲綑鏁伴噺鏄剧ず
+                                agvWrkDetl.setVolume(agvLocDetl.getAnfme() - anfme);
+                            }
+                            if(agvWrkMast.getIoType() == 53){
+                                AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime());
+                                if(Cools.isEmpty(agvLocDetl)){
+                                    agvWrkDetl.setVolume(0.0);
+                                }else {
+                                    agvWrkDetl.setVolume(agvLocDetl.getAnfme());
+                                }
+                            }
                         }
-                        if(agvWrkMast.getIoType() == 53){
-                            AgvLocDetl agvLocDetl = agvLocDetlService.selectByLocNo(agvWrkMast.getLocNo());
-                            agvWrkDetl.setVolume(agvLocDetl.getAnfme());
-                            //agvWrkDetl.setAnfme(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());
+
+                        if(!Cools.isEmpty(agvWrkDetlList)){
+                            //鐢ㄤ簬鐢佃鏈烘樉绀�
+                            agvBasDevpDto.setAgvWrkDetls(agvWrkDetlList);
+                            //鐢ㄤ簬鍙鍖栫珯鐐规樉绀�
+                            agvBasDevpDto.setAgvWrkDetl(agvWrkDetlList.get(0));
                         }
-                        agvBasDevpDto.setAgvWrkDetl(agvWrkDetl);
+
                     }
                 }
 
@@ -163,6 +201,19 @@
         result.put("body", body);
 
         return result;
+    }
+
+    private double getAllAnfmeInAgvWrkDetlList(List<AgvWrkDetl> agvWrkDetlList, AgvWrkDetl wd0) {
+        double allAnfme = 0;
+        for (AgvWrkDetl wd1 : agvWrkDetlList){
+            if(Cools.eq(wd0.getMatnr(),wd1.getMatnr())
+                    && Cools.eq(wd0.getBatch(),wd1.getBatch())
+                    && Cools.eq(wd0.getThreeCode(),wd1.getThreeCode())
+                    && Cools.eq(wd0.getDeadTime(),wd1.getDeadTime())){
+                allAnfme += wd1.getAnfme();
+            }
+        }
+        return allAnfme;
     }
 
     private void setFlagForAgvBasDevpDto(AgvWrkMast agvWrkMast, AgvBasDevpDto agvBasDevpDto){
@@ -194,4 +245,31 @@
         return this.selectOne(new EntityWrapper<AgvBasDevp>().eq("dev_no",devNo));
     }
 
+    @Override
+    public AgvBasDevp selectEmptyDevpByStation(String stationCode) {
+        return this.selectOne(new EntityWrapper<AgvBasDevp>()
+                .eq("station_code", stationCode)
+                .eq("loc_sts", "O"));
+    }
+
+    @Override
+    public List<AgvBasDevp> getBasDevpByNoCacheShelves() {
+        return this.selectList(new EntityWrapper<AgvBasDevp>().eq("cache_shelves","N"));
+    }
+
+    @Override
+    public List<String> selectCacheShelvesStationCodeByFloor(int floor) {
+        //Object o = this.selectList(new EntityWrapper<AgvBasDevp>().setSqlSelect("station_code").eq("floor",floor).eq("cache_shelves","Y").groupBy("station_code"));
+        return this.baseMapper.selectCacheShelvesStationCodeByFloor(floor);
+    }
+
+    public List<Map<String,Object>> selectDevNoAndNumBystationCode(String stationCode){
+        return this.baseMapper.selectDevNoAndNumBystationCode(stationCode);
+    }
+
+    @Override
+    public List<String> selectAllStationCode() {
+        return this.baseMapper.selectAllStationCode();
+    }
+
 }

--
Gitblit v1.9.1