|
|
@ -2,6 +2,7 @@ package com.keyware.composeanalysis.service.impl; |
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.date.DateUnit; |
|
|
|
import cn.hutool.core.date.DateUnit; |
|
|
|
import cn.hutool.core.date.DateUtil; |
|
|
|
import cn.hutool.core.date.DateUtil; |
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|
|
|
import com.keyware.common.constant.RedisConst; |
|
|
|
import com.keyware.common.constant.RedisConst; |
|
|
|
import com.keyware.common.constant.enums.AnalysisStatusEnum; |
|
|
|
import com.keyware.common.constant.enums.AnalysisStatusEnum; |
|
|
@ -69,8 +70,11 @@ public class AnalysisTaskServiceImpl extends ServiceImpl<AnalyzeTaskMapper, Anal |
|
|
|
retryGetDecompressionFlag(analysisTask); |
|
|
|
retryGetDecompressionFlag(analysisTask); |
|
|
|
|
|
|
|
|
|
|
|
//开始分析前,将成分分析的状态为 进行中
|
|
|
|
//开始分析前,将成分分析的状态为 进行中
|
|
|
|
analysisTask.setComposeFlag(AnalysisStatusEnum.ANALYSISING.getCode()); |
|
|
|
LambdaUpdateWrapper<AnalysisTask> updateWrapper = new LambdaUpdateWrapper<>(); |
|
|
|
this.updateById(analysisTask); |
|
|
|
updateWrapper.eq(AnalysisTask::getId, analysisTask.getId()) |
|
|
|
|
|
|
|
.set(AnalysisTask::getComposeFlag, AnalysisStatusEnum.ANALYSISING.getCode()); |
|
|
|
|
|
|
|
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()); |
|
|
|
AnalysisLogUtil.insert(mongoTemplate, "【成分分析】开始:" + analysisTask.getFileName()); |
|
|
|
AnalysisLogUtil.insert(mongoTemplate, "【成分分析】开始:" + analysisTask.getFileName()); |
|
|
|
|
|
|
|
|
|
|
@ -85,8 +89,10 @@ public class AnalysisTaskServiceImpl extends ServiceImpl<AnalyzeTaskMapper, Anal |
|
|
|
checkProjectIfOpen(mongoTemplate,analysisTask); |
|
|
|
checkProjectIfOpen(mongoTemplate,analysisTask); |
|
|
|
|
|
|
|
|
|
|
|
//修改成分分析状态为完成
|
|
|
|
//修改成分分析状态为完成
|
|
|
|
analysisTask.setComposeFlag(AnalysisStatusEnum.ANALYSIS_DONE.getCode()); |
|
|
|
updateWrapper.eq(AnalysisTask::getId, analysisTask.getId()) |
|
|
|
this.updateById(analysisTask); |
|
|
|
.set(AnalysisTask::getComposeFlag, AnalysisStatusEnum.ANALYSIS_DONE.getCode()) |
|
|
|
|
|
|
|
.set(AnalysisTask::getOpenType, analysisTask.getOpenType()); |
|
|
|
|
|
|
|
this.update(null,updateWrapper); |
|
|
|
|
|
|
|
|
|
|
|
//插入分析日志
|
|
|
|
//插入分析日志
|
|
|
|
AnalysisLogUtil.insert(mongoTemplate,"【成分分析】已完成,耗时:"+ DateUtil.between(analysisTask.getAnalysisStartTime(),DateUtil.date(), DateUnit.SECOND) +"秒"); |
|
|
|
AnalysisLogUtil.insert(mongoTemplate,"【成分分析】已完成,耗时:"+ DateUtil.between(analysisTask.getAnalysisStartTime(),DateUtil.date(), DateUnit.SECOND) +"秒"); |
|
|
|