diff --git a/src/main/java/com/kwan/springbootkwan/controller/SeataControlller.java b/src/main/java/com/kwan/springbootkwan/controller/SeataControlller.java new file mode 100644 index 0000000000000000000000000000000000000000..2c3256e71e3e0b145ab11a1d7e62c9f023f20b2f --- /dev/null +++ b/src/main/java/com/kwan/springbootkwan/controller/SeataControlller.java @@ -0,0 +1,29 @@ +package com.kwan.springbootkwan.controller; + +import com.kwan.springbootkwan.entity.User; +import com.kwan.springbootkwan.service.IUserService; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RestController; + +@Slf4j +@RestController +@RequestMapping("/seata") +public class SeataControlller { + + @Autowired + private IUserService userService; + + @ApiOperation(value = "保存用户", notes = "保存用户") + @RequestMapping(value = "/save", method = RequestMethod.GET) + public User save() { + //保存用户 + User user = new User(); + user.setName("秦梓淞"); + user.setSex("男"); + return userService.saveUser(user); + } +} diff --git a/src/main/java/com/kwan/springbootkwan/mapper/PersonMapper.java b/src/main/java/com/kwan/springbootkwan/mapper/PersonMapper.java new file mode 100644 index 0000000000000000000000000000000000000000..450081f5411d356f09f8e847cedb28d85741b811 --- /dev/null +++ b/src/main/java/com/kwan/springbootkwan/mapper/PersonMapper.java @@ -0,0 +1,12 @@ +package com.kwan.springbootkwan.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.kwan.springbootkwan.entity.Person; +import org.apache.ibatis.annotations.Mapper; + + +@Mapper +public interface PersonMapper extends BaseMapper { + +} + diff --git a/src/main/java/com/kwan/springbootkwan/service/IPersonService.java b/src/main/java/com/kwan/springbootkwan/service/IPersonService.java new file mode 100644 index 0000000000000000000000000000000000000000..6083d65b5f38a941cca8fd347d2154c9c0f0d487 --- /dev/null +++ b/src/main/java/com/kwan/springbootkwan/service/IPersonService.java @@ -0,0 +1,9 @@ +package com.kwan.springbootkwan.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.kwan.springbootkwan.entity.Person; + +public interface IPersonService extends IService { + + Person savePerson(Person person); +} diff --git a/src/main/java/com/kwan/springbootkwan/service/IUserService.java b/src/main/java/com/kwan/springbootkwan/service/IUserService.java index 1cdb87d2ed49beaef9b57b6da7a9026c8c015c08..9591165a25944df55f6f508fa54e83504e516059 100644 --- a/src/main/java/com/kwan/springbootkwan/service/IUserService.java +++ b/src/main/java/com/kwan/springbootkwan/service/IUserService.java @@ -28,4 +28,13 @@ public interface IUserService extends IService { * @return */ User getUserByName(String sex); + + /** + * 保存用户 + * + * @param user + * @return + */ + User saveUser(User user); + } diff --git a/src/main/java/com/kwan/springbootkwan/service/impl/PersonServiceImpl.java b/src/main/java/com/kwan/springbootkwan/service/impl/PersonServiceImpl.java new file mode 100644 index 0000000000000000000000000000000000000000..14defff0e5086e3a3949e10af352ef864e2c2147 --- /dev/null +++ b/src/main/java/com/kwan/springbootkwan/service/impl/PersonServiceImpl.java @@ -0,0 +1,22 @@ +package com.kwan.springbootkwan.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.kwan.springbootkwan.entity.Person; +import com.kwan.springbootkwan.mapper.PersonMapper; +import com.kwan.springbootkwan.service.IPersonService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +@Service +public class PersonServiceImpl extends ServiceImpl implements IPersonService { + + @Autowired + private PersonMapper personMapper; + +// @DS(value ="ali-ds" ) + @Override + public Person savePerson(Person person) { + personMapper.insert(person); + return person; + } +} diff --git a/src/main/java/com/kwan/springbootkwan/service/impl/UserServiceImpl.java b/src/main/java/com/kwan/springbootkwan/service/impl/UserServiceImpl.java index f72cbf85afa96b1e3495b9f8235bccea78d184a0..5ac8ba651a4aa3763e1981f0c7c0878b774c2077 100644 --- a/src/main/java/com/kwan/springbootkwan/service/impl/UserServiceImpl.java +++ b/src/main/java/com/kwan/springbootkwan/service/impl/UserServiceImpl.java @@ -1,8 +1,10 @@ package com.kwan.springbootkwan.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.kwan.springbootkwan.entity.Person; import com.kwan.springbootkwan.entity.User; import com.kwan.springbootkwan.mapper.UserMapper; +import com.kwan.springbootkwan.service.IPersonService; import com.kwan.springbootkwan.service.IUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -15,6 +17,8 @@ public class UserServiceImpl extends ServiceImpl implements IU @Autowired private UserMapper userMapper; + @Autowired + private IPersonService personService; @Override public List getUsers() { @@ -28,10 +32,21 @@ public class UserServiceImpl extends ServiceImpl implements IU @Override public User getUserByName(String sex) { - User userByName = userMapper.getUserByName(sex); + User userByName = userMapper.getUserByName(sex); if (Objects.isNull(userByName)) { userByName = new User(); } return userByName; } + + @Override + public User saveUser(User user) { + userMapper.insert(user); + Person person = new Person(); + person.setUsername(user.getName()); + person.setAddress("当铺"); + person.setGender(user.getSex()); + personService.savePerson(person); + return user; + } } \ No newline at end of file diff --git a/src/main/resources/application-bak.yaml b/src/main/resources/application-bak.yaml new file mode 100644 index 0000000000000000000000000000000000000000..804b99a0427447cf95073d023b8470bee040c851 --- /dev/null +++ b/src/main/resources/application-bak.yaml @@ -0,0 +1,115 @@ +server: + port: 8761 + servlet: + encoding: + force: true + charset: UTF-8 + enabled: true + +swagger: + enable: true + +#兼容swagger配置 +spring: + application: + name: spring-boot-demo + #项目启动时创建数据表的 SQL 脚本，该脚本由 Spring Batch 提供 + #spring.datasource.schema=classpath:/org/springframework/batch/core/schema-mysql.sql + # 在项目启动时执行建表 SQL + batch: + initialize-schema: always + # 禁止 Spring Batch 自动执行，在 SpringBoot 中，默认情况，当项目启动时就会执行配置好的批理操作，添加了该配置后则不会自动执行，而需要用户手动触发执行 + job: + enabled: false + mail: + host: smtp.qq.com + # 发送者的邮箱账号 + username: 327782001@qq.com + # 邮箱密码授权码 + password: kypxnmwfniqrcbeh + properties: + mail: + smtp: + auth: true + starttls: + enable: true + required: true + redis: + database: 0 # Redis数据库索引（默认为0） + host: 120.79.36.53 #Redis服务器地址 + port: 6379 # Redis服务器连接端口 + password: # Redis服务器连接密码（默认为空） + jedis: + pool: + max-active: 200 # 连接池最大连接数（使用负值表示没有限制） + max-idle: 10 # 连接池中的最大空闲连接 + min-idle: 0 # 连接池中的最小空闲连接 + max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制） + mvc: + pathmatch: + matching-strategy: ant_path_matcher + # mysql + datasource: + url: jdbc:mysql://localhost:3306/kwan?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai + driver-class-name: com.mysql.cj.jdbc.Driver + username: root + password: 716288qwe + + +# dynamic: +# primary: kwan-ds +# datasource: +# kwan-ds: +# url: jdbc:mysql://localhost:3306/kwan?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai +# driver-class-name: com.mysql.cj.jdbc.Driver +# username: root +# password: 716288qwe +## ali-ds: +## url: jdbc:mysql://localhost:3306/spring-boot?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai +## driver-class-name: com.mysql.cj.jdbc.Driver +## username: root +## password: 1716288qwe +# seata: true +# cloud: +# nacos: +# discovery: +# server-addr: http://120.79.36.53:8848 #服务注册地址 +# config: +# enabled: false + +#seata配置 +seata: + enable-auto-data-source-proxy: false + application-id: ${spring.application.name} + tx-service-group: ${spring.application.name}-group + service: + vgroup-mapping: + spring-boot-demo-group: default + grouplist: + default: 127.0.0.1:8091 + config: + type: file + registry: + type: file + +#mybatis-plus配置 +mybatis-plus: + configuration: + map-underscore-to-camel-case: true + call-setters-on-nulls: true + auto-mapping-behavior: full + log-impl: org.apache.ibatis.logging.stdout.StdOutImpl + mapper-locations: classpath*:mapper/**/*Mapper.xml + global-config: + banner: false + # 逻辑删除配置 + db-config: + id-type: AUTO + logic-delete-field: delFlag + logic-delete-value: 1 + logic-not-delete-value: 0 + table-underline: true + +#logger配置 +logging: + config: classpath:logback-spring.xml