package com.vincent.rsf.openApi.feign.wms.fallback;

import com.vincent.rsf.framework.common.R;
import com.vincent.rsf.openApi.entity.params.ErpMatnrParms;
import com.vincent.rsf.openApi.entity.params.ErpOpParams;
import com.vincent.rsf.openApi.feign.wms.WmsServerFeignClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.List;
import java.util.Map;

/**
 * WMS Server Feign 客户端降级处理，在 Feign 内统一返回错误响应（不抛异常）。
 * 由 WmsServerFeignClientFallbackFactory 创建并传入异常 cause。
 */
@Slf4j
@Component
public class WmsServerFeignClientFallback implements WmsServerFeignClient {

    /** 触发降级时的异常，由 FallbackFactory 传入；无 cause 时为 null */
    private final Throwable cause;

    public WmsServerFeignClientFallback() {
        this.cause = null;
    }

    public WmsServerFeignClientFallback(Throwable cause) {
        this.cause = cause;
    }

    private Map<String, Object> errorResponse() {
        return R.error(filterErrorMessage(cause));
    }

    /**
     * 过滤错误消息中的URL，只保留错误类型
     * @param throwable 异常对象（可选）
     * @return 过滤后的完整错误消息（包含"查询失败："前缀）
     */
    public static String filterErrorMessage(Throwable throwable) {
        if (throwable == null) {
            return "查询失败：服务调用失败，请稍后重试";
        }
        return filterErrorMessage(throwable.getMessage());
    }

    /**
     * 过滤错误消息中的URL，只保留错误类型
     * @param errorMessage 错误消息字符串（可选）
     * @return 过滤后的完整错误消息（包含"查询失败："前缀）
     */
    public static String filterErrorMessage(String errorMessage) {
        if (errorMessage == null || errorMessage.isEmpty()) {
            return "查询失败：未知错误";
        }

        String filteredMessage = errorMessage;

        // 如果包含"executing"，说明是HTTP请求错误，去掉URL部分
        if (filteredMessage.contains("executing")) {
            int executingIndex = filteredMessage.indexOf("executing");
            if (executingIndex > 0) {
                // 提取"executing"之前的部分（如"Read timed out"）
                filteredMessage = filteredMessage.substring(0, executingIndex).trim();
            } else {
                // 如果"executing"在开头，使用默认错误消息
                filteredMessage = "请求超时";
            }
        }
        // 如果包含"http://"或"https://"，也尝试去掉URL部分
        else if (filteredMessage.contains("http://") || filteredMessage.contains("https://")) {
            // 使用正则表达式去掉URL
            filteredMessage = filteredMessage.replaceAll("https?://[^\\s]+", "").trim();
            if (filteredMessage.isEmpty()) {
                filteredMessage = "请求失败";
            }
        }

        // 如果过滤后的消息为空，使用默认错误消息
        if (filteredMessage.isEmpty()) {
            filteredMessage = "未知错误";
        }

        // 返回包含"查询失败："前缀的完整错误消息
        return "查询失败：" + filteredMessage;
    }

    @Override
    public Map<String, Object> queryOrderAndDetls(ErpOpParams params) {
        log.error("调用立库WMS Server订单信息查询接口失败，触发降级", cause);
        return errorResponse();
    }

    @Override
    public Map<String, Object> updateOrderDetls(List<Map<String, Object>> body) {
        log.error("调用立库WMS Server订单修改接口失败，触发降级", cause);
        return errorResponse();
    }

    @Override
    public Map<String, Object> orderDel(List<Map<String, Object>> body) {
        log.error("调用立库WMS Server取消单据接口失败，触发降级", cause);
        return errorResponse();
    }

    @Override
    public Map<String, Object> syncMatnrs(ErpMatnrParms params) {
        log.error("调用立库WMS Server物料信息同步接口失败，触发降级", cause);
        return errorResponse();
    }

    @Override
    public Map<String, Object> queryLocsDetls(Map<String, Object> params) {
        log.error("调用立库WMS Server库位信息查询接口失败，触发降级", cause);
        return errorResponse();
    }

    @Override
    public Map<String, Object> inventoryDetails(Map<String, Object> params) {
        log.error("调用立库WMS Server库存明细查询接口失败，触发降级", cause);
        return errorResponse();
    }

    @Override
    public Map<String, Object> inventorySummary(Map<String, Object> params) {
        log.error("调用立库WMS Server库存汇总查询接口失败，触发降级", cause);
        return errorResponse();
    }
}