/**
* 該文件由自動生成代碼器生成
*/
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.Recording;


/**
* @author Administrator
* @date 2008-03-21 14:20:37
*
*/
public class RecordingDaoImpl extends BaseDao implements IRecordingDao {
	/**
	* 可以根據其他字段的查詢條件來獲取唯一的數據
	*/
	public Recording findRecording(Recording data) {		
		String sql = "select * from recording";
		String countsql = "select count(1) from recording";
		StringBuilder where = new StringBuilder(" where 1=1");
		if(null != data){
			if(data.getSeqid()>0){
				return this.getRecordingById(data.getSeqid());
			}
			//TODO: 添加你的代碼，查詢條件
			
			countsql += where.toString();
			sql += where.toString();
			if (this.getSingleInt(countsql) == 1) {
				return this.queryOne(Recording.class, sql);
			}			
		}
		return null;
	}
	
	public Sheet<Recording> queryRecording(Recording data, PagedFliper fliper) {
		String sql = "select * from recording";
		String countsql = "select count(1) from recording";
		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<Recording>(rowcount, this.query(Recording.class, sql));
	}
	/**
	* 根據傳入的對象,刪除相應的數據 
	*
	*/
	public void deleteRecording(Recording data) {
		if (null != data) {
			if (data.getSeqid() > 0) {
				this.deleteRecordingById(data.getSeqid());
			}
			//TODO: 添加你的代碼，刪除符合條件的記錄
		}
	}

	public Recording getRecordingById(long seqid) {
		return findObject(Recording.class, seqid);
	}
		
	public void insertRecording(Recording data) {
		insertObject(data);		
	}
	
	public void updateRecording(Recording data) {
		updateObject(data);
	}
	
	public void deleteRecordingById(long... seqids) {
		this.deleteObject("recording", seqids);
	}

	public void deleteRecordingBySql(String sql) {
		getJdbcTemplate().update(sql);
		
	}

	public int getRecordinglistCount(Recording conditonbean) {
		StringBuilder sql = new StringBuilder("select count(*) from recording where 1=1 ");
		if(conditonbean.getDateBegin()!=null&&!conditonbean.getDateBegin().equals(""))sql.append(" and substr(InputTime,1,8)>='"+ conditonbean.getDateBegin().replaceAll("-", "")+"'");
		if(conditonbean.getDateEnd()!=null&&!conditonbean.getDateEnd().equals(""))sql.append(" and substr(InputTime,1,8)<='"+ conditonbean.getDateEnd().replaceAll("-", "")+"'");
		if(conditonbean.getUserlogno()!=null&&!conditonbean.getUserlogno().equals(""))sql.append(" and UserLogNo='"+ conditonbean.getUserlogno()+"'");
		if(conditonbean.getTimeBegin()!=null&&!conditonbean.getTimeBegin().equals(""))sql.append(" and substr(InputTime,9,4)>='"+ conditonbean.getTimeBegin().replaceAll(":", "")+"'");
		if(conditonbean.getDateEnd()!=null&&!conditonbean.getDateEnd().equals(""))sql.append(" and substr(InputTime,9,4)<='"+ conditonbean.getTimeEnd().replaceAll(":", "")+"'");
		return com.xunlei.common.facade.IFacadeCommon.INSTANCE.getRecordCount(sql.toString());
	}

	public List<Recording> getRecordinglist(Recording conditonbean, int rowcount,
			int pagesize, int pageno,final String path) {
		
	    final String downpath = com.xunlei.callcenter.util.FileUtil.getConfigFilePath("recording_path");
		StringBuilder sql = new StringBuilder("select * from recording where 1=1 ");
		if(conditonbean.getDateBegin()!=null&&!conditonbean.getDateBegin().equals(""))sql.append(" and substr(InputTime,1,8)>='"+ conditonbean.getDateBegin().replaceAll("-", "")+"'");
		if(conditonbean.getDateEnd()!=null&&!conditonbean.getDateEnd().equals(""))sql.append(" and substr(InputTime,1,8)<='"+ conditonbean.getDateEnd().replaceAll("-", "")+"'");
		if(conditonbean.getUserlogno()!=null&&!conditonbean.getUserlogno().equals(""))sql.append(" and UserLogNo='"+ conditonbean.getUserlogno()+"'");
		if(conditonbean.getTimeBegin()!=null&&!conditonbean.getTimeBegin().equals(""))sql.append(" and substr(InputTime,9,4)>='"+ conditonbean.getTimeBegin().replaceAll(":", "")+"'");
		if(conditonbean.getDateEnd()!=null&&!conditonbean.getDateEnd().equals(""))sql.append(" and substr(InputTime,9,4)<='"+ conditonbean.getTimeEnd().replaceAll(":", "")+"'");		
		String querysql = addLimitToSql(sql.toString(), rowcount, pagesize, pageno);
		final List<Recording> datas = new ArrayList<Recording>();
		getJdbcTemplate().query(querysql, new RowCallbackHandler() {
			public void processRow(ResultSet rs) throws SQLException {
				Recording recording = new Recording();
				recording.setSeqid(rs.getLong("seqid"));
				recording.setGroupid(rs.getString("groupid"));
				recording.setUserlogno(rs.getString("UserLogNo"));
				recording.setCustomertel(rs.getString("CustomerTel"));
				recording.setFileurl(rs.getString("FileUrl"));
				recording.setInputtime(rs.getString("InputTime"));
				recording.setRealfileurl(path+"/"+rs.getString("FileUrl"));
				recording.setDownfilepath(downpath+"/"+rs.getString("FileUrl"));
				datas.add(recording);
			}
		});
		return datas;
	}
}