package com.vincent.rsf.openApi.service;

import com.fasterxml.jackson.databind.JsonNode;
import com.vincent.rsf.openApi.tv.TvMonitorRedisKeys;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * RCS 推送：写入与电视机后台相同的 Redis 格式（不修改 zy-monitor-admin / 电视机）
 */
@Slf4j
@Service
public class RcsTvCallbackService {

    @Resource
    @Qualifier("tvMonitorStringRedisTemplate")
    private StringRedisTemplate tvMonitorStringRedisTemplate;

    @Value("${tv-monitor.rcs-callback-token:}")
    private String rcsCallbackToken;

    public void assertToken(String headerToken) {
        if (!StringUtils.hasText(rcsCallbackToken)) {
            return;
        }
        if (!rcsCallbackToken.equals(headerToken)) {
            throw new IllegalArgumentException("X-Rcs-Token 无效");
        }
    }

    /**
     * 解析输送线异常列表，写入 {@link TvMonitorRedisKeys#TV_MANUAL_ERROR_MSG}（分号拼接，与推送端 join 风格一致）
     */
    public Map<String, Object> handleStationError(JsonNode body) {
        if (body != null && body.isObject() && body.has("clear") && body.get("clear").asBoolean(false)) {
            tvMonitorStringRedisTemplate.delete(TvMonitorRedisKeys.TV_MANUAL_ERROR_MSG);
            return rcsOk(null);
        }
        JsonNode arr = resolveErrorArray(body);
        if (arr == null || !arr.isArray() || arr.size() == 0) {
            tvMonitorStringRedisTemplate.delete(TvMonitorRedisKeys.TV_MANUAL_ERROR_MSG);
            return rcsOk(null);
        }
        List<String> parts = new ArrayList<>();
        for (JsonNode item : arr) {
            if (item == null || !item.isObject()) {
                continue;
            }
            String staNo = text(item.get("staNo"));
            String err = text(item.get("error"));
            String plc = text(item.get("plcDesc"));
            String msg = StringUtils.hasText(err) ? err : plc;
            if (!StringUtils.hasText(msg)) {
                continue;
            }
            if (StringUtils.hasText(staNo)) {
                parts.add("[" + staNo + "]" + msg);
            } else {
                parts.add(msg);
            }
        }
        if (parts.isEmpty()) {
            tvMonitorStringRedisTemplate.delete(TvMonitorRedisKeys.TV_MANUAL_ERROR_MSG);
            return rcsOk(null);
        }
        String value = String.join("；", parts);
        tvMonitorStringRedisTemplate.opsForValue().set(TvMonitorRedisKeys.TV_MANUAL_ERROR_MSG, value);
        log.info("RCS 报警已写入 Redis tvManualErrorMsg，条数={}", parts.size());
        return rcsOk(value);
    }

    private static JsonNode resolveErrorArray(JsonNode body) {
        if (body == null || body.isNull()) {
            return null;
        }
        if (body.isArray()) {
            return body;
        }
        if (body.isObject()) {
            if (body.has("data") && body.get("data").isArray()) {
                return body.get("data");
            }
            if (body.has("errors") && body.get("errors").isArray()) {
                return body.get("errors");
            }
        }
        return null;
    }

    private static String text(JsonNode n) {
        if (n == null || n.isNull()) {
            return "";
        }
        String s = n.asText("");
        return s == null ? "" : s.trim();
    }

    /**
     * 站点任务号写入 Redis Hash，供后续扩展；电视机 led 任务号仍来自 WCS 站点轮询
     */
    public Map<String, Object> handleStationTaskNo(JsonNode body) {
        if (body == null || body.isNull() || !body.isObject()) {
            throw new IllegalArgumentException("body 须为 JSON 对象");
        }
        JsonNode dataNode = body.get("data");
        JsonNode src = (dataNode != null && dataNode.isObject()) ? dataNode : body;
        String staNo = text(body.get("staNo"));
        if (!StringUtils.hasText(staNo)) {
            staNo = text(src.get("staNo"));
        }
        String taskNo = text(src.get("taskNo"));
        if (!StringUtils.hasText(staNo)) {
            throw new IllegalArgumentException("staNo 不能为空");
        }
        if (!StringUtils.hasText(taskNo)) {
            tvMonitorStringRedisTemplate.opsForHash().delete(TvMonitorRedisKeys.TV_RCS_STATION_TASK_NO, staNo);
        } else {
            tvMonitorStringRedisTemplate.opsForHash()
                    .put(TvMonitorRedisKeys.TV_RCS_STATION_TASK_NO, staNo, taskNo);
        }
        log.info("RCS 任务号已写入 Redis Hash staNo={} taskNo={}", staNo, taskNo);
        Map<String, Object> payload = new LinkedHashMap<>();
        payload.put("staNo", staNo);
        payload.put("taskNo", taskNo);
        return rcsOk(payload);
    }

    private Map<String, Object> rcsOk(Object data) {
        Map<String, Object> m = new LinkedHashMap<>();
        m.put("code", 200);
        m.put("message", "请求成功");
        m.put("timestamp", System.currentTimeMillis());
        m.put("data", data);
        return m;
    }
}