From da6d9c70d1fd94ba43643cfaaae889195dc66cb0 Mon Sep 17 00:00:00 2001 From: pqh <2897412868@qq.com> Date: Tue, 7 Nov 2023 21:11:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .gitignore | 38 + .idea/.gitignore | 8 + .idea/encodings.xml | 20 + .idea/mavenServices.xml | 9 + .idea/misc.xml | 14 + .idea/uiDesigner.xml | 124 +++ bwie-auth/.gitignore | 38 + bwie-auth/pom.xml | 34 + .../java/com/bwie/auth/AuthApplication.java | 19 + .../bwie/auth/controller/AuthController.java | 55 ++ .../com/bwie/auth/feign/UserFeignService.java | 19 + .../com/bwie/auth/service/AuthService.java | 21 + .../auth/service/impl/AuthServiceImpl.java | 87 ++ bwie-auth/src/main/resources/bootstrap.yml | 30 + bwie-common/.gitignore | 38 + bwie-common/pom.xml | 125 +++ .../com/bwie/common/config/RedisConfig.java | 40 + .../bwie/common/config/RedissonConfig.java | 33 + .../com/bwie/common/constants/Constants.java | 18 + .../bwie/common/constants/JwtConstants.java | 29 + .../common/constants/RabbitMQConstants.java | 11 + .../bwie/common/constants/RedisConstants.java | 15 + .../bwie/common/constants/TokenConstants.java | 24 + .../com/bwie/common/domain/GoodsInfo.java | 59 ++ .../java/com/bwie/common/domain/Rule.java | 29 + .../java/com/bwie/common/domain/TypeInfo.java | 15 + .../java/com/bwie/common/domain/User.java | 19 + .../common/domain/request/GoodsRequest.java | 18 + .../common/domain/request/LoginRequest.java | 15 + .../common/domain/response/JwtResponse.java | 16 + .../com/bwie/common/result/PageResult.java | 34 + .../java/com/bwie/common/result/Result.java | 76 ++ .../java/com/bwie/common/utils/FastUtil.java | 55 ++ .../java/com/bwie/common/utils/JwtUtils.java | 109 +++ .../java/com/bwie/common/utils/OssUtil.java | 153 ++++ .../com/bwie/common/utils/RedisUtils.java | 795 ++++++++++++++++++ .../com/bwie/common/utils/StringUtils.java | 68 ++ .../com/bwie/common/utils/TelSmsUtils.java | 87 ++ .../main/resources/META-INF/spring.factories | 3 + bwie-gateway/.gitignore | 38 + bwie-gateway/pom.xml | 45 + .../com/bwie/gateway/GatewayApplication.java | 17 + .../gateway/config/IgnoreWhiteConfig.java | 32 + .../com/bwie/gateway/filters/AuthFilter.java | 71 ++ .../com/bwie/gateway/utils/GatewayUtils.java | 98 +++ bwie-gateway/src/main/resources/bootstrap.yml | 29 + bwie-modules/.gitignore | 38 + bwie-modules/bwie-es/.gitignore | 38 + bwie-modules/bwie-es/pom.xml | 42 + .../main/java/com/bwie/es/EsApplication.java | 21 + .../es/config/InitEsRestHighLevelClient.java | 36 + .../com/bwie/es/controller/EsController.java | 48 ++ .../java/com/bwie/es/exception/AllError.java | 26 + .../com/bwie/es/feign/GoodsFeignService.java | 20 + .../java/com/bwie/es/service/EsService.java | 20 + .../bwie/es/service/impl/EsServiceImpl.java | 101 +++ .../main/java/com/bwie/es/sync/SyncGoods.java | 44 + .../bwie-es/src/main/resources/bootstrap.yml | 22 + bwie-modules/bwie-goods/.gitignore | 38 + bwie-modules/bwie-goods/pom.xml | 56 ++ .../java/com/bwie/goods/GoodsApplication.java | 17 + .../java/com/bwie/goods/config/InitMeda.java | 45 + .../goods/controller/GoodsController.java | 53 ++ .../bwie/goods/controller/RuleController.java | 44 + .../bwie/goods/controller/TypeController.java | 30 + .../bwie/goods/exception/GlobalException.java | 25 + .../com/bwie/goods/mapper/GoodsMapper.java | 25 + .../com/bwie/goods/mapper/RuleMapper.java | 23 + .../com/bwie/goods/mapper/TypesMapper.java | 19 + .../com/bwie/goods/service/GoodsService.java | 24 + .../com/bwie/goods/service/RuleService.java | 22 + .../com/bwie/goods/service/TypeService.java | 15 + .../goods/service/impl/GoodsServiceImpl.java | 62 ++ .../goods/service/impl/RuleServiceImpl.java | 54 ++ .../goods/service/impl/TypeServiceImpl.java | 29 + .../src/main/resources/bootstrap.yml | 41 + .../src/main/resources/mapper/GoodsMapper.xml | 15 + .../src/main/resources/mapper/RuleMapper.xml | 21 + .../src/main/resources/mapper/TypeMapper.xml | 10 + bwie-modules/bwie-user/.gitignore | 38 + bwie-modules/bwie-user/pom.xml | 55 ++ .../java/com/bwie/user/UserApplication.java | 17 + .../bwie/user/controller/UserController.java | 34 + .../java/com/bwie/user/mapper/UserMapper.java | 17 + .../com/bwie/user/service/UserService.java | 13 + .../user/service/impl/UserServiceImpl.java | 26 + .../src/main/resources/bootstrap.yml | 29 + .../src/main/resources/mapper/UserMapper.xml | 10 + bwie-modules/pom.xml | 26 + pom.xml | 69 ++ 90 files changed, 4188 insertions(+) create mode 100644 .gitignore create mode 100644 .idea/.gitignore create mode 100644 .idea/encodings.xml create mode 100644 .idea/mavenServices.xml create mode 100644 .idea/misc.xml create mode 100644 .idea/uiDesigner.xml create mode 100644 bwie-auth/.gitignore create mode 100644 bwie-auth/pom.xml create mode 100644 bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java create mode 100644 bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java create mode 100644 bwie-auth/src/main/java/com/bwie/auth/feign/UserFeignService.java create mode 100644 bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java create mode 100644 bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java create mode 100644 bwie-auth/src/main/resources/bootstrap.yml create mode 100644 bwie-common/.gitignore create mode 100644 bwie-common/pom.xml create mode 100644 bwie-common/src/main/java/com/bwie/common/config/RedisConfig.java create mode 100644 bwie-common/src/main/java/com/bwie/common/config/RedissonConfig.java create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/Constants.java create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/JwtConstants.java create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/RedisConstants.java create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/TokenConstants.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/GoodsInfo.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/Rule.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/TypeInfo.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/User.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/request/GoodsRequest.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java create mode 100644 bwie-common/src/main/java/com/bwie/common/result/PageResult.java create mode 100644 bwie-common/src/main/java/com/bwie/common/result/Result.java create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/FastUtil.java create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/JwtUtils.java create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/OssUtil.java create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/RedisUtils.java create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java create mode 100644 bwie-common/src/main/resources/META-INF/spring.factories create mode 100644 bwie-gateway/.gitignore create mode 100644 bwie-gateway/pom.xml create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java create mode 100644 bwie-gateway/src/main/resources/bootstrap.yml create mode 100644 bwie-modules/.gitignore create mode 100644 bwie-modules/bwie-es/.gitignore create mode 100644 bwie-modules/bwie-es/pom.xml create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/EsApplication.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/config/InitEsRestHighLevelClient.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/controller/EsController.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/exception/AllError.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/feign/GoodsFeignService.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/service/EsService.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/service/impl/EsServiceImpl.java create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/sync/SyncGoods.java create mode 100644 bwie-modules/bwie-es/src/main/resources/bootstrap.yml create mode 100644 bwie-modules/bwie-goods/.gitignore create mode 100644 bwie-modules/bwie-goods/pom.xml create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/GoodsApplication.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/config/InitMeda.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/GoodsController.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/RuleController.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/TypeController.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/exception/GlobalException.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/GoodsMapper.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/RuleMapper.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/TypesMapper.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/GoodsService.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/RuleService.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/TypeService.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/GoodsServiceImpl.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/RuleServiceImpl.java create mode 100644 bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/TypeServiceImpl.java create mode 100644 bwie-modules/bwie-goods/src/main/resources/bootstrap.yml create mode 100644 bwie-modules/bwie-goods/src/main/resources/mapper/GoodsMapper.xml create mode 100644 bwie-modules/bwie-goods/src/main/resources/mapper/RuleMapper.xml create mode 100644 bwie-modules/bwie-goods/src/main/resources/mapper/TypeMapper.xml create mode 100644 bwie-modules/bwie-user/.gitignore create mode 100644 bwie-modules/bwie-user/pom.xml create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/UserApplication.java create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/controller/UserController.java create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/mapper/UserMapper.java create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/service/UserService.java create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java create mode 100644 bwie-modules/bwie-user/src/main/resources/bootstrap.yml create mode 100644 bwie-modules/bwie-user/src/main/resources/mapper/UserMapper.xml create mode 100644 bwie-modules/pom.xml create mode 100644 pom.xml diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..35410ca --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,8 @@ +# 默认忽略的文件 +/shelf/ +/workspace.xml +# 基于编辑器的 HTTP 客户端请求 +/httpRequests/ +# Datasource local storage ignored files +/dataSources/ +/dataSources.local.xml diff --git a/.idea/encodings.xml b/.idea/encodings.xml new file mode 100644 index 0000000..a3d04d0 --- /dev/null +++ b/.idea/encodings.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/mavenServices.xml b/.idea/mavenServices.xml new file mode 100644 index 0000000..ace6d4b --- /dev/null +++ b/.idea/mavenServices.xml @@ -0,0 +1,9 @@ + + + + https://oss.sonatype.org/service/local/ + https://repo.jfrog.org/artifactory/api/ + https://repository.jboss.org/nexus/service/local/ + http://124.223.23.100:8081/repository/maven-public/ + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..82dbec8 --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,14 @@ + + + + + + + + + + \ No newline at end of file diff --git a/.idea/uiDesigner.xml b/.idea/uiDesigner.xml new file mode 100644 index 0000000..2b63946 --- /dev/null +++ b/.idea/uiDesigner.xml @@ -0,0 +1,124 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/bwie-auth/.gitignore b/bwie-auth/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-auth/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-auth/pom.xml b/bwie-auth/pom.xml new file mode 100644 index 0000000..812e5a8 --- /dev/null +++ b/bwie-auth/pom.xml @@ -0,0 +1,34 @@ + + + 4.0.0 + + com.bwie + zg6-month-exam-1107 + 1.0-SNAPSHOT + + + bwie-auth + + + 17 + 17 + UTF-8 + + + + + + + com.bwie + bwie-common + + + + org.springframework.boot + spring-boot-starter-web + + + + diff --git a/bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java b/bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java new file mode 100644 index 0000000..8e8ef2a --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java @@ -0,0 +1,19 @@ +package com.bwie.auth; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.openfeign.EnableFeignClients; + +/** + * @author : 李朋果 + * @ClassName : AuthApplication + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:14 + */ +@SpringBootApplication +@EnableFeignClients +public class AuthApplication { + public static void main(String[] args) { + SpringApplication.run(AuthApplication.class); + } +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java b/bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java new file mode 100644 index 0000000..df6c499 --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java @@ -0,0 +1,55 @@ +package com.bwie.auth.controller; + +import com.bwie.auth.service.AuthService; +import com.bwie.common.domain.User; +import com.bwie.common.domain.request.LoginRequest; +import com.bwie.common.domain.response.JwtResponse; +import com.bwie.common.result.Result; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author : 李朋果 + * @ClassName : AuthController + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:12 + */ +@RestController +public class AuthController { + private AuthService authService; + + public AuthController(AuthService authService) { + this.authService = authService; + } + + /** + * 根据用户名 + * @param loginRequest + * @return + */ + @PostMapping("/login") + public Result login(@RequestBody LoginRequest loginRequest) { + Result result=authService.login(loginRequest); + return result; + } + + /** + * 获取用户信息 + * @return + */ + @GetMapping("/user/info") + public Result userInfo(){ + User user = authService.userInfo(); + return Result.success(user); + } + /** + * 登出 + */ + @PostMapping("/logout") + public Result logout() { + authService.logout(); + return Result.success(); + } +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/feign/UserFeignService.java b/bwie-auth/src/main/java/com/bwie/auth/feign/UserFeignService.java new file mode 100644 index 0000000..a88602b --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/feign/UserFeignService.java @@ -0,0 +1,19 @@ +package com.bwie.auth.feign; + +import com.bwie.common.domain.User; +import com.bwie.common.result.Result; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; + +/** + * @author : 李朋果 + * @ClassName : UserFeignService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:13 + */ +@FeignClient(value = "bwie-user") +public interface UserFeignService { + @PostMapping("/findByUserName/{username}") + public Result findByUserName(@PathVariable String username); +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java b/bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java new file mode 100644 index 0000000..3e5db09 --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java @@ -0,0 +1,21 @@ +package com.bwie.auth.service; + +import com.bwie.common.domain.User; +import com.bwie.common.domain.request.LoginRequest; +import com.bwie.common.domain.response.JwtResponse; +import com.bwie.common.result.Result; + +/** + * @author : 李朋果 + * @ClassName : AuthService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:13 + */ +public interface AuthService { + User userInfo(); + + Result login(LoginRequest loginRequest); + + void logout(); + +} diff --git a/bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java b/bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java new file mode 100644 index 0000000..a16fa13 --- /dev/null +++ b/bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java @@ -0,0 +1,87 @@ +package com.bwie.auth.service.impl; + +import cn.hutool.http.server.HttpServerRequest; +import com.alibaba.fastjson.JSONObject; +import com.bwie.auth.feign.UserFeignService; +import com.bwie.auth.service.AuthService; +import com.bwie.common.constants.JwtConstants; +import com.bwie.common.constants.TokenConstants; +import com.bwie.common.domain.User; +import com.bwie.common.domain.request.LoginRequest; +import com.bwie.common.domain.response.JwtResponse; +import com.bwie.common.result.Result; +import com.bwie.common.utils.JwtUtils; +import com.bwie.common.utils.StringUtils; +import org.springframework.data.redis.core.StringRedisTemplate; +import org.springframework.stereotype.Service; + +import javax.servlet.http.HttpServlet; +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.UUID; +import java.util.concurrent.TimeUnit; + +/** + * @author : 李朋果 + * @ClassName : AuthServiceImpl + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:13 + */ +@Service +public class AuthServiceImpl implements AuthService { + private UserFeignService userFeignService; + private StringRedisTemplate stringRedisTemplate; + private HttpServletRequest request; + + public AuthServiceImpl(UserFeignService userFeignService, StringRedisTemplate stringRedisTemplate, HttpServletRequest request) { + this.userFeignService = userFeignService; + this.stringRedisTemplate = stringRedisTemplate; + this.request = request; + } + + + + + @Override + public Result login(LoginRequest loginRequest) { + if (StringUtils.isAllBlank(loginRequest.getUsername(),loginRequest.getPassword())) { + return Result.error("用户名或密码不正确"); + } + Result byUserName = userFeignService.findByUserName(loginRequest.getUsername()); + User loginUser = byUserName.getData(); + if (null == loginUser) { + return Result.error("用户名不存在"); + } + + if (!loginRequest.getPassword().equals(loginUser.getPassword())) { + return Result.error("密码不正确"); + } + + //登录成功 + String userKey = UUID.randomUUID().toString().replaceAll("-", ""); + HashMap claims = new HashMap<>(); + claims.put(JwtConstants.USER_KEY,userKey); + String token = JwtUtils.createToken(claims); + //存用户信息 loginUser + stringRedisTemplate.opsForValue().set(TokenConstants.LOGIN_TOKEN_KEY+userKey, JSONObject.toJSONString(loginUser),30, TimeUnit.MINUTES); + //返回数据 + JwtResponse jwtResponse = new JwtResponse(); + jwtResponse.setToken(token); + jwtResponse.setExpireTime("30MIN"); + + return Result.success(jwtResponse); + } + @Override + public User userInfo() { + String token = request.getHeader(TokenConstants.TOKEN); + String userKey = JwtUtils.getUserKey(token); + String s = stringRedisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey); + return JSONObject.parseObject(s,User.class); + } + @Override + public void logout() { + String token = request.getHeader(TokenConstants.TOKEN); + String userKey = JwtUtils.getUserKey(token); + stringRedisTemplate.delete(TokenConstants.LOGIN_TOKEN_KEY + userKey); + } +} diff --git a/bwie-auth/src/main/resources/bootstrap.yml b/bwie-auth/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..91b928c --- /dev/null +++ b/bwie-auth/src/main/resources/bootstrap.yml @@ -0,0 +1,30 @@ +# Tomcat +server: + port: 9001 +# Spring +spring: + main: + allow-circular-references: true + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + application: + # 应用名称 + name: bwie-auth + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 124.223.23.100:8848 + config: + # 配置中心地址 + server-addr: 124.223.23.100:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} + diff --git a/bwie-common/.gitignore b/bwie-common/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-common/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-common/pom.xml b/bwie-common/pom.xml new file mode 100644 index 0000000..de76eb3 --- /dev/null +++ b/bwie-common/pom.xml @@ -0,0 +1,125 @@ + + + 4.0.0 + + com.bwie + zg6-month-exam-1107 + 1.0-SNAPSHOT + + + bwie-common + + + 17 + 17 + UTF-8 + + + + + + + org.springframework.cloud + spring-cloud-starter-bootstrap + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-sentinel + + + + org.springframework.cloud + spring-cloud-starter-loadbalancer + + + + org.springframework.cloud + spring-cloud-starter-openfeign + + + + io.jsonwebtoken + jjwt + 0.9.1 + + + + com.alibaba + fastjson + 1.2.80 + + + + org.springframework.boot + spring-boot-starter-data-redis + + + + org.springframework.boot + spring-boot-starter-validation + + + + org.apache.commons + commons-lang3 + + + + org.projectlombok + lombok + + + + cn.hutool + hutool-all + 5.8.3 + + + + com.aliyun + dysmsapi20170525 + 2.0.1 + + + + com.aliyun.oss + aliyun-sdk-oss + 3.12.0 + + + + org.springframework.boot + spring-boot-starter-amqp + + + + com.github.tobato + fastdfs-client + 1.26.5 + + + + org.redisson + redisson + 3.16.0 + + + + diff --git a/bwie-common/src/main/java/com/bwie/common/config/RedisConfig.java b/bwie-common/src/main/java/com/bwie/common/config/RedisConfig.java new file mode 100644 index 0000000..b62e4b1 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/config/RedisConfig.java @@ -0,0 +1,40 @@ +package com.bwie.common.config; + +import com.fasterxml.jackson.annotation.JsonAutoDetect; +import com.fasterxml.jackson.annotation.PropertyAccessor; +import com.fasterxml.jackson.databind.ObjectMapper; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.data.redis.connection.RedisConnectionFactory; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; +import org.springframework.data.redis.serializer.StringRedisSerializer; + +@Configuration +public class RedisConfig { + + @Bean + public RedisTemplate redisTemplate(RedisConnectionFactory factory) { + RedisTemplate template = new RedisTemplate<>(); + template.setConnectionFactory(factory); + Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new + Jackson2JsonRedisSerializer(Object.class); + ObjectMapper om = new ObjectMapper(); + om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); + om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); + jackson2JsonRedisSerializer.setObjectMapper(om); + + StringRedisSerializer stringRedisSerializer = new StringRedisSerializer(); + // key采用String的序列化方式 + template.setKeySerializer(stringRedisSerializer); + // hash的key也采用String的序列化方式 + template.setHashKeySerializer(stringRedisSerializer); + // value序列化方式采用jackson + template.setValueSerializer(jackson2JsonRedisSerializer); + // hash的value序列化方式采用jackson + template.setHashValueSerializer(jackson2JsonRedisSerializer); + template.afterPropertiesSet(); + + return template; + } +} diff --git a/bwie-common/src/main/java/com/bwie/common/config/RedissonConfig.java b/bwie-common/src/main/java/com/bwie/common/config/RedissonConfig.java new file mode 100644 index 0000000..548e164 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/config/RedissonConfig.java @@ -0,0 +1,33 @@ +package com.bwie.common.config; + +import org.redisson.Redisson; +import org.redisson.api.RedissonClient; +import org.redisson.config.Config; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.io.IOException; + +/** + * @BelongsProject: demo02 + * @BelongsPackage: com.bw.config + * @Author: zhupengfei + * @CreateTime: 2022-12-24 09:26 + */ + +@Configuration +public class RedissonConfig { + + @Bean(destroyMethod="shutdown") // 服务停止后调用 shutdown 方法。 + public RedissonClient redisson() throws IOException { + System.out.println("配置类初始加载......"); + // 1.创建配置 + Config config = new Config(); + // 集群模式 + // config.useClusterServers().addNodeAddress("127.0.0.1:6379", "127.0.0.1:6378"); + // 2.根据 Config 创建出 RedissonClient 实例。 + config.useSingleServer().setAddress("redis://8.130.43.65:6379"); + return Redisson.create(config); + } + +} diff --git a/bwie-common/src/main/java/com/bwie/common/constants/Constants.java b/bwie-common/src/main/java/com/bwie/common/constants/Constants.java new file mode 100644 index 0000000..2fdc9fe --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/constants/Constants.java @@ -0,0 +1,18 @@ +package com.bwie.common.constants; + +/** + * @description: 系统常量 + * @author DongZl + */ +public class Constants { + /** + * 成功标记 + */ + public static final Integer SUCCESS = 200; + public static final String SUCCESS_MSG = "操作成功"; + /** + * 失败标记 + */ + public static final Integer ERROR = 500; + public static final String ERROR_MSG = "操作异常"; +} diff --git a/bwie-common/src/main/java/com/bwie/common/constants/JwtConstants.java b/bwie-common/src/main/java/com/bwie/common/constants/JwtConstants.java new file mode 100644 index 0000000..03692c1 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/constants/JwtConstants.java @@ -0,0 +1,29 @@ +package com.bwie.common.constants; + +/** + * @author DongZl + * @description: Jwt常量 + */ +public class JwtConstants { + + /** + * 用户ID字段 + */ + public static final String DETAILS_USER_ID = "user_id"; + + /** + * 用户名字段 + */ + public static final String DETAILS_USERNAME = "username"; + + /** + * 用户标识 + */ + public static final String USER_KEY = "user_key"; + + /** + * 令牌秘钥 + */ + public final static String SECRET = "abcdefghijklmnopqrstuvwxyz"; + +} diff --git a/bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java b/bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java new file mode 100644 index 0000000..e442e68 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java @@ -0,0 +1,11 @@ +package com.bwie.common.constants; + +/** + * @author : 李朋果 + * @ClassName : RabbitMQConstants + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 16:41 + */ +public class RabbitMQConstants { + +} diff --git a/bwie-common/src/main/java/com/bwie/common/constants/RedisConstants.java b/bwie-common/src/main/java/com/bwie/common/constants/RedisConstants.java new file mode 100644 index 0000000..e424c39 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/constants/RedisConstants.java @@ -0,0 +1,15 @@ +package com.bwie.common.constants; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : RedisConstants + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 16:41 + */ + +public class RedisConstants { + + public static final String REDIS_KEY="redis_key"; +} diff --git a/bwie-common/src/main/java/com/bwie/common/constants/TokenConstants.java b/bwie-common/src/main/java/com/bwie/common/constants/TokenConstants.java new file mode 100644 index 0000000..1871fb7 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/constants/TokenConstants.java @@ -0,0 +1,24 @@ +package com.bwie.common.constants; + +/** + * @author DongZl + * @description: 令牌常量 + */ +public class TokenConstants { + /** + * 缓存有效期，默认720（分钟） + */ + public final static long EXPIRATION = 720; + /** + * 缓存刷新时间，默认120（分钟） + */ + public final static long REFRESH_TIME = 120; + /** + * 权限缓存前缀 + */ + public final static String LOGIN_TOKEN_KEY = "login_tokens:"; + /** + * token标识 + */ + public static final String TOKEN = "token"; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/GoodsInfo.java b/bwie-common/src/main/java/com/bwie/common/domain/GoodsInfo.java new file mode 100644 index 0000000..90dc9bd --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/GoodsInfo.java @@ -0,0 +1,59 @@ +package com.bwie.common.domain; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : GoodsInfo + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 10:24 + */ +@Data +public class GoodsInfo { + /** + * 编号 + */ + private Long id; + /** + *商品名称 + */ + private String goodsName; + /** + *商品类别 + */ + private String goodsType; + /** + * 商品图片 + */ + private String goodsPic; + /** + * 商品简介 + */ + private String goodsDetails; + /** + *商品价格 + */ + private Double goodsPrice; + /** + * 砍价规则 + */ + private Integer bargainRuleId; + /** + * 成功砍价数量 + */ + private Integer successNum; + /** + * 正在砍价数量 + */ + private Integer beInNum; + /** + * 参与客户数量 + */ + private Integer joinClientNum; + /** + * 商品状态 + */ + private Integer goodsStatus; + + +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/Rule.java b/bwie-common/src/main/java/com/bwie/common/domain/Rule.java new file mode 100644 index 0000000..b1c03fe --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/Rule.java @@ -0,0 +1,29 @@ +package com.bwie.common.domain; + +import lombok.Data; + +import javax.validation.constraints.NotEmpty; + +/** + * @author : 李朋果 + * @ClassName : Rule + * @description : 规则信息 + * @createTime : 2023/11/7 14:01 + */ +@Data +public class Rule { + /** + * + */ + private Long id; + @NotEmpty(message = "砍价规则名称不能为空") + private String ruleName; + private Integer typeId; + private Integer startNum; + private Integer endNum; + private Double startRadius; + private Double endRadius; + + private String typeName; + +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/TypeInfo.java b/bwie-common/src/main/java/com/bwie/common/domain/TypeInfo.java new file mode 100644 index 0000000..12d941d --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/TypeInfo.java @@ -0,0 +1,15 @@ +package com.bwie.common.domain; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : TypeInfo + * @description : 砍价类型信息 + * @createTime : 2023/11/7 16:33 + */ +@Data +public class TypeInfo { + private Long id; + private String typeName; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/User.java b/bwie-common/src/main/java/com/bwie/common/domain/User.java new file mode 100644 index 0000000..d27c7cb --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/User.java @@ -0,0 +1,19 @@ +package com.bwie.common.domain; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : User + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:14 + */ +@Data +public class User { + private Integer userId; + private String username; + private String password; + private String name; + private String phone; + private String role; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/request/GoodsRequest.java b/bwie-common/src/main/java/com/bwie/common/domain/request/GoodsRequest.java new file mode 100644 index 0000000..82751a4 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/request/GoodsRequest.java @@ -0,0 +1,18 @@ +package com.bwie.common.domain.request; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : GoodsRequest + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 10:58 + */ +@Data +public class GoodsRequest { + private Integer pageNum=1; + private Integer pageSize=10; + + private String goodsName; + private String goodsType; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java b/bwie-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java new file mode 100644 index 0000000..e590429 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java @@ -0,0 +1,15 @@ +package com.bwie.common.domain.request; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : LoginRequest + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:16 + */ +@Data +public class LoginRequest { + private String username; + private String password; +} diff --git a/bwie-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java b/bwie-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java new file mode 100644 index 0000000..b91c1fb --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java @@ -0,0 +1,16 @@ +package com.bwie.common.domain.response; + +import lombok.Data; + +/** + * @author : 李朋果 + * @ClassName : JwtResponse + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:16 + */ +@Data +public class JwtResponse { + private String token; + private String expireTime; +} + diff --git a/bwie-common/src/main/java/com/bwie/common/result/PageResult.java b/bwie-common/src/main/java/com/bwie/common/result/PageResult.java new file mode 100644 index 0000000..85ecdda --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/result/PageResult.java @@ -0,0 +1,34 @@ +package com.bwie.common.result; + +import lombok.Data; + +import java.io.Serializable; +import java.util.List; + +/** + * @author DongZl + * @description: 列表返回结果集 + */ +@Data +public class PageResult implements Serializable { + /** + * 总条数 + */ + private long total; + /** + * 结果集合 + */ + private List list; + public PageResult() { + } + public PageResult(long total, List list) { + this.total = total; + this.list = list; + } + public static PageResult toPageResult(long total, List list){ + return new PageResult(total , list); + } + public static Result> toResult(long total, List list){ + return Result.success(PageResult.toPageResult(total,list)); + } +} diff --git a/bwie-common/src/main/java/com/bwie/common/result/Result.java b/bwie-common/src/main/java/com/bwie/common/result/Result.java new file mode 100644 index 0000000..30b1e73 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/result/Result.java @@ -0,0 +1,76 @@ +package com.bwie.common.result; + +import com.bwie.common.constants.Constants; +import lombok.Data; + +import java.io.Serializable; + +/** + * @author DongZl + * @description: 响应信息主体 + */ +@Data +public class Result implements Serializable { + + private static final long serialVersionUID = 1L; + /** + * 成功 + */ + public static final int SUCCESS = Constants.SUCCESS; + /** + * 失败 + */ + public static final int FAIL = Constants.ERROR; + /** + * 返回状态码 + */ + private int code; + /** + * 响应信息 + */ + private String msg; + /** + * 响应数据 + */ + private T data; + + public static Result success() { + return restResult(null, SUCCESS, Constants.SUCCESS_MSG); + } + + public static Result success(T data) { + return restResult(data, SUCCESS, Constants.SUCCESS_MSG); + } + + public static Result success(T data, String msg) { + return restResult(data, SUCCESS, msg); + } + + public static Result error() { + return restResult(null, FAIL, Constants.ERROR_MSG); + } + + public static Result error(String msg) { + return restResult(null, FAIL, msg); + } + + public static Result error(T data) { + return restResult(data, FAIL, Constants.ERROR_MSG); + } + + public static Result error(T data, String msg) { + return restResult(data, FAIL, msg); + } + + public static Result error(int code, String msg) { + return restResult(null, code, msg); + } + + private static Result restResult(T data, int code, String msg) { + Result apiResult = new Result<>(); + apiResult.setCode(code); + apiResult.setData(data); + apiResult.setMsg(msg); + return apiResult; + } +} diff --git a/bwie-common/src/main/java/com/bwie/common/utils/FastUtil.java b/bwie-common/src/main/java/com/bwie/common/utils/FastUtil.java new file mode 100644 index 0000000..94b1722 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/utils/FastUtil.java @@ -0,0 +1,55 @@ +package com.bwie.common.utils; + +import org.springframework.stereotype.Component; +import com.github.tobato.fastdfs.domain.fdfs.StorePath; +import com.github.tobato.fastdfs.service.FastFileStorageClient; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.util.StringUtils; +import org.springframework.web.multipart.MultipartFile; + +import javax.annotation.Resource; + +/** + * @BelongsProject: 0107day02 + * @BelongsPackage: com.bw.config + * @Author: zhupengfei + * @CreateTime: 2023-02-01 08:52 + */ +@Component +public class FastUtil { + private static final Logger log = LoggerFactory.getLogger(FastUtil.class); + + @Resource + private FastFileStorageClient storageClient ; + + /** + * 上传文件 + */ + public String upload(MultipartFile multipartFile) throws Exception{ + String originalFilename = multipartFile.getOriginalFilename(). + substring(multipartFile.getOriginalFilename(). + lastIndexOf(".") + 1); + StorePath storePath = this.storageClient.uploadImageAndCrtThumbImage( + multipartFile.getInputStream(), + multipartFile.getSize(),originalFilename , null); + return storePath.getFullPath() ; + } + /** + * 删除文件 + */ + public String deleteFile(String fileUrl) { + if (StringUtils.isEmpty(fileUrl)) { + log.info("fileUrl == >>文件路径为空..."); + return "文件路径不能为空"; + } + try { + StorePath storePath = StorePath.parseFromUrl(fileUrl); + storageClient.deleteFile(storePath.getGroup(), storePath.getPath()); + } catch (Exception e) { + log.error(e.getMessage()); + } + return "删除成功"; + } + +} diff --git a/bwie-common/src/main/java/com/bwie/common/utils/JwtUtils.java b/bwie-common/src/main/java/com/bwie/common/utils/JwtUtils.java new file mode 100644 index 0000000..f560aa9 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/utils/JwtUtils.java @@ -0,0 +1,109 @@ +package com.bwie.common.utils; + +import com.bwie.common.constants.JwtConstants; +import io.jsonwebtoken.Claims; +import io.jsonwebtoken.Jwts; +import io.jsonwebtoken.SignatureAlgorithm; + +import java.util.Map; + +/** + * @description: Jwt工具类 + * @author DongZl + */ +public class JwtUtils { + + /** + * 秘钥 + */ + public static String secret = JwtConstants.SECRET; + + /** + * 从数据声明生成令牌 + * + * @param claims 数据声明 + * @return 令牌 + */ + public static String createToken(Map claims){ + String token = Jwts.builder().setClaims(claims).signWith(SignatureAlgorithm.HS512, secret).compact(); + return token; + } + + /** + * 从令牌中获取数据声明 + * + * @param token 令牌 + * @return 数据声明 + */ + public static Claims parseToken(String token){ + return Jwts.parser().setSigningKey(secret).parseClaimsJws(token).getBody(); + } + /** + * 根据令牌获取用户标识 + * + * @param token 令牌 + * @return 用户ID + */ + public static String getUserKey(String token){ + Claims claims = parseToken(token); + return getValue(claims, JwtConstants.USER_KEY); + } + /** + * 根据令牌获取用户标识 + * + * @param claims 身份信息 + * @return 用户ID + */ + public static String getUserKey(Claims claims){ + return getValue(claims, JwtConstants.USER_KEY); + } + /** + * 根据令牌获取用户ID + * + * @param token 令牌 + * @return 用户ID + */ + public static String getUserId(String token){ + Claims claims = parseToken(token); + return getValue(claims, JwtConstants.DETAILS_USER_ID); + } + /** + * 根据身份信息获取用户ID + * + * @param claims 身份信息 + * @return 用户ID + */ + public static String getUserId(Claims claims){ + return getValue(claims, JwtConstants.DETAILS_USER_ID); + } + /** + * 根据令牌获取用户名 + * + * @param token 令牌 + * @return 用户名 + */ + public static String getUserName(String token){ + Claims claims = parseToken(token); + return getValue(claims, JwtConstants.DETAILS_USERNAME); + } + /** + * 根据身份信息获取用户名 + * + * @param claims 身份信息 + * @return 用户名 + */ + public static String getUserName(Claims claims){ + return getValue(claims, JwtConstants.DETAILS_USERNAME); + } + /** + * 根据身份信息获取键值 + * + * @param claims 身份信息 + * @param key 键 + * @return 值 + */ + public static String getValue(Claims claims, String key){ + Object obj = claims.get(key); + return obj == null ? "" : obj.toString(); + } +} diff --git a/bwie-common/src/main/java/com/bwie/common/utils/OssUtil.java b/bwie-common/src/main/java/com/bwie/common/utils/OssUtil.java new file mode 100644 index 0000000..9c1383f --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/utils/OssUtil.java @@ -0,0 +1,153 @@ +package com.bwie.common.utils; + +import com.aliyun.oss.OSS; +import com.aliyun.oss.OSSClientBuilder; +import com.aliyun.oss.model.GetObjectRequest; +import com.aliyun.oss.model.PutObjectRequest; +import lombok.extern.log4j.Log4j2; +import org.springframework.web.multipart.MultipartFile; + +import java.io.*; +import java.time.LocalDateTime; +import java.util.UUID; + +/** + * Oss服务调用 + */ +@Log4j2 +public class OssUtil { + + /** + * Endpoint 存储对象概述 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限 访问路径前缀 存储对象概述 + */ + private static String endPoint = "oss-cn-shanghai.aliyuncs.com"; + private static String accessKeyId = "LTAI5tD2tppzLQ4Rb6yKYyph"; + private static String accessKeySecret = "KEKNKwVvDq7PZLjE63NPBouqHXox4Q"; + private static String accessPre = "https://dzlmuyu.oss-cn-shanghai.aliyuncs.com/"; + + /** + * bucket名称 + * @return + */ + private static String bucketName = "dzlmuyu"; + + private static OSS ossClient ; + + static { + ossClient = new OSSClientBuilder().build( + endPoint, + accessKeyId, + accessKeySecret); + log.info("oss服务连接成功！"); + } + + /** + * 默认路径上传本地文件 + * @param filePath + */ + public static String uploadFile(String filePath){ + return uploadFileForBucket(bucketName,getOssFilePath(filePath) ,filePath); + } + + /** + * 默认路径上传multipartFile文件 + * @param multipartFile + */ + public static String uploadMultipartFile(MultipartFile multipartFile) { + return uploadMultipartFile(bucketName,getOssFilePath(multipartFile.getOriginalFilename()),multipartFile); + } + /** + * 上传 multipartFile 类型文件 + * @param bucketName + * @param ossPath + * @param multipartFile + */ + public static String uploadMultipartFile(String bucketName , String ossPath , MultipartFile multipartFile){ + InputStream inputStream = null; + try { + inputStream = multipartFile.getInputStream(); + } catch (IOException e) { + e.printStackTrace(); + } + uploadFileInputStreamForBucket(bucketName, ossPath, inputStream); + return accessPre+ossPath; + } + + /** + * 使用File上传PutObject上传文件 ** 程序默认使用次方法上传 + * @param bucketName 实例名称 + * @param ossPath oss存储路径 + * @param filePath 本地文件路径 + */ + public static String uploadFileForBucket(String bucketName , String ossPath , String filePath) { + // 创建PutObjectRequest对象。 + PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, ossPath, new File(filePath)); + + // 上传 + ossClient.putObject(putObjectRequest); + return accessPre+ossPath; + } + + /** + * 使用文件流上传到指定的bucket实例 + * @param bucketName 实例名称 + * @param ossPath oss存储路径 + * @param filePath 本地文件路径 + */ + public static String uploadFileInputStreamForBucket(String bucketName , String ossPath , String filePath){ + + // 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。 + InputStream inputStream = null; + try { + inputStream = new FileInputStream(filePath); + } catch (FileNotFoundException e) { + e.printStackTrace(); + } + // 填写Bucket名称和Object完整路径。Object完整路径中不能包含Bucket名称。 + uploadFileInputStreamForBucket(bucketName, ossPath, inputStream); + return accessPre+ossPath; + } + + public static void uploadFileInputStreamForBucket(String bucketName , String ossPath , InputStream inputStream ){ + ossClient.putObject(bucketName, ossPath, inputStream); + } + + /** + * 下载 + * @param ossFilePath + * @param filePath + */ + public static void downloadFile(String ossFilePath , String filePath ){ + downloadFileForBucket(bucketName , ossFilePath , filePath); + } + /** + * 下载 + * @param bucketName 实例名称 + * @param ossFilePath oss存储路径 + * @param filePath 本地文件路径 + */ + public static void downloadFileForBucket(String bucketName , String ossFilePath , String filePath ){ + ossClient.getObject(new GetObjectRequest(bucketName, ossFilePath), new File(filePath)); + } + + /** + * + * @return + */ + public static String getOssDefaultPath(){ + LocalDateTime now = LocalDateTime.now(); + String url = + now.getYear()+"/"+ + now.getMonth()+"/"+ + now.getDayOfMonth()+"/"+ + now.getHour()+"/"+ + now.getMinute()+"/"; + return url; + } + + public static String getOssFilePath(String filePath){ + String fileSuf = filePath.substring(filePath.indexOf(".") + 1); + return getOssDefaultPath() + UUID.randomUUID().toString() + "." + fileSuf; + } + +} diff --git a/bwie-common/src/main/java/com/bwie/common/utils/RedisUtils.java b/bwie-common/src/main/java/com/bwie/common/utils/RedisUtils.java new file mode 100644 index 0000000..dd26d90 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/utils/RedisUtils.java @@ -0,0 +1,795 @@ +//package com.bwie.common.utils; +// +//import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.C; +//import com.bwie.common.constants.MyConstant; +//import com.bwie.common.utils.StringUtils; +//import io.jsonwebtoken.lang.Collections; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.beans.factory.annotation.Qualifier; +//import org.springframework.data.redis.core.RedisTemplate; +//import org.springframework.stereotype.Component; +// +//import java.util.Collection; +//import java.util.List; +//import java.util.Map; +//import java.util.Set; +//import java.util.concurrent.TimeUnit; +// +///** +// * @author : 李朋果 +// * @ClassName : Redis +// * @description : redis工具类 +// * @createTime : 2023/10/31 20:34 +// */ +//@Component +//public class RedisUtils { +// public String itemCode = MyConstant.ITEM_CODE+"_"; +// +// +// @Autowired +// @Qualifier("redisTemplate") +// private RedisTemplate redisTemplate; +// +// /** +// * 指定缓存失效时间 +// * @param key 键 +// * @param time 时间(秒) +// * @return +// */ +// public boolean expire(String key, long time) { +// try { +// if (time > 0) { +// redisTemplate.expire(key, time, TimeUnit.SECONDS); +// } +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 根据key获取过期时间 +// * @param key 键 不能为null +// * @return 时间(秒) 返回0代表为永久有效 +// */ +// public long getExpire(String key) { +// return redisTemplate.getExpire(key, TimeUnit.SECONDS); +// } +// +// /** +// * 判断key 是否存在 +// * @param key 键 +// * @return true 存在 false 不存在 +// */ +// public boolean hasKey(String key) { +// try { +// return redisTemplate.hasKey(key); +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 删除缓存 +// * @param key 可以传一个值或多个 +// */ +// public void del(String... key){ +// if (key != null && key.length > 0) { +// if (key.length == 1) { +// redisTemplate.delete(key[0]); +// } else { +// redisTemplate.delete((Collection) Collections.arrayToList(key)); +// } +// } +// +// } +// +// public void del(Set keySet) { +// redisTemplate.delete(keySet); +// } +// +// /** +// * 删除全部缓存 +// */ +// public void deleteAll(){ +// Set keys = redisTemplate.keys("*"); +// redisTemplate.delete(keys); +// } +// +// /** +// * 前缀 +// * 模糊查询key +// * redis中模糊匹配key值 +// * @param key 键 +// * @return 值 +// */ +// public Set fuzzyQueryKeysStart(String key) { +// Set keys = redisTemplate.keys(key+"*"); +// return keys; +// } +// +// /** +// * 模糊查询key +// * redis中模糊匹配key值 +// * @param key 键 +// * @return 值 +// */ +// public Set fuzzyQueryKeys(String key) { +// Set keys = redisTemplate.keys("*"+key+"*"); +// return keys; +// } +// +// /** +// * 后缀 +// * 模糊查询key +// * redis中模糊匹配key值 +// * @param key 键 +// * @return 值 +// */ +// public Set fuzzyQueryKeysEnd(String key) { +// Set keys = redisTemplate.keys("*"+key); +// return keys; +// } +// +// /** +// * 普通缓存获取 +// * @param key 键 +// * @return 值 +// */ +// public Object get(String key) { +// return key == null ? null : redisTemplate.opsForValue().get(key); +// } +// +// /** +// * 普通缓存放入 +// * @param key 键 +// * @param value 值 +// * @return true成功 false失败 +// */ +// public boolean set(String key, Object value) { +// try { +// redisTemplate.opsForValue().set(key, value); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 普通缓存放并设置时间 +// * @param key 键 +// * @param value 值 +// * @param time 时间(秒) time要大于0 如果time小于等于0将设置无限期 +// * @return true成功 false失败 +// */ +// public boolean set(String key, Object value, long time) { +// try { +// if (time > 0) { +// redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS); +// } +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 递增 +// * @param key 键 +// * @param delta 要增加几 +// * @return +// */ +// public Long incr(String key, long delta) { +// if (delta < 0) { +// throw new IllegalArgumentException("递增因子必须大于0"); +// } +// return redisTemplate.opsForValue().increment(key, delta); +// } +// +// /** +// * 递减 +// * @param key 键 +// * @param delta 要减少几 +// * @return +// */ +// public Long decr(String key, long delta) { +// if (delta < 0) { +// throw new IllegalArgumentException("递减因子必须大于0"); +// } +// return redisTemplate.opsForValue().increment(key, -delta); +// } +// +// /** +// * HashGet +// * +// * @param key 键 不能为null +// * @param item 项 不能为null +// * @return 值 +// */ +// public Object hget(String key, String item) { +// return redisTemplate.opsForHash().get(key, item); +// } +// +// /** +// * 获取hashKey对应的所有键值 +// * +// * @param key 键 +// * @return 对应的多个键值 +// */ +// public Map hmget(String key) { +// return redisTemplate.opsForHash().entries(key); +// } +// +// /** +// * HashSet +// * +// * @param key 键 +// * @param map 对应多个键值 +// * @return true成功 false失败 +// */ +// public boolean hmset(String key, Map map) { +// try { +// redisTemplate.opsForHash().putAll(key, map); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * HashSet并设置时间 +// * +// * @param key 键 +// * @param map 对应多个键值 +// * @param time 时间(秒) +// * @return true成功 false失败 +// */ +// public boolean hmset(String key, Map map, long time) { +// try { +// redisTemplate.opsForHash().putAll(key, map); +// if (time > 0) { +// expire(key, time); +// } +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 向一张hash表中放入数据,如果不存在将创建 +// * +// * @param key 键 +// * @param item 项 +// * @param value 值 +// * @return true成功 false失败 +// */ +// public boolean hset(String key, String item, Object value) { +// try { +// redisTemplate.opsForHash().put(key, item, value); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 向一张hash表中放入数据,如果不存在将创建 +// * +// * @param key 键 +// * @param item 项 +// * @param value 值 +// * @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间 +// * @return true成功 false失败 +// */ +// public boolean hset(String key, String item, Object value, long time) { +// try { +// redisTemplate.opsForHash().put(key, item, value); +// if (time > 0) { +// expire(key, time); +// } +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 删除hash表中的值 +// * +// * @param key 键 不能为null +// * @param item 项 可以使多个 不能为null +// */ +// public void hdel(String key, Object... item) { +// redisTemplate.opsForHash().delete(key, item); +// } +// +// /** +// * 判断hash表中是否有该项的值 +// * +// * @param key 键 不能为null +// * @param item 项 不能为null +// * @return true存在 false不存在 +// */ +// public boolean hHasKey(String key, String item) { +// return redisTemplate.opsForHash().hasKey(key, item); +// } +// +// /** +// * hash递增 如果不存在,就会创建一个 并把新增后的值返回 +// * +// * @param key 键 +// * @param item 项 +// * @param by 要增加几 +// * @return +// */ +// public double hincr(String key, String item, long by) { +// return redisTemplate.opsForHash().increment(key, item, by); +// } +// +// /** +// * hash递减 +// * +// * @param key 键 +// * @param item 项 +// * @param by 要减少几 +// * @return +// */ +// public double hdecr(String key, String item, long by) { +// return redisTemplate.opsForHash().increment(key, item, -by); +// } +// +// /** +// * 根据key获取Set中的所有值 +// * +// * @param key 键 +// * @return +// */ +// public Set sGet(String key) { +// try { +// return redisTemplate.opsForSet().members(key); +// } catch (Exception e) { +// e.printStackTrace(); +// return null; +// } +// } +// +// /** +// * 根据value从一个set中查询,是否存在 +// * +// * @param key 键 +// * @param value 值 +// * @return true存在 false不存在 +// */ +// public boolean sHasKey(String key, Object value) { +// try { +// return redisTemplate.opsForSet().isMember(key, value); +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 将数据放入set缓存 +// * +// * @param key 键 +// * @param values 值 可以是多个 +// * @return 成功个数 +// */ +// public long sSet(String key, Object... values) { +// try { +// return redisTemplate.opsForSet().add(key, values); +// } catch (Exception e) { +// e.printStackTrace(); +// return 0; +// } +// } +// +// /** +// * 将set数据放入缓存 +// * +// * @param key 键 +// * @param time 时间(秒) +// * @param values 值 可以是多个 +// * @return 成功个数 +// */ +// public long sSetAndTime(String key, long time, Object... values) { +// try { +// Long count = redisTemplate.opsForSet().add(key, values); +// if (time > 0) { +// expire(key, time); +// } +// return count; +// } catch (Exception e) { +// e.printStackTrace(); +// return 0; +// } +// } +// +// /** +// * 获取set缓存的长度 +// * +// * @param key 键 +// * @return +// */ +// public long sGetSetSize(String key) { +// try { +// return redisTemplate.opsForSet().size(key); +// } catch (Exception e) { +// e.printStackTrace(); +// return 0; +// } +// } +// +// /** +// * 移除值为value的 +// * +// * @param key 键 +// * @param values 值 可以是多个 +// * @return 移除的个数 +// */ +// public long setRemove(String key, Object... values) { +// try { +// Long count = redisTemplate.opsForSet().remove(key, values); +// return count; +// } catch (Exception e) { +// e.printStackTrace(); +// return 0; +// } +// } +// +// /** +// * 获取list缓存的内容 +// * +// * @param key 键 +// * @param start 开始 +// * @param end 结束 0到-1代表所有值 +// * @return +// */ +// public List lGet(String key, long start, long end) { +// try { +// return redisTemplate.opsForList().range(key, start, end); +// } catch (Exception e) { +// e.printStackTrace(); +// return null; +// } +// } +// +// /** +// * 获取list缓存的长度 +// * +// * @param key 键 +// * @return +// */ +// public long lGetListSize(String key) { +// try { +// return redisTemplate.opsForList().size(key); +// } catch (Exception e) { +// e.printStackTrace(); +// return 0; +// } +// } +// +// /** +// * 通过索引 获取list中的值 +// * +// * @param key 键 +// * @param index 索引 index>=0时，0表头，1第二个元素，依次类推；index<0时，-1表尾，-2倒数第二个元素，依次类推 +// * @return +// */ +// public Object lGetIndex(String key, long index) { +// try { +// return redisTemplate.opsForList().index(key, index); +// } catch (Exception e) { +// e.printStackTrace(); +// return null; +// } +// } +// +// /** +// * 将list放入缓存 +// * +// * @param key 键 +// * @param value 值 +// * @return +// */ +// public boolean lSet(String key, Object value) { +// try { +// redisTemplate.opsForList().rightPush(key, value); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 将list放入缓存 +// * +// * @param key 键 +// * @param value 值 +// * @param time 时间(秒) +// * @return +// */ +// public boolean lSet(String key, Object value, long time) { +// try { +// redisTemplate.opsForList().rightPush(key, value); +// if (time > 0) { +// expire(key, time); +// } +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 将list放入缓存 +// * +// * @param key 键 +// * @param value 值 +// * @return +// */ +// public boolean lSet(String key, List value) { +// try { +// redisTemplate.opsForList().rightPushAll(key, value); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 将list放入缓存 +// * +// * @param key 键 +// * @param value 值 +// * @param time 时间(秒) +// * @return +// */ +// public boolean lSet(String key, List value, long time) { +// try { +// redisTemplate.opsForList().rightPushAll(key, value); +// if (time > 0) { +// expire(key, time); +// } +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 根据索引修改list中的某条数据 +// * +// * @param key 键 +// * @param index 索引 +// * @param value 值 +// * @return +// */ +// public boolean lUpdateIndex(String key, long index, Object value) { +// try { +// redisTemplate.opsForList().set(key, index, value); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * zset放入缓存 +// * +// * @param key 键 +// * @param index 索引 +// * @param score 分数 +// * @return +// */ +// public boolean setZset(String key, String index, double score) { +// try { +// redisTemplate.opsForZSet().add(key, index, score); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * zset添加分数 +// * +// * @param key 键 +// * @param index 索引 +// * @param score 分数 +// * @return +// */ +// public boolean addScore(String key, String index, double score) { +// try { +// redisTemplate.opsForZSet().incrementScore(key, index, score); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// +// /** +// * zset修改，覆盖 +// * +// * @param key 键 +// * @param id 索引 +// * @param score 分数 +// * @return +// */ +// public boolean updateScore(String key, int id, double score) { +// try { +// redisTemplate.opsForZSet().add(key, id, score); +// return true; +// } catch (Exception e) { +// e.printStackTrace(); +// return false; +// } +// } +// +// /** +// * 获取排行榜 +// * +// * @param key 键 +// * @param top 获取前几名 +// * @return +// */ +// public Set getZsetTop(String key, int top) { +// Set set = null; +// try { +// set = redisTemplate.opsForZSet().reverseRange(key, 0, top - 1); +// return set; +// } catch (Exception e) { +// e.printStackTrace(); +// return set; +// } +// } +// +// /** +// * 根据分数获取排行榜前几 +// * +// * @param key 键 +// * @param top 获取前几名 +// * @return +// */ +// public Set getTopWithScore(String key, int top) { +// Set set = null; +// try { +// set = redisTemplate.opsForZSet().reverseRangeWithScores(key, 0, top - 1); +// return set; +// } catch (Exception e) { +// e.printStackTrace(); +// return set; +// } +// } +// +// +// /** +// * 移除N个值为value +// * +// * @param key 键 +// * @param count 移除多少个 +// * @param value 值 +// * @return 移除的个数 +// */ +// public long lRemove(String key, long count, Object value) { +// try { +// Long remove = redisTemplate.opsForList().remove(key, count, value); +// return remove; +// } catch (Exception e) { +// e.printStackTrace(); +// return 0; +// } +// } +// +// /** +// * 获取锁 +// * +// * @param key 键 +// * @param timeout 超时时间，例：5（秒） +// * @param count 重试次数 +// * @param sleepTime 重试睡眠时间，例：500（毫秒） +// * @return time，获取锁失败时为 null +// */ +// public String getLock(String key, Long timeout, Integer count, Long sleepTime) { +// String time = null; +// boolean isLock = false; +// // 重试 +// for (int i = 0; i < count; i++) { +// // 超时时间 +// time = String.valueOf(System.currentTimeMillis() + 1000L * timeout); +// // 获取锁 +// isLock = lock(key, time); +// if (isLock) { +// break; +// } else { +// if (i != (count - 1)) { +// try { +// // 睡眠 +// Thread.sleep(sleepTime); +// } catch (InterruptedException e) { +// e.printStackTrace(); +// } +// } +// } +// } +// // 失败 +// if (!isLock) { +// return null; +// } +// return time; +// } +// +// /** +// * 加锁 +// * +// * @param key 键 +// * @param time 当前时间+超时时间，如：超时时间为10秒，String.valueOf(System.currentTimeMillis() + 1000L * 10) +// * @return +// */ +// public boolean lock(String key, String time) { +// // 这个其实就是setnx命令，只不过在java这边稍有变化，返回的是boolean +// if (redisTemplate.opsForValue().setIfAbsent(key, time)) { +// return true; +// } +// // 避免死锁，且只让一个线程拿到锁 +// String currentValue = (String) redisTemplate.opsForValue().get(key); +// // 如果锁过期了 +// if (!StringUtils.isEmpty(currentValue) && Long.parseLong(currentValue) < System.currentTimeMillis()) { +// // 获取上一个锁的时间 +// String oldValues = (String) redisTemplate.opsForValue().getAndSet(key, time); +// +// // 只会让一个线程拿到锁 +// // 如果旧的value和currentValue相等，只会有一个线程达成条件，因为第二个线程拿到的oldValue已经和currentValue不一样了 +// if (!StringUtils.isEmpty(oldValues) && oldValues.equals(currentValue)) { +// return true; +// } +// } +// return false; +// } +// +// /** +// * 解锁 +// * +// * @param key 键 +// * @param time 同加锁时传的值，不变 +// */ +// public void unlock(String key, String time) { +// try { +// String currentValue = (String) redisTemplate.opsForValue().get(key); +// if (!StringUtils.isEmpty(currentValue) && currentValue.equals(time)) { +// redisTemplate.opsForValue().getOperations().delete(key); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// +// +// +// +// +// +// +// +// +// +// +//} diff --git a/bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java b/bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java new file mode 100644 index 0000000..93c47fd --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java @@ -0,0 +1,68 @@ +package com.bwie.common.utils; + +import org.springframework.util.AntPathMatcher; + +import java.util.Collection; +import java.util.List; + +/** + * @author DongZl + * @description: 字符串处理工具类 + */ +public class StringUtils extends org.apache.commons.lang3.StringUtils { + + /** + * * 判断一个对象是否为空 + * + * @param object Object + * @return true：为空 false：非空 + */ + public static boolean isNull(Object object) { + return object == null; + } + + /** + * * 判断一个Collection是否为空， 包含List，Set，Queue + * + * @param coll 要判断的Collection + * @return true：为空 false：非空 + */ + public static boolean isEmpty(Collection coll) { + return isNull(coll) || coll.isEmpty(); + } + + /** + * 查找指定字符串是否匹配指定字符串列表中的任意一个字符串 + * + * @param str 指定字符串 + * @param strs 需要检查的字符串数组 + * @return 是否匹配 + */ + public static boolean matches(String str, List strs) { + if (isEmpty(str) || isEmpty(strs)) { + return false; + } + for (String pattern : strs) { + if (isMatch(pattern, str)) + { + return true; + } + } + return false; + } + + /** + * 判断url是否与规则配置: + * ? 表示单个字符; + * * 表示一层路径内的任意字符串，不可跨层级; + * ** 表示任意层路径; + * + * @param pattern 匹配规则 + * @param url 需要匹配的url + * @return + */ + public static boolean isMatch(String pattern, String url) { + AntPathMatcher matcher = new AntPathMatcher(); + return matcher.match(pattern, url); + } +} diff --git a/bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java b/bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java new file mode 100644 index 0000000..a91c807 --- /dev/null +++ b/bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java @@ -0,0 +1,87 @@ +package com.bwie.common.utils; + +import com.alibaba.fastjson.JSONObject; +import com.aliyun.dysmsapi20170525.Client; +import com.aliyun.dysmsapi20170525.models.SendSmsRequest; +import com.aliyun.dysmsapi20170525.models.SendSmsResponse; +import com.aliyun.teaopenapi.models.Config; +import lombok.extern.log4j.Log4j2; + +import java.util.Map; + +/** + * 短信工具类 + */ +@Log4j2 +public class TelSmsUtils { + + /** + * 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限 + */ + private static String accessKeyId = "LTAI5tLAy4cHBn7sEdVXoYsq"; + private static String accessKeySecret = "hcjHkIkuzcmRNCm8IB1YWVdmJJS4zx"; + + /** + * 短信访问域名 + */ + private static String endpoint = "dysmsapi.aliyuncs.com"; + /** + * 短信签名 + */ + private static String signName = "登录验证"; + + /** + * 实例化短信对象 + */ + private static Client client; + + static { + log.info("初始化短信服务开始"); + long startTime = System.currentTimeMillis(); + try { + client = initClient(); + log.info("初始化短信成功：{}",signName); + } catch (Exception e) { + e.printStackTrace(); + } + log.info("初始化短信服务结束：耗时：{}MS",(System.currentTimeMillis()-startTime)); + } + /** + * 初始化短信对象 + * @return + * @throws Exception + */ + private static Client initClient() throws Exception{ + Config config = new Config() + // 您的AccessKey ID + .setAccessKeyId(accessKeyId) + // 您的AccessKey Secret + .setAccessKeySecret(accessKeySecret); + // 访问的域名 + config.endpoint = endpoint; + return new Client(config); + } + + /** + * 发送单条短信 + * @param tel + * @param templateCode SMS_153991546 + * @param sendDataMap + */ + public static String sendSms(String tel , String templateCode , Map sendDataMap){ + SendSmsRequest sendSmsRequest = new SendSmsRequest() + .setPhoneNumbers(tel) + .setSignName(signName) + .setTemplateCode(templateCode) + .setTemplateParam(JSONObject.toJSONString(sendDataMap)); + SendSmsResponse sendSmsResponse = null; + try { + log.info("发送短信验证码：消息内容是：【{}】", JSONObject.toJSONString(sendDataMap)); + sendSmsResponse = client.sendSms(sendSmsRequest); + } catch (Exception e) { + log.error("短信发送异常，手机号：【{}】，短信内容：【{}】，异常信息：【{}】", tel, sendDataMap, e); + } + return JSONObject.toJSONString(sendSmsResponse.getBody()); + } + +} diff --git a/bwie-common/src/main/resources/META-INF/spring.factories b/bwie-common/src/main/resources/META-INF/spring.factories new file mode 100644 index 0000000..95ec018 --- /dev/null +++ b/bwie-common/src/main/resources/META-INF/spring.factories @@ -0,0 +1,3 @@ +org.springframework.boot.autoconfigure.EnableAutoConfiguration = \ + com.bwie.common.config.RedisConfig,\ + com.bwie.common.utils.FastUtil \ No newline at end of file diff --git a/bwie-gateway/.gitignore b/bwie-gateway/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-gateway/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-gateway/pom.xml b/bwie-gateway/pom.xml new file mode 100644 index 0000000..9478b83 --- /dev/null +++ b/bwie-gateway/pom.xml @@ -0,0 +1,45 @@ + + + 4.0.0 + + com.bwie + zg6-month-exam-1107 + 1.0-SNAPSHOT + + + bwie-gateway + + + 17 + 17 + UTF-8 + + + + + + + com.bwie + bwie-common + + + + + org.springframework.cloud + spring-cloud-starter-gateway + + + + com.alibaba.cloud + spring-cloud-alibaba-sentinel-gateway + + + + com.alibaba.csp + sentinel-spring-cloud-gateway-adapter + + + + diff --git a/bwie-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java b/bwie-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java new file mode 100644 index 0000000..2a2e960 --- /dev/null +++ b/bwie-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java @@ -0,0 +1,17 @@ +package com.bwie.gateway; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @author : 李朋果 + * @ClassName : GatewayApplication + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:30 + */ +@SpringBootApplication +public class GatewayApplication { + public static void main(String[] args) { + SpringApplication.run(GatewayApplication.class); + } +} diff --git a/bwie-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java b/bwie-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java new file mode 100644 index 0000000..5705d6f --- /dev/null +++ b/bwie-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java @@ -0,0 +1,32 @@ +package com.bwie.gateway.config; + +import com.alibaba.fastjson.JSONObject; +import lombok.Data; +import lombok.extern.log4j.Log4j2; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.context.annotation.Configuration; + +import java.util.ArrayList; +import java.util.List; + +/** + * @description: 放行白名单配置 + * @author DongZl + */ +@Configuration +@RefreshScope +@ConfigurationProperties(prefix = "ignore") +@Data +@Log4j2 +public class IgnoreWhiteConfig { + /** + * 放行白名单配置，网关不校验此处的白名单 + */ + private List whites = new ArrayList<>(); + + public void setWhites(List whites) { + log.info("加载网关路径白名单:{}", JSONObject.toJSONString(whites)); + this.whites = whites; + } +} diff --git a/bwie-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java b/bwie-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java new file mode 100644 index 0000000..d11f724 --- /dev/null +++ b/bwie-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java @@ -0,0 +1,71 @@ +package com.bwie.gateway.filters; + +import com.bwie.common.constants.TokenConstants; +import com.bwie.common.utils.JwtUtils; +import com.bwie.common.utils.StringUtils; +import com.bwie.gateway.config.IgnoreWhiteConfig; +import com.bwie.gateway.utils.GatewayUtils; +import lombok.extern.log4j.Log4j2; +import org.springframework.cloud.gateway.filter.GatewayFilterChain; +import org.springframework.cloud.gateway.filter.GlobalFilter; +import org.springframework.core.Ordered; +import org.springframework.data.redis.core.StringRedisTemplate; +import org.springframework.http.HttpStatus; +import org.springframework.http.server.reactive.ServerHttpRequest; +import org.springframework.web.server.ServerWebExchange; +import reactor.core.publisher.Mono; + +import java.util.List; +import java.util.concurrent.TimeUnit; + +/** + * @author : 李朋果 + * @ClassName : AuthFilter + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:48 + */ +@Log4j2 +public class AuthFilter implements GlobalFilter, Ordered { + private IgnoreWhiteConfig ignoreWhiteConfig; + private StringRedisTemplate stringRedisTemplate; + + public AuthFilter(IgnoreWhiteConfig ignoreWhiteConfig, StringRedisTemplate stringRedisTemplate) { + this.ignoreWhiteConfig = ignoreWhiteConfig; + this.stringRedisTemplate = stringRedisTemplate; + } + + @Override + public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) { + List whites = ignoreWhiteConfig.getWhites(); + ServerHttpRequest request = exchange.getRequest(); + String path = request.getURI().getPath(); + if (StringUtils.matches(path,whites)) { + return chain.filter(exchange); + } + //token非空 + String token = request.getHeaders().getFirst(TokenConstants.TOKEN); + if (StringUtils.isEmpty(token)) { + return GatewayUtils.errorResponse(exchange,"token不能为空", HttpStatus.UNAUTHORIZED); + } + + try { + JwtUtils.parseToken(token); + } catch (Exception e) { + return GatewayUtils.errorResponse(exchange,"token不合法"); + } + + String userKey = JwtUtils.getUserKey(token); + Boolean hasKey = stringRedisTemplate.hasKey(TokenConstants.LOGIN_TOKEN_KEY + userKey); + if (!hasKey) { + return GatewayUtils.errorResponse(exchange,"token过期"); + } + stringRedisTemplate.expire(TokenConstants.LOGIN_TOKEN_KEY+userKey,30, TimeUnit.MINUTES); + log.info("续期成功"); + return chain.filter(exchange); + } + + @Override + public int getOrder() { + return 0; + } +} diff --git a/bwie-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java b/bwie-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java new file mode 100644 index 0000000..7b789e5 --- /dev/null +++ b/bwie-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java @@ -0,0 +1,98 @@ +package com.bwie.gateway.utils; + +import com.alibaba.fastjson.JSONObject; +import com.bwie.common.result.Result; +import com.bwie.common.utils.StringUtils; +import lombok.extern.log4j.Log4j2; +import org.springframework.core.io.buffer.DataBuffer; +import org.springframework.http.HttpHeaders; +import org.springframework.http.HttpStatus; +import org.springframework.http.server.reactive.ServerHttpRequest; +import org.springframework.http.server.reactive.ServerHttpResponse; +import org.springframework.web.server.ServerWebExchange; +import reactor.core.publisher.Mono; + +/** + * @author DongZl + * @description: 网关处理工具类 + */ +@Log4j2 +public class GatewayUtils { + /** + * 添加请求头参数 + * @param mutate 修改对象 + * @param key 键 + * @param value 值 + */ + public static void addHeader(ServerHttpRequest.Builder mutate, String key, Object value) { + if (StringUtils.isEmpty(key)){ + log.warn("添加请求头参数键不可以为空"); + return; + } + if (value == null) { + log.warn("添加请求头参数：[{}]值为空",key); + return; + } + String valueStr = value.toString(); + mutate.header(key, valueStr); + log.info("添加请求头参数成功 - 键:[{}] , 值:[{}]", key , value); + } + + /** + * 删除请求头参数 + * @param mutate 修改对象 + * @param key 键 + */ + public static void removeHeader(ServerHttpRequest.Builder mutate, String key) { + if (StringUtils.isEmpty(key)){ + log.warn("删除请求头参数键不可以为空"); + return; + } + mutate.headers(httpHeaders -> httpHeaders.remove(key)).build(); + log.info("删除请求头参数 - 键:[{}]",key); + } + + /** + * 错误结果响应 + * @param exchange 响应上下文 + * @param msg 响应消息 + * @return + */ + public static Mono errorResponse(ServerWebExchange exchange, String msg, HttpStatus httpStatus) { + ServerHttpResponse response = exchange.getResponse(); + //设置HTTP响应头状态 + response.setStatusCode(httpStatus); + //设置HTTP响应头文本格式 + response.getHeaders().add(HttpHeaders.CONTENT_TYPE, "application/json"); + //定义响应内容 + Result result = Result.error(msg); + String resultJson = JSONObject.toJSONString(result); + log.error("[鉴权异常处理]请求路径:[{}]，异常信息：[{}]，响应结果：[{}]", exchange.getRequest().getPath(), msg, resultJson); + DataBuffer dataBuffer = response.bufferFactory().wrap(resultJson.getBytes()); + //进行响应 + return response.writeWith(Mono.just(dataBuffer)); + } + + /** + * 错误结果响应 + * @param exchange 响应上下文 + * @param msg 响应消息 + * @return + */ + public static Mono errorResponse(ServerWebExchange exchange, String msg) { + ServerHttpResponse response = exchange.getResponse(); + //设置HTTP响应头状态 + response.setStatusCode(HttpStatus.OK); + //设置HTTP响应头文本格式 + response.getHeaders().add(HttpHeaders.CONTENT_TYPE, "application/json"); + //定义响应内容 + Result result = Result.error(msg); + String resultJson = JSONObject.toJSONString(result); + log.error("[鉴权异常处理]请求路径:[{}]，异常信息：[{}]，响应结果：[{}]", exchange.getRequest().getPath(), msg, resultJson); + DataBuffer dataBuffer = response.bufferFactory().wrap(resultJson.getBytes()); + //进行响应 + return response.writeWith(Mono.just(dataBuffer)); + } + + +} diff --git a/bwie-gateway/src/main/resources/bootstrap.yml b/bwie-gateway/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..e8b0822 --- /dev/null +++ b/bwie-gateway/src/main/resources/bootstrap.yml @@ -0,0 +1,29 @@ +# Tomcat +server: + port: 18080 +# Spring +spring: + application: + # 应用名称 + name: bwie-gateway + profiles: + # 环境配置 + active: dev + main: + # 允许使用循环引用 + allow-circular-references: true + # 允许定义相同的bean对象 去覆盖原有的 + allow-bean-definition-overriding: true + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 124.223.23.100:8848 + config: + # 配置中心地址 + server-addr: 124.223.23.100:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bwie-modules/.gitignore b/bwie-modules/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-modules/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-modules/bwie-es/.gitignore b/bwie-modules/bwie-es/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-modules/bwie-es/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-modules/bwie-es/pom.xml b/bwie-modules/bwie-es/pom.xml new file mode 100644 index 0000000..7c05e44 --- /dev/null +++ b/bwie-modules/bwie-es/pom.xml @@ -0,0 +1,42 @@ + + + 4.0.0 + + com.bwie + bwie-modules + 1.0-SNAPSHOT + + + bwie-es + + + 17 + 17 + UTF-8 + + + + com.bwie + bwie-common + + + org.springframework.boot + spring-boot-starter-web + + + org.elasticsearch.client + elasticsearch-rest-high-level-client + + + + + org.springframework.boot + spring-boot-starter-test + test + + + + + diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/EsApplication.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/EsApplication.java new file mode 100644 index 0000000..dd6f17c --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/EsApplication.java @@ -0,0 +1,21 @@ +package com.bwie.es; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.openfeign.EnableFeignClients; +import org.springframework.scheduling.annotation.EnableScheduling; + +/** + * @author : 李朋果 + * @ClassName : EsApplication + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:30 + */ +@SpringBootApplication +@EnableFeignClients +@EnableScheduling +public class EsApplication { + public static void main(String[] args) { + SpringApplication.run(EsApplication.class); + } +} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/config/InitEsRestHighLevelClient.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/config/InitEsRestHighLevelClient.java new file mode 100644 index 0000000..0fcc04a --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/config/InitEsRestHighLevelClient.java @@ -0,0 +1,36 @@ +package com.bwie.es.config; + +import lombok.Data; +import lombok.extern.log4j.Log4j2; +import org.apache.http.HttpHost; +import org.elasticsearch.client.RestClient; +import org.elasticsearch.client.RestClientBuilder; +import org.elasticsearch.client.RestHighLevelClient; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @BelongsProject: day20k-6.12 + * @BelongsPackage: com.bwie.es.conifg + * @Author: LiFan + * @CreateTime: 2023-06-12 14:33 + * @Description: //TODO + * @Version: 1.0 + */ +@Configuration +@ConfigurationProperties(prefix = "es") +@Data +@Log4j2 +public class InitEsRestHighLevelClient { + private String host; + private Integer port; + private String scheme; + + @Bean + public RestHighLevelClient RestHighLevelClient() { + return new RestHighLevelClient( + RestClient.builder(new HttpHost(host,port,scheme)) + ); + } +} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/controller/EsController.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/controller/EsController.java new file mode 100644 index 0000000..235f420 --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/controller/EsController.java @@ -0,0 +1,48 @@ +package com.bwie.es.controller; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.domain.request.GoodsRequest; +import com.bwie.common.result.PageResult; +import com.bwie.common.result.Result; +import com.bwie.es.service.EsService; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : EsController + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 10:42 + */ +@RestController +public class EsController { + private EsService esService; + + + public EsController(EsService esService) { + this.esService = esService; + } + + /** + * es查询 + * @param goodsRequest 请求 + * @return + */ + @PostMapping("/search") + public Result> search(@RequestBody GoodsRequest goodsRequest) { + Result> result=esService.search(goodsRequest); + return result; + } + + @PostMapping("/batchAdd") + public Result batchAdd(@RequestBody List goodsInfos) { + esService.batchAdd(goodsInfos); + return Result.success(); + } + + + +} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/exception/AllError.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/exception/AllError.java new file mode 100644 index 0000000..e2be4c3 --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/exception/AllError.java @@ -0,0 +1,26 @@ +//package com.bwie.es.exception; +// +//import com.bwie.common.result.Result; +//import lombok.extern.log4j.Log4j2; +//import org.springframework.web.bind.annotation.ExceptionHandler; +//import org.springframework.web.bind.annotation.RestControllerAdvice; +// +//import javax.servlet.http.HttpServletRequest; +// +///** +// * @author : 李朋果 +// * @ClassName : AllException +// * @description : 描述说明该类的功能 +// * @createTime : 2023/11/7 10:43 +// */ +//@RestControllerAdvice +//@Log4j2 +//public class AllError { +// +// +// @ExceptionHandler(Exception.class) +// public Result AllException(HttpServletRequest request, Throwable throwable) { +// +// return Result.error(null,"系统异常"); +// } +//} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/feign/GoodsFeignService.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/feign/GoodsFeignService.java new file mode 100644 index 0000000..0feb3f5 --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/feign/GoodsFeignService.java @@ -0,0 +1,20 @@ +package com.bwie.es.feign; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.result.Result; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.GetMapping; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : GoodsFeignService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 11:18 + */ +@FeignClient(value = "bwie-goods") +public interface GoodsFeignService { + @GetMapping("/list") + public Result> list(); +} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/service/EsService.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/service/EsService.java new file mode 100644 index 0000000..5edb959 --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/service/EsService.java @@ -0,0 +1,20 @@ +package com.bwie.es.service; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.domain.request.GoodsRequest; +import com.bwie.common.result.PageResult; +import com.bwie.common.result.Result; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : EsService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 10:50 + */ +public interface EsService { + Result> search(GoodsRequest goodsRequest); + + void batchAdd(List goodsInfos); +} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/service/impl/EsServiceImpl.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/service/impl/EsServiceImpl.java new file mode 100644 index 0000000..a55a0cf --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/service/impl/EsServiceImpl.java @@ -0,0 +1,101 @@ +package com.bwie.es.service.impl; + +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.serializer.SimplePropertyPreFilter; +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.domain.request.GoodsRequest; +import com.bwie.common.result.PageResult; +import com.bwie.common.result.Result; +import com.bwie.common.utils.StringUtils; +import com.bwie.es.service.EsService; +import org.elasticsearch.action.bulk.BulkRequest; +import org.elasticsearch.action.index.IndexRequest; +import org.elasticsearch.action.search.SearchRequest; +import org.elasticsearch.action.search.SearchResponse; +import org.elasticsearch.client.RequestOptions; +import org.elasticsearch.client.RestHighLevelClient; +import org.elasticsearch.common.xcontent.XContentType; +import org.elasticsearch.index.query.BoolQueryBuilder; +import org.elasticsearch.index.query.QueryBuilders; +import org.elasticsearch.search.SearchHit; +import org.elasticsearch.search.SearchHits; +import org.elasticsearch.search.builder.SearchSourceBuilder; +import org.springframework.stereotype.Service; + +import java.util.ArrayList; +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : EsServiceImpl + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 10:50 + */ +@Service +public class EsServiceImpl implements EsService { + private static final String INDEX_NAME="goods"; + private RestHighLevelClient restHighLevelClient; + + public EsServiceImpl(RestHighLevelClient restHighLevelClient) { + this.restHighLevelClient = restHighLevelClient; + } + + @Override + public Result> search(GoodsRequest goodsRequest) { + List goodsInfos = new ArrayList<>(); + long total = 0; + try { + SearchRequest searchRequest = new SearchRequest(INDEX_NAME); + SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); + BoolQueryBuilder boolQuery = QueryBuilders.boolQuery(); + + if (StringUtils.isNotEmpty(goodsRequest.getGoodsName())) { + boolQuery.must(QueryBuilders.matchQuery("goodsName",goodsRequest.getGoodsName())); + } + if (StringUtils.isNotEmpty(goodsRequest.getGoodsType())) { + boolQuery.must(QueryBuilders.matchQuery("goodsType",goodsRequest.getGoodsType())); + } + searchSourceBuilder.query(boolQuery); + + searchSourceBuilder.from((goodsRequest.getPageNum()-1) * goodsRequest.getPageSize()); + searchSourceBuilder.size(goodsRequest.getPageSize()); + + searchRequest.source(searchSourceBuilder); + + SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT); + + SearchHits searchHits = searchResponse.getHits(); + total=searchHits.getTotalHits().value; + SearchHit[] hits = searchHits.getHits(); + for (SearchHit hit : hits) { + String sourceAsString = hit.getSourceAsString(); + GoodsInfo goodsInfo = JSONObject.parseObject(sourceAsString, GoodsInfo.class); + goodsInfo.setId(Long.valueOf(hit.getId())); + goodsInfos.add(goodsInfo); + } + + + } catch (Exception e) { + e.printStackTrace(); + } + return PageResult.toResult(total,goodsInfos); + } + + @Override + public void batchAdd(List goodsInfos) { + try { + BulkRequest bulkRequest = new BulkRequest(); + SimplePropertyPreFilter filter = new SimplePropertyPreFilter(); + filter.getExcludes().add("id"); + goodsInfos.forEach(item->{ + bulkRequest.add(new IndexRequest(INDEX_NAME) + .id(item.getId()+"") + .source((JSONObject.toJSONString(item,filter)), XContentType.JSON)); + }); + restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT); + + } catch (Exception e) { + e.printStackTrace(); + } + } +} diff --git a/bwie-modules/bwie-es/src/main/java/com/bwie/es/sync/SyncGoods.java b/bwie-modules/bwie-es/src/main/java/com/bwie/es/sync/SyncGoods.java new file mode 100644 index 0000000..9d05bf0 --- /dev/null +++ b/bwie-modules/bwie-es/src/main/java/com/bwie/es/sync/SyncGoods.java @@ -0,0 +1,44 @@ +package com.bwie.es.sync; + +import cn.hutool.core.collection.CollectionUtil; +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.result.Result; +import com.bwie.es.feign.GoodsFeignService; +import com.bwie.es.service.EsService; +import lombok.extern.log4j.Log4j2; +import org.springframework.context.annotation.Bean; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : SyncGoods + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 10:52 + */ +@Component +@Log4j2 +public class SyncGoods { + + private EsService esService; + private GoodsFeignService goodsFeignService; + + public SyncGoods(EsService esService, GoodsFeignService goodsFeignService) { + this.esService = esService; + this.goodsFeignService = goodsFeignService; + } + + @Scheduled(cron = "0/30 * * * * ?" ) + public void syncGoods() { + Result> list = goodsFeignService.list(); + List data = list.getData(); + if (!CollectionUtil.isEmpty(data)) { + log.info("开始同步,数量是{}",data.size()); + long s = System.currentTimeMillis(); + esService.batchAdd(data); + log.info("完成同步,耗时:{}毫秒",System.currentTimeMillis()-s); + } + } +} diff --git a/bwie-modules/bwie-es/src/main/resources/bootstrap.yml b/bwie-modules/bwie-es/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..601c68a --- /dev/null +++ b/bwie-modules/bwie-es/src/main/resources/bootstrap.yml @@ -0,0 +1,22 @@ +server: + port: 9006 +spring: + main: + allow-circular-references: true + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + application: + name: bwie-es + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + serverAddr: 124.223.23.100:8848 + config: + serverAddr: 124.223.23.100:8848 + fileExtension: yml + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bwie-modules/bwie-goods/.gitignore b/bwie-modules/bwie-goods/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-modules/bwie-goods/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-modules/bwie-goods/pom.xml b/bwie-modules/bwie-goods/pom.xml new file mode 100644 index 0000000..ab14f53 --- /dev/null +++ b/bwie-modules/bwie-goods/pom.xml @@ -0,0 +1,56 @@ + + + 4.0.0 + + com.bwie + bwie-modules + 1.0-SNAPSHOT + + + bwie-goods + + + 17 + 17 + UTF-8 + + + + + + com.bwie + bwie-common + + + + org.springframework.boot + spring-boot-starter-web + + + + com.alibaba + druid-spring-boot-starter + 1.2.8 + + + + mysql + mysql-connector-java + + + + org.mybatis.spring.boot + mybatis-spring-boot-starter + 2.2.2 + + + + com.github.pagehelper + pagehelper-spring-boot-starter + 1.4.1 + + + + diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/GoodsApplication.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/GoodsApplication.java new file mode 100644 index 0000000..decee5c --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/GoodsApplication.java @@ -0,0 +1,17 @@ +package com.bwie.goods; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @author : 李朋果 + * @ClassName : UserApplication + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:28 + */ +@SpringBootApplication +public class GoodsApplication { + public static void main(String[] args) { + SpringApplication.run(GoodsApplication.class); + } +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/config/InitMeda.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/config/InitMeda.java new file mode 100644 index 0000000..326cce4 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/config/InitMeda.java @@ -0,0 +1,45 @@ +package com.bwie.goods.config; + +import com.alibaba.fastjson.JSONObject; +import com.bwie.common.constants.RedisConstants; +import com.bwie.common.domain.TypeInfo; +import com.bwie.goods.mapper.TypesMapper; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.data.redis.core.StringRedisTemplate; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : RedisMeda + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 14:13 + */ +@Configuration +public class InitMeda { + /** + * 注入redis + */ + @Resource + private StringRedisTemplate stringRedisTemplate; + /** + * 注入持久层 + */ + @Resource + private TypesMapper typesMapper; + + @Bean + public void syncTypeRedis() { + //获取类型数据 + List list = typesMapper.list(); + list.forEach(item->{ + stringRedisTemplate.opsForList().rightPush(RedisConstants.REDIS_KEY, JSONObject.toJSONString(item)); + }); + + } + + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/GoodsController.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/GoodsController.java new file mode 100644 index 0000000..4187cda --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/GoodsController.java @@ -0,0 +1,53 @@ +package com.bwie.goods.controller; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.domain.User; +import com.bwie.common.result.Result; +import com.bwie.goods.service.GoodsService; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : UserController + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:17 + */ +@RestController +public class GoodsController { + private GoodsService goodsService; + + public GoodsController(GoodsService goodsService) { + this.goodsService = goodsService; + } + + /** + * 查询商品的所有数据 + * @return + */ + @GetMapping("/list") + public Result> list() { + List list=goodsService.list(); + return Result.success(list); + } + + @GetMapping("/upload") + public Result upload(@RequestParam("file")MultipartFile file){ + Result result = goodsService.upload(file); + return result; + } + + @PostMapping("/add") + @Transactional + public Result add(@RequestBody GoodsInfo goodsInfo) { + Result result = goodsService.add(goodsInfo); + return result; + } + + + + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/RuleController.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/RuleController.java new file mode 100644 index 0000000..60996f6 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/RuleController.java @@ -0,0 +1,44 @@ +package com.bwie.goods.controller; + +import com.bwie.common.domain.Rule; +import com.bwie.common.result.Result; +import com.bwie.goods.service.RuleService; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +import javax.validation.Valid; +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : RuleController + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 14:06 + */ +@RestController +public class RuleController { + private RuleService ruleService; + + public RuleController(RuleService ruleService) { + this.ruleService = ruleService; + } + + @GetMapping("/ruleList") + public Result> ruleList() { + List rules= ruleService.ruleList(); + return Result.success(rules); + } + + @PostMapping("/addRule") + public Result addRule(@RequestBody @Valid Rule rule) { + Result result=ruleService.addRule(rule); + return result; + } + + +} + + diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/TypeController.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/TypeController.java new file mode 100644 index 0000000..fa02644 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/controller/TypeController.java @@ -0,0 +1,30 @@ +package com.bwie.goods.controller; + +import com.bwie.common.domain.TypeInfo; +import com.bwie.common.result.Result; +import com.bwie.goods.service.TypeService; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : TypeController + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 14:12 + */ +@RestController +public class TypeController { + private TypeService typeService; + + public TypeController(TypeService typeService) { + this.typeService = typeService; + } + + @PostMapping("/typeList") + public Result> typeList() { + List typeInfos =typeService.typeList(); + return Result.success(typeInfos); + } +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/exception/GlobalException.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/exception/GlobalException.java new file mode 100644 index 0000000..99d780a --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/exception/GlobalException.java @@ -0,0 +1,25 @@ +//package com.bwie.goods.exception; +// +//import com.bwie.common.result.Result; +//import lombok.extern.log4j.Log4j2; +//import org.springframework.web.bind.annotation.ExceptionHandler; +//import org.springframework.web.bind.annotation.RestControllerAdvice; +// +//import javax.servlet.http.HttpServletRequest; +// +///** +// * @author : 李朋果 +// * @ClassName : GlobalException +// * @description : 全局异常 +// * @createTime : 2023/11/7 16:51 +// */ +//@RestControllerAdvice +//@Log4j2 +//public class GlobalException { +// @ExceptionHandler(Exception.class) +// public Result AllException(HttpServletRequest request, Throwable throwable) { +// String methodName = throwable.getStackTrace()[0].getMethodName(); +// log.info("路径:{},方法:{}",request.getRequestURI(),methodName); +// return Result.error(null,"系统异常"); +// } +//} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/GoodsMapper.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/GoodsMapper.java new file mode 100644 index 0000000..ba1d8cb --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/GoodsMapper.java @@ -0,0 +1,25 @@ +package com.bwie.goods.mapper; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.domain.User; +import com.bwie.common.result.Result; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : UserMapper + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:18 + */ +@Mapper +public interface GoodsMapper { + + + List list(); + + + int add(GoodsInfo goodsInfo); + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/RuleMapper.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/RuleMapper.java new file mode 100644 index 0000000..86b0e1d --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/RuleMapper.java @@ -0,0 +1,23 @@ +package com.bwie.goods.mapper; + +import com.bwie.common.domain.Rule; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : RuleMapper + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 14:07 + */ +@Mapper +public interface RuleMapper { + + List ruleList(); + + + + int addRule(Rule rule); + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/TypesMapper.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/TypesMapper.java new file mode 100644 index 0000000..b39bd53 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/mapper/TypesMapper.java @@ -0,0 +1,19 @@ +package com.bwie.goods.mapper; + +import com.bwie.common.domain.TypeInfo; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : TypesMapper + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 16:32 + */ +@Mapper +public interface TypesMapper { + + List list(); + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/GoodsService.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/GoodsService.java new file mode 100644 index 0000000..f0e1908 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/GoodsService.java @@ -0,0 +1,24 @@ +package com.bwie.goods.service; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.domain.User; +import com.bwie.common.result.Result; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : UserService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:18 + */ +public interface GoodsService { + + List list(); + + + Result upload(MultipartFile file); + + Result add(GoodsInfo goodsInfo); +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/RuleService.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/RuleService.java new file mode 100644 index 0000000..9465b04 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/RuleService.java @@ -0,0 +1,22 @@ +package com.bwie.goods.service; + +import com.bwie.common.domain.Rule; +import com.bwie.common.result.Result; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : RuleService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 14:07 + */ + +public interface RuleService { + List ruleList(); + + + Result addRule(Rule rule); + + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/TypeService.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/TypeService.java new file mode 100644 index 0000000..e61e4c4 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/TypeService.java @@ -0,0 +1,15 @@ +package com.bwie.goods.service; + +import com.bwie.common.domain.TypeInfo; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : TypeService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 16:30 + */ +public interface TypeService { + List typeList(); +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/GoodsServiceImpl.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/GoodsServiceImpl.java new file mode 100644 index 0000000..634d3f3 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/GoodsServiceImpl.java @@ -0,0 +1,62 @@ +package com.bwie.goods.service.impl; + +import com.bwie.common.domain.GoodsInfo; +import com.bwie.common.result.Result; +import com.bwie.common.utils.FastUtil; +import com.bwie.goods.mapper.GoodsMapper; +import com.bwie.goods.service.GoodsService; + +import org.springframework.stereotype.Service; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : UserServiceImpl + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:18 + */ +@Service +public class GoodsServiceImpl implements GoodsService { + private GoodsMapper goodsMapper; + private FastUtil fastUtil; + + public GoodsServiceImpl(GoodsMapper goodsMapper, FastUtil fastUtil) { + this.goodsMapper = goodsMapper; + this.fastUtil = fastUtil; + } + + @Override + public List list() { + return goodsMapper.list(); + } + + @Override + public Result upload(MultipartFile file) { + String upload=null; + try { + upload=fastUtil.upload(file); + if (upload==null) { + return Result.error("上传失败"); + } + } catch (Exception e) { + e.printStackTrace(); + } + + return Result.success("http://124.223.23.100:8888/"+upload,"上传成功"); + } + + @Override + + public Result add(GoodsInfo goodsInfo) { + goodsInfo.setSuccessNum(0); + goodsInfo.setBeInNum(0); + goodsInfo.setGoodsStatus(0); + goodsInfo.setJoinClientNum(0); + int i= goodsMapper.add(goodsInfo); + System.out.println(i); + + return Result.success(i>0?200:500,"添加成功"); + } +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/RuleServiceImpl.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/RuleServiceImpl.java new file mode 100644 index 0000000..4343f51 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/RuleServiceImpl.java @@ -0,0 +1,54 @@ +package com.bwie.goods.service.impl; + +import cn.hutool.core.util.RandomUtil; +import com.alibaba.nacos.common.utils.RandomUtils; +import com.bwie.common.domain.Rule; +import com.bwie.common.result.Result; +import com.bwie.goods.mapper.RuleMapper; +import com.bwie.goods.service.RuleService; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.Random; + +/** + * @author : 李朋果 + * @ClassName : RuleServiceImpl + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 14:07 + */ +@Service +public class RuleServiceImpl implements RuleService { + private RuleMapper ruleMapper; + + public RuleServiceImpl(RuleMapper ruleMapper) { + this.ruleMapper = ruleMapper; + } + + + @Override + public List ruleList() { + return ruleMapper.ruleList(); + } + + @Override + public Result addRule(Rule rule) { + if (rule.getStartNum()==null) { + rule.setStartNum(1); + } + if (rule.getStartNum()> rule.getEndNum()) { + return Result.error("截止次数不可小于起始次数"); + } + + int i= ruleMapper.addRule(rule); + + return Result.success(i>0?200:500,"规则添加成功"); + } + +// public static void main(String[] args) { +// int i1 = RandomUtils.nextInt(10, 100); +// int i = new Random().nextInt(); +// System.out.println(i1); +// } + +} diff --git a/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/TypeServiceImpl.java b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/TypeServiceImpl.java new file mode 100644 index 0000000..b85471b --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/java/com/bwie/goods/service/impl/TypeServiceImpl.java @@ -0,0 +1,29 @@ +package com.bwie.goods.service.impl; + +import com.bwie.common.domain.TypeInfo; +import com.bwie.goods.mapper.TypesMapper; +import com.bwie.goods.service.TypeService; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * @author : 李朋果 + * @ClassName : TypeServiceImpl + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 16:30 + */ +@Service +public class TypeServiceImpl implements TypeService { + private TypesMapper typesMapper; + + + public TypeServiceImpl(TypesMapper typesMapper) { + this.typesMapper = typesMapper; + } + + @Override + public List typeList() { + return typesMapper.list(); + } +} diff --git a/bwie-modules/bwie-goods/src/main/resources/bootstrap.yml b/bwie-modules/bwie-goods/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..ae13d95 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/resources/bootstrap.yml @@ -0,0 +1,41 @@ +# Tomcat +server: + port: 9003 +# Spring +spring: + main: + allow-circular-references: true + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + application: + # 应用名称 + name: bwie-goods + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 124.223.23.100:8848 + config: + # 配置中心地址 + server-addr: 124.223.23.100:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} +fdfs: + so-timeout: 1500 # socket 连接时长 + connect-timeout: 600 # 连接 tracker 服务器超时时长 + # 这两个是你服务器的 IP 地址，注意 23000 端口也要打开，阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流 + tracker-list: 124.223.23.100:22122 + web-server-url: 124.223.23.100:8888 + pool: + jmx-enabled: false + # 生成缩略图 + thumb-image: + height: 500 + width: 500 diff --git a/bwie-modules/bwie-goods/src/main/resources/mapper/GoodsMapper.xml b/bwie-modules/bwie-goods/src/main/resources/mapper/GoodsMapper.xml new file mode 100644 index 0000000..590f249 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/resources/mapper/GoodsMapper.xml @@ -0,0 +1,15 @@ + + + + + + INSERT INTO MONTH.goods_info ( goods_name, goods_type, goods_details, goods_price, bargain_rule_id, success_num, be_in_num, join_client_num, goods_status ) + VALUES + ( #{goodsName}, #{goodsType}, #{goodsDetails}, #{goodsPrice}, #{bargainRuleId}, #{successNum}, #{joinClientNum}, #{beInNum}, #{goodsStatus} ) + + + + + diff --git a/bwie-modules/bwie-goods/src/main/resources/mapper/RuleMapper.xml b/bwie-modules/bwie-goods/src/main/resources/mapper/RuleMapper.xml new file mode 100644 index 0000000..305b9a0 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/resources/mapper/RuleMapper.xml @@ -0,0 +1,21 @@ + + + + + + INSERT INTO MONTH.bargain_rule + ( rule_name, type_id, start_num, end_num, start_radius, end_radius ) + VALUES + ( #{ruleName}, #{typeId}, #{startNum}, #{endNum}, #{startRadius}, #{endRadius} ) + + + + + diff --git a/bwie-modules/bwie-goods/src/main/resources/mapper/TypeMapper.xml b/bwie-modules/bwie-goods/src/main/resources/mapper/TypeMapper.xml new file mode 100644 index 0000000..887e636 --- /dev/null +++ b/bwie-modules/bwie-goods/src/main/resources/mapper/TypeMapper.xml @@ -0,0 +1,10 @@ + + + + + + + + diff --git a/bwie-modules/bwie-user/.gitignore b/bwie-modules/bwie-user/.gitignore new file mode 100644 index 0000000..5ff6309 --- /dev/null +++ b/bwie-modules/bwie-user/.gitignore @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### IntelliJ IDEA ### +.idea/modules.xml +.idea/jarRepositories.xml +.idea/compiler.xml +.idea/libraries/ +*.iws +*.iml +*.ipr + +### Eclipse ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ + +### Mac OS ### +.DS_Store \ No newline at end of file diff --git a/bwie-modules/bwie-user/pom.xml b/bwie-modules/bwie-user/pom.xml new file mode 100644 index 0000000..4758bd2 --- /dev/null +++ b/bwie-modules/bwie-user/pom.xml @@ -0,0 +1,55 @@ + + + 4.0.0 + + com.bwie + bwie-modules + 1.0-SNAPSHOT + + + bwie-user + + + 17 + 17 + UTF-8 + + + + + + com.bwie + bwie-common + + + + org.springframework.boot + spring-boot-starter-web + + + + com.alibaba + druid-spring-boot-starter + 1.2.8 + + + + mysql + mysql-connector-java + + + + org.mybatis.spring.boot + mybatis-spring-boot-starter + 2.2.2 + + + + com.github.pagehelper + pagehelper-spring-boot-starter + 1.4.1 + + + diff --git a/bwie-modules/bwie-user/src/main/java/com/bwie/user/UserApplication.java b/bwie-modules/bwie-user/src/main/java/com/bwie/user/UserApplication.java new file mode 100644 index 0000000..c771d0e --- /dev/null +++ b/bwie-modules/bwie-user/src/main/java/com/bwie/user/UserApplication.java @@ -0,0 +1,17 @@ +package com.bwie.user; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @author : 李朋果 + * @ClassName : UserApplication + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:28 + */ +@SpringBootApplication +public class UserApplication { + public static void main(String[] args) { + SpringApplication.run(UserApplication.class); + } +} diff --git a/bwie-modules/bwie-user/src/main/java/com/bwie/user/controller/UserController.java b/bwie-modules/bwie-user/src/main/java/com/bwie/user/controller/UserController.java new file mode 100644 index 0000000..d68e36d --- /dev/null +++ b/bwie-modules/bwie-user/src/main/java/com/bwie/user/controller/UserController.java @@ -0,0 +1,34 @@ +package com.bwie.user.controller; + +import com.bwie.common.domain.User; +import com.bwie.common.result.Result; +import com.bwie.user.service.UserService; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author : 李朋果 + * @ClassName : UserController + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:17 + */ +@RestController +public class UserController { + private UserService userService; + + public UserController(UserService userService) { + this.userService = userService; + } + + /** + * 根据用户名获取信息 + * @param username 用户名 + * @return + */ + @PostMapping("/findByUserName/{username}") + public Result findByUserName(@PathVariable String username) { + User user= userService.findByUserName(username); + return Result.success(user); + } +} diff --git a/bwie-modules/bwie-user/src/main/java/com/bwie/user/mapper/UserMapper.java b/bwie-modules/bwie-user/src/main/java/com/bwie/user/mapper/UserMapper.java new file mode 100644 index 0000000..e524be1 --- /dev/null +++ b/bwie-modules/bwie-user/src/main/java/com/bwie/user/mapper/UserMapper.java @@ -0,0 +1,17 @@ +package com.bwie.user.mapper; + +import com.bwie.common.domain.User; +import org.apache.ibatis.annotations.Mapper; + +/** + * @author : 李朋果 + * @ClassName : UserMapper + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:18 + */ +@Mapper +public interface UserMapper { + + User findByUserName(String username); + +} diff --git a/bwie-modules/bwie-user/src/main/java/com/bwie/user/service/UserService.java b/bwie-modules/bwie-user/src/main/java/com/bwie/user/service/UserService.java new file mode 100644 index 0000000..ba8d4a3 --- /dev/null +++ b/bwie-modules/bwie-user/src/main/java/com/bwie/user/service/UserService.java @@ -0,0 +1,13 @@ +package com.bwie.user.service; + +import com.bwie.common.domain.User; + +/** + * @author : 李朋果 + * @ClassName : UserService + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:18 + */ +public interface UserService { + User findByUserName(String username); +} diff --git a/bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java b/bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java new file mode 100644 index 0000000..8bdedd8 --- /dev/null +++ b/bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java @@ -0,0 +1,26 @@ +package com.bwie.user.service.impl; + +import com.bwie.common.domain.User; +import com.bwie.user.mapper.UserMapper; +import com.bwie.user.service.UserService; +import org.springframework.stereotype.Service; + +/** + * @author : 李朋果 + * @ClassName : UserServiceImpl + * @description : 描述说明该类的功能 + * @createTime : 2023/11/7 9:18 + */ +@Service +public class UserServiceImpl implements UserService { + private UserMapper userMapper; + + public UserServiceImpl(UserMapper userMapper) { + this.userMapper = userMapper; + } + + @Override + public User findByUserName(String username) { + return userMapper.findByUserName(username); + } +} diff --git a/bwie-modules/bwie-user/src/main/resources/bootstrap.yml b/bwie-modules/bwie-user/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..e9ecfac --- /dev/null +++ b/bwie-modules/bwie-user/src/main/resources/bootstrap.yml @@ -0,0 +1,29 @@ +# Tomcat +server: + port: 9002 +# Spring +spring: + main: + allow-circular-references: true + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + application: + # 应用名称 + name: bwie-user + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 124.223.23.100:8848 + config: + # 配置中心地址 + server-addr: 124.223.23.100:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/bwie-modules/bwie-user/src/main/resources/mapper/UserMapper.xml b/bwie-modules/bwie-user/src/main/resources/mapper/UserMapper.xml new file mode 100644 index 0000000..a4c269c --- /dev/null +++ b/bwie-modules/bwie-user/src/main/resources/mapper/UserMapper.xml @@ -0,0 +1,10 @@ + + + + + + + + diff --git a/bwie-modules/pom.xml b/bwie-modules/pom.xml new file mode 100644 index 0000000..967fa3e --- /dev/null +++ b/bwie-modules/pom.xml @@ -0,0 +1,26 @@ + + + 4.0.0 + + com.bwie + zg6-month-exam-1107 + 1.0-SNAPSHOT + + + bwie-modules + pom + + bwie-user + bwie-es + bwie-goods + + + + 17 + 17 + UTF-8 + + + diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..8224fd5 --- /dev/null +++ b/pom.xml @@ -0,0 +1,69 @@ + + + 4.0.0 + + com.bwie + zg6-month-exam-1107 + 1.0-SNAPSHOT + pom + + bwie-auth + bwie-common + bwie-gateway + bwie-modules + + + + 17 + 17 + UTF-8 + + + + + + + spring-boot-starter-parent + org.springframework.boot + 2.6.2 + + + + + + + + org.springframework.cloud + spring-cloud-dependencies + 2021.0.0 + pom + import + + + + com.alibaba.cloud + spring-cloud-alibaba-dependencies + 2021.1 + pom + import + + + + com.alibaba.nacos + nacos-client + 2.0.4 + + + + + com.bwie + bwie-common + 1.0-SNAPSHOT + + + + + +