package com.ld.igds.protocol.fzzy.analysis;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.gas.CoreGasService;
|
import com.ld.igds.gas.dto.GasProgressData;
|
import com.ld.igds.io.notify.NotifyWebInvoker;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.models.DepotConf;
|
import com.ld.igds.models.DeviceSer;
|
import com.ld.igds.models.Gas;
|
import com.ld.igds.models.GasInfo;
|
import com.ld.igds.order.ExeOrderService;
|
import com.ld.igds.protocol.fzzy.ServerUtils;
|
import com.ld.igds.protocol.fzzy.command.BaseRemoteImpl;
|
import com.ld.igds.protocol.fzzy.dto.ReMessage;
|
import com.ld.igds.protocol.fzzy.dto.SendMessage;
|
import com.ld.igds.protocol.fzzy.req.Request2302;
|
import com.ld.igds.protocol.fzzy.req.Request2303;
|
import com.ld.igds.protocol.fzzy.req.RequestBody2303;
|
import com.ld.igds.protocol.fzzy.builder.SimpleCommandBuilder;
|
import com.ld.igds.util.ContextUtil;
|
|
import com.ld.igds.util.NumberUtil;
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 气体解析
|
*
|
* @author vince
|
*/
|
@Slf4j
|
@Component(AnalysisGas.BEAN_ID)
|
public class AnalysisGas extends BaseRemoteImpl {
|
|
public static final String BEAN_ID = "fzzy.analysisGas";
|
|
@Autowired
|
private CoreGasService gasService;
|
@Autowired
|
private CoreCommonService commonService;
|
|
@Autowired
|
private NotifyWebInvoker notifyInvoker;
|
|
public static Double ERROR_TAG = -1000.0;
|
public static Double ERROR_TAG2 = -2000.0;
|
|
public void analysis2301(ReMessage message, DeviceSer ser) {
|
//DO NOTHING
|
}
|
|
public void analysis2302(ReMessage reMessage, DeviceSer ser) {
|
//平台不反馈
|
|
//终端请求-返回的进度信息
|
Request2302 request = JSONObject.parseObject(reMessage.getContent(), Request2302.class);
|
|
GasProgressData gasProgress = new GasProgressData();
|
gasProgress.setCompanyId(ser.getCompanyId());
|
gasProgress.setCheckPoint(request.getPoint());
|
gasProgress.setSerId(ser.getId());
|
gasProgress.setDepotId(request.getHouseId());
|
gasProgress.setSumCheckNum(0);
|
|
DepotConf depotConf = commonService.getCacheDepotConf(
|
ser.getCompanyId(), request.getHouseId());
|
|
|
gasProgress.setMsg("气体检测进度：仓库：" + depotConf.getDepotName() + " 当前："
|
+ gasProgress.getCheckPoint());
|
|
notifyInvoker.notifyGasProgress(gasProgress);
|
}
|
|
public void analysis2303(ReMessage reMessage, DeviceSer ser) {
|
//平台反馈
|
SimpleCommandBuilder commandBuilder = SimpleCommandBuilder.getInstance();
|
SendMessage message = commandBuilder.buildMessage(ser, ServerUtils.FUNCTION_2303);
|
send(message);
|
|
//解析结果
|
Request2303 request2303 = JSONObject.parseObject(reMessage.getContent(), Request2303.class);
|
|
List<RequestBody2303> points = request2303.getPoints();
|
|
DepotConf depotConf = commonService.getCacheDepotConf(ser.getCompanyId(), request2303.getHouseId());
|
|
//主体信息
|
Gas gas = new Gas();
|
gas.setBatchId(request2303.getTime().substring(0, 12));
|
gas.setCheckNum(points.size());
|
gas.setCompanyId(ser.getCompanyId());
|
gas.setDepotId(request2303.getHouseId());
|
gas.setGasEnd(depotConf.getPestEnd());
|
gas.setGasStart(depotConf.getPestStart());
|
gas.setReceiveDate(new Date());
|
|
List<GasInfo> items = new ArrayList<>();
|
GasInfo info;
|
|
StringBuffer sb = new StringBuffer();
|
double sumO2 = 0.0, sumCo2 = 0.0, sumPh3 = 0.0, sumN2 = 0.0;
|
int index = 0;
|
for (RequestBody2303 point : points) {
|
info = new GasInfo();
|
info.setId(ContextUtil.buildInfoId(gas.getCompanyId(), gas.getDepotId(), gas.getBatchId()));
|
|
//调整错误码
|
if (point.getCo2() == ERROR_TAG || point.getCo2() == ERROR_TAG2) {
|
point.setCo2(Constant.ERROR_TEMP);
|
}
|
if (point.getO2() == ERROR_TAG || point.getO2() == ERROR_TAG2) {
|
point.setO2(Constant.ERROR_TEMP);
|
}
|
if (point.getPh3() == ERROR_TAG || point.getPh3() == ERROR_TAG2) {
|
point.setPh3(Constant.ERROR_TEMP);
|
}
|
if (point.getN2() == ERROR_TAG || point.getN2() == ERROR_TAG2) {
|
point.setN2(Constant.ERROR_TEMP);
|
}
|
|
info.setPassCode(point.getPoint());
|
info.setPerCo2(point.getCo2());
|
info.setPerO2(point.getO2());
|
info.setPerPh3(point.getPh3());
|
info.setPerN2(point.getN2());
|
items.add(info);
|
if(index == 0){
|
//添加最大值和最小值
|
gas.setPerCo2Max(info.getPerCo2());
|
gas.setPerCo2Min(info.getPerCo2());
|
gas.setPerO2Max(info.getPerO2());
|
gas.setPerO2Min(info.getPerO2());
|
gas.setPerPh3Max(info.getPerPh3());
|
gas.setPerPh3Min(info.getPerPh3());
|
gas.setPerN2Max(info.getPerN2());
|
gas.setPerN2Min(info.getPerN2());
|
}
|
sumO2 += info.getPerO2();
|
sumCo2 += info.getPerCo2();
|
sumPh3 += info.getPerPh3();
|
sumN2 += info.getPerN2();
|
index ++;
|
if (info.getPerCo2() > gas.getPerCo2Max()) {
|
gas.setPerCo2Max(info.getPerCo2());
|
}
|
if (info.getPerCo2() < gas.getPerCo2Min()) {
|
gas.setPerCo2Min(info.getPerCo2());
|
}
|
|
if (info.getPerO2() > gas.getPerO2Max()) {
|
gas.setPerO2Max(info.getPerO2());
|
}
|
|
if (info.getPerO2() < gas.getPerO2Min()) {
|
gas.setPerO2Min(info.getPerO2());
|
}
|
|
if (info.getPerPh3() > gas.getPerPh3Max()) {
|
gas.setPerPh3Max(info.getPerPh3());
|
}
|
|
if (info.getPerPh3() < gas.getPerPh3Min()) {
|
gas.setPerPh3Min(info.getPerPh3());
|
}
|
|
if (info.getPerN2() > gas.getPerN2Max()) {
|
gas.setPerN2Max(info.getPerN2());
|
}
|
|
if (info.getPerN2() < gas.getPerN2Min()) {
|
gas.setPerN2Min(info.getPerN2());
|
}
|
|
//固定为：passCode,co2,o2,ph3,n2;passCode,co2,o2,ph3,n2;"
|
sb.append(info.getPassCode());
|
sb.append(",");
|
sb.append(info.getPerCo2());
|
sb.append(",");
|
sb.append(info.getPerO2());
|
sb.append(",");
|
sb.append(info.getPerPh3());
|
sb.append(",");
|
sb.append(info.getPerN2());
|
sb.append(";");
|
}
|
gas.setPoints(sb.toString());
|
//计算平均值
|
if(index > 0){
|
gas.setPerCo2(NumberUtil.keepPrecision(sumCo2/index, 2));
|
gas.setPerO2(NumberUtil.keepPrecision(sumO2/index, 2));
|
gas.setPerN2(NumberUtil.keepPrecision(sumN2/index, 2));
|
gas.setPerPh3(NumberUtil.keepPrecision(sumPh3/index, 2));
|
}
|
|
gasService.saveInfoGas(items);
|
|
gasService.saveOrUpdateData(gas);
|
|
// 调用通知前端
|
notifyInvoker.notifyWeb(gas.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.GAS, depotConf.getDepotName() + " 气体检测：结果返回成功.");
|
|
log.info("控制柜----->>>平台：气体解析完成-仓库={}", depotConf.getDepotName());
|
}
|
|
public void analysis2304(ReMessage message, DeviceSer ser) {
|
//DO NOTHING
|
}
|
}
|
