From 8311467a832af7973f1f11fe6cd9a136ce5c45fc Mon Sep 17 00:00:00 2001
From: hekaiyu <13673834656@163.com>
Date: Wed, 15 Oct 2025 15:18:34 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E8=BF=9E?=
 =?UTF-8?q?=E6=8E=A5=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dataSource/controller/StasDataSourceController.java     | 6 +++---
 .../jeecg/dataSource/service/IStasDataSourceService.java    | 4 ++--
 .../dataSource/service/impl/StasDataSourceServiceImpl.java  | 3 +--
 3 files changed, 6 insertions(+), 7 deletions(-)

diff --git a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
index 843622d..1f48d7c 100644
--- a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
+++ b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
@@ -121,15 +121,15 @@ public class StasDataSourceController extends JeecgController<StasDataSource, IS
 
 	/**
 	 * 数据库连接测试
-	 * @param sourceId
+	 * @param stasDataSource
 	 * @return
 	 */
 	@AutoLog(value = "数据库连接测试")
 	@Operation(summary = "数据库连接测试")
 	@RequestMapping(value = "/testConnection", method = RequestMethod.GET)
-	public Result<StasDataSource> testConnection(String sourceId) {
+	public Result<StasDataSource> testConnection(StasDataSource stasDataSource) {
 		try {
-			boolean isValue = stasDataSourceService.testConnection(sourceId);
+			boolean isValue = stasDataSourceService.testConnection(stasDataSource);
 			if(isValue){
 				return Result.OK("连接成功");
 			}
diff --git a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/IStasDataSourceService.java b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/IStasDataSourceService.java
index 290a8ae..0cf3323 100644
--- a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/IStasDataSourceService.java
+++ b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/IStasDataSourceService.java
@@ -39,10 +39,10 @@ import java.util.List;
 
     /**
      * 测试数据库连接
-     * @param sourceId
+     * @param stasDataSource
      * @return
      */
-     boolean testConnection(String sourceId);
+     boolean testConnection(StasDataSource stasDataSource);
 
     /**
      * 查询所有用户信息
diff --git a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/impl/StasDataSourceServiceImpl.java b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/impl/StasDataSourceServiceImpl.java
index 0ec2482..f433e02 100644
--- a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/impl/StasDataSourceServiceImpl.java
+++ b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/impl/StasDataSourceServiceImpl.java
@@ -57,8 +57,7 @@ public class StasDataSourceServiceImpl extends ServiceImpl<StasDataSourceMapper,
     }
 
     @Override
-    public boolean testConnection(String sourceId) {
-        StasDataSource stasDataSource = this.baseMapper.selectById(sourceId);
+    public boolean testConnection(StasDataSource stasDataSource) {
         Connection conn = null;
         try {
             String urlSource = "";

From 83f027d1dd78601f5a42a9f4d7c2a92cb652f580 Mon Sep 17 00:00:00 2001
From: hekaiyu <13673834656@163.com>
Date: Wed, 15 Oct 2025 15:55:06 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E7=9B=AE=E6=A0=87?=
 =?UTF-8?q?=E6=BA=90=E6=89=80=E6=9C=89=E7=94=A8=E6=88=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/StasDataSourceController.java  | 24 ++++++++++++++++++-
 1 file changed, 23 insertions(+), 1 deletion(-)

diff --git a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
index 1f48d7c..2a60d14 100644
--- a/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
+++ b/jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
@@ -19,7 +19,9 @@ import org.jeecg.common.util.oConvertUtils;
 import org.jeecg.modules.base.entity.StasDataSource;
 import org.jeecg.dataSource.service.IStasDataSourceService;
 import org.jeecg.modules.base.entity.StasSyncStrategy;
+import org.jeecg.modules.base.entity.StasTaskConfig;
 import org.jeecg.modules.base.service.BaseCommonService;
+import org.jeecg.taskConfig.service.IStasTaskConfigService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import java.util.*;
@@ -40,6 +42,8 @@ public class StasDataSourceController extends JeecgController<StasDataSource, IS
 
 	@Autowired
 	private IStasDataSourceService stasDataSourceService;
+	@Autowired
+	private IStasTaskConfigService stasTaskConfigService;
 
 	/**
 	  * 分页列表查询
@@ -77,7 +81,7 @@ public class StasDataSourceController extends JeecgController<StasDataSource, IS
 	@AutoLog(value = "根据数据源名称查询所有表")
 	@Operation(summary = "根据数据源名称查询所有表")
 	@GetMapping(value = "/userList")
-	public Result<?> queryTargetUserList(@RequestParam(name="sourceId",required=false) String sourceId) {
+	public Result<?> queryUserList(@RequestParam(name="sourceId",required=false) String sourceId) {
 		List<String> tableNameList= stasDataSourceService.queryUserList(sourceId);
 		if (tableNameList != null && !"".equals(tableNameList)){
 			return Result.OK(tableNameList);
@@ -85,6 +89,24 @@ public class StasDataSourceController extends JeecgController<StasDataSource, IS
 		return Result.error("获取源端用户为空");
 	}
 
+	/**
+	 * 查询目标源所有用户
+	 *
+	 * @param taskId
+	 * @return
+	 */
+	@AutoLog(value = "查询目标源所有用户")
+	@Operation(summary = "查询目标源所有用户")
+	@GetMapping(value = "/targetUser")
+	public Result<?> queryTargetUserList(@RequestParam(name="taskId",required=false) String taskId) {
+		StasTaskConfig taskConfig = stasTaskConfigService.getById(taskId);
+		List<String> tableNameList= stasDataSourceService.queryUserList(taskConfig.getSourceId());
+		if (tableNameList != null && !"".equals(tableNameList)){
+			return Result.OK(tableNameList);
+		}
+		return Result.error("获取源端用户为空");
+	}
+
 	/**
 	 * 查询数据源表
 	 *