From 5a5f6fca264fbeeda8f602d3336dcaf404a81dc4 Mon Sep 17 00:00:00 2001
From: Cui YongXing <2835316714@qq.com>
Date: Tue, 3 Sep 2024 17:13:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AD=97=E6=AE=B5=E5=92=8C?=
 =?UTF-8?q?=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/muyu/remote/feign/DatasourceFeign.java | 6 ++++++
 .../remote/feign/Factory/DatasourceFeignFactory.java     | 9 +++++++++
 .../task/server/service/impl/TaskInfoServiceImpl.java    | 3 +--
 3 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java b/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java
index ca3e234..f2c77ac 100644
--- a/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java
+++ b/cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java
@@ -6,6 +6,7 @@ import com.muyu.remote.feign.Factory.DatasourceFeignFactory;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 import com.muyu.common.core.domain.Result;
 
@@ -19,4 +20,9 @@ import java.util.List;
 public interface DatasourceFeign {
     @PostMapping("/dataValue/findTableValue")
     public Result<List<List<DataValue>>> findTableValue(@RequestParam("basicId") Long basicId, @RequestParam("sql") String sql);
+
+
+    @PostMapping("/dataValue/addProduct")
+    public Result addProduct(@RequestParam("basicId") Long basicId, @RequestParam("tableId") Long tableId, @RequestBody List<List<DataValue>> listList);
+
 }
diff --git a/cloud-task-remote/src/main/java/com/muyu/remote/feign/Factory/DatasourceFeignFactory.java b/cloud-task-remote/src/main/java/com/muyu/remote/feign/Factory/DatasourceFeignFactory.java
index 360ee90..38783df 100644
--- a/cloud-task-remote/src/main/java/com/muyu/remote/feign/Factory/DatasourceFeignFactory.java
+++ b/cloud-task-remote/src/main/java/com/muyu/remote/feign/Factory/DatasourceFeignFactory.java
@@ -1,11 +1,14 @@
 package com.muyu.remote.feign.Factory;
 
 import com.muyu.common.core.domain.Result;
+import com.muyu.common.domain.DataValue;
 import com.muyu.remote.feign.DatasourceFeign;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.cloud.openfeign.FallbackFactory;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+
 @Log4j2
 @Component
 public class DatasourceFeignFactory implements FallbackFactory<DatasourceFeign> {
@@ -17,6 +20,12 @@ public class DatasourceFeignFactory implements FallbackFactory<DatasourceFeign>
                 log.info(e);
                 return Result.error("网络开小差......");
             }
+
+            @Override
+            public Result addProduct(Long basicId, Long tableId, List<List<DataValue>> listList) {
+                log.info(e);
+                return Result.error("网络开小差......");
+            }
         };
     }
 }
diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
index b38aafd..94a9cfa 100644
--- a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
+++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
@@ -235,10 +235,9 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
                 String newKey = map.get(key);
                 dataValue.setKey(newKey);
                 log.info(dataValue);
-
-
             }
         }
+        Result result = datasourceFeign.addProduct(basicId, tableId, tableValue);
         return "执行成功";
     }