fix: 2.6.0
1. 修复日志排序问题 2. 优化去掉工作流锁重试
This commit is contained in:
byteblogs168
parent
baa128360d
commit
ec49ad46d3
@ -10,11 +10,6 @@ import lombok.Data;
|
||||
@Data
|
||||
public class WorkflowNodeTaskExecuteDTO {
|
||||
|
||||
/**
|
||||
* 工作流id
|
||||
*/
|
||||
private Long workflowId;
|
||||
|
||||
/**
|
||||
* 工作流任务批次id
|
||||
*/
|
||||
|
||||
@ -51,8 +51,6 @@ public class JobExecutorResultActor extends AbstractActor {
|
||||
@Autowired
|
||||
private JobTaskMapper jobTaskMapper;
|
||||
@Autowired
|
||||
private TransactionTemplate transactionTemplate;
|
||||
@Autowired
|
||||
private JobTaskBatchHandler jobTaskBatchHandler;
|
||||
@Autowired
|
||||
private DistributedLockHandler distributedLockHandler;
|
||||
@ -73,12 +71,12 @@ public class JobExecutorResultActor extends AbstractActor {
|
||||
() -> new EasyRetryServerException("更新任务实例失败"));
|
||||
// 先尝试完成，若已完成则不需要通过获取分布式锁来完成
|
||||
boolean tryCompleteAndStop = tryCompleteAndStop(result);
|
||||
if (!tryCompleteAndStop) {
|
||||
if (!tryCompleteAndStop) {
|
||||
// 存在并发问题
|
||||
distributedLockHandler.lockWithDisposableAndRetry(() -> {
|
||||
tryCompleteAndStop(result);
|
||||
}, MessageFormat.format(KEY, result.getTaskBatchId(),
|
||||
result.getJobId()), Duration.ofSeconds(2), Duration.ofSeconds(1), 3);
|
||||
result.getJobId()), Duration.ofSeconds(1), Duration.ofSeconds(1), 3);
|
||||
}
|
||||
} catch (Exception e) {
|
||||
EasyRetryLog.LOCAL.error(" job executor result exception. [{}]", result, e);
|
||||
|
||||
@ -61,9 +61,8 @@ public abstract class AbstractWorkflowExecutor implements WorkflowExecutor, Init
|
||||
|
||||
@Override
|
||||
public void execute(WorkflowExecutorContext context) {
|
||||
distributedLockHandler.lockWithDisposableAndRetry(
|
||||
distributedLockHandler.lockWithDisposable(
|
||||
() -> {
|
||||
|
||||
long total = 0;
|
||||
// 条件节点存在并发问题，需要特殊处理
|
||||
if (WorkflowNodeTypeEnum.DECISION.getType() == context.getNodeType()) {
|
||||
@ -110,7 +109,7 @@ public abstract class AbstractWorkflowExecutor implements WorkflowExecutor, Init
|
||||
}
|
||||
});
|
||||
}, MessageFormat.format(KEY, context.getWorkflowTaskBatchId(), context.getWorkflowNodeId()),
|
||||
Duration.ofSeconds(6), Duration.ofSeconds(2), 12);
|
||||
Duration.ofSeconds(10));
|
||||
|
||||
}
|
||||
|
||||
@ -132,22 +131,12 @@ public abstract class AbstractWorkflowExecutor implements WorkflowExecutor, Init
|
||||
}
|
||||
|
||||
protected void workflowTaskExecutor(WorkflowExecutorContext context) {
|
||||
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
|
||||
@Override
|
||||
public void afterCompletion(int status) {
|
||||
try {
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(context.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setTaskExecutorScene(context.getTaskExecutorScene());
|
||||
taskExecuteDTO.setParentId(context.getWorkflowNodeId());
|
||||
taskExecuteDTO.setTaskBatchId(context.getTaskBatchId());
|
||||
ActorRef actorRef = ActorGenerator.workflowTaskExecutorActor();
|
||||
actorRef.tell(taskExecuteDTO, actorRef);
|
||||
} catch (Exception e) {
|
||||
log.error("工作流执行失败", e);
|
||||
}
|
||||
}
|
||||
});
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(context.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setTaskExecutorScene(context.getTaskExecutorScene());
|
||||
taskExecuteDTO.setParentId(context.getWorkflowNodeId());
|
||||
taskExecuteDTO.setTaskBatchId(context.getTaskBatchId());
|
||||
workflowBatchHandler.openNextNode(taskExecuteDTO);
|
||||
}
|
||||
|
||||
protected JobTask generateJobTask(WorkflowExecutorContext context, JobTaskBatch jobTaskBatch) {
|
||||
|
||||
@ -13,11 +13,13 @@ import com.aizuda.easy.retry.server.job.task.dto.JobTimerTaskDTO;
|
||||
import com.aizuda.easy.retry.common.core.enums.JobTaskBatchStatusEnum;
|
||||
import com.aizuda.easy.retry.server.job.task.dto.WorkflowNodeTaskExecuteDTO;
|
||||
import com.aizuda.easy.retry.server.job.task.support.JobTaskConverter;
|
||||
import com.aizuda.easy.retry.server.job.task.support.handler.WorkflowBatchHandler;
|
||||
import com.aizuda.easy.retry.server.job.task.support.timer.JobTimerTask;
|
||||
import com.aizuda.easy.retry.server.job.task.support.timer.JobTimerWheel;
|
||||
import com.aizuda.easy.retry.template.datasource.persistence.mapper.JobTaskBatchMapper;
|
||||
import com.aizuda.easy.retry.template.datasource.persistence.po.JobTaskBatch;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.dao.DuplicateKeyException;
|
||||
@ -39,10 +41,11 @@ import java.util.concurrent.TimeUnit;
|
||||
*/
|
||||
@Component
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor
|
||||
public class JobTaskBatchGenerator {
|
||||
|
||||
@Autowired
|
||||
private JobTaskBatchMapper jobTaskBatchMapper;
|
||||
private final JobTaskBatchMapper jobTaskBatchMapper;
|
||||
private final WorkflowBatchHandler workflowBatchHandler;
|
||||
|
||||
@Transactional
|
||||
public JobTaskBatch generateJobTaskBatch(JobTaskBatchGeneratorContext context) {
|
||||
@ -79,18 +82,12 @@ public class JobTaskBatchGenerator {
|
||||
|
||||
// 非待处理状态无需进入时间轮中
|
||||
if (JobTaskBatchStatusEnum.WAITING.getStatus() != jobTaskBatch.getTaskBatchStatus()) {
|
||||
|
||||
if (TransactionSynchronizationManager.isActualTransactionActive()) {
|
||||
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
|
||||
@Override
|
||||
public void afterCompletion(int status) {
|
||||
openNextNode(context);
|
||||
}
|
||||
});
|
||||
} else {
|
||||
openNextNode(context);
|
||||
}
|
||||
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(context.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setTaskExecutorScene(context.getTaskExecutorScene());
|
||||
taskExecuteDTO.setParentId(context.getWorkflowNodeId());
|
||||
taskExecuteDTO.setTaskBatchId(jobTaskBatch.getId());
|
||||
workflowBatchHandler.openNextNode(taskExecuteDTO);
|
||||
|
||||
return jobTaskBatch;
|
||||
}
|
||||
@ -109,24 +106,4 @@ public class JobTaskBatchGenerator {
|
||||
return jobTaskBatch;
|
||||
}
|
||||
|
||||
/**
|
||||
* 工作流开启下一个节点
|
||||
* @param context
|
||||
*/
|
||||
private static void openNextNode(final JobTaskBatchGeneratorContext context) {
|
||||
if (Objects.nonNull(context.getWorkflowNodeId()) && Objects.nonNull(context.getWorkflowTaskBatchId())) {
|
||||
// 若是工作流则开启下一个任务
|
||||
try {
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(context.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setTaskExecutorScene(context.getTaskExecutorScene());
|
||||
taskExecuteDTO.setParentId(context.getWorkflowNodeId());
|
||||
ActorRef actorRef = ActorGenerator.workflowTaskExecutorActor();
|
||||
actorRef.tell(taskExecuteDTO, actorRef);
|
||||
} catch (Exception e) {
|
||||
log.error("任务调度执行失败", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@ -105,8 +105,7 @@ public class DistributedLockHandler {
|
||||
* @param lockName 锁名称
|
||||
* @param lockAtMost 锁超时时间
|
||||
*/
|
||||
@Transactional(propagation = Propagation.NOT_SUPPORTED)
|
||||
public void lockWithDisposable(String lockName, Duration lockAtMost, LockExecutor lockExecutor) {
|
||||
public void lockWithDisposable(LockExecutor lockExecutor, String lockName, Duration lockAtMost) {
|
||||
|
||||
LockProvider lockProvider = LockBuilder.newBuilder()
|
||||
.withDisposable(lockName)
|
||||
@ -122,8 +121,8 @@ public class DistributedLockHandler {
|
||||
EasyRetryLog.LOCAL.error("lock execute error. lockName:[{}]", lockName, e);
|
||||
} finally {
|
||||
if (lock) {
|
||||
EasyRetryLog.LOCAL.info("[{}] 锁已释放", lockName);
|
||||
lockProvider.unlock();
|
||||
EasyRetryLog.LOCAL.info("[{}] 锁已释放", lockName);
|
||||
} else {
|
||||
// 未获取到锁直接清除线程中存储的锁信息
|
||||
LockManager.clear();
|
||||
|
||||
@ -1,10 +1,8 @@
|
||||
package com.aizuda.easy.retry.server.job.task.support.handler;
|
||||
|
||||
import akka.actor.ActorRef;
|
||||
import com.aizuda.easy.retry.common.core.context.SpringContext;
|
||||
import com.aizuda.easy.retry.common.core.enums.JobTaskBatchStatusEnum;
|
||||
import com.aizuda.easy.retry.common.core.enums.JobTaskStatusEnum;
|
||||
import com.aizuda.easy.retry.server.common.akka.ActorGenerator;
|
||||
import com.aizuda.easy.retry.server.common.enums.JobTaskExecutorSceneEnum;
|
||||
import com.aizuda.easy.retry.server.job.task.dto.CompleteJobBatchDTO;
|
||||
import com.aizuda.easy.retry.server.job.task.dto.WorkflowNodeTaskExecuteDTO;
|
||||
@ -15,12 +13,10 @@ import com.aizuda.easy.retry.template.datasource.persistence.po.JobTask;
|
||||
import com.aizuda.easy.retry.template.datasource.persistence.po.JobTaskBatch;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.transaction.support.TransactionSynchronization;
|
||||
import org.springframework.transaction.support.TransactionSynchronizationManager;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
|
||||
import java.time.LocalDateTime;
|
||||
@ -34,13 +30,13 @@ import java.util.stream.Collectors;
|
||||
* @date : 2023-10-10 16:50
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor
|
||||
@Slf4j
|
||||
public class JobTaskBatchHandler {
|
||||
private final JobTaskMapper jobTaskMapper;
|
||||
private final JobTaskBatchMapper jobTaskBatchMapper;
|
||||
private final WorkflowBatchHandler workflowBatchHandler;
|
||||
|
||||
@Autowired
|
||||
private JobTaskMapper jobTaskMapper;
|
||||
@Autowired
|
||||
private JobTaskBatchMapper jobTaskBatchMapper;
|
||||
|
||||
@Transactional
|
||||
public boolean complete(CompleteJobBatchDTO completeJobBatchDTO) {
|
||||
@ -80,27 +76,12 @@ public class JobTaskBatchHandler {
|
||||
jobTaskBatch.setOperationReason(completeJobBatchDTO.getJobOperationReason());
|
||||
}
|
||||
|
||||
if (Objects.nonNull(completeJobBatchDTO.getWorkflowNodeId()) && Objects.nonNull(
|
||||
completeJobBatchDTO.getWorkflowTaskBatchId())) {
|
||||
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
|
||||
@Override
|
||||
public void afterCompletion(int status) {
|
||||
// 若是工作流则开启下一个任务
|
||||
try {
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(completeJobBatchDTO.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setTaskExecutorScene(JobTaskExecutorSceneEnum.AUTO_WORKFLOW.getType());
|
||||
taskExecuteDTO.setParentId(completeJobBatchDTO.getWorkflowNodeId());
|
||||
taskExecuteDTO.setTaskBatchId(completeJobBatchDTO.getTaskBatchId());
|
||||
ActorRef actorRef = ActorGenerator.workflowTaskExecutorActor();
|
||||
actorRef.tell(taskExecuteDTO, actorRef);
|
||||
} catch (Exception e) {
|
||||
log.error("任务调度执行失败", e);
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
}
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(completeJobBatchDTO.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setTaskExecutorScene(JobTaskExecutorSceneEnum.AUTO_WORKFLOW.getType());
|
||||
taskExecuteDTO.setParentId(completeJobBatchDTO.getWorkflowNodeId());
|
||||
taskExecuteDTO.setTaskBatchId(completeJobBatchDTO.getTaskBatchId());
|
||||
workflowBatchHandler.openNextNode(taskExecuteDTO);
|
||||
|
||||
jobTaskBatch.setUpdateDt(LocalDateTime.now());
|
||||
return 1 == jobTaskBatchMapper.update(jobTaskBatch,
|
||||
|
||||
@ -5,6 +5,7 @@ import cn.hutool.core.lang.Assert;
|
||||
import com.aizuda.easy.retry.common.core.constant.SystemConstants;
|
||||
import com.aizuda.easy.retry.common.core.enums.JobOperationReasonEnum;
|
||||
import com.aizuda.easy.retry.common.core.enums.JobTaskBatchStatusEnum;
|
||||
import com.aizuda.easy.retry.common.log.EasyRetryLog;
|
||||
import com.aizuda.easy.retry.server.common.akka.ActorGenerator;
|
||||
import com.aizuda.easy.retry.server.common.enums.JobTaskExecutorSceneEnum;
|
||||
import com.aizuda.easy.retry.server.common.exception.EasyRetryServerException;
|
||||
@ -27,6 +28,8 @@ import com.google.common.collect.Lists;
|
||||
import com.google.common.graph.MutableGraph;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.stereotype.Component;
|
||||
import org.springframework.transaction.support.TransactionSynchronization;
|
||||
import org.springframework.transaction.support.TransactionSynchronizationManager;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
|
||||
import java.io.IOException;
|
||||
@ -218,7 +221,7 @@ public class WorkflowBatchHandler {
|
||||
.in(JobTaskBatch::getWorkflowNodeId, graph.nodes()).orderByDesc(JobTaskBatch::getId)
|
||||
);
|
||||
|
||||
Map<Long, JobTaskBatch> jobTaskBatchMap = jobTaskBatches.stream().collect(Collectors.toMap(JobTaskBatch::getWorkflowNodeId, i -> i, (i,j) -> i));
|
||||
Map<Long, JobTaskBatch> jobTaskBatchMap = jobTaskBatches.stream().collect(Collectors.toMap(JobTaskBatch::getWorkflowNodeId, i -> i, (i, j) -> i));
|
||||
|
||||
checkWorkflowExecutor(SystemConstants.ROOT, workflowTaskBatchId, graph, jobTaskBatchMap);
|
||||
}
|
||||
@ -245,8 +248,10 @@ public class WorkflowBatchHandler {
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(workflowTaskBatchId);
|
||||
taskExecuteDTO.setTaskExecutorScene(JobTaskExecutorSceneEnum.AUTO_WORKFLOW.getType());
|
||||
taskExecuteDTO.setParentId(parentId);
|
||||
ActorRef actorRef = ActorGenerator.workflowTaskExecutorActor();
|
||||
actorRef.tell(taskExecuteDTO, actorRef);
|
||||
if (Objects.nonNull(parentJobTaskBatch)) {
|
||||
taskExecuteDTO.setTaskBatchId(parentJobTaskBatch.getId());
|
||||
}
|
||||
openNextNode(taskExecuteDTO);
|
||||
break;
|
||||
}
|
||||
|
||||
@ -270,5 +275,30 @@ public class WorkflowBatchHandler {
|
||||
}
|
||||
}
|
||||
|
||||
public void openNextNode(WorkflowNodeTaskExecuteDTO taskExecuteDTO) {
|
||||
if (Objects.isNull(taskExecuteDTO.getParentId()) || Objects.isNull(taskExecuteDTO.getWorkflowTaskBatchId())) {
|
||||
return;
|
||||
}
|
||||
|
||||
// 若是工作流则开启下一个任务
|
||||
if (TransactionSynchronizationManager.isActualTransactionActive()) {
|
||||
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
|
||||
@Override
|
||||
public void afterCompletion(int status) {
|
||||
tellWorkflowTaskExecutor(taskExecuteDTO);
|
||||
}
|
||||
});
|
||||
} else {
|
||||
tellWorkflowTaskExecutor(taskExecuteDTO);
|
||||
}
|
||||
}
|
||||
|
||||
private void tellWorkflowTaskExecutor(WorkflowNodeTaskExecuteDTO taskExecuteDTO) {
|
||||
try {
|
||||
ActorRef actorRef = ActorGenerator.workflowTaskExecutorActor();
|
||||
actorRef.tell(taskExecuteDTO, actorRef);
|
||||
} catch (Exception e) {
|
||||
EasyRetryLog.LOCAL.error("任务调度执行失败", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ -32,7 +32,6 @@ public class WorkflowTimerTask implements TimerTask {
|
||||
|
||||
WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
|
||||
taskExecuteDTO.setWorkflowTaskBatchId(workflowTimerTaskDTO.getWorkflowTaskBatchId());
|
||||
taskExecuteDTO.setWorkflowId(workflowTimerTaskDTO.getWorkflowId());
|
||||
taskExecuteDTO.setTaskExecutorScene(workflowTimerTaskDTO.getTaskExecutorScene());
|
||||
taskExecuteDTO.setParentId(SystemConstants.ROOT);
|
||||
ActorRef actorRef = ActorGenerator.workflowTaskExecutorActor();
|
||||
|
||||
File diff suppressed because one or more lines are too long
@ -1 +1 @@
|
||||
.log[data-v-4a9e5221]{height:calc(100vh - 56px);color:#abb2bf;background-color:#282c34;position:relative!important;-webkit-box-sizing:border-box;box-sizing:border-box;display:-webkit-box!important;display:-ms-flexbox!important;display:flex!important;-webkit-box-orient:vertical;-webkit-box-direction:normal;-ms-flex-direction:column;flex-direction:column}.log[data-v-4a9e5221] ::-webkit-scrollbar{width:10px;height:10px}.log[data-v-4a9e5221] ::-webkit-scrollbar-track{width:6px;background:rgba(16,31,28,.1);border-radius:2em}.log[data-v-4a9e5221] ::-webkit-scrollbar-thumb{background-color:rgba(144,147,153,.5);background-clip:padding-box;min-height:28px;border-radius:2em;-webkit-transition:background-color .3s;transition:background-color .3s;cursor:pointer}.log[data-v-4a9e5221] ::-webkit-scrollbar-thumb:hover{background-color:rgba(144,147,153,.3)}.log .scroller[data-v-4a9e5221]{height:100%;overflow:auto;display:-webkit-box!important;display:-ms-flexbox!important;display:flex!important;-webkit-box-align:start!important;-ms-flex-align:start!important;align-items:flex-start!important;font-family:monospace;line-height:1.4;position:relative;z-index:0}.log .scroller .index[data-v-4a9e5221]{width:32px;min-width:32px;height:100%;background-color:#1e1f22;color:#7d8799;text-align:center;vertical-align:top;padding-top:4px;font-size:16px;z-index:200}.log .scroller .gutters[data-v-4a9e5221]{min-height:100%;position:sticky;background-color:#1e1f22;border:none;-ms-flex-negative:0;flex-shrink:0;-webkit-box-orient:vertical;-webkit-box-direction:normal;-ms-flex-direction:column;flex-direction:column;inset-inline-start:0;z-index:200}.log .scroller .gutters .gutter-element[data-v-4a9e5221],.log .scroller .gutters[data-v-4a9e5221]{color:#7d8799;display:-webkit-box;display:-ms-flexbox;display:flex;-webkit-box-sizing:border-box;box-sizing:border-box}.log .scroller .gutters .gutter-element[data-v-4a9e5221]{height:25px;font-size:14px;padding:0 8px 0 5px;min-width:20px;text-align:right;white-space:nowrap;-webkit-box-align:center;-ms-flex-align:center;align-items:center;-webkit-box-pack:end;-ms-flex-pack:end;justify-content:flex-end}.log .scroller .content[data-v-4a9e5221]{-moz-tab-size:4;-o-tab-size:4;tab-size:4;caret-color:transparent!important;margin:0;white-space:pre;padding:4px 8px;outline:none;color:#bcbec4}.log .scroller .content .line[data-v-4a9e5221]{height:25px;caret-color:transparent!important;font-size:16px;display:contents;padding:0 2px 0 6px}.log .scroller .content .line .flex[data-v-4a9e5221]{display:-webkit-box;display:-ms-flexbox;display:flex;-webkit-box-align:center;-ms-flex-align:center;align-items:center;gap:5px}.log .scroller .content .line .text[data-v-4a9e5221]{font-size:16px}[data-v-4a9e5221] .ant-modal{max-width:100%;top:0;padding-bottom:0;margin:0}[data-v-4a9e5221] .ant-modal-content{display:-webkit-box;display:-ms-flexbox;display:flex;-webkit-box-orient:vertical;-webkit-box-direction:normal;-ms-flex-direction:column;flex-direction:column;height:100vh}[data-v-4a9e5221] .ant-modal-body{-webkit-box-flex:1;-ms-flex:1;flex:1;padding:0}
|
||||
.log[data-v-681db452]{height:calc(100vh - 56px);color:#abb2bf;background-color:#282c34;position:relative!important;-webkit-box-sizing:border-box;box-sizing:border-box;display:-webkit-box!important;display:-ms-flexbox!important;display:flex!important;-webkit-box-orient:vertical;-webkit-box-direction:normal;-ms-flex-direction:column;flex-direction:column}.log[data-v-681db452] ::-webkit-scrollbar{width:10px;height:10px}.log[data-v-681db452] ::-webkit-scrollbar-track{width:6px;background:rgba(16,31,28,.1);border-radius:2em}.log[data-v-681db452] ::-webkit-scrollbar-thumb{background-color:rgba(144,147,153,.5);background-clip:padding-box;min-height:28px;border-radius:2em;-webkit-transition:background-color .3s;transition:background-color .3s;cursor:pointer}.log[data-v-681db452] ::-webkit-scrollbar-thumb:hover{background-color:rgba(144,147,153,.3)}.log .scroller[data-v-681db452]{height:100%;overflow:auto;display:-webkit-box!important;display:-ms-flexbox!important;display:flex!important;-webkit-box-align:start!important;-ms-flex-align:start!important;align-items:flex-start!important;font-family:monospace;line-height:1.4;position:relative;z-index:0}.log .scroller .index[data-v-681db452]{width:32px;min-width:32px;height:100%;background-color:#1e1f22;color:#7d8799;text-align:center;vertical-align:top;padding-top:4px;font-size:16px;z-index:200}.log .scroller .gutters[data-v-681db452]{min-height:100%;position:sticky;background-color:#1e1f22;border:none;-ms-flex-negative:0;flex-shrink:0;-webkit-box-orient:vertical;-webkit-box-direction:normal;-ms-flex-direction:column;flex-direction:column;inset-inline-start:0;z-index:200}.log .scroller .gutters .gutter-element[data-v-681db452],.log .scroller .gutters[data-v-681db452]{color:#7d8799;display:-webkit-box;display:-ms-flexbox;display:flex;-webkit-box-sizing:border-box;box-sizing:border-box}.log .scroller .gutters .gutter-element[data-v-681db452]{height:25px;font-size:14px;padding:0 8px 0 5px;min-width:20px;text-align:right;white-space:nowrap;-webkit-box-align:center;-ms-flex-align:center;align-items:center;-webkit-box-pack:end;-ms-flex-pack:end;justify-content:flex-end}.log .scroller .content[data-v-681db452]{-moz-tab-size:4;-o-tab-size:4;tab-size:4;caret-color:transparent!important;margin:0;white-space:pre;padding:4px 8px;outline:none;color:#bcbec4}.log .scroller .content .line[data-v-681db452]{height:25px;caret-color:transparent!important;font-size:16px;display:contents;padding:0 2px 0 6px}.log .scroller .content .line .flex[data-v-681db452]{display:-webkit-box;display:-ms-flexbox;display:flex;-webkit-box-align:center;-ms-flex-align:center;align-items:center;gap:5px}.log .scroller .content .line .text[data-v-681db452]{font-size:16px}[data-v-681db452] .ant-modal{max-width:100%;top:0;padding-bottom:0;margin:0}[data-v-681db452] .ant-modal-content{display:-webkit-box;display:-ms-flexbox;display:flex;-webkit-box-orient:vertical;-webkit-box-direction:normal;-ms-flex-direction:column;flex-direction:column;height:100vh}[data-v-681db452] .ant-modal-body{-webkit-box-flex:1;-ms-flex:1;flex:1;padding:0}
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-1136b4c6"],{"430f":function(e,t,n){"use strict";n("f8f4")},"71bc":function(e,t,n){"use strict";n.d(t,"a",(function(){return o}));n("80ab"),n("a98c"),n("3dec"),n("e73f"),n("0c40"),n("79da");function o(e){return o="function"===typeof Symbol&&"symbol"===typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"===typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},o(e)}},"8f70":function(e,t,n){"use strict";var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:("production"===e.mode?e.baseUrl:"")+"/lib/index.html?id="+e.id+"&mode="+e.mode+"&x1c2Hdd6="+e.value,marginwidth:"0",frameborder:"no"}})},s=[],i=n("71bc"),r={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(i["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},a=r,c=(n("430f"),n("f7c6")),u=Object(c["a"])(a,o,s,!1,null,null,null);t["a"]=u.exports},e9f5:function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("work-flow",{attrs:{value:"wA4wN1nZ"}})},s=[],i=n("8f70"),r={name:"WorkFlowEdit",components:{WorkFlow:i["a"]}},a=r,c=n("f7c6"),u=Object(c["a"])(a,o,s,!1,null,null,null);t["default"]=u.exports},f8f4:function(e,t,n){}}]);
|
||||
File diff suppressed because one or more lines are too long
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-21492311"],{"8f70":function(e,t,n){"use strict";n("99af");var o=function(){var e=this,t=e._self._c;return t("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:"".concat("production"===e.mode?e.baseUrl:"","/lib/index.html?id=").concat(e.id,"&mode=").concat(e.mode,"&x1c2Hdd6=").concat(e.value),marginwidth:"0",frameborder:"no"}})},s=[],a=n("53ca"),i={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(a["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},r=i,c=(n("a3be"),n("2877")),d=Object(c["a"])(r,o,s,!1,null,null,null);t["a"]=d.exports},a3be:function(e,t,n){"use strict";n("f945")},e9f5:function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e._self._c;return t("work-flow",{attrs:{value:"wA4wN1nZ"}})},s=[],a=n("8f70"),i={name:"WorkFlowEdit",components:{WorkFlow:a["a"]}},r=i,c=n("2877"),d=Object(c["a"])(r,o,s,!1,null,null,null);t["default"]=d.exports},f945:function(e,t,n){}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-251479d0"],{"339f":function(t,e,r){"use strict";var a=function(){var t=this,e=this,r=e._self._c;return r("div",[r("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[r("span",{staticStyle:{"padding-left":"18px"}},[e._v("调用日志详情 (总调度次数: "+e._s(e.total)+")")]),r("span",{staticStyle:{"padding-left":"18px"}},[r("a-icon",{attrs:{type:"sync"},on:{click:function(){return t.$refs.table.refresh(!0)}}})],1)]),r("a-card",[r("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:e.columns,data:e.loadData},scopedSlots:e._u([{key:"serial",fn:function(t,a){return r("span",{},[e._v(" "+e._s(a.id)+" ")])}},{key:"clientInfo",fn:function(t){return r("span",{},[e._v(" "+e._s(t?t.split("@")[1]:"无")+" ")])}}])})],1)],1)},s=[],n=r("c1df"),o=r.n(n),i=r("0fea"),l=r("2af9"),c={name:"RetryTaskLogMessageList",components:{STable:l["i"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"地址",dataIndex:"clientInfo",scopedSlots:{customRender:"clientInfo"},width:"10%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){if(t.queryParam["groupName"])return Object(i["w"])(Object.assign(e,t.queryParam)).then((function(e){return t.total=e.total,e}))},total:0}},methods:{refreshTable:function(t){this.queryParam=t,this.$refs.table.refresh(!0)}}},d=c,u=r("2877"),f=Object(u["a"])(d,a,s,!1,null,"7ee48017",null);e["a"]=f.exports},"5fe2":function(t,e,r){"use strict";r.r(e);r("ac1f"),r("5319"),r("b0c0");var a=function(){var t=this,e=t._self._c;return e("div",[t.showHeader?e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.replace("/retry/log/list")}}},[e("div")]):t._e(),e("a-card",{attrs:{bordered:!1}},[null!==t.retryInfo?e("a-descriptions",{attrs:{title:"",column:t.column,bordered:""}},[e("a-descriptions-item",{attrs:{label:"组名称"}},[t._v(" "+t._s(t.retryInfo.groupName)+" ")]),e("a-descriptions-item",{attrs:{label:"场景名称"}},[t._v(" "+t._s(t.retryInfo.sceneName)+" ")]),e("a-descriptions-item",{attrs:{label:"唯一id"}},[t._v(" "+t._s(t.retryInfo.uniqueId)+" ")]),e("a-descriptions-item",{attrs:{label:"幂等id",span:2}},[t._v(" "+t._s(t.retryInfo.idempotentId)+" ")]),e("a-descriptions-item",{attrs:{label:"业务编号"}},[t._v(" "+t._s(t.retryInfo.bizNo)+" ")]),e("a-descriptions-item",{attrs:{label:"当前重试状态 | 数据类型"}},[e("a-tag",{attrs:{color:"red"}},[t._v(" "+t._s(t.retryStatus[t.retryInfo.retryStatus])+" ")]),e("a-divider",{attrs:{type:"vertical"}}),e("a-tag",{attrs:{color:t.taskType[t.retryInfo.taskType].color}},[t._v(" "+t._s(t.taskType[t.retryInfo.taskType].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"创建时间"}},[t._v(" "+t._s(t.retryInfo.createDt)+" ")]),e("a-descriptions-item",{attrs:{label:"执行器名称",span:3}},[t._v(" "+t._s(t.retryInfo.executorName)+" ")]),e("a-descriptions-item",{attrs:{label:"参数",span:3}},[t._v(" "+t._s(t.retryInfo.argsStr)+" ")]),e("a-descriptions-item",{attrs:{label:"扩展参数",span:3}},[t._v(" "+t._s(t.retryInfo.extAttrs)+" ")])],1):t._e()],1),e("RetryTaskLogMessageList",{ref:"retryTaskLogMessageListRef"})],1)},s=[],n=(r("a9e3"),r("0fea")),o=r("2af9"),i=r("339f"),l={name:"RetryLogInfo",components:{RetryTaskLogMessageList:i["a"],STable:o["i"]},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{retryInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this.$route.query.id;t&&this.getRetryTaskLogById(t)},methods:{getRetryTaskLogById:function(t){var e=this;Object(n["v"])(t).then((function(t){e.retryInfo=t.data,e.queryParam={groupName:e.retryInfo.groupName,uniqueId:e.retryInfo.uniqueId},e.$refs.retryTaskLogMessageListRef.refreshTable(e.queryParam)}))}}},c=l,d=r("2877"),u=Object(d["a"])(c,a,s,!1,null,"3750b48e",null);e["default"]=u.exports}}]);
|
||||
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-251479d0"],{"339f":function(t,e,r){"use strict";var a=function(){var t=this,e=this,r=e.$createElement,a=e._self._c||r;return a("div",[a("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[a("span",{staticStyle:{"padding-left":"18px"}},[e._v("调用日志详情 (总调度次数: "+e._s(e.total)+")")]),a("span",{staticStyle:{"padding-left":"18px"}},[a("a-icon",{attrs:{type:"sync"},on:{click:function(){return t.$refs.table.refresh(!0)}}})],1)]),a("a-card",[a("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:e.columns,data:e.loadData},scopedSlots:e._u([{key:"serial",fn:function(t,r){return a("span",{},[e._v(" "+e._s(r.id)+" ")])}},{key:"clientInfo",fn:function(t){return a("span",{},[e._v(" "+e._s(t?t.split("@")[1]:"无")+" ")])}}])})],1)],1)},s=[],n=r("1635"),o=r.n(n),i=r("0fea"),l=r("2af9"),c={name:"RetryTaskLogMessageList",components:{STable:l["i"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"地址",dataIndex:"clientInfo",scopedSlots:{customRender:"clientInfo"},width:"10%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){if(t.queryParam["groupName"])return Object(i["w"])(Object.assign(e,t.queryParam)).then((function(e){return t.total=e.total,e}))},total:0}},methods:{refreshTable:function(t){this.queryParam=t,this.$refs.table.refresh(!0)}}},d=c,u=r("f7c6"),f=Object(u["a"])(d,a,s,!1,null,"7ee48017",null);e["a"]=f.exports},"5fe2":function(t,e,r){"use strict";r.r(e);var a=function(){var t=this,e=t.$createElement,r=t._self._c||e;return r("div",[t.showHeader?r("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.replace("/retry/log/list")}}},[r("div")]):t._e(),r("a-card",{attrs:{bordered:!1}},[null!==t.retryInfo?r("a-descriptions",{attrs:{title:"",column:t.column,bordered:""}},[r("a-descriptions-item",{attrs:{label:"组名称"}},[t._v(" "+t._s(t.retryInfo.groupName)+" ")]),r("a-descriptions-item",{attrs:{label:"场景名称"}},[t._v(" "+t._s(t.retryInfo.sceneName)+" ")]),r("a-descriptions-item",{attrs:{label:"唯一id"}},[t._v(" "+t._s(t.retryInfo.uniqueId)+" ")]),r("a-descriptions-item",{attrs:{label:"幂等id",span:2}},[t._v(" "+t._s(t.retryInfo.idempotentId)+" ")]),r("a-descriptions-item",{attrs:{label:"业务编号"}},[t._v(" "+t._s(t.retryInfo.bizNo)+" ")]),r("a-descriptions-item",{attrs:{label:"当前重试状态 | 数据类型"}},[r("a-tag",{attrs:{color:"red"}},[t._v(" "+t._s(t.retryStatus[t.retryInfo.retryStatus])+" ")]),r("a-divider",{attrs:{type:"vertical"}}),r("a-tag",{attrs:{color:t.taskType[t.retryInfo.taskType].color}},[t._v(" "+t._s(t.taskType[t.retryInfo.taskType].name)+" ")])],1),r("a-descriptions-item",{attrs:{label:"创建时间"}},[t._v(" "+t._s(t.retryInfo.createDt)+" ")]),r("a-descriptions-item",{attrs:{label:"执行器名称",span:3}},[t._v(" "+t._s(t.retryInfo.executorName)+" ")]),r("a-descriptions-item",{attrs:{label:"参数",span:3}},[t._v(" "+t._s(t.retryInfo.argsStr)+" ")]),r("a-descriptions-item",{attrs:{label:"扩展参数",span:3}},[t._v(" "+t._s(t.retryInfo.extAttrs)+" ")])],1):t._e()],1),r("RetryTaskLogMessageList",{ref:"retryTaskLogMessageListRef"})],1)},s=[],n=(r("d6a4"),r("0fea")),o=r("2af9"),i=r("339f"),l={name:"RetryLogInfo",components:{RetryTaskLogMessageList:i["a"],STable:o["i"]},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{retryInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this.$route.query.id;t&&this.getRetryTaskLogById(t)},methods:{getRetryTaskLogById:function(t){var e=this;Object(n["v"])(t).then((function(t){e.retryInfo=t.data,e.queryParam={groupName:e.retryInfo.groupName,uniqueId:e.retryInfo.uniqueId},e.$refs.retryTaskLogMessageListRef.refreshTable(e.queryParam)}))}}},c=l,d=r("f7c6"),u=Object(d["a"])(c,a,s,!1,null,"3750b48e",null);e["default"]=u.exports}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0aa660"],{"119c":function(t,a,e){"use strict";e.r(a);var o=function(){var t=this,a=this,e=a.$createElement,o=a._self._c||e;return o("div",[a.showHeader?o("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return a.$router.replace("/job/batch/list")}}},[o("div")]):a._e(),null!==a.jobBatchInfo?o("a-card",{attrs:{bordered:!1}},[o("a-descriptions",{attrs:{title:"",column:a.column,bordered:""}},[o("a-descriptions-item",{attrs:{label:"组名称"}},[a._v(" "+a._s(a.jobBatchInfo.groupName)+" ")]),o("a-descriptions-item",{attrs:{label:"任务名称"}},[a._v(" "+a._s(a.jobBatchInfo.jobName)+" ")]),o("a-descriptions-item",{attrs:{label:"状态"}},[o("a-tag",{attrs:{color:a.taskBatchStatus[a.jobBatchInfo.taskBatchStatus].color}},[a._v(" "+a._s(a.taskBatchStatus[a.jobBatchInfo.taskBatchStatus].name)+" ")])],1),o("a-descriptions-item",{attrs:{label:"执行器类型"}},[o("a-tag",{attrs:{color:a.executorType[a.jobBatchInfo.executorType].color}},[a._v(" "+a._s(a.executorType[a.jobBatchInfo.executorType].name)+" ")])],1),o("a-descriptions-item",{attrs:{label:"操作原因"}},[o("a-tag",{attrs:{color:a.operationReason[a.jobBatchInfo.operationReason].color}},[a._v(" "+a._s(a.operationReason[a.jobBatchInfo.operationReason].name)+" ")])],1),o("a-descriptions-item",{attrs:{label:"开始执行时间"}},[a._v(" "+a._s(a.jobBatchInfo.executionAt)+" ")]),o("a-descriptions-item",{attrs:{label:"执行器名称",span:"4"}},[a._v(" "+a._s(a.jobBatchInfo.executorInfo)+" ")]),o("a-descriptions-item",{attrs:{label:"创建时间"}},[a._v(" "+a._s(a.jobBatchInfo.createDt)+" ")])],1)],1):a._e(),o("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[o("span",{staticStyle:{"padding-left":"18px"}},[a._v("任务项列表")]),o("span",{staticStyle:{"padding-left":"18px"}},[o("a-icon",{attrs:{type:"sync"},on:{click:function(){return t.$refs.JobTaskListRef.refreshTable(t.queryParam)}}})],1)]),o("JobTaskList",{ref:"JobTaskListRef"})],1)},r=[],s=(e("d6a4"),e("3b7a")),n=e("1635"),c=e.n(n),i=e("38b7"),l=e.n(i),p=e("36e8"),u={name:"JobInfo",components:{JobTaskList:p["default"]},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{jobBatchInfo:null,taskBatchStatus:l.a.taskBatchStatus,operationReason:l.a.operationReason,taskType:l.a.taskType,triggerType:l.a.triggerType,blockStrategy:l.a.blockStrategy,executorType:l.a.executorType,queryParam:{}}},created:function(){var t=this.$route.query.id,a=this.$route.query.groupName;t&&a?this.jobBatchDetail(t):this.showHeader&&this.$router.push({path:"/404"})},methods:{parseDate:function(t){return c()(t).format("YYYY-MM-DD HH:mm:ss")},jobBatchDetail:function(t){var a=this;Object(s["g"])(t).then((function(e){a.jobBatchInfo=e.data,a.queryParam={groupName:a.jobBatchInfo.groupName,taskBatchId:t,startId:0,fromIndex:0},a.$refs.JobTaskListRef.refreshTable(a.queryParam)}))}}},b=u,f=e("f7c6"),d=Object(f["a"])(b,o,r,!1,null,"14ced32a",null);a["default"]=d.exports}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0aa660"],{"119c":function(t,a,e){"use strict";e.r(a);e("ac1f"),e("5319"),e("b0c0");var o=function(){var t=this,a=this,e=a._self._c;return e("div",[a.showHeader?e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return a.$router.replace("/job/batch/list")}}},[e("div")]):a._e(),null!==a.jobBatchInfo?e("a-card",{attrs:{bordered:!1}},[e("a-descriptions",{attrs:{title:"",column:a.column,bordered:""}},[e("a-descriptions-item",{attrs:{label:"组名称"}},[a._v(" "+a._s(a.jobBatchInfo.groupName)+" ")]),e("a-descriptions-item",{attrs:{label:"任务名称"}},[a._v(" "+a._s(a.jobBatchInfo.jobName)+" ")]),e("a-descriptions-item",{attrs:{label:"状态"}},[e("a-tag",{attrs:{color:a.taskBatchStatus[a.jobBatchInfo.taskBatchStatus].color}},[a._v(" "+a._s(a.taskBatchStatus[a.jobBatchInfo.taskBatchStatus].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"执行器类型"}},[e("a-tag",{attrs:{color:a.executorType[a.jobBatchInfo.executorType].color}},[a._v(" "+a._s(a.executorType[a.jobBatchInfo.executorType].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"操作原因"}},[e("a-tag",{attrs:{color:a.operationReason[a.jobBatchInfo.operationReason].color}},[a._v(" "+a._s(a.operationReason[a.jobBatchInfo.operationReason].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"开始执行时间"}},[a._v(" "+a._s(a.jobBatchInfo.executionAt)+" ")]),e("a-descriptions-item",{attrs:{label:"执行器名称",span:"4"}},[a._v(" "+a._s(a.jobBatchInfo.executorInfo)+" ")]),e("a-descriptions-item",{attrs:{label:"创建时间"}},[a._v(" "+a._s(a.jobBatchInfo.createDt)+" ")])],1)],1):a._e(),e("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[e("span",{staticStyle:{"padding-left":"18px"}},[a._v("任务项列表")]),e("span",{staticStyle:{"padding-left":"18px"}},[e("a-icon",{attrs:{type:"sync"},on:{click:function(){return t.$refs.JobTaskListRef.refreshTable(t.queryParam)}}})],1)]),e("JobTaskList",{ref:"JobTaskListRef"})],1)},r=[],s=(e("a9e3"),e("3b7a")),n=e("c1df"),c=e.n(n),i=e("38b7"),p=e.n(i),u=e("36e8"),l={name:"JobInfo",components:{JobTaskList:u["default"]},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{jobBatchInfo:null,taskBatchStatus:p.a.taskBatchStatus,operationReason:p.a.operationReason,taskType:p.a.taskType,triggerType:p.a.triggerType,blockStrategy:p.a.blockStrategy,executorType:p.a.executorType,queryParam:{}}},created:function(){var t=this.$route.query.id,a=this.$route.query.groupName;t&&a?this.jobBatchDetail(t):this.showHeader&&this.$router.push({path:"/404"})},methods:{parseDate:function(t){return c()(t).format("YYYY-MM-DD HH:mm:ss")},jobBatchDetail:function(t){var a=this;Object(s["g"])(t).then((function(e){a.jobBatchInfo=e.data,a.queryParam={groupName:a.jobBatchInfo.groupName,taskBatchId:t,startId:0,fromIndex:0},a.$refs.JobTaskListRef.refreshTable(a.queryParam)}))}}},b=l,f=e("2877"),d=Object(f["a"])(b,o,r,!1,null,"14ced32a",null);a["default"]=d.exports}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0c8f97"],{"56bb":function(e,t,r){"use strict";r.r(t);r("ac1f"),r("5319"),r("b0c0");var a=function(){var e=this,t=e._self._c;return t("div",[e.showHeader?t("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return e.$router.replace("/retry/dead-letter/list")}}},[t("div")]):e._e(),t("a-card",{attrs:{bordered:!1}},[null!==e.retryDealLetterInfo?t("a-descriptions",{attrs:{title:"",column:e.column,bordered:""}},[t("a-descriptions-item",{attrs:{label:"组名称"}},[e._v(" "+e._s(e.retryDealLetterInfo.groupName)+" ")]),t("a-descriptions-item",{attrs:{label:"场景名称"}},[e._v(" "+e._s(e.retryDealLetterInfo.sceneName)+" ")]),t("a-descriptions-item",{attrs:{label:"业务id",span:"2"}},[e._v(" "+e._s(e.retryDealLetterInfo.idempotentId)+" ")]),t("a-descriptions-item",{attrs:{label:"业务编号"}},[e._v(" "+e._s(e.retryDealLetterInfo.bizNo)+" ")]),t("a-descriptions-item",{attrs:{label:"数据类型"}},[t("a-tag",{attrs:{color:e.taskType[e.retryDealLetterInfo.taskType].color}},[e._v(" "+e._s(e.taskType[e.retryDealLetterInfo.taskType].name)+" ")])],1),t("a-descriptions-item",{attrs:{label:"创建时间"}},[e._v(" "+e._s(e.retryDealLetterInfo.createDt)+" ")]),t("a-descriptions-item",{attrs:{label:"执行器名称",span:"2"}},[e._v(" "+e._s(e.retryDealLetterInfo.executorName)+" ")]),t("a-descriptions-item",{attrs:{label:"扩展参数",span:"3"}},[e._v(" "+e._s(e.retryDealLetterInfo.bizNo)+" ")]),t("a-descriptions-item",{attrs:{label:"参数",span:"3"}},[e._v(" "+e._s(e.retryDealLetterInfo.argsStr)+" ")])],1):e._e()],1)],1)},s=[],n=(r("a9e3"),r("0fea")),o={name:"RetryDeadLetterInfo",props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{retryDealLetterInfo:null,taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var e=this.$route.query.id,t=this.$route.query.groupName;e&&t&&this.retryDeadLetterById(e,t)},methods:{retryDeadLetterById:function(e,t){var r=this;Object(n["s"])(e,{groupName:t}).then((function(e){r.retryDealLetterInfo=e.data}))}}},l=o,i=r("2877"),c=Object(i["a"])(l,a,s,!1,null,"7c315ea2",null);t["default"]=c.exports}}]);
|
||||
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0c8f97"],{"56bb":function(e,t,r){"use strict";r.r(t);var a=function(){var e=this,t=e.$createElement,r=e._self._c||t;return r("div",[e.showHeader?r("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return e.$router.replace("/retry/dead-letter/list")}}},[r("div")]):e._e(),r("a-card",{attrs:{bordered:!1}},[null!==e.retryDealLetterInfo?r("a-descriptions",{attrs:{title:"",column:e.column,bordered:""}},[r("a-descriptions-item",{attrs:{label:"组名称"}},[e._v(" "+e._s(e.retryDealLetterInfo.groupName)+" ")]),r("a-descriptions-item",{attrs:{label:"场景名称"}},[e._v(" "+e._s(e.retryDealLetterInfo.sceneName)+" ")]),r("a-descriptions-item",{attrs:{label:"业务id",span:"2"}},[e._v(" "+e._s(e.retryDealLetterInfo.idempotentId)+" ")]),r("a-descriptions-item",{attrs:{label:"业务编号"}},[e._v(" "+e._s(e.retryDealLetterInfo.bizNo)+" ")]),r("a-descriptions-item",{attrs:{label:"数据类型"}},[r("a-tag",{attrs:{color:e.taskType[e.retryDealLetterInfo.taskType].color}},[e._v(" "+e._s(e.taskType[e.retryDealLetterInfo.taskType].name)+" ")])],1),r("a-descriptions-item",{attrs:{label:"创建时间"}},[e._v(" "+e._s(e.retryDealLetterInfo.createDt)+" ")]),r("a-descriptions-item",{attrs:{label:"执行器名称",span:"2"}},[e._v(" "+e._s(e.retryDealLetterInfo.executorName)+" ")]),r("a-descriptions-item",{attrs:{label:"扩展参数",span:"3"}},[e._v(" "+e._s(e.retryDealLetterInfo.bizNo)+" ")]),r("a-descriptions-item",{attrs:{label:"参数",span:"3"}},[e._v(" "+e._s(e.retryDealLetterInfo.argsStr)+" ")])],1):e._e()],1)],1)},s=[],n=(r("d6a4"),r("0fea")),o={name:"RetryDeadLetterInfo",props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{retryDealLetterInfo:null,taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var e=this.$route.query.id,t=this.$route.query.groupName;e&&t&&this.retryDeadLetterById(e,t)},methods:{retryDeadLetterById:function(e,t){var r=this;Object(n["s"])(e,{groupName:t}).then((function(e){r.retryDealLetterInfo=e.data}))}}},l=o,i=r("f7c6"),d=Object(i["a"])(l,a,s,!1,null,"7c315ea2",null);t["default"]=d.exports}}]);
|
||||
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0e488b"],{9141:function(t,e,a){"use strict";a.r(e);var o=function(){var t=this,e=t.$createElement,a=t._self._c||e;return a("a-card",{attrs:{bordered:!1}},[a("div",{staticClass:"table-page-search-wrapper"},[a("a-form",{attrs:{layout:"inline"}},[a("a-row",{attrs:{gutter:48}},[[a("a-col",{attrs:{md:8,sm:24}},[a("a-form-item",{attrs:{label:"组名称"}},[a("a-input",{attrs:{placeholder:"请输入组名称",allowClear:""},model:{value:t.queryParam.groupName,callback:function(e){t.$set(t.queryParam,"groupName",e)},expression:"queryParam.groupName"}})],1)],1)],a("a-col",{attrs:{md:t.advanced?24:8,sm:24}},[a("span",{staticClass:"table-page-search-submitButtons",style:t.advanced&&{float:"right",overflow:"hidden"}||{}},[a("a-button",{attrs:{type:"primary"},on:{click:function(e){return t.$refs.table.refresh(!0)}}},[t._v("查询")]),a("a-button",{staticStyle:{"margin-left":"8px"},on:{click:function(){return t.queryParam={}}}},[t._v("重置")])],1)])],2)],1)],1),a("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:t.columns,data:t.loadData,alert:t.options.alert,rowSelection:t.options.rowSelection,scroll:{x:1600}},scopedSlots:t._u([{key:"serial",fn:function(e,o,n){return a("span",{},[t._v(" "+t._s(n+1)+" ")])}},{key:"contextPath",fn:function(e,o){return a("span",{},[1===o.nodeType?a("div",[t._v(" Path: "),a("a-tag",{attrs:{color:"#108ee9"}},[t._v(" "+t._s(e)+" ")])],1):a("div",[t._v(" Bucket: "),a("a-popover",{attrs:{placement:"topLeft"}},[a("template",{slot:"content"},t._l(o.consumerBuckets,(function(e){return a("a-tag",{key:e,staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" "+t._s(e)+" ")])})),1),a("template",{slot:"title"},[a("span",[t._v("Bucket列表")])]),t._l(5,(function(e){return a("a-tag",{key:e,staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" "+t._s(o.consumerBuckets[e-1])+" ")])})),o.consumerBuckets.length>5?a("a-tag",{staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" ... ")]):t._e()],2)],1)])}}])})],1)},n=[],r=a("1635"),s=a.n(r),l=a("0fea"),c=a("2af9"),i={name:"PodList",components:{STable:c["i"]},data:function(){var t=this;return{advanced:!1,queryParam:{},columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"6%"},{title:"类型",dataIndex:"nodeType",customRender:function(e){return t.nodeType[e]},width:"8%"},{title:"组名称",dataIndex:"groupName",width:"10%"},{title:"PodId",dataIndex:"hostId",width:"18%"},{title:"IP",dataIndex:"hostIp",width:"12%"},{title:"Port",dataIndex:"hostPort",width:"8%"},{title:"路径/组",dataIndex:"contextPath",scopedSlots:{customRender:"contextPath"},ellipsis:!0,width:"22%"},{title:"更新时间",dataIndex:"updateDt",sorter:!0,customRender:function(t){return s()(t).format("YYYY-MM-DD HH:mm:ss")}}],loadData:function(e){return Object(l["J"])(Object.assign(e,t.queryParam)).then((function(t){return t}))},selectedRowKeys:[],selectedRows:[],options:{alert:{show:!0,clear:function(){t.selectedRowKeys=[]}},rowSelection:{selectedRowKeys:this.selectedRowKeys,onChange:this.onSelectChange}},nodeType:{1:"客户端",2:"服务端"}}},methods:{}},d=i,u=a("f7c6"),p=Object(u["a"])(d,o,n,!1,null,"38a41799",null);e["default"]=p.exports}}]);
|
||||
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-3319a472"],{"430f":function(e,t,n){"use strict";n("f8f4")},6139:function(e,t,n){"use strict";n("b9f2")},"71bc":function(e,t,n){"use strict";n.d(t,"a",(function(){return o}));n("80ab"),n("a98c"),n("3dec"),n("e73f"),n("0c40"),n("79da");function o(e){return o="function"===typeof Symbol&&"symbol"===typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"===typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},o(e)}},8186:function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("work-flow",{attrs:{value:"kaxC8Iml"}})},s=[],i=n("8f70"),r={name:"WorkFlowDetail",components:{WorkFlow:i["a"]}},a=r,c=(n("6139"),n("f7c6")),u=Object(c["a"])(a,o,s,!1,null,null,null);t["default"]=u.exports},"8f70":function(e,t,n){"use strict";var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:("production"===e.mode?e.baseUrl:"")+"/lib/index.html?id="+e.id+"&mode="+e.mode+"&x1c2Hdd6="+e.value,marginwidth:"0",frameborder:"no"}})},s=[],i=n("71bc"),r={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(i["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},a=r,c=(n("430f"),n("f7c6")),u=Object(c["a"])(a,o,s,!1,null,null,null);t["a"]=u.exports},b9f2:function(e,t,n){},f8f4:function(e,t,n){}}]);
|
||||
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-35f76107"],{"339f":function(t,e,a){"use strict";var r=function(){var t=this,e=this,a=e.$createElement,r=e._self._c||a;return r("div",[r("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[r("span",{staticStyle:{"padding-left":"18px"}},[e._v("调用日志详情 (总调度次数: "+e._s(e.total)+")")]),r("span",{staticStyle:{"padding-left":"18px"}},[r("a-icon",{attrs:{type:"sync"},on:{click:function(){return t.$refs.table.refresh(!0)}}})],1)]),r("a-card",[r("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:e.columns,data:e.loadData},scopedSlots:e._u([{key:"serial",fn:function(t,a){return r("span",{},[e._v(" "+e._s(a.id)+" ")])}},{key:"clientInfo",fn:function(t){return r("span",{},[e._v(" "+e._s(t?t.split("@")[1]:"无")+" ")])}}])})],1)],1)},s=[],n=a("1635"),o=a.n(n),i=a("0fea"),l=a("2af9"),u={name:"RetryTaskLogMessageList",components:{STable:l["i"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"地址",dataIndex:"clientInfo",scopedSlots:{customRender:"clientInfo"},width:"10%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){if(t.queryParam["groupName"])return Object(i["w"])(Object.assign(e,t.queryParam)).then((function(e){return t.total=e.total,e}))},total:0}},methods:{refreshTable:function(t){this.queryParam=t,this.$refs.table.refresh(!0)}}},c=u,d=a("f7c6"),f=Object(d["a"])(c,r,s,!1,null,"7ee48017",null);e["a"]=f.exports},"99f5":function(t,e,a){"use strict";a.r(e);var r=function(){var t=this,e=t.$createElement,a=t._self._c||e;return a("div",[t.showHeader?a("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.replace("/retry/list")}}},[a("div")]):t._e(),null!==t.retryTaskInfo?a("a-card",{attrs:{bordered:!1}},[a("a-descriptions",{attrs:{title:"",column:t.column,bordered:""}},[a("a-descriptions-item",{attrs:{label:"组名称"}},[t._v(" "+t._s(t.retryTaskInfo.groupName)+" ")]),a("a-descriptions-item",{attrs:{label:"场景名称"}},[t._v(" "+t._s(t.retryTaskInfo.sceneName)+" ")]),a("a-descriptions-item",{attrs:{label:"幂等id"}},[t._v(" "+t._s(t.retryTaskInfo.idempotentId)+" ")]),a("a-descriptions-item",{attrs:{label:"唯一id"}},[t._v(" "+t._s(t.retryTaskInfo.uniqueId)+" ")]),a("a-descriptions-item",{attrs:{label:"业务编号"}},[t._v(" "+t._s(t.retryTaskInfo.bizNo)+" ")]),a("a-descriptions-item",{attrs:{label:"重试次数"}},[t._v(" "+t._s(t.retryTaskInfo.retryCount)+" ")]),a("a-descriptions-item",{attrs:{label:"重试状态 | 数据类型"}},[a("a-tag",{attrs:{color:"red"}},[t._v(" "+t._s(t.retryStatus[t.retryTaskInfo.retryStatus])+" ")]),a("a-divider",{attrs:{type:"vertical"}}),a("a-tag",{attrs:{color:t.taskType[t.retryTaskInfo.taskType].color}},[t._v(" "+t._s(t.taskType[t.retryTaskInfo.taskType].name)+" ")])],1),a("a-descriptions-item",{attrs:{label:"下次触发时间"}},[t._v(" "+t._s(t.retryTaskInfo.nextTriggerAt)+" ")]),a("a-descriptions-item",{attrs:{label:"更新时间"}},[t._v(" "+t._s(t.retryTaskInfo.updateDt)+" ")]),a("a-descriptions-item",{attrs:{label:"执行器名称",span:"3"}},[t._v(" "+t._s(t.retryTaskInfo.executorName)+" ")]),a("a-descriptions-item",{attrs:{label:"参数",span:"3"}},[t._v(" "+t._s(t.retryTaskInfo.argsStr)+" ")]),a("a-descriptions-item",{attrs:{label:"扩展参数",span:"3"}},[t._v(" "+t._s(t.retryTaskInfo.extAttrs)+" ")])],1)],1):t._e(),a("RetryTaskLogMessageList",{ref:"retryTaskLogMessageListRef"})],1)},s=[],n=(a("d6a4"),a("0fea")),o=a("339f"),i={name:"RetryTaskInfo",components:{RetryTaskLogMessageList:o["a"]},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{retryTaskInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数",3:"暂停"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this.$route.query.id,e=this.$route.query.groupName;t&&e?this.getRetryTaskById(t,e):this.showHeader&&this.$router.push({path:"/404"})},methods:{getRetryTaskById:function(t,e){var a=this;Object(n["u"])(t,{groupName:e}).then((function(t){a.retryTaskInfo=t.data,a.queryParam={groupName:a.retryTaskInfo.groupName,uniqueId:a.retryTaskInfo.uniqueId},a.$refs.retryTaskLogMessageListRef.refreshTable(a.queryParam)}))}}},l=i,u=a("f7c6"),c=Object(u["a"])(l,r,s,!1,null,"0b3ba3ef",null);e["default"]=c.exports}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-35f76107"],{"339f":function(t,e,a){"use strict";var r=function(){var t=this,e=this,a=e._self._c;return a("div",[a("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[a("span",{staticStyle:{"padding-left":"18px"}},[e._v("调用日志详情 (总调度次数: "+e._s(e.total)+")")]),a("span",{staticStyle:{"padding-left":"18px"}},[a("a-icon",{attrs:{type:"sync"},on:{click:function(){return t.$refs.table.refresh(!0)}}})],1)]),a("a-card",[a("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:e.columns,data:e.loadData},scopedSlots:e._u([{key:"serial",fn:function(t,r){return a("span",{},[e._v(" "+e._s(r.id)+" ")])}},{key:"clientInfo",fn:function(t){return a("span",{},[e._v(" "+e._s(t?t.split("@")[1]:"无")+" ")])}}])})],1)],1)},s=[],n=a("c1df"),o=a.n(n),i=a("0fea"),l=a("2af9"),u={name:"RetryTaskLogMessageList",components:{STable:l["i"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"地址",dataIndex:"clientInfo",scopedSlots:{customRender:"clientInfo"},width:"10%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){if(t.queryParam["groupName"])return Object(i["w"])(Object.assign(e,t.queryParam)).then((function(e){return t.total=e.total,e}))},total:0}},methods:{refreshTable:function(t){this.queryParam=t,this.$refs.table.refresh(!0)}}},d=u,c=a("2877"),f=Object(c["a"])(d,r,s,!1,null,"7ee48017",null);e["a"]=f.exports},"99f5":function(t,e,a){"use strict";a.r(e);a("ac1f"),a("5319"),a("b0c0");var r=function(){var t=this,e=t._self._c;return e("div",[t.showHeader?e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.replace("/retry/list")}}},[e("div")]):t._e(),null!==t.retryTaskInfo?e("a-card",{attrs:{bordered:!1}},[e("a-descriptions",{attrs:{title:"",column:t.column,bordered:""}},[e("a-descriptions-item",{attrs:{label:"组名称"}},[t._v(" "+t._s(t.retryTaskInfo.groupName)+" ")]),e("a-descriptions-item",{attrs:{label:"场景名称"}},[t._v(" "+t._s(t.retryTaskInfo.sceneName)+" ")]),e("a-descriptions-item",{attrs:{label:"幂等id"}},[t._v(" "+t._s(t.retryTaskInfo.idempotentId)+" ")]),e("a-descriptions-item",{attrs:{label:"唯一id"}},[t._v(" "+t._s(t.retryTaskInfo.uniqueId)+" ")]),e("a-descriptions-item",{attrs:{label:"业务编号"}},[t._v(" "+t._s(t.retryTaskInfo.bizNo)+" ")]),e("a-descriptions-item",{attrs:{label:"重试次数"}},[t._v(" "+t._s(t.retryTaskInfo.retryCount)+" ")]),e("a-descriptions-item",{attrs:{label:"重试状态 | 数据类型"}},[e("a-tag",{attrs:{color:"red"}},[t._v(" "+t._s(t.retryStatus[t.retryTaskInfo.retryStatus])+" ")]),e("a-divider",{attrs:{type:"vertical"}}),e("a-tag",{attrs:{color:t.taskType[t.retryTaskInfo.taskType].color}},[t._v(" "+t._s(t.taskType[t.retryTaskInfo.taskType].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"下次触发时间"}},[t._v(" "+t._s(t.retryTaskInfo.nextTriggerAt)+" ")]),e("a-descriptions-item",{attrs:{label:"更新时间"}},[t._v(" "+t._s(t.retryTaskInfo.updateDt)+" ")]),e("a-descriptions-item",{attrs:{label:"执行器名称",span:"3"}},[t._v(" "+t._s(t.retryTaskInfo.executorName)+" ")]),e("a-descriptions-item",{attrs:{label:"参数",span:"3"}},[t._v(" "+t._s(t.retryTaskInfo.argsStr)+" ")]),e("a-descriptions-item",{attrs:{label:"扩展参数",span:"3"}},[t._v(" "+t._s(t.retryTaskInfo.extAttrs)+" ")])],1)],1):t._e(),e("RetryTaskLogMessageList",{ref:"retryTaskLogMessageListRef"})],1)},s=[],n=(a("a9e3"),a("0fea")),o=a("339f"),i={name:"RetryTaskInfo",components:{RetryTaskLogMessageList:o["a"]},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{retryTaskInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数",3:"暂停"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this.$route.query.id,e=this.$route.query.groupName;t&&e?this.getRetryTaskById(t,e):this.showHeader&&this.$router.push({path:"/404"})},methods:{getRetryTaskById:function(t,e){var a=this;Object(n["u"])(t,{groupName:e}).then((function(t){a.retryTaskInfo=t.data,a.queryParam={groupName:a.retryTaskInfo.groupName,uniqueId:a.retryTaskInfo.uniqueId},a.$refs.retryTaskLogMessageListRef.refreshTable(a.queryParam)}))}}},l=i,u=a("2877"),d=Object(u["a"])(l,r,s,!1,null,"0b3ba3ef",null);e["default"]=d.exports}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-4ed5b3ba"],{"430f":function(e,t,n){"use strict";n("f8f4")},"49de":function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("work-flow",{attrs:{value:"D7Rzd7Oe"}})},s=[],i=n("8f70"),r={name:"WorkFlowEdit",components:{WorkFlow:i["a"]}},a=r,c=n("f7c6"),u=Object(c["a"])(a,o,s,!1,null,null,null);t["default"]=u.exports},"71bc":function(e,t,n){"use strict";n.d(t,"a",(function(){return o}));n("80ab"),n("a98c"),n("3dec"),n("e73f"),n("0c40"),n("79da");function o(e){return o="function"===typeof Symbol&&"symbol"===typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"===typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},o(e)}},"8f70":function(e,t,n){"use strict";var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:("production"===e.mode?e.baseUrl:"")+"/lib/index.html?id="+e.id+"&mode="+e.mode+"&x1c2Hdd6="+e.value,marginwidth:"0",frameborder:"no"}})},s=[],i=n("71bc"),r={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(i["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},a=r,c=(n("430f"),n("f7c6")),u=Object(c["a"])(a,o,s,!1,null,null,null);t["a"]=u.exports},f8f4:function(e,t,n){}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-5e4dab78"],{"12b3":function(o,e){var a={sceneStatus:{0:{name:"停用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},backOffLabels:{1:{name:"延迟等级",color:"#d06892"},2:{name:"固定时间",color:"#f5a22d"},3:{name:"CRON表达式",color:"#e1f52d"},4:{name:"随机等待",color:"#a127f3"}},triggerInterval:{1:{name:"CRON表达式",color:"#d06892"},2:{name:"固定时间",color:"#f5a22d"}},notifyScene:{1:{name:"场景重试数量超过阈值",color:"#d06892"},2:{name:"场景重试失败数量超过阈值",color:"#f5a22d"},3:{name:"客户端上报失败",color:"#e1f52d"},4:{name:"客户端组件异常",color:"#a127f3"},5:{name:"任务重试失败数量超过阈值",color:"#f5a22d"},6:{name:"任务重试失败进入死信队列",color:"#f5a22d"}},routeKey:{4:{name:"轮询",color:"#8f68d2"},1:{name:"一致性Hash",color:"#d06892"},2:{name:"随机",color:"#f5a22d"},3:{name:"LRU",color:"#e1f52d"}},notifyType:{1:{name:"钉钉通知",color:"#64a6ea"},2:{name:"邮箱通知",color:"#1b7ee5"},3:{name:"企业微信",color:"#0082EF"},4:{name:"飞书",color:"#087da1"}},rateLimiterStatus:{0:{name:"未启用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},notifyStatus:{0:{name:"停用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},idGenMode:{1:{name:"号段模式",color:"#1b7ee5"},2:{name:"雪花算法",color:"#087da1"}},groupStatus:{0:{name:"停用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},initScene:{0:{name:"否",color:"#9c1f1f"},1:{name:"是",color:"#f5a22d"}}};o.exports=a},"9b4b":function(o,e,a){"use strict";a.r(e);var r=function(){var o=this,e=o.$createElement,a=o._self._c||e;return a("div",[o.showHeader?a("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return o.$router.replace("/group/list")}}},[a("div")]):o._e(),null!==o.groupInfo?a("a-card",{attrs:{bordered:!1}},[a("a-descriptions",{attrs:{title:"通用配置",column:o.column,bordered:""}},[a("a-descriptions-item",{attrs:{label:"组名称"}},[o._v(" "+o._s(o.groupInfo.groupName)+" ")]),a("a-descriptions-item",{attrs:{label:"状态"}},[a("a-tag",{attrs:{color:o.groupStatus[o.groupInfo.groupStatus].color}},[o._v(" "+o._s(o.groupStatus[o.groupInfo.groupStatus].name)+" ")])],1),a("a-descriptions-item",{attrs:{label:"版本"}},[o._v(" "+o._s(o.groupInfo.version)+" ")]),a("a-descriptions-item",{attrs:{label:"描述",span:"3"}},[o._v(" "+o._s(o.groupInfo.description)+" ")]),a("a-descriptions-item",{attrs:{label:"OnLine机器",span:"3"}},o._l(o.podInfo,(function(e){return a("a-tag",{key:e,attrs:{color:"blue"}},[o._v(" "+o._s(e)+" ")])})),1)],1),a("br"),a("a-descriptions",{attrs:{title:"重试配置",column:o.column,bordered:""}},[a("a-descriptions-item",{attrs:{label:"ID生成模式"}},[a("a-tag",{attrs:{color:o.idGeneratorMode[o.groupInfo.idGeneratorMode].color}},[o._v(" "+o._s(o.idGeneratorMode[o.groupInfo.idGeneratorMode].name)+" ")])],1),a("a-descriptions-item",{attrs:{label:"分区"}},[o._v(" "+o._s(o.groupInfo.groupPartition)+" ")]),a("a-descriptions-item",{attrs:{label:"初始化场景"}},[a("a-tag",{attrs:{color:o.initScene[o.groupInfo.initScene].color}},[o._v(" "+o._s(o.initScene[o.groupInfo.initScene].name)+" ")])],1)],1)],1):o._e()],1)},t=[],n=(a("d6a4"),a("0fea")),c=a("12b3"),i=a.n(c),l={name:"GroupInfo",components:{},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{groupInfo:null,podInfo:[],initScene:i.a.initScene,groupStatus:i.a.groupStatus,idGeneratorMode:i.a.idGenMode}},created:function(){var o=this.$route.query.groupName;o?this.groupConfigDetail(o):this.showHeader&&this.$router.push({path:"/404"})},methods:{groupConfigDetail:function(o){var e=this;Object(n["o"])(o).then((function(o){e.groupInfo=o.data})),Object(n["I"])(o).then((function(o){e.podInfo=o.data}))}}},s=l,d=a("f7c6"),u=Object(d["a"])(s,r,t,!1,null,"4f09eb18",null);e["default"]=u.exports}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-5e4dab78"],{"12b3":function(o,e){var a={sceneStatus:{0:{name:"停用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},backOffLabels:{1:{name:"延迟等级",color:"#d06892"},2:{name:"固定时间",color:"#f5a22d"},3:{name:"CRON表达式",color:"#e1f52d"},4:{name:"随机等待",color:"#a127f3"}},triggerInterval:{1:{name:"CRON表达式",color:"#d06892"},2:{name:"固定时间",color:"#f5a22d"}},notifyScene:{1:{name:"场景重试数量超过阈值",color:"#d06892"},2:{name:"场景重试失败数量超过阈值",color:"#f5a22d"},3:{name:"客户端上报失败",color:"#e1f52d"},4:{name:"客户端组件异常",color:"#a127f3"},5:{name:"任务重试失败数量超过阈值",color:"#f5a22d"},6:{name:"任务重试失败进入死信队列",color:"#f5a22d"}},routeKey:{4:{name:"轮询",color:"#8f68d2"},1:{name:"一致性Hash",color:"#d06892"},2:{name:"随机",color:"#f5a22d"},3:{name:"LRU",color:"#e1f52d"}},notifyType:{1:{name:"钉钉通知",color:"#64a6ea"},2:{name:"邮箱通知",color:"#1b7ee5"},3:{name:"企业微信",color:"#0082EF"},4:{name:"飞书",color:"#087da1"}},rateLimiterStatus:{0:{name:"未启用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},notifyStatus:{0:{name:"停用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},idGenMode:{1:{name:"号段模式",color:"#1b7ee5"},2:{name:"雪花算法",color:"#087da1"}},groupStatus:{0:{name:"停用",color:"#9c1f1f"},1:{name:"启用",color:"#f5a22d"}},initScene:{0:{name:"否",color:"#9c1f1f"},1:{name:"是",color:"#f5a22d"}}};o.exports=a},"9b4b":function(o,e,a){"use strict";a.r(e);a("ac1f"),a("5319"),a("b0c0"),a("a4d3"),a("e01a");var r=function(){var o=this,e=o._self._c;return e("div",[o.showHeader?e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return o.$router.replace("/group/list")}}},[e("div")]):o._e(),null!==o.groupInfo?e("a-card",{attrs:{bordered:!1}},[e("a-descriptions",{attrs:{title:"通用配置",column:o.column,bordered:""}},[e("a-descriptions-item",{attrs:{label:"组名称"}},[o._v(" "+o._s(o.groupInfo.groupName)+" ")]),e("a-descriptions-item",{attrs:{label:"状态"}},[e("a-tag",{attrs:{color:o.groupStatus[o.groupInfo.groupStatus].color}},[o._v(" "+o._s(o.groupStatus[o.groupInfo.groupStatus].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"版本"}},[o._v(" "+o._s(o.groupInfo.version)+" ")]),e("a-descriptions-item",{attrs:{label:"描述",span:"3"}},[o._v(" "+o._s(o.groupInfo.description)+" ")]),e("a-descriptions-item",{attrs:{label:"OnLine机器",span:"3"}},o._l(o.podInfo,(function(a){return e("a-tag",{key:a,attrs:{color:"blue"}},[o._v(" "+o._s(a)+" ")])})),1)],1),e("br"),e("a-descriptions",{attrs:{title:"重试配置",column:o.column,bordered:""}},[e("a-descriptions-item",{attrs:{label:"ID生成模式"}},[e("a-tag",{attrs:{color:o.idGeneratorMode[o.groupInfo.idGeneratorMode].color}},[o._v(" "+o._s(o.idGeneratorMode[o.groupInfo.idGeneratorMode].name)+" ")])],1),e("a-descriptions-item",{attrs:{label:"分区"}},[o._v(" "+o._s(o.groupInfo.groupPartition)+" ")]),e("a-descriptions-item",{attrs:{label:"初始化场景"}},[e("a-tag",{attrs:{color:o.initScene[o.groupInfo.initScene].color}},[o._v(" "+o._s(o.initScene[o.groupInfo.initScene].name)+" ")])],1)],1)],1):o._e()],1)},t=[],n=(a("a9e3"),a("0fea")),c=a("12b3"),i=a.n(c),l={name:"GroupInfo",components:{},props:{showHeader:{type:Boolean,default:!0},column:{type:Number,default:3}},data:function(){return{groupInfo:null,podInfo:[],initScene:i.a.initScene,groupStatus:i.a.groupStatus,idGeneratorMode:i.a.idGenMode}},created:function(){var o=this.$route.query.groupName;o?this.groupConfigDetail(o):this.showHeader&&this.$router.push({path:"/404"})},methods:{groupConfigDetail:function(o){var e=this;Object(n["o"])(o).then((function(o){e.groupInfo=o.data})),Object(n["I"])(o).then((function(o){e.podInfo=o.data}))}}},s=l,d=a("2877"),u=Object(d["a"])(s,r,t,!1,null,"4f09eb18",null);e["default"]=u.exports}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-6204f6d4"],{"49de":function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e._self._c;return t("work-flow",{attrs:{value:"D7Rzd7Oe"}})},s=[],a=n("8f70"),i={name:"WorkFlowEdit",components:{WorkFlow:a["a"]}},r=i,c=n("2877"),d=Object(c["a"])(r,o,s,!1,null,null,null);t["default"]=d.exports},"8f70":function(e,t,n){"use strict";n("99af");var o=function(){var e=this,t=e._self._c;return t("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:"".concat("production"===e.mode?e.baseUrl:"","/lib/index.html?id=").concat(e.id,"&mode=").concat(e.mode,"&x1c2Hdd6=").concat(e.value),marginwidth:"0",frameborder:"no"}})},s=[],a=n("53ca"),i={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(a["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},r=i,c=(n("a3be"),n("2877")),d=Object(c["a"])(r,o,s,!1,null,null,null);t["a"]=d.exports},a3be:function(e,t,n){"use strict";n("f945")},f945:function(e,t,n){}}]);
|
||||
File diff suppressed because one or more lines are too long
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-6cba1710"],{"8f70":function(e,t,n){"use strict";n("99af");var a=function(){var e=this,t=e._self._c;return t("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:"".concat("production"===e.mode?e.baseUrl:"","/lib/index.html?id=").concat(e.id,"&mode=").concat(e.mode,"&x1c2Hdd6=").concat(e.value),marginwidth:"0",frameborder:"no"}})},o=[],s=n("53ca"),i={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(s["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},r=i,c=(n("a3be"),n("2877")),d=Object(c["a"])(r,a,o,!1,null,null,null);t["a"]=d.exports},a3be:function(e,t,n){"use strict";n("f945")},af96:function(e,t,n){"use strict";n.r(t);var a=function(){var e=this,t=e._self._c;return t("work-flow",{attrs:{value:"xkjIc2ZHZ0"}})},o=[],s=n("8f70"),i={name:"WorkFlowDetail",components:{WorkFlow:s["a"]}},r=i,c=n("2877"),d=Object(c["a"])(r,a,o,!1,null,null,null);t["default"]=d.exports},f945:function(e,t,n){}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-74bac939"],{"9141d":function(t,e,a){"use strict";a.r(e);var o=function(){var t=this,e=t._self._c;return e("a-card",{attrs:{bordered:!1}},[e("div",{staticClass:"table-page-search-wrapper"},[e("a-form",{attrs:{layout:"inline"}},[e("a-row",{attrs:{gutter:48}},[[e("a-col",{attrs:{md:8,sm:24}},[e("a-form-item",{attrs:{label:"组名称"}},[e("a-input",{attrs:{placeholder:"请输入组名称",allowClear:""},model:{value:t.queryParam.groupName,callback:function(e){t.$set(t.queryParam,"groupName",e)},expression:"queryParam.groupName"}})],1)],1)],e("a-col",{attrs:{md:t.advanced?24:8,sm:24}},[e("span",{staticClass:"table-page-search-submitButtons",style:t.advanced&&{float:"right",overflow:"hidden"}||{}},[e("a-button",{attrs:{type:"primary"},on:{click:function(e){return t.$refs.table.refresh(!0)}}},[t._v("查询")]),e("a-button",{staticStyle:{"margin-left":"8px"},on:{click:function(){return t.queryParam={}}}},[t._v("重置")])],1)])],2)],1)],1),e("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:t.columns,data:t.loadData,alert:t.options.alert,rowSelection:t.options.rowSelection,scroll:{x:1600}},scopedSlots:t._u([{key:"serial",fn:function(a,o,n){return e("span",{},[t._v(" "+t._s(n+1)+" ")])}},{key:"contextPath",fn:function(a,o){return e("span",{},[1===o.nodeType?e("div",[t._v(" Path: "),e("a-tag",{attrs:{color:"#108ee9"}},[t._v(" "+t._s(a)+" ")])],1):e("div",[t._v(" Bucket: "),e("a-popover",{attrs:{placement:"topLeft"}},[e("template",{slot:"content"},t._l(o.consumerBuckets,(function(a){return e("a-tag",{key:a,staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" "+t._s(a)+" ")])})),1),e("template",{slot:"title"},[e("span",[t._v("Bucket列表")])]),t._l(5,(function(a){return e("a-tag",{key:a,staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" "+t._s(o.consumerBuckets[a-1])+" ")])})),o.consumerBuckets.length>5?e("a-tag",{staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" ... ")]):t._e()],2)],1)])}}])})],1)},n=[],r=a("c1df"),s=a.n(r),l=a("0fea"),c=a("2af9"),i={name:"PodList",components:{STable:c["i"]},data:function(){var t=this;return{advanced:!1,queryParam:{},columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"6%"},{title:"类型",dataIndex:"nodeType",customRender:function(e){return t.nodeType[e]},width:"8%"},{title:"组名称",dataIndex:"groupName",width:"10%"},{title:"PodId",dataIndex:"hostId",width:"18%"},{title:"IP",dataIndex:"hostIp",width:"12%"},{title:"Port",dataIndex:"hostPort",width:"8%"},{title:"路径/组",dataIndex:"contextPath",scopedSlots:{customRender:"contextPath"},ellipsis:!0,width:"22%"},{title:"更新时间",dataIndex:"updateDt",sorter:!0,customRender:function(t){return s()(t).format("YYYY-MM-DD HH:mm:ss")}}],loadData:function(e){return Object(l["J"])(Object.assign(e,t.queryParam)).then((function(t){return t}))},selectedRowKeys:[],selectedRows:[],options:{alert:{show:!0,clear:function(){t.selectedRowKeys=[]}},rowSelection:{selectedRowKeys:this.selectedRowKeys,onChange:this.onSelectChange}},nodeType:{1:"客户端",2:"服务端"}}},methods:{}},d=i,u=a("2877"),p=Object(u["a"])(d,o,n,!1,null,"38a41799",null);e["default"]=p.exports}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-a2914e04"],{"430f":function(e,t,n){"use strict";n("f8f4")},"71bc":function(e,t,n){"use strict";n.d(t,"a",(function(){return o}));n("80ab"),n("a98c"),n("3dec"),n("e73f"),n("0c40"),n("79da");function o(e){return o="function"===typeof Symbol&&"symbol"===typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"===typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},o(e)}},"8f70":function(e,t,n){"use strict";var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:("production"===e.mode?e.baseUrl:"")+"/lib/index.html?id="+e.id+"&mode="+e.mode+"&x1c2Hdd6="+e.value,marginwidth:"0",frameborder:"no"}})},s=[],a=n("71bc"),i={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(a["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},r=i,c=(n("430f"),n("f7c6")),u=Object(c["a"])(r,o,s,!1,null,null,null);t["a"]=u.exports},af96:function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("work-flow",{attrs:{value:"xkjIc2ZHZ0"}})},s=[],a=n("8f70"),i={name:"WorkFlowDetail",components:{WorkFlow:a["a"]}},r=i,c=n("f7c6"),u=Object(c["a"])(r,o,s,!1,null,null,null);t["default"]=u.exports},f8f4:function(e,t,n){}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-aa00ce98"],{3656:function(e,t,n){},"51c1":function(e,t,n){"use strict";n("3656")},8186:function(e,t,n){"use strict";n.r(t);var o=function(){var e=this,t=e._self._c;return t("work-flow",{attrs:{value:"kaxC8Iml"}})},a=[],s=n("8f70"),i={name:"WorkFlowDetail",components:{WorkFlow:s["a"]}},r=i,c=(n("51c1"),n("2877")),u=Object(c["a"])(r,o,a,!1,null,null,null);t["default"]=u.exports},"8f70":function(e,t,n){"use strict";n("99af");var o=function(){var e=this,t=e._self._c;return t("iframe",{ref:"iframe",style:"width: 100%;height:calc(99vh - 60px)",attrs:{src:"".concat("production"===e.mode?e.baseUrl:"","/lib/index.html?id=").concat(e.id,"&mode=").concat(e.mode,"&x1c2Hdd6=").concat(e.value),marginwidth:"0",frameborder:"no"}})},a=[],s=n("53ca"),i={name:"WorkFlow",components:{},props:{value:{type:String,default:""}},data:function(){return{id:"",mode:"production",baseUrl:"/easy-retry"}},mounted:function(){this.id=this.$route.query.id},created:function(){window.addEventListener("message",this.handleMessage,!1)},destroyed:function(){window.removeEventListener("message",this.handleMessage)},methods:{save:function(){window.removeEventListener("message",this.handleMessage),this.$message.info("工作流新增成功"),this.$router.push({path:"/job/workflow/list"})},cancel:function(){window.removeEventListener("message",this.handleMessage),this.$router.push({path:"/job/workflow/list"})},update:function(){this.$message.info("工作流修改成功"),this.$router.push({path:"/job/workflow/list"})},handleMessage:function(e){"object"===Object(s["a"])(e.data)&&("SV5ucvLBhvFkOftb"===e.data.code?this.save():"kb4DO9h6WIiqFhbp"===e.data.code?this.cancel():"8Rr3XPtVVAHfduQg"===e.data.code&&this.update())}}},r=i,c=(n("a3be"),n("2877")),u=Object(c["a"])(r,o,a,!1,null,null,null);t["a"]=u.exports},a3be:function(e,t,n){"use strict";n("f945")},f945:function(e,t,n){}}]);
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -1 +0,0 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["fail"],{cc89:function(t,e,o){"use strict";o.r(e);var n=function(){var t=this,e=t.$createElement,o=t._self._c||e;return o("a-result",{attrs:{status:"404",title:"404","sub-title":"Sorry, the page you visited does not exist."},scopedSlots:t._u([{key:"extra",fn:function(){return[o("a-button",{attrs:{type:"primary"},on:{click:t.toHome}},[t._v(" Back Home ")])]},proxy:!0}])})},s=[],r={name:"Exception404",methods:{toHome:function(){this.$router.push({path:"/"})}}},u=r,a=o("f7c6"),c=Object(a["a"])(u,n,s,!1,null,null,null);e["default"]=c.exports}}]);
|
||||
@ -0,0 +1 @@
|
||||
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["fail"],{cc89:function(t,e,o){"use strict";o.r(e);var n=function(){var t=this,e=t._self._c;return e("a-result",{attrs:{status:"404",title:"404","sub-title":"Sorry, the page you visited does not exist."},scopedSlots:t._u([{key:"extra",fn:function(){return[e("a-button",{attrs:{type:"primary"},on:{click:t.toHome}},[t._v(" Back Home ")])]},proxy:!0}])})},s=[],r={name:"Exception404",methods:{toHome:function(){this.$router.push({path:"/"})}}},u=r,a=o("2877"),i=Object(a["a"])(u,n,s,!1,null,null,null);e["default"]=i.exports}}]);
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue
Block a user