From 22f5cee4b4f9a717df573456f3b149be697b17d1 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期三, 03 七月 2024 08:36:10 +0800
Subject: [PATCH] 下片优化出片逻辑 大理片出片:出片线路调整

---
 hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java |  295 ++++++++++++++++++++++++++++++++++------------------------
 1 files changed, 173 insertions(+), 122 deletions(-)

diff --git a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java
index cd2a2f3..9eaf129 100644
--- a/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java
+++ b/hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java
@@ -20,6 +20,7 @@
 import com.mes.downworkstation.service.DownWorkstationService;
 import com.mes.glassinfo.entity.GlassInfo;
 import com.mes.glassinfo.service.GlassInfoService;
+import com.mes.tools.S7control;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -75,17 +76,19 @@
     @Scheduled(fixedDelay = 1000)
     public void plcHomeEdgTask() {
         PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
-        String requestWord = plcParameterObject.getPlcParameter("RequestWord").getValue();
-        String glassIdeValue = plcParameterObject.getPlcParameter("G04ID").getValue();
-        String confirmationWrodValue = plcParameterObject.getPlcParameter("MES_confirmation_word").getValue();
+        String requestWord = plcParameterObject.getPlcParameter("requestWord").getValue();
+        String glassIdeValue = plcParameterObject.getPlcParameter("requestID").getValue();
         //A08  A09琛ㄧず绾胯矾鐩稿悓  鍙仛绛変环  鏃犳暟鎹浆int寮傚父
-        String out08Glassstate = plcParameterObject.getPlcParameter("A08_glass_status").getValue();
-        String out10Glassstate = plcParameterObject.getPlcParameter("A10_glass_status").getValue();
-        String confirmationWrodAddress = plcParameterObject.getPlcParameter("MES_confirmation_word").getAddress();
-        String currentSlot = plcParameterObject.getPlcParameter("Current_slot").getValue();
+        String out06Glassstate = plcParameterObject.getPlcParameter("glassStatus06").getValue();
+        String out08Glassstate = plcParameterObject.getPlcParameter("glassStatus08").getValue();
+        String out11Glassstate = plcParameterObject.getPlcParameter("glassStatus11").getValue();
+        String out13Glassstate = plcParameterObject.getPlcParameter("glassStatus13").getValue();
+        String confirmationWrodValue = plcParameterObject.getPlcParameter("confirmationWord").getValue();
+        String confirmationWrodAddress = plcParameterObject.getPlcParameter("confirmationWord").getAddress();
+        String currentSlot = plcParameterObject.getPlcParameter("currentCell").getValue();
 
-        log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佸垎鍒负锛欰09:{}銆丄10:{},褰撳墠鏍煎瓙鍙蜂负锛歿}",
-                requestWord, glassIdeValue, confirmationWrodValue, out08Glassstate, out10Glassstate, currentSlot);
+        log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佸垎鍒负锛歡06:{}銆乬08:{}銆乬11:{}銆乬13:{},褰撳墠鏍煎瓙鍙蜂负锛歿}",
+                requestWord, glassIdeValue, confirmationWrodValue, out06Glassstate, out08Glassstate, out11Glassstate, out13Glassstate, currentSlot);
 
         if ("0".equals(requestWord)) {
             if ("0".equals(confirmationWrodValue)) {
@@ -102,26 +105,23 @@
         }
         if ("1".equals(requestWord)) {
             log.info("2銆佽繘鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�");
-            inTo(glassIdeValue, requestWord, confirmationWrodAddress, currentSlot);
+            inTo(glassIdeValue, requestWord, currentSlot);
         } else if ("2".equals(requestWord)) {
             //09绌洪棽 锛�1      10绌洪棽 锛�2        閮界┖闂诧細3    鍏朵粬0
             log.info("2銆佸嚭鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�");
-//            outTo(Integer.parseInt(out08Glassstate),
-//                    Integer.parseInt(out10Glassstate), confirmationWrodAddress, "", 0);
+            outTo(out06Glassstate, out08Glassstate, out11Glassstate, out13Glassstate, glassIdeValue, currentSlot);
         } else if ("3".equals(requestWord)) {
             log.info("2銆佽繘鐗囧拰鍑虹墖閮界┖闂诧紝鎵ц鍑虹墖浠诲姟");
             //鍔犵瀛愰噷闈㈡槸鍚︽湁鐜荤拑锛屾湁鍏堝嚭锛屾棤鐜荤拑鍏堣繘
-            boolean outFlase = false;
-//                    outTo(Integer.parseInt(out08Glassstate),
-//                    Integer.parseInt(out10Glassstate), confirmationWrodAddress, glassIdeValue, Integer.parseInt(currentSlot));
+            boolean outFlase = outTo(out06Glassstate, out08Glassstate, out11Glassstate, out13Glassstate, glassIdeValue, currentSlot);
             log.info("鍑虹墖浠诲姟鏄惁瀹屾垚锛歿},澶辫触涓旂幓鐠僫d:{}涓嶄负绌哄垯鎵ц杩涚墖浠诲姟", outFlase, glassIdeValue);
             if (!outFlase && StringUtils.isNotBlank(glassIdeValue)) {
-                inTo(glassIdeValue, requestWord, confirmationWrodAddress, currentSlot);
+                inTo(glassIdeValue, requestWord, currentSlot);
             }
         }
     }
 
-    private void inTo(String glassId, String requestWord, String confirmationWrodAddress, String currentSlot) {
+    public void inTo(String glassId, String requestWord, String currentSlot) {
         log.info("1銆佹寜鐓х幓鐠僫d:{}鑾峰彇鐜荤拑灏忕墖淇℃伅,褰撳墠鏍煎瓙涓�:{}", glassId, currentSlot);
         //娣诲姞杩涚墖浠诲姟  鏌ユ壘绌烘牸
         DownStorageCage nearestEmpty = downStorageCageService.selectCacheEmpty(Integer.parseInt(currentSlot), Boolean.FALSE);
@@ -147,7 +147,7 @@
             if (null != one) {
                 log.info("璇ユ祦绋嬪崱宸茬粦瀹氭灦瀛�");
                 isBind = Boolean.TRUE;
-                checkFlag = multilayerCheck(glassInfo);
+                checkFlag = multilayerCheck(glassInfo, isBind);
             }
             if (!checkFlag && !isBind) {
                 log.info("璇ョ幓鐠冪殑娴佺▼鍗℃湭缁戝畾鏋跺瓙锛岃幏鍙栨槸鍚︽湁绌烘灦瀛�");
@@ -156,7 +156,9 @@
                 if (CollectionUtils.isNotEmpty(list)) {
                     log.info("鏈夌┖鏋跺瓙,灏嗘祦绋嬪崱涓庢灦瀛愬ソ缁戝畾锛屾墽琛岃繘鐗囦换鍔� 缁撴潫");
                     //缁戝畾娴佺▼鍗�
-                    downWorkstationService.update(new LambdaUpdateWrapper<DownWorkstation>().set(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())
+                    downWorkstationService.update(new LambdaUpdateWrapper<DownWorkstation>()
+                            .set(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())
+                            .set(DownWorkstation::getLayer, glassInfo.getLayer())
                             .eq(DownWorkstation::getWorkstationId, list.get(0).getWorkstationId()));
                     checkFlag = Boolean.TRUE;
                 }
@@ -165,31 +167,34 @@
                 log.info("鏃犵┖鏋跺瓙,鑾峰彇宸茬粦瀹氭灦瀛愮殑娴佺▼鍗′俊鎭�,鏌ョ湅鐜荤拑淇℃伅鏄惁鍙瀵硅皟");
                 List<DownGlassInfoDTO> downGlassInfoDTOList = downGlassInfoService.queryWorkStationIsIn(Boolean.FALSE);
                 log.info("鑾峰彇鏋跺瓙涓婂凡缁戝畾娴佺▼鍗¤惤鏋剁殑鏁伴噺鍙婃湭钀芥灦鐨勭幓鐠冩暟鎹細{}", downGlassInfoDTOList);
-                Assert.isTrue(CollectionUtils.isNotEmpty(downGlassInfoDTOList), "宸茬粦瀹氭祦绋嬪崱鍧囨棤鏈惤鏋剁幓鐠冿紝璇峰強鏃跺鐞嗘灦瀛愪笂鐨勭幓鐠冿紝娓呴櫎娴佺▼鍗�");
-                //鏇挎崲鐜荤拑淇℃伅
-                endLoop:
-                for (DownGlassInfoDTO e : downGlassInfoDTOList) {
-                    List<GlassInfo> glassInfoList = e.getGlassInfoList();
-                    for (GlassInfo item : glassInfoList) {
-                        if (item.getWidth().equals(glassInfo.getWidth()) && item.getHeight().equals(glassInfo.getHeight())
-                                && item.getThickness().equals(glassInfo.getThickness()) && item.getFilmsid().equals(glassInfo.getFilmsid())) {
-                            //鐜荤拑鏄惁涓哄灞�
-                            checkFlag = multilayerCheck(item);
-                            if (checkFlag) {
-                                //鐜荤拑鏇挎崲 浠呮浛鎹㈡祦绋嬪崱id鍙婂眰鏁�
-                                String tempFlowCardId = item.getFlowCardId();
-                                Integer tempLayer = item.getLayer();
-                                String flowCardId = glassInfo.getFlowCardId();
-                                Integer layer = glassInfo.getLayer();
-                                log.info("鏇挎崲娴佺▼鍗′俊鎭�,褰撳墠鐜荤拑淇℃伅:{}鐨勬祦绋嬪崱鍙穥}鍙婂眰鏁皗},鏇挎崲鍚庣幓鐠冧俊鎭�:{}鐨勬祦绋嬪崱鍙穥}鍙婂眰鏁皗}",
-                                        item, glassInfo, flowCardId, layer, tempFlowCardId, tempLayer);
-                                glassInfo.setFlowCardId(tempFlowCardId);
-                                glassInfo.setLayer(tempLayer);
-                                glassInfoService.updateById(glassInfo);
-                                item.setFlowCardId(flowCardId);
-                                item.setLayer(layer);
-                                glassInfoService.updateById(item);
-                                break endLoop;
+                if (CollectionUtils.isEmpty(downGlassInfoDTOList)) {
+                    log.info("宸茬粦瀹氭祦绋嬪崱鍧囨棤鏈惤鏋剁幓鐠冿紝璇峰強鏃跺鐞嗘灦瀛愪笂鐨勭幓鐠冿紝娓呴櫎娴佺▼鍗�,鎵ц杩涚墖浠诲姟");
+                } else {
+                    //鏇挎崲鐜荤拑淇℃伅
+                    endLoop:
+                    for (DownGlassInfoDTO e : downGlassInfoDTOList) {
+                        List<GlassInfo> glassInfoList = e.getGlassInfoList();
+                        for (GlassInfo item : glassInfoList) {
+                            if (item.getWidth() == glassInfo.getWidth() && item.getHeight() == glassInfo.getHeight()
+                                    && item.getThickness() == glassInfo.getThickness() && item.getFilmsid().equals(glassInfo.getFilmsid())) {
+                                //鐜荤拑鏄惁涓哄灞�
+                                checkFlag = multilayerCheck(item, Boolean.FALSE);
+                                if (checkFlag) {
+                                    //鐜荤拑鏇挎崲 浠呮浛鎹㈡祦绋嬪崱id鍙婂眰鏁�
+                                    String tempFlowCardId = item.getFlowCardId();
+                                    Integer tempLayer = item.getLayer();
+                                    String flowCardId = glassInfo.getFlowCardId();
+                                    Integer layer = glassInfo.getLayer();
+                                    log.info("鏇挎崲娴佺▼鍗′俊鎭�,褰撳墠鐜荤拑淇℃伅:{}鐨勬祦绋嬪崱鍙穥}鍙婂眰鏁皗},鏇挎崲鍚庣幓鐠冧俊鎭�:{}鐨勬祦绋嬪崱鍙穥}鍙婂眰鏁皗}",
+                                            item, glassInfo, flowCardId, layer, tempFlowCardId, tempLayer);
+                                    glassInfo.setFlowCardId(tempFlowCardId);
+                                    glassInfo.setLayer(tempLayer);
+                                    glassInfoService.updateById(glassInfo);
+                                    item.setFlowCardId(flowCardId);
+                                    item.setLayer(layer);
+                                    glassInfoService.updateById(item);
+                                    break endLoop;
+                                }
                             }
                         }
                     }
@@ -200,33 +205,92 @@
         DownStorageCageDetails downStorageCageDetails = new DownStorageCageDetails();
         BeanUtils.copyProperties(glassInfo, downStorageCageDetails);
         downStorageCageDetails.setState(Const.GLASS_STATE_IN);
+        downStorageCageDetails.setSlot(nearestEmpty.getSlot());
         downStorageCageDetailsService.save(downStorageCageDetails);
 //        鐢熸垚杩涚墖浠诲姟
-        initDownGlassTask(glassInfo, nearestEmpty.getSlot(), null, Const.GLASS_CACHE_TYPE_IN);
-        //log.info("5銆佺敓鎴愯繘鐗囦换鍔′俊鎭瓨鍏ヤ换鍔¤〃鏄惁瀹屾垚锛歿}", taskCache);
-//        S7object.getinstance().plccontrol.writeWord(confirmationWrodAddress, (short) 1);
-//        log.info("6銆佸彂閫佺‘璁ゅ瓧瀹屾垚");
+        initDownGlassTask(glassInfo, 0, nearestEmpty.getSlot(), Const.GLASS_CACHE_TYPE_IN);
     }
 
-    private Boolean outTo(String glassStatus06, String glassStatus11, String glassStatus13, String glassId) {
+    public Boolean outTo(String glassStatus06, String out08Glassstate, String glassStatus11, String glassStatus13, String glassId, String currentSlot) {
         if ("2".equals(glassStatus06) && "2".equals(glassStatus11) && "2".equals(glassStatus13)) {
             log.info("G06銆丟11銆丟13鍒嗗埆涓簕},{}銆亄}闈炶嚜鍔ㄧ姸鎬侊紝鏃犳硶鍑虹墖", glassStatus06, glassStatus11, glassStatus13);
             return Boolean.FALSE;
         }
+
         List<DownStorageCageDetails> tempList = downStorageCageDetailsService.list(new LambdaQueryWrapper<DownStorageCageDetails>()
                 .eq(DownStorageCageDetails::getState, Const.GLASS_STATE_IN));
+        //鑾峰彇寰呰繘鐗囩幓鐠�
+        DownStorageCageDetails cageDetails = new DownStorageCageDetails();
+        if (StringUtils.isNotBlank(glassId)) {
+            GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId));
+            BeanUtils.copyProperties(glassInfo, cageDetails);
+            //鑾峰彇褰撳墠绗煎瓙绌烘牸淇℃伅
+            DownStorageCage empty = downStorageCageService.selectCacheEmpty(Integer.parseInt(currentSlot), Boolean.TRUE);
+            cageDetails.setSlot(empty.getSlot());
+            tempList.add(cageDetails);
+        }
+
         log.info("绗煎唴鐜荤拑鐨勬暟鎹湁锛歿}", tempList);
         if (CollectionUtils.isEmpty(tempList)) {
             log.info("绗煎唴娌℃湁鐜荤拑,鏃犳硶鎵ц鍑虹墖");
             return Boolean.FALSE;
         }
+        Boolean flag08 = "1".equals(out08Glassstate) ? Boolean.TRUE : Boolean.FALSE;
+        if (!generateTaskByShelf(glassStatus11, flag08, glassStatus13, tempList, cageDetails)) {
+            return generateTaskByShelf(glassStatus11, !flag08, glassStatus13, tempList, cageDetails);
+        }
+        return Boolean.TRUE;
+    }
+
+    private Boolean multilayerCheck(GlassInfo glassInfo, boolean isBind) {
+        //鏌ヨ璇ユ祦绋嬪崱鏄惁涓哄灞�
+        if (glassInfo.getTotalLayer() > 1) {
+            log.info("鎸夌収娴佺▼鍗¤幏鍙栧綋鍓嶆祦绋嬪崱鍚勫眰宸茶惤鏋舵暟閲�");
+            DownGlassInfoDTO downGlassInfoDTO = downGlassInfoService.queryDownGlassMaxLayer(glassInfo.getFlowCardId());
+            if (null == downGlassInfoDTO) {
+                if (isBind) {
+                    return Boolean.TRUE;
+                } else {
+                    log.info("鏋跺瓙宸茬粡鍗犳弧锛屽灞傜幓鐠冩棤娉曟壘鍒板搴旂殑鏍煎瓙锛岄渶鎵ц鏇挎崲鐜荤拑鐨勬搷浣�");
+                    return Boolean.FALSE;
+                }
+
+            }
+            if (downGlassInfoDTO.getLayer().equals(glassInfo.getLayer())) {
+                log.info("褰撳墠鐜荤拑鐨勬祦绋嬪湪鏋跺瓙涓婅惤鏋舵渶澶� 鐩存帴杩涚墖");
+                return Boolean.TRUE;
+            }
+            Integer sequence = downGlassInfoService.queryMaxSequence(glassInfo.getFlowCardId(), glassInfo.getLayer());
+            log.info("鑾峰彇褰撳墠鐜荤拑闇�瑕佹斁鐨勬搴忥細绗煎唴鍚屾祦绋� 鍚屽眰鏁扮殑閫氳揪娆″簭+1:{}", sequence);
+            DownGlassInfo downGlassInfo = downGlassInfoService.getOne(new LambdaQueryWrapper<DownGlassInfo>()
+                    .eq(DownGlassInfo::getFlowCardId, downGlassInfoDTO.getFlowCardId())
+                    .eq(DownGlassInfo::getLayer, downGlassInfoDTO.getLayer()).eq(DownGlassInfo::getSequence, sequence));
+            log.info("鎷垮綋鍓嶇増搴忚幏鍙栫幓鐠冧俊鎭瘂}锛屾寜鐓ф搴忓垽鏂綋鍓嶇幓鐠冩槸鍚﹀昂瀵稿搴旂殑涓婏紙涓庢暟閲忔渶澶氱殑娆″簭姣旇緝锛夈��", downGlassInfo);
+            if (null != downGlassInfoDTO && downGlassInfo.getWidth() == glassInfo.getWidth() && downGlassInfo.getHeight() == glassInfo.getHeight()) {
+                log.info("鐩稿悓娆″簭鐜荤拑瀵瑰簲涓婏紝鍙墽琛岃繘鐗囦换鍔�");
+                return Boolean.TRUE;
+            } else {
+                log.info("鍚屾搴忕幓鐠冨搴斾笉涓婏紝闇�鎵ц鏇挎崲鐜荤拑鐨勬搷浣�");
+                return Boolean.FALSE;
+            }
+        } else {
+            log.info("闈炲灞傜幓鐠冿紝鐩存帴杩涚墖");
+            return Boolean.TRUE;
+        }
+    }
+
+    private Boolean generateTaskByShelf(String glassStatus, Boolean flag08, String glassStatus13, List<DownStorageCageDetails> tempList, DownStorageCageDetails cageDetails) {
         //鑾峰彇2涓満姊拌噦鑼冨洿鍐呯殑鏋跺瓙缁戝畾鐨勬祦绋嬪崱淇℃伅
         List<Integer> workList = new ArrayList();
-        if (!"2".equals(glassStatus06)) {
-            workList.addAll(Const.G06_WORK_STATION);
-        }
-        if (!"2".equals(glassStatus11)) {
-            workList.addAll(Const.G11_WORK_STATION);
+
+        if (flag08) {
+            if (!"2".equals(glassStatus)) {
+                workList.addAll(Const.G11_WORK_STATION);
+            }
+        } else {
+            if (!"2".equals(glassStatus)) {
+                workList.addAll(Const.G06_WORK_STATION);
+            }
         }
         List<DownStorageCageDetails> list = new ArrayList();
         Boolean isEmptyShelf = Boolean.FALSE;
@@ -257,23 +321,25 @@
                 }
             }
         } else {
-            //鐩存帴璧颁汉宸ヤ笅鐗�
-            list = tempList.stream().filter(item -> item.getWidth() > maxWidth || item.getHeight() > maxHeight).collect(Collectors.toList());
+            if (flag08 && !"2".equals(glassStatus13)) {
+                //鐩存帴璧颁汉宸ヤ笅鐗�
+                list = tempList.stream().filter(item -> item.getWidth() > maxWidth || item.getHeight() > maxHeight).collect(Collectors.toList());
+            }
         }
         if (CollectionUtils.isEmpty(list)) {
             log.info("绗煎唴鐜荤拑鏃犳硶鎵ц鍑虹墖");
             return Boolean.FALSE;
         }
-        //瀹氫箟绗煎唴鏃犳硶鍑虹墖鐜荤拑鏁伴噺
-        int glassCount = tempList.size() - list.size();
         String tempGlassId = null;
         Boolean isBind = Boolean.FALSE;
 
         for (DownStorageCageDetails item : list) {
             if (item.getWidth() > maxWidth || item.getHeight() > maxHeight) {
-                log.info("鐜荤拑瀹藉害鎴栭珮搴﹁秴鍑洪槇鍊硷紝鎵ц浜哄伐涓嬬墖");
-                tempGlassId = item.getGlassId();
-                break;
+                if (flag08 && !"2".equals(glassStatus13)) {
+                    log.info("鐜荤拑瀹藉害鎴栭珮搴﹁秴鍑洪槇鍊硷紝鎵ц浜哄伐涓嬬墖");
+                    tempGlassId = item.getGlassId();
+                    break;
+                }
             }
         }
         loop:
@@ -282,7 +348,7 @@
             List<DownGlassInfoDTO> downGlassInfoDTOList = downGlassInfoService.queryWorkStationIsIn(Boolean.TRUE);
             List<String> downGlassFlowList = downGlassInfoDTOList.stream().map(item -> item.getFlowCardId() + ":" + item.getLayer()).collect(Collectors.toList());
             if (CollectionUtils.isEmpty(downGlassFlowList)) {
-                //鏋跺瓙鐜荤拑閮戒负绌猴紝鍑虹鍐呭瓙鏁伴噺鏈�澶氬昂瀵告渶澶х殑鐜荤拑
+                //鏋跺瓙閮芥湭缁戝畾娴佺▼鍗★紝鍑虹鍐呭瓙鏁伴噺鏈�澶氬昂瀵告渶澶х殑鐜荤拑
                 DownStorageCageDetails downStorageCageDetails = downStorageCageDetailsService.getGlassInfoMaxCount();
                 //缁戝畾娴佺▼鍗★紝鏇存柊鐜荤拑鐘舵�侊紝鐢熸垚鍑虹墖浠诲姟锛�
                 tempGlassId = downStorageCageDetails.getGlassId();
@@ -302,13 +368,6 @@
                     isBind = Boolean.TRUE;
                     break loop;
                 }
-                glassCount = noDownLoadList.size();
-                if (glassCount > threshold) {
-                    //鏇存柊鐜荤拑鐘舵�侊紝鐢熸垚鍑虹墖浜哄伐涓嬬墖浠诲姟
-                    tempGlassId = noDownLoadList.get(0).getGlassId();
-                    isBind = Boolean.FALSE;
-                    break loop;
-                }
             }
             //灏嗙瀛愬唴鐨勭幓鐠冭繘琛岃繃婊わ紝浠呰幏鍙栧彲钀芥灦鐨勬祦绋嬪崱鐜荤拑
             List<DownStorageCageDetails> downLoadList = list.stream().filter(item -> downGlassFlowList.contains(item.getFlowCardId() + ":" + item.getLayer())).collect(Collectors.toList());
@@ -323,14 +382,16 @@
                 for (DownStorageCageDetails item : multiLayerList) {
                     DownGlassInfoDTO downGlassInfoDTO = downGlassInfoService.queryDownGlassMaxLayer(item.getFlowCardId());
                     if (null == downGlassInfoDTO) {
-//                    钀芥灦鐜荤拑鏌ュ埌鐩稿叧娴佺▼鍗$幓鐠冧俊鎭紝琛ㄦ槑褰撳墠娴佺▼鍗$幓鐠冩湭钀芥灦
+//                    鍘嗗彶钀芥灦鐜荤拑鎸夌収鐩稿叧娴佺▼鍗″彇鏁版嵁搴撴湭鎵惧埌鏈�澶氱幓鐠冧俊鎭紝琛ㄦ槑褰撳墠娴佺▼鍗′笅鐨勬湁灞傜殑鐜荤拑鍧囨湭钀芥灦锛岀洿鎺ュ彲鍑哄綋鍓嶇幓鐠�
                         log.info("");
-                        return Boolean.FALSE;
+                        isBind = Boolean.FALSE;
+                        tempGlassId = item.getGlassId();
+                        break loop;
                     }
                     if (downGlassInfoDTO.getLayer().equals(downGlassInfoDTO.getLayer())) {
                         log.info("褰撳墠鐜荤拑鐨勬祦绋嬪湪鏋跺瓙涓婅惤鏋舵渶澶�,鐩存帴鍑虹墖");
                         //鏇存柊鐜荤拑鐘舵�侊紝鐢熸垚鍑虹墖浠诲姟
-                        tempGlassId = noDownLoadList.get(0).getGlassId();
+                        tempGlassId = item.getGlassId();
                         isBind = Boolean.FALSE;
                         break loop;
                     }
@@ -339,21 +400,12 @@
                     DownGlassInfo downGlassInfo = downGlassInfoService.getOne(new LambdaQueryWrapper<DownGlassInfo>()
                             .eq(DownGlassInfo::getFlowCardId, downGlassInfoDTO.getFlowCardId())
                             .eq(DownGlassInfo::getLayer, downGlassInfoDTO.getLayer()).eq(DownGlassInfo::getSequence, sequence));
-                    if (null != downGlassInfoDTO && downGlassInfo.getWidth().equals(item.getWidth()) && downGlassInfo.getHeight().equals(item.getHeight())) {
+                    if (null != downGlassInfoDTO && downGlassInfo.getWidth() == item.getWidth() && downGlassInfo.getHeight() == item.getHeight()) {
                         log.info("鐩稿悓娆″簭鐜荤拑瀵瑰簲涓婏紝鍙墽琛岃繘鐗囦换鍔�");
                         //鏇存柊鐜荤拑鐘舵�侊紝鐢熸垚鍑虹墖浠诲姟
-                        tempGlassId = noDownLoadList.get(0).getGlassId();
+                        tempGlassId = item.getGlassId();
                         isBind = Boolean.FALSE;
                         break loop;
-                    } else {
-                        log.info("鍚屾搴忕幓鐠冨搴斾笉涓婏紝闇�鎵ц鏇挎崲鐜荤拑鐨勬搷浣�");
-                        glassCount += 1;
-                        if (glassCount > threshold) {
-                            tempGlassId = noDownLoadList.get(0).getGlassId();
-                            isBind = Boolean.FALSE;
-                            break loop;
-                        }
-                        continue;
                     }
                 }
             }
@@ -379,46 +431,21 @@
             return Boolean.FALSE;
         } else {
             //鎸夌収鍑虹墖鐨勭幓鐠僫d鏇存柊绗煎唴鐨勭幓鐠冪姸鎬佷负宸插嚭鐗�
-            return generateDownGlassOutTask(tempGlassId, Const.GLASS_CACHE_TYPE_OUT, isBind);
+            return generateDownGlassOutTask(tempGlassId, Const.GLASS_CACHE_TYPE_OUT, isBind, cageDetails);
         }
     }
 
-    private Boolean multilayerCheck(GlassInfo glassInfo) {
-        //鏌ヨ璇ユ祦绋嬪崱鏄惁涓哄灞�
-        if (glassInfo.getTotalLayer() > 1) {
-            log.info("鎸夌収娴佺▼鍗¤幏鍙栧綋鍓嶆祦绋嬪崱鍚勫眰宸茶惤鏋舵暟閲�");
-            DownGlassInfoDTO downGlassInfoDTO = downGlassInfoService.queryDownGlassMaxLayer(glassInfo.getFlowCardId());
-            if (null == downGlassInfoDTO) {
-                log.info("鏋跺瓙宸茬粡鍗犳弧锛屽灞傜幓鐠冩棤娉曟壘鍒板搴旂殑鏍煎瓙锛岄渶鎵ц鏇挎崲鐜荤拑鐨勬搷浣�");
-                return Boolean.FALSE;
-            }
-            if (downGlassInfoDTO.getLayer().equals(glassInfo.getLayer())) {
-                log.info("褰撳墠鐜荤拑鐨勬祦绋嬪湪鏋跺瓙涓婅惤鏋舵渶澶� 鐩存帴杩涚墖");
-                return Boolean.TRUE;
-            }
-            Integer sequence = downGlassInfoService.queryMaxSequence(glassInfo.getFlowCardId(), glassInfo.getLayer());
-            log.info("鑾峰彇褰撳墠鐜荤拑闇�瑕佹斁鐨勬搴忥細绗煎唴鍚屾祦绋� 鍚屽眰鏁扮殑閫氳揪娆″簭+1:{}", sequence);
-            DownGlassInfo downGlassInfo = downGlassInfoService.getOne(new LambdaQueryWrapper<DownGlassInfo>()
-                    .eq(DownGlassInfo::getFlowCardId, downGlassInfoDTO.getFlowCardId())
-                    .eq(DownGlassInfo::getLayer, downGlassInfoDTO.getLayer()).eq(DownGlassInfo::getSequence, sequence));
-            log.info("鎷垮綋鍓嶇増搴忚幏鍙栫幓鐠冧俊鎭瘂}锛屾寜鐓ф搴忓垽鏂綋鍓嶇幓鐠冩槸鍚﹀昂瀵稿搴旂殑涓婏紙涓庢暟閲忔渶澶氱殑娆″簭姣旇緝锛夈��", downGlassInfo);
-            if (null != downGlassInfoDTO && downGlassInfo.getWidth().equals(glassInfo.getWidth()) && downGlassInfo.getHeight().equals(glassInfo.getHeight())) {
-                log.info("鐩稿悓娆″簭鐜荤拑瀵瑰簲涓婏紝鍙墽琛岃繘鐗囦换鍔�");
-                return Boolean.TRUE;
-            } else {
-                log.info("鍚屾搴忕幓鐠冨搴斾笉涓婏紝闇�鎵ц鏇挎崲鐜荤拑鐨勬搷浣�");
-                return Boolean.FALSE;
-            }
-        } else {
-            log.info("闈炲灞傜幓鐠冿紝鐩存帴杩涚墖");
-            return Boolean.TRUE;
-        }
-    }
-
-    private Boolean generateDownGlassOutTask(String glassId, Integer taskType, Boolean isBind) {
+    public Boolean generateDownGlassOutTask(String glassId, Integer taskType, Boolean isBind, DownStorageCageDetails cageDetails) {
         //鎸夌幓鐠僫d鑾峰彇鐜荤拑淇℃伅
-        DownStorageCageDetails downStorageCageDetails = downStorageCageDetailsService.getOne(new LambdaQueryWrapper<DownStorageCageDetails>()
-                .eq(DownStorageCageDetails::getGlassId, glassId));
+        DownStorageCageDetails downStorageCageDetails = null;
+        if (glassId.equals(cageDetails.getGlassId())) {
+            downStorageCageDetails = cageDetails;
+            taskType = 3;
+        } else {
+            downStorageCageDetails = downStorageCageDetailsService.getOne(new LambdaQueryWrapper<DownStorageCageDetails>()
+                    .eq(DownStorageCageDetails::getGlassId, glassId));
+        }
+
         Integer endCell = null;
         if (isBind) {
             //鑾峰彇绌烘灦瀛愪俊鎭紝灏嗙┖鏋跺瓙淇℃伅缁戝畾娴佺▼鍗�
@@ -448,20 +475,44 @@
             return Boolean.FALSE;
         }
         //鐢熸垚浠诲姟淇℃伅
+        DownGlassInfo downGlassInfo = new DownGlassInfo();
+        BeanUtils.copyProperties(downStorageCageDetails, downGlassInfo);
+        downGlassInfoService.save(downGlassInfo);
+        //鐢熸垚浠诲姟淇℃伅
         GlassInfo glassInfo = new GlassInfo();
         BeanUtils.copyProperties(downStorageCageDetails, glassInfo);
         return initDownGlassTask(glassInfo, downStorageCageDetails.getSlot(), endCell, taskType);
     }
 
-    private Boolean initDownGlassTask(GlassInfo glassInfo, Integer startCell, Integer endCell, Integer taskType) {
+    public Boolean initDownGlassTask(GlassInfo glassInfo, Integer startCell, Integer endCell, Integer taskType) {
         log.info("鐜荤拑{}鐢熸垚杩涚墖浠诲姟", glassInfo.getGlassId());
         DownGlassTask downGlassTask = new DownGlassTask();
-        BeanUtils.copyProperties(glassInfo, downGlassTask);
         downGlassTask.setStartCell(startCell);
+        downGlassTask.setGlassId(glassInfo.getGlassId());
         downGlassTask.setEndCell(endCell);
         downGlassTask.setTaskType(taskType + "");
+        downGlassTask.setWidth((int) glassInfo.getWidth());
+        downGlassTask.setHeight((int) glassInfo.getHeight());
+        downGlassTask.setFlowCardId(glassInfo.getFlowCardId());
+        downGlassTask.setLayer(glassInfo.getLayer());
         downGlassTask.setTaskStauts(0);
         downGlassTask.setCreateTime(new Date());
-        return downGlassTaskService.save(downGlassTask);
+        downGlassTaskService.save(downGlassTask);
+        //鍚憄lc鍙戦�佸懡浠�
+        return sendMessageToPlc((int) glassInfo.getWidth(), (int) glassInfo.getHeight(), (int) glassInfo.getThickness(),
+                startCell, endCell, taskType);
+    }
+
+    private Boolean sendMessageToPlc(int width, int height, int thickness, int startCell, int endCell, int taskType) {
+        S7control s7control = S7object.getinstance().plccontrol;
+        PlcParameterObject plcMesObject = S7object.getinstance().PlcMesObject;
+        s7control.writeWord(plcMesObject.getPlcParameter("Glass_width").getAddress(), (short) width);
+        s7control.writeWord(plcMesObject.getPlcParameter("Glass_height").getAddress(), (short) height);
+        s7control.writeWord(plcMesObject.getPlcParameter("Glass_thickness").getAddress(), (short) thickness);
+        s7control.writeWord(plcMesObject.getPlcParameter("Start_cell").getAddress(), (short) startCell);
+        s7control.writeWord(plcMesObject.getPlcParameter("End_cell").getAddress(), (short) endCell);
+        s7control.writeWord(plcMesObject.getPlcParameter("task_type").getAddress(), (short) taskType);
+        s7control.writeWord(plcMesObject.getPlcParameter("confirmationWord").getAddress(), (short) 1);
+        return Boolean.TRUE;
     }
 }

--
Gitblit v1.8.0