From 819a65d0127b6c64429255738fb46b3d280d3116 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期三, 29 十月 2025 17:43:33 +0800
Subject: [PATCH] 1、 中空理片笼任务优化:新增笼子避免出片调度 2、解决无法生成lisec文件异常

---
 hangzhoumesParent/moduleService/hollowGlassModule/src/main/java/com/mes/job/OpcPlcStorageCageHollowTask.java |   59 ++++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 48 insertions(+), 11 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 78670a0..6232302 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
@@ -157,14 +157,17 @@
 
         List<BigStorageCageTask> inTaskList = new ArrayList();
         Integer from = s7DataZKDLPOne.getFrom1();
+        List<Integer> states = s7DataZKDLPOne.getStates();
         List<String> glassIdList = new ArrayList<>();
         List<String> requestWords = s7DataZKDLPOne.getIds();
         for (int i = 1; i <= 6; i++) {
             String requestWord = requestWords.get(i - 1);
+            Integer state = states.get(i - 1);
             if (null != requestWord && !requestWord.isEmpty()) {
                 BigStorageCageTask task = new BigStorageCageTask();
                 task.setGlassId(requestWord);
                 task.setStartSlot(from);
+                task.setTaskState(state);
                 inTaskList.add(task);
                 glassIdList.add(requestWord);
                 continue;
@@ -456,6 +459,7 @@
             //nothing
             log.info("浜�/涓夌嚎绾跨┖闂茬姸鎬佽幏鍙栧紓甯�");
         }
+
         List<Integer> resultList = new ArrayList<>();
         if (redisUtil.getCacheObject("priorityHollowSwitch")) {
             resultList = TWO_LINE_FIRST;
@@ -502,14 +506,29 @@
             //鏄惁鏈夋鍦ㄤ腑绌虹殑鐜荤拑:涓┖灏忕墖琛ㄧ瓫閫夋湭鍑虹鐨勭幓鐠冧俊鎭�
 //            鑾峰彇褰撳墠涓┖浠诲姟鏈畬鎴愬嚭鐗囩殑鐜荤拑淇℃伅
             List<HollowGlassQueueInfo> unFinishHollowQueueList = hollowGlassQueueInfoService.list(new LambdaQueryWrapper<HollowGlassQueueInfo>()
-                    .eq(HollowGlassQueueInfo::getFlowCardId, hollowGlassOutRelationInfo.getFlowCardId())
-                    .eq(HollowGlassQueueInfo::getCell, hollowGlassOutRelationInfo.getCell())
                     .eq(HollowGlassQueueInfo::getState, Const.TEMPERING_NEW)
+                    .eq(HollowGlassQueueInfo::getRelationId, hollowGlassOutRelationInfo.getId())
                     .orderByAsc(HollowGlassQueueInfo::getHollowSequence));
             if (CollectionUtil.isNotEmpty(unFinishHollowQueueList)) {
+                //鐩撮�氬彴鏈夌幓鐠冩椂灏嗕腑绌哄嚭鐗囬槦鍒椾腑瀵瑰簲鐜荤拑id鐨勬牸瀛愬彿鏇挎崲鏈洿閫氬彴
+                HollowBigStorageCageDetails details = hollowBigStorageCageDetailsService.getOne(new LambdaQueryWrapper<HollowBigStorageCageDetails>()
+                        .eq(HollowBigStorageCageDetails::getSlot, THROUGH_SLOT)
+                        .in(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_IN_ALL).last("limit 1"));
+                log.info("涓┖澶х悊鐗囩洿閫氬彴鐜荤拑淇℃伅{}", details);
+                if (details != null) {
+                    unFinishHollowQueueList.stream().forEach(e -> {
+                        if (e.getGlassId().equals(details.getGlassId())) {
+                            e.setSlot(THROUGH_SLOT);
+                            e.setDeviceId(0);
+                            log.info("灏嗕腑绌洪槦鍒椾腑鐨勬牸瀛愬彿鏇挎崲涓虹洿閫氬彴{}", e);
+                        }
+                    });
+                }
+
+                List<HollowGlassQueueInfo> infoList = unFinishHollowQueueList.stream().filter(e -> !(e.getSlot() > 500 && e.getSlot() < 900 && e.getIsPair() != 1)).collect(Collectors.toList());
                 log.info("鏈夋鍦ㄥ嚭鐗囩殑涓┖浠诲姟");
-                Integer isPair = unFinishHollowQueueList.get(0).getIsPair();
-                hollowOutGlassByIsPair(unFinishHollowQueueList, hollowGlassOutRelationInfo.getCell(), isPair, hollowGlassOutRelationInfo.getTotalLayer(), hollowGlassOutRelationInfo.getIsForce());
+                Integer isPair = infoList.get(0).getIsPair();
+                hollowOutGlassByIsPair(infoList, hollowGlassOutRelationInfo.getCell(), isPair, hollowGlassOutRelationInfo.getTotalLayer(), hollowGlassOutRelationInfo.getIsForce());
                 Date endDate = new Date();
                 log.info("澶х悊鐗囩鍑虹墖浠诲姟缁撴潫鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime());
                 return;
@@ -869,17 +888,22 @@
             log.info("褰撳墠涓洪潪鑱旀満鐘舵�侊紝缁撴潫杩涚墖浠诲姟");
             return;
         }
-        if (StringUtils.isNotBlank(s7DataZKDLPOne.getId1())) {
+        Integer requestEntity = s7DataZKDLPOne.getRequestMes();
+        if (StringUtils.isNotBlank(s7DataZKDLPOne.getId7()) && requestEntity == 0) {
             //姹囨姤瀛椾负1 鍚姩瀛椾负1鏄�  娓呴櫎鎵�鏈変换鍔′俊鎭�
-            if (s7DataZKDLPOne.getId1().equals(s7DataZKDLPOne.getId1())) {
+            if (s7DataZKDLPOne.getId7().equals(s7DataZKDLPOne.getId1())) {
                 //todo:娓呯┖浠诲姟
-                s7DataZKDLPOne.setFrom1(0);
-                s7DataZKDLPOne.getId1();
+                S7DataZKDLPOne sendTask = new S7DataZKDLPOne();
+                sendTask.setFrom7(0);
+                sendTask.setId7("");
+                s7SerializerZKDLPOne.write(sendTask);
+                log.info("娓呴櫎鎵�鏈変换鍔′俊鎭瘂}", sendTask);
+                s7DataZKDLPOne = s7SerializerZKDLPOne.read(S7DataZKDLPOne.class);
+                log.info("娓呯┖浠诲姟鍚庡啀璇诲彇{}", s7DataZKDLPOne);
             }
             log.info("瀛樺湪浠诲姟锛岀粨鏉�");
             return;
         }
-        Integer requestEntity = s7DataZKDLPOne.getRequestMes();
         if (1 != requestEntity) {
             log.info("褰撳墠鏈敹鍒拌繘鐗囪姹傦紝缁撴潫杩涚墖浠诲姟");
             return;
@@ -897,17 +921,23 @@
         }
         List<HollowBigStorageCageDetails> list = hollowBigStorageCageDetailsService.list(new LambdaQueryWrapper<HollowBigStorageCageDetails>()
                 .eq(HollowBigStorageCageDetails::getState, Const.GLASS_STATE_IN)
-                .in(HollowBigStorageCageDetails::getDeviceId, 5)
+//                .in(HollowBigStorageCageDetails::getDeviceId, 6)
                 .in(HollowBigStorageCageDetails::getGlassId, glassIdList));
         if (CollectionUtil.isEmpty(list)) {
             return;
         }
         HollowBigStorageCageDetails details = list.get(0);
+
         //todo:鐢熸垚杩涜繘鐗囧ぇ杞︿换鍔�
         hollowBigStorageCageDetailsService.update(new LambdaUpdateWrapper<HollowBigStorageCageDetails>()
                 .set(HollowBigStorageCageDetails::getState, Const.RAW_GLASS_STATE_OUT)
                 .eq(HollowBigStorageCageDetails::getGlassId, details.getGlassId()));
-
+        S7DataZKDLPOne sendTask = new S7DataZKDLPOne();
+        sendTask.setFrom7(details.getSlot());
+        sendTask.setId7(details.getGlassId());
+        s7SerializerZKDLPOne.write(sendTask);
+        log.info("鏂扮瀛愬啓鍏d涓巉rom{}", sendTask);
+        updateSlotRemainBySlots(Arrays.asList(details.getSlot()));
     }
 
 
@@ -1081,6 +1111,7 @@
         Integer outCarMaxSize = sysConfigService.queryConfigValue(ConstSysConfig.HOLLOW_OUT_CAR_SIZE);
 //        Integer glassGap = sysConfigService.queryConfigValue(ConstSysConfig.HOLLOW_GLASS_GAP);
         Integer glassGap = hollowGlassRelationInfoService.getGlassGapByThickness(list.get(0).getThickness());
+        log.info("涓┖鐢熸垚涓�杞︿换鍔★細{}", list);
         for (T e : list) {
             if (templist.size() >= outCarMaxSize || Math.max((int) e.getWidth(), (int) e.getHeight()) > remainWidth) {
                 break;
@@ -1133,6 +1164,12 @@
         for (T t : baseInfoList) {
             bigStorageCageTaskList.add(new BigStorageCageTask(t.getGlassId(), t.getSlot(), targetSlot, 0));
         }
+
+        List<BigStorageCageTask> tasks = bigStorageCageTaskList.stream().filter(e -> e.getStartSlot() >= 500 && e.getStartSlot() < 900).collect(Collectors.toList());
+        if (CollectionUtil.isNotEmpty(tasks)) {
+            log.info("褰撳墠鍑虹墖闃熷垪瀛樺湪鏂扮瀛愮殑鐜荤拑灏忕墖锛岀粨鏉熸湰娆′换鍔★細{}", tasks);
+            return false;
+        }
         //娓呯┖浠诲姟琛ㄦ暟鎹�
         resetOutTask();
         log.info("鐢熸垚鍑虹墖浠诲姟鏁版嵁{}", bigStorageCageTaskList);

--
Gitblit v1.8.0