package com.ard.sample.manage.service.impl;

import com.ard.sample.component.mqtt.model.CommonTopicReceiver;
import com.ard.sample.component.websocket.config.ConcurrentWebSocketSession;
import com.ard.sample.component.websocket.model.CustomWebSocketMessage;
import com.ard.sample.manage.model.dto.DeviceDTO;
import com.ard.sample.manage.model.dto.TelemetryDTO;
import com.ard.sample.manage.model.enums.DockModelEnum;
import com.ard.sample.manage.service.ITSAService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;

import java.util.Collection;

/**
 * 【机场1】OSD 入站分发器（Dock1 适配共享层新增，唯一侵入共享层的分流点）。
 *
 * <p>DeviceServiceImpl.handleOSD 收到 INBOUND_OSD 消息后委托本类，按设备机型分发到两条 OSD 处理链：
 * <ul>
 *   <li>DOCK1(67) → dock1 链：{@code dock1GatewayOSDServiceImpl → dock1DeviceOSDServiceImpl → dock1DockOSDServiceImpl}</li>
 *   <li>其余（DOCK2(91) / 遥控器等无法识别来源）→ dock2 原链：
 *       {@code gatewayOSDServiceImpl → deviceOSDServiceImpl → dockOSDServiceImpl}（行为与改造前完全一致）</li>
 * </ul>
 * dock1 链为普通 @Service（不带 @ServiceActivator），INBOUND_OSD 通道消费者仍只有 DeviceServiceImpl 一个。
 *
 * @author ard
 * @date 2026/10/16
 */
@Service
public class DockOsdDispatcher {

    @Autowired
    @Qualifier("gatewayOSDServiceImpl")
    private ITSAService dock2TsaService;

    @Autowired
    @Qualifier("dock1GatewayOSDServiceImpl")
    private ITSAService dock1TsaService;

    /**
     * 分发 OSD 消息到对应机型的处理链。
     *
     * @param receiver    OSD 报文
     * @param device      消息来源设备（含 domain/type/subType）
     * @param webSessions 目标 WebSocket 会话
     * @param wsMessage   待推送的 WebSocket 消息
     */
    public void dispatch(CommonTopicReceiver receiver, DeviceDTO device,
                         Collection<ConcurrentWebSocketSession> webSessions,
                         CustomWebSocketMessage<TelemetryDTO> wsMessage) {
        DockModelEnum model = DockModelResolver.resolve(device);
        if (DockModelEnum.DOCK1 == model) {
            dock1TsaService.handleOSD(receiver, device, webSessions, wsMessage);
            return;
        }
        // dock2 及一切无法识别的来源：原链透传，保证 dock2 行为零变化
        dock2TsaService.handleOSD(receiver, device, webSessions, wsMessage);
    }
}