dongjunchuan/de
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 定时报告设置额外等待时间

Browse Source
This commit is contained in:
fit2cloud-chenyw 2023-12-13 15:04:14 +08:00
parent 056e1448d0
commit 2c72b7441c
10 changed files with 35 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
core/backend/src/main/java/io/dataease/job/sechedule/strategy/impl/EmailTaskHandler.java
View File

@ -179,6 +179,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
// 下面继续执行发送邮件的
String recipients = emailTemplateDTO.getRecipients();
String reciUsers = emailTemplateDTO.getReciUsers();
Integer extWaitTime = emailTemplateDTO.getExtWaitTime();
List<String> reciLists = null;
if (StringUtils.isNotBlank(reciUsers)) {
String emailUsers = Arrays.stream(reciUsers.split(",")).map(userService::getUserByName).filter(tempUser -> StringUtils.isNotBlank(tempUser.getEmail()) && 1 == tempUser.getEnabled()).map(SysUserEntity::getEmail).collect(Collectors.joining(","));
@ -239,7 +240,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
try {
Integer panelFormat = emailTemplateDTO.getPanelFormat();
if (ObjectUtils.isEmpty(panelFormat) || panelFormat == 0) {
bytes = emailXpackService.printData(url, token, xpackPixelEntity);
bytes = emailXpackService.printData(url, token, xpackPixelEntity, extWaitTime);
emailService.sendWithImageAndFiles(recipients, emailTemplateDTO.getTitle(), contentStr, bytes, files);
} else {
bytes = emailXpackService.printPdf(url, token, xpackPixelEntity, false, true);
@ -265,7 +266,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
if (CollectionUtils.isNotEmpty(wecomUsers)) {
WecomXpackService wecomXpackService = SpringContextUtil.getBean(WecomXpackService.class);
bytes = emailXpackService.printData(url, token, xpackPixelEntity);
bytes = emailXpackService.printData(url, token, xpackPixelEntity, extWaitTime);
WecomMsgResult wecomMsgResult = wecomXpackService.pushOaMsg(wecomUsers, emailTemplateDTO.getTitle(), contentStr, bytes, files);
if (wecomMsgResult.getErrcode() != 0) {
errorMsgs.add("wecom: " + wecomMsgResult.getErrmsg());
@ -289,7 +290,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
if (CollectionUtils.isNotEmpty(dingTalkUsers)) {
DingtalkXpackService dingtalkXpackService = SpringContextUtil.getBean(DingtalkXpackService.class);
bytes = emailXpackService.printData(url, token, xpackPixelEntity);
bytes = emailXpackService.printData(url, token, xpackPixelEntity, extWaitTime);
DingtalkMsgResult dingtalkMsgResult = dingtalkXpackService.pushOaMsg(dingTalkUsers, emailTemplateDTO.getTitle(), contentStr, bytes, files);
if (dingtalkMsgResult.getErrcode() != 0) {
errorMsgs.add("dingtalk: " + dingtalkMsgResult.getErrmsg());
@ -313,7 +314,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
if (CollectionUtils.isNotEmpty(larkUsers)) {
LarkXpackService larkXpackService = SpringContextUtil.getBean(LarkXpackService.class);
bytes = emailXpackService.printData(url, token, xpackPixelEntity);
bytes = emailXpackService.printData(url, token, xpackPixelEntity, extWaitTime);
LarkMsgResult larkMsgResult = larkXpackService.pushOaMsg(larkUsers, emailTemplateDTO.getTitle(), contentStr, bytes, files);
if (larkMsgResult.getCode() != 0) {
errorMsgs.add("lark: " + larkMsgResult.getMsg());
@ -337,7 +338,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
if (CollectionUtils.isNotEmpty(larksuiteUsers)) {
LarksuiteXpackService larksuiteXpackService = SpringContextUtil.getBean(LarksuiteXpackService.class);
bytes = emailXpackService.printData(url, token, xpackPixelEntity);
bytes = emailXpackService.printData(url, token, xpackPixelEntity, extWaitTime);
LarksuiteMsgResult larksuiteMsgResult = larksuiteXpackService.pushOaMsg(larksuiteUsers, emailTemplateDTO.getTitle(), contentStr, bytes, files);
if (larksuiteMsgResult.getCode() != 0) {
errorMsgs.add("larksuite: " + larksuiteMsgResult.getMsg());
@ -354,7 +355,7 @@ public class EmailTaskHandler extends TaskHandler implements Job {
if (SpringContextUtil.getBean(AuthUserService.class).supportLark() && CollectionUtils.isNotEmpty(groupList)) {
LarkXpackService larkXpackService = SpringContextUtil.getBean(LarkXpackService.class);
if (ObjectUtils.isEmpty(bytes)) {
bytes = emailXpackService.printData(url, token, xpackPixelEntity);
bytes = emailXpackService.printData(url, token, xpackPixelEntity, extWaitTime);
}
List<LarkMsgResult> larkMsgResultList = larkXpackService.pushChatOaMsg(groupList, emailTemplateDTO.getTitle(), contentStr, bytes, files);
larkMsgResultList.forEach(larkMsgResult -> {

4
core/backend/src/main/java/io/dataease/plugins/server/XEmailTaskServer.java
View File

@ -207,7 +207,7 @@ public class XEmailTaskServer {
String currentToken = ServletUtils.getToken();
Future<?> future = priorityExecutor.submit(() -> {
try {
return emailXpackService.print(url, currentToken, buildPixel(request.getPixel()));
return emailXpackService.print(url, currentToken, buildPixel(request.getPixel()), request.getExtWaitTime());
} catch (Exception e) {
LogUtil.error(e.getMessage(), e);
DEException.throwException("预览失败，请联系管理员");
@ -247,7 +247,7 @@ public class XEmailTaskServer {
try {
Future<?> future = priorityExecutor.submit(() -> {
try {
return emailXpackService.print(url, token, buildPixel(request.getPixel()));
return emailXpackService.print(url, token, buildPixel(request.getPixel()), request.getExtWaitTime());
} catch (Exception e) {
LogUtil.error(e.getMessage(), e);
DEException.throwException("预览失败，请联系管理员");

10
core/backend/src/main/resources/db/migration/V59__1.18.14.sql
View File

@ -1 +1,9 @@
UPDATE `sys_user` set `enabled` = 0 where `user_id` = 2;
UPDATE `sys_user`
set `enabled` = 0
where `user_id` = 2;
ALTER TABLE `sys_task_email`
ADD COLUMN `groups` varchar(255) NULL COMMENT '群聊' AFTER `view_data_range`;
ALTER TABLE `sys_task_email`
ADD COLUMN `ext_wait_time` int(0) NOT NULL DEFAULT 0 COMMENT '加载仪表板额外等待时间(s)' AFTER `groups`;

4
core/frontend/src/lang/en.js
View File

@ -2776,7 +2776,9 @@ export default {
range_all: 'All data',
execute_now: 'Execute now',
fire_now_success: 'Task executing',
larkgroups: 'Lark group'
larkgroups: 'Lark group',
ext_wait_time: 'Additional waiting time for dashboard loading (unit: seconds)',
wat_time_limit: 'The additional waiting time must be between [0 - 30]'
},
dynamic_time: {
set_default: 'Set Default',

4
core/frontend/src/lang/tw.js
View File

@ -2768,7 +2768,9 @@ export default {
range_all: '全部數據',
execute_now: '立即執行',
fire_now_success: '任務發起成功',
larkgroups: '飛書群'
larkgroups: '飛書群',
ext_wait_time: '加載儀表板額外等待時間(單位:秒)',
wat_time_limit: '額外等待時間必須在[0 - 30]'
},
dynamic_time: {
set_default: '設置默認值',

4
core/frontend/src/lang/zh.js
View File

@ -2769,7 +2769,9 @@ export default {
range_all: '全部数据',
execute_now: '立即执行',
fire_now_success: '任务发起成功',
larkgroups: '飞书群'
larkgroups: '飞书群',
ext_wait_time: '加载仪表板额外等待时间(单位:秒)',
wat_time_limit: '额外等待时间必须在[0 - 30]'
},
dynamic_time: {
set_default: '设置默认值',

2
sdk/dataease-plugin-interface/src/main/java/io/dataease/plugins/xpack/email/dto/request/XpackEmailTaskRequest.java
View File

@ -34,4 +34,6 @@ public class XpackEmailTaskRequest extends XpackTaskCreateRequest {
private String viewDataRange = "view";
private String groups;
private Integer extWaitTime = 0;
}

2
sdk/dataease-plugin-interface/src/main/java/io/dataease/plugins/xpack/email/dto/request/XpackEmailViewRequest.java
View File

@ -12,5 +12,7 @@ public class XpackEmailViewRequest implements Serializable{
private String content;
private String pixel;
private Integer extWaitTime = 0;
}

2
sdk/dataease-plugin-interface/src/main/java/io/dataease/plugins/xpack/email/dto/response/XpackEmailTemplateDTO.java
View File

@ -37,4 +37,6 @@ public class XpackEmailTemplateDTO implements Serializable {
private String groups;
private Integer extWaitTime = 0;
}

4
sdk/dataease-plugin-interface/src/main/java/io/dataease/plugins/xpack/email/service/EmailXpackService.java
View File

@ -40,7 +40,7 @@ public abstract class EmailXpackService extends PluginMenuService {
public abstract GlobalTaskInstance instanceForm(Long instanceId);
public abstract byte[] print(String url, String token, XpackPixelEntity XpackPixelEntity) throws Exception;
public abstract byte[] print(String url, String token, XpackPixelEntity XpackPixelEntity, Integer extWaitTime) throws Exception;
public abstract byte[] printPdf(String url, String token, XpackPixelEntity XpackPixelEntity, boolean showPageNo, boolean picture2pdf) throws Exception;
@ -48,7 +48,7 @@ public abstract class EmailXpackService extends PluginMenuService {
public abstract XpackEmailTemplateDTO emailTemplate(Long taskId);
public abstract byte[] printData(String url, String token, XpackPixelEntity XpackPixelEntity) throws Exception;
public abstract byte[] printData(String url, String token, XpackPixelEntity XpackPixelEntity, Integer extWaitTime) throws Exception;
public abstract void batchDel(List<Long> taskIds);