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> 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 } log.info("任务执行完成,新增sql为: [{}]", addSql); - Result> 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 "执行成功"; }