package com.ruoyi.message.sms.provider.aliyun;

import com.aliyun.dysmsapi20170525.Client;
import com.aliyun.dysmsapi20170525.models.AddSmsTemplateRequest;
import com.aliyun.dysmsapi20170525.models.AddSmsTemplateResponse;
import com.aliyun.dysmsapi20170525.models.AddSmsTemplateResponseBody;
import com.aliyun.dysmsapi20170525.models.ModifySmsTemplateRequest;
import com.aliyun.dysmsapi20170525.models.ModifySmsTemplateResponse;
import com.aliyun.dysmsapi20170525.models.ModifySmsTemplateResponseBody;
import com.aliyun.dysmsapi20170525.models.QuerySmsTemplateListRequest;
import com.aliyun.dysmsapi20170525.models.QuerySmsTemplateListResponse;
import com.aliyun.dysmsapi20170525.models.QuerySmsTemplateListResponseBody;
import com.aliyun.dysmsapi20170525.models.QuerySmsTemplateRequest;
import com.aliyun.dysmsapi20170525.models.QuerySmsTemplateResponse;
import com.aliyun.dysmsapi20170525.models.QuerySmsTemplateResponseBody;
import com.aliyun.dysmsapi20170525.models.SendBatchSmsRequest;
import com.aliyun.dysmsapi20170525.models.SendBatchSmsResponse;
import com.aliyun.dysmsapi20170525.models.SendBatchSmsResponseBody;
import com.aliyun.dysmsapi20170525.models.SendSmsRequest;
import com.aliyun.dysmsapi20170525.models.SendSmsResponse;
import com.aliyun.dysmsapi20170525.models.SendSmsResponseBody;
import com.aliyun.tea.TeaException;
import com.aliyun.teaopenapi.models.Config;
import com.aliyun.teautil.Common;
import com.aliyun.teautil.models.RuntimeOptions;
import com.ruoyi.message.config.MessageProperties;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

/**
 * 阿里云短信 API。
 * <p>
 * 迁移说明：逻辑取自 {@code com.smartor.service.impl.BaseSmsaccountServiceImpl}，
 * 但<b>不再依赖 smartor 的 domain 对象</b>（{@code BaseSmsRequest} / {@code BatchBaseSmsRequest} /
 * {@code TemplateSmsRequest}），改为直接接收基础参数，从而让本模块可以放在
 * {@code ruoyi-system} 之前、被所有业务模块复用。
 * <p>
 * 原 {@code BaseSmsaccountServiceImpl} 保留为「短信账号管理 + DB 读写」的 Service，
 * 其上的阿里云调用改为委托本类（见改造说明）。
 */
@Slf4j
@Component
public class AliYunSmsApi {

    private final MessageProperties properties;

    public AliYunSmsApi(MessageProperties properties) {
        this.properties = properties;
    }

    /**
     * 发送短信
     *
     * @param phoneNumbers  手机号，多个用逗号分隔
     * @param templateCode  模板编码
     * @param templateParam 模板参数 JSON
     */
    public SendSmsResponseBody sendSms(String phoneNumbers, String templateCode, String templateParam) {
        try {
            Client client = createClient();
            SendSmsRequest sendSmsRequest = new SendSmsRequest()
                    .setPhoneNumbers(phoneNumbers)
                    .setSignName(properties.getSms().getAliyun().getSignName())
                    .setTemplateCode(templateCode)
                    .setTemplateParam(templateParam);
            SendSmsResponse sendSmsResponse = client.sendSmsWithOptions(sendSmsRequest, new RuntimeOptions());
            return sendSmsResponse.getBody();
        } catch (Exception e) {
            log.error("阿里云短信发送失败，phoneNumbers：{}，templateCode：{}", phoneNumbers, templateCode, e);
        }
        return null;
    }

    /**
     * 批量发送短信
     */
    public SendBatchSmsResponseBody batchSendMsg(List<String> phoneNumbers, String templateCode) {
        try {
            Client client = createClient();
            List<String> signNameJson = new ArrayList<>();
            for (int i = 0; i < phoneNumbers.size(); i++) {
                signNameJson.add("\"" + properties.getSms().getAliyun().getSignName() + "\"");
            }
            SendBatchSmsRequest sendBatchSmsRequest = new SendBatchSmsRequest()
                    .setSignNameJson(signNameJson.toString())
                    .setPhoneNumberJson(phoneNumbers.toString())
                    .setTemplateCode(templateCode);
            RuntimeOptions runtime = new RuntimeOptions();
            try {
                SendBatchSmsResponse sendBatchSmsResponse = client.sendBatchSmsWithOptions(sendBatchSmsRequest, runtime);
                return sendBatchSmsResponse.getBody();
            } catch (TeaException error) {
                Common.assertAsString(error.message);
            } catch (Exception innerError) {
                TeaException error = new TeaException(innerError.getMessage(), innerError);
                Common.assertAsString(error.message);
            }
        } catch (Exception e) {
            log.error("阿里云短信批量发送失败，templateCode：{}", templateCode, e);
        }
        return null;
    }

