usermessagebean.java

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

package com.sxit.wap.usermess;

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

public class UserMessageBean extends UserMessageDao {
public static Hashtable getAccountByUserMdn(String userMdn) {
String sql ="SELECT COUNT(*),MESS_STATUS FROM WAP_USER_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_USER_MESSAGE WHERE USER_MDN = '" + userMdn + "' AND MESS_STATUS = " + status + " ORDER BY MESS_DATE";
  return queryBySql(sql);
}
public static UserMessageModel getUserMessById(long id)throws SysException,FinderException{
  return UserMessageDao.findByPK(id);
}
public static boolean insert(String userMdn,String toUserMdn,String content)throws SysException,UpdateException,AppException{
  UserMessageModel model = new UserMessageModel();
  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 delete(int id)throws SysException{
  String sql = "DELETE FROM WAP_USER_MESSAGE WHERE ID = " + id;
  updateBySql(sql);
}
public static void deleteAll(String userMdn,String status)throws SysException{
  String sql = "DELETE FROM WAP_USER_MESSAGE WHERE USER_MDN = '" + userMdn + "' AND MESS_STATUS = " + status;
  updateBySql(sql);
}
public static void updateNewToOld(int id)throws SysException{
  String sql = "UPDATE WAP_USER_MESSAGE SET MESS_STATUS = 1 WHERE ID = " + id;
  updateBySql(sql);
}
public static void main(String[] args){
}
}