增加数据源的远程调用模块

master
冷调 2024-08-21 11:04:35 +08:00
parent a1ff33d35a
commit 833b4e8ff4
4 changed files with 48 additions and 7 deletions

View File

@ -0,0 +1,18 @@
package com.muyu.source.remote;
import com.muyu.source.remote.factory.RemoteDataSourceFactory;
import org.springframework.cloud.openfeign.FeignClient;
import com.muyu.common.core.constant.ServiceNameConstants;
/**
* @ ToolIntelliJ IDEA
* @ AuthorCHX
* @ Date2024-08-21-10:50
* @ Version1.0
* @ Description
* @author Lenovo
*/
@FeignClient(contextId = "RemoteDataSourceService",value = ServiceNameConstants.SOURCE_SERVICE,fallbackFactory = RemoteDataSourceFactory.class, path = "/dataSource")
public interface RemoteDataSourceService {
}

View File

@ -0,0 +1,19 @@
package com.muyu.source.remote.factory;
import com.muyu.source.remote.RemoteDataSourceService;
import org.springframework.cloud.openfeign.FallbackFactory;
/**
* @ ToolIntelliJ IDEA
* @ AuthorCHX
* @ Date2024-08-21-10:54
* @ Version1.0
* @ Description
* @author Lenovo
*/
public class RemoteDataSourceFactory implements FallbackFactory<RemoteDataSourceService> {
@Override
public RemoteDataSourceService create(Throwable cause) {
return null;
}
}

View File

@ -1 +1 @@
com.muyu.source.remote.factory.RemoteDataSourceFactory

View File

@ -1,8 +1,5 @@
package com.muyu.source.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.conditions.update.UpdateChainWrapper;
import com.dtflys.forest.annotation.Post;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.source.domain.DataSource;
@ -43,12 +40,19 @@ public class DataSourceController extends BaseController {
List<DataSource> list =dataSourceService.list();
return Result.success(list);
}
@PutMapping("/update")
public Result<?> update(@RequestBody DataSource dataSource){
UpdateChainWrapper<DataSource> update = dataSourceService.update();
/**
*
* @param dataSource
* @return
*/
@PostMapping("/insert")
public Result<String> insert(@RequestBody DataSource dataSource){
dataSourceService.save(dataSource);
return Result.success();
}
}