From 0d04bc5d8080b82338302fba0a59fccff2eaedfc Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期日, 06 七月 2025 11:28:29 +0800 Subject: [PATCH] # --- zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/LiftProtocol.java | 93 ++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 89 insertions(+), 4 deletions(-) diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/LiftProtocol.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/LiftProtocol.java index 7ea5a7f..3288912 100644 --- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/LiftProtocol.java +++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/model/protocol/LiftProtocol.java @@ -1,24 +1,31 @@ package com.zy.asrs.wcs.rcs.model.protocol; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.zy.asrs.framework.common.Cools; +import com.zy.asrs.framework.common.SpringUtils; +import com.zy.asrs.wcs.core.utils.RedisUtil; +import com.zy.asrs.wcs.rcs.constant.DeviceRedisConstant; +import com.zy.asrs.wcs.rcs.entity.BasLiftErr; import com.zy.asrs.wcs.rcs.entity.Device; import com.zy.asrs.wcs.rcs.model.enums.LiftProtocolStatusType; +import com.zy.asrs.wcs.rcs.service.BasLiftErrService; import lombok.Data; import lombok.extern.slf4j.Slf4j; @Slf4j @Data -public class LiftProtocol { +public class LiftProtocol implements Cloneable { //**********************蹇呴』瀛樺湪灞炴��********************** /** * 鎻愬崌鏈哄彿 */ - private String liftNo; + private Integer liftNo; /** * 浠诲姟鍙� */ - private String taskNo; + private Integer taskNo; /** * 鍥涘悜绌挎杞﹀彿 @@ -118,7 +125,12 @@ /** * 浣滀笟鏍囪 */ - private Boolean pakMk = false; + private Boolean pakMk = true; + + /** + * 鎸囦护涓嬪彂鏃堕棿 + */ + private Long sendTime = 0L; /** * 鏃ュ織閲囬泦鏃堕棿 @@ -129,6 +141,35 @@ * 璁惧淇℃伅 */ private Device device; + + /** + * 鎵╁睍瀛楁 + */ + private Object extend; + + public String getRun$() { + if (this.run == null) { + return "鏈煡"; + } + + return this.run ? "杩愯涓�" : "绌洪棽"; + } + + public String getReady$() { + if (this.ready == null) { + return "鏈煡"; + } + + return this.ready ? "灏辩华" : "鏈氨缁�"; + } + + public String getModel$() { + if (this.model == null) { + return "鏈煡"; + } + + return this.model ? "鑷姩" : "鎵嬪姩"; + } /** * 璁剧疆鎻愬崌鏈虹姸鎬� @@ -146,4 +187,48 @@ this.protocolStatusType = status; } + public synchronized void setTaskNo(Integer taskNo) { + RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); + if (null != redisUtil) { + redisUtil.set(DeviceRedisConstant.LIFT_FLAG + this.liftNo, taskNo); + this.taskNo = taskNo; + } + } + + public Integer getTaskNo() { + RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); + if (null != redisUtil) { + Object o = redisUtil.get(DeviceRedisConstant.LIFT_FLAG + this.liftNo); + if (!Cools.isEmpty(o)) { + this.taskNo = Integer.valueOf(String.valueOf(o)); + } + } + return this.taskNo == null ? 0 : this.taskNo; + } + + public String getErrorCode$() { + if (this.errorCode == null) { + return ""; + } + BasLiftErrService basLiftErrService = SpringUtils.getBean(BasLiftErrService.class); + BasLiftErr liftErr = basLiftErrService.getOne(new LambdaQueryWrapper<BasLiftErr>() + .eq(BasLiftErr::getErrorCode, this.errorCode) + .eq(BasLiftErr::getHostId, this.device.getHostId()) + .eq(BasLiftErr::getDevicePlc, this.device.getDevicePlc())); + if (liftErr != null) { + return this.errorCode + "-" + liftErr.getErrName(); + } + return errorCode; + } + + @Override + public LiftProtocol clone() { + try { + return (LiftProtocol) super.clone(); + } catch (CloneNotSupportedException e) { + e.printStackTrace(); + } + return null; + } + } -- Gitblit v1.9.1