usertrafficstatdaoimpl.java.svn-base

利用sip协议

/**
* 该文件由自动生成代码器生成
*/
package com.xunlei.callcenter.dao;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.RowCallbackHandler;

import com.xunlei.common.util.*;
import com.xunlei.callcenter.vo.Groups;
import com.xunlei.callcenter.vo.Usertrafficstat;


/**
* @author Administrator
* @date 2008-03-20 20:48:55
*
*/
public class UsertrafficstatDaoImpl extends BaseDao implements IUsertrafficstatDao {
	/**
	* 可以根据其他字段的查询条件来获取唯一的数据
	*/
	public Usertrafficstat findUsertrafficstat(Usertrafficstat data) {		
		String sql = "select * from usertrafficstat";
		String countsql = "select count(1) from usertrafficstat";
		StringBuilder where = new StringBuilder(" where 1=1");
		if(null != data){
			if(data.getSeqid()>0){
				return this.getUsertrafficstatById(data.getSeqid());
			}
			//TODO: 添加你的代码，查询条件
			
			countsql += where.toString();
			sql += where.toString();
			if (this.getSingleInt(countsql) == 1) {
				return this.queryOne(Usertrafficstat.class, sql);
			}			
		}
		return null;
	}
	
	public Sheet<Usertrafficstat> queryUsertrafficstat(Usertrafficstat data, PagedFliper fliper) {
		String sql = "select * from usertrafficstat";
		String countsql = "select count(1) from usertrafficstat";
		StringBuilder where = new StringBuilder(" where 1=1 ");
		if(null != data){
			//TODO: 添加你的代码，查询条件
		}
		countsql += where.toString();
		int rowcount = this.getSingleInt(countsql);
		if(rowcount <= 0){
			return Sheet.EMPTY;
		}
		sql += where.toString();
		if(null != fliper){
			if(isNotEmpty(fliper.getSortColumn())){
				sql += " order by " + fliper.getSortColumn();
			}
			sql += fliper.limitsql(rowcount);
		}		
		return new Sheet<Usertrafficstat>(rowcount, this.query(Usertrafficstat.class, sql));
	}
	/**
	* 根据传入的对象,删除相应的数据 
	*
	*/
	public void deleteUsertrafficstat(Usertrafficstat data) {
		if (null != data) {
			if (data.getSeqid() > 0) {
				this.deleteUsertrafficstatById(data.getSeqid());
			}
			//TODO: 添加你的代码，删除符合条件的记录
		}
	}

	public Usertrafficstat getUsertrafficstatById(long seqid) {
		return findObject(Usertrafficstat.class, seqid);
	}
		
	public void insertUsertrafficstat(Usertrafficstat data) {
		insertObject(data);		
	}
	
	public void updateUsertrafficstat(Usertrafficstat data) {
		updateObject(data);
	}
	
	public void deleteUsertrafficstatById(long... seqids) {
		this.deleteObject("usertrafficstat", seqids);
	}

	public List<Usertrafficstat> queryTraffic(String groupname, String date) {
		StringBuilder sql = new StringBuilder("select * from  usertrafficstat where 1=1 ");
		if(groupname!=null&& !"".equals(groupname.trim()))sql.append(" and groupid='"+groupname+"'");
		if(date!=null&& !"".equals(date.trim()))sql.append(" and BalanceDate='"+date+"'");
		final List<Usertrafficstat> datas = new ArrayList<Usertrafficstat>();
		getJdbcTemplate().query(sql.toString(), new RowCallbackHandler() {
			public void processRow(ResultSet rs) throws SQLException {
				Usertrafficstat data = new Usertrafficstat();  
				data.setSeqid(rs.getLong("seqid"));
				data.setGroupid(rs.getString("groupid"));
				data.setTraffic(rs.getInt("traffic"));
				data.setBalancedate(rs.getString("balancedate"));
				data.setUserlogno(rs.getString("UserLogNo"));
				datas.add(data);
			}
		});		
		// TODO Auto-generated method stub
		return datas;
	}
}