zhanghaining
/
zhn-cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

first commit

main
张海宁 2024-02-29 17:31:01 +08:00
commit 9f8c25fc7d
174 changed files with 6000 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
.gitignore vendored 100644
View File

8
.idea/.gitignore vendored 100644
View File

@ -0,0 +1,8 @@
# 默认忽略的文件
/shelf/
/workspace.xml
# 基于编辑器的 HTTP 客户端请求
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

26
.idea/compiler.xml 100644
View File

@ -0,0 +1,26 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile default="true" name="Default" enabled="true" />
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="zhn-auth" />
<module name="zhn-common" />
<module name="zhn-gateway" />
<module name="zhn-system" />
</profile>
</annotationProcessing>
<bytecodeTargetLevel target="17" />
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="zhn-auth" options="-parameters" />
<module name="zhn-common" options="-parameters" />
<module name="zhn-gateway" options="-parameters" />
<module name="zhn-system" options="-parameters" />
</option>
</component>
</project>

13
.idea/encodings.xml 100644
View File

@ -0,0 +1,13 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/zhn-auth/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/zhn-common/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/zhn-gateway/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/zhn-modules/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/zhn-modules/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/zhn-modules/zhn-system/src/main/java" charset="UTF-8" />
</component>
</project>

20
.idea/jarRepositories.xml 100644
View File

@ -0,0 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="http://maven.aliyun.com/nexus/content/repositories/central/" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>

15
.idea/misc.xml 100644
View File

@ -0,0 +1,15 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CodeInsightWorkspaceSettings">
<option name="optimizeImportsOnTheFly" value="true" />
</component>
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>

1
README.md 100644
View File

@ -0,0 +1 @@
# 用于自动化部署的测试项目

57
devops/build/build.sh 100644
View File

@ -0,0 +1,57 @@
#!/bin/bash
echo "==============build begin 当前环境:【$ENV】=============="
if [[ "$ENV" = "" ]]; then
ENV=$env
fi
if [[ $ENV == 'test' ]]; then
HUB_USERNAME=wlf19941002
HUB_PASSWORD=901002wei
UCLOUD_HUB=registry.cn-hangzhou.aliyuncs.com/weilingfeng-dev
elif [[ $ENV == 'prod' ]]; then
HUB_USERNAME=wlf19941002
HUB_PASSWORD=901002wei
UCLOUD_HUB=registry.cn-hangzhou.aliyuncs.com/weilingfeng-prod
else
echo 'Please enter right environment! eg: test || prod(master or v/V*.*.* branch)'
exit 1
fi
#编译后将包拷贝至新建的publish目录下，gitlab上可以在对应节点下载包。
mvn clean package -Dmaven.test.skip=true || exit 1 && \
echo 'build successful!'
# 构建 TAG 变量
TAG="${CI_COMMIT_SHA:0:4}${CI_PIPELINE_ID:0:4}"
# 打印 TAG 变量的值
echo "TAG value: $TAG"
ZHN_AUTH=zhn-auth
ZHN_GATEWAY=zhn-gateway
ZHN_SYSTEM=zhn-system
#构建镜像
docker build -f zhn-gateway/Dockerfile -t $UCLOUD_HUB/${ZHN_GATEWAY}:$TAG .
docker build -f zhn-auth/Dockerfile -t $UCLOUD_HUB/${ZHN_AUTH}:$TAG .
docker build -f zhn-modules/zhn-system/Dockerfile -t $UCLOUD_HUB/${ZHN_SYSTEM}:$TAG .
#镜像仓库登录
docker login registry.cn-hangzhou.aliyuncs.com --username $HUB_USERNAME --password $HUB_PASSWORD
#推送镜像
docker push $UCLOUD_HUB/${ZHN_AUTH}:$TAG
docker push $UCLOUD_HUB/${ZHN_GATEWAY}:$TAG
docker push $UCLOUD_HUB/${ZHN_SYSTEM}:$TAG
#删除镜像
docker rmi -f $UCLOUD_HUB/${ZHN_AUTH}:$TAG
docker rmi -f $UCLOUD_HUB/${ZHN_GATEWAY}:$TAG
docker push $UCLOUD_HUB/${ZHN_SYSTEM}:$TAG
#删除none 镜像
docker image prune -f --filter "dangling=true"
echo "$UCLOUD_HUB/${ZHN_AUTH}:$TAG"
echo "$UCLOUD_HUB/${ZHN_GATEWAY}:$TAG"
echo "$UCLOUD_HUB/${ZHN_SYSTEM}:$TAG"
echo "==============build end!!!================"

47
devops/release/deploy.sh 100644
View File

@ -0,0 +1,47 @@
#!/bin/bash
echo "==============deploy begin!!!================"
UCLOUD_HUB=registry.cn-hangzhou.aliyuncs.com/weilingfeng-dev
UCLOUD_HUB=registry.cn-hangzhou.aliyuncs.com/weilingfeng-prod
TAG="${CI_COMMIT_SHA:0:4}${CI_PIPELINE_ID:0:4}"
ZHN_GATEWAY=zhn-gateway
ZHN_AUTH=zhn-auth
ZHN_SYSTEM=zhn-system
#停止
if [ -n "$(docker ps -a -q -f name=$ZHN_GATEWAY)" ]; then
docker rm -f $ZHN_GATEWAY
echo "$ZHN_GATEWAY 已经停止"
fi
if [ -n "$(docker ps -a -q -f name=$ZHN_AUTH)" ]; then
docker rm -f $ZHN_AUTH
echo "$ZHN_AUTH 已经停止"
fi
if [ -n "$(docker ps -a -q -f name=$ZHN_SYSTEM)" ]; then
docker rm -f $ZHN_SYSTEM
echo "$ZHN_SYSTEM 已经停止"
fi
#删除所有镜像
docker images | grep "zhn-gateway" | awk '{print $3}' | while read image_id; do docker rmi -f "$image_id"; done
docker images | grep "zhn-auth" | awk '{print $3}' | while read image_id; do docker rmi -f "$image_id"; done
docker images | grep "zhn-system" | awk '{print $3}' | while read image_id; do docker rmi -f "$image_id"; done
#拉取镜像
docker pull $UCLOUD_HUB/${ZHN_AUTH}:$TAG || exit 1
docker pull $UCLOUD_HUB/${ZHN_SYSTEM}:$TAG || exit 1
docker pull $UCLOUD_HUB/${ZHN_GATEWAY}:$TAG || exit 1
#发布
docker run -itd -p 8080:8080 --name=zhn-gateway --restart=always $UCLOUD_HUB/${ZHN_GATEWAY}:$TAG || exit 1
docker run -itd -p 9200:9200 --name=zhn-auth --restart=always $UCLOUD_HUB/${ZHN_AUTH}:$TAG || exit 1
docker run -itd -p 9201:9201 --name=zhn-system --restart=always $UCLOUD_HUB/${ZHN_SYSTEM}:$TAG || exit 1
echo "==============deploy success end!!!=================="

