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场景原始资源结束"); // } }