From d127d72c6542a66ba394b7789ff544fb0dadfa42 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 14 十一月 2023 16:31:59 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   98 +++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 94 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index f32b182..119c1e8 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -1213,7 +1213,7 @@
 
             //鑾峰彇鎻愬崌鏈哄懡浠�
             NyLiftCommand liftCommand = NyLiftUtils.getLiftCommand(liftProtocol.getLiftNo().intValue(), NyLiftTaskModelType.MOVE_TRAY.id, startSta, targetSta, wrkMast.getWrkNo());
-            if (wrkMast.getIoType() == 53) {
+            if (wrkMast.getIoType() == 53 || wrkMast.getIoType() == 57) {
                 //鎷f枡鍐嶅洖搴擄紝閲嶆柊鍒嗛厤璁惧宸ヤ綔鍙�
                 Random random = new Random();
                 int deviceWrk = Math.abs((liftCommand.getTaskNo().intValue() + random.nextInt(9999)));//鑾峰彇璁惧宸ヤ綔鍙�
@@ -2287,6 +2287,40 @@
         return false;
     }
 
+    /**
+     * AGV琛ヨ揣(鎮寕绾块�氱煡AGV鍙栬揣)
+     */
+    public void agvRestockIntoByHangingWire() {
+        //妫�娴�350鍜�351鎵爜鍣�
+        int[] barcodeStaNo = {10, 11};//10 => 350绔欐壂鐮佸櫒,11 => 351绔欐壂鐮佸櫒
+        for (int staNo : barcodeStaNo) {
+            // 鑾峰彇鏉$爜鎵弿浠俊鎭�
+            BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, staNo);
+            if (barcodeThread == null) {
+                continue;
+            }
+            String barcode = barcodeThread.getBarcode();
+            if(!Cools.isEmpty(barcode)) {
+                if (barcode.contains("NoRead")) {
+                    continue;
+                }
+
+                String agvStaNo = null;
+                if (staNo == 10) {
+                    agvStaNo = "303-1";
+                }else {
+                    agvStaNo = "304-1";
+                }
+                //閫氱煡AGV鍙栬揣
+                boolean result = agvRestockCall(agvStaNo, barcode);
+                if (result) {
+                    barcodeThread.setBarcode("");
+                }
+                log.info(barcodeThread.getSlave().getId() + "鍙锋壂鐮佸櫒锛岄�氱煡AGV鍙栬揣锛屾潯鐮佸彿锛�" + barcode);
+            }
+        }
+    }
+
     // 300绔欐嫞鏂�
     public void pick300() {
         //妫�娴�300绔欐槸鍚﹁嚜鍔ㄣ�佹湁鐗┿�佸伐浣滃彿
@@ -2384,8 +2418,64 @@
                 ledCommand.setLocNo(wrkMast.getLocNo());
                 ledCommand.setStaNo(wrkMast.getStaNo());
                 if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) {
-                    List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkMast.getWrkNo());
-                    wrkDetls.forEach(wrkDetl -> ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getAnfme(),wrkDetl.getSpecs())));
+                    //for (WrkDetl wrkDetl : wrkDetls) {
+                    //    LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("zpallet", wrkDetl.getZpallet()).eq("matnr", wrkDetl.getMatnr()));
+                    //
+                    //    locDetls.forEach(locDetl1 -> {
+                    //        //宸ヤ綔妗d腑瀛樺湪璇ョ墿鏂欏垯璺宠繃
+                    //        String suppCode = "";
+                    //
+                    //        if (wrkDetl.getMatnr().equals(locDetl1.getMatnr())) {
+                    //            Double anfme = 0D;
+                    //            if (locDetl != null) {
+                    //                anfme = locDetl.getAnfme();
+                    //            }
+                    //            if (wrkDetl.getSuppCode() != null) {
+                    //                suppCode = wrkDetl.getSuppCode();
+                    //            }
+                    //            ledCommand.getMatDtos()
+                    //                    .add(new MatDto(wrkDetl.getMatnr()
+                    //                            , wrkDetl.getMaktx()
+                    //                            , wrkDetl.getAnfme()
+                    //                            , (wrkDetl.getAnfme()-anfme)
+                    //                            , wrkDetl.getSpecs()
+                    //                            , suppCode));
+                    //        } else {
+                    //            if (locDetl1.getSuppCode() != null) {
+                    //                suppCode = locDetl1.getSuppCode();
+                    //            }
+                    //            ledCommand.getMatDtos()
+                    //                    .add(new MatDto(locDetl1.getMatnr()
+                    //                            , locDetl1.getMaktx()
+                    //                            , 0D
+                    //                            , locDetl1.getAnfme()
+                    //                            , locDetl1.getSpecs()
+                    //                            , suppCode));
+                    //        }
+                    //    });
+                    //    //LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("zpallet", wrkDetl.getZpallet()).eq("matnr", wrkDetl.getMatnr()));
+                    //}
+                    List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getSourceLocNo()));
+                    locDetls.forEach(locDetl -> {
+                        Wrapper<WrkDetl> wrapper = new EntityWrapper<WrkDetl>().eq("matnr", locDetl.getMatnr()).eq("wrk_no",wrkMast.getWrkNo());
+                        Utils.wapperSetCondition(wrapper,"batch",locDetl.getBatch());
+                        Utils.wapperSetCondition(wrapper,"three_code",locDetl.getThreeCode());
+                        Utils.wapperSetCondition(wrapper,"dead_time",locDetl.getDeadTime());
+                        WrkDetl detl = wrkDetlService.selectOne(wrapper);
+                        if (Cools.isEmpty(detl)) {
+                            String suppCode = "";
+                            if (locDetl.getSuppCode() != null) {
+                                suppCode = locDetl.getSuppCode();
+                            }
+                            ledCommand.getMatDtos().add(new MatDto(locDetl.getMatnr(), locDetl.getMaktx(), 0D, locDetl.getAnfme(), locDetl.getSpecs(), suppCode));
+                        } else {
+                            String suppCode = "";
+                            if (detl.getSuppCode() != null) {
+                                suppCode = detl.getSuppCode();
+                            }
+                            ledCommand.getMatDtos().add(new MatDto(detl.getMatnr(), detl.getMaktx(), detl.getAnfme(), (locDetl.getAnfme() - detl.getAnfme()), detl.getSpecs(), suppCode));
+                        }
+                    });
                 }
                 commands.add(ledCommand);
             }
@@ -2479,7 +2569,7 @@
             LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, led.getId());
             // led鏄剧ず榛樿鍐呭
             if (reset && !ledThread.isLedMk()) {
-                ledThread.setLedMk(true);
+                ledThread.setLedMk(false);
                 if (!MessageQueue.offer(SlaveType.Led, led.getId(), new Task(2, new ArrayList<>()))) {
                     News.error("{}鍙稬ED鍛戒护涓嬪彂澶辫触锛侊紒锛乕ip锛歿}] [port锛歿}]", led.getId(), led.getIp(), led.getPort());
                 }else {

--
Gitblit v1.9.1