test环境修改 调度代码打磨

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/JavaTaskCallbackThread.java

 package com.byit.thread;
 
+import com.byit.enums.JobResultEnum;
+import com.byit.enums.task.RunResultEnum;
 import com.byit.model.JobTaskRunLogWithBLOBs;
 import com.byit.packet.response.PluginRpcResponsePacket;
 import com.byit.service.impl.JobTaskRunLogServiceImpl;
@@ -23,8 +25,14 @@ public class JavaTaskCallbackThread implements Runnable {
         JobTaskRunLogServiceImpl mythJobTaskRunLogService = SpringUtil.getBean(JobTaskRunLogServiceImpl.class);
         Map<String,String> result = (Map<String,String>)pluginRpcResponsePacket.getResult();
         JobTaskRunLogWithBLOBs jobTaskRunLog = new JobTaskRunLogWithBLOBs();
+        String code;
+        if(JobResultEnum.SUCCESS.getCode().equals(result.get("code"))){
+            code = RunResultEnum.RUN_SUCCESS.getCode();
+        }else {
+            code = RunResultEnum.RUN_ERROR.getCode();
+        }
         jobTaskRunLog.setRunMsg(result.get("msg"));
-        jobTaskRunLog.setRunCode(result.get("code"));
+        jobTaskRunLog.setRunCode(code);
         jobTaskRunLog.setLogId(logId);
         mythJobTaskRunLogService.updateJobTaskRunLogWithBLOBs(jobTaskRunLog);
 

byit-plugin-core/myth-plugin-rpc-client/src/main/java/com/byit/client/NettyPluginClient.java

@@ -15,7 +15,6 @@ public class NettyPluginClient extends PluginClient  {
 
     @Override
     public void send(String address, PluginRpcRequestPacket pluginRpcRequestPacket) throws Exception {
-        System.out.println("--------------我发送信息了");
         PluginConnectClient.send(pluginRpcRequestPacket,address,pluginConnectClientImpl,pluginClientInitialization);
     }
 }