    /**
     * 新增短信模板
     */
    public AddSmsTemplateResponseBody addSmsTemplate(Integer templateType, String templateName,
                                                     String templateContent, String remark) {
        try {
            Client client = createClient();
            AddSmsTemplateRequest addSmsTemplateRequest = new AddSmsTemplateRequest()
                    .setTemplateType(templateType)
                    .setTemplateName(templateName)
                    .setTemplateContent(templateContent)
                    .setRemark(remark);
            RuntimeOptions runtime = new RuntimeOptions();
            AddSmsTemplateResponse response = client.addSmsTemplateWithOptions(addSmsTemplateRequest, runtime);
            return response.getBody();
        } catch (TeaException error) {
            Common.assertAsString(error.message);
        } catch (Exception innerError) {
            TeaException error = new TeaException(innerError.getMessage(), innerError);
            Common.assertAsString(error.message);
        }
        return null;
    }

    /**
     * 修改短信模板
     */
    public ModifySmsTemplateResponseBody modifySmsTemplate(Integer templateType, String templateName,
                                                          String templateCode, String templateContent, String remark) {
        try {
            Client client = createClient();
            ModifySmsTemplateRequest modifySmsTemplateRequest = new ModifySmsTemplateRequest();
            modifySmsTemplateRequest.setTemplateType(templateType);
            modifySmsTemplateRequest.setTemplateName(templateName);
            modifySmsTemplateRequest.setTemplateCode(templateCode);
            modifySmsTemplateRequest.setTemplateContent(templateContent);
            modifySmsTemplateRequest.setRemark(remark);
            RuntimeOptions runtime = new RuntimeOptions();
            ModifySmsTemplateResponse response = client.modifySmsTemplateWithOptions(modifySmsTemplateRequest, runtime);
            return response.getBody();
        } catch (TeaException error) {
            Common.assertAsString(error.message);
        } catch (Exception innerError) {
            TeaException error = new TeaException(innerError.getMessage(), innerError);
            Common.assertAsString(error.message);
        }
        return null;
    }

    /**
     * 查询短信模板列表
     */
    public QuerySmsTemplateListResponseBody querySmsTemplate(Integer pageIndex, Integer pageSize) {
        try {
            Client client = createClient();
            QuerySmsTemplateListRequest request = new QuerySmsTemplateListRequest()
                    .setPageIndex(pageIndex)
                    .setPageSize(pageSize);
            RuntimeOptions runtime = new RuntimeOptions();
            QuerySmsTemplateListResponse response = client.querySmsTemplateListWithOptions(request, runtime);
            return response.getBody();
        } catch (TeaException error) {
            Common.assertAsString(error.message);
        } catch (Exception innerError) {
            TeaException error = new TeaException(innerError.getMessage(), innerError);
            Common.assertAsString(error.message);
        }
        return null;
    }

    /**
     * 查询短信模板审核状态
     */
    public QuerySmsTemplateResponseBody querySmsTemplateStatus(String templateCode) {
        try {
            Client client = createClient();
            QuerySmsTemplateRequest request = new QuerySmsTemplateRequest().setTemplateCode(templateCode);
            RuntimeOptions runtime = new RuntimeOptions();
            QuerySmsTemplateResponse response = client.querySmsTemplateWithOptions(request, runtime);
            return response.getBody();
        } catch (TeaException error) {
            Common.assertAsString(error.message);
        } catch (Exception innerError) {
            TeaException error = new TeaException(innerError.getMessage(), innerError);
            Common.assertAsString(error.message);
        }
        return null;
    }

    private Client createClient() throws Exception {
        Config config = new Config()
                .setAccessKeyId(properties.getSms().getAliyun().getAccessKeyId())
                .setAccessKeySecret(properties.getSms().getAliyun().getAccessKeySecret());
        // 访问的域名
        config.endpoint = "dysmsapi.aliyuncs.com";
        return new Client(config);
    }
}