channelbean.java

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

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


public class ChannelBean extends ChannelDao{
  public static Collection queryChannel() throws SysException {
    String sql = "SELECT * FROM WAP_CHANNEL WHERE CHANNEL_APPEAR = 2 OR CHANNEL_APPEAR = 3 ORDER BY CHANNEL_APPEAR";
    return queryBySql(sql);
  }
  public static int getRowCountOfChannel() throws SysException {
    String sql = "SELECT COUNT(*) FROM WAP_CHANNEL WHERE CHANNEL_APPEAR = 2 OR CHANNEL_APPEAR = 3";
    return getRowCountBySql(sql);
  }
  public static Collection queryChannel(int channelAppear, int beginRow, int endRow) throws SysException {
    String sql = "SELECT C.*, P.CP_NAME, T.NAME CHANNEL_TYPE_DESC FROM WAP_CHANNEL C, WAP_CP P, WAP_CHANNEL_TYPE T WHERE C.CP_ID = P.ID AND C.CHANNEL_TYPE = T.ID AND CHANNEL_APPEAR = " + channelAppear;
    return queryBySql(sql, beginRow, endRow);
  }
  public static Collection queryChannelByAppear(int channelAppear) throws SysException {
    String sql = "SELECT * FROM WAP_CHANNEL WHERE CHANNEL_APPEAR = " + channelAppear;
    return queryBySql(sql);
  }
  public static int getRowCountOfChannel(int channelAppear) throws SysException {
    String sql = "SELECT COUNT(*) FROM WAP_CHANNEL C, WAP_CP P, WAP_CHANNEL_TYPE T WHERE C.CP_ID = P.ID AND C.CHANNEL_TYPE = T.ID AND CHANNEL_APPEAR = " + channelAppear;
    return getRowCountBySql(sql);
  }
  public static Hashtable getGroupChannel(String userMdn) throws SysException {
    Hashtable value = new Hashtable();
    String sql = "SELECT C.* FROM WAP_CHANNEL C, WAP_GROUP G, WAP_USER U" +
                 " WHERE C.CHANNEL_TRADE = G.ID" +
                 " AND G.ID = U.USER_GROUP AND U.USER_MDN = '" + userMdn + "'";
    Collection coll = queryBySql(sql);System.out.println(sql);
    Iterator it = coll.iterator();
    while ( it.hasNext() ) {
        Hashtable element = (Hashtable)it.next();
        ChannelModel channelModel = ChannelBean.toModel(element);
        int id = channelModel.getId();
        value.put(""+id, channelModel);
    }
    return value;
  }
  public static boolean isExists(String channelName) throws SysException {
    return getRowCountBySql("SELECT COUNT(*) FROM " + tableName + " WHERE CHANNEL_NAME = '" + channelName +"'")>=1;
  }
  public static boolean isExists(int id, String channelName) throws SysException {
    return getRowCountBySql("SELECT COUNT(*) FROM " + tableName + " WHERE CHANNEL_NAME = '" + channelName +"'" + " AND ID <> '" + id + "'")>=1;
  }
  public static boolean isChannelCodeExists(String channelCode) throws SysException {
    return getRowCountBySql("SELECT COUNT(*) FROM " + tableName + " WHERE CHANNEL_CODE = '" + channelCode +"'")>=1;
  }
  public static boolean isChannelCodeExists(int id, String channelCode) throws SysException {
    return getRowCountBySql("SELECT COUNT(*) FROM " + tableName + " WHERE CHANNEL_CODE = '" + channelCode +"'" + " AND ID <> '" + id + "'")>=1;
  }
  public static void subscribeInc(int channelId) throws SysException {
    String sql = "update " + tableName + " set CHANNEL_SUBSCRIBE = CHANNEL_SUBSCRIBE + 1 where ID = " + channelId;
    updateBySql(sql);
  }
  public static void subscribeDec(int channelId) throws SysException {
    String sql = "update " +tableName + " set CHANNEL_SUBSCRIBE = CHANNEL_SUBSCRIBE - 1 where ID = " + channelId;
    updateBySql(sql);
  }
  public static void accessInc(int channelId) throws SysException {
    String sql = "update " + tableName + " set CHANNEL_ACCESS = CHANNEL_ACCESS + 1 where ID = " + channelId;
    updateBySql(sql);
  }
  public static Collection queryApply(int beginRow, int endRow) throws SysException {
    String sql = "SELECT CH.*, CP.CP_NAME FROM " + tableName + " CH, WAP_CP CP WHERE CH.CP_ID = CP.ID AND CHANNEL_STATUS = 0";
    return queryBySql(sql, beginRow, endRow);
  }
  public static int getRowCountOfApply() throws SysException {
    String sql = "SELECT COUNT(*) FROM " + tableName + " CH, WAP_CP CP WHERE CH.CP_ID = CP.ID AND CHANNEL_STATUS = 0";
    return getRowCountBySql(sql);
  }
  public static Collection queryApply(int cpId, int beginRow, int endRow) throws SysException {
    String sql = "SELECT * FROM " + tableName + " WHERE CHANNEL_STATUS = 0 AND CP_ID = " + cpId;
    return queryBySql(sql, beginRow, endRow);
  }
  public static int getRowCountOfApply(int cpId) throws SysException {
    String sql = "SELECT COUNT(*) FROM " + tableName + " WHERE CHANNEL_STATUS = 0 AND CP_ID = " + cpId;
    return getRowCountBySql(sql);
  }
  //获取等待批准的频道个数（新加）
 public static int getRowCBySta()  {
   int returnV=0 ;
   try{
   String sql = "select count(*) from wap_channel where CHANNEL_STATUS=0";
   returnV=getRowCountBySql(sql);
 }catch(SysException e){}
   return returnV;
 }

