package com.fzzy.igds.io.notify;
|
|
import com.fzzy.igds.constant.GrainFrequence;
|
import com.fzzy.igds.constant.OrderRespEnum;
|
import com.fzzy.igds.domain.Depot;
|
import com.fzzy.igds.domain.DepotConf;
|
import com.fzzy.igds.domain.Grain;
|
import com.fzzy.igds.domain.WeatherInfo;
|
import com.fzzy.igds.io.order.ExeOrderService;
|
import com.fzzy.igds.request.ExeBaseRequest;
|
import com.fzzy.igds.service.GrainService;
|
import com.fzzy.igds.service.WeatherService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
@Slf4j
|
@Component
|
public class NotifyGrainInvokerImpl extends NotifyWebParent implements NotifyGrainInvoker {
|
|
@Resource
|
private GrainService grainService;
|
@Resource
|
private ExeOrderService exeRequestService;
|
@Resource
|
private WeatherService weatherService;
|
|
@Override
|
public String analysisSuccess(Grain grain, DepotConf depotConf, Depot depot, boolean isNotifyWeb, ExeBaseRequest exeRequest) {
|
grain = addWeatherInfo(grain);
|
try {
|
// 如果是一日多次
|
if (null == depotConf) {
|
grainService.saveOrUpdateGrain(grain, null);
|
} else {
|
if (depotConf.getGrainFreq().equals(
|
GrainFrequence.FREQ_01.getCode())) {
|
grainService.saveOrUpdateGrain(grain, null);
|
} else {
|
grainService.saveOrUpdateGrain(grain, null);
|
}
|
}
|
String notifyMsg = depot.getName() + " 粮情采集并解析成功，批次号=" + grain.getBatchId();
|
//完成
|
exeRequest.setExeMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_SUCCESS, "grain", notifyMsg);
|
|
log.info(depot.getName() + "粮情解析成功:" + grain.getBatchId());
|
|
} catch (Exception e) {
|
String notifyMsg = depot.getName() + "-保存失败，请勿2分钟内重复采集";
|
//完成
|
exeRequest.setErrorMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_ERROR, "grain", notifyMsg);
|
log.error(depot.getName() + "粮情解析保存失败：" + e);
|
}
|
return null;
|
}
|
|
@Override
|
public String analysisSuccess(Grain grain, Depot depot) {
|
grain = addWeatherInfo(grain);
|
|
try {
|
grainService.saveOrUpdateGrain(grain,null);
|
|
String notifyMsg = depot.getName() + " 收到推送粮情信息并解析成功，批次号=" + grain.getBatchId();
|
|
notifyWeb(grain.getCompanyId(), OrderRespEnum.MSG_SUCCESS, "grain", notifyMsg);
|
|
} catch (Exception e) {
|
String notifyMsg = depot.getName() + "-保存失败，请勿2分钟内重复采集";
|
this.notifyWeb(grain.getCompanyId(), OrderRespEnum.MSG_ERROR, "grain", notifyMsg);
|
|
log.error("粮情解析保存失败：" + e);
|
return notifyMsg;
|
}
|
return null;
|
}
|
|
@Override
|
public String analysisSuccess(Grain grain, Depot depot, ExeBaseRequest exeRequest) {
|
|
grain = addWeatherInfo(grain);
|
try {
|
grainService.saveOrUpdateGrain(grain,null);
|
|
String notifyMsg = exeRequest.getDepotName() + " 粮情采集并解析成功，批次号=" + grain.getBatchId();
|
|
//完成
|
exeRequest.setExeMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
} catch (Exception e) {
|
String notifyMsg = exeRequest.getDepotName() + "-保存失败，请勿2分钟内重复采集";
|
//完成
|
exeRequest.setErrorMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
return notifyMsg;
|
}
|
return null;
|
}
|
|
@Override
|
public String analysisSuccess(Grain grain, Depot depot, ExeBaseRequest exeRequest, DepotConf depotConf) {
|
|
grain = addWeatherInfo(grain);
|
try {
|
grainService.saveOrUpdateGrain(grain,null);
|
|
String notifyMsg = exeRequest.getDepotName() + " 粮情采集并解析成功，批次号=" + grain.getBatchId();
|
|
//完成
|
exeRequest.setExeMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_SUCCESS, "grain", notifyMsg);
|
log.info(depot.getName() + "粮情解析成功:" + grain.getBatchId());
|
} catch (Exception e) {
|
String notifyMsg = exeRequest.getDepotName() + "-保存失败，请勿2分钟内重复采集";
|
|
//完成
|
exeRequest.setErrorMsg(notifyMsg);
|
exeRequestService.completeCache(exeRequest, false);
|
|
notifyWeb(depotConf.getCompanyId(), OrderRespEnum.MSG_ERROR, "grain", notifyMsg);
|
|
log.error(depot.getName() + "粮情解析保存失败：" + 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;
|
}
|
|
}
|
