From 3181d10cd687272c20252a020eeaa9974527dc14 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: Fri, 01 Nov 2024 15:19:07 +0800
Subject: [PATCH] 增加：航线开始/暂停/恢复/结束的回复解析
---
ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineEndReplyCmd.java | 2 ++
ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java | 20 ++++++++++++++++++++
ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLinePauseReplyCmd.java | 2 ++
ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineBeginReplyCmd.java | 2 ++
ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineResumeReplyCmd.java | 2 ++
5 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineBeginReplyCmd.java b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineBeginReplyCmd.java
index 73aeb7a..5fc04b3 100644
--- a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineBeginReplyCmd.java
+++ b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineBeginReplyCmd.java
@@ -3,6 +3,7 @@
import com.ard.tianyu.model.dto.wayline.WayLineBeginDTO;
import com.ard.tianyu.netty.command.BaseCmd;
import io.netty.buffer.ByteBuf;
+import lombok.Data;
/**
* 开始航线回复指令
@@ -10,6 +11,7 @@
* @author liusuyi
* @date 2024年10月30日16:20
**/
+@Data
public class WayLineBeginReplyCmd extends BaseCmd {
private final byte encryptFlag = 0x00; // 加密标志
diff --git a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineEndReplyCmd.java b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineEndReplyCmd.java
index 96cf448..56a9120 100644
--- a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineEndReplyCmd.java
+++ b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineEndReplyCmd.java
@@ -2,6 +2,7 @@
import com.ard.tianyu.netty.command.BaseCmd;
import io.netty.buffer.ByteBuf;
+import lombok.Data;
/**
* 结束航线回复指令
@@ -9,6 +10,7 @@
* @author liusuyi
* @date 2024年10月30日16:20
**/
+@Data
public class WayLineEndReplyCmd extends BaseCmd {
private final byte encryptFlag = 0x00; // 加密标志
diff --git a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLinePauseReplyCmd.java b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLinePauseReplyCmd.java
index a3523a9..693e722 100644
--- a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLinePauseReplyCmd.java
+++ b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLinePauseReplyCmd.java
@@ -2,6 +2,7 @@
import com.ard.tianyu.netty.command.BaseCmd;
import io.netty.buffer.ByteBuf;
+import lombok.Data;
/**
* 暂停航线回复指令
@@ -9,6 +10,7 @@
* @author liusuyi
* @date 2024年10月30日16:20
**/
+@Data
public class WayLinePauseReplyCmd extends BaseCmd {
private final byte encryptFlag = 0x00; // 加密标志
diff --git a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineResumeReplyCmd.java b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineResumeReplyCmd.java
index d226e47..7ebf458 100644
--- a/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineResumeReplyCmd.java
+++ b/ard-work/src/main/java/com/ard/tianyu/netty/command/wayline/WayLineResumeReplyCmd.java
@@ -2,6 +2,7 @@
import com.ard.tianyu.netty.command.BaseCmd;
import io.netty.buffer.ByteBuf;
+import lombok.Data;
/**
* 恢复航线回复指令
@@ -9,6 +10,7 @@
* @author liusuyi
* @date 2024年10月30日16:20
**/
+@Data
public class WayLineResumeReplyCmd extends BaseCmd {
private final byte encryptFlag = 0x00; // 加密标志
diff --git a/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java b/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java
index fd8ae57..40b7338 100644
--- a/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java
+++ b/ard-work/src/main/java/com/ard/tianyu/service/impl/TyServiceImpl.java
@@ -684,6 +684,26 @@
WayLineUploadReplyCmd wayLineUploadReplyCmd = (WayLineUploadReplyCmd) tyCommand;
logPrint("上传航线", wayLineUploadReplyCmd.getResult(), wayLineUploadReplyCmd.getErrorCode());
}
+ //开始航线回复
+ if (tyCommand instanceof WayLineBeginReplyCmd) {
+ WayLineBeginReplyCmd wayLineBeginReplyCmd = (WayLineBeginReplyCmd) tyCommand;
+ logPrint("上传航线", wayLineBeginReplyCmd.getResult(), wayLineBeginReplyCmd.getErrorCode());
+ }
+ //暂停航线回复
+ if (tyCommand instanceof WayLinePauseReplyCmd) {
+ WayLinePauseReplyCmd wayLinePauseReplyCmd = (WayLinePauseReplyCmd) tyCommand;
+ logPrint("上传航线", wayLinePauseReplyCmd.getResult(), wayLinePauseReplyCmd.getErrorCode());
+ }
+ //恢复航线回复
+ if (tyCommand instanceof WayLineResumeReplyCmd) {
+ WayLineResumeReplyCmd wayLineResumeReplyCmd = (WayLineResumeReplyCmd) tyCommand;
+ logPrint("上传航线", wayLineResumeReplyCmd.getResult(), wayLineResumeReplyCmd.getErrorCode());
+ }
+ //结束航线回复
+ if (tyCommand instanceof WayLineEndReplyCmd) {
+ WayLineEndReplyCmd wayLineEndReplyCmd = (WayLineEndReplyCmd) tyCommand;
+ logPrint("上传航线", wayLineEndReplyCmd.getResult(), wayLineEndReplyCmd.getErrorCode());
+ }
break;
default:
// 处理其他消息
--
Gitblit v1.9.3