package com.dy.rtuMw.server.rtuData.pSdV1;
|
|
import com.dy.common.mw.protocol4Mqtt.MqttSubMsg;
|
import com.dy.common.mw.protocol4Mqtt.pSdV1.upVos.SoilVo;
|
import com.dy.common.util.DateTime;
|
import com.dy.pipIrrGlobal.pojoPr.PrStSoil;
|
import com.dy.pipIrrGlobal.pojoRm.RmSoilDay;
|
import com.dy.pipIrrGlobal.pojoRm.RmSoilHistory;
|
import com.dy.pipIrrGlobal.pojoRm.RmSoilLast;
|
import com.dy.rtuMw.server.rtuData.TaskSurpport;
|
import com.dy.rtuMw.server.rtuData.dbSv.DbSv;
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2025/6/25 11:38
|
* @Description
|
*/
|
public class TkDealSoilSdV1 extends TaskSurpport {
|
|
private static Logger log = LogManager.getLogger(TkDealSoilSdV1.class.getName());
|
|
//类ID，一定与Tree.xml配置文件中配置一致
|
public static final String taskId = "TkDealSoilSdV1";
|
|
/**
|
* 执行节点任务
|
*
|
* @param data 需要处理的数据
|
*/
|
@Override
|
public void execute(Object data) {
|
//前面的任务已经判断了data不为空且为墒情数据
|
MqttSubMsg msg = (MqttSubMsg) data;
|
SoilVo stVo = (SoilVo) msg.vo4Up;
|
Object[] objs = this.getTaskResults(TkPreGenObjs4SoilSdV1.taskId);
|
DbSv sv = (DbSv) objs[0];
|
PrStSoil stPo = (PrStSoil) objs[1];
|
try{
|
this.doDeal(sv, stPo, msg, stVo);
|
}catch (Exception e){
|
log.error("保存墒情数据时发生异常", e);
|
}
|
}
|
|
/**
|
* 处理上行消息数据
|
* @param sv 服务
|
* @param stPo 实体对象
|
* @param msg 上行的订阅消息
|
* @param stVo 上行的设备数据
|
*/
|
private void doDeal(DbSv sv,
|
PrStSoil stPo,
|
MqttSubMsg msg,
|
SoilVo stVo) throws Exception {
|
RmSoilHistory hpo = this.saveHistory(sv, stPo, msg, stVo);
|
this.saveOrUpdateLast(sv, stPo, msg, stVo, hpo);
|
this.saveOrUpdateDay(sv, stPo, msg, stVo, hpo);
|
}
|
|
/**
|
* 处理上行消息数据
|
* @param sv 服务
|
* @param stPo 实体对象
|
* @param msg 上行的订阅消息
|
* @param stVo 上行的设备数据
|
* @param hpo 历史记录最新数据
|
*/
|
private void saveOrUpdateLast(DbSv sv,
|
PrStSoil stPo,
|
MqttSubMsg msg,
|
SoilVo stVo,
|
RmSoilHistory hpo) throws Exception {
|
RmSoilLast po = sv.getRmSoilLast(stPo.id) ;
|
if(po == null){
|
po = new RmSoilLast();
|
po.valueFrom(msg, stVo);
|
po.soilId = stPo.id ;
|
po.lastHistoryId = hpo==null?null:hpo.id ;
|
sv.saveRmSoilLast(po) ;
|
}else{
|
po.valueFrom(msg, stVo);
|
po.soilId = stPo.id ;
|
po.lastHistoryId = hpo==null?null:hpo.id ;
|
sv.updateRmSoilLast(po);
|
}
|
}
|
|
/**
|
* 处理上行消息数据
|
* @param sv 服务
|
* @param stPo 实体对象
|
* @param msg 上行的订阅消息
|
* @param stVo 上行的设备数据
|
*/
|
private RmSoilHistory saveHistory(DbSv sv,
|
PrStSoil stPo,
|
MqttSubMsg msg,
|
SoilVo stVo) throws Exception {
|
RmSoilHistory po = new RmSoilHistory();
|
po.valueFrom(msg, stVo);
|
po.soilId = stPo.id ;
|
sv.saveRmSoilHistory(po);
|
return po ;
|
}
|
/**
|
* 处理上行消息数据
|
* @param sv 服务
|
* @param stPo 实体对象
|
* @param msg 上行的订阅消息
|
* @param stVo 上行的设备数据
|
* @param hpo 历史记录最新数据
|
*/
|
private void saveOrUpdateDay(DbSv sv,
|
PrStSoil stPo,
|
MqttSubMsg msg,
|
SoilVo stVo,
|
RmSoilHistory hpo) throws Exception {
|
RmSoilDay po = sv.getRmSoilDay(stPo.id, Integer.parseInt(DateTime.yyyyMMdd())) ;
|
if(po == null){
|
po = new RmSoilDay();
|
po.valueFrom(msg, stVo);
|
po.soilId = stPo.id ;
|
sv.saveRmSoilDay(po) ;
|
}else{
|
po.updateFrom(msg, stVo);
|
po.soilId = stPo.id ;
|
sv.updateRmSoilDay(po);
|
}
|
}
|
}
|
