l1024-jav/src/main/java/top/lvzhiqiang/service/impl/VideoInfoServiceImpl.java

package top.lvzhiqiang.service.impl;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import top.lvzhiqiang.config.WebAppConfig;
import top.lvzhiqiang.entity.VideoGenres;
import top.lvzhiqiang.entity.VideoInfo;
import top.lvzhiqiang.entity.VideoInfoOther;
import top.lvzhiqiang.mapper.*;
import top.lvzhiqiang.service.VideoInfoService;
import top.lvzhiqiang.util.MarkdownToHtmlUtils;
import top.lvzhiqiang.util.StringUtils;

import javax.annotation.Resource;
import java.io.File;
import java.util.Comparator;
import java.util.List;
import java.util.Map;

/**
 * 电影信息ServiceImpl
 *
 * @author lvzhiqiang
 * 2022/4/4 15:28
 */
@Service
public class VideoInfoServiceImpl extends BaseServiceImpl<Object> implements VideoInfoService {

    @Resource
    private VideoInfoMapper videoInfoMapper;
    @Resource
    private VideoInfoPoolMapper videoInfoPoolMapper;
    @Resource
    private VideoInfoUncensoredMapper videoInfoUncensoredMapper;
    @Resource
    private VideoInfoInfantryMapper videoInfoInfantryMapper;

    @Resource
    private CrawlerLoveFootMapper crawlerLoveFootMapper;

    @Resource
    private VideoInfoOtherMapper videoInfoOtherMapper;

    @Value("${spring.profiles.active}")
    private String env;

    /**
     * 查询所有
     *
     * @return
     */
    @Override
    public List<VideoInfo> findAll() {
        return videoInfoMapper.findAll();
    }

    /**
     * 分页查询所有
     *
     * @return
     */
    @Override
    public PageInfo<VideoInfo> findAll(int pageNo, int pageSize) {
        PageHelper.startPage(pageNo, pageSize);
        List<VideoInfo> videoInfoList = videoInfoMapper.findAll();
        PageInfo<VideoInfo> videoInfoPageInfo = new PageInfo<>(videoInfoList);
        return videoInfoPageInfo;
    }

    @Override
    public PageInfo<VideoInfo> getVideoInfoPage(Map<String, Object> params) {
        Object bigType = params.get("bigType");
        List<VideoInfo> videoInfoList;

        // 转换成like
        paramsToLike(params, "keyword");
        // 分页
        paramsToPagination(params);
        // 排序

        if ("骑兵".equals(bigType)) {
            paramsToSort2(params,"vi.identification_code desc");
            videoInfoList = videoInfoMapper.getVideoInfoList(params);
        } else if ("步兵".equals(bigType)) {
            Object genres = params.get("genres");
            paramsToSort(params);
            if (null == genres) {
                List<VideoGenres> videoGenresList = videoInfoInfantryMapper.findGenres();
                params.put("genres", videoGenresList.get(0).getName());
            }

            videoInfoList = videoInfoInfantryMapper.getVideoInfoInfantryList(params);
        } else if ("流出".equals(bigType)) {
            paramsToSort(params);
            videoInfoList = videoInfoUncensoredMapper.getVideoInfoUncensoredList(params);
        } else if ("码池".equals(bigType)) {
            paramsToSort2(params, "vi.identification_code desc");
            videoInfoList = videoInfoPoolMapper.getVideoInfoPoolList(params);
        } else if ("足舐".equals(bigType)) {
            paramsToSort2(params, "vi.identification_code desc");
            videoInfoList = crawlerLoveFootMapper.getVideoInfoLoveFootList(params);
        } else {
            paramsToSort(params);
            videoInfoList = videoInfoMapper.getVideoInfoList(params);
        }

        PageInfo<VideoInfo> videoInfoPageInfo = new PageInfo<>(videoInfoList);
        return videoInfoPageInfo;
    }

