|
@@ -8,6 +8,7 @@ import com.xxl.job.admin.core.trigger.XxlJobTrigger;
|
8
|
8
|
import com.xxl.job.admin.dao.XxlJobInfoDao;
|
9
|
9
|
import com.xxl.job.admin.dao.XxlJobLogDao;
|
10
|
10
|
import com.xxl.job.admin.dao.XxlJobRegistryDao;
|
|
11
|
+import com.xxl.job.admin.service.XxlJobService;
|
11
|
12
|
import com.xxl.job.core.biz.AdminBiz;
|
12
|
13
|
import com.xxl.job.core.biz.model.HandleCallbackParam;
|
13
|
14
|
import com.xxl.job.core.biz.model.RegistryParam;
|
|
@@ -36,6 +37,9 @@ public class AdminBizImpl implements AdminBiz {
|
36
|
37
|
private XxlJobInfoDao xxlJobInfoDao;
|
37
|
38
|
@Resource
|
38
|
39
|
private XxlJobRegistryDao xxlJobRegistryDao;
|
|
40
|
+ @Resource
|
|
41
|
+ private XxlJobService xxlJobService;
|
|
42
|
+
|
39
|
43
|
|
40
|
44
|
@Override
|
41
|
45
|
public ReturnT<String> callback(List<HandleCallbackParam> callbackParamList) {
|
|
@@ -127,9 +131,7 @@ public class AdminBizImpl implements AdminBiz {
|
127
|
131
|
|
128
|
132
|
@Override
|
129
|
133
|
public ReturnT<String> triggerJob(int jobId) {
|
130
|
|
- // TODO (thread queue trigger)
|
131
|
|
-
|
132
|
|
- return ReturnT.SUCCESS;
|
|
134
|
+ return xxlJobService.triggerJob(jobId);
|
133
|
135
|
}
|
134
|
136
|
|
135
|
137
|
}
|