package com.ld.igds.protocol.es.dlt645.analysis;
|
|
import com.ld.igds.common.CoreSerService;
|
import com.ld.igds.constant.RedisConst;
|
import com.ld.igds.es.dto.EsData;
|
import com.ld.igds.es.service.CoreEsService;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.protocol.es.dlt645.util.Dlt645Utils;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import java.util.Date;
|
|
/**
|
* DLT645电表协议解析
|
*
|
* @author czt
|
*/
|
@Slf4j
|
@Component(AnalysisService.BEAN_ID)
|
public class AnalysisService {
|
|
|
public static final String BEAN_ID = "dlt645.analysisService";
|
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private CoreSerService coreSerService;
|
@Autowired
|
private CoreEsService esService;
|
|
/**
|
*
|
* @param result
|
*/
|
public void analysis(String result){
|
log.info("能耗分机------->>平台：信息报文={}", result);
|
if(!result.startsWith(Dlt645Utils.MSG_START)){
|
log.error("能耗分机------->>平台，解析能耗失败：报文起始符错误，不解析");
|
return;
|
}
|
//去除起始符
|
result = result.substring(8);
|
//获取校验位
|
String oldCheck = result.substring(result.length() - 4, result.length() - 2);
|
String check = Dlt645Utils.makeCheck(result.substring(0, result.length() - 4));
|
|
if(!check.equals(oldCheck)){
|
log.error("能耗分机------->>平台，解析能耗失败：校验位不对，不解析");
|
return;
|
}
|
analysisGrain(result);
|
}
|
|
|
private void analysisGrain(String result) {
|
try {
|
|
//获取能耗分机地址
|
String serId = Dlt645Utils.addrToString(result.substring(2, 14));
|
|
//根据分机地址获取分机信息
|
DeviceSer ser = coreSerService.getCacheSer(ContextUtil.getDefaultCompanyId(), serId);
|
if (ser == null) {
|
log.error("能耗分机-------->>平台，解析能耗失败，未获取到系统能耗主机配置：" + serId);
|
return;
|
}
|
|
String key = RedisConst.buildKey(ser.getCompanyId(), "ES-DLT645", ser.getId());
|
String depotId = (String) redisUtil.get(key);
|
if(null == depotId){
|
log.error("能耗分机-------->>平台，解析能耗失败，未获取到仓库信息：" + depotId);
|
return;
|
}
|
|
//解析总能耗数据
|
String dataStr = result.substring(28, 36);
|
|
Double esNum = Dlt645Utils.parseData(dataStr);
|
EsData esData = new EsData();
|
esData.setDeviceName("电表");
|
esData.setCompanyId(ser.getCompanyId());
|
esData.setDepotId(depotId);
|
esData.setUpdateTime(new Date());
|
|
esData.setEp(esNum);
|
esData.setEs(esNum);
|
|
log.info("DLT645电表----->>>平台：能耗数据解析完成-仓库={}", esData.getDepotId());
|
esService.saveAndUpdateInc(esData);
|
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
}
|
}
|
}
|
