Compare commits
2 Commits
bbacb8e1a0
...
afe6c34db7
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
afe6c34db7 | ||
|
|
300bb18b97 |
@ -20,7 +20,7 @@
|
|||||||
</content>
|
</content>
|
||||||
<orderEntry type="inheritedJdk" />
|
<orderEntry type="inheritedJdk" />
|
||||||
<orderEntry type="sourceFolder" forTests="false" />
|
<orderEntry type="sourceFolder" forTests="false" />
|
||||||
<orderEntry type="library" name="Maven: org.jetbrains:annotations:24.1.0" level="project" />
|
<orderEntry type="library" name="Maven: org.jetbrains:annotations:26.0.2" level="project" />
|
||||||
<orderEntry type="library" name="Maven: org.apache.commons:commons-compress:1.18" level="project" />
|
<orderEntry type="library" name="Maven: org.apache.commons:commons-compress:1.18" level="project" />
|
||||||
<orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.75" level="project" />
|
<orderEntry type="library" name="Maven: com.alibaba:fastjson:1.2.75" level="project" />
|
||||||
<orderEntry type="library" name="Maven: org.projectlombok:lombok:1.18.16" level="project" />
|
<orderEntry type="library" name="Maven: org.projectlombok:lombok:1.18.16" level="project" />
|
||||||
|
|||||||
@ -86,7 +86,6 @@ public class TaskService {
|
|||||||
public boolean updateTaskDirect(Task task) {
|
public boolean updateTaskDirect(Task task) {
|
||||||
task.setCron(task.getCron() == null || task.getCron().length() == 0 ? "0 0 0/6 * * ? *" : task.getCron()); //默认采集频率6小时一次
|
task.setCron(task.getCron() == null || task.getCron().length() == 0 ? "0 0 0/6 * * ? *" : task.getCron()); //默认采集频率6小时一次
|
||||||
|
|
||||||
Map<String, String> params = new HashMap<>();
|
|
||||||
//先更新xxljob
|
//先更新xxljob
|
||||||
XxlJobInfo xxlJobInfo = buildXxlJobByTask(task);
|
XxlJobInfo xxlJobInfo = buildXxlJobByTask(task);
|
||||||
String resultString = HttpUtil.post(xxlJobAdminServer + "xxl-job-admin/api/update", xxlJobInfo);
|
String resultString = HttpUtil.post(xxlJobAdminServer + "xxl-job-admin/api/update", xxlJobInfo);
|
||||||
|
|||||||
@ -11,9 +11,6 @@ SCHEDULER_PERSIST = True
|
|||||||
|
|
||||||
SELENIUM_DRIVER_NAME = 'firefox'
|
SELENIUM_DRIVER_NAME = 'firefox'
|
||||||
SELENIUM_DRIVER_EXECUTABLE_PATH = [
|
SELENIUM_DRIVER_EXECUTABLE_PATH = [
|
||||||
'http://154.90.40.71:28095',
|
|
||||||
'http://154.90.63.14:28095',
|
|
||||||
# 'http://156.244.20.57:28095',
|
|
||||||
'http://10.55.13.121:28095',
|
'http://10.55.13.121:28095',
|
||||||
'http://10.55.13.108:28095',
|
'http://10.55.13.108:28095',
|
||||||
'http://10.55.13.3:28095',
|
'http://10.55.13.3:28095',
|
||||||
|
|||||||
@ -48,7 +48,7 @@ public class JobApiController {
|
|||||||
@Resource
|
@Resource
|
||||||
private XxlJobService xxlJobService;
|
private XxlJobService xxlJobService;
|
||||||
|
|
||||||
private static Logger logger = LoggerFactory.getLogger(JobApiController.class);
|
private static final Logger logger = LoggerFactory.getLogger(JobApiController.class);
|
||||||
/**
|
/**
|
||||||
* api
|
* api
|
||||||
*
|
*
|
||||||
@ -63,31 +63,34 @@ public class JobApiController {
|
|||||||
|
|
||||||
// valid
|
// valid
|
||||||
if (!"POST".equalsIgnoreCase(request.getMethod())) {
|
if (!"POST".equalsIgnoreCase(request.getMethod())) {
|
||||||
return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, HttpMethod not support.");
|
return new ReturnT<>(ReturnT.FAIL_CODE, "invalid request, HttpMethod not support.");
|
||||||
}
|
}
|
||||||
if (uri==null || uri.trim().length()==0) {
|
if (uri==null || uri.trim().length()==0) {
|
||||||
return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping empty.");
|
return new ReturnT<>(ReturnT.FAIL_CODE, "invalid request, uri-mapping empty.");
|
||||||
}
|
}
|
||||||
if (XxlJobAdminConfig.getAdminConfig().getAccessToken()!=null
|
if (XxlJobAdminConfig.getAdminConfig().getAccessToken()!=null
|
||||||
&& XxlJobAdminConfig.getAdminConfig().getAccessToken().trim().length()>0
|
&& XxlJobAdminConfig.getAdminConfig().getAccessToken().trim().length()>0
|
||||||
&& !XxlJobAdminConfig.getAdminConfig().getAccessToken().equals(request.getHeader(XxlJobRemotingUtil.XXL_JOB_ACCESS_TOKEN))) {
|
&& !XxlJobAdminConfig.getAdminConfig().getAccessToken().equals(request.getHeader(XxlJobRemotingUtil.XXL_JOB_ACCESS_TOKEN))) {
|
||||||
return new ReturnT<String>(ReturnT.FAIL_CODE, "The access token is wrong.");
|
return new ReturnT<>(ReturnT.FAIL_CODE, "The access token is wrong.");
|
||||||
}
|
}
|
||||||
|
|
||||||
// services mapping
|
// services mapping
|
||||||
if ("callback".equals(uri)) {
|
switch (uri) {
|
||||||
List<HandleCallbackParam> callbackParamList = GsonTool.fromJson(data, List.class, HandleCallbackParam.class);
|
case "callback":
|
||||||
return adminBiz.callback(callbackParamList);
|
List<HandleCallbackParam> callbackParamList = GsonTool.fromJson(data, List.class, HandleCallbackParam.class);
|
||||||
} else if ("registry".equals(uri)) {
|
return adminBiz.callback(callbackParamList);
|
||||||
RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
|
case "registry": {
|
||||||
return adminBiz.registry(registryParam);
|
RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
|
||||||
} else if ("registryRemove".equals(uri)) {
|
return adminBiz.registry(registryParam);
|
||||||
RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
|
}
|
||||||
return adminBiz.registryRemove(registryParam);
|
case "registryRemove": {
|
||||||
|
RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
|
||||||
}else {
|
return adminBiz.registryRemove(registryParam);
|
||||||
return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping("+ uri +") not found.");
|
|
||||||
}
|
}
|
||||||
|
default:
|
||||||
|
return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping(" + uri + ") not found.");
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -37,7 +37,7 @@ import java.util.UUID;
|
|||||||
*/
|
*/
|
||||||
@Component
|
@Component
|
||||||
public class SampleXxlJob {
|
public class SampleXxlJob {
|
||||||
private static final Logger logger = LoggerFactory.getLogger(SampleXxlJob.class);
|
private final Logger logger = LoggerFactory.getLogger(this.getClass().getName());
|
||||||
|
|
||||||
@Value(value = "${oscm.server.url}")
|
@Value(value = "${oscm.server.url}")
|
||||||
private String oscmServer;
|
private String oscmServer;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user