commit 1dba744cb40653bd2ddfa583a322eecc76c248cb
Author: 微醺 <14463847+zmw770157181@user.noreply.gitee.com>
Date: Thu Aug 1 10:17:44 2024 +0800
日考
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/$PROJECT_FILE$ b/.idea/$PROJECT_FILE$
new file mode 100644
index 0000000..58b7e3e
--- /dev/null
+++ b/.idea/$PROJECT_FILE$
@@ -0,0 +1,11 @@
+
+
+
+
+
+
+
+
+
+
+
\ 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..e55f3d8
--- /dev/null
+++ b/.idea/encodings.xml
@@ -0,0 +1,14 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml
new file mode 100644
index 0000000..8d66637
--- /dev/null
+++ b/.idea/inspectionProfiles/Project_Default.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/misc.xml b/.idea/misc.xml
new file mode 100644
index 0000000..81c1fc4
--- /dev/null
+++ b/.idea/misc.xml
@@ -0,0 +1,23 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/qaplug_profiles.xml b/.idea/qaplug_profiles.xml
new file mode 100644
index 0000000..3dfd21f
--- /dev/null
+++ b/.idea/qaplug_profiles.xml
@@ -0,0 +1,465 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/bwie-common/pom.xml b/bwie-common/pom.xml
new file mode 100644
index 0000000..c44bd8b
--- /dev/null
+++ b/bwie-common/pom.xml
@@ -0,0 +1,131 @@
+
+
+ 4.0.0
+
+ com.bwie
+ wei_zg6_rikao_13
+ 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
+
+
+
+
+
+
+ com.github.tobato
+ fastdfs-client
+ 1.26.5
+
+
+
+
+ org.springframework.cloud
+ spring-cloud-starter-netflix-hystrix
+ 2.2.7.RELEASE
+
+
+ org.springframework.boot
+ spring-boot-starter-amqp
+
+
+
+ com.google.guava
+ guava
+ 30.1-jre
+
+
+
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/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..1f09187
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java
@@ -0,0 +1,5 @@
+package com.bwie.common.constants;
+
+public class RabbitMQConstants {
+ public static final String SEND_SMS_QUEUE = "send_sms_queue";
+}
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/R.java b/bwie-common/src/main/java/com/bwie/common/domain/R.java
new file mode 100644
index 0000000..7f9671a
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/domain/R.java
@@ -0,0 +1,54 @@
+package com.bwie.common.domain;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+
+@Data
+public class R implements Serializable {
+
+ private Integer code; //编码:1成功,0和其它数字为失败
+
+ private String msg; //错误信息
+
+ private T data; //数据
+
+ private Map map = new HashMap(); //动态数据
+
+ public static R success(T object) {
+ R r = new R();
+ r.data = object;
+ r.code = 1;
+ return r;
+ }
+ public static R success(String msg,T object) {
+ R r = new R();
+ r.data = object;
+ r.code = 1;
+ r.msg = msg;
+ return r;
+ }
+
+ public static R error(String msg) {
+ R r = new R();
+ r.msg = msg;
+ r.code = 0;
+ return r;
+ }
+
+ public static R success(String msg) {
+ R r = new R();
+ r.msg = msg;
+ r.code = 1;
+ return r;
+ }
+
+ public R add(String key, Object value) {
+ this.map.put(key, value);
+ return this;
+ }
+
+}
+
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..b0ca141
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/domain/User.java
@@ -0,0 +1,13 @@
+package com.bwie.common.domain;
+
+import lombok.Data;
+
+@Data
+public class User {
+ // 表
+ private Integer uid;
+ // 用户名
+ private String uname;
+ // 密码
+ private String upwd;
+}
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..5d888b2
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java
@@ -0,0 +1,9 @@
+package com.bwie.common.domain.response;
+
+import lombok.Data;
+
+@Data
+public class JwtResponse {
+ private String token;
+ private String existTime;
+}
diff --git a/bwie-common/src/main/java/com/bwie/common/exception/CustomException.java b/bwie-common/src/main/java/com/bwie/common/exception/CustomException.java
new file mode 100644
index 0000000..7bab617
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/exception/CustomException.java
@@ -0,0 +1,44 @@
+package com.bwie.common.exception;
+
+/**
+ * @ClassName exceptionCategoryDelete
+ * @Description 描述
+ * @Author ZhiXiAng.Li
+ * @Date 2024/6/2 23:07
+ */
+
+import com.bwie.common.domain.R;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+
+/**
+ * 将业务层抛出的异常信息捕获到,然后交给全局异常处理器去处理,给前端提供错误信息
+ * @param exception
+ * @return
+ */
+@Slf4j
+public class CustomException extends RuntimeException{
+ /**
+ * 自定义业务异常类
+ * @param message
+ */
+ public CustomException(String message){
+ super(message);
+ log.info(message.toString());
+ }
+
+ /**
+ * 将业务层抛出的异常信息捕获到,然后交给全局异常处理器去处理,给前端提供错误信息
+ * @param exception
+ * @return
+ */
+ @ExceptionHandler(CustomException.class)//RuntimeException异常类型通过注解拿到
+ public R exceptionCategoryDelete(CustomException exception){
+ log.error(exception.getMessage());//在控制台打印错误信息
+ return R.error(exception.getMessage());
+
+ }
+
+}
+
+
diff --git a/bwie-common/src/main/java/com/bwie/common/handler/GlobalExceptionHandler.java b/bwie-common/src/main/java/com/bwie/common/handler/GlobalExceptionHandler.java
new file mode 100644
index 0000000..1db3c7b
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/handler/GlobalExceptionHandler.java
@@ -0,0 +1,31 @@
+package com.bwie.common.handler;
+
+import com.bwie.common.domain.R;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 全局异常捕获
+ */
+@Slf4j
+@ControllerAdvice(annotations = {RestController.class, Controller.class})
+//只要类的注解上有这些注解。那么发生的异常都能被捕获到
+@ResponseBody
+public class GlobalExceptionHandler {
+ /**
+ * 处理除0异常捕获
+ * @param exception
+ * @return
+ */
+ @ExceptionHandler(ArithmeticException.class)//ArithmeticException异常类型通过注解拿到
+ public R exceptionHandler(ArithmeticException exception){
+ log.error(exception.getMessage());//在控制台打印错误信息
+ return R.error(exception.getMessage());
+
+ }
+}
+
diff --git a/bwie-common/src/main/java/com/bwie/common/result/ErrorHandler.java b/bwie-common/src/main/java/com/bwie/common/result/ErrorHandler.java
new file mode 100644
index 0000000..1b6af45
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/result/ErrorHandler.java
@@ -0,0 +1,31 @@
+package com.bwie.common.result;
+
+
+import com.bwie.common.result.Result;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+
+
+/**
+ * @ClassName ErrorHandler
+ * @Description 描述
+ * @Author Wen.Li
+ * @Date 2024/1/8 20:49
+ */
+@RestControllerAdvice
+public class ErrorHandler {//全局异常
+
+// @Autowired
+// private HttpServletRequest request;
+
+
+ @ExceptionHandler(Exception.class)
+ public Result exceptionHandler(Exception exception){
+ return new Result(){{
+ setCode(500);
+ setMsg(exception.getMessage());
+ }};
+ }
+}
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..6d92a56
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/utils/FastUtil.java
@@ -0,0 +1,50 @@
+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;
+
+
+@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/GenCodeUtils.java b/bwie-common/src/main/java/com/bwie/common/utils/GenCodeUtils.java
new file mode 100644
index 0000000..2ae9ff9
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/utils/GenCodeUtils.java
@@ -0,0 +1,86 @@
+package com.bwie.common.utils;
+
+import java.util.Random;
+
+/**
+ * @description: 生成验证码工具类
+ * @Date 2023-5-11 上午 10:09
+ */
+public class GenCodeUtils {
+
+ /**
+ * 数字类型
+ */
+ private static final String NUMBER_STR = "0123456789";
+ /**
+ * 字母类型
+ */
+ private static final String LETTERS_STR = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
+
+ /**
+ * 短信验证码长度
+ */
+ private static final Integer SMS_CODE_LENGTH = 4;
+
+ /**
+ * 生成短信四位验证码
+ * @return 验证码
+ */
+ public static String genLetterStrSms(){
+ return genCode(LETTERS_STR, SMS_CODE_LENGTH);
+ }
+
+ /**
+ * 生成短信四位验证码
+ * @return 验证码
+ */
+ public static String genNumberCodeSms(){
+ return genCode(NUMBER_STR, SMS_CODE_LENGTH);
+ }
+
+ /**
+ * 生成验证码
+ * @param codeLength 验证码长度
+ * @return 验证码
+ */
+ public static String genLetterStr(int codeLength){
+ return genCode(LETTERS_STR, codeLength);
+ }
+
+ /**
+ * 生成验证码
+ * @param codeLength 验证码长度
+ * @return 验证码
+ */
+ public static String genNumberCode( int codeLength){
+ return genCode(NUMBER_STR, codeLength);
+ }
+
+ /**
+ * 生成验证码
+ * @param str 验证码字符串
+ * @param codeLength 验证码长度
+ * @return 验证码
+ */
+ public static String genCode (String str, int codeLength){
+ //将字符串转换为一个新的字符数组。
+ char[] verificationCodeArray = str.toCharArray();
+ Random random = new Random();
+ //计数器
+ int count = 0;
+ StringBuilder stringBuilder = new StringBuilder();
+ do {
+ //随机生成一个随机数
+ int index = random.nextInt(verificationCodeArray.length);
+ char c = verificationCodeArray[index];
+ //限制四位不重复数字
+ if (stringBuilder.indexOf(String.valueOf(c)) == -1) {
+ stringBuilder.append(c);
+ //计数器加1
+ count++;
+ }
+ //当count等于4时结束,随机生成四位数的验证码
+ } while (count != codeLength);
+ return stringBuilder.toString();
+ }
+}
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..75f3c7b
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/utils/JwtUtils.java
@@ -0,0 +1,115 @@
+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工具类
+ */
+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/StringUtils.java b/bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java
new file mode 100644
index 0000000..7cf6a15
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java
@@ -0,0 +1,67 @@
+package com.bwie.common.utils;
+
+import org.springframework.util.AntPathMatcher;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * @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..12053bd
--- /dev/null
+++ b/bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
@@ -0,0 +1,92 @@
+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 = "LTAI5tHU282xbcCSKZJSuKyH";
+
+ private static String accessKeySecret = "mX4tPoqoI55x3ACK1Z7IFiuAMVxuQr";
+
+ /**
+ * 短信访问域名
+ */
+ private static String endpoint = "dysmsapi.aliyuncs.com";
+ /**
+ * 短信签名
+ */
+ private static String signName = "乐优购";
+
+ private static String templateCode = "SMS_163851467";
+
+ /**
+ * 实例化短信对象
+ */
+ 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 sendDataMap
+ */
+ public static String sendSms(String tel, 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-modules/bwie-expressage/pom.xml b/bwie-modules/bwie-expressage/pom.xml
new file mode 100644
index 0000000..dd960b6
--- /dev/null
+++ b/bwie-modules/bwie-expressage/pom.xml
@@ -0,0 +1,56 @@
+
+
+ 4.0.0
+
+ com.bwie
+ wei_zg6_rikao_13
+ 1.0-SNAPSHOT
+ ../../pom.xml
+
+
+ bwie-expressage
+
+
+ 17
+ 17
+ UTF-8
+
+
+
+
+ com.bwie
+ bwie-common
+ 1.0-SNAPSHOT
+
+
+
+ com.alibaba
+ druid-spring-boot-starter
+ 1.2.8
+
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ 2.2.2
+
+
+
+ mysql
+ mysql-connector-java
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ com.github.pagehelper
+ pagehelper-spring-boot-starter
+ 1.4.1
+
+
+
diff --git a/bwie-modules/bwie-expressage/src/main/java/com/bwie/Expressage.java b/bwie-modules/bwie-expressage/src/main/java/com/bwie/Expressage.java
new file mode 100644
index 0000000..9bffa5e
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/java/com/bwie/Expressage.java
@@ -0,0 +1,11 @@
+package com.bwie;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class Expressage {
+ public static void main(String[] args) {
+ SpringApplication.run(Expressage.class);
+ }
+}
diff --git a/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/controller/ExController.java b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/controller/ExController.java
new file mode 100644
index 0000000..7a57d39
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/controller/ExController.java
@@ -0,0 +1,19 @@
+package com.bwie.expressage.controller;
+
+import com.bwie.common.domain.User;
+import com.bwie.common.result.Result;
+import com.bwie.expressage.service.ExService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class ExController {
+ @Autowired
+ private ExService exService;
+ @PostMapping("login")
+ public Result login(@RequestBody User user){
+ return exService.login(user);
+ }
+}
diff --git a/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/mapper/ExMapper.java b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/mapper/ExMapper.java
new file mode 100644
index 0000000..1121d04
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/mapper/ExMapper.java
@@ -0,0 +1,10 @@
+package com.bwie.expressage.mapper;
+
+import com.bwie.common.domain.User;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface ExMapper {
+
+ User login(User user);
+}
diff --git a/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/service/ExService.java b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/service/ExService.java
new file mode 100644
index 0000000..d71d7f2
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/service/ExService.java
@@ -0,0 +1,8 @@
+package com.bwie.expressage.service;
+
+import com.bwie.common.domain.User;
+import com.bwie.common.result.Result;
+
+public interface ExService {
+ Result login(User user);
+}
diff --git a/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/service/impl/ExServiceImpl.java b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/service/impl/ExServiceImpl.java
new file mode 100644
index 0000000..6329f7f
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/service/impl/ExServiceImpl.java
@@ -0,0 +1,26 @@
+package com.bwie.expressage.service.impl;
+
+import com.bwie.common.domain.User;
+import com.bwie.common.result.Result;
+import com.bwie.expressage.mapper.ExMapper;
+import com.bwie.expressage.service.ExService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class ExServiceImpl implements ExService {
+ @Autowired
+ private ExMapper exMapper;
+
+ @Override
+ public Result login(User user) {
+ User login = exMapper.login(user);
+ if(null == login){
+ return Result.error("用户名不存在");
+ }
+ if(!login.getUpwd().equals(user.getUpwd())){
+ return Result.error("密码错误");
+ }
+ return Result.success(login);
+ }
+}
diff --git a/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/util/OssUtil.java b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/util/OssUtil.java
new file mode 100644
index 0000000..c7ad064
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/java/com/bwie/expressage/util/OssUtil.java
@@ -0,0 +1,162 @@
+package com.bwie.expressage.util;
+
+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 = "LTAI5tDbRqXkC5i3SMrCSDcX";
+ private static String accessKeySecret = "XUzMZoHPLsjNLafHsdQnMElBWZATsu";
+ private static String accessPre = "https://mall-bw.oss-cn-shanghai.aliyuncs.com/";
+
+ /**
+ * bucket名称
+ *
+ * @return
+ */
+ private static String bucketName = "mall-bw";
+
+ 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-modules/bwie-expressage/src/main/resources/bootstrap.yml b/bwie-modules/bwie-expressage/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..ce9c1a8
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/resources/bootstrap.yml
@@ -0,0 +1,45 @@
+# Tomcat
+server:
+ port: 9007
+# Spring
+spring:
+ main:
+ allow-circular-references: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ application:
+ # 应用名称
+ name: bwie-expressage
+ profiles:
+ # 环境配置
+ active: dev
+ cloud:
+ nacos:
+ discovery:
+ # 服务注册地址
+ server-addr: 42.192.54.130:8848
+ # 命名空间
+ namespace: 23e28ad0-161c-4dd7-b23a-b90aa24e98a6
+ config:
+ # 配置中心地址
+ server-addr: 42.192.54.130:8848
+ # 命名空间
+ namespace: 23e28ad0-161c-4dd7-b23a-b90aa24e98a6
+ # 配置文件格式
+ 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: 42.192.54.130:22122
+ web-server-url: 42.192.54.130:8888
+ pool:
+ jmx-enabled: false
+ # 生成缩略图
+ thumb-image:
+ height: 500
+ width: 500
diff --git a/bwie-modules/bwie-expressage/src/main/resources/mapper/ExMapper.xml b/bwie-modules/bwie-expressage/src/main/resources/mapper/ExMapper.xml
new file mode 100644
index 0000000..1477a76
--- /dev/null
+++ b/bwie-modules/bwie-expressage/src/main/resources/mapper/ExMapper.xml
@@ -0,0 +1,11 @@
+
+
+
+
+
+
+
diff --git a/bwie-modules/pom.xml b/bwie-modules/pom.xml
new file mode 100644
index 0000000..122d755
--- /dev/null
+++ b/bwie-modules/pom.xml
@@ -0,0 +1,20 @@
+
+
+ 4.0.0
+
+ com.bwie
+ wei_zg6_rikao_13
+ 1.0-SNAPSHOT
+
+
+ bwie-modules
+
+
+ 17
+ 17
+ UTF-8
+
+
+
diff --git a/imgs/A6A%QUTEPV2MRHZIO}GISWM.png b/imgs/A6A%QUTEPV2MRHZIO}GISWM.png
new file mode 100644
index 0000000..a97248e
Binary files /dev/null and b/imgs/A6A%QUTEPV2MRHZIO}GISWM.png differ
diff --git a/imgs/Q$A`MOEE$`TD}1$[V}}~U]I.png b/imgs/Q$A`MOEE$`TD}1$[V}}~U]I.png
new file mode 100644
index 0000000..2750fd9
Binary files /dev/null and b/imgs/Q$A`MOEE$`TD}1$[V}}~U]I.png differ
diff --git a/imgs/S~}@E9Q%GG17J`5KU5}OA]A.png b/imgs/S~}@E9Q%GG17J`5KU5}OA]A.png
new file mode 100644
index 0000000..247bc8f
Binary files /dev/null and b/imgs/S~}@E9Q%GG17J`5KU5}OA]A.png differ
diff --git a/imgs/UTXOO)6U35(J2CR1WE8[1J1.png b/imgs/UTXOO)6U35(J2CR1WE8[1J1.png
new file mode 100644
index 0000000..9ed6661
Binary files /dev/null and b/imgs/UTXOO)6U35(J2CR1WE8[1J1.png differ
diff --git a/imgs/_Q39_[@H1O3$Z}%@9XVAWA9.png b/imgs/_Q39_[@H1O3$Z}%@9XVAWA9.png
new file mode 100644
index 0000000..1d4f55d
Binary files /dev/null and b/imgs/_Q39_[@H1O3$Z}%@9XVAWA9.png differ
diff --git a/imgs/_X9[@KBA[52KF_{9GZ3B9QO.png b/imgs/_X9[@KBA[52KF_{9GZ3B9QO.png
new file mode 100644
index 0000000..d99071e
Binary files /dev/null and b/imgs/_X9[@KBA[52KF_{9GZ3B9QO.png differ
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..ee1f79e
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,65 @@
+
+
+ 4.0.0
+
+ com.bwie
+ wei_zg6_rikao_13
+ 1.0-SNAPSHOT
+ pom
+
+ bwie-common
+ bwie-modules
+ bwie-modules/bwie-expressage
+
+
+
+ 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
+
+
+
+
+