Commit edf3d434 by huangfusuper

记录runNode方法日志

parent d0801ab0
......@@ -6,7 +6,6 @@ import com.byit.dto.plugin.JavaTask;
import com.byit.dto.plugin.RunLog;
import com.byit.dto.plugin.RunNode;
import com.byit.enums.NodePropertyEnum;
import com.byit.enums.NodeTypeEnum;
import com.byit.enums.PlaceholderEnum;
import com.byit.enums.ScheduleTypeEnum;
import com.byit.job.WorkRoulette;
......@@ -19,6 +18,7 @@ import com.byit.model.JobTaskRunLog;
import com.byit.model.JobTaskRunLogWithBLOBs;
import com.byit.model.JobTaskSchedule;
import com.byit.service.ApiNodeService;
import com.byit.service.JobTaskRunLogService;
import com.byit.task.JavaTaskJobTask;
import com.byit.task.ScriptExecutorJobTask;
import com.byit.utils.ValidationUtil;
......@@ -31,7 +31,6 @@ import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.text.ParseException;
import java.util.*;
import static com.alibaba.fastjson.serializer.SerializerFeature.WriteClassName;
......@@ -46,12 +45,18 @@ public class ApiNodeServiceImpl implements ApiNodeService {
@Resource
private JobTaskRunLogMapper jobTaskRunLogMapper;
private final JobTaskRunLogService jobTaskRunLogService;
@Resource
private StringRedisTemplate stringRedisTemplate;
@Resource
private JavaTaskMapper javaTaskMapper;
public ApiNodeServiceImpl(JobTaskRunLogService jobTaskRunLogService) {
this.jobTaskRunLogService = jobTaskRunLogService;
}
@Override
public String runNode(String param) {
......@@ -91,7 +96,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
JobTaskRunLogWithBLOBs jobTaskRunLog = new JobTaskRunLogWithBLOBs();
BeanUtils.copyProperties(schedule, jobTaskRunLog);
jobTaskRunLogMapper.saveJobTaskRunLog(jobTaskRunLog);
jobTaskRunLogService.saveJobTaskRunLog(jobTaskRunLog);
//获取日志id
Integer logId= jobTaskRunLog.getLogId();
//设置日志id
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment