tempusersmanager.java

Email营销是在用户事先许可的前提下

package com.qq.content;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.sql.rowset.CachedRowSet;

import java.sql.SQLException;
import java.sql.Timestamp;


public class TempUsersManager {
	private static DBTool db = null;
	
	private SqlChecker sqlChecker = new SqlChecker();
	public 	TempUsersManager() throws Exception {
		db=new DBTool();
	}	

	public String getDateStr(){
	      Date timeer = new Date(); // 取当前的时间
	      SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd"); // 设置显示的格式
	      String msg = df.format(timeer); // msg中存放格式化后的时间字串
	      return msg;		
	}

	public boolean haveSubed(String mail,String[] services){
		try{
			UsersManager um=new UsersManager();
			for(int i=0;i<services.length;i++)
			if(um.haveSubed(mail,services[i]))return true;			
			return false;
		}
		catch(Exception e){
			return true;
		}
	}
	
	public String getSubedService(String email){
		if(email==null || email.length()==0)return "";
		String sql="SELECT services FROM tempusers WHERE email='"+email+"'";
		System.out.println(sql);
		try {
			CachedRowSet crs=db.query(sql);
			while(crs.next()){
				return crs.getString(1);
			}
			return null;
		} catch (SQLException e) {
			e.printStackTrace();
			return "";
		}		
	}
	
	public boolean addValidUser(String email,String[] services){
		String servs=this.getSubedService(email);
		if(servs==null || servs.length()==0)return false;
		for(int i=0;i<services.length;i++){
			if(servs.indexOf(services[i])==-1)return false;
		}
		String sql="SELECT * FROM tempusers WHERE email='"+email+"'";
		System.out.println(sql);
		CachedRowSet rs;
		try {
			rs = db.query(sql);
			if(rs.next()){
			String service=rs.getString("services");
			String source=rs.getString("source");
			String submail_sent_times=rs.getString("submail_sent_times");
			String last_submail_time=rs.getString("last_submail_time");
			for(int i=0;i<services.length;i++){
				try{
					UsersManager um=new UsersManager();
				if(um.haveSubed(email,services[i])){
					sql="UPDATE user_detail SET status=0 WHERE email='"+email+"' AND service='"+services[i]+"'";
				}else{
					sql="INSERT INTO user_detail VALUES('"+email+"','"+services[i];
					sql+="','','','','','"+source+"','"+DATA.getDateTimeStr()+"','"+submail_sent_times;
					sql+="','"+last_submail_time+"','','','','','','')";
				}
				System.out.println(sql);
				try {
					db.execute(sql);
				} catch (Exception e1) {
					e1.printStackTrace();
					return false;
				}
				}catch(Exception ee){
					
				}
			}
				sql="DELETE FROM tempusers WHERE email='"+email+"'";
				System.out.println(sql);
				try {
					db.execute(sql);
					return true;
				} catch (Exception e) {
					e.printStackTrace();
					return false;
				}					
		}else return false;		  
		} catch (SQLException e2) {
			e2.printStackTrace();
			return false;
		}
	}
	public boolean Submit(String email,String[] services,String source){
		if(services.length==0)return false;
		String sql="SELECT * FROM tempusers WHERE email='"+email+"'";
		System.out.println(sql);
		try {
			CachedRowSet crs=db.query(sql);
			if(crs.next()){
				String sub_servs="";
				for(int i=0;i<services.length;i++){
					sub_servs+=services[i]+":";
				}
				if(sub_servs.length()>0)sub_servs=sub_servs.substring(0,sub_servs.length()-1);
				sql="UPDATE tempusers SET services='"+sub_servs+"' WHERE email='"+email+"'";
				try {
					db.execute(sql);
					return true;
				} catch (Exception e) {
					e.printStackTrace();
					return false;
				}
			}else{
				String sub_servs="";
				for(int i=0;i<services.length;i++){
					sub_servs+=services[i]+":";
				}
				if(sub_servs.length()>0)sub_servs=sub_servs.substring(0,sub_servs.length()-1);
				sql="INSERT INTO tempusers VALUES('"+email+"','"+sub_servs+"','"+source+"',0,'','')";
				System.out.println(sql);
				try {
					db.execute(sql);
					return true;
				} catch (Exception e) {
					e.printStackTrace();
					return false;
				}
			}
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		}
	}
	
	/**
	 * @param args
	 */
	public static void main(String[] args) {


	}

}