package com.wondertek.service.impl;
import java.time.LocalDateTime;
import java.util.*;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.wondertek.dto.*;
import com.wondertek.entity.Admin;
import com.wondertek.entity.LiveMonitorRoom;
import com.wondertek.entity.StreamTask;
import com.wondertek.mapper.LiveMonitorRoomMapper;
import com.wondertek.service.LiveMonitorRoomService;
import com.wondertek.service.StreamTaskService;
import com.wondertek.util.*;
import com.wondertek.vo.LMRoomListVo;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
@Slf4j
@Service
public class LiveMonitorRoomServiceImpl extends ServiceImpl<LiveMonitorRoomMapper, LiveMonitorRoom> implements LiveMonitorRoomService {

    @Resource
    private LiveMonitorRoomMapper liveMonitorRoomMapper;

    @Resource
    private StreamTaskService monitorMarkService;

    @Resource
    private Admin admin;


    @Value("${transcode.getTaskDetail}")
    private String getTaskDetail;


    @Value("${crp.pIp}")
    private String pIp;


    @Value("${crp.pPort}")
    private String pProt;

    @Override
    public PageBean queryPage(LMRoomDto lmRoomDto) {
        Page<LMRoomListVo> page = new Page<>(lmRoomDto.getPage(), lmRoomDto.getSize());
        IPage<LMRoomListVo> resultPage = liveMonitorRoomMapper.findPageList(page, lmRoomDto);

        List<LMRoomListVo> records = resultPage.getRecords();
        if(!CollectionUtils.isEmpty(records)){
            for (LMRoomListVo record : records) {
                String mixOutputUrl = record.getMixOutputUrl();
                record.setMixOutputUrl(FileUtils.replacePUrl(mixOutputUrl,pIp,pProt));
            }

        }

        return new PageBean(Integer.parseInt(String.valueOf(resultPage.getPages())),resultPage.getTotal(),resultPage.getRecords());
    }

    @Override
    public PageBean taskPage(LMRoomDto lmRoomDto) {
        Page<LMRoomListVo> page = new Page<>(lmRoomDto.getPage(), lmRoomDto.getSize());


        IPage<LMRoomListVo> resultPage = liveMonitorRoomMapper.findPageList(page, lmRoomDto);

        List<LMRoomListVo> records = resultPage.getRecords();
        List<Map<String, Object>> list = new ArrayList<>();
        if(!CollectionUtils.isEmpty(records)){

                list = records.stream().map(record -> {
                Map<String, Object> dataMap = JSON.parseObject(JSON.toJSONString(record), new TypeReference<Map<String, Object>>() {
                });

                LambdaQueryWrapper<StreamTask> wrapper = new LambdaQueryWrapper<>();
                wrapper.eq(StreamTask::getRoomId, record.getId());
                wrapper.eq(StreamTask::getTaskType, "0");
                wrapper.eq(StreamTask::getPlayType, "source");
                String mixOutputUrl = record.getMixOutputUrl();
                record.setMixOutputUrl(FileUtils.replacePUrl(mixOutputUrl, pIp, pProt));

                List<StreamTask> taskList = monitorMarkService.list(wrapper);
                if (!CollectionUtils.isEmpty(taskList)) {
                    dataMap.put("streamTask", taskList.get(0));
                }
                return dataMap;
            }).toList();

        }


        return new PageBean(Integer.parseInt(String.valueOf(resultPage.getPages())),resultPage.getTotal(),list);
    }

    @Override
    public PageBean editPage(LMRoomDto lmRoomDto) {
        Page<LMRoomListVo> page = new Page<>(lmRoomDto.getPage(), lmRoomDto.getSize());


        IPage<LMRoomListVo> resultPage = liveMonitorRoomMapper.findPageList(page, lmRoomDto);

        List<LMRoomListVo> records = resultPage.getRecords();
        if(!CollectionUtils.isEmpty(records)){
            for (LMRoomListVo record : records) {
                //赋值source 的延迟时间
                LambdaQueryWrapper<StreamTask> wrapper = new LambdaQueryWrapper<>();
                wrapper.eq(StreamTask::getRoomId,record.getId());
                wrapper.eq(StreamTask::getTaskType,"0");
                wrapper.eq(StreamTask::getPlayType,"play");
                String mixOutputUrl = record.getMixOutputUrl();
                record.setMixOutputUrl(FileUtils.replacePUrl(mixOutputUrl,pIp,pProt));

                List<StreamTask> taskList = monitorMarkService.list(wrapper);
                if(!CollectionUtils.isEmpty(taskList)){
                    record.setDelayTime(taskList.get(0).getDelayTime());
                }
            }
        }


        return new PageBean(Integer.parseInt(String.valueOf(resultPage.getPages())),resultPage.getTotal(),resultPage.getRecords());
    }


    @Override
    public ResultBean create(LMRoomParam lmRoomParam) {


        //审片间信息
        LiveMonitorRoom liveMonitorRoom = new LiveMonitorRoom();
        liveMonitorRoom.setName(lmRoomParam.getName());
        liveMonitorRoom.setRoomStatus("0");
        liveMonitorRoom.setCreatedBy(admin.getUsername());
        liveMonitorRoom.setCreatedTime(LocalDateTime.now());
        liveMonitorRoom.setLiveName(lmRoomParam.getLiveName());
        boolean b = saveOrUpdate(liveMonitorRoom);
        Long roomId = liveMonitorRoom.getId();


        List<CrpDataVo> dataList = lmRoomParam.getDataList();

        //初始化子任务信息
        if(!CollectionUtils.isEmpty(dataList)){
            List<StreamTask> taskList = dataList.stream().map(crpDataVo -> {
                StreamTask streamTask = new StreamTask();
                streamTask.setTaskId(crpDataVo.getTaskId());
                streamTask.setChannelId(crpDataVo.getChannelId());
                streamTask.setRoomId(roomId);
                streamTask.setTaskType(crpDataVo.getTaskType());
                streamTask.setCreatedBy(admin.getUsername());
                streamTask.setCreatedTime(LocalDateTime.now());
                return streamTask;
            }).toList();
            monitorMarkService.saveOrUpdateBatch(taskList);
        }

        return ResultBean.ok("创建成功");
    }

    @Override
    public ResultBean update(LMRoomParam lmRoomParam) {

        Long id = lmRoomParam.getId();

        LiveMonitorRoom monitorRoom = getById(id);

        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }

        monitorRoom.setName(lmRoomParam.getName());
        monitorRoom.setLiveName(lmRoomParam.getLiveName());
        saveOrUpdate(monitorRoom);

        List<CrpDataVo> dataList = lmRoomParam.getDataList();

        //更新子任务信息
        if(!CollectionUtils.isEmpty(dataList)){
            dataList.forEach(crpDataVo -> {
                Long sId = crpDataVo.getId();
                StreamTask streamTask = monitorMarkService.getById(sId);

                if (streamTask==null){
                    return;
                }
                streamTask.setTaskId(crpDataVo.getTaskId());
                streamTask.setChannelId(crpDataVo.getChannelId());
                streamTask.setTaskType(crpDataVo.getTaskType());
                streamTask.setCreatedBy(admin.getUsername());
                streamTask.setCreatedTime(LocalDateTime.now());
                monitorMarkService.updateById(streamTask);
            });
        }