 //获取等待批准的某个频道（新加）
 public static int getRowCByStaAndChI(String channelId){
   int returnV=0 ;
   try{
   String sql = "select count(*) from wap_channel where channel_status=0 and id='" +
       channelId + "'";
  returnV=getRowCountBySql(sql);
   }catch(SysException e){}
   return returnV;
}

 //获取等待批准的频道(新加)
 public static Collection getAll(int beginRow, int endRow){
   Collection returnVa=null;
   try{
     String sql = "select * from wap_channel where channel_status=0";
     returnVa = queryBySql(sql, beginRow, endRow);
   } catch (SysException e) {}
   return returnVa;
 }

 //获取等待批准的某个频道(新加)
 public static Collection getOneByChannelId(String channelId) {
   Collection returnVa = null;
   try {
     String sql =
         "select * from wap_channel where channel_status=0 and id='" +
         channelId + "'";
     returnVa = queryBySql(sql);
   }
   catch (SysException e) {}
   return returnVa;
 }
  public static Collection getChannelMsgBySql(int menuChannel)throws SysException{
   String sql = "SELECT CP.CP_NAME,CH.CHANNEL_DESCRIBE,CH.CHANNEL_NAME FROM WAP_CP CP,WAP_CHANNEL CH WHERE CP.ID=CH.CP_ID AND CH.ID ="+menuChannel;
   return queryBySql(sql);
 }

