package jnpf.message.controller;

import com.alibaba.fastjson.JSONObject;
import io.swagger.v3.oas.annotations.tags.Tag;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Parameters;
import io.swagger.v3.oas.annotations.Operation;
import jnpf.base.*;
import jnpf.base.model.synthirdinfo.DingTalkModel;
import jnpf.base.model.synthirdinfo.QyWebChatModel;
import jnpf.config.ConfigValueUtil;
import jnpf.constant.MsgCode;
import jnpf.message.SentMessageApi;
import jnpf.message.model.SentMessageForm;
import jnpf.message.service.MessageService;
import jnpf.message.service.SendConfigTemplateService;
import jnpf.message.service.SendMessageConfigService;
import jnpf.message.util.OnlineUserProvider;
import jnpf.message.util.SendFlowMsgUtil;
import jnpf.util.NoDataSourceBind;
import jnpf.util.StringUtil;
import jnpf.util.third.DingTalkUtil;
import jnpf.util.third.QyWebChatUtil;
import jnpf.util.wxutil.HttpUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.web.bind.annotation.*;

import jakarta.validation.Valid;

import java.util.*;

/**
 * 发送消息模型
 *
 * @版本： V3.1.0
 * @版权： 引迈信息技术有限公司（https://www.jnpfsoft.com）
 * @作者： JNPF开发平台组
 * @日期： 2021/4/21 10:28
 */
@Tag(name = "发送消息", description = "MessageAll")
@RestController
@RequestMapping("/MessageAll")
@Slf4j
public class SentMessageController implements SentMessageApi {


    @Autowired
    private MessageTemplateApi messageTemplateApi;

    @Autowired
    private StreamBridge streamBridge;
    @Autowired
    private MessageService messageService;
    @Autowired
    private SendFlowMsgUtil sendFlowMsgUtil;
    @Autowired
    private SendMessageConfigService sendMessageConfigService;

    @Autowired
    private SendConfigTemplateService sendConfigTemplateService;
    @Autowired
    private ConfigValueUtil configValueUtil;


    /**
     * @param sentMessageForm
     * @return
     */
    @Override
    @PostMapping
    public void sendMessage(@RequestBody SentMessageForm sentMessageForm) {
        sendFlowMsgUtil.sendMessage(sentMessageForm);
    }

    //=====================================测试企业微信、钉钉的连接=====================================

    /**
     * 测试企业微信配置的连接功能
     *
     * @param qyWebChatModel 企业微信配置模型
     * @return
     */
    @Operation(summary = "测试企业微信配置的连接")
    @Parameters({
            @Parameter(name = "qyWebChatModel", description = "企业微信配置模型", required = true)
    })
    @PostMapping("/testQyWebChatConnect")
    public ActionResult testQyWebChatConnect(@RequestBody @Valid QyWebChatModel qyWebChatModel) {
        // 测试发送消息、组织同步的连接
        String corpId = qyWebChatModel.getQyhCorpId();
        String agentSecret = qyWebChatModel.getQyhAgentSecret();
        String corpSecret = qyWebChatModel.getQyhCorpSecret();
        // 测试发送消息的连接
        JSONObject retMsg = QyWebChatUtil.getAccessToken(corpId, agentSecret);
        if (HttpUtil.isWxError(retMsg)) {
            return ActionResult.fail(MsgCode.SYS031.get(retMsg.getString("errmsg")));
        }

        // 测试发送组织同步的连接
        retMsg = QyWebChatUtil.getAccessToken(corpId, corpSecret);
        if (HttpUtil.isWxError(retMsg)) {
            return ActionResult.fail(MsgCode.SYS033.get(retMsg.getString("errmsg")));
        }

        return ActionResult.success(MsgCode.SYS037.get());
    }


    /**
     * 测试钉钉配置的连接功能
     *
     * @param dingTalkModel 钉钉配置模型
     * @return
     */
    @Operation(summary = "测试钉钉配置的连接")
    @Parameters({
            @Parameter(name = "dingTalkModel", description = "钉钉配置模型", required = true)
    })
    @PostMapping("/testDingTalkConnect")
    public ActionResult testDingTalkConnect(@RequestBody @Valid DingTalkModel dingTalkModel) {
        // 测试钉钉配置的连接
        String appKey = dingTalkModel.getDingSynAppKey();
        String appSecret = dingTalkModel.getDingSynAppSecret();
        String agentId = dingTalkModel.getDingAgentId();
        // 测试钉钉的连接
        JSONObject retMsg = DingTalkUtil.getAccessToken(appKey, appSecret);
        if (!retMsg.getBoolean("code")) {
            return ActionResult.fail(MsgCode.SYS036.get(retMsg.getString("error")));
        }

        return ActionResult.success(MsgCode.SYS037.get());
    }

    /**
     * 发送消息
     *
     * @param toUserIds 发送用户
     * @param title     标题
     * @param bodyText  内容
     */
    @Override
    @PostMapping("/sentMessage")
    public void sentMessage(@RequestParam("toUserIds") List<String> toUserIds, @RequestParam("title") String title, @RequestParam(value = "bodyText", required = false) String bodyText, @RequestParam("source") Integer source, @RequestParam("type") Integer type, @RequestBody UserInfo userInfo) {
        messageService.sentMessage(toUserIds, title, bodyText, userInfo, source, type, false);
    }

    /**
     * 退出在线的WebSocket
     *
     * @param token  token
     * @param userId 用户id
     */
    @Operation(summary = "退出在线的WebSocket")
    @Parameters({
            @Parameter(name = "token", description = "token"),
            @Parameter(name = "userId", description = "用户id")
    })
    @NoDataSourceBind
    @GetMapping("/logoutWS")
    public void logoutWebsocketByToken(@RequestParam(name = "token", required = false) String token, @RequestParam(name = "userId", required = false) String userId) {
        if (StringUtil.isNotEmpty(token)) {
            OnlineUserProvider.removeWebSocketByToken(token.split(","));
        } else {
            OnlineUserProvider.removeWebSocketByUser(userId);
        }
    }

    @Override
    @PostMapping("/sendScheduleMessage")
    public List<String> sendScheduleMessage(@RequestBody SentMessageForm sentMessageForm) {
        return sendFlowMsgUtil.sendScheduleMessage(sentMessageForm);
    }

}