From d1099b48aecf383fcefbe7b5a7ac3c2de0f0793f Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期三, 06 十一月 2024 23:22:03 +0800
Subject: [PATCH] 1、卧理进出片功能已完成开发,与电气调试中,新增磨边队列表 2、卧理新增历史任务表,记录卧理两台设备执行过的历史数据 3、大理片笼opc任务,新增玻璃进笼计算方式:在笼内存储同炉的多片玻璃,笼内玻璃顺序可不按照固定的顺序进笼 4、上片任务初步完成开发,新增历史任务表记录上片的历史信息

---
 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/job/PlcStorageCageTask.java |  236 +++++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 198 insertions(+), 38 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 c056e63..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();
@@ -574,59 +606,144 @@
     /**
      * 纭瀛楁竻绌�
      */
-//    @Scheduled(fixedDelay = 300)
+    @Scheduled(fixedDelay = 300)
     public void confirmClear() {
         PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
         String d01ToMES = plcParameterObject.getPlcParameter("D01ToMES").getValue();
         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)){
+        if (!REQUEST_WORD.equals(d01ToMES)) {
+            log.info("鍦板潃锛歿}鍐欏叆0",mesD01Address);
             S7object.getinstance().plccontrol.writeWord(mesD01Address, 0);
         }
-        if(!REQUEST_WORD.equals(d04ToMES)){
+        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);
         }
     }
+
     /**
      * 杩涚墖鐘舵�佷慨鏀�
      */
-//    @Scheduled(fixedDelay = 300)
+    @Scheduled(fixedDelay = 300)
     public void feedStatusUpdate() {
-        List<String> glassIds1=null;
-        List<String> glassIds2=null;
-        List<BigStorageCageFeedTask> bigStorageCageFeedTasks1=bigStorageCageFeedTaskService.list(
+        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++) {
+            String line1GlassId = plcParameterObject.getPlcParameter("D03ID" + i).getValue();
+            if (StringUtils.isNotEmpty(line1GlassId)) {
+                glassIds1.add(line1GlassId);
+            }
+            String line2GlassId = plcParameterObject.getPlcParameter("D05ID" + i).getValue();
+            if (StringUtils.isNotEmpty(line2GlassId)) {
+                glassIds2.add(line2GlassId);
+            }
+        }
+        List<BigStorageCageFeedTask> bigStorageCageFeedTasks1 = bigStorageCageFeedTaskService.list(
                 new LambdaQueryWrapper<BigStorageCageFeedTask>()
-                .eq(BigStorageCageFeedTask::getTaskState,1)
-                .eq(BigStorageCageFeedTask::getLine,Const.ARTIFICIAL_OUT_TARGET_POSITION)
+                        .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_NEW)
+                        .eq(BigStorageCageFeedTask::getLine, Const.A09_OUT_TARGET_POSITION)
         );
-        List<BigStorageCageFeedTask> bigStorageCageFeedTasks2=bigStorageCageFeedTaskService.list(
+        List<BigStorageCageFeedTask> bigStorageCageFeedTasks2 = bigStorageCageFeedTaskService.list(
                 new LambdaQueryWrapper<BigStorageCageFeedTask>()
-                        .eq(BigStorageCageFeedTask::getTaskState,1)
-                        .eq(BigStorageCageFeedTask::getLine,Const.TEMPERING_OUT_TARGET_POSITION)
+                        .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_NEW)
+                        .eq(BigStorageCageFeedTask::getLine, Const.A10_OUT_TARGET_POSITION)
         );
