GTsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 2.1.0

Browse Source 
1. 优化批量导入的
2. 组配置添加字段说明文档
This commit is contained in:
byteblogs168 2023-07-30 23:23:48 +08:00
parent 44ba9c744b
commit 3a73a53e0e
44 changed files with 199 additions and 108 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/client/RetryEndPoint.java
View File

@ -66,7 +66,7 @@ public class RetryEndPoint {
RetryerInfo retryerInfo = RetryerInfoCache.get(executeReqDto.getScene(), executeReqDto.getExecutorName());
if (Objects.isNull(retryerInfo)) {
throw new EasyRetryClientException("场景:[{}]配置不存在", executeReqDto.getScene());
throw new EasyRetryClientException("场景:[{}]配置不存在, 请检查您的场景和执行器是否存在", executeReqDto.getScene());
}
RetryArgSerializer retryArgSerializer = new JacksonSerializer();
@ -126,7 +126,7 @@ public class RetryEndPoint {
public Result callback(@RequestBody @Validated RetryCallbackDTO callbackDTO) {
RetryerInfo retryerInfo = RetryerInfoCache.get(callbackDTO.getScene(), callbackDTO.getExecutorName());
if (Objects.isNull(retryerInfo)) {
throw new EasyRetryClientException("场景:[{}]配置不存在", callbackDTO.getScene());
throw new EasyRetryClientException("场景:[{}]配置不存在, 请检查您的场景和执行器是否存在", callbackDTO.getScene());
}
RetryArgSerializer retryArgSerializer = new JacksonSerializer();

47
easy-retry-client-core/src/main/java/com/aizuda/easy/retry/client/core/strategy/AbstractRetryStrategies.java
View File

@ -2,9 +2,18 @@ package com.aizuda.easy.retry.client.core.strategy;
import com.aizuda.easy.retry.client.core.RetryExecutor;
import com.aizuda.easy.retry.client.core.RetryExecutorParameter;
import com.aizuda.easy.retry.client.core.cache.GroupVersionCache;
import com.aizuda.easy.retry.client.core.config.EasyRetryProperties;
import com.aizuda.easy.retry.client.core.event.EasyRetryListener;
import com.aizuda.easy.retry.client.core.intercepter.RetrySiteSnapshot;
import com.aizuda.easy.retry.client.core.Report;
import com.aizuda.easy.retry.common.core.alarm.Alarm;
import com.aizuda.easy.retry.common.core.alarm.AlarmContext;
import com.aizuda.easy.retry.common.core.alarm.EasyRetryAlarmFactory;
import com.aizuda.easy.retry.common.core.enums.NotifySceneEnum;
import com.aizuda.easy.retry.common.core.log.LogUtils;
import com.aizuda.easy.retry.common.core.util.EnvironmentUtils;
import com.aizuda.easy.retry.server.model.dto.ConfigDTO;
import com.github.rholder.retry.Retryer;
import com.github.rholder.retry.StopStrategy;
import com.github.rholder.retry.WaitStrategy;
@ -15,7 +24,10 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.Objects;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.function.Consumer;
@ -26,10 +38,18 @@ import java.util.function.Consumer;
*/
@Slf4j
public abstract class AbstractRetryStrategies implements RetryStrategy {
private static final DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
private static String retryErrorMoreThresholdTextMessageFormatter =
"<font face=\"微软雅黑\" color=#ff0000 size=4>{}环境 重试组件异常</font> \r\n" +
"> 名称:{} \r\n" +
"> 时间:{} \r\n" +
"> 异常:{} \n"
;
@Autowired
private List<EasyRetryListener> easyRetryListeners;
@Autowired
private EasyRetryAlarmFactory easyRetryAlarmFactory;
@Autowired
private List<Report> reports;
@ -68,6 +88,9 @@ public abstract class AbstractRetryStrategies implements RetryStrategy {
retryerResultContext.setMessage("非预期异常" + e.getMessage());
// 本地重试状态为失败 远程重试状态为成功
unexpectedError(e, retryerResultContext);
// 预警
sendMessage(e);
}
return retryerResultContext;
@ -144,4 +167,26 @@ public abstract class AbstractRetryStrategies implements RetryStrategy {
return Boolean.FALSE;
}
private void sendMessage(Exception e) {
try {
ConfigDTO.Notify notifyAttribute = GroupVersionCache.getNotifyAttribute(NotifySceneEnum.CLIENT_COMPONENT_ERROR.getNotifyScene());
if (Objects.nonNull(notifyAttribute)) {
AlarmContext context = AlarmContext.build()
.text(retryErrorMoreThresholdTextMessageFormatter,
EnvironmentUtils.getActiveProfile(),
EasyRetryProperties.getGroup(),
LocalDateTime.now().format(formatter),
e.getMessage())
.title("retry component handling exception:[{}]", EasyRetryProperties.getGroup())
.notifyAttribute(notifyAttribute.getNotifyAttribute());
Alarm<AlarmContext> alarmType = easyRetryAlarmFactory.getAlarmType(notifyAttribute.getNotifyType());
alarmType.asyncSendMessage(context);
}
} catch (Exception e1) {
LogUtils.error(log, "Client failed to send component exception alert.", e1);
}
}
}

2
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/server/handler/ReportRetryInfoHttpRequestHandler.java
View File

@ -80,6 +80,8 @@ public class ReportRetryInfoHttpRequestHandler extends PostHttpRequestHandler {
Assert.notEmpty(args, () -> new EasyRetryServerException("上报的数据不能为空. reqId:[{}]", retryRequest.getReqId()));
List<RetryTaskDTO> retryTaskList = JsonUtil.parseList(JsonUtil.toJsonString(args[0]), RetryTaskDTO.class);
LogUtils.info(log, "begin handler report data. <|>{}<|>", JsonUtil.toJsonString(retryTaskList));
Set<String> set = retryTaskList.stream().map(RetryTaskDTO::getGroupName).collect(Collectors.toSet());
Assert.isTrue(set.size() <= 1, () -> new EasyRetryServerException("批量上报数据,同一批次只能是相同的组. reqId:[{}]", retryRequest.getReqId()));

25
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/service/impl/RetryTaskServiceImpl.java
View File

@ -184,6 +184,7 @@ public class RetryTaskServiceImpl implements RetryTaskService {
TaskContext taskContext = new TaskContext();
taskContext.setSceneName(retryTaskRequestVO.getSceneName());
taskContext.setGroupName(retryTaskRequestVO.getGroupName());
taskContext.setInitStatus(retryTaskRequestVO.getRetryStatus());
taskContext.setTaskInfos(Collections.singletonList(TaskContextConverter.INSTANCE.toTaskContextInfo(retryTaskRequestVO)));
// 生成任务
@ -238,6 +239,10 @@ public class RetryTaskServiceImpl implements RetryTaskService {
@Override
public Integer parseLogs(ParseLogsVO parseLogsVO) {
RetryStatusEnum retryStatusEnum = RetryStatusEnum.getByStatus(parseLogsVO.getRetryStatus());
if (Objects.isNull(retryStatusEnum)) {
throw new EasyRetryServerException("重试状态错误");
}
String logStr = parseLogsVO.getLogStr();
@ -266,13 +271,21 @@ public class RetryTaskServiceImpl implements RetryTaskService {
.filter(t -> t.supports(TaskGeneratorScene.MANA_BATCH.getScene()))
.findFirst().orElseThrow(() -> new EasyRetryServerException("没有匹配的任务生成器"));
TaskContext taskContext = new TaskContext();
taskContext.setSceneName(parseLogsVO.getSceneName());
taskContext.setGroupName(parseLogsVO.getGroupName());
taskContext.setTaskInfos(TaskContextConverter.INSTANCE.toTaskContextInfo(waitInsertList));
boolean allMatch = waitInsertList.stream().allMatch(retryTaskDTO -> retryTaskDTO.getGroupName().equals(parseLogsVO.getGroupName()));
Assert.isTrue(allMatch, () -> new EasyRetryServerException("存在数据groupName不匹配，请检查您的数据"));
// 生成任务
taskGenerator.taskGenerator(taskContext);
Map<String, List<RetryTaskDTO>> map = waitInsertList.stream().collect(Collectors.groupingBy(RetryTaskDTO::getSceneName));
map.forEach(((sceneName, retryTaskDTOS) -> {
TaskContext taskContext = new TaskContext();
taskContext.setSceneName(sceneName);
taskContext.setGroupName(parseLogsVO.getGroupName());
taskContext.setInitStatus(parseLogsVO.getRetryStatus());
taskContext.setTaskInfos(TaskContextConverter.INSTANCE.toTaskContextInfo(retryTaskDTOS));
// 生成任务
taskGenerator.taskGenerator(taskContext);
}));
return waitInsertList.size();
}

4
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/AbstractGenerator.java
View File

@ -2,6 +2,7 @@ package com.aizuda.easy.retry.server.support.generator.task;
import cn.hutool.core.lang.Assert;
import cn.hutool.core.lang.Pair;
import com.aizuda.easy.retry.common.core.enums.RetryStatusEnum;
import com.aizuda.easy.retry.common.core.log.LogUtils;
import com.aizuda.easy.retry.common.core.util.JsonUtil;
import com.aizuda.easy.retry.server.config.RequestDataHelper;
@ -121,6 +122,7 @@ public abstract class AbstractGenerator implements TaskGenerator {
retryTask.setTaskType(TaskTypeEnum.RETRY.getType());
retryTask.setGroupName(taskContext.getGroupName());
retryTask.setSceneName(taskContext.getSceneName());
retryTask.setRetryStatus(initStatus(taskContext));
retryTask.setCreateDt(now);
retryTask.setUpdateDt(now);
@ -140,6 +142,8 @@ public abstract class AbstractGenerator implements TaskGenerator {
return Pair.of(waitInsertTasks, waitInsertTaskLogs);
}
protected abstract Integer initStatus(TaskContext taskContext);
private void checkAndInitScene( TaskContext taskContext) {
SceneConfig sceneConfig = configAccess.getSceneConfigByGroupNameAndSceneName(taskContext.getGroupName(), taskContext.getSceneName());
if (Objects.isNull(sceneConfig)) {

6
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/ClientReportRetryGenerator.java
View File

@ -1,5 +1,6 @@
package com.aizuda.easy.retry.server.support.generator.task;
import com.aizuda.easy.retry.common.core.enums.RetryStatusEnum;
import com.aizuda.easy.retry.server.enums.TaskGeneratorScene;
import org.springframework.stereotype.Component;
@ -16,4 +17,9 @@ public class ClientReportRetryGenerator extends AbstractGenerator {
public boolean supports(int scene) {
return TaskGeneratorScene.CLIENT_REPORT.getScene() == scene;
}
@Override
protected Integer initStatus(TaskContext taskContext) {
return RetryStatusEnum.RUNNING.getStatus();
}
}

8
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/ManaBatchRetryGenerator.java
View File

@ -1,8 +1,11 @@
package com.aizuda.easy.retry.server.support.generator.task;
import com.aizuda.easy.retry.common.core.enums.RetryStatusEnum;
import com.aizuda.easy.retry.server.enums.TaskGeneratorScene;
import org.springframework.stereotype.Component;
import java.util.Optional;
/**
* 控制台手动批量新增
*
@ -16,4 +19,9 @@ public class ManaBatchRetryGenerator extends AbstractGenerator {
public boolean supports(int scene) {
return TaskGeneratorScene.MANA_BATCH.getScene() == scene;
}
@Override
protected Integer initStatus(TaskContext taskContext) {
return Optional.ofNullable(taskContext.getInitStatus()).orElse(RetryStatusEnum.RUNNING.getStatus());
}
}

8
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/ManaSingleRetryGenerator.java
View File

@ -1,8 +1,11 @@
package com.aizuda.easy.retry.server.support.generator.task;
import com.aizuda.easy.retry.common.core.enums.RetryStatusEnum;
import com.aizuda.easy.retry.server.enums.TaskGeneratorScene;
import org.springframework.stereotype.Component;
import java.util.Optional;
/**
* 控制台手动单个新增
*
@ -16,4 +19,9 @@ public class ManaSingleRetryGenerator extends AbstractGenerator {
public boolean supports(int scene) {
return TaskGeneratorScene.MANA_SINGLE.getScene() == scene;
}
@Override
protected Integer initStatus(TaskContext taskContext) {
return Optional.ofNullable(taskContext.getInitStatus()).orElse(RetryStatusEnum.RUNNING.getStatus());
}
}

5
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/generator/task/TaskContext.java
View File

@ -24,6 +24,11 @@ public class TaskContext {
*/
private String sceneName;
/**
* 任务的初始状态
*/
private Integer initStatus;
/**
* 任务信息
*/

8
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/web/model/request/ParseLogsVO.java
View File

@ -19,21 +19,15 @@ public class ParseLogsVO {
* 客户端打印的上报日志信息
*/
@NotBlank(message = "组名称不能为空")
@Pattern(regexp = "^[A-Za-z0-9_]{1,64}$", message = "仅支持长度为1~64字符且类型为数字、字母和下划线")
private String logStr;
/**
* 组名称
*/
@NotBlank(message = "组名称不能为空")
@Pattern(regexp = "^[A-Za-z0-9_]{1,64}$", message = "仅支持长度为1~64字符且类型为数字、字母和下划线")
private String groupName;
/**
* 场景名称
*/
@NotBlank(message = "场景名称不能为空")
private String sceneName;
@NotNull(message = "重试状态不能为空")
private Integer retryStatus;
}

0
easy-retry-server/src/main/resources/admin/assets/background.ebcb9160.svg → easy-retry-server/src/main/resources/admin/assets/background.6f870c8d.svg
View File

Side by Side Swipe Overlay

Before

Width:  |  Height:  |  Size: 8.7 KiB

After

Width:  |  Height:  |  Size: 8.7 KiB

2
easy-retry-server/src/main/resources/admin/css/app.b0a9877f.css → easy-retry-server/src/main/resources/admin/css/app.37a20ada.css
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/index.html
View File

@ -1 +1 @@
<!DOCTYPE html><html lang="zh-cmn-Hans"><head><meta charset="utf-8"><meta http-equiv="X-UA-Compatible" content="IE=edge"><meta name="viewport" content="width=device-width,initial-scale=1"><link rel="icon" href="/logo.png"><title>Easy-Retry</title><style>.first-loading-wrp{display:flex;justify-content:center;align-items:center;flex-direction:column;min-height:420px;height:100%}.first-loading-wrp>h1{font-size:128px}.first-loading-wrp .loading-wrp{padding:98px;display:flex;justify-content:center;align-items:center}.dot{animation:antRotate 1.2s infinite linear;transform:rotate(45deg);position:relative;display:inline-block;font-size:32px;width:32px;height:32px;box-sizing:border-box}.dot i{width:14px;height:14px;position:absolute;display:block;background-color:#1890ff;border-radius:100%;transform:scale(.75);transform-origin:50% 50%;opacity:.3;animation:antSpinMove 1s infinite linear alternate}.dot i:nth-child(1){top:0;left:0}.dot i:nth-child(2){top:0;right:0;-webkit-animation-delay:.4s;animation-delay:.4s}.dot i:nth-child(3){right:0;bottom:0;-webkit-animation-delay:.8s;animation-delay:.8s}.dot i:nth-child(4){bottom:0;left:0;-webkit-animation-delay:1.2s;animation-delay:1.2s}@keyframes antRotate{to{-webkit-transform:rotate(405deg);transform:rotate(405deg)}}@-webkit-keyframes antRotate{to{-webkit-transform:rotate(405deg);transform:rotate(405deg)}}@keyframes antSpinMove{to{opacity:1}}@-webkit-keyframes antSpinMove{to{opacity:1}}</style><link href="/css/chunk-758b2aa4.1c9c785f.css" rel="prefetch"><link href="/css/chunk-ec9b3564.28cc4171.css" rel="prefetch"><link href="/css/chunk-ff9025ec.cd4961ff.css" rel="prefetch"><link href="/css/user.6ccd4506.css" rel="prefetch"><link href="/js/chunk-251479d0.e1c8b507.js" rel="prefetch"><link href="/js/chunk-2d0a4079.5177c872.js" rel="prefetch"><link href="/js/chunk-2d0b7230.c85996e7.js" rel="prefetch"><link href="/js/chunk-2d0c8f97.4c714037.js" rel="prefetch"><link href="/js/chunk-2d0f085f.fad578dd.js" rel="prefetch"><link href="/js/chunk-2d21a08f.e2d1813d.js" rel="prefetch"><link href="/js/chunk-2d228eef.761b6d05.js" rel="prefetch"><link href="/js/chunk-35f76107.649fbf09.js" rel="prefetch"><link href="/js/chunk-40597980.df361e27.js" rel="prefetch"><link href="/js/chunk-74bac939.1c9ff18a.js" rel="prefetch"><link href="/js/chunk-758b2aa4.7f890993.js" rel="prefetch"><link href="/js/chunk-ec9b3564.6325e54a.js" rel="prefetch"><link href="/js/chunk-ff9025ec.29b053ee.js" rel="prefetch"><link href="/js/fail.578566f1.js" rel="prefetch"><link href="/js/lang-zh-CN-account-settings.f8f25eaf.js" rel="prefetch"><link href="/js/lang-zh-CN-account.c724e71d.js" rel="prefetch"><link href="/js/lang-zh-CN-dashboard-analysis.98c2997a.js" rel="prefetch"><link href="/js/lang-zh-CN-dashboard.6a9e378b.js" rel="prefetch"><link href="/js/lang-zh-CN-form-basicForm.ff3088ac.js" rel="prefetch"><link href="/js/lang-zh-CN-form.cc39e450.js" rel="prefetch"><link href="/js/lang-zh-CN-global.bf0df5c8.js" rel="prefetch"><link href="/js/lang-zh-CN-menu.25425a62.js" rel="prefetch"><link href="/js/lang-zh-CN-result-fail.232762aa.js" rel="prefetch"><link href="/js/lang-zh-CN-result-success.3519c60c.js" rel="prefetch"><link href="/js/lang-zh-CN-result.32c5cf1c.js" rel="prefetch"><link href="/js/lang-zh-CN-setting.8c2ce690.js" rel="prefetch"><link href="/js/lang-zh-CN-user.81513cba.js" rel="prefetch"><link href="/js/lang-zh-CN.41562a6f.js" rel="prefetch"><link href="/js/user.e154f3a6.js" rel="prefetch"><link href="/css/app.b0a9877f.css" rel="preload" as="style"><link href="/css/chunk-vendors.5be6e05a.css" rel="preload" as="style"><link href="/js/app.2591e360.js" rel="preload" as="script"><link href="/js/chunk-vendors.87c1e94d.js" rel="preload" as="script"><link href="/css/chunk-vendors.5be6e05a.css" rel="stylesheet"><link href="/css/app.b0a9877f.css" rel="stylesheet"></head><body><noscript><strong>We're sorry but vue-antd-pro doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id="app"><div class="first-loading-wrp"><h2>Easy-Retry</h2><div class="loading-wrp"><span class="dot dot-spin"><i></i><i></i><i></i><i></i></span></div><div style="display: flex; justify-content: center; align-items: center;">分布式重试服务平台</div></div></div><script src="//cdn.jsdelivr.net/npm/vue@2.6.14/dist/vue.min.js"></script><script src="//cdn.jsdelivr.net/npm/vue-router@3.5.1/dist/vue-router.min.js"></script><script src="//cdn.jsdelivr.net/npm/vuex@3.1.1/dist/vuex.min.js"></script><script src="//cdn.jsdelivr.net/npm/axios@0.21.1/dist/axios.min.js"></script><script src="/js/chunk-vendors.87c1e94d.js"></script><script src="/js/app.2591e360.js"></script></body></html>
<!DOCTYPE html><html lang="zh-cmn-Hans"><head><meta charset="utf-8"><meta http-equiv="X-UA-Compatible" content="IE=edge"><meta name="viewport" content="width=device-width,initial-scale=1"><link rel="icon" href="/logo.png"><title>Easy-Retry</title><style>.first-loading-wrp{display:flex;justify-content:center;align-items:center;flex-direction:column;min-height:420px;height:100%}.first-loading-wrp>h1{font-size:128px}.first-loading-wrp .loading-wrp{padding:98px;display:flex;justify-content:center;align-items:center}.dot{animation:antRotate 1.2s infinite linear;transform:rotate(45deg);position:relative;display:inline-block;font-size:32px;width:32px;height:32px;box-sizing:border-box}.dot i{width:14px;height:14px;position:absolute;display:block;background-color:#1890ff;border-radius:100%;transform:scale(.75);transform-origin:50% 50%;opacity:.3;animation:antSpinMove 1s infinite linear alternate}.dot i:nth-child(1){top:0;left:0}.dot i:nth-child(2){top:0;right:0;-webkit-animation-delay:.4s;animation-delay:.4s}.dot i:nth-child(3){right:0;bottom:0;-webkit-animation-delay:.8s;animation-delay:.8s}.dot i:nth-child(4){bottom:0;left:0;-webkit-animation-delay:1.2s;animation-delay:1.2s}@keyframes antRotate{to{-webkit-transform:rotate(405deg);transform:rotate(405deg)}}@-webkit-keyframes antRotate{to{-webkit-transform:rotate(405deg);transform:rotate(405deg)}}@keyframes antSpinMove{to{opacity:1}}@-webkit-keyframes antSpinMove{to{opacity:1}}</style><link href="/css/chunk-758b2aa4.1c9c785f.css" rel="prefetch"><link href="/css/chunk-ec9b3564.28cc4171.css" rel="prefetch"><link href="/css/chunk-ff9025ec.cd4961ff.css" rel="prefetch"><link href="/css/user.6ccd4506.css" rel="prefetch"><link href="/js/chunk-251479d0.e2c0c40d.js" rel="prefetch"><link href="/js/chunk-2d0a4079.a906a166.js" rel="prefetch"><link href="/js/chunk-2d0b7230.5818ed63.js" rel="prefetch"><link href="/js/chunk-2d0c8f97.92fe18bf.js" rel="prefetch"><link href="/js/chunk-2d0f085f.8a525ddb.js" rel="prefetch"><link href="/js/chunk-2d21a08f.c722a09e.js" rel="prefetch"><link href="/js/chunk-2d228eef.99da53dc.js" rel="prefetch"><link href="/js/chunk-35f76107.e618444b.js" rel="prefetch"><link href="/js/chunk-40597980.d4433461.js" rel="prefetch"><link href="/js/chunk-74bac939.ed51f80d.js" rel="prefetch"><link href="/js/chunk-758b2aa4.47a4a2ae.js" rel="prefetch"><link href="/js/chunk-ec9b3564.f548537b.js" rel="prefetch"><link href="/js/chunk-ff9025ec.00478b3f.js" rel="prefetch"><link href="/js/fail.96c4c17e.js" rel="prefetch"><link href="/js/lang-zh-CN-account-settings.f8f25eaf.js" rel="prefetch"><link href="/js/lang-zh-CN-account.7e2ad2ea.js" rel="prefetch"><link href="/js/lang-zh-CN-dashboard-analysis.98c2997a.js" rel="prefetch"><link href="/js/lang-zh-CN-dashboard.ea812f6e.js" rel="prefetch"><link href="/js/lang-zh-CN-form-basicForm.ff3088ac.js" rel="prefetch"><link href="/js/lang-zh-CN-form.5f6efd97.js" rel="prefetch"><link href="/js/lang-zh-CN-global.bf0df5c8.js" rel="prefetch"><link href="/js/lang-zh-CN-menu.25425a62.js" rel="prefetch"><link href="/js/lang-zh-CN-result-fail.232762aa.js" rel="prefetch"><link href="/js/lang-zh-CN-result-success.3519c60c.js" rel="prefetch"><link href="/js/lang-zh-CN-result.7201a99b.js" rel="prefetch"><link href="/js/lang-zh-CN-setting.8c2ce690.js" rel="prefetch"><link href="/js/lang-zh-CN-user.81513cba.js" rel="prefetch"><link href="/js/lang-zh-CN.ae67e03e.js" rel="prefetch"><link href="/js/user.232b2ff0.js" rel="prefetch"><link href="/css/app.37a20ada.css" rel="preload" as="style"><link href="/css/chunk-vendors.5be6e05a.css" rel="preload" as="style"><link href="/js/app.cdd19479.js" rel="preload" as="script"><link href="/js/chunk-vendors.2d5d4160.js" rel="preload" as="script"><link href="/css/chunk-vendors.5be6e05a.css" rel="stylesheet"><link href="/css/app.37a20ada.css" rel="stylesheet"></head><body><noscript><strong>We're sorry but vue-antd-pro doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id="app"><div class="first-loading-wrp"><h2>Easy-Retry</h2><div class="loading-wrp"><span class="dot dot-spin"><i></i><i></i><i></i><i></i></span></div><div style="display: flex; justify-content: center; align-items: center;">分布式重试服务平台</div></div></div><script src="//cdn.jsdelivr.net/npm/vue@2.6.14/dist/vue.min.js"></script><script src="//cdn.jsdelivr.net/npm/vue-router@3.5.1/dist/vue-router.min.js"></script><script src="//cdn.jsdelivr.net/npm/vuex@3.1.1/dist/vuex.min.js"></script><script src="//cdn.jsdelivr.net/npm/axios@0.21.1/dist/axios.min.js"></script><script src="/js/chunk-vendors.2d5d4160.js"></script><script src="/js/app.cdd19479.js"></script></body></html>

1
easy-retry-server/src/main/resources/admin/js/app.2591e360.js
View File

File diff suppressed because one or more lines are too long

1
easy-retry-server/src/main/resources/admin/js/app.cdd19479.js Normal file
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-251479d0.e1c8b507.js → easy-retry-server/src/main/resources/admin/js/chunk-251479d0.e2c0c40d.js
View File

@ -1 +1 @@
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-251479d0"],{"339f":function(t,e,r){"use strict";var a=function(){var t=this,e=t._self._c;return e("div",[e("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[t._v("    调用日志详情 (总调度次数: "+t._s(t.total)+") ")]),e("a-card",[e("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:t.columns,data:t.loadData},scopedSlots:t._u([{key:"serial",fn:function(r,a){return e("span",{},[t._v(" "+t._s(a.id)+" ")])}}])})],1)],1)},s=[],n=r("c1df"),o=r.n(n),i=r("0fea"),l=r("2af9"),d={name:"RetryTaskLogMessageList",components:{STable:l["j"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){return Object(i["p"])(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=d,f=r("2877"),u=Object(f["a"])(c,a,s,!1,null,"fb0977b6",null);e["a"]=u.exports},"5fe2":function(t,e,r){"use strict";r.r(e);r("b0c0");var a=function(){var t=this,e=t._self._c;return e("div",[e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.go(-1)}}},[e("div")]),e("a-card",{attrs:{bordered:!1}},[null!==t.retryInfo?e("a-descriptions",{attrs:{title:"",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:"下次触发时间"}},[t._v(" "+t._s(t.parseDate(t.retryInfo.nextTriggerAt))+" ")]),e("a-descriptions-item",{attrs:{label:"执行时间"}},[t._v(" "+t._s(t.parseDate(t.retryInfo.createDt))+" ")]),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:"执行器名称",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("0fea"),o=r("c1df"),i=r.n(o),l=r("2af9"),d=r("339f"),c={name:"RetryLogInfo",components:{RetryTaskLogMessageList:d["a"],STable:l["j"]},data:function(){return{retryInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this,e=this.$route.query.id;e&&Object(n["o"])(e).then((function(e){t.retryInfo=e.data,t.queryParam={groupName:t.retryInfo.groupName,uniqueId:t.retryInfo.uniqueId},t.$refs.retryTaskLogMessageListRef.refreshTable(t.queryParam)}))},methods:{parseDate:function(t){return i()(t).format("YYYY-MM-DD HH:mm:ss")}}},f=c,u=r("2877"),p=Object(u["a"])(f,a,s,!1,null,"2bf6bc3d",null);e["default"]=p.exports}}]);
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-251479d0"],{"339f":function(t,e,r){"use strict";var a=function(){var t=this,e=t._self._c;return e("div",[e("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[t._v("    调用日志详情 (总调度次数: "+t._s(t.total)+") ")]),e("a-card",[e("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:t.columns,data:t.loadData},scopedSlots:t._u([{key:"serial",fn:function(r,a){return e("span",{},[t._v(" "+t._s(a.id)+" ")])}}])})],1)],1)},s=[],n=r("c1df"),o=r.n(n),i=r("0fea"),l=r("2af9"),d={name:"RetryTaskLogMessageList",components:{STable:l["j"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){return Object(i["q"])(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=d,f=r("2877"),u=Object(f["a"])(c,a,s,!1,null,"fb0977b6",null);e["a"]=u.exports},"5fe2":function(t,e,r){"use strict";r.r(e);r("b0c0");var a=function(){var t=this,e=t._self._c;return e("div",[e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.go(-1)}}},[e("div")]),e("a-card",{attrs:{bordered:!1}},[null!==t.retryInfo?e("a-descriptions",{attrs:{title:"",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:"下次触发时间"}},[t._v(" "+t._s(t.parseDate(t.retryInfo.nextTriggerAt))+" ")]),e("a-descriptions-item",{attrs:{label:"执行时间"}},[t._v(" "+t._s(t.parseDate(t.retryInfo.createDt))+" ")]),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:"执行器名称",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("0fea"),o=r("c1df"),i=r.n(o),l=r("2af9"),d=r("339f"),c={name:"RetryLogInfo",components:{RetryTaskLogMessageList:d["a"],STable:l["j"]},data:function(){return{retryInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this,e=this.$route.query.id;e&&Object(n["p"])(e).then((function(e){t.retryInfo=e.data,t.queryParam={groupName:t.retryInfo.groupName,uniqueId:t.retryInfo.uniqueId},t.$refs.retryTaskLogMessageListRef.refreshTable(t.queryParam)}))},methods:{parseDate:function(t){return i()(t).format("YYYY-MM-DD HH:mm:ss")}}},f=c,u=r("2877"),p=Object(u["a"])(f,a,s,!1,null,"2bf6bc3d",null);e["default"]=p.exports}}]);

2
easy-retry-server/src/main/resources/admin/js/chunk-2d0a4079.5177c872.js → easy-retry-server/src/main/resources/admin/js/chunk-2d0a4079.a906a166.js
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-2d0b7230.c85996e7.js → easy-retry-server/src/main/resources/admin/js/chunk-2d0b7230.5818ed63.js
View File

@ -1 +1 @@
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0b7230"],{"1faf":function(t,e,a){"use strict";a.r(e);a("d3b7"),a("25f0");var r=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.username,callback:function(e){t.$set(t.queryParam,"username",e)},expression:"queryParam.username"}})],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)])],1)],1)],1),e("div",{staticClass:"table-operator"},[e("a-button",{attrs:{type:"primary",icon:"plus"},on:{click:function(e){return t.handleNew()}}},[t._v("新建")]),t.selectedRowKeys.length>0?e("a-dropdown",{directives:[{name:"action",rawName:"v-action:edit",arg:"edit"}]},[e("a-menu",{attrs:{slot:"overlay"},slot:"overlay"},[e("a-menu-item",{key:"1"},[e("a-icon",{attrs:{type:"delete"}}),t._v("删除")],1),e("a-menu-item",{key:"2"},[e("a-icon",{attrs:{type:"lock"}}),t._v("锁定")],1)],1),e("a-button",{staticStyle:{"margin-left":"8px"}},[t._v(" 批量操作 "),e("a-icon",{attrs:{type:"down"}})],1)],1):t._e()],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},scopedSlots:t._u([{key:"serial",fn:function(a,r,n){return e("span",{},[t._v(" "+t._s(n+1)+" ")])}},{key:"groupNameList",fn:function(a,r){return e("span",{},[t._v(" "+t._s(2===r.role?"所有组":a.toString())+" ")])}},{key:"role",fn:function(a,r){return e("span",{},[t._v(" "+t._s(2===r.role?"管理员":"普通用户")+" ")])}},{key:"action",fn:function(a,r){return e("span",{},[[e("a",{on:{click:function(e){return t.handleEdit(r)}}},[t._v("编辑")]),e("a-divider",{attrs:{type:"vertical"}}),e("a",{attrs:{href:"javascript:;"}},[t._v("删除")])]],2)}}])})],1)},n=[],o=a("261e"),s=a("27e3"),i=a("c1df"),c=a.n(i),l=a("0fea"),u=a("2af9"),d={name:"TableListWrapper",components:{AInput:s["a"],ATextarea:o["a"],STable:u["j"]},data:function(){var t=this;return{currentComponet:"List",record:"",mdl:{},advanced:!1,queryParam:{},columns:[{title:"#",width:"5%",scopedSlots:{customRender:"serial"}},{title:"用户名",width:"12%",dataIndex:"username"},{title:"角色",dataIndex:"role",width:"10%",scopedSlots:{customRender:"role"}},{title:"权限",dataIndex:"groupNameList",width:"45%",scopedSlots:{customRender:"groupNameList"}},{title:"更新时间",width:"18%",dataIndex:"updateDt",customRender:function(t){return c()(t).format("YYYY-MM-DD HH:mm:ss")}},{title:"操作",width:"10%",dataIndex:"action",scopedSlots:{customRender:"action"}}],loadData:function(e){return Object(l["w"])(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}},optionAlertShow:!1}},filters:{},methods:{handleNew:function(){this.$router.push("/user-form")},handleEdit:function(t){this.record=t||"",this.$router.push({path:"/user-form",query:{username:t.username}})},handleGoBack:function(){this.record="",this.currentComponet="List"}},watch:{"$route.path":function(){this.record="",this.currentComponet="List"}}},p=d,m=a("2877"),f=Object(m["a"])(p,r,n,!1,null,null,null);e["default"]=f.exports}}]);
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0b7230"],{"1faf":function(t,e,a){"use strict";a.r(e);a("d3b7"),a("25f0");var r=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.username,callback:function(e){t.$set(t.queryParam,"username",e)},expression:"queryParam.username"}})],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)])],1)],1)],1),e("div",{staticClass:"table-operator"},[e("a-button",{attrs:{type:"primary",icon:"plus"},on:{click:function(e){return t.handleNew()}}},[t._v("新建")]),t.selectedRowKeys.length>0?e("a-dropdown",{directives:[{name:"action",rawName:"v-action:edit",arg:"edit"}]},[e("a-menu",{attrs:{slot:"overlay"},slot:"overlay"},[e("a-menu-item",{key:"1"},[e("a-icon",{attrs:{type:"delete"}}),t._v("删除")],1),e("a-menu-item",{key:"2"},[e("a-icon",{attrs:{type:"lock"}}),t._v("锁定")],1)],1),e("a-button",{staticStyle:{"margin-left":"8px"}},[t._v(" 批量操作 "),e("a-icon",{attrs:{type:"down"}})],1)],1):t._e()],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},scopedSlots:t._u([{key:"serial",fn:function(a,r,n){return e("span",{},[t._v(" "+t._s(n+1)+" ")])}},{key:"groupNameList",fn:function(a,r){return e("span",{},[t._v(" "+t._s(2===r.role?"所有组":a.toString())+" ")])}},{key:"role",fn:function(a,r){return e("span",{},[t._v(" "+t._s(2===r.role?"管理员":"普通用户")+" ")])}},{key:"action",fn:function(a,r){return e("span",{},[[e("a",{on:{click:function(e){return t.handleEdit(r)}}},[t._v("编辑")]),e("a-divider",{attrs:{type:"vertical"}}),e("a",{attrs:{href:"javascript:;"}},[t._v("删除")])]],2)}}])})],1)},n=[],o=a("261e"),s=a("27e3"),i=a("c1df"),c=a.n(i),l=a("0fea"),u=a("2af9"),d={name:"TableListWrapper",components:{AInput:s["a"],ATextarea:o["a"],STable:u["j"]},data:function(){var t=this;return{currentComponet:"List",record:"",mdl:{},advanced:!1,queryParam:{},columns:[{title:"#",width:"5%",scopedSlots:{customRender:"serial"}},{title:"用户名",width:"12%",dataIndex:"username"},{title:"角色",dataIndex:"role",width:"10%",scopedSlots:{customRender:"role"}},{title:"权限",dataIndex:"groupNameList",width:"45%",scopedSlots:{customRender:"groupNameList"}},{title:"更新时间",width:"18%",dataIndex:"updateDt",customRender:function(t){return c()(t).format("YYYY-MM-DD HH:mm:ss")}},{title:"操作",width:"10%",dataIndex:"action",scopedSlots:{customRender:"action"}}],loadData:function(e){return Object(l["x"])(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}},optionAlertShow:!1}},filters:{},methods:{handleNew:function(){this.$router.push("/user-form")},handleEdit:function(t){this.record=t||"",this.$router.push({path:"/user-form",query:{username:t.username}})},handleGoBack:function(){this.record="",this.currentComponet="List"}},watch:{"$route.path":function(){this.record="",this.currentComponet="List"}}},p=d,m=a("2877"),f=Object(m["a"])(p,r,n,!1,null,null,null);e["default"]=f.exports}}]);

2
easy-retry-server/src/main/resources/admin/js/chunk-2d0c8f97.4c714037.js → easy-retry-server/src/main/resources/admin/js/chunk-2d0c8f97.92fe18bf.js
View File

@ -1 +1 @@
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0c8f97"],{"56bb":function(e,t,r){"use strict";r.r(t);r("b0c0");var a=function(){var e=this,t=e._self._c;return t("div",[t("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return e.$router.go(-1)}}},[t("div")]),t("a-card",{attrs:{bordered:!1}},[null!==e.retryDealLetterInfo?t("a-descriptions",{attrs:{title:"",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:"下次触发时间"}},[e._v(" "+e._s(e.parseDate(e.retryDealLetterInfo.nextTriggerAt))+" ")]),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.parseDate(e.retryDealLetterInfo.createDt))+" ")]),t("a-descriptions-item",{attrs:{label:"更新时间"}},[e._v(" "+e._s(e.parseDate(e.retryDealLetterInfo.updateDt))+" ")]),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("0fea"),o=r("c1df"),i=r.n(o),l={name:"RetryDeadLetterInfo",data:function(){return{retryDealLetterInfo:null,taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var e=this,t=this.$route.query.id,r=this.$route.query.groupName;t&&r&&Object(n["l"])(t,{groupName:r}).then((function(t){e.retryDealLetterInfo=t.data}))},methods:{parseDate:function(e){return i()(e).format("YYYY-MM-DD HH:mm:ss")}}},p=l,c=r("2877"),d=Object(c["a"])(p,a,s,!1,null,"e8b093b2",null);t["default"]=d.exports}}]);
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d0c8f97"],{"56bb":function(e,t,r){"use strict";r.r(t);r("b0c0");var a=function(){var e=this,t=e._self._c;return t("div",[t("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return e.$router.go(-1)}}},[t("div")]),t("a-card",{attrs:{bordered:!1}},[null!==e.retryDealLetterInfo?t("a-descriptions",{attrs:{title:"",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:"下次触发时间"}},[e._v(" "+e._s(e.parseDate(e.retryDealLetterInfo.nextTriggerAt))+" ")]),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.parseDate(e.retryDealLetterInfo.createDt))+" ")]),t("a-descriptions-item",{attrs:{label:"更新时间"}},[e._v(" "+e._s(e.parseDate(e.retryDealLetterInfo.updateDt))+" ")]),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("0fea"),o=r("c1df"),i=r.n(o),l={name:"RetryDeadLetterInfo",data:function(){return{retryDealLetterInfo:null,taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var e=this,t=this.$route.query.id,r=this.$route.query.groupName;t&&r&&Object(n["m"])(t,{groupName:r}).then((function(t){e.retryDealLetterInfo=t.data}))},methods:{parseDate:function(e){return i()(e).format("YYYY-MM-DD HH:mm:ss")}}},p=l,c=r("2877"),d=Object(c["a"])(p,a,s,!1,null,"e8b093b2",null);t["default"]=d.exports}}]);

