package com.ard.qs.controller;

import com.ard.common.core.web.controller.BaseController;
import com.ard.common.core.web.domain.AjaxResult;
import com.ard.common.core.web.page.TableDataInfo;
import com.ard.common.log.annotation.Log;
import com.ard.common.log.enums.BusinessType;
import com.ard.common.security.annotation.RequiresPermissions;
import com.ard.common.security.utils.SecurityUtils;
import com.ard.qs.api.domain.QsDevice;
import com.ard.qs.domain.*;
import com.ard.qs.service.IQsDeviceService;
import com.ard.qs.utils.VideoSnapshotUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * 视频监控设备Controller
 *
 * @author fengcheng
 * @date 2026-03-27
 */
@Slf4j
@Tag(name = "视频监控设备")
@RestController
@RequestMapping("/device")
public class QsDeviceController extends BaseController {
    @Autowired
    private IQsDeviceService qsDeviceService;

    /**
     * 查询视频监控设备列表
     */
    @Operation(summary = "查询视频监控设备列表")
    @GetMapping("/list")
    public TableDataInfo list(QsDevice qsDevice) {
        startPage();
        List<QsDevice> list = qsDeviceService.selectQsDeviceList(qsDevice);
        return getDataTable(list);
    }

    /**
     * 根据行政区域获取视频监控设备列表
     */
    @Operation(summary = "根据行政区域获取视频监控设备列表")
    @GetMapping("/queryListByCivilCode")
    public TableDataInfo queryListByCivilCode(QsDevice qsDevice) {
        startPage();
        List<QsDevice> list = qsDeviceService.queryListByCivilCode(qsDevice);
        return getDataTable(list);
    }

    /**
     * 获取视频监控设备详细信息
     */
    @Operation(summary = "获取视频监控设备详细信息")
    @GetMapping(value = "/{id}")
    public AjaxResult getInfo(@PathVariable("id") Long id) {
        return success(qsDeviceService.selectQsDeviceById(id));
    }

    /**
     * 新增视频监控设备
     */
    @Operation(summary = "新增视频监控设备")
    @Log(title = "视频监控设备", businessType = BusinessType.INSERT)
    @PostMapping
    public AjaxResult add(@RequestBody QsDevice qsDevice) {
        return toAjax(qsDeviceService.insertQsDevice(qsDevice));
    }

    /**
     * 修改视频监控设备
     */
    @Operation(summary = "修改视频监控设备")
    @Log(title = "视频监控设备", businessType = BusinessType.UPDATE)
    @PutMapping
    public AjaxResult edit(@RequestBody QsDevice qsDevice) {
        return toAjax(qsDeviceService.updateQsDevice(qsDevice));
    }

    /**
     * 删除视频监控设备
     */
    @Operation(summary = "删除视频监控设备")
    @Log(title = "视频监控设备", businessType = BusinessType.DELETE)
    @DeleteMapping("/{ids}")
    public AjaxResult remove(@PathVariable Long[] ids) {
        return toAjax(qsDeviceService.deleteQsDeviceByIds(ids));
    }

    /**
     * 状态修改
     */
    @Operation(summary = "状态修改")
    @Log(title = "视频监控设备", businessType = BusinessType.UPDATE)
    @PutMapping("/changeStatus")
    public AjaxResult changeStatus(@RequestBody QsDevice qsDevice) {
        qsDevice.setUpdateBy(SecurityUtils.getUsername());
        return toAjax(qsDeviceService.updateQsDeviceStatus(qsDevice));
    }

    /**
     * 获取计划记录对应的视频监控设备
     */
    @GetMapping("/listPlanRecord")
    public TableDataInfo listPlanRecordQsDevice(QsDevice qsDevice) {
        startPage();
        List<QsDevice> list = qsDeviceService.listPlanRecordQsDevice(qsDevice);
        return getDataTable(list);
    }

    /**
     * 设备关联录制计划
     *
     * @param param
     * @return
     */
    @PostMapping("/link")
    public AjaxResult link(@RequestBody RecordPlanParam param) {
        if (param.getAllLink() != null) {
            if (param.getAllLink()) {
                qsDeviceService.linkAll(param.getPlanId());
            } else {
                qsDeviceService.cleanAll(param.getPlanId());
            }
            return success();
        }

        if (param.getDeviceIds() == null) {
            throw new RuntimeException("设备ID不可都为NULL");
        }

        qsDeviceService.link(param.getDeviceIds(), param.getPlanId());

        return success();
    }


