Merge remote-tracking branch 'origin/dev' into dev

# Conflicts:
#	srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/StuApp.java
#	srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/controllor/StuController.java
#	srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/mapper/StuMapper.java
#	srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/StuService.java
#	srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/server/impl/StuServiceImpl.java
#	srt-cloud-module/srt-cloud-datax/src/main/java/net/srt/datax/vo/Stu.java
#	srt-cloud-module/srt-cloud-datax/src/main/resources/auth.yml
master
jpz 2023-12-14 20:46:33 +08:00
commit 458daa1f83
9 changed files with 65 additions and 34 deletions

View File

@ -23,6 +23,7 @@ spring:
- Path=/sys/** - Path=/sys/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-quartz - id: srt-cloud-quartz
uri: lb://srt-cloud-quartz uri: lb://srt-cloud-quartz
order: 2 order: 2
@ -30,6 +31,7 @@ spring:
- Path=/schedule/** - Path=/schedule/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-message - id: srt-cloud-message
uri: lb://srt-cloud-message uri: lb://srt-cloud-message
order: 3 order: 3
@ -37,6 +39,7 @@ spring:
- Path=/message/** - Path=/message/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-data-integrate - id: srt-cloud-data-integrate
uri: lb://srt-cloud-data-integrate uri: lb://srt-cloud-data-integrate
order: 4 order: 4
@ -44,6 +47,7 @@ spring:
- Path=/data-integrate/** - Path=/data-integrate/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-data-development - id: srt-cloud-data-development
uri: lb://srt-cloud-data-development uri: lb://srt-cloud-data-development
order: 5 order: 5
@ -51,6 +55,7 @@ spring:
- Path=/data-development/** - Path=/data-development/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-data-service - id: srt-cloud-data-service
uri: lb://srt-cloud-data-service uri: lb://srt-cloud-data-service
order: 6 order: 6
@ -58,6 +63,7 @@ spring:
- Path=/data-service/** - Path=/data-service/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-data-governance - id: srt-cloud-data-governance
uri: lb://srt-cloud-data-governance uri: lb://srt-cloud-data-governance
order: 7 order: 7
@ -65,6 +71,7 @@ spring:
- Path=/data-governance/** - Path=/data-governance/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: srt-cloud-data-assets - id: srt-cloud-data-assets
uri: lb://srt-cloud-data-assets uri: lb://srt-cloud-data-assets
order: 8 order: 8
@ -72,19 +79,29 @@ spring:
- Path=/data-assets/** - Path=/data-assets/**
filters: filters:
- StripPrefix=1 - StripPrefix=1
- id: openapi - id: openapi
uri: http://localhost:${server.port} uri: http://localhost:${server.port}
predicates: predicates:
- Path=/v3/api-docs/** - Path=/v3/api-docs/**
filters: filters:
- RewritePath=/v3/api-docs/(?<path>.*), /$\{path}/v3/api-docs - RewritePath=/v3/api-docs/(?<path>.*), /$\{path}/v3/api-docs
- id: srt-cloud-datax # New Gateway
uri: lb://srt-cloud-datax # Update with the correct URI for your new service
predicates:
- Path=/srt-cloud-datax/** # Adjust the path as needed
filters:
- StripPrefix=1
nacos: nacos:
discovery: discovery:
server-addr: 101.34.77.101:8848 server-addr: 101.34.77.101:8848
# 命名空间默认public # 命名空间默认public
namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b
service: ${spring.application.name} service: ${spring.application.name}
group: srt2.0 group: srt2.1
springdoc: springdoc:
swagger-ui: swagger-ui:

View File

@ -11,6 +11,7 @@
<modules> <modules>
<module>srt-cloud-quartz</module> <module>srt-cloud-quartz</module>
<module>srt-cloud-message</module> <module>srt-cloud-message</module>
<module>srt-cloud-datax</module>
</modules> </modules>

View File

@ -16,5 +16,6 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
public class StuApp { public class StuApp {
public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(StuApp.class); SpringApplication.run(StuApp.class);
System.out.println("Hello world!");
} }
} }

View File

@ -7,7 +7,6 @@ import net.srt.datax.server.StuService;
import net.srt.datax.vo.Stu; import net.srt.datax.vo.Stu;
import net.srt.framework.common.utils.Result; import net.srt.framework.common.utils.Result;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List; import java.util.List;
@ -18,7 +17,7 @@ import java.util.List;
* @Author * @Author
*/ */
@RestController @RestController
@RequestMapping("stu/platform") @RequestMapping("/stu/platform")
@Tag(name = "对学生进行操作") @Tag(name = "对学生进行操作")
@AllArgsConstructor @AllArgsConstructor
public class StuController { public class StuController {
@ -28,35 +27,35 @@ public class StuController {
@Operation(summary = "查询列表") @Operation(summary = "查询列表")
@PostMapping("stuList") @PostMapping("/stuList")
public Result<List<Stu>> stuList() { public Result<List<Stu>> stuList() {
List<Stu> stuList = stuService.stuList(); List<Stu> stuList = stuService.stuList();
return Result.ok(stuList); return Result.ok(stuList);
} }
@Operation(summary = "新增") @Operation(summary = "新增")
@PostMapping("addStudent") @PostMapping("/addStudent")
public Result<Stu> add(@RequestBody Stu stu) { public Result<Stu> add(@RequestBody Stu stu) {
stuService.add(stu); stuService.add(stu);
return Result.ok(); return Result.ok();
} }
@Operation(summary = "修改列表") @Operation(summary = "修改列表")
@PostMapping("updateStudent") @PostMapping("/updateStudent")
public Result<Stu> updateStudent(@RequestBody Stu stu) { public Result<Stu> updateStudent(@RequestBody Stu stu) {
stuService.updateStudent(stu); stuService.updateStudent(stu);
return Result.ok(); return Result.ok();
} }
@Operation(summary = "删除列表") @Operation(summary = "删除列表")
@PostMapping("delStudent/{id}") @PostMapping("/delStudent/{id}")
public Result<String> delStudent(@PathVariable Long id) { public Result<String> delStudent(@PathVariable Long id) {
stuService.delStudent(id); stuService.delStudent(id);
return Result.ok(); return Result.ok();
} }
@Operation(summary = "回显") @Operation(summary = "回显")
@PostMapping("findById/{id}") @PostMapping("/findById/{id}")
public Result<Stu> findById(@PathVariable Integer id) { public Result<Stu> findById(@PathVariable Integer id) {
if (id!= null) { if (id!= null) {
return Result.ok(stuService.findById(id)); return Result.ok(stuService.findById(id));

View File

@ -2,9 +2,6 @@ package net.srt.datax.server;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import net.srt.datax.vo.Stu; import net.srt.datax.vo.Stu;
import net.srt.framework.common.utils.Result;
import net.srt.framework.mybatis.service.BaseService;
import org.bouncycastle.asn1.x509.IssuerSerial;
import java.util.List; import java.util.List;

View File

@ -1,24 +1,14 @@
package net.srt.datax.server.impl; package net.srt.datax.server.impl;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import net.srt.datax.mapper.StuMapper; import net.srt.datax.mapper.StuMapper;
import net.srt.datax.server.StuService; import net.srt.datax.server.StuService;
import net.srt.datax.vo.Stu; import net.srt.datax.vo.Stu;
import net.srt.framework.common.cache.bean.DataProjectCacheBean;
import net.srt.framework.common.utils.Result;
import net.srt.framework.mybatis.service.impl.BaseServiceImpl; import net.srt.framework.mybatis.service.impl.BaseServiceImpl;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.lang.annotation.Annotation;
import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.function.Function;
/** /**
* @ClassName StuServiceImpl * @ClassName StuServiceImpl
* @Description * @Description

View File

@ -1,12 +1,10 @@
package net.srt.datax.vo; package net.srt.datax.vo;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor;
import javax.naming.directory.SearchControls;
import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import java.util.Date; import java.util.Date;
@ -19,10 +17,11 @@ import java.util.Date;
@Data @Data
@Schema(description = "字典数据") @Schema(description = "字典数据")
@TableName("data_datax") @TableName("data_datax")
public class Stu { public class Stu {
@Schema(description = "id", required = true) @Schema(description = "id", required = true)
@NotNull(message = "id不能为空") @NotNull(message = "id不能为空")
@TableId(value = "id")
private Long id; private Long id;
@Schema(description = "库名", required = true) @Schema(description = "库名", required = true)
@ -48,20 +47,12 @@ public class Stu {
@NotBlank(message = "创建人不能为空") @NotBlank(message = "创建人不能为空")
private String createUser; private String createUser;
@Schema(description = "data同步", required = true)
@NotBlank(message = "不能为空")
private Integer dataSynchronization;
@Schema(description = "***", required = true)
@NotBlank(message = "***不能为空")
private Integer dataxEngine;
@Schema(description = "修改时间", required = true) @Schema(description = "修改时间", required = true)
@NotBlank(message = "修改时间不能为空") @NotBlank(message = "修改时间不能为空")
private Date updateTime; private Date updateTime;
@Schema(description = "修改人", required = true) @Schema(description = "修改人", required = true)
@NotBlank(message = "修改人不能为空") @NotBlank(message = "修改人不能为空")
private String updateUser; private Date updateUser;
} }

View File

@ -1,3 +1,4 @@
auth: auth:
ignore_urls: ignore_urls:
- /datax/** - /datax/**
- /api/quartz/**

View File

@ -0,0 +1,34 @@
server:
port: 8091
spring:
application:
name: srt-cloud-datax
profiles:
active: dev
cloud:
nacos:
discovery:
server-addr: 101.34.77.101:8848
# 命名空间默认public
namespace: c5d32e76-b83c-4254-8176-1c6a2cee8e3b
service: ${spring.application.name}
group: srt2.1
config:
server-addr: ${spring.cloud.nacos.discovery.server-addr}
namespace: ${spring.cloud.nacos.discovery.namespace}
file-extension: yaml
# 指定配置
extension-configs:
- data-id: datasource.yaml
refresh: true
# feign 配置
feign:
client:
config:
default:
connectTimeout: 1200000
readTimeout: 1200000
loggerLevel: basic
okhttp:
enabled: true