package com.fgkj.dao.impl;

import java.sql.Connection;
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.LimitNumberFactory;
import com.fgkj.db.DBUtil;
import com.fgkj.db.IDatabaseName;
import com.fgkj.dto.Batt_Maint_Dealarm;
import com.fgkj.dto.Page;
import com.fgkj.dto.User_sms;

public class User_smsImpl implements BaseDAO, CallBack {

	public List getResults(ResultSet rs) {
		List list = new ArrayList();
		try {
			while (rs.next()) {
				User_sms usms = new User_sms();
				usms.setNum(rs.getInt("num"));
				usms.setTask_id(rs.getInt("task_id"));
				usms.setPriority_level(rs.getInt("priority_level"));
				usms.setUId(rs.getInt("uId"));
				usms.setPhone_num(rs.getString("phone_num"));
				usms.setSms(rs.getString("sms"));
				usms.setSms_add_date(rs.getTimestamp("sms_add_date"));
				usms.setSms_send_date(rs.getTimestamp("sms_send_date"));
				usms.setSms_send_err_count(rs.getInt("sms_send_err_count"));
				usms.setSms_state(rs.getInt("sms_state"));
				
				Page page=new Page();
				usms.setPage(page);
				list.add(usms);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} 
		return list;
	}

	public boolean add(Object obj) {
		User_sms usms=(User_sms) obj;
		String sql="insert into db_user.tb_user_sms(task_id,priority_level,uId,phone_num," +
				"sms,sms_add_date,sms_send_date,sms_send_err_count,sms_state) values(?,?,?,?,?,?,?,?,?)";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{usms.getTask_id(),
			usms.getPriority_level(),usms.getUId(),usms.getPhone_num(),usms.getSms(),usms.getSms_add_date(),
			usms.getSms_send_date(),usms.getSms_send_err_count(),usms.getSms_state()});
		return bl;
	}

