From 7acaa5448429c3a28a74561236224e7c1f57b329 Mon Sep 17 00:00:00 2001 From: zhoushihao <zsh19950802@163.com> Date: 星期六, 25 五月 2024 16:12:36 +0800 Subject: [PATCH] 卧式理片笼线程改造:新增尺寸校验,10磨边线最大尺寸限制 --- hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java | 110 +++++++++++++++++++++++++++---------------------------- 1 files changed, 54 insertions(+), 56 deletions(-) diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java index a3615de..365eb8d 100644 --- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java +++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java @@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.yulichang.query.MPJQueryWrapper; -import com.github.yulichang.wrapper.MPJLambdaWrapper; import com.mes.common.S7object; import com.mes.common.WebSocketServer; import com.mes.common.config.Const; @@ -182,7 +181,7 @@ * @param glassId * @param currentSlot */ - private boolean outTo(int out08Glassstate, int out10Glassstate, String confirmationWrodAddress, String glassId, int currentSlot) { + public boolean outTo(int out08Glassstate, int out10Glassstate, String confirmationWrodAddress, String glassId, int currentSlot) { //閫昏緫姝ラ锛� // 0銆丄09銆丄10鏄惁绌洪棽锛屾槸鍚﹀彲浠ユ墽琛屽嚭鐗囦换鍔� // 1銆佽幏鍙栭挗鍖栫増鍥炬槸鍚﹁秴杩囬槇鍊� @@ -219,37 +218,59 @@ endcell = queryLineByGlassInfo(a09EdgGlass, a10EdgGlass, glassInfo, out08Glassstate, out10Glassstate); } else { //鍒ゆ柇涓ゆ潯绾挎槸鍚﹂兘绌洪棽 - endcell = out08Glassstate == 1 || out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; + endcell = out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; if ((out08Glassstate == 0 && out10Glassstate == 0) || (out08Glassstate == 1 && out10Glassstate == 1)) { EdgStorageCageDetails a09EdgGlass = queryGlassByTaskCache(Const.A09_OUT_TARGET_POSITION, Const.GLASS_CACHE_TYPE_OUT); EdgStorageCageDetails a10EdgGlass = queryGlassByTaskCache(Const.A10_OUT_TARGET_POSITION, Const.GLASS_CACHE_TYPE_OUT); if (a09EdgGlass == null && a10EdgGlass == null) { - MPJLambdaWrapper<EdgStorageCageDetails> wrapper = new MPJLambdaWrapper<>(); - wrapper.select(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight) - .selectCount(EdgStorageCageDetails::getGlassId, EdgStorageCageDetails::getCount) - .groupBy(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight) - .last("order by count(t.glass_id) desc limit 2"); + MPJQueryWrapper<EdgStorageCageDetails> wrapper = new MPJQueryWrapper<>(); + wrapper.select("count(t.glass_id), t.width, t.height") + .eq("t.state", Const.GLASS_STATE_IN) + .groupBy("t.width, t.height"); + if (endcell == Const.A10_OUT_TARGET_POSITION) { + wrapper.innerJoin("(select glass_id, case when height <= width then width else height end as first_length, " + + "case when width < height then width else height end as second_length from edg_storage_cage_details) t1 " + + "on t.glass_id = t1.glass_id and t1.first_length <3500 and t1.second_length<2600 "); + } + wrapper.last("order by count(t.glass_id) desc limit 2"); List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(wrapper); if (CollectionUtil.isEmpty(list)) { - GlassInfo one = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>() - .eq(GlassInfo::getGlassId, glassId)); - EdgStorageCageDetails resultDetails = new EdgStorageCageDetails(); - BeanUtils.copyProperties(one, resultDetails); - glassInfo = resultDetails; + MPJQueryWrapper<GlassInfo> queryWrapper = new MPJQueryWrapper<GlassInfo>() + .selectAll(GlassInfo.class).eq("t.glass_id", glassId); + if (endcell == Const.A10_OUT_TARGET_POSITION) { + queryWrapper.innerJoin("(select glass_id, case when height <= width then width else height end as first_length, " + + "case when width < height then width else height end as second_length from glass_info) t1 " + + "on t.glass_id = t1.glass_id and t1.first_length <3500 and t1.second_length<2600 "); + } + GlassInfo one = glassInfoService.getOne(queryWrapper); + if (one != null) { + EdgStorageCageDetails resultDetails = new EdgStorageCageDetails(); + BeanUtils.copyProperties(one, resultDetails); + glassInfo = resultDetails; + } else { + log.info("鑾峰彇绗煎唴鐜荤拑鍜屽甫杩涚墖鐜荤拑涓虹┖鎴栬�呬笉绗﹀悎纾ㄨ竟灏哄"); + } } else { glassInfo = queryMinGlass(list.get(0).getWidth(), list.get(0).getHeight(), glassId); } } else if (a09EdgGlass != null && a10EdgGlass != null) { List<EdgStorageCageDetails> a09Count = queryGlassByTaskLine(Const.A09_OUT_TARGET_POSITION); - List<EdgStorageCageDetails> a10Count = queryGlassByTaskLine(Const.A09_OUT_TARGET_POSITION); + List<EdgStorageCageDetails> a10Count = queryGlassByTaskLine(Const.A10_OUT_TARGET_POSITION); endcell = a09Count.size() > a10Count.size() ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; glassInfo = a09Count.size() > a10Count.size() ? queryMinGlass(a09EdgGlass.getWidth(), a09EdgGlass.getHeight(), glassId) : queryMinGlass(a10EdgGlass.getWidth(), a10EdgGlass.getHeight(), glassId); } else { - endcell = a09EdgGlass != null ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; - glassInfo = a09EdgGlass != null ? queryMinGlass(a09EdgGlass.getWidth(), a09EdgGlass.getHeight(), glassId) - : queryMinGlass(a10EdgGlass.getWidth(), a10EdgGlass.getHeight(), glassId); + //鎸夌収鍘嗗彶浠诲姟鑾峰彇闇�瑕佹墽琛岀殑璺嚎锛屽鏋滆鏉$嚎绗煎唴鏃犵幓鐠� 璧板叾浠栭�昏緫 + endcell = a09EdgGlass == null ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; + List<EdgStorageCageDetails> details = queryGlassByTaskLine(endcell); + if (CollectionUtil.isEmpty(details)) { + int othercell = endcell == Const.A10_OUT_TARGET_POSITION ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; + glassInfo = queryChangeGlassInfo(othercell, glassId); + } else { + glassInfo = a09EdgGlass != null ? queryMinGlass(a09EdgGlass.getWidth(), a09EdgGlass.getHeight(), glassId) + : queryMinGlass(a10EdgGlass.getWidth(), a10EdgGlass.getHeight(), glassId); + } } } else { List<EdgStorageCageDetails> edgStorageCageDetails = queryGlassByTaskLine(endcell); @@ -410,41 +431,14 @@ boolean b10 = a10EdgStorageCageDetails != null && a10EdgStorageCageDetails.getHeight().equals(glassInfo.getHeight()) && a10EdgStorageCageDetails.getWidth().equals(glassInfo.getWidth()); //瀛樺湪鍑虹墖浠诲姟 07涓虹┖ - if (a08EdgStorageCageDetails == null && a10EdgStorageCageDetails == null) { - return queryLineNoTask(out08Glassstate, out10Glassstate); - } else { - if (b08) { - return queryLineHasTask(out08Glassstate); - } - if (b10) { - return queryLineHasTask(out10Glassstate); - } - return queryLineNoTask(out08Glassstate, out10Glassstate); + if (b10) { + return out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; } - } - - /** - * 鑾峰彇鏈変换鍔″悗鐨勫嚭鐗囬�昏緫 - */ - private Integer queryLineHasTask(int outGlassstate) { - return outGlassstate == 2 ? Const.A10_OUT_TARGET_POSITION : Const.A09_OUT_TARGET_POSITION; - } - - /** - * 鑾峰彇鏃犱换鍔″悗鐨勫嚭鐗囬�昏緫 - * - * @return - */ - private Integer queryLineNoTask(int out08Glassstate, int out10Glassstate) { - if (out08Glassstate == 2) { - return Const.A10_OUT_TARGET_POSITION; + if (b08) { + return out08Glassstate == 2 ? Const.A10_OUT_TARGET_POSITION : Const.A09_OUT_TARGET_POSITION; } - if (out10Glassstate == 2 || out08Glassstate == 1) { - return Const.A09_OUT_TARGET_POSITION; - } - return Const.A10_OUT_TARGET_POSITION; + return out10Glassstate == 2 ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION; } - /** * 鎸夌収灏哄鍑虹幓鐠� @@ -453,14 +447,18 @@ * @param glassId * @return */ - private EdgStorageCageDetails queryChangeGlassInfo(int endcell, String glassId) { + public EdgStorageCageDetails queryChangeGlassInfo(int endcell, String glassId) { //鑾峰彇绗煎瓙鍐呮暟閲忓墠浜岀殑鐜荤拑鏁伴噺 - MPJLambdaWrapper<EdgStorageCageDetails> wrapper = new MPJLambdaWrapper<>(); - wrapper.select(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight) - .selectCount(EdgStorageCageDetails::getGlassId, EdgStorageCageDetails::getCount) - .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN) - .groupBy(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight) - .last("order by count(t.glass_id) desc limit 2"); + MPJQueryWrapper<EdgStorageCageDetails> wrapper = new MPJQueryWrapper<>(); + wrapper.select("count(t.glass_id), t.width, t.height") + .eq("t.state", Const.GLASS_STATE_IN) + .groupBy("t.width, t.height"); + if (endcell == Const.A09_OUT_TARGET_POSITION) { + wrapper.innerJoin("(select glass_id, case when height <= width then width else height end as first_length, " + + "case when width < height then width else height end as second_length from edg_storage_cage_details) t1 " + + "on t.glass_id = t1.glass_id and t1.first_length <3500 and t1.second_length<2600 "); + } + wrapper.last("order by count(t.glass_id) desc limit 2"); List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(wrapper); if (CollectionUtil.isEmpty(list)) { return null; -- Gitblit v1.8.0