package com.ard.work.carousel.service.impl;

import com.ard.common.core.constant.SecurityConstants;
import com.ard.common.core.domain.R;
import com.ard.common.core.utils.DateUtils;
import com.ard.common.core.utils.uuid.IdUtils;
import com.ard.common.datascope.annotation.DataScope;
import com.ard.vtdu.api.RemoteArdVtduService;
import com.ard.vtdu.api.domian.ArdVtdu;
import com.ard.work.api.domian.ArdChannel;
import com.ard.work.carousel.domain.ArdCarouselPlans;
import com.ard.work.carousel.domain.ArdCarouselWindow;
import com.ard.work.carousel.domain.ArdCarouselWindowChannel;
import com.ard.work.carousel.mapper.ArdCarouselPlansMapper;
import com.ard.work.carousel.mapper.ArdCarouselWindowChannelMapper;
import com.ard.work.carousel.mapper.ArdCarouselWindowMapper;
import com.ard.work.carousel.service.IArdCarouselPlansService;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 视频轮播方案Service业务层处理
 *
 * @author ruoyi
 * @date 2024-09-03
 */
@Service
public class ArdCarouselPlansServiceImpl implements IArdCarouselPlansService {
    @Resource
    private ArdCarouselPlansMapper ardCarouselPlansMapper;
    @Resource
    private ArdCarouselWindowMapper ardCarouselWindowMapper;
    @Resource
    private ArdCarouselWindowChannelMapper ardCarouselWindowChannelMapper;
    @Resource
    private RemoteArdVtduService remoteArdVtduService;

    /**
     * 查询视频轮播方案
     *
     * @param id 视频轮播方案主键
     * @return 视频轮播方案
     */
    @Override
    public ArdCarouselPlans selectArdCarouselPlansById(String id) {
        ArdCarouselPlans ardCarouselPlans = ardCarouselPlansMapper.selectArdCarouselPlansById(id);
        if (ardCarouselPlans == null) {
            return new ArdCarouselPlans();
        }
        ArdCarouselWindow ardCarouselWindow = new ArdCarouselWindow();
        ardCarouselWindow.setPlanId(id);
        List<ArdCarouselWindow> ardCarouselWindows = ardCarouselWindowMapper.selectArdCarouselWindowList(ardCarouselWindow);
        ardCarouselWindows.stream().forEach(ardCarouselWindow1 -> {
            //获取窗口关联的通道
            List<ArdChannel> ardChannels = ardCarouselWindowChannelMapper.selectChannelIdsByWindowId(ardCarouselWindow1.getId());
            ardCarouselWindow1.setArdChannels(ardChannels);

            //获取通道关联的流媒体
            List<ArdVtdu> ardVtduList = ardChannels.stream().map(channel -> {
                        // 拼接名称
                        String name = channel.getDeviceId() + "_" + channel.getChanNo();
                        // 从 流媒体微服务 中获取对应的 ArdVtdu 对象
                        R<ArdVtdu> ArdVtduR = remoteArdVtduService.getInfo(name, SecurityConstants.INNER);
                        if (ArdVtduR.getCode() != R.SUCCESS) {
                            return null; // 如果不成功，返回 null
                        }
                        return ArdVtduR.getData();
                    }).filter(vtdu -> vtdu != null) // 过滤掉 null 值
                    .collect(Collectors.toList());
            ardCarouselWindow1.setArdVtdus(ardVtduList);
        });
        ardCarouselPlans.setArdCarouselWindows(ardCarouselWindows);
        return ardCarouselPlans;
    }

    /**
     * 查询视频轮播方案列表
     *
     * @param ardCarouselPlans 视频轮播方案
     * @return 视频轮播方案
     */
    @Override
    @DataScope(deptAlias = "d", userAlias = "u")
    public List<ArdCarouselPlans> selectArdCarouselPlansList(ArdCarouselPlans ardCarouselPlans) {
        return ardCarouselPlansMapper.selectArdCarouselPlansList(ardCarouselPlans);
    }