-//        if(CollectionUtils.isNotEmpty(bigStorageCageFeedTasks1)){
-//
-//        }
-//        if(CollectionUtils.isNotEmpty(bigStorageCageFeedTasks1)){
-//
-//        }
+        if (CollectionUtils.isNotEmpty(bigStorageCageFeedTasks1) && CollectionUtils.isNotEmpty(glassIds1)) {
+            List<String> matchingIds1 = bigStorageCageFeedTasks1.stream()
+                    .map(BigStorageCageFeedTask::getGlassId)
+                    .filter(glassIds1::contains)
+                    .distinct()
+                    .collect(Collectors.toList());
+            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()
+                    .map(BigStorageCageFeedTask::getGlassId)
+                    .filter(glassIds2::contains)
+                    .distinct()
+                    .collect(Collectors.toList());
+            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)
+                            .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)
+                            .gt(BigStorageCageFeedTask::getTargetSlot, 0)
+                            .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                            .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_CAR)
+            );
+        }
+        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)
+                            .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP)
+                            .gt(BigStorageCageFeedTask::getTargetSlot, 0)
+                            .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                            .set(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_CAR)
+            );
+        }
     }
 
     /**
      * 鎸夌収鐜荤拑id鍒ゆ柇鐜荤拑鐘舵�佸強鍗ц浆绔嬫槸鍚﹀彲鐩存帴鍚姩
      */
     public Boolean judgeGlassTypeStatus(String glassId, Integer line, String mesAddress) {
+        //鍒ゆ柇姝ょ幓鐠冩槸鍦ㄧ鍐呮垨宸茬敓鎴愯繘鐗囦换鍔�
+        BigStorageCageFeedTask bigStorageCageFeedTask = bigStorageCageFeedTaskService.getOne(
+                new LambdaQueryWrapper<BigStorageCageFeedTask>()
+                        .lt(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_SLOT)
+                        .eq(BigStorageCageFeedTask::getGlassId, glassId)
+        );
+        BigStorageCageDetails bigStorageCageDetails = bigStorageCageDetailsService.getOne(
+                new LambdaQueryWrapper<BigStorageCageDetails>()
+                        .eq(BigStorageCageDetails::getGlassId, glassId)
+                        .ne(BigStorageCageDetails::getState, Const.GLASS_STATE_IN)
+        );
+        if (bigStorageCageFeedTask != null || bigStorageCageDetails != null) {
+            log.info("姝ょ幓鐠冨瓨浠诲姟鎴栧凡鍦ㄧ鍐�");
+            return Boolean.TRUE;
+        }
         //1銆佽幏鍙栦换鍔¤〃涓浉閭荤幓鐠�
         List<EdgGlassTaskInfo> edgGlassTaskInfoList;
         edgGlassTaskInfoList = edgGlassTaskInfoService.list(new LambdaQueryWrapper<EdgGlassTaskInfo>()
@@ -711,13 +828,19 @@
         //鍚憄lc鍙戦�佽繘鐗囩‘璁�
         if (flag) {
             //鍚憄lc鍐欏叆纭瀛�
-            int returnData = 0;
+            PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
+            int returnData = 1;
             int count = 1;
-            while (returnData == 0) {
+            while (returnData != 0) {
                 S7object.getinstance().plccontrol.writeWord(mesAddress, 1);
-                returnData = S7object.getinstance().plccontrol.readWord(mesAddress, 1).get(0);
-                log.info("杩涘崸杞珛绗瑊}娆″彂閫佺‘璁ゅ瓧瀹屾垚锛屽湴鍧�涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, mesAddress, returnData);
 
+                if (Const.A10_OUT_TARGET_POSITION.equals(line)) {
+                    returnData = Integer.parseInt(plcParameterObject.getPlcParameter("D04ToMES").getValue());
+                } else {
+                    returnData = Integer.parseInt(plcParameterObject.getPlcParameter("D01ToMES").getValue());
+                }
+//                returnData = S7object.getinstance().plccontrol.readWord(mesAddress, 1).get(0);
+                log.info("杩涘崸杞珛绗瑊}娆″彂閫佺‘璁ゅ瓧瀹屾垚锛屽湴鍧�涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, mesAddress, 1);
             }
         }
         //璁板綍鏃犳硶鏀句笅鐜荤拑锛屽悗缁垽鏂惎鍔�
@@ -830,18 +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 = 0;
+//        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);
-            returnData = s7control.readWord(outLine, 1).get(0);
-            log.info("宸插悜plc绗瑊}娆″彂閫佽繘鐗囦换鍔$‘璁わ紝鍦板潃涓猴細{},鍐欏叆鐨勫唴瀹逛负{}", count++, outLine, returnData);
+            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 = glassIds1;
+            } else {
+//                returnData = Integer.parseInt(plcMesObject.getPlcParameter("D05ToMES").getValue());
+                returnData = glassIds2;
+            }
+//            returnData = s7control.readWord(outLine, 1).get(0);
+            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);
+//        }
     }
 
     /**
@@ -953,7 +1112,8 @@
         log.info("灏嗗嚭鐗囩幓鐠儃}鐜荤拑鐘舵�佹敼涓哄凡鍑虹墖", glassIds);
         bigStorageCageDetailsService.update(new LambdaUpdateWrapper<BigStorageCageDetails>()
                 .set(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT_ING)
-                .in(BigStorageCageDetails::getGlassId, glassIds));
+                .in(BigStorageCageDetails::getGlassId, glassIds)
+                .ne(BigStorageCageDetails::getState, Const.GLASS_STATE_OUT));
 //        int returnData = 0;
 //        int count = 1;
 //        while (returnData == 0) {

--
Gitblit v1.8.0