|
|
@@ -3,7 +3,6 @@ package cn.com.ctop.job.bytedance.handler;
|
|
|
|
|
|
import cn.com.ctop.job.bytedance.data.service.IZtPolicyRunService;
|
|
|
import cn.com.ctop.job.bytedance.data.utils.Check;
|
|
|
-import cn.com.ctop.job.bytedance.utils.FeishuRobotUtil;
|
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -38,13 +37,12 @@ public class ZtPolicyKob {
|
|
|
return;
|
|
|
}
|
|
|
Long policyId = Long.valueOf(param);
|
|
|
- FeishuRobotUtil.sendTextToWebhook("智投助手执行半小时级策略:"+policyId, "https://open.feishu.cn/open-apis/bot/v2/hook/c0a4845b-a7a6-4241-ae6a-6c656567fbd7");
|
|
|
-// halfHourExecutorService.submit(new Runnable() {
|
|
|
-// @Override
|
|
|
-// public void run() {
|
|
|
-// policyRunService.run(policyId);
|
|
|
-// }
|
|
|
-// });
|
|
|
+ halfHourExecutorService.submit(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ policyRunService.run(policyId);
|
|
|
+ }
|
|
|
+ });
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -62,13 +60,12 @@ public class ZtPolicyKob {
|
|
|
return;
|
|
|
}
|
|
|
Long policyId = Long.valueOf(param);
|
|
|
- FeishuRobotUtil.sendTextToWebhook("智投助手执行小时级策略:"+policyId, "https://open.feishu.cn/open-apis/bot/v2/hook/c0a4845b-a7a6-4241-ae6a-6c656567fbd7");
|
|
|
-// oneHourExecutorService.submit(new Runnable() {
|
|
|
-// @Override
|
|
|
-// public void run() {
|
|
|
-// policyRunService.run(policyId);
|
|
|
-// }
|
|
|
-// });
|
|
|
+ oneHourExecutorService.submit(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ policyRunService.run(policyId);
|
|
|
+ }
|
|
|
+ });
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -86,13 +83,12 @@ public class ZtPolicyKob {
|
|
|
return;
|
|
|
}
|
|
|
Long policyId = Long.valueOf(param);
|
|
|
- FeishuRobotUtil.sendTextToWebhook("智投助手执行天级策略:"+policyId, "https://open.feishu.cn/open-apis/bot/v2/hook/c0a4845b-a7a6-4241-ae6a-6c656567fbd7");
|
|
|
-// oneDayExecutorService.submit(new Runnable() {
|
|
|
-// @Override
|
|
|
-// public void run() {
|
|
|
-// policyRunService.run(policyId);
|
|
|
-// }
|
|
|
-// });
|
|
|
+ oneDayExecutorService.submit(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ policyRunService.run(policyId);
|
|
|
+ }
|
|
|
+ });
|
|
|
}
|
|
|
|
|
|
|