etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改超时时间

master
Cui YongXing 2024-09-10 15:00:13 +08:00
parent e0a92000ab
commit 825ddaf79e
1 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -409,25 +409,28 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
DataValueRows dataValueRows = new DataValueRows(); DataValueRows dataValueRows = new DataValueRows();
dataValueRows.setDataValue(prevResult); dataValueRows.setDataValue(prevResult);
dataValueRows.setKey(nodeRule.getConfig()); dataValueRows.setKey(nodeRule.getConfig());
ruleConfig.DataSetEngine(data.getClassName(),dataValueRows); Result<DataValue[][]> result1 = ruleConfig.DataSetEngine(data.getClassName(), dataValueRows);
if (result1.getCode() == 200) {
prevResult = result1.getData();
}
} }
if (data.getRuleId().equals("1")) { if (data.getRuleId().equals("1")) {
for (DataValue[] values : prevResult) { for (int i = 0; i < prevResult.length; i++) {
for (DataValue value : values) { for (DataValue value : prevResult[i]) {
//log.info(value.getValue()); //log.info(value.getValue());
try {
DataValueFie dataValueFie = new DataValueFie(); DataValueFie dataValueFie = new DataValueFie();
dataValueFie.setDataValue(value); dataValueFie.setDataValue(value);
dataValueFie.setKey(nodeRule.getConfig()); dataValueFie.setKey(nodeRule.getConfig());
//DataValue dataValue = loadEngineClass.testEngine(data.getClassName(), value); //DataValue dataValue = loadEngineClass.testEngine(data.getClassName(), value);
Result<DataValue> dataValueResult = ruleConfig.testEngine(data.getClassName(), dataValueFie); Result<DataValue> dataValueResult = ruleConfig.testEngine(data.getClassName(), dataValueFie);
DataValue data1 = dataValueResult.getData(); if (dataValueResult.getCode() == 200) {
value=data1; DataValue data1 = dataValueResult.getData();
} catch (Exception e) { value = data1;
log.error(e.getMessage()); }else {
set.add(i);
}
} }
} }
}
} }
if (data.getRuleId().equals("2")) { if (data.getRuleId().equals("2")) {
@ -436,10 +439,10 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
valueRow.setDataValue(prevResult[i]); valueRow.setDataValue(prevResult[i]);
valueRow.setKey(nodeRule.getConfig()); valueRow.setKey(nodeRule.getConfig());
Result<DataValue[]> result1 = ruleConfig.testEngine(data.getClassName(), valueRow); Result<DataValue[]> result1 = ruleConfig.testEngine(data.getClassName(), valueRow);
if (result1.getCode()==200){ if (result1.getCode() == 200) {
DataValue[] result1Data = result1.getData(); DataValue[] result1Data = result1.getData();
prevResult[i]=result1Data; prevResult[i] = result1Data;
}else { } else {
set.add(i); set.add(i);
} }
} }