package com.sandu.ximon.admin.newnova.program;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.file.config.NovaFileConfig;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.newnova.conf.ProgramPathConfig;
import com.sandu.ximon.admin.newnova.file.NewNovaFileService;
import com.sandu.ximon.admin.newnova.param.ProgramPrarm;
import com.sandu.ximon.admin.newnova.utils.NovaAPIUtil;
import com.sandu.ximon.admin.newnova.vo.StatusVO;
import com.sandu.ximon.admin.newnova.vo.TrasfromStatusVO;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.dao.bo.NewNovaProgramBo;
import com.sandu.ximon.dao.domain.NewNovaFile;
import com.sandu.ximon.dao.domain.NewNovaProFileRelation;
import com.sandu.ximon.dao.domain.NewNovaProgram;
import com.sandu.ximon.dao.mapper.NewNovaProgramMapper;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * @author LiuHaoNan
 * @date 2022/11/16
 */
@Service
@AllArgsConstructor
public class NewNovaProgramService extends BaseServiceImpl<NewNovaProgramMapper, NewNovaProgram> {

    private NewNovaProFileRelationService fileRelationService;
    private NewNovaFileService fileService;
    private ProgramPathConfig filePathConfig;

    /**
     * 节目新增
     *
     * @param programPrarm
     * @return
     */
    public List<TrasfromStatusVO> addProgram(ProgramPrarm programPrarm) throws InterruptedException {

        NovaAPIUtil instanceUtil = NovaAPIUtil.getInstanceUtil();

        NewNovaProgram newNovaProgram = new NewNovaProgram();
        newNovaProgram.setName(programPrarm.getProgramMsg().getName());
        newNovaProgram.setWidth(programPrarm.getProgramMsg().getWidth());
        newNovaProgram.setHeight(programPrarm.getProgramMsg().getHeight());
        newNovaProgram.setScreenShot(programPrarm.getScreenShot());
        if (programPrarm.getInsertPlay()) {
            newNovaProgram.setInsertPlay(1);
        } else {
            newNovaProgram.setInsertPlay(0);
        }
        if (programPrarm.getStartPlayAfterTransferred()) {
            newNovaProgram.setStartPlayAfterTransferred(1);
        } else {
            newNovaProgram.setStartPlayAfterTransferred(0);
        }

        Integer pid = null;
        //创建节目
        if (programPrarm.getProgramID() == null) {
            StatusVO createPro = instanceUtil.createPro(programPrarm.getProgramMsg());
            pid = Integer.valueOf(createPro.getStatusData());
            checkProgram(createPro);
        } else {
            NewNovaProgram byId = getById(programPrarm.getProgramID());
            if (byId == null) {
                throw new BusinessException("未找到节目");
            }
            pid = byId.getPid();
            newNovaProgram.setId(byId.getId());
        }
        System.out.println("pid = " + pid);

        programPrarm.setProgramID(pid);
        newNovaProgram.setPid(pid);
        //编辑节目
        StatusVO editProgram = instanceUtil.editPrograms(pid, programPrarm.getSceneItems());
        checkProgram(editProgram);
        newNovaProgram.setPageInfoJsonStr(JSON.toJSONString(programPrarm.getSceneItems()));
        //生成节目
        StatusVO genrateProgram = instanceUtil.genrateProgram(pid);
        checkProgram(genrateProgram);
        //发布节目
        List<TrasfromStatusVO> trasfromStatusVOS = new ArrayList<>();
        if (programPrarm.getFileIds().size() > 0) {
            Map<String, String> proFile = getProFile(programPrarm);
            programPrarm.setFileMap(proFile);
        }
        trasfromStatusVOS = instanceUtil.trasfromProgram(programPrarm);
        newNovaProgram.setUserId(SecurityUtils.getUserId());
        saveOrUpdate(newNovaProgram);
        fileRelationService.saveRelation(newNovaProgram.getId(), programPrarm.getFileIds());
        return trasfromStatusVOS;

    }


