package com.ard.work.sdk.fjr.service;

import com.ard.common.core.exception.ServiceException;
import com.ard.work.api.domian.*;
import com.ard.work.device.camera.domain.PtzParamDTO;
import com.ard.work.event.LoginEvent;
import com.ard.work.sdk.fjr.netty.FjrNettyClient;
import com.ard.work.sdk.fjr.netty.ThermalCommand;
import com.ard.work.sdk.model.DeviceCFG;
import com.ard.work.sdk.model.PtzScope;
import com.ard.work.sdk.service.CameraSDK;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * 类描述：富吉瑞机芯SDK
 *
 * @author lsy
 * @since 2026/3/11 7:55
 */
@Service("fjrSDK")
@Slf4j
public class FjrSDK implements CameraSDK {

    @Resource
    private ApplicationEventPublisher eventPublisher;
    @Resource
    private FjrNettyClient nettyClient;

    @Override
    public void login(ArdCamera camera) {
        try {
            // 3. 建立连接
            boolean success = nettyClient.connect(camera);
            if (success) {
                // 登录成功处理
                handleLoginSuccess(camera);
            } else {
                handleLoginFail(camera);
            }
            // 发布登录事件
            eventPublisher.publishEvent(new LoginEvent(camera));
        } catch (Exception e) {
            camera.setLoginId(-1L);
            log.error("登录失败: {}", e.getMessage());
        }
    }

    /**
     * 登录失败处理
     */
    private void handleLoginFail(ArdCamera camera) {
        camera.setChanNum(0);
        camera.setLoginId(-1L);
        camera.setState("0");
        log.warn("设备[{}:{}]登录失败", camera.getIp(), camera.getPort());
    }

    /**
     * 登录成功处理
     */
    private void handleLoginSuccess(ArdCamera camera) {
        Long loginId = System.currentTimeMillis();
        // 更新设备信息
        camera.setLoginId(loginId);
        camera.setState("1");
        camera.setChanNum(1);
        // 获取最新通道
        List<ArdChannel> channels = getChannels(camera);
        if (!channels.isEmpty()) {
            camera.setChannelList(channels);
        }
        // 登录成功
        log.info("设备登录成功 [{}:{}]", camera.getIp(), camera.getPort());
    }


    @Override
    public void logout(String cameraId) {
        try {
            nettyClient.disconnect(cameraId);
        } catch (Exception e) {
            log.error("【{}】注销异常", cameraId, e);
        }
    }


