package com.xiaopeng.map.event;

import com.xiaopeng.map.service.AdcFencePushService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

/**
 * 围栏变更事件监听器。
 * 同步处理 ADC 推送，推送失败时异常会向上抛出，调用方可感知。
 */
@Slf4j
@Component
public class FenceChangeEventListener {

    @Autowired
    private AdcFencePushService adcFencePushService;

    @EventListener
    public void onFenceChanged(FenceChangedEvent event) {
        Long electronicId = event.getElectronicId();
        Integer status = event.getStatus();
        log.info("[ADC推送] 收到围栏变更事件, electronicId={}, status={}", electronicId, status);

        if (status == 2) {
            // 启用中 → 推送最新 FBS 到绑定车辆
            adcFencePushService.pushFenceToVehicles(electronicId);
        } else if (status == 0 || status == 3) {
            // 草稿/已停用 → 上传范围框占位FBS标记围栏失效
            adcFencePushService.deactivateFenceForVehicles(electronicId);
        }
        // status=1 待启用 → 不推送，等定时任务触发
    }
}