|
|
@@ -33,6 +33,7 @@ import java.util.Date;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* index controller
|
|
|
@@ -110,6 +111,11 @@ public class JobLogController {
|
|
|
|
|
|
// page query
|
|
|
List<XxlJobLog> list = xxlJobLogDao.pageList(start, length, jobGroup, jobId, triggerTimeStart, triggerTimeEnd, logStatus);
|
|
|
+ if (list != null && !list.isEmpty()) {
|
|
|
+ List<XxlJobGroup> groupList = xxlJobGroupDao.findAll();
|
|
|
+ Map<Integer, String> groupMap = groupList.stream().parallel().collect(Collectors.toMap(XxlJobGroup::getId, XxlJobGroup::getTitle));
|
|
|
+ list.stream().filter(l -> groupMap.containsKey(l.getJobGroup())).forEach(l -> l.setJobTitle(groupMap.get(l.getJobGroup())));
|
|
|
+ }
|
|
|
int list_count = xxlJobLogDao.pageListCount(start, length, jobGroup, jobId, triggerTimeStart, triggerTimeEnd, logStatus);
|
|
|
|
|
|
// package result
|