From 266ca8c80300d479351eed50fee5a30751a22fda Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期四, 09 十月 2025 11:46:11 +0800
Subject: [PATCH] 1、中空领取任务界面查询慢解决 2、卧理新增日志记录

---
 hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcPlcStorageCageHollowTask.java |  265 ++++++++++++++++++++++++++++++++++------------------
 1 files changed, 173 insertions(+), 92 deletions(-)

diff --git a/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcPlcStorageCageHollowTask.java b/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcPlcStorageCageHollowTask.java
index da9d263..07ae663 100644
--- a/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcPlcStorageCageHollowTask.java
+++ b/hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcPlcStorageCageHollowTask.java
@@ -10,6 +10,8 @@
 import com.github.xingshuangs.iot.protocol.s7.serializer.S7Serializer;
 import com.kangaroohy.milo.model.ReadWriteEntity;
 import com.kangaroohy.milo.service.MiloService;
+import com.mes.alarm.entity.ProductAlarmInfo;
+import com.mes.alarm.service.ProductAlarmInfoService;
 import com.mes.base.entity.HollowBigStorageCageBaseInfo;
 import com.mes.bigstoragecagetask.entity.BigStorageCageTask;
 import com.mes.bigstoragecagetask.service.BigStorageCageTaskService;
@@ -101,8 +103,20 @@
     @Qualifier("CMJ1ModbusTcp")
     ModbusTcp CMJ1ModbusTcp;
 
+    @Resource
+    private ProductAlarmInfoService productAlarmInfoService;
+
     private static final String BIG_STORAGE_CAGE_IN_TWO_TASK = "big_storage_cage_in_two_task";
     private static final String BIG_STORAGE_CAGE_OUT_TWO_TASK = "big_storage_cage_out_two_task";
