accessbean.java

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

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

public class AccessBean extends AccessDao{
  public static Collection queryAccess(String userMdn, String groupId, String cpId, Timestamp beginDate, Timestamp endDate, int beginRow, int endRow) throws SysException {
     String sql = "SELECT A.*, H.CHANNEL_NAME, C.CP_NAME FROM " + tableName + " A, WAP_CP C, WAP_CHANNEL H WHERE H.CP_ID = C.ID AND A.CHANNEL_ID = H.ID AND " + DateUtil.getDateCompareSql(Database.dbType, "VISIT_TIME", beginDate, DateUtil.getSomeDate(endDate, 1));
     sql += StringUtil.isNotEmpty(userMdn)?" AND USER_MDN = '" + userMdn + "'":"";
     sql += StringUtil.isNotEmpty(cpId)?" AND C.CP_ID = " + cpId:"";
     return queryBySql(sql, beginRow, endRow);
   }
   public static int getRowCountAccess(String userMdn, String groupId, String cpId, Timestamp beginDate, Timestamp endDate)  throws SysException {
     String sql = "SELECT COUNT(*) FROM " + tableName + " A, WAP_CP C, WAP_CHANNEL H WHERE H.CP_ID = C.ID AND A.CHANNEL_ID = H.ID AND " + DateUtil.getDateCompareSql(Database.dbType, "VISIT_TIME", beginDate, DateUtil.getSomeDate(endDate, 1));
     sql += StringUtil.isNotEmpty(userMdn)?" AND USER_MDN = '" + userMdn + "'":"";
     sql += StringUtil.isNotEmpty(cpId)?" AND C.CP_ID = " + cpId:"";
     return getRowCountBySql(sql);
   }
   public static void clear(String userMdn, Timestamp beginDate, Timestamp endDate) throws SysException {
     String sql = "DELETE FROM " + tableName + " WHERE " + DateUtil.getDateCompareSql(Database.dbType, "VISIT_TIME", beginDate, DateUtil.getSomeDate(endDate, 1));
     sql += StringUtil.isNotEmpty(userMdn)?" AND USER_MDN = '" + userMdn + "'":"";
     updateBySql(sql);
   }
   public static Collection queryAccessByGroupId(String userMdn, String groupId, String cpId, Timestamp beginDate, Timestamp endDate, int beginRow, int endRow) throws SysException {
     String sql = "SELECT A.*, H.CHANNEL_NAME, C.CP_NAME FROM " + tableName + " A, WAP_CP C, WAP_CHANNEL H WHERE H.CP_ID = C.ID AND A.CHANNEL_ID = H.ID AND " + DateUtil.getDateCompareSql(Database.dbType, "VISIT_TIME", beginDate, DateUtil.getSomeDate(endDate, 1));
     sql += StringUtil.isNotEmpty(userMdn)?" AND USER_MDN = '" + userMdn + "'":"";
     sql += StringUtil.isNotEmpty(cpId)?" AND C.CP_ID = " + cpId:"";
     sql += StringUtil.isNotEmpty(groupId)?" AND H.CHANNEL_TRADE = " + groupId:"";
     System.out.println(sql);
     return queryBySql(sql, beginRow, endRow);
   }
   public static int getRowCountAccessByGroupId(String userMdn, String groupId, String cpId, Timestamp beginDate, Timestamp endDate)  throws SysException {
     String sql = "SELECT COUNT(*) FROM " + tableName + " A, WAP_CP C, WAP_CHANNEL H WHERE H.CP_ID = C.ID AND A.CHANNEL_ID = H.ID AND " + DateUtil.getDateCompareSql(Database.dbType, "VISIT_TIME", beginDate, DateUtil.getSomeDate(endDate, 1));
     sql += StringUtil.isNotEmpty(userMdn)?" AND USER_MDN = '" + userMdn + "'":"";
     sql += StringUtil.isNotEmpty(cpId)?" AND C.CP_ID = " + cpId:"";
     sql += StringUtil.isNotEmpty(groupId)?" AND H.CHANNEL_TRADE = " + groupId:"";
     return getRowCountBySql(sql);
   }
   public static int isAccess(String userMdn,int channelId,Timestamp start,Timestamp end)throws SysException{
     String sql = "SELECT COUNT(*) FROM WAP_ACCESS WHERE CHANNEL_ID = " + channelId + " AND USER_MDN = '" + userMdn + "'";
     sql +=  " AND " + DateUtil.getDateCompareSql(DBType.ORACLE,"VISIT_TIME",start,end);
     return getRowCountBySql(sql);
   }
  }