From 5fc1000fcce3e2ac688110be1dbb1bb7ae725d1c Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Sun, 7 Apr 2024 06:56:39 +0800
Subject: [PATCH] =?UTF-8?q?1078-=E6=B7=BB=E5=8A=A0=E6=96=87=E4=BB=B6?=
 =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E5=AE=8C=E6=88=90=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/vmp/jt1078/proc/request/J1205.java    |  1 +
 .../iot/vmp/jt1078/proc/request/J1206.java    | 75 +++++++++++++++++++
 2 files changed, 76 insertions(+)
 create mode 100644 src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1206.java

diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1205.java b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1205.java
index d6b5d95a4..f7cbba246 100644
--- a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1205.java
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1205.java
@@ -50,6 +50,7 @@ public class J1205 extends Re {
 
     @Override
     protected Rs handler(Header header, Session session, Ijt1078Service service) {
+        // TODO 可能未处理分包的情况
         SessionManager.INSTANCE.response(header.getTerminalId(), "1205", (long) respNo, JSON.toJSONString(this));
         J8001 j8001 = new J8001();
         j8001.setRespNo(header.getSn());
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1206.java b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1206.java
new file mode 100644
index 000000000..e6079e5b2
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1206.java
@@ -0,0 +1,75 @@
+package com.genersoft.iot.vmp.jt1078.proc.request;
+
+import com.alibaba.fastjson2.JSON;
+import com.genersoft.iot.vmp.jt1078.annotation.MsgId;
+import com.genersoft.iot.vmp.jt1078.proc.Header;
+import com.genersoft.iot.vmp.jt1078.proc.response.J8001;
+import com.genersoft.iot.vmp.jt1078.proc.response.Rs;
+import com.genersoft.iot.vmp.jt1078.service.Ijt1078Service;
+import com.genersoft.iot.vmp.jt1078.session.Session;
+import com.genersoft.iot.vmp.jt1078.session.SessionManager;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufUtil;
+import org.springframework.context.ApplicationEvent;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 文件上传完成通知
+ *
+ */
+@MsgId(id = "1206")
+public class J1206 extends Re {
+    Integer respNo;
+
+    // 0：成功； 1：失败
+    private int result;
+
+    @Override
+    protected Rs decode0(ByteBuf buf, Header header, Session session) {
+        respNo = buf.readUnsignedShort();
+        result = buf.readUnsignedByte();
+        return null;
+    }
+
+    @Override
+    protected Rs handler(Header header, Session session, Ijt1078Service service) {
+        J8001 j8001 = new J8001();
+        j8001.setRespNo(header.getSn());
+        j8001.setRespId(header.getMsgId());
+        j8001.setResult(J8001.SUCCESS);
+        return j8001;
+    }
+
+
+    public Integer getRespNo() {
+        return respNo;
+    }
+
+    public void setRespNo(Integer respNo) {
+        this.respNo = respNo;
+    }
+
+    public int getResult() {
+        return result;
+    }
+
+    public void setResult(int result) {
+        this.result = result;
+    }
+
+
+    @Override
+    public String toString() {
+        return "J1206{" +
+                "respNo=" + respNo +
+                ", result=" + result +
+                '}';
+    }
+
+    @Override
+    public ApplicationEvent getEvent() {
+        return null;
+    }
+}