|
@@ -39,13 +39,13 @@ public class Job {
|
|
|
|
|
|
@Scheduled(initialDelay = 2*10*1000, fixedDelay = 10*60*1000)
|
|
|
public void push(){
|
|
|
- Map<String, Object> lockMap = redisClient.lockLeaseTime(Constant.REDIS_LOCK_SCENE_CONVERT, 30 * 60 * 1000);
|
|
|
- boolean lock = (Boolean) lockMap.get("lock");
|
|
|
- if(!lock){
|
|
|
- return;
|
|
|
- }
|
|
|
- String uniqueFlag = (String) lockMap.get("uniqueFlag");
|
|
|
- try {
|
|
|
+// Map<String, Object> lockMap = redisClient.lockLeaseTime(Constant.REDIS_LOCK_SCENE_CONVERT, 30 * 60 * 1000);
|
|
|
+// boolean lock = (Boolean) lockMap.get("lock");
|
|
|
+// if(!lock){
|
|
|
+// return;
|
|
|
+// }
|
|
|
+// String uniqueFlag = (String) lockMap.get("uniqueFlag");
|
|
|
+// try {
|
|
|
String startTimeStr = redisClient.get(Constant.REDIS_SCENE_CONVERT_STARTTIME);
|
|
|
if(StrUtil.isEmpty(startTimeStr)){
|
|
|
startTimeStr = "2024-09-01 00:00:00";
|
|
@@ -72,11 +72,11 @@ public class Job {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- }finally {
|
|
|
- if(lock){
|
|
|
- redisClient.unLock(Constant.REDIS_LOCK_SCENE_CONVERT, uniqueFlag);
|
|
|
- }
|
|
|
- }
|
|
|
+// }finally {
|
|
|
+// if(lock){
|
|
|
+// redisClient.unLock(Constant.REDIS_LOCK_SCENE_CONVERT, uniqueFlag);
|
|
|
+// }
|
|
|
+// }
|
|
|
}
|
|
|
|
|
|
}
|