107 changed files with 3002 additions and 3002 deletions
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,12 +1,12 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
|
|||
import com.fasterxml.jackson.core.JsonProcessingException; |
|||
import com.fasterxml.jackson.core.type.TypeReference; |
|||
import com.galaxis.rcs.plan.path.PathUtils; |
|||
import com.galaxis.rcs.ptr.receiveEntity.*; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.*; |
|||
import com.galaxis.rcs.ptr.sendEntity.*; |
|||
import com.galaxis.rcs.amr.receiveEntity.*; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.*; |
|||
import com.galaxis.rcs.amr.sendEntity.*; |
|||
import com.google.common.base.Splitter; |
|||
import com.google.common.collect.Maps; |
|||
import com.google.common.collect.Sets; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.google.common.collect.Maps; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.google.common.collect.Maps; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
public enum ControlMode { |
|||
FULL_AUTO, |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonInclude; |
|||
import com.fasterxml.jackson.core.JsonProcessingException; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.galaxis.rcs.common.enums.LCCDirection; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
public abstract class PtrAgvConnector { |
|||
|
|||
@ -1,8 +1,8 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.fasterxml.jackson.core.JsonProcessingException; |
|||
import com.galaxis.rcs.connector.cl2.Cl2DeviceConnector; |
|||
import com.galaxis.rcs.ptr.sendEntity.RcsTaskMessage; |
|||
import com.galaxis.rcs.amr.sendEntity.RcsTaskMessage; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.eclipse.paho.mqttv5.common.MqttException; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.yvan.logisticsModel.StaticItem; |
|||
|
|||
@ -1,15 +1,15 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.galaxis.rcs.common.entity.RcsTaskPlan; |
|||
import com.galaxis.rcs.common.enums.*; |
|||
import com.galaxis.rcs.connector.cl2.Cl2DeviceConnector; |
|||
import com.galaxis.rcs.plan.PlanTaskSequence; |
|||
import com.galaxis.rcs.plan.path.PathUtils; |
|||
import com.galaxis.rcs.ptr.receiveEntity.AmrHeartbeatMessage; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.CurBatteryData; |
|||
import com.galaxis.rcs.ptr.sendEntity.RcsConfigMessage; |
|||
import com.galaxis.rcs.ptr.sendEntity.RcsSRMessage; |
|||
import com.galaxis.rcs.ptr.sendEntity.RcsSetLocationMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.AmrHeartbeatMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.CurBatteryData; |
|||
import com.galaxis.rcs.amr.sendEntity.RcsConfigMessage; |
|||
import com.galaxis.rcs.amr.sendEntity.RcsSRMessage; |
|||
import com.galaxis.rcs.amr.sendEntity.RcsSetLocationMessage; |
|||
import com.google.common.collect.Queues; |
|||
import com.yvan.entity.AgvStatusVo; |
|||
import com.yvan.entity.BasLocationVo; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.yvan.logisticsEnv.EnvConfig; |
|||
import lombok.SneakyThrows; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr; |
|||
package com.galaxis.rcs.amr; |
|||
|
|||
import com.google.common.collect.Maps; |
|||
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 消息应答 20050
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 小车主程序启动 20149
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 开机上报 20147 在开机后上报一次,此后AMR程序重启不会重新上报(与ID#20149的差异),除非人为清除内部记录已上报的标志。
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
import java.util.Map; |
|||
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
//心跳 20100
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 地标报告 20020
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 小车子模块任务状态 20012
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 小车离线 20200 注意:目前未实现此报文
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 小车上线 20150 代表车已经完成初始化,可以接收任务了。
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
// 关机上报 20148 在收到关机信号后上报此消息。
|
|||
//@Data
|
|||
@ -1,9 +1,9 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.CurBatteryData; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.LocationData; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.CurBatteryData; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.LocationData; |
|||
|
|||
// 状态上报 20060
|
|||
//@Data
|
|||
@ -1,9 +1,9 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.LocationData; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.SummaryData; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.LocationData; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.SummaryData; |
|||
|
|||
// 小车作业完成 20010
|
|||
//@Data
|
|||
@ -1,7 +1,7 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity; |
|||
package com.galaxis.rcs.amr.receiveEntity; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import com.galaxis.rcs.ptr.receiveEntity.base.AmrCommonMessage; |
|||
import com.galaxis.rcs.amr.receiveEntity.base.AmrCommonMessage; |
|||
|
|||
//@Data
|
|||
@JsonIgnoreProperties(ignoreUnknown = true) |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.receiveEntity.base; |
|||
package com.galaxis.rcs.amr.receiveEntity.base; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonIgnoreProperties; |
|||
import lombok.Data; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
public class BaseMessage { |
|||
public int id; |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
// 电文应答 10050
|
|||
public class RcsAckMessage { |
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
// 取消已下发小车任务 10120
|
|||
public class RcsCancelTaskMessage { |
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
//配置信息 10060
|
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
// 控制卷帘门 10082
|
|||
@ -1,4 +1,4 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
// 心跳 10100
|
|||
public class RcsHeartBeatMessage { |
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
//状态查询 10110
|
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
//旋转车身 10081
|
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
//旋转货架 10080
|
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
// 停止/解除 10040
|
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
|
|||
// 设置小车坐标 10200
|
|||
public class RcsSetLocationMessage { |
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
import lombok.AllArgsConstructor; |
|||
|
|||
@ -1,6 +1,6 @@ |
|||
package com.galaxis.rcs.ptr.sendEntity; |
|||
package com.galaxis.rcs.amr.sendEntity; |
|||
|
|||
import com.galaxis.rcs.ptr.AmrMessageHandler; |
|||
import com.galaxis.rcs.amr.AmrMessageHandler; |
|||
import com.yvan.logisticsModel.LogisticsRuntime; |
|||
|
|||
public class RcsWaitMessage { |
|||
Loading…
Reference in new issue