61
pom.xml 100644
View File

@ -0,0 +1,61 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.zhn</groupId>
<artifactId>zhn-dev</artifactId>
<packaging>pom</packaging>
<version>1.0.0</version>
<modules>
<module>zhn-common</module>
<module>zhn-gateway</module>
<module>zhn-auth</module>
<module>zhn-modules</module>
</modules>
<!-- 规定SpringBoot版本 -->
<!-- 父级pom文件 主要用于规定项目依赖的各个版本，用于进行项目版本约束 -->
<parent>
<artifactId>spring-boot-starter-parent</artifactId>
<groupId>org.springframework.boot</groupId>
<version>2.6.2</version>
<relativePath/>
</parent>
<!-- 依赖声明 -->
<dependencyManagement>
<dependencies>
<!-- SpringCloud 微服务 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>2021.0.0</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- SpringCloud Alibaba 微服务 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>2021.1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- Alibaba Nacos 配置 -->
<dependency>
<groupId>com.alibaba.nacos</groupId>
<artifactId>nacos-client</artifactId>
<version>2.0.4</version>
</dependency>
<!-- common依赖(公共模块声明) -->
<dependency>
<groupId>com.zhn</groupId>
<artifactId>zhn-common</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
</dependencyManagement>
</project>

15
zhn-auth/Dockerfile 100644
View File

@ -0,0 +1,15 @@
# 基础镜像
FROM openjdk:8-jre
# author
MAINTAINER ex_weilingfeng@163.com
# 挂载目录
VOLUME /home/zhn
# 创建目录
RUN mkdir -p /home/zhn
# 指定路径
WORKDIR /home/zhn
# 复制jar文件到路径
COPY zhn-auth/target/zhn-auth.jar /home/zhn/zhn-auth.jar
# 启动网关服务
ENTRYPOINT ["java","-jar","zhn-auth.jar"]

49
zhn-auth/pom.xml 100644
View File

@ -0,0 +1,49 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>zhn-dev</artifactId>
<groupId>com.zhn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>zhn-auth</artifactId>
<dependencies>
<!-- 项目公共 依赖 -->
<dependency>
<groupId>com.zhn</groupId>
<artifactId>zhn-common</artifactId>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

16
zhn-auth/src/main/java/com/zhn/auth/AuthMian.java 100644
View File

@ -0,0 +1,16 @@
package com.zhn.auth;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
* @author zhang
*/
@SpringBootApplication
@EnableFeignClients
public class AuthMian {
public static void main(String[] args) {
SpringApplication.run(AuthMian.class, args);
}
}

32
zhn-auth/src/main/java/com/zhn/auth/controller/AuthController.java 100644
View File

@ -0,0 +1,32 @@
package com.zhn.auth.controller;
import com.zhn.auth.service.AuthService;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import com.zhn.common.domain.response.RespJwt;
import com.zhn.common.result.Result;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
@RestController
public class AuthController {
@Autowired
AuthService authService;
@PostMapping("/login")
Result<RespJwt> login(@RequestBody RequestUser requestUser){
return authService.login(requestUser);
}
@GetMapping("/user/info")
Result<User> userinfo(HttpServletRequest request){
return authService.userinfo(request);
}
}

17
zhn-auth/src/main/java/com/zhn/auth/feign/AuthFeignSystem.java 100644
View File

@ -0,0 +1,17 @@
package com.zhn.auth.feign;
import com.zhn.common.domain.User;
import com.zhn.common.result.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@FeignClient("zhn-system")
public interface AuthFeignSystem {
@GetMapping("/user/byphone/{phone}")
Result<User> byphone(@PathVariable String phone);
}

14
zhn-auth/src/main/java/com/zhn/auth/service/AuthService.java 100644
View File

@ -0,0 +1,14 @@
package com.zhn.auth.service;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import com.zhn.common.domain.response.RespJwt;
import com.zhn.common.result.Result;
import javax.servlet.http.HttpServletRequest;
public interface AuthService {
Result<RespJwt> login(RequestUser requestUser);
Result<User> userinfo(HttpServletRequest request);
}

85
zhn-auth/src/main/java/com/zhn/auth/service/impl/AuthServiceImpl.java 100644
View File

@ -0,0 +1,85 @@
package com.zhn.auth.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.zhn.auth.feign.AuthFeignSystem;
import com.zhn.auth.service.AuthService;
import com.zhn.common.constants.JwtConstants;
import com.zhn.common.constants.TokenConstants;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import com.zhn.common.domain.response.RespJwt;
import com.zhn.common.result.Result;
import com.zhn.common.utils.JwtUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.TimeoutUtils;
import org.springframework.stereotype.Service;
import com.zhn.auth.service.AuthService;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
@Service
public class AuthServiceImpl implements AuthService {
@Autowired
AuthFeignSystem authFeignSystem;
@Autowired
RedisTemplate<String, String> redisTemplate;
@Override
public Result<RespJwt> login(RequestUser requestUser) {
String phone = requestUser.getPhone();
String password = requestUser.getPassword();
if (null == phone || null == password) {
return Result.error("联系管理员");
}
if ("".equals(phone) || "".equals(password)) {
return Result.error("请输入手机号+密码");
}
Result<User> byphone = authFeignSystem.byphone(phone);
User data = byphone.getData();
if (null == data) {
return Result.error("先注册手机号,在登录");
}
HashMap<String, Object> map = new HashMap<>();
String userkey = UUID.randomUUID().toString().replaceAll("-", "");
map.put(JwtConstants.USER_KEY, userkey);
map.put(JwtConstants.DETAILS_USER_ID, data.getId());
String token = JwtUtils.createToken(map);
redisTemplate.opsForValue().set(
TokenConstants.LOGIN_TOKEN_KEY + userkey,
JSONObject.toJSONString(data),
TokenConstants.EXPIRATION,
TimeUnit.MINUTES
);
RespJwt respJwt = new RespJwt();
respJwt.setToken(token);
respJwt.setEidTime("720MIN");
return Result.success(respJwt);
}
/*
* 前台每次请求都会来到这里进行解析user
*
* */
@Override
public Result<User> userinfo(HttpServletRequest request) {
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(
TokenConstants.LOGIN_TOKEN_KEY + userKey
);
User user = JSONObject.parseObject(s, User.class);
return Result.success(user);
}
}

