package com.doumee.core.utils.qiyeweixin;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.utils.HttpsUtil;
import com.doumee.core.utils.qiyeweixin.model.request.QywxSendMsgRequest;
import com.doumee.core.utils.qiyeweixin.model.response.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


@Component
@Slf4j
public class QywxUtil {
    private static JSONObject json = new JSONObject();


    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    private static QywxUtil qyUtil;

    @PostConstruct
    private void init() {
        qyUtil = this;
        systemDictDataBiz = qyUtil.systemDictDataBiz;
    }


    public static String create(Map<String, Object> map, String url, String token) throws IOException {
        //  String token = getToken(QY_Constant.CORPID, QY_Constant.SCHEDULESECRET);
        String postData = createPostData(map);
        String response = HttpsUtil.post(url + token, postData,  "application/json", false);
        System.out.println("获取到的token======>" + token);
        System.out.println("请求数据======>" + postData);
        System.out.println("发送微信的响应数据======>" + response);
        return response;
    }

    private static String createPostData(Map<String, Object> map) {
        System.out.println("进入createPostData方法-------------------------");
        return JSONObject.toJSONString(map);
    }


    public static String getAccessToken(String corpId, String corpSecret)  {
        String[] interfaceUrl = QywxConstant.GET_ACCESS_TOKEN;
        String url = interfaceUrl[0].replace("${corpid}",corpId).replace("${secret}",corpSecret);
        QywxBaseResponse response = sendHttpRequest(url,interfaceUrl[1],"",new TypeReference<QywxBaseResponse<String>>(){});
        if(response.getErrcode()!=null && response.getErrcode() ==0){
            return response.getAccess_token();
        }
        return null;
    }
    public static List<QywxDepartInfoResponse> getDepartmentAll(String token)   {
        String[] interfaceUrl = QywxConstant.GET_DEPARTMENT_LIST;
        String url = interfaceUrl[0].replace("${accesstoken}",token).replace("${id}","");
        QywxBaseResponse<List<QywxDepartInfoResponse>> response = sendHttpRequest(url,interfaceUrl[1],"",new TypeReference<QywxBaseResponse<List<QywxDepartInfoResponse>>>(){});
        if(response.getErrcode()!=null && response.getErrcode() ==0){
            return response.getData();
        }
        return null;
    }
    public static QywxDepartInfoResponse getDepartmentInfo(String token,String departid)  {
        String[] interfaceUrl = QywxConstant.GET_DEPARTMENT_INFO;
        String url = interfaceUrl[0].replace("${accesstoken}",token).replace("${id}",departid);
        QywxBaseResponse<QywxDepartInfoResponse> response = sendHttpRequest(url,interfaceUrl[1],""
                ,new TypeReference< QywxBaseResponse<QywxDepartInfoResponse>>(){});
        if(response.getErrcode()!=null && response.getErrcode() ==0){
            return response.getData();
        }
        return null;
    }
    public static QywxSendMsgResponse sendMsg(String token, QywxSendMsgRequest param)  {
        String[] interfaceUrl = QywxConstant.SEND_MSG;
        String url = interfaceUrl[0].replace("${accesstoken}",token);
        QywxSendMsgResponse response = sendHttpRequestSingle(url,interfaceUrl[1],JSONObject.toJSONString(param)
                ,new TypeReference<QywxSendMsgResponse>(){});
        if(response.getErrcode()!=null && response.getErrcode() ==0){
            return response;
        }
        return null;
    }
    public static List<QywxUserListResponse> getUserList(String token,String depatId)   {
        try {
            String[] interfaceUrl = QywxConstant.GET_DEPARTMENT_USER_LIST;
            String url = interfaceUrl[0].replace("${accesstoken}",token).replace("${departmentId}",depatId);
            QywxBaseResponse<List<QywxUserListResponse>> response = sendHttpRequest(url,interfaceUrl[1],"",new TypeReference<QywxBaseResponse<List<QywxUserListResponse>>>(){});
            if(response.getErrcode()!=null && response.getErrcode() ==0){
                return response.getData();
            }
        }catch (Exception e){
            e.printStackTrace();
        }

        return null;
    }
    public static QywxUserInfoResponse getUserInfo(String token,String id)  {
        String[] interfaceUrl = QywxConstant.GET_USER_DETAIL;
        String url = interfaceUrl[0].replace("${accesstoken}",token).replace("${id}",id);
        QywxUserInfoResponse response = sendHttpRequestSingle(url,interfaceUrl[1],""
                ,new TypeReference<QywxUserInfoResponse>(){});
        if(response.getErrcode()!=null && response.getErrcode() ==0){
            return response;
        }
        return null;
    }

    /**
     * 发起wms接口请求
     * @param url
     * @param name
     * @param param
     * @param typeReference
     * @return
     * @param <T>
     */
    public static   <T> QywxBaseResponse<T> sendHttpRequest(String url, String name, String param, TypeReference<QywxBaseResponse<T>> typeReference){
        log.info("【"+name+"】================开始===="+ JSONObject.toJSONString(param));
        if ( StringUtils.isNotBlank(url)) {
            String res = null;
            try {
                Map<String,String> headers = new HashMap<>();
                res = HttpsUtil.postJson(url,param);
                QywxBaseResponse result = JSONObject.parseObject(res, typeReference.getType());
                logResult(result,name);
                return  result;
            }catch (Exception e){
                e.printStackTrace();
                log.error("【"+name+"】================失败===="+ JSONObject.toJSONString(param));
            }
        }
        return  null;
    }
    public static  <T extends QywxBaseSingleResponse>  T sendHttpRequestSingle(String url, String name, String param, TypeReference<T> typeReference){
        log.info("【"+name+"】================开始===="+ JSONObject.toJSONString(param));
        if ( StringUtils.isNotBlank(url)) {
            String res = null;
            try {
                Map<String,String> headers = new HashMap<>();
                res = HttpsUtil.postJson(url,param);
                T result = JSONObject.parseObject(res, typeReference.getType());
//                logResult(result,name);
                return  result;
            }catch (Exception e){
                e.printStackTrace();
                log.error("【"+name+"】================失败===="+ JSONObject.toJSONString(param));
            }
        }
        return  null;
    }
    private static void logResult(QywxBaseResponse res,String name) {
        if( res.getErrcode() !=null && res.getErrcode().equals(0)){
            log.info("【企业微信接口："+name+"】================成功====\n"+ JSONObject.toJSONString(res));
        }else{
            log.error("【企业微信接口："+name+"】================失败====：\n"+  JSONObject.toJSONString(res));
        }
    }
}