package com.dy.rtuMw.server.rtuData.p206V202404;
|
|
import com.dy.common.mw.protocol.Data;
|
import com.dy.common.mw.protocol.p206V202404.DataV202404;
|
import com.dy.common.mw.protocol.p206V202404.upVos.DataCd85Vo;
|
import com.dy.common.util.DateTime;
|
import com.dy.pipIrrGlobal.pojoPr.PrController;
|
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory;
|
import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast;
|
import com.dy.pipIrrGlobal.pojoSe.SeClient;
|
import com.dy.rtuMw.server.msCenter.MsCenterUnit;
|
import com.dy.rtuMw.server.msCenter.MsObj;
|
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 ZhuBaoMin
|
* @date 2024-06-20 13:48
|
* @LastEditTime 2024-06-20 13:48
|
* @Description
|
*/
|
public class TkDealCloseValveReportV202404 extends TaskSurpport {
|
private static final Logger log = LogManager.getLogger(TkDealCloseValveReportV202404.class.getName());
|
|
//类ID，一定与Tree.xml配置文件中配置一致
|
public static final String taskId = "TkDealCloseValveReportV202404";
|
|
/**
|
* 执行节点任务：关阀上报
|
*
|
* @param data 需要处理的数据
|
*/
|
@Override
|
public void execute(Object data) {
|
Data d = (Data) data;
|
DataV202404 dV202404 = (DataV202404) d.getSubData();
|
Object cdObj = dV202404.subData;
|
if (cdObj != null && cdObj instanceof DataCd85Vo) {
|
try {
|
Object[] objs = this.getTaskResults(TkPreGenObjsV202404.taskId);
|
DbSv sv = (DbSv) objs[0];
|
PrController controller = (PrController) objs[1];
|
SeClient clientVo = (SeClient)objs[3] ;//这个值对象中只有id和name会有值
|
this.toMsCenter(clientVo, controller, d.getRtuAddr(), dV202404, (DataCd85Vo)cdObj) ;
|
this.doDeal(sv, clientVo, controller, d.getRtuAddr(), dV202404, (DataCd85Vo)cdObj);
|
} catch (Exception e) {
|
log.error("保存控制器开阀报数据时发生异常", e);
|
}
|
}
|
}
|
|
/**
|
* 把开阀消息存入消息中心
|
* @param clientVo
|
* @param controller
|
* @param rtuAddr
|
* @param dV202404
|
* @param dataCd85Vo
|
*/
|
private void toMsCenter(SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dV202404, DataCd85Vo dataCd85Vo){
|
if(clientVo != null && controller != null){
|
MsObj msObj = new MsObj() ;
|
msObj.put("name", "关阀");
|
msObj.put("clientId", clientVo.getId());
|
msObj.put("clientName", clientVo.getName());
|
msObj.put("clientAddress", clientVo.getAddress());
|
msObj.put("icCardNo", dataCd85Vo.icCardNo);
|
msObj.put("rtuAddr", rtuAddr);
|
msObj.put("intakeId", controller.getIntakeId());
|
msObj.put("dt", dV202404.dt);
|
MsCenterUnit.getInstance().pushMs(msObj);
|
}
|
}
|
|
/**
|
* 保存数据
|
* @param sv 服务
|
* @param clientVo 农户对象（不为空时，只有id和name有值）
|
* @param controller 控制器对象
|
* @param rtuAddr 控制器地址
|
* @param dV202404 上报数据
|
* @param dataCd85Vo 关阀上报数据对象
|
*/
|
private void doDeal(DbSv sv, SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dV202404, DataCd85Vo dataCd85Vo) throws Exception {
|
RmOpenCloseValveLast poLast = sv.getRmOpenCloseValveLast(controller.getIntakeId()) ;
|
if(poLast == null){
|
//数据库中不存在该控制器的开关阀数据
|
//首先生成最新数据及历史数据，并先保存
|
poLast = this.newRmOpenCloseValveLast(clientVo, controller, rtuAddr, dV202404, dataCd85Vo);
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
|
//保存最新数据
|
sv.saveRmOpenCloseValveLast(poLast);
|
}else{
|
//数据库中存在该控制器的开关阀数据
|
if(poLast.closeDt != null && poLast.clIcCardAddr != null && poLast.clIcCardNo != null){
|
if(poLast.closeDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.endDt))
|
&& poLast.clIcCardAddr.equals(dataCd85Vo.icCardAddr)
|
&& poLast.clIcCardNo.equals(dataCd85Vo.icCardNo)){
|
//重复上报，原因是下行数据处理慢了，就重复上报了
|
return ;
|
}
|
}
|
if(poLast.clType == null){
|
//原记录不存在关阀数据，所以当前关阀上报是新的一次关阀
|
if(poLast.opType == null || poLast.openDt == null){
|
//原记录中不存在开阀数据(即开阀与关阀数据都没有，这种情况一般不存在)，没办法进行匹配
|
//生成并保存新的关阀上报历史数据记录
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
|
}else{
|
//原记录中存在开阀数据，进行历史数据匹配
|
RmOpenCloseValveHistory poHistory = null ;
|
if(poLast.lastHistoryId != null){
|
poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ;
|
if(poHistory != null){
|
if(poHistory.openDt != null){
|
//上面已经判断了poLast.openDt == null，所以此处一般会是poHistory.openDt != null
|
if(poHistory.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
|
//匹配成功
|
//当前关阀是原记录中开阀的对应关阀
|
this.updateCloseValve(clientVo, controller, poLast, poHistory, dV202404, dataCd85Vo, false) ;
|
sv.updateRmOpenCloseValveHistory(poHistory);
|
}else if(poHistory.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
|
//匹配失败(对于after:等于或晚于都返回true)
|
//本地最新数据中的开阀时间晚于当前关阀上报中的开阀时间，说明是补报
|
this.dealSupplyReport() ;
|
}else{
|
//匹配失败
|
//本地最新数据中的开阀时间早于当前关阀上报中的开阀时间，说明是新的一次关阀报，而且对应关阀报的上一次开阀报未收到
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, true);
|
}
|
}else{
|
//这种情况不存在，认为匹配失败
|
//当前关阀不是原记录中开阀的对应关阀，生成并保存新的关阀上报历史数据记录
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, true);
|
}
|
}else{
|
//没有历史数据，这种情况不存在，认为匹配失败，生成并保存新的关阀上报历史数据记录
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, true);
|
}
|
}else{
|
//没有历史数据，这种情况不存在，认为匹配失败，生成并保存新的关阀上报历史数据记录
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, true);
|
}
|
}
|
}else if(poLast.opType != null){
|
//原记录存在关阀数据，也存在开阀数据，首先进行开关阀时间对比
|
if(poLast.closeDt != null && poLast.closeDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.endDt))){
|
//重复上报了，不进行处理
|
}else if(poLast.closeDt != null && poLast.closeDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.endDt))){
|
//补报的许久之前的数据(对于after:等于或晚于都返回true)
|
this.dealSupplyReport() ;
|
}else {
|
//是新的上报关阀数据
|
//进行历史数据匹配
|
RmOpenCloseValveHistory poHistory = null ;
|
if(poLast.lastHistoryId != null) {
|
poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId);
|
if (poHistory != null) {
|
if(poHistory.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
|
//匹配上了
|
this.updateCloseValve(clientVo, controller, poLast, poHistory, dV202404, dataCd85Vo, false) ;
|
sv.updateRmOpenCloseValveHistory(poHistory);
|
}else{
|
//上个关阀报未上报
|
this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
|
}
|
}else{
|
//这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
|
this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
|
}
|
}else{
|
//这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
|
this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
|
}
|
}
|
}else{
|
//if(po.opType == null)
|
//原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
|
this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
|
//生成并保存新的关阀上报历史数据记录，没有对应的开发数据
|
this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
|
}
|
|
sv.updateRmOpenCloseValveLast(poLast);
|
}
|
}
|
|
/**
|
* 处理补报，暂时无逻辑
|
*/
|
private void dealSupplyReport(){
|
}
|
|
/**
|
* 保存新的关阀上报历史数据记录，并把ID赋值给最新记录的 lastHistoryId
|
* @param sv
|
* @param controller
|
* @param rtuAddr
|
* @param dV202404
|
* @param dataCd85Vo
|
* @param poLast
|
* @param clearLastOpenValue
|
* @throws Exception
|
*/
|
private void newHistoryDataDeal(DbSv sv,
|
SeClient clientVo,
|
PrController controller,
|
String rtuAddr,
|
DataV202404 dV202404,
|
DataCd85Vo dataCd85Vo,
|
RmOpenCloseValveLast poLast,
|
Boolean clearLastOpenValue)throws Exception {
|
RmOpenCloseValveHistory poHistory = this.newRmOpenCloseValveHistory(clientVo, controller, rtuAddr, dV202404, dataCd85Vo) ;
|
sv.saveRmOpenCloseValveHistory(poHistory);
|
//由最新数据持有历史数据中的最新记录ID，以方便快速查询
|
poLast.lastHistoryId = poHistory == null ? null: poHistory.id ;
|
if(clearLastOpenValue != null && clearLastOpenValue.booleanValue()){
|
poLast.clearOpenValue();
|
}
|
}
|
|
/**
|
* 生成新的关阀上报最新数据记录
|
* @param clientVo
|
* @param controller
|
* @param rtuAddr
|
* @param dV202404
|
* @param dataCd85Vo
|
* @return
|
* @throws Exception
|
*/
|
private RmOpenCloseValveLast newRmOpenCloseValveLast(SeClient clientVo,
|
PrController controller,
|
String rtuAddr,
|
DataV202404 dV202404,
|
DataCd85Vo dataCd85Vo)throws Exception {
|
RmOpenCloseValveLast po = new RmOpenCloseValveLast() ;
|
po.clientId = clientVo==null?null:clientVo.getId() ;
|
po.clientName = clientVo==null?null:clientVo.getName() ;
|
po.controllerId = controller==null?null:controller.getId() ;
|
po.intakeId = controller==null?null:controller.getIntakeId() ;
|
po.rtuAddr = rtuAddr ;
|
po.valueFrom85(dV202404, dataCd85Vo);
|
return po ;
|
}
|
|
|
/**
|
* 生成新的关阀上报历史数据记录
|
* @param clientVo
|
* @param controller
|
* @param rtuAddr
|
* @param dV202404
|
* @param dataCd85Vo
|
* @return
|
* @throws Exception
|
*/
|
private RmOpenCloseValveHistory newRmOpenCloseValveHistory(SeClient clientVo,
|
PrController controller,
|
String rtuAddr,
|
DataV202404 dV202404,
|
DataCd85Vo dataCd85Vo)throws Exception {
|
RmOpenCloseValveHistory po = new RmOpenCloseValveHistory() ;
|
po.clientId = clientVo==null?null:clientVo.getId() ;
|
po.clientName = clientVo==null?null:clientVo.getName() ;
|
po.controllerId = controller==null?null:controller.getId() ;
|
po.intakeId = controller==null?null:controller.getIntakeId() ;
|
po.rtuAddr = rtuAddr ;
|
po.valueFrom85(dV202404, dataCd85Vo);
|
return po ;
|
}
|
|
|
/**
|
* 更新数据
|
* @param clientVo
|
* @param controller
|
* @param poLast
|
* @param poHistory
|
* @param dV202404
|
* @param dataCd85Vo
|
* @param clearLastOpenValue
|
* @throws Exception
|
*/
|
private void updateCloseValve(SeClient clientVo,
|
PrController controller,
|
RmOpenCloseValveLast poLast,
|
RmOpenCloseValveHistory poHistory,
|
DataV202404 dV202404,
|
DataCd85Vo dataCd85Vo,
|
boolean clearLastOpenValue) throws Exception {
|
poLast.clientId = clientVo==null?null:clientVo.getId() ;
|
poLast.clientName = clientVo==null?null:clientVo.getName() ;
|
poLast.controllerId = controller==null?null:controller.getId();
|
poLast.intakeId = controller==null?null:controller.getIntakeId();
|
|
poLast.updateFrom(dV202404, dataCd85Vo, clearLastOpenValue);
|
|
if(poHistory != null){
|
poHistory.clientId = clientVo==null?null:clientVo.getId() ;
|
poHistory.clientName = clientVo==null?null:clientVo.getName() ;
|
poHistory.controllerId = controller==null?null:controller.getId();
|
poHistory.intakeId = controller==null?null:controller.getIntakeId();
|
|
poHistory.updateFrom(dV202404, dataCd85Vo, false);
|
}
|
}
|
|
|
// /**
|
// * 处理关阀报数据
|
// * @param sv 服务
|
// * @param clientVo 农户对象（不为空时，只有id和name有值）
|
// * @param controller 控制器对象
|
// * @param rtuAddr 控制器地址
|
// * @param dataV202404 协议数据
|
// * @param cdData 功能数据
|
// */
|
// private void doDeal(DbSv sv, SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData) throws Exception {
|
// this.saveOrUpdateLast(sv, controller, rtuAddr, dataV202404, cdData);
|
// this.saveHistory(sv, controller, rtuAddr, dataV202404, cdData);
|
// }
|
//
|
// /**
|
// * 保存或更新控制器关阀报最新数据
|
// * @param sv 服务bean
|
// * @param controller 控制器对象
|
// * @param rtuAddr 控制器地址
|
// * @param dataV202404 协议数据
|
// * @param cdData 功能数据
|
// */
|
// private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData)throws Exception {
|
// RmOpenCloseValveLast po = sv.getRmOpenCloseValveLast(controller.getIntakeId());
|
// if(po == null){
|
// po = new RmOpenCloseValveLast();
|
// po.controllerId = controller==null?null:controller.getId();
|
// po.intakeId = controller==null?null:controller.getIntakeId();
|
// po.rtuAddr = rtuAddr;
|
// po.valueFrom85(dataV202404, cdData);
|
// sv.saveRmOpenCloseValveLast(po);
|
// }else{
|
// po.controllerId = controller==null?null:controller.getId();
|
// po.intakeId = controller==null?null:controller.getIntakeId();
|
// po.valueFrom85(dataV202404, cdData);
|
// sv.updateRmOpenCloseValveLast(po);
|
// }
|
// }
|
//
|
// /**
|
// * 保存控制器关阀报历史数据
|
// * @param sv 服务bean
|
// * @param controller 控制器对象
|
// * @param rtuAddr 控制器地址
|
// * @param dataV202404 协议数据
|
// * @param cdData 功能数据
|
// */
|
// private void saveHistory(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData)throws Exception {
|
// RmOpenCloseValveHistory po = new RmOpenCloseValveHistory();
|
// po.controllerId = controller==null?null:controller.getId();
|
// po.intakeId = controller==null?null:controller.getIntakeId();
|
// po.rtuAddr = rtuAddr;
|
// po.valueFrom85(dataV202404, cdData);
|
// sv.saveRmOpenCloseValveHistory(po); ;
|
// }
|
}
|
