From eb852430ce781189ca5f9f6abcf3da539464c79e Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期五, 01 十一月 2024 14:57:24 +0800
Subject: [PATCH] 修改大理片为按工程数分前后两块进片

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java |  137 ++++++++++++++++++++++++++++++++++++---------
 1 files changed, 109 insertions(+), 28 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 f30b7d0..b80f6d4 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
@@ -127,21 +127,38 @@
         }
         //鎸夌収绾胯矾鍙婄幓鐠僫d鑾峰彇鐩搁偦涓ゅ潡鐜荤拑 鍗ц浆绔嬩笂鐨勭幓鐠�:  鐘舵�佷负0涓嶆搷浣滐紙D01閫佺墖锛�0涓嶆搷浣滐紝1鍏佽閫佺墖锛夛紝璇锋眰瀛椾负1锛� 锛�02鐜荤拑id涓虹┖鎴栬�呭崸杞珛鏈惎鍔級
         if (!REQUEST_WORD.equals(mesD01Value) && REQUEST_WORD.equals(d01ToMES) && (StringUtils.isBlank(d02State) || !REQUEST_WORD.equals(d03State))) {
-            if (!d01GlassId.equals(d01Id)) {
-                judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD01Address);
-                edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>()
-                        .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d01Id));
+            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_UP)
+            );
+            if(CollectionUtils.isEmpty(bigStorageCageFeedTasks)){
+                if (!d01GlassId.equals(d01Id)) {
+                    judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD01Address);
+                    edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>()
+                            .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d01Id));
 //                d01GlassId = d01Id;
+                }
             }
         }
 //        鐘舵�佷负0涓嶆搷浣滐紙D01閫佺墖锛�0涓嶆搷浣滐紝1鍏佽閫佺墖锛夛紝璇锋眰瀛椾负1锛� 鍗ц浆绔嬫湭鍚姩
         if (!REQUEST_WORD.equals(mesD04Value) && REQUEST_WORD.equals(d04ToMES) && !REQUEST_WORD.equals(d05State)) {
-            if (!d04GlassId.equals(d04Id)) {
-                judgeGlassTypeStatus(d04Id, Const.A10_OUT_TARGET_POSITION, mesD04Address);
-                edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>()
-                        .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d04Id));
+            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_UP)
+            );
+            if(CollectionUtils.isEmpty(bigStorageCageFeedTasks)){
+                if (!d04GlassId.equals(d04Id)) {
+                    judgeGlassTypeStatus(d04Id, Const.A10_OUT_TARGET_POSITION, mesD04Address);
+                    edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>()
+                            .set(EdgGlassTaskInfo::getStatus, Const.EDG_GLASS_SUCCESS).eq(EdgGlassTaskInfo::getGlassId, d04Id));
 //                d04GlassId = d04Id;
+                }
             }