    /**
     * 影片信息详情
     *
     * @param type
     * @param code
     * @return
     */
    @Override
    public VideoInfo getVideoInfoDetail(String type, String code) {
        VideoInfo videoInfo;
        if ("qibing".equals(type)) {
            videoInfo = videoInfoMapper.getVideoInfoDetail(code);
            if (videoInfo == null) {
                return null;
            }

            String qibingPath = WebAppConfig.dicCodeList.stream().filter(x -> 1 == x.getType() && env.equals(x.getEnv()) && "apics_path".equals(x.getCodeKey())).findFirst().get().getCodeValue();
            String imgPrefixGFPath = "骑兵/".concat(videoInfo.getIdentificationCode()).concat("/img_gf/");
            String imgPrefixSYPath = "骑兵/".concat(videoInfo.getIdentificationCode()).concat("/img_sy/");
            videoInfo.setImgPrefixGFPath(imgPrefixGFPath);
            videoInfo.setImgPrefixSYPath(imgPrefixSYPath);

            // 获取样品图像-官方
            File imgGFFile = new File(qibingPath, imgPrefixGFPath);
            if (imgGFFile.exists()) {
                File[] files = imgGFFile.listFiles();
                for (File file : files) {
                    videoInfo.getImgGFList().add(file.getName());
                }
                videoInfo.getImgGFList().sort(Comparator.naturalOrder());
            }
            // 获取样品图像-私有
            File imgSYFile = new File(qibingPath, imgPrefixSYPath);
            if (imgSYFile.exists()) {
                File[] files = imgSYFile.listFiles();
                for (File file : files) {
                    videoInfo.getImgSYList().add(file.getName());
                }
                videoInfo.getImgSYList().sort(Comparator.naturalOrder());
            }

            videoInfo.setCommentFirst(MarkdownToHtmlUtils.markdownToHtmlExtensions(videoInfo.getCommentFirst()));
            videoInfo.setComment(MarkdownToHtmlUtils.markdownToHtmlExtensions(videoInfo.getComment()));
            videoInfo.setCommentXp(MarkdownToHtmlUtils.markdownToHtmlExtensions(videoInfo.getCommentXp()));
        } else if ("bubing".equals(type)) {
            videoInfo = videoInfoInfantryMapper.getVideoInfoDetail(code);
            if (videoInfo == null) {
                return null;
            }

            String bubingPath = WebAppConfig.dicCodeList.stream().filter(x -> 1 == x.getType() && env.equals(x.getEnv()) && "apics_path".equals(x.getCodeKey())).findFirst().get().getCodeValue();
            String imgPrefixGFPath = "步兵/".concat(videoInfo.getInfantryType()).concat("/").concat(videoInfo.getIdentificationCode()).concat("/img_gf/");
            String imgPrefixSYPath = "步兵/".concat(videoInfo.getInfantryType()).concat("/").concat(videoInfo.getIdentificationCode()).concat("/img_sy/");
            videoInfo.setImgPrefixGFPath(imgPrefixGFPath);
            videoInfo.setImgPrefixSYPath(imgPrefixSYPath);

            // 获取样品图像-官方
            File imgGFFile = new File(bubingPath, imgPrefixGFPath);
            if (imgGFFile.exists()) {
                File[] files = imgGFFile.listFiles();
                for (File file : files) {
                    videoInfo.getImgGFList().add(file.getName());
                }
                videoInfo.getImgGFList().sort(Comparator.naturalOrder());
            }
            // 获取样品图像-私有
            File imgSYFile = new File(bubingPath, imgPrefixSYPath);
            if (imgSYFile.exists()) {
                File[] files = imgSYFile.listFiles();
                for (File file : files) {
                    videoInfo.getImgSYList().add(file.getName());
                }
                videoInfo.getImgSYList().sort(Comparator.naturalOrder());
            }
        } else if ("liuchu".equals(type)) {
            videoInfo = videoInfoUncensoredMapper.getVideoInfoDetail(code);
            if (videoInfo == null) {
                return null;
            }

            String bubingPath = WebAppConfig.dicCodeList.stream().filter(x -> 1 == x.getType() && env.equals(x.getEnv()) && "apics_path".equals(x.getCodeKey())).findFirst().get().getCodeValue();
            String imgPrefixGFPath = "流出/".concat(videoInfo.getMainWho()).concat("/").concat(videoInfo.getIdentificationCode()).concat("/img_gf/");
            String imgPrefixSYPath = "流出/".concat(videoInfo.getMainWho()).concat("/").concat(videoInfo.getIdentificationCode()).concat("/img_sy/");
            videoInfo.setImgPrefixGFPath(imgPrefixGFPath);
            videoInfo.setImgPrefixSYPath(imgPrefixSYPath);

            // 获取样品图像-官方
            File imgGFFile = new File(bubingPath, imgPrefixGFPath);
            if (imgGFFile.exists()) {
                File[] files = imgGFFile.listFiles();
                for (File file : files) {
                    videoInfo.getImgGFList().add(file.getName());
                }
                videoInfo.getImgGFList().sort(Comparator.naturalOrder());
            }
            // 获取样品图像-私有
            File imgSYFile = new File(bubingPath, imgPrefixSYPath);
            if (imgSYFile.exists()) {
                File[] files = imgSYFile.listFiles();
                for (File file : files) {
                    videoInfo.getImgSYList().add(file.getName());
                }
                videoInfo.getImgSYList().sort(Comparator.naturalOrder());
            }
        } else {
            videoInfo = null;
        }

        return videoInfo;
    }

    @Override
    public void insertOrUpdateQibing(String identificationCode, String commentfirst, String commenttwo, String commentxp, String commentscore, String javdburl) {
        VideoInfoOther videoInfoOther = videoInfoOtherMapper.findVideoInfoOtherByCode(identificationCode);

        if (videoInfoOther == null) {
            videoInfoOther = new VideoInfoOther();
        }

        videoInfoOther.setComment("暂无评论".equals(commenttwo) ? null : commenttwo);
        videoInfoOther.setCommentFirst("暂无评论".equals(commentfirst) ? null : commentfirst);
        videoInfoOther.setCommentXp("暂无评论".equals(commentxp) ? null : commentxp);
        videoInfoOther.setScore(commentscore);

        videoInfoOther.setXpCount(StringUtils.isEmpty(videoInfoOther.getCommentXp()) ? 0 : videoInfoOther.getCommentXp().split("\\R").length);

        videoInfoOther.setJavdbUrl(StringUtils.isNotEmpty(javdburl) ? javdburl : null);

        videoInfoOtherMapper.updateVideoInfoOther4Xp(videoInfoOther);
    }
}