|
@@ -9,6 +9,7 @@ import cn.hutool.json.JSONObject;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import jakarta.annotation.Resource;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.eco.als.domain.DataImport;
|
|
|
import org.eco.als.domain.FaultDiagnosis;
|
|
|
import org.eco.als.domain.LifePrediction;
|
|
|
import org.eco.als.domain.PreProcessing;
|
|
@@ -69,6 +70,8 @@ public class AlgorithmService implements IAlgorithmService {
|
|
|
|
|
|
@Resource
|
|
|
private IFormulaService formulaService;
|
|
|
+ @Resource
|
|
|
+ private IDataImportService dataImportService;
|
|
|
|
|
|
@Value("${kgqa.ask-url}")
|
|
|
private String askUrl;
|
|
@@ -150,6 +153,10 @@ public class AlgorithmService implements IAlgorithmService {
|
|
|
if (ObjectUtil.isEmpty(algorithmBo.getOssId())) {
|
|
|
throw new BusinessException("OssId不能为空!");
|
|
|
}
|
|
|
+ if (ObjectUtil.isEmpty(algorithmBo.getDataId())) {
|
|
|
+ throw new BusinessException("dataId不能为空!");
|
|
|
+ }
|
|
|
+
|
|
|
warningBo.setSortieNo(algorithmBo.getSortieNo());
|
|
|
// 警告列表
|
|
|
List<WarningVo> warningList = warningService.selectList(warningBo);
|
|
@@ -166,6 +173,10 @@ public class AlgorithmService implements IAlgorithmService {
|
|
|
.build();
|
|
|
falseAlarmResultService.insert(falseAlarmResultBo);
|
|
|
});
|
|
|
+ DataImport dataImport = new DataImport();
|
|
|
+ dataImport.setId(algorithmBo.getDataId());
|
|
|
+ dataImport.setStatus("4");
|
|
|
+ dataImportService.updateById(dataImport);
|
|
|
}
|
|
|
|
|
|
/**
|