    @Override
    public Boolean isOnLine(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean pTZControl(CameraCmd cmd) {
        String cameraId = cmd.getCameraId();
        Integer speed = cmd.getSpeed();
        // 1. 先判断是否是“停止”动作
        // 如果 isEnable 为 false，说明按钮松开了，必须发送停止指令
        if (!cmd.isEnable()) {
            ThermalCommand stopCmd = ThermalCommand.createFocusStopCmd(cameraId);
            nettyClient.send(cameraId, stopCmd);
            if (cmd.getCode() == 10 || cmd.getCode() == 11) {
                // 2. 延迟 300ms 发送自动调焦
                ThermalCommand autoFocusCmd = ThermalCommand.createAutoFocusCmd(cameraId);
                nettyClient.sendDelay(cameraId, autoFocusCmd, 1000);
            }
            return true;
        }
        // 1. 创建一个统一速度指令
        ThermalCommand uniformSpeedCmd = ThermalCommand.createUniformSpeedCmd(cameraId, speed);
        nettyClient.send(cameraId, uniformSpeedCmd);
        // 2. 如果是“开始”动作 (isEnable == true)，再判断方向
        switch (cmd.getCode()) {
            case 10: // 变倍+
                ThermalCommand zoomPlus = ThermalCommand.createZoomCmd(cameraId, true);
                nettyClient.send(cameraId, zoomPlus);
                break;

            case 11: // 变倍-
                ThermalCommand zoomMinus = ThermalCommand.createZoomCmd(cameraId, false);
                nettyClient.send(cameraId, zoomMinus);
                break;

            case 12: // 调焦-
                // 这里假设你的 createFocusCmd 接受 boolean，true代表+，false代表-
                ThermalCommand cmdMinus = ThermalCommand.createFocusCmd(cameraId, false);
                nettyClient.send(cameraId, cmdMinus);
                break;

            case 13: // 调焦+
                ThermalCommand cmdPlus = ThermalCommand.createFocusCmd(cameraId, true);
                nettyClient.send(cameraId, cmdPlus);
                break;

            default:
                System.err.println("未知的指令码: " + cmd.getCode());
                return false;
        }

        return true;
    }

    @Override
    public Boolean setFocusPos(CameraCmd cmd) {
        return true;
    }

    @Override
    public Integer getFocusPos(CameraCmd cmd) {
        return 0;
    }

    @Override
    public Boolean setPreset(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean gotoPreset(CameraCmd cmd) {
        return true;
    }

    @Override
    public VideoCompressionCfg getVideoCompressionCfg(CameraCmd cmd) {
        return null;
    }

    @Override
    public Boolean controlDefog(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean isEnableDefog(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean controlInfrared(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean isEnableInfrared(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean controlFocusMode(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean getFocusMode(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean controlPTHeater(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean controlCameraDeicing(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean getPTZLockInfo(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean setPTZLockInfo(CameraCmd cmd) {
        return true;
    }

    @Override
    public byte[] localCapture(CameraCmd cmd) {
        return new byte[0];
    }

    @Override
    public String picCutCate(CameraCmd cmd) {
        return "";
    }

    @Override
    public String picCutCate(CameraCmd cmd, String bucketName, String objectName) {
        return "";
    }

    @Override
    public PtzDto getPtz(CameraCmd cmd) {
        return null;
    }

    @Override
    public PtzDto getPtzHigh(CameraCmd cmd) {
        return null;
    }

    @Override
    public PtzScope getPtzScope(CameraCmd cmd) {
        return null;
    }

    @Override
    public Boolean setPtz(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean setPtzHigh(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean setPtzHighT(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean setZeroPtz(CameraCmd cmd) {
        return true;
    }

    @Override
    public String record(CameraCmd cmd) {
        return "";
    }

    @Override
    public Boolean guideTargetPosition(CameraCmd cmd) {
        return true;
    }

    @Override
    public Boolean recordStart(CameraCmd cmd) {
        return true;
    }

    @Override
    public String recordStop(CameraCmd cmd) {
        return "";
    }

    @Override
    public PtzParamDTO getGisInfo(CameraCmd cmd) {
        return null;
    }

    @Override
    public Double correctPitch(CameraCmd cmd) {
        return 0.0;
    }

    @Override
    public List<ArdChannel> getChannels(ArdCamera camera) {
        //获取通道
        List<ArdChannel> channelList = new ArrayList<>();
        try {
            ArdChannel ardChannel = new ArdChannel();
            ardChannel.setName("热红外");
            ardChannel.setChanNo(2);
            ardChannel.setDeviceId(camera.getId());
            ardChannel.setVideoCode("h264");
            String rtspUrl = String.format("rtsp://%s:%s@%s:%d/h264/ch%d/main/av_stream",
                    camera.getUsername(),
                    camera.getPassword(),
                    camera.getIp(),
                    camera.getRtspPort(),
                    2
            );
            ardChannel.setLiveAddress(rtspUrl);
            channelList.add(ardChannel);
        } catch (Exception ex) {
            log.error("获取IP通道异常:{}", ex.getMessage(), ex);
        }
        return channelList;
    }

    @Override
    public Boolean set3DPosition(CameraCmd cmd) {
        return null;
    }

    @Override
    public DeviceCFG getSystemInfo(CameraCmd cmd) {
        return null;
    }
    @Override
    public List<Map<String, Object>> getCameraVideoLable(Long userId, CameraCmd cmd)throws ServiceException {
        return null;
    }

}