package com.stylefeng.guns.modular.system.util;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Date;
import java.util.HashSet;
import java.util.Set;

/**
 * 创博优订单支付适配工具。
 */
@Component
public class CbyzxOrderPayHelper {

    private static final String CALLBACK_PATH = "/base/cbyzxPayOrderTaxi";
    private static final Set<String> SUCCESS_STATUS = new HashSet<>(Arrays.asList(
            "SUCCESS", "SUCCEEDED", "PAY_SUCCESS", "TRADE_SUCCESS", "PAID", "PAYED", "1", "00", "TRUE"
    ));
    private static final Set<String> FAIL_STATUS = new HashSet<>(Arrays.asList(
            "FAIL", "FAILED", "CLOSED", "CANCEL", "CANCELED", "CANCELLED", "0", "FALSE"
    ));

    @Value("${callbackPath}")
    private String callbackPath;

    public JSONObject createOrder(Integer buyerId, String openId, String outRequestNo, Double amount) {
        CbyzxPayUtil.CreatePayOrderRequest request = new CbyzxPayUtil.CreatePayOrderRequest();
        request.setOutRequestNo(outRequestNo);
        request.setPaymentOrderAmount(new BigDecimal(String.valueOf(amount)).setScale(2, RoundingMode.HALF_UP));
        request.setBuyerId(Long.valueOf(String.valueOf(buyerId)));
        request.setOpenId(openId);
        request.setPayEndTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(System.currentTimeMillis() + 30L * 60L * 1000L)));
        request.setCallbackUrl(buildCallbackUrl());
        return CbyzxPayUtil.createPayOrder(request);
    }

    public String buildCallbackUrl() {
        return callbackPath + CALLBACK_PATH;
    }

    public boolean isCreateSuccess(JSONObject response) {
        if (response == null) {
            return false;
        }
        Object code = findValue(response, names("code"));
        if (code != null && "0".equals(String.valueOf(code))) {
            return true;
        }
        Object success = findValue(response, names("success"));
        return success != null && Boolean.parseBoolean(String.valueOf(success));
    }

    /**
     * 解析创博优表单回调参数。
     * out_trade_no 为平台订单号，trade_no 为三方支付流水号。
     */
    public JSONObject parseCallbackRequest(HttpServletRequest request) {
        if (request == null || request.getParameterMap() == null || request.getParameterMap().isEmpty()) {
            return null;
        }
        JSONObject payload = new JSONObject();
        for (String key : request.getParameterMap().keySet()) {
            String[] values = request.getParameterValues(key);
            if (values == null || values.length == 0) {
                continue;
            }
            payload.put(key, values.length == 1 ? values[0] : Arrays.asList(values));
        }
        return payload;
    }

    /**
     * trade_status=TRADE_SUCCESS 视为支付成功。
     */
    public boolean isPaySuccess(JSONObject payload) {
        if (payload == null) {
            return false;
        }
        Object status = findValue(payload, names("trade_status", "tradeStatus", "payStatus", "paymentStatus", "status", "result", "resultCode", "state"));
        if (status != null) {
            String normalized = String.valueOf(status).trim().toUpperCase();
            if (SUCCESS_STATUS.contains(normalized)) {
                return true;
            }
            if (FAIL_STATUS.contains(normalized)) {
                return false;
            }
        }
        Object success = findValue(payload, names("success"));
        if (success != null) {
            return Boolean.parseBoolean(String.valueOf(success));
        }
        Object code = findValue(payload, names("code"));
        return code != null && "0".equals(String.valueOf(code)) && StringUtils.hasText(extractOutRequestNo(payload));
    }

    /**
     * out_trade_no 为平台侧订单号，格式为 orderId_orderType_random。
     */
    public String extractOutRequestNo(JSONObject payload) {
        return valueToString(findValue(payload, names("outRequestNo", "out_trade_no")));
    }

    /**
     * 回查本地支付记录时优先使用 out_trade_no。
     */
    public String extractRecordCode(JSONObject payload) {
        String code = valueToString(findValue(payload, names("out_trade_no", "outRequestNo", "merchantSerialNo", "merchant_serial_no")));
        return StringUtils.hasText(code) ? code : null;
    }

    /**
     * trade_no 为创博优侧交易流水号，用于标记实际支付成功流水。
     */
    public String extractThirdPartyOrderNo(JSONObject payload) {
        String orderNo = valueToString(findValue(payload, names(
                "trade_no", "tradeNo", "merchantSerialNo", "merchant_serial_no", "paymentOrderId", "payment_order_id",
                "transactionId", "transaction_id", "tradeNo", "trade_no"
        )));
        return StringUtils.hasText(orderNo) ? orderNo : null;
    }

    /**
     * notify_type=directpay.status.sync 表示支付结果同步通知。
     */
    public String extractNotifyType(JSONObject payload) {
        String notifyType = valueToString(findValue(payload, names("notify_type", "notifyType")));
        return StringUtils.hasText(notifyType) ? notifyType : null;
    }

    public String extractMessage(JSONObject payload) {
        String message = valueToString(findValue(payload, names("msg", "message", "errorMsg", "errorMessage", "trade_status", "notify_type")));
        return StringUtils.hasText(message) ? message : "支付回调处理失败";
    }

    private Set<String> names(String... names) {
        return new HashSet<>(Arrays.asList(names));
    }

    private Object findValue(Object current, Set<String> names) {
        if (current == null) {
            return null;
        }
        if (current instanceof JSONObject) {
            JSONObject jsonObject = (JSONObject) current;
            for (String key : jsonObject.keySet()) {
                if (names.contains(key)) {
                    return jsonObject.get(key);
                }
            }
            for (String key : jsonObject.keySet()) {
                Object found = findValue(jsonObject.get(key), names);
                if (found != null) {
                    return found;
                }
            }
            return null;
        }
        if (current instanceof JSONArray) {
            JSONArray jsonArray = (JSONArray) current;
            for (Object item : jsonArray) {
                Object found = findValue(item, names);
                if (found != null) {
                    return found;
                }
            }
        }
        return null;
    }

    private String valueToString(Object value) {
        return value == null ? null : String.valueOf(value);
    }
}