+
         }
         Date endDate = new Date();
         log.info("澶х悊鐗囩鎵爜浠诲姟缁撴潫鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime());
@@ -180,13 +197,26 @@
         }
         if (!REQUEST_WORD.equals(d03ToMES) && !REQUEST_WORD.equals(d05ToMES)) {
             Date endDate = new Date();
-            log.info("鍗ц浆绔嬫病鏈夐�佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟锛屼换鍔$粨鏉熸椂闂达細{}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime());
+            log.info("鍗ц浆绔嬬涓�娆℃病鏈夐�佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟锛屼换鍔$粨鏉熸椂闂达細{}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime());
             return;
         }
+        if (!REQUEST_WORD.equals(d03ToMES) && !REQUEST_WORD.equals(d05ToMES)) {
+            Date endDate = new Date();
+            log.info("鍗ц浆绔嬬浜屾娌℃湁閫佺墖璇锋眰锛岀粨鏉熼�佺墖浠诲姟锛屼换鍔$粨鏉熸椂闂达細{}锛屽叡鑰楁椂锛歿}ms,缁撴潫鎵爜浠诲姟", endDate, endDate.getTime() - startDate.getTime());
+            return;
+        }
+//        List<Integer> lines=new ArrayList<>();
+//        if(REQUEST_WORD.equals(d03ToMES)){
+//            lines.add(Const.A09_OUT_TARGET_POSITION);
+//        }
+//        if(REQUEST_WORD.equals(d05ToMES)){
+//            lines.add(Const.A10_OUT_TARGET_POSITION);
+//        }
         LambdaQueryWrapper<BigStorageCageFeedTask> wrapper = new LambdaQueryWrapper<BigStorageCageFeedTask>()
                 .eq(BigStorageCageFeedTask::getTaskType, Const.BIG_STORAGE_IN_RUN)
                 .and(e -> e.isNull(BigStorageCageFeedTask::getTargetSlot).or().eq(BigStorageCageFeedTask::getTargetSlot, Const.OUT_TARGET_POSITION_ZERO))
                 .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP);
+//                .in(BigStorageCageFeedTask::getLine,lines);
         //鑾峰彇鍙互鍚姩鍗ц浆绔嬬殑浠诲姟绾胯矾
         List<BigStorageCageFeedTask> feedTaskList = bigStorageCageFeedTaskService.list(wrapper);
         if (CollectionUtils.isNotEmpty(feedTaskList)) {
@@ -224,6 +254,8 @@
                 //鑾峰彇鍗ц浆绔嬪墿浣欏搴�
                 if (computeIsRun(lineFirst, lineGlassId)) {
                     computeTargetByLine(lineFirst);
+                }else{
+                    log.info("褰撳墠绾胯矾锛歿}锛屾湁鎵爜鐜荤拑锛歿}",lineFirst,lineGlassId);
                 }
             }
             Date endDate = new Date();
@@ -581,20 +613,26 @@
         String d04ToMES = plcParameterObject.getPlcParameter("D04ToMES").getValue();
         String mesD01Address = plcParameterObject.getPlcParameter("MESToD01").getAddress();
         String mesD04Address = plcParameterObject.getPlcParameter("MESToD04").getAddress();
-        String d03ToMES = plcParameterObject.getPlcParameter("D03ToMES").getValue();
-        String d05ToMES = plcParameterObject.getPlcParameter("D05ToMES").getValue();
+//        String d03ToMES = plcParameterObject.getPlcParameter("D03ToMES").getValue();
+//        String d05ToMES = plcParameterObject.getPlcParameter("D05ToMES").getValue();
+        String d03ToMES = plcParameterObject.getPlcParameter("D03Request").getValue();
+        String d05ToMES = plcParameterObject.getPlcParameter("D05Request").getValue();
         String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress();
         String mesD05Address = plcParameterObject.getPlcParameter("MESToD05").getAddress();
         if (!REQUEST_WORD.equals(d01ToMES)) {
+            log.info("鍦板潃锛歿}鍐欏叆0",mesD01Address);
             S7object.getinstance().plccontrol.writeWord(mesD01Address, 0);
         }
         if (!REQUEST_WORD.equals(d04ToMES)) {
+            log.info("鍦板潃锛歿}鍐欏叆0",mesD04Address);
             S7object.getinstance().plccontrol.writeWord(mesD04Address, 0);
         }
         if (!REQUEST_WORD.equals(d03ToMES)) {
+            log.info("鍦板潃锛歿}鍐欏叆0",mesD03Address);
             S7object.getinstance().plccontrol.writeWord(mesD03Address, 0);
         }
         if (!REQUEST_WORD.equals(d05ToMES)) {
+            log.info("鍦板潃锛歿}鍐欏叆0",mesD05Address);
             S7object.getinstance().plccontrol.writeWord(mesD05Address, 0);
         }
     }
