package com.fzzy.protocol.zldz.cmd;
|
|
import com.fzzy.api.Constant;
|
import com.fzzy.api.data.ApiCommonDevice;
|
import com.fzzy.api.utils.BytesUtil;
|
import com.fzzy.gateway.entity.GatewayDevice;
|
import com.fzzy.io.request.BaseRequest;
|
import com.fzzy.protocol.zldz.data.Message;
|
import com.fzzy.protocol.zldz.data.MessageBody;
|
import com.fzzy.protocol.zldz.server.ZldzServerUtil;
|
|
|
/**
|
* @author Andy
|
*/
|
public class CommandBuilder1116_1 extends CommandBuilder {
|
|
|
private final static CommandBuilder1116_1 instance = new CommandBuilder1116_1();
|
|
private CommandBuilder1116_1() {
|
|
}
|
|
public static CommandBuilder1116_1 getInstance() {
|
return instance;
|
}
|
|
public Message buildMessage(BaseRequest request, GatewayDevice device) {
|
|
Message message = new Message();
|
|
message.setBegin(ZldzServerUtil.MSG_START);
|
|
// 调整Message头部信息
|
buildHeader(message, request, device);
|
|
//包头校验
|
buildCrc8(message);
|
|
// 创建消息体
|
buildBody(message, request, device);
|
|
// 添加校验
|
buildCrc16(message);
|
|
message.setEnd(ZldzServerUtil.MSG_END);
|
|
// 生成整体命令信息和BYte信息
|
build(message);
|
|
return message;
|
}
|
|
public void buildHeader(Message message, BaseRequest request, GatewayDevice device) {
|
|
String hexCompanyId = BytesUtil.getTargetId(request.getCompanyId(), true);
|
hexCompanyId = BytesUtil.tran_LH(hexCompanyId);
|
|
message.setSourceId(hexCompanyId);
|
message.setSendId(hexCompanyId);
|
|
//发送的必须是原来的组织编码
|
String orgId = BytesUtil.tran_LH(BytesUtil.getTargetId(device.getOrgId(), true));
|
message.setCompanyId(orgId);
|
|
message.setTargetId(BytesUtil.tran_LH(BytesUtil.getTargetId(request.getSerId(), true)));
|
message.setMessageType(BytesUtil.tran_LH(ZldzServerUtil.MSG_TYPE_1116));
|
}
|
|
|
public void buildBody(Message message, BaseRequest request, GatewayDevice device) {
|
MessageBody body = new MessageBody();
|
StringBuffer content = new StringBuffer();
|
content.append("01");//写标记
|
content.append(message.getTargetId());
|
content.append(BytesUtil.getTargetId("01", false));//网络ID
|
content.append("0A");//默认10 信道
|
content.append(BytesUtil.getTargetId("03", false));//速率
|
|
ApiCommonDevice commonDevice = Constant.getCommonDeviceCacheByIp(device.getIp());
|
|
String cable = commonDevice.getCable();
|
if (null == cable) {
|
cable = device.getCableRule();
|
}
|
String[] attr = cable.split("-");
|
int z = Integer.valueOf(attr[0]);
|
int y = Integer.valueOf(attr[1]);
|
int x = Integer.valueOf(attr[2]);
|
|
content.append(BytesUtil.toHexString(z));
|
content.append(BytesUtil.toHexString(y));
|
content.append(BytesUtil.toHexString(x));
|
|
content.append(BytesUtil.getTargetId(device.getCableFormat(), false));
|
content.append(BytesUtil.getTargetId(device.getCableType(), false));
|
|
String powerModel = "02";
|
content.append(BytesUtil.getTargetId(powerModel, false));
|
|
content.append(message.getSourceId());
|
|
body.setContent(content.toString());
|
body.setLength(14);
|
message.setBody(body);
|
}
|
|
}
|
