From 66d9a37adfa32014d479ae1e67575d2392084676 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期五, 12 九月 2025 09:05:51 +0800
Subject: [PATCH] 1、大屏动画修改

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java |  107 +++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 94 insertions(+), 13 deletions(-)

diff --git a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java
index b5328a8..71767b1 100644
--- a/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java
+++ b/hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java
@@ -27,6 +27,8 @@
 import com.mes.device.PlcParameterObject;
 import com.mes.edgglasstask.entity.EdgGlassTaskInfo;
 import com.mes.edgglasstask.service.EdgGlassTaskInfoService;
+import com.mes.engineering.entity.Engineering;
+import com.mes.engineering.mapper.EngineeringMapper;
 import com.mes.glassinfo.entity.GlassInfo;
 import com.mes.glassinfo.service.GlassInfoService;
 import com.mes.temperingglass.entity.TemperingGlassInfo;
@@ -68,6 +70,8 @@
     private TemperingGlassInfoService temperingGlassInfoService;
     @Resource
     private DamageService damageService;
+    @Resource
+    private EngineeringMapper engineeringMapper;
 
     @Resource
     private RedisUtil redisUtil;
@@ -121,7 +125,7 @@
         String d04ToMES = plcParameterObject.getPlcParameter("D04ToMES").getValue();
 
 
-//        d01Id="P24111102|1|13";
+//        d01Id="P25031806|15|3";
 //        d04ToMES="1";
 //        d01ToMES="1";
 
@@ -134,6 +138,34 @@
             log.info("涓ゆ潯绾垮崸杞珛鍧囧湪鎵ц浠诲姟锛岀粨鏉熸湰娆℃壂鎻忚繘鍗ц浆绔嬩换鍔�");
             return;
         }
