bookuserbean.java

WAP PUSH后台源码,WAP PUSH后台源码

package com.sxit.wap.bookuser;
import java.sql.*;
import java.util.*;
import com.sxit.wap.bookterm.*;
import com.sxit.wap.common.*;
import com.sxit.wap.exception.*;

public class BookUserBean extends BookUserDao{
  public static boolean isExist(String userMdn)throws SysException{
    String sql = "SELECT COUNT(*) FROM " + tableName + " WHERE USER_MDN = '" +userMdn + "'";
    return getRowCountBySql(sql) > 0;
  }
  public static BookUserModel getModelByUserMdn(String userMdn)throws SysException{
   try{
      return findByPK(userMdn);
   }catch(FinderException ex){
      return null;
   }
  }
  public static BookUserModel regByUserMdn(String userMdn)throws SysException,UpdateException,AppException{
    try{
        return findByPK(userMdn);
    }catch(FinderException ex){
        BookUserModel bookuser = new BookUserModel();
        bookuser.setUserMdn(userMdn);
        bookuser.setRegDate(new Timestamp(System.currentTimeMillis()));
        int number = 0;java.util.Random r = new Random();
        while ((number = Math.round(r.nextFloat() * 1000000)) < 100000) {}
        String userPwd = "" + number;
        bookuser.setUserPwd(userPwd);
        return regditUser(bookuser);
    }
  }
public static BookUserModel regditUser(BookUserModel bookuser)throws SysException{
  Connection conn = null;
  boolean flag = false;
  try {
    conn = Database.getConnection();
    conn.setAutoCommit(false);
    bookuser = insert(bookuser);
    BookTermBean.newTerm(bookuser.getUserMdn(),"其他","0",0);
    conn.commit();
    flag = true;
  } catch (AppException e) {
    e.printStackTrace();
    try {conn.rollback();} catch (Exception ex) {}
  } catch (UpdateException e) {
    e.printStackTrace();
    try {conn.rollback();} catch (Exception ex) {}
  } catch (SysException e) {
    e.printStackTrace();
    try {conn.rollback();} catch (Exception ex) {}
  } catch (SQLException e) {
    e.printStackTrace();
    try {conn.rollback();} catch (Exception ex) {}
    throw new SysException("SQLException while execute subscribe");
  } finally {
    try {conn.setAutoCommit(true);} catch (Exception ex) {}
    try {conn.close();} catch (Exception ex) {}
  }
  if(flag){
    return bookuser;
  }else{
    return null;
  }
}
public static Hashtable getAllCardId()throws SysException{
  String sql = "SELECT CARD_ID FROM WAP_BOOK_USER";
  Hashtable hash = new Hashtable();
  Collection coll = queryBySql(sql);
  Iterator it = coll.iterator();
  while(it.hasNext()){
    Hashtable element = (Hashtable)it.next();
    String cardId = (String)element.get("cardId");
    hash.put(cardId,"1");
  }
  return hash;
}
public static void main(String[] args){
  try{
    Hashtable hash = getAllCardId();
    System.out.println(hash.size());
  }catch(Exception ex){

  }
}
}