From 30fd531c95ece1c0e7306cad138307dedd459d9a Mon Sep 17 00:00:00 2001
From: wangfei <3597712270@qq.com>
Date: 星期三, 19 二月 2025 08:49:50 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10105/r/YiWuProject

---
 hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java |   36 ++++++++++++++++++++++++++++++++++++
 1 files changed, 36 insertions(+), 0 deletions(-)

diff --git a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java
index d4ba068..c6dfac3 100644
--- a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java
+++ b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/RawGlassTask.java
@@ -117,6 +117,11 @@
             log.info("鎵ц鍏ュ簱浠诲姟");
             return;
         }
+        flag = shelfResetTask();
+        if (flag) {
+            log.info("鎵ц澶嶄綅浠诲姟");
+            return;
+        }
         log.info("鏃犱换鍔℃墽琛岋紝缁撴潫");
     }
 
@@ -280,6 +285,37 @@
         return Boolean.TRUE;
     }
 
+
+    /**
+     * 澶嶄綅浠诲姟锛�1銆佺偣澶嶄綅锛岀珛椹敓鎴愬浣嶄换鍔� 2銆佺偣鍑哄簱淇敼宸ヤ綅璇︽儏鍐呯殑鐘舵�佷负鏋跺瓙澶嶄綅锛屽畾鏃朵换鍔℃壂鎻忕敓鎴愬浣嶄换鍔�
+     */
+    public boolean shelfResetTask() throws Exception {
+        List<RawGlassStorageDetails> rawGlassList = rawGlassStorageDetailsService.list(new LambdaQueryWrapper<RawGlassStorageDetails>()
+                .eq(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_RESET)
+                .inSql(RawGlassStorageDetails::getSlot, "select slot from raw_glass_storage_station where enable_state = 1"));
+        if (CollectionUtil.isEmpty(rawGlassList)) {
+            log.info("绯荤粺娌℃湁闇�瑕佸浣嶇殑鍘熺墖淇℃伅");
+            return Boolean.FALSE;
+        }
+        //鐢熸垚澶嶄綅浠诲姟
+
+        rawGlassStorageDetailsService.generateTask(rawGlassList.get(0).getSlot(), rawGlassList.get(0).getShelf(), rawGlassList.get(0).getShelf(), rawGlassList.get(0).getRemainQuantity(), Const.RAW_GLASS_TASK_TYPE_DISPATCH);
+
+//        List<ReadWriteEntity> list = new ArrayList<>();
+//        list.add(generateReadWriteEntity("CC.CC.taskWord", 1));
+//        list.add(generateReadWriteEntity("CC.CC.taskSending", 1));
+//        list.add(generateReadWriteEntity("CC.CC.startSlot", startSlot));
+//        list.add(generateReadWriteEntity("CC.CC.endSlot", lefting));
+//        miloService.writeToOpcWord(list);
+
+        //淇敼澶嶄綅浠诲姟鐘舵��
+        rawGlassStorageDetailsService.update(new LambdaUpdateWrapper<RawGlassStorageDetails>()
+                .eq(RawGlassStorageDetails::getSlot, rawGlassList.get(0).getSlot())
+                .eq(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_RESET)
+                .set(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_RUNNING));
+        return Boolean.TRUE;
+    }
+
     /**
      * 鍏ュ簱浠诲姟锛氬悐瑁呬綅鏈夌幓鐠冿紝鍏堝幓宸ヤ綅琛ㄦ煡璇㈢┖鏍煎瓙锛岀敓鎴愬叆搴撲换鍔′粠鍚婅浣嶅埌鐩爣鏍煎瓙
      *

--
Gitblit v1.8.0