package com.fzzy.protocol.zldz.analysis;
|
|
import com.fzzy.api.utils.BytesUtil;
|
import com.fzzy.gateway.entity.GatewayDevice;
|
import com.fzzy.gateway.service.GatewayDeviceService;
|
import com.fzzy.protocol.zldz.data.ReMessage;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @author vince
|
*/
|
@Slf4j
|
@Component(AnalysisConf.BEAN_ID)
|
public class AnalysisConf {
|
|
public static final String BEAN_ID = "zldz.analysisConf";
|
|
@Resource
|
private GatewayDeviceService gatewayDeviceService;
|
|
/**
|
* 解析分机配置信息
|
*
|
* @param message
|
* @param ser
|
*/
|
public void analysis8816(ReMessage message, GatewayDevice ser) {
|
|
log.debug("分机---->>>平台：消息类型=8816-----{}", ser.getDeviceName());
|
|
String content = message.getBody().getContent();
|
|
// 读写标志
|
int start = 0, len = 1;
|
String temp = content.substring(start * 2, start * 2 + len * 2);
|
int readTag = BytesUtil.hexToInt(temp);
|
|
// 设备ID，全局唯一
|
start = 1;
|
len = 2;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
|
// 网络ID
|
start = 3;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
|
// 信道
|
start = 4;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
|
// 速率
|
start = 5;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
|
// 层数
|
String cable = "";
|
start = 6;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
cable += BytesUtil.hexToInt(temp);
|
|
// 行数
|
start = 7;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
cable += "-" + BytesUtil.hexToInt(temp);
|
|
// 列数
|
start = 8;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
cable += "-" + BytesUtil.hexToInt(temp);
|
|
//层 - 行 - 列 配置
|
ser.setCableRule(cable);
|
|
// 电缆制式
|
start = 9;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
ser.setCableFormat("0" + BytesUtil.hexToInt(temp));
|
|
// 电缆类型
|
start = 10;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
ser.setCableType("0" + BytesUtil.hexToInt(temp));
|
|
// 供电模式
|
start = 11;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
//ser.setPowerModel("0" + BytesUtil.hexToInt(temp));
|
|
String msg = ser.getDeviceName() + " 远程获取配置成功，请刷新数据查看！";
|
|
// 组织编码
|
start = 12;
|
temp = content.substring(start * 2);
|
if (readTag == 1) {// 表示写的成功返回
|
ser.setOrgId(ser.getOrgId());
|
msg = ser.getDeviceName() + " 远程写入成功，请刷新数据查看！";
|
} else {
|
ser.setOrgId(BytesUtil.hexToInt(BytesUtil.tran_LH(temp)) + "");
|
}
|
|
if (null == ser.getDeviceSn()) {
|
ser.setDeviceSn(ser.getId());
|
}
|
ser.setIp(message.getIp());
|
ser.setPort(message.getPort());
|
|
// 开始列默认=1
|
if (ser.getCableStart() == 0) {
|
ser.setCableStart(1);
|
}
|
|
log.info("分机---->>>平台：分机配置解析完成---{}，更新到服服务器",
|
ser.getDeviceName());
|
|
//更新设备信息
|
gatewayDeviceService.updateData(ser);
|
}
|
|
/**
|
* 电缆初始化成功
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
public void analysis8822(ReMessage reMessage, GatewayDevice ser) {
|
log.info("--------电缆初始化成功------------{}", ser.getDeviceName());
|
}
|
|
/**
|
* 电缆修改返回，
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
public void analysis8826(ReMessage reMessage, GatewayDevice ser) {
|
log.info("--------修改电缆信息返回------------{}", ser.getDeviceName());
|
}
|
|
/**
|
* 通道电缆获取返回，分机返回收到命令信息，实际返回值在8829中说明
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
public void analysis8825(ReMessage reMessage, GatewayDevice ser) {
|
log.info("--------通道电缆获取返回------------{}", ser.getDeviceName());
|
}
|
|
/**
|
* 终端发送通道电缆数据给后台，分机主动推送
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
@SuppressWarnings("unchecked")
|
public void analysis1129(ReMessage reMessage, GatewayDevice ser) {
|
log.info("--------终端发送通道电缆数据给后台------------{}", ser.getDeviceName());
|
}
|
|
/**
|
* 电缆汇总应答
|
*
|
* @param reMessage
|
* @param ser
|
*/
|
public void analysis8823(ReMessage reMessage, GatewayDevice ser) {
|
// 开始解析
|
String content = reMessage.getBody().getContent();
|
|
//DO NOTHING
|
}
|
}
|
