Merge branch 'dev' into v1.18

This commit is contained in:
taojinlong 2023-05-16 15:04:03 +08:00
commit 63a01b93e9
5 changed files with 17 additions and 15 deletions

View File

@ -19,9 +19,10 @@ public interface ExtSysMsgMapper {
"<foreach collection='msgIds' item='msgId' open='(' separator=',' close=')' >", "<foreach collection='msgIds' item='msgId' open='(' separator=',' close=')' >",
" #{msgId}", " #{msgId}",
"</foreach>", "</foreach>",
" and user_id = #{uid}",
"</script>" "</script>"
}) })
int batchStatus(@Param("msgIds") List<Long> msgIds, @Param("time") Long time); int batchStatus(@Param("msgIds") List<Long> msgIds, @Param("time") Long time, @Param("uid") Long uid);
@Delete({ @Delete({
"<script>", "<script>",
@ -29,9 +30,10 @@ public interface ExtSysMsgMapper {
"<foreach collection='msgIds' item='msgId' open='(' separator=',' close=')' >", "<foreach collection='msgIds' item='msgId' open='(' separator=',' close=')' >",
" #{msgId}", " #{msgId}",
"</foreach>", "</foreach>",
" and user_id = #{uid} ",
"</script>" "</script>"
}) })
int batchDelete(@Param("msgIds") List<Long> msgIds); int batchDelete(@Param("msgIds") List<Long> msgIds, @Param("uid") Long uid);
int batchInsert(@Param("settings") List<SysMsgSetting> settings); int batchInsert(@Param("settings") List<SysMsgSetting> settings);

View File

@ -18,6 +18,7 @@ import io.dataease.plugins.common.entity.XpackConditionEntity;
import io.dataease.plugins.common.entity.XpackGridRequest; import io.dataease.plugins.common.entity.XpackGridRequest;
import io.dataease.plugins.config.SpringContextUtil; import io.dataease.plugins.config.SpringContextUtil;
import io.dataease.plugins.xpack.email.dto.request.*; import io.dataease.plugins.xpack.email.dto.request.*;
import io.dataease.plugins.xpack.email.dto.response.XpackTaskEntity;
import io.dataease.plugins.xpack.email.dto.response.XpackTaskGridDTO; import io.dataease.plugins.xpack.email.dto.response.XpackTaskGridDTO;
import io.dataease.plugins.xpack.email.dto.response.XpackTaskInstanceDTO; import io.dataease.plugins.xpack.email.dto.response.XpackTaskInstanceDTO;
import io.dataease.plugins.xpack.email.service.EmailXpackService; import io.dataease.plugins.xpack.email.service.EmailXpackService;
@ -35,6 +36,9 @@ import org.springframework.web.bind.annotation.*;
import org.springframework.web.util.HtmlUtils; import org.springframework.web.util.HtmlUtils;
import springfox.documentation.annotations.ApiIgnore; import springfox.documentation.annotations.ApiIgnore;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import java.io.*; import java.io.*;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.util.ArrayList; import java.util.ArrayList;
@ -43,10 +47,6 @@ import java.util.List;
import java.util.concurrent.Future; import java.util.concurrent.Future;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import javax.annotation.Resource;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
@ApiIgnore @ApiIgnore
@RequestMapping("/plugin/task") @RequestMapping("/plugin/task")
@RestController @RestController
@ -108,8 +108,8 @@ public class XEmailTaskServer {
@PostMapping("/fireNow/{taskId}") @PostMapping("/fireNow/{taskId}")
public void fireNow(@PathVariable("taskId") Long taskId) throws Exception { public void fireNow(@PathVariable("taskId") Long taskId) throws Exception {
EmailXpackService emailXpackService = SpringContextUtil.getBean(EmailXpackService.class); EmailXpackService emailXpackService = SpringContextUtil.getBean(EmailXpackService.class);
XpackEmailTaskRequest request = emailXpackService.taskForm(taskId); XpackTaskEntity xpackTaskEntity = emailXpackService.taskDetail(taskId);
GlobalTaskEntity globalTaskEntity = BeanUtils.copyBean(new GlobalTaskEntity(), request); GlobalTaskEntity globalTaskEntity = BeanUtils.copyBean(new GlobalTaskEntity(), xpackTaskEntity);
Boolean invalid = false; Boolean invalid = false;
if (CronUtils.taskExpire(globalTaskEntity.getEndTime())) { if (CronUtils.taskExpire(globalTaskEntity.getEndTime())) {
globalTaskEntity.setEndTime(null); globalTaskEntity.setEndTime(null);

View File

@ -657,8 +657,8 @@ public class JdbcProvider extends DefaultJdbcProvider {
if (StringUtils.isEmpty(oracleConfiguration.getSchema())) { if (StringUtils.isEmpty(oracleConfiguration.getSchema())) {
throw new Exception(Translator.get("i18n_schema_is_empty")); throw new Exception(Translator.get("i18n_schema_is_empty"));
} }
return "select table_name, owner, comments from all_tab_comments where owner='OWNER' AND table_type = 'TABLE' AND table_name in (select table_name from all_tables where owner='OWNER')".replaceAll("OWNER", oracleConfiguration.getSchema()); return "select table_name, owner, comments from all_tab_comments where owner='" + oracleConfiguration.getSchema() + "' AND table_type = 'TABLE'";
case pg: case pg:
PgConfiguration pgConfiguration = new Gson().fromJson(datasourceRequest.getDatasource().getConfiguration(), PgConfiguration.class); PgConfiguration pgConfiguration = new Gson().fromJson(datasourceRequest.getDatasource().getConfiguration(), PgConfiguration.class);
if (StringUtils.isEmpty(pgConfiguration.getSchema())) { if (StringUtils.isEmpty(pgConfiguration.getSchema())) {
throw new Exception(Translator.get("i18n_schema_is_empty")); throw new Exception(Translator.get("i18n_schema_is_empty"));

View File

@ -1,16 +1,16 @@
package io.dataease.service.message; package io.dataease.service.message;
import io.dataease.commons.utils.LogUtil;
import io.dataease.ext.ExtSysMsgMapper;
import io.dataease.commons.constants.SysMsgConstants; import io.dataease.commons.constants.SysMsgConstants;
import io.dataease.commons.utils.AuthUtils; import io.dataease.commons.utils.AuthUtils;
import io.dataease.commons.utils.CommonBeanFactory; import io.dataease.commons.utils.CommonBeanFactory;
import io.dataease.commons.utils.LogUtil;
import io.dataease.controller.sys.request.BatchSettingRequest; import io.dataease.controller.sys.request.BatchSettingRequest;
import io.dataease.controller.sys.request.MsgRequest; import io.dataease.controller.sys.request.MsgRequest;
import io.dataease.controller.sys.request.MsgSettingRequest; import io.dataease.controller.sys.request.MsgSettingRequest;
import io.dataease.controller.sys.response.MsgGridDto; import io.dataease.controller.sys.response.MsgGridDto;
import io.dataease.controller.sys.response.SettingTreeNode; import io.dataease.controller.sys.response.SettingTreeNode;
import io.dataease.controller.sys.response.SubscribeNode; import io.dataease.controller.sys.response.SubscribeNode;
import io.dataease.ext.ExtSysMsgMapper;
import io.dataease.plugins.common.base.domain.*; import io.dataease.plugins.common.base.domain.*;
import io.dataease.plugins.common.base.mapper.SysMsgChannelMapper; import io.dataease.plugins.common.base.mapper.SysMsgChannelMapper;
import io.dataease.plugins.common.base.mapper.SysMsgMapper; import io.dataease.plugins.common.base.mapper.SysMsgMapper;
@ -105,11 +105,11 @@ public class SysMsgService {
} }
public void setBatchRead(List<Long> msgIds) { public void setBatchRead(List<Long> msgIds) {
extSysMsgMapper.batchStatus(msgIds, System.currentTimeMillis()); extSysMsgMapper.batchStatus(msgIds, System.currentTimeMillis(), AuthUtils.getUser().getUserId());
} }
public void batchDelete(List<Long> msgIds) { public void batchDelete(List<Long> msgIds) {
extSysMsgMapper.batchDelete(msgIds); extSysMsgMapper.batchDelete(msgIds, AuthUtils.getUser().getUserId());
} }
public void save(SysMsg sysMsg) { public void save(SysMsg sysMsg) {

View File

@ -50,7 +50,7 @@ module.exports = {
'@': resolve('src') '@': resolve('src')
} }
}, },
output: { output: process.env.NODE_ENV === 'development' ? {} : {
filename: `js/[name].[contenthash:8].${pkg.version}.js`, filename: `js/[name].[contenthash:8].${pkg.version}.js`,
publicPath: '/', publicPath: '/',
chunkFilename: `js/[name].[contenthash:8].${pkg.version}.js` chunkFilename: `js/[name].[contenthash:8].${pkg.version}.js`