package com.ld.igds.protocol.zldz.analysis;
|
|
import com.ld.igds.common.dto.THDto;
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.order.ExeOrderService;
|
import com.ld.igds.order.data.ExeRequest;
|
import com.ld.igds.protocol.zldz.analysis.message.ReMessage;
|
import com.ld.igds.th.CoreThService;
|
import com.ld.igds.util.BytesUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
/**
|
* 解析温湿度信息
|
*
|
* @author Andy
|
*/
|
@Slf4j
|
@Component(AnalysisTH.BEAN_ID)
|
public class AnalysisTH {
|
|
public static final String BEAN_ID = "zldz.analysisTH";
|
|
@Autowired
|
private CoreThService thService;
|
|
@Autowired
|
private NotifyWebInvoker notifyWebInvoker;
|
|
@Autowired
|
private ExeOrderService exeOrderService;
|
|
public static int ERROR_TH_TAG = -50;
|
|
/**
|
* 解析仓库温湿度信息，将信息放在缓存中，以便粮情使用
|
*
|
* @param msg
|
* @param ser
|
*/
|
public void analysis8828(ReMessage msg, DeviceSer ser) {
|
|
log.debug("-----------analysis8828------------{}-{}.{}", ser.getCompanyId(), ser.getIp(), ser.getPort());
|
|
String content = msg.getBody().getContent();
|
|
//温湿度地址,截取4位
|
String temp = content.substring(0, 0 + 2 * 2);
|
//高低位转换
|
temp = BytesUtil.tran_LH(temp);
|
int thConf = BytesUtil.hexToInt(temp);
|
|
List<ExeRequest> list = exeOrderService.getInProgressOrderBySerId(BizType.SYS.getCode(), ser.getId() + "_" + thConf);
|
ExeRequest exeRequest = list.get(0);
|
|
int t, h;
|
|
THDto th = new THDto();
|
th.setCompanyId(ser.getCompanyId());
|
th.setTempIn(Constant.ERROR_TEMP);
|
th.setHumidityIn(Constant.ERROR_TEMP);
|
|
//温度
|
int start = 2, len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
t = BytesUtil.hexToInt(temp);
|
if (t > 127) {//说明是负数
|
t = BytesUtil.hexToInt("FF" + temp);
|
}
|
if (t == ERROR_TH_TAG) {
|
log.error("{}温湿度解析异常，原因：没有检测到传感器", ser.getName());
|
th.setRemark(ser.getName() + "温湿度解析异常，原因：没有检测到传感器");
|
} else {
|
th.setTempIn(Double.valueOf(t));
|
}
|
|
//湿度
|
start = 3;
|
len = 1;
|
temp = content.substring(start * 2, start * 2 + len * 2);
|
h = BytesUtil.hexToInt(temp);
|
if (h > 127) {//说明是负数
|
h = BytesUtil.hexToInt("FF" + temp);
|
}
|
if (h == ERROR_TH_TAG) {
|
log.error("{}温湿度解析异常，原因：没有检测到传感器", ser.getName());
|
th.setRemark(ser.getName() + "温湿度解析异常，原因：没有检测到传感器");
|
} else {
|
th.setHumidityIn(Double.valueOf(h));
|
}
|
|
th.setSerId(ser.getId());
|
if (null != exeRequest) {
|
th.setThConf(exeRequest.getThConf());
|
} else {
|
th.setThConf(thConf + "");
|
}
|
|
log.info("仓温仓湿解析完成={}", th.toString());
|
|
//按照分机采集来确定
|
thService.setCacheTH(th);
|
|
String info = ser.getName() + " 温湿度获取完成";
|
if (null != exeRequest) {
|
//完成
|
exeRequest.setMsg(info);
|
exeOrderService.completeCache(exeRequest, false);
|
}
|
notifyWebInvoker.notifyWeb(ser.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.SYS, info);
|
|
}
|
}
|
