package com.fzzy.protocol.zldz.cmd;
|
|
import com.fzzy.api.data.ApiCommonDevice;
|
import com.fzzy.api.utils.BytesUtil;
|
import com.fzzy.api.utils.ContextUtil;
|
import com.fzzy.protocol.zldz.data.ReMessage;
|
import com.fzzy.protocol.zldz.data.ReMessageBody;
|
|
import java.util.Date;
|
|
/**
|
* 根据接收到的信息进行封装
|
*
|
* @author Andy
|
*/
|
public class ReMessageBuilder {
|
|
private final static ReMessageBuilder instance = new ReMessageBuilder();
|
|
private ReMessageBuilder() {
|
}
|
|
public static ReMessageBuilder getInstance() {
|
return instance;
|
}
|
|
/**
|
* 使用中发现CRC16可能以EE结尾，NETTY误以为是结尾导致截取少了一个EE，当前方法必须从头向后截取，保证CRC16的位置准确
|
*
|
* @param bytes
|
* @param device
|
* @param strMsg
|
* @return
|
*/
|
public ReMessage buildMessage(byte[] bytes, ApiCommonDevice device, String strMsg) {
|
|
ReMessage message = new ReMessage();
|
message.setIp(device.getIp());
|
message.setPort(device.getPort());
|
message.setStrMsg(strMsg);
|
message.setByteMsg(bytes);
|
|
// 源ID，分机唯一ID
|
int start = 2, len = 2;
|
String temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setSourceId(BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) + "");
|
|
//分机所属组织编码
|
String companyId = device.getOrgId();
|
|
// 目标ID
|
start = 4;
|
len = 2;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setTargetId(BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) + "");
|
|
// 发送ID
|
start = 6;
|
len = 2;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setSendId(BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) + "");
|
|
// 路由信息，不解析
|
|
// 消息类型
|
start = 12;
|
len = 2;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setMessageType(BytesUtil.tran_LH(temp));
|
|
// 处理结果
|
start = 14;
|
len = 1;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setResult(BytesUtil.hexToInt(temp));
|
|
// 组织编码
|
start = 15;
|
len = 2;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
if (null == companyId) {
|
message.setCompanyId(BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) + "");
|
} else {
|
message.setCompanyId(companyId);
|
}
|
|
//包头校验
|
start = 17;
|
len = 1;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setHexCrc8(temp);
|
|
// 命令体-长度
|
message.setBody(buildBody());
|
start = 18;
|
len = 2;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
int bodyLen = BytesUtil.hexToInt(BytesUtil.tran_LH(temp));
|
message.getBody().setLength(bodyLen);
|
|
//命令体-内容
|
start = 20;
|
len = bodyLen;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.getBody().setContent(temp);
|
|
// crc16验证
|
start = 20 + bodyLen;
|
len = 2;
|
temp = strMsg.substring(start * 2, start * 2 + len * 2);
|
message.setHexCrc16(temp);
|
|
message.setReceiveDate(new Date());
|
|
message.setBatchId(ContextUtil.getDefaultBatchId());
|
return message;
|
}
|
|
/**
|
* 创建BODY对象
|
*
|
* @param
|
* @return
|
*/
|
public ReMessageBody buildBody() {
|
ReMessageBody body = new ReMessageBody();
|
body.setLength(0);
|
body.setContent("");
|
return body;
|
}
|
}
|