31
zhn-auth/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,31 @@
# Tomcat
server:
port: 9001
# Spring
spring:
main:
allow-bean-definition-overriding: true
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: zhn-auth
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 192.168.2.51:8848
config:
# 配置中心地址
server-addr: 192.168.2.51:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

7
zhn-auth/src/main/resources/mapper/AuthMapper.xml 100644
View File

@ -0,0 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.zhn.auth.mapper.AuthMapper">
<!--namespace根据自己需要创建的的mapper的路径和名称填写-->
</mapper>

31
zhn-auth/target/classes/bootstrap.yml 100644
View File

@ -0,0 +1,31 @@
# Tomcat
server:
port: 9001
# Spring
spring:
main:
allow-bean-definition-overriding: true
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: zhn-auth
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 192.168.2.51:8848
config:
# 配置中心地址
server-addr: 192.168.2.51:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

BIN
zhn-auth/target/classes/com/zhn/auth/AuthMian.class 100644
View File

Binary file not shown.

BIN
zhn-auth/target/classes/com/zhn/auth/controller/AuthController.class 100644
View File

Binary file not shown.

BIN
zhn-auth/target/classes/com/zhn/auth/feign/AuthFeignSystem.class 100644
View File

Binary file not shown.

BIN
zhn-auth/target/classes/com/zhn/auth/service/AuthService.class 100644
View File

Binary file not shown.

BIN
zhn-auth/target/classes/com/zhn/auth/service/impl/AuthServiceImpl.class 100644
View File

Binary file not shown.

7
zhn-auth/target/classes/mapper/AuthMapper.xml 100644
View File

@ -0,0 +1,7 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.zhn.auth.mapper.AuthMapper">
<!--namespace根据自己需要创建的的mapper的路径和名称填写-->
</mapper>

96
zhn-common/pom.xml 100644
View File

@ -0,0 +1,96 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>zhn-dev</artifactId>
<groupId>com.zhn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>zhn-common</artifactId>
<dependencies>
<!-- bootstrap 启动器 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- SpringCloud Alibaba Nacos Config -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- SpringCloud Alibaba Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- 负载均衡-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
<!-- SpringCloud Openfeign -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<!-- JWT -->
<dependency>
<groupId>io.jsonwebtoken</groupId>
<artifactId>jjwt</artifactId>
<version>0.9.1</version>
</dependency>
<!-- Alibaba Fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.80</version>
</dependency>
<!-- SpringBoot Boot Redis -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- Hibernate Validator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
</dependency>
<!-- Apache Lang3 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<!-- lombok依赖 -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<!-- hutool -->
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.3</version>
</dependency>
<!-- 阿里大鱼 -->
<dependency>
<groupId>com.aliyun</groupId>
<artifactId>dysmsapi20170525</artifactId>
<version>2.0.1</version>
</dependency>
<!-- oss -->
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.12.0</version>
</dependency>
</dependencies>
</project>

18
zhn-common/src/main/java/com/zhn/common/constants/Constants.java 100644
View File

@ -0,0 +1,18 @@
package com.zhn.common.constants;
/**
* @description: 系统常量
* @author zhn
*/
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 = "操作异常";
}

29
zhn-common/src/main/java/com/zhn/common/constants/JwtConstants.java 100644
View File

@ -0,0 +1,29 @@
package com.zhn.common.constants;
/**
* @author zhn
* @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";
}

24
zhn-common/src/main/java/com/zhn/common/constants/TokenConstants.java 100644
View File

@ -0,0 +1,24 @@
package com.zhn.common.constants;
/**
* @author zhn
* @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";
}

22
zhn-common/src/main/java/com/zhn/common/domain/User.java 100644
View File

@ -0,0 +1,22 @@
package com.zhn.common.domain;
import lombok.Data;
import java.util.Date;
@Data
public class User {
private String id;
private String username;
private String password;
private String tel;
private String name;
private String avatar;
/**
* 最后登录时间
*/
private Date lastLoginTime;
private String balance;
}

21
zhn-common/src/main/java/com/zhn/common/domain/request/RequestUser.java 100644
View File

@ -0,0 +1,21 @@
package com.zhn.common.domain.request;
import lombok.Data;
@Data
public class RequestUser {
private String id;
private String avctie;
private String name;
private String username;
private String password;
private String phone;
private String emil;
private String lastLoginTime;
private String balance;
}

15
zhn-common/src/main/java/com/zhn/common/domain/response/RespJwt.java 100644
View File

@ -0,0 +1,15 @@
package com.zhn.common.domain.response;
import lombok.Data;
/**
* @ClassName:RespJwt
* @author:zhn
* @create: 2023-08-03 09:01
* @Description: 用户登录token返回实体类
*/
@Data
public class RespJwt {
private String token;
private String eidTime;
}

23
zhn-common/src/main/java/com/zhn/common/domain/response/ResponseUser.java 100644
View File

@ -0,0 +1,23 @@
package com.zhn.common.domain.response;
import lombok.Data;
import java.util.Date;
@Data
public class ResponseUser {
private String id;
private String username;
private String password;
private String tel;
private String name;
private String avatar;
/**
* 最后登录时间
*/
private Date lastLoginTime;
private String balance;
}

