/*
 * 【机场1】航线准备异常通知消费者（flight_setup_exception_notify）。
 * Dock1/M30 在 flighttask_prepare 失败时会发送该事件；共享层原枚举未注册此方法，
 * 消息会被路由到 default 通道后丢弃。这里新增独立通道与 dock1 消费者，
 * 仅处理 Dock1 设备，机场2/3 收到同名事件时保持原行为（只记录日志）。
 */
package com.ard.sample.dock1.manage.service.impl;

import com.ard.sample.component.mqtt.model.ChannelName;
import com.ard.sample.component.mqtt.model.CommonTopicReceiver;
import com.ard.sample.component.websocket.enums.MessageType;
import com.ard.sample.component.websocket.handler.DockWebSocketHandler;
import com.ard.sample.manage.model.dto.DeviceDTO;
import com.ard.sample.manage.service.IDeviceService;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.messaging.MessageHeaders;
import org.springframework.stereotype.Service;

import java.util.Objects;
import java.util.Optional;

/**
 * 机场1航线准备异常通知处理器。
 *
 * @author ard
 */
@Slf4j
@Service
public class Dock1FlightSetupExceptionHandler {

    /**
     * 机场1：Dock1 设备类型。
     */
    private static final int DOCK1_DEVICE_TYPE = 1;

    @Autowired
    private IDeviceService deviceService;

    @Autowired
    private DockWebSocketHandler dockWebSocketHandler;

    @Autowired
    private ObjectMapper mapper;

    @ServiceActivator(inputChannel = ChannelName.INBOUND_EVENTS_FLIGHT_SETUP_EXCEPTION_NOTIFY)
    public void handleFlightSetupException(CommonTopicReceiver receiver, MessageHeaders headers) {
        String dockSn = receiver.getGateway();
        Optional<DeviceDTO> deviceOpt = deviceService.getDeviceBySn(dockSn);
        if (deviceOpt.isEmpty() || !Objects.equals(DOCK1_DEVICE_TYPE, deviceOpt.get().getType())) {
            // 机场2/3 的事件仍按原逻辑只记录日志，不改变其行为。
            log.info("非机场1设备的航线准备异常通知，忽略。sn={}, method={}, data={}",
                    dockSn, receiver.getMethod(), receiver.getData());
            return;
        }

        log.warn("机场1航线准备异常：sn={}, bid={}, data={}", dockSn, receiver.getBid(), receiver.getData());
        try {
            // 原样推送给前端，便于机场1页面展示准备失败原因。
            dockWebSocketHandler.sendMessageToSubscribers(dockSn, MessageType.STATUS.getType(),
                    mapper.writeValueAsString(receiver), "");
        } catch (Exception e) {
            log.error("机场1航线准备异常通知推送失败：sn={}", dockSn, e);
        }
    }
}