termuserbean.java

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

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

public class TermUserBean extends TermUserDao{
public static Collection getTermUserByUserId(String termId)throws SysException{
  String sql = "SELECT U.*,C.USER_NAME FROM WAP_TERM_USER U,WAP_USER_CARD C WHERE U.USER_MDN = C.USER_MDN AND U.TERM_ID =" + termId;
  return queryBySql(sql);
}
public static boolean sendCard(String from,String to)throws SysException{
  String sql = "INSERT INTO WAP_TERM_USER (SELECT T.TERM_ID,'" + from + "' FROM WAP_TERM T WHERE USER_MDN = '" + to + "' AND T.TERM_ATTR =99)";
  return updateBySql(sql) == 1;
}
public static boolean update(String oldid,String newid,String userMdn)throws SysException{
  String sql = "UPDATE WAP_TERM_USER SET TERM_ID = " + newid + " WHERE TERM_ID = " + oldid + " AND USER_MDN = '" + userMdn + "'";
  return updateBySql(sql) ==1;
}
public static boolean delete(String id,String userMdn)throws SysException{
  String sql = "DELETE FROM WAP_TERM_USER WHERE TERM_ID = " + id + " AND USER_MDN = '" + userMdn + "'";
  System.out.println(sql);
  return updateBySql(sql) == 1;
}
}