From 82154c2033851ba6c871467acedde11a4376c59c Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期五, 10 五月 2024 17:00:56 +0800
Subject: [PATCH] 卧式理片笼线程改造：整理出片逻辑
---
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/CacheGlassTask.java | 199 +++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 173 insertions(+), 26 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 19e77e5..fc0aa21 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
@@ -3,6 +3,9 @@
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.lang.Assert;
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.config.Const;
import com.mes.device.PlcParameterObject;
@@ -21,6 +24,7 @@
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
+import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -51,12 +55,13 @@
String taskRequestTypeValue = plcParameterObject.getPlcParameter("A06_request_word").getValue();
String glassIdeValue = plcParameterObject.getPlcParameter("A05_scanning_ID").getValue();
String confirmationWrodValue = plcParameterObject.getPlcParameter("MES_confirmation_word").getValue();
-// 1涓篈09绌洪棽锛�2涓篈10绌洪棽锛�3涓篈09A10閮界┖闂�,0涓篈09A10閮芥湁鐜荤拑
- String outGlassstate = plcParameterObject.getPlcParameter("A09_glass_status").getValue();
+ //A08 A09琛ㄧず绾胯矾鐩稿悓 鍙仛绛変环
+ 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();
- log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佷负锛歿},褰撳墠鏍煎瓙鍙蜂负锛歿}",
- taskRequestTypeValue, glassIdeValue, confirmationWrodValue, outGlassstate, currentSlot);
+ log.info("1銆佽幏鍙栧埌鐨勮姹傚瓧涓猴細{}锛岃幏鍙栧埌鐨勬壂鎻廔D涓猴細{}锛岃幏鍙栧埌鐨勭‘璁ゅ瓧涓猴細{}锛岃幏鍙栧埌鐨勫嚭鐗囩姸鎬佸垎鍒负锛欰09{}銆丄10{},褰撳墠鏍煎瓙鍙蜂负锛歿}",
+ taskRequestTypeValue, glassIdeValue, confirmationWrodValue, out08Glassstate, out10Glassstate, currentSlot);
if ("0".equals(taskRequestTypeValue)) {
if ("0".equals(confirmationWrodValue)) {
@@ -79,19 +84,22 @@
} else if ("2".equals(taskRequestTypeValue)) {
//09绌洪棽 锛�1 10绌洪棽 锛�2 閮界┖闂诧細3 鍏朵粬0
log.info("3銆佸嚭鐗囪姹傦紝涓旂‘璁ゅ瓧涓�0锛屾墽琛岃繘鐗囦换鍔�");
- outTo(Integer.parseInt(outGlassstate), confirmationWrodAddress, currentSlot);
+ outTo(Integer.parseInt(out08Glassstate), confirmationWrodAddress);
} else if ("3".equals(taskRequestTypeValue)) {
log.info("3銆佽繘鐗囧拰鍑虹墖閮界┖闂诧紝鎵ц鍑虹墖浠诲姟");
- if ("0".equals(outGlassstate)) {
+ //鍔犵瀛愰噷闈㈡槸鍚︽湁鐜荤拑锛屾湁鍏堝嚭锛屾棤鐜荤拑鍏堣繘
+ int count = edgStorageCageDetailsService.count(new LambdaQueryWrapper<EdgStorageCageDetails>().eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN));
+ if ("0".equals(out08Glassstate) || count > 0) {
inTo(glassIdeValue, confirmationWrodAddress, currentSlot);
} else {
- outTo(Integer.parseInt(outGlassstate), confirmationWrodAddress, currentSlot);
+ outTo(Integer.parseInt(out08Glassstate), confirmationWrodAddress);
}
}
}
/**
* 杩涚墖浠诲姟
+ *
* @param glassId
* @param confirmationWrodAddress
* @param currentSlot
@@ -137,31 +145,58 @@
/**
* 鍑虹墖浠诲姟
+ *
* @param line
* @param confirmationWrodAddress
- * @param currentSlot
*/
- private void outTo(int line, String confirmationWrodAddress, String currentSlot) {
+ private void outTo(int line, String confirmationWrodAddress) {
+ //閫昏緫姝ラ锛�
+// 0銆丄09銆丄10鏄惁绌洪棽锛屾槸鍚﹀彲浠ユ墽琛屽嚭鐗囦换鍔�
+// 1銆佽幏鍙栭挗鍖栫増鍥炬槸鍚﹁秴杩囬槇鍊�
+// 1.1銆佽秴杩囬槇鍊硷細鑾峰彇褰撳墠鏈�灏忕増鍥鹃渶瑕佸嚭鐗囩殑鐜荤拑淇℃伅
+// 1.1.1銆佽幏鍙栦袱鏉＄嚎鏈�鍚庝竴娆″嚭鐗囩殑浠诲姟淇℃伅
+// 1.1.2銆佹寜鐓у嚭鐗囦俊鎭幓璇︽儏琛ㄦ煡璇㈡牸瀛愬湪绗煎瓙閲岄潰鍓╀綑鐩稿悓灏哄鐨勭幓鐠冩暟鎹�
+// 1.1.3銆佸垽鏂摢鏉＄嚎鐜荤拑鏁伴噺鍦ㄧ悊鐗囩鍐呯殑鏁版嵁鏈�灏戯紝鍐冲畾鏈�灏忕増鍥捐蛋璇ユ潯绾匡紙闂锛氬鏋滆繖鏉＄嚎闈炵┖闂诧紝鐩存帴缁撴潫锛�
+// 1.2銆佹湭瓒呰繃闃堝�硷細
+// 1.2.1銆佽幏鍙栫▼搴忛偅鏉＄嚎绌洪棽
+// 1.2.2銆佽幏鍙栬鏉＄嚎鏈�鍚庝竴娆″嚭鐗囩殑浠诲姟淇℃伅
+// 1.2.3銆佹寜鐓у嚭鐗囦俊鎭幓璇︽儏琛ㄦ煡璇㈡牸瀛愬湪绗煎瓙閲岄潰鍓╀綑鐩稿悓灏哄鐨勭幓鐠冩暟鎹笖浠ョ増鍥緄d銆佺増搴忓崌搴忔帓搴� 鍙栫涓�鍧楃幓鐠冨嚭鐗�
+// 2銆佸鏋滄病鏈夊巻鍙插嚭鐗囦换鍔�
+// 2.1銆佸嚭褰撳墠鐗堝浘id鏈�灏忕増搴忔渶灏忕殑鐜荤拑锛堥棶棰橈細涓ゆ潯绾块兘娌℃湁鍘嗗彶浠诲姟锛屽嚭鐗囨椂涓ゆ潯绾跨殑鐜荤拑灏哄鐩稿悓锛屾槸鍚︽壘灏哄涓嶅悓鐨勶級
Assert.isTrue(line != 0, "A09銆丄10閮芥湁鐜荤拑锛屾棤娉曞嚭鐗�");
- log.info("1銆佸嚭鐗囦换鍔″嚭銆恵}銆戝彿绾�,澶囨敞(09绌洪棽锛�1;10绌洪棽锛�2;閮界┖闂诧細3)", line);
+ log.info("0銆佸嚭鐗囦换鍔″嚭銆恵}銆戝彿绾�,澶囨敞(09绌洪棽锛�1;10绌洪棽锛�2;閮界┖闂诧細3)", line);
+ //瀹氫箟鍑虹墖鐜荤拑淇℃伅
+ EdgStorageCageDetails glassInfo = null;
int endcell = 0;
-
- List<TaskCache> oldTaskCacheList;
- if (line == 2) {
- endcell = Const.A10_OUT_TARGET_POSITION;
- oldTaskCacheList = taskCacheService.selectLastOutCacheInfos(Const.A10_OUT_TARGET_POSITION);
+ boolean flag = queryMaxMinDiff(threshold);
+ log.info("1銆佽幏鍙栭挗鍖栫増鍥炬槸鍚﹁秴杩囬槇鍊�:{}", flag);
+ if (flag) {
+ glassInfo = queryMinGlass(0.0, 0.0);
+ log.info("1.1銆佽秴杩囬槇鍊硷細鑾峰彇褰撳墠鏈�灏忕増鍥鹃渶瑕佸嚭鐗囩殑鐜荤拑淇℃伅:{}", glassInfo);
+ Integer a09Count = queryCountByTaskLine(Const.A09_OUT_TARGET_POSITION).size();
+ Integer a10Count = queryCountByTaskLine(Const.A10_OUT_TARGET_POSITION).size();
+ log.info("1.2銆佽幏鍙栫瀛愬墿浣欐暟閲廇09涓簕},A10涓簕}", a09Count, a10Count);
+ if (a10Count <= a09Count && line != 2) {
+ log.info("1.2.1銆丄09绾垮嚭鐗�");
+ endcell = Const.A09_OUT_TARGET_POSITION;
+ } else {
+ log.info("1.2.2銆丄10绾垮嚭鐗�");
+ endcell = Const.A09_OUT_TARGET_POSITION;
+ }
} else {
- endcell = Const.A09_OUT_TARGET_POSITION;
- oldTaskCacheList = taskCacheService.selectLastOutCacheInfos(Const.A09_OUT_TARGET_POSITION);
- }
- log.info("2銆佸垽鏂嚭鐗囩嚎璺瘂}锛岃幏鍙栨渶鍚庤鏉＄嚎宸插嚭鐗囩殑浠诲姟淇℃伅{}(澶囨敞锛�0寰呮墽琛岋紝1宸叉墽琛�).閮界┖闂蹭紭鍏堝嚭A09绾�", endcell, oldTaskCacheList);
+ //鑾峰彇鎸囧畾绾胯矾灏嗚鍑虹殑鐜荤拑淇℃伅
+ endcell = line == 2 ? Const.A10_OUT_TARGET_POSITION : Const.A09_OUT_TARGET_POSITION;
+ //褰撳墠浠诲姟鍑哄畬鏃犵幓鐠� 鏇存崲鐜荤拑
+ int othercell = endcell == Const.A10_OUT_TARGET_POSITION ? Const.A09_OUT_TARGET_POSITION : Const.A10_OUT_TARGET_POSITION;
+ List<EdgStorageCageDetails> details = queryCountByTaskLine(endcell);
+ if (details.size() > 0) {
+ glassInfo = details.get(0);
+ } else {
+ //todo:鍘荤悊鐗囩閲岄潰鏌�
+ glassInfo = queryChangeGlassInfo(othercell);
+ }
- String glassId = "";
- if (CollectionUtil.isNotEmpty(oldTaskCacheList)) {
- glassId = oldTaskCacheList.get(0).getGlassId();
}
- EdgStorageCageDetails glassInfo = edgStorageCageDetailsService.selectOutGlass(glassId, threshold);
- log.info("3銆佹寜鐓у巻鍙插凡鍑虹幓鐠僫d{}鍜岄槇鍊納}锛屾嬁鍑虹悊鐗囩鍐呯殑鍑虹墖淇℃伅{}", glassId, threshold, glassInfo);
if (glassInfo != null) {
log.info("4銆佹坊鍔犲嚭鐗囦换鍔★紝鐜荤拑id锛歿}锛屼换鍔＄被鍨嬶細{}锛岃捣濮嬩綅缃細{}锛岀粨鏉熶綅缃細{}", glassInfo.getGlassId(),
@@ -176,9 +211,121 @@
taskCacheService.insertTaskCache(taskCache);
S7object.getinstance().plccontrol.WriteWord(confirmationWrodAddress, (short) 1);
}
-
-
}
+ /**
+ * 鑾峰彇璇︽儏琛ㄥ唴鏈�澶ф渶灏忕増鍥緄d鐨勫樊鍊硷紝鍒ゆ柇鏄惁鍑烘渶灏忕増鍥剧幓鐠�
+ *
+ * @return
+ */
+ private boolean queryMaxMinDiff(int threshold) {
+ //todo:鑾峰彇绗煎瓙鍐呮渶澶х増鍥緄d鍜屾渶灏忕増鍥緄d鎻掑�硷紝鍒ゆ柇鏄惁澶т簬闃堝�硷紝澶т簬闃堝�肩洿鎺ュ嚭鏈�灏忕増鍥剧幓鐠�
+ QueryWrapper<EdgStorageCageDetails> queryWrapper = new QueryWrapper<>();
+ queryWrapper.select("max(tempering_layout_id)-min(tempering_layout_id) as diff")
+ .eq("state", Const.GLASS_STATE_IN);
+ Integer diff = (Integer) edgStorageCageDetailsService.listObjs(queryWrapper).get(0);
+ return diff > threshold;
+ }
+ /**
+ * 鑾峰彇褰撳墠鏈�灏忕増鍥鹃渶瑕佸嚭鐗囩殑鐜荤拑淇℃伅
+ *
+ * @param width
+ * @param height
+ */
+ private EdgStorageCageDetails queryMinGlass(Double width, Double height) {
+ return edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
+ .eq(EdgStorageCageDetails::getState, 100)
+ .eq(width != 0, EdgStorageCageDetails::getWidth, width)
+ .eq(height != 0, EdgStorageCageDetails::getHeight, height)
+ .orderByAsc(EdgStorageCageDetails::getTemperingLayoutId, EdgStorageCageDetails::getTemperingFeedSequence)
+ .last("limit 1"));
+ }
+
+ /**
+ * 鑾峰彇浠诲姟琛ㄤ腑鎸囧畾绾胯矾绗煎瓙鍐呰繕鍓╀綑鐨勭幓鐠冩暟閲�
+ */
+ private List<EdgStorageCageDetails> queryCountByTaskLine(int line) {
+ //鑾峰彇浠诲姟琛ㄤ腑鏈�鍚庝竴娆″嚭鐗囩殑鐜荤拑id
+ LambdaQueryWrapper<TaskCache> queryWrapper = new LambdaQueryWrapper<TaskCache>().eq(TaskCache::getTaskType, Const.GLASS_CACHE_TYPE_OUT)
+ .eq(TaskCache::getEndCell, line).orderByDesc(TaskCache::getCreateTime);
+ List<TaskCache> taskCacheList = taskCacheService.list(queryWrapper);
+ if (CollectionUtil.isEmpty(taskCacheList)) {
+ return new ArrayList<>();
+ }
+ TaskCache taskCache = taskCacheList.get(0);
+ MPJQueryWrapper<EdgStorageCageDetails> mpjLambdaWrapper = new MPJQueryWrapper<>();
+ mpjLambdaWrapper.select("a.*")
+ .innerJoin("edg_storage_cage_details t1 on t.width = t1.width and t.height = t1.height")
+ .eq("t.glass_id", taskCache.getGlassId())
+ .ne("t1.glass_id", taskCache.getGlassId())
+ .orderByAsc("t1.tempering_layout_id", "t1.tempering_feed_sequence");
+ List<EdgStorageCageDetails> details = edgStorageCageDetailsService.selectJoinList(EdgStorageCageDetails.class, mpjLambdaWrapper);
+ if (CollectionUtil.isEmpty(details)) {
+ return new ArrayList<>();
+ }
+ return details;
+ }
+
+ /**
+ * 鏇存崲鍑虹墖鐜荤拑
+ *
+ * @param othercell
+ * @return
+ */
+ private EdgStorageCageDetails queryChangeGlassInfo(int othercell) {
+ //鑾峰彇绗煎瓙鍐呮暟閲忓墠浜岀殑鐜荤拑鏁伴噺
+ MPJLambdaWrapper<EdgStorageCageDetails> wrapper = new MPJLambdaWrapper<>();
+ wrapper.select(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight)
+ .selectCount("*", EdgStorageCageDetails::getCount)
+ .groupBy(EdgStorageCageDetails::getWidth, EdgStorageCageDetails::getHeight)
+ .last("order by count(*) desc limit 2");
+ List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(wrapper);
+ log.info("鑾峰彇绗煎瓙鍐呮暟閲忓墠浜岀殑鐜荤拑鏁伴噺锛歿}", list);
+ Assert.notEmpty(list, "绗煎瓙閲屾病鏈夌幓鐠�");
+ //涓�鐗囩幓鐠冪洿鎺ュ嚭
+ if (list.size() == 1) {
+ return list.get(0);
+ }
+ //鍒嗗埆鑾峰彇瀹介珮鐨勭幓鐠冩暟閲�
+ EdgStorageCageDetails firstSize = list.get(0);
+ EdgStorageCageDetails secondSize = list.get(1);
+ //鑾峰彇浠诲姟琛ㄤ腑鏈�鍚庝竴娆″嚭鐗囩殑鐜荤拑id
+ LambdaQueryWrapper<TaskCache> queryWrapper = new LambdaQueryWrapper<TaskCache>().eq(TaskCache::getTaskType, Const.GLASS_CACHE_TYPE_OUT)
+ .eq(TaskCache::getEndCell, othercell).orderByDesc(TaskCache::getCreateTime);
+ List<TaskCache> taskCacheList = taskCacheService.list(queryWrapper);
+ log.info("鑾峰彇浠诲姟琛ㄤ腑{}绾挎渶鍚庝竴娆″嚭鐗囩殑鐜荤拑浠诲姟淇℃伅锛歿}", othercell, taskCacheList);
+ if (CollectionUtil.isEmpty(taskCacheList)) {
+ log.info("{}绾挎病鏈夊嚭鐗囦换鍔′俊鎭紝鐩存帴鍑虹墖", othercell);
+ return queryMinGlass(firstSize.getWidth(), firstSize.getHeight());
+ }
+ Integer firstCount = firstSize.getCount();
+ Double firstWidth = firstSize.getWidth();
+ Double firstHeight = firstSize.getHeight();
+ Integer secondCount = secondSize.getCount();
+ Double secondWidth = secondSize.getWidth();
+ Double secondHeight = secondSize.getHeight();
+ //鑾峰彇鏁伴噺鍓�2鐨勭幓鐠冩暟閲忔瘮渚�
+ Integer mix = firstCount / secondCount;
+ log.info("鑾峰彇鐜荤拑鏁伴噺鍓�2鐨勭幓鐠冨崰姣斾负锛歿}", mix);
+
+ if (mix >= 2) {
+ log.info("鑾峰彇鐜荤拑鏁伴噺鍓�2鐨勭幓鐠冨崰姣斾负{}锛屽ぇ浜�2锛岀洿鎺ュ嚭鐜荤拑鏁版嵁鐨勬渶澶氱殑锛屽锛歿}锛岄珮锛歿}", mix, firstWidth, firstHeight);
+ return queryMinGlass(firstWidth, firstHeight);
+ } else {
+ log.info("鑾峰彇鐜荤拑鏁伴噺鍓�2鐨勭幓鐠冨崰姣斾负{}锛屽皬浜�2", mix);
+ TaskCache taskCache = taskCacheList.get(0);
+ EdgStorageCageDetails outGlassInfo = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>().eq(EdgStorageCageDetails::getGlassId, taskCache.getGlassId()));
+ log.info("{}绾挎湁鍑虹墖浠诲姟淇℃伅,浠诲姟淇℃伅涓簕}锛岀幓鐠冧俊鎭负{}", othercell, taskCache, outGlassInfo);
+ if (outGlassInfo.getWidth().equals(firstWidth) && outGlassInfo.getHeight().equals(firstHeight)) {
+ log.info("鏁伴噺鏈�澶氱殑瀹絳}楂榹}鍜寋}绾夸换鍔＄殑瀹絳}楂榹}鐩稿悓锛屽嚭鏁伴噺鎺掔浜岀殑鐜荤拑锛屽{}楂榹}",
+ firstWidth, firstHeight, othercell, outGlassInfo.getWidth(), outGlassInfo.getHeight(), secondWidth, secondHeight);
+ return queryMinGlass(secondWidth, secondHeight);
+ } else {
+ log.info("鏁伴噺绗簩澶氱殑瀹絳}楂榹}鍜寋}绾夸换鍔＄殑瀹絳}楂榹}鐩稿悓锛屽嚭鏁伴噺鎺掔浜岀殑鐜荤拑锛屽{}楂榹}",
+ secondWidth, secondHeight, othercell, outGlassInfo.getWidth(), outGlassInfo.getHeight(), firstWidth, firstHeight);
+ return queryMinGlass(firstWidth, firstHeight);
+ }
+ }
+ }
}
--
Gitblit v1.8.0