From 62163a5d16eb77db7df69123119f22f3d6167e50 Mon Sep 17 00:00:00 2001
From: king <hfjinsong@163.com>
Date: Fri, 13 Mar 2026 11:56:45 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A1=E7=AE=97=E9=94=80=E5=94=AE=E6=8A=A5?=
 =?UTF-8?q?=E8=A1=A8-=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../framework/service/impl/GrBiFsBusinessRealServiceImpl.java   | 2 ++
 .../core/framework/service/impl/GrBiStLotServiceImpl.java       | 2 ++
 .../framework/service/impl/GrBiStProductAvlServiceImpl.java     | 2 ++
 .../core/framework/service/impl/GrBiStProductServiceImpl.java   | 2 ++
 4 files changed, 8 insertions(+)

diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessRealServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessRealServiceImpl.java
index bebc166..50261a2 100644
--- a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessRealServiceImpl.java
+++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiFsBusinessRealServiceImpl.java
@@ -2,6 +2,7 @@ package com.lideeyunji.core.framework.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.lideeyunji.core.framework.entity.GrBiFsBusinessReal;
@@ -27,6 +28,7 @@ public class GrBiFsBusinessRealServiceImpl extends ServiceImpl<GrBiFsBusinessRea
 
 
     @Override
+    @DSTransactional
     @DS(value = "#dataSourceType")
     public void generateBusinessReal(String dataSourceType) {
         //获取本地mysql数据库中表中UPDATE_TIME最新的数据
diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStLotServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStLotServiceImpl.java
index 9008652..f92a944 100644
--- a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStLotServiceImpl.java
+++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStLotServiceImpl.java
@@ -2,6 +2,7 @@ package com.lideeyunji.core.framework.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.lideeyunji.core.framework.entity.GrBiStLot;
 import com.lideeyunji.core.framework.mapper.GrBiStLotMapper;
@@ -24,6 +25,7 @@ public class GrBiStLotServiceImpl extends ServiceImpl<GrBiStLotMapper, GrBiStLot
 {
 
     @Override
+    @DSTransactional
     @DS(value = "#dataSourceType")
     public void generateStLot(String dataSourceType) {
         //获取本地mysql数据库中表中UPDATE_TIME最新的数据
diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductAvlServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductAvlServiceImpl.java
index 3075802..31e7396 100644
--- a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductAvlServiceImpl.java
+++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductAvlServiceImpl.java
@@ -4,6 +4,7 @@ import java.util.List;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.lideeyunji.core.framework.entity.GrBiStProduct;
 import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant;
@@ -25,6 +26,7 @@ public class GrBiStProductAvlServiceImpl extends ServiceImpl<GrBiStProductAvlMap
 {
 
     @Override
+    @DSTransactional
     @DS(value = "#dataSourceType")
     public void generateStProductAvl(String dataSourceType) {
         //获取本地mysql数据库中表中UPDATE_TIME最新的数据
diff --git a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductServiceImpl.java b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductServiceImpl.java
index 3773f20..8fb70df 100644
--- a/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductServiceImpl.java
+++ b/lidee-core/src/main/java/com/lideeyunji/core/framework/service/impl/GrBiStProductServiceImpl.java
@@ -4,6 +4,7 @@ import java.util.List;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.lideeyunji.core.framework.entity.GrBiStProduct;
 import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant;
@@ -24,6 +25,7 @@ import com.lideeyunji.core.framework.service.IGrBiStProductService;
 public class GrBiStProductServiceImpl extends ServiceImpl<GrBiStProductMapper, GrBiStProduct> implements IGrBiStProductService
 {
     @Override
+    @DSTransactional
     @DS(value = "#dataSourceType")
     public void generateStProduct(String dataSourceType) {
         //获取本地mysql数据库中表中UPDATE_TIME最新的数据