package com.talentcard.server.service;

import java.net.URI;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.Locale;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;

import com.talentcard.server.common.BusinessException;
import com.talentcard.server.common.ErrorCode;
import com.talentcard.server.mapper.TransportCarWashServiceMapper;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class CarWashJumpConfigPortalService {
    private final TransportCarWashServiceMapper serviceMapper;
    private final Set<String> allowedWebHosts;

    public CarWashJumpConfigPortalService(
            TransportCarWashServiceMapper serviceMapper,
            @Value("${app.external-web.allowed-hosts:}") String allowedWebHosts
    ) {
        this.serviceMapper = serviceMapper;
        this.allowedWebHosts = Arrays.stream(allowedWebHosts.split(","))
                .map(String::trim)
                .filter(value -> !value.isEmpty())
                .map(value -> value.toLowerCase(Locale.ROOT))
                .collect(Collectors.toUnmodifiableSet());
    }

    @Transactional(readOnly = true)
    public Map<String, Object> jumpConfig(Long merchantId) {
        Long id = requireMerchantId(merchantId);
        Map<String, Object> row = serviceMapper.selectPortalJumpConfig(id);
        if (row == null || row.isEmpty()) {
            throw new BusinessException(ErrorCode.NOT_FOUND, "洗车商家不存在");
        }

        boolean merchantEnabled = intValue(row, "merchantStatus", "merchant_status") == 1;
        boolean serviceConfigured = value(row, "configId", "config_id") != null;
        boolean serviceEnabled = intValue(row, "serviceStatus", "service_status") == 1;
        boolean available = merchantEnabled && serviceConfigured && serviceEnabled;

        Map<String, Object> result = new LinkedHashMap<>();
        result.put("merchantId", value(row, "merchantId", "merchant_id"));
        result.put("merchantName", text(row, "merchantName", "merchant_name"));
        result.put("available", available);
        result.put("unavailableReason", unavailableReason(row, available, merchantEnabled, serviceConfigured, serviceEnabled));
        applyExternalLink(result, row, available);
        result.put("updatedAt", value(row, "updatedAt", "updated_at"));
        return result;
    }

    private void applyExternalLink(Map<String, Object> result, Map<String, Object> row, boolean available) {
        if (available) {
            String type = text(row, "externalLinkType", "external_link_type");
            if ("miniProgram".equals(type)) {
                String appId = text(row, "externalMiniProgramAppId", "external_mini_program_app_id");
                if (appId.matches("^wx[a-zA-Z0-9]{16}$")) {
                    result.put("externalLinkType", "miniProgram");
                    result.put("externalMiniProgramAppId", appId);
                    result.put("externalMiniProgramPath", text(row, "externalMiniProgramPath", "external_mini_program_path"));
                    result.put("externalWebUrl", "");
                    return;
                }
            }
            if ("web".equals(type)) {
                String webUrl = text(row, "externalWebUrl", "external_web_url");
                if (isAllowedWebUrl(webUrl)) {
                    result.put("externalLinkType", "web");
                    result.put("externalMiniProgramAppId", "");
                    result.put("externalMiniProgramPath", "");
                    result.put("externalWebUrl", webUrl);
                    return;
                }
            }
        }
        result.put("externalLinkType", "");
        result.put("externalMiniProgramAppId", "");
        result.put("externalMiniProgramPath", "");
        result.put("externalWebUrl", "");
    }

    private String unavailableReason(Map<String, Object> row,
                                     boolean available,
                                     boolean merchantEnabled,
                                     boolean serviceConfigured,
                                     boolean serviceEnabled) {
        if (available) {
            return "";
        }
        if (!merchantEnabled) {
            return "洗车商家当前不可用";
        }
        if (!serviceConfigured) {
            return "洗车服务配置不存在";
        }
        if (!serviceEnabled) {
            String configuredReason = text(row, "unavailableReason", "unavailable_reason");
            return configuredReason.isBlank() ? "洗车服务当前不可用" : configuredReason;
        }
        return "洗车跳转配置不可用";
    }

    private boolean isAllowedWebUrl(String value) {
        if (value.isBlank() || allowedWebHosts.isEmpty()) {
            return false;
        }
        try {
            URI uri = URI.create(value);
            String host = uri.getHost();
            return "https".equalsIgnoreCase(uri.getScheme())
                    && host != null
                    && uri.getUserInfo() == null
                    && allowedWebHosts.contains(host.toLowerCase(Locale.ROOT));
        } catch (IllegalArgumentException exception) {
            return false;
        }
    }

    private Long requireMerchantId(Long merchantId) {
        if (merchantId == null || merchantId <= 0) {
            throw new BusinessException(ErrorCode.BAD_REQUEST, "洗车商家ID不能为空");
        }
        return merchantId;
    }

    private Object value(Map<String, Object> row, String... keys) {
        for (String key : keys) {
            if (row.containsKey(key)) {
                return row.get(key);
            }
        }
        return null;
    }

    private String text(Map<String, Object> row, String... keys) {
        Object value = value(row, keys);
        return value == null ? "" : String.valueOf(value).trim();
    }

    private int intValue(Map<String, Object> row, String... keys) {
        Object value = value(row, keys);
        return value instanceof Number number ? number.intValue() : 0;
    }
}