Commit e5e1e24a by huangfusuper

修正写死的回调路径

parent a8496dca
...@@ -17,6 +17,7 @@ import com.byit.rpc.remoting.invoker.route.RpcLoadBalance; ...@@ -17,6 +17,7 @@ import com.byit.rpc.remoting.invoker.route.RpcLoadBalance;
import com.byit.service.impl.JobTaskRunLogServiceImpl; import com.byit.service.impl.JobTaskRunLogServiceImpl;
import com.byit.service.impl.RunRecordingServiceImpl; import com.byit.service.impl.RunRecordingServiceImpl;
import com.byit.util.ServiceInfoUtil;
import com.byit.util.SpringUtil; import com.byit.util.SpringUtil;
import io.netty.util.Timeout; import io.netty.util.Timeout;
import io.netty.util.TimerTask; import io.netty.util.TimerTask;
...@@ -32,6 +33,10 @@ import java.util.Date; ...@@ -32,6 +33,10 @@ import java.util.Date;
**/ **/
@Slf4j @Slf4j
public class JavaBeanJobTask implements TimerTask { public class JavaBeanJobTask implements TimerTask {
private final String HTTP_PRE = "http://";
private final String HTTP_SUFFIX = "/job/callbackRes";
private JobTaskSchedule mythJobTaskSchedule; private JobTaskSchedule mythJobTaskSchedule;
public JavaBeanJobTask(JobTaskSchedule mythJobTaskSchedule) { public JavaBeanJobTask(JobTaskSchedule mythJobTaskSchedule) {
this.mythJobTaskSchedule = mythJobTaskSchedule; this.mythJobTaskSchedule = mythJobTaskSchedule;
...@@ -79,7 +84,7 @@ public class JavaBeanJobTask implements TimerTask { ...@@ -79,7 +84,7 @@ public class JavaBeanJobTask implements TimerTask {
String param = mythJobTaskSchedule.getRunParam( ); String param = mythJobTaskSchedule.getRunParam( );
String runId = mythJobTaskSchedule.getRunId(); String runId = mythJobTaskSchedule.getRunId();
AdminSenPluginDto adminSenPluginDto = new AdminSenPluginDto(); AdminSenPluginDto adminSenPluginDto = new AdminSenPluginDto();
adminSenPluginDto.setCallbackUrl("http://127.0.0.1:8998/job/callbackRes"); adminSenPluginDto.setCallbackUrl(HTTP_PRE+ ServiceInfoUtil.getIpAndPort()+HTTP_SUFFIX);
adminSenPluginDto.setJobHandelName(jobHandelName); adminSenPluginDto.setJobHandelName(jobHandelName);
adminSenPluginDto.setJobParam(param); adminSenPluginDto.setJobParam(param);
adminSenPluginDto.setRunId(runId); adminSenPluginDto.setRunId(runId);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment