termbean.java

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

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

public class TermBean extends TermDao{
public static Collection getUserMessageByName(String name,String userMdn)throws SysException{
  String sql = "SELECT U.USER_MDN,C.USER_NAME FROM WAP_TERM T,WAP_USER_CARD C,WAP_TERM_USER U WHERE U.USER_MDN =C.USER_MDN AND T.USER_MDN = '" + userMdn + "' AND T.TERM_ID = U.TERM_ID AND C.USER_NAME LIKE '" + name + "%'";
  return queryBySql(sql);
}
public static Collection getUserMessageByMdn(String mdn,String userMdn)throws SysException{
  String sql = "SELECT U.USER_MDN,C.USER_NAME FROM WAP_TERM T,WAP_USER_CARD C,WAP_TERM_USER U WHERE U.USER_MDN =C.USER_MDN AND T.USER_MDN = '" + userMdn + "' AND T.TERM_ID = U.TERM_ID AND C.USER_MDN LIKE '" + mdn + "%'";
  return queryBySql(sql);
}
public static Collection getTermByUserMdn(String userMdn)throws SysException{
  String sql = "SELECT * FROM WAP_TERM WHERE USER_MDN = '" + userMdn + "' ORDER BY TERM_ATTR";
  return queryBySql(sql);
}
public static TermModel insert(String userMdn,String termName,int termAttr)throws SysException,UpdateException,AppException{
  TermModel model = new TermModel();
  model.setTermId(TermDao.getSequenceNextValue());
  model.setTermName(termName);
  model.setUserMdn(userMdn);
  model.setTermAttr(termAttr);
  insert(model);
  return model;
}
public static boolean isExist(String userMdn)throws SysException{
  String sql = "SELECT COUNT(*) FROM WAP_TERM WHERE USER_MDN = '" + userMdn + "'";
  return getRowCountBySql(sql) > 0;
}
public static void newTerm(String userMdn)throws SysException{
  Connection conn = null;
try {
  conn = Database.getConnection();
  conn.setAutoCommit(false);
  insert(userMdn,"我的朋友",99);
  conn.commit();
} 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) {}
}
}
public static boolean deleteTerm(int id,int term)throws SysException{
boolean flag = false;
Connection conn = null;
try {
conn = Database.getConnection();
conn.setAutoCommit(false);
String sql = "UPDATE WAP_TERM_USER SET TERM_ID = " + term + " WHERE TERM_ID = " + id;
updateBySql(sql);
sql = "DELETE FROM WAP_TERM WHERE TERM_ID = " + id;
updateBySql(sql);
conn.commit();
flag = true;
}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) {}
}
 return flag;
}
}