    /**
     * 设备设置行政区划
     *
     * @param param
     */
    @Operation(summary = "设备设置行政区划")
    @PostMapping("/region/add")
    public AjaxResult addChannelToRegion(@RequestBody DeviceToRegionParam param) {
        Assert.notEmpty(param.getDeviceIds(), "设备ID不可为空");
        Assert.hasLength(param.getCivilCode(), "未添加行政区划");
        qsDeviceService.addDeviceToRegion(param.getCivilCode(), param.getDeviceIds());
        return success();
    }

    /**
     * 设备删除行政区划
     *
     * @param param
     */
    @Operation(summary = "设备删除行政区划")
    @PostMapping("/region/delete")
    public AjaxResult deleteDeviceToRegion(@RequestBody DeviceToRegionParam param) {
        Assert.isTrue(!param.getDeviceIds().isEmpty() || !ObjectUtils.isEmpty(param.getCivilCode()), "参数异常");
        qsDeviceService.deleteDeviceToRegion(param.getCivilCode(), param.getDeviceIds());
        return success();
    }


    /**
     * 存在行政区划但无法挂载的设备列表
     */
    @Operation(summary = "存在行政区划但无法挂载的设备列表")
    @GetMapping("/civilCode/unusual/list")
    public TableDataInfo queryListByCivilCodeForUnusual(QsDevice qsDevice) {
        startPage();
        List<QsDevice> list = qsDeviceService.queryListByCivilCodeForUnusual(qsDevice);
        return getDataTable(list);
    }

    /**
     * 清除存在行政区划但无法挂载的设备列表
     *
     * @param param
     */
    @Operation(summary = "清除存在行政区划但无法挂载的设备列表")
    @PostMapping("/civilCode/unusual/clear")
    public AjaxResult clearDeviceCivilCode(@RequestBody DeviceToRegionParam param) {
        qsDeviceService.clearDeviceCivilCode(param.getAll(), param.getDeviceIds());
        return success();
    }

    /**
     * 获取编码列表
     *
     * @return
     */
    @Operation(summary = "获取编码列表")
    @GetMapping("/network/identification/list")
    public AjaxResult getNetworkIdentificationTypeList() {
        List<NetworkIdentificationType> list = qsDeviceService.getNetworkIdentificationTypeList();
        return success(list);
    }

    /**
     * 获取编码列表
     *
     * @return
     */
    @Operation(summary = "获取编码列表")
    @GetMapping("/type/list")
    public AjaxResult getDeviceTypeList() {
        List<DeviceType> list = qsDeviceService.getDeviceTypeList();
        return success(list);
    }

    /**
     * 获取行业编码列表
     *
     * @return
     */
    @GetMapping("/industry/list")
    public AjaxResult getIndustryCodeList() {
        List<IndustryCodeType> list = qsDeviceService.getIndustryCodeList();
        return success(list);
    }

    /**
     * 获取关联业务分组设备列表
     */
    @GetMapping("/parent/list")
    public TableDataInfo queryListByParentId(QsDevice qsDevice) {
        startPage();
        List<QsDevice> list = qsDeviceService.queryListByParentId(qsDevice);
        return getDataTable(list);
    }

    /**
     * 设备设置业务分组
     *
     * @param param
     */
    @PostMapping("/group/add")
    public AjaxResult addChannelToGroup(@RequestBody DeviceToGroupParam param) {
        Assert.notEmpty(param.getDeviceIds(), "设备ID不可为空");
        Assert.hasLength(param.getParentId(), "未添加上级分组编号");
        Assert.hasLength(param.getBusinessGroup(), "未添加业务分组");
        qsDeviceService.addChannelToGroup(param.getParentId(), param.getBusinessGroup(), param.getDeviceIds());
        return success();
    }

    /**
     * 删除业务分组设备
     *
     * @param param
     */
    @PostMapping("/group/delete")
    public AjaxResult deleteDeviceToGroup(@RequestBody DeviceToGroupParam param) {
        Assert.isTrue(!param.getDeviceIds().isEmpty() || (!ObjectUtils.isEmpty(param.getParentId()) && !ObjectUtils.isEmpty(param.getBusinessGroup())), "参数异常");
        qsDeviceService.deleteDeviceToGroup(param.getParentId(), param.getBusinessGroup(), param.getDeviceIds());
        return success();
    }

