From 6aa8f23171b3c881da774123f1c079d7d0b88691 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期三, 03 四月 2024 13:07:04 +0800
Subject: [PATCH] Merge branch 'Four-Way-Rack' of http://47.97.1.152:5880/r/zy-asrs-master into Four-Way-Rack

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java |  126 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 126 insertions(+), 0 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
index 0b8e774..b804446 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
@@ -123,4 +123,130 @@
         }
     }
 
+    /**
+     * 鍥涘悜绌挎杞︾數閲忔娴� ===>> 鍙戣捣鍏呯數
+     */
+    public synchronized void loopShuttleCharge() {
+//        ShuttleChargeType shuttleCharge = ShuttleChargeType.CHARGE_1;
+//        for (ShuttleSlave shuttle : slaveProperties.getShuttle()) {
+//            // 鍒ゆ柇鍏呯數浣嶆槸鍚﹁鍗犵敤
+//            if (wrkChargeService.hasShuttleInChargeLoc(shuttleCharge.locNo, shuttle.getId())) {
+//                continue;
+//            }
+//
+//            //鑾峰彇鍥涘悜绌挎杞︾嚎绋�
+//            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttle.getId());
+//            ShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol();
+//            if (shuttleProtocol == null) {
+//                continue;
+//            }
+//            if (motionService.selectCount(new EntityWrapper<Motion>()
+//                    .eq("device_ctg", DeviceCtgType.SHUTTLE.val())
+//                    .eq("device", shuttle.getId())
+//                    .eq("motion_sts", MotionStsType.EXECUTING.val())) > 0) {
+//                continue;
+//            }
+//
+//            //鍒ゆ柇褰撳墠灏忚溅鏄惁婊¤冻闇�瑕佸厖鐢佃姹�
+//            if (!shuttleProtocol.isRequireCharge()) {
+//                continue;
+//            }
+//
+//            WrkCharge wrkCharge = wrkChargeService.selectWorking(null);
+//            if (wrkCharge != null) {//宸叉湁鍏呯數浠诲姟
+//                continue;
+//            }
+//
+//            String chargeLocNo = shuttleCharge.locNo;
+//            wrkCharge = new WrkCharge();
+//            wrkCharge.setShuttleNo(shuttle.getId());
+//            wrkCharge.setCharge(shuttleCharge.id);
+//            wrkCharge.setWrkNo(commonService.getChargeWorkNo(4));
+//            wrkCharge.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
+//            wrkCharge.setWrkSts(WrkMastStsType.NEW_CHARGE.sts);   // 鍏呯數浠诲姟
+//            wrkCharge.setIoType(WrkIoTypeType.CHARGE.sts);
+//            wrkCharge.setIoPri((double) 10);
+//            wrkCharge.setLocNo(chargeLocNo);
+//            wrkCharge.setMemo("charge");
+//            wrkCharge.setAppeTime(new Date());
+//
+//            // generate motion list
+//            List<Motion> motionList = analyzeService.generateChargeMotion(wrkCharge);
+//            if (Cools.isEmpty(motionList)) {
+//                News.error("淇濆瓨{}鍙峰洓鍚戠┛姊溅鍏呯數浠诲姟澶辫触!!!", shuttle.getId());
+//                continue;
+//            }
+//            motionService.batchInsert(motionList, wrkCharge.getUuid(), wrkCharge.getWrkNo());
+//
+//            wrkCharge.setWrkSts(WrkMastStsType.ANALYZE_CHARGE.sts);
+//
+//            if (!wrkChargeService.insert(wrkCharge)) {
+//                News.error("淇濆瓨{}鍙峰洓鍚戠┛姊溅鍏呯數浠诲姟澶辫触!!!", shuttle.getId());
+//                continue;
+//            }
+//
+//            News.info("淇濆瓨{}鍙峰洓鍚戠┛姊溅鍏呯數浠诲姟鎴愬姛!!!", shuttle.getId());
+//        }
+    }
+
+    /**
+     * 鍥涘悜绌挎杞︾數閲忔娴� ===>> 婊$數鍚庡洖鍒板緟鏈轰綅
+     */
+    public synchronized void loopShuttleToStandbyCauseCharge() {
+//        ShuttleChargeType shuttleCharge = ShuttleChargeType.CHARGE_1;
+//        Integer enoughPower = 90;
+//        Config config = configService.selectOne(new EntityWrapper<Config>()
+//                .eq("code", "chargeMaxValue")
+//                .eq("status", 1));
+//        if (config != null) {
+//            enoughPower = Integer.parseInt(config.getValue());
+//        }
+//
+//        for (ShuttleSlave shuttle : slaveProperties.getShuttle()) {
+//            //鑾峰彇鍥涘悜绌挎杞︾嚎绋�
+//            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttle.getId());
+//            ShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol();
+//            if (shuttleProtocol == null) {
+//                continue;
+//            }
+//            // 鏄惁瀛樺湪鍏呯數浠诲姟
+//            WrkCharge wrkCharge = wrkChargeService.selectWorking(shuttle.getId());
+//            if (wrkCharge == null) {
+//                continue;
+//            }
+//
+//            if (motionService.selectCount(new EntityWrapper<Motion>()
+//                    .eq("device_ctg", DeviceCtgType.SHUTTLE.val())
+//                    .eq("device", shuttle.getId())
+//                    .eq("motion_sts", MotionStsType.EXECUTING.val())) > 0) {
+//                continue;
+//            }
+//            // 涓嶅浜庡厖鐢典腑
+//            if (!shuttleProtocol.getPlcOutputCharge()) {
+//                continue;
+//            }
+//            // 鍦ㄥ厖鐢典綅
+//            if (!shuttleProtocol.getCurrentLocNo().equals(shuttleCharge.locNo)) {
+//                continue;
+//            }
+//            // 鐢甸噺鏄惁杈惧埌婊$數瑕佹眰
+//            if (shuttleProtocol.getBatteryPower$().intValue() < enoughPower) {
+//                continue;
+//            }
+//            // 宸叉湁杩佺Щ浠诲姟
+//            if (wrkChargeService.selectMoveWorking(shuttle.getId()) != null) {
+//                continue;
+//            }
+//
+//            // 寰呮満浣�
+//            String standByLocNo = ShuttleTempLocType.query(shuttleProtocol.getShuttleNo().intValue(), 2, Utils.getLev(shuttleCharge.locNo)).locNo;
+//
+//            shuttleDispatcher.generateShuttleChargeWrkComplete(shuttleProtocol.getShuttleNo().intValue(), standByLocNo);
+//
+//            wrkCharge.setWrkSts(WrkMastStsType.COMPLETE_CHARGE.sts);
+//            wrkCharge.setIoTime(new Date());
+//            wrkChargeMapper.updateById(wrkCharge);
+//        }
+    }
+
 }

--
Gitblit v1.9.1