异常信息

byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java

@@ -246,6 +246,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         for(PluginBaseNode pluginNode : nodeList){
             Node node = new Node();
             buildNode(pluginNode, flow, node);
+            node.setNodeId(null);
             Integer nodeId = nodeMapper.insertSelective(node);
             nameIdRel.put(node.getNodeName(), node.getNodeId());
         }

byit-myth-core/myth-admin-core/src/main/java/com/byit/factory/DaemonScanThreadRunHelperDbLock.java

 package com.byit.factory;
 
 import com.byit.thread.BaseThreadRunHelper;
+import com.byit.util.MythLogUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.context.annotation.Primary;
@@ -71,7 +72,7 @@ public class DaemonScanThreadRunHelperDbLock extends BaseDaemonScanThreadRunHelp
                         sleepTime = examplesValue.start();
                     }catch (Exception e){
                         if(!THREAD_GROUP_STOP){
-                            e.printStackTrace();
+                            log.error("-----{}-----", MythLogUtils.getMessage(e));
 
                         }
                     }finally {

byit-myth-core/myth-admin-core/src/main/java/com/byit/factory/DaemonScanThreadRunHelperRedisLock.java

 package com.byit.factory;
 
 import com.byit.thread.BaseThreadRunHelper;
+import com.byit.util.MythLogUtils;
 import com.byit.util.lock.RedissLockUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
@@ -52,7 +53,7 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
                 }catch (Exception e) {
                     RedissLockUtil.unlock(lockName);
                     if(!THREAD_GROUP_STOP){
-                        log.error("---------{}---------",e.getMessage());
+                        log.error("---------{}---------", MythLogUtils.getMessage(e));
                     }
                 }
                 sleepTime = sleepTime==null || sleepTime<=0?examplesValue.UNIVERSAL_WAIT_TIME:sleepTime;

byit-myth-core/myth-admin-core/src/main/java/com/byit/task/JavaNodeExecutorTask.java

@@ -14,6 +14,7 @@ import com.byit.service.FastRunLogService;
 import com.byit.service.FlowStatusService;
 import com.byit.service.impl.JobTaskRunLogServiceImpl;
 import com.byit.service.impl.RunJavaServiceImpl;
+import com.byit.util.MythLogUtils;
 import com.byit.util.ServiceInfoUtil;
 import com.byit.util.SpringUtil;
 import io.netty.util.Timeout;
@@ -101,17 +102,18 @@ public class JavaNodeExecutorTask  implements TimerTask {
         }catch (Exception e){
             if (mythJobTaskSchedule.getScheduleType().equals(4)) {
                 StringRedisTemplate stringRedisTemplate = (StringRedisTemplate) SpringUtil.getBean("stringRedisTemplate");
-                RunLog runLog = RunLog.builder().isEnd(true).isSuccess(false).runLog("执行资源异常" +  e.getMessage()).build();
+                RunLog runLog = RunLog.builder().isEnd(true).isSuccess(false).runLog("执行资源异常" +  MythLogUtils.getMessage(e)).build();
                 //stringRedisTemplate.convertAndSend("REAL:EXEC:" + mythJobTaskSchedule.getLogId() , JSON.toJSONString(runLog, WriteClassName));
                 //使用redis 想队尾push一个值
                 stringRedisTemplate.opsForList().rightPush("REAL:EXEC:" + mythJobTaskSchedule.getLogId() , JSON.toJSONString(runLog, WriteClassName));
             }
 
-            log.error("------执行机异常{}-----", e.getMessage());
+            log.error("------执行机异常{}-----", MythLogUtils.getMessage(e));
+            assert jobTaskRunLogById != null;
             jobTaskRunLogById.setTriggerCode(RunResultEnum.TRIGGER_ERROR.getCode());
             jobTaskRunLogById.setRunCode(RunResultEnum.RUN_ERROR.getCode());
-            jobTaskRunLogById.setRunMsg(mythJobTaskSchedule.getNodeName()+":"+e.getMessage());
-            jobTaskRunLogById.setTriggerMsg(mythJobTaskSchedule.getNodeName()+":"+e.getMessage());
+            jobTaskRunLogById.setRunMsg(mythJobTaskSchedule.getNodeName()+":"+MythLogUtils.getMessage(e));
+            jobTaskRunLogById.setTriggerMsg(mythJobTaskSchedule.getNodeName()+":"+MythLogUtils.getMessage(e));
         }
 
         jobTaskRunLogService.updateJobTaskRunLogWithBLOBs(jobTaskRunLogById);

byit-myth-core/myth-admin-core/src/main/java/com/byit/util/MythLogUtils.java

+package com.byit.util;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+
+/**
+ * @author huangfu
+ */
+public class MythLogUtils {
+    /**
+     * 读取异常信息
+     * @param obj 异常对象
+     * @return 返回堆栈异常信息
+     */
+    public static String getMessage(Object obj) {
+        if (obj == null) {
+            return "";
+        }
+
+        if (obj instanceof Throwable) {
+            StringWriter str = new StringWriter();
+            PrintWriter pw = new PrintWriter(str);
+            ((Throwable) obj).printStackTrace(pw);
+            return str.toString();
+        } else {
+            return obj.toString();
+        }
+    }
+}