package com.xcong.excoin.modules.station.producer;

import com.alibaba.fastjson.JSON;
import com.xcong.excoin.configurations.RabbitMqConfig;
import com.xcong.excoin.modules.station.model.GateCommand;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.UUID;

/**
 * Station → JAR 指令发送器（精准路由到 QUEUE_GATE_CMD_{apiKeyMd5}）
 */
@Slf4j
@Component
public class CmdProducer {

    private final RabbitTemplate rabbitTemplate;

    /** RabbitTemplate 是 prototype，必须用构造器注入 */
    @Autowired
    public CmdProducer(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    /**
     * 发送指令到目标 JAR
     *
     * @param apiKeyMd5 目标 apiKey MD5
     * @param type      START / STOP
     */
    public void sendCommand(String apiKeyMd5, String type) {
        sendCommand(apiKeyMd5, type, null);
    }

    /**
     * 发送带 payload 的指令到目标 JAR
     *
     * @param apiKeyMd5 目标 apiKey MD5
     * @param type      START / STOP / UPDATE_CONFIG
     * @param payload   指令附加数据（JSON），可为 null
     */
    public void sendCommand(String apiKeyMd5, String type, String payload) {
        GateCommand cmd = GateCommand.builder()
                .commandId(UUID.randomUUID().toString())
                .commandType(type)
                .apiKeyMd5(apiKeyMd5)
                .timestamp(System.currentTimeMillis())
                .payload(payload)
                .build();

        String routingKey = "cmd." + apiKeyMd5;
        CorrelationData cd = new CorrelationData(cmd.getCommandId());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_GATE, routingKey, JSON.toJSONString(cmd), cd);
        log.info("[Station] 发送指令: type={}, apiKeyMd5={}, cmdId={}, routingKey={}",
                type, apiKeyMd5, cmd.getCommandId(), routingKey);
    }
}