package com.doumee.core.utils.xpyun;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.Constants;
import com.doumee.core.utils.HttpsUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

/**
 * 芯烨云打印机API服务
 */
@Slf4j
@Service
public class XpyunPrintService {

    private static final String BASE_URL = "https://open.xpyun.net/api/openapi/xprinter/";

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    /**
     * 添加打印机
     */
    public XpyunResponse addPrinter(String sn, String name) {
        JSONObject body = buildBaseRequest();
        JSONArray printerContent = new JSONArray();
        JSONObject printer = new JSONObject();
        printer.put("sn", sn);
        printer.put("name", name);
        printerContent.add(printer);
        body.put("printerContent", printerContent);
        return callApi("addPrinters", body);
    }

    /**
     * 删除打印机
     */
    public XpyunResponse deletePrinter(String sn) {
        JSONObject body = buildBaseRequest();
        JSONArray snlist = new JSONArray();
        snlist.add(sn);
        body.put("snlist", snlist);
        return callApi("delPrinters", body);
    }

    /**
     * 查询打印机状态
     */
    public XpyunResponse queryPrinterStatus(String sn) {
        JSONObject body = buildBaseRequest();
        body.put("sn", sn);
        return callApi("queryPrinterStatus", body);
    }

    /**
     * 打印标签
     */
    public XpyunResponse printLabel(String sn, String content) {
        JSONObject body = buildBaseRequest();
        body.put("sn", sn);
        body.put("content", content);
        return callApi("printLabel", body);
    }

    /**
     * 构建订单标签内容 (60mm × 60mm = 480 × 480 dots)
     *
     * 布局:
     * shopName                   sn/countSn
     * 订单编号：code              下单时间：xxx
     * 收件信息：张三（手机尾号1234）
     * 订单行李：
     *   行李箱×1 双肩包×2
     * 订单备注
     *   xxxxxxx
     */
    public String buildOrderLabel(String shopName, String orderCode, String createTime,
                                  String takeUser, String takePhone,
                                  String goodsInfo, String remark,
                                  String snLabel) {
        StringBuilder sb = new StringBuilder();
        sb.append("<PAGE>");
        sb.append("<WIDTH>480</WIDTH>");
        sb.append("<HEIGHT>480</HEIGHT>");

        // 第1行: shopName 左侧, snLabel 右侧
        sb.append("<TEXT X=\"8\" Y=\"8\" W=\"320\" H=\"28\" T=\"16\">")
                .append(escapeXml(shopName)).append("</TEXT>");
        sb.append("<TEXT X=\"340\" Y=\"8\" W=\"140\" H=\"28\" T=\"14\">")
                .append(escapeXml(snLabel)).append("</TEXT>");

        // 第2行: 订单编号 + 下单时间
        sb.append("<TEXT X=\"8\" Y=\"44\" W=\"340\" H=\"24\" T=\"13\">")
                .append("订单编号：").append(escapeXml(orderCode)).append("</TEXT>");
        sb.append("<TEXT X=\"356\" Y=\"44\" W=\"124\" H=\"24\" T=\"13\">")
                .append(escapeXml(createTime)).append("</TEXT>");

        // 订单编号条形码
        sb.append("<C128 X=\"8\" Y=\"72\" W=\"464\" H=\"56\" T=\"")
                .append(escapeXml(orderCode)).append("\"/>");

        // 第4行: 收件信息
        String contactInfo = takeUser != null ? takeUser : "";
        if (takePhone != null && takePhone.length() >= 4) {
            contactInfo += "（手机尾号" + takePhone.substring(takePhone.length() - 4) + "）";
        }
        sb.append("<TEXT X=\"8\" Y=\"140\" W=\"464\" H=\"24\" T=\"13\">")
                .append("收件信息：").append(escapeXml(contactInfo)).append("</TEXT>");

        // 第5行: 订单行李
        sb.append("<TEXT X=\"8\" Y=\"172\" W=\"464\" H=\"24\" T=\"13\">")
                .append("订单行李：</TEXT>");
        if (StringUtils.isNotBlank(goodsInfo)) {
            sb.append("<TEXT X=\"8\" Y=\"200\" W=\"464\" H=\"24\" T=\"12\">")
                    .append(escapeXml(goodsInfo)).append("</TEXT>");
        }

        // 订单备注
        if (StringUtils.isNotBlank(remark)) {
            sb.append("<TEXT X=\"8\" Y=\"240\" W=\"464\" H=\"24\" T=\"13\">")
                    .append("订单备注：</TEXT>");
            sb.append("<TEXT X=\"8\" Y=\"268\" W=\"464\" H=\"48\" T=\"12\">")
                    .append(escapeXml(remark)).append("</TEXT>");
        }

        sb.append("</PAGE>");
        return sb.toString();
    }

    // ========== 私有方法 ==========

    private JSONObject buildBaseRequest() {
        String user = systemDictDataBiz.queryByCode(Constants.XPYUN_CONFIG, Constants.XPYUN_USER).getCode();
        String userKey = systemDictDataBiz.queryByCode(Constants.XPYUN_CONFIG, Constants.XPYUN_USER_KEY).getCode();
        long timestamp = System.currentTimeMillis() / 1000;
        String sign = sha1(user + userKey + timestamp);

        JSONObject body = new JSONObject();
        body.put("user", user);
        body.put("timestamp", timestamp);
        body.put("sign", sign);
        return body;
    }

    private XpyunResponse callApi(String endpoint, JSONObject body) {
        try {
            String url = BASE_URL + endpoint;
            String result = HttpsUtil.postJson(url, body.toJSONString());
            if (result == null) {
                log.error("芯烨云API调用失败: endpoint={}, 响应为空", endpoint);
                XpyunResponse resp = new XpyunResponse();
                resp.setCode(-1);
                resp.setMsg("响应为空");
                return resp;
            }
            return JSON.parseObject(result, XpyunResponse.class);
        } catch (Exception e) {
            log.error("芯烨云API调用异常: endpoint={}, error={}", endpoint, e.getMessage(), e);
            XpyunResponse resp = new XpyunResponse();
            resp.setCode(-1);
            resp.setMsg(e.getMessage());
            return resp;
        }
    }

    private static String sha1(String input) {
        try {
            MessageDigest md = MessageDigest.getInstance("SHA-1");
            byte[] digest = md.digest(input.getBytes(StandardCharsets.UTF_8));
            StringBuilder sb = new StringBuilder();
            for (byte b : digest) {
                sb.append(String.format("%02x", b));
            }
            return sb.toString();
        } catch (Exception e) {
            throw new RuntimeException("SHA-1计算失败", e);
        }
    }

    private static String escapeXml(String text) {
        if (text == null) return "";
        return text.replace("&", "&amp;")
                .replace("<", "&lt;")
                .replace(">", "&gt;")
                .replace("\"", "&quot;")
                .replace("'", "&apos;");
    }
}