package com.fgkj.services;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.AlarmDaoFactory;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.BaseDAOFactory;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.dao.UinfDaoFactory;
|
import com.fgkj.dao.impl.BattInfImpl;
|
import com.fgkj.dao.impl.Batt_devalarm_dataImpl;
|
import com.fgkj.dao.impl.Battalarm_dataDAOImpl;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.db.IDatabaseName;
|
import com.fgkj.dto.BattInf;
|
import com.fgkj.dto.Batt_Maint_Dealarm;
|
import com.fgkj.dto.Batt_devalarm_data;
|
import com.fgkj.dto.Batt_maint_inf;
|
import com.fgkj.dto.Batt_maintenance_inf;
|
import com.fgkj.dto.Batt_rtstate;
|
import com.fgkj.dto.Battalarm_data;
|
import com.fgkj.dto.Batttestdata_inf;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.ServiceModel;
|
import com.fgkj.dto.User;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.dto.User_log;
|
|
public class Battalarm_dataService {
|
private ServiceModel model;
|
private BaseDAO dao;
|
public Battalarm_dataService() {
|
model=new ServiceModel();
|
dao=BaseDAOFactory.getBaseDAO(BaseDAO.BATTALARM_DATA);
|
}
|
|
|
|
public ServiceModel add(Object obj) {
|
|
Boolean bl=dao.add(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("添加成功!");
|
}
|
else{
|
model.setMsg("添加失败!");
|
}
|
return model;
|
|
}
|
|
// 3.1电池告警实时查询(确认告警)
|
public ServiceModel update(Object obj) {
|
boolean flag=true;
|
List list=(List)obj;
|
if(list!=null && list.size()>0){
|
for (int i = 0; i < list.size(); i++) {
|
if(!dao.update(list.get(i))){
|
flag=false;
|
}
|
}
|
}else{
|
flag=false;
|
}
|
if(flag){
|
model.setCode(1);
|
model.setMsg("修改成功!");
|
}
|
else{
|
model.setMsg("修改失败!");
|
}
|
return model;
|
}
|
|
//3.1电池告警实时查询(确认告警)(多条记录)
|
public ServiceModel updatePro(Object obj) {
|
List<Battalarm_data> list=(List<Battalarm_data>) obj;
|
ArrayList<String> str_sql=new ArrayList<String>();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list!=null&&list.size()>0){
|
for(int i=0;i<list.size();i++){
|
Battalarm_data adata=list.get(i);
|
String updateSql=((Battalarm_dataDAOImpl)dao).updatePro(adata);
|
str_sql.add(updateSql);
|
{ //机房和电池组名称 //告警的类型
|
String msg="确认"+adata.getStationname()+"的"+adata.getNote();
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), str_sql);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
if(bl){
|
model.setCode(1);
|
model.setMsg("确认成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("确认失败!");
|
}
|
return model;
|
}
|
|
|
//3.1/3.2电池告警查询(删除记录)
|
public ServiceModel delete(Object obj) {
|
List<Battalarm_data> list=(List<Battalarm_data>) obj;
|
ArrayList<String> str_sql=new ArrayList<String>();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list!=null&&list.size()>0){
|
for(int i=0;i<list.size();i++){
|
Battalarm_data adata=list.get(i);
|
String delSql=((Battalarm_dataDAOImpl)dao).delPro(adata);
|
str_sql.add(delSql);
|
{
|
String msg="删除"+adata.getStationname()+"的"+adata.getNote();
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Delete, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), str_sql);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
if(bl){
|
model.setCode(1);
|
model.setMsg("删除成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("删除失败!");
|
}
|
return model;
|
}
|
|
// 3.1电池容量告警实时查询
|
public ServiceModel serchCapAlarm(Object obj){
|
model=new ServiceModel();
|
List<Batt_Maint_Dealarm> list=dao.serchByCondition(obj);
|
String name="未知";//存放告警名称
|
String type="未知";//存放告警等级
|
String stationName="";//机房站点
|
String battgroupName="";//蓄电池组名
|
/*battinf中的StationName8，StationName9存放告警名称和等级*/
|
if(list!=null && list.size()>1){
|
for(int i=0;i<list.size()-1;i++){
|
BattInf binf=list.get(i).getBinf();;
|
Battalarm_data adata=list.get(i).getAdata();
|
binf.setBattGroupId(adata.getBattGroupId());
|
List listB=new BattInfImpl().serchByCondition(binf);
|
if(listB!=null&listB.size()>0){
|
stationName=((BattInf)listB.get(0)).getStationName();
|
battgroupName=((BattInf)listB.get(0)).getBattGroupName();
|
}
|
name=AlarmDaoFactory.getAlarmName(adata.getAlm_signal_id());
|
type=AlarmDaoFactory.getAlarmType(adata.getAlm_level());
|
binf.setStationName(stationName);
|
binf.setBattGroupName(battgroupName);
|
binf.setStationName8(name);
|
binf.setStationName9(type);
|
}
|
model.setCode(1);
|
model.setData(list);
|
}else {
|
model.setCode(0);
|
model.setData(list);
|
}
|
return model;
|
}
|
|
|
//3.1电池告警实时查询
|
public ServiceModel serchByCondition(Object obj){
|
model=new ServiceModel();
|
List list=dao.serchByCondition(obj);
|
if(list!=null && list.size()>1){
|
model.setCode(1);
|
model.setData(list);
|
}else {
|
model.setCode(0);
|
model.setData(list);
|
}
|
return model;
|
}
|
//3.1电池告警实时查询<***********跨域专用**************>
|
public ServiceModel serchByCondition_ky(Object obj){
|
model=new ServiceModel();
|
List list=((Battalarm_dataDAOImpl)dao).serchByCondition_ky(obj);
|
if(list!=null && list.size()>1){
|
model.setCode(1);
|
model.setData(list);
|
model.setMsg("查询成功!");
|
}else {
|
model.setCode(0);
|
model.setData(list);
|
model.setMsg("查询失败!");
|
}
|
return model;
|
}
|
|
//3.2电池告警历史记录查询
|
public ServiceModel serchByInfo(Object obj){
|
List<Batt_Maint_Dealarm> list=dao.serchByInfo(obj);
|
if(list!=null && list.size()>0){
|
model.setCode(1);
|
model.setData(list);
|
}else{
|
model.setCode(0);
|
model.setMsg("查询失败!");
|
|
}
|
|
return model;
|
}
|
|
public ServiceModel serch(Object obj){
|
Battalarm_data bdata=(Battalarm_data) obj;
|
//告警记录总数
|
List<Battalarm_data> list=((Battalarm_dataDAOImpl)dao).serchByBatt(bdata);
|
//新增告警记录条数
|
List<Battalarm_data> list1=((Battalarm_dataDAOImpl)dao).serchByAlmType(bdata);
|
model=new ServiceModel();
|
if(list!=null && list.size()>0){
|
model.setCode(1);
|
model.setSum(list.size());
|
model.setNewsum(list1.size());
|
model.setData(list.get(list.size()-1));
|
|
}
|
else{
|
model.setCode(0);
|
model.setSum(0);
|
model.setNewsum(0);
|
}
|
return model;
|
|
}
|
|
//0.5查询实时告警数(电池告警率)
|
public ServiceModel serchAlm(Object obj){
|
Battalarm_data adata=new Battalarm_data();
|
adata.setNum(0);//实时告警总数
|
adata.setBattGroupId(0);//容量告警告警数
|
adata.setMonNum(0);//组端电压告警数
|
adata.setAlm_id(0);//充电电流告警数
|
adata.setAlm_signal_id(0);//放电电流告警数
|
adata.setAlm_level(0);//单体电压告警数
|
adata.setAlm_is_confirmed(0);//单体温度告警数
|
adata.setAlm_cleared_type(0);//单体内阻告警数
|
adata.setUsr_Id(0);//连接条阻抗告警数
|
adata.setAlm_value(0f);//容量更换告警
|
adata.setRecord_Id(0l);//在线电压告警数
|
int numZ=0;//告警总数
|
//求八种类型告警的数量
|
List<Battalarm_data> list=((Battalarm_dataDAOImpl)dao).serchAlm(obj);
|
if(list!=null&&list.size()>0){
|
for(int i=0;i<list.size();i++){
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_CapAlarm){
|
adata.setBattGroupId(list.get(i).getNum());//容量告警告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_vol_Group){
|
adata.setMonNum(list.get(i).getNum());//组端电压告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_curr_Charge){
|
adata.setAlm_id(list.get(i).getNum());//充电电流告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_curr_Discharge){
|
adata.setAlm_signal_id(list.get(i).getNum());//放电电流告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_vol_Monomer){
|
adata.setAlm_level(list.get(i).getNum());//单体电压告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_tmp_Monomer){
|
adata.setAlm_is_confirmed(list.get(i).getNum());//单体温度告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_res_Monomer){
|
adata.setAlm_cleared_type(list.get(i).getNum());//单体内阻告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_res_Conn){
|
adata.setUsr_Id(list.get(i).getNum());//连接条阻抗告警数
|
numZ+=list.get(i).getNum();
|
}
|
if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_CapChange){
|
adata.setAlm_value((float)list.get(i).getNum());//容量更换告警数
|
numZ+=list.get(i).getNum();
|
}if(list.get(i).getAlm_id()==AlarmDaoFactory.Alarm_vol_Online){
|
adata.setRecord_Id((long)list.get(i).getNum());//在线电压告警数
|
numZ+=list.get(i).getNum();
|
}
|
|
}
|
}
|
adata.setNum(numZ);//实时告警总数
|
model.setCode(1);
|
model.setData(adata);
|
//System.out.println(model.getData());
|
return model;
|
}
|
|
|
//0.10实时告警记录总数查询
|
public ServiceModel serchRealTime(Object obj){
|
List<Battalarm_data> list=((Battalarm_dataDAOImpl)dao).serchRealTime(obj);
|
if(list.size()>0&&list!=null){
|
model.setCode(1);
|
model.setSum(list.get(0).getNum());
|
}else{
|
model.setCode(0);
|
model.setMsg("查询失败!");
|
}
|
return model;
|
|
}
|
|
public ServiceModel searchAll(){
|
List<Battalarm_data> list=dao.searchAll();
|
if(list!=null && list.size()>0){
|
model.setCode(1);
|
model.setData(list);
|
}
|
return model;
|
}
|
//饼状图电池单体健康率
|
public ServiceModel serchGood(Object obj){
|
List list=((Battalarm_dataDAOImpl)dao).serchGood(obj);//单体容量告警和单体告警告警
|
int moncounts=(new BattInfImpl()).serchMonAll(obj);//总单体数
|
model.setCode(1);
|
model.setSum(moncounts);
|
model.setData(list);
|
//System.out.println(model);
|
return model;
|
}
|
//取消告警
|
public ServiceModel cancelalarm(Object obj){
|
boolean flag=true;
|
if(obj!=null){
|
List list=(List)obj;
|
if(list!=null && list.size()>0){
|
for (int i = 0; i < list.size(); i++) {
|
if(!((Battalarm_dataDAOImpl)dao).cancelalarm(list.get(i))){
|
flag=false;
|
}
|
}
|
}else{
|
flag=false;
|
}
|
}else{
|
flag=false;
|
}
|
if(flag){
|
model.setCode(1);
|
model.setMsg("操作成功!");
|
}
|
else{
|
model.setMsg("操作失败!");
|
}
|
return model;
|
}
|
|
//取消告警(多条记录)
|
public ServiceModel cancelalarmPro(Object obj) {
|
List<Battalarm_data> list=(List<Battalarm_data>) obj;
|
ArrayList<String> str_sql=new ArrayList<String>();
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
if(list!=null&&list.size()>0){
|
for(int i=0;i<list.size();i++){
|
Battalarm_data adata=list.get(i);
|
String cancelSql=((Battalarm_dataDAOImpl)dao).cancelalarmPro(adata);
|
str_sql.add(cancelSql);
|
{
|
String msg="取消"+adata.getStationname()+"的"+adata.getNote();
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
Boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), str_sql);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
if(bl){
|
model.setCode(1);
|
model.setMsg("取消成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("取消失败!");
|
}
|
return model;
|
}
|
|
//项目下方的滚动，查询最新电池告警(电池告警和设备告警筛选出最新的一条)(旧版本)
|
public ServiceModel serchTopAlm(){
|
List<Battalarm_data> lista=((Battalarm_dataDAOImpl)dao).serchTopAlmInBatt();
|
List<Batt_devalarm_data> listd=(new Batt_devalarm_dataImpl()).serchTopAlmInDev();
|
String adataStr="";//最后的电池告警字符串
|
String ddataStr="";//最后的设备告警字符串
|
if(lista.size()>0&&lista!=null&&listd.size()>0&&listd!=null){
|
model.setCode(1);
|
Battalarm_data adata=lista.get(lista.size()-1);
|
Batt_devalarm_data ddata= listd.get(listd.size()-1);
|
int flag=ActionUtil.compareDate(adata.getAlm_start_time(),ddata.getAlm_start_time());
|
if(flag==1){
|
model.setData(adata);
|
adataStr=adata.getStationname()
|
+"在"+ActionUtil.chageDateToString(adata.getAlm_start_time(), ActionUtil.time_yyyyMMddHHmmss)
|
+"出现了"+AlarmDaoFactory.getAlarmName(adata.getAlm_signal_id())
|
+"告警";
|
model.setMsg(adataStr);
|
model.setSum(0);//0表示电池告警
|
}else{
|
model.setData(ddata);
|
ddataStr=""+ddata.getStationName() // 机房名称
|
+"在"+ActionUtil.chageDateToString(ddata.getAlm_start_time(), ActionUtil.time_yyyyMMddHHmmss) // 告警开始时间
|
+"出现了"+AlarmDaoFactory.getdevName(ddata.getAlm_type()) // 告警类型名称
|
+"告警!";
|
model.setMsg(ddataStr);
|
model.setSum(1);//1表示设备告警
|
}
|
}else if(lista==null&&listd.size()>0&&listd!=null){
|
Batt_devalarm_data ddata= listd.get(listd.size()-1);
|
model.setData(ddata);
|
ddataStr=ddata.getStationName()
|
+"在"+ActionUtil.chageDateToString(ddata.getAlm_start_time(), ActionUtil.time_yyyyMMddHHmmss)
|
+"出现了"+AlarmDaoFactory.getdevName(ddata.getAlm_type())
|
+"告警!";
|
model.setMsg(ddataStr);
|
model.setSum(1);//1表示设备告警
|
}else if(listd==null&&lista.size()>0&&lista!=null){
|
Battalarm_data adata=lista.get(lista.size()-1);
|
model.setData(adata);
|
adataStr=adata.getStationname()
|
+"在"+ActionUtil.chageDateToString(adata.getAlm_start_time(), ActionUtil.time_yyyyMMddHHmmss)
|
+"出现了"+AlarmDaoFactory.getAlarmName(adata.getAlm_signal_id())
|
+"告警!";
|
model.setMsg(adataStr);
|
model.setSum(0);//0表示电池告警
|
}else{
|
model.setCode(0);
|
model.setMsg("没有最新的告警!");
|
}
|
return model;
|
}
|
|
//项目下方的滚动，查询最新电池告警(电池告警和设备告警筛选出最新的五条)
|
public ServiceModel serchTopAlmTen(Object obj){
|
List<Battalarm_data> lista=((Battalarm_dataDAOImpl)dao).serchTopBattTen(obj);
|
List<Batt_devalarm_data> listd=(new Batt_devalarm_dataImpl()).serchTopDevTen(obj);
|
if(listd!=null&&listd.size()>0){
|
for (Batt_devalarm_data ddata : listd) {
|
Battalarm_data data=new Battalarm_data();
|
data.setAlm_id(ddata.getDev_id());
|
data.setNote(ddata.getNote());
|
data.setNum(ddata.getNum());//1表示设备告警
|
data.setAlm_start_time(ddata.getAlm_start_time());
|
data.setAlm_signal_id(ddata.getAlm_type());
|
lista.add(data);
|
}
|
}
|
if(lista!=null&&lista.size()>0){
|
model.setCode(1);
|
model.setData(lista);
|
model.setMsg("查询成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("查询失败!");
|
}
|
return model;
|
}
|
//告警发声(30秒之内的告警)
|
public ServiceModel serchIn30(Object obj){
|
List<Battalarm_data> lista=((Battalarm_dataDAOImpl)dao).serchIn30(obj);
|
List<Batt_devalarm_data> listd=(new Batt_devalarm_dataImpl()).serchIn30(obj);
|
if(listd!=null&&listd.size()>0){
|
for (Batt_devalarm_data ddata : listd) {
|
Battalarm_data data=new Battalarm_data();
|
data.setAlm_id(ddata.getDev_id());
|
data.setNote(ddata.getNote());
|
data.setNum(ddata.getNum());//1表示设备告警
|
data.setAlm_start_time(ddata.getAlm_start_time());
|
data.setAlm_signal_id(ddata.getAlm_type());
|
lista.add(data);
|
}
|
}
|
if(lista!=null&&lista.size()>0){
|
model.setCode(1);
|
model.setData(lista);
|
model.setMsg("查询成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("查询失败!");
|
}
|
return model;
|
}
|
//点击项目下方的滚动，查询该条告警的实时信息
|
public ServiceModel serchBatt_alarm(Object obj){
|
List list=((Battalarm_dataDAOImpl)dao).serchBatt_alarm(obj);
|
if(list!=null && list.size()>0){
|
model.setCode(1);
|
model.setData(list);
|
model.setMsg("查询成功!");
|
}else{
|
model.setCode(0);
|
model.setMsg("查询失败!");
|
}
|
return model;
|
}
|
public static void main(String[] args) throws ParseException {
|
Battalarm_dataService bs=new Battalarm_dataService();
|
Page p = new Page();
|
p.setPageCurr(1);
|
p.setPageSize(10);
|
/*条件所存放的位置前台：tb_batt_maint_inf
|
* 在线电压：usr_id
|
* 组端电压：fault_type_id
|
* 充电电流：fault_level
|
* 放电电流：record_uid
|
* 单体电压：maint_type_id
|
* 单体温度：maint_done
|
* 单体内阻：maint_close
|
* 连接条阻抗：master_id
|
* */
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2017-12-09");
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
|
mainf.setUsr_id(0);
|
mainf.setFault_type_id(0);
|
mainf.setFault_level(0);
|
mainf.setRecord_uid(0);
|
mainf.setMaint_type_id(0);
|
mainf.setMaint_done(0);
|
mainf.setMaint_close(0);
|
mainf.setMaster_id(119008);
|
|
|
mainf.setNum(1);
|
mainf.setBattGroupId(2);
|
mainf.setMaster_audit(3);
|
mainf.setAppoint_uid(4);
|
|
mainf.setRemark("100");
|
mainf.setMaint_done_time(ActionUtil.getSimpDate(date1));
|
mainf.setMaint_done_time1(ActionUtil.getSimpDate(date2));
|
|
|
Battalarm_data adata = new Battalarm_data();
|
adata.setAlm_id(1);//下限告警未选中
|
adata.setAlm_signal_id(0);//上限告警选中
|
adata.setUsr_Id(100);//全部包机人
|
adata.setAlm_cleared_type(100);//告警
|
adata.setAlm_start_time(ActionUtil.getSimpDate(date1));
|
adata.setAlm_start_time1(ActionUtil.getSimpDate(date2));
|
adata.setMonNum(0);
|
adata.setRecord_Id(0l);
|
BattInf binf = new BattInf();
|
|
binf.setStationName("");
|
binf.setStationName1("");
|
binf.setBattGroupId(0);
|
binf.setBattGroupName1("");
|
binf.setBattProducer("");
|
binf.setMonCapStd(0f);
|
binf.setMonVolStd(0f);
|
|
binf.setBattProductDate(ActionUtil.getSimpDate(date1));
|
binf.setBattProductDate1(ActionUtil.getSimpDate(date2));
|
binf.setBattInUseDate(ActionUtil.getSimpDate(date1));
|
binf.setBattInUseDate1(ActionUtil.getSimpDate(date2));
|
|
Batttestdata_inf tdata=new Batttestdata_inf();
|
tdata.setTest_type(0);
|
tdata.setTest_starttype(0);
|
tdata.setRecord_time(ActionUtil.getSimpDate(date1));
|
tdata.setRecord_time1(ActionUtil.getSimpDate(date2));
|
|
User_inf uinf=new User_inf();
|
uinf.setUId(1002);
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
bmd.setPage(p);
|
bmd.setAdata(adata);
|
bmd.setMainf(mainf);
|
bmd.setBinf(binf);
|
bmd.setTdata(tdata);
|
bmd.setUinf(uinf);
|
//System.out.println(bmd);
|
//bs.serchByCondition(bmd);
|
//bs.serchByInfo(bmd);
|
bs.serchAlm(uinf);
|
//bs.serchGood();
|
//bs.serchTopAlmTen(uinf);
|
}
|
|
}
|
