cpstatreport.java

来自「WAP PUSH后台源码,WAP PUSH后台源码」· Java 代码 · 共 84 行

package com.sxit.wap.report;

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

public class CpStatReport extends Report {
    public CpStatReport() {
    }
	public String[] getReportHeader () {
		String [] str = {"MDN","频道名称","费率","费率类型","订制时间"};
		return str;
	}
	public String getReportTitle () {
		return "mdn 收费明细报表";
	}


	public ResultSet getResult ( java.sql.Statement statement, java.util.Date startDate, java.util.Date endDate, int cpId, String mdn ) {
		if (startDate == null)
			startDate = new java.util.Date();
		if (endDate == null)
			endDate = new java.util.Date();
		if (mdn ==null)
			mdn = "";
		String sql = "SELECT S.USER_MDN, c.channel_name ,s.fee_code ,fe.fee_name,S.SUB_DATE ";
		sql += " FROM WAP_USER_SUB_HIS S, WAP_CHANNEL C,WAP_FEE_TYPE fe";
		sql += " WHERE S.CHANNEL_ID = C.ID and fe.fee_type = s.fee_type and ";
		Timestamp bt = new java.sql.Timestamp ( startDate.getTime () );
		Timestamp et = new java.sql.Timestamp ( endDate.getTime () );
		sql += DateUtil.getDateCompareSql ( Database.dbType, "S.SUB_DATE", bt, et );
		if ( !"".equals ( mdn ) && mdn!= null )

			sql += " AND S.USER_MDN = '" + mdn + "'";
		if ( cpId != -1 )
			sql += " and C.cp_ID =" + cpId;
		java.sql.ResultSet rs = null;
		try {
			rs = statement.executeQuery ( sql );
		} catch ( Exception e1 ) {
		}
		return rs;
	}

	public Collection getCollection ( java.util.Date startDate, java.util.Date endDate, int cpId, String mdn, int beginRow,
									  int endRow ) throws SysException {
		if (startDate == null)
			startDate = new java.util.Date();
		if (endDate == null)
			endDate = new java.util.Date();
		String sql = "SELECT S.USER_MDN, c.channel_name ,s.fee_code ,fe.fee_name,S.SUB_DATE ";
		sql += " FROM WAP_USER_SUB_HIS S, WAP_CHANNEL C,WAP_FEE_TYPE fe";
		sql += " WHERE S.CHANNEL_ID = C.ID and fe.fee_type = s.fee_type and ";
		Timestamp bt = new java.sql.Timestamp ( startDate.getTime () );
		Timestamp et = new java.sql.Timestamp ( endDate.getTime () );
		sql += DateUtil.getDateCompareSql ( Database.dbType, "S.SUB_DATE", bt, et );
		if ( !"".equals ( mdn ) && mdn!= null )
			sql += " AND S.USER_MDN = '" + mdn + "'";
		if ( cpId != -1 )
			sql += " and C.cp_ID =" + cpId;
		return queryBySql ( sql, beginRow, endRow );
	}

	public int getCollectionCount ( java.util.Date startDate, java.util.Date endDate, int cpId, String mdn ) throws SysException {
		if (startDate == null)
			startDate = new java.util.Date();
		if (endDate == null)
			endDate = new java.util.Date();
		String sql = "SELECT count(*) ";
		sql += " FROM WAP_USER_SUB_HIS S, WAP_CHANNEL C,WAP_FEE_TYPE fe";
		sql += " WHERE S.CHANNEL_ID = C.ID and fe.fee_type = s.fee_type and ";
		Timestamp bt = new java.sql.Timestamp ( startDate.getTime () );
		Timestamp et = new java.sql.Timestamp ( endDate.getTime () );
		sql += DateUtil.getDateCompareSql ( Database.dbType, "S.SUB_DATE", bt, et );
		if ( !"".equals ( mdn ) && mdn!= null )
			sql += " AND S.USER_MDN = '" + mdn + "'";
		if ( cpId != -1 )
			sql += " and C.cp_ID =" + cpId;

		return getRowCountBySql ( sql );
	}

}