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

import com.alibaba.fastjson.JSONObject;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.smartman.common.constant.CommonConstant;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.modules.sync.constant.DingConstant;
import com.qianwen.smartman.modules.sync.constant.OuterAppConfigConstant;
import com.qianwen.smartman.modules.sync.constant.QyWechatConstant;
import com.qianwen.smartman.modules.sync.entity.OuterAppConfig;
import com.qianwen.smartman.modules.sync.service.IDingEventService;
import com.qianwen.smartman.modules.sync.service.IOuterAppConfigService;
import com.qianwen.smartman.modules.sync.util.DingCallbackCrypto;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RequestMapping({"blade-sync/ding"})
@RestController
public class DingEventCallBackController {
    private static final Logger log = LoggerFactory.getLogger(DingEventCallBackController.class);
    private final IDingEventService dingEventService;
    private final IOuterAppConfigService outerAppConfigService;

    public DingEventCallBackController(final IDingEventService dingEventService, final IOuterAppConfigService outerAppConfigService) {
        this.dingEventService = dingEventService;
        this.outerAppConfigService = outerAppConfigService;
    }

    @PostMapping({"dingCallback"})
    public Map<String, String> callBack(HttpServletRequest request, @RequestParam(value = "msg_signature", required = false) String msg_signature, @RequestParam(value = "timestamp", required = false) String timeStamp, @RequestParam(value = "nonce", required = false) String nonce, @RequestBody(required = false) JSONObject json) {
        try {
            OuterAppConfig outerAppConfig = this.outerAppConfigService.getAppConfig(OuterAppConfigConstant.DING);
            DingCallbackCrypto callbackCrypto = new DingCallbackCrypto(outerAppConfig.getDingCallbackToken(), outerAppConfig.getDingAesKey(), outerAppConfig.getDingAppKey());
            if (Func.isNotEmpty(outerAppConfig) && outerAppConfig.getStatus().equals(CommonConstant.ENABLE)) {
                String encryptMsg = json.getString("encrypt");
                String decryptMsg = callbackCrypto.getDecryptMsg(msg_signature, timeStamp, nonce, encryptMsg);
                this.dingEventService.handleEvent(callbackCrypto, decryptMsg, outerAppConfig);
            }
            Map<String, String> successMap = callbackCrypto.getEncryptedMap(QyWechatConstant.CALLBACK_RESULT);
            return successMap;
        } catch (DingCallbackCrypto.DingTalkEncryptException e) {
            e.printStackTrace();
            return null;
        }
    }

    public static void main(String[] args) {
        try {
            DingCallbackCrypto callbackCrypto = new DingCallbackCrypto(DingConstant.AES_TOKEN, DingConstant.AES_KEY, DingConstant.OWNER_KEY);
            String result = callbackCrypto.getDecryptMsg(DingConstant.AES_TOKEN, "1660726099662", "NSSkKApu", "bg0JooSnFmsmy605VIHDnp2u1QFCrkYhdUUJ75miOvpDFANCzDP2YuE3J7o2rorRRAriRqnnmI4IxNsVJDCU62Ym5zwCoYX5sTiAG5PRX2NXnf3tKoBwqkDnGDgtIdH9JbzGOVaUHnEzb4aibDXPlbe/VdXeyJCmHSA/mE0V6j2CGn2jkVrlK0PDGS+tdb9HP/SlJWWuya6agC29dD7hLmlRqYjrZ8NciAYWpTRJrVForDpoQlHOuCgrQO2/tyq8");
            System.out.println(result);
        } catch (DingCallbackCrypto.DingTalkEncryptException e) {
            e.printStackTrace();
        }
    }
}