package com.ld.igds.protocol.gps.analysis;
|
|
import com.ld.igds.io.notify.NotifyGpsMacService;
|
import com.ld.igds.oa.dto.GpsData;
|
import com.ld.igds.protocol.gps.RemoteGpsMacServiceImpl;
|
import com.ld.igds.protocol.gps.Gps808ServerEngine;
|
import com.ld.igds.protocol.utl.GpsUtils;
|
import com.ld.igds.util.BytesUtil;
|
import com.ld.io.api.InvokeResult;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 注册解析及应答
|
*/
|
@Slf4j
|
@Component(AnalysisRegisterInfo.BEAN_ID)
|
public class AnalysisRegisterInfo {
|
|
public static final String BEAN_ID = "gps.analysisRegisterInfo";
|
|
@Autowired
|
private NotifyGpsMacService notifyGpsMacService;
|
|
@Autowired
|
private RemoteGpsMacServiceImpl remoteGpsMacService;
|
|
/**
|
* 7E 01 00 00 31 01 38 20 03 63 16 00 02 00 00 00 00 00 00 00 00 00 46 32 30 30 28 46 4C 59 2D 44 72 53 70 29 2D 56 32 2E 39 33 30 30 33 36 33 31 36 31 31 33 2E 31 30 36 2E 39 33 2E 35 30 3A 7E(64)
|
* -------消息头-------
|
* 0100 消息ID
|
* 0031 消息体属性(转10进制为49，即消息体长度为49)
|
* 013820036316 手机号 (不进行解析，方便直接使用)
|
* 0002 消息流水号
|
* -------消息体-------
|
* 0000000000000000004632303028464C592D44725370
|
* 292D56322E3933303033363331363131332E3130362E
|
* 39332E3530
|
* 3A 校验码
|
*
|
* 注册消息解析
|
*
|
* @param ip
|
* @param port
|
* @param message
|
*/
|
public void analysisRegisterInfo(String ip, Integer port, String message) {
|
//01000031 013820036316 00020000000000000000004632303028464C592D44725370292D56322E3933303033363331363131332E3130362E39332E35303A
|
|
GpsData data = new GpsData();
|
//获取手机卡号(即SN)
|
String tempPhone = message.substring(8, 20);
|
data.setPhone(tempPhone);
|
data.setIp(ip);
|
data.setPort(port);
|
data.setName("GPS设备(SN:"+tempPhone+")");
|
//生成鉴权码，直接使用手机卡号作为鉴权码(不进行解析)
|
data.setSn(tempPhone);
|
data.setProtocol(remoteGpsMacService.getProtocol());
|
//注册信息更新到数据库和缓存
|
notifyGpsMacService.registerAndAuthNotify(data);
|
|
//注册应答
|
registerResponse(ip, port, message);
|
}
|
|
/**
|
* 注册应答回复鉴权码
|
* 注意<发送消息时：消息封装---计算并填充检验码---转义>
|
* @param ip
|
* @param port
|
* @param message
|
*/
|
private static void registerResponse(String ip, Integer port, String message) {
|
//0100 0031 013820036316 0002 0000000000000000004632303028464C592D44725370292D56322E3933303033363331363131332E3130362E39332E35303A
|
//应答：7E 81 00 00 09 01 38 20 03 63 16 00 02 00 02 00 01 38 20 03 63 16 88 7E
|
String msg = "";
|
//消息头信息(消息ID+消息体属性+手机卡号+注册消息流水号)
|
msg += GpsUtils.MSG_11;
|
msg += "0009";
|
msg += message.substring(8, 20);
|
msg += message.substring(20, 24);
|
|
//消息体信息(注册消息流水号+消息成功应答+鉴权码)
|
msg += message.substring(20, 24);
|
msg += "00";
|
msg += message.substring(8, 20);
|
|
//获取校验码
|
String checkCode = GpsUtils.checkCode(msg);
|
msg += checkCode;
|
|
//对消息整体转义：7D-->7D01,7E-->7D02
|
msg = GpsUtils.escapeCode1(msg);
|
|
//首尾添加标识符
|
msg = GpsUtils.addIdentifier(msg);
|
|
//注册应答
|
byte[] mess = BytesUtil.hexStrToBytes(msg);
|
InvokeResult result = Gps808ServerEngine.push(ip, port, mess);
|
|
log.debug("注册成功，发送应答结果：{}", result.toString());
|
}
|
}
|