	public boolean update(Object obj) {
		User_sms usms=(User_sms) obj;
		String sql="update db_user.tb_user_sms set task_id=?,priority_level=?,uId=?,phone_num=?," +
				"sms=?,sms_add_date=?,sms_send_date=?,sms_send_err_count=?,sms_state=? where num=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{usms.getTask_id(),
			usms.getPriority_level(),usms.getUId(),usms.getPhone_num(),usms.getSms(),usms.getSms_add_date(),
			usms.getSms_send_date(),usms.getSms_send_err_count(),usms.getSms_state(),usms.getNum()});
		return bl;
	}

	public boolean del(Object obj) {
		User_sms usms=(User_sms) obj;
		String sql="delete from db_user.tb_user_sms where num=?";
		Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{usms.getNum()});
		return bl;
	}

	public List searchAll() {
		String sql = "select * from db_user.tb_user_sms";
		List list = DAOHelper
				.executeQuery(sql, DBUtil.getConn(), null,
						new User_smsImpl());
		return list;

	}

	//4.9短信息查询
	public List serchByCondition1(Object obj) {
		User_sms usms=(User_sms) obj;
		String sql="";
		String baseSql = "select num,task_id,priority_level,uId,phone_num,sms,sms_add_date,sms_send_date,sms_send_err_count,sms_state " +
				"from db_user.tb_user_sms " +
				"where (sms_send_date)>=(?) and (sms_send_date)<=(?)  ";
		//用于选取接收人姓名
		String nameSqlT=" and uid!=?";
		String nameSqlF=" and uid=?";
		if(usms.getUId()==0){
			baseSql+=nameSqlT;
		}else{
			baseSql+=nameSqlF;
		}
		//用于短信状态
		String stateSqlT=" and sms_state!=?";
		String stateSqlF=" and sms_state=?";
		if(usms.getSms_state()==100){
			baseSql+=stateSqlT;
		}else{
			baseSql+=stateSqlF;
		}
		//根据uid/sms_add_date升序排序
		String endSql=" order by uId asc,sms_add_date asc";
		sql=baseSql+endSql;
		//System.out.println(sql);
		List list = DAOHelper
				.executeQuery(sql, DBUtil.getConn(),  new Object[]{usms.getSms_send_date(),usms.getSms_send_date1(),
					usms.getUId(),usms.getSms_state()},
						new User_smsImpl());
        List<User_sms> listd=new ArrayList();
		int index=0;
		///System.out.println(list.size());
		for(int i=(usms.getPage().getPageCurr()-1)*usms.getPage().getPageSize();i<usms.getPage().getPageSize()*usms.getPage().getPageCurr()&&i<list.size();i++){
			listd.add((User_sms) list.get(i));
			//system.out.println(list.get(i));
			((User_sms)listd.get(index++)).getPage().setPageAll(list.size());
		}
		return listd;
	}
	//4.9短信息查询
		@SuppressWarnings("unchecked")
	public List serchByCondition(Object obj) {
			User_sms usms=(User_sms) obj;
			String sql="";
			String numberSql=" SELECT FOUND_ROWS() number";
			Connection conn=DBUtil.getConn();
			String baseSql = "select SQL_CALC_FOUND_ROWS num,task_id,priority_level,uId,phone_num,sms,sms_add_date,sms_send_date,sms_send_err_count,sms_state " +
					"from db_user.tb_user_sms " +
					"where (sms_send_date)>=(?) and (sms_send_date)<=(?)  ";
			//用于选取接收人姓名
			String nameSqlT=" and uid!=?";
			String nameSqlF=" and uid=?";
			if(usms.getUId()==0){
				baseSql+=nameSqlT;
			}else{
				baseSql+=nameSqlF;
			}
			//用于短信状态
			String stateSqlT=" and sms_state!=?";
			String stateSqlF=" and sms_state=?";
			if(usms.getSms_state()==100){
				baseSql+=stateSqlT;
			}else{
				baseSql+=stateSqlF;
			}
			//根据uid/sms_add_date升序排序
			String endSql=" order by uId asc,sms_add_date asc";
			String limitSql=" limit ?,? ";
			sql=baseSql+endSql+limitSql;
			//System.out.println(sql);
			List<User_sms> list = DAOHelper
					.executeQueryLimit(sql, conn,  new Object[]{usms.getSms_send_date(),usms.getSms_send_date1(),
						usms.getUId(),usms.getSms_state(),(usms.getPage().getPageCurr() - 1)* usms.getPage().getPageSize(),
						usms.getPage().getPageSize()},
							new User_smsImpl());
	       /* List<User_sms> listd=new ArrayList();
			int index=0;
			///System.out.println(list.size());
			for(int i=(usms.getPage().getPageCurr()-1)*usms.getPage().getPageSize();i<usms.getPage().getPageSize()*usms.getPage().getPageCurr()&&i<list.size();i++){
				listd.add((User_sms) list.get(i));
				//system.out.println(list.get(i));
				((User_sms)listd.get(index++)).getPage().setPageAll(list.size());
			}*/
			//去掉limit条件后的总数
			int number=LimitNumberFactory.GetLimtitNumber(conn, numberSql);
			//System.out.println("number: "+number);
			if(list!=null&&list.size()>0){
				list.get(list.size()-1).getPage().setPageAll(number);
			}	
			return list;
		}
	public List serchByInfo(Object obj) {
		// TODO Auto-generated method stub
		return null;
	}

	public static void main(String[] args) throws ParseException {
		User_smsImpl us=new User_smsImpl();
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		Date date1 = sdf.parse("2000-01-01");
		Date date2 = sdf.parse("2020-01-01");
		
		Page p=new Page();
		p.setPageCurr(1);
		p.setPageSize(10);
		
		User_sms u=new User_sms();
		u.setUId(1001);
		u.setSms_state(100);
		u.setSms_send_date(ActionUtil.getSimpDate(date1));
		u.setSms_send_date1(ActionUtil.getSimpDate(date2));
		u.setPage(p);
		List<User_sms> list=us.serchByCondition(u);
		for(User_sms uu:list){
			System.out.println(uu);
		}
		System.out.println(list.size());
	}
}