34
zhn-common/src/main/java/com/zhn/common/result/PageResult.java 100644
View File

@ -0,0 +1,34 @@
package com.zhn.common.result;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* @author zhn
* @description: 列表返回结果集
*/
@Data
public class PageResult<T> implements Serializable {
/**
* 总条数
*/
private long total;
/**
* 结果集合
*/
private List<T> list;
public PageResult() {
}
public PageResult(long total, List<T> list) {
this.total = total;
this.list = list;
}
public static <T> PageResult<T> toPageResult(long total, List<T> list){
return new PageResult(total , list);
}
public static <T> Result<PageResult<T>> toResult(long total, List<T> list){
return Result.success(PageResult.toPageResult(total,list));
}
}

76
zhn-common/src/main/java/com/zhn/common/result/Result.java 100644
View File

@ -0,0 +1,76 @@
package com.zhn.common.result;
import com.zhn.common.constants.Constants;
import lombok.Data;
import java.io.Serializable;
/**
* @author zhn
* @description: 响应信息主体
*/
@Data
public class Result<T> 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 <T> Result<T> success() {
return restResult(null, SUCCESS, Constants.SUCCESS_MSG);
}
public static <T> Result<T> success(T data) {
return restResult(data, SUCCESS, Constants.SUCCESS_MSG);
}
public static <T> Result<T> success(T data, String msg) {
return restResult(data, SUCCESS, msg);
}
public static <T> Result<T> error() {
return restResult(null, FAIL, Constants.ERROR_MSG);
}
public static <T> Result<T> error(String msg) {
return restResult(null, FAIL, msg);
}
public static <T> Result<T> error(T data) {
return restResult(data, FAIL, Constants.ERROR_MSG);
}
public static <T> Result<T> error(T data, String msg) {
return restResult(data, FAIL, msg);
}
public static <T> Result<T> error(int code, String msg) {
return restResult(null, code, msg);
}
private static <T> Result<T> restResult(T data, int code, String msg) {
Result<T> apiResult = new Result<>();
apiResult.setCode(code);
apiResult.setData(data);
apiResult.setMsg(msg);
return apiResult;
}
}

109
zhn-common/src/main/java/com/zhn/common/utils/JwtUtils.java 100644
View File

@ -0,0 +1,109 @@
package com.zhn.common.utils;
import com.zhn.common.constants.JwtConstants;
import io.jsonwebtoken.Claims;
import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm;
import java.util.Map;
/**
* @description: Jwt工具类
* @author zhn
*/
public class JwtUtils {
/**
* 秘钥
*/
public static String secret = JwtConstants.SECRET;
/**
* 从数据声明生成令牌
*
* @param claims 数据声明
* @return 令牌
*/
public static String createToken(Map<String, Object> 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();
}
}

318
zhn-common/src/main/java/com/zhn/common/utils/Msg/HttpUtils.java 100644
View File

