From 7866f81d8becf2c28412c0181948be48b620a113 Mon Sep 17 00:00:00 2001 From: tianwenbo Date: Fri, 10 Mar 2023 13:45:55 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=20sonar=E3=80=91=20JobInfoControll?= =?UTF-8?q?er.java=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/controller/JobInfoController.java | 40 +++++++++---------- 1 file changed, 20 insertions(+), 20 deletions(-) diff --git a/jero-boot/jero-cloud-module/jero-cloud-xxljob/src/main/java/com/xxl/job/admin/controller/JobInfoController.java b/jero-boot/jero-cloud-module/jero-cloud-xxljob/src/main/java/com/xxl/job/admin/controller/JobInfoController.java index 3cf8029a..96c631f4 100644 --- a/jero-boot/jero-cloud-module/jero-cloud-xxljob/src/main/java/com/xxl/job/admin/controller/JobInfoController.java +++ b/jero-boot/jero-cloud-module/jero-cloud-xxljob/src/main/java/com/xxl/job/admin/controller/JobInfoController.java @@ -39,7 +39,7 @@ public class JobInfoController { private XxlJobGroupDao xxlJobGroupDao; @Resource private XxlJobService xxlJobService; - + @RequestMapping public String index(HttpServletRequest request, Model model, @RequestParam(required = false, defaultValue = "-1") int jobGroup) { @@ -49,11 +49,11 @@ public class JobInfoController { model.addAttribute("ExecutorBlockStrategyEnum", ExecutorBlockStrategyEnum.values()); // 阻塞处理策略-字典 // 执行器列表 - List jobGroupList_all = xxlJobGroupDao.findAll(); + List jobGroupListAll = xxlJobGroupDao.findAll(); // filter group - List jobGroupList = filterJobGroupByRole(request, jobGroupList_all); - if (jobGroupList==null || jobGroupList.size()==0) { + List jobGroupList = filterJobGroupByRole(request, jobGroupListAll); + if (!jobGroupList.isEmpty()) { throw new XxlJobException(I18nUtil.getString("jobgroup_empty")); } @@ -63,18 +63,18 @@ public class JobInfoController { return "jobinfo/jobinfo.index"; } - public static List filterJobGroupByRole(HttpServletRequest request, List jobGroupList_all){ + public static List filterJobGroupByRole(HttpServletRequest request, List jobGroupListAll){ List jobGroupList = new ArrayList<>(); - if (jobGroupList_all!=null && jobGroupList_all.size()>0) { + if (jobGroupListAll!=null && !jobGroupListAll.isEmpty()) { XxlJobUser loginUser = (XxlJobUser) request.getAttribute(LoginService.LOGIN_IDENTITY_KEY); if (loginUser.getRole() == 1) { - jobGroupList = jobGroupList_all; + jobGroupList = jobGroupListAll; } else { List groupIdStrs = new ArrayList<>(); if (loginUser.getPermission()!=null && loginUser.getPermission().trim().length()>0) { groupIdStrs = Arrays.asList(loginUser.getPermission().trim().split(",")); } - for (XxlJobGroup groupItem:jobGroupList_all) { + for (XxlJobGroup groupItem:jobGroupListAll) { if (groupIdStrs.contains(String.valueOf(groupItem.getId()))) { jobGroupList.add(groupItem); } @@ -89,46 +89,46 @@ public class JobInfoController { throw new RuntimeException(I18nUtil.getString("system_permission_limit") + "[username="+ loginUser.getUsername() +"]"); } } - + @RequestMapping("/pageList") @ResponseBody - public Map pageList(@RequestParam(required = false, defaultValue = "0") int start, + public Map pageList(@RequestParam(required = false, defaultValue = "0") int start, @RequestParam(required = false, defaultValue = "10") int length, int jobGroup, int triggerStatus, String jobDesc, String executorHandler, String author) { - + return xxlJobService.pageList(start, length, jobGroup, triggerStatus, jobDesc, executorHandler, author); } - + @RequestMapping("/add") @ResponseBody public ReturnT add(XxlJobInfo jobInfo) { return xxlJobService.add(jobInfo); } - + @RequestMapping("/update") @ResponseBody public ReturnT update(XxlJobInfo jobInfo) { return xxlJobService.update(jobInfo); } - + @RequestMapping("/remove") @ResponseBody public ReturnT remove(int id) { return xxlJobService.remove(id); } - + @RequestMapping("/stop") @ResponseBody public ReturnT pause(int id) { return xxlJobService.stop(id); } - + @RequestMapping("/start") @ResponseBody public ReturnT start(int id) { return xxlJobService.start(id); } - + @RequestMapping("/trigger") @ResponseBody //@PermissionLimit(limit = false) @@ -158,9 +158,9 @@ public class JobInfoController { } } } catch (ParseException e) { - return new ReturnT>(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid")); + return new ReturnT<>(ReturnT.FAIL_CODE, I18nUtil.getString("jobinfo_field_cron_unvalid")); } - return new ReturnT>(result); + return new ReturnT<>(result); } - + }