From 4868860bb3435ad73092bf2ef5954961394f2604 Mon Sep 17 00:00:00 2001
From: wxy <14293288+zysysys@user.noreply.gitee.com>
Date: Thu, 1 Aug 2024 09:25:51 +0800
Subject: [PATCH] =?UTF-8?q?81=E6=97=A5=E8=80=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.gitignore | 38 ++
.idea/$PROJECT_FILE$ | 468 ++++++++++++++++++
.idea/.gitignore | 8 +
.idea/encodings.xml | 11 +
.idea/inspectionProfiles/Project_Default.xml | 5 +
.idea/misc.xml | 34 ++
.idea/qaplug_profiles.xml | 465 +++++++++++++++++
.idea/setting.xml | 8 +
.idea/vcs.xml | 6 +
boot-common/pom.xml | 116 +++++
.../com/bwie/common/constants/Constants.java | 18 +
.../bwie/common/constants/JwtConstants.java | 29 ++
.../bwie/common/constants/QueueConstants.java | 15 +
.../constants/RabbitMQOneConstants.java | 18 +
.../constants/RabbitMQTwoConstants.java | 18 +
.../bwie/common/constants/TokenConstants.java | 24 +
.../com/bwie/common/domain/pojo/User.java | 27 +
.../com/bwie/common/result/PageResult.java | 34 ++
.../java/com/bwie/common/result/Result.java | 84 ++++
.../java/com/bwie/common/utils/HttpUtils.java | 311 ++++++++++++
.../java/com/bwie/common/utils/IpUtils.java | 312 ++++++++++++
.../java/com/bwie/common/utils/JwtUtils.java | 109 ++++
.../java/com/bwie/common/utils/MsgUtil.java | 64 +++
.../com/bwie/common/utils/StringUtils.java | 68 +++
.../com/bwie/common/utils/TelSmsUtils.java | 64 +++
moudles/boot-goods/pom.xml | 76 +++
.../java/com/bwie/xxxxxx/Application.java | 15 +
.../xxxxxx/controller/UserController.java | 39 ++
.../com/bwie/xxxxxx/mapper/UserMapper.java | 16 +
.../com/bwie/xxxxxx/service/UserService.java | 14 +
.../xxxxxx/service/impl/UserServiceImpl.java | 35 ++
.../java/com/bwie/xxxxxx/util/FastUtil.java | 56 +++
.../src/main/resources/bootstrap.yml | 41 ++
.../src/main/resources/mapper/XXXmapper.xml | 5 +
moudles/pom.xml | 86 ++++
pom.xml | 66 +++
36 files changed, 2803 insertions(+)
create mode 100644 .gitignore
create mode 100644 .idea/$PROJECT_FILE$
create mode 100644 .idea/.gitignore
create mode 100644 .idea/encodings.xml
create mode 100644 .idea/inspectionProfiles/Project_Default.xml
create mode 100644 .idea/misc.xml
create mode 100644 .idea/qaplug_profiles.xml
create mode 100644 .idea/setting.xml
create mode 100644 .idea/vcs.xml
create mode 100644 boot-common/pom.xml
create mode 100644 boot-common/src/main/java/com/bwie/common/constants/Constants.java
create mode 100644 boot-common/src/main/java/com/bwie/common/constants/JwtConstants.java
create mode 100644 boot-common/src/main/java/com/bwie/common/constants/QueueConstants.java
create mode 100644 boot-common/src/main/java/com/bwie/common/constants/RabbitMQOneConstants.java
create mode 100644 boot-common/src/main/java/com/bwie/common/constants/RabbitMQTwoConstants.java
create mode 100644 boot-common/src/main/java/com/bwie/common/constants/TokenConstants.java
create mode 100644 boot-common/src/main/java/com/bwie/common/domain/pojo/User.java
create mode 100644 boot-common/src/main/java/com/bwie/common/result/PageResult.java
create mode 100644 boot-common/src/main/java/com/bwie/common/result/Result.java
create mode 100644 boot-common/src/main/java/com/bwie/common/utils/HttpUtils.java
create mode 100644 boot-common/src/main/java/com/bwie/common/utils/IpUtils.java
create mode 100644 boot-common/src/main/java/com/bwie/common/utils/JwtUtils.java
create mode 100644 boot-common/src/main/java/com/bwie/common/utils/MsgUtil.java
create mode 100644 boot-common/src/main/java/com/bwie/common/utils/StringUtils.java
create mode 100644 boot-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
create mode 100644 moudles/boot-goods/pom.xml
create mode 100644 moudles/boot-goods/src/main/java/com/bwie/xxxxxx/Application.java
create mode 100644 moudles/boot-goods/src/main/java/com/bwie/xxxxxx/controller/UserController.java
create mode 100644 moudles/boot-goods/src/main/java/com/bwie/xxxxxx/mapper/UserMapper.java
create mode 100644 moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/UserService.java
create mode 100644 moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/impl/UserServiceImpl.java
create mode 100644 moudles/boot-goods/src/main/java/com/bwie/xxxxxx/util/FastUtil.java
create mode 100644 moudles/boot-goods/src/main/resources/bootstrap.yml
create mode 100644 moudles/boot-goods/src/main/resources/mapper/XXXmapper.xml
create mode 100644 moudles/pom.xml
create mode 100644 pom.xml
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..5ff6309
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
\ No newline at end of file
diff --git a/.idea/$PROJECT_FILE$ b/.idea/$PROJECT_FILE$
new file mode 100644
index 0000000..c1ce1bb
--- /dev/null
+++ b/.idea/$PROJECT_FILE$
@@ -0,0 +1,468 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ 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..688dc1a
--- /dev/null
+++ b/.idea/encodings.xml
@@ -0,0 +1,11 @@
+
+
+
+
+
+
+
+
+
+
+
\ 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..9fc3d5f
--- /dev/null
+++ b/.idea/misc.xml
@@ -0,0 +1,34 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 用户定义
+
+
+
+
+
+
+
+
+
+
+
+
\ 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/.idea/setting.xml b/.idea/setting.xml
new file mode 100644
index 0000000..ed05fd8
--- /dev/null
+++ b/.idea/setting.xml
@@ -0,0 +1,8 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/vcs.xml b/.idea/vcs.xml
new file mode 100644
index 0000000..94a25f7
--- /dev/null
+++ b/.idea/vcs.xml
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/boot-common/pom.xml b/boot-common/pom.xml
new file mode 100644
index 0000000..fa72707
--- /dev/null
+++ b/boot-common/pom.xml
@@ -0,0 +1,116 @@
+
+
+ 4.0.0
+
+ com.bwie
+ spring81
+ 1.0-SNAPSHOT
+
+
+ boot-common
+
+
+ 17
+ 17
+ UTF-8
+
+
+
+
+
+
+
+
+
+ javax.servlet
+ javax.servlet-api
+
+
+ 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.springframework.boot
+ spring-boot-starter-amqp
+
+
+ com.baomidou
+ mybatis-plus-annotation
+ 3.5.6
+ compile
+
+
+
+
diff --git a/boot-common/src/main/java/com/bwie/common/constants/Constants.java b/boot-common/src/main/java/com/bwie/common/constants/Constants.java
new file mode 100644
index 0000000..2fdc9fe
--- /dev/null
+++ b/boot-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/boot-common/src/main/java/com/bwie/common/constants/JwtConstants.java b/boot-common/src/main/java/com/bwie/common/constants/JwtConstants.java
new file mode 100644
index 0000000..03692c1
--- /dev/null
+++ b/boot-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/boot-common/src/main/java/com/bwie/common/constants/QueueConstants.java b/boot-common/src/main/java/com/bwie/common/constants/QueueConstants.java
new file mode 100644
index 0000000..2c4c3c2
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/constants/QueueConstants.java
@@ -0,0 +1,15 @@
+package com.bwie.common.constants;
+
+/**
+ * @Project boot-month
+ * @Author 张子豪
+ * @Date 2023/9/6 10:06-+
+ * @Description
+ */
+public class QueueConstants {
+
+ public static final String SEND_CODE_QUEUE = "send_code_queue";
+ public static final String SEND_CODE_PREVENT_REPEAT_ID = "send_code_prevent_repeat_id:";
+ public static final String BLOG_UPDATE_QUEUE = "blog_update_queue";
+ public static final String BLOG_UPDATE_PREVENT_REPEAT_ID = "blog_update_prevent_repeat_id:";
+}
diff --git a/boot-common/src/main/java/com/bwie/common/constants/RabbitMQOneConstants.java b/boot-common/src/main/java/com/bwie/common/constants/RabbitMQOneConstants.java
new file mode 100644
index 0000000..a05740c
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/constants/RabbitMQOneConstants.java
@@ -0,0 +1,18 @@
+package com.bwie.common.constants;
+
+/**
+ * Clazz:2103A
+ * Name :FYSN
+ * Desc :世界上只有一种英雄主义。那就是认清生活的真相后，仍然热爱生活。--罗曼·罗兰
+ * Date :2023-08-20 20:37:02
+ */
+
+public class RabbitMQOneConstants {
+
+ //发送短消息队列名称
+ public static final String SEND_SHORT_MESSAGE_QUEUE_NAME = "send_short_message";
+
+ //查看的日志队列名称
+ public static final String QUERY_LOG_QUEUE_NAME = "query_log_message";
+
+}
diff --git a/boot-common/src/main/java/com/bwie/common/constants/RabbitMQTwoConstants.java b/boot-common/src/main/java/com/bwie/common/constants/RabbitMQTwoConstants.java
new file mode 100644
index 0000000..95361f1
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/constants/RabbitMQTwoConstants.java
@@ -0,0 +1,18 @@
+package com.bwie.common.constants;
+
+/**
+ * Clazz:2103A
+ * Name :FYSN
+ * Desc :世界上只有一种英雄主义。那就是认清生活的真相后，仍然热爱生活。--罗曼·罗兰
+ * Date :2023-08-20 20:37:02
+ */
+
+public class RabbitMQTwoConstants {
+
+ //发送消息队列名称
+ public static final String SEND_SMS_QUEUE = "send_sms_queue";
+
+ //添加消息队列名称日志
+ public static final String ADD_MESSAGE_QUEUE_NAME_LOG = "add_message_log";
+
+}
diff --git a/boot-common/src/main/java/com/bwie/common/constants/TokenConstants.java b/boot-common/src/main/java/com/bwie/common/constants/TokenConstants.java
new file mode 100644
index 0000000..1871fb7
--- /dev/null
+++ b/boot-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/boot-common/src/main/java/com/bwie/common/domain/pojo/User.java b/boot-common/src/main/java/com/bwie/common/domain/pojo/User.java
new file mode 100644
index 0000000..64e966b
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/domain/pojo/User.java
@@ -0,0 +1,27 @@
+package com.bwie.common.domain.pojo;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author: wangxinyuan
+ * @Date: 2024/8/1 上午8:39
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("user")
+public class User {
+
+ private Integer id;
+
+ private String userName;
+
+ private String userPwd;
+
+ private String email;
+
+ private String rule;
+}
diff --git a/boot-common/src/main/java/com/bwie/common/result/PageResult.java b/boot-common/src/main/java/com/bwie/common/result/PageResult.java
new file mode 100644
index 0000000..85ecdda
--- /dev/null
+++ b/boot-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/boot-common/src/main/java/com/bwie/common/result/Result.java b/boot-common/src/main/java/com/bwie/common/result/Result.java
new file mode 100644
index 0000000..6545526
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/result/Result.java
@@ -0,0 +1,84 @@
+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 success(String msg) {
+ return restResult(null, 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/boot-common/src/main/java/com/bwie/common/utils/HttpUtils.java b/boot-common/src/main/java/com/bwie/common/utils/HttpUtils.java
new file mode 100644
index 0000000..2e62648
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/utils/HttpUtils.java
@@ -0,0 +1,311 @@
+package com.bwie.common.utils;
+
+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;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+
+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;
+
+public class HttpUtils {
+ /**
+ * 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("https://")) {
+ sslClient(httpClient);
+ }
+
+ return httpClient;
+ }
+
+ private static void sslClient(HttpClient httpClient) {
+ try {
+ SSLContext ctx = SSLContext.getInstance("TLS");
+ X509TrustManager tm = new X509TrustManager() {
+ public X509Certificate[] getAcceptedIssuers() {
+ return null;
+ }
+ public void checkClientTrusted(X509Certificate[] xcs, String str) {
+
+ }
+ 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);
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/boot-common/src/main/java/com/bwie/common/utils/IpUtils.java b/boot-common/src/main/java/com/bwie/common/utils/IpUtils.java
new file mode 100644
index 0000000..20c1405
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/utils/IpUtils.java
@@ -0,0 +1,312 @@
+package com.bwie.common.utils;
+
+import javax.servlet.http.HttpServletRequest;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+/**
+ * 获取IP方法
+ *
+ * @author ruoyi
+ */
+public class IpUtils {
+ public final static String REGX_0_255 = "(25[0-5]|2[0-4]\\d|1\\d{2}|[1-9]\\d|\\d)";
+ // 匹配 ip
+ public final static String REGX_IP = "((" + REGX_0_255 + "\\.){3}" + REGX_0_255 + ")";
+ public final static String REGX_IP_WILDCARD = "(((\\*\\.){3}\\*)|(" + REGX_0_255 + "(\\.\\*){3})|(" + REGX_0_255 + "\\." + REGX_0_255 + ")(\\.\\*){2}" + "|((" + REGX_0_255 + "\\.){3}\\*))";
+ // 匹配网段
+ public final static String REGX_IP_SEG = "(" + REGX_IP + "\\-" + REGX_IP + ")";
+
+ /**
+ * 获取客户端IP
+ *
+ * @param request 请求对象
+ * @return IP地址
+ */
+ public static String getIpAddr(HttpServletRequest request) {
+ if (request == null) {
+ return "unknown";
+ }
+ String ip = request.getHeader("x-forwarded-for");
+ if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+ ip = request.getHeader("Proxy-Client-IP");
+ }
+ if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+ ip = request.getHeader("X-Forwarded-For");
+ }
+ if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+ ip = request.getHeader("WL-Proxy-Client-IP");
+ }
+ if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+ ip = request.getHeader("X-Real-IP");
+ }
+
+ if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+ ip = request.getRemoteAddr();
+ }
+
+ return "0:0:0:0:0:0:0:1".equals(ip) ? "127.0.0.1" : getMultistageReverseProxyIp(ip);
+ }
+
+ /**
+ * 检查是否为内部IP地址
+ *
+ * @param ip IP地址
+ * @return 结果
+ */
+ public static boolean internalIp(String ip) {
+ byte[] addr = textToNumericFormatV4(ip);
+ return internalIp(addr) || "127.0.0.1".equals(ip);
+ }
+
+ /**
+ * 检查是否为内部IP地址
+ *
+ * @param addr byte地址
+ * @return 结果
+ */
+ private static boolean internalIp(byte[] addr) {
+ if (StringUtils.isNull(addr) || addr.length < 2) {
+ return true;
+ }
+ final byte b0 = addr[0];
+ final byte b1 = addr[1];
+ // 10.x.x.x/8
+ final byte SECTION_1 = 0x0A;
+ // 172.16.x.x/12
+ final byte SECTION_2 = (byte) 0xAC;
+ final byte SECTION_3 = (byte) 0x10;
+ final byte SECTION_4 = (byte) 0x1F;
+ // 192.168.x.x/16
+ final byte SECTION_5 = (byte) 0xC0;
+ final byte SECTION_6 = (byte) 0xA8;
+ switch (b0) {
+ case SECTION_1:
+ return true;
+ case SECTION_2:
+ if (b1 >= SECTION_3 && b1 <= SECTION_4) {
+ return true;
+ }
+ case SECTION_5:
+ switch (b1) {
+ case SECTION_6:
+ return true;
+ }
+ default:
+ return false;
+ }
+ }
+
+ /**
+ * 将IPv4地址转换成字节
+ *
+ * @param text IPv4地址
+ * @return byte 字节
+ */
+ public static byte[] textToNumericFormatV4(String text) {
+ if (text.length() == 0) {
+ return null;
+ }
+
+ byte[] bytes = new byte[4];
+ String[] elements = text.split("\\.", -1);
+ try {
+ long l;
+ int i;
+ switch (elements.length) {
+ case 1:
+ l = Long.parseLong(elements[0]);
+ if ((l < 0L) || (l > 4294967295L)) {
+ return null;
+ }
+ bytes[0] = (byte) (int) (l >> 24 & 0xFF);
+ bytes[1] = (byte) (int) ((l & 0xFFFFFF) >> 16 & 0xFF);
+ bytes[2] = (byte) (int) ((l & 0xFFFF) >> 8 & 0xFF);
+ bytes[3] = (byte) (int) (l & 0xFF);
+ break;
+ case 2:
+ l = Integer.parseInt(elements[0]);
+ if ((l < 0L) || (l > 255L)) {
+ return null;
+ }
+ bytes[0] = (byte) (int) (l & 0xFF);
+ l = Integer.parseInt(elements[1]);
+ if ((l < 0L) || (l > 16777215L)) {
+ return null;
+ }
+ bytes[1] = (byte) (int) (l >> 16 & 0xFF);
+ bytes[2] = (byte) (int) ((l & 0xFFFF) >> 8 & 0xFF);
+ bytes[3] = (byte) (int) (l & 0xFF);
+ break;
+ case 3:
+ for (i = 0; i < 2; ++i) {
+ l = Integer.parseInt(elements[i]);
+ if ((l < 0L) || (l > 255L)) {
+ return null;
+ }
+ bytes[i] = (byte) (int) (l & 0xFF);
+ }
+ l = Integer.parseInt(elements[2]);
+ if ((l < 0L) || (l > 65535L)) {
+ return null;
+ }
+ bytes[2] = (byte) (int) (l >> 8 & 0xFF);
+ bytes[3] = (byte) (int) (l & 0xFF);
+ break;
+ case 4:
+ for (i = 0; i < 4; ++i) {
+ l = Integer.parseInt(elements[i]);
+ if ((l < 0L) || (l > 255L)) {
+ return null;
+ }
+ bytes[i] = (byte) (int) (l & 0xFF);
+ }
+ break;
+ default:
+ return null;
+ }
+ } catch (NumberFormatException e) {
+ return null;
+ }
+ return bytes;
+ }
+
+ /**
+ * 获取IP地址
+ *
+ * @return 本地IP地址
+ */
+ public static String getHostIp() {
+ try {
+ return InetAddress.getLocalHost().getHostAddress();
+ } catch (UnknownHostException e) {
+ }
+ return "127.0.0.1";
+ }
+
+ /**
+ * 获取主机名
+ *
+ * @return 本地主机名
+ */
+ public static String getHostName() {
+ try {
+ return InetAddress.getLocalHost().getHostName();
+ } catch (UnknownHostException e) {
+ }
+ return "未知";
+ }
+
+ /**
+ * 从多级反向代理中获得第一个非unknown IP地址
+ *
+ * @param ip 获得的IP地址
+ * @return 第一个非unknown IP地址
+ */
+ public static String getMultistageReverseProxyIp(String ip) {
+ // 多级反向代理检测
+ if (ip != null && ip.indexOf(",") > 0) {
+ final String[] ips = ip.trim().split(",");
+ for (String subIp : ips) {
+ if (false == isUnknown(subIp)) {
+ ip = subIp;
+ break;
+ }
+ }
+ }
+ return StringUtils.substring(ip, 0, 255);
+ }
+
+ /**
+ * 检测给定字符串是否为未知，多用于检测HTTP请求相关
+ *
+ * @param checkString 被检测的字符串
+ * @return 是否未知
+ */
+ public static boolean isUnknown(String checkString) {
+ return StringUtils.isBlank(checkString) || "unknown".equalsIgnoreCase(checkString);
+ }
+
+ /**
+ * 是否为IP
+ */
+ public static boolean isIP(String ip) {
+ return StringUtils.isNotBlank(ip) && ip.matches(REGX_IP);
+ }
+
+ /**
+ * 是否为IP，或 *为间隔的通配符地址
+ */
+ public static boolean isIpWildCard(String ip) {
+ return StringUtils.isNotBlank(ip) && ip.matches(REGX_IP_WILDCARD);
+ }
+
+ /**
+ * 检测参数是否在ip通配符里
+ */
+ public static boolean ipIsInWildCardNoCheck(String ipWildCard, String ip) {
+ String[] s1 = ipWildCard.split("\\.");
+ String[] s2 = ip.split("\\.");
+ boolean isMatchedSeg = true;
+ for (int i = 0; i < s1.length && !s1[i].equals("*"); i++) {
+ if (!s1[i].equals(s2[i])) {
+ isMatchedSeg = false;
+ break;
+ }
+ }
+ return isMatchedSeg;
+ }
+
+ /**
+ * 是否为特定格式如:“10.10.10.1-10.10.10.99”的ip段字符串
+ */
+ public static boolean isIPSegment(String ipSeg) {
+ return StringUtils.isNotBlank(ipSeg) && ipSeg.matches(REGX_IP_SEG);
+ }
+
+ /**
+ * 判断ip是否在指定网段中
+ */
+ public static boolean ipIsInNetNoCheck(String iparea, String ip) {
+ int idx = iparea.indexOf('-');
+ String[] sips = iparea.substring(0, idx).split("\\.");
+ String[] sipe = iparea.substring(idx + 1).split("\\.");
+ String[] sipt = ip.split("\\.");
+ long ips = 0L, ipe = 0L, ipt = 0L;
+ for (int i = 0; i < 4; ++i) {
+ ips = ips << 8 | Integer.parseInt(sips[i]);
+ ipe = ipe << 8 | Integer.parseInt(sipe[i]);
+ ipt = ipt << 8 | Integer.parseInt(sipt[i]);
+ }
+ if (ips > ipe) {
+ long t = ips;
+ ips = ipe;
+ ipe = t;
+ }
+ return ips <= ipt && ipt <= ipe;
+ }
+
+ /**
+ * 校验ip是否符合过滤串规则
+ *
+ * @param filter 过滤IP列表,支持后缀'*'通配,支持网段如:`10.10.10.1-10.10.10.99`
+ * @param ip 校验IP地址
+ * @return boolean 结果
+ */
+ public static boolean isMatchedIp(String filter, String ip) {
+ if (StringUtils.isEmpty(filter) || StringUtils.isEmpty(ip)) {
+ return false;
+ }
+ String[] ips = filter.split(";");
+ for (String iStr : ips) {
+ if (isIP(iStr) && iStr.equals(ip)) {
+ return true;
+ } else if (isIpWildCard(iStr) && ipIsInWildCardNoCheck(iStr, ip)) {
+ return true;
+ } else if (isIPSegment(iStr) && ipIsInNetNoCheck(iStr, ip)) {
+ return true;
+ }
+ }
+ return false;
+ }
+}
diff --git a/boot-common/src/main/java/com/bwie/common/utils/JwtUtils.java b/boot-common/src/main/java/com/bwie/common/utils/JwtUtils.java
new file mode 100644
index 0000000..f560aa9
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/utils/JwtUtils.java
@@ -0,0 +1,109 @@
+package com.bwie.common.utils;
+
+import com.bwie.common.constants.JwtConstants;
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.SignatureAlgorithm;
+
+import java.util.Map;
+
+/**
+ * @description: Jwt工具类
+ * @author DongZl
+ */
+public class JwtUtils {
+
+ /**
+ * 秘钥
+ */
+ public static String secret = JwtConstants.SECRET;
+
+ /**
+ * 从数据声明生成令牌
+ *
+ * @param claims 数据声明
+ * @return 令牌
+ */
+ public static String createToken(Map claims){
+ String token = Jwts.builder().setClaims(claims).signWith(SignatureAlgorithm.HS512, secret).compact();
+ return token;
+ }
+
+ /**
+ * 从令牌中获取数据声明
+ *
+ * @param token 令牌
+ * @return 数据声明
+ */
+ public static Claims parseToken(String token){
+ return Jwts.parser().setSigningKey(secret).parseClaimsJws(token).getBody();
+ }
+ /**
+ * 根据令牌获取用户标识
+ *
+ * @param token 令牌
+ * @return 用户ID
+ */
+ public static String getUserKey(String token){
+ Claims claims = parseToken(token);
+ return getValue(claims, JwtConstants.USER_KEY);
+ }
+ /**
+ * 根据令牌获取用户标识
+ *
+ * @param claims 身份信息
+ * @return 用户ID
+ */
+ public static String getUserKey(Claims claims){
+ return getValue(claims, JwtConstants.USER_KEY);
+ }
+ /**
+ * 根据令牌获取用户ID
+ *
+ * @param token 令牌
+ * @return 用户ID
+ */
+ public static String getUserId(String token){
+ Claims claims = parseToken(token);
+ return getValue(claims, JwtConstants.DETAILS_USER_ID);
+ }
+ /**
+ * 根据身份信息获取用户ID
+ *
+ * @param claims 身份信息
+ * @return 用户ID
+ */
+ public static String getUserId(Claims claims){
+ return getValue(claims, JwtConstants.DETAILS_USER_ID);
+ }
+ /**
+ * 根据令牌获取用户名
+ *
+ * @param token 令牌
+ * @return 用户名
+ */
+ public static String getUserName(String token){
+ Claims claims = parseToken(token);
+ return getValue(claims, JwtConstants.DETAILS_USERNAME);
+ }
+ /**
+ * 根据身份信息获取用户名
+ *
+ * @param claims 身份信息
+ * @return 用户名
+ */
+ public static String getUserName(Claims claims){
+ return getValue(claims, JwtConstants.DETAILS_USERNAME);
+ }
+ /**
+ * 根据身份信息获取键值
+ *
+ * @param claims 身份信息
+ * @param key 键
+ * @return 值
+ */
+ public static String getValue(Claims claims, String key){
+ Object obj = claims.get(key);
+ return obj == null ? "" : obj.toString();
+ }
+}
diff --git a/boot-common/src/main/java/com/bwie/common/utils/MsgUtil.java b/boot-common/src/main/java/com/bwie/common/utils/MsgUtil.java
new file mode 100644
index 0000000..6e518eb
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/utils/MsgUtil.java
@@ -0,0 +1,64 @@
+package com.bwie.common.utils;
+
+import org.apache.http.HttpResponse;
+import org.apache.http.util.EntityUtils;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author A3385
+ */
+@Component
+public class MsgUtil {
+ //取code
+
+
+ public String sendMsg(String phone,String code){
+ String result = null;
+ String host = "https://gyytz.market.alicloudapi.com";
+ String path = "/sms/smsSend";
+ String method = "POST";
+ String appcode = "033359549f644a32858017cd76df3f88";
+ Map headers = new HashMap();
+ //最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
+ headers.put("Authorization", "APPCODE " + appcode);
+ Map querys = new HashMap();
+ querys.put("mobile", phone);
+ querys.put("param", "**code**:"+code+",**minute**:5");
+
+//smsSignId（短信前缀）和templateId（短信模板），可登录国阳云控制台自助申请。参考文档：http://help.guoyangyun.com/Problem/Qm.html
+
+ querys.put("smsSignId", "2e65b1bb3d054466b82f0c9d125465e2");
+ querys.put("templateId", "908e94ccf08b4476ba6c876d13f084ad");
+ Map bodys = new HashMap();
+
+
+ try {
+ /**
+ * 重要提示如下:
+ * HttpUtils请从\r\n\t \t* https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/src/main/java/com/aliyun/api/gateway/demo/util/HttpUtils.java\r\n\t \t* 下载
+ *
+ * 相应的依赖请参照
+ * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/pom.xml
+ */
+ HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys);
+// System.out.println(response.toString());
+ //获取response的body
+ result = EntityUtils.toString(response.getEntity());
+ System.out.println(result);
+ //{
+ // "msg": "成功",
+ // "smsid": "16565614329364584123421", //批次号。可通过该ID查询发送状态或者回复短信。API接口可联系客服获取。
+ // "code": "0",
+ // "balance": "1234" //账户剩余次数
+ //}
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return result;
+ }
+}
diff --git a/boot-common/src/main/java/com/bwie/common/utils/StringUtils.java b/boot-common/src/main/java/com/bwie/common/utils/StringUtils.java
new file mode 100644
index 0000000..93c47fd
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/utils/StringUtils.java
@@ -0,0 +1,68 @@
+package com.bwie.common.utils;
+
+import org.springframework.util.AntPathMatcher;
+
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * @author DongZl
+ * @description: 字符串处理工具类
+ */
+public class StringUtils extends org.apache.commons.lang3.StringUtils {
+
+ /**
+ * * 判断一个对象是否为空
+ *
+ * @param object Object
+ * @return true：为空 false：非空
+ */
+ public static boolean isNull(Object object) {
+ return object == null;
+ }
+
+ /**
+ * * 判断一个Collection是否为空， 包含List，Set，Queue
+ *
+ * @param coll 要判断的Collection
+ * @return true：为空 false：非空
+ */
+ public static boolean isEmpty(Collection coll) {
+ return isNull(coll) || coll.isEmpty();
+ }
+
+ /**
+ * 查找指定字符串是否匹配指定字符串列表中的任意一个字符串
+ *
+ * @param str 指定字符串
+ * @param strs 需要检查的字符串数组
+ * @return 是否匹配
+ */
+ public static boolean matches(String str, List strs) {
+ if (isEmpty(str) || isEmpty(strs)) {
+ return false;
+ }
+ for (String pattern : strs) {
+ if (isMatch(pattern, str))
+ {
+ return true;
+ }
+ }
+ return false;
+ }
+
+ /**
+ * 判断url是否与规则配置:
+ * ? 表示单个字符;
+ * * 表示一层路径内的任意字符串，不可跨层级;
+ * ** 表示任意层路径;
+ *
+ * @param pattern 匹配规则
+ * @param url 需要匹配的url
+ * @return
+ */
+ public static boolean isMatch(String pattern, String url) {
+ AntPathMatcher matcher = new AntPathMatcher();
+ return matcher.match(pattern, url);
+ }
+}
diff --git a/boot-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java b/boot-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
new file mode 100644
index 0000000..daed20d
--- /dev/null
+++ b/boot-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
@@ -0,0 +1,64 @@
+//
+// Source code recreated from a .class file by IntelliJ IDEA
+// (powered by FernFlower decompiler)
+//
+
+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 java.util.Map;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+public class TelSmsUtils {
+ private static final Logger log = LogManager.getLogger(TelSmsUtils.class);
+ private static String accessKeyId = "LTAI5tQWdAodc1EJ1doShoW4";
+ private static String accessKeySecret = "9MbfDBJ3Efqc6iN5yPFX0zq3ZErsII";
+ private static String templateCode = "SMS0001";
+ private static String endpoint = "dysmsapi.aliyuncs.com";
+ private static String signName = "登录验证";
+ private static Client client;
+
+ public TelSmsUtils() {
+ }
+
+ private static Client initClient() throws Exception {
+ Config config = (new Config()).setAccessKeyId(accessKeyId).setAccessKeySecret(accessKeySecret);
+ config.endpoint = endpoint;
+ return new Client(config);
+ }
+
+ 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 var6) {
+ Exception e = var6;
+ log.error("短信发送异常，手机号：【{}】，短信内容：【{}】，异常信息：【{}】", tel, sendDataMap, e);
+ }
+
+ return JSONObject.toJSONString(sendSmsResponse.getBody());
+ }
+
+ static {
+ log.info("初始化短信服务开始");
+ long startTime = System.currentTimeMillis();
+
+ try {
+ client = initClient();
+ log.info("初始化短信成功：{}", signName);
+ } catch (Exception var3) {
+ Exception e = var3;
+ e.printStackTrace();
+ }
+
+ log.info("初始化短信服务结束：耗时：{}MS", System.currentTimeMillis() - startTime);
+ }
+}
diff --git a/moudles/boot-goods/pom.xml b/moudles/boot-goods/pom.xml
new file mode 100644
index 0000000..e2ea754
--- /dev/null
+++ b/moudles/boot-goods/pom.xml
@@ -0,0 +1,76 @@
+
+
+ 4.0.0
+
+ com.bwie
+ moudles
+ 1.0-SNAPSHOT
+
+
+ boot-goods
+
+
+ 17
+ 17
+ UTF-8
+
+
+
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ 3.5.1
+
+
+
+
+ com.bwie
+ boot-common
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ com.alibaba
+ druid-spring-boot-starter
+ 1.2.8
+
+
+
+ mysql
+ mysql-connector-java
+
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ 2.2.2
+
+
+
+ com.github.pagehelper
+ pagehelper-spring-boot-starter
+ 1.4.1
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+ com.github.tobato
+ fastdfs-client
+ 1.26.5
+
+
+
+
+
diff --git a/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/Application.java b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/Application.java
new file mode 100644
index 0000000..4ea07c5
--- /dev/null
+++ b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/Application.java
@@ -0,0 +1,15 @@
+package com.bwie.xxxxxx;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @Author: wangxinyuan
+ * @Date: 2024/8/1 上午8:46
+ */
+@SpringBootApplication
+public class Application {
+ public static void main(String[] args) {
+ SpringApplication.run(Application.class);
+ }
+}
diff --git a/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/controller/UserController.java b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/controller/UserController.java
new file mode 100644
index 0000000..600d90f
--- /dev/null
+++ b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/controller/UserController.java
@@ -0,0 +1,39 @@
+package com.bwie.xxxxxx.controller;
+
+import com.bwie.common.domain.pojo.User;
+import com.bwie.xxxxxx.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author: wangxinyuan
+ * @Date: 2024/8/1 上午8:40
+ */
+@RestController
+@RequestMapping("/user")
+public class UserController {
+
+
+ @Autowired
+ private UserService userService;
+
+
+ @PostMapping("/login")
+ public ResponseEntity login(@RequestParam String username, @RequestParam String password) {
+ User user = userService.login(username, password);
+ if (user != null && userService.checkRole(user)) {
+ return ResponseEntity.ok("管理员登录成功");
+ } else {
+ return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body("用户名或密码错误");
+ }
+ }
+
+
+
+
+}
diff --git a/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/mapper/UserMapper.java b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/mapper/UserMapper.java
new file mode 100644
index 0000000..8ea2216
--- /dev/null
+++ b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/mapper/UserMapper.java
@@ -0,0 +1,16 @@
+package com.bwie.xxxxxx.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.bwie.common.domain.pojo.User;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @Author: wangxinyuan
+ * @Date: 2024/8/1 上午8:40
+ */
+@Mapper
+public interface UserMapper extends BaseMapper {
+
+
+
+}
diff --git a/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/UserService.java b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/UserService.java
new file mode 100644
index 0000000..61a152c
--- /dev/null
+++ b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/UserService.java
@@ -0,0 +1,14 @@
+package com.bwie.xxxxxx.service;
+
+import com.bwie.common.domain.pojo.User;
+
+/**
+ * @Author: wangxinyuan
+ * @Date: 2024/8/1 上午8:43
+ */
+public interface UserService {
+
+ User login(String username, String password);
+
+ boolean checkRole(User user);
+}
diff --git a/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/impl/UserServiceImpl.java b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/impl/UserServiceImpl.java
new file mode 100644
index 0000000..7223445
--- /dev/null
+++ b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/service/impl/UserServiceImpl.java
@@ -0,0 +1,35 @@
+package com.bwie.xxxxxx.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.bwie.common.domain.pojo.User;
+import com.bwie.xxxxxx.mapper.UserMapper;
+import com.bwie.xxxxxx.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author: wangxinyuan
+ * @Date: 2024/8/1 上午8:43
+ */
+@Service
+public class UserServiceImpl implements UserService {
+
+
+ @Autowired
+ private UserMapper userMapper;
+
+
+
+ @Override
+ public User login(String username, String password) {
+ QueryWrapper queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("user_name", username).eq("user_pwd", password);
+ return userMapper.selectOne(queryWrapper);
+}
+
+
+ @Override
+ public boolean checkRole(User user) {
+ return user.getUserName().equals("admin") && user.getUserPwd().equals("123");
+ }
+}
diff --git a/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/util/FastUtil.java b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/util/FastUtil.java
new file mode 100644
index 0000000..934da83
--- /dev/null
+++ b/moudles/boot-goods/src/main/java/com/bwie/xxxxxx/util/FastUtil.java
@@ -0,0 +1,56 @@
+package com.bwie.xxxxxx.util;
+
+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.stereotype.Component;
+import org.springframework.util.StringUtils;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+
+/**
+ * @BelongsProject: 0107day02
+ * @BelongsPackage: com.bw.config
+ * @Author: zhupengfei
+ * @CreateTime: 2023-02-01 08:52
+ */
+@Component
+public class FastUtil {
+ private static final Logger log = LoggerFactory.getLogger(FastUtil.class);
+
+ @Resource
+ private FastFileStorageClient storageClient ;
+
+ /**
+ * 上传文件
+ */
+ public String upload(MultipartFile multipartFile) throws Exception{
+ String originalFilename = multipartFile.getOriginalFilename().
+ substring(multipartFile.getOriginalFilename().
+ lastIndexOf(".") + 1);
+ StorePath storePath = this.storageClient.uploadImageAndCrtThumbImage(
+ multipartFile.getInputStream(),
+ multipartFile.getSize(),originalFilename , null);
+ return storePath.getFullPath() ;
+ }
+ /**
+ * 删除文件
+ */
+ public String deleteFile(String fileUrl) {
+ if (StringUtils.isEmpty(fileUrl)) {
+ log.info("fileUrl == >>文件路径为空...");
+ return "文件路径不能为空";
+ }
+ try {
+ StorePath storePath = StorePath.parseFromUrl(fileUrl);
+ storageClient.deleteFile(storePath.getGroup(), storePath.getPath());
+ } catch (Exception e) {
+ log.error(e.getMessage());
+ }
+ return "删除成功";
+ }
+
+}
diff --git a/moudles/boot-goods/src/main/resources/bootstrap.yml b/moudles/boot-goods/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..5d6d54d
--- /dev/null
+++ b/moudles/boot-goods/src/main/resources/bootstrap.yml
@@ -0,0 +1,41 @@
+# Tomcat
+server:
+ port: 9004
+# Spring
+spring:
+ main:
+ allow-circular-references: true
+ jackson:
+ date-format: yyyy-MM-dd HH:mm:ss
+ time-zone: GMT+8
+ application:
+ # 应用名称
+ name: boot-goods
+ profiles:
+ # 环境配置use
+ active: dev
+ cloud:
+ nacos:
+ discovery:
+ # 服务注册地址
+ server-addr: 124.222.182.195:8848
+ config:
+ # 配置中心地址
+ server-addr: 124.222.182.195:8848
+ # 配置文件格式
+ file-extension: yml
+ # 共享配置
+ shared-configs:
+ - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+fdfs:
+ so-timeout: 1500 # socket 连接时长
+ connect-timeout: 600 # 连接 tracker 服务器超时时长
+ # 这两个是你服务器的 IP 地址，注意 23000 端口也要打开，阿里云服务器记得配置安全组。tracker 要和 stroage 服务进行交流
+ tracker-list: 124.222.182.195:22122
+ web-server-url: 124.222.182.195:8888
+ pool:
+ jmx-enabled: false
+ # 生成缩略图
+ thumb-image:
+ height: 500
+ width: 500
diff --git a/moudles/boot-goods/src/main/resources/mapper/XXXmapper.xml b/moudles/boot-goods/src/main/resources/mapper/XXXmapper.xml
new file mode 100644
index 0000000..2fbf085
--- /dev/null
+++ b/moudles/boot-goods/src/main/resources/mapper/XXXmapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
diff --git a/moudles/pom.xml b/moudles/pom.xml
new file mode 100644
index 0000000..d9f6a87
--- /dev/null
+++ b/moudles/pom.xml
@@ -0,0 +1,86 @@
+
+
+ 4.0.0
+
+ com.bwie
+ spring81
+ 1.0-SNAPSHOT
+
+
+ moudles
+ pom
+
+ boot-goods
+
+
+
+ 17
+ 17
+ UTF-8
+
+
+
+
+
+ com.bwie
+ boot-common
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ com.alibaba
+ druid-spring-boot-starter
+ 1.2.8
+
+
+
+ mysql
+ mysql-connector-java
+
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ 2.2.2
+
+
+
+ com.github.pagehelper
+ pagehelper-spring-boot-starter
+ 1.4.1
+
+
+
+ org.springframework.boot
+ spring-boot-starter-amqp
+
+
+
+ org.elasticsearch.client
+ elasticsearch-rest-high-level-client
+
+
+
+ org.springframework
+ spring-web
+ 5.3.14
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+ com.github.tobato
+ fastdfs-client
+ 1.26.5
+
+
+
+
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..b8ec9ed
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,66 @@
+
+
+ 4.0.0
+
+ com.bwie
+ spring81
+ 1.0-SNAPSHOT
+ pom
+
+ boot-common
+ moudles
+
+
+
+ 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
+ boot-common
+ 1.0-SNAPSHOT
+
+
+
+
+
+