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<Task_Batt_Test> 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<tbt.getPage().getPageSize()*tbt.getPage().getPageCurr()&&i<list.size();i++){
|
listd.add((Task_Batt_Test) list.get(i));
|
//system.out.println(list.get(i));
|
((Task_Batt_Test)listd.get(index++)).getPage().setPageAll(list.size());
|
}
|
return listd;
|
}
|
|
//0.1作业管理查询user_task所有信息
|
public List serchByTask(Object obj) {
|
Task_Batt_Test tbt=(Task_Batt_Test) obj;
|
BattInf binf=tbt.getBinf();
|
User_task utask=tbt.getUtask();
|
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_batt_test.num,task_usr_ids,tb_user_task_batt_test.BattGroupId,tb_user_task_batt_test.task_enabled" +
|
",task_exe_date,tb_user_task_batt_test.task_close_date,tb_user_task_batt_test.task_notice_starttime,tb_user_task_batt_test.task_notice_endtime" +
|
",tb_user_task_batt_test.task_notice_count,tb_user_task_batt_test.task_notice_latesttime,task_notice_master,test_complete,test_completetime,test_starttime,test_record_count_id,tb_user_task_batt_test.note" +
|
",stationname ,battgroupname " +
|
"from db_user.tb_user_task,db_battinf.tb_battinf,db_user.tb_user_task_batt_test " +
|
"where tb_user_task.task_id=tb_user_task_batt_test.task_id " +
|
"and tb_user_task_batt_test.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 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<Task_Batt_Test> 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;
|
if(list!=null && list.size()>0){
|
for(int i=(tbt.getPage().getPageCurr()-1)*tbt.getPage().getPageSize();i<tbt.getPage().getPageSize()*tbt.getPage().getPageCurr()&& i<list.size();i++){
|
listd.add((Task_Batt_Test) list.get(i));
|
//system.out.println(list.get(i));
|
((Task_Batt_Test)listd.get(index++)).getPage().setPageAll(list.size());
|
}
|
}
|
return listd;
|
}
|
|
//4.1查询当前最大的task_id
|
public List serchMaxId(){
|
String sql="select max(task_id) as Max_task_id from db_user.tb_user_task ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
User_task utask=new User_task();
|
utask.setTask_id(rs.getInt("Max_task_id"));
|
list.add(utask);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
|
public static void main(String[] args) throws ParseException {
|
User_taskImpl uimpl=new User_taskImpl();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2120-01-01");
|
|
BattInf binf=new BattInf();
|
binf.setStationName("");
|
binf.setStationName1("");
|
binf.setBattGroupId(0);
|
binf.setBattGroupName1("");
|
binf.setBattProducer("");
|
binf.setMonCapStd(0f);
|
binf.setMonVolStd(0f);
|
|
User_task utask=new User_task();
|
utask.setTask_type(2);
|
utask.setTask_complete(100);
|
utask.setTask_create_date(ActionUtil.getSimpDate(date1));
|
utask.setTask_create_date1(ActionUtil.getSimpDate(date2));
|
utask.setTask_complete_date(ActionUtil.getSimpDate(date1));
|
utask.setTask_complete_date1(ActionUtil.getSimpDate(date2));
|
utask.setTask_close_date(date1);
|
utask.setTask_close_date1(date2);
|
|
User_task_user_list ulist=new User_task_user_list();
|
ulist.setUId(0);
|
|
User_task_batt_test utest=new User_task_batt_test();
|
utest.setTask_usr_ids("100");
|
utest.setTask_exe_date(ActionUtil.getSimpDate(date1));
|
utest.setTask_exe_date1(ActionUtil.getSimpDate(date2));
|
|
User_task_batt_check ucheck=new User_task_batt_check();
|
ucheck.setTask_usr_ids("100");
|
ucheck.setTask_exe_date(ActionUtil.getSimpDate(date1));
|
ucheck.setTask_exe_date1(ActionUtil.getSimpDate(date2));
|
|
User_inf uinf=new User_inf();
|
uinf.setUId(100);//包机人100全部
|
|
Page p=new Page();
|
p.setPageCurr(1);
|
p.setPageSize(10);
|
|
Task_Batt_Test tbt=new Task_Batt_Test();
|
tbt.setBinf(binf);
|
tbt.setUinf(uinf);
|
tbt.setUtask(utask);
|
tbt.setUtest(utest);
|
tbt.setUlist(ulist);
|
tbt.setUcheck(ucheck);
|
tbt.setPage(p);
|
List<Task_Batt_Test> list=uimpl.serchByCondition(tbt);
|
//List<Task_Batt_Test> list=uimpl.serchByInfo(tbt);
|
//List<Task_Batt_Test> list=uimpl.serchByTask(tbt);
|
for (Task_Batt_Test t : list) {
|
System.out.println(t);
|
}
|
System.out.println(list.size());
|
/*List<User_task> uts=uimpl.serchMaxId();
|
System.out.println(uts);*/
|
}
|
|
}
|
