|
|
@@ -10,6 +10,7 @@ import com.server.ImplementSqlService;
|
|
|
import com.util.BasesSource.TargetDataSource;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
|
+import org.springframework.web.bind.annotation.RequestHeader;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
|
|
@@ -26,8 +27,9 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
保存数据源配置
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/inputDataConnector")
|
|
|
- public RepEntity inputDataConnector(@RequestBody DataConnectorInfo body) {
|
|
|
+ public RepEntity inputDataConnector(@RequestHeader String token, @RequestBody DataConnectorInfo body) {
|
|
|
System.out.println("-----------");
|
|
|
System.out.println(body);
|
|
|
return dataConnectorService.setDataConnector(body);
|
|
|
@@ -36,32 +38,36 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
查看数据源列表
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/getListDataConnector")
|
|
|
- public RepEntity getListDataConnector(){
|
|
|
+ public RepEntity getListDataConnector(@RequestHeader String token){
|
|
|
return dataConnectorService.getListConnector();
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
查看单个数据源配置
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/getDataConnector")
|
|
|
- public RepEntity getDataConnector(@RequestBody int body){
|
|
|
+ public RepEntity getDataConnector(@RequestHeader String token,@RequestBody int body){
|
|
|
return dataConnectorService.getConnector(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
更新数据源配置
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/updateData")
|
|
|
- public RepEntity updateData(@RequestBody DataConnectorInfo body){
|
|
|
+ public RepEntity updateData(@RequestHeader String token,@RequestBody DataConnectorInfo body){
|
|
|
return dataConnectorService.updateData(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
更新数据源配置的分组
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/updateConnectConfigGroup")
|
|
|
- public RepEntity updateConConfigGroup(@RequestBody GroupUpdateId body){
|
|
|
+ public RepEntity updateConConfigGroup(@RequestHeader String token,@RequestBody GroupUpdateId body){
|
|
|
return dataConnectorService.updateConfigGroup(body);
|
|
|
}
|
|
|
|
|
|
@@ -69,57 +75,69 @@ public class DataConnectorController {
|
|
|
/*
|
|
|
删除配置
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/delDataConnector")
|
|
|
- public RepEntity delDataConnector(@RequestBody List<Integer> body){
|
|
|
+ public RepEntity delDataConnector(@RequestHeader String token,@RequestBody List<Integer> body){
|
|
|
return dataConnectorService.delDataConnector(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
执行数据源配置
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/implementSql")
|
|
|
@TargetDataSource
|
|
|
- public RepEntity implementSql(@RequestBody ToSql body){
|
|
|
+ public RepEntity implementSql(@RequestHeader String token,@RequestBody ToSql body){
|
|
|
return implementSqlService.implementSql(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
添加数据源分组
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/setConnectorGroup")
|
|
|
- public RepEntity setConnectorGroup(@RequestBody GroupInfo body){
|
|
|
+ public RepEntity setConnectorGroup(@RequestHeader String token,@RequestBody GroupInfo body){
|
|
|
return dataConnectorService.setDataConnectorGroup(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
更新数据源分组
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/updataDataConnectorGroup")
|
|
|
- public RepEntity updataDataConnectorGroup(@RequestBody GroupInfo body){
|
|
|
+ public RepEntity updataDataConnectorGroup(@RequestHeader String token,@RequestBody GroupInfo body){
|
|
|
return dataConnectorService.updataDataConnectorGroup(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
批量更新数据源分组
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/updataConnectorGroup")
|
|
|
- public RepEntity updataConnectorGroup(@RequestBody List<GroupInfo> body){
|
|
|
+ public RepEntity updataConnectorGroup(@RequestHeader String token,@RequestBody List<GroupInfo> body){
|
|
|
return dataConnectorService.updataConnectorGroups(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
删除数据源分组
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/delDataConnectorGroup")
|
|
|
- public RepEntity delDataConnectorGroup(@RequestBody List<Integer> body){
|
|
|
+ public RepEntity delDataConnectorGroup(@RequestHeader String token,@RequestBody List<Integer> body){
|
|
|
return dataConnectorService.delDataConnectorGroup(body);
|
|
|
}
|
|
|
|
|
|
/*
|
|
|
查询数据源分组
|
|
|
*/
|
|
|
+ @CheckToken
|
|
|
@RequestMapping("/getConnectorGroup")
|
|
|
- public RepEntity getConnectorGroup(){
|
|
|
+ public RepEntity getConnectorGroup(@RequestHeader String token){
|
|
|
return dataConnectorService.getConnectorGroup();
|
|
|
}
|
|
|
+
|
|
|
+ /*
|
|
|
+ 添加数据源策略
|
|
|
+ */
|
|
|
+// @RequestMapping("/")
|
|
|
}
|