From b4ff04d7dd22f0e48bf386cd422e885aef08fed7 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期四, 22 五月 2025 15:03:10 +0800
Subject: [PATCH] OPC通讯修改为S7通讯
---
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/OpcCacheGlassNewTask.java | 237 ++++++++++++++++++++++++++++++++++++++++++----------------
1 files changed, 171 insertions(+), 66 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 1a09f85..68d4036 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
@@ -23,10 +23,11 @@
import com.mes.opctask.entity.EdgStorageDeviceTaskHistory;
import com.mes.opctask.service.EdgStorageDeviceTaskHistoryService;
import com.mes.opctask.service.EdgStorageDeviceTaskService;
-import com.mes.s7.entity.S7DataMBOne;
-import com.mes.s7.entity.S7DataWLOne;
-import com.mes.s7.entity.S7DataWLTwo;
+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 io.swagger.models.auth.In;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
@@ -36,7 +37,6 @@
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
-import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -85,6 +85,10 @@
@Qualifier("s7SerializerMBOne")
private S7Serializer s7SerializerMBOne;
+ @Autowired
+ @Qualifier("s7SerializerMBTwo")
+ private S7Serializer s7SerializerMBTwo;
+
// @Value("${mes.threshold}")
private int threshold;
// @Value("${mes.cellLength}")
@@ -120,7 +124,9 @@
@Scheduled(fixedDelay = 1000)
public void startOneOpcTask() throws Exception {
- S7DataWLTwo s7DataWLTwo = s7SerializerWLTwo.read(S7DataWLTwo.class);
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ log.info("浜岀嚎鍗х悊: {}", s7DataWLTwo);
//鑾峰彇绗簩鏉＄嚎璺殑鍗у紡鐞嗙墖绗肩姸鎬�
// ReadWriteEntity twoInkageEntity = miloService.readFromOpcUa("WL2.WL2.deviceState");
Boolean twoInkageEntity = s7DataWLTwo.getDeviceState();
@@ -131,12 +137,14 @@
if (twoInkageEntity != null && !twoInkageEntity) {
cellFlag = 2;
}
- startOneOpcTaskChild(EDG_STORAGE_DEVICE_ONE_TASK, 1, cellFlag);
+ startOneOpcTaskChild(s7DataWLOne, 1, cellFlag);
}
@Scheduled(fixedDelay = 1000)
public void startTwoOpcTask() throws Exception {
- S7DataWLOne s7DataWLOne = s7SerializerWLOne.read(S7DataWLOne.class);
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ log.info("涓�绾垮崸鐞�: {}", s7DataWLOne);
// ReadWriteEntity oneInkageEntity = miloService.readFromOpcUa("WL1.WL1.deviceState");
Boolean oneInkageEntity = s7DataWLOne.getDeviceState();
int cellFlag = 1;
@@ -144,10 +152,11 @@
if (oneInkageEntity != null && !oneInkageEntity) {
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 {
+ // private void startOneOpcTaskChild(String tableName, int device, int cellFlag) throws Exception {
+ 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);
@@ -159,7 +168,8 @@
maxTwoSecondLength = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MAX_SECOND_LENGTH);
maxThickness = sysConfigService.queryConfigValue(ConstSysConfig.CACHE_MAX_THICKNESS);
- EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(tableName);
+// EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(tableName);
+
if (task == null) {
log.info("浠诲姟琛ㄥ熀纭�鏁版嵁褰曞叆澶辫触锛岃妫�鏌ユ暟鎹槸鍚﹀綍鍏ユ垚鍔�");
return;
@@ -178,27 +188,33 @@
//杩涚墖浠诲姟
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);
+// task.setTaskRunning(Const.GLASS_CACHE_TYPE_RUNNING);
+// edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ if (device == 2) {
+ s7SerializerWLTwo.write(S7DataWL.builder().taskRunning(Const.GLASS_CACHE_TYPE_RUNNING.shortValue()).build());
+ } else {
+ s7SerializerWLOne.write(S7DataWL.builder().taskRunning(Const.GLASS_CACHE_TYPE_RUNNING.shortValue()).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)
//
@@ -214,8 +230,10 @@
@Scheduled(fixedDelay = 1000)
public void edgOneOpcTask() throws Exception {
- EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(EDG_STORAGE_DEVICE_ONE_TASK);
- String glassId = task.getGlassId();
+// EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(EDG_STORAGE_DEVICE_ONE_TASK);
+// String glassId = task.getGlassId();
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ String glassId = s7DataWLOne.getGlassId();
if (StringUtils.isBlank(glassId) || glassId.equals(glassIdOne)) {
log.info("{}鍙风嚎纾ㄨ竟鍓嶇幓鐠冩湭灏变綅锛岀粨鏉熸湰娆′换鍔�", 1);
return;
@@ -225,8 +243,10 @@
@Scheduled(fixedDelay = 1000)
public void edgTwoOpcTask() throws Exception {
- EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(EDG_STORAGE_DEVICE_TWO_TASK);
- String glassId = task.getGlassId();
+// EdgStorageDeviceTask task = edgStorageDeviceTaskService.queryTaskMessage(EDG_STORAGE_DEVICE_TWO_TASK);
+// String glassId = task.getGlassId();
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ String glassId = s7DataWLTwo.getGlassId();
if (StringUtils.isBlank(glassId) || glassId.equals(glassIdTwo)) {
log.info("{}鍙风嚎纾ㄨ竟鍓嶇幓鐠冩湭灏变綅锛岀粨鏉熸湰娆′换鍔�", 2);
return;
@@ -251,16 +271,20 @@
//
// miloService.writeToOpcUa(list);
// miloService.writeToOpcWord(generateReadWriteEntity("MB" + cell + ".MB" + cell + ".thickness", (int) glassInfo.getThickness() * ratio));
- S7DataMBOne s7DataMBOne =new S7DataMBOne();
- s7DataMBOne.setToEdingId(Integer.parseInt(toEndingId));
- s7DataMBOne.setGlassId(Integer.parseInt(toEndingId));
- s7DataMBOne.setWidth((int) Math.max(glassInfo.getWidth() * ratio, glassInfo.getHeight() * ratio));
- s7DataMBOne.setHeight((int) Math.min(glassInfo.getWidth() * ratio, glassInfo.getHeight() * ratio));
- s7SerializerMBOne.write(s7DataMBOne);
+ 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));
+ s7SerializerMBOne.write(s7DataMB);
- s7DataMBOne =new S7DataMBOne();
- s7DataMBOne.setThickness((short) (glassInfo.getThickness() * ratio));
- s7SerializerMBOne.write(s7DataMBOne);
+ s7DataMB = new S7DataMB();
+ s7DataMB.setThickness((short) (glassInfo.getThickness() * ratio));
+ if (cell == 1) {
+ s7SerializerMBOne.write(s7DataMB);
+ } else {
+ s7SerializerMBTwo.write(s7DataMB);
+ }
//淇敼纾ㄨ竟瀵瑰垪涓殑纾ㄨ竟绾胯矾鍙婄姸鎬�
edgGlassTaskInfoService.update(new LambdaUpdateWrapper<EdgGlassTaskInfo>()
.set(EdgGlassTaskInfo::getLine, cell)
@@ -275,7 +299,7 @@
}
}
- private boolean intoTask(EdgStorageDeviceTask task, String tableName, int deviceId) {
+ private boolean intoTask(S7DataWL task, String tableName, int deviceId) {
Date startDate = new Date();
log.info("寮�濮嬫墽琛岃繘鐗囦换鍔★紝浠诲姟淇℃伅涓猴細{},琛ㄥ悕涓猴細{},璁惧id:{},寮�濮嬫椂闂达細{}", task, tableName, deviceId, startDate);
//鑾峰彇鐜荤拑鐨勫熀鏈俊鎭�
@@ -294,17 +318,21 @@
}
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(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();
@@ -315,9 +343,22 @@
edgStorageCageDetailsService.save(details);
//鏇存柊浠诲姟淇℃伅
- task.setStartCell(edgStorageCage.getSlot());
- task.setTaskRunning(Const.GLASS_CACHE_TYPE_IN);
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+// task.setStartCell(edgStorageCage.getSlot());
+// task.setTaskRunning(Const.GLASS_CACHE_TYPE_IN);
+// edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+ task.setStartCell(edgStorageCage.getSlot().shortValue());
+ task.setTaskRunning(Const.GLASS_CACHE_TYPE_IN.shortValue());
+ if (deviceId == 1) {
+ s7SerializerWLOne.write(
+ S7DataWL.builder().startCell(edgStorageCage.getSlot().shortValue())
+ .taskRunning(Const.GLASS_CACHE_TYPE_IN.shortValue()).build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder().startCell(edgStorageCage.getSlot().shortValue())
+ .taskRunning(Const.GLASS_CACHE_TYPE_IN.shortValue()).build()
+ );
+ }
saveHistoryTask(task, deviceId);
//璁板綍杩涚墖浠诲姟鐨勭幓鐠僫d鐢ㄤ簬涓嬫浠诲姟鐨勬瘮杈冿紝闃叉鍚屼竴鍧楃幓鐠冮噸澶嶆墽琛�
if (deviceId == 1) {
@@ -330,17 +371,18 @@
return Boolean.TRUE;
}
- private boolean outTask(EdgStorageDeviceTask task, String tableName, int deviceId, int cellFlag) throws Exception {
+ private boolean outTask(S7DataWL task, String tableName, int deviceId, int cellFlag) throws Exception {
Date startDate = new Date();
//鑾峰彇瀵瑰簲鐨勮澶囩姸鎬佷俊鎭�
// ReadWriteEntity oneOutStateEntity = miloService.readFromOpcUa("WL1.WL1.slotState");
// ReadWriteEntity twoOutStateEntity = miloService.readFromOpcUa("WL2.WL2.slotState");
// ReadWriteEntity d06OutStateEntity = miloService.readFromOpcUa("WL2.WL2.d06SlotState");
- S7DataWLOne s7DataWLOne = s7SerializerWLOne.read(S7DataWLOne.class);
- S7DataWLTwo s7DataWLTwo = s7SerializerWLTwo.read(S7DataWLTwo.class);
+ S7DataWL s7DataWLOne = s7SerializerWLOne.read(S7DataWL.class);
+ S7DataWL s7DataWLTwo = s7SerializerWLTwo.read(S7DataWL.class);
+ S7DataWLExtra s7DataWLExtraTwo = s7SerializerWLTwo.read(S7DataWLExtra.class);
Short oneOutStateEntity = s7DataWLOne.getSlotState();
Short twoOutStateEntity = s7DataWLTwo.getSlotState();
- Short d06OutStateEntity = s7DataWLTwo.getD06SlotState();
+ Short d06OutStateEntity = s7DataWLExtraTwo.getD06SlotState();
//鐘舵�佹湁3涓儏鍐碉細0绌洪棽 1蹇欑 2绂佺敤
String oneOutState = Const.OUT_DISABLE;
String twoOutState = Const.OUT_DISABLE;
@@ -348,13 +390,13 @@
// if (null != oneOutStateEntity && null != oneOutStateEntity.getValue()) {
// oneOutState = oneOutStateEntity.getValue().toString();
// }
- if (null != oneOutStateEntity ) {
+ if (null != oneOutStateEntity) {
oneOutState = oneOutStateEntity.toString();
}
// if (null != twoOutStateEntity && null != twoOutStateEntity.getValue()) {
// twoOutState = twoOutStateEntity.getValue().toString();
// }
- if (null != twoOutStateEntity ) {
+ if (null != twoOutStateEntity) {
twoOutState = twoOutStateEntity.toString();
}
//涓ゆ潯绾块兘涓虹鐢ㄥ垯涓嶅嚭鐜荤拑
@@ -365,7 +407,7 @@
// if (null != d06OutStateEntity && null != d06OutStateEntity.getValue()) {
// d06OutState = d06OutStateEntity.getValue().toString();
// }
- if (null != d06OutStateEntity ) {
+ if (null != d06OutStateEntity) {
d06OutState = d06OutStateEntity.toString();
}
//鑾峰彇d06鐗囧彴鐘舵��
@@ -414,7 +456,7 @@
return Boolean.TRUE;
}
- private boolean outChildTask(EdgStorageDeviceTask task, String tableName, int deviceId, int cell, Date startDate) {
+ private boolean outChildTask(S7DataWL task, String tableName, int deviceId, int cell, Date startDate) {
EdgStorageCageDetails edgStorageCageDetails = null;
//绗煎唴鏄増鍥剧浉宸槸鍚﹁秴杩囬槇鍊�
@@ -468,7 +510,7 @@
}
//鍓嶉潰宸茬粡灏哄闂澶勭悊瀹屾瘯锛屽紑濮嬭绠楁棤鐩稿悓灏哄鐨勬柊鐜荤拑灏忕墖
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);
}
if (edgStorageCageDetails == null && StringUtils.isNotBlank(task.getGlassIdIn())) {
@@ -548,12 +590,30 @@
log.info("5銆佹洿鏂板嚭鐗囩幓鐠冪殑鐘舵�佷负{}", Const.GLASS_STATE_OUT);
}
//鐢熸垚鍑虹墖浠诲姟
- task.setGlassIdOut(edgStorageCageDetails.getGlassId());
- task.setStartCell(edgStorageCageDetails.getSlot());
- task.setTaskRunning(taskType);
- task.setEndCell(cell);
-
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+// task.setGlassIdOut(edgStorageCageDetails.getGlassId());
+// 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().shortValue())
+ .taskRunning((short) taskType)
+ .endCell((short) cell)
+ .build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder()
+ .glassIdOut(edgStorageCageDetails.getGlassId())
+ .startCell(edgStorageCageDetails.getSlot().shortValue())
+ .taskRunning((short) taskType)
+ .endCell((short) cell)
+ .build()
+ );
+ }
saveHistoryTask(task, deviceId);
//璁板綍鐩撮�氫换鍔＄殑鐜荤拑id鐢ㄤ簬涓嬫浠诲姟鐨勬瘮杈冿紝闃叉鍚屼竴鍧楃幓鐠冮噸澶嶆墽琛�
if (3 == task.getTaskState()) {
@@ -574,17 +634,17 @@
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);
+// 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)
@@ -602,13 +662,37 @@
);
}
//鏈�鍚庢洿鏂颁换鍔★紝淇濊瘉浠诲姟鍓嶇殑鍔ㄤ綔閮藉仛瀹�
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+
+// 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.shortValue())
+ .glassIdOut("")
+ .startCell((short) 0)
+ .endCell((short) 0)
+ .build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder()
+ .taskRunning(Const.GLASS_CACHE_TYPE_EMPTY.shortValue())
+ .glassIdOut("")
+ .startCell((short) 0)
+ .endCell((short) 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;
@@ -644,11 +728,30 @@
);
}
//鏈�鍚庢洿鏂颁换鍔★紝淇濊瘉浠诲姟鍓嶇殑鍔ㄤ綔閮藉仛瀹�
- task.setTaskRunning(Const.GLASS_CACHE_TYPE_EMPTY);
- task.setGlassIdOut("");
- task.setStartCell(0);
- task.setEndCell(0);
- edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
+// 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.shortValue())
+ .glassIdOut("")
+ .startCell((short) 0)
+ .endCell((short) 0)
+ .build()
+ );
+ } else {
+ s7SerializerWLTwo.write(
+ S7DataWL.builder()
+ .taskRunning(Const.GLASS_CACHE_TYPE_EMPTY.shortValue())
+ .glassIdOut("")
+ .startCell((short) 0)
+ .endCell((short) 0)
+ .build()
+ );
+ }
Date endDate = new Date();
log.info("瀹屾垚鎵ц寮傚父澶勭悊浠诲姟鍚庢竻闄ゅ姩浣滐紝琛ㄥ悕涓猴細{},缁撴潫鏃堕棿涓猴細{}锛屽叡鑰楁椂锛歿}ms", tableName, endDate, endDate.getTime() - startDate.getTime());
return Boolean.TRUE;
@@ -788,10 +891,12 @@
}
}
- 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.setTaskType(Integer.parseInt(task.getTaskRunning().toString()));
taskHistory.setCreateTime(new Date());
taskHistory.setTaskState(Const.RAW_GLASS_TASK_NEW);
taskHistory.setDeviceId(deviceId);
--
Gitblit v1.8.0