From 233ff9e9e82c67ac33695b479fd31df6ffb77b22 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 02 十二月 2024 15:44:30 +0800
Subject: [PATCH] #
---
zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AgvDataService.java | 39 ++++++++++++++++++++++++++++++---------
1 files changed, 30 insertions(+), 9 deletions(-)
diff --git a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AgvDataService.java b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AgvDataService.java
index 27a4948..153a959 100644
--- a/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AgvDataService.java
+++ b/zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/AgvDataService.java
@@ -3,10 +3,14 @@
import com.alibaba.fastjson.JSON;
import com.zy.acs.common.domain.AgvProtocol;
import com.zy.acs.common.domain.protocol.*;
+import com.zy.acs.common.enums.AgvStatusType;
import com.zy.acs.common.utils.GsonUtils;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.framework.common.Cools;
+import com.zy.acs.framework.common.DateUtils;
+import com.zy.acs.manager.core.constant.MapDataConstant;
import com.zy.acs.manager.core.domain.BackpackDto;
+import com.zy.acs.manager.core.domain.VehicleFaultDto;
import com.zy.acs.manager.manager.entity.Agv;
import com.zy.acs.manager.manager.entity.AgvDetail;
import com.zy.acs.manager.manager.entity.Code;
@@ -121,9 +125,18 @@
if (msgBody instanceof AGV_04_UP) {
AGV_04_UP agv_04_up = (AGV_04_UP) msgBody;
log.info("Agv [{}] 鏁呴殰鏁版嵁鍖� ===>> {}", protocol.getAgvNo(), JSON.toJSONString(agv_04_up));
-// faultProcessor.execute(new VehicleFaultDto());
+ faultProcessor.execute(new VehicleFaultDto<>(protocol.getAgvNo(), protocol.getTimestamp(), agv_04_up));
+ detail.setError(agv_04_up.getHexFaultId());
+ detail.setErrorTime(new Date());
}
+ // 鏁呴殰澶嶄綅
+ if (!Cools.isEmpty(detail.realError())) {
+ assert detail.getErrorTime() != null;
+ if (DateUtils.diffToSeconds(detail.getErrorTime(), new Date()) > 20) {
+ detail.setError(MapDataConstant.EMPTY_OF_ERROR);
+ }
+ }
if (!agvDetailService.updateById(detail)) {
log.error("Agv [{}] 璇︽儏鏇存柊澶辫触 锛侊紒锛�", protocol.getAgvNo());
}
@@ -132,6 +145,8 @@
// 鏈夌爜瀹炴椂鏁版嵁鍖�
private void sync(AGV_12_UP mesBody, AgvDetail detail) {
+ detail.setStatus(mesBody.getStatus());
+
Code code = codeService.selectByData(mesBody.getQrCode());
if (null != code) {
detail.setCode(code.getId());
@@ -143,8 +158,6 @@
} else {
log.error("Agv [{}] 鏇存柊瀹氫綅鏁版嵁澶辫触 锛侊紒锛佷笂浼犳潯鐮侊細{}", agvService.getById(detail.getAgvId()).getUuid(), mesBody.getQrCode());
}
-
- detail.setStatus(mesBody.getStatus());
// 鍦伴潰鐮佸亸绉�
detail.setCodeOffsert(JSON.toJSONString(Cools
@@ -180,14 +193,22 @@
// 鏃犵爜瀹炴椂鏁版嵁鍖�
private void sync(AGV_13_UP mesBody, AgvDetail detail) {
+ detail.setStatus(mesBody.getStatus());
+
Code code = codeService.selectByData(mesBody.getQrCode());
if (null != code) {
- detail.setCode(null);
- detail.setLastCode(code.getId());
- detail.setPos(0);
-// if (!agvDetailService.updateUnPosCode(detail.getId(), code.getId())) {
-// log.error("Agv [{}] 鏇存柊瀹氫綅鏁版嵁澶辫触 锛侊紒锛�", agvService.getById(detail.getAgvId()).getUuid());
-// }
+
+ if (!detail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
+ detail.setCode(null);
+ detail.setLastCode(code.getId());
+ detail.setPos(0);
+ } else {
+ detail.setCode(code.getId());
+ detail.setLastCode(null);
+ detail.setPos(1);
+ }
+
+
} else {
log.error("Agv [{}] 鏇存柊瀹氫綅鏁版嵁澶辫触 锛侊紒锛佷笂浼犳潯鐮侊細{}", agvService.getById(detail.getAgvId()).getUuid(), mesBody.getQrCode());
}
--
Gitblit v1.9.1