From 8223485b2f6c909de81924e107b1e268aa04bd41 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期日, 30 六月 2024 22:59:26 +0800
Subject: [PATCH] 1、大理片笼进片逻辑调整:a、将扫描id后进生成任务信息,不执行卧转立进片命令;                      b、进片车空闲扫描,如果存在卧转立有满片的直接启动, 2、下片任务新增任务向plc发送任务信息 3、对外提供手工生成人工下片任务

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java |  108 ++++++++++++++++++++++++++++++++---------------------
 1 files changed, 65 insertions(+), 43 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 4b1aa74..28c7f1f 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
@@ -78,11 +78,11 @@
     @Value("${mes.galssGap}")
     private Integer galssGap;
 
-    @Scheduled(fixedDelay = 5000)
+    //    @Scheduled(fixedDelay = 5000)
     public void plcToHomeEdgScan() {
         PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
-        String d01Id = plcParameterObject.getPlcParameter("D01ID1").getValue();
-        String d02Id = plcParameterObject.getPlcParameter("D02ID1").getValue();
+        String d01Id = plcParameterObject.getPlcParameter("D01ID").getValue();
+        String d02Id = plcParameterObject.getPlcParameter("D02ID").getValue();
         String d03State = plcParameterObject.getPlcParameter("D03State").getValue();
         String d05State = plcParameterObject.getPlcParameter("D05State").getValue();
         String mesD03Address = plcParameterObject.getPlcParameter("MESToD03").getAddress();
@@ -98,27 +98,28 @@
             log.info("涓ゆ潯绾垮崸杞珛鍧囧湪鎵ц浠诲姟锛岀粨鏉熸湰娆℃壂鎻忚繘鍗ц浆绔嬩换鍔�");
             return;
         }
-        Boolean flag01 = Boolean.FALSE;
-        Boolean flag04 = Boolean.FALSE;
+//        Boolean flag01 = Boolean.FALSE;
+//        Boolean flag04 = Boolean.FALSE;
         //鎸夌収绾胯矾鍙婄幓鐠僫d鑾峰彇鐩搁偦涓ゅ潡鐜荤拑 鍗ц浆绔嬩笂鐨勭幓鐠�
-        if (StringUtils.isBlank(d01Id) && !REQUEST_WORD.equals(d03State)) {
-            flag01 = judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD03Address);
+        if (StringUtils.isNotBlank(d01Id) && !REQUEST_WORD.equals(d03State)) {
+            judgeGlassTypeStatus(d01Id, Const.A09_OUT_TARGET_POSITION, mesD03Address);
         }
-        if (StringUtils.isBlank(d02Id) && !REQUEST_WORD.equals(d05State)) {
-            flag04 = judgeGlassTypeStatus(d02Id, Const.A10_OUT_TARGET_POSITION, mesD05Address);
+        if (StringUtils.isNotBlank(d02Id) && !REQUEST_WORD.equals(d05State)) {
+            judgeGlassTypeStatus(d02Id, Const.A10_OUT_TARGET_POSITION, mesD05Address);
         }
-        if (flag01 && flag04) {
-            //姣旇緝鏈�鏃╀竴鐗囦换鍔$殑鐗堝浘id鍙婄増搴� 姹傚嚭鍗ц浆绔嬬殑绾胯矾
-            Integer startLine = getStartLine();
-            //璁$畻鐩爣鏍煎瓙锛屽彂閫佸惎鍔ㄤ换鍔�
-            computeTargetByLine(startLine);
-        } else if (flag01 || flag04) {
-            Integer startLine = flag01.equals(Boolean.TRUE) ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
-            //璁$畻鐩爣鏍煎瓙锛屽彂閫佸惎鍔ㄤ换鍔�
-            computeTargetByLine(startLine);
-        } else {
-            log.info("涓ゆ潯绾挎湭鏀跺埌杩涚墖浠诲姟锛岀粨鏉熸湰娆℃壂鎻忚繘鍗ц浆绔嬩换鍔�");
-        }
+        log.info("缁撴潫鎵爜浠诲姟");
+//        if (flag01 && flag04) {
+//            //姣旇緝鏈�鏃╀竴鐗囦换鍔$殑鐗堝浘id鍙婄増搴� 姹傚嚭鍗ц浆绔嬬殑绾胯矾
+//            Integer startLine = getStartLine();
+//            //璁$畻鐩爣鏍煎瓙锛屽彂閫佸惎鍔ㄤ换鍔�
+//            computeTargetByLine(startLine);
+//        } else if (flag01 || flag04) {
+//            Integer startLine = flag01.equals(Boolean.TRUE) ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
+//            //璁$畻鐩爣鏍煎瓙锛屽彂閫佸惎鍔ㄤ换鍔�
+//            computeTargetByLine(startLine);
+//        } else {
+//            log.info("涓ゆ潯绾挎湭鏀跺埌杩涚墖浠诲姟锛岀粨鏉熸湰娆℃壂鎻忚繘鍗ц浆绔嬩换鍔�");
+//        }
     }
 
     @Scheduled(fixedDelay = 5000)
