package com.ruoyi.message.wechat.provider.xh;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.ruoyi.common.utils.http.HttpUtils;
import com.ruoyi.message.wechat.WechatMpConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.util.HashMap;
import java.util.Map;

/**
 * 新华医院公众号 API。
 * <p>
 * 对接特征：POST JSON 报文，签名 {@code sign = MD5(appSecret + body)} 放在请求头，
 * 网关地址来自机构级配置（{@code WxGZHEnum}）。
 * <p>
 * 迁移说明：原逻辑分散在 {@code RyTask.getWXCode}、{@code RedisMqReceiver.getWXCode}、
 * {@code ServiceSubtaskServiceImpl.getWXCode} 三份拷贝里，此处合并为一份（行为保持不变）。
 */
@Slf4j
@Component
public class XinHuaMpApi {

    private final com.ruoyi.message.config.MessageProperties properties;

    public XinHuaMpApi(com.ruoyi.message.config.MessageProperties properties) {
        this.properties = properties;
    }

    /**
     * 发送公众号消息（默认不关闭 HTML 转义，等价 {@code RyTask.getWXCode}）
     */
    public String sendMessage(String idcard, String url, String taskName, String taskDesc,
                              String phone, String patientName, String patientId, WechatMpConfig config) {
        return sendMessage(idcard, url, taskName, taskDesc, phone, patientName, patientId, config, false);
    }

    /**
     * 发送公众号消息
     *
     * @param idcard         身份证号
     * @param url            外链地址
     * @param taskName       标题
     * @param taskDesc       内容
     * @param phone          手机号
     * @param patientName    患者姓名
     * @param patientId      HIS 侧患者ID
     * @param config         机构级公众号配置
     * @param disableHtmlEscaping 是否关闭 Gson 的 HTML 转义
     *                      <p>
     *                      ⚠️ 站点差异（必须区分）：{@code RedisMqReceiver.getWXCode} 用的是
     *                      {@code new GsonBuilder().disableHtmlEscaping()}，而
     *                      {@code RyTask.getWXCode} / {@code ServiceSubtaskServiceImpl.getWXCode}
     *                      用的是 {@code new Gson()}（会把 {@code < > & = '} 转成 unicode 转义）。
     *                      两者产出的报文体不同，进而影响 sign 签名。此处按调用方区分，保持线上行为。
     * @return 第三方原始响应
     */
    public String sendMessage(String idcard, String url, String taskName, String taskDesc,
                              String phone, String patientName, String patientId, WechatMpConfig config,
                              boolean disableHtmlEscaping) {
        XinHuaWXReq req = new XinHuaWXReq();
        req.setService(properties.getWechat().getXinhua().getService());
        req.setIdcard(idcard);
        req.setUrl(url);
        req.setPatientid(patientId);
        req.setPatientname(patientName);
        req.setMobile(phone);
        req.setMedcardno(null);
        req.setTitlename(taskName);
        req.setContent(taskDesc);
        req.setAppid(config.getAppid());

        log.info("【XinHuaMpApi】微信公众号请求参数：{}（disableHtmlEscaping={}）", req, disableHtmlEscaping);
        String body;
        if (disableHtmlEscaping) {
            GsonBuilder gb = new GsonBuilder();
            gb.disableHtmlEscaping();
            body = gb.create().toJson(req);
        } else {
            body = new Gson().toJson(req);
        }
        String sign = md5(config.getAppSecret().concat(body));
        Map<String, String> headerMap = new HashMap<>();
        headerMap.put("sign", sign);
        String result = HttpUtils.sendPostByHeader(config.getAddress(), body, headerMap);
        log.info("【XinHuaMpApi】微信公众号返回参数：{}", result);
        return result;
    }

    /**
     * MD5 转十六进制小写（等价原 {@code getWXCode} 里的 {@code encode}）
     */
    private String md5(String arg) {
        if (arg == null) {
            arg = "";
        }
        try {
            MessageDigest md5 = MessageDigest.getInstance("MD5");
            md5.update(arg.getBytes(StandardCharsets.UTF_8));
            return toHex(md5.digest());
        } catch (Exception e) {
            log.error("【XinHuaMpApi】MD5 签名失败：{}", e.getMessage(), e);
            return "";
        }
    }

    private String toHex(byte[] hash) {
        StringBuilder hexString = new StringBuilder();
        for (byte b : hash) {
            String hex = Integer.toHexString(0xff & b);
            if (hex.length() == 1) {
                hexString.append('0');
            }
            hexString.append(hex);
        }
        return hexString.toString();
    }
}