From adfce4464d5150f7bfeadd12db0b6176f83f24dc Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Mon, 27 May 2024 23:55:44 +0800
Subject: [PATCH] =?UTF-8?q?1078-=E7=BB=88=E7=AB=AF=E4=B8=8A=E4=BC=A0?=
 =?UTF-8?q?=E4=B9=98=E5=AE=A2=E6=B5=81=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/vmp/jt1078/bean/JTPassengerNum.java   | 91 +++++++++++++++++++
 .../jt1078/controller/JT1078Controller.java   |  4 +
 .../iot/vmp/jt1078/proc/request/J1005.java    | 44 +++++++++
 3 files changed, 139 insertions(+)
 create mode 100644 src/main/java/com/genersoft/iot/vmp/jt1078/bean/JTPassengerNum.java
 create mode 100644 src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1005.java

diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/bean/JTPassengerNum.java b/src/main/java/com/genersoft/iot/vmp/jt1078/bean/JTPassengerNum.java
new file mode 100644
index 000000000..9f50ce669
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/bean/JTPassengerNum.java
@@ -0,0 +1,91 @@
+package com.genersoft.iot.vmp.jt1078.bean;
+
+import com.genersoft.iot.vmp.jt1078.bean.config.JTDeviceSubConfig;
+import com.genersoft.iot.vmp.jt1078.util.BCDUtil;
+import com.genersoft.iot.vmp.utils.DateUtil;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+
+/**
+ * 终端上传乘客流量
+ */
+public class JTPassengerNum implements JTDeviceSubConfig {
+
+    /**
+     * 起始时间, YY-MM-DD-HH-MM-SS( GMT + 8 时间,本标准中之后涉及的时间均采用此时区)
+     */
+    private String startTime;
+
+    /**
+     * 结束时间, YY-MM-DD-HH-MM-SS( GMT + 8 时间,本标准中之后涉及的时间均采用此时区)
+     */
+    private String endTime;
+
+    /**
+     * 上车人数
+     */
+    private int getIn;
+
+    /**
+     * 下车人数
+     */
+    private int getOut;
+
+    public String getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(String startTime) {
+        this.startTime = startTime;
+    }
+
+    public String getEndTime() {
+        return endTime;
+    }
+
+    public void setEndTime(String endTime) {
+        this.endTime = endTime;
+    }
+
+    public int getGetIn() {
+        return getIn;
+    }
+
+    public void setGetIn(int getIn) {
+        this.getIn = getIn;
+    }
+
+    public int getGetOut() {
+        return getOut;
+    }
+
+    public void setGetOut(int getOut) {
+        this.getOut = getOut;
+    }
+
+    @Override
+    public ByteBuf encode() {
+        return null;
+    }
+
+    public static JTPassengerNum decode(ByteBuf buf) {
+        JTPassengerNum jtPassengerNum = new JTPassengerNum();
+        byte[] bytes = new byte[6];
+        buf.readBytes(bytes);
+        jtPassengerNum.setStartTime(DateUtil.jt1078Toyyyy_MM_dd_HH_mm_ss(BCDUtil.transform(bytes)));
+        buf.readBytes(bytes);
+        jtPassengerNum.setEndTime(DateUtil.jt1078Toyyyy_MM_dd_HH_mm_ss(BCDUtil.transform(bytes)));
+        jtPassengerNum.setGetIn(buf.readUnsignedShort());
+        jtPassengerNum.setGetOut(buf.readUnsignedShort());
+        return jtPassengerNum;
+    }
+
+    @Override
+    public String toString() {
+        return "终端上传乘客流量：" +
+                " 时间： " + startTime + '到'  + endTime +
+                ", 上车：" + getIn +
+                ", 下车：" + getOut
+                ;
+    }
+}
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/controller/JT1078Controller.java b/src/main/java/com/genersoft/iot/vmp/jt1078/controller/JT1078Controller.java
index 89868af05..e8381491d 100644
--- a/src/main/java/com/genersoft/iot/vmp/jt1078/controller/JT1078Controller.java
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/controller/JT1078Controller.java
@@ -914,5 +914,9 @@ public class JT1078Controller {
     ) {
         return service.queryMediaAttribute(deviceId);
     }
+
+    // TODO 视频报警上报
+
+
 }
 
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1005.java b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1005.java
new file mode 100644
index 000000000..8a626df9e
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/J1005.java
@@ -0,0 +1,44 @@
+package com.genersoft.iot.vmp.jt1078.proc.request;
+
+import com.genersoft.iot.vmp.jt1078.annotation.MsgId;
+import com.genersoft.iot.vmp.jt1078.bean.JTMediaAttribute;
+import com.genersoft.iot.vmp.jt1078.bean.JTPassengerNum;
+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 org.springframework.context.ApplicationEvent;
+
+/**
+ * 终端上传乘客流量
+ *
+ */
+@MsgId(id = "1005")
+public class J1005 extends Re {
+
+    JTPassengerNum passengerNum;
+
+    @Override
+    protected Rs decode0(ByteBuf buf, Header header, Session session) {
+        passengerNum = JTPassengerNum.decode(buf);
+        System.out.println(passengerNum);
+        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;
+    }
+
+    @Override
+    public ApplicationEvent getEvent() {
+        return null;
+    }
+}