package com.chinacreator.videoalliance.query.dao;

import java.sql.SQLException;
import java.util.List;

import org.apache.commons.lang.math.NumberUtils;
import org.springframework.stereotype.Component;
import com.chinacreator.videoalliance.common.util.DataSource;
import com.chinacreator.videoalliance.query.bean.UserMsgInfo;
import com.frameworkset.common.poolman.SQLExecutor;

@Component
public class UserMsgDao {

	
	public void insert(UserMsgInfo userMsgInfo) throws SQLException {
		String sql = "insert into td_usermsg_info(userid,cpid,spid,msg1,msg2,msg3,activeid,inserttime) values(#[userid],#[cpid],#[spid],#[msg1],#[msg2],#[msg3],#[activeid],sysdate)";
		SQLExecutor.insertBean(DataSource.NET3G, sql, userMsgInfo);
	}
	
	public boolean query(String userid,String cpid,String spid,String activeid) throws SQLException{
		String sql ="select count(1) from td_usermsg_info where userid =? and cpid =? and spid=? and activeid=?";
		return NumberUtils.toInt(SQLExecutor.queryFieldWithDBName(DataSource.NET3G, sql,userid,cpid,spid,activeid), 0) > 0;
	}
	
	public List<UserMsgInfo> queryList(String userid,String cpid,String spid) throws SQLException{
		String sql ="select * from td_usermsg_info where userid =? and cpid =? and spid=?";
		return SQLExecutor.queryListWithDBName(UserMsgInfo.class, DataSource.NET3G, sql, userid,cpid,spid);
	}
	
	public static void main(String[] args) throws SQLException {
		UserMsgDao dao = new UserMsgDao();
//		UserMsgInfo userMsgInfo = new UserMsgInfo();
//		userMsgInfo.setCpid("tencent");
//		userMsgInfo.setSpid("6");
//		userMsgInfo.setMsg1("21646");
//		userMsgInfo.setActiveid("txcj");
//		userMsgInfo.setUserid("18574414678");
//		dao.insert(userMsgInfo);
		System.out.println(dao.queryList("18574414678", "tencent", "6").size());
	}
}