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());
	}

}