1
easy-retry-server/src/main/resources/admin/js/chunk-2d0f085f.8a525ddb.js Normal file
View File

File diff suppressed because one or more lines are too long

1
easy-retry-server/src/main/resources/admin/js/chunk-2d0f085f.fad578dd.js
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-2d21a08f.e2d1813d.js → easy-retry-server/src/main/resources/admin/js/chunk-2d21a08f.c722a09e.js
View File

@ -1 +1 @@
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d21a08f"],{ba93:function(t,e,a){"use strict";a.r(e);var n=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("div",{staticClass:"table-operator"},[t.$auth("group.add")?e("a-button",{attrs:{type:"primary",icon:"plus"},on:{click:function(e){return t.handleNew()}}},[t._v("新建")]):t._e()],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,n,r){return e("span",{},[t._v(" "+t._s(r+1)+" ")])}},{key:"groupStatus",fn:function(a){return e("span",{},[t._v(" "+t._s(0===a?"停用":"启用")+" ")])}},{key:"initScene",fn:function(a){return e("span",{},[t._v(" "+t._s(0===a?"否":"是")+" ")])}},{key:"action",fn:function(a,n){return e("span",{},[[e("a",{on:{click:function(e){return t.handleEdit(n)}}},[t._v("编辑")]),e("a-divider",{attrs:{type:"vertical"}}),e("a",{on:{click:function(e){return t.handleEditStatus(n)}}},[t._v(t._s(1===n.groupStatus?"停用":"启用"))])]],2)}}])})],1)},r=[],o=(a("d3b7"),a("25f0"),a("27e3")),s=a("0fea"),i=a("2af9"),u=a("c1df"),c=a.n(u),d={name:"TableListWrapper",components:{AInput:o["a"],STable:i["j"]},data:function(){var t=this;return{advanced:!1,queryParam:{},columns:[{title:"#",scopedSlots:{customRender:"serial"}},{title:"名称",dataIndex:"groupName"},{title:"状态",dataIndex:"groupStatus",scopedSlots:{customRender:"groupStatus"}},{title:"路由策略",dataIndex:"routeKey",customRender:function(e){return t.routeKey[e]}},{title:"版本",dataIndex:"version"},{title:"分区",dataIndex:"groupPartition",needTotal:!0},{title:"ID生成模式",dataIndex:"idGeneratorModeName"},{title:"初始化场景",dataIndex:"initScene",scopedSlots:{customRender:"initScene"}},{title:"更新时间",dataIndex:"updateDt",sorter:!0,customRender:function(t){return c()(t).format("YYYY-MM-DD HH:mm:ss")}},{title:"描述",dataIndex:"description"},{title:"OnLine机器",dataIndex:"onlinePodList",customRender:function(t){return t.toString()}},{title:"操作",dataIndex:"action",width:"150px",fixed:"right",scopedSlots:{customRender:"action"}}],loadData:function(e){return Object(s["i"])(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}},routeKey:{1:"一致性hash算法",2:"随机算法",3:"最近最久未使用算法"}}},created:function(){},methods:{handleNew:function(){this.$router.push("/basic-config")},handleEdit:function(t){this.$router.push({path:"/basic-config",query:{groupName:t.groupName}})},toggleAdvanced:function(){this.advanced=!this.advanced},handleEditStatus:function(t){var e=this,a=t.groupStatus,n=t.groupName,r=this.$notification;Object(s["F"])({groupName:n,groupStatus:1===a?0:1}).then((function(t){0===t.status?r["error"]({message:t.message}):(r["success"]({message:t.message}),e.$refs.table.refresh())}))}}},l=d,p=a("2877"),f=Object(p["a"])(l,n,r,!1,null,null,null);e["default"]=f.exports}}]);
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-2d21a08f"],{ba93:function(t,e,a){"use strict";a.r(e);var n=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("div",{staticClass:"table-operator"},[t.$auth("group.add")?e("a-button",{attrs:{type:"primary",icon:"plus"},on:{click:function(e){return t.handleNew()}}},[t._v("新建")]):t._e()],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,n,r){return e("span",{},[t._v(" "+t._s(r+1)+" ")])}},{key:"groupStatus",fn:function(a){return e("span",{},[t._v(" "+t._s(0===a?"停用":"启用")+" ")])}},{key:"initScene",fn:function(a){return e("span",{},[t._v(" "+t._s(0===a?"否":"是")+" ")])}},{key:"action",fn:function(a,n){return e("span",{},[[e("a",{on:{click:function(e){return t.handleEdit(n)}}},[t._v("编辑")]),e("a-divider",{attrs:{type:"vertical"}}),e("a",{on:{click:function(e){return t.handleEditStatus(n)}}},[t._v(t._s(1===n.groupStatus?"停用":"启用"))])]],2)}}])})],1)},r=[],o=(a("d3b7"),a("25f0"),a("27e3")),s=a("0fea"),i=a("2af9"),u=a("c1df"),c=a.n(u),d={name:"TableListWrapper",components:{AInput:o["a"],STable:i["j"]},data:function(){var t=this;return{advanced:!1,queryParam:{},columns:[{title:"#",scopedSlots:{customRender:"serial"}},{title:"名称",dataIndex:"groupName"},{title:"状态",dataIndex:"groupStatus",scopedSlots:{customRender:"groupStatus"}},{title:"路由策略",dataIndex:"routeKey",customRender:function(e){return t.routeKey[e]}},{title:"版本",dataIndex:"version"},{title:"分区",dataIndex:"groupPartition",needTotal:!0},{title:"ID生成模式",dataIndex:"idGeneratorModeName"},{title:"初始化场景",dataIndex:"initScene",scopedSlots:{customRender:"initScene"}},{title:"更新时间",dataIndex:"updateDt",sorter:!0,customRender:function(t){return c()(t).format("YYYY-MM-DD HH:mm:ss")}},{title:"描述",dataIndex:"description"},{title:"OnLine机器",dataIndex:"onlinePodList",customRender:function(t){return t.toString()}},{title:"操作",dataIndex:"action",width:"150px",fixed:"right",scopedSlots:{customRender:"action"}}],loadData:function(e){return Object(s["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}},routeKey:{1:"一致性hash算法",2:"随机算法",3:"最近最久未使用算法"}}},created:function(){},methods:{handleNew:function(){this.$router.push("/basic-config")},handleEdit:function(t){this.$router.push({path:"/basic-config",query:{groupName:t.groupName}})},toggleAdvanced:function(){this.advanced=!this.advanced},handleEditStatus:function(t){var e=this,a=t.groupStatus,n=t.groupName,r=this.$notification;Object(s["G"])({groupName:n,groupStatus:1===a?0:1}).then((function(t){0===t.status?r["error"]({message:t.message}):(r["success"]({message:t.message}),e.$refs.table.refresh())}))}}},l=d,p=a("2877"),f=Object(p["a"])(l,n,r,!1,null,null,null);e["default"]=f.exports}}]);