    /**
     * 存在父节点编号但无法挂载的设备列表
     */
    @GetMapping("/parent/unusual/list")
    public TableDataInfo queryListByParentForUnusual(QsDevice qsDevice) {
        startPage();
        List<QsDevice> list = qsDeviceService.queryListByParentForUnusual(qsDevice);
        return getDataTable(list);
    }

    /**
     * 清除存在分组节点但无法挂载的设备列表
     *
     * @param param
     */
    @PostMapping("/parent/unusual/clear")
    public AjaxResult clearDeviceParent(@RequestBody DeviceToGroupParam param) {
        qsDeviceService.clearDeviceParent(param.getAll(), param.getDeviceIds());
        return success();
    }

    /**
     * 获取本地mp4截图
     */
    @RequiresPermissions("qs:device:edit")
    @Log(title = "视频监控设备", businessType = BusinessType.UPDATE)
    @PutMapping("/getVideoSnapshot/{id}")
    public AjaxResult getVideoSnapshot(@PathVariable("id") Long id) {


        return success();
    }

    /**
     * 开始云台控制
     *
     * @param id           设备id
     * @param direction    方向
     * @param controlSpeed 控制速度
     * @return 结果
     */
    @Log(title = "云台控制", businessType = BusinessType.OTHER)
    @GetMapping("/startPtz/{id}")
    public AjaxResult startPtz(@PathVariable Long id, @RequestParam String direction, @RequestParam Integer controlSpeed) {
        qsDeviceService.startPtz(id, direction, controlSpeed);
        return AjaxResult.success();
    }

    /**
     * 结束云台控制
     *
     * @param id           设备id
     * @param direction    方向
     * @param controlSpeed 控制速度
     * @return 结果
     */
    @Log(title = "云台控制", businessType = BusinessType.OTHER)
    @GetMapping("/endPtz/{id}")
    public AjaxResult endPtz(@PathVariable Long id, @RequestParam String direction, @RequestParam Integer controlSpeed) {
        qsDeviceService.endPtz(id, direction, controlSpeed);
        return AjaxResult.success();
    }

    /**
     * 获取预置点列表
     *
     * @param id         设备id
     * @param channelId  通道id
     * @return 预置点列表
     */
    @Log(title = "预置点控制", businessType = BusinessType.OTHER)
    @GetMapping("/preset/list/{id}")
    public AjaxResult getPresetList(@PathVariable Long id, @RequestParam(required = false) Integer channelId) {
        List<Preset> presetList = qsDeviceService.getPresetList(id, channelId);
        return AjaxResult.success(presetList);
    }

    /**
     * 设置预置点
     *
     * @param id          设备id
     * @param channelId   通道id
     * @param presetIndex 预置点索引
     * @param presetName  预置点名称
     * @return 结果
     */
    @Log(title = "预置点控制", businessType = BusinessType.OTHER)
    @GetMapping("/preset/set/{id}")
    public AjaxResult setPreset(@PathVariable Long id, @RequestParam(required = false) Integer channelId, @RequestParam Integer presetIndex, @RequestParam(required = false) String presetName) {
        qsDeviceService.setPreset(id, channelId, presetIndex, presetName);
        return AjaxResult.success();
    }

    /**
     * 调用预置点
     *
     * @param id          设备id
     * @param channelId   通道id
     * @param presetIndex 预置点索引
     * @param speed       速度
     * @return 结果
     */
    @Log(title = "预置点控制", businessType = BusinessType.OTHER)
    @GetMapping("/preset/goto/{id}")
    public AjaxResult gotoPreset(@PathVariable Long id, @RequestParam(required = false) Integer channelId, @RequestParam Integer presetIndex, @RequestParam(required = false) Integer speed) {
        qsDeviceService.gotoPreset(id, channelId, presetIndex, speed);
        return AjaxResult.success();
    }

    /**
     * 删除预置点
     *
     * @param id          设备id
     * @param channelId   通道id
     * @param presetIndex 预置点索引
     * @return 结果
     */
    @Log(title = "预置点控制", businessType = BusinessType.OTHER)
    @GetMapping("/preset/delete/{id}")
    public AjaxResult deletePreset(@PathVariable Long id, @RequestParam(required = false) Integer channelId, @RequestParam Integer presetIndex) {
        qsDeviceService.deletePreset(id, channelId, presetIndex);
        return AjaxResult.success();
    }
}