@@ -129,10 +130,24 @@
             log.info("杩涚墖澶ц溅闈炵┖闂�");
             return;
         }
-        String d01Id = plcParameterObject.getPlcParameter("D01ID1").getValue();
-        String d02Id = plcParameterObject.getPlcParameter("D02ID1").getValue();
+        List<BigStorageCageFeedTask> feedTaskList = bigStorageCageFeedTaskService.list(new LambdaQueryWrapper<BigStorageCageFeedTask>()
+                .eq(BigStorageCageFeedTask::getTaskType, Const.BIG_STORAGE_IN_RUN)
+                .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP));
+        if (CollectionUtils.isNotEmpty(feedTaskList)) {
+            if (feedTaskList.size() == 1) {
+                computeTargetByLine(feedTaskList.get(0).getLine());
+                return;
+            } else {
+                //姣旇緝鏈�鏃╀竴鐗囦换鍔$殑鐗堝浘id鍙婄増搴� 姹傚嚭鍗ц浆绔嬬殑绾胯矾
+                Integer startLine = getStartLine();
+//            //璁$畻鐩爣鏍煎瓙锛屽彂閫佸惎鍔ㄤ换鍔�
+                computeTargetByLine(startLine);
+                return;
+            }
+        }
+        String d01Id = plcParameterObject.getPlcParameter("D01ID").getValue();
+        String d02Id = plcParameterObject.getPlcParameter("D02ID").getValue();
         log.info("1銆佽幏鍙杁01Id鎵弿ID涓猴細{};鑾峰彇d02Id鎵弿ID涓猴細{};", d01Id, d02Id);
-        ;
         //涓ゆ潯绾块兘鏈夎繘鍗ц浆绔嬩换鍔★紝鐩存帴缁撴潫
         if (StringUtils.isNotBlank(d01Id) && StringUtils.isNotBlank(d02Id)) {
             log.info("涓ゆ潯绾块兘瀛樺湪杩涚墖浠诲姟锛岀粨鏉熶换鍔�");
@@ -168,7 +183,7 @@
         computeTargetByLine(outLine);
     }
 
-    @Scheduled(fixedDelay = 5000)
+    //    @Scheduled(fixedDelay = 5000)
     public void plcToHomeEdgOutTask() {
 
         List<BigStorageCageOutTask> outingList = bigStorageCageOutTaskService.list(new LambdaQueryWrapper<BigStorageCageOutTask>().eq(BigStorageCageOutTask::getTaskState, Const.BIG_STORAGE_OUT_NEW));
@@ -253,17 +268,19 @@
             remainWidth = sitToUpRemainWidth.getWidth();
             glassCount = sitToUpRemainWidth.getGlassCount();
         }
+
+        Boolean flag = Boolean.TRUE;
         //2銆佽幏鍙栧崸杞珛
         Integer widthFirst = edgGlassTaskInfoList.get(0).getWidth();
         if (edgGlassTaskInfoList.size() == 1) {
             if (remainWidth >= widthFirst) {
                 if (glassCount <= 5) {
                     addFeedTask(glassId, line, Const.BIG_STORAGE_IN_WAIT, widthFirst);
-                    return Boolean.FALSE;
                 } else {
                     addFeedTask(glassId, line, Const.BIG_STORAGE_IN_RUN, widthFirst);
-                    return Boolean.TRUE;
                 }
+            } else {
+                flag = Boolean.FALSE;
             }
         } else {
             Integer widthSecond = edgGlassTaskInfoList.get(1).getWidth();
@@ -271,20 +288,22 @@
                 if (remainWidth - widthFirst - galssGap >= widthSecond) {
                     if (glassCount <= carMaxSize - 1) {
                         addFeedTask(glassId, line, Const.BIG_STORAGE_IN_WAIT, widthFirst);
-                        return Boolean.FALSE;
                     } else {
                         addFeedTask(glassId, line, Const.BIG_STORAGE_IN_RUN, widthFirst);
-                        return Boolean.TRUE;
                     }
                 } else {
                     addFeedTask(glassId, line, Const.BIG_STORAGE_IN_RUN, widthFirst);
                 }
+            } else {
+                flag = Boolean.FALSE;
             }
         }
         //鍚憄lc鍙戦�佽繘鐗囩‘璁�
-        S7object.getinstance().plccontrol.writeWord(mesAddress, (short) 1);
+        if (flag) {
+            S7object.getinstance().plccontrol.writeWord(mesAddress, (short) 1);
+        }
         //璁板綍鏃犳硶鏀句笅鐜荤拑锛屽悗缁垽鏂惎鍔�
