package com.ard.gb28181.api.factory;

import com.ard.common.core.domain.R;
import com.ard.common.core.domain.RtpServerParam;
import com.ard.gb28181.api.RemoteGb28181Service;
import com.ard.gb28181.api.domain.Device;
import com.ard.gb28181.api.domain.DeviceChannel;
import com.ard.gb28181.api.domain.GbChannelDTO;
import com.ard.gb28181.api.domain.GbDeviceDTO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.openfeign.FallbackFactory;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * gb28181服务降级处理
 *
 * @FileName RemoteGb28181FallbackFactory
 * @Description
 * @Author fengcheng
 * @date 2026-03-30
 **/
@Component
public class RemoteGb28181FallbackFactory implements FallbackFactory<RemoteGb28181Service> {

    private static final Logger log = LoggerFactory.getLogger(RemoteGb28181FallbackFactory.class);

    @Override
    public RemoteGb28181Service create(Throwable throwable) {
        log.error("gb28181服务调用失败:{}", throwable.getMessage());
        return new RemoteGb28181Service() {
            @Override
            public R<Device> getDeviceByDeviceId(String gbDeviceId, String inner) {
                return R.fail("gb28181 根据设备id获取设备失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> playStreamCmd(RtpServerParam rtpServer, String inner) {
                return R.fail("gb28181 请求预览视频流失败:" + throwable.getMessage());
            }

            @Override
            public R<DeviceChannel> getDeviceChannelByChannelId(String gbDeviceId, String gbChannelId, String inner) {
                return R.fail("gb28181 根据设备id和通道获取设备通道:" + throwable.getMessage());
            }

            @Override
            public R<Void> streamByeCmd(RtpServerParam rtpServer, String inner) {
                return R.fail("gb28181 请求停止预览视频流失败:" + throwable.getMessage());
            }

            @Override
            public R<List<Device>> getAllDevices(String inner) {
                return R.fail("gb28181 获取全部设备失败:" + throwable.getMessage());
            }

            @Override
            public R<GbDeviceDTO> getGbDevice(String gbDeviceId, String inner) {
                return R.fail("gb28181 获取GbDevice失败:" + throwable.getMessage());
            }

            @Override
            public R<List<GbDeviceDTO>> getAllGbDevices(String inner) {
                return R.fail("gb28181 获取所有GbDevice失败:" + throwable.getMessage());
            }

            @Override
            public R<GbChannelDTO> getGbChannel(String gbDeviceId, String gbChannelId, String inner) {
                return R.fail("gb28181 获取GbChannel失败:" + throwable.getMessage());
            }

            @Override
            public R<List<GbChannelDTO>> getGbChannelsByDeviceId(String gbDeviceId, String inner) {
                return R.fail("gb28181 获取设备通道列表失败:" + throwable.getMessage());
            }

            @Override
            public R<Boolean> updateGbChannelStream(GbChannelDTO gbChannel, String inner) {
                return R.fail("gb28181 更新GbChannel流状态失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> frontEndCommand(String deviceId, String channelId, Integer cmdCode, Integer parameter1, Integer parameter2, Integer combindCode2, String inner) {
                return R.fail("gb28181 通用前端控制命令失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> ptz(String deviceId, String channelId, String command, Integer horizonSpeed, Integer verticalSpeed, Integer zoomSpeed, String inner) {
                return R.fail("gb28181 云台控制失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> iris(String deviceId, String channelId, String command, Integer speed, String inner) {
                return R.fail("gb28181 光圈控制失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> focus(String deviceId, String channelId, String command, Integer speed, String inner) {
                return R.fail("gb28181 聚焦控制失败:" + throwable.getMessage());
            }

            @Override
            public R<Object> queryPreset(String deviceId, String channelId, String inner) {
                return R.fail("gb28181 查询预置位失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> addPreset(String deviceId, String channelId, Integer presetId, String inner) {
                return R.fail("gb28181 设置预置位失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> callPreset(String deviceId, String channelId, Integer presetId, String inner) {
                return R.fail("gb28181 调用预置位失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> deletePreset(String deviceId, String channelId, Integer presetId, String inner) {
                return R.fail("gb28181 删除预置位失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> addCruisePoint(String deviceId, String channelId, Integer cruiseId, Integer presetId, String inner) {
                return R.fail("gb28181 加入巡航点失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> deleteCruisePoint(String deviceId, String channelId, Integer cruiseId, Integer presetId, String inner) {
                return R.fail("gb28181 删除巡航点失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> setCruiseSpeed(String deviceId, String channelId, Integer cruiseId, Integer speed, String inner) {
                return R.fail("gb28181 设置巡航速度失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> setCruiseTime(String deviceId, String channelId, Integer cruiseId, Integer time, String inner) {
                return R.fail("gb28181 设置巡航停留时间失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> startCruise(String deviceId, String channelId, Integer cruiseId, String inner) {
                return R.fail("gb28181 开始巡航失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> stopCruise(String deviceId, String channelId, Integer cruiseId, String inner) {
                return R.fail("gb28181 停止巡航失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> startScan(String deviceId, String channelId, Integer scanId, String inner) {
                return R.fail("gb28181 开始自动扫描失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> stopScan(String deviceId, String channelId, Integer scanId, String inner) {
                return R.fail("gb28181 停止自动扫描失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> setScanLeft(String deviceId, String channelId, Integer scanId, String inner) {
                return R.fail("gb28181 设置自动扫描左边界失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> setScanRight(String deviceId, String channelId, Integer scanId, String inner) {
                return R.fail("gb28181 设置自动扫描右边界失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> setScanSpeed(String deviceId, String channelId, Integer scanId, Integer speed, String inner) {
                return R.fail("gb28181 设置自动扫描速度失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> wiper(String deviceId, String channelId, String command, String inner) {
                return R.fail("gb28181 雨刷控制失败:" + throwable.getMessage());
            }

            @Override
            public R<Void> auxiliarySwitch(String deviceId, String channelId, String command, Integer switchId, String inner) {
                return R.fail("gb28181 辅助开关控制失败:" + throwable.getMessage());
            }
        };
    }
}