|
@@ -8,6 +8,7 @@ import com.fdkankan.manage.exception.BusinessException;
|
|
|
import com.fdkankan.manage.mq.param.SceneRestStoreVo;
|
|
|
import com.fdkankan.manage.service.ISceneColdStorageLogService;
|
|
|
import com.fdkankan.manage.service.ISceneColdStorageService;
|
|
|
+import com.fdkankan.manage.service.ISceneProService;
|
|
|
import com.fdkankan.manage.thread.ThreadService;
|
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
|
import com.rabbitmq.client.Channel;
|
|
@@ -41,6 +42,8 @@ public class SceneRestStoreConsumer {
|
|
|
ISceneColdStorageService sceneColdStorageService;
|
|
|
@Autowired
|
|
|
ISceneColdStorageLogService sceneColdStorageLogService;
|
|
|
+ @Autowired
|
|
|
+ ISceneProService sceneProService;
|
|
|
|
|
|
@RabbitListener(
|
|
|
queuesToDeclare = @Queue("${queue.scene.rest-store:scene-rest-store}"),
|
|
@@ -72,7 +75,7 @@ public class SceneRestStoreConsumer {
|
|
|
log.info("scene-restStore-mq-cloudBucket:{},bucket:{},folderName:{},process:{}",cloudBucket,bucket,folderName,process);
|
|
|
while (process != 100 ){
|
|
|
Long time = new Date().getTime();
|
|
|
- if(time - startTime >1000 * 60){
|
|
|
+ if(time - startTime >1000 * 60 * 10){
|
|
|
startTime = time;
|
|
|
process = fYunFileServiceInterface.getRestoreFolderProcess(cloudBucket, folderName);
|
|
|
log.info("scene-restStore-mq-cloudBucket:{},bucket:{},folderName:{},process:{}",cloudBucket,bucket,folderName,process);
|
|
@@ -82,6 +85,7 @@ public class SceneRestStoreConsumer {
|
|
|
log.info("Tscene-restStore-mq-copy-bucket");
|
|
|
sceneColdStorageService.updateStatus(num,2);
|
|
|
sceneColdStorageLogService.saveLog(num,folderName);
|
|
|
+ sceneProService.restStoreSuccess(num);
|
|
|
redisUtil.del(redisKey);
|
|
|
|
|
|
}catch (Exception e){
|