-        return Boolean.TRUE;
+        return flag;
     }
 
     /**
@@ -332,17 +351,17 @@
         //2銆佸幓绗煎瓙鍐呮煡鎵炬槸鍚﹀彲浠ョ户缁瓨鏀剧殑绗煎瓙
         List<String> glassIds = taskList.stream().map(BigStorageCageFeedTask::getGlassId).collect(Collectors.toList());
         List<GlassInfo> glassInfos = glassInfoService.list(new LambdaQueryWrapper<GlassInfo>().in(GlassInfo::getGlassId, glassIds));
-        return computeIsTemperingTargetByLine(glassInfos, taskList, Boolean.TRUE) && computeIsTemperingTargetByLine(glassInfos, taskList, Boolean.FALSE);
+        return computeIsTemperingTargetByLine(glassInfos, taskList, line);
     }
 
     /**
      * 鏄惁閽㈠寲鐜荤拑杩涚鐩爣浣嶇疆
      *
-     * @param glassInfos  褰撴潯绾垮崸杞珛鎵�鏈夌幓鐠�
-     * @param taskList    褰撴潯绾垮崸杞珛鎵�鏈変换鍔�
-     * @param isTempering true 閽㈠寲  false  涓嶉挗鍖�
+     * @param glassInfos 褰撴潯绾垮崸杞珛鎵�鏈夌幓鐠�
+     * @param taskList   褰撴潯绾垮崸杞珛鎵�鏈変换鍔�
+     * @param line       浠诲姟鏄摢鏉$嚎
      */
-    private boolean computeIsTemperingTargetByLine(List<GlassInfo> glassInfos, List<BigStorageCageFeedTask> taskList, Boolean isTempering) {
+    private boolean computeIsTemperingTargetByLine(List<GlassInfo> glassInfos, List<BigStorageCageFeedTask> taskList, Integer line) {
         //1銆佸皢鐜荤拑淇℃伅闆嗗悎杞负glassid涓簁ey鐨刴ap
         Map<String, GlassInfo> glassInfoMap = glassInfos.stream()
                 .collect(Collectors.toMap(GlassInfo::getGlassId, p -> p));
@@ -368,18 +387,21 @@
             cageDetails.setState(Const.GLASS_STATE_IN);
             bigStorageCageDetailsService.save(cageDetails);
         }
-        //todo:鎸夌収杩涚墖淇℃伅鍚戞墦杞﹀彂閫佽繘杞︽暟鎹�
-        sendTaskListToPLC(taskList);
+        sendTaskListToPLC(taskList, line);
         return Boolean.TRUE;
     }
 
-    private void sendTaskListToPLC(List<BigStorageCageFeedTask> taskList) {
+    private void sendTaskListToPLC(List<BigStorageCageFeedTask> taskList, Integer line) {
         S7control s7control = S7object.getinstance().plccontrol;
         PlcParameterObject plcMesObject = S7object.getinstance().PlcMesObject;
+        String mesD03Address = plcMesObject.getPlcParameter("MESToD03").getAddress();
+        String mesD05Address = plcMesObject.getPlcParameter("MESToD05").getAddress();
+        String outLine = line.equals(Const.A09_OUT_TARGET_POSITION) ? mesD03Address : mesD05Address;
         for (int i = 1; i <= taskList.size(); i++) {
-            s7control.writeWord(plcMesObject.getPlcParameter("StartAddToImport" + i).getAddress(), Short.parseShort(taskList.get(i).getLine() + ""));
-            s7control.writeWord(plcMesObject.getPlcParameter("TargetAddToImport1" + i).getAddress(), Short.parseShort(taskList.get(i).getTargetSlot() + ""));
+            s7control.writeWord(plcMesObject.getPlcParameter("StartAddToImport" + i).getAddress(), (short) taskList.get(i).getLine());
+            s7control.writeWord(plcMesObject.getPlcParameter("TargetAddToImport1" + i).getAddress(), (short) taskList.get(i).getTargetSlot());
         }
+        s7control.writeWord(outLine, (short) 1);
     }
 
     private <T extends BigStorageCageBaseInfo> Boolean computeOutGlassInfo(List<T> list) {
@@ -391,9 +413,9 @@
             if (bigStorageCageOutTaskList.size() > carMaxSize || e.getWidth() > remainWidth) {
                 break;
             }
-            remainWidth = remainWidth - e.getWidth().intValue() - galssGap;
+            remainWidth = remainWidth - (int) e.getWidth() - galssGap;
             bigStorageCageOutTaskList.add(new BigStorageCageOutTask(e.getGlassId(), e.getSlot(), Const.A09_OUT_TARGET_POSITION,
-                    e.getWidth().intValue(), 0, 0, 1));
+                    (int) e.getWidth(), 0, 0, 1));
         }
         Assert.isFalse(CollectionUtils.isEmpty(bigStorageCageOutTaskList), "鏈幏鍙栧嚭鐗囨暟鎹紝缁撴潫鍑虹墖浠诲姟");
         log.info("鑾峰彇鍑虹墖浠诲姟鏁版嵁{}鏉★紝鎵ц淇濆瓨", bigStorageCageOutTaskList.size());

--
Gitblit v1.8.0