package com.chinacreator.videoalliance.query.action;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.math.NumberUtils;
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.chinacreator.common.exception.BusinessException;
import com.chinacreator.common.pipe.DataOutPipe;
import com.chinacreator.common.util.DESUtil;
import com.chinacreator.common.util.MD5;
import com.chinacreator.common.util.URLUtil;
import com.chinacreator.videoalliance.common.annotation.DataOut;
import com.chinacreator.videoalliance.order.bean.WxcsBean;
import com.chinacreator.videoalliance.order.dao.BussinessDao;
import com.chinacreator.videoalliance.order.dao.WxcsDao;
import com.chinacreator.videoalliance.order.util.JsonUtil;

@Controller
public class CsQueryVipNumAction {

 
	@Autowired
	private WxcsDao wxcsDao;
	
	@Autowired
	private BussinessDao bussinessDao;
	
	@RequestMapping("/getVipNum.do")
	@DataOut(callback = "getVipNum")
	public DataOutPipe doOrder(HttpServletRequest request, String cpid) throws Exception {
		DataOutPipe pipe = new DataOutPipe();
		if (StringUtils.isEmpty(cpid)) {
			throw new BusinessException("7002", "参数错误");
		}
		WxcsBean wxcsBean = wxcsDao.getConfig(cpid);
		if(wxcsBean == null){
			throw new BusinessException("7002", "参数错误");
		}
		if(!wxcsBean.getVipstatus().equals("0")
				|| NumberUtils.toLong(DateFormatUtils.format(new Date(), "yyyyMMddHHmmss")) > NumberUtils.toLong(wxcsBean.getVipendtime())
				|| NumberUtils.toLong(DateFormatUtils.format(new Date(), "yyyyMMddHHmmss")) < NumberUtils.toLong(wxcsBean
						.getVipstarttime())){
			throw new BusinessException("9906", "会员赠送已停止");
		}
		pipe.add("total", wxcsBean.getTotalvip());
		long usenum = bussinessDao.queryVipNum(cpid);
		pipe.add("usenum", usenum+"");
		pipe.add("surplus", (NumberUtils.toLong(wxcsBean.getTotalvip())-usenum));
		pipe.add("time", DateFormatUtils.format(new Date(), "yyyyMMddHHmmss"));
		return pipe;
	}
	
	public static void main(String[] args) throws Exception { 
		//腾讯赠送会员
		String url = "http://vip.video.qq.com/fcgi-bin/comm_cgi?name=hlwmp_access_layer&cmd=1&otype=xjson";
		Map<String,Object> map = new HashMap<String, Object>();
		map.put("channel_id", 30049);
		map.put("order_id", "201803301047327338600");
		map.put("user_type", 1);
		map.put("user_id", "306581007");
		map.put("appid", "");
		map.put("oper_type", 1);
		map.put("days", "vip_31");
		int timestamp =  (int) (System.currentTimeMillis()/1000);
		map.put("timestamp", 1522393277);
		String signature = MD5.MD5Encode("300499a381rspstgu3wt8k2mxvb2w6uiybimfv2k4mkjxaieiyxojoi31vfpg2iovfg71201803301047327338600306581007"+1522393277);
		map.put("signature", signature);
		System.out.println(signature);
		map.put("times", 1);
		map.put("remark", "");
		map.put("callback", "");
		String postContent = JsonUtil.objectToJson(map);
		System.out.println(postContent);
		String result = URLUtil.post(url, postContent);
		System.out.println(result);
	}
	
	public static void main1(String[] args) throws UnsupportedEncodingException, Exception {
		//leshi 赠送会员
		String url = "http://lepay.leeco.com/lems/lepay/flow/vip";
		Map<String,Object> map = new HashMap<String, Object>();
		map.put("cpid", "leshilt");
		map.put("spid", "1154");
		String userid = DESUtil.encode("18574414678", "eb0d1e4b");
		map.put("userid",URLEncoder.encode(userid, "utf-8"));
		map.put("tradeid", "000000001");
		String timestampe = (System.currentTimeMillis())/1000+"";
		map.put("timestampe", timestampe);
		String sign = MD5.MD5Encode(userid+"1154"+"leshilt"+ timestampe +"eb0d1e4b");
		map.put("sign", sign);
		System.out.println(JsonUtil.objectToJson(map));
		System.out.println(URLUtil.get(url+"?cpid=leshilt&spid=1154&userid="+URLEncoder.encode(userid, "utf-8")+"&tradeid=000000001&timestampe="+timestampe+"&sign="+sign)); 
	}
}