 public static boolean isTest(int channelId) throws SysException{
   String sql = "SELECT CHANNEL_TEST FROM WAP_CHANNEL WHERE ID =" + channelId + " AND CHANNEL_TEST =1";
   return queryBySql(sql).size()>=1;
 }
 public static Collection queryAllByCpId(int id,int beginRow, int endRow) throws SysException{
   String sql = "SELECT * FROM WAP_CHANNEL WHERE CP_ID =" + id;
   return queryBySql(sql, beginRow, endRow);
 }
 public static int getRowCountByCpId(int cpId) throws SysException{
   String sql = "SELECT COUNT(*) FROM WAP_CHANNEL WHERE CP_ID =" + cpId;
   return getRowCountBySql(sql);
 }
 public static Hashtable getGroupChannel() throws SysException {
   Hashtable value = new Hashtable();
   String sql = "SELECT ID CHANNEL_ID FROM WAP_CHANNEL WHERE CHANNEL_TRADE <> 0";
   Collection coll = queryBySql(sql);
   Iterator it = coll.iterator();
   while (it.hasNext()) {
     Hashtable element = (Hashtable)it.next();
     value.put(((String)element.get("channelId")), "1");
   }
   return value;
 }
 public static Hashtable getMyGroupChannel(String userMdn) throws SysException {
   Hashtable value = new Hashtable();
   String sql = "SELECT C.ID CHANNEL_ID FROM WAP_GROUP_USER G, WAP_CHANNEL C " +
       " WHERE G.GROUP_ID = C.CHANNEL_TRADE " +
       " AND C.CHANNEL_STATUS = 1 " +
       " AND USER_MDN = '" + userMdn + "' ";
   System.out.println(sql);
   Collection coll = queryBySql(sql);
   Iterator it = coll.iterator();
   while (it.hasNext()) {
     Hashtable element = (Hashtable)it.next();
     value.put(((String)element.get("channelId")), "1");
   }
   return value;
 }
 public static Collection queryApply(String queryCpId, String queryCpName, String queryChannelCode, String queryChannelName, String channelStatus, String channelTest, int beginRow, int endRow) throws SysException {
   String sql = "SELECT CH.*, CP.CP_NAME FROM " + tableName +
       " CH, WAP_CP CP WHERE CH.CP_ID = CP.ID ";
   if (StringUtil.isNotEmpty(queryCpId)) sql += " AND CH.CP_ID = '" + queryCpId + "'";
   if (StringUtil.isNotEmpty(queryCpName)) sql += " AND CP.CP_NAME LIKE '%" + queryCpName + "%'";
   if (StringUtil.isNotEmpty(queryChannelCode)) sql += " AND CH.CHANNEL_CODE LIKE '%" + queryChannelCode + "%'";
   if (StringUtil.isNotEmpty(queryChannelName)) sql += " AND CH.CHANNEL_NAME LIKE '%" + queryChannelName + "%'";
   if (StringUtil.isNotEmpty(channelStatus)) sql += " AND CHANNEL_STATUS = '" + channelStatus + "'";
   if (StringUtil.isNotEmpty(channelTest)) sql += " AND CHANNEL_TEST = '" + channelTest + "'";
   sql += " ORDER BY CH.CP_ID, CH.CHANNEL_NAME";
   return queryBySql(sql, beginRow, endRow);
 }
 public static int getRowCountOfApply(String queryCpId, String queryCpName, String queryChannelCode, String queryChannelName, String channelStatus, String channelTest) throws SysException {
   String sql = "SELECT COUNT(*) FROM " + tableName +
       " CH, WAP_CP CP WHERE CH.CP_ID = CP.ID ";
   if (StringUtil.isNotEmpty(queryCpId)) sql += " AND CH.CP_ID = '" + queryCpId + "'";
   if (StringUtil.isNotEmpty(queryCpName)) sql += " AND CP.CP_NAME LIKE '%" + queryCpName + "%'";
   if (StringUtil.isNotEmpty(queryChannelCode)) sql += " AND CH.CHANNEL_CODE LIKE '%" + queryChannelCode + "%'";
   if (StringUtil.isNotEmpty(queryChannelName)) sql += " AND CH.CHANNEL_NAME LIKE '%" + queryChannelName + "%'";
   if (StringUtil.isNotEmpty(channelStatus)) sql += " AND CHANNEL_STATUS = '" + channelStatus + "'";
   if (StringUtil.isNotEmpty(channelTest)) sql += " AND CHANNEL_TEST = '" + channelTest + "'";
   return getRowCountBySql(sql);
 }

}