From 649e50a1b4fa3811072843c79787163b87ab3889 Mon Sep 17 00:00:00 2001
From: zhoushihao <zsh19950802@163.com>
Date: 星期三, 20 十一月 2024 08:41:16 +0800
Subject: [PATCH] 1、大理片功能初步提交 2、卧理功能优化
---
hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/opccallback/CacheGlassStartCallback.java | 33 +++++++++++++--------------------
1 files changed, 13 insertions(+), 20 deletions(-)
diff --git a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/opccallback/CacheGlassStartCallback.java b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/opccallback/CacheGlassStartCallback.java
index 0322df3..8941f5c 100644
--- a/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/opccallback/CacheGlassStartCallback.java
+++ b/hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/job/opccallback/CacheGlassStartCallback.java
@@ -67,16 +67,7 @@
@Override
public void onSubscribe(String identifier, Object value) {
- if (identifier.equals("PLC.WL2.plc_task_tate")) {
- startDate = new Date();
- log.info("鏈浠诲姟鑾峰彇plc鐨勫�间负{}锛屾椂闂达細{}锛屽叡鑰楁椂锛歿}ms", value, startDate);
- return;
- }
- if (!identifier.equals("PLC.WL2.plc_task_tate")) {
- Date endDate = new Date();
- log.info("鏈浠诲姟link鍚庣殑鍊间负{},鏃堕棿锛歿}锛屽叡鑰楁椂锛歿}ms", value, endDate, endDate.getTime() - startDate.getTime());
- startDate = null;
- }
+
log.info("褰撳墠姝ｅ湪鎵ц鐨勪换鍔′负{}", value);
String tableName = identifier.contains("edg_storage_device_one_task") ? EDG_STORAGE_DEVICE_ONE_TASK : EDG_STORAGE_DEVICE_TWO_TASK;
int device = tableName.equals("edg_storage_device_one_task") ? 1 : 2;
@@ -85,6 +76,10 @@
if (task == null) {
log.info("浠诲姟琛ㄥ熀纭�鏁版嵁褰曞叆澶辫触锛岃妫�鏌ユ暟鎹槸鍚﹀綍鍏ユ垚鍔�");
return;
+ }
+ if (task.getTaskState() == 2) {
+ //闃叉鍑虹墖浠诲姟涓旂鍓嶆湁鐜荤拑鐨勬儏鍐碉紝灏嗚繘鐗噄d缃┖锛屽嵆鍑虹墖浠呰�冭檻绗煎唴鐨勭幓鐠�
+ task.setGlassIdIn("");
}
int request = Integer.parseInt("" + value);
log.info("寮�濮嬫墽琛屼换鍔★紝浠诲姟璇蜂俊鎭负{}", task);
@@ -246,6 +241,8 @@
log.info("5銆佺洿閫氫换鍔�,灏嗙幓鐠冧俊鎭彃鍏ュ崸寮忕悊鐗囩,褰撳墠鐜荤拑淇℃伅:{}", edgStorageCageDetails);
//鐜荤拑淇℃伅鏇挎崲
String glassIdChange = queryAndChangeGlass(glassId);
+ //澶勭悊鍦ㄥ崸鐞嗗唴鐨勭幓鐠冧俊鎭細绗煎唴鐨勬暟鎹鐞�
+ queryEdgAndChangeGlass(edgStorageCageDetails.getGlassId(), glassIdChange);
if (StringUtils.isNotBlank(glassIdChange)) {
edgStorageCageDetails = new EdgStorageCageDetails();
GlassInfo one = glassInfoService.getOne(new LambdaQueryWrapper<GlassInfo>().eq(GlassInfo::getGlassId, glassId));
@@ -286,28 +283,24 @@
edgStorageCageDetailsService.update(wrapper);
log.info("5銆佹洿鏂板嚭鐗囩幓鐠冪殑鐘舵�佷负{}", Const.GLASS_STATE_OUT);
}
-
- //鐜荤拑淇℃伅鏇挎崲
-// String glassIdChange = queryAndChangeGlass(edgStorageCageDetails.getGlassId());
- //澶勭悊鍦ㄥ崸鐞嗗唴鐨勭幓鐠冧俊鎭細绗煎唴鐨勬暟鎹鐞�
-// queryEdgAndChangeGlass(edgStorageCageDetails.getGlassId(), glassIdChange);
//鐢熸垚鍑虹墖浠诲姟
task.setGlassIdOut(edgStorageCageDetails.getGlassId());
task.setStartCell(edgStorageCageDetails.getSlot());
task.setTaskRunning(taskType);
-// task.setWidth((int) edgStorageCageDetails.getWidth() * 10);
-// task.setHeight((int) edgStorageCageDetails.getHeight() * 10);
-// task.setThickness((int) edgStorageCageDetails.getThickness() * 10);
-// task.setFilmRemove(0);
+
edgStorageDeviceTaskService.updateTaskMessage(tableName, task);
saveHistoryTask(task);
//鏇存柊璇︽儏琛ㄤ换鍔″嚭鐗囦腑
edgStorageCageDetailsService.update(new LambdaUpdateWrapper<EdgStorageCageDetails>()
.set(EdgStorageCageDetails::getState, Const.GLASS_STATE_OUT)
.eq(EdgStorageCageDetails::getGlassId, edgStorageCageDetails.getGlassId()));
- //todo:纾ㄨ竟瀵瑰垪琛ㄦ柊澧炰竴鏉℃暟鎹�
+ //纾ㄨ竟瀵瑰垪琛ㄦ柊澧炰竴鏉℃暟鎹�
EdgGlassTaskQueueInfo edgInfo = new EdgGlassTaskQueueInfo();
BeanUtils.copyProperties(task, edgInfo);
+ edgInfo.setCreateTime(new Date());
+ edgInfo.setWidth((int) edgStorageCageDetails.getWidth());
+ edgInfo.setHeight((int) edgStorageCageDetails.getWidth());
+ edgInfo.setThickness((int) edgStorageCageDetails.getWidth());
edgInfo.setState(Const.GLASS_STATE_NEW);
edgGlassTaskQueueInfoService.save(edgInfo);
return Boolean.TRUE;
--
Gitblit v1.8.0