package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
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.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
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_maint_inf;
|
import com.fgkj.dto.Batt_maint_process;
|
import com.fgkj.dto.Batt_maintenance_inf;
|
import com.fgkj.dto.Batttestdata_inf;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.User_inf;
|
|
public class Batt_maint_infImpl implements BaseDAO,CallBack{
|
|
public Batt_maint_infImpl() {
|
DAOHelper.sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
}
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList<BattInf>();
|
int id=0;
|
try {
|
while (rs.next()) {
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
BattInf binf = new BattInf();
|
Page p=new Page();
|
|
binf.setBattGroupId(rs.getInt("battGroupId"));
|
if(id==rs.getInt("battGroupId")){
|
continue;
|
}else{
|
id=rs.getInt("battGroupId");
|
}
|
binf.setStationName(rs.getString("stationName"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
|
/*Batt_maintenance_inf minf=new Batt_maintenance_inf();
|
if (rs.getString("maintenance_time") != null)
|
minf.setMaintenance_time(DAOHelper.sdf.parse(rs
|
.getString("maintenance_time")));
|
|
*/
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setNum(rs.getInt("num"));
|
mainf.setUsr_id(rs.getInt("usr_id"));
|
|
|
mainf.setFault_type_id(rs.getInt("fault_type_id"));
|
mainf.setFault_level(rs.getInt("fault_level"));
|
mainf.setFault_caption(rs.getString("fault_caption"));
|
|
if(rs.getString("record_time")!=null)
|
mainf.setRecord_time(DAOHelper.sdf.parse(rs.getString("record_time")));
|
|
if(rs.getString("maint_time_limit")!=null)
|
mainf.setMaint_time_limit(DAOHelper.sdf.parse(rs.getString("maint_time_limit")));
|
|
mainf.setMaint_type_id(rs.getInt("maint_type_id"));
|
mainf.setMaint_result(rs.getString("maint_result"));
|
mainf.setMaint_done(rs.getInt("maint_done"));
|
|
if(rs.getString("maint_done_time")!=null)
|
mainf.setMaint_done_time(DAOHelper.sdf.parse(rs.getString("maint_done_time")));
|
|
|
mainf.setMaint_close(rs.getInt("maint_close"));
|
mainf.setMaster_id(rs.getInt("master_id"));
|
|
mainf.setMaster_audit(rs.getInt("master_audit"));
|
mainf.setCopy_uids(rs.getString("copy_uids"));//数据库存储时用的字符串
|
|
mainf.setAppoint_uid(rs.getInt("appoint_uid"));
|
|
bmd.setBinf(binf);
|
// bmd.setMinf(minf);
|
bmd.setPage(p);
|
bmd.setMainf(mainf);
|
|
list.add(bmd);
|
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} catch (ParseException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
return list;
|
}
|
|
public boolean add(Object obj) {
|
Batt_maint_inf binf=(Batt_maint_inf) obj;
|
String sql="insert into db_battinf.tb_batt_maint_inf(BattGroupId,usr_id,fault_type_id,fault_type,fault_level,fault_cation," +
|
"fault_time,record_uid,record_time,maint_time_limit,maint_type_id,maint_type,maint_result," +
|
"maint_done,maint_done_time,maint_close,master_id,master_audit,copy_uids,appoint_check,remark) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{binf.getBattGroupId(),binf.getUsr_id(),binf.getFault_type_id(),
|
binf.getFault_type(),binf.getFault_level(),binf.getFault_caption(),binf.getFault_time(),binf.getRecord_uid(),binf.getRecord_time(),binf.getMaint_time_limit(),
|
binf.getMaint_type_id(),binf.getMaint_type(),binf.getMaint_result(),binf.getMaint_done(),binf.getMaint_done_time(),binf.getMaint_close(),binf.getMaster_id(),
|
binf.getMaster_audit(),binf.getCopy_uids(),binf.getAppoint_uid(),binf.getMaster_check(),binf.getRemark()});
|
return bl;
|
}
|
|
//2.1 电池维护记录查询(编辑记录)<故障类型和排除方法对应问题？>
|
public boolean update(Object obj) {
|
Batt_maint_inf mainf = (Batt_maint_inf) obj;
|
String sql = "update db_battinf.tb_batt_maint_inf set usr_id=?,fault_type_id=?,fault_level=?,fault_caption=?,"
|
+ "record_time=?,maint_time_limit=?,maint_type_id=?,"
|
+ "maint_done=?,maint_done_time=?,maint_result=?,maint_close=?,master_audit=?,copy_uids=?,appoint_uid=? where num=?";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(),
|
sql,
|
new Object[] {
|
mainf.getUsr_id(),
|
mainf.getFault_type_id(),
|
mainf.getFault_level(),
|
mainf.getFault_caption(),
|
mainf.getFault_time(),
|
mainf.getMaint_time_limit(),
|
mainf.getMaint_type_id(),
|
mainf.getMaint_done(),
|
mainf.getMaint_done_time(),
|
mainf.getMaint_result(),
|
mainf.getMaint_close(),
|
mainf.getMaster_audit(),
|
mainf.getCopy_uids(),
|
mainf.getAppoint_uid(),
|
mainf.getNum() });
|
return bl;
|
}
|
//2.1 电池维护记录查询（删除记录）
|
public boolean del(Object obj) {
|
Batt_maint_inf mainf = (Batt_maint_inf) obj;
|
String sql = "delete from db_battinf.tb_batt_maint_inf where num=?";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(), sql,
|
new Object[] { mainf.getNum()});
|
return bl;
|
}
|
|
// 3.1 根据battgroupid查维护数据信息
|
public List serchByCondition(Object obj) {
|
Batt_Maint_Dealarm bmd = (Batt_Maint_Dealarm) obj;
|
List list = null;
|
BattInf binf = bmd.getBinf();
|
Batt_maint_inf mainf = bmd.getMainf();
|
Batttestdata_inf tdata = bmd.getTdata();
|
User_inf uinf=bmd.getUinf();
|
String sql="";
|
String baseSql="select distinct(db_battinf.tb_batt_maint_inf.battgroupid),StationName,BattGroupName "
|
+ ",db_battinf.tb_batt_maint_inf.num,usr_id,fault_type_id,fault_level,fault_caption,db_battinf.tb_batt_maint_inf.record_time,maint_time_limit,maint_type_id"
|
+ ",maint_result,maint_done,maint_done_time,maint_close,master_id,master_audit"
|
+ ",copy_uids,appoint_uid "
|
+ "from db_battinf.tb_batt_maint_inf "
|
+ "left outer join db_battinf.tb_battinf on db_battinf.tb_battinf.BattgroupId=db_battinf.tb_batt_maint_inf.BattGroupId "
|
+ "left outer join db_batt_testdata.tb_batttestdata_inf on db_battinf.tb_batt_maint_inf.BattGroupId=db_batt_testdata.tb_batttestdata_inf.BattGroupId " +
|
"left outer join db_user.tb_user_battgroup_baojigroup_battgroup on db_user.tb_user_battgroup_baojigroup_battgroup.battgroupid=db_battinf.tb_batt_maint_inf.BattGroupId " +
|
"left outer join db_user.tb_user_battgroup_baojigroup_usr on db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id= db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id " +
|
"left outer join db_user.tb_user_inf on db_user.tb_user_inf.uId=db_user.tb_user_battgroup_baojigroup_usr.uid " +
|
"where to_days(battproductdate)>=to_days(?) and to_days(battproductdate)<=to_days(?) and to_days(battinusedate)>=to_days(?) and to_days(battinusedate)<=to_days(?)";
|
//用于维护区
|
String station1SqlT=" and stationname1!=? ";//全部
|
String station1SqlF=" and stationname1=? ";
|
if(binf.getStationName1().equals("")){
|
baseSql+=station1SqlT;
|
}else{
|
baseSql+=station1SqlF;
|
}
|
//用于机房站点
|
String stationSqlT=" and stationname!=? ";//全部
|
String stationSqlF=" and stationname=? ";
|
if(binf.getStationName().equals("")){
|
baseSql+=stationSqlT;
|
}else{
|
baseSql+=stationSqlF;
|
}
|
//用于电池类型
|
String producerSqlT=" and battproducer!=? ";//全部
|
String producerSqlF=" and battproducer=? ";
|
if(binf.getBattProducer().equals("")){
|
baseSql+=producerSqlT;
|
}else{
|
baseSql+=producerSqlF;
|
}
|
//用于电池测试记录条件:
|
//放电/充电单个/有在线监测记录
|
String testSqlH="and db_battinf.tb_batt_maint_inf.BattGroupId in(select distinct(db_batt_testdata.tb_batttestdata_inf.BattGroupId ) from db_batt_testdata.tb_batttestdata_inf where db_batt_testdata.tb_batttestdata_inf.test_type=? and to_days(record_time)>=to_days(?) and to_days(record_time)<=to_days(?)) ";
|
//内阻/电导
|
String testSqlF="and db_battinf.tb_batt_maint_inf.BattGroupId in(select distinct(db_batt_testdata.tb_battresdata_inf.BattGroupId ) from db_batt_testdata.tb_battresdata_inf where db_batt_testdata.tb_battresdata_inf.test_type=? and to_days(record_time)>=to_days(?) and to_days(record_time)<=to_days(?)) ";
|
//充电或者放电都行
|
String testSqlT="and db_battinf.tb_batt_maint_inf.BattGroupId in(select distinct(db_batt_testdata.tb_batttestdata_inf.BattGroupId ) from db_batt_testdata.tb_batttestdata_inf where db_batt_testdata.tb_batttestdata_inf.test_type in(?,2,3) and to_days(record_time)>=to_days(?) and to_days(record_time)<=to_days(?)) ";
|
//无记录
|
String testSqlN="and db_battinf.tb_batt_maint_inf.BattGroupId not in(select distinct(db_batt_testdata.tb_batttestdata_inf.BattGroupId ) from db_batt_testdata.tb_batttestdata_inf where db_batt_testdata.tb_batttestdata_inf.test_type in(?,2,3) and to_days(record_time)>=to_days(?) and to_days(record_time)<=to_days(?)) " ;
|
//全部
|
String testSqlA="and db_battinf.tb_batt_maint_inf.BattGroupId!=(select count(distinct(db_batt_testdata.tb_batttestdata_inf.BattGroupId )) from db_batt_testdata.tb_batttestdata_inf where db_batt_testdata.tb_batttestdata_inf.test_type in(?,2,3) and to_days(record_time)>=to_days(?) and to_days(record_time)<=to_days(?)) " ;
|
if(tdata.getTest_type()==2){
|
baseSql+=testSqlH;
|
}else if(tdata.getTest_type()==3){
|
baseSql+=testSqlH;
|
}else if(tdata.getTest_type()==9){//有在线监测记录
|
baseSql+=testSqlH;
|
}else if(tdata.getTest_type()==5){
|
baseSql+=testSqlF;
|
}else if(tdata.getTest_type()==3000){//充电或放电
|
baseSql+=testSqlT;
|
}else if(tdata.getTest_type()==4000){//无记录
|
baseSql+=testSqlN;
|
}else if(tdata.getTest_type()==0){
|
baseSql+=testSqlA;
|
}
|
//选取蓄电池组条件
|
String idSqlT=" and db_battinf.tb_battinf.battgroupid!=? ";
|
String idSqlF=" and db_battinf.tb_battinf.battgroupid=? ";
|
if(binf.getBattGroupId()==0){
|
baseSql+=idSqlT;
|
}else{
|
baseSql+=idSqlF;
|
}
|
//选取系统类型
|
String nameSqlT=" and BattGroupName1 like ? ";
|
String nameSqlF=" and BattGroupName1 not like '%开关电源系统%' and BattGroupName1 not like '%UPS系统%' and BattGroupName1 not like ? ";
|
if(binf.getBattGroupName1().equals("其他")){
|
baseSql+=nameSqlF;
|
}else{
|
baseSql+=nameSqlT;
|
}
|
//用于单体电压
|
String volSqlT=" and monVolStd!=? ";//全部
|
String volSqlF=" and monVolStd=?" ;
|
if(binf.getMonVolStd()==0){
|
baseSql+=volSqlT;
|
}else{
|
baseSql+=volSqlF;
|
}
|
//用于电池容量
|
String capSqlT=" and monCapStd!=? ";//全部
|
String capSqlF=" and monCapStd=?" ;
|
if(binf.getMonCapStd()==0){
|
baseSql+=capSqlT;
|
}else{
|
baseSql+=capSqlF;
|
}
|
//包机人
|
String userSqlF=" and db_user.tb_user_inf.uname=? and db_user.tb_user_inf.ubaojiusr=1 ";
|
if(uinf.getUName().equals("0")){
|
baseSql=baseSql;
|
}else{
|
baseSql+=userSqlF;
|
}
|
//用于测试类型
|
//全部
|
String start_typeA=" ";
|
//拉闸放电
|
String start_typeF=" and test_starttype<5 and test_type not in(2,9) and test_starttype!=2 ";
|
//核对性放电
|
String start_typeT=" and test_starttype>=5 or (test_type not in(2,9) and test_starttype=2) ";
|
if(tdata.getTest_starttype()==0){
|
baseSql+=start_typeA;
|
}else if(tdata.getTest_starttype()==1){
|
baseSql+=start_typeF;
|
}else if(tdata.getTest_starttype()==2){
|
baseSql+=start_typeT;
|
}
|
//用于电池维护记录条件
|
//有维护记录
|
String maintSqlT=" and db_battinf.tb_battinf.BattGroupId in(select db_battinf.tb_batt_maint_inf.battgroupid from db_battinf.tb_batt_maint_inf where to_days(maint_done_time)>=to_days(?) and to_days(maint_done_time)<=to_days(?)) " ;
|
//无维护记录
|
String maintSqlF=" and db_battinf.tb_battinf.BattGroupId not in(select db_battinf.tb_batt_maint_inf.battgroupid from db_battinf.tb_batt_maint_inf where to_days(maint_done_time)>=to_days(?) and to_days(maint_done_time)<=to_days(?)) " ;
|
//全部
|
String maintSqlA=" and db_battinf.tb_battinf.BattGroupId!=(select count(distinct(db_battinf.tb_batt_maint_inf.battgroupid )) from db_battinf.tb_batt_maint_inf where to_days(maint_done_time)>=to_days(?) and to_days(maint_done_time)<=to_days(?)) " ;
|
|
if(mainf.getRemark().equals("0")){
|
baseSql+=maintSqlF;
|
}else if(mainf.getRemark().equals("1")){
|
baseSql+=maintSqlT;
|
}else if(mainf.getRemark().equals("100")){
|
baseSql+=maintSqlA;
|
}
|
String endSql=" order by StationName1 asc,db_battinf.tb_battinf.BattgroupId asc,test_starttime asc ";
|
|
sql=baseSql+endSql;
|
//System.out.println(sql);
|
if(uinf.getUName().equals("0")){
|
list = DAOHelper.executeQuery(
|
sql,
|
DBUtil.getConn(),
|
new Object[] {
|
binf.getBattProductDate(),
|
binf.getBattProductDate1(),
|
binf.getBattInUseDate(),
|
binf.getBattInUseDate1(),
|
binf.getStationName1(),
|
binf.getStationName(),
|
binf.getBattProducer(),
|
|
tdata.getTest_type(),
|
tdata.getRecord_time(),
|
tdata.getRecord_time1(),
|
binf.getBattGroupId(),
|
"%"+binf.getBattGroupName1()+"%",
|
binf.getMonVolStd(),
|
binf.getMonCapStd(),
|
mainf.getMaint_done_time(),
|
mainf.getMaint_done_time1()
|
},
|
new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList<BattInf>();
|
try {
|
while (rs.next()) {
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
BattInf binf = new BattInf();
|
Page p=new Page();
|
binf.setBattGroupId(rs.getInt("battGroupId"));
|
binf.setStationName(rs.getString("stationName"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setNum(rs.getInt("num"));
|
mainf.setUsr_id(rs.getInt("usr_id"));
|
|
|
mainf.setFault_type_id(rs.getInt("fault_type_id"));
|
mainf.setFault_level(rs.getInt("fault_level"));
|
mainf.setFault_caption(rs.getString("fault_caption"));
|
|
if(rs.getString("record_time")!=null)
|
mainf.setRecord_time(DAOHelper.sdf.parse(rs.getString("record_time")));
|
|
if(rs.getString("maint_time_limit")!=null)
|
mainf.setMaint_time_limit(DAOHelper.sdf.parse(rs.getString("maint_time_limit")));
|
|
mainf.setMaint_type_id(rs.getInt("maint_type_id"));
|
mainf.setMaint_result(rs.getString("maint_result"));
|
mainf.setMaint_done(rs.getInt("maint_done"));
|
|
if(rs.getString("maint_done_time")!=null)
|
mainf.setMaint_done_time(DAOHelper.sdf.parse(rs.getString("maint_done_time")));
|
|
|
mainf.setMaint_close(rs.getInt("maint_close"));
|
mainf.setMaster_id(rs.getInt("master_id"));
|
|
mainf.setMaster_audit(rs.getInt("master_audit"));
|
mainf.setCopy_uids(rs.getString("copy_uids"));//数据库存储时用的字符串
|
|
mainf.setAppoint_uid(rs.getInt("appoint_uid"));
|
|
bmd.setBinf(binf);
|
// bmd.setMinf(minf);
|
bmd.setPage(p);
|
bmd.setMainf(mainf);
|
|
list.add(bmd);
|
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} catch (ParseException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
return list;
|
}
|
});
|
}else{
|
list = DAOHelper.executeQuery(
|
sql,
|
DBUtil.getConn(),
|
new Object[] {
|
binf.getBattProductDate(),
|
binf.getBattProductDate1(),
|
binf.getBattInUseDate(),
|
binf.getBattInUseDate1(),
|
binf.getStationName1(),
|
binf.getStationName(),
|
binf.getBattProducer(),
|
|
tdata.getTest_type(),
|
tdata.getRecord_time(),
|
tdata.getRecord_time1(),
|
binf.getBattGroupId(),
|
"%"+binf.getBattGroupName1()+"%",
|
binf.getMonVolStd(),
|
binf.getMonCapStd(),
|
uinf.getUName(),
|
mainf.getMaint_done_time(),
|
mainf.getMaint_done_time1()
|
},
|
new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList<BattInf>();
|
try {
|
while (rs.next()) {
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
BattInf binf = new BattInf();
|
Page p=new Page();
|
|
binf.setBattGroupId(rs.getInt("battGroupId"));
|
binf.setStationName(rs.getString("stationName"));
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setNum(rs.getInt("num"));
|
mainf.setUsr_id(rs.getInt("usr_id"));
|
|
|
mainf.setFault_type_id(rs.getInt("fault_type_id"));
|
mainf.setFault_level(rs.getInt("fault_level"));
|
mainf.setFault_caption(rs.getString("fault_caption"));
|
|
if(rs.getString("record_time")!=null)
|
mainf.setRecord_time(DAOHelper.sdf.parse(rs.getString("record_time")));
|
|
if(rs.getString("maint_time_limit")!=null)
|
mainf.setMaint_time_limit(DAOHelper.sdf.parse(rs.getString("maint_time_limit")));
|
|
mainf.setMaint_type_id(rs.getInt("maint_type_id"));
|
mainf.setMaint_result(rs.getString("maint_result"));
|
mainf.setMaint_done(rs.getInt("maint_done"));
|
|
if(rs.getString("maint_done_time")!=null)
|
mainf.setMaint_done_time(DAOHelper.sdf.parse(rs.getString("maint_done_time")));
|
|
|
mainf.setMaint_close(rs.getInt("maint_close"));
|
mainf.setMaster_id(rs.getInt("master_id"));
|
|
mainf.setMaster_audit(rs.getInt("master_audit"));
|
mainf.setCopy_uids(rs.getString("copy_uids"));//数据库存储时用的字符串
|
|
mainf.setAppoint_uid(rs.getInt("appoint_uid"));
|
|
bmd.setBinf(binf);
|
// bmd.setMinf(minf);
|
bmd.setPage(p);
|
bmd.setMainf(mainf);
|
|
list.add(bmd);
|
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} catch (ParseException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
return list;
|
}
|
});
|
}
|
|
List<Batt_Maint_Dealarm> listd=new ArrayList();
|
/*for(int i=0;i<list.size();i++){
|
System.out.println(((Batt_Maint_Dealarm)list.get(i)).getBinf().getBattGroupId());
|
}*/
|
int index=0;
|
//System.out.println(list.size());
|
for(int i=(bmd.getPage().getPageCurr()-1)*bmd.getPage().getPageSize();i<bmd.getPage().getPageSize()*bmd.getPage().getPageCurr()&&i<list.size();i++){
|
listd.add((Batt_Maint_Dealarm) list.get(i));
|
//system.out.println(list.get(i));
|
((Batt_Maint_Dealarm)listd.get(index++)).getPage().setPageAll(list.size());
|
}
|
return listd;
|
|
}
|
|
|
//1.1,1.2根据battgroupid查时间
|
public List serchByInfo(Object obj) {
|
Batt_maint_inf mainf = (Batt_maint_inf) obj;
|
// System.out.println(mainf.getBattGroupId());
|
String sql="select distinct(battgroupid),maint_done_time from db_battinf.tb_batt_maint_inf where battgroupid=? order by battgroupid ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{mainf.getBattGroupId()}, new CallBack() {
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setBattGroupId(rs.getInt("battGroupId"));
|
mainf.setMaint_done_time(DAOHelper.sdf.parse(rs.getString("maint_done_time")));
|
list.add(mainf);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
} catch (ParseException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//3.2 电池故障处理统计查询
|
public List statistical(Object obj){
|
Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
|
BattInf binf=bmd.getBinf();
|
Batt_maint_inf mainf=bmd.getMainf();
|
String baseSql="";
|
List list=DAOHelper.executeQuery(baseSql,DBUtil.getConn(), null, new Batt_maint_infImpl());
|
return list;
|
}
|
|
//0.3查询所有的维护记录
|
public List search() {
|
//Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm);
|
//System.out.println(bmd+"***********");
|
String sql = "select distinct(tb_batt_maint_inf.battgroupid),tb_batt_maint_inf.usr_id,fault_type_id,fault_level,fault_caption,record_time" +
|
",maint_time_limit,maint_type_id,maint_result,maint_done_time,maint_close" +
|
",master_id,master_audit,copy_uids,appoint_uid " +
|
",batt_maint_rec_id,tb_batt_maint_process.usr_id,work_caption,work_caption_time" +
|
",uname" +
|
",stationname,battgroupname " +
|
"from db_battinf.tb_batt_maint_inf,db_battinf.tb_batt_maint_process,db_user.tb_user_inf,db_battinf.tb_battinf " +
|
"where tb_batt_maint_inf.usr_id=tb_batt_maint_process.usr_id " +
|
"and tb_batt_maint_inf.battgroupid=tb_battinf.BattGroupId " +
|
"and tb_batt_maint_inf.usr_id=db_user.tb_user_inf.uId " +
|
"order by work_caption_time desc ";
|
//System.out.println(sql);
|
List list = DAOHelper.executeQuery(sql,
|
DBUtil.getConn(), null,
|
new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_Maint_Dealarm bmd=new Batt_Maint_Dealarm();
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setUsr_id(rs.getInt("usr_id"));
|
mainf.setBattGroupId(rs.getInt("battGroupId"));
|
mainf.setFault_type_id(rs.getInt("fault_type_id"));
|
mainf.setFault_level(rs.getInt("fault_level"));
|
mainf.setFault_caption(rs.getString("fault_caption"));
|
//System.out.println("-----"+rs.getString("record_time")+"-----");
|
if (rs.getString("record_time") != null && rs.getString("record_time").length()>0){
|
//System.out.println(rs.getString("record_time"));
|
mainf.setRecord_time(rs.getTimestamp("record_time"));
|
|
//mainf.setRecord_time(rs.getDate("record_time"));
|
//System.out.println("-----"+rs.getString("maint_time_limit")+"-----");
|
}
|
if (rs.getString("maint_time_limit") != null && rs.getString("maint_time_limit").length()>0){
|
mainf.setMaint_time_limit(rs.getTimestamp("maint_time_limit"));
|
|
} //mainf.setMaint_time_limit(rs.getDate("maint_time_limit"));
|
mainf.setMaint_type_id(rs.getInt("maint_type_id"));
|
mainf.setMaint_result(rs.getString("maint_result"));
|
//System.out.println("-----"+rs.getString("maint_done_time")+"-----");
|
if (rs.getString("maint_done_time") != null && rs.getString("maint_done_time").length()>0){
|
//System.out.println(rs.getString("maint_done_time"));
|
mainf.setMaint_done_time(rs.getTimestamp("maint_done_time"));
|
//System.out.println(mainf.getMaint_done_time());
|
} //mainf.setMaint_done_time(rs.getDate("maint_done_time"));
|
mainf.setMaint_close(rs.getInt("maint_close"));
|
mainf.setMaster_id(rs.getInt("master_id"));
|
mainf.setMaster_audit(rs.getInt("master_audit"));
|
mainf.setCopy_uids(rs.getString("copy_uids"));// 数据库存储时用的字符串
|
mainf.setAppoint_uid(rs.getInt("appoint_uid"));
|
|
Batt_maint_process mprocess=new Batt_maint_process();
|
mprocess.setUname(rs.getString("uname"));
|
mprocess.setBatt_maint_rec_id(rs.getInt("batt_maint_rec_id"));
|
mprocess.setUsr_id(rs.getInt("usr_id"));
|
mprocess.setWork_caption(rs.getString("work_caption"));
|
if(rs.getString("work_caption_time")!=null && rs.getString("work_caption_time").length()>0){
|
mprocess.setWork_caption_time(rs.getTimestamp("work_caption_time"));
|
//mprocess.setWork_caption_time(rs.getDate("work_caption_time"));
|
}
|
|
BattInf binf=new BattInf();
|
binf.setBattGroupName(rs.getString("battGroupName"));
|
binf.setStationName(rs.getString("stationName"));
|
|
Page page=new Page();
|
bmd.setBinf(binf);
|
bmd.setMainf(mainf);
|
bmd.setMprocess(mprocess);
|
bmd.setPage(page);
|
list.add(bmd);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
// List<Batt_Maint_Dealarm> listd=new ArrayList();
|
/*for(int i=0;i<list.size();i++){
|
System.out.println(((Batt_Maint_Dealarm)list.get(i)).getBinf().getBattGroupId());
|
}*/
|
// int index=0;
|
//System.out.println(list.size()+"&&&&&&&&&&&&777777");
|
// for(int i=(bmd.getPage().getPageCurr()-1)*bmd.getPage().getPageSize();i<bmd.getPage().getPageSize()*bmd.getPage().getPageCurr()&&i<list.size();i++){
|
// listd.add((Batt_Maint_Dealarm) list.get(i));
|
// //system.out.println(list.get(i));
|
// ((Batt_Maint_Dealarm)listd.get(index++)).getPage().setPageAll(list.size());
|
// }
|
return list;
|
|
}
|
|
//0.4查询所有故障的电池组
|
public List searchAll() {
|
String sql="select distinct(battgroupid),usr_id,fault_type_id,fault_level,fault_caption,record_time" +
|
",maint_time_limit,maint_type_id,maint_result,maint_done_time,maint_close" +
|
",master_id,master_audit,copy_uids,appoint_uid " +
|
"from db_battinf.tb_batt_maint_inf " +
|
"order by maint_done_time desc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setUsr_id(rs.getInt("usr_id"));
|
mainf.setBattGroupId(rs.getInt("battGroupId"));
|
mainf.setFault_type_id(rs.getInt("fault_type_id"));
|
mainf.setFault_level(rs.getInt("fault_level"));
|
mainf.setFault_caption(rs.getString("fault_caption"));
|
if (rs.getString("record_time") != null)
|
mainf.setRecord_time(rs.getTimestamp("record_time"));
|
if (rs.getString("maint_time_limit") != null)
|
mainf.setMaint_time_limit(rs.getTimestamp("maint_time_limit"));
|
mainf.setMaint_type_id(rs.getInt("maint_type_id"));
|
mainf.setMaint_result(rs.getString("maint_result"));
|
if (rs.getString("maint_done_time") != null)
|
mainf.setMaint_done_time(rs.getTimestamp("maint_done_time"));
|
mainf.setMaint_close(rs.getInt("maint_close"));
|
mainf.setMaster_id(rs.getInt("master_id"));
|
mainf.setMaster_audit(rs.getInt("master_audit"));
|
mainf.setCopy_uids(rs.getString("copy_uids"));// 数据库存储时用的字符串
|
mainf.setAppoint_uid(rs.getInt("appoint_uid"));
|
|
list.add(mainf);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//0.4/0.8根据城市查询所有故障的电池组(故障率和维护率)
|
public List searchByStationName(Object obj) {
|
Batt_Maint_Dealarm bmd=(Batt_Maint_Dealarm) obj;
|
BattInf binf=bmd.getBinf();
|
Batt_maint_inf mainf=bmd.getMainf();
|
String sql="";
|
String baseSql="select distinct(tb_batt_maint_inf.battgroupid),usr_id,fault_type_id,fault_level,fault_caption,record_time,maint_time_limit,maint_type_id,maint_result,maint_done_time,maint_close,master_id,master_audit,copy_uids,appoint_uid " +
|
"from db_battinf.tb_batt_maint_inf,db_battinf.tb_battinf " +
|
"where tb_batt_maint_inf.battgroupid=tb_battinf.battgroupid " +
|
"and stationname like ? " ;
|
//是否已修复
|
String maintSqlT=" and maint_done!=? "; //全部
|
String maintSqlF=" and maint_done=? "; //1求维护率
|
if(mainf.getMaint_done()==100){ //100求故障率
|
baseSql+=maintSqlT;
|
}else{
|
baseSql+=maintSqlF;
|
}
|
String endSql=" order by maint_done_time desc ";
|
sql=baseSql+endSql;
|
|
//System.out.println(sql);
|
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName()+"%",mainf.getMaint_done()}, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Batt_maint_inf mainf=new Batt_maint_inf();
|
mainf.setUsr_id(rs.getInt("usr_id"));
|
mainf.setBattGroupId(rs.getInt("battGroupId"));
|
mainf.setFault_type_id(rs.getInt("fault_type_id"));
|
mainf.setFault_level(rs.getInt("fault_level"));
|
mainf.setFault_caption(rs.getString("fault_caption"));
|
if (rs.getString("record_time").length()>0)
|
mainf.setRecord_time(rs.getTimestamp(("record_time")));
|
if (rs.getString("maint_time_limit").length()>0)
|
mainf.setMaint_time_limit(rs.getTimestamp("maint_time_limit"));
|
mainf.setMaint_type_id(rs.getInt("maint_type_id"));
|
mainf.setMaint_result(rs.getString("maint_result"));
|
if (rs.getString("maint_done_time").length()>0)
|
mainf.setMaint_done_time(rs.getTimestamp("maint_done_time"));
|
mainf.setMaint_close(rs.getInt("maint_close"));
|
mainf.setMaster_id(rs.getInt("master_id"));
|
mainf.setMaster_audit(rs.getInt("master_audit"));
|
mainf.setCopy_uids(rs.getString("copy_uids"));// 数据库存储时用的字符串
|
mainf.setAppoint_uid(rs.getInt("appoint_uid"));
|
|
list.add(mainf);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
//根据电池组id查询电池的维护记录
|
public List searchByBattgroupId(Object obj) {
|
Batt_maint_inf bmi=(Batt_maint_inf)obj;
|
String sql="select num,BattGroupId,usr_id,fault_type_id,fault_type,fault_level,fault_caption," +
|
"fault_time,record_uid,record_time,maint_time_limit,maint_type_id,maint_type,maint_result," +
|
"maint_done,maint_done_time,maint_close,master_id,master_audit,copy_uids,appoint_uid,master_check,remark " +
|
"from db_battinf.tb_batt_maint_inf where BattGroupId=?";
|
return DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{bmi.getBattGroupId()}, new CallBack() {
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while (rs.next()) {
|
Batt_maint_inf b=new Batt_maint_inf();
|
b.setNum(rs.getInt("num"));
|
b.setBattGroupId(rs.getInt("BattGroupId"));
|
b.setUsr_id(rs.getInt("usr_id"));
|
b.setFault_type_id(rs.getInt("fault_type_id"));
|
b.setFault_type(rs.getString("fault_type"));
|
b.setFault_level(rs.getInt("fault_level"));
|
b.setFault_caption(rs.getString("fault_caption"));
|
b.setFault_time(rs.getTimestamp("fault_time"));
|
b.setRecord_uid(rs.getInt("record_uid"));
|
b.setRecord_time(rs.getTimestamp("record_time"));
|
b.setMaint_time_limit(rs.getTimestamp("maint_time_limit"));
|
b.setMaint_type_id(rs.getInt("maint_type_id"));
|
b.setMaint_type(rs.getString("maint_type"));
|
b.setMaint_result(rs.getString("maint_result"));
|
b.setMaint_done(rs.getInt("maint_done"));
|
b.setMaint_done_time(rs.getTimestamp("maint_done_time"));
|
b.setMaint_close(rs.getInt("maint_close"));
|
b.setMaster_id(rs.getInt("master_id"));
|
b.setCopy_uids(rs.getString("copy_uids"));
|
b.setAppoint_uid(rs.getInt("appoint_uid"));
|
b.setMaster_check(rs.getString("master_check"));
|
b.setRemark(rs.getString("remark"));
|
list.add(b);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
}
|
|
public static void main(String[] args) throws ParseException {
|
|
Batt_maint_infImpl bimpl=new Batt_maint_infImpl();
|
BattInfImpl biml =new BattInfImpl();
|
BattInf binf = new BattInf();
|
|
|
binf.setStationName("");
|
binf.setStationName1("一枢纽");
|
//binf.setBattGroupName("");
|
binf.setBattGroupId(0);
|
binf.setBattGroupName1("");
|
binf.setBattProducer("光宇");
|
binf.setMonCapStd(0f);
|
binf.setMonVolStd(0f);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2016-07-14");
|
binf.setBattProductDate(ActionUtil.getSimpDate(date1));
|
binf.setBattProductDate1(ActionUtil.getSimpDate(date2));
|
binf.setBattInUseDate(ActionUtil.getSimpDate(date1));
|
binf.setBattInUseDate1(ActionUtil.getSimpDate(date2));
|
|
|
Batt_maint_inf mainf = new Batt_maint_inf();
|
mainf.setRemark("100");
|
mainf.setMaint_done_time(ActionUtil.getSimpDate(date1));
|
mainf.setMaint_done_time1(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.setUName("0");
|
|
Page p=new Page();
|
p.setPageCurr(1);
|
p.setPageSize(1);
|
|
Batt_Maint_Dealarm bmd = new Batt_Maint_Dealarm();
|
bmd.setBinf(binf);
|
bmd.setMainf(mainf);
|
bmd.setTdata(tdata);
|
bmd.setPage(p);
|
bmd.setUinf(uinf);
|
|
//List<Batt_Maint_Dealarm> list = bimpl.serchByCondition(bmd);
|
// for (Batt_Maint_Dealarm b : list) {
|
// System.out.println(b.getMainf());
|
// }
|
|
}
|
|
|
}
|
