package com.bean;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;

import com.util.Constant;
import com.util.DBO;

/**
 * 
 * 网站后台管理注册会员 查询 冻结 删除会员
 */	

public class MemberManageBean {

	private List list;
	private ResultSet rs = null;
	private int EVERYPAGENUM = 2;
	private int count = -1;
	private int qq = 0;
	private String sql="select count(*) from member where type='person'";
	private String sql2="select * from member where type='person' order by id desc ";
	//声明时间变量
	String date1=new SimpleDateFormat("yyyy-MM-dd").format(Calendar.getInstance().getTime());
	String date=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Calendar.getInstance().getTime());
	
	//分页查询所有个人会员
	public void setEVERYPAGENUM(int EVERYPAGENUM){
    	this.EVERYPAGENUM=EVERYPAGENUM;
    }
    public int getMessageCount() { //得到信息总数
       DBO dbo=new DBO();
       dbo.open();
        try { 
            rs = dbo.executeQuery(sql);
            rs.next();
            count = rs.getInt(1);
            return count;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return -1;
        } finally {
            dbo.close();
        }
    }
    public int getPageCount() { //得到共多少页（根据每页要显示几条信息）
        if (count % EVERYPAGENUM == 0) {
            return count / EVERYPAGENUM;
        } else {
            return count / EVERYPAGENUM + 1;
        }
    }
    public List getMessage(int page) { //得到每页要显示的信息
        DBO dbo=new DBO();
        dbo.open();
        List list = new ArrayList();
        try {
            rs = dbo.executeQuery(sql2);
            for (int i = 0; i < (page - 1) * EVERYPAGENUM; i++) {
                rs.next();
            }
            for (int t = 0; t < EVERYPAGENUM; t++) {
                if (rs.next()) {
                    qq++;
                    List list2=new ArrayList();
                    list2.add(rs.getInt("id"));
    				list2.add(rs.getString("username"));
    				list2.add(rs.getString("regtime"));
    				list2.add(rs.getString("ifuse"));
    				list2.add(rs.getString("logintimes"));
    				list2.add(rs.getString("lasttime"));
    				list2.add(rs.getString("lastip"));
    				list.add(list2);
                } else {
                    break; //减少空循环的时间
                }
            }
            return list;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return null;
        } finally {
            dbo.close();
        }
    }
    
    ///所有企业会员////////////////////
    public int getMessageCountCO() { //得到信息总数
        DBO dbo=new DBO();
        dbo.open();
         try { 
             rs = dbo.executeQuery("select count(*) from member where type='co'");
             rs.next();
             count = rs.getInt(1);
             return count;
         } catch (SQLException ex) {
             ex.printStackTrace();
             return -1;
         } finally {
             dbo.close();
         }
     }
     public List getMessageCO(int page) { //得到每页要显示的信息
         DBO dbo=new DBO();
         dbo.open();
         List list = new ArrayList();
         try {
             rs = dbo.executeQuery("select * from member where type='co' order by id desc ");
             for (int i = 0; i < (page - 1) * EVERYPAGENUM; i++) {
                 rs.next();
             }
             for (int t = 0; t < EVERYPAGENUM; t++) {
                 if (rs.next()) {
                     qq++;
                    List list2=new ArrayList();
                    list2.add(rs.getInt("id"));
     				list2.add(rs.getString("username"));
     				list2.add(rs.getString("regtime"));
     				list2.add(rs.getString("ifuse"));
     				list2.add(rs.getString("logintimes"));
     				list2.add(rs.getString("lasttime"));
     				list2.add(rs.getString("lastip"));
     				list.add(list2);
                 } else {
                     break; //减少空循环的时间
                 }
             }
             return list;
         } catch (SQLException ex) {
             ex.printStackTrace();
             return null;
         } finally {
             dbo.close();
         }
     }
     
     //所有在用会员
     public int getMessageCountUS() { //得到信息总数
         DBO dbo=new DBO();
         dbo.open();
          try { 
              rs = dbo.executeQuery("select count(*) from member where ifuse='1'");
              rs.next();
              count = rs.getInt(1);
              return count;
          } catch (SQLException ex) {
              ex.printStackTrace();
              return -1;
          } finally {
              dbo.close();
          }
      }
      public List getMessageUS(int page) { //得到每页要显示的信息
          DBO dbo=new DBO();
          dbo.open();
          List list = new ArrayList();
          try {
              rs = dbo.executeQuery("select * from member where ifuse='1' order by id desc ");
              for (int i = 0; i < (page - 1) * EVERYPAGENUM; i++) {
                  rs.next();
              }
              for (int t = 0; t < EVERYPAGENUM; t++) {
                  if (rs.next()) {
                      qq++;
                     List list2=new ArrayList();
                     list2.add(rs.getInt("id"));
      				list2.add(rs.getString("username"));
      				list2.add(rs.getString("regtime"));
      				list2.add(rs.getString("ifuse"));
      				list2.add(rs.getString("logintimes"));
      				list2.add(rs.getString("lasttime"));
      				list2.add(rs.getString("lastip"));
      				list2.add(rs.getString("type"));
      				list.add(list2);
                  } else {
                      break; //减少空循环的时间
                  }
              }
              return list;
          } catch (SQLException ex) {
              ex.printStackTrace();
              return null;
          } finally {
              dbo.close();
          }
      }
