Commit 895a9f4f by huangfusuper

修正前端的BUG

parent 61d4c8f8
...@@ -16,6 +16,8 @@ import java.util.List; ...@@ -16,6 +16,8 @@ import java.util.List;
@Repository @Repository
public interface JobTaskRunLogMapper { public interface JobTaskRunLogMapper {
public List<JobTaskRunLogWithBLOBs> findAllByType(@Param("type") Integer type,@Param("jobName") String jobName);
List<JobTaskRunLog> findImmediatelyNode(String nodeName); List<JobTaskRunLog> findImmediatelyNode(String nodeName);
/** /**
* 查询没有结束的节点 * 查询没有结束的节点
......
package com.byit.model.vo; package com.byit.model.vo;
import com.byit.dto.plugin.JavaTask; import com.byit.dto.plugin.JavaTask;
import com.byit.dto.plugin.JobTaskRunLog;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
...@@ -9,7 +10,7 @@ import lombok.EqualsAndHashCode; ...@@ -9,7 +10,7 @@ import lombok.EqualsAndHashCode;
*/ */
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
@Data @Data
public class JavaTaskLogImportantVo extends JavaTask { public class JavaTaskLogImportantVo extends JobTaskRunLog {
private String rowKey; private String rowKey;
private boolean hasChildren; private boolean hasChildren;
} }
...@@ -14,6 +14,8 @@ import java.util.List; ...@@ -14,6 +14,8 @@ import java.util.List;
**/ **/
public interface JobTaskRunLogService { public interface JobTaskRunLogService {
List<JobTaskRunLogWithBLOBs> findAllByType(Integer type,String jobName);
List<JobTaskRunLog> findImmediatelyNode(String nodeName); List<JobTaskRunLog> findImmediatelyNode(String nodeName);
List<RunLogVo> findNodeLogByHandlerName(String handlerName); List<RunLogVo> findNodeLogByHandlerName(String handlerName);
......
...@@ -2,8 +2,10 @@ package com.byit.service.impl; ...@@ -2,8 +2,10 @@ package com.byit.service.impl;
import com.byit.dto.plugin.JavaTask; import com.byit.dto.plugin.JavaTask;
import com.byit.mapper.JavaTaskMapper; import com.byit.mapper.JavaTaskMapper;
import com.byit.model.JobTaskRunLogWithBLOBs;
import com.byit.model.vo.JavaTaskLogImportantVo; import com.byit.model.vo.JavaTaskLogImportantVo;
import com.byit.service.JavaTaskService; import com.byit.service.JavaTaskService;
import com.byit.service.JobTaskRunLogService;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -17,9 +19,11 @@ import java.util.stream.Collectors; ...@@ -17,9 +19,11 @@ import java.util.stream.Collectors;
@Service @Service
public class JavaTaskServiceImpl implements JavaTaskService { public class JavaTaskServiceImpl implements JavaTaskService {
private final JavaTaskMapper javaTaskMapper; private final JavaTaskMapper javaTaskMapper;
private final JobTaskRunLogService jobTaskRunLogService;
public JavaTaskServiceImpl(JavaTaskMapper javaTaskMapper) { public JavaTaskServiceImpl(JavaTaskMapper javaTaskMapper, JobTaskRunLogService jobTaskRunLogService) {
this.javaTaskMapper = javaTaskMapper; this.javaTaskMapper = javaTaskMapper;
this.jobTaskRunLogService = jobTaskRunLogService;
} }
@Override @Override
...@@ -29,12 +33,12 @@ public class JavaTaskServiceImpl implements JavaTaskService { ...@@ -29,12 +33,12 @@ public class JavaTaskServiceImpl implements JavaTaskService {
@Override @Override
public List<JavaTaskLogImportantVo> findAllJavaTaskLogImportantVo(String jobName) { public List<JavaTaskLogImportantVo> findAllJavaTaskLogImportantVo(String jobName) {
List<JavaTask> javaTasks = this.findAll(jobName); List<JobTaskRunLogWithBLOBs> allByType = jobTaskRunLogService.findAllByType(5, jobName);
return javaTasks.stream().map(javaTask -> { return allByType.stream().map(javaTaskLog -> {
JavaTaskLogImportantVo javaTaskLogImportantVo = new JavaTaskLogImportantVo(); JavaTaskLogImportantVo javaTaskLogImportantVo = new JavaTaskLogImportantVo();
javaTaskLogImportantVo.setRowKey(UUID.randomUUID().toString().replace("-","")); javaTaskLogImportantVo.setRowKey(UUID.randomUUID().toString().replace("-",""));
javaTaskLogImportantVo.setHasChildren(true); javaTaskLogImportantVo.setHasChildren(true);
BeanUtils.copyProperties(javaTask,javaTaskLogImportantVo); BeanUtils.copyProperties(javaTaskLog,javaTaskLogImportantVo);
return javaTaskLogImportantVo; return javaTaskLogImportantVo;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
} }
......
...@@ -41,6 +41,12 @@ public class JobTaskRunLogServiceImpl implements JobTaskRunLogService { ...@@ -41,6 +41,12 @@ public class JobTaskRunLogServiceImpl implements JobTaskRunLogService {
} }
@Override @Override
public List<JobTaskRunLogWithBLOBs> findAllByType(Integer type,String jobName) {
return jobTaskRunLogMapper.findAllByType(type,jobName);
}
@Override
public List<JobTaskRunLog> findImmediatelyNode(String nodeName) { public List<JobTaskRunLog> findImmediatelyNode(String nodeName) {
return jobTaskRunLogMapper.findImmediatelyNode(nodeName); return jobTaskRunLogMapper.findImmediatelyNode(nodeName);
} }
......
...@@ -62,6 +62,17 @@ ...@@ -62,6 +62,17 @@
</foreach> </foreach>
</select> </select>
<select id="findAllByType" resultMap="ResultMapWithBLOBs">
select
<include refid="Base_Column_List" />
,
<include refid="Blob_Column_List" />
from job_task_run_log where schedule_type = #{type}
<if test="jobName != null and jobName != ''">
node_name = #{jobName}
</if>
</select>
<select id="findImmediatelyNode" resultMap="ResultMapWithBLOBs"> <select id="findImmediatelyNode" resultMap="ResultMapWithBLOBs">
select select
<include refid="Base_Column_List" /> <include refid="Base_Column_List" />
......
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