    /**
     * 校验是否执行成功
     */
    public void checkProgram(StatusVO statusVO) {
        if (statusVO.getStatusCode() != 0) {
            throw new BusinessException("节目新增失败 : " + statusVO.getStatusData());
        }
    }

    /**
     * 获取节目文件
     *
     * @return
     */
    public Map<String, String> getProFile(ProgramPrarm programPrarm) {
        List<NewNovaFile> novaFiles = fileService.listByIds(programPrarm.getFileIds());
        if (novaFiles == null || novaFiles.size() == 0) {
            return new HashMap<String, String>();
        }
        Map<String, String> fileMap = new HashMap<String, String>();
        novaFiles.forEach(file -> {
            fileMap.put(file.getRealUrl(), file.getRealName());
        });
        return fileMap;
    }

    /**
     * 删除节目
     *
     * @param pids
     * @return
     */
    public Boolean delProgram(List<Long> pids) {
        if (pids.isEmpty()) {
            throw new BusinessException("节目id不能为空");
        }
        List<NewNovaProgram> newNovaPrograms = listByIds(pids);
        if (newNovaPrograms.isEmpty()) {
            throw new BusinessException("未找到节目");
        }
        newNovaPrograms.forEach(newNovaProgram -> {
            if (SecurityUtils.getClientId() != null) {
                if (!newNovaProgram.getUserId().equals(SecurityUtils.getUserId())) {
                    throw new BusinessException("不能操作不属于你的节目");
                }
            }
            File file = new File(filePathConfig.getOutPutPath() + "/program" + newNovaProgram.getPid());
            deleteFile(file);
        });
        return removeByIds(pids);
    }

    /**
     * .
     * 删除本地文件内容
     *
     * @param file
     * @return
     */

    public Boolean deleteFile(File file) {
        //判断文件不为null或文件目录存在
        if (file == null || !file.exists()) {
            System.out.println("文件删除失败,请检查文件是否存在以及文件路径是否正确");
            return false;
        }
        //获取目录下子文件
        File[] files = file.listFiles();
        //遍历该目录下的文件对象
        for (File f : files) {
            //判断子目录是否存在子目录,如果是文件则删除
            if (f.isDirectory()) {
                //递归删除目录下的文件
                deleteFile(f);
            } else {
                //文件删除
                f.delete();
                //打印文件名
                System.out.println("文件名：" + f.getName());
            }
        }
        //文件夹删除
        file.delete();
        System.out.println("目录名：" + file.getName());
        return true;
    }

    /**
     * 节目详情
     *
     * @param id
     * @return
     */

    public NewNovaProgram programInfo(Long id) {
        NewNovaProgram byId = getById(id);
        if (byId == null) {
            throw new BusinessException("未找到节目 ! ");
        }
        List<NewNovaProFileRelation> fileRelations = fileRelationService.list(Wrappers.lambdaQuery(NewNovaProFileRelation.class).eq(NewNovaProFileRelation::getNewNovaProgramId, id));
        if (!fileRelations.isEmpty()) {
            List<Long> fileIds = fileRelations.stream().map(NewNovaProFileRelation::getNewNovaFileId).collect(Collectors.toList());
            List<NewNovaFile> newNovaFiles = fileService.listByIds(fileIds);
            List<String> fileUrls = new ArrayList<>();
            NovaFileConfig config = SpringContextHolder.getBean(NovaFileConfig.class);
            for (NewNovaFile newNovaFile : newNovaFiles) {
                fileUrls.add(config.getFileUrl() + newNovaFile.getFileUrl());
            }
            byId.setFiles(fileUrls);
        }
        byId.setPageInfo(JSON.parseObject(byId.getPageInfoJsonStr(), List.class));
        return byId;
    }

    public List<NewNovaProgramBo> listProgram(BaseConditionVO baseConditionVO, String keyword) {
        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
        List<NewNovaProgramBo> list = baseMapper.listProgram(keyword, SecurityUtils.getClientId());
        return list;
    }
}