//    所有冻结会员
      public int getMessageCountCL() { //得到信息总数
          DBO dbo=new DBO();
          dbo.open();
           try { 
               rs = dbo.executeQuery("select count(*) from member where ifuse='0'");
               rs.next();
               count = rs.getInt(1);
               return count;
           } catch (SQLException ex) {
               ex.printStackTrace();
               return -1;
           } finally {
               dbo.close();
           }
       }
       public List getMessageCL(int page) { //得到每页要显示的信息
           DBO dbo=new DBO();
           dbo.open();
           List list = new ArrayList();
           try {
               rs = dbo.executeQuery("select * from member where ifuse='0' order by id desc ");
               for (int i = 0; i < (page - 1) * EVERYPAGENUM; i++) {
                   rs.next();
               }
               for (int t = 0; t < EVERYPAGENUM; t++) {
                   if (rs.next()) {
                       qq++;
                      List list2=new ArrayList();
                      list2.add(rs.getInt("id"));
       				list2.add(rs.getString("username"));
       				list2.add(rs.getString("regtime"));
       				list2.add(rs.getString("ifuse"));
       				list2.add(rs.getString("logintimes"));
       				list2.add(rs.getString("lasttime"));
       				list2.add(rs.getString("lastip"));
       				list2.add(rs.getString("type"));
       				list.add(list2);
                   } else {
                       break; //减少空循环的时间
                   }
               }
               return list;
           } catch (SQLException ex) {
               ex.printStackTrace();
               return null;
           } finally {
               dbo.close();
           }
       }
//     今日注册会员
       public int getMessageCountTODAY() { //得到信息总数
           DBO dbo=new DBO();
           dbo.open();
            try { 
                rs = dbo.executeQuery("select count(*) from member where regtime between '"+date1+"' and '"+date+"'");
                rs.next();
                count = rs.getInt(1);
                return count;
            } catch (SQLException ex) {
                ex.printStackTrace();
                return -1;
            } finally {
                dbo.close();
            }
        }
        public List getMessageTODAY(int page) { //得到每页要显示的信息
            DBO dbo=new DBO();
            dbo.open();
            List list = new ArrayList();
            try {
                rs = dbo.executeQuery("select * from member where regtime between '"+date1+"' and '"+date+"' order by id desc ");
                for (int i = 0; i < (page - 1) * EVERYPAGENUM; i++) {
                    rs.next();
                }
                for (int t = 0; t < EVERYPAGENUM; t++) {
                    if (rs.next()) {
                        qq++;
                       List list2=new ArrayList();
                       list2.add(rs.getInt("id"));
        				list2.add(rs.getString("username"));
        				list2.add(rs.getString("regtime"));
        				list2.add(rs.getString("ifuse"));
        				list2.add(rs.getString("logintimes"));
        				list2.add(rs.getString("lasttime"));
        				list2.add(rs.getString("lastip"));
        				list2.add(rs.getString("type"));
        				list.add(list2);
                    } else {
                        break; //减少空循环的时间
                    }
                }
                return list;
            } catch (SQLException ex) {
                ex.printStackTrace();
                return null;
            } finally {
                dbo.close();
            }
        }
   
    /*********************************************************************************************************************************
     * 删除 冻结会员
     * @param id
     * @return
     *********************************************************************/
    //  删除会员
	public int delMember(int id[]){
		DBO dbo=new DBO();
		dbo.open();
		try{
			for(int i = 0;i<id.length;i++){
				dbo.executeUpdate("delete from  member where  id = '"+id[i]+"'");	
				dbo.executeUpdate("delete from  pmember where  mid = '"+id[i]+"'");
				dbo.executeUpdate("delete from  cmember where  mid = '"+id[i]+"'");
			}
			return Constant.SUCCESS;
		}catch(Exception e){
			e.printStackTrace();
			return Constant.SYSTEM_ERROR;
		}finally{
			dbo.close();
		}
	}
	//冻结会员
	public int closeMember(int id){
		String sql = "select ifuse from member where id='"+id+"' ";
		String sql2 = "update member set ifuse='0' where id='"+id+"'";
		String sql3 = "update member set ifuse='1' where id='"+id+"'";
		DBO dbo=new DBO();
		dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			if(rs.next()){
				int ifuse=rs.getInt(1);
				if(ifuse == 1){
					int j = dbo.executeUpdate(sql2);
					if(j == 1)
						return Constant.SUCCESS;
					else
						return Constant.SYSTEM_ERROR;
				}
				else{
					int j = dbo.executeUpdate(sql3);
					if(j == 1)
						return Constant.SUCCESS;
					else
						return Constant.SYSTEM_ERROR;
				}
			}
			else{
				return Constant.SYSTEM_ERROR;
			}
		}catch(Exception e){
			e.printStackTrace();
			return Constant.SYSTEM_ERROR;
		}finally{
			dbo.close();
		}
	}
	/**********************************************************************
     * 后台查询单条个人 企业会员信息 查询会员类型
     * @param id
     * @return
     *********************************************************************/
    //以id为条件查询会员类型
    public String getType(int id){
    	String sql = "select type from member where id='"+id+"'";
    	DBO dbo=new DBO();
    	dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			if(rs.next()){
				String type = rs.getString(1);
				return type;
			}
			else
				return null;
		}catch(Exception e){
			e.printStackTrace();
			return null;
		}finally{
			dbo.close();
		}
    }
    //以id为条件 单条会员登陆信息
    public List getMemberLogin(int id){
		String sql = "select * from member where id='"+id+"'";
		DBO dbo=new DBO();
		list = new ArrayList();
		dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			rs.next();
			list.add(rs.getString("username"));
			list.add(rs.getString("type"));
			list.add(rs.getString("regtime"));
			list.add(rs.getString("ifuse"));
			list.add(rs.getString("logintimes"));
			list.add(rs.getString("lasttime"));
			list.add(rs.getString("lastip"));
			return list;
		}catch(Exception e){
			e.printStackTrace();
			return list;
		}finally{
			dbo.close();
		}
	}
	//以id为条件 单条个人会员信息
	public List getPerSonMember(int id){
		String sql = "select * from pmember where mid='"+id+"'";
		DBO dbo=new DBO();
		list = new ArrayList();
		dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			rs.next();
			list.add(rs.getString("realname"));
			list.add(rs.getString("sex"));
			list.add(rs.getString("bir"));
			list.add(rs.getString("sheng"));
			list.add(rs.getString("city"));
			list.add(rs.getString("telphone"));
			list.add(rs.getString("email"));
			list.add(rs.getString("question"));
			list.add(rs.getString("answer"));
			list.add(rs.getString("address"));
			return list;
		}catch(Exception e){
			e.printStackTrace();
			return list;
		}finally{
			dbo.close();
		}
	}
