productDev/parkBike.git

package org.yzh.client;
 
import io.github.yezhihao.netmc.core.annotation.Endpoint;
import io.github.yezhihao.netmc.core.annotation.Mapping;
import io.github.yezhihao.netmc.session.Session;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.yzh.protocol.basics.JTMessage;
import org.yzh.protocol.commons.JT808;
import org.yzh.protocol.t808.*;
 
import java.util.concurrent.atomic.AtomicInteger;
 
import static org.yzh.protocol.commons.JT808.*;
 
/**
 * @author yezhihao
 * https://gitee.com/yezhihao/jt808-server
 */
@Endpoint
public class JTClientEndpoint {
 
    private static final Logger log = LoggerFactory.getLogger(JTClientEndpoint.class);
 
    private AtomicInteger serialNo = new AtomicInteger();
 
    private String mobileNo = "12345678901";
 
    @Mapping(types = 平台通用应答, desc = "平台通用应答")
    public void 平台通用应答(T0001 message) {
    }
 
    @Mapping(types = 服务器补传分包请求, desc = "服务器补传分包请求")
    public T0001 服务器补传分包请求(T8003 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 查询服务器时间应答, desc = "查询服务器时间应答")
    public T0001 查询服务器时间应答(T8004 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 终端注册应答, desc = "终端注册应答")
    public T0001 终端注册应答(T8100 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 设置终端参数, desc = "设置终端参数")
    public T0001 设置终端参数(T8103 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 查询终端参数, desc = "查询终端参数")
    public T0001 查询终端参数(JTMessage message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 终端控制, desc = "终端控制")
    public T0001 终端控制(T8105 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 查询指定终端参数, desc = "查询指定终端参数")
    public T0001 查询指定终端参数(T8106 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 查询终端属性, desc = "查询终端属性")
    public T0107 查询终端属性(JTMessage message) {
        T0107 result = ClientTest.T0107_0500(message );
        return result;
    }
 
    @Mapping(types = 下发终端升级包, desc = "下发终端升级包")
    public T0001 下发终端升级包(T8108 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
  /*    @Mapping(types = 位置信息查询, desc = "位置信息查询")
      public T0200 位置信息查询(JTMessage message ) {
          return ClientTest.T0200(message.getClientId() ,message.getSerialNo());
      }*/
     @Mapping(types = 位置信息查询, desc = "位置信息查询")
     public T0201_0500 位置信息查询(JTMessage message ) {
          return ClientTest.T0201_0500(message);
      }
    @Mapping(types = {位置信息查询应答, 车辆控制应答}, desc = "位置信息查询应答/车辆控制应答")
    public void T0201_0500(T0201_0500 message, Session session) {
        session.response(message);
    }
    @Mapping(types = 临时位置跟踪控制, desc = "临时位置跟踪控制")
    public T0001 临时位置跟踪控制(T8202 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 人工确认报警消息, desc = "人工确认报警消息")
    public T0001 人工确认报警消息(T8203 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 服务器向终端发起链路检测请求, desc = "服务器向终端发起链路检测请求")
    public T0001 服务器向终端发起链路检测请求(JTMessage message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 文本信息下发, desc = "文本信息下发")
    public T0001 文本信息下发(T8300 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 事件设置, desc = "事件设置")
    public T0001 事件设置(T8301 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 提问下发, desc = "提问下发")
    public T0001 提问下发(T8302 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 信息点播菜单设置, desc = "信息点播菜单设置")
    public T0001 信息点播菜单设置(T8303 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 信息服务, desc = "信息服务")
    public T0001 信息服务(T8304 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 电话回拨, desc = "电话回拨")
    public T0001 电话回拨(T8400 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 设置电话本, desc = "设置电话本")
    public T0001 设置电话本(T8401 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 车辆控制, desc = "车辆控制")
    public T0001 车辆控制(T8500 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = {删除圆形区域, 删除矩形区域, 删除多边形区域, 删除路线,}, desc = "删除圆形区域")
    public T0001 删除圆形区域(T8601 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 设置圆形区域, desc = "设置圆形区域")
    public T0001 设置圆形区域(T8600 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
 
    @Mapping(types = 设置矩形区域, desc = "设置矩形区域")
    public T0001 设置矩形区域(T8602 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 设置多边形区域, desc = "设置多边形区域")
    public T0001 设置多边形区域(T8604 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 设置路线, desc = "设置路线")
    public T0001 设置路线(T8606 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 查询区域或线路数据, desc = "查询区域或线路数据")
    public T0001 查询区域或线路数据(T8608 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 行驶记录仪数据采集命令, desc = "行驶记录仪数据采集命令")
    public T0001 行驶记录仪数据采集命令(JTMessage message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 行驶记录仪参数下传命令, desc = "行驶记录仪参数下传命令")
    public T0001 行驶记录仪参数下传命令(T8701 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 上报驾驶员身份信息请求, desc = "上报驾驶员身份信息请求")
    public T0001 上报驾驶员身份信息请求(JTMessage message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 多媒体数据上传应答, desc = "多媒体数据上传应答")
    public T0001 多媒体数据上传应答(T8800 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 摄像头立即拍摄命令, desc = "摄像头立即拍摄命令")
    public T0001 摄像头立即拍摄命令(T8801 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 存储多媒体数据检索, desc = "存储多媒体数据检索")
    public T0001 存储多媒体数据检索(T8802 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 存储多媒体数据上传, desc = "存储多媒体数据上传")
    public T0001 存储多媒体数据上传(T8803 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 录音开始命令, desc = "录音开始命令")
    public T0001 录音开始命令(T8804 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 单条存储多媒体数据检索上传命令, desc = "单条存储多媒体数据检索上传命令")
    public T0001 单条存储多媒体数据检索上传命令(T8805 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 数据下行透传, desc = "数据下行透传")
    public T0001 数据下行透传(T8900 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
 
    @Mapping(types = 平台RSA公钥, desc = "平台RSA公钥")
    public T0001 平台RSA公钥(T0A00_8A00 message) {
        T0001 result = buildResult(message, T0001.Success);
        return result;
    }
    private T0107 buildResult107(JTMessage message ) {
        T0107 result = new T0107();
        result.copyBy(message);
        result.setMessageId(JT808.查询终端属性应答);
        result.setClientId(mobileNo);
        result.setSerialNo(serialNo.addAndGet(1));
        result.setDeviceType(2);
        return result;
    }
    private T0001 buildResult(JTMessage message, int resultCode) {
        T0001 result = new T0001();
        result.copyBy(message);
        result.setMessageId(JT808.终端通用应答);
        result.setClientId(mobileNo);
        result.setSerialNo(serialNo.addAndGet(1));
 
        result.setResponseSerialNo(message.getSerialNo());
        result.setResponseMessageId(message.getMessageId());
        result.setResultCode(resultCode);
        return result;
    }
}