package com.westvalley.rrl.wechat.service;

import java.io.UnsupportedEncodingException;

import java.net.URLDecoder;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.UUID;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.jfinal.kit.LogKit;

import com.westvalley.ctrl.apprrl.fixedassets.Cache.CacheManager;

import com.westvalley.ctrl.apprrl.fixedassets.bean.Cache;

import com.westvalley.http.HttpXmlClientProxy;

import com.westvalley.rrl.fixedassets.utils.EncryptUtils;

import com.westvalley.rrl.wechat.bean.WechatUser;

import com.westvalley.rrl.wechat.bean.WechatWork;

import com.westvalley.rrl.wechat.prop.WechatProp;

import com.westvalley.rrl.wechat.utils.DateUtils;

public class WechatService {

    private WechatProp wechatProp = WechatProp.me();

    private String corpid;

    private String secret;

    /**

     * 打卡

     * @return

     */

    public String getWorkDate(){

        corpid = getWXstr("corpid");

        secret = getWXstr("punchCardSecret");

        String accessTokenVal = isCache("WORKACCESSTOKEN");

        //查询打卡记录

        //List<Record> users = Db.find("select id from hrmresource where status=0");

        List<String> useridlist = getAddressBook();

        LogKit.error("users---->"+useridlist);

        String starttime = DateUtils.getSECBeginTimes(new Date());

        String endtime = DateUtils.getSECEndTimes(new Date());

        WechatWork wechatWork = new WechatWork();

        wechatWork.setOpencheckindatatype("3");

        wechatWork.setStarttime(starttime);

        wechatWork.setEndtime(endtime);

        wechatWork.setUseridlist(useridlist);

        String body = JSON.toJSONString(wechatWork);

        LogKit.error("users-body--->"+body);

        String work = HttpXmlClientProxy.httpPost("https://qyapi.weixin.qq.com/cgi-bin/checkin/getcheckindata?access_token="+accessTokenVal+"", body);

        LogKit.error("work------------->"+work);

        return work;

    }

    /**

     * 通讯录

     * @return

     */

    public List<String> getAddressBook(){

        corpid = getWXstr("corpid");

        secret = getWXstr("addressBookSecret");

        String accessTokenVal = isCache("ADDRESSBOOK");

        String body = HttpXmlClientProxy.httpGet("https://qyapi.weixin.qq.com/cgi-bin/user/simplelist?access_token="+accessTokenVal+"&department_id=1&fetch_child=1");

        String userlist = JSON.parseObject(body).getString("userlist");

        @SuppressWarnings("unchecked")

        List<WechatUser> wechatUsers = JSONObject.parseArray((userlist), WechatUser.class);

        List<String> lists = new ArrayList<String>();

        for(int i=0 ; i < wechatUsers.size() ; i++){

            lists.add(wechatUsers.get(i).getUserid());

        }

        return lists;

    }

    /**

     * 获取配置的参数

     * @param key

     * @return

     */

    public String getWXstr(String key){

        return wechatProp.getPropValue(key);

    }

    /**

     * AccessToken进行判断获取

     * @param secretKey

     * @return

     */

    public String isCache(String secretKey){

        Cache cacheAccessToken = CacheManager.getCacheInfo(secretKey);

        LogKit.error("获取企业微信打卡的cacheAccessToken------------>"+JSON.toJSONString(cacheAccessToken));

        String accessTokenVal = "";

        if(cacheAccessToken == null){

            accessTokenVal = getAccessToken();

            CacheManager.putCacheInfo(secretKey, accessTokenVal, 1000*60*60*2, false);

        }else{

            if(cacheAccessToken.getValue() == null){

                accessTokenVal = getAccessToken();

                CacheManager.putCacheInfo(secretKey, accessTokenVal, 1000*60*60*2, false);

            }else{

                accessTokenVal = cacheAccessToken.getValue().toString();

            }

        }

        return accessTokenVal;

    }

    /**

     * 获取企业微信的AccessToken

     * @return

     */

    public String getAccessToken(){

        String body = HttpXmlClientProxy.httpGet("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid="+corpid+"&corpsecret="+secret);

        return JSON.parseObject(body).getString("access_token");

    }

    /**

     * 获取企业微信的jsapiTicket

     * @param accessToken

     * @return

     */

    public String getJsapiTicket(String accessToken){

        String body = HttpXmlClientProxy.httpGet("https://qyapi.weixin.qq.com/cgi-bin/get_jsapi_ticket?access_token="+accessToken);

        return JSON.parseObject(body).getString("ticket");

    }

    /**

     * 签名加密

     * @param jsapiTicket

     * @return

     */

    public String signature(String jsapiTicket,String nowUrl){

        try {

            String noncestr = UUID.randomUUID().toString().replace("-", "").substring(0, 16);

            String timestamp=String.valueOf(new Date().getTime() / 1000);

            nowUrl = URLDecoder.decode(nowUrl, "UTF-8");

            String appendStr = "jsapi_ticket="+jsapiTicket+"&noncestr="+noncestr+"&timestamp="+timestamp+"&url="+nowUrl;

            String signature = EncryptUtils.SHA1(appendStr);

            Map<String,Object> map = new HashMap<String,Object>();

            map.put("noncestr",noncestr);

            map.put("timestamp",timestamp);

            map.put("signature",signature);

            map.put("appid", corpid);

            String shaSignature = JSON.toJSONString(map);

            LogKit.error("获取企业微信的Signature"+shaSignature);

            return shaSignature;

        } catch (UnsupportedEncodingException e) {

            return e.getMessage();

        }

    }

}