4dkankan-center-scene/src/main/java/com/fdkankan/scene/schedule/ScheduleJob.java

package com.fdkankan.scene.schedule;

import cn.hutool.core.util.StrUtil;
import com.fdkankan.redis.constant.RedisKey;
import com.fdkankan.redis.constant.RedisLockKey;
import com.fdkankan.redis.util.RedisLockUtil;
import com.fdkankan.redis.util.RedisUtil;
import com.fdkankan.scene.service.ISceneAsynOperLogService;
import com.fdkankan.scene.service.ISceneCleanOrigService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

@RefreshScope
@Log4j2
@Component
public class ScheduleJob {

    @Value("${environment:#{null}}")
    private String environment;

    @Autowired
    private ISceneAsynOperLogService sceneAsynOperLogService;
    @Autowired
    private ISceneCleanOrigService sceneCleanOrigService;
    @Autowired
    private RedisLockUtil redisLockUtil;

    /**
     * 每天凌晨一点执行
     */
    @Scheduled(cron="0 0 1 * * ?")
    public void cleanDownloadPanorama() {
        log.info("定时清除全景图压缩包开始");
        sceneAsynOperLogService.cleanDownloadPanorama();
        log.info("定时清除全景图压缩包完毕");
    }

//    /**
//     * 删除场景原始资源
//     * 每天凌晨执行
//     */
//    @Scheduled(cron="0 0 1 * * ?")
//    public void cleanOssHomeV3() {
//        log.info("删除v3场景原始资源开始");
//        String lockKey = RedisLockKey.LOCK_CLEAN_SCENE_ORIG_V3;
//        try {
//            boolean lock = redisLockUtil.lock(lockKey, 24*60*60);
//            if(!lock){
//                return;
//            }
//            sceneCleanOrigService.cleanOrigV3();
//        }finally {
//            redisLockUtil.unlockLua(lockKey);
//        }
//        log.info("删除v3场景原始资源结束");
//    }
//
//    /**
//     * 删除场景原始资源
//     * 每天凌晨执行
//     */
//    @Scheduled(cron="0 0 1 * * ?")
//    public void cleanOssHomeV4() {
//        log.info("删除v4场景原始资源开始");
//        String lockKey = RedisLockKey.LOCK_CLEAN_SCENE_ORIG_V4;
//        try {
//            boolean lock = redisLockUtil.lock(lockKey, 24*60*60);
//            if(!lock){
//                return;
//            }
//            sceneCleanOrigService.cleanOrigV4();
//        }finally {
//            redisLockUtil.unlockLua(lockKey);
//        }
//        log.info("删除v4场景原始资源结束");
//    }

    /**
     * 删除已删除场景原始资源及caches
     * 每天凌晨执行
     */
    @PostConstruct
    @Scheduled(cron="0 0 1 * * ?")
    public void cleanOss4DeletedSceneV3() {
        log.info("删除已删除V3场景原始资源开始");
        String lockKey = RedisLockKey.LOCK_CLEAN_SCENE_DELETED_ORIG_V3;
        try {
            boolean lock = redisLockUtil.lock(lockKey, 24*60*60);
            if(!lock){
                return;
            }
            sceneCleanOrigService.cleanOss4DeletedSceneV3();
        }finally {
            redisLockUtil.unlockLua(lockKey);
        }
        log.info("删除已删除V3场景原始资源结束");
    }


    /**
     * 删除已删除场景原始资源及caches
     * 每天凌晨执行
     */
    @PostConstruct
    @Scheduled(cron="0 0 1 * * ?")
    public void cleanOss4DeletedSceneV4() {
        log.info("删除已删除V4场景原始资源开始");
        String lockKey = RedisLockKey.LOCK_CLEAN_SCENE_DELETED_ORIG_V4;
        try {
            boolean lock = redisLockUtil.lock(lockKey, 24*60*60);
            if(!lock){
                return;
            }
            sceneCleanOrigService.cleanOss4DeletedSceneV4();
        }finally {
            redisLockUtil.unlockLua(lockKey);
        }
        log.info("删除已删除V4场景原始资源结束");
    }

//    /**
//     * 删除测试相机场景原始资源及caches
//     * 每天凌晨执行
//     */
//    @Scheduled(cron="0 0 1 * * ?")
//    public void cleanOss4TestCameraV3() {
//        if(StrUtil.isEmpty(environment) || !environment.equals("dev")){
//            return;
//        }
//        log.info("删除已删除V4场景原始资源开始");
//        sceneCleanOrigService.cleanOss4TestCameraV3();
//        log.info("删除已删除V4场景原始资源结束");
//    }
//
//
//    /**
//     * 删除测试相机场景原始资源及caches
//     * 每天凌晨执行
//     */
//    @Scheduled(cron="0 0 1 * * ?")
//    public void cleanOss4TestCameraV4() {
//        if(StrUtil.isEmpty(environment) || !environment.equals("dev")){
//            return;
//        }
//        log.info("删除已删除V4场景原始资源开始");
//        sceneCleanOrigService.cleanOss4TestCameraV4();
//        log.info("删除已删除V4场景原始资源结束");
//    }
}