package com.smartor.common;

import com.smartor.domain.ShiyiSmsRequest;
import com.smartor.domain.ShiyiSmsResponse;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;

import java.io.StringReader;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 杭州市一 HIS 服务平台对接工具类。
 * <p>
 * 按《HIS 服务平台接口说明文档 V1.1》3.1 节约定，HIS 对外以 WCF Web Service 形式发布，
 * 统一入口：{@code int RunService(string TradeType, string TradeMsg, ref string TradeOut)}，
 * 其中 {@code TradeType} 标识业务编码，{@code TradeMsg} 为 UTF-8 编码的 XML 报文。
 * 本工具类目前实现 5.2 短信业务 (TradeType=FASONGDX)。
 */
@Slf4j
@Component
public class ShiyiSmsUtil {

    /** 5.2 短信业务 TradeType */
    public static final String TRADE_TYPE_FASONGDX = "FASONGDX";

    /** WCF 命名空间，默认随文档示例 */
    private String namespace = "http://tempuri.org/";

    /** 默认操作员代码 */
    @Value("${his.service.defaultCaozuoydm:}")
    private String defaultCaozuoydm;

    /** 默认操作员姓名 */
    @Value("${his.service.defaultCaozuoyxm:}")
    private String defaultCaozuoyxm;

    /** 默认系统标识 */
    private String defaultXitongbs = "0";

    /** 默认分院代码 */
    private String defaultFenyuandm = "1";

    /** 默认机构代码 */
    private String defaultJigoudm = "1";

    private final RestTemplate restTemplate = new RestTemplate();

    /**
     * 发送短信 (FASONGDX)
     */
    public ShiyiSmsResponse sendSms(ShiyiSmsRequest request) {
        if (request == null) {
            throw new IllegalArgumentException("短信请求不能为空");
        }
        if (StringUtils.isBlank(request.getShoujihao())) {
            throw new IllegalArgumentException("手机号不能为空");
        }
        if (StringUtils.isBlank(request.getDuanxinnr())) {
            throw new IllegalArgumentException("短信内容不能为空");
        }

        applyDefaults(request);

        String tradeMsg = buildFasongdxXml(request);
        log.info("市一 短信请求, TradeType={}, TradeMsg={}", TRADE_TYPE_FASONGDX, tradeMsg);

        String tradeOut = invokeRunService(TRADE_TYPE_FASONGDX, tradeMsg);
        log.info("市一 短信响应, TradeOut={}", tradeOut);

        return parseFasongdxResponse(tradeOut);
    }

    /**
     * 调用 市一 WCF RunService 接口。SOAP 1.1 基础鉴权按文档不要求。
     *
     * @return TradeOut 报文（服务端 ref 参数）
     */
    public String invokeRunService(String tradeType, String tradeMsg) {
        String soapEnvelope = buildSoapEnvelope(tradeType, tradeMsg);
        String hisServiceUrl = "http://192.200.54.57:7790/MediInfoHis.svc";

        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(new MediaType("text", "xml", StandardCharsets.UTF_8));
        headers.set("SOAPAction", joinNamespace(namespace, "IMediInfoHis/RunService"));

        HttpEntity<String> entity = new HttpEntity<>(soapEnvelope, headers);
        try {
            ResponseEntity<String> response = restTemplate.postForEntity(hisServiceUrl, entity, String.class);
            String body = response.getBody();
            if (StringUtils.isBlank(body)) {
                throw new RuntimeException("HIS 返回空响应");
            }
            return extractTradeOut(body);
        } catch (Exception e) {
            log.error("调用 HIS RunService 失败, url={}, tradeType={}, err={}", hisServiceUrl, tradeType, e.getMessage(), e);
            throw new RuntimeException("调用 HIS RunService 失败: " + e.getMessage(), e);
        }
    }