//	以id为条件 单条企业会员信息
	public List getCoMember(int id){
		String sql = "select * from cmember where mid='"+id+"'";
		DBO dbo=new DBO();
		list = new ArrayList();
		dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			rs.next();
			list.add(rs.getString("coname"));
			list.add(rs.getString("address"));
			list.add(rs.getString("postnum"));
			list.add(rs.getString("tel"));
			list.add(rs.getString("email"));
			list.add(rs.getString("question"));
			list.add(rs.getString("answer"));
			list.add(rs.getString("intro"));
			return list;
		}catch(Exception e){
			e.printStackTrace();
			return list;
		}finally{
			dbo.close();
		}
	}
	//////////////以用户名为条件查询///////////////
//	以用户名为条件查询会员类型
    public String getType(String name){
    	String sql = "select type from member where username='"+name+"'";
    	DBO dbo=new DBO();
    	dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			if(rs.next()){
				String type = rs.getString(1);
				return type;
			}
			else
				return null;
		}catch(Exception e){
			e.printStackTrace();
			return null;
		}finally{
			dbo.close();
		}
    }
    //以用户名为条件查询用户id，然后用id来查询会员信息 跳转到//以id为条件查询会员类型
    public int getID(String name){
    	String sql = "select id from member where username='"+name+"'";
    	DBO dbo=new DBO();
    	dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			if(rs.next()){
				int id = rs.getInt(1);
				return id;
			}
			else
				return 0;
		}catch(Exception e){
			e.printStackTrace();
			return 0;
		}finally{
			dbo.close();
		}
    }
//////////////以用户名 id为条件查询///////////////
//	以用户名 id为条件查询会员类型，然后用id来查询会员信息 跳转到//以id为条件查询会员
    public String getType(int id,String name){
    	String sql = "select type from member where id='"+id+"' and username='"+name+"'";
    	DBO dbo=new DBO();
    	dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			if(rs.next()){
				String type = rs.getString(1);
				return type;
			}
			else
				return null;
		}catch(Exception e){
			e.printStackTrace();
			return null;
		}finally{
			dbo.close();
		}
    }
    
	/////////////////////按注册时间查询/////////////////////
    public List getMemberByTime(String stime,String etime){
    	String sql = "select * from member where regtime between '"+stime+"' and '"+etime+" 23:59:59' ";
    	DBO dbo=new DBO();
		list = new ArrayList();
		dbo.open();
		try{
			rs = dbo.executeQuery(sql);
			while(rs.next()){
				List list2=new ArrayList();
                list2.add(rs.getInt("id"));
 				list2.add(rs.getString("username"));
 				list2.add(rs.getString("regtime"));
 				list2.add(rs.getString("ifuse"));
 				list2.add(rs.getString("logintimes"));
 				list2.add(rs.getString("lasttime"));
 				list2.add(rs.getString("lastip"));
 				list2.add(rs.getString("type"));
 				list.add(list2);
			}
			return list;
		}catch(Exception e){
			e.printStackTrace();
			return list;
		}finally{
			dbo.close();
		}
    }
}