@ -0,0 +1,318 @@
package com.zhn.common.utils.Msg;
import com.zhn.common.utils.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;
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<String, String> headers,
Map<String, String> querys)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpGet request = new HttpGet(buildUrl(host, path, querys));
for (Map.Entry<String, String> 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<String, String> headers,
Map<String, String> querys,
Map<String, String> bodys)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPost request = new HttpPost(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
if (bodys != null) {
List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
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<String, String> headers,
Map<String, String> querys,
String body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPost request = new HttpPost(buildUrl(host, path, querys));
for (Map.Entry<String, String> 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<String, String> headers,
Map<String, String> querys,
byte[] body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPost request = new HttpPost(buildUrl(host, path, querys));
for (Map.Entry<String, String> 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<String, String> headers,
Map<String, String> querys,
String body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPut request = new HttpPut(buildUrl(host, path, querys));
for (Map.Entry<String, String> 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<String, String> headers,
Map<String, String> querys,
byte[] body)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpPut request = new HttpPut(buildUrl(host, path, querys));
for (Map.Entry<String, String> 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<String, String> headers,
Map<String, String> querys)
throws Exception {
HttpClient httpClient = wrapClient(host);
HttpDelete request = new HttpDelete(buildUrl(host, path, querys));
for (Map.Entry<String, String> e : headers.entrySet()) {
request.addHeader(e.getKey(), e.getValue());
}
return httpClient.execute(request);
}
private static String buildUrl(String host, String path, Map<String, String> 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<String, String> 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() {
@Override
public X509Certificate[] getAcceptedIssuers() {
return null;
}
@Override
public void checkClientTrusted(X509Certificate[] xcs, String 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);
}
}
}

41
zhn-common/src/main/java/com/zhn/common/utils/Msg/MsgUtil.java 100644
View File

@ -0,0 +1,41 @@
package com.zhn.common.utils.Msg;
import org.apache.http.HttpResponse;
import java.util.HashMap;
import java.util.Map;
/**
* @author
* @version 1.0.0
* @ClassName MsgUtil.java
* @Description TODO
* @createTime 2022年05月26日 15:49: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 = "6519301ba878422488063fe815c9910";
Map<String, String> headers = new HashMap<String, String>();
headers.put("Authorization", "APPCODE " + appcode);
Map<String, String> querys = new HashMap<String, String>();
querys.put("mobile", phone);
querys.put("param", "code:"+code);
querys.put("tpl_id", "TP1711063");
Map<String, String> bodys = new HashMap<String, String>();
try {
HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys);
System.out.println(response.toString());
} catch (Exception e) {
e.printStackTrace();
}
}
}

153
zhn-common/src/main/java/com/zhn/common/utils/OssUtil.java 100644
View File

@ -0,0 +1,153 @@
package com.zhn.common.utils;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.PutObjectRequest;
import lombok.extern.log4j.Log4j2;
import org.springframework.web.multipart.MultipartFile;
import java.io.*;
import java.time.LocalDateTime;
import java.util.UUID;
/**
* Oss服务调用
*/
@Log4j2
public class OssUtil {
/**
* Endpoint 存储对象概述 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限 访问路径前缀 存储对象概述
*/
private static String endPoint = "oss-cn-shanghai.aliyuncs.com";
private static String accessKeyId = "LTAI5tGupmX9LkM6mEcmrbX7";
private static String accessKeySecret = "4phVRUQpFcEk7Olar6E8mDfTA5JOlc";
private static String accessPre = "https://liuxiaoting.oss-cn-shanghai.aliyuncs.com/";
/**
* bucket名称
* @return
*/
private static String bucketName = "liuxiaoting";
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;
}
}

68
zhn-common/src/main/java/com/zhn/common/utils/StringUtils.java 100644
View File

@ -0,0 +1,68 @@
package com.zhn.common.utils;
import org.springframework.util.AntPathMatcher;
import java.util.Collection;
import java.util.List;
/**
* @author zhn
* @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<String> 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);
}
}

87
zhn-common/src/main/java/com/zhn/common/utils/TelSmsUtils.java 100644
View File

@ -0,0 +1,87 @@
package com.zhn.common.utils;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.dysmsapi20170525.Client;
import com.aliyun.dysmsapi20170525.models.SendSmsRequest;
import com.aliyun.dysmsapi20170525.models.SendSmsResponse;
import com.aliyun.teaopenapi.models.Config;
import lombok.extern.log4j.Log4j2;
import java.util.Map;
/**
* 短信工具类
*/
@Log4j2
public class TelSmsUtils {
/**
* 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限
*/
private static String accessKeyId = "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<String, String> 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());
}
}

1
zhn-common/src/main/resources/date.txt 100644
View File

@ -0,0 +1 @@
数据源文件

BIN
zhn-common/target/classes/com/zhn/common/constants/Constants.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/constants/JwtConstants.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/constants/TokenConstants.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/domain/User.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/domain/request/RequestUser.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/domain/response/RespJwt.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/domain/response/ResponseUser.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/result/PageResult.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/result/Result.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/JwtUtils.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/Msg/HttpUtils$1.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/Msg/HttpUtils.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/Msg/MsgUtil.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/OssUtil.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/StringUtils.class 100644
View File

Binary file not shown.

BIN
zhn-common/target/classes/com/zhn/common/utils/TelSmsUtils.class 100644
View File

Binary file not shown.

1
zhn-common/target/classes/date.txt 100644
View File

@ -0,0 +1 @@
数据源文件

15
zhn-gateway/Dockerfile 100644
View File

@ -0,0 +1,15 @@
# 基础镜像
FROM openjdk:8-jre
# author
MAINTAINER ex_weilingfeng@163.com
# 挂载目录
VOLUME /home/zhn
# 创建目录
RUN mkdir -p /home/zhn
# 指定路径
WORKDIR /home/zhn
# 复制jar文件到路径
COPY zhn-gateway/target/zhn-gateway.jar /home/zhn/zhn-gateway.jar
# 启动网关服务
ENTRYPOINT ["java","-jar","zhn-gateway.jar"]

54
zhn-gateway/pom.xml 100644
View File

@ -0,0 +1,54 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>zhn-dev</artifactId>
<groupId>com.zhn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>zhn-gateway</artifactId>
<dependencies>
<!-- 公共模块 -->
<dependency>
<groupId>com.zhn</groupId>
<artifactId>zhn-common</artifactId>
</dependency>
<!-- 网关依赖 -->
<!-- SpringCloud Gateway -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!-- SpringCloud Alibaba Sentinel Gateway -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
</dependency>
<!-- 引入阿里巴巴sentinel限流 依赖-->
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-spring-cloud-gateway-adapter</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

14
zhn-gateway/src/main/java/com/zhn/gateway/GatewayMian.java 100644
View File

@ -0,0 +1,14 @@
package com.zhn.gateway;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @author zhang
*/
@SpringBootApplication
public class GatewayMian {
public static void main(String[] args) {
SpringApplication.run(GatewayMian.class,args);
}
}

32
zhn-gateway/src/main/java/com/zhn/gateway/config/IgnoreWhiteConfig.java 100644
View File

@ -0,0 +1,32 @@
package com.zhn.gateway.config;
import com.alibaba.fastjson.JSONObject;
import lombok.Data;
import lombok.extern.log4j.Log4j2;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;
import java.util.ArrayList;
import java.util.List;
/**
* @description: 放行白名单配置
* @author zhn
*/
@Configuration
@RefreshScope
@ConfigurationProperties(prefix = "ignore")
@Data
@Log4j2
public class IgnoreWhiteConfig {
/**
* 放行白名单配置，网关不校验此处的白名单
*/
private List<String> whites = new ArrayList<>();
public void setWhites(List<String> whites) {
log.info("加载网关路径白名单:{}", JSONObject.toJSONString(whites));
this.whites = whites;
}
}

4
zhn-gateway/src/main/java/com/zhn/gateway/constants/Constants.java 100644
View File

@ -0,0 +1,4 @@
package com.zhn.gateway.constants;
public class Constants {
}

72
zhn-gateway/src/main/java/com/zhn/gateway/filters/AuthFilters.java 100644
View File

@ -0,0 +1,72 @@
package com.zhn.gateway.filters;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSONObject;
import com.zhn.common.constants.TokenConstants;
import com.zhn.common.domain.User;
import com.zhn.common.utils.JwtUtils;
import com.zhn.common.utils.StringUtils;
import com.zhn.gateway.config.IgnoreWhiteConfig;
import com.zhn.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.HttpStatus;
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.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
@Component
public class AuthFilters implements GlobalFilter, Ordered {
@Autowired
private IgnoreWhiteConfig ignoreWhitesConfig;
@Autowired
private RedisTemplate<String, String> redisTemplate;
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
List<String> whites = ignoreWhitesConfig.getWhites();
ServerHttpRequest request = exchange.getRequest();
String path = request.getURI().getPath();
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不能为空！", HttpStatus.UNAUTHORIZED);
}
try {
JwtUtils.parseToken(token);
} catch (Exception e) {
return GatewayUtils.errorResponse(exchange, "token不合法！");
}
String userKey = JwtUtils.getUserKey(token);
Boolean hasKey = redisTemplate.hasKey(TokenConstants.LOGIN_TOKEN_KEY + userKey);
if (null == hasKey || !hasKey) {
return GatewayUtils.errorResponse(exchange, "token过期！");
}
String jsonStr = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSONObject.parseObject(jsonStr, User.class);
Date lastLoginTime = user.getLastLoginTime();
long between = DateUtil.between(lastLoginTime, new Date(), DateUnit.MINUTE);
if (between >= 10) {
redisTemplate.expire(TokenConstants.LOGIN_TOKEN_KEY + userKey, 15, TimeUnit.MINUTES);
}
// 验证通过放行
return chain.filter(exchange);
}
@Override
public int getOrder() {
return 0;
}
}

