Compare commits

..

No commits in common. "afe6c34db7ff46317fd8254e7926254b615eb251" and "bbacb8e1a00354c91196b1bdd0d43014424bebb2" have entirely different histories.

5 changed files with 23 additions and 22 deletions

View File

@ -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:26.0.2" level="project" /> <orderEntry type="library" name="Maven: org.jetbrains:annotations:24.1.0" 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" />

View File

@ -86,6 +86,7 @@ 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);

View File

@ -11,6 +11,9 @@ 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',

View File

@ -48,7 +48,7 @@ public class JobApiController {
@Resource @Resource
private XxlJobService xxlJobService; private XxlJobService xxlJobService;
private static final Logger logger = LoggerFactory.getLogger(JobApiController.class); private static Logger logger = LoggerFactory.getLogger(JobApiController.class);
/** /**
* api * api
* *
@ -63,32 +63,29 @@ public class JobApiController {
// valid // valid
if (!"POST".equalsIgnoreCase(request.getMethod())) { if (!"POST".equalsIgnoreCase(request.getMethod())) {
return new ReturnT<>(ReturnT.FAIL_CODE, "invalid request, HttpMethod not support."); return new ReturnT<String>(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<>(ReturnT.FAIL_CODE, "invalid request, uri-mapping empty."); return new ReturnT<String>(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<>(ReturnT.FAIL_CODE, "The access token is wrong."); return new ReturnT<String>(ReturnT.FAIL_CODE, "The access token is wrong.");
} }
// services mapping // services mapping
switch (uri) { if ("callback".equals(uri)) {
case "callback":
List<HandleCallbackParam> callbackParamList = GsonTool.fromJson(data, List.class, HandleCallbackParam.class); List<HandleCallbackParam> callbackParamList = GsonTool.fromJson(data, List.class, HandleCallbackParam.class);
return adminBiz.callback(callbackParamList); return adminBiz.callback(callbackParamList);
case "registry": { } else if ("registry".equals(uri)) {
RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class); RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
return adminBiz.registry(registryParam); return adminBiz.registry(registryParam);
} } else if ("registryRemove".equals(uri)) {
case "registryRemove": {
RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class); RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class);
return adminBiz.registryRemove(registryParam); return adminBiz.registryRemove(registryParam);
} }else {
default:
return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping("+ uri +") not found."); return new ReturnT<String>(ReturnT.FAIL_CODE, "invalid request, uri-mapping("+ uri +") not found.");
} }

View File

@ -37,7 +37,7 @@ import java.util.UUID;
*/ */
@Component @Component
public class SampleXxlJob { public class SampleXxlJob {
private final Logger logger = LoggerFactory.getLogger(this.getClass().getName()); private static final Logger logger = LoggerFactory.getLogger(SampleXxlJob.class);
@Value(value = "${oscm.server.url}") @Value(value = "${oscm.server.url}")
private String oscmServer; private String oscmServer;