+//        if (REQUEST_WORD.equals(d01ToMES)) {
+//            List<BigStorageCageFeedTask> bigStorageCageFeedTasks = bigStorageCageFeedTaskService.list(
+//                    new LambdaQueryWrapper<BigStorageCageFeedTask>()
+//                            .gt(BigStorageCageFeedTask::getTargetSlot, 0)
+//                            .eq(BigStorageCageFeedTask::getLine, Const.A09_OUT_TARGET_POSITION)
+//                            .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_NEW)
+//                            .eq(BigStorageCageFeedTask::getGlassId, d01Id)
+//            );
+//            if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks)) {
+//                S7object.getinstance().plccontrol.writeWord(mesD01Address, 1);
+//            }
+//            log.info("{}绾垮啀娆″彂閫佽繘鐗囧惎鍔�", Const.A09_OUT_TARGET_POSITION);
+//            return;
+//        }
+//        if (REQUEST_WORD.equals(d04ToMES)) {
+//            List<BigStorageCageFeedTask> bigStorageCageFeedTasks = bigStorageCageFeedTaskService.list(
+//                    new LambdaQueryWrapper<BigStorageCageFeedTask>()
+//                            .gt(BigStorageCageFeedTask::getTargetSlot, 0)
+//                            .eq(BigStorageCageFeedTask::getLine, Const.A10_OUT_TARGET_POSITION)
+//                            .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_NEW)
+//                            .eq(BigStorageCageFeedTask::getGlassId, d01Id)
+//            );
+//            if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks)) {
+//                S7object.getinstance().plccontrol.writeWord(mesD04Address, 1);
+//            }
+//            log.info("{}绾垮啀娆″彂閫佽繘鐗囧惎鍔�", Const.A10_OUT_TARGET_POSITION);
+//            return;
+//        }
         //鎸夌収绾胯矾鍙婄幓鐠僫d鑾峰彇鐩搁偦涓ゅ潡鐜荤拑 鍗ц浆绔嬩笂鐨勭幓鐠�:  鐘舵�佷负0涓嶆搷浣滐紙D01閫佺墖锛�0涓嶆搷浣滐紝1鍏佽閫佺墖锛夛紝璇锋眰瀛椾负1锛� 锛�02鐜荤拑id涓虹┖鎴栬�呭崸杞珛鏈惎鍔級
         if (!REQUEST_WORD.equals(mesD01Value) && REQUEST_WORD.equals(d01ToMES) && (StringUtils.isBlank(d02State) || !REQUEST_WORD.equals(d03State))) {
             List<BigStorageCageFeedTask> bigStorageCageFeedTasks = bigStorageCageFeedTaskService.list(
@@ -270,7 +302,8 @@
         //涓ゆ潯鍏堝潎鍙墽琛岃繘鐗囦换鍔★紝鍒ゆ柇涓ゆ潯绾挎槸鍚﹁繘鐗囪姹傛槸鍚﹂兘涓虹┖
         if (StringUtils.isBlank(d01Id) && StringUtils.isBlank(d04Id)) {
             //姣旇緝鏈�鏃╀竴鐗囦换鍔$殑鐗堝浘id鍙婄増搴� 姹傚嚭鍗ц浆绔嬬殑绾胯矾
-            Integer line = getStartLine();
+//            Integer line = getStartLine();
+            Integer line = lineList.get(0);
             //璁$畻浠诲姟琛ㄨ繘鐗囨牸瀛� 鍙戦�佽繘鐗囦换鍔�
             computeTargetByLine(line);
             Date endDate = new Date();
@@ -333,6 +366,17 @@
                     .isNull(BigStorageCageOutTask::getGlassId)
                     .orderBy(Boolean.TRUE, sequenceOrder, TemperingGlassInfo::getTemperingFeedSequence));
             log.info("鏌ヨ鐨勫嚭鐗囦换鍔★細{}", temperingGlassInfoList);
+            List<String> glassIds = temperingGlassInfoList.stream().map(TemperingGlassInfo::getGlassId).collect(Collectors.toList());
+            List<BigStorageCageDetails> bigStorageCageDetailsList = bigStorageCageDetailsService.list(
+                    new LambdaQueryWrapper<BigStorageCageDetails>()
+                            .in(BigStorageCageDetails::getGlassId, glassIds)
+                            .in(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT)
+            );
+            if (CollectionUtils.isNotEmpty(temperingGlassInfoList)) {
+                List<String> detialGlassIds = bigStorageCageDetailsList.stream().map(BigStorageCageDetails::getGlassId).collect(Collectors.toList());
+                temperingGlassInfoList.removeIf(info -> detialGlassIds.contains(info.getGlassId()));
+                log.info("绗煎唴涓嶅瓨鍦ㄧ幓鐠冪殑閽㈠寲浠诲姟{}", bigStorageCageDetailsList);
+            }
             if (CollectionUtils.isNotEmpty(temperingGlassInfoList)) {
                 log.info("鏈夋鍦ㄥ嚭鐗囩殑閽㈠寲浠诲姟");
                 computeOutMoreGlassInfo(temperingGlassInfoList, Boolean.TRUE, 1);
@@ -360,6 +404,16 @@
                 //鍒伴綈锛屽皢鐜荤拑灏忕墖鏁版嵁瀛樺叆閽㈠寲灏忕墖琛紝閫昏緫鐢熸垚鍑虹墖浠诲姟  缁撴潫
                 for (TemperingLayoutDTO item : temperingLayoutDTOList) {
                     if (redisUtil.getCacheObject("temperingengineerId").equals(item.getEngineerId())) {
+                        Engineering engineering = engineeringMapper.selectOne(
+                                new LambdaQueryWrapper<Engineering>()
+                                        .eq(Engineering::getEngineerId, item.getEngineerId())
+                        );
+                        if (engineering.getState() == 2) {
+                            redisUtil.setCacheObject("temperingengineerId", "");
+                            Date endDate = new Date();
+                            log.info("褰撳墠宸ョ▼琚姝㈢敓浜э紝澶х悊鐗囩鍑虹墖浠诲姟缁撴潫鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime());
+                            return;
+                        }
                         List<TemperingGlassInfo> temperingGlassInfos = glassInfoService.selectJoinList(TemperingGlassInfo.class, JoinWrappers.lambda(GlassInfo.class)
                                 .selectAll(GlassInfo.class)
                                 .select("-1 as state")
@@ -406,7 +460,7 @@
                         List<BigStorageCageDetails> overSizeGlass = bigStorageCageDetailsList.stream().filter(
                                 t -> Math.min(t.getWidth(), t.getHeight()) > 2500
                         ).collect(Collectors.toList());
-                        if(CollectionUtils.isEmpty(overSizeGlass)){
+                        if (CollectionUtils.isEmpty(overSizeGlass)) {
                             //褰撲竴鏍肩幓鐠冮兘鍒伴綈鏃�
                             if (bigStorageCageDetailsList.size() == valueList.size()) {
                                 long distinctSlotCount = bigStorageCageDetailsList.stream()
@@ -752,7 +806,7 @@
         }
         if (CollectionUtils.isEmpty(glassIds1)) {
             S7object.getinstance().plccontrol.writeWord(mesD03Address, 0);
-            log.info("{}绾夸慨鏀圭幓鐠冪姸鎬佷负3", Const.A09_OUT_TARGET_POSITION);
+            log.info("{}绾夸慨鏀圭幓鐠儃}鐘舵�佷负3", Const.A09_OUT_TARGET_POSITION, glassIds1);
             bigStorageCageFeedTaskService.update(
                     new LambdaUpdateWrapper<BigStorageCageFeedTask>()
                             .eq(BigStorageCageFeedTask::getLine, Const.A09_OUT_TARGET_POSITION)
@@ -764,7 +818,7 @@
         }
         if (CollectionUtils.isEmpty(glassIds2)) {
             S7object.getinstance().plccontrol.writeWord(mesD05Address, 0);
-            log.info("{}绾夸慨鏀圭幓鐠冪姸鎬佷负3", Const.A10_OUT_TARGET_POSITION);
+            log.info("{}绾夸慨鏀圭幓鐠儃}鐘舵�佷负3", Const.A10_OUT_TARGET_POSITION, glassIds2);
             bigStorageCageFeedTaskService.update(
                     new LambdaUpdateWrapper<BigStorageCageFeedTask>()
                             .eq(BigStorageCageFeedTask::getLine, Const.A10_OUT_TARGET_POSITION)
@@ -972,6 +1026,7 @@
         bigStorageCageFeedTask.setWidth(width);
         bigStorageCageFeedTask.setHeight(height);
         bigStorageCageFeedTask.setCreateTime(new Date());
+        bigStorageCageFeedTask.setTargetSlot(0);
         //鍒犻櫎鐞嗙墖绗艰〃鎷胯蛋/鐮存崯鏁版嵁鏁版嵁
         damageService.deleteByGlassId(glassId);
         Damage damage = new Damage();
@@ -1266,11 +1321,21 @@
                     maxX = e.getXCoordinate();
                     slot = e.getSlot();
                     bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.TEMPERING_OUT_TARGET_POSITION,
-                            e.getWidth() * 10, e.getHeight(), trainNumber, serialNumber++, 1, new Date()));
+                            e.getWidth() * 10, e.getHeight() * 10, trainNumber, serialNumber++, 1, new Date()));
                 }
             } else {
-                bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.ARTIFICIAL_OUT_TARGET_POSITION,
-                        e.getWidth() * 10, e.getHeight(), trainNumber, serialNumber++, 1, new Date()));
+                if (serialNumber <= outCarMaxSize && remainWidth > maxLength) {
+                    remainWidth = remainWidth - maxLength - glassGap;
+                    bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.ARTIFICIAL_OUT_TARGET_POSITION,
+                            e.getWidth() * 10, e.getHeight() * 10, trainNumber, serialNumber++, 1, new Date()));
+                } else {
+                    remainWidth = carWidth - maxLength - glassGap;
+                    trainNumber = trainNumber + 1;
+                    serialNumber = 1;
+                    bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.ARTIFICIAL_OUT_TARGET_POSITION,
+                            e.getWidth() * 10, e.getHeight() * 10, trainNumber, serialNumber++, 1, new Date()));
+                }
+
             }
         }
         if (isTask == 2) {
@@ -1282,11 +1347,27 @@
         }
         Assert.isFalse(CollectionUtils.isEmpty(bigStorageCageOutTaskList), "鏈幏鍙栧嚭鐗囨暟鎹紝缁撴潫鍑虹墖浠诲姟");
         log.info("鑾峰彇鍑虹墖浠诲姟鏁版嵁{}鏉★紝鎵ц淇濆瓨", bigStorageCageOutTaskList.size());