98
zhn-gateway/src/main/java/com/zhn/gateway/utils/GatewayUtils.java 100644
View File

@ -0,0 +1,98 @@
package com.zhn.gateway.utils;
import com.alibaba.fastjson.JSONObject;
import com.zhn.common.result.Result;
import com.zhn.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 zhn
* @description: 网关处理工具类
*/
@Log4j2
public class GatewayUtils {
/**
* 添加请求头参数
* @param mutate 修改对象
* @param key 键
* @param value 值
*/
public static void addHeader(ServerHttpRequest.Builder mutate, String key, Object value) {
if (StringUtils.isEmpty(key)){
log.warn("添加请求头参数键不可以为空");
return;
}
if (value == null) {
log.warn("添加请求头参数：[{}]值为空",key);
return;
}
String valueStr = value.toString();
mutate.header(key, valueStr);
log.info("添加请求头参数成功 - 键:[{}] , 值:[{}]", key , value);
}
/**
* 删除请求头参数
* @param mutate 修改对象
* @param key 键
*/
public static void removeHeader(ServerHttpRequest.Builder mutate, String key) {
if (StringUtils.isEmpty(key)){
log.warn("删除请求头参数键不可以为空");
return;
}
mutate.headers(httpHeaders -> httpHeaders.remove(key)).build();
log.info("删除请求头参数 - 键:[{}]",key);
}
/**
* 错误结果响应
* @param exchange 响应上下文
* @param msg 响应消息
* @return
*/
public static Mono<Void> 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<Void> 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));
}
}

29
zhn-gateway/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,29 @@
# Tomcat
server:
port: 18080
# Spring
spring:
application:
# 应用名称
name: zhn-gateway
profiles:
# 环境配置
active: dev
main:
# 允许使用循环引用
allow-circular-references: true
# 允许定义相同的bean对象 去覆盖原有的
allow-bean-definition-overriding: true
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 192.168.2.51:8848
config:
# 配置中心地址
server-addr: 192.168.2.51:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

29
zhn-gateway/target/classes/bootstrap.yml 100644
View File

@ -0,0 +1,29 @@
# Tomcat
server:
port: 18080
# Spring
spring:
application:
# 应用名称
name: zhn-gateway
profiles:
# 环境配置
active: dev
main:
# 允许使用循环引用
allow-circular-references: true
# 允许定义相同的bean对象 去覆盖原有的
allow-bean-definition-overriding: true
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 192.168.2.51:8848
config:
# 配置中心地址
server-addr: 192.168.2.51:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

BIN
zhn-gateway/target/classes/com/zhn/gateway/GatewayMian.class 100644
View File

Binary file not shown.

BIN
zhn-gateway/target/classes/com/zhn/gateway/config/IgnoreWhiteConfig.class 100644
View File

Binary file not shown.

BIN
zhn-gateway/target/classes/com/zhn/gateway/constants/Constants.class 100644
View File

Binary file not shown.

BIN
zhn-gateway/target/classes/com/zhn/gateway/filters/AuthFilters.class 100644
View File

Binary file not shown.

BIN
zhn-gateway/target/classes/com/zhn/gateway/utils/GatewayUtils.class 100644
View File

Binary file not shown.

19
zhn-modules/pom.xml 100644
View File

@ -0,0 +1,19 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>zhn-dev</artifactId>
<groupId>com.zhn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>zhn-modules</artifactId>
<packaging>pom</packaging>
<modules>
<module>zhn-system</module>
</modules>
</project>

15
zhn-modules/zhn-system/Dockerfile 100644
View File

@ -0,0 +1,15 @@
# 基础镜像
FROM openjdk:8-jre
# author
MAINTAINER ex_weilingfeng
# 挂载目录
VOLUME /home/zhn
# 创建目录
RUN mkdir -p /home/zhn
# 指定路径
WORKDIR /home/zhn
# 复制jar文件到路径
COPY zhn-modules/zhn-system/target/zhn-modules-system.jar /home/zhn/zhn-modules-system.jar
# 启动系统服务
ENTRYPOINT ["java","-jar","zhn-modules-system.jar"]

100
zhn-modules/zhn-system/pom.xml 100644
View File

@ -0,0 +1,100 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>zhn-modules</artifactId>
<groupId>com.zhn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>zhn-system</artifactId>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.zhn</groupId>
<artifactId>zhn-common</artifactId>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<!-- Druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.8</version>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Mybatis 依赖配置 -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<!-- Pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.4.1</version>
</dependency>
<!-- rabbitMQ -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<!-- 消息转换器 -->
<dependency>
<groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactId>jackson-dataformat-xml</artifactId>
<version>2.9.10</version>
</dependency>
<!--es-->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>2.7.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

15
zhn-modules/zhn-system/src/main/java/com/zhn/system/SystemMian.java 100644
View File

@ -0,0 +1,15 @@
package com.zhn.system;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@EnableFeignClients
@EnableScheduling
public class SystemMian {
public static void main(String[] args) {
SpringApplication.run(SystemMian.class, args);
}
}

42
zhn-modules/zhn-system/src/main/java/com/zhn/system/controller/UserController.java 100644
View File

@ -0,0 +1,42 @@
package com.zhn.system.controller;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import com.zhn.common.result.Result;
import com.zhn.system.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
* 作者:zhn
* \/\n
* 描述:用户控制层
*/
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
UserService userService;
@GetMapping("/byphone/{phone}")
Result<User> byphone(@PathVariable String phone){
return userService.byphone(phone);
}
@PostMapping("/updateUser")
Result updateUser(@RequestBody RequestUser requestUser){
return userService.updateUser(requestUser);
}
}

