From a52b87449e493d4312cc81c33a4169eb6be3c144 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期二, 01 四月 2025 09:14:19 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10105/r/YiWuProject

---
 hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/opctask/service/impl/EdgStorageDeviceTaskServiceImpl.java |   52 +++++++++++++++++++++++++---------------------------
 1 files changed, 25 insertions(+), 27 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/opctask/service/impl/EdgStorageDeviceTaskServiceImpl.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/opctask/service/impl/EdgStorageDeviceTaskServiceImpl.java
index d4d3e3f..d41a4cd 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/opctask/service/impl/EdgStorageDeviceTaskServiceImpl.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/opctask/service/impl/EdgStorageDeviceTaskServiceImpl.java
@@ -9,7 +9,6 @@
 import com.mes.edgstoragecage.entity.vo.EdgSlotRemainVO;
 import com.mes.edgstoragecage.service.EdgStorageCageDetailsService;
 import com.mes.edgstoragecage.service.EdgStorageCageService;
-import com.mes.job.OpcCacheGlassTask;
 import com.mes.opctask.entity.EdgStorageDeviceTask;
 import com.mes.opctask.entity.EdgStorageDeviceTaskHistory;
 import com.mes.opctask.mapper.EdgStorageDeviceTaskMapper;
@@ -66,33 +65,32 @@
                 .eq(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_NEW)
                 .eq(EdgStorageDeviceTaskHistory::getDeviceId, deviceId)
                 .orderByDesc(EdgStorageDeviceTaskHistory::getCreateTime).last("limit 1"));
-        if (taskHistory == null) {
-            return Boolean.FALSE;
-        }
-        Integer cell = taskHistory.getStartCell();
-        Integer taskType = taskHistory.getTaskType();
-        if (Const.GLASS_CACHE_TYPE_IN_ALL.contains(taskType)) {
-            String glassId = taskHistory.getGlassIdIn();
-            edgStorageCageDetailsService.remove(new LambdaQueryWrapper<EdgStorageCageDetails>()
-                    .eq(EdgStorageCageDetails::getDeviceId, deviceId)
-                    .eq(EdgStorageCageDetails::getSlot, cell)
-                    .eq(EdgStorageCageDetails::getGlassId, glassId));
-        } else {
-            String glassId = taskHistory.getGlassIdOut();
-            edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
-                    .set(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
-                    .eq(EdgStorageCageDetails::getDeviceId, deviceId)
-                    .eq(EdgStorageCageDetails::getSlot, cell)
-                    .eq(EdgStorageCageDetails::getGlassId, glassId));
-        }
+        if (taskHistory != null) {
+            Integer cell = taskHistory.getStartCell();
+            Integer taskType = taskHistory.getTaskType();
+            if (Const.GLASS_CACHE_TYPE_IN_ALL.contains(taskType)) {
+                String glassId = taskHistory.getGlassIdIn();
+                edgStorageCageDetailsService.remove(new LambdaQueryWrapper<EdgStorageCageDetails>()
+                        .eq(EdgStorageCageDetails::getDeviceId, deviceId)
+                        .eq(EdgStorageCageDetails::getSlot, cell)
+                        .eq(EdgStorageCageDetails::getGlassId, glassId));
+            } else {
+                String glassId = taskHistory.getGlassIdOut();
+                edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
+                        .set(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN)
+                        .eq(EdgStorageCageDetails::getDeviceId, deviceId)
+                        .eq(EdgStorageCageDetails::getSlot, cell)
+                        .eq(EdgStorageCageDetails::getGlassId, glassId));
+            }
 
-        edgStorageDeviceTaskHistoryService.update(new LambdaUpdateWrapper<EdgStorageDeviceTaskHistory>()
-                .eq(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_NEW)
-                .eq(EdgStorageDeviceTaskHistory::getDeviceId, deviceId)
-                .set(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_FAILURE)
-        );
-        //璁$畻姣忎釜鍚勮嚜鐨勫墿浣欏昂瀵镐俊鎭�
-        resetSlotRemainWidth();
+            edgStorageDeviceTaskHistoryService.update(new LambdaUpdateWrapper<EdgStorageDeviceTaskHistory>()
+                    .eq(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_NEW)
+                    .eq(EdgStorageDeviceTaskHistory::getDeviceId, deviceId)
+                    .set(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_FAILURE)
+            );
+            //璁$畻姣忎釜鍚勮嚜鐨勫墿浣欏昂瀵镐俊鎭�
+            resetSlotRemainWidth();
+        }
         //鏈�鍚庢洿鏂颁换鍔★紝淇濊瘉浠诲姟鍓嶇殑鍔ㄤ綔閮藉仛瀹�
         EdgStorageDeviceTask task = new EdgStorageDeviceTask();
         task.setTaskRunning(Const.GLASS_CACHE_TYPE_EMPTY);

--
Gitblit v1.8.0