    /**
     * 新增视频轮播方案
     *
     * @param ardCarouselPlans 视频轮播方案
     * @return 结果
     */
    @Override
    @Transactional
    public int insertArdCarouselPlans(ArdCarouselPlans ardCarouselPlans) {
        ardCarouselPlans.setId(IdUtils.fastSimpleUUID());
        insertWindowChannel(ardCarouselPlans);
        ardCarouselPlans.setCreateTime(DateUtils.getNowDate());
        return ardCarouselPlansMapper.insertArdCarouselPlans(ardCarouselPlans);
    }

    /**
     * 修改视频轮播方案
     *
     * @param ardCarouselPlans 视频轮播方案
     * @return 结果
     */
    @Override
    @Transactional
    public int updateArdCarouselPlans(ArdCarouselPlans ardCarouselPlans) {
        ardCarouselPlans.setUpdateTime(DateUtils.getNowDate());
        //先删除当前计划ID关联的所有窗口和通道数据
        deleteWindowChannel(ardCarouselPlans.getId());
        //后插入ID关联的所有窗口和通道数据
        insertWindowChannel(ardCarouselPlans);
        return ardCarouselPlansMapper.updateArdCarouselPlans(ardCarouselPlans);
    }

    /**
     * 批量删除视频轮播方案
     *
     * @param ids 需要删除的视频轮播方案主键
     * @return 结果
     */
    @Override
    public int deleteArdCarouselPlansByIds(String[] ids) {
        Arrays.stream(ids).forEach(id -> {
            //先删除当前计划ID关联的所有窗口和通道数据
            deleteWindowChannel(id);
        });
        return ardCarouselPlansMapper.deleteArdCarouselPlansByIds(ids);
    }

    /**
     * 删除视频轮播方案信息
     *
     * @param id 视频轮播方案主键
     * @return 结果
     */
    @Override
    public int deleteArdCarouselPlansById(String id) {
        //先删除当前计划ID关联的所有窗口和通道数据
        deleteWindowChannel(id);
        return ardCarouselPlansMapper.deleteArdCarouselPlansById(id);
    }

    /**
     * 添加轮播方案和窗口和通道的关系
     *
     * @param ardCarouselPlans 巡检方案
     * @return
     * @author 刘苏义
     * @date 2024/9/4 10:57
     */
    public void insertWindowChannel(ArdCarouselPlans ardCarouselPlans) {
        ardCarouselPlans.getArdCarouselWindows().forEach(ardCarouselWindow -> {
            ardCarouselWindow.setId(IdUtils.fastSimpleUUID());
            List<ArdCarouselWindowChannel> windowChannelList = ardCarouselWindow.getArdChannels().stream()
                    .map(ardChannel -> {
                        ArdCarouselWindowChannel ardCarouselWindowChannel = new ArdCarouselWindowChannel();
                        ardCarouselWindowChannel.setCameraId(ardChannel.getDeviceId());
                        ardCarouselWindowChannel.setChanNo(ardChannel.getChanNo());
                        ardCarouselWindowChannel.setWindowId(ardCarouselWindow.getId());
                        return ardCarouselWindowChannel;
                    })
                    .collect(Collectors.toList());

            ardCarouselWindow.setCreateTime(DateUtils.getNowDate());
            ardCarouselWindow.setPlanId(ardCarouselPlans.getId());
            ardCarouselWindowMapper.insertArdCarouselWindow(ardCarouselWindow);
            if (!windowChannelList.isEmpty()) {
                ardCarouselWindowChannelMapper.batchWindowChannel(windowChannelList);
            }
        });
    }

    /**
     * 删除轮播方案和窗口和通道的关系
     *
     * @param id 巡检方案ID
     * @return
     * @author 刘苏义
     * @date 2024/9/4 10:57
     */
    public void deleteWindowChannel(String id) {
        //先删除当前计划ID关联的所有窗口和通道数据
        ArdCarouselWindow ardCarouselWindow = new ArdCarouselWindow();
        ardCarouselWindow.setPlanId(id);
        List<ArdCarouselWindow> windows = ardCarouselWindowMapper.selectArdCarouselWindowList(ardCarouselWindow);
        if (!windows.isEmpty()) {
            List<String> windowIds = windows.stream().map(ArdCarouselWindow::getId).collect(Collectors.toList());
            ardCarouselWindowChannelMapper.deleteWindowChannel(windowIds.toArray(new String[0]));
            ardCarouselWindowMapper.deleteArdCarouselWindowByIds(windowIds.toArray(new String[0]));
        }
    }
}