15
zhn-modules/zhn-system/src/main/java/com/zhn/system/mapper/UserMapper.java 100644
View File

@ -0,0 +1,15 @@
package com.zhn.system.mapper;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@Mapper
public interface UserMapper {
User byphone(@Param("phone") String phone);
int updatemenoy(RequestUser requestUser);
}

11
zhn-modules/zhn-system/src/main/java/com/zhn/system/service/UserService.java 100644
View File

@ -0,0 +1,11 @@
package com.zhn.system.service;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import com.zhn.common.result.Result;
public interface UserService {
Result<User> byphone(String phone);
Result updateUser(RequestUser requestUser);
}

28
zhn-modules/zhn-system/src/main/java/com/zhn/system/service/impl/UserServiceImpl.java 100644
View File

@ -0,0 +1,28 @@
package com.zhn.system.service.impl;
import com.zhn.common.domain.User;
import com.zhn.common.domain.request.RequestUser;
import com.zhn.common.result.Result;
import com.zhn.system.mapper.UserMapper;
import com.zhn.system.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class UserServiceImpl implements UserService {
@Autowired
UserMapper userMapper;
@Override
public Result<User> byphone(String phone) {
User user = userMapper.byphone(phone);
return Result.success(user);
}
@Override
public Result updateUser(RequestUser requestUser) {
return null;
}
}

42
zhn-modules/zhn-system/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,42 @@
server:
port: 9002
spring:
main:
allow-bean-definition-overriding: true
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
name: zhn-system
profiles:
active: dev
cloud:
nacos:
discovery:
server-addr: 192.168.2.51:8848
config:
server-addr: 192.168.2.51:8848
file-extension: yml
shared-configs:
- "application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}"
rabbitmq:
host: 124.222.164.80
port: 5672
username: guest
password: guest
virtualHost: /
listener:
simple:
prefetch: 1
acknowledge-mode: manual
retry:
enabled: true
publisher-confirm-type: correlated
publisher-returns: true
es:
host: 124.222.164.80
port: 9200
scheme: http

22
zhn-modules/zhn-system/src/main/resources/mappers/UserMapper.xml 100644
View File

@ -0,0 +1,22 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.zhn.system.mapper.UserMapper">
<update id="updatemenoy">
update user
set balance = #{balance}
where username = #{username};
</update>
<!--namespace根据自己需要创建的的mapper的路径和名称填写-->
<select id="byphone" resultType="com.zhn.common.domain.User">
select *
from user
<where>
<if test="null!=phone and ''!=phone">
and phone =#{phone}
</if>
</where>
</select>
</mapper>

42
zhn-modules/zhn-system/target/classes/bootstrap.yml 100644
View File

@ -0,0 +1,42 @@
server:
port: 9002
spring:
main:
allow-bean-definition-overriding: true
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
name: zhn-system
profiles:
active: dev
cloud:
nacos:
discovery:
server-addr: 192.168.2.51:8848
config:
server-addr: 192.168.2.51:8848
file-extension: yml
shared-configs:
- "application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}"
rabbitmq:
host: 124.222.164.80
port: 5672
username: guest
password: guest
virtualHost: /
listener:
simple:
prefetch: 1
acknowledge-mode: manual
retry:
enabled: true
publisher-confirm-type: correlated
publisher-returns: true
es:
host: 124.222.164.80
port: 9200
scheme: http

BIN
zhn-modules/zhn-system/target/classes/com/zhn/system/SystemMian.class 100644
View File

Binary file not shown.

BIN
zhn-modules/zhn-system/target/classes/com/zhn/system/controller/UserController.class 100644
View File

Binary file not shown.

BIN
zhn-modules/zhn-system/target/classes/com/zhn/system/mapper/UserMapper.class 100644
View File

Binary file not shown.

BIN
zhn-modules/zhn-system/target/classes/com/zhn/system/service/UserService.class 100644
View File

Binary file not shown.

BIN
zhn-modules/zhn-system/target/classes/com/zhn/system/service/impl/UserServiceImpl.class 100644
View File

Binary file not shown.

22
zhn-modules/zhn-system/target/classes/mappers/UserMapper.xml 100644
View File

@ -0,0 +1,22 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.zhn.system.mapper.UserMapper">
<update id="updatemenoy">
update user
set balance = #{balance}
where username = #{username};
</update>
<!--namespace根据自己需要创建的的mapper的路径和名称填写-->
<select id="byphone" resultType="com.zhn.common.domain.User">
select *
from user
<where>
<if test="null!=phone and ''!=phone">
and phone =#{phone}
</if>
</where>
</select>
</mapper>

14
zhn-vue-ui/.editorconfig 100644
View File

@ -0,0 +1,14 @@
# http://editorconfig.org
root = true
[*]
charset = utf-8
indent_style = space
indent_size = 2
end_of_line = lf
insert_final_newline = true
trim_trailing_whitespace = true
[*.md]
insert_final_newline = false
trim_trailing_whitespace = false

5
zhn-vue-ui/.env.development 100644
View File

@ -0,0 +1,5 @@
# just a flag
ENV = 'development'
# base api
VUE_APP_BASE_API = '/dev-api'

6
zhn-vue-ui/.env.production 100644
View File

@ -0,0 +1,6 @@
# just a flag
ENV = 'production'
# base api
VUE_APP_BASE_API = '/prod-api'

8
zhn-vue-ui/.env.staging 100644
View File

@ -0,0 +1,8 @@
NODE_ENV = production
# just a flag
ENV = 'staging'
# base api
VUE_APP_BASE_API = '/stage-api'

5
zhn-vue-ui/.eslintignore 100644
View File

