bookmessagebean.java

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

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

public class BookMessageBean extends BookMessageDao{
  public static Hashtable getAccountByUserMdn(String userMdn) {
  String sql ="SELECT COUNT(*),MESS_STATUS FROM WAP_BOOK_MESSAGE WHERE USER_MDN = '" + userMdn + "' GROUP BY MESS_STATUS ORDER BY MESS_STATUS";
  Hashtable ht = new Hashtable();
  Statement stmt = null;
  try {
        Connection dbConnection = Database.getConnection();
        stmt = dbConnection.createStatement();
        ResultSet rs = stmt.executeQuery(sql);
        while (rs.next()) {
          String acount = rs.getString(1);
          String status = rs.getString(2);
          System.out.println(status);
          System.out.println(acount);
          ht.put(status, acount);
        }
  }catch(SysException ex){
        ex.printStackTrace();
  }catch (SQLException e) {
       Debug.println(sql + "\n" + "SQLException while execute insert method :\n" + e);
  }finally {
    try {
        if (stmt != null) {
           stmt.close();
        }
    }catch (SQLException se) {
          //throw new SysException("SQL Exception while closing Statement : \n" + se);
    }
  }
  return ht;
  }
  public static Collection getMessByUserMdn(String userMdn,String status)throws SysException{
    String sql = "SELECT * FROM WAP_BOOK_MESSAGE WHERE USER_MDN = '" + userMdn + "' AND MESS_STATUS = " + status + " ORDER BY MESS_DATE";
    return queryBySql(sql);
  }
  public static boolean insert(String userMdn,String toUserMdn,String content)throws SysException,UpdateException,AppException{
    BookMessageModel model = new BookMessageModel();
    model.setId(getSequenceNextValue());
    model.setMessDate(new Timestamp(System.currentTimeMillis()));
    model.setMessFrom(userMdn);
    model.setUserMdn(toUserMdn);
    model.setMessStatus(0);
    model.setMessContent(content);
    insert(model);
    return true;
  }
  public static void deleteAll(String userMdn,String status)throws SysException{
    String sql = "DELETE FROM WAP_BOOK_MESSAGE WHERE USER_MDN = '" + userMdn + "' AND MESS_STATUS = " + status;
    updateBySql(sql);
  }
  public static void delete(int id)throws SysException{
  String sql = "DELETE FROM WAP_BOOK_MESSAGE WHERE ID = " + id;
  updateBySql(sql);
}
public static BookMessageModel getUserMessById(long id)throws SysException,FinderException{
  return findByPK(id);
}
public static void updateNewToOld(int id)throws SysException{
  String sql = "UPDATE WAP_BOOK_MESSAGE SET MESS_STATUS = 1 WHERE ID = " + id;
  updateBySql(sql);
}
public static int getRowCountOfAll(int status,String userMdn)throws SysException{
  String sql = "SELECT COUNT(*) FROM WAP_BOOK_MESSAGE WHERE MESS_STATUS =" + status + " AND USER_MDN = '"+userMdn + "'";
  return getRowCountBySql(sql);
}
public static Collection queryUserByStatus(int status,String userMdn, int beginRow, int endRow)throws SysException{
  String sql =  "SELECT * FROM WAP_BOOK_MESSAGE WHERE MESS_STATUS =" + status + " AND USER_MDN = '"+userMdn + "'";
  return queryBySql(sql,beginRow,endRow);
}
}