package com.dy.aceMw.server.rtuData.dbSv;
|
|
import com.dy.pipIrrGlobal.daoPr.PrControllerMapper;
|
import com.dy.pipIrrGlobal.daoPr.PrControllerTrampMapper;
|
import com.dy.pipIrrGlobal.daoPr.PrIntakeMapper;
|
import com.dy.pipIrrGlobal.daoRm.RmAlarmStateHistoryMapper;
|
import com.dy.pipIrrGlobal.daoRm.RmAlarmStateLastMapper;
|
import com.dy.pipIrrGlobal.daoRm.RmAutoReportHistoryMapper;
|
import com.dy.pipIrrGlobal.daoRm.RmAutoReportLastMapper;
|
import com.dy.pipIrrGlobal.pojoPr.PrController;
|
import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp;
|
import com.dy.pipIrrGlobal.pojoPr.PrIntake;
|
import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateHistory;
|
import com.dy.pipIrrGlobal.pojoRm.RmAlarmStateLast;
|
import com.dy.pipIrrGlobal.pojoRm.RmAutoReportHistory;
|
import com.dy.pipIrrGlobal.pojoRm.RmAutoReportLast;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
|
/**
|
* @Author liurunyu
|
* @Date 2024/1/13 10:57
|
* @LastEditTime 2024/1/13 10:57
|
* @Description
|
*/
|
@Service()
|
public class DbSv {
|
@Autowired
|
private PrControllerTrampMapper prControllerTrampMapperDao;//流浪控制器DAO
|
@Autowired
|
private PrControllerMapper prControllerMapperDao ;//控制器DAO
|
@Autowired
|
private RmAlarmStateLastMapper rmAlarmStateLastMapperDao ;//控制器最新报警和状态DAO
|
@Autowired
|
private RmAlarmStateHistoryMapper rmAlarmStateHistoryMapperDao ;//控制器历史报警和状态DAO
|
@Autowired
|
private RmAutoReportLastMapper rmAutoReportLastMapperDao ;//控制器最新上报数据DAO
|
@Autowired
|
private RmAutoReportHistoryMapper rmAutoReportHistoryMapperDao ;//控制器历史上报数据DAO
|
|
//@Autowired
|
//@Lazy
|
//private DbSv sv ;
|
|
/**
|
* 通过控制器地址从数据库表中查询控制器
|
* @param rtuAddr 控制器地址
|
* @return 控制器
|
*/
|
public PrController getControllersByRtuAddrAndIntakeNotNull(String rtuAddr){
|
List<PrController> list = this.prControllerMapperDao.getControllersByRtuAddrAndIntakeNotNull(rtuAddr) ;
|
if(list != null && list.size() > 0){
|
return list.get(0) ;
|
}
|
return null ;
|
}
|
/**
|
* 通过控制器地址从数据库表中查询流浪控制器
|
* @param rtuAddr 控制器地址
|
* @return 流浪控制器
|
*/
|
public PrControllerTramp getPrControllerTrampByRtuAddr(String rtuAddr){
|
List<PrControllerTramp> list = this.prControllerTrampMapperDao.getPrControllerTrampByRtuAddr(rtuAddr) ;
|
if(list != null && list.size() > 0){
|
return list.get(0) ;
|
}
|
return null ;
|
}
|
/**
|
* 保存流浪控制器
|
* @param po
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void savePrConctrollerTramp(PrControllerTramp po){
|
this.prControllerTrampMapperDao.insert(po) ;
|
}
|
/**
|
* 得到控制器报警与状态最新记录
|
* @param rtuAddr
|
* @return
|
*/
|
public RmAlarmStateLast getRmLastAlarmState(String rtuAddr){
|
List<RmAlarmStateLast> list = rmAlarmStateLastMapperDao.selectByRtuAddr(rtuAddr) ;
|
if(list != null && list.size() > 0){
|
return list.get(0) ;
|
}
|
return null ;
|
}
|
/**
|
* 保存控制器报警与状态最新记录
|
* @param po
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void saveRmAlarmStateLast(RmAlarmStateLast po){
|
this.rmAlarmStateLastMapperDao.insert(po) ;
|
}
|
/**
|
* 保存控制器报警与状态历史记录
|
* @param po
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void saveRmAlarmStateHistory(RmAlarmStateHistory po){
|
this.rmAlarmStateHistoryMapperDao.insert(po) ;
|
}
|
/**
|
* 得到控制器上报数据最新记录
|
* @param rtuAddr
|
* @return
|
*/
|
public RmAutoReportLast getRmLastAutoReport(String rtuAddr){
|
List<RmAutoReportLast> list = rmAutoReportLastMapperDao.selectByRtuAddr(rtuAddr) ;
|
if(list != null && list.size() > 0){
|
return list.get(0) ;
|
}
|
return null ;
|
}
|
/**
|
* 保存控制器上报数据最新记录
|
* @param po
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void saveRmAutoReportLast(RmAutoReportLast po){
|
this.rmAutoReportLastMapperDao.insert(po) ;
|
}
|
/**
|
* 保存控制器上报数据历史记录
|
* @param po
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void saveRmAutoReportHistory(RmAutoReportHistory po){
|
this.rmAutoReportHistoryMapperDao.insert(po) ;
|
}
|
|
}
|
