Commit 74289a20 by huangfusuper

修正NUM字段

parent 4fdf3519
package com.byit.controller; package com.byit.controller;
import com.byit.call.TaskServer;
import com.byit.conf.MythJobAutoConfigure; import com.byit.conf.MythJobAutoConfigure;
import com.byit.dto.executor.DispatchResponseDto; import com.byit.dto.executor.DispatchResponseDto;
import com.byit.dto.executor.JobRunResultDto; import com.byit.dto.executor.JobRunResultDto;
import com.byit.dto.executor.PluginBeanJobInfo; import com.byit.dto.executor.PluginBeanJobInfo;
import com.byit.model.JobTask; import com.byit.model.JobTask;
import com.byit.packet.request.PluginRpcRequestPacket;
import com.byit.packet.response.PluginRpcResponsePacket;
import com.byit.service.JobTaskService; import com.byit.service.JobTaskService;
import com.byit.service.RunScriptService; import com.byit.service.RunScriptService;
import com.byit.task.annotations.TaskClient;
import com.byit.thread.LogCallbackThread; import com.byit.thread.LogCallbackThread;
import com.byit.util.SourceObj2TargetObjUtil; import com.byit.util.SourceObj2TargetObjUtil;
import com.byit.utils.ValidationUtil; import com.byit.utils.ValidationUtil;
...@@ -35,6 +39,9 @@ public class JobController { ...@@ -35,6 +39,9 @@ public class JobController {
this.jobTaskService = jobTaskService; this.jobTaskService = jobTaskService;
} }
@TaskClient
private TaskServer taskServer;
@PostMapping(value = "addJob") @PostMapping(value = "addJob")
public String addJob(@RequestBody PluginBeanJobInfo pluginBeanJobInfo){ public String addJob(@RequestBody PluginBeanJobInfo pluginBeanJobInfo){
...@@ -55,10 +62,10 @@ public class JobController { ...@@ -55,10 +62,10 @@ public class JobController {
} }
@GetMapping("test") @GetMapping("test")
public DispatchResponseDto test(){ public PluginRpcResponsePacket test(){
DispatchResponseDto dispatchResponseDto = runScriptService.runScript(null); PluginRpcRequestPacket rpcRequestPacket = new PluginRpcRequestPacket();
rpcRequestPacket.setJobName("qualityBeforeTaskJob");
System.out.println("---------------------"); PluginRpcResponsePacket call = taskServer.call(rpcRequestPacket);
return dispatchResponseDto; return call;
} }
} }
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