From 19f92e5de6ac9441838d1f2ec04d5ef150fe55d1 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期五, 10 十月 2025 08:17:37 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcCacheGlassNewTask.java | 351 ++++++++++++++++++++++++++++++++++++---------------------
1 files changed, 220 insertions(+), 131 deletions(-)
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcCacheGlassNewTask.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcCacheGlassNewTask.java
index ee90fdb..a49c7f9 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcCacheGlassNewTask.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcCacheGlassNewTask.java
@@ -5,9 +5,11 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.github.xingshuangs.iot.protocol.s7.serializer.S7Serializer;
import com.kangaroohy.milo.model.ReadWriteEntity;
import com.kangaroohy.milo.service.MiloService;
import com.mes.common.config.Const;
+import com.mes.common.config.ConstSysConfig;
import com.mes.damage.service.DamageService;
import com.mes.edgglasstask.entity.EdgGlassTaskInfo;
import com.mes.edgglasstask.service.EdgGlassTaskInfoService;
@@ -17,20 +19,22 @@
import com.mes.edgstoragecage.service.EdgStorageCageService;
import com.mes.glassinfo.entity.GlassInfo;
import com.mes.glassinfo.service.GlassInfoService;
-import com.mes.opctask.entity.EdgStorageDeviceTask;
import com.mes.opctask.entity.EdgStorageDeviceTaskHistory;
import com.mes.opctask.service.EdgStorageDeviceTaskHistoryService;
import com.mes.opctask.service.EdgStorageDeviceTaskService;
+import com.mes.s7.entity.S7DataMB;
+import com.mes.s7.entity.S7DataWL;
+import com.mes.s7.entity.S7DataWLExtra;
+import com.mes.sysconfig.service.SysConfigService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
+import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
-import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -64,35 +68,44 @@
EdgStorageDeviceTaskHistoryService edgStorageDeviceTaskHistoryService;
@Resource
DamageService damageService;
+ @Resource
+ SysConfigService sysConfigService;
- @Value("${mes.glassGap}")
- private int glassGap;
- @Value("${mes.threshold}")
+ @Autowired
+ @Qualifier("s7SerializerWLOne")
+ private S7Serializer s7SerializerWLOne;
+
+ @Autowired
+ @Qualifier("s7SerializerWLTwo")
+ private S7Serializer s7SerializerWLTwo;
+
+ @Autowired
+ @Qualifier("s7SerializerMBOne")
+ private S7Serializer s7SerializerMBOne;
+
+ @Autowired
+ @Qualifier("s7SerializerMBTwo")
+ private S7Serializer s7SerializerMBTwo;
+
+
private int threshold;
- @Value("${mes.cellLength}")
+
private int cellLength;
- @Value("${mes.ratio}")
+
private int ratio;
- @Value("${mes.min.one.firstLength}")
private int minOneFirstLength;
- @Value("${mes.min.one.secondLength}")
private int minOneSecondLength;
- @Value("${mes.min.two.firstLength}")
private int minTwoFirstLength;
- @Value("${mes.min.two.secondLength}")
private int minTwoSecondLength;
- @Value("${mes.max.firstLength}")
private int maxTwoFirstLength;
- @Value("${mes.max.secondLength}")
private int maxTwoSecondLength;
- @Value("${mes.maxThickness}")
private int maxThickness;
private String glassInIdOne = "";
@@ -102,29 +115,49 @@
@Scheduled(fixedDelay = 1000)
public void startOneOpcTask() throws Exception {
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ S7DataWLExtra s7DataWLExtraTwo = s7SerializerWLTwo.read(S7DataWLExtra.class);
+ log.info("涓�绾垮崸鐞�: {}", s7DataWLOne);
//鑾峰彇绗簩鏉＄嚎璺殑鍗у紡鐞嗙墖绗肩姸鎬�
- ReadWriteEntity twoInkageEntity = miloService.readFromOpcUa("WL2.WL2.deviceState");
+ Boolean twoInkageEntity = s7DataWLTwo.getDeviceState();
//榛樿鍙窇涓�鍙板崸寮忕悊鐗�,涓ゆ潯绾胯矾閮藉彲浠ヨ蛋
int cellFlag = 1;
//濡傛灉涓ゆ潯绾块兘鍚姩鍒欏彧鑳借窇涓�鏉＄嚎
- if (twoInkageEntity != null && !Boolean.parseBoolean(twoInkageEntity.getValue() + "")) {
+ if (!twoInkageEntity && !Const.OUT_DISABLE.equals(s7DataWLExtraTwo.getD06SlotState())) {
cellFlag = 2;
}
- startOneOpcTaskChild(EDG_STORAGE_DEVICE_ONE_TASK, 1, cellFlag);
+ startOneOpcTaskChild(s7DataWLOne, 1, cellFlag);
}
@Scheduled(fixedDelay = 1000)
public void startTwoOpcTask() throws Exception {
- ReadWriteEntity oneInkageEntity = miloService.readFromOpcUa("WL1.WL1.deviceState");
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ S7DataWLExtra s7DataWLExtraTwo = s7SerializerWLTwo.read(S7DataWLExtra.class);
+ log.info("浜岀嚎鍗х悊: {}", s7DataWLTwo);
+ Boolean oneInkageEntity = s7DataWLOne.getDeviceState();
int cellFlag = 1;
- if (oneInkageEntity != null && !Boolean.parseBoolean(oneInkageEntity.getValue() + "")) {
+ if (!oneInkageEntity && !Const.OUT_DISABLE.equals(s7DataWLExtraTwo.getD06SlotState())) {
cellFlag = 2;
}
- startOneOpcTaskChild(EDG_STORAGE_DEVICE_TWO_TASK, 2, cellFlag);
+ startOneOpcTaskChild(s7DataWLTwo, 2, cellFlag);
+
}
- private void startOneOpcTaskChild(String tableName, int device, int cellFlag) throws Exception {
- EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(tableName);
+ private void startOneOpcTaskChild(S7DataWL task, int device, int cellFlag) throws Exception {
+ threshold = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_THRESHOLD);
+ cellLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_CELL_LENGTH);
+ ratio = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_RATIO);
+ minOneFirstLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MIN_ONE_FIRST_LENGTH);
+ minOneSecondLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MIN_ONE_SECOND_LENGTH);
+ minTwoFirstLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MIN_TWO_FIRST_LENGTH);
+ minTwoSecondLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MIN_TWO_SECOND_LENGTH);
+ maxTwoFirstLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MAX_FIRST_LENGTH);
+ maxTwoSecondLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MAX_SECOND_LENGTH);
+ maxThickness = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MAX_THICKNESS);
+
+
if (task == null) {
log.info("浠诲姟琛ㄥ熀纭�鏁版嵁褰曞叆澶辫触锛岃妫�鏌ユ暟鎹槸鍚﹀綍鍏ユ垚鍔�");
return;
@@ -143,44 +176,43 @@
//杩涚墖浠诲姟
log.info("璁惧锛歿}鐘舵�侊細{}", device, request);
log.info("杩涚墖浠诲姟锛氳繘鐗囩幓鐠僫d涓猴細{}", task.getGlassIdIn());
- intoTask(task, tableName, device);
+ intoTask(task, device);
} else if (request == 2 && taskRunning == 0) {
//鍑虹墖浠诲姟
- outTask(task, tableName, device, cellFlag);
+ outTask(task, device, cellFlag);
} else if (request == 3 && taskRunning == 0) {
//鐩撮�氫换鍔�
log.info("璁惧锛歿}鐘舵�侊細{}", device, request);
- if (!outTask(task, tableName, device, cellFlag)) {
- intoTask(task, tableName, device);
+ if (!outTask(task, device, cellFlag)) {
+ intoTask(task, device);
}
} else if (request == 4) {
log.info("璁惧锛歿}鐘舵�侊細{}", device, request);
log.info("灏嗗惎鍔ㄥ瓙鏀逛负4");
- task.setTaskRunning(Const.GLASS_CACHE_TYPE_RUNNING);
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ if (device == 2) {
+ task.setTaskRunning(Const.GLASS_CACHE_TYPE_RUNNING);
+ s7SerializerWLTwo.write(S7DataWL.builder().taskRunning(Const.GLASS_CACHE_TYPE_RUNNING).build());
+ } else {
+ task.setTaskRunning(Const.GLASS_CACHE_TYPE_RUNNING);
+ s7SerializerWLOne.write(S7DataWL.builder().taskRunning(Const.GLASS_CACHE_TYPE_RUNNING).build());
+ }
+
} else if (request == 5) {
log.info("璁惧锛歿}鐘舵�侊細{}", device, request);
- finishTask(task, tableName, device);
+ finishTask(task, "", device);
} else {
log.info("鐜荤拑寮傚父澶勭悊");
- damageTask(task, tableName, device);
+ damageTask(task, "", device);
}
-// } catch(Exception e)
-//
-// {
-// log.info("鎵ц浠诲姟杩囩▼涓彂鐢熷紓甯革紝浠诲姟瀛梴}锛寋}", task.getTaskState(), e.getMessage());
-// log.info("灏嗗惎鍔ㄥ瓧鏀逛负0");
-// task.setTaskRunning(Const.GLASS_CACHE_TYPE_EMPTY);
-// edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
-// }
}
@Scheduled(fixedDelay = 1000)
public void edgOneOpcTask() throws Exception {
- EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(EDG_STORAGE_DEVICE_ONE_TASK);
- String glassId = task.getGlassId();
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ String glassId = s7DataWLOne.getGlassId();
+ log.info("1鍙风嚎鐜荤拑id{},鍘嗗彶id{}", glassId, glassIdOne);
if (StringUtils.isBlank(glassId) || glassId.equals(glassIdOne)) {
log.info("{}鍙风嚎纾ㄨ竟鍓嶇幓鐠冩湭灏变綅锛岀粨鏉熸湰娆′换鍔�", 1);
return;
@@ -189,9 +221,10 @@
}
@Scheduled(fixedDelay = 1000)
- public void edgTwoOpcTask() throws Exception {
- EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(EDG_STORAGE_DEVICE_TWO_TASK);
- String glassId = task.getGlassId();
+ public void edgTwoOpcTask() {
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ String glassId = s7DataWLTwo.getGlassId();
+ log.info("2鍙风嚎鐜荤拑id{},鍘嗗彶id{}", glassId, glassIdTwo);
if (StringUtils.isBlank(glassId) || glassId.equals(glassIdTwo)) {
log.info("{}鍙风嚎纾ㄨ竟鍓嶇幓鐠冩湭灏变綅锛岀粨鏉熸湰娆′换鍔�", 2);
return;
@@ -199,22 +232,33 @@
edgTaskChild(glassId, 2);
}
- private void edgTaskChild(String glassId, int cell) throws Exception {
+ private void edgTaskChild(String glassId, int cell) {
+ ratio = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_RATIO);
GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId).last("limit 1"));
if (glassInfo == null) {
log.info("瀵瑰垪琛ㄤ腑鐨勭幓鐠僫d閿欒锛岃妫�鏌ユ暟鎹紝鐜荤拑id锛歿}", glassId);
return;
}
String toEndingId = glassInfo.getTemperingLayoutId() + "" + glassInfo.getTemperingFeedSequence();
- List<ReadWriteEntity> list = new ArrayList<>();
-// list.add(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".mesControl", true));
- list.add(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".glassId", Integer.parseInt(toEndingId)));
- list.add(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".toEdingId", Integer.parseInt(toEndingId)));
- list.add(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".width", (int) Math.max(glassInfo.getWidth() * 10, glassInfo.getHeight() * 10)));
- list.add(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".height", (int) Math.min(glassInfo.getWidth() * 10, glassInfo.getHeight() * 10)));
-
- miloService.writeToOpcUa(list);
- miloService.writeToOpcWord(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".thickness", (int) glassInfo.getThickness() * 10));
+ S7DataMB s7DataMB = new S7DataMB();
+ s7DataMB.setToEdingId(Integer.parseInt(toEndingId));
+ s7DataMB.setGlassId(Integer.parseInt(toEndingId));
+ s7DataMB.setWidth((int) Math.max(glassInfo.getWidth() * ratio, glassInfo.getHeight() * ratio));
+ s7DataMB.setHeight((int) Math.min(glassInfo.getWidth() * ratio, glassInfo.getHeight() * ratio));
+ log.info("鐜荤拑id:{},{}绾垮悜PLC鍙戦�佸楂樻暟鎹畕}", glassId, cell, s7DataMB);
+ if (cell == 1) {
+ s7SerializerMBOne.write(s7DataMB);
+ } else {
+ s7SerializerMBTwo.write(s7DataMB);
+ }
+ s7DataMB = new S7DataMB();
+ s7DataMB.setThickness((int) (glassInfo.getThickness() * ratio));
+ log.info("{}绾垮悜PLC鍙戦�佸帤搴︽暟鎹畕}", cell, s7DataMB);
+ if (cell == 1) {
+ s7SerializerMBOne.write(s7DataMB);
+ } else {
+ s7SerializerMBTwo.write(s7DataMB);
+ }
//淇敼纾ㄨ竟瀵瑰垪涓殑纾ㄨ竟绾胯矾鍙婄姸鎬�
edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>()
.set(EdgGlassTaskInfo::getLine, cell)
@@ -229,9 +273,9 @@
}
}
- private boolean intoTask(EdgStorageDeviceTask task, String tableName, int deviceId) {
+ private boolean intoTask(S7DataWL task, int deviceId) {
Date startDate = new Date();
- log.info("寮�濮嬫墽琛岃繘鐗囦换鍔★紝浠诲姟淇℃伅涓猴細{},琛ㄥ悕涓猴細{},璁惧id:{},寮�濮嬫椂闂达細{}", task, tableName, deviceId, startDate);
+ log.info("寮�濮嬫墽琛岃繘鐗囦换鍔★紝浠诲姟淇℃伅涓猴細{},璁惧id:{},寮�濮嬫椂闂达細{}", task, deviceId, startDate);
//鑾峰彇鐜荤拑鐨勫熀鏈俊鎭�
GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, task.getGlassIdIn()));
if (null == glassInfo) {
@@ -248,17 +292,20 @@
}
int firstLength = minTwoFirstLength;
int secondLength = minTwoSecondLength;
+ int fecondMaxLength = 2300;
if (deviceId == 1) {
firstLength = minOneFirstLength;
secondLength = minOneSecondLength;
+ fecondMaxLength = 2500;
}
- if (Math.max(glassInfo.getWidth(), glassInfo.getHeight()) < firstLength || Math.min(glassInfo.getWidth(), glassInfo.getHeight()) < secondLength) {
+ if (Math.max(glassInfo.getWidth(), glassInfo.getHeight()) < firstLength || Math.min(glassInfo.getWidth(), glassInfo.getHeight()) < secondLength
+ || Math.max(glassInfo.getWidth(), glassInfo.getHeight()) > fecondMaxLength) {
log.info("杩涚墖鐜荤拑灏哄灏忎簬{}*{}锛岀姝㈣繘绗肩幓鐠僫d:{}锛屽昂瀵镐负{}銆亄}", firstLength, secondLength, task.getGlassIdIn(), glassInfo.getWidth(), glassInfo.getHeight());
Date endDate = new Date();
log.info("缁撴潫杩涚墖浠诲姟璁惧涓簕}锛岀粨鏉熸椂闂翠负锛歿}锛屽叡鑰楁椂锛歿}ms", deviceId, endDate, endDate.getTime() - startDate.getTime());
return Boolean.FALSE;
}
- EdgStorageCage edgStorageCage = edgStorageCageService.selectNearestEmpty(task.getCurrentCell(), deviceId, Boolean.FALSE);
+ EdgStorageCage edgStorageCage = edgStorageCageService.selectNearestEmpty(Integer.parseInt(task.getCurrentCell().toString()), deviceId, Boolean.FALSE);
Assert.isTrue(null != edgStorageCage, "鏍煎瓙宸叉弧");
log.info("4銆佸皢鐜荤拑淇℃伅鎻掑叆鍗у紡鐞嗙墖绗�,褰撳墠鐜荤拑淇℃伅:{}", glassInfo);
EdgStorageCageDetails details = new EdgStorageCageDetails();
@@ -271,7 +318,17 @@
//鏇存柊浠诲姟淇℃伅
task.setStartCell(edgStorageCage.getSlot());
task.setTaskRunning(Const.GLASS_CACHE_TYPE_IN);
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ if (deviceId == 1) {
+ s7SerializerWLOne.write(
+ S7DataWL.builder().startCell(edgStorageCage.getSlot())
+ .taskRunning(Const.GLASS_CACHE_TYPE_IN).build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder().startCell(edgStorageCage.getSlot())
+ .taskRunning(Const.GLASS_CACHE_TYPE_IN).build()
+ );
+ }
saveHistoryTask(task, deviceId);
//璁板綍杩涚墖浠诲姟鐨勭幓鐠僫d鐢ㄤ簬涓嬫浠诲姟鐨勬瘮杈冿紝闃叉鍚屼竴鍧楃幓鐠冮噸澶嶆墽琛�
if (deviceId == 1) {
@@ -284,27 +341,35 @@
return Boolean.TRUE;
}
- private boolean outTask(EdgStorageDeviceTask task, String tableName, int deviceId, int cellFlag) throws Exception {
+ private boolean outTask(S7DataWL task, int deviceId, int cellFlag) {
Date startDate = new Date();
//鑾峰彇瀵瑰簲鐨勮澶囩姸鎬佷俊鎭�
- ReadWriteEntity oneOutStateEntity = miloService.readFromOpcUa("WL1.WL1.slotState");
- ReadWriteEntity twoOutStateEntity = miloService.readFromOpcUa("WL2.WL2.slotState");
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ S7DataWLExtra s7DataWLExtraTwo = s7SerializerWLTwo.read(S7DataWLExtra.class);
+ Integer oneOutState = s7DataWLOne.getSlotState();
+ Integer twoOutState = s7DataWLTwo.getSlotState();
+ Integer d06OutState = s7DataWLExtraTwo.getD06SlotState();
//鐘舵�佹湁3涓儏鍐碉細0绌洪棽 1蹇欑 2绂佺敤
- String oneOutState = "2";
- String twoOutState = "2";
- if (null != oneOutStateEntity && null != oneOutStateEntity.getValue()) {
- oneOutState = oneOutStateEntity.getValue().toString();
- }
- if (null != twoOutStateEntity && null != twoOutStateEntity.getValue()) {
- twoOutState = twoOutStateEntity.getValue().toString();
- }
-
- if ((cellFlag == 2 && Const.OUT_BUSY.equals(oneOutState) && Const.OUT_BUSY.equals(twoOutState)) || (Const.OUT_DISABLE.equals(oneOutState) && Const.OUT_DISABLE.equals(twoOutState))) {
- log.info("A09銆丄10涓簕},{}闈炶嚜鍔ㄧ姸鎬侊紝鏃犳硶鍑虹墖", oneOutState, oneOutState);
+ //涓ゆ潯绾块兘涓虹鐢ㄥ垯涓嶅嚭鐜荤拑
+ if (Const.OUT_DISABLE.equals(oneOutState) && Const.OUT_DISABLE.equals(twoOutState)) {
+ log.info("璁惧{}:A09銆丄10涓簕},{}闈炶嚜鍔ㄧ姸鎬侊紝鏃犳硶鍑虹墖", deviceId, oneOutState, oneOutState);
return Boolean.FALSE;
}
- log.info("寮�濮嬫墽琛屽嚭鐗�/鐩撮�氫换鍔★紝浠诲姟淇℃伅涓猴細{},琛ㄥ悕涓猴細{},璁惧id:{},寮�濮嬫椂闂达細{},涓�鍙风嚎鐘舵�侊細{}锛屼簩鍙风嚎鐘舵�侊細{}",
- task, tableName, deviceId, startDate, oneOutState, twoOutState);
+ //鑾峰彇d06鐗囧彴鐘舵��
+ // 1:涓�瀵逛竴鐨勬儏鍐典笅涓嶉渶瑕佸垽鏂璬06鐘舵��
+ // 2:涓�鍙风嚎涓�瀵瑰鐨勬儏鍐典笅锛岃幏鍙栦簩鍙风嚎纾ㄨ竟鍓嶇墖鍙癉07鐨勭姸鎬侊紝D07闈炵鐢ㄦ椂锛屼簩鍙风嚎灏嗘寜鐓06鐗囧彴鐘舵�佽寰楀嚭鐗�
+ // 3:浜屽彿绾夸竴瀵瑰鐨勬儏鍐典笅锛岃幏鍙栦竴鍙风嚎纾ㄨ竟鍓嶇墖鍙癈08鐨勭姸鎬侊紝C08闈炵鐢ㄦ椂锛屼竴鍙风嚎灏嗘寜鐓06鐗囧彴鐘舵�佽寰楀嚭鐗�
+ if (cellFlag == 2) {
+ if (deviceId == 1) {
+ twoOutState = twoOutState & d06OutState;
+ } else {
+ oneOutState = oneOutState & d06OutState;
+ }
+ }
+
+ log.info("寮�濮嬫墽琛屽嚭鐗�/鐩撮�氫换鍔★紝浠诲姟淇℃伅涓猴細{},璁惧id:{},寮�濮嬫椂闂达細{},涓�鍙风嚎鐘舵�侊細{}锛屼簩鍙风嚎鐘舵�侊細{}",
+ task, deviceId, startDate, oneOutState, twoOutState);
//鑾峰彇褰撳墠闇�瑕佽蛋閭ｆ潯绾�
int cell = 0;
if (cellFlag == 1) {
@@ -315,29 +380,27 @@
} else if (Const.OUT_FREE.equals(oneOutState)) {
cell = Const.ONE_OUT_TARGET_POSITION;
} else {
- return Boolean.FALSE;
+ cell = Const.TWO_OUT_TARGET_POSITION;
}
}
- if (Const.OUT_FREE.equals(oneOutState) && Const.OUT_FREE.equals(twoOutState)) {
- if (cellFlag == 2) {
- if (!outChildTask(task, tableName, deviceId, cell, startDate)) {
- cell = cell == Const.ONE_OUT_TARGET_POSITION ? Const.TWO_OUT_TARGET_POSITION : Const.ONE_OUT_TARGET_POSITION;
- return outChildTask(task, tableName, deviceId, cell, startDate);
- }
- } else {
- return outChildTask(task, tableName, deviceId, cell, startDate);
+ log.info("{}绾胯矾璁＄畻瀹屾垚锛歿}", deviceId, cell);
+ if (cellFlag == 2) {
+ if (!outChildTask(task, deviceId, cell, startDate)) {
+ cell = cell == Const.ONE_OUT_TARGET_POSITION ? Const.TWO_OUT_TARGET_POSITION : Const.ONE_OUT_TARGET_POSITION;
+ return outChildTask(task, deviceId, cell, startDate);
}
} else {
- return outChildTask(task, tableName, deviceId, cell, startDate);
+ return outChildTask(task, deviceId, cell, startDate);
}
return Boolean.TRUE;
}
- private boolean outChildTask(EdgStorageDeviceTask task, String tableName, int deviceId, int cell, Date startDate) {
+ private boolean outChildTask(S7DataWL task, int deviceId, int cell, Date startDate) {
EdgStorageCageDetails edgStorageCageDetails = null;
//绗煎唴鏄増鍥剧浉宸槸鍚﹁秴杩囬槇鍊�
boolean flag = queryMaxMinDiffByDevice(threshold, deviceId);
+ log.info("{}闃堝�艰绠楀畬鎴愶細{}", deviceId, flag);
if (flag) {
//鍏堟壘鏈�灏忕増鍥剧増搴忕殑鐜荤拑灏忕墖
EdgStorageCageDetails minEdgDetails = edgStorageCageDetailsService.getOne(new LambdaQueryWrapper<EdgStorageCageDetails>()
@@ -361,15 +424,18 @@
);
}
}
+ log.info("{}鎸夌収闃堝�兼煡鎵剧粨鏋滐細{}", deviceId, edgStorageCageDetails);
if (null == edgStorageCageDetails) {
// 鑾峰彇鍘嗗彶琛ㄤ腑涓婃浠诲姟鏈�鍚庝竴鐗囧昂瀵�
EdgStorageDeviceTaskHistory edgeData = edgStorageDeviceTaskHistoryService.getOne(new LambdaQueryWrapper<EdgStorageDeviceTaskHistory>()
.eq(EdgStorageDeviceTaskHistory::getDeviceId, cell)
.in(EdgStorageDeviceTaskHistory::getTaskType, Const.GLASS_CACHE_TYPE_OUT, Const.GLASS_CACHE_TYPE_THROUGH)
.orderByDesc(EdgStorageDeviceTaskHistory::getId).last("limit 1"));
+ log.info("{}鑾峰彇涓婃浠诲姟淇℃伅锛歿}", deviceId, edgeData);
if (null != edgeData) {
GlassInfo glassOutInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, edgeData.getGlassIdOut()));
//绗煎唴鐨勭幓鐠冪殑灏哄鏄惁鍜屼笂涓�娆′换鍔′竴鑷�
+
edgStorageCageDetails = edgStorageCageDetailsService.queryEdgStorageDetailsBySize(deviceId, task.getCurrentCell(), glassOutInfo.getWidth(), glassOutInfo.getHeight(), cell, maxThickness);
if (null == edgStorageCageDetails && StringUtils.isNotBlank(task.getGlassIdIn())) {
GlassInfo glassInInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>()
@@ -385,11 +451,13 @@
}
}
}
+ log.info("{}鑾峰彇鍘嗗彶琛ㄤ腑涓婃浠诲姟鏈�鍚庝竴鐗囧昂瀵革細{}", deviceId, edgStorageCageDetails);
//鍓嶉潰宸茬粡灏哄闂澶勭悊瀹屾瘯锛屽紑濮嬭绠楁棤鐩稿悓灏哄鐨勬柊鐜荤拑灏忕墖
if (null == edgStorageCageDetails) {
- edgStorageCageDetails = edgStorageCageDetailsService.queryEdgStorageDetailsByLimitSize(deviceId, task.getCurrentCell(), 0, 0,
+ edgStorageCageDetails = edgStorageCageDetailsService.queryEdgStorageDetailsByLimitSize(deviceId, Integer.parseInt(task.getCurrentCell().toString()), 0, 0,
cell, minOneFirstLength, minOneSecondLength, maxTwoFirstLength, maxTwoSecondLength, maxThickness);
}
+ log.info("{}寮�濮嬭绠楁棤鐩稿悓灏哄鐨勬柊鐜荤拑灏忕墖锛歿}", deviceId, edgStorageCageDetails);
if (edgStorageCageDetails == null && StringUtils.isNotBlank(task.getGlassIdIn())) {
//鍜屼笂娆′换鍔′笉瀛樺湪鐩稿悓灏哄
GlassInfo glassInInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, task.getGlassIdIn()));
@@ -406,6 +474,7 @@
log.info("鐩撮�氫换鍔＄洰鏍囩嚎璺负{},杩涚墖鐜荤拑灏哄涓簕}*{},涓嶇鍚堝嚭鐗囨潯浠�", cell, maxLength, minLength);
}
}
+ log.info("{}鐩撮�氫换鍔★細{}", deviceId, edgStorageCageDetails);
if (edgStorageCageDetails == null) {
//鍜屼笂娆′换鍔′笉瀛樺湪鐩稿悓灏哄
log.info("绗煎唴娌℃湁鐜荤拑浜�");
@@ -417,7 +486,7 @@
if (3 != task.getTaskState()) {
return Boolean.FALSE;
}
- log.info("5銆佺洿閫氫换鍔�,灏嗙幓鐠冧俊鎭彃鍏ュ崸寮忕悊鐗囩,褰撳墠鐜荤拑淇℃伅:{}", edgStorageCageDetails);
+ log.info("5銆亄}鐩撮�氫换鍔�,灏嗙幓鐠冧俊鎭彃鍏ュ崸寮忕悊鐗囩,褰撳墠鐜荤拑淇℃伅:{}", edgStorageCageDetails);
if (glassInIdOne.equals(task.getGlassIdIn()) || glassInIdTwo.equals(task.getGlassIdIn())) {
log.info("鐜荤拑id涓庝笂娆＄浉鍚岋紝绂佹杩涚墖");
return Boolean.FALSE;
@@ -431,11 +500,7 @@
GlassInfo one = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId));
BeanUtils.copyProperties(one, edgStorageCageDetails);
}
- EdgStorageCage storageCage = edgStorageCageService.getOne(new LambdaQueryWrapper<EdgStorageCage>()
- .eq(EdgStorageCage::getDeviceId, deviceId)
- .eq(EdgStorageCage::getEnableState, Const.SLOT_ON)
- .ge(EdgStorageCage::getRemainWidth, cellLength)
- .last("order by abs(slot - " + task.getCurrentCell() + ") limit 1"));
+ EdgStorageCage storageCage = edgStorageCageService.selectNearestEmpty(Integer.parseInt(task.getCurrentCell().toString()), deviceId, Boolean.TRUE);
Assert.isTrue(null != storageCage, "鏍煎瓙宸叉弧,鏃犳硶鎵ц鐩撮�氫换鍔�");
log.info("3銆佹煡璇㈠崸寮忕悊鐗囩閲岄潰鐨勭┖鏍�:{}", storageCage);
edgStorageCageDetails.setSlot(storageCage.getSlot());
@@ -471,8 +536,25 @@
task.setStartCell(edgStorageCageDetails.getSlot());
task.setTaskRunning(taskType);
task.setEndCell(cell);
-
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ if (deviceId == 1) {
+ s7SerializerWLOne.write(
+ S7DataWL.builder()
+ .glassIdOut(edgStorageCageDetails.getGlassId())
+ .startCell(edgStorageCageDetails.getSlot())
+ .taskRunning(taskType)
+ .endCell(cell)
+ .build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder()
+ .glassIdOut(edgStorageCageDetails.getGlassId())
+ .startCell(edgStorageCageDetails.getSlot())
+ .taskRunning(taskType)
+ .endCell(cell)
+ .build()
+ );
+ }
saveHistoryTask(task, deviceId);
//璁板綍鐩撮�氫换鍔＄殑鐜荤拑id鐢ㄤ簬涓嬫浠诲姟鐨勬瘮杈冿紝闃叉鍚屼竴鍧楃幓鐠冮噸澶嶆墽琛�
if (3 == task.getTaskState()) {
@@ -493,17 +575,13 @@
return Boolean.TRUE;
}
- private boolean finishTask(EdgStorageDeviceTask task, String tableName, int device) {
+ private boolean finishTask(S7DataWL task, String tableName, int device) {
if (task.getTaskState() <= 4) {
log.info("鏈夋鍦ㄦ墽琛岀殑浠诲姟鎴栬繖浠诲姟宸叉墽琛屼换鍔＄姸鎬亄}锛屼换鍔″惎鍔ㄦ儏鍐祘}锛岀粨鏉�", task.getTaskState(), task.getTaskRunning());
return Boolean.FALSE;
}
Date startDate = new Date();
log.info("寮�濮嬫墽琛屽畬鎴愪换鍔″悗娓呴櫎鍔ㄤ綔锛屼换鍔′俊鎭负锛歿},琛ㄥ悕涓猴細{},寮�濮嬫椂闂达細{}", task, tableName, startDate);
- task.setTaskRunning(Const.GLASS_CACHE_TYPE_EMPTY);
- task.setGlassIdOut("");
- task.setStartCell(0);
- task.setEndCell(0);
EdgStorageDeviceTaskHistory taskHistory = edgStorageDeviceTaskHistoryService.getOne(new LambdaQueryWrapper<EdgStorageDeviceTaskHistory>()
.eq(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_NEW)
.eq(EdgStorageDeviceTaskHistory::getDeviceId, device)
@@ -521,13 +599,31 @@
);
}
//鏈�鍚庢洿鏂颁换鍔★紝淇濊瘉浠诲姟鍓嶇殑鍔ㄤ綔閮藉仛瀹�
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ if (device == 1) {
+ s7SerializerWLOne.write(
+ S7DataWL.builder()
+ .taskRunning(Const.GLASS_CACHE_TYPE_EMPTY)
+ .glassIdOut("")
+ .startCell(0)
+ .endCell(0)
+ .build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder()
+ .taskRunning(Const.GLASS_CACHE_TYPE_EMPTY)
+ .glassIdOut("")
+ .startCell(0)
+ .endCell(0)
+ .build()
+ );
+ }
Date endDate = new Date();
log.info("缁撴潫瀹屾垚浠诲姟鍚庢竻闄ゅ姩浣滐紝琛ㄥ悕涓猴細{},缁撴潫鏃堕棿涓猴細{}锛屽叡鑰楁椂锛歿}ms", tableName, endDate, endDate.getTime() - startDate.getTime());
return Boolean.TRUE;
}
- private boolean damageTask(EdgStorageDeviceTask task, String tableName, int device) {
+ private boolean damageTask(S7DataWL task, String tableName, int device) {
if (task.getTaskState() <= 5) {
log.info("浠诲姟鏈彂鐢熷紓甯告竻绌猴紝浠诲姟缁撴潫锛岀數姘旂姸鎬亄},mes鐘舵�亄}", task.getTaskState(), task.getTaskRunning());
return Boolean.FALSE;
@@ -562,12 +658,25 @@
.set(EdgStorageDeviceTaskHistory::getTaskState, Const.RAW_GLASS_TASK_FAILURE)
);
}
- //鏈�鍚庢洿鏂颁换鍔★紝淇濊瘉浠诲姟鍓嶇殑鍔ㄤ綔閮藉仛瀹�
- task.setTaskRunning(Const.GLASS_CACHE_TYPE_EMPTY);
- task.setGlassIdOut("");
- task.setStartCell(0);
- task.setEndCell(0);
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ if (device == 1) {
+ s7SerializerWLOne.write(
+ S7DataWL.builder()
+ .taskRunning(Const.GLASS_CACHE_TYPE_EMPTY)
+ .glassIdOut("")
+ .startCell(0)
+ .endCell(0)
+ .build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder()
+ .taskRunning(Const.GLASS_CACHE_TYPE_EMPTY)
+ .glassIdOut("")
+ .startCell(0)
+ .endCell(0)
+ .build()
+ );
+ }
Date endDate = new Date();
log.info("瀹屾垚鎵ц寮傚父澶勭悊浠诲姟鍚庢竻闄ゅ姩浣滐紝琛ㄥ悕涓猴細{},缁撴潫鏃堕棿涓猴細{}锛屽叡鑰楁椂锛歿}ms", tableName, endDate, endDate.getTime() - startDate.getTime());
return Boolean.TRUE;
@@ -582,7 +691,6 @@
*/
public String queryAndChangeGlass(String glassId) {
GlassInfo glassInfo = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId));
-// .inSql(GlassInfo::getEngineerId, "select engineer_id from engineering where state = 1"));
Assert.isFalse(null == glassInfo, "鐜荤拑淇℃伅涓嶅瓨鍦�"); //鎸夌収鐜荤拑灏哄
LambdaQueryWrapper<GlassInfo> queryWrapper = new LambdaQueryWrapper<GlassInfo>()
.eq(GlassInfo::getWidth, glassInfo.getWidth())
@@ -707,35 +815,16 @@
}
}
- public boolean saveHistoryTask(EdgStorageDeviceTask task, int deviceId) {
+ // public boolean saveHistoryTask(EdgStorageDeviceTask task, int deviceId) {
+ public boolean saveHistoryTask(S7DataWL task, int deviceId) {
EdgStorageDeviceTaskHistory taskHistory = new EdgStorageDeviceTaskHistory();
BeanUtils.copyProperties(task, taskHistory);
+// taskHistory.setTaskType(task.getTaskRunning());
taskHistory.setTaskType(task.getTaskRunning());
taskHistory.setCreateTime(new Date());
taskHistory.setTaskState(Const.RAW_GLASS_TASK_NEW);
taskHistory.setDeviceId(deviceId);
edgStorageDeviceTaskHistoryService.save(taskHistory);
- return Boolean.TRUE;
- }
-
- public boolean updateCellRemainWidth(int slot, int device, EdgStorageDeviceTaskHistory taskHistory) {
- List<EdgStorageCageDetails> list = edgStorageCageDetailsService.list(new LambdaQueryWrapper<EdgStorageCageDetails>().eq(EdgStorageCageDetails::getSlot, slot)
- .eq(EdgStorageCageDetails::getState, Const.GLASS_STATE_IN));
- int remainWidth = cellLength;
- if (CollectionUtil.isNotEmpty(list)) {
- if (2 == taskHistory.getTaskType()) {
- remainWidth = 0;
- } else {
- for (EdgStorageCageDetails item : list) {
- remainWidth = remainWidth - glassGap - (int) Math.max(item.getWidth(), item.getHeight());
- }
- if (remainWidth <= 0) {
- remainWidth = 0;
- }
- }
- }
- edgStorageCageService.update(new LambdaUpdateWrapper<EdgStorageCage>().
- set(EdgStorageCage::getRemainWidth, remainWidth).eq(EdgStorageCage::getSlot, slot).eq(EdgStorageCage::getDeviceId, device));
return Boolean.TRUE;
}
--
Gitblit v1.8.0