mycdrreport.java

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

package com.sxit.wap.report;

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

public class MyCdrReport extends Report {
    public MyCdrReport() {
    }
	public String[] getReportHeader () {
		String [] str = {"订制时间","频道","费率","资费类型"};
		return str;
	}
	public String getReportTitle () {
		return "个人话费查询";
	}


	public ResultSet getResult ( java.sql.Statement statement, java.util.Date startDate, java.util.Date endDate,String mdn ) {
		Timestamp bt = new java.sql.Timestamp ( startDate.getTime () );
		Timestamp et = new java.sql.Timestamp ( endDate.getTime () );
		String sql = "SELECT S.SUB_DATE, c.channel_name ,s.fee_code ,fe.fee_name";
		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 ";
		sql += " AND S.USER_MDN = '" + mdn + "'and ";
		sql += DateUtil.getDateCompareSql ( Database.dbType, "S.SUB_DATE", bt, et );
		System.out.println(sql);
		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, String mdn,int beginRow,
									  int endRow ) throws SysException {
		Timestamp bt = new java.sql.Timestamp ( startDate.getTime () );
		Timestamp et = new java.sql.Timestamp ( endDate.getTime () );
		String sql ="SELECT S.SUB_DATE, c.channel_name ,s.fee_code ,fe.fee_name";
		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  ";
		sql += " AND S.USER_MDN = '" + mdn + "' and ";
		sql += DateUtil.getDateCompareSql ( Database.dbType, "S.SUB_DATE", bt, DateUtil.getSomeDate(et, 1) );

		return queryBySql ( sql, beginRow, endRow );
	}

	public int getCollectionCount ( java.util.Date startDate, java.util.Date endDate,String mdn ) throws SysException {
		Timestamp bt = new java.sql.Timestamp ( startDate.getTime () );
		Timestamp et = new java.sql.Timestamp ( endDate.getTime () );
		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 ";
		sql += " AND S.USER_MDN = '" + mdn + "'and ";
		sql += DateUtil.getDateCompareSql ( Database.dbType, "S.SUB_DATE", bt, et );
		return getRowCountBySql ( sql );
	}
        public int getFeeCodeSum(Timestamp start, Timestamp end, String mdn)
            throws SysException
        {
            String sql = "SELECT SUM(FEE_CODE)";
            sql = sql + " FROM WAP_USER_SUB_HIS WHERE USER_MDN = '" + mdn + "' and ";
            sql = sql + DateUtil.getDateCompareSql(Database.dbType, "SUB_DATE", start, DateUtil.getSomeDate(end, 1));
            System.out.println(sql);
            return getRowCountBySql(sql);
        }

}