jwtMap = new HashMap<>(100, 100);
+ jwtMap.put(JwtConstants.USER_KEY, userKey);
+ jwtMap.put(JwtConstants.DETAILS_USER_ID, loginUser.getUserId());
+ String token = JwtUtils.createToken(jwtMap);
+ redisTemplate.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 json = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
+ return JSONObject.parseObject(json, User.class);
+ }
+
+ @Override
+ public void logout() {
+ String token = request.getHeader(TokenConstants.TOKEN);
+ String userKey = JwtUtils.getUserKey(token);
+ redisTemplate.delete(TokenConstants.LOGIN_TOKEN_KEY + userKey);
+ }
+}
diff --git a/work-auth/src/main/resources/bootstrap.yml b/work-auth/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..3cec30e
--- /dev/null
+++ b/work-auth/src/main/resources/bootstrap.yml
@@ -0,0 +1,33 @@
+# Tomcat
+server:
+ port: 10001
+# Spring
+spring:
+ main:
+ allow-circular-references: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ application:
+ # 应用名称
+ name: work-auth
+ profiles:
+ # 环境配置
+ active: dev
+ cloud:
+ nacos:
+ discovery:
+ # 服务注册地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ config:
+ # 配置中心地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ # 配置文件格式
+ file-extension: yml
+ # 共享配置
+ shared-configs:
+ - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
diff --git a/work-common/pom.xml b/work-common/pom.xml
new file mode 100644
index 0000000..579c15a
--- /dev/null
+++ b/work-common/pom.xml
@@ -0,0 +1,149 @@
+
+
+ 4.0.0
+
+ com.bwie
+ pms
+ 1.0-SNAPSHOT
+
+
+ work-common
+
+
+
+
+ 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
+
+
+
+ org.apache.httpcomponents
+ httpclient
+ 4.2.1
+
+
+ org.apache.httpcomponents
+ httpcore
+ 4.2.1
+
+
+ commons-lang
+ commons-lang
+ 2.6
+
+
+ org.eclipse.jetty
+ jetty-util
+ 9.3.7.v20160115
+
+
+
+ org.springframework.boot
+ spring-boot-starter-amqp
+
+
+
+ com.fasterxml.jackson.dataformat
+ jackson-dataformat-xml
+ 2.9.10
+
+
+
+ org.springframework.kafka
+ spring-kafka
+
+
+
+ com.aliyun.oss
+ aliyun-sdk-oss
+ 3.12.0
+
+
+
+ com.github.tobato
+ fastdfs-client
+ 1.26.5
+
+
+
+ org.springframework.boot
+ spring-boot-starter-mail
+
+
+ org.apache.tomcat.embed
+ tomcat-embed-core
+
+
+
+
diff --git a/work-common/src/main/java/com/bwie/common/constants/Constants.java b/work-common/src/main/java/com/bwie/common/constants/Constants.java
new file mode 100644
index 0000000..e5f6c66
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/constants/Constants.java
@@ -0,0 +1,20 @@
+package com.bwie.common.constants;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO 系统常量
+ * @Version: 1.0
+ */
+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/work-common/src/main/java/com/bwie/common/constants/JwtConstants.java b/work-common/src/main/java/com/bwie/common/constants/JwtConstants.java
new file mode 100644
index 0000000..18acfd4
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/constants/JwtConstants.java
@@ -0,0 +1,31 @@
+package com.bwie.common.constants;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO Jwt常量
+ * @Version: 1.0
+ */
+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/work-common/src/main/java/com/bwie/common/constants/TokenConstants.java b/work-common/src/main/java/com/bwie/common/constants/TokenConstants.java
new file mode 100644
index 0000000..9080624
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/constants/TokenConstants.java
@@ -0,0 +1,26 @@
+package com.bwie.common.constants;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO 令牌常量
+ * @Version: 1.0
+ */
+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/work-common/src/main/java/com/bwie/common/domain/Person.java b/work-common/src/main/java/com/bwie/common/domain/Person.java
new file mode 100644
index 0000000..2622bb5
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/domain/Person.java
@@ -0,0 +1,51 @@
+package com.bwie.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Pattern;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class Person {
+ /**
+ * 人员id
+ */
+ private Integer personId;
+ /**
+ * 人员名称
+ */
+ @NotBlank(message = "人员名称不能为空")
+ private String personName;
+ /**
+ * 身份证
+ */
+ @NotBlank(message = "身份证不能为空")
+ @Pattern(regexp = "^[1-9]\\d{7}(0\\d|10|11|12)([0-2]\\d|30|31)\\d{3}$|^(\\d{6}(18|19|20)\\d{2}(0[1-9]|1[0-2])([0-2]\\d|30|31)\\d{3}[0-9Xx]$)", message = "身份证格式错误")
+ private String idCard;
+ /**
+ * 性别:1-男 2-女
+ */
+ @NotBlank(message = "性别不能为空")
+ private Integer gender;
+ /**
+ * 年龄
+ */
+ @NotBlank(message = "年龄不能为空")
+ private Integer age;
+ /**
+ * 小区
+ */
+ private Integer propertyId;
+}
diff --git a/work-common/src/main/java/com/bwie/common/domain/Property.java b/work-common/src/main/java/com/bwie/common/domain/Property.java
new file mode 100644
index 0000000..334d520
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/domain/Property.java
@@ -0,0 +1,38 @@
+package com.bwie.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Size;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO 小区
+ * @Version 1.0
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class Property {
+ /**
+ * 小区id
+ */
+ private Integer propertyId;
+ /**
+ * 小区名称
+ */
+ @NotBlank(message = "小区名称不能为空")
+ @Size(max = 20, message = "小区名称长度不能大于20")
+ private String propertyName;
+ /**
+ * 所在区域
+ */
+ @NotBlank(message = "所在区域不能为空")
+ private String district;
+
+}
diff --git a/work-common/src/main/java/com/bwie/common/domain/User.java b/work-common/src/main/java/com/bwie/common/domain/User.java
new file mode 100644
index 0000000..cbb61ad
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/domain/User.java
@@ -0,0 +1,26 @@
+package com.bwie.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class User {
+ private Integer userId;
+ private String username;
+ private String password;
+ private String bankCard;
+ private BigDecimal balance;
+}
diff --git a/work-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java b/work-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java
new file mode 100644
index 0000000..af3cd9b
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/domain/request/LoginRequest.java
@@ -0,0 +1,16 @@
+package com.bwie.common.domain.request;
+
+import lombok.Data;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Data
+public class LoginRequest {
+
+ private String username;
+ private String password;
+}
diff --git a/work-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java b/work-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java
new file mode 100644
index 0000000..5f94b42
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java
@@ -0,0 +1,21 @@
+package com.bwie.common.domain.response;
+
+import lombok.Data;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Data
+public class JwtResponse {
+ /**
+ * token
+ */
+ private String token;
+ /**
+ * 过期时间
+ */
+ private String expireTime;
+}
diff --git a/work-common/src/main/java/com/bwie/common/domain/response/PropertyResponse.java b/work-common/src/main/java/com/bwie/common/domain/response/PropertyResponse.java
new file mode 100644
index 0000000..641a789
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/domain/response/PropertyResponse.java
@@ -0,0 +1,42 @@
+package com.bwie.common.domain.response;
+
+import com.bwie.common.domain.Property;
+import lombok.Data;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Data
+public class PropertyResponse extends Property {
+ /**
+ * 小区名称
+ */
+ private String propertyName;
+ /**
+ * 所在区域
+ */
+ private String district;
+ /**
+ * 总人数
+ */
+ private Integer total;
+ /**
+ * 男性人数
+ */
+ private Integer men;
+ /**
+ * 女性人数
+ */
+ private Integer women;
+ /**
+ * 平均年龄
+ */
+ private Float avgAge;
+ /**
+ * 最大年龄
+ */
+ private Integer maxAge;
+}
diff --git a/work-common/src/main/java/com/bwie/common/exception/GlobalExceptionHandler.java b/work-common/src/main/java/com/bwie/common/exception/GlobalExceptionHandler.java
new file mode 100644
index 0000000..7b434d5
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/exception/GlobalExceptionHandler.java
@@ -0,0 +1,58 @@
+package com.bwie.common.exception;
+
+
+import com.bwie.common.result.Result;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.validation.FieldError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.validation.ConstraintViolationException;
+import java.util.stream.Collectors;
+
+/**
+ * @author liyongjie
+ */
+@RestControllerAdvice
+@Log4j2
+public class GlobalExceptionHandler {
+
+ @ExceptionHandler(SystemException.class)
+ public Result SystemException(HttpServletRequest request, SystemException systemException) {
+
+ String path = request.getServletPath();
+
+ System.out.println("请求路径" + path);
+
+
+ log.info("请求Url：{}，测试除了异常：{}", path, SystemException.class);
+
+ return Result.error(systemException.getMassage());
+ }
+
+
+ /**
+ * 自定义验证异常
+ */
+ @ExceptionHandler(MethodArgumentNotValidException.class)
+ public Object methodArgumentNotValidException(MethodArgumentNotValidException e) {
+ log.info(e.getMessage());
+
+ String collect = e.getBindingResult().getFieldErrors().stream().map(FieldError::getDefaultMessage).collect(Collectors.joining(","));
+
+
+ return Result.error(collect);
+ }
+
+
+ /**
+ * 自定义验证异常 集合
+ */
+ @ExceptionHandler(ConstraintViolationException.class)
+ public Object handleConstraintViolationException(ConstraintViolationException e) {
+ log.error(e.getMessage(), e);
+ return Result.error(e.getMessage());
+ }
+}
diff --git a/work-common/src/main/java/com/bwie/common/exception/ServiceException.java b/work-common/src/main/java/com/bwie/common/exception/ServiceException.java
new file mode 100644
index 0000000..20c25a6
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/exception/ServiceException.java
@@ -0,0 +1,67 @@
+package com.bwie.common.exception;
+
+/**
+ * @ClassName:
+ * @Description: 业务异常
+ * @Author: LiYonJie
+ * @Date: 2023/11/28
+ */
+public class ServiceException extends RuntimeException {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 错误码
+ */
+ private Integer code;
+
+ /**
+ * 错误提示
+ */
+ private String message;
+
+ /**
+ * 错误明细，内部调试错误
+ *
+ */
+ private String detailMessage;
+
+ /**
+ * 空构造方法，避免反序列化问题
+ */
+ public ServiceException() {
+ }
+
+ public ServiceException(String message) {
+ this.message = message;
+ }
+
+ public ServiceException(String message, Integer code) {
+ this.message = message;
+ this.code = code;
+ }
+
+ public String getDetailMessage() {
+ return detailMessage;
+ }
+
+ public ServiceException setDetailMessage(String detailMessage) {
+ this.detailMessage = detailMessage;
+ return this;
+ }
+
+ @Override
+ public String getMessage() {
+ return message;
+ }
+
+ public ServiceException setMessage(String message) {
+ this.message = message;
+ return this;
+ }
+
+ public Integer getCode() {
+ return code;
+ }
+
+}
diff --git a/work-common/src/main/java/com/bwie/common/exception/SystemException.java b/work-common/src/main/java/com/bwie/common/exception/SystemException.java
new file mode 100644
index 0000000..ca45e82
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/exception/SystemException.java
@@ -0,0 +1,21 @@
+package com.bwie.common.exception;
+
+import lombok.Data;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Data
+public class SystemException extends RuntimeException{
+
+
+ private String massage;
+
+ public SystemException(String message, String massage) {
+ super(message);
+ this.massage = massage;
+ }
+}
diff --git a/work-common/src/main/java/com/bwie/common/result/PageResult.java b/work-common/src/main/java/com/bwie/common/result/PageResult.java
new file mode 100644
index 0000000..33a9ce4
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/result/PageResult.java
@@ -0,0 +1,36 @@
+package com.bwie.common.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO 列表返回结果集
+ * @Version: 1.0
+ */
+@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/work-common/src/main/java/com/bwie/common/result/Result.java b/work-common/src/main/java/com/bwie/common/result/Result.java
new file mode 100644
index 0000000..f2c031a
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/result/Result.java
@@ -0,0 +1,78 @@
+package com.bwie.common.result;
+
+import com.bwie.common.constants.Constants;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO 响应信息主体
+ * @Version: 1.0
+ */
+@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/work-common/src/main/java/com/bwie/common/utils/FastUtil.java b/work-common/src/main/java/com/bwie/common/utils/FastUtil.java
new file mode 100644
index 0000000..1d0899d
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/FastUtil.java
@@ -0,0 +1,55 @@
+package com.bwie.common.utils;
+
+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.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.utils
+ * @Description: TODO 需要使用的微服务中放入该服务下的utils包内
+ * @Version: 1.0 121.36.202.181
+ */
+@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/work-common/src/main/java/com/bwie/common/utils/HttpUtils.java b/work-common/src/main/java/com/bwie/common/utils/HttpUtils.java
new file mode 100644
index 0000000..0dd0fd4
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/HttpUtils.java
@@ -0,0 +1,341 @@
+package com.bwie.common.utils;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.http.HttpResponse;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.HttpDelete;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpPut;
+import org.apache.http.conn.ClientConnectionManager;
+import org.apache.http.conn.scheme.Scheme;
+import org.apache.http.conn.scheme.SchemeRegistry;
+import org.apache.http.conn.ssl.SSLSocketFactory;
+import org.apache.http.entity.ByteArrayEntity;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.DefaultHttpClient;
+import org.apache.http.message.BasicNameValuePair;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.security.cert.X509Certificate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author Li YongJie
+ * @version 1.0.0
+ * @ClassName MsgUtil.java
+ * @Description TODO
+ * @createTime 2022年04月27日 13:53:00
+ */
+public class HttpUtils {
+
+ private static final String SCHEME = "https://";
+
+ /**
+ * get
+ *
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doGet(String host, String path, String method,
+ Map headers,
+ Map querys)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpGet request = new HttpGet(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ return httpClient.execute(request);
+ }
+
+ /**
+ * post form
+ *
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @param bodys
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doPost(String host, String path, String method,
+ Map headers,
+ Map querys,
+ Map bodys)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpPost request = new HttpPost(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ if (bodys != null) {
+ List nameValuePairList = new ArrayList();
+
+ for (String key : bodys.keySet()) {
+ nameValuePairList.add(new BasicNameValuePair(key, bodys.get(key)));
+ }
+ UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
+ formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
+ request.setEntity(formEntity);
+ }
+
+ return httpClient.execute(request);
+ }
+
+ /**
+ * Post String
+ *
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @param body
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doPost(String host, String path, String method,
+ Map headers,
+ Map querys,
+ String body)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpPost request = new HttpPost(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ if (StringUtils.isNotBlank(body)) {
+ request.setEntity(new StringEntity(body, "utf-8"));
+ }
+
+ return httpClient.execute(request);
+ }
+
+ /**
+ * Post stream
+ *
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @param body
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doPost(String host, String path, String method,
+ Map headers,
+ Map querys,
+ byte[] body)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpPost request = new HttpPost(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ if (body != null) {
+ request.setEntity(new ByteArrayEntity(body));
+ }
+
+ return httpClient.execute(request);
+ }
+
+ /**
+ * Put String
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @param body
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doPut(String host, String path, String method,
+ Map headers,
+ Map querys,
+ String body)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpPut request = new HttpPut(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ if (StringUtils.isNotBlank(body)) {
+ request.setEntity(new StringEntity(body, "utf-8"));
+ }
+
+ return httpClient.execute(request);
+ }
+
+ /**
+ * Put stream
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @param body
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doPut(String host, String path, String method,
+ Map headers,
+ Map querys,
+ byte[] body)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpPut request = new HttpPut(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ if (body != null) {
+ request.setEntity(new ByteArrayEntity(body));
+ }
+
+ return httpClient.execute(request);
+ }
+
+ /**
+ * Delete
+ *
+ * @param host
+ * @param path
+ * @param method
+ * @param headers
+ * @param querys
+ * @return
+ * @throws Exception
+ */
+ public static HttpResponse doDelete(String host, String path, String method,
+ Map headers,
+ Map querys)
+ throws Exception {
+ HttpClient httpClient = wrapClient(host);
+
+ HttpDelete request = new HttpDelete(buildUrl(host, path, querys));
+ for (Map.Entry e : headers.entrySet()) {
+ request.addHeader(e.getKey(), e.getValue());
+ }
+
+ return httpClient.execute(request);
+ }
+
+ private static String buildUrl(String host, String path, Map querys) throws UnsupportedEncodingException {
+ StringBuilder sbUrl = new StringBuilder();
+ sbUrl.append(host);
+ if (!StringUtils.isBlank(path)) {
+ sbUrl.append(path);
+ }
+ if (null != querys) {
+ StringBuilder sbQuery = new StringBuilder();
+ for (Map.Entry query : querys.entrySet()) {
+ if (0 < sbQuery.length()) {
+ sbQuery.append("&");
+ }
+ if (StringUtils.isBlank(query.getKey()) && !StringUtils.isBlank(query.getValue())) {
+ sbQuery.append(query.getValue());
+ }
+ if (!StringUtils.isBlank(query.getKey())) {
+ sbQuery.append(query.getKey());
+ if (!StringUtils.isBlank(query.getValue())) {
+ sbQuery.append("=");
+ sbQuery.append(URLEncoder.encode(query.getValue(), "utf-8"));
+ }
+ }
+ }
+ if (0 < sbQuery.length()) {
+ sbUrl.append("?").append(sbQuery);
+ }
+ }
+
+ return sbUrl.toString();
+ }
+
+ private static HttpClient wrapClient(String host) {
+ HttpClient httpClient = new DefaultHttpClient();
+ if (host.startsWith(SCHEME)) {
+ sslClient(httpClient);
+ }
+
+ return httpClient;
+ }
+
+ /**
+ * sslClient
+ * @param httpClient
+ */
+ private static void sslClient(HttpClient httpClient) {
+ try {
+ SSLContext ctx = SSLContext.getInstance("TLS");
+ X509TrustManager tm = new X509TrustManager() {
+ /**
+ * getAcceptedIssuers
+ * @return
+ */
+ @Override
+ public X509Certificate[] getAcceptedIssuers() {
+ return null;
+ }
+ /**
+ * checkClientTrusted
+ * @param xcs
+ * @param str
+ */
+ @Override
+ public void checkClientTrusted(X509Certificate[] xcs, String str) {
+
+ }
+ /**
+ * checkServerTrusted
+ * @param xcs
+ * @param str
+ */
+ @Override
+ public void checkServerTrusted(X509Certificate[] xcs, String str) {
+
+ }
+ };
+ ctx.init(null, new TrustManager[] { tm }, null);
+ SSLSocketFactory ssf = new SSLSocketFactory(ctx);
+ ssf.setHostnameVerifier(SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
+ ClientConnectionManager ccm = httpClient.getConnectionManager();
+ SchemeRegistry registry = ccm.getSchemeRegistry();
+ registry.register(new Scheme("https", 443, ssf));
+ } catch (KeyManagementException ex) {
+ throw new RuntimeException(ex);
+ } catch (NoSuchAlgorithmException ex) {
+ throw new RuntimeException(ex);
+ }
+ }
+}
diff --git a/work-common/src/main/java/com/bwie/common/utils/JwtUtils.java b/work-common/src/main/java/com/bwie/common/utils/JwtUtils.java
new file mode 100644
index 0000000..4ec81ab
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/JwtUtils.java
@@ -0,0 +1,111 @@
+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;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO Jwt工具类
+ * @Version: 1.0
+ */
+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/work-common/src/main/java/com/bwie/common/utils/MsgUtil.java b/work-common/src/main/java/com/bwie/common/utils/MsgUtil.java
new file mode 100644
index 0000000..6db5add
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/MsgUtil.java
@@ -0,0 +1,55 @@
+package com.bwie.common.utils;
+
+import org.apache.http.HttpResponse;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author Li YongJie
+ * @version 1.0.0
+ * @ClassName MsgUtil.java
+ * @Description TODO
+ * @createTime 2022年04月27日 13:53:00
+ */
+public class MsgUtil {
+
+
+ public static void sendMsg(String phone,String code){
+
+ String host = "http://dingxin.market.alicloudapi.com";
+ String path = "/dx/sendSms";
+ String method = "POST";
+ String appcode = "fe89da4e62954ebda78bd257785e6a53";
+ Map headers = new HashMap(200,200);
+ //最后在header中的格式(中间是英文空格)为Authorization:APPCODE 86873be959334103b775996a22409375
+ headers.put("Authorization", "APPCODE " + appcode);
+ Map querys = new HashMap(200,200);
+ querys.put("mobile", phone);
+ querys.put("param", "code:"+code);
+ //模板不允许改动。 如果要改动，联系客服
+ querys.put("tpl_id", "TP1711063");
+ Map bodys = new HashMap(200,200);
+
+
+ try {
+ /**
+ * 重要提示如下:
+ * HttpUtils请从
+ * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/src/main/java/com/aliyun/api/gateway/demo/util/HttpUtils.java
+ * 下载
+ *
+ * 相应的依赖请参照
+ * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/pom.xml
+ *
+ *
+ * 获取response的body
+ * EntityUtils.toString(response.getEntity())
+ */
+ HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys);
+ System.out.println(response.toString());
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+}
diff --git a/work-common/src/main/java/com/bwie/common/utils/OssUtil.java b/work-common/src/main/java/com/bwie/common/utils/OssUtil.java
new file mode 100644
index 0000000..9d96152
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/OssUtil.java
@@ -0,0 +1,156 @@
+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;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.utils
+ * @Description: TODO Oss服务调用
+ * @Version: 1.0
+ */
+@Log4j2
+public class OssUtil {
+
+ /**
+ * Endpoint 存储对象概述 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限 访问路径前缀 存储对象概述
+ */
+ private static String endPoint = "oss-cn-shanghai.aliyuncs.com";// 访问域名
+ private static String accessKeyId = "LTAI5tKXvCvwq7hKpZgsY2hk";//密钥id
+ private static String accessKeySecret = "HaOTCePEpeLNukQL3jhR6DZu9CAnmA";// 密钥值
+ private static String accessPre = "https://arklorse.oss-cn-shanghai.aliyuncs.com/";//服务前缀URL
+
+ /**
+ * bucket名称
+ * @return
+ */
+ private static String bucketName = "arklorse";
+
+ 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/work-common/src/main/java/com/bwie/common/utils/StringUtils.java b/work-common/src/main/java/com/bwie/common/utils/StringUtils.java
new file mode 100644
index 0000000..b7206c6
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/StringUtils.java
@@ -0,0 +1,70 @@
+package com.bwie.common.utils;
+
+import org.springframework.util.AntPathMatcher;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO 字符串处理工具类
+ * @Version: 1.0
+ */
+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/work-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java b/work-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
new file mode 100644
index 0000000..739dcfc
--- /dev/null
+++ b/work-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
@@ -0,0 +1,90 @@
+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;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.common.domain
+ * @Description: TODO 短信工具类
+ * @Version: 1.0
+ */
+@Log4j2
+public class TelSmsUtils {
+
+ /**
+ * 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限
+ */
+ private static String accessKeyId = "LTAIEVXszCmcd1T5";
+ private static String accessKeySecret = "2zHwciQXln8wExSEnkIYtRTSwLeRNd";
+
+ /**
+ * 短信访问域名
+ */
+ 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/work-gateway/pom.xml b/work-gateway/pom.xml
new file mode 100644
index 0000000..1f1ee10
--- /dev/null
+++ b/work-gateway/pom.xml
@@ -0,0 +1,39 @@
+
+
+ 4.0.0
+
+ com.bwie
+ pms
+ 1.0-SNAPSHOT
+
+
+ work-gateway
+
+
+
+
+ com.bwie
+ work-common
+ 1.0-SNAPSHOT
+
+
+
+
+ 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/work-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java b/work-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java
new file mode 100644
index 0000000..5189014
--- /dev/null
+++ b/work-gateway/src/main/java/com/bwie/gateway/GatewayApplication.java
@@ -0,0 +1,19 @@
+package com.bwie.gateway;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@SpringBootApplication
+@EnableDiscoveryClient
+public class GatewayApplication {
+ public static void main(String[] args) {
+ SpringApplication.run(GatewayApplication.class);
+ }
+}
diff --git a/work-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java b/work-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java
new file mode 100644
index 0000000..fabcea4
--- /dev/null
+++ b/work-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java
@@ -0,0 +1,34 @@
+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;
+
+/**
+ * @Author: Li YongJie
+ * @BelongsPackage: com.bwie.gateway
+ * @Description: TODO 放行白名单配置
+ * @Version: 1.0
+ */
+@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/work-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java b/work-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java
new file mode 100644
index 0000000..eb26437
--- /dev/null
+++ b/work-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java
@@ -0,0 +1,67 @@
+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 org.springframework.beans.factory.annotation.Autowired;
+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.RedisTemplate;
+import org.springframework.http.server.reactive.ServerHttpRequest;
+import org.springframework.stereotype.Component;
+import org.springframework.web.server.ServerWebExchange;
+import reactor.core.publisher.Mono;
+
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Component
+public class AuthFilter implements GlobalFilter, Ordered {
+
+ @Autowired
+ private RedisTemplate redisTemplate;
+
+ @Autowired
+ private IgnoreWhiteConfig ignoreWhiteConfig;
+
+ @Override
+ public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
+ ServerHttpRequest request = exchange.getRequest();
+ String path = request.getURI().getPath();
+ List whites = ignoreWhiteConfig.getWhites();
+ if (StringUtils.matches(path, whites)){
+ return chain.filter(exchange);
+ }
+ String token = request.getHeaders().getFirst(TokenConstants.TOKEN);
+ if (StringUtils.isEmpty(token)){
+ return GatewayUtils.errorResponse(exchange,"token不能为空");
+ }
+ try {
+ JwtUtils.parseToken(token);
+ } catch (Exception e) {
+ return GatewayUtils.errorResponse(exchange,"token不合法");
+ }
+ String userKey = JwtUtils.getUserKey(token);
+ Boolean aBoolean = redisTemplate.hasKey(TokenConstants.LOGIN_TOKEN_KEY + userKey);
+ if (!aBoolean){
+ return GatewayUtils.errorResponse(exchange,"token过期");
+ }else {
+ redisTemplate.expire(TokenConstants.LOGIN_TOKEN_KEY + userKey, 30, TimeUnit.MINUTES);
+ }
+ return chain.filter(exchange);
+ }
+
+ @Override
+ public int getOrder() {
+ return 0;
+ }
+}
diff --git a/work-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java b/work-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java
new file mode 100644
index 0000000..44298e9
--- /dev/null
+++ b/work-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java
@@ -0,0 +1,100 @@
+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: Li YongJie
+ * @BelongsPackage: com.bwie.gateway
+ * @Description: TODO 网关处理工具类
+ * @Version: 1.0
+ */
+@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/work-gateway/src/main/resources/bootstrap.yml b/work-gateway/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..99cf95e
--- /dev/null
+++ b/work-gateway/src/main/resources/bootstrap.yml
@@ -0,0 +1,33 @@
+# Tomcat
+server:
+ port: 18080
+# Spring
+spring:
+ application:
+ # 应用名称
+ name: work-gateway
+ profiles:
+ # 环境配置
+ active: dev
+ main:
+ # 允许使用循环引用
+ allow-circular-references: true
+ # 允许定义相同的bean对象 去覆盖原有的
+ allow-bean-definition-overriding: true
+ cloud:
+ nacos:
+ discovery:
+ # 服务注册地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ config:
+ # 配置中心地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ # 配置文件格式
+ file-extension: yml
+ # 共享配置
+ shared-configs:
+ - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
diff --git a/work-modules/pom.xml b/work-modules/pom.xml
new file mode 100644
index 0000000..f2b6c66
--- /dev/null
+++ b/work-modules/pom.xml
@@ -0,0 +1,26 @@
+
+
+ 4.0.0
+
+ com.bwie
+ pms
+ 1.0-SNAPSHOT
+
+
+ pom
+
+ work-user
+ work-house
+
+
+ work-modules
+
+
+ 8
+ 8
+ UTF-8
+
+
+
diff --git a/work-modules/work-house/pom.xml b/work-modules/work-house/pom.xml
new file mode 100644
index 0000000..140eb59
--- /dev/null
+++ b/work-modules/work-house/pom.xml
@@ -0,0 +1,57 @@
+
+
+ 4.0.0
+
+ com.bwie
+ work-modules
+ 1.0-SNAPSHOT
+
+
+ work-house
+
+
+
+
+ com.bwie
+ work-common
+ 1.0-SNAPSHOT
+
+
+
+ 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
+
+
+
+ io.springfox
+ springfox-swagger2
+ 3.0.0
+
+
+
+
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/HouseApplication.java b/work-modules/work-house/src/main/java/com/bwie/house/HouseApplication.java
new file mode 100644
index 0000000..9d47df3
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/HouseApplication.java
@@ -0,0 +1,19 @@
+package com.bwie.house;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@SpringBootApplication
+@EnableDiscoveryClient
+public class HouseApplication {
+ public static void main(String[] args) {
+ SpringApplication.run(HouseApplication.class);
+ }
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/controller/PersonController.java b/work-modules/work-house/src/main/java/com/bwie/house/controller/PersonController.java
new file mode 100644
index 0000000..d482416
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/controller/PersonController.java
@@ -0,0 +1,30 @@
+package com.bwie.house.controller;
+
+import com.bwie.common.domain.Person;
+import com.bwie.common.result.Result;
+import com.bwie.house.service.PersonService;
+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.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@RestController
+@RequestMapping("/person")
+public class PersonController {
+
+ @Autowired
+ private PersonService personService;
+
+ @PostMapping("/add")
+ public Result add(@RequestBody Person person){
+ personService.add(person);
+ return Result.success();
+ }
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/controller/PropertyController.java b/work-modules/work-house/src/main/java/com/bwie/house/controller/PropertyController.java
new file mode 100644
index 0000000..0507a13
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/controller/PropertyController.java
@@ -0,0 +1,39 @@
+package com.bwie.house.controller;
+
+import com.bwie.common.domain.Property;
+import com.bwie.common.domain.response.PropertyResponse;
+import com.bwie.common.result.Result;
+import com.bwie.house.service.PropertyService;
+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.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@RestController
+@RequestMapping("/property")
+public class PropertyController {
+
+ @Autowired
+ private PropertyService propertyService;
+
+ @PostMapping("/add")
+ public Result add(@RequestBody Property property){
+ propertyService.add(property);
+ return Result.success();
+ }
+
+ @PostMapping("/list")
+ public Result> list(){
+ List list = propertyService.list();
+ return Result.success(list);
+ }
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/mapper/PersonMapper.java b/work-modules/work-house/src/main/java/com/bwie/house/mapper/PersonMapper.java
new file mode 100644
index 0000000..162a01f
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/mapper/PersonMapper.java
@@ -0,0 +1,19 @@
+package com.bwie.house.mapper;
+
+import com.bwie.common.domain.Person;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @Description TODO
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Version 1.0
+ */
+@Mapper
+public interface PersonMapper {
+ /**
+ * 新增人员
+ * @param person
+ */
+ void add(Person person);
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/mapper/PropertyMapper.java b/work-modules/work-house/src/main/java/com/bwie/house/mapper/PropertyMapper.java
new file mode 100644
index 0000000..f944701
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/mapper/PropertyMapper.java
@@ -0,0 +1,29 @@
+package com.bwie.house.mapper;
+
+import com.bwie.common.domain.Property;
+import com.bwie.common.domain.response.PropertyResponse;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * @Description TODO
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Version 1.0
+ */
+@Mapper
+public interface PropertyMapper {
+ /**
+ * 新增小区
+ * @param property
+ */
+ void add(Property property);
+
+ /**
+ * 小区列表
+ * @return
+ */
+ List list();
+
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/service/PersonService.java b/work-modules/work-house/src/main/java/com/bwie/house/service/PersonService.java
new file mode 100644
index 0000000..f47b34b
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/service/PersonService.java
@@ -0,0 +1,17 @@
+package com.bwie.house.service;
+
+import com.bwie.common.domain.Person;
+
+/**
+ * @Description TODO
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Version 1.0
+ */
+public interface PersonService {
+ /**
+ * 新增人员
+ * @param person
+ */
+ void add(Person person);
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/service/PropertyService.java b/work-modules/work-house/src/main/java/com/bwie/house/service/PropertyService.java
new file mode 100644
index 0000000..cb10219
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/service/PropertyService.java
@@ -0,0 +1,26 @@
+package com.bwie.house.service;
+
+import com.bwie.common.domain.Property;
+import com.bwie.common.domain.response.PropertyResponse;
+
+import java.util.List;
+
+/**
+ * @Description TODO
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Version 1.0
+ */
+public interface PropertyService {
+ /**
+ * 新增小区
+ * @param property
+ */
+ void add(Property property);
+
+ /**
+ * 小区列表
+ * @return
+ */
+ List list();
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/service/impl/PersonServiceImpl.java b/work-modules/work-house/src/main/java/com/bwie/house/service/impl/PersonServiceImpl.java
new file mode 100644
index 0000000..78d31eb
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/service/impl/PersonServiceImpl.java
@@ -0,0 +1,25 @@
+package com.bwie.house.service.impl;
+
+import com.bwie.common.domain.Person;
+import com.bwie.house.mapper.PersonMapper;
+import com.bwie.house.service.PersonService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Service
+public class PersonServiceImpl implements PersonService {
+
+ @Autowired
+ private PersonMapper personMapper;
+
+ @Override
+ public void add(Person person) {
+ personMapper.add(person);
+ }
+}
diff --git a/work-modules/work-house/src/main/java/com/bwie/house/service/impl/PropertyServiceImpl.java b/work-modules/work-house/src/main/java/com/bwie/house/service/impl/PropertyServiceImpl.java
new file mode 100644
index 0000000..06e75dd
--- /dev/null
+++ b/work-modules/work-house/src/main/java/com/bwie/house/service/impl/PropertyServiceImpl.java
@@ -0,0 +1,33 @@
+package com.bwie.house.service.impl;
+
+import com.bwie.common.domain.Property;
+import com.bwie.common.domain.response.PropertyResponse;
+import com.bwie.house.mapper.PropertyMapper;
+import com.bwie.house.service.PropertyService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Service
+public class PropertyServiceImpl implements PropertyService {
+
+ @Autowired
+ private PropertyMapper propertyMapper;
+
+ @Override
+ public void add(Property property) {
+ propertyMapper.add(property);
+ }
+
+ @Override
+ public List list() {
+ return propertyMapper.list();
+ }
+}
diff --git a/work-modules/work-house/src/main/resources/bootstrap.yml b/work-modules/work-house/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..de08ee4
--- /dev/null
+++ b/work-modules/work-house/src/main/resources/bootstrap.yml
@@ -0,0 +1,55 @@
+# Tomcat
+server:
+ port: 10003
+# Spring
+spring:
+ main:
+ allow-circular-references: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ application:
+ # 应用名称
+ name: work-house
+ profiles:
+ # 环境配置
+ active: dev
+ cloud:
+ nacos:
+ discovery:
+ # 服务注册地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ config:
+ # 配置中心地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ # 配置文件格式
+ file-extension: yml
+ # 共享配置
+ shared-configs:
+ - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+fdfs:
+ # socket 连接时长
+ so-timeout: 1500
+ # 连接 tracker 服务器超时时长
+ connect-timeout: 600
+ # 这两个是你服务器的 IP 地址，注意 23000 端口也要打开，阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流
+ tracker-list: 121.36.202.181:22122
+ web-server-url: 121.36.202.181:8888
+ pool:
+ jmx-enabled: false
+ # 生成缩略图
+ thumb-image:
+ height: 500
+ width: 500
+
+aliyun:
+ oss:
+ file:
+ bucketName: arklorse
+ endpoint: oss-cn-shanghai.aliyuncs.com
+ AccessKeyId: LTAI5tKXvCvwq7hKpZgsY2hk
+ AccessKeySecret: HaOTCePEpeLNukQL3jhR6DZu9CAnmA
diff --git a/work-modules/work-house/src/main/resources/mapper/PersonMapper.xml b/work-modules/work-house/src/main/resources/mapper/PersonMapper.xml
new file mode 100644
index 0000000..18eeb63
--- /dev/null
+++ b/work-modules/work-house/src/main/resources/mapper/PersonMapper.xml
@@ -0,0 +1,13 @@
+
+
+
+
+
+
+
+ insert into t_person(person_name, id_card, gender, age, property_id)
+ values (#{personName}, #{idCard}, #{gender}, #{age}, #{propertyId})
+
+
diff --git a/work-modules/work-house/src/main/resources/mapper/PropertyMapper.xml b/work-modules/work-house/src/main/resources/mapper/PropertyMapper.xml
new file mode 100644
index 0000000..91c1e6b
--- /dev/null
+++ b/work-modules/work-house/src/main/resources/mapper/PropertyMapper.xml
@@ -0,0 +1,30 @@
+
+
+
+
+
+
+
+ insert into t_property(property_name, district) values (#{propertyName},#{district})
+
+
+
+
diff --git a/work-modules/work-user/pom.xml b/work-modules/work-user/pom.xml
new file mode 100644
index 0000000..557228e
--- /dev/null
+++ b/work-modules/work-user/pom.xml
@@ -0,0 +1,52 @@
+
+
+ 4.0.0
+
+ com.bwie
+ pms
+ 1.0-SNAPSHOT
+ ../../pom.xml
+
+
+ work-user
+
+
+
+
+ com.bwie
+ work-common
+ 1.0-SNAPSHOT
+
+
+
+ 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/work-modules/work-user/src/main/java/com/bwie/user/UserApplication.java b/work-modules/work-user/src/main/java/com/bwie/user/UserApplication.java
new file mode 100644
index 0000000..69f4091
--- /dev/null
+++ b/work-modules/work-user/src/main/java/com/bwie/user/UserApplication.java
@@ -0,0 +1,19 @@
+package com.bwie.user;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@SpringBootApplication
+@EnableDiscoveryClient
+public class UserApplication {
+ public static void main(String[] args) {
+ SpringApplication.run(UserApplication.class);
+ }
+}
diff --git a/work-modules/work-user/src/main/java/com/bwie/user/controller/UserController.java b/work-modules/work-user/src/main/java/com/bwie/user/controller/UserController.java
new file mode 100644
index 0000000..942cc43
--- /dev/null
+++ b/work-modules/work-user/src/main/java/com/bwie/user/controller/UserController.java
@@ -0,0 +1,27 @@
+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.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@RestController
+public class UserController {
+
+ @Autowired
+ private UserService userService;
+
+ @PostMapping("/findByName/{username}")
+ public Result findByName(@PathVariable("username") String username){
+ return Result.success(userService.findByName(username));
+ }
+}
diff --git a/work-modules/work-user/src/main/java/com/bwie/user/mapper/UserMapper.java b/work-modules/work-user/src/main/java/com/bwie/user/mapper/UserMapper.java
new file mode 100644
index 0000000..158d318
--- /dev/null
+++ b/work-modules/work-user/src/main/java/com/bwie/user/mapper/UserMapper.java
@@ -0,0 +1,21 @@
+package com.bwie.user.mapper;
+
+import com.bwie.common.domain.User;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * @Description TODO
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Version 1.0
+ */
+@Mapper
+public interface UserMapper {
+ /**
+ * 根据用户名查询用户
+ * @param username
+ * @return
+ */
+ User findByName(@Param("username") String username);
+}
diff --git a/work-modules/work-user/src/main/java/com/bwie/user/service/UserService.java b/work-modules/work-user/src/main/java/com/bwie/user/service/UserService.java
new file mode 100644
index 0000000..4ecdc37
--- /dev/null
+++ b/work-modules/work-user/src/main/java/com/bwie/user/service/UserService.java
@@ -0,0 +1,18 @@
+package com.bwie.user.service;
+
+import com.bwie.common.domain.User;
+
+/**
+ * @Description TODO
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Version 1.0
+ */
+public interface UserService {
+ /**
+ * 根据用户名查询用户
+ * @param username
+ * @return
+ */
+ User findByName(String username);
+}
diff --git a/work-modules/work-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java b/work-modules/work-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java
new file mode 100644
index 0000000..8494116
--- /dev/null
+++ b/work-modules/work-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java
@@ -0,0 +1,25 @@
+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.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author LiYonJie
+ * @Date 2024/1/14
+ * @Description TODO
+ * @Version 1.0
+ */
+@Service
+public class UserServiceImpl implements UserService {
+
+ @Autowired
+ private UserMapper userMapper;
+
+ @Override
+ public User findByName(String username) {
+ return userMapper.findByName(username);
+ }
+}
diff --git a/work-modules/work-user/src/main/resources/bootstrap.yml b/work-modules/work-user/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..9560c3b
--- /dev/null
+++ b/work-modules/work-user/src/main/resources/bootstrap.yml
@@ -0,0 +1,55 @@
+# Tomcat
+server:
+ port: 10002
+# Spring
+spring:
+ main:
+ allow-circular-references: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ application:
+ # 应用名称
+ name: work-user
+ profiles:
+ # 环境配置
+ active: dev
+ cloud:
+ nacos:
+ discovery:
+ # 服务注册地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ config:
+ # 配置中心地址
+ server-addr: 192.168.73.129:8848
+ username: nacos
+ password: nacos
+ # 配置文件格式
+ file-extension: yml
+ # 共享配置
+ shared-configs:
+ - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+fdfs:
+ # socket 连接时长
+ so-timeout: 1500
+ # 连接 tracker 服务器超时时长
+ connect-timeout: 600
+ # 这两个是你服务器的 IP 地址，注意 23000 端口也要打开，阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流
+ tracker-list: 121.36.202.181:22122
+ web-server-url: 121.36.202.181:8888
+ pool:
+ jmx-enabled: false
+ # 生成缩略图
+ thumb-image:
+ height: 500
+ width: 500
+
+aliyun:
+ oss:
+ file:
+ bucketName: arklorse
+ endpoint: oss-cn-shanghai.aliyuncs.com
+ AccessKeyId: LTAI5tKXvCvwq7hKpZgsY2hk
+ AccessKeySecret: HaOTCePEpeLNukQL3jhR6DZu9CAnmA
diff --git a/work-modules/work-user/src/main/resources/mapper/UserMapper.xml b/work-modules/work-user/src/main/resources/mapper/UserMapper.xml
new file mode 100644
index 0000000..066d2a9
--- /dev/null
+++ b/work-modules/work-user/src/main/resources/mapper/UserMapper.xml
@@ -0,0 +1,12 @@
+
+
+
+
+
+
+
+