分布式锁

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

@@ -42,13 +42,11 @@ public class DaemonScanThreadRunHelperRedisLock extends BaseDaemonScanThreadRunH
                 Long sleepTime = 0L;
                 try{
                     //加锁  60秒后超时
-                    if (RedissLockUtil.trlock(lockName, TimeUnit.SECONDS, 30)) {
+                    if (RedissLockUtil.trlock(lockName, TimeUnit.SECONDS, 59)) {
                         log.debug("------------{},加锁成功，锁名称为{}----------",threadName,lockName);
                         dateAligned(CYCLE_INTERVAL,threadName);
                         //调用业务操作
                         sleepTime = examplesValue.start();
-                    }else {
-                        log.debug("------------{},加锁失败，锁名称为{}----------",threadName,lockName);
                     }
                 }catch (Exception e) {
                     if(!THREAD_GROUP_STOP){

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

@@ -110,6 +110,7 @@ public class RunRecordingServiceImpl implements RunRecordingService  {
             //判断当前的实例  中是否有 未完成的
             if (RunRecordingEnum.FLOW_STATUS_RUN_ING.getCode().equals(runRecording.getFlowStatus()) ||
                     RunRecordingEnum.FLOW_STATUS_IS_STOP.getCode().equals(runRecording.getFlowStatus())) {
+                log.info("----------{}实例正在运行中--------",runRecording);
                 return true;
             }
         }