From 541cf632855fb991e400df21a64522d56d9f477d Mon Sep 17 00:00:00 2001
From: yxFwq <1>
Date: 星期三, 30 十月 2024 09:36:27 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   24 +++++++++++++++---------
 1 files changed, 15 insertions(+), 9 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 9e2a822..b56a323 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -5120,8 +5120,9 @@
                                 break;
                             }
                             BasJar basJar = basJarMapper.selectById(jarSlave.getId());
+                            BasJar basJarOther = basJarMapper.selectById(jarSlave.getJarOtherId());
                             jarMaxLoc = basJar.getJarCount();
-                            if (jarMaxLoc == 0) {
+                            if (jarMaxLoc == 0 || basJarOther.getJarCount() != 0) {
                                 break;
                             }
                             int count = basJarMastService.selectCount(new EntityWrapper<BasJarMast>().eq("jar_regin", basJar.getRegion()).lt("status", 17).gt("status", 11));
@@ -5129,7 +5130,7 @@
                                 break;
                             }
                             if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),3)!=0){
-                                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 3).equals(jarMaxLoc)){
+                                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 3).equals(basJarOther.getJarCount())){
                                     JarThread jarOtherThread = (JarThread) SlaveConnection.get(SlaveType.Jar, jarSlave.getJarOtherId());
                                     JarProtocol jarOtherProtocol = jarOtherThread.getJarProtocol();
                                     if (jarOtherProtocol == null) {
@@ -5760,11 +5761,6 @@
             List<BasJarMast> basJarMastList = basJarMastService.getJarMastByJarIdAndStatusList(jarSlave.getId(), new ArrayList<Integer>() {{
                 add(6);
             }});
-//            if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),5)!=0
-//                    && basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),5)!=jarMaxLoc
-//                    && basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),5)!=jarMaxLoc*2){
-//                return false;
-//            }
             if (basJarMastList.isEmpty()){
                 return false;
             }
@@ -5912,7 +5908,17 @@
                 if (basJarMastList10.size()==jarMaxLoc){
                     return false;
                 }
-                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),4)!=0 && !basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 4).equals(jarMaxLoc)){
+
+                BasJar basJarOther = basJarMapper.selectById(jarSlave.getJarOtherId());
+                if (Cools.isEmpty(basJarOther)){
+                    log.error("{}鍙风~鍖栫綈鏌ヨ璁惧妗f鏃犱俊鎭紒锛侊紒",jarSlave.getJarOtherId());
+                    return false;
+                }
+
+                if (basJarOther.getJarCount() == 0) {
+                    return false;
+                }
+                if (basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(),4)!=0 && !basJarMastService.selectJarMastOperation(jarSlave.getJarOtherId(), 4).equals(basJarOther.getJarCount() )){
                     return false;
                 }
 
@@ -8680,7 +8686,7 @@
         try {
             int[] jarNos=new int[]{3,1,4,2};//(607鍒嗛厤纭寲缃�)
             ArrayList<Integer> staNos = new ArrayList<Integer>() {{
-                add(607);add(608);add(609);add(610);add(611);add(612);
+                add(608);add(609);add(610);add(611);add(612);
                 add(613);add(614);add(615);add(616);add(617);add(618);
                 add(619);add(620);add(621);add(622);
             }};

--
Gitblit v1.9.1