From 2d0358932cd63ed46778be72d126fc8d766a27a8 Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期三, 18 九月 2024 16:15:59 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- hangzhoumesParent/moduleService/UnLoadGlassModule/src/main/java/com/mes/job/DownLoadCacheGlassTask.java | 57 +++++++++++++++++++++++++++++++++++++++++---------------- 1 files changed, 41 insertions(+), 16 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 f3a73be..27d3131 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 @@ -81,7 +81,6 @@ @Scheduled(fixedDelay = 300) - @Async public void plcHomeEdgTask() { PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; String requestWord = plcParameterObject.getPlcParameter("requestWord").getValue(); @@ -98,7 +97,6 @@ log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佸垎鍒负锛歡06:{}銆乬08:{}銆乬11:{}銆乬13:{},褰撳墠鏍煎瓙鍙蜂负锛歿}", requestWord, glassIdeValue, confirmationWrodValue, out06Glassstate, out08Glassstate, out11Glassstate, out13Glassstate, currentSlot); - if ("0".equals(requestWord)) { if ("0".equals(confirmationWrodValue)) { log.info("2銆佽幏鍙栧埌鐨勮姹傚瓧涓�0锛屼笖纭瀛椾负0锛屼笉鎵ц浠诲姟"); @@ -131,7 +129,6 @@ } @Scheduled(fixedDelay = 300) - @Async public void plcShelfFull() { List<DownWorkstation> list = downGlassInfoService.queryWorkStationIsFull(); if (CollectionUtils.isNotEmpty(list)) { @@ -142,7 +139,6 @@ } @Scheduled(fixedDelay = 1000) - @Async public void dealDamageTask() { Date startDate = new Date(); log.info("涓嬬墖鐮存崯鐜荤拑娓呴櫎浠诲姟寮�濮嬫墽琛屾椂闂达細{}", startDate); @@ -187,7 +183,6 @@ * 鏇存柊宸茬粦瀹氬伐浣嶆祦绋嬪崱鐨勭牬鎹�/鎷胯蛋鐨勬暟閲忎俊鎭� */ @Scheduled(fixedDelay = 1000) - @Async public void updateWorkStationOtherCount() { Date startDate = new Date(); log.info("涓嬬墖鐮存洿鏂版崯鐜荤拑鏁伴噺浠诲姟寮�濮嬫墽琛屾椂闂达細{}", startDate); @@ -230,9 +225,16 @@ } else { log.info("璇ョ幓鐠冨昂瀵搁潪浜哄伐涓嬬墖"); //鑾峰彇璇ョ幓鐠冪殑娴佺▼鍗℃槸鍚﹀凡缁戝畾鏋跺瓙 - DownWorkstation one = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>() - .eq(DownWorkstation::getLayer, glassInfo.getLayer()) - .eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); + DownWorkstation one; + if (glassInfo.getCombine() != 0) { + one = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>() + .eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); + } else { + one = downWorkstationService.getOne(new LambdaQueryWrapper<DownWorkstation>() + .eq(DownWorkstation::getLayer, glassInfo.getLayer()) + .eq(DownWorkstation::getFlowCardId, glassInfo.getFlowCardId())); + } + //鏄惁宸茬粡缁戝畾 true锛氬凡缁戝畾 false:鏈粦瀹� Boolean isBind = Boolean.FALSE; if (null != one) { @@ -247,8 +249,12 @@ if (CollectionUtils.isNotEmpty(list)) { log.info("鏈夌┖鏋跺瓙,灏嗘祦绋嬪崱涓庢灦瀛愬ソ缁戝畾锛屾墽琛岃繘鐗囦换鍔� 缁撴潫"); //缁戝畾娴佺▼鍗� - downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getWorkstationId(), glassInfo.getLayer()); -// downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getId(), glassInfo.getLayer()); + if (glassInfo.getCombine() == 0) { + downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getWorkstationId(), glassInfo.getLayer()); + } else { + downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getWorkstationId(), 0); + } +// downWorkstationService.updateFlowCardIdAndCount(glassInfo.getFlowCardId(), list.get(0).getId(), glassInfo.getLayer()); checkFlag = Boolean.TRUE; } } @@ -298,8 +304,8 @@ DownStorageCageDetails downStorageCageDetails = new DownStorageCageDetails(); BeanUtils.copyProperties(glassInfo, downStorageCageDetails); //褰撻渶瑕佸悎骞惰惤鏋舵椂涓嶇粦瀹氬眰鍙� - if(glassInfo.getCombine()==0){ - downStorageCageDetails.setLayer(null); + if (glassInfo.getCombine() != 0) { + downStorageCageDetails.setLayer(0); } downStorageCageDetails.setState(Const.GLASS_STATE_IN); downStorageCageDetails.setSlot(nearestEmpty.getSlot()); @@ -326,8 +332,8 @@ GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId)); BeanUtils.copyProperties(glassInfo, cageDetails); //褰撻渶瑕佸悎骞惰惤鏋舵椂涓嶇粦瀹氬眰鍙� - if(glassInfo.getCombine()==0){ - cageDetails.setLayer(null); + if (glassInfo.getCombine() != 0) { + cageDetails.setLayer(0); } //鑾峰彇褰撳墠绗煎瓙绌烘牸淇℃伅 DownStorageCage empty = downStorageCageService.selectCacheEmpty(Integer.parseInt(currentSlot), Boolean.TRUE); @@ -345,6 +351,7 @@ //2銆�08鍙扮┖闂诧紝鍏堣蛋鎵斿伐涓嬬墖鎴�2鍙锋満姊拌噦锛屾棤鐜荤拑鍑虹墖 鍦ㄨ蛋1鍙锋満姊拌噦 //鏈烘鑷傝绂佺敤鐨勬儏鍐典笅涓嶈兘缁х画鍚戠鐢ㄧ殑鏈烘鑷傛斁鐜荤拑 Boolean flag08 = "1".equals(out08Glassstate) ? Boolean.TRUE : Boolean.FALSE; + flag08 = true; if (!flag08) { generateTaskByShelf(glassStatus06, glassStatus11, flag08, glassStatus13, tempList, cageDetails, glassId); } else { @@ -445,6 +452,7 @@ Map<String, List<DownWorkstation>> listMap = downWorkstationList.stream() .filter(item -> StringUtils.isNotBlank(item.getFlowCardId())).collect(Collectors.groupingBy(item -> item.getFlowCardId() + ":" + item.getLayer())); //杩囨护绛涢�夎幏鍙栨灦瀛愪笂瀵瑰簲娴佺▼鍗�+灞傛暟鐨勭瀛愬唴鐨勭幓鐠冧俊鎭� + list = tempList.stream().filter(item -> listMap.containsKey(item.getFlowCardId() + ":" + item.getLayer())).collect(Collectors.toList()); if (CollectionUtils.isEmpty(list) && flag08 && !"2".equals(glassStatus13)) { list = tempList.stream().filter(item -> { @@ -634,7 +642,8 @@ if (downStorageCageDetails.getWidth() > maxWidth || downStorageCageDetails.getHeight() > maxHeight) { endCell = Const.G13_WORK_STATION; } else { - DownWorkstation workstation = downWorkstationService.getOne(new LambdaUpdateWrapper<DownWorkstation>() + DownWorkstation workstation; + workstation = downWorkstationService.getOne(new LambdaUpdateWrapper<DownWorkstation>() .eq(DownWorkstation::getFlowCardId, downStorageCageDetails.getFlowCardId()).eq(DownWorkstation::getLayer, downStorageCageDetails.getLayer())); endCell = workstation.getWorkstationId(); } @@ -652,12 +661,28 @@ DownGlassInfo downGlassInfo = new DownGlassInfo(); BeanUtils.copyProperties(downStorageCageDetails, downGlassInfo); //钀芥灦鐗囧簭 - downGlassInfo.setSequence(downGlassInfoService.queryMaxSequence(downGlassInfo.getFlowCardId(), downGlassInfo.getLayer())); + LambdaQueryWrapper<DownGlassInfo> wrapper = new LambdaQueryWrapper<DownGlassInfo>(); + wrapper.eq(DownGlassInfo::getFlowCardId, downGlassInfo.getFlowCardId()) + .orderByDesc(DownGlassInfo::getSequence) + .last("limit 1"); + if (downStorageCageDetails.getLayer() != 0) { + wrapper.eq(DownGlassInfo::getLayer, downGlassInfo.getLayer()); + } +// downGlassInfo.setSequence(downGlassInfoService.queryMaxSequence(downGlassInfo.getFlowCardId(), downGlassInfo.getLayer())); + int k = 0; + DownGlassInfo downGlassInfo1 = downGlassInfoService.getOne(wrapper); + if (downGlassInfo1 != null) { + k = 1; + } else { + k = 1; + } + downGlassInfo.setSequence(k); downGlassInfo.setWorkStationId(endCell); downGlassInfo.setGmtCreate(new Date()); downGlassInfoService.save(downGlassInfo); //鐢熸垚浠诲姟淇℃伅 GlassInfo glassInfo = new GlassInfo(); + downStorageCageDetails.setLayer(0); BeanUtils.copyProperties(downStorageCageDetails, glassInfo); //鍒犻櫎鐞嗙墖绗艰〃鎷胯蛋/鐮存崯鏁版嵁鏁版嵁 damageService.deleteByGlassId(glassInfo.getGlassId()); -- Gitblit v1.8.0