2
easy-retry-server/src/main/resources/admin/js/chunk-2d228eef.761b6d05.js → easy-retry-server/src/main/resources/admin/js/chunk-2d228eef.99da53dc.js
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-35f76107.649fbf09.js → easy-retry-server/src/main/resources/admin/js/chunk-35f76107.e618444b.js
View File

@ -1 +1 @@
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-35f76107"],{"339f":function(t,e,r){"use strict";var a=function(){var t=this,e=t._self._c;return e("div",[e("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[t._v("    调用日志详情 (总调度次数: "+t._s(t.total)+") ")]),e("a-card",[e("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:t.columns,data:t.loadData},scopedSlots:t._u([{key:"serial",fn:function(r,a){return e("span",{},[t._v(" "+t._s(a.id)+" ")])}}])})],1)],1)},s=[],n=r("c1df"),o=r.n(n),i=r("0fea"),l=r("2af9"),u={name:"RetryTaskLogMessageList",components:{STable:l["j"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){return Object(i["p"])(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=r("2877"),f=Object(c["a"])(d,a,s,!1,null,"fb0977b6",null);e["a"]=f.exports},"99f5":function(t,e,r){"use strict";r.r(e);r("b0c0");var a=function(){var t=this,e=t._self._c;return e("div",[e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.go(-1)}}},[e("div")]),null!==t.retryTaskInfo?e("a-card",{attrs:{bordered:!1}},[e("a-descriptions",{attrs:{title:"",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.createDt)+" ")]),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=r("0fea"),o=r("c1df"),i=r.n(o),l=r("339f"),u={name:"RetryTaskInfo",components:{RetryTaskLogMessageList:l["a"]},data:function(){return{retryTaskInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数",3:"暂停"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this,e=this.$route.query.id,r=this.$route.query.groupName;e&&r?Object(n["n"])(e,{groupName:r}).then((function(e){t.retryTaskInfo=e.data,t.queryParam={groupName:t.retryTaskInfo.groupName,uniqueId:t.retryTaskInfo.uniqueId},t.$refs.retryTaskLogMessageListRef.refreshTable(t.queryParam)})):this.$router.push({path:"/404"})},methods:{parseDate:function(t){return i()(t).format("YYYY-MM-DD HH:mm:ss")}}},d=u,c=r("2877"),f=Object(c["a"])(d,a,s,!1,null,"76bc38a1",null);e["default"]=f.exports}}]);
(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-35f76107"],{"339f":function(t,e,r){"use strict";var a=function(){var t=this,e=t._self._c;return e("div",[e("div",{staticStyle:{margin:"20px 0","border-left":"#f5222d 5px solid","font-size":"medium","font-weight":"bold"}},[t._v("    调用日志详情 (总调度次数: "+t._s(t.total)+") ")]),e("a-card",[e("s-table",{ref:"table",attrs:{size:"default",rowKey:"key",columns:t.columns,data:t.loadData},scopedSlots:t._u([{key:"serial",fn:function(r,a){return e("span",{},[t._v(" "+t._s(a.id)+" ")])}}])})],1)],1)},s=[],n=r("c1df"),o=r.n(n),i=r("0fea"),l=r("2af9"),u={name:"RetryTaskLogMessageList",components:{STable:l["j"]},data:function(){var t=this;return{columns:[{title:"#",scopedSlots:{customRender:"serial"},width:"10%"},{title:"信息",dataIndex:"message",width:"50%"},{title:"触发时间",dataIndex:"createDt",sorter:!0,customRender:function(t){return o()(t).format("YYYY-MM-DD HH:mm:ss")},width:"10%"}],queryParam:{},loadData:function(e){return Object(i["q"])(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=r("2877"),f=Object(c["a"])(d,a,s,!1,null,"fb0977b6",null);e["a"]=f.exports},"99f5":function(t,e,r){"use strict";r.r(e);r("b0c0");var a=function(){var t=this,e=t._self._c;return e("div",[e("page-header-wrapper",{staticStyle:{margin:"-24px -1px 0"},on:{back:function(){return t.$router.go(-1)}}},[e("div")]),null!==t.retryTaskInfo?e("a-card",{attrs:{bordered:!1}},[e("a-descriptions",{attrs:{title:"",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.createDt)+" ")]),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=r("0fea"),o=r("c1df"),i=r.n(o),l=r("339f"),u={name:"RetryTaskInfo",components:{RetryTaskLogMessageList:l["a"]},data:function(){return{retryTaskInfo:null,retryStatus:{0:"处理中",1:"处理成功",2:"最大次数",3:"暂停"},taskType:{1:{name:"重试数据",color:"#d06892"},2:{name:"回调数据",color:"#f5a22d"}}}},created:function(){var t=this,e=this.$route.query.id,r=this.$route.query.groupName;e&&r?Object(n["o"])(e,{groupName:r}).then((function(e){t.retryTaskInfo=e.data,t.queryParam={groupName:t.retryTaskInfo.groupName,uniqueId:t.retryTaskInfo.uniqueId},t.$refs.retryTaskLogMessageListRef.refreshTable(t.queryParam)})):this.$router.push({path:"/404"})},methods:{parseDate:function(t){return i()(t).format("YYYY-MM-DD HH:mm:ss")}}},d=u,c=r("2877"),f=Object(c["a"])(d,a,s,!1,null,"76bc38a1",null);e["default"]=f.exports}}]);

2
easy-retry-server/src/main/resources/admin/js/chunk-40597980.df361e27.js → easy-retry-server/src/main/resources/admin/js/chunk-40597980.d4433461.js
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-74bac939.1c9ff18a.js → easy-retry-server/src/main/resources/admin/js/chunk-74bac939.ed51f80d.js
View File

@ -1 +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(" 路径: "),e("a-tag",{attrs:{color:"#108ee9"}},[t._v(" "+t._s(a)+" ")])],1):e("div",[t._v(" 组: "),t._l(o.consumerGroup,(function(a){return e("a-tag",{key:a,staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" "+t._s(a)+" ")])}))],2)])}}])})],1)},n=[],r=a("c1df"),s=a.n(r),l=a("0fea"),c=a("2af9"),d={name:"PodList",components:{STable:c["j"]},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"},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["y"])(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:{}},i=d,u=a("2877"),p=Object(u["a"])(i,o,n,!1,null,"1902f2a8",null);e["default"]=p.exports}}]);
(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(" 路径: "),e("a-tag",{attrs:{color:"#108ee9"}},[t._v(" "+t._s(a)+" ")])],1):e("div",[t._v(" 组: "),t._l(o.consumerGroup,(function(a){return e("a-tag",{key:a,staticStyle:{"margin-bottom":"16px"},attrs:{color:"pink"}},[t._v(" "+t._s(a)+" ")])}))],2)])}}])})],1)},n=[],r=a("c1df"),s=a.n(r),l=a("0fea"),c=a("2af9"),d={name:"PodList",components:{STable:c["j"]},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"},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["z"])(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:{}},i=d,u=a("2877"),p=Object(u["a"])(i,o,n,!1,null,"1902f2a8",null);e["default"]=p.exports}}]);

1
easy-retry-server/src/main/resources/admin/js/chunk-758b2aa4.47a4a2ae.js Normal file
View File

File diff suppressed because one or more lines are too long

1
easy-retry-server/src/main/resources/admin/js/chunk-758b2aa4.7f890993.js
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-ec9b3564.6325e54a.js → easy-retry-server/src/main/resources/admin/js/chunk-ec9b3564.f548537b.js
View File

File diff suppressed because one or more lines are too long

2
easy-retry-server/src/main/resources/admin/js/chunk-ff9025ec.29b053ee.js → easy-retry-server/src/main/resources/admin/js/chunk-ff9025ec.00478b3f.js
View File

File diff suppressed because one or more lines are too long

12
easy-retry-server/src/main/resources/admin/js/chunk-vendors.87c1e94d.js → easy-retry-server/src/main/resources/admin/js/chunk-vendors.2d5d4160.js
View File

File diff suppressed because one or more lines are too long

0
easy-retry-server/src/main/resources/admin/js/fail.578566f1.js → easy-retry-server/src/main/resources/admin/js/fail.96c4c17e.js
View File

0
easy-retry-server/src/main/resources/admin/js/lang-zh-CN-account.c724e71d.js → easy-retry-server/src/main/resources/admin/js/lang-zh-CN-account.7e2ad2ea.js
View File

0
easy-retry-server/src/main/resources/admin/js/lang-zh-CN-dashboard.6a9e378b.js → easy-retry-server/src/main/resources/admin/js/lang-zh-CN-dashboard.ea812f6e.js
View File

0
easy-retry-server/src/main/resources/admin/js/lang-zh-CN-form.cc39e450.js → easy-retry-server/src/main/resources/admin/js/lang-zh-CN-form.5f6efd97.js
View File

0
easy-retry-server/src/main/resources/admin/js/lang-zh-CN-result.32c5cf1c.js → easy-retry-server/src/main/resources/admin/js/lang-zh-CN-result.7201a99b.js
View File

0
easy-retry-server/src/main/resources/admin/js/lang-zh-CN.41562a6f.js → easy-retry-server/src/main/resources/admin/js/lang-zh-CN.ae67e03e.js
View File

2
easy-retry-server/src/main/resources/admin/js/user.e154f3a6.js → easy-retry-server/src/main/resources/admin/js/user.232b2ff0.js
View File

File diff suppressed because one or more lines are too long

38
easy-retry-server/src/main/resources/mapper/RetryTaskMapper.xml
View File

@ -22,20 +22,6 @@
id, unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, args_str, ext_attrs, next_trigger_at, retry_count, retry_status,
create_dt, update_dt, task_type
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from retry_task_${partition}
where id = #{id,jdbcType=BIGINT}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
delete from retry_task_${partition}
where id = #{id,jdbcType=BIGINT}
</delete>
<delete id="deleteByRetryStatus">
delete from retry_task_${partition}
where retry_status = #{retryStatus,jdbcType=TINYINT}
</delete>
<delete id="deleteBatch">
delete from retry_task_${partition}
where id IN
@ -43,37 +29,17 @@
#{id}
</foreach>
</delete>
<select id="selectRetryTask" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from retry_task_${partition} where create_dt &gt;#{createDt,jdbcType=TIMESTAMP} and retry_status = 0 limit #{pageSize}
</select>
<select id="selectRetryTaskByRetryCount" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from retry_task_${partition} where retry_status = #{retryStatus,jdbcType=TINYINT} limit 1000
</select>
<select id="countAllRetryTaskByRetryStatus" resultType="int">
select
count(*)
from retry_task_${partition} where retry_status = #{retryStatus}
</select>
<select id="selectRetryTaskByGroupIdAndSceneId" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from retry_task_${partition} where idempotent_id = #{idempotentId,jdbcType=VARCHAR} AND scene_id = #{sceneId,jdbcType=VARCHAR}
</select>
<select id="selectRetryTaskPage" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from retry_task_${partition}
</select>
<!-- 定义批量新增的 SQL 映射 -->
<insert id="batchInsert" parameterType="java.util.List">
INSERT INTO retry_task_${partition} (unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, args_str, ext_attrs, next_trigger_at, task_type, create_dt)
INSERT INTO retry_task_${partition} (unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, args_str, ext_attrs, next_trigger_at, task_type, retry_status, create_dt)
VALUES
<foreach collection="list" item="item" separator=",">
(#{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId}, #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs}, #{item.nextTriggerAt}, #{item.taskType}, #{item.createDt})
(#{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId}, #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs}, #{item.nextTriggerAt}, #{item.taskType}, #{item.retryStatus}, #{item.createDt})
</foreach>
</insert>
</mapper>

2
example/pom.xml
View File

@ -38,7 +38,7 @@
<dependency>
<groupId>com.aizuda</groupId>
<artifactId>easy-retry-client-starter</artifactId>
<version>2.0.1</version>
<version>2.1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>

8
frontend/src/utils/util.js
View File

@ -182,3 +182,11 @@ export function permissionsConfig (roleId) {
return role[roleId]
}
export function officialWebsite () {
if (process.env.NODE_ENV === 'development') {
return 'http://localhost:8081'
} else {
return 'https://www.easyretry.com'
}
}

57
frontend/src/views/config/basicConfigForm/GroupForm.vue
View File

@ -10,7 +10,16 @@
'id',
]" />
</a-form-item>
<a-form-item label="组名称">
<a-form-item>
<span slot="label">
组名称&nbsp;
<a
:href="officialWebsite + '/pages/32e4a0/#组是何物' +
''"
target="_blank">
<a-icon type="question-circle-o" />
</a>
</span>
<a-input
placeholder="请输入组名称"
:maxLength="64"
@ -22,8 +31,13 @@
</a-form-item>
</a-col>
<a-col :lg="6" :md="12" :sm="24">
<a-form-item
label="状态">
<a-form-item>
<span slot="label">
状态&nbsp;
<a :href="officialWebsite + '/pages/32e4a0/#什么是组状态'" target="_blank">
<a-icon type="question-circle-o" />
</a>
</span>
<a-select
placeholder="请选择状态"
v-decorator="[
@ -36,8 +50,13 @@
</a-form-item>
</a-col>
<a-col :lg="6" :md="12" :sm="24">
<a-form-item
label="路由策略">
<a-form-item>
<span slot="label">
路由策略&nbsp;
<a :href="officialWebsite + '/pages/32e4a0/#什么是路由策略'" target="_blank">
<a-icon type="question-circle-o" />
</a>
</span>
<a-select
placeholder="请选择路由策略"
v-decorator="[
@ -60,7 +79,13 @@
</a-form-item>
</a-col>
<a-col :lg="3" :md="6" :sm="12">
<a-form-item label="指定分区">
<a-form-item>
<span slot="label">
指定分区&nbsp;
<a :href="officialWebsite + '/pages/32e4a0/#什么是分区'" target="_blank">
<a-icon type="question-circle-o" />
</a>
</span>
<a-input-number
id="inputNumber"
placeholder="分区"
@ -73,8 +98,13 @@
</a-form-item>
</a-col>
<a-col :lg="3" :md="6" :sm="12">
<a-form-item
label="Id生成模式">
<a-form-item>
<span slot="label">
Id生成模式&nbsp;
<a :href="officialWebsite + '/pages/32e4a0/#什么是id生成模式'" target="_blank">
<a-icon type="question-circle-o" />
</a>
</span>
<a-select
placeholder="请选择Id生成模式"
v-decorator="[
@ -86,13 +116,14 @@
</a-form-item>
</a-col>
<a-col :lg="3" :md="6" :sm="12">
<a-form-item>
<span slot="label">
初始化场景&nbsp;
<a-tooltip title="【是】: 当未查询到场景时默认生成一个场景(退避策略: 等级策略, 最大重试次数: 26); 【否】: 新增场景时必须先配置场景">
<a
:href="officialWebsite + '/pages/32e4a0/#什么是初始化场景'"
target="_blank">
<a-icon type="question-circle-o" />
</a-tooltip>
</a>
</span>
<a-select
placeholder="请选择是否初始化场景"
@ -114,6 +145,7 @@
<script>
import { getGroupConfigByGroupName, getTotalPartition } from '@/api/manage'
import pick from 'lodash.pick'
import { officialWebsite } from '@/utils/util'
export default {
name: 'GroupForm',
@ -139,7 +171,8 @@ export default {
initScene: {
'0': '否',
'1': '是'
}
},
officialWebsite: officialWebsite()
}
},
mounted () {

23
frontend/src/views/task/form/BatchSaveRetryTask.vue
View File

@ -11,15 +11,6 @@
<a-select-option v-for="item in groupNameList" :value="item" :key="item">{{ item }}</a-select-option>
</a-select>
</a-form-item>
<a-form-item label="场景名称">
<a-select
placeholder="请选择场景名称"
v-decorator="['sceneName', { rules: [{ required: true, message: '请选择场景名称' }] }]" >
<a-select-option v-for="item in sceneList" :value="item.sceneName" :key="item.sceneName">
{{ item.sceneName }}</a-select-option
>
</a-select>
</a-form-item>
<a-form-item label="重试状态">
<a-select
placeholder="请选择重试状态"
@ -36,7 +27,7 @@
placeholder="请输入日志信息"
v-decorator="['logStr', { rules: [{ required: true, message: '请输入包含<|>参数<|>的日志信息.' }, { validator: handleLogStr }], validateTrigger: 'change' }]"
/>
<a href="https://www.easyretry.com/" target="_blank">获取日志信息？</a>
<a :href="officialWebsite + '/pages/b74542/#如何获取日志信息'" target="_blank"> 获取日志信息？</a>
</a-form-item>
</a-form>
@ -46,6 +37,7 @@
<script>
import { getAllGroupNameList, getSceneList, batchSaveRetryTask } from '@/api/manage'
import { officialWebsite } from '@/utils/util'
export default {
name: 'SavRetryTask',
@ -65,7 +57,8 @@ export default {
1: '重试完成',
2: '最大次数',
3: '暂停'
}
},
officialWebsite: officialWebsite()
}
},
methods: {
@ -76,10 +69,10 @@ export default {
if (!err) {
console.log(values)
batchSaveRetryTask(values).then((res) => {
// this.form.resetFields()
// this.$message.success('新增任务成功')
// this.visible = false
// this.$emit('refreshTable', 1)
this.form.resetFields()
this.$message.success('新增任务成功')
this.visible = false
this.$emit('refreshTable', 1)
})
}
})

