package cn.ksource.core.weixin.service;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.HttpCharset;
import cn.ksource.core.util.HttpUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.weixin.SHA1;
import cn.ksource.core.weixin.WeiXinConstants;
import cn.ksource.core.weixin.service.WeiXinCoreService;
import cn.ksource.web.controller.wechat.util.WechatConstants;

@Service
public class WeiXinCoreServiceImpl implements WeiXinCoreService {

	Logger logger = Logger.getLogger(this.getClass());
	
	@Cacheable(value="WeiXinCache")
	public String getAccess_token() {
		String url = WechatConstants.GET_TOKEN_URL;
		logger.info("获取token----------"+url);
		System.out.println("获取token----------"+url);
		String valString = HttpUtil.doGet(url, new HashMap<String, String>(), HttpCharset.UTF8);
		Map map = JsonUtil.json2Map(valString);
		return ConvertUtil.obj2Str(map.get("access_token"));
	}
	
	
	@Cacheable(value="jsApiTicketCache")
	public String getJsApiTicket() {
		String url = WechatConstants.GET_JSAPITICKET_URL+getAccess_token();
		String valString = HttpUtil.doGet(url, new HashMap<String, String>(), HttpCharset.UTF8);
		Map map = JsonUtil.json2Map(valString);
		return ConvertUtil.obj2Str(map.get("ticket"));
	}

	@Override
	public boolean checkLegitimacy(HttpServletRequest request) {
		
		String token = WeiXinConstants.token;
		
		String signature = request.getParameter("signature");
		String timestamp = request.getParameter("timestamp");
		String nonce = request.getParameter("nonce");
		String echostr = request.getParameter("echostr");
		
		
		ArrayList list = new ArrayList();
		list.add(token);
		list.add(timestamp);
		list.add(nonce);
	  /*
	   * 运用Collections的sort（）方法对其进行排序 sort（）方法需要传 连个参数，一个是需要进行排序的Collection 另一个是一个Comparator
	   */
		String resultStr = "";
		Collections.sort(list, new SpellComparator());
		for (int i = 0; i < list.size(); i++) {
			resultStr += list.get(i);
		}
		resultStr = new SHA1().getDigestOfString(resultStr.getBytes()); 
		
		logger.info(request.getQueryString());
		logger.info(resultStr); 
		
		return StringUtils.equalsIgnoreCase(signature, resultStr);
	}
	
	/**
	 * 排序比较器
	 */
	class SpellComparator implements Comparator {
	 public int compare(Object o1, Object o2) {
	  try {
	   // 取得比较对象的汉字编码，并将其转换成字符串
//	   String s1 = new String(o1.toString().getBytes("GB2312"), "ISO-8859-1");
//	   String s2 = new String(o2.toString().getBytes("GB2312"), "ISO-8859-1");
	   String s1 = o1.toString();
	   String s2 = o2.toString();  
	   // 运用String类的 compareTo（）方法对两对象进行比较
	   return s1.compareTo(s2);
	  } catch (Exception e) {
	   e.printStackTrace();
	  }
	  return 0;
	 }
	}
}