|
@@ -58,7 +58,7 @@ public class MaterialUploadTaskServiceImpl
|
|
@Autowired private MaterialUploadTaskMapper materialUploadTaskMapper;
|
|
@Autowired private MaterialUploadTaskMapper materialUploadTaskMapper;
|
|
private static String downloadUrl = "/data/file/video/";
|
|
private static String downloadUrl = "/data/file/video/";
|
|
// private static String downloadUrl = "D:\\file";
|
|
// private static String downloadUrl = "D:\\file";
|
|
- private static ExecutorService kuaishouExecutorService = Executors.newFixedThreadPool(4);
|
|
|
|
|
|
+ private static ExecutorService kuaishouExecutorService = Executors.newFixedThreadPool(3);
|
|
private static ExecutorService bytedanceExecutorService = Executors.newFixedThreadPool(5);
|
|
private static ExecutorService bytedanceExecutorService = Executors.newFixedThreadPool(5);
|
|
private static ExecutorService submitExecutorService = Executors.newFixedThreadPool(5);
|
|
private static ExecutorService submitExecutorService = Executors.newFixedThreadPool(5);
|
|
|
|
|
|
@@ -175,6 +175,7 @@ public class MaterialUploadTaskServiceImpl
|
|
materialUploadTaskMapper.updateStatusById(
|
|
materialUploadTaskMapper.updateStatusById(
|
|
task.getId(), 0, "返回结果为空-待重试", new Date());
|
|
task.getId(), 0, "返回结果为空-待重试", new Date());
|
|
}
|
|
}
|
|
|
|
+ Thread.sleep(1000L);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
materialUploadTaskMapper.updateStatusById(task.getId(), 0, "接口异常-待重试", new Date());
|
|
materialUploadTaskMapper.updateStatusById(task.getId(), 0, "接口异常-待重试", new Date());
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|