package org.theyeasy.weixin.util;

import java.util.HashMap;
import java.util.Map;

import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;

import com.w1hd.zzhnc.util.CommonUtil;
import com.w1hd.zzhnc.util.RedisUtil;
import com.w1hd.zzhnc.vo.Vo_TemplateDataItem;
import com.w1hd.zzhnc.vo.Vo_Template_KHZXTZ;
import com.w1hd.zzhnc.vo.Vo_Template_Param;

import me.chanjar.weixin.common.exception.WxErrorException;
import net.sf.json.JSONObject;

public class WxMpUtil {
	// 添加消息模板 add by lcc 171027
	public static String addTemplate(String template_id_short) {
		if (getTemplateLongId(template_id_short)!="") return "error:该模板已经存在，请勿重复添加!";
		String url = "https://api.weixin.qq.com/cgi-bin/template/api_add_template";
		Map<String, Object> param = new HashMap<String, Object>();
		param.put("template_id_short", template_id_short);

		try {
			String result = sendWxPost(url, param);
			System.out.println("addTemplate post.result=:" + result);
			
			JSONObject resultJson = JSONObject.fromObject(result);
			if (resultJson.getInt("errcode")==0) {
				String template_id = resultJson.getString("template_id");
				String key = RedisUtil.getMpAppid() + "_TemplateId_" + template_id_short;
				RedisUtil.set(key, template_id); // 将长ID保存到缓存。
				return template_id;
			} else {
				return "error:" + resultJson.getString("errmsg");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "error:服务器处理失败";
	}


	//判断是否添加过模板id
	public static String getTemplateLongId(String template_id_short)
	{
		String redisKey = RedisUtil.getMpAppid() + "_TemplateId_" + template_id_short;
		String template_id = RedisUtil.get(redisKey);
		System.out.println("缓存里中" + redisKey + "的值是：" + template_id);
		if (null == template_id || template_id.equals("")) return "";
		return template_id;
	}
	
	
	// 发送模板消息_(模板名称：客户跟进提醒 Template_id_short:?) add by lcc 171027
	public static String SendTemplate_Vanker(String openid, String custMsg, String custName, String projectName, String askTime, String directUrl) {
		String template_id = "123O4orTZimyb1UY1L2SOiJsEn8-6DswBWTFE9kwnZw";

		// 发送模板消息
		Vo_Template_Param param = new Vo_Template_Param();
		param.setTouser(openid);
		param.setTemplate_id(template_id);
		param.setUrl(directUrl);

		Vo_Template_KHZXTZ data = new Vo_Template_KHZXTZ();
		

		data.setFirst(new Vo_TemplateDataItem(custMsg,"#A00000")); //标题		
		data.setKeyword1(new Vo_TemplateDataItem(custName,"#173177"));//任务信息
		data.setKeyword2(new Vo_TemplateDataItem(projectName,"#B0B0B0"));//所在项目
		data.setKeyword3(new Vo_TemplateDataItem(askTime,"#B0B0B0"));//任务时间
		data.setRemark(new Vo_TemplateDataItem("请点击打开客服面板进行回复","#B0B0B0"));//remark

		param.setData(data);
		
		try {
			String result = sendTemplet(param);			
			return result;
		} catch (WxErrorException e) {
			e.printStackTrace();
		}
		return "发送失败，系统处理错误!";
	}

	
	// 发送模板消息_基础 add by lcc 171027
	public static String sendTemplet(Vo_Template_Param data) throws WxErrorException {
		String requestUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + RedisUtil.getMpToken();
		
		String param = CommonUtil.getJson(data);
		System.out.println("发送模板消息,参数=" + param);
		return CommonUtil.sendPost(requestUrl, param);
	}

	// 向微信服务器发送Post请求 add by lcc 171027
	public static String sendWxPost(String uri, Map<String, Object> param) throws WxErrorException {

		String uriWithAccessToken = uri;
		String accessToken = RedisUtil.getMpToken();
		System.out.print("MpAccessToken is:" + accessToken);
		uriWithAccessToken += uri.indexOf('?') == -1 ? "?access_token=" + accessToken : "&access_token=" + accessToken;

		RestTemplate rest = new RestTemplate();

		MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
		HttpEntity<Map<String, Object>> requestEntity = new HttpEntity<Map<String, Object>>(param, headers);
		ResponseEntity<String> entity = rest.exchange(uriWithAccessToken, HttpMethod.POST, requestEntity, String.class);

		String result = entity.getBody();

		System.out.print("sendWxPost.result=" + result + "  param=" + param.toString());

		return result;
	}
	
	
	public static void main(String[] arg)
	{
		//WxMpUtil.SendTemplate_KHZXTZ("odxglt22ULkY7ZgpdgzdMW9zBr5c", "这是一条测试的模板消息", "admin", "无", "2017-10-28 21:33:31", "mini.weiyisz.com/wx/chatListView?salesId=1");
		String res = WxMpUtil.SendTemplate_Vanker("oXqmKwSoVLT31zRncvr9Q5pWiLFI", "这是一条测试的模板消息", "admin", "无", "2017-10-28 21:33:31", "mini.weiyisz.com/wx/chatListView?salesId=1");
		System.out.print("send:" + res);
	}
}