    private void applyDefaults(ShiyiSmsRequest request) {
        if (StringUtils.isBlank(request.getCaozuoydm())) {
            request.setCaozuoydm(defaultCaozuoydm);
        }
        if (StringUtils.isBlank(request.getCaozuoyxm())) {
            request.setCaozuoyxm(defaultCaozuoyxm);
        }
        if (StringUtils.isBlank(request.getCaozuorq())) {
            request.setCaozuorq(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        }
        if (StringUtils.isBlank(request.getXitongbs())) {
            request.setXitongbs(defaultXitongbs);
        }
        if (StringUtils.isBlank(request.getFenyuandm())) {
            request.setFenyuandm(defaultFenyuandm);
        }
        if (StringUtils.isBlank(request.getJigoudm())) {
            request.setJigoudm(defaultJigoudm);
        }
        if (StringUtils.isBlank(request.getDuanxinlx())) {
            request.setDuanxinlx("0");
        }
    }

    private String buildFasongdxXml(ShiyiSmsRequest r) {
        StringBuilder sb = new StringBuilder(512);
        sb.append("<?xml version=\"1.0\" encoding=\"utf-8\"?>");
        sb.append("<FASONGDX_IN>");
        sb.append("<BASEINFO>");
        appendTag(sb, "CAOZUOYDM", r.getCaozuoydm());
        appendTag(sb, "CAOZUOYXM", r.getCaozuoyxm());
        appendTag(sb, "CAOZUORQ", r.getCaozuorq());
        appendTag(sb, "XITONGBS", r.getXitongbs());
        appendTag(sb, "FENYUANDM", r.getFenyuandm());
        appendTag(sb, "JIGOUDM", r.getJigoudm());
        appendTag(sb, "JIGOUMC", r.getJigoumc());
        appendTag(sb, "JIGOUYZM", r.getJigouyzm());
        appendTag(sb, "JIESHOUJGDM", r.getJieshoujgdm());
        appendTag(sb, "ZHONGDUANJB", r.getZhongduanjb());
        appendTag(sb, "ZHONGDUANLS", r.getZhongduanls());
        appendTag(sb, "IPADDRESS", r.getIpaddress());
        appendTag(sb, "YEWULX", r.getYewulx());
        appendTag(sb, "JIERUCSDM", r.getJierucsdm());
        sb.append("</BASEINFO>");
        appendTag(sb, "DUANXINLX", r.getDuanxinlx());
        appendTag(sb, "SHOUJIHAO", r.getShoujihao());
        appendTag(sb, "DUANXINNR", r.getDuanxinnr());
        sb.append("</FASONGDX_IN>");
        return sb.toString();
    }

    private ShiyiSmsResponse parseFasongdxResponse(String xml) {
        ShiyiSmsResponse resp = new ShiyiSmsResponse();
        resp.setRawXml(xml);
        if (StringUtils.isBlank(xml)) {
            resp.setErrno("-1");
            resp.setErrmsg("HIS 返回空 TradeOut");
            return resp;
        }
        try {
            Document doc = parseXml(xml);
            resp.setErrno(readTag(doc, "ERRNO"));
            resp.setErrmsg(readTag(doc, "ERRMSG"));
            resp.setErrmsgex(readTag(doc, "ERRMSGEX"));
            resp.setMessageId(readTag(doc, "MessageID"));
            resp.setDuanxinid(readTag(doc, "DUANXINID"));
        } catch (Exception e) {
            log.error("解析 HIS 短信响应失败, xml={}, err={}", xml, e.getMessage(), e);
            resp.setErrno("-1");
            resp.setErrmsg("解析响应失败: " + e.getMessage());
        }
        return resp;
    }

    private String buildSoapEnvelope(String tradeType, String tradeMsg) {
        // WCF 默认 BasicHttpBinding 下接口方法以 Message Contract 形式发布，参数节点名与 C# 方法签名一致。
        // TradeOut 为 ref 参数，入参也需传空元素占位。
        return "<?xml version=\"1.0\" encoding=\"utf-8\"?>"
                + "<s:Envelope xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:t=\"" + namespace + "\">"
                + "<s:Body>"
                + "<t:RunService>"
                + "<t:TradeType>" + escapeXml(tradeType) + "</t:TradeType>"
                + "<t:TradeMsg>" + escapeXml(tradeMsg) + "</t:TradeMsg>"
                + "<t:TradeOut></t:TradeOut>"
                + "</t:RunService>"
                + "</s:Body>"
                + "</s:Envelope>";
    }

    private String extractTradeOut(String soapResponse) throws Exception {
        Document doc = parseXml(soapResponse);
        // TradeOut 节点 (带命名空间)
        String tradeOut = readTagIgnoreNs(doc, "TradeOut");
        if (StringUtils.isBlank(tradeOut)) {
            // 有些 WCF 实现会把 ref 参数输出节点命名为 RunServiceResult 的同级 TradeOut
            tradeOut = readTagIgnoreNs(doc, "tradeOut");
        }
        return tradeOut;
    }

    private Document parseXml(String xml) throws Exception {
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        factory.setNamespaceAware(false);
        factory.setFeature("http://apache.org/xml/features/disallow-doctype-decl", true);
        factory.setFeature("http://xml.org/sax/features/external-general-entities", false);
        factory.setFeature("http://xml.org/sax/features/external-parameter-entities", false);
        DocumentBuilder builder = factory.newDocumentBuilder();
        return builder.parse(new InputSource(new StringReader(xml)));
    }

    private String readTag(Document doc, String name) {
        NodeList list = doc.getElementsByTagName(name);
        if (list.getLength() == 0) {
            return null;
        }
        return list.item(0).getTextContent();
    }

    private String readTagIgnoreNs(Document doc, String localName) {
        NodeList all = doc.getElementsByTagName("*");
        for (int i = 0; i < all.getLength(); i++) {
            Node node = all.item(i);
            if (node instanceof Element) {
                Element el = (Element) node;
                String local = el.getLocalName() != null ? el.getLocalName() : el.getNodeName();
                if (local.equalsIgnoreCase(localName) || local.endsWith(":" + localName)) {
                    return el.getTextContent();
                }
                if (el.getNodeName().endsWith(":" + localName) || el.getNodeName().equalsIgnoreCase(localName)) {
                    return el.getTextContent();
                }
            }
        }
        return null;
    }

    private void appendTag(StringBuilder sb, String tag, String value) {
        sb.append('<').append(tag).append('>');
        if (StringUtils.isNotBlank(value)) {
            sb.append(escapeXml(value));
        }
        sb.append("</").append(tag).append('>');
    }

    private String escapeXml(String input) {
        if (input == null) {
            return "";
        }
        StringBuilder out = new StringBuilder(input.length());
        for (int i = 0; i < input.length(); i++) {
            char c = input.charAt(i);
            switch (c) {
                case '&':
                    out.append("&amp;");
                    break;
                case '<':
                    out.append("&lt;");
                    break;
                case '>':
                    out.append("&gt;");
                    break;
                case '"':
                    out.append("&quot;");
                    break;
                case '\'':
                    out.append("&apos;");
                    break;
                default:
                    out.append(c);
            }
        }
        return out.toString();
    }

    private String joinNamespace(String ns, String op) {
        if (ns == null) {
            return "\"" + op + "\"";
        }
        if (ns.endsWith("/")) {
            return "\"" + ns + op + "\"";
        }
        return "\"" + ns + "/" + op + "\"";
    }
}