|
|
@ -70,9 +70,8 @@ public class AnalysisTaskServiceImpl extends ServiceImpl<AnalyzeTaskMapper, Anal |
|
|
|
retryGetDecompressionFlag(analysisTask); |
|
|
|
retryGetDecompressionFlag(analysisTask); |
|
|
|
|
|
|
|
|
|
|
|
//开始分析前,将成分分析的状态为 进行中
|
|
|
|
//开始分析前,将成分分析的状态为 进行中
|
|
|
|
analysisTask.setComposeFlag(AnalysisStatusEnum.ANALYSISING.getCode()); |
|
|
|
|
|
|
|
LambdaUpdateWrapper<AnalysisTask> updateWrapper = new LambdaUpdateWrapper<>(); |
|
|
|
LambdaUpdateWrapper<AnalysisTask> updateWrapper = new LambdaUpdateWrapper<>(); |
|
|
|
updateWrapper.set(AnalysisTask::getId, analysisTask.getId()) |
|
|
|
updateWrapper.eq(AnalysisTask::getId, analysisTask.getId()) |
|
|
|
.set(AnalysisTask::getComposeFlag, AnalysisStatusEnum.ANALYSISING.getCode()); |
|
|
|
.set(AnalysisTask::getComposeFlag, AnalysisStatusEnum.ANALYSISING.getCode()); |
|
|
|
this.update(null,updateWrapper); |
|
|
|
this.update(null,updateWrapper); |
|
|
|
MongoTemplate mongoTemplate = new MongoTemplate(mongoClient, MongoDBConst.DB_NAME_PREFIX + analysisTask.getId()); |
|
|
|
MongoTemplate mongoTemplate = new MongoTemplate(mongoClient, MongoDBConst.DB_NAME_PREFIX + analysisTask.getId()); |
|
|
|