package com.ld.igds.io.impl;
|
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.constant.GrainFrequence;
|
import com.ld.igds.grain.dto.GrainItemInfo;
|
import com.ld.igds.grain.service.CoreGrainService;
|
import com.ld.igds.io.constant.OrderRespEnum;
|
import com.ld.igds.io.notify.NotifyGrainInvoker;
|
import com.ld.igds.models.*;
|
import com.ld.igds.order.ExeOrderService;
|
import com.ld.igds.order.data.ExeRequest;
|
import com.ld.igds.weather.CoreWeatherService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
|
@Slf4j
|
@Component
|
public class NotifyGrainInvokerImpl extends NotifyWebParent implements NotifyGrainInvoker {
|
|
@Autowired
|
private CoreGrainService grainService;
|
@Autowired
|
private CoreWeatherService weatherService;
|
@Autowired
|
private ExeOrderService exeRequestService;
|
|
@Override
|
public String analysisSuccess(Grain grain, List<GrainItemInfo> listGrainItems, DepotConf depotConf, DicSysConf sysConf, boolean isNotifyWeb, ExeRequest exeRequest) {
|
grain = addWeatherInfo(grain);
|
try {
|
// 如果是一日多次
|
if (null == depotConf) {
|
grainService.saveGrain(grain);
|
} else {
|
if (depotConf.getGrainFreq().equals(
|
GrainFrequence.FREQ_01.getCode())) {
|
grainService.saveGrain(grain);
|
} else {
|
grainService.saveOrUpdateGrain(grain);
|
}
|
}
|
String notifyMsg = depotConf.getDepotName() + " 粮情采集并解析成功，批次号="
|
+ grain.getBatchId();
|
|
//完成
|
exeRequest.setMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.GRAIN, notifyMsg);
|
|
log.info(depotConf.getDepotName() + "粮情解析成功:" + grain.getBatchId());
|
|
// 采集点保存，采集点的异常信息不考虑在粮情内部，直接忽略
|
if (StringUtils.isNotEmpty(sysConf.getGrainAddPoint())
|
&& Constant.YN_Y.equals(sysConf.getGrainAddPoint())) {
|
grainService.addGrainItems(listGrainItems, grain);
|
|
}
|
} catch (Exception e) {
|
String notifyMsg = depotConf.getDepotName() + "-保存失败，请勿2分钟内重复采集";
|
|
//完成
|
exeRequest.setMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, true);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_ERROR, BizType.GRAIN, notifyMsg);
|
|
log.error(depotConf.getDepotName() + "粮情解析保存失败：" + e);
|
}
|
return null;
|
}
|
|
@Override
|
public String analysisSuccess(Grain grain, Depot depot, DicSysConf sysConf) {
|
grain = addWeatherInfo(grain);
|
|
try {
|
grainService.saveOrUpdateGrain(grain);
|
|
String notifyMsg = depot.getName() + " 收到推送粮情信息并解析成功，批次号=" + grain.getBatchId();
|
|
notifyWeb(grain.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.GRAIN, notifyMsg);
|
|
} catch (Exception e) {
|
String notifyMsg = depot.getName() + "-保存失败，请勿2分钟内重复采集";
|
this.notifyWeb(grain.getCompanyId(), OrderRespEnum.MSG_ERROR, BizType.GRAIN, notifyMsg);
|
|
log.error("粮情解析保存失败：" + e);
|
return notifyMsg;
|
}
|
return null;
|
}
|
|
@Override
|
public String analysisSuccess(Grain grain, ExeRequest exeRequest, DicSysConf sysConf) {
|
|
grain = addWeatherInfo(grain);
|
try {
|
grainService.saveOrUpdateGrain(grain);
|
|
String notifyMsg = exeRequest.getDepotName() + " 粮情采集并解析成功，批次号=" + grain.getBatchId();
|
|
//完成
|
exeRequest.setMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
} catch (Exception e) {
|
String notifyMsg = exeRequest.getDepotName() + "-保存失败，请勿2分钟内重复采集";
|
|
//完成
|
exeRequest.setMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, true);
|
|
return notifyMsg;
|
}
|
return null;
|
}
|
|
@Override
|
public String analysisSuccess(Grain grain, ExeRequest exeRequest, DepotConf depotConf, DicSysConf sysConf) {
|
|
grain = addWeatherInfo(grain);
|
try {
|
grainService.saveOrUpdateGrain(grain);
|
|
String notifyMsg = exeRequest.getDepotName() + " 粮情采集并解析成功，批次号=" + grain.getBatchId();
|
|
//完成
|
exeRequest.setMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_SUCCESS, BizType.GRAIN, notifyMsg);
|
log.info(depotConf.getDepotName() + "粮情解析成功:" + grain.getBatchId());
|
} catch (Exception e) {
|
String notifyMsg = exeRequest.getDepotName() + "-保存失败，请勿2分钟内重复采集";
|
|
//完成
|
exeRequest.setMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, true);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_ERROR, BizType.GRAIN, notifyMsg);
|
|
log.error(depotConf.getDepotName() + "粮情解析保存失败：" + e);
|
return notifyMsg;
|
}
|
return null;
|
}
|
|
|
// 从缓存中获取当前的外温度外部湿度
|
private Grain addWeatherInfo(Grain grain) {
|
if(grain.getHumidityOut() != null && grain.getTempOut() != null){
|
return grain;
|
}
|
WeatherInfo weatherInfo = weatherService.getCacheWeather(grain.getCompanyId());
|
Double tOut = -100.0, hOut = -100.0;
|
if (null != weatherInfo) {
|
if (weatherInfo.getTemp().indexOf("℃") > 0) {
|
weatherInfo.setTemp(weatherInfo.getTemp().replace("℃", ""));
|
}
|
if (weatherInfo.getHumidity().indexOf("%") > 0) {
|
weatherInfo.setHumidity(weatherInfo.getHumidity().replace("%",
|
""));
|
}
|
tOut = Double.valueOf(weatherInfo.getTemp());
|
hOut = Double.valueOf(weatherInfo.getHumidity());
|
grain.setWeather(weatherInfo.getWeather());
|
}
|
if(grain.getHumidityOut() == null || grain.getHumidityOut() == 0.0){
|
grain.setHumidityOut(hOut);
|
}
|
if(grain.getTempOut() == null || grain.getTempOut() == 0.0){
|
grain.setTempOut(tOut);
|
}
|
return grain;
|
}
|
|
}
|