+
+    private static final List<Integer> ONE_LINE_FIRST = Arrays.asList(930, 931, 932);
+    private static final List<Integer> TWO_LINE_FIRST = Arrays.asList(931, 930, 932);
+
+
+    private static final String ALARM_MODULE = "涓┖";
+    private static final String ALARM_TYPE = "涓┖澶х悊鐗�";
+    private static final String ALARM_CODE_SIZE = "sizeSame";
+    private static final String ALARM_CODE_ID = "idSame";
 
     /**
      * 鐩撮�氭牸瀛�
@@ -115,6 +129,14 @@
 
     @Scheduled(fixedDelay = 1000)
     public void inBigStorageTask() {
+        List<ProductAlarmInfo> alarmInfos = productAlarmInfoService.list(new LambdaQueryWrapper<ProductAlarmInfo>()
+                .eq(ProductAlarmInfo::getState, Const.LOAD_RAW_GLASS_NEW)
+                .eq(ProductAlarmInfo::getAlarmModule, ALARM_MODULE)
+                .eq(ProductAlarmInfo::getAlarmType, ALARM_TYPE));
+        if (CollectionUtil.isNotEmpty(alarmInfos)) {
+            log.info("鐣岄潰鎶ヨ锛岀瓑寰呬汉宸ュ共棰勫鐞�");
+            return;
+        }
         S7DataZKDLPOne s7DataZKDLPOne = s7SerializerZKDLPOne.read(S7DataZKDLPOne.class);
         log.info("杩涚墖浠诲姟璇诲彇s7DataZKDLPOne:{}", s7DataZKDLPOne);
         Boolean inkageEntity = s7DataZKDLPOne.getMesControl();
@@ -157,6 +179,13 @@
         for (Map.Entry<String, Long> entry : glassCountMap.entrySet()) {
             if (entry.getValue() > 1) {
                 log.info("杩涚墖鐜荤拑{}瀛樺湪鐩稿悓锛岀粨鏉熸湰娆′换鍔�", entry.getKey());
+                ProductAlarmInfo alarmInfo = new ProductAlarmInfo();
+                alarmInfo.setState(Const.LOAD_RAW_GLASS_NEW);
+                alarmInfo.setAlarmModule(ALARM_MODULE);
+                alarmInfo.setAlarmType(ALARM_TYPE);
+                alarmInfo.setAlarmCode(ALARM_CODE_ID);
+                alarmInfo.setAlarmMessage(entry.getKey());
+                productAlarmInfoService.save(alarmInfo);
                 //鍚憄lc鍙戦�佹姤璀�:鍚屼竴杞﹁繘鐗囩幓鐠冨瓨鍦ㄧ浉鍚�
                 s7DataZKDLPOne = new S7DataZKDLPOne();
                 s7DataZKDLPOne.setAlramSignal(2);
@@ -169,6 +198,16 @@
         if (CollectionUtil.isNotEmpty(detailsList)) {
             log.info("鐞嗙墖绗煎瓨鍦ㄧ浉鍚岀殑杩涚墖鐜荤拑{}锛岀粨鏉熸湰娆′换鍔�", detailsList);
             //鍚憄lc鍙戦�佹姤璀�:鐞嗙墖绗煎瓨鍦ㄧ浉鍚岀殑杩涚墖鐜荤拑
+            List<String> sameGlassIds = detailsList.stream()
+                    .map(HollowBigStorageCageDetails::getGlassId)
+                    .collect(Collectors.toList());
+            ProductAlarmInfo alarmInfo = new ProductAlarmInfo();
+            alarmInfo.setState(Const.LOAD_RAW_GLASS_NEW);
+            alarmInfo.setAlarmModule(ALARM_MODULE);
+            alarmInfo.setAlarmType(ALARM_TYPE);
+            alarmInfo.setAlarmCode(ALARM_CODE_ID);
+            alarmInfo.setAlarmMessage(sameGlassIds.toString());
+            productAlarmInfoService.save(alarmInfo);
             s7DataZKDLPOne = new S7DataZKDLPOne();
             s7DataZKDLPOne.setAlramSignal(4);
             s7SerializerZKDLPOne.write(s7DataZKDLPOne);
@@ -237,51 +276,49 @@
         List<HollowBigStorageCageHistoryTask> historyTasks = new ArrayList<>();
 
         Integer glassGap = sysConfigService.queryConfigValue(ConstSysConfig.HOLLOW_GLASS_GAP);
-        try {
-            log.info("寮�濮嬭绠楃洰鏍囨牸瀛�,鐜荤拑id鏈夛細{}", inTaskList);
-            if (slotMaxHeight > Math.min(glassInfoList.get(0).getWidth(), glassInfoList.get(0).getHeight()) && glassInfoList.get(0).getThickness() < slotMaxthickness) {
-                for (BigStorageCageTask task : inTaskList) {
-                    GlassInfo info = glassListMap.get(task.getGlassId()).get(0);
-                    HollowBigStorageDTO bigStorageDTO = hollowGlassRelationInfoService.queryHollowTargetSlot(info.getFlowCardId(), info.getGlassType(),
+
+        log.info("寮�濮嬭绠楃洰鏍囨牸瀛�,鐜荤拑id鏈夛細{}", inTaskList);
+        if (slotMaxHeight > Math.min(glassInfoList.get(0).getWidth(), glassInfoList.get(0).getHeight()) && glassInfoList.get(0).getThickness() < slotMaxthickness) {
+            for (BigStorageCageTask task : inTaskList) {
+                GlassInfo info = glassListMap.get(task.getGlassId()).get(0);
+                HollowBigStorageDTO bigStorageDTO = null;
+                try {
+                    bigStorageDTO = hollowGlassRelationInfoService.queryHollowTargetSlot(info.getFlowCardId(), info.getGlassType(),
                             info.getWidth(), info.getHeight(), info.getTotalLayer(), info.getLayer());
-//            涓存椂鏇存柊鏍煎瓙鐨勫墿浣欏昂瀵革細闃叉鐩搁偦鐜荤拑杩涘悓涓�鏍煎瓙閫犳垚鍓╀綑灏哄涓嶈冻锛岀幓鐠冭秺鐣岀殑鎯呭喌锛屼换鍔″畬鎴愬悗鍐嶆鏇存柊澶х悊鐗囩琛ㄥ墿浣欏搴︼紙鎸夌収绗煎唴鐜荤拑鏁伴噺鏇存柊澶х悊鐗囩鍓╀綑灏哄锛�
-                    hollowBigStorageCageService.update(new LambdaUpdateWrapper<HollowBigStorageCage>()
-                            .set(HollowBigStorageCage::getRemainWidth, bigStorageDTO.getRemainWidth() - Math.max(info.getWidth(), info.getHeight()) - glassGap)
-                            .eq(HollowBigStorageCage::getSlot, bigStorageDTO.getSlot()));
-                    task.setTargetSlot(bigStorageDTO.getSlot());
-                    task.setGlassId(info.getGlassId());
-                    //瀛樻斁鍘嗗彶浠诲姟
-                    HollowBigStorageCageHistoryTask historyTask = new HollowBigStorageCageHistoryTask();
-                    BeanUtils.copyProperties(task, historyTask);
-                    historyTask.setTaskType(Const.BIG_STORAGE_AFTER_IN);
-                    historyTask.setGlassCount(glassInfoList.size());
-                    historyTask.setTaskState(Const.ENGINEERING_NEW);
-                    historyTasks.add(historyTask);
-                    //瀛樻斁璇︽儏鏁版嵁
-                    HollowBigStorageCageDetails cageDetails = new HollowBigStorageCageDetails();
-                    BeanUtils.copyProperties(bigStorageDTO, cageDetails);
-                    BeanUtils.copyProperties(info, cageDetails);
-                    cageDetails.setState(Const.GLASS_STATE_NEW);
-                    cageDetails.setSequence(bigStorageDTO.getSlotSequence());
-                    cageDetails.setGap(glassGap);
-                    cageDetails.setId(null);
-                    hollowBigStorageCageDetailsService.save(cageDetails);
+                } catch (Exception exception) {
+                    log.info("杩涚墖浠诲姟鎵ц涓彂鐢熷紓甯革細{}", exception);
+                    //淇濆瓨鏁呴殰淇℃伅
+                    ProductAlarmInfo alarmInfo = new ProductAlarmInfo();
+                    alarmInfo.setState(Const.LOAD_RAW_GLASS_NEW);
+                    alarmInfo.setAlarmModule(ALARM_MODULE);
+                    alarmInfo.setAlarmType(ALARM_TYPE);
+                    alarmInfo.setAlarmCode(ALARM_CODE_SIZE);
+                    alarmInfo.setAlarmMessage(info.getGlassId());
+                    productAlarmInfoService.save(alarmInfo);
+                    //閲嶇疆璇︽儏琛ㄦ暟鎹�
+                    hollowBigStorageCageDetailsService.update(new LambdaUpdateWrapper<HollowBigStorageCageDetails>()
+                            .set(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_TAKE)
+                            .eq(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_NEW));
+                    //閲嶇疆涓┖鍏崇郴琛ㄦ暟鎹�
                     hollowGlassRelationInfoService.update(new LambdaUpdateWrapper<HollowGlassRelationInfo>()
-                            .set(HollowGlassRelationInfo::getGlassId, cageDetails.getGlassId())
-                            .set(HollowGlassRelationInfo::getTemperingLayoutId, cageDetails.getTemperingLayoutId())
-                            .set(HollowGlassRelationInfo::getTemperingFeedSequence, cageDetails.getTemperingFeedSequence())
-                            .set(HollowGlassRelationInfo::getEngineerId, cageDetails.getEngineerId())
-                            .set(HollowGlassRelationInfo::getState, Const.HOLLOW_RELATION_OCCUPY)
-                            .eq(HollowGlassRelationInfo::getFlowCardId, bigStorageDTO.getFlowCardId())
-                            .eq(HollowGlassRelationInfo::getLayer, bigStorageDTO.getLayer())
-                            .eq(HollowGlassRelationInfo::getVirtualSlot, bigStorageDTO.getVirtualSlot())
-                            .eq(HollowGlassRelationInfo::getSlotSequence, bigStorageDTO.getSlotSequence())
-                            .eq(HollowGlassRelationInfo::getHollowSequence, bigStorageDTO.getHollowSequence())
+                            .set(HollowGlassRelationInfo::getGlassId, null)
+                            .set(HollowGlassRelationInfo::getTemperingLayoutId, null)
+                            .set(HollowGlassRelationInfo::getTemperingFeedSequence, null)
+                            .set(HollowGlassRelationInfo::getEngineerId, null)
+                            .set(HollowGlassRelationInfo::getState, Const.HOLLOW_RELATION_NEW)
+                            .eq(HollowGlassRelationInfo::getState, Const.HOLLOW_RELATION_OCCUPY)
                     );
+                    //灏嗘牸瀛愬昂瀵告仮澶�
+                    hollowBigStorageCageService.resetCage();
+                    return;
                 }
-            } else {
-                BigStorageCageTask task = inTaskList.get(0);
-                task.setTargetSlot(THROUGH_SLOT);
+
+//            涓存椂鏇存柊鏍煎瓙鐨勫墿浣欏昂瀵革細闃叉鐩搁偦鐜荤拑杩涘悓涓�鏍煎瓙閫犳垚鍓╀綑灏哄涓嶈冻锛岀幓鐠冭秺鐣岀殑鎯呭喌锛屼换鍔″畬鎴愬悗鍐嶆鏇存柊澶х悊鐗囩琛ㄥ墿浣欏搴︼紙鎸夌収绗煎唴鐜荤拑鏁伴噺鏇存柊澶х悊鐗囩鍓╀綑灏哄锛�
+                hollowBigStorageCageService.update(new LambdaUpdateWrapper<HollowBigStorageCage>()
+                        .set(HollowBigStorageCage::getRemainWidth, bigStorageDTO.getRemainWidth() - Math.max(info.getWidth(), info.getHeight()) - glassGap)
+                        .eq(HollowBigStorageCage::getSlot, bigStorageDTO.getSlot()));
+                task.setTargetSlot(bigStorageDTO.getSlot());
+                task.setGlassId(info.getGlassId());
                 //瀛樻斁鍘嗗彶浠诲姟
                 HollowBigStorageCageHistoryTask historyTask = new HollowBigStorageCageHistoryTask();
                 BeanUtils.copyProperties(task, historyTask);
@@ -289,34 +326,52 @@
                 historyTask.setGlassCount(glassInfoList.size());
                 historyTask.setTaskState(Const.ENGINEERING_NEW);
                 historyTasks.add(historyTask);
-                GlassInfo info = glassInfoList.get(0);
+                //瀛樻斁璇︽儏鏁版嵁
                 HollowBigStorageCageDetails cageDetails = new HollowBigStorageCageDetails();
+                BeanUtils.copyProperties(bigStorageDTO, cageDetails);
                 BeanUtils.copyProperties(info, cageDetails);
-                cageDetails.setSlot(THROUGH_SLOT);
                 cageDetails.setState(Const.GLASS_STATE_NEW);
-                cageDetails.setDeviceId(0);
-                cageDetails.setSequence(0);
-                cageDetails.setHollowSequence(0);
+                cageDetails.setSequence(bigStorageDTO.getSlotSequence());
                 cageDetails.setGap(glassGap);
-                cageDetails.setFilmsId(info.getFilmsid());
                 cageDetails.setId(null);
                 hollowBigStorageCageDetailsService.save(cageDetails);
+                hollowGlassRelationInfoService.update(new LambdaUpdateWrapper<HollowGlassRelationInfo>()
+                        .set(HollowGlassRelationInfo::getGlassId, cageDetails.getGlassId())
+                        .set(HollowGlassRelationInfo::getTemperingLayoutId, cageDetails.getTemperingLayoutId())
+                        .set(HollowGlassRelationInfo::getTemperingFeedSequence, cageDetails.getTemperingFeedSequence())
+                        .set(HollowGlassRelationInfo::getEngineerId, cageDetails.getEngineerId())
+                        .set(HollowGlassRelationInfo::getState, Const.HOLLOW_RELATION_OCCUPY)
+                        .eq(HollowGlassRelationInfo::getFlowCardId, bigStorageDTO.getFlowCardId())
+                        .eq(HollowGlassRelationInfo::getLayer, bigStorageDTO.getLayer())
+                        .eq(HollowGlassRelationInfo::getVirtualSlot, bigStorageDTO.getVirtualSlot())
+                        .eq(HollowGlassRelationInfo::getSlotSequence, bigStorageDTO.getSlotSequence())
+                        .eq(HollowGlassRelationInfo::getHollowSequence, bigStorageDTO.getHollowSequence())
+                );
             }
-        } catch (Exception exception) {
-            log.info("杩涚墖浠诲姟鎵ц涓彂鐢熷紓甯革細{}", exception);
-            hollowBigStorageCageDetailsService.update(new LambdaUpdateWrapper<HollowBigStorageCageDetails>()
-                    .set(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_TAKE)
-                    .eq(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_NEW));
-            hollowGlassRelationInfoService.update(new LambdaUpdateWrapper<HollowGlassRelationInfo>()
-                    .set(HollowGlassRelationInfo::getGlassId, null)
-                    .set(HollowGlassRelationInfo::getTemperingLayoutId, null)
-                    .set(HollowGlassRelationInfo::getTemperingFeedSequence, null)
-                    .set(HollowGlassRelationInfo::getEngineerId, null)
-                    .set(HollowGlassRelationInfo::getState, Const.HOLLOW_RELATION_NEW)
-                    .eq(HollowGlassRelationInfo::getState, Const.HOLLOW_RELATION_OCCUPY)
-            );
-            return;
+        } else {
+            BigStorageCageTask task = inTaskList.get(0);
+            task.setTargetSlot(THROUGH_SLOT);
+            //瀛樻斁鍘嗗彶浠诲姟
+            HollowBigStorageCageHistoryTask historyTask = new HollowBigStorageCageHistoryTask();
+            BeanUtils.copyProperties(task, historyTask);
+            historyTask.setTaskType(Const.BIG_STORAGE_AFTER_IN);
+            historyTask.setGlassCount(glassInfoList.size());
+            historyTask.setTaskState(Const.ENGINEERING_NEW);
+            historyTasks.add(historyTask);
+            GlassInfo info = glassInfoList.get(0);
+            HollowBigStorageCageDetails cageDetails = new HollowBigStorageCageDetails();
+            BeanUtils.copyProperties(info, cageDetails);
+            cageDetails.setSlot(THROUGH_SLOT);
+            cageDetails.setState(Const.GLASS_STATE_NEW);
+            cageDetails.setDeviceId(0);
+            cageDetails.setSequence(0);
+            cageDetails.setHollowSequence(0);
+            cageDetails.setGap(glassGap);
+            cageDetails.setFilmsId(info.getFilmsid());
+            cageDetails.setId(null);
+            hollowBigStorageCageDetailsService.save(cageDetails);
         }
+
         //鍘嗗彶鏁版嵁鍏ュ簱
         hollowBigStorageCageHistoryTaskService.saveBatch(historyTasks);
         //鍚憃pc鍙戦�佸惎鍔ㄤ俊鍙�
@@ -372,14 +427,14 @@
             return;
         }
         //鑾峰彇鎵�鏈夌┖闂茬殑绾胯矾淇℃伅
-        List<Integer> freeLineList = new ArrayList<>();
+        HashMap<Integer, Boolean> map = new HashMap<>();
         //鑾峰彇绌洪棽涓旈鍙栦换鍔$殑鏁版嵁淇℃伅锛屾病鏈変换鍔$洿鎺ヨ蛋鐜荤拑璋冨害
         try {
             if (CMJ1ModbusTcp.checkConnected()) {
                 Boolean oneState = CMJ1ModbusTcp.readUInt16(42027 - 40001) != 0;
-                if (oneState) {
-                    freeLineList.add(930);
-                }
+                map.put(930, oneState);
+            } else {
+                map.put(930, Boolean.FALSE);
             }
         } catch (Exception e) {
             //nothing
@@ -388,34 +443,51 @@
         try {
             S7DataZKExtra s7DataZKExtra = s7SerializerZKQ2.read(S7DataZKExtra.class);
             log.info("涓┖棰濆璇诲彇{}", s7DataZKExtra);
-            Boolean twoState = s7DataZKExtra.getIsFree();
-            Boolean threeState = s7DataZKExtra.getIsFree03();
-            if (twoState) {
-                freeLineList.add(931);
-            }
-            if (threeState) {
-                freeLineList.add(932);
-            }
+            map.put(931, s7DataZKExtra.getIsFree());
+            map.put(932, s7DataZKExtra.getIsFree03());
         } catch (Exception e) {
             //nothing
             log.info("浜�/涓夌嚎绾跨┖闂茬姸鎬佽幏鍙栧紓甯�");
         }
-        HollowGlassOutRelationInfo hollowGlassOutRelationInfo = null;
-        if (CollectionUtil.isNotEmpty(freeLineList)) {
-            hollowGlassOutRelationInfo = hollowGlassOutRelationInfoService
-                    .getOne(new LambdaQueryWrapper<HollowGlassOutRelationInfo>()
-                            .in(HollowGlassOutRelationInfo::getCell, freeLineList)
-                            .eq(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START)
-                            .orderByAsc(HollowGlassOutRelationInfo::getUpdateTime).last("limit 1")
-                    );
+        List<Integer> resultList = new ArrayList<>();
+        if (redisUtil.getCacheObject("priorityHollowSwitch")) {
+            resultList = TWO_LINE_FIRST;
+        } else {
+            resultList = ONE_LINE_FIRST;
         }
 
-        if (hollowGlassOutRelationInfo == null) {
-            hollowGlassOutRelationInfo = hollowGlassOutRelationInfoService
-                    .getOne(new LambdaQueryWrapper<HollowGlassOutRelationInfo>()
-                            .eq(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START)
-                            .orderByAsc(HollowGlassOutRelationInfo::getUpdateTime).last("limit 1")
-                    );
+        HollowGlassOutRelationInfo hollowGlassOutRelationInfo = null;
+        int cell = -1;
+        for (Integer i : resultList) {
+            if (null == hollowGlassOutRelationInfo) {
+                Boolean entity = map.get(i);
+                cell = i;
+                if (null != entity && entity) {
+                    hollowGlassOutRelationInfo = hollowGlassOutRelationInfoService
+                            .getOne(new LambdaQueryWrapper<HollowGlassOutRelationInfo>()
+                                    .eq(HollowGlassOutRelationInfo::getCell, cell)
+                                    .eq(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START)
+                                    .orderByAsc(HollowGlassOutRelationInfo::getId)
+                                    .last("limit 1")
+                            );
+                }
+            } else {
+                break;
+            }
+        }
+        for (Integer i : resultList) {
+            if (null == hollowGlassOutRelationInfo) {
+                cell = i;
+                hollowGlassOutRelationInfo = hollowGlassOutRelationInfoService
+                        .getOne(new LambdaQueryWrapper<HollowGlassOutRelationInfo>()
+                                .eq(HollowGlassOutRelationInfo::getCell, cell)
+                                .eq(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START)
+                                .orderByAsc(HollowGlassOutRelationInfo::getId)
+                                .last("limit 1")
+                        );
+            } else {
+                break;
+            }
         }
 
         if (null != hollowGlassOutRelationInfo) {
@@ -850,7 +922,7 @@
             List<String> glassList = noDealTaskList.stream().map(BigStorageCageTask::getGlassId).collect(Collectors.toList());
             hollowBigStorageCageDetailsService.update(new LambdaUpdateWrapper<HollowBigStorageCageDetails>()
                     .set(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_IN)
-                    .ne(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_OUT)
+                    .notIn(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_OUT, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
                     .in(HollowBigStorageCageDetails::getGlassId, glassList));
 
         } else {
@@ -859,7 +931,7 @@
                 hollowBigStorageCageDetailsService.update(new LambdaUpdateWrapper<HollowBigStorageCageDetails>()
                         .set(HollowBigStorageCageDetails::getSlot, item.getStartSlot())
                         .set(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_IN)
-                        .ne(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_OUT)
+                        .notIn(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_OUT, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
                         .eq(HollowBigStorageCageDetails::getGlassId, item.getGlassId()));
             }
         }
@@ -969,10 +1041,19 @@
                     }
                     baseInfoList = resultList;
                 } else {
-                    //澶т簬鎬诲眰鏁板厛鍙杢otalLyaer鍊嶆暟鏁伴噺鐨勭幓鐠冿紝淇濊瘉澶ц溅涓婄殑鐜荤拑鎴愬浼�
+                    //澶т簬鎬诲眰鏁板厛鍙杢otalLayer鍊嶆暟鏁伴噺鐨勭幓鐠冿紝淇濊瘉澶ц溅涓婄殑鐜荤拑鎴愬浼�
                     int remainCount = templist.size() % totalLayer;
                     if (targetSlot == 930) {
-                        baseInfoList = templist.subList(0, totalLayer);
+                        int tempSequence = templist.get(0).getHollowSequence();
+                        List<T> resultList = new ArrayList<>();
+                        for (int i = 0; i < templist.size(); i++) {
+                            if (tempSequence == list.get(i).getHollowSequence()) {
+                                resultList.add(templist.get(i));
+                            } else {
+                                break;
+                            }
+                        }
+                        baseInfoList = resultList;
                     } else {
                         baseInfoList = templist.subList(0, templist.size() - remainCount);
                     }
@@ -1046,7 +1127,7 @@
         hollowBigStorageCageDetailsService.update(new LambdaUpdateWrapper<HollowBigStorageCageDetails>()
                 .set(HollowBigStorageCageDetails::getState, state)
                 .set(Const.BIG_STORAGE_AFTER_DISPATCH.equals(taskType), HollowBigStorageCageDetails::getSlot, targetSlot)
-                .ne(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_OUT)
+                .notIn(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_OUT, Const.GLASS_STATE_DAMAGE, Const.GLASS_STATE_TAKE)
                 .in(HollowBigStorageCageDetails::getGlassId, glassIds));
         try {
             s7DataZKDLPTwo = new S7DataZKDLPTwo();

--
Gitblit v1.8.0