1078-终端上传乘客流量

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
+                ;
+    }
+}

src/main/java/com/genersoft/iot/vmp/jt1078/controller/JT1078Controller.java

@@ -914,5 +914,9 @@ public class JT1078Controller {
     ) {
         return service.queryMediaAttribute(deviceId);
     }
+
+    // TODO 视频报警上报
+
+
 }
 

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;
+    }
+}