From 5c00b4908068ea89c8d477504e06ab8e43a42278 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=91=E5=B9=B4=E6=A2=A6=E4=B8=8E=E7=A0=96?=
 <2847127106@qq.com>
Date: Wed, 4 Sep 2024 19:05:13 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E4=BB=BB=E5=8A=A1=E6=A8=A1?=
 =?UTF-8?q?=E5=9D=97=E7=9A=84=E6=89=A7=E8=A1=8C=E6=8E=A5=E5=8F=A3=E4=B8=8E?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=85=A5=E6=A8=A1=E5=9D=97=E7=9A=84?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2sql=E6=89=A7=E8=A1=8C=E6=8E=A5=E5=8F=A3+?=
 =?UTF-8?q?=E6=96=B0=E5=A2=9Esql=E6=89=A7=E8=A1=8C=E6=8E=A5=E5=8F=A3?=
 =?UTF-8?q?=E8=81=94=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/muyu/quest/remote/RemoteDataSourceService.java | 10 ++++++++++
 .../quest/remote/factory/RemoteDataSourceFactory.java  |  5 +++++
 .../com/muyu/quest/service/impl/TaskServiceImpl.java   |  6 +++---
 3 files changed, 18 insertions(+), 3 deletions(-)

diff --git a/muyu-quest-remote/src/main/java/com/muyu/quest/remote/RemoteDataSourceService.java b/muyu-quest-remote/src/main/java/com/muyu/quest/remote/RemoteDataSourceService.java
index 61d17bf..c323871 100644
--- a/muyu-quest-remote/src/main/java/com/muyu/quest/remote/RemoteDataSourceService.java
+++ b/muyu-quest-remote/src/main/java/com/muyu/quest/remote/RemoteDataSourceService.java
@@ -4,6 +4,7 @@ import com.muyu.common.core.domain.Result;
 import com.muyu.quest.model.DataModel;
 import com.muyu.quest.model.DataValueModel;
 import com.muyu.quest.remote.factory.RemoteDataSourceFactory;
+import io.swagger.v3.oas.annotations.Operation;
 import org.springframework.cloud.openfeign.FeignClient;
 import com.muyu.common.core.constant.ServiceNameConstants;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -26,4 +27,13 @@ public interface RemoteDataSourceService {
 
     @PostMapping("/value/findTableValue")
     public Result<List<DataModel>> findTableValue(@RequestBody DataValueModel dataValueModel);
+
+    /**
+     * 根据基础表ID和SQL语句查询数据
+     *
+     * @param dataValueModel 基础表ID和sql语句
+     * @return DataValue{kltv}
+     */
+    @PostMapping("/value/addTableValue")
+    public Result addTableValue(@RequestBody DataValueModel dataValueModel);
 }
diff --git a/muyu-quest-remote/src/main/java/com/muyu/quest/remote/factory/RemoteDataSourceFactory.java b/muyu-quest-remote/src/main/java/com/muyu/quest/remote/factory/RemoteDataSourceFactory.java
index d1a3460..f6b6a04 100644
--- a/muyu-quest-remote/src/main/java/com/muyu/quest/remote/factory/RemoteDataSourceFactory.java
+++ b/muyu-quest-remote/src/main/java/com/muyu/quest/remote/factory/RemoteDataSourceFactory.java
@@ -21,6 +21,11 @@ public class RemoteDataSourceFactory implements FallbackFactory<RemoteDataSource
             public Result findTableValue(DataValueModel dataValueModel) {
                 return Result.error("数据接入模块连接失败,网络异常...");
             }
+
+            @Override
+            public Result addTableValue(DataValueModel dataValueModel) {
+                return Result.error("数据接入模块连接失败,网络异常...");
+            }
         };
     }
 }
diff --git a/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java b/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java
index 893c875..158e621 100644
--- a/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java
+++ b/muyu-quest-server/src/main/java/com/muyu/quest/service/impl/TaskServiceImpl.java
@@ -204,9 +204,9 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task>
         }
 
         log.info("任务执行完成,新增sql为: [{}]", addSql);
-        Result<List<DataModel>> tableValue = remoteDataSourceService.findTableValue(new DataValueModel(4L, addSql));
-        if (tableValue.getCode() != 200){
-            throw new TaskException(tableValue.getMsg());
+        Result i = remoteDataSourceService.addTableValue(new DataValueModel(4L, addSql));
+        if (i.getCode() != 200){
+            throw new TaskException(i.getMsg());
         }
         return "执行成功";
     }