package com.qianwen.smartman.modules.sync.api;

import cn.hutool.core.collection.ListUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.beust.jcommander.ParameterException;
import com.jeecg.qywx.api.base.JwAccessTokenAPI;
import com.jeecg.qywx.api.core.common.AccessToken;
import com.jeecg.qywx.api.department.vo.Department;
import java.util.ArrayDeque;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.StringJoiner;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.redis.cache.BladeRedis;
import com.qianwen.core.tool.api.IResultCode;
import com.qianwen.core.tool.utils.SpringUtil;
import com.qianwen.smartman.modules.sync.constant.OuterAppConfigConstant;
import com.qianwen.smartman.modules.sync.constant.QyWechatApiConstant;
import com.qianwen.smartman.modules.sync.constant.QyWechatConstant;
import com.qianwen.smartman.modules.sync.entity.OuterAppConfig;
import com.qianwen.smartman.modules.sync.entity.QyTag;
import com.qianwen.smartman.modules.sync.entity.QyUser;
import com.qianwen.smartman.modules.sync.entity.QyUserTicket;
import com.qianwen.smartman.modules.sync.service.impl.OuterAppConfigServiceImpl;


/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/sync/api/QyWechatApi.class */
public class QyWechatApi {
    private static final Logger log = LoggerFactory.getLogger(QyWechatApi.class);

    public static List<Department> getDepartmentAll() {
        log.info("[企业微信获取所有的部门].[getDepartmentAll start]");
        return listApi(null, QyWechatApiConstant.DEPARTMENT_LIST_URL, "department", Department.class, new String[0]);
    }

    public static List<Department> getDepartmentAll(String token) {
        log.info("[企业微信获取所有的部门].[getDepartmentAll start]");
        return listApi(token, QyWechatApiConstant.DEPARTMENT_LIST_URL, "department", Department.class, new String[0]);
    }

    public static List<QyUser> getUsersByDepartId(String deptId) {
        log.info("[企业微信获取部门下的用户].[getUsersByDepartId start,departmentId={}]", deptId);
        return listApi(null, QyWechatApiConstant.USER_LIST_BY_DEPARTMENT_URL, QyWechatConstant.USER_LIST_KEY, QyUser.class, deptId);
    }

    public static List<QyUser> getUsersByDepartId(String token, String deptId) {
        log.info("[企业微信获取部门下的用户].[getUsersByDepartId start,departmentId={}]", deptId);
        return listApi(token, QyWechatApiConstant.USER_LIST_BY_DEPARTMENT_URL, QyWechatConstant.USER_LIST_KEY, QyUser.class, deptId);
    }

    public static List<QyTag> getTags() {
        log.info("[企业微信获取岗位列表].[getTags start]");
        return listApi(null, QyWechatApiConstant.TAG_LIST_URL, QyWechatConstant.TAG_LIST_KEY, QyTag.class, new String[0]);
    }

    public static List<QyTag> getTags(String token) {
        log.info("[企业微信获取岗位列表].[getTags start]");
        return listApi(token, QyWechatApiConstant.TAG_LIST_URL, QyWechatConstant.TAG_LIST_KEY, QyTag.class, new String[0]);
    }

    public static Map<String, StringJoiner> getUserTagMap() {
        Map<String, StringJoiner> resTagMap = new HashMap<>();
        List<QyTag> tags = getTags();
        for (QyTag tag : tags) {
            List<QyUser> userListByTag = getUserListByTag(tag.getTagid());
            for (QyUser qyUser : userListByTag) {
                StringJoiner tagIdJoiner = resTagMap.get(qyUser.getUserid());
                if (Objects.isNull(tagIdJoiner)) {
                    StringJoiner postIdJoiner = new StringJoiner(",");
                    postIdJoiner.add(tag.getTagid());
                    resTagMap.put(qyUser.getUserid(), postIdJoiner);
                } else {
                    tagIdJoiner.add(tag.getTagid());
                }
            }
        }
        return resTagMap;
    }

    public static Department getDeptById(String token, String deptId) {
        return (Department) getObjApi(token, QyWechatApiConstant.DEPT_GET_BY_ID_URL, Department.class, deptId);
    }

    public static Department getDeptById(String deptId) {
        return (Department) getObjApi(null, QyWechatApiConstant.DEPT_GET_BY_ID_URL, Department.class, deptId);
    }

    public static List<QyUser> getUserListByTag(String tagId) {
        log.info("[企业微信获取该岗位的员工].[getUserListByTag start,tagId={}]", tagId);
        return listApi(null, QyWechatApiConstant.TAG_USER_URL, QyWechatConstant.USER_LIST_KEY, QyUser.class, tagId);
    }

