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

import com.alibaba.fastjson2.JSON;
import com.google.gson.Gson;
import com.ruoyi.common.utils.OkHttpExample;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.message.MessageChannel;
import com.ruoyi.message.SendResult;
import com.ruoyi.message.sms.AbstractSmsSender;
import com.ruoyi.message.sms.SmsSendRequest;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * 丽水短信发送方（{@code ls} 通道，丽水 13 家医院）。
 * <p>
 * 对接特征（与其他通道差异最大的一个）：
 * <ul>
 *   <li>报文为 {@code XiaoXiTou + YeWuXX.DuanXinXX} 的嵌套 JSON；</li>
 *   <li>需要先用 {@code LyraTokenUtil} 换 token，再以 header 传 token；</li>
 *   <li>机构地址/租户/发送人存在 {@code sys_config} 表的 {@code ls.msg.info} 里（按机构查询）；</li>
 *   <li>成功判定为响应体 {@code Code == "0"}。</li>
 * </ul>
 * 代码来源：{@code RyTask.ls 分支} + {@code RyTask.getDXCode}（行为保持不变）。
 */
@Slf4j
@Component
public class LishuiSmsSender extends AbstractSmsSender {

    /**
     * 渠道 key，与 {@code spring.profiles.active=ls} 对应
     */
    public static final String KEY = "ls";

    private final ObjectProvider<LishuiMessageConfigProvider> configProvider;

    public LishuiSmsSender(ObjectProvider<LishuiMessageConfigProvider> configProvider) {
        this.configProvider = configProvider;
    }

    @Override
    public String key() {
        return KEY;
    }

    @Override
    public String description() {
        return "丽水短信（13家医院，token + 机构级配置）";
    }

    @Override
    protected SendResult doSend(SmsSendRequest request) throws Exception {
        LishuiMessageConfig config = resolveConfig(request.getOrgid());
        if (config == null || StringUtils.isEmpty(config.getAddress())) {
            //与线上行为一致：该机构没有配置短信地址，视为发送失败
            return SendResult.fail(KEY, MessageChannel.SMS, "短信发送失败,该机构没有配置短信地址", null);
        }

        String token = resolveToken(request.getOrgid(), config);
        Map<String, Object> body = buildBody(request, config);

        log.info("【{}】丽水短信发送，地址：{}，参数：{}，机构ID：{}",
                KEY, config.getAddress(), request, request.getOrgid());
        String result = OkHttpExample.sendPostRequest(config.getAddress(), new Gson().toJson(body), token);
        log.info("【{}】丽水短信发送结果：{}", KEY, result);

        if (StringUtils.isEmpty(result)) {
            return SendResult.fail(KEY, MessageChannel.SMS, "短信发送失败", result);
        }
        Map<String, Object> textParam = JSON.parseObject(result, Map.class);
        Object codeObj = textParam == null ? null : textParam.get("Code");
        String code = codeObj == null ? null : codeObj.toString();
        if ("0".equals(code)) {
            return SendResult.success(KEY, MessageChannel.SMS, result).withCode(code);
        }
        return SendResult.fail(KEY, MessageChannel.SMS, "短信发送失败", result).withCode(code);
    }

    /**
     * 优先使用业务模块注册的 {@link LishuiMessageConfigProvider}（查 sys_config），
     * 否则退化为代码内静态配置。
     */
    private LishuiMessageConfig resolveConfig(String orgid) {
        LishuiMessageConfigProvider provider = configProvider.getIfAvailable();
        if (provider != null) {
            LishuiMessageConfig config = provider.getConfig(orgid);
            if (config != null) {
                if (StringUtils.isEmpty(config.getOrgid())) {
                    config.setOrgid(orgid);
                }
                return config;
            }
        }
        LishuiMessageConfig fallback = LishuiStaticConfig.fallback(orgid);
        return fallback;
    }

    private String resolveToken(String orgid, LishuiMessageConfig config) {
        if (StringUtils.isEmpty(config.getTokenUrl())) {
            return null;
        }
        LishuiMessageConfigProvider provider = configProvider.getIfAvailable();
        if (provider == null) {
            log.warn("【{}】未找到 LishuiMessageConfigProvider 实现，无法换取 token，将以空 token 调用", KEY);
            return null;
        }
        return provider.getToken(orgid, config.getTokenUrl());
    }

    /**
     * 组装丽水报文：{@code XiaoXiTou + YeWuXX.DuanXinXX}（与 {@code RyTask.getDXCode} 完全一致）
     */
    private Map<String, Object> buildBody(SmsSendRequest request, LishuiMessageConfig config) {
        Map<String, Object> headerMap = new LinkedHashMap<>();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        headerMap.put("XiaoXiID", IdUtils.simpleUUID());
        headerMap.put("FaSongSJ", sdf.format(new Date()));
        headerMap.put("ZuHuID", config.getZuHuId());
        headerMap.put("ZuHuMC", config.getZuHuMc());
        headerMap.put("FaSongJGID", config.getOrgid());
        headerMap.put("FaSongJGMC", config.getZuHuMc());
        headerMap.put("FaSongXTJC", "SUIFANGXT");
        headerMap.put("FaSongXTMC", "随访系统");
        headerMap.put("FaSongFCSJC", "ZJHES");
        headerMap.put("XiaoXiLX", "FZ_PT_DuanXinFS");
        headerMap.put("XiaoXiMC", "短信发送");

        Map<String, Object> duanXinXX = new LinkedHashMap<>();
        duanXinXX.put("ShouJiHM", request.getPhone());
        duanXinXX.put("FaSongNR", request.getContent());
        duanXinXX.put("FaSongRID", config.getSendPersonId());
        duanXinXX.put("FaSongRXM", config.getSendPersonName());

        Map<String, Object> yeWuXX = new LinkedHashMap<>();
        yeWuXX.put("DuanXinXX", duanXinXX);

        Map<String, Object> body = new LinkedHashMap<>();
        body.put("XiaoXiTou", headerMap);
        body.put("YeWuXX", yeWuXX);
        return body;
    }
}