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.dao.ThreadLocalDateUtil; import com.fgkj.db.DBUtil; import com.fgkj.db.IDatabaseName; import com.fgkj.dto.BattInf; import com.fgkj.dto.Page; import com.fgkj.dto.Task_Batt_Test; import com.fgkj.dto.User_inf; import com.fgkj.dto.User_task; import com.fgkj.dto.User_task_batt_check; import com.fgkj.dto.User_task_batt_test; import com.fgkj.dto.User_task_user_list; public class User_taskImpl implements BaseDAO,CallBack{ public List getResults(ResultSet rs) { List list=new ArrayList(); int id=0; try { while(rs.next()){ Task_Batt_Test tbt=new Task_Batt_Test(); User_task utask=new User_task(); utask.setNum(rs.getInt("num")); utask.setTask_id(rs.getInt("task_id")); utask.setTask_id_ex(rs.getInt("task_id_ex")); utask.setTask_type(rs.getInt("task_type")); utask.setTask_name(rs.getString("task_name")); utask.setTask_enabled(rs.getInt("task_enabled")); utask.setTask_create_date(rs.getTimestamp("task_create_date")); utask.setTask_start_date(rs.getTimestamp("task_start_date")); utask.setTask_close_date(rs.getTimestamp("task_close_date")); utask.setSubtask_count(rs.getInt("subtask_count")); utask.setTask_notice_sum(rs.getInt("task_notice_sum")); utask.setTask_notice_starttime(rs.getTimestamp("task_notice_starttime")); utask.setTask_notice_endtime(rs.getTimestamp("task_notice_endtime")); utask.setTask_notice_timeinterval(rs.getInt("task_notice_timeinterval")); utask.setTask_notice_count(rs.getInt("task_notice_count")); utask.setTask_notice_latesttime(rs.getTimestamp("task_notice_latesttime")); utask.setTask_autoinc_day_count(rs.getInt("task_autoinc_day_count")); utask.setTask_delay_day_count(rs.getInt("task_delay_day_count")); utask.setTask_pass_saturday(rs.getInt("task_pass_saturday")); utask.setTask_pass_sunday(rs.getInt("task_pass_sunday")); utask.setTask_pass_jiejiari(rs.getInt("task_pass_jiejiari")); utask.setTask_confirm(rs.getInt("task_confirm")); utask.setTask_complete(rs.getInt("task_complete")); utask.setTask_complete_date(rs.getTimestamp("task_complete_date")); utask.setTask_complete_confirm(rs.getInt("task_complete_confirm")); utask.setTask_complete_confirm_date(rs.getTimestamp("task_complete_confirm_date")); utask.setTask_confirm_date(rs.getTimestamp("task_confirm_date")); utask.setNotice_master_enabled(rs.getInt("notice_master_enabled")); utask.setNotice_master(rs.getInt("notice_master")); utask.setNote(rs.getString("note")); User_task_batt_test utest=new User_task_batt_test(); utest.setTask_usr_ids(rs.getString("task_usr_ids")); User_task_batt_check ucheck=new User_task_batt_check(); ucheck.setTask_usr_ids(rs.getString("task_usr_ids")); User_task_user_list ulist=new User_task_user_list(); ulist.setUId(rs.getInt("uId")); tbt.setUtask(utask); tbt.setUtest(utest); tbt.setUlist(ulist); tbt.setUcheck(ucheck); list.add(tbt); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } public boolean add(Object obj) { User_task u=(User_task) obj; String sql="insert into db_user.tb_user_task(task_id,task_id_ex,task_name,task_type,task_enabled,task_create_date," + "task_start_date,task_close_date,subtask_count,task_notice_sum,task_notice_starttime,task_notice_endtime," + "task_notice_timeinterval,task_notice_count,task_notice_latesttime,task_autoinc_day_count,task_delay_day_count," + "task_pass_saturday,task_pass_sunday,task_pass_jiejiari,task_confirm,task_confirm_date,task_complete,task_complete_date,task_complete_confirm," + "task_complete_confirm_date,notice_master_enabled,notice_master,note) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{u.getTask_id(),u.getTask_id_ex(), u.getTask_name(),u.getTask_type(),u.getTask_enabled(),u.getTask_create_date(),u.getTask_start_date(),u.getTask_close_date(), u.getSubtask_count(),u.getTask_notice_sum(),u.getTask_notice_starttime(),u.getTask_notice_endtime(),u.getTask_notice_timeinterval(), u.getTask_notice_count(),u.getTask_notice_latesttime(),u.getTask_autoinc_day_count(),u.getTask_delay_day_count(), u.getTask_pass_saturday(),u.getTask_pass_sunday(),u.getTask_pass_jiejiari(),u.getTask_confirm(),u.getTask_confirm_date(),u.getTask_complete(), u.getTask_complete_date(),u.getTask_complete_confirm(),u.getTask_complete_confirm_date(),u.getNotice_master_enabled(),u.getNotice_master(),u.getNote()}); return bl; } //4.1添加作业并确定 public String addPro(Object obj){ User_task utask=(User_task) obj; String sql="insert into db_user.tb_user_task(task_id,task_id_ex,task_name,task_type,task_enabled,task_create_date," + "task_start_date,task_close_date,subtask_count,task_notice_sum,task_notice_starttime,task_notice_endtime," + "task_notice_timeinterval,task_notice_count,task_notice_latesttime,task_autoinc_day_count,task_delay_day_count," + "task_pass_saturday,task_pass_sunday,task_pass_jiejiari,task_confirm,task_confirm_date,task_complete,task_complete_date,task_complete_confirm," + "task_complete_confirm_date,notice_master_enabled,notice_master,note) " + "values("+utask.getTask_id()+","+utask.getTask_id_ex()+",'"+utask.getTask_name()+"',"+utask.getTask_type()+","+utask.getTask_enabled()+",'"+DAOHelper.sdf.format(utask.getTask_create_date())+"','" +DAOHelper.sdf.format(utask.getTask_start_date())+"','"+DAOHelper.sdf.format(utask.getTask_close_date())+"',"+utask.getSubtask_count()+","+utask.getTask_notice_sum()+",'"+DAOHelper.sdf.format(utask.getTask_notice_starttime())+"','"+DAOHelper.sdf.format(utask.getTask_notice_endtime())+"'," +utask.getTask_notice_timeinterval()+","+utask.getTask_notice_count()+",'"+DAOHelper.sdf.format(utask.getTask_notice_latesttime())+"',"+utask.getTask_autoinc_day_count()+","+utask.getTask_delay_day_count()+"," +utask.getTask_pass_saturday()+","+utask.getTask_pass_sunday()+","+utask.getTask_pass_jiejiari()+","+utask.getTask_confirm()+",'"+DAOHelper.sdf.format(utask.getTask_confirm_date())+"',"+utask.getTask_complete()+",'" +DAOHelper.sdf.format(utask.getTask_complete_date())+"',"+utask.getTask_complete_confirm()+",'"+DAOHelper.sdf.format(utask.getTask_complete_confirm_date())+"',"+utask.getNotice_master_enabled()+","+utask.getNotice_master()+",'"+utask.getNote()+"')"; return sql; } //4.1作业管理(修改作业名称，作业使能，作业开始时间，作业提醒次数，作业提醒时间，作业主管提醒使能,确认作业,确认作业时间，完成作业，完成作业确认) public boolean update(Object obj) { User_task utask=(User_task) obj; String sql="update db_user.tb_user_task set task_name=?,task_enabled=?,task_start_date=?,task_notice_sum=?,task_notice_starttime=?,task_notice_endtime=?,task_confirm=?,task_confirm_date=?,task_complete=?,task_complete_confirm=?,notice_master_enabled=? where task_id=?"; Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ utask.getTask_name(), utask.getTask_enabled(), utask.getTask_start_date(), utask.getTask_notice_sum(), utask.getTask_notice_starttime(), utask.getTask_notice_endtime(), utask.getTask_confirm(), utask.getTask_confirm_date(), utask.getTask_complete(), utask.getTask_complete_confirm(), utask.getNotice_master_enabled(), utask.getTask_id(), }); return bl; } //4.1作业管理(增加一条新的作业时，要将最新的一条作业的task_id_ex值+1) public String updatePro(Object obj){ User_task utask=(User_task) obj; String sql="update db_user.tb_user_task set " + "task_id_ex="+utask.getTask_id()+ " where task_id="+(utask.getTask_id()-1); return sql; } //4.1作业管理(作业删除) public boolean del(Object obj) { User_task utask=(User_task) obj; //删除utask中的数据 String sql="delete from db_user.tb_user_task where task_id=?"; //删除utest中的数据 String sqlT="delete from db_user.tb_user_task_batt_test where task_id=?"; //删除ucheck中的数据 String sqlC="delete from db_user.tb_user_task_batt_check where task_id=?"; Boolean blT=false; Boolean blF=false; if(utask.getTask_type()==2){ blT=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{utask.getTask_id()}); blF=DAOHelper.executeUpdate(DBUtil.getConn(), sqlC, new Object[]{utask.getTask_id()}); }else{ blT=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{utask.getTask_id()}); blF=DAOHelper.executeUpdate(DBUtil.getConn(), sqlT, new Object[]{utask.getTask_id()}); } return blT|blF; } public List searchAll() { String sql="select * from db_user.tb_user_task"; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new User_taskImpl()); return list; } //4.1作业管理查询user_task所有信息 public List serchByCondition(Object obj) { Task_Batt_Test tbt=(Task_Batt_Test) obj; BattInf binf=tbt.getBinf(); User_task utask=tbt.getUtask(); User_inf uinf=tbt.getUinf(); User_task_user_list ulist=tbt.getUlist(); User_task_batt_test utest=tbt.getUtest(); User_task_batt_check ucheck=tbt.getUcheck(); List list=null; String sql=""; String baseSql=""; String baseSqlTest="select distinct(tb_user_task.task_id),tb_user_task.num,task_id_ex,task_name,task_type,tb_user_task.task_enabled,task_create_date,task_start_date,tb_user_task.task_close_date,subtask_count,task_notice_sum,tb_user_task.task_notice_starttime,tb_user_task.task_notice_endtime," + "task_notice_timeinterval,tb_user_task.task_notice_count,tb_user_task.task_notice_latesttime,task_autoinc_day_count,task_delay_day_count,task_pass_saturday,task_pass_sunday,task_pass_jiejiari,task_confirm,task_confirm_date,task_complete,task_complete_date,task_complete_confirm," + "task_complete_confirm_date,notice_master_enabled,notice_master,tb_user_task.note," + "task_usr_ids,uid " + "from db_user.tb_user_task,db_battinf.tb_battinf,db_user.tb_user_task_batt_test,db_user.tb_user_task_user_list " + "where tb_user_task.task_id=tb_user_task_batt_test.task_id " + "and tb_user_task.task_id=tb_user_task_user_list.task_id " + "and tb_user_task_batt_test.BattGroupId=db_battinf.tb_battinf.BattGroupId " + "and task_type=? " + "and (task_create_date)>=(?) and (task_create_date)<=(?) " + "and (task_complete_date)>=(?) and (task_complete_date)<=(?) " + "and (task_exe_date)>=(?) and (task_exe_date)<=(?) "; String baseSqlCheck="select distinct(tb_user_task.task_id),tb_user_task.num,task_id_ex,task_name,task_type,tb_user_task.task_enabled,task_create_date,task_start_date,tb_user_task.task_close_date,subtask_count,task_notice_sum,tb_user_task.task_notice_starttime,tb_user_task.task_notice_endtime," + "task_notice_timeinterval,tb_user_task.task_notice_count,tb_user_task.task_notice_latesttime,task_autoinc_day_count,task_delay_day_count,task_pass_saturday,task_pass_sunday,task_pass_jiejiari,task_confirm,task_confirm_date,task_complete,task_complete_date,task_complete_confirm," + "task_complete_confirm_date,notice_master_enabled,notice_master,tb_user_task.note," + "task_usr_ids,uid " + "from db_user.tb_user_task,db_battinf.tb_battinf,db_user.tb_user_task_batt_check,db_user.tb_user_task_user_list " + "where tb_user_task.task_id=tb_user_task_batt_check.task_id " + "and tb_user_task.task_id=tb_user_task_user_list.task_id " + "and tb_user_task_batt_check.BattGroupId=db_battinf.tb_battinf.BattGroupId " + "and task_type=? " + "and (task_create_date)>=(?) and (task_create_date)<=(?) " + "and (task_complete_date)>=(?) and (task_complete_date)<=(?) " + "and (task_exe_date)>=(?) and (task_exe_date)<=(?) "; //用于维护区 String station1SqlT=" and stationname1!=? ";//全部 String station1SqlF=" and stationname1=? "; if(binf.getStationName1().equals("")){ baseSqlTest+=station1SqlT; baseSqlCheck+=station1SqlT; }else{ baseSqlTest+=station1SqlF; baseSqlCheck+=station1SqlF; } //用于机房站点 String stationSqlT=" and stationname!=? ";//全部 String stationSqlF=" and stationname=? "; if(binf.getStationName().equals("")){ baseSqlTest+=stationSqlT; baseSqlCheck+=stationSqlT; }else{ baseSqlTest+=stationSqlF; baseSqlCheck+=stationSqlF; } //用于电池类型 String producerSqlT=" and battproducer!=? ";//全部 String producerSqlF=" and battproducer=? "; if(binf.getBattProducer().equals("")){ baseSqlTest+=producerSqlT; baseSqlCheck+=producerSqlT; }else{ baseSqlTest+=producerSqlF; baseSqlCheck+=producerSqlF; } //用于包机人 String baojiSqlT=" and db_battinf.tb_battinf.BattGroupId in(select distinct(db_battinf.tb_battinf.BattgroupId) " + "from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " + "where db_user.tb_user_battgroup_baojigroup_battgroup.battgroupid=db_battinf.tb_battinf.BattgroupId " + "and db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id= db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id " + "and db_user.tb_user_inf.uId=db_user.tb_user_battgroup_baojigroup_usr.uid and db_user.tb_user_inf.uId!=? ) "; String baojiSqlF=" and db_battinf.tb_battinf.BattGroupId in(select distinct(db_battinf.tb_battinf.BattgroupId) " + "from db_battinf.tb_battinf,db_user.tb_user_battgroup_baojigroup_battgroup,db_user.tb_user_battgroup_baojigroup_usr,db_user.tb_user_inf " + "where db_user.tb_user_battgroup_baojigroup_battgroup.battgroupid=db_battinf.tb_battinf.BattgroupId " + "and db_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id= db_user.tb_user_battgroup_baojigroup_usr.baoji_group_id " + "and db_user.tb_user_inf.uId=db_user.tb_user_battgroup_baojigroup_usr.uid and db_user.tb_user_inf.uId=? and db_user.tb_user_inf.ubaojiusr=1 ) "; if(uinf.getUId()==100){ baseSqlTest+=baojiSqlT; baseSqlCheck+=baojiSqlT; }else{ baseSqlTest+=baojiSqlF; baseSqlCheck+=baojiSqlF; } //用于作业执行人 String testSqlT=" and tb_user_task_batt_test.task_usr_ids!=? "; String testSqlF=" and tb_user_task_batt_test.task_usr_ids=? "; String checkSqlT=" and tb_user_task_batt_check.task_usr_ids!=? "; String checkSqlF=" and tb_user_task_batt_check.task_usr_ids=? "; //用于判断作业类型 if(utask.getTask_type()!=2){ baseSql=baseSqlTest; if(utest.getTask_usr_ids().equals("100")){ baseSql+=testSqlT; //System.out.println("&&&&&&&&&&&&&&&&&&&&&"); }else{ baseSql+=testSqlF; } }else if(utask.getTask_type()==2){ baseSql=baseSqlCheck; if(ucheck.getTask_usr_ids().equals("100")){ baseSql+=checkSqlT; }else{ baseSql+=checkSqlF; } } //用于完成状态 String comSqlT=" and task_complete!=?"; String comSqlF=" and task_complete=?"; if(utask.getTask_complete()==100){ baseSql+=comSqlT; }else{ baseSql+=comSqlF; } //用于电池组条件 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 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 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 listSqlT=" and tb_user_task_user_list.uId!=? and tb_user_task_user_list.usr_type=2 "; String listSqlF=" and tb_user_task_user_list.uId=? and tb_user_task_user_list.usr_type=2 ";//2代表指派人 if(ulist.getUId()==0){ baseSql+=listSqlT; }else{ baseSql+=listSqlF; } //按照task_id 排序 String endSql=" order by tb_user_task.task_id "; sql=baseSql+endSql; //System.out.println("utask :"+sql); if(utask.getTask_type()!=2){ list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{utask.getTask_type() ,utask.getTask_create_date(),utask.getTask_create_date1() ,utask.getTask_complete_date(),utask.getTask_complete_date1(),utest.getTask_exe_date(),utest.getTask_exe_date1() ,binf.getStationName1(),binf.getStationName(),binf.getBattProducer() ,uinf.getUId(),utest.getTask_usr_ids(),utask.getTask_complete() ,binf.getBattGroupId(),binf.getMonVolStd(),binf.getMonCapStd(),"%"+binf.getBattGroupName1()+"%" ,ulist.getUId() }, new User_taskImpl()); }else if(utask.getTask_type()==2){ list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{utask.getTask_type() ,utask.getTask_create_date(),utask.getTask_create_date1() ,utask.getTask_complete_date(),utask.getTask_complete_date1(),ucheck.getTask_exe_date(),ucheck.getTask_exe_date1() ,binf.getStationName1(),binf.getStationName(),binf.getBattProducer() ,uinf.getUId(),ucheck.getTask_usr_ids(),utask.getTask_complete() ,binf.getBattGroupId(),binf.getMonVolStd(),binf.getMonCapStd(),"%"+binf.getBattGroupName1()+"%" ,ulist.getUId() }, new User_taskImpl()); } return list; } //0.1首页根据uid查询对应人的作业 public List serchByInfo(Object obj) { Task_Batt_Test tbt=(Task_Batt_Test) obj; User_inf uinf=tbt.getUinf(); User_task utask=tbt.getUtask(); String sql=""; String baseSql="select distinct(db_user.tb_user_task.task_id),tb_user_task.num,task_id_ex,task_name,task_type,tb_user_task.task_enabled,task_create_date,task_start_date,tb_user_task.task_close_date,subtask_count,task_notice_sum,tb_user_task.task_notice_starttime,tb_user_task.task_notice_endtime," + "task_notice_timeinterval,tb_user_task.task_notice_count,tb_user_task.task_notice_latesttime,task_autoinc_day_count,task_delay_day_count,task_pass_saturday,task_pass_sunday,task_pass_jiejiari,task_confirm,task_confirm_date,task_complete,task_complete_date,task_complete_confirm," + "task_complete_confirm_date,notice_master_enabled,notice_master,tb_user_task.note" + ",db_user.tb_user_task_batt_test.task_id as task_id1,db_user.tb_user_task_batt_test.task_usr_ids as task_usr_ids1,db_user.tb_user_task_batt_test.battgroupid as battgroupid1,db_user.tb_user_task_batt_test.task_exe_date as task_exe_date1,db_user.tb_user_task_batt_test.task_close_date as task_close_date1 " + ",db_user.tb_user_task_batt_check.task_id as task_id2,db_user.tb_user_task_batt_check.task_usr_ids as task_usr_ids2,db_user.tb_user_task_batt_check.battgroupid as battgroupid2,db_user.tb_user_task_batt_check.task_exe_date as task_exe_date2,db_user.tb_user_task_batt_check.task_close_date as task_close_date2 " + "from db_user.tb_user_task " + "left outer join db_user.tb_user_task_batt_test on db_user.tb_user_task.task_id=db_user.tb_user_task_batt_test.task_id " + "left outer join db_user.tb_user_task_batt_check on db_user.tb_user_task.task_id=db_user.tb_user_task_batt_check.task_id " + "where (db_user.tb_user_task_batt_test.task_usr_ids like ? " + "or db_user.tb_user_task_batt_check.task_usr_ids like ?) " + "and to_days(tb_user_task.task_close_date)>=to_days(?) and to_days(tb_user_task.task_close_date)<=to_days(?) "; //作业类型 String sqlC=" and task_type in(?,0,1) ";//核对性放电作业 tasktype=10 String sqlM=" and task_type=? "; //日常巡检放电作业2//拉闸动环3 String sqlA=" and task_type!=? "; //全部 tasktype=100 if(utask.getTask_type()==10){ baseSql+=sqlC; }else if(utask.getTask_type()==2){ baseSql+=sqlM; }else if(utask.getTask_type()==3){ baseSql+=sqlM; }else if(utask.getTask_type()==100){ baseSql+=sqlA; } //作业是否完成 String sqlCompleteT=" and task_complete!=? ";//全部 String sqlCompleteF=" and task_complete=? ";//完成1或否0 if(utask.getTask_complete()==100){ baseSql+=sqlCompleteT; }else{ baseSql+=sqlCompleteF; } String endSql=" order by task_start_date desc "; sql=baseSql+endSql; //System.out.println(sql); List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUId(),uinf.getUId(),utask.getTask_close_date(),utask.getTask_close_date1(),utask.getTask_type(),utask.getTask_complete()}, new CallBack() { public List getResults(ResultSet rs) { List list=new ArrayList(); try { while (rs.next()) { Task_Batt_Test tbt=new Task_Batt_Test(); User_task utask=new User_task(); utask.setNum(rs.getInt("num")); utask.setTask_id(rs.getInt("task_id")); utask.setTask_id_ex(rs.getInt("task_id_ex")); utask.setTask_type(rs.getInt("task_type")); utask.setTask_name(rs.getString("task_name")); utask.setTask_enabled(rs.getInt("task_enabled")); utask.setTask_create_date(rs.getDate(("task_create_date"))); utask.setTask_start_date(rs.getTimestamp("task_start_date")); utask.setTask_close_date(rs.getTimestamp("task_close_date")); utask.setSubtask_count(rs.getInt("subtask_count")); utask.setTask_notice_sum(rs.getInt("task_notice_sum")); utask.setTask_notice_starttime(rs.getTimestamp("task_notice_starttime")); utask.setTask_notice_endtime(rs.getTimestamp("task_notice_endtime")); utask.setTask_notice_timeinterval(rs.getInt("task_notice_timeinterval")); utask.setTask_notice_count(rs.getInt("task_notice_count")); utask.setTask_notice_latesttime(rs.getTimestamp("task_notice_latesttime")); utask.setTask_autoinc_day_count(rs.getInt("task_autoinc_day_count")); utask.setTask_delay_day_count(rs.getInt("task_delay_day_count")); utask.setTask_pass_saturday(rs.getInt("task_pass_saturday")); utask.setTask_pass_sunday(rs.getInt("task_pass_sunday")); utask.setTask_pass_jiejiari(rs.getInt("task_pass_jiejiari")); utask.setTask_confirm(rs.getInt("task_confirm")); utask.setTask_confirm_date(rs.getTimestamp("task_confirm_date")); utask.setTask_complete(rs.getInt("task_complete")); utask.setTask_complete_date(rs.getTimestamp("task_complete_date")); utask.setTask_complete_confirm(rs.getInt("task_complete_confirm")); utask.setTask_complete_confirm_date(rs.getTimestamp("task_complete_confirm_date")); utask.setNotice_master_enabled(rs.getInt("notice_master_enabled")); utask.setNotice_master(rs.getInt("notice_master")); utask.setNote(rs.getString("note")); User_task_batt_test utest=new User_task_batt_test(); utest.setTask_id(rs.getInt("task_id1")); utest.setTask_usr_ids(rs.getString("task_usr_ids1")); utest.setBattGroupId(rs.getInt("battgroupid1")); if(rs.getString("task_exe_date1")!=null){ utest.setTask_exe_date(rs.getTimestamp("task_exe_date1")); } if(rs.getString("task_close_date1")!=null){ utest.setTask_close_date(rs.getTimestamp("task_close_date1")); } User_task_batt_check ucheck=new User_task_batt_check(); ucheck.setTask_id(rs.getInt("task_id2")); ucheck.setTask_usr_ids(rs.getString("task_usr_ids2")); ucheck.setBattGroupId(rs.getInt("battgroupid2")); if(rs.getString("task_exe_date2")!=null){ ucheck.setTask_exe_date(rs.getTimestamp("task_exe_date2")); } if(rs.getString("task_close_date2")!=null){ ucheck.setTask_close_date(rs.getTimestamp("task_close_date2")); } BattInf binf=new BattInf(); Page page=new Page(); tbt.setUtask(utask); tbt.setUtest(utest); tbt.setUcheck(ucheck); tbt.setBinf(binf); tbt.setPage(page); list.add(tbt); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } return list; } }); List listd=new ArrayList(); //System.out.println(list.size()); int index=0; //System.out.println(list.size()); for(int i=(tbt.getPage().getPageCurr()-1)*tbt.getPage().getPageSize();i=(?) and (task_complete_date)<=(?) " + "and (task_exe_date)>=(?) and (task_exe_date)<=(?) "; String baseSqlCheck="select distinct(tb_user_task.task_id)," + " tb_user_task_batt_check.num,task_usr_ids,tb_user_task_batt_check.BattGroupId,tb_user_task_batt_check.task_enabled,task_exe_date,tb_user_task_batt_check.task_close_date,test_complete,test_completetime,batt_clean_done," + "batt_clean_done_result,batt_clean_done_recheck,batt_clean_done_recheck_result,batt_clean_done_recheck_check," + "batt_clean_done_recheck_check_result,battvol_tempe_done,battvol_tempe_done_result,battvol_tempe_done_recheck,battvol_tempe_done_recheck_result,"+ "battvol_tempe_done_recheck_check,battvol_tempe_done_recheck_check_result,battfault_check_done,battfault_check_done_result,battfault_check_done_recheck," + "battfault_check_done_recheck_result,battfault_check_done_recheck_check,battfault_check_done_recheck_check_result," + "stationname ,battgroupname " + "from db_user.tb_user_task,db_battinf.tb_battinf,db_user.tb_user_task_batt_check,db_user.tb_user_task_user_list " + "where tb_user_task.task_id=tb_user_task_batt_check.task_id " + "and tb_user_task_batt_check.BattGroupId=db_battinf.tb_battinf.BattGroupId " + "and stationname1 like ? and stationname like ? and task_type=? " + "and (task_complete_date)>=(?) and (task_complete_date)<=(?) " + "and (task_exe_date)>=(?) and (task_exe_date)<=(?) "; //用于作业执行人 String testSqlT=" and tb_user_task_batt_test.task_usr_ids like ? "; String checkSqlT=" and tb_user_task_batt_check.task_usr_ids like ? "; //用于判断作业类型 if(utask.getTask_type()!=2){ baseSql=baseSqlTest; baseSql+=testSqlT; //System.out.println("&&&&&&&&&&&&&&&&&&&&&"); }else if(utask.getTask_type()==2){ baseSql=baseSqlCheck; baseSql+=checkSqlT; } //用于完成状态 String comSqlT=" and task_complete!=?"; String comSqlF=" and task_complete=?"; if(utask.getTask_complete()==100){ baseSql+=comSqlT; }else{ baseSql+=comSqlF; } //用于电池组条件 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; } //按照task_id 排序 String endSql=" order by tb_user_task.task_id,db_battinf.tb_battinf.BattGroupId"; sql=baseSql+endSql; //System.out.println(sql); if(utask.getTask_type()!=2){ list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName1()+"%","%"+binf.getStationName()+"%" ,utask.getTask_type() ,utask.getTask_complete_date(),utask.getTask_complete_date1(),utest.getTask_exe_date(),utest.getTask_exe_date1() ,"%"+utest.getTask_usr_ids()+"%",utask.getTask_complete() ,binf.getBattGroupId() }, new CallBack() { public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Task_Batt_Test tbt=new Task_Batt_Test(); User_task_batt_test utest=new User_task_batt_test(); utest.setNum(rs.getInt("num")); utest.setTask_id(rs.getInt("task_id")); utest.setTask_usr_ids(rs.getString("task_usr_ids")); utest.setBattGroupId(rs.getInt("BattGroupId")); utest.setTask_enabled(rs.getInt("task_enabled")); utest.setTask_exe_date(rs.getTimestamp("task_exe_date")); utest.setTask_close_date(rs.getTimestamp("task_close_date")); utest.setTask_notice_starttime(rs.getTimestamp("task_notice_starttime")); utest.setTask_notice_endtime(rs.getTimestamp("task_notice_endtime")); utest.setTask_notice_count(rs.getInt("task_notice_count")); utest.setTask_notice_latesttime(rs.getTimestamp("task_notice_latesttime")); utest.setTask_notice_master(rs.getInt("task_notice_master")); utest.setTest_complete(rs.getInt("test_complete")); utest.setTest_completetime(rs.getTimestamp("test_completetime")); utest.setTest_starttime(rs.getTimestamp("test_starttime")); utest.setTest_record_count_id(rs.getInt("test_record_count_id")); utest.setNote(rs.getString("note")); BattInf binf=new BattInf(); binf.setBattGroupId(rs.getInt("battGroupId")); binf.setStationName(rs.getString("stationName")); binf.setBattGroupName(rs.getString("battGroupName")); binf.setStationName1(rs.getString("task_usr_ids")); User_inf uinf=new User_inf(); Page p=new Page(); tbt.setBinf(binf); tbt.setUtest(utest); tbt.setPage(p); tbt.setUinf(uinf); list.add(tbt); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); }else if(utask.getTask_type()==2){ //System.out.println(sql); list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+binf.getStationName1()+"%","%"+binf.getStationName()+"%" ,utask.getTask_type() ,utask.getTask_complete_date(),utask.getTask_complete_date1(),ucheck.getTask_exe_date(),ucheck.getTask_exe_date1() ,"%"+ucheck.getTask_usr_ids()+"%",utask.getTask_complete() ,binf.getBattGroupId() }, new CallBack() { public List getResults(ResultSet rs) { List list=new ArrayList(); try { while(rs.next()){ Task_Batt_Test tbt=new Task_Batt_Test(); User_task_batt_check ucheck=new User_task_batt_check(); ucheck.setNum(rs.getInt("num")); ucheck.setTask_id(rs.getInt("task_id")); ucheck.setTask_usr_ids(rs.getString("task_usr_ids")); ucheck.setBattGroupId(rs.getInt("BattGroupId")); ucheck.setTask_enabled(rs.getInt("task_enabled")); ucheck.setTask_exe_date(rs.getTimestamp("task_exe_date")); ucheck.setTask_close_date(rs.getTimestamp("task_close_date")); ucheck.setTest_complete(rs.getInt("test_complete")); ucheck.setTest_completetime(rs.getTimestamp("test_completetime")); ucheck.setBatt_clean_done(rs.getInt("batt_clean_done")); ucheck.setBatt_clean_done_result(rs.getString("batt_clean_done_result")); ucheck.setBatt_clean_done_recheck(rs.getInt("batt_clean_done_recheck")); ucheck.setBatt_clean_done_recheck_result(rs.getString("batt_clean_done_recheck_result")); ucheck.setBatt_clean_done_recheck_check(rs.getInt("batt_clean_done_recheck_check")); ucheck.setBatt_clean_done_recheck_check_result(rs.getString("batt_clean_done_recheck_check_result")); ucheck.setBattvol_tempe_done(rs.getInt("battvol_tempe_done")); ucheck.setBattvol_tempe_done_result(rs.getString("battvol_tempe_done_result")); ucheck.setBattvol_tempe_done_recheck(rs.getInt("battvol_tempe_done_recheck")); ucheck.setBattvol_tempe_done_recheck_result(rs.getString("battvol_tempe_done_recheck_result")); ucheck.setBattvol_tempe_done_recheck_check(rs.getInt("battvol_tempe_done_recheck_check")); ucheck.setBattvol_tempe_done_recheck_check_result(rs.getString("battvol_tempe_done_recheck_check_result")); ucheck.setBattfault_check_done(rs.getInt("battfault_check_done")); ucheck.setBattfault_check_done_result(rs.getString("battfault_check_done_result")); ucheck.setBattfault_check_done_recheck(rs.getInt("battfault_check_done_recheck")); ucheck.setBattfault_check_done_recheck_result(rs.getString("battfault_check_done_recheck_result")); ucheck.setBattfault_check_done_recheck_check(rs.getInt("battfault_check_done_recheck_check")); ucheck.setBattfault_check_done_recheck_check_result(rs.getString("battfault_check_done_recheck_check_result")); BattInf binf=new BattInf(); binf.setBattGroupId(rs.getInt("battGroupId")); binf.setStationName(rs.getString("stationName")); binf.setBattGroupName(rs.getString("battGroupName")); binf.setStationName1(rs.getString("task_usr_ids")); User_inf uinf=new User_inf(); Page p=new Page(); tbt.setBinf(binf); tbt.setPage(p); tbt.setUcheck(ucheck); tbt.setUinf(uinf); list.add(tbt); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); } List listd=new ArrayList(); /*for(int i=0;i0){ for(int i=(tbt.getPage().getPageCurr()-1)*tbt.getPage().getPageSize();i list=uimpl.serchByCondition(tbt); //List list=uimpl.serchByInfo(tbt); //List list=uimpl.serchByTask(tbt); for (Task_Batt_Test t : list) { System.out.println(t); } System.out.println(list.size()); /*List uts=uimpl.serchMaxId(); System.out.println(uts);*/ } }