        return ResultBean.ok("修改成功");
    }

    @Override
    public ResultBean updateStatus(Long id, String status) {

        LiveMonitorRoom monitorRoom = getById(id);

        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }

        String brocStatus = monitorRoom.getBrocStatus();

        if("0".equals(brocStatus)){
            return ResultBean.error("播控中房间不能禁用");
        }
        monitorRoom.setRoomStatus(status);
        monitorRoom.setUpdatedBy(admin.getUsername());
        monitorRoom.setUpdatedTime(LocalDateTime.now());
        saveOrUpdate(monitorRoom);

        log.info(JSON.toJSONString(ResultBean.ok("修改成功")));
        return ResultBean.ok("修改成功");
    }

    @Override
    public ResultBean delete(Long id) {
        LiveMonitorRoom monitorRoom = getById(id);

        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }

        String roomStatus = monitorRoom.getRoomStatus();

        if("0".equals(roomStatus)){
            return ResultBean.error("启用的房间不能删除");
        }
        monitorRoom.setDel("1");
        monitorRoom.setUpdatedTime(LocalDateTime.now());
        monitorRoom.setUpdatedBy(admin.getNickname());
        saveOrUpdate(monitorRoom);

        return ResultBean.ok("删除成功");
    }

    @Override
    public ResultBean setting(CrpRoomSetDto crpRoomSetDto) {

        Long id = crpRoomSetDto.getId();

        LiveMonitorRoom monitorRoom = getById(id);
        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }
        monitorRoom.setName(crpRoomSetDto.getName());
        monitorRoom.setUpdatedTime(LocalDateTime.now());
        saveOrUpdate(monitorRoom);
        List<CrpSetDate> dataList = crpRoomSetDto.getSetlist();
        //更新子任务信息
        if(!CollectionUtils.isEmpty(dataList)){
            dataList.forEach(setVo -> {
                Long sId = setVo.getId();
                StreamTask streamTask = monitorMarkService.getById(sId);
                if (streamTask==null){
                    return;
                }
                streamTask.setCreatedTime(LocalDateTime.now());
                streamTask.setUpdatedBy(admin.getUsername());
                streamTask.setOutputGroup(setVo.getOutputGroup());
                streamTask.setOutputDir(setVo.getOutputDir());
                streamTask.setOutputHigh(setVo.getOutputHigh());
                streamTask.setMixConfig(setVo.getMixConfig());
                monitorMarkService.updateById(streamTask);
            });
        }

        return ResultBean.ok("修改成功");
    }

    @Override
    public ResultBean taskDetail(Long id) {


        LiveMonitorRoom monitorRoom = getById(id);

        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }

        Map<String, Object> result = JSON.parseObject(JSON.toJSONString(monitorRoom), new TypeReference<Map<String, Object>>() {
        });


        List<Map<String, Object>> streamTaskMapList = new ArrayList<>();


        List<StreamTask> taskList = monitorMarkService.list(new QueryWrapper<StreamTask>().eq("room_id", id));

        if(!CollectionUtils.isEmpty(taskList)){
            for (StreamTask streamTask : taskList) {
                String taskId = streamTask.getTaskId();
                String outputDirCheck = streamTask.getOutputDir();
                String outputHighCheck = streamTask.getOutputHigh();


                Map<String, Object> streamTaskMap = JSON.parseObject(JSON.toJSONString(streamTask), new TypeReference<Map<String, Object>>() {
                });

                String reqUrl = getTaskDetail+"?taskId="+taskId;
                String res = HttpClientUtils.executeByGET(reqUrl);

//                Map<Object,Object> output = new HashMap<>();
                List<Map<String, Object>> outputDirList= new ArrayList<>();

                if(StringUtils.isNotBlank(res)){
                    Map<String, Object> resMap = JSON.parseObject(res, new TypeReference<Map<String, Object>>() {
                    });
                    Object returnMessage = resMap.get("returnMessage");
                    Object resultCode = resMap.get("resultCode");

                    if(Objects.equals("0",resultCode) && Objects.equals("成功",returnMessage)){

                        if(resMap.get("taskInfo")!=null){

                            Map<String, Object> taskInfo = (Map<String, Object>) resMap.get("taskInfo");
                            streamTaskMap.put("deviceIp", taskInfo.get("deviceIp"));
                            if(taskInfo.get("taskList")!=null){
                                List<Map<String, Object>> tasks = (List<Map<String, Object>>) taskInfo.get("taskList");

                                for (Map<String, Object> item : tasks) {
                                    //输出地址
                                    Object outGroupNo = item.get("outGroupNo");

                                    if(item.get("outPutList")!=null){
                                        List<Map<String, Object>> outPutList = (List<Map<String, Object>>) item.get("outPutList");
                                        for (Map<String, Object> opmap : outPutList) {
                                            Object outputDir = opmap.get("outputDir");
                                            Map<String, Object> outputDirMap = new HashMap<>();
                                            outputDirMap.put("outputDir", outputDir);
                                            outputDirMap.put("checked", false);
                                            outputDirMap.put("outGroupNo", outGroupNo);

                                            outputDirMap.put("checkedHigh", false);

                                            if(StringUtils.isNotBlank(outputHighCheck)){
                                                if(outputDir.equals(outputHighCheck)){
                                                    outputDirMap.put("checkedHigh", true);
                                                }
                                            }

                                            if(outputDir.equals(outputDirCheck)){
                                                outputDirMap.put("checked", true);
                                            }
                                            outputDirList.add(outputDirMap);
                                        }
                                    }

//                                    output.put(outGroupNo,outputDirList);
                                }
                            }
                        }
                    }
                }

                streamTaskMap.put("output",outputDirList);

                streamTaskMapList.add(streamTaskMap);
            }

        }

        result.put("taskList",streamTaskMapList);

        return ResultBean.ok(result);
    }


    @Override
    public ResultBean getLMRoomDetail(Long id) {
        LiveMonitorRoom monitorRoom = getById(id);
        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }
        Map<String, Object> result = JSON.parseObject(JSON.toJSONString(monitorRoom), new TypeReference<Map<String, Object>>() {
        });
        List<StreamTask> taskList = monitorMarkService.list(new QueryWrapper<StreamTask>().eq("room_id", id));

        if(!CollectionUtils.isEmpty(taskList)){
            for (StreamTask streamTask : taskList) {
                String mixOutputUrl = streamTask.getOutputDir();
                streamTask.setOutputDir(FileUtils.replacePUrl(mixOutputUrl,pIp,pProt));
            }
        }
        result.put("taskList",taskList);
        return ResultBean.ok(result);
    }


    @Override
    public ResultBean startRecord(Long id) {

        LiveMonitorRoom monitorRoom = getById(id);

        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }

        String recordStatus = monitorRoom.getRecordStatus();
        if(recordStatus == null || Objects.equals("1",recordStatus)){
            return ResultBean.error("房间在已在收录中");
        }
        monitorRoom.setRoomStatus("1");

        //请求收录服务



        monitorRoom.setUpdatedTime(LocalDateTime.now());
        saveOrUpdate(monitorRoom);

        return ResultBean.ok("操作成功");
    }

    @Override
    public ResultBean stopRecord(Long id) {
        LiveMonitorRoom monitorRoom = getById(id);

        if(monitorRoom == null){
            return ResultBean.error("房间不存在");
        }

        String recordStatus = monitorRoom.getRecordStatus();
        if(recordStatus == null || Objects.equals("2",recordStatus)){
            return ResultBean.error("房间在已在停止收录");
        }
        monitorRoom.setRoomStatus("2");

        //请求收录服务



        monitorRoom.setUpdatedTime(LocalDateTime.now());
        saveOrUpdate(monitorRoom);

        return ResultBean.ok("操作成功");
    }
}