@@ -50,41 +50,56 @@ public class JobLogController {
50
50
public XxlJobLogMapper xxlJobLogMapper ;
51
51
52
52
@ RequestMapping
53
- public String index (HttpServletRequest request , Model model , @ RequestParam (value = "jobId" , required = false , defaultValue = "0" ) Integer jobId ) {
53
+ public String index (HttpServletRequest request , Model model ,
54
+ @ RequestParam (value = "jobGroup" , required = false , defaultValue = "0" ) Integer jobGroup ,
55
+ @ RequestParam (value = "jobId" , required = false , defaultValue = "0" ) Integer jobId ) {
54
56
55
- // 执行器列表
57
+ // find jobGroup
56
58
List <XxlJobGroup > jobGroupListTotal = xxlJobGroupMapper .findAll ();
57
-
58
- // filter group
59
+ // filter jobGroup
59
60
List <XxlJobGroup > jobGroupList = JobInfoController .filterJobGroupByPermission (request , jobGroupListTotal );
60
61
if (jobGroupList ==null || jobGroupList .isEmpty ()) {
61
62
throw new XxlJobException (I18nUtil .getString ("jobgroup_empty" ));
62
63
}
63
-
64
+ // write jobGroup
64
65
model .addAttribute ("JobGroupList" , jobGroupList );
65
66
66
- // 任务
67
+ // parse jobId、jobGroup
67
68
if (jobId > 0 ) {
68
69
XxlJobInfo jobInfo = xxlJobInfoMapper .loadById (jobId );
69
70
if (jobInfo == null ) {
70
71
throw new RuntimeException (I18nUtil .getString ("jobinfo_field_id" ) + I18nUtil .getString ("system_unvalid" ));
71
72
}
73
+ jobGroup = jobInfo .getJobGroup ();
74
+ } else if (jobGroup > 0 ){
75
+ jobId = 0 ;
76
+ }
77
+ jobGroup = jobGroup > 0 ? jobGroup : jobGroupList .get (0 ).getId ();
78
+ // valid permission
79
+ JobInfoController .validJobGroupPermission (request , jobGroup );
72
80
73
- model .addAttribute ("jobInfo" , jobInfo );
81
+ // find jobList
82
+ List <XxlJobInfo > jobInfoList = xxlJobInfoMapper .getJobsByGroup (jobGroup );
74
83
75
- // valid permission
76
- JobInfoController .validJobGroupPermission (request , jobInfo .getJobGroup ());
77
- }
84
+ // write
85
+ model .addAttribute ("jobInfoList" , jobInfoList );
86
+ model .addAttribute ("jobGroup" , jobGroup );
87
+ model .addAttribute ("jobId" , jobId );
78
88
79
89
return "joblog/joblog.index" ;
80
90
}
81
91
82
- @ RequestMapping ("/getJobsByGroup" )
92
+ /* @RequestMapping("/getJobsByGroup")
83
93
@ResponseBody
84
- public ReturnT <List <XxlJobInfo >> getJobsByGroup (@ RequestParam ("jobGroup" ) int jobGroup ){
94
+ public ReturnT<List<XxlJobInfo>> getJobsByGroup(HttpServletRequest request, @RequestParam("jobGroup") int jobGroup){
95
+
96
+ // valid permission
97
+ JobInfoController.validJobGroupPermission(request, jobGroup);
98
+
99
+ // query
85
100
List<XxlJobInfo> list = xxlJobInfoMapper.getJobsByGroup(jobGroup);
86
101
return ReturnT.ofSuccess(list);
87
- }
102
+ }*/
88
103
89
104
@ RequestMapping ("/pageList" )
90
105
@ ResponseBody
@@ -209,7 +224,7 @@ private String filter(String originData){
209
224
210
225
@ RequestMapping ("/logKill" )
211
226
@ ResponseBody
212
- public ReturnT <String > logKill (@ RequestParam ("id" ) int id ){
227
+ public ReturnT <String > logKill (HttpServletRequest request , @ RequestParam ("id" ) int id ){
213
228
// base check
214
229
XxlJobLog log = xxlJobLogMapper .load (id );
215
230
XxlJobInfo jobInfo = xxlJobInfoMapper .loadById (log .getJobId ());
@@ -220,6 +235,9 @@ public ReturnT<String> logKill(@RequestParam("id") int id){
220
235
return new ReturnT <String >(500 , I18nUtil .getString ("joblog_kill_log_limit" ));
221
236
}
222
237
238
+ // valid JobGroup permission
239
+ JobInfoController .validJobGroupPermission (request , jobInfo .getJobGroup ());
240
+
223
241
// request of kill
224
242
ReturnT <String > runResult = null ;
225
243
try {
@@ -247,7 +265,7 @@ public ReturnT<String> clearLog(HttpServletRequest request,
247
265
@ RequestParam ("jobGroup" ) int jobGroup ,
248
266
@ RequestParam ("jobId" ) int jobId ,
249
267
@ RequestParam ("type" ) int type ){
250
- // valid permission
268
+ // valid JobGroup permission
251
269
JobInfoController .validJobGroupPermission (request , jobGroup );
252
270
253
271
// opt
0 commit comments