package com.ruoyi.publicity.api;

import com.ruoyi.common.core.service.PublicityApi;
import com.ruoyi.publicity.config.PublicityProperties;
import com.ruoyi.publicity.config.PublicitySwitch;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 宣教模块对外门面（<b>常驻 Bean</b>），实现 ruoyi-common 里的 {@link PublicityApi}。
 *
 * <h3>为什么实现 ruoyi-common 的接口，而不是自带一个</h3>
 * 调用方是 {@code ruoyi-inhospvisit}，而它只依赖 ruoyi-common（不能依赖 ruoyi-publicity，
 * 否则 {@code inhospvisit <-> publicity} 双向依赖 → Maven 构建失败）。
 * 所以契约放在 ruoyi-common，本模块实现它；
 * 调用方用 {@code ObjectProvider}/{@code SpringUtils.getBean} 按类型查找 + 降级。
 * —— 与满意度的 {@code SatisfactionFacade} 实现 ruoyi-common 的
 * {@code ISatisfactionCategoryService} 完全同一手法。
 *
 * <h3>关闭时的行为</h3>
 * 返回 0（没有宣教要做）并打 WARN，<b>不抛异常</b>。
 * 宣教失败绝不能拖垮出入院随访主流程。
 */
@Slf4j
@Component
public class PublicityFacade implements PublicityApi {

    private final PublicityProperties properties;

    private final PublicitySwitch publicitySwitch;

    /**
     * 内部实现（{@link DefaultPublicityApi}）；
     * 用 {@code ObjectProvider} 惰性取，即使实现缺失也不至于注入失败。
     */
    private final ObjectProvider<PublicityApi> apiProvider;

    /**
     * Spring 使用的构造器。
     * <p>
     * ⚠️ <b>必须显式标注 {@code @Autowired}</b>：本类有两个公开构造器，
     * 不标注会因"构造器不唯一"退回无参构造器 → 启动报 {@code No default constructor found}。
     * —— 满意度模块实机踩到的坑，此处刻意规避。
     */
    @Autowired
    public PublicityFacade(PublicityProperties properties,
                           PublicitySwitch publicitySwitch,
                           ObjectProvider<PublicityApi> apiProvider) {
        this.properties = properties;
        this.publicitySwitch = publicitySwitch;
        this.apiProvider = apiProvider;
    }

    /**
     * 供<b>测试/非 Spring 环境</b>直接构造
     */
    public PublicityFacade(PublicityProperties properties, PublicityApi delegate, String sysConfigValue) {
        this(properties, new PublicitySwitch(properties, sysConfigValue), new FixedProvider(delegate));
    }

    /**
     * 取运行时开关（供测试断言 / 将来若加拦截器时复用）
     */
    public PublicitySwitch getPublicitySwitch() {
        return publicitySwitch;
    }

    /**
     * 取内部实现；关闭、缺失、或只找到自己时返回 {@code null}。
     * <p>
     * ⚠️ <b>必须排除"自己"</b>：本类自身也实现了 {@link PublicityApi}，
     * Spring 按类型查找时若没有别的实现，会把自引用当兜底候选返回，
     * 于是 {@code delegate.dealInHospPublicity(...)} 变成无限递归 → {@code StackOverflowError}。
     * <p>
     * 用 {@code stream()} 而不是 {@code getIfAvailable()}：后者候选 &gt;1 时抛
     * {@code NoUniqueBeanDefinitionException}，会被吞成 null，掩盖配置错误。
     */
    private PublicityApi delegateOrNull() {
        if (apiProvider == null) {
            return null;
        }
        try {
            return apiProvider.stream()
                    .filter(api -> api != this)
                    .findFirst()
                    .orElse(null);
        } catch (Exception e) {
            log.warn("【宣教】获取内部实现失败，按未启用处理：{}", e.toString());
            return null;
        }
    }

    /**
     * 宣教模块是否可用（开关打开 <b>且</b> 实现存在）
     */
    public boolean isEnabled() {
        return publicitySwitch.isEnabled() && delegateOrNull() != null;
    }

    @Override
    public int dealInHospPublicity(String config) {
        if (!isEnabled()) {
            log.warn("【宣教】模块未启用（参数配置 publicity.enabled=false），入院宣教跳过。config={}", config);
            return 0;
        }
        return delegateOrNull().dealInHospPublicity(config);
    }

    @Override
    public int dealMedicalPublicity(String config) {
        if (!isEnabled()) {
            log.warn("【宣教】模块未启用（参数配置 publicity.enabled=false），药品宣教跳过。config={}", config);
            return 0;
        }
        return delegateOrNull().dealMedicalPublicity(config);
    }

    /**
     * 固定值的 {@code ObjectProvider} 实现：仅用于非 Spring 环境/测试
     */
    private static final class FixedProvider implements ObjectProvider<PublicityApi> {

        private final PublicityApi api;

        private FixedProvider(PublicityApi api) {
            this.api = api;
        }

        @Override
        public PublicityApi getObject(Object... args) {
            return api;
        }

        @Override
        public PublicityApi getIfAvailable() {
            return api;
        }

        @Override
        public PublicityApi getIfUnique() {
            return api;
        }

        @Override
        public PublicityApi getObject() {
            return api;
        }

        @Override
        public java.util.stream.Stream<PublicityApi> stream() {
            return api == null ? java.util.stream.Stream.empty() : java.util.stream.Stream.of(api);
        }
    }
}