-        for (BigStorageCageOutTask bigStorageCageOutTask : bigStorageCageOutTaskList
-        ) {
-            bigStorageCageOutTaskService.save(bigStorageCageOutTask);
+        List<String> outGlassIds = bigStorageCageOutTaskList.stream()
+                .map(BigStorageCageOutTask::getGlassId)
+                .collect(Collectors.toList());
+        //鍒ゆ柇宸ョ▼鍙樻洿鏃朵慨鏀瑰嚭鐗囦綅缃�
+        List<GlassInfo> glassInfos = glassInfoService.list(
+                new LambdaQueryWrapper<GlassInfo>()
+                        .in(GlassInfo::getGlassId, outGlassIds)
+                        .eq(GlassInfo::getProductionStatus, 3)
+        );
+        if (CollectionUtils.isNotEmpty(glassInfos)) {
+            List<String> changeGlassIds = glassInfos.stream()
+                    .map(GlassInfo::getGlassId)
+                    .collect(Collectors.toList());
+            bigStorageCageOutTaskList.forEach(task -> {
+                if (changeGlassIds.contains(task.getGlassId())) {
+                    task.setEndSlot(Const.ARTIFICIAL_OUT_TARGET_POSITION);
+                }
+            });
         }
-//        bigStorageCageOutTaskService.saveBatch(bigStorageCageOutTaskList);
+
+        bigStorageCageOutTaskService.saveBatch(bigStorageCageOutTaskList);
         List<String> glassIds = bigStorageCageOutTaskList.stream().map(BigStorageCageOutTask::getGlassId).collect(Collectors.toList());
         log.info("灏嗗嚭鐗囩幓鐠儃}鐜荤拑鐘舵�佹敼涓哄凡鍑虹墖", glassIds);
         bigStorageCageDetailsService.update(new LambdaUpdateWrapper<BigStorageCageDetails>()
@@ -1365,7 +1446,7 @@
                 .eq(GlassInfo::getEngineerId, glassInfo.getEngineerId())
                 .eq(GlassInfo::getMarkIcon, glassInfo.getMarkIcon())
                 .notInSql(GlassInfo::getGlassId, "select distinct glass_id from big_storage_cage_details " +
-                        "where state!=101 and engineer_id = '" + glassInfo.getEngineerId() + "' and width = " + glassInfo.getWidth() + " and height = " + glassInfo.getHeight())
+                        "where engineer_id = '" + glassInfo.getEngineerId() + "' and width = " + glassInfo.getWidth() + " and height = " + glassInfo.getHeight())
                 .orderByAsc(GlassInfo::getTemperingLayoutId)
                 .orderBy(Boolean.TRUE, sequenceOrder, GlassInfo::getTemperingFeedSequence)
                 .last("Limit 1");

--
Gitblit v1.8.0