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.BaseDAOFactory;
|
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.Page;
|
import com.fgkj.dto.Task_Batt_Test;
|
import com.fgkj.dto.User_battmaint_check;
|
|
public class User_battmaint_checkImpl implements BaseDAO,CallBack{
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Task_Batt_Test tbt=new Task_Batt_Test();
|
User_battmaint_check battcheck=new User_battmaint_check();
|
battcheck.setNum(rs.getInt("num"));
|
battcheck.setStationId(rs.getInt("stationId"));
|
battcheck.setUsr_id(rs.getInt("usr_id"));
|
battcheck.setMaster_id(rs.getInt("master_id"));
|
battcheck.setAppoint_uid(rs.getInt("appoint_uid"));
|
battcheck.setCopy_uids(rs.getString("copy_uids"));
|
battcheck.setTask_type_id(rs.getInt("task_type_id"));
|
battcheck.setTask_level(rs.getInt("task_level"));
|
battcheck.setTask_caption(rs.getString("task_caption"));
|
battcheck.setTask_time_start(rs.getTimestamp("task_time_start"));
|
battcheck.setTask_time_end(rs.getTimestamp("task_time_end"));
|
battcheck.setTask_process(rs.getString("task_process"));
|
battcheck.setTask_done(rs.getInt("task_done"));
|
battcheck.setTask_done_time(rs.getTimestamp("task_done_time"));
|
battcheck.setOrigin_usr_work_mark(rs.getInt("origin_usr_work_mark"));
|
battcheck.setTask_done_confirm(rs.getInt("task_done_confirm"));
|
battcheck.setMaster_audit(rs.getInt("master_audit"));
|
battcheck.setRemark(rs.getString("StationName"));
|
Page p=new Page();
|
tbt.setMcheck(battcheck);
|
tbt.setPage(p);
|
list.add(tbt);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
//4.10作业抽查管理(新建)
|
public boolean add(Object obj) {
|
User_battmaint_check ucheck=(User_battmaint_check) obj;
|
String sql="insert into db_user.tb_user_battmaint_check(StationId,usr_id,master_id,appoint_uid,copy_uids,task_type_id,task_level," +
|
"task_caption,task_time_start,task_time_end,task_process,task_done,task_done_time,origin_usr_work_mark," +
|
"task_done_confirm,master_audit,remark) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ucheck.getStationId(),
|
ucheck.getUsr_id(),ucheck.getMaster_id(),ucheck.getAppoint_uid(),ucheck.getCopy_uids(),ucheck.getTask_type_id(),
|
ucheck.getTask_level(),ucheck.getTask_caption(),ucheck.getTask_time_start(),ucheck.getTask_time_end(),
|
ucheck.getTask_process(),ucheck.getTask_done(),ucheck.getTask_done_time(),ucheck.getOrigin_usr_work_mark(),
|
ucheck.getTask_done_confirm(),ucheck.getMaster_audit(),ucheck.getRemark()});
|
return bl;
|
}
|
//4.10作业抽查管理(编辑记录)
|
public boolean update(Object obj) {
|
User_battmaint_check ucheck=(User_battmaint_check) obj;
|
String sql="update db_user.tb_user_battmaint_check set usr_id=?,master_id=?,appoint_uid=?,copy_uids=?,task_type_id=?,task_level=?," +
|
"task_caption=?,task_time_start=?,task_time_end=?,task_process=?,task_done=?,task_done_time=?,origin_usr_work_mark=?," +
|
"task_done_confirm=?,master_audit=?,remark=? where num=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{
|
ucheck.getUsr_id(),ucheck.getMaster_id(),ucheck.getAppoint_uid(),ucheck.getCopy_uids(),ucheck.getTask_type_id(),
|
ucheck.getTask_level(),ucheck.getTask_caption(),ucheck.getTask_time_start(),ucheck.getTask_time_end(),
|
ucheck.getTask_process(),ucheck.getTask_done(),ucheck.getTask_done_time(),ucheck.getOrigin_usr_work_mark(),
|
ucheck.getTask_done_confirm(),ucheck.getMaster_audit(),ucheck.getRemark(),ucheck.getNum()});
|
return bl;
|
}
|
//4.10作业抽查管理(编辑记录)
|
public String updatePro(Object obj) {
|
User_battmaint_check ucheck=(User_battmaint_check) obj;
|
String sql="update db_user.tb_user_battmaint_check set usr_id="+ucheck.getUsr_id()+",master_id="+ucheck.getMaster_id()+",appoint_uid="+ucheck.getAppoint_uid()
|
+",copy_uids='"+ucheck.getCopy_uids()+"',task_type_id="+ucheck.getTask_type_id()+",task_level="+ucheck.getTask_level()+",task_caption='"+ucheck.getTask_caption()
|
+"',task_time_start='"+DAOHelper.sdf.format(ucheck.getTask_time_start())+"',task_time_end='"+DAOHelper.sdf.format(ucheck.getTask_time_end())+"',task_process='"+ucheck.getTask_process()+"',task_done="+ucheck.getTask_done()
|
+",task_done_time='"+DAOHelper.sdf.format(ucheck.getTask_done_time())+"',origin_usr_work_mark="+ucheck.getOrigin_usr_work_mark()
|
+",task_done_confirm="+ucheck.getTask_done_confirm()+",master_audit="+ucheck.getMaster_audit()+",remark='"+ucheck.getRemark()
|
+"' where num="+ucheck.getNum();
|
//System.out.println(sql);
|
return sql;
|
}
|
|
//4.10作业抽查管理(删除记录)
|
public boolean del(Object obj) {
|
User_battmaint_check ucheck=(User_battmaint_check) obj;
|
String sql="delete from db_user.tb_user_battmaint_check where num=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{ucheck.getNum()});
|
return bl;
|
}
|
//4.10作业抽查管理(删除记录)
|
public String delPro(Object obj) {
|
User_battmaint_check ucheck=(User_battmaint_check) obj;
|
String sql="delete from db_user.tb_user_battmaint_check where num="+ucheck.getNum();
|
return sql;
|
}
|
|
public List searchAll() {
|
String sql="select * from db_user.tb_user_battmaint_check";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new User_battmaint_checkImpl());
|
return list;
|
}
|
|
//4.10作业抽查管理
|
public List serchByCondition(Object obj) {
|
Task_Batt_Test tbt=(Task_Batt_Test) obj;
|
BattInf binf=tbt.getBinf();
|
User_battmaint_check mcheck=tbt.getMcheck();
|
String sql="";
|
String baseSql="select distinct(tb_user_battmaint_check.StationId), tb_user_battmaint_check.num,usr_id,master_id,appoint_uid,copy_uids,task_type_id,task_level,task_caption," +
|
"task_time_start,task_time_end,task_process,task_done,task_done_time,origin_usr_work_mark,task_done_confirm,master_audit,remark," +
|
"StationName " +
|
"from db_user.tb_user_battmaint_check,db_battinf.tb_battinf " +
|
"where tb_user_battmaint_check.StationId=db_battinf.tb_battinf.StationId " +
|
"and (task_time_start)>=(?) and (task_time_end)<=(?) " +
|
"and origin_usr_work_mark>=? and origin_usr_work_mark<=? ";
|
|
//用于维护区
|
String station1SqlT=" and db_battinf.tb_battinf.StationName1!=? ";//全部
|
String station1SqlF=" and db_battinf.tb_battinf.StationName1=? ";
|
if(binf.getStationName1().equals("")){
|
baseSql+=station1SqlT;
|
}else{
|
baseSql+=station1SqlF;
|
}
|
//用于机房站点
|
String stationSqlT=" and db_battinf.tb_battinf.StationName!=? ";//全部
|
String stationSqlF=" and db_battinf.tb_battinf.StationName=? ";
|
if(binf.getStationName().equals("")){
|
baseSql+=stationSqlT;
|
}else{
|
baseSql+=stationSqlF;
|
}
|
|
//用于电池组条件
|
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 nameSql=" and copy_uids like ? ";
|
baseSql+=nameSql;
|
//任务是否完成
|
String completeSqlT=" and task_done!=? ";
|
String completeSqlF=" and task_done=? ";
|
if(mcheck.getTask_done()==100){
|
baseSql+=completeSqlT;
|
//System.out.println(mcheck.getTask_done_confirm());
|
}else{
|
baseSql+=completeSqlF;
|
}
|
//抽查任务是否被确认
|
String confirmSqlT=" and task_done_confirm!=? ";
|
String confirmSqlF=" and task_done_confirm=? ";
|
if(mcheck.getTask_done_confirm()==100){
|
baseSql+=confirmSqlT;
|
}else{
|
baseSql+=confirmSqlF;
|
}
|
//按照num排序
|
String endSql=" order by tb_user_battmaint_check.num ";
|
sql=baseSql+endSql;
|
//System.out.println(sql);
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(),
|
new Object[]{mcheck.getTask_time_start(),mcheck.getTask_time_end(),
|
mcheck.getOrigin_usr_work_mark(),mcheck.getOrigin_usr_work_mark1(),
|
binf.getStationName1(),binf.getStationName(),binf.getBattGroupId(),"%"+mcheck.getCopy_uids()+"%",
|
mcheck.getTask_done(),mcheck.getTask_done_confirm()}, new User_battmaint_checkImpl());
|
|
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;
|
//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;
|
}
|
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public static void main(String[] args) throws ParseException {
|
|
User_battmaint_checkImpl uimpl=new User_battmaint_checkImpl();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date date1 = sdf.parse("2000-01-01");
|
Date date2 = sdf.parse("2020-01-01");
|
|
BattInf binf = new BattInf();
|
binf.setStationName("");
|
binf.setStationName1("");
|
binf.setBattGroupId(0);
|
|
User_battmaint_check mcheck=new User_battmaint_check();
|
mcheck.setCopy_uids("");
|
mcheck.setOrigin_usr_work_mark(0);
|
mcheck.setOrigin_usr_work_mark1(100);
|
mcheck.setTask_done(100);
|
mcheck.setTask_done_confirm(100);
|
mcheck.setTask_time_start(ActionUtil.getSimpDate(date1));
|
mcheck.setTask_time_end(ActionUtil.getSimpDate(date2));
|
|
Page p = new Page();
|
p.setPageCurr(1);
|
p.setPageSize(10);
|
|
Task_Batt_Test tbt=new Task_Batt_Test();
|
tbt.setBinf(binf);
|
tbt.setMcheck(mcheck);
|
tbt.setPage(p);
|
List<Task_Batt_Test> list=uimpl.serchByCondition(tbt);
|
for (Task_Batt_Test u : list) {
|
System.out.println(u);
|
}
|
System.out.println(list.size());
|
}
|
|
}
|
