|
@@ -152,6 +152,10 @@ public class TDataProcessServiceImpl implements ITDataProcessService {
|
|
|
logger.warn("无法查找到该DataProcess的数据,id:{},algConfig:{},data:{},bizAlgType:{}", id, algConfig, data, bizAlgType);
|
|
|
errorMsg = "数据有残缺";
|
|
|
} else {
|
|
|
+ dataProcess.setProcessStatus("2");
|
|
|
+ dataProcess.setStartTime(new Date());
|
|
|
+ dataProcess.setEndTime(null);
|
|
|
+ this.updateTDataProcess(dataProcess);
|
|
|
// 异步调用
|
|
|
ITDataProcessService proxy = applicationContext.getBean(ITDataProcessService.class);
|
|
|
proxy.asyncRunDataProcess(dataProcess, algConfig, data, bizAlgType);
|
|
@@ -167,10 +171,7 @@ public class TDataProcessServiceImpl implements ITDataProcessService {
|
|
|
@Transactional
|
|
|
public void asyncRunDataProcess(TDataProcess dataProcess, AlgConfig algConfig, Data data, String bizAlgType) {
|
|
|
// 状态设置为处理中
|
|
|
- dataProcess.setProcessStatus("2");
|
|
|
- dataProcess.setStartTime(new Date());
|
|
|
- dataProcess.setEndTime(null);
|
|
|
- this.updateTDataProcess(dataProcess);
|
|
|
+
|
|
|
process(dataProcess, algConfig, data, bizAlgType);
|
|
|
}
|
|
|
|