    public static List<QyUser> getUserListByTag(String token, String tagId) {
        log.info("[企业微信获取该岗位的员工].[getUserListByTag start,tagId={}]", tagId);
        return listApi(token, QyWechatApiConstant.TAG_USER_URL, QyWechatConstant.USER_LIST_KEY, QyUser.class, tagId);
    }

    public static QyUser getUserById(String userId) {
        log.info("[企业微信根据用户id获取用户].[getUserById start,userId={}]", userId);
        return (QyUser) getObjApi(null, QyWechatApiConstant.USERINFO_BY_ID_URL, QyUser.class, userId);
    }

    public static QyUser getUserById(String token, String userId) {
        log.info("[企业微信根据用户id获取用户].[getUserById start,userId={}]", userId);
        return (QyUser) getObjApi(token, QyWechatApiConstant.USERINFO_BY_ID_URL, QyUser.class, userId);
    }

    private static String getAccessToken(Integer type) {
        OuterAppConfigServiceImpl configService = (OuterAppConfigServiceImpl) SpringUtil.getBean(OuterAppConfigServiceImpl.class);
        OuterAppConfig appConfig = configService.getAppConfig(OuterAppConfigConstant.QY_WECHAT);
        if (Objects.isNull(appConfig)) {
            throw new ServiceException(MessageUtils.message("sync.qy.config.not.exist", new Object[0]));
        }
        String cacheKey = QyWechatConstant.TOKEN_KEY + (type.equals(QyWechatConstant.BOOK_TYPE) ? QyWechatConstant.BOOK_TYPE : QyWechatConstant.QY_APP_TYPE);
        BladeRedis bladeRedis = (BladeRedis) SpringUtil.getBean(BladeRedis.class);
        Object tokenObj = bladeRedis.get(cacheKey);
        if (!Objects.isNull(tokenObj)) {
            return String.valueOf(tokenObj);
        }
        String syncSecret = type.equals(QyWechatConstant.BOOK_TYPE) ? appConfig.getWxBookSecret() : appConfig.getWxAppSecret();
        AccessToken accessToken = JwAccessTokenAPI.getAccessToken(appConfig.getWxCorpId(), syncSecret);
        if (Objects.isNull(accessToken)) {
            throw new ServiceException(MessageUtils.message("sync.qy.generate.token.fail", new Object[0]));
        }
        bladeRedis.setEx(cacheKey, accessToken.getAccesstoken(), Long.valueOf(accessToken.getExpiresIn()));
        return accessToken.getAccesstoken();
    }

    public static String getBookAccessToken() {
        return getAccessToken(QyWechatConstant.BOOK_TYPE);
    }

    public static String getAppAccessToken() {
        return getAccessToken(QyWechatConstant.QY_APP_TYPE);
    }

    public static QyUserTicket getUserTicketByCode(String code) {
        log.info("[企业微信根据授权Code获取用户身份].[getUserTicketByCode code={}]", code);
        return (QyUserTicket) getObjApi(null, QyWechatApiConstant.USER_TICKET_URL, QyUserTicket.class, code);
    }

    public static QyUserTicket getUserTicketByCode(String token, String code) {
        log.info("[企业微信根据授权Code获取用户身份].[getUserTicketByCode code={}]", code);
        return (QyUserTicket) getObjApi(token, QyWechatApiConstant.USER_TICKET_URL, QyUserTicket.class, code);
    }

    public static QyUser getUserDetailByTicket(String userTicket) {
        log.info("[企业微信根据用户授权身份获取详情].[getUserDetailByTicket userTicket={}]", userTicket);
        if (StrUtil.isEmpty(userTicket)) {
            throw new ParameterException("用户身份参数异常");
        }
        JSONObject params = JSONUtil.createObj().put("user_ticket", userTicket);
        return (QyUser) postObjApi(null, QyWechatApiConstant.AUTH_USER_DETAIL_URL, QyUser.class, JSONUtil.toJsonStr(params), new String[0]);
    }

    public static QyUser getUserDetailByTicket(String token, String userTicket) {
        log.info("[企业微信根据用户授权身份获取详情].[getUserDetailByTicket userTicket={}]", userTicket);
        if (StrUtil.isEmpty(userTicket)) {
            throw new ParameterException("用户身份参数异常");
        }
        JSONObject params = JSONUtil.createObj().put("user_ticket", userTicket);
        return (QyUser) postObjApi(token, QyWechatApiConstant.AUTH_USER_DETAIL_URL, QyUser.class, JSONUtil.toJsonStr(params), new String[0]);
    }

    private static <T> List<T> listApi(String token, String apiUrl, String responseKey, Class<T> responseClass, String... params) {
        String accessToken = StrUtil.isEmpty(token) ? getAppAccessToken() : token;
        String requestUrl = parseRequestUrl(apiUrl, handlerParam(accessToken, params));
        log.info("[企业微信API].[list->api调用  request apiUrl={}]", requestUrl);
        String responseData = HttpUtil.get(requestUrl);
        log.info("[企业微信API].[list->api调用 response class={},responseData={}]", responseClass, responseData);
        if (StrUtil.isEmpty(responseData)) {
            return new ArrayList();
        }
        return parseResponseDataList(responseData, responseClass, responseKey);
    }

    private static String[] handlerParam(String accessToken, String... params) {
        ArrayDeque<String> arrayDeque = new ArrayDeque<>(ListUtil.toList(params));
        arrayDeque.addFirst(accessToken);
        String[] temp = new String[arrayDeque.size()];
        return (String[]) arrayDeque.toArray(temp);
    }

    private static <T> T getObjApi(String token, String apiUrl, Class<T> responseClass, String... params) {
        String accessToken = StrUtil.isEmpty(token) ? getAppAccessToken() : token;
        String requestUrl = parseRequestUrl(apiUrl, handlerParam(accessToken, params));
        log.info("[企业微信API].[obj->api调用 【GET】 request apiUrl={}]", requestUrl);
        String responseData = HttpUtil.get(requestUrl);
        log.info("[企业微信API].[obj->api调用 response class={},responseData={}]", responseClass, responseData);
        if (StrUtil.isEmpty(responseData)) {
            return null;
        }
        return (T) parseResponseDataObj(responseData, responseClass);
    }

    private static <T> T postObjApi(String token, String apiUrl, Class<T> responseClass, String body, String... params) {
        String accessToken = StrUtil.isEmpty(token) ? getAppAccessToken() : token;
        String requestUrl = parseRequestUrl(apiUrl, handlerParam(accessToken, params));
        log.info("[企业微信API].[obj->api调用 【POST】 request apiUrl={}]", requestUrl);
        String responseData = HttpUtil.post(requestUrl, body);
        log.info("[企业微信API].[obj->api调用 response class={},responseData={}]", responseClass, responseData);
        if (StrUtil.isEmpty(responseData)) {
            return null;
        }
        return (T) parseResponseDataObj(responseData, responseClass);
    }

    private static <T> List<T> parseResponseDataList(String responseData, Class<T> clazz, String dataKey) {
        JSONObject jsonObject = JSONUtil.parseObj(responseData);
        Integer errCode = jsonObject.getInt(QyWechatConstant.ERROR_CODE_KEY);
        String errMsg = jsonObject.getStr(QyWechatConstant.ERROR_MSG_KEY);
        if (errCode.equals(QyWechatConstant.SUCCESS)) {
            JSONArray jsonArray = jsonObject.getJSONArray(dataKey);
            return JSONUtil.toList(jsonArray, clazz);
        }
        log.error("[parseResponseData].[请求方法= {} error errCode={},errMsg={}]", new Object[]{Thread.currentThread().getStackTrace()[2].getMethodName(), errCode, errMsg});
        errCheck(errMsg, errCode);
        return null;
    }

    private static <T> T parseResponseDataObj(String responseData, Class<T> clazz) {
        JSONObject jsonObject = JSONUtil.parseObj(responseData);
        Integer errCode = jsonObject.getInt(QyWechatConstant.ERROR_CODE_KEY);
        String errMsg = jsonObject.getStr(QyWechatConstant.ERROR_MSG_KEY);
        if (errCode.equals(QyWechatConstant.SUCCESS)) {
            return (T) jsonObject.toBean(clazz);
        }
        log.error("[parseResponseData].[请求方法= {} error errCode={},errMsg={}]", new Object[]{Thread.currentThread().getStackTrace()[2].getMethodName(), errCode, errMsg});
        errCheck(errMsg, errCode);
        return null;
    }

    private static void errCheck(String errMsg, Integer errCode) {
        if (errCode.intValue() == 40029) {
            throw new ServiceException(setResultCode(MessageUtils.message("sync.qy.login.invalid.code", new Object[0]), 400));
        }
        if (errCode.intValue() == 60020) {
            throw new ServiceException(setResultCode(MessageUtils.message("sync.qy.ip.trust", new Object[0]) + ":" + errMsg, 400));
        }
        throw new ServiceException(setResultCode(MessageUtils.message("sync.qy.api.error", new Object[0]) + ":" + errMsg, 400));
    }

    private static IResultCode setResultCode(final String errMsg, final Integer code) {
        return new IResultCode() { // from class: org.springblade.modules.sync.api.QyWechatApi.1
            public String getMessage() {
                return errMsg;
            }

            public int getCode() {
                return code.intValue();
            }
        };
    }

    public static String parseRequestUrl(String url, String... params) {
        String requestUrl = url;
        for (int i = 0; i < params.length; i++) {
            String placeholder = StrUtil.format("{{}}", new Object[]{Integer.valueOf(i)});
            requestUrl = requestUrl.replace(placeholder, params[i]);
        }
        return requestUrl;
    }
}