@@ -605,6 +643,8 @@
     @Scheduled(fixedDelay = 300)
     public void feedStatusUpdate() {
         PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
+        String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress();
+        String mesD05Address = plcParameterObject.getPlcParameter("MESToD05").getAddress();
         List<String> glassIds1 = new ArrayList<>();
         List<String> glassIds2 = new ArrayList<>();
         for (int i = 1; i <= 6; i++) {
@@ -633,12 +673,15 @@
                     .filter(glassIds1::contains)
                     .distinct()
                     .collect(Collectors.toList());
-            bigStorageCageFeedTaskService.update(
-                    new LambdaUpdateWrapper<BigStorageCageFeedTask>()
-                            .in(BigStorageCageFeedTask::getGlassId, matchingIds1)
-                            .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
-                            .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)
-            );
+            log.info("D3id{},鍖归厤id:{}",glassIds1,matchingIds1);
+            if(CollectionUtils.isNotEmpty(matchingIds1)){
+                bigStorageCageFeedTaskService.update(
+                        new LambdaUpdateWrapper<BigStorageCageFeedTask>()
+                                .in(BigStorageCageFeedTask::getGlassId, matchingIds1)
+                                .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                                .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)
+                );
+            }
         }
         if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks2) && CollectionUtils.isNotEmpty(glassIds2)) {
             List<String> matchingIds2 = bigStorageCageFeedTasks2.stream()
@@ -646,14 +689,19 @@
                     .filter(glassIds2::contains)
                     .distinct()
                     .collect(Collectors.toList());
-            bigStorageCageFeedTaskService.update(
-                    new LambdaUpdateWrapper<BigStorageCageFeedTask>()
-                            .in(BigStorageCageFeedTask::getGlassId, matchingIds2)
-                            .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
-                            .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)
-            );
+            log.info("D5id{},鍖归厤id:{}",glassIds2,matchingIds2);
+            if(CollectionUtils.isNotEmpty(matchingIds2)){
+                bigStorageCageFeedTaskService.update(
+                        new LambdaUpdateWrapper<BigStorageCageFeedTask>()
+                                .in(BigStorageCageFeedTask::getGlassId, matchingIds2)
+                                .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                                .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)
+                );
+            }
         }
         if (CollectionUtils.isEmpty(glassIds1)) {
+            S7object.getinstance().plccontrol.writeWord(mesD03Address, 0);
+            log.info("{}绾夸慨鏀圭幓鐠冪姸鎬佷负3",Const.A09_OUT_TARGET_POSITION);
             bigStorageCageFeedTaskService.update(
                     new LambdaUpdateWrapper<BigStorageCageFeedTask>()
                             .eq(BigStorageCageFeedTask::getLine, Const.A09_OUT_TARGET_POSITION)
@@ -664,6 +712,8 @@
             );
         }
         if (CollectionUtils.isEmpty(glassIds2)) {
+            S7object.getinstance().plccontrol.writeWord(mesD05Address, 0);
+            log.info("{}绾夸慨鏀圭幓鐠冪姸鎬佷负3",Const.A10_OUT_TARGET_POSITION);
             bigStorageCageFeedTaskService.update(
                     new LambdaUpdateWrapper<BigStorageCageFeedTask>()
                             .eq(BigStorageCageFeedTask::getLine, Const.A10_OUT_TARGET_POSITION)
@@ -903,23 +953,54 @@
         String mesD03Address = plcMesObject.getPlcParameter("MESToD03").getAddress();
         String mesD05Address = plcMesObject.getPlcParameter("MESToD05").getAddress();
         String outLine = line.equals(Const.A09_OUT_TARGET_POSITION) ? mesD03Address : mesD05Address;
+        List<String> returnData = new ArrayList<>();
+
         for (int i = 1; i <= taskList.size(); i++) {
             s7control.writeWord(plcMesObject.getPlcParameter("StartAddToImport" + i).getAddress(), taskList.get(i - 1).getLine());
             s7control.writeWord(plcMesObject.getPlcParameter("TargetAddToImport" + i).getAddress(), taskList.get(i - 1).getTargetSlot());
+            returnData.add(taskList.get(i - 1).getGlassId());
             log.info("鍚憄lc鍙戦�佺{}鐗囩幓鐠冨凡瀹屾垚,璧峰浣嶇疆鏄瘂}锛岀洰鏍囦綅缃槸", i, taskList.get(i - 1).getLine(), taskList.get(i - 1).getTargetSlot());
         }
-        int returnData = 1;
+//        int returnData = 1;
         int count = 1;
-        while (returnData != 0) {
+
+
+        while (CollectionUtils.isNotEmpty(returnData)) {
+            List<String> glassIds1 = new ArrayList<>();
+            List<String> glassIds2 = new ArrayList<>();
             s7control.writeWord(outLine, 2);
+            for (int i = 1; i <= 6; i++) {
+                String line1GlassId = plcMesObject.getPlcParameter("D03ID" + i).getValue();
+                if (StringUtils.isNotEmpty(line1GlassId)) {
+                    glassIds1.add(line1GlassId);
+                }
+                String line2GlassId = plcMesObject.getPlcParameter("D05ID" + i).getValue();
+                if (StringUtils.isNotEmpty(line2GlassId)) {
+                    glassIds2.add(line2GlassId);
+                }
+            }
             if (line.equals(Const.A09_OUT_TARGET_POSITION)) {
-                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D03ToMES").getValue());
+//                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D03ToMES").getValue());
+                returnData = glassIds1;
             } else {
-                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue());
+//                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue());
+                returnData = glassIds2;
             }
 //            returnData = s7control.readWord(outLine, 1).get(0);
-            log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, outLine, 2);
+            log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{},璇诲埌鐨勮姹備负{}", count++, outLine, 2,returnData);
         }
+//        while (returnData != 0) {
+//            s7control.writeWord(outLine, 2);
+//            if (line.equals(Const.A09_OUT_TARGET_POSITION)) {
+////                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D03ToMES").getValue());
+//                returnData = s7control.readWord(plcMesObject.getPlcParameter("D03Request").getAddress(), 1).get(0);
+//            } else {
+////                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue());
+//                returnData = s7control.readWord(plcMesObject.getPlcParameter("D05Request").getAddress(), 1).get(0);
+//            }
+////            returnData = s7control.readWord(outLine, 1).get(0);
+//            log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{},璇诲埌鐨勮姹備负{}", count++, outLine, 2,returnData);
+//        }
     }
 
     /**

--
Gitblit v1.8.0