|
@@ -53,6 +53,7 @@ import org.springframework.transaction.annotation.Transactional;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
import java.util.concurrent.ExecutorService;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
import static edp.davinci.core.common.Constants.DAVINCI_TOPIC_CHANNEL;
|
|
|
|
|
@@ -108,7 +109,12 @@ public class CronJobServiceImpl extends BaseEntityService implements CronJobServ
|
|
|
*/
|
|
|
@Override
|
|
|
public List<CronJob> getCronJobs(Long projectId, User user) {
|
|
|
- return checkReadPermission(entity, projectId, user) == true ? cronJobMapper.getByProject(projectId) : null;
|
|
|
+ List<CronJob> cronJobs = checkReadPermission(entity, projectId, user) == true ? cronJobMapper.getByProject(projectId) : null;
|
|
|
+
|
|
|
+// cronJobs = cronJobs.stream()
|
|
|
+// .filter(Collectors.partitioningBy(p -> !"John".equals(p.getJobType())));
|
|
|
+
|
|
|
+ return cronJobs;
|
|
|
// return cronJobMapper.getByProject(projectId);
|
|
|
}
|
|
|
|