16
frontend/src/views/task/form/SaveRetryTask.vue
View File

@ -33,8 +33,10 @@
name="idempotentId"
placeholder="请输入幂等ID"
>
<a-tooltip slot="suffix" title="同一个场景下正在重试中的幂等ID不能重复,若重复的幂等ID在上报时会被幂等处理">
<a-icon type="info-circle" style="color: rgba(0, 0, 0, 0.45)" />
<a-tooltip slot="suffix">
<a :href="officialWebsite + '/pages/b74542/#幂等id(idempotentId)'" target="_blank">
<a-icon type="info-circle" style="color: rgba(0, 0, 0, 0.45)" />
</a>
</a-tooltip>
</a-input>
<a-button type="primary" style="position: absolute; margin: 3px 10px" @click="idempotentIdGenerate"> 通过客户端生成 </a-button>
@ -45,8 +47,10 @@
name="bizNo"
placeholder="请输入业务编号"
>
<a-tooltip slot="suffix" title="具有业务特征的编号比如订单号、物流编号等">
<a-icon type="info-circle" style="color: rgba(0, 0, 0, 0.45)" />
<a-tooltip slot="suffix">
<a :href="officialWebsite + '/pages/b74542/#业务编号(bizNo)'" target="_blank">
<a-icon type="info-circle" style="color: rgba(0, 0, 0, 0.45)" />
</a>
</a-tooltip>
</a-input>
</a-form-item>
@ -72,6 +76,7 @@
<script>
import { getAllGroupNameList, getSceneList, saveRetryTask, idempotentIdGenerate } from '@/api/manage'
import { officialWebsite } from '@/utils/util'
export default {
name: 'SavRetryTask',
@ -91,7 +96,8 @@ export default {
1: '重试完成',
2: '最大次数',
3: '暂停'
}
},
officialWebsite: officialWebsite()
}
},
methods: {