给所有动态数据源切换DynamicDataSourceContextHolder.push 加上try finally处理

This commit is contained in:
1378012178@qq.com 2025-10-16 15:28:12 +08:00
parent 8c63f3f367
commit 2f3e41dd38
5 changed files with 78 additions and 29 deletions

View File

@ -42,9 +42,12 @@ public class CategoryMQDto implements Serializable {
* 是否删除 0未删除 1删除
*/
private String delFlag;
/**
* 网络标记0为用pad本地静态图片1为用网络图
*/
private java.lang.String netFlag;
/**
* 动画图片
*/
private String animationPath;
private java.lang.String animationPath;
}

View File

@ -46,4 +46,12 @@ public class DirectiveTypeMQDto implements Serializable {
* 是否删除 0未删除 1删除
*/
private String delFlag;
/**
* 网络标记0为用pad本地静态图片1为用网络图
*/
private java.lang.String netFlag;
/**
* 动画图片
*/
private java.lang.String animationPath;
}

View File

@ -1,8 +1,6 @@
package com.nu.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.jeecgframework.poi.excel.annotation.Excel;
import java.io.Serializable;
import java.math.BigDecimal;
@ -11,43 +9,79 @@ import java.util.Date;
/**
* @Description: 长者标签
* @Author: zmy
* @Date: 2025-08-13
* @Date: 2025-08-13
* @Version: V1.0
*/
@Data
public class ElderTagAsyncMQDto implements Serializable {
/**id*/
/**
* id
*/
private String id;
/**标签类型*/
/**
* 标签类型
*/
private String type;
/**标签名称*/
/**
* 标签名称
*/
private String tagName;
/**说明*/
/**
* 说明
*/
private java.lang.String describ;
/**价格*/
/**
* 价格
*/
private BigDecimal price;
/**图标*/
/**
* 图标
*/
private String pic;
/**图标md5值*/
/**
* 图标md5值
*/
private String picMd5;
/**排序*/
/**
* 焦点图标
*/
private java.lang.String picFocus;
/**
* 排序
*/
private Integer sort;
/**是否启用*/
/**
* 是否启用
*/
private String izEnabled;
/**是否删除*/
/**
* 是否删除
*/
private String delFlag;
/**创建人*/
/**
* 创建人
*/
private String createBy;
/**创建日期*/
/**
* 创建日期
*/
private Date createTime;
/**更新人*/
/**
* 更新人
*/
private String updateBy;
/**更新日期*/
/**
* 更新日期
*/
private Date updateTime;
/**所属机构*/
/**
* 所属机构
*/
private String sysOrgCode;
/**资源请求接口域名+项目上下文路径 */
/**
* 资源请求接口域名+项目上下文路径
*/
private String api;
}

View File

@ -16,7 +16,7 @@ public class ElderTagMQDto {
//同步子表code
private String code;
//指令集合
//标签集合
private List<ElderTagAsyncMQDto> elderTagList;
//是否同步指令资源
private boolean izSyncMedia;

View File

@ -92,13 +92,17 @@ public class NuEmployeesAdvisoryInfoController extends JeecgController<NuEmploye
//切换为本地数据源
DynamicDataSourceContextHolder.push("ope");
QueryWrapper<NuEmployeesAdvisoryInfo> queryWrapper = QueryGenerator.initQueryWrapper(nuEmployeesAdvisoryInfo, req.getParameterMap());
Page<NuEmployeesAdvisoryInfo> page = new Page<NuEmployeesAdvisoryInfo>(pageNo, pageSize);
if (ids1 != null && ids1.size() > 0) {
queryWrapper.notIn("id", ids1);
IPage<NuEmployeesAdvisoryInfo> pageList;
try {
QueryWrapper<NuEmployeesAdvisoryInfo> queryWrapper = QueryGenerator.initQueryWrapper(nuEmployeesAdvisoryInfo, req.getParameterMap());
Page<NuEmployeesAdvisoryInfo> page = new Page<NuEmployeesAdvisoryInfo>(pageNo, pageSize);
if (ids1 != null && ids1.size() > 0) {
queryWrapper.notIn("id", ids1);
}
pageList = nuEmployeesAdvisoryInfoService.page(page, queryWrapper);
} finally {
DynamicDataSourceContextHolder.clear();
}
IPage<NuEmployeesAdvisoryInfo> pageList = nuEmployeesAdvisoryInfoService.page(page, queryWrapper);
DynamicDataSourceContextHolder.clear();
List<NuEmployeesAdvisoryInfo> records = pageList.getRecords();
if (records != null && records.size() > 0) {
@ -122,7 +126,7 @@ public class NuEmployeesAdvisoryInfoController extends JeecgController<NuEmploye
List<BizEmployeesMedia> list = employeesMediaService.list(qw);
for (int i = 0; i < list.size(); i++) {
Integer index = idToIndexMap.get(list.get(i).getEmployeesId());
if(index!=null){
if (index != null) {
records.get(index).setHasCardZmPath(list.get(i).getCardZmPath());//是否有身份证正面
records.get(index).setHasCardFmPath(list.get(i).getCardFmPath());//是否有身份证反面
}