@ -0,0 +1,5 @@
build/*.js
src/assets
public
dist
*

198
zhn-vue-ui/.eslintrc.js 100644
View File

@ -0,0 +1,198 @@
module.exports = {
root: true,
parserOptions: {
parser: 'babel-eslint',
sourceType: 'module'
},
env: {
browser: true,
node: true,
es6: true,
},
extends: ['plugin:vue/recommended', 'eslint:recommended'],
// add your custom rules here
//it is base on https://github.com/vuejs/eslint-config-vue
rules: {
"vue/max-attributes-per-line": [2, {
"singleline": 10,
"multiline": {
"max": 1,
"allowFirstLine": false
}
}],
"vue/singleline-html-element-content-newline": "off",
"vue/multiline-html-element-content-newline":"off",
"vue/name-property-casing": ["error", "PascalCase"],
"vue/no-v-html": "off",
'accessor-pairs': 2,
'arrow-spacing': [2, {
'before': true,
'after': true
}],
'block-spacing': [2, 'always'],
'brace-style': [2, '1tbs', {
'allowSingleLine': true
}],
'camelcase': [0, {
'properties': 'always'
}],
'comma-dangle': [2, 'never'],
'comma-spacing': [2, {
'before': false,
'after': true
}],
'comma-style': [2, 'last'],
'constructor-super': 2,
'curly': [2, 'multi-line'],
'dot-location': [2, 'property'],
'eol-last': 2,
'eqeqeq': ["error", "always", {"null": "ignore"}],
'generator-star-spacing': [2, {
'before': true,
'after': true
}],
'handle-callback-err': [2, '^(err|error)$'],
'indent': [2, 2, {
'SwitchCase': 1
}],
'jsx-quotes': [2, 'prefer-single'],
'key-spacing': [2, {
'beforeColon': false,
'afterColon': true
}],
'keyword-spacing': [2, {
'before': true,
'after': true
}],
'new-cap': [2, {
'newIsCap': true,
'capIsNew': false
}],
'new-parens': 2,
'no-array-constructor': 2,
'no-caller': 2,
'no-console': 'off',
'no-class-assign': 2,
'no-cond-assign': 2,
'no-const-assign': 2,
'no-control-regex': 0,
'no-delete-var': 2,
'no-dupe-args': 2,
'no-dupe-class-members': 2,
'no-dupe-keys': 2,
'no-duplicate-case': 2,
'no-empty-character-class': 2,
'no-empty-pattern': 2,
'no-eval': 2,
'no-ex-assign': 2,
'no-extend-native': 2,
'no-extra-bind': 2,
'no-extra-boolean-cast': 2,
'no-extra-parens': [2, 'functions'],
'no-fallthrough': 2,
'no-floating-decimal': 2,
'no-func-assign': 2,
'no-implied-eval': 2,
'no-inner-declarations': [2, 'functions'],
'no-invalid-regexp': 2,
'no-irregular-whitespace': 2,
'no-iterator': 2,
'no-label-var': 2,
'no-labels': [2, {
'allowLoop': false,
'allowSwitch': false
}],
'no-lone-blocks': 2,
'no-mixed-spaces-and-tabs': 2,
'no-multi-spaces': 2,
'no-multi-str': 2,
'no-multiple-empty-lines': [2, {
'max': 1
}],
'no-native-reassign': 2,
'no-negated-in-lhs': 2,
'no-new-object': 2,
'no-new-require': 2,
'no-new-symbol': 2,
'no-new-wrappers': 2,
'no-obj-calls': 2,
'no-octal': 2,
'no-octal-escape': 2,
'no-path-concat': 2,
'no-proto': 2,
'no-redeclare': 2,
'no-regex-spaces': 2,
'no-return-assign': [2, 'except-parens'],
'no-self-assign': 2,
'no-self-compare': 2,
'no-sequences': 2,
'no-shadow-restricted-names': 2,
'no-spaced-func': 2,
'no-sparse-arrays': 2,
'no-this-before-super': 2,
'no-throw-literal': 2,
'no-trailing-spaces': 2,
'no-undef': 2,
'no-undef-init': 2,
'no-unexpected-multiline': 2,
'no-unmodified-loop-condition': 2,
'no-unneeded-ternary': [2, {
'defaultAssignment': false
}],
'no-unreachable': 2,
'no-unsafe-finally': 2,
'no-unused-vars': [2, {
'vars': 'all',
'args': 'none'
}],
'no-useless-call': 2,
'no-useless-computed-key': 2,
'no-useless-constructor': 2,
'no-useless-escape': 0,
'no-whitespace-before-property': 2,
'no-with': 2,
'one-var': [2, {
'initialized': 'never'
}],
'operator-linebreak': [2, 'after', {
'overrides': {
'?': 'before',
':': 'before'
}
}],
'padded-blocks': [2, 'never'],
'quotes': [2, 'single', {
'avoidEscape': true,
'allowTemplateLiterals': true
}],
'semi': [2, 'never'],
'semi-spacing': [2, {
'before': false,
'after': true
}],
'space-before-blocks': [2, 'always'],
'space-before-function-paren': [2, 'never'],
'space-in-parens': [2, 'never'],
'space-infix-ops': 2,
'space-unary-ops': [2, {
'words': true,
'nonwords': false
}],
'spaced-comment': [2, 'always', {
'markers': ['global', 'globals', 'eslint', 'eslint-disable', '*package', '!', ',']
}],
'template-curly-spacing': [2, 'never'],
'use-isnan': 2,
'valid-typeof': 2,
'wrap-iife': [2, 'any'],
'yield-star-spacing': [2, 'both'],
'yoda': [2, 'never'],
'prefer-const': 2,
'no-debugger': process.env.NODE_ENV === 'production' ? 2 : 0,
'object-curly-spacing': [2, 'always', {
objectsInObjects: false
}],
'array-bracket-spacing': [2, 'never']
}
}

16
zhn-vue-ui/.gitignore vendored 100644
View File

@ -0,0 +1,16 @@
.DS_Store
node_modules/
dist/
npm-debug.log*
yarn-debug.log*
yarn-error.log*
package-lock.json
tests/**/coverage/
# Editor directories and files
.idea
.vscode
*.suo
*.ntvs*
*.njsproj
*.sln

5
zhn-vue-ui/.travis.yml 100644
View File

@ -0,0 +1,5 @@
language: node_js
node_js: 10
script: npm run test
notifications:
email: false

21
zhn-vue-ui/LICENSE 100644
View File

@ -0,0 +1,21 @@
MIT License
Copyright (c) 2017-present PanJiaChen
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all
copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.

Some files were not shown because too many files have changed in this diff Show More