package com.chinacreator.videoalliance.order.dao;

import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

import org.apache.commons.lang.math.NumberUtils;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Component;

import com.chinacreator.videoalliance.common.util.DataSource;
import com.chinacreator.videoalliance.order.bean.BussinessBean;
import com.frameworkset.common.poolman.SQLExecutor;

@Component
public class BussinessDao {
	
	private static Logger log = Logger.getLogger("orderError");

	public BussinessBean getBussinessInfo(String cpid,String spid,String userid) throws SQLException{
		String sql = "select userid,cpid,spid,to_char(ordertime,'yyyymmddhh24miss') ordertime,to_char(endtime,'yyyymmddhh24miss') endtime,flowstatus,vipstatus,portstatus from TD_BUSSINESS_HANDLE where userid = ? and cpid = ? and spid = ? and activetype =5";
		return   SQLExecutor.queryObjectWithDBName(BussinessBean.class, DataSource.NET3G, sql, userid,cpid,spid);
	}
	
	public long queryVipNum(String cpid) throws SQLException{
		String sql = "select  count(1)  from TD_BUSSINESS_HANDLE where  cpid = ? and activetype =5 and vipstatus=0";
		return NumberUtils.toLong(SQLExecutor.queryFieldWithDBName(DataSource.NET3G,sql, cpid));
	}
	
	/**
	 * 添加数据到活动关系处理表
	 * @param map
	 * @return
	 */
	public boolean addBussHandleWait(Map<String, String> map){
		String sql = "INSERT INTO TD_BUSSHANDLE_WAIT (ID, USERID, PROVINCE, AREA, CPID, SPID, STATUS, ORDERTIME, ORDERCHANNEL, CANCELTIME, CANCELCHANNEL, SRCFLAG) "+
					 " VALUES "+
					 " (TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS')||SEQ_COMMON6.NEXTVAL, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, '0')";
			try {
				Object obj = SQLExecutor.insertWithDBName("net3g", sql, 
						  map.get("userid"), 
						  map.get("province"),
						  map.get("area"),
						  map.get("cpid"), 
						  map.get("spid"), 
						  map.get("status"), 
						  map.get("ordertime"),  
						  map.get("orderchannel"),
						  map.get("canceltime"),
						  map.get("cancelchannel")
						  );				  
				  return ((Integer)obj)>0;
			} catch (Exception e) {
				e.printStackTrace();
				log.error("DATA=>"+map+"，添加数据到活动关系处理表出现异常，"+e.getMessage());
			}
			  
			return false;
	}
	
	public static void main(String[] args) {
		BussinessDao dao = new BussinessDao();
        Map<String, String> map = new HashMap<String, String>();
        map.put("userid", "18673197465");
        map.put("cpid", "youtu");
        map.put("spid", "1167");
        map.put("province", "湖南");
        map.put("area", "长沙");
       // map.put("ordertime", "20210615172932");
        map.put("canceltime", "20210615172959");
        map.put("status", "1");
       // map.put("orderchannel", "WP_ttt");
        map.put("cancelchannel", "WP_ttt");	
		System.out.println(dao.addBussHandleWait(map));
	}
}