KH/kh-device-admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【fix sonar】 XxlJobTrigger.java文件

Browse Source
This commit is contained in:
tianwenbo
2023-03-10 17:23:29 +08:00
parent 1d872c5e8c
commit 9d7bd1170f
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-cloud-module/jero-cloud-xxljob/src/main/java/com/xxl/job/admin/core/trigger/XxlJobTrigger.java
+9 -6
View File
@@ -25,6 +25,9 @@ import java.util.Date;
public class XxlJobTrigger { public class XxlJobTrigger {
private static Logger logger = LoggerFactory.getLogger(XxlJobTrigger.class); private static Logger logger = LoggerFactory.getLogger(XxlJobTrigger.class);
private XxlJobTrigger() {
}
/** /**
* trigger job * trigger job
* *
@@ -93,7 +96,7 @@ public class XxlJobTrigger {
private static boolean isNumeric(String str){ private static boolean isNumeric(String str){
try { try {
int result = Integer.valueOf(str); Integer.valueOf(str);
return true; return true;
} catch (NumberFormatException e) { } catch (NumberFormatException e) {
return false; return false;
@@ -155,7 +158,7 @@ public class XxlJobTrigger {
} }
} }
} else { } else {
routeAddressResult = new ReturnT<String>(ReturnT.FAIL_CODE, I18nUtil.getString("jobconf_trigger_address_empty")); routeAddressResult = new ReturnT<>(ReturnT.FAIL_CODE, I18nUtil.getString("jobconf_trigger_address_empty"));
} }
// 4、trigger remote executor // 4、trigger remote executor
@@ -163,11 +166,11 @@ public class XxlJobTrigger {
if (address != null) { if (address != null) {
triggerResult = runExecutor(triggerParam, address); triggerResult = runExecutor(triggerParam, address);
} else { } else {
triggerResult = new ReturnT<String>(ReturnT.FAIL_CODE, null); triggerResult = new ReturnT<>(ReturnT.FAIL_CODE, null);
} }
// 5、collection trigger info // 5、collection trigger info
StringBuffer triggerMsgSb = new StringBuffer(); StringBuilder triggerMsgSb = new StringBuilder();
triggerMsgSb.append(I18nUtil.getString("jobconf_trigger_type")).append("：").append(triggerType.getTitle()); triggerMsgSb.append(I18nUtil.getString("jobconf_trigger_type")).append("：").append(triggerType.getTitle());
triggerMsgSb.append("<br>").append(I18nUtil.getString("jobconf_trigger_admin_adress")).append("：").append(IpUtil.getIp()); triggerMsgSb.append("<br>").append(I18nUtil.getString("jobconf_trigger_admin_adress")).append("：").append(IpUtil.getIp());
triggerMsgSb.append("<br>").append(I18nUtil.getString("jobconf_trigger_exe_regtype")).append("：") triggerMsgSb.append("<br>").append(I18nUtil.getString("jobconf_trigger_exe_regtype")).append("：")
@@ -211,10 +214,10 @@ public class XxlJobTrigger {
runResult = executorBiz.run(triggerParam); runResult = executorBiz.run(triggerParam);
} catch (Exception e) { } catch (Exception e) {
logger.error(">>>>>>>>>>> xxl-job trigger error, please check if the executor[{}] is running.", address, e); logger.error(">>>>>>>>>>> xxl-job trigger error, please check if the executor[{}] is running.", address, e);
runResult = new ReturnT<String>(ReturnT.FAIL_CODE, ThrowableUtil.toString(e)); runResult = new ReturnT<>(ReturnT.FAIL_CODE, ThrowableUtil.toString(e));
} }
StringBuffer runResultSB = new StringBuffer(I18nUtil.getString("jobconf_trigger_run") + "："); StringBuilder runResultSB = new StringBuilder(I18nUtil.getString("jobconf_trigger_run") + "：");
runResultSB.append("<br>address：").append(address); runResultSB.append("<br>address：").append(address);
runResultSB.append("<br>code：").append(runResult.getCode()); runResultSB.append("<br>code：").append(runResult.getCode());
runResultSB.append("<br>msg：").append(runResult.getMsg()); runResultSB.append("<br>msg：").append(runResult.getMsg());