数据处理任务 异步 修改

This commit is contained in:
limin 2024-12-31 19:09:37 +08:00
parent 04ffbde6d3
commit 8c8274d2ee

View File

@ -72,11 +72,11 @@ public class AsyncDataProcessService {
answerDO.setId(null);
answerDO.setDatasetId(dataProcessTask.getDatasetPostId());
datasetAnswerMapper.insert(answerDO);
dataProcessTaskMapper.updateStatus(dataProcessTask.getId(), 2);
});
}
});
}
dataProcessTaskMapper.updateStatus(dataProcessTask.getId(), 2);
}catch(Exception e){
datasetQuestionMapper.deleteTrue(dataProcessTask.getDatasetPostId());
datasetAnswerMapper.deleteTrue(dataProcessTask.getDatasetPostId());