关闭定时器

EricsHu

2023-06-25 bc835f7b8d4ab951999ff7a08bf62d18daa0461e

 src/main/java/com/qxueyou/scc/teach/res/service/impl/resitem/ResItemVideoService.java

@@ -157,43 +157,43 @@
    /**
     * 定时器转码成功后 同步更新ResItemVideo的状态
     */
    @Scheduled(cron = "0/2 * * * * ?") // 每2秒执行一次
    public void doTimer() {

        String mediaVideoId = cacheService.lstLeftPop(RES_VIDEO_CONVER_LST);

        if (StringUtils.isBlank(mediaVideoId)) {
            return;
        }

        MediaVideo mediaVideo = read(MediaVideo.class, mediaVideoId);
        if (mediaVideo.getStatus() == MediaVideo.STATUS_DRAFT) {
            if (mediaVideo.getType().equals("video")) {
                ResItemVideo resItemVideo = findUnique(
                        "from ResItemVideo where deleteFlag is false and mediaVideoId = ?",
                        CollectionUtils.newList(mediaVideoId), ResItemVideo.class);
                resItemVideo.setStatus(ResItemVideo.STATUS_DRAFT);
                TraceUtils.setUpdateTrace(resItemVideo);
                resItemVideo.setVideoSeconds(mediaVideo.getPlayTime());
                save(resItemVideo);

                cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemVideo.getVideoId());// 将转码完成后的文件id放入缓存。
                return;
            } else if (mediaVideo.getType().equals("audio")) {
                ResItemAudio resItemAudio = findUnique(
                        "from ResItemAudio where deleteFlag is false and mediaVideoId = ?",
                        CollectionUtils.newList(mediaVideoId), ResItemAudio.class);
                resItemAudio.setStatus(ResItemVideo.STATUS_DRAFT);
                TraceUtils.setUpdateTrace(resItemAudio);
                resItemAudio.setSeconds(mediaVideo.getPlayTime());
                save(resItemAudio);

                cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemAudio.getAudioId());// 将转码完成后的文件id放入缓存。
                return;
            }

        }
        cacheService.lstRightPush(RES_VIDEO_CONVER_LST, mediaVideoId);

    }
//    @Scheduled(cron = "0/2 * * * * ?") // 每2秒执行一次
//    public void doTimer() {
//
//        String mediaVideoId = cacheService.lstLeftPop(RES_VIDEO_CONVER_LST);
//
//        if (StringUtils.isBlank(mediaVideoId)) {
//            return;
//        }
//
//        MediaVideo mediaVideo = read(MediaVideo.class, mediaVideoId);
//        if (mediaVideo.getStatus() == MediaVideo.STATUS_DRAFT) {
//            if (mediaVideo.getType().equals("video")) {
//                ResItemVideo resItemVideo = findUnique(
//                        "from ResItemVideo where deleteFlag is false and mediaVideoId = ?",
//                        CollectionUtils.newList(mediaVideoId), ResItemVideo.class);
//                resItemVideo.setStatus(ResItemVideo.STATUS_DRAFT);
//                TraceUtils.setUpdateTrace(resItemVideo);
//                resItemVideo.setVideoSeconds(mediaVideo.getPlayTime());
//                save(resItemVideo);
//
//                cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemVideo.getVideoId());// 将转码完成后的文件id放入缓存。
//                return;
//            } else if (mediaVideo.getType().equals("audio")) {
//                ResItemAudio resItemAudio = findUnique(
//                        "from ResItemAudio where deleteFlag is false and mediaVideoId = ?",
//                        CollectionUtils.newList(mediaVideoId), ResItemAudio.class);
//                resItemAudio.setStatus(ResItemVideo.STATUS_DRAFT);
//                TraceUtils.setUpdateTrace(resItemAudio);
//                resItemAudio.setSeconds(mediaVideo.getPlayTime());
//                save(resItemAudio);
//
//                cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemAudio.getAudioId());// 将转码完成后的文件id放入缓存。
//                return;
//            }
//
//        }
//        cacheService.lstRightPush(RES_VIDEO_CONVER_LST, mediaVideoId);
//
//    }
}