package club.itwork.dingtalk.handler;

import club.itwork.dingtalk.constant.Constants;
import club.itwork.dingtalk.dto.EventMsg;
import club.itwork.dingtalk.service.CorpInfoService;
import club.itwork.dingtalk.service.DingTalkCorpService;
import club.itwork.dingtalk.thread.ThreadPoolManager;
import com.dingtalk.api.response.OapiServiceGetAuthInfoResponse;
import com.dingtalk.api.response.OapiServiceGetPermanentCodeResponse;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * 当企业开通授权第三方企业应用后，
 * 钉钉服务器会向创建应用时填写的回调URL推送临时授权码。
 *
 * @author dgb8901
 */
@Slf4j
@Component(value = Constants.Event.TMP_AUTH_CODE)
public class TmpAuthCodeEventHandler implements EventHandler {

    @Resource
    private DingTalkCorpService dingTalkCorpService;
    @Resource
    private CorpInfoService corpInfoService;

    /**
     * 处理授权事件
     * - 最好异步处理
     *
     * @param eventMsg
     */
    @Override
    public void handle(EventMsg eventMsg) {
        log.info("处理授权事件参数：{}", eventMsg);

        // 异步处理
        ThreadPoolManager.getInstance().addTask(TmpAuthCodeEventHandler.class, () -> {
            // 1. 拿到临时授权码 --> 临时授权码只能使用一次
            String authCode = eventMsg.getAuthCode();
            // 2. 换取永久授权码
            OapiServiceGetPermanentCodeResponse response = dingTalkCorpService.getPermanentCode(authCode);
            if (response != null) {
                String permanentCode = response.getPermanentCode();
                // 3. 激活应用
                Boolean result = dingTalkCorpService.activateSuite(eventMsg.getAuthCorpId(), permanentCode);
                log.info("激活应用结果：{}", result);
                // 4. 获取企业授权信息
                OapiServiceGetAuthInfoResponse authInfo = dingTalkCorpService.getCorpAuthInfo(eventMsg.getAuthCorpId());
                // 5. 保存企业授权信息
                corpInfoService.save(authInfo, permanentCode);
            }
        });
    }
}