guoxubao
/
gxb-yuekao
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

第一次提交

a2
31353 2024-01-03 18:32:25 +08:00
commit d8e661d7c4
89 changed files with 4622 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
.gitignore vendored 100644
View File

@ -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

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

124
.idea/uiDesigner.xml 100644
View File

@ -0,0 +1,124 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Palette2">
<group name="Swing">
<item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
</item>
<item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
</item>
<item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
<default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
</item>
<item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
<initial-values>
<property name="text" value="Button" />
</initial-values>
</item>
<item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="RadioButton" />
</initial-values>
</item>
<item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="CheckBox" />
</initial-values>
</item>
<item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
<initial-values>
<property name="text" value="Label" />
</initial-values>
</item>
<item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
</item>
<item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
</item>
<item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
<preferred-size width="-1" height="20" />
</default-constraints>
</item>
<item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
</item>
<item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
</item>
</group>
</component>
</project>

32
bwie-api/bwie-user-api/pom.xml 100644
View File

@ -0,0 +1,32 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>bwie-api</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-user-api</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
</project>

25
bwie-api/bwie-user-api/src/main/java/com/bwie/user/fatory/RemoteUserFtroy.java 100644
View File

@ -0,0 +1,25 @@
package com.bwie.user.fatory;
import com.bwie.common.domain.User;
import com.bwie.common.result.Result;
import com.bwie.user.feign.RemoteUserService;
import org.springframework.cloud.openfeign.FallbackFactory;
import org.springframework.stereotype.Component;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:13
*/
@Component
public class RemoteUserFtroy implements FallbackFactory<RemoteUserService> {
@Override
public RemoteUserService create(Throwable cause) {
return new RemoteUserService() {
@Override
public Result<User> findName(String username) {
return Result.error("调用USER服务失败，系统繁忙，稍后重试");
}
};
}
}

21
bwie-api/bwie-user-api/src/main/java/com/bwie/user/feign/RemoteUserService.java 100644
View File

@ -0,0 +1,21 @@
package com.bwie.user.feign;
import com.bwie.common.domain.User;
import com.bwie.common.result.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:03
*/
@FeignClient("bwie-user")
public interface RemoteUserService {
/**
* 查询姓名
*/
@PostMapping("/findName/{username}")
public Result<User> findName(@PathVariable String username);
}

2
bwie-api/bwie-user-api/src/main/resources/META-INF/spring.factories 100644
View File

@ -0,0 +1,2 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.bwie.user.fatory.RemoteUserFtroy

24
bwie-api/pom.xml 100644
View File

@ -0,0 +1,24 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-api</artifactId>
<packaging>pom</packaging>
<modules>
<module>bwie-user-api</module>
</modules>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>

42
bwie-auth/pom.xml 100644
View File

@ -0,0 +1,42 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-auth</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 项目公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-user-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project>

18
bwie-auth/src/main/java/com/bwie/AuthAppliction.java 100644
View File

@ -0,0 +1,18 @@
package com.bwie;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:15
*/
@SpringBootApplication
@EnableFeignClients(basePackages = {"com.bwie"})
public class AuthAppliction {
public static void main(String[] args) {
SpringApplication.run(AuthAppliction.class,args);
}
}

35
bwie-auth/src/main/java/com/bwie/controller/AuthController.java 100644
View File

@ -0,0 +1,35 @@
package com.bwie.controller;
import com.bwie.common.domain.request.UserRequest;
import com.bwie.common.result.Result;
import com.bwie.service.impl.AuthService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:04
*/
@RestController
public class AuthController {
@Autowired
private AuthService authService;
/**
* 登录
*/
@PostMapping("/login")
public Result login(@RequestBody UserRequest userRequest){
return authService.login(userRequest);
}
/**
* 退出
*/
@GetMapping("/lout")
public Result lout(){
return authService.lout();
}
}

16
bwie-auth/src/main/java/com/bwie/service/impl/AuthService.java 100644
View File

@ -0,0 +1,16 @@
package com.bwie.service.impl;
import com.bwie.common.domain.request.UserRequest;
import com.bwie.common.result.Result;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:04
*/
public interface AuthService {
Result login(UserRequest userRequest);
Result lout();
}

88
bwie-auth/src/main/java/com/bwie/service/impl/AuthServicelmpl.java 100644
View File

@ -0,0 +1,88 @@
package com.bwie.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.common.utils.UuidUtils;
import com.bwie.common.constants.Constants;
import com.bwie.common.constants.JwtConstants;
import com.bwie.common.constants.TokenConstants;
import com.bwie.common.domain.User;
import com.bwie.common.domain.request.UserRequest;
import com.bwie.common.domain.response.JwtResponse;
import com.bwie.common.exception.auth.AuthException;
import com.bwie.common.result.Result;
import com.bwie.common.utils.JwtUtils;
import com.bwie.user.feign.RemoteUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.concurrent.TimeUnit;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:05
*/
@Service
public class AuthServicelmpl implements AuthService{
@Autowired
private RemoteUserService remoteUserService;
@Autowired
private StringRedisTemplate redisTemplate;
@Autowired
private HttpServletRequest request;
/**
* 登录
* @param userRequest
* @return
*/
@Override
public Result login(UserRequest userRequest) {
Result<User> userData = remoteUserService.findName(userRequest.getUsername());
if (userData.getCode()== Constants.ERROR){
throw new AuthException(userData.getMsg());
}
User user = userData.getData();
if (null==user){
throw new AuthException("用户名不存在，请重新登录！");
}
if (!user.getPassword().equals(userRequest.getPassword())){
throw new AuthException("密码错误，请重新检查输入！");
}
JwtResponse token = this.getToken(user);
if (1==user.getRole()){
return Result.success(token,"管理员登录成功");
}
if (2==user.getRole()){
return Result.success(token,"审核员登录成功");
}
return Result.success(token,"业务员登录成功");
}
@Override
public Result lout() {
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
redisTemplate.delete(TokenConstants.LOGIN_TOKEN_KEY+userKey);
return Result.success("chenggg");
}
/**
* 生成token
* @param user
* @return
*/
private JwtResponse getToken(User user){
HashMap<String, Object> map = new HashMap<>();
String userKey = UuidUtils.generateUuid().replaceAll("-", "");
map.put(JwtConstants.USER_KEY,userKey);
String token = JwtUtils.createToken(map);
redisTemplate.opsForValue().set(TokenConstants.LOGIN_TOKEN_KEY+userKey,
JSON.toJSONString(user),15, TimeUnit.MINUTES);
return new JwtResponse(token);
}
}

30
bwie-auth/src/main/resources/bootstrap.yml 100644
View File

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

181
bwie-common/pom.xml 100644
View File

@ -0,0 +1,181 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-common</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- bootstrap 启动器 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
<!-- 后台校验Hibernate Validator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</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>
<exclusions>
<exclusion>
<groupId>io.lettuce</groupId>
<artifactId>lettuce-core</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- 过滤lettuce 使用jedis作为redis客户端-->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</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>
<!-- &lt;!&ndash;mq 依赖&ndash;&gt;
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>-->
<!--ES-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!--短信依赖 5条依赖-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.15</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.2.1</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-util</artifactId>
<version>9.3.7.v20160115</version>
</dependency>
<!-- 测试 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!--fastDfs文件上传-->
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
<!-- ES -->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>
<!-- servlet -api -->
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.5</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
</dependencies>
</project>

40
bwie-common/src/main/java/com/bwie/common/config/RedisConfig.java 100644
View File

@ -0,0 +1,40 @@
package com.bwie.common.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(factory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new
Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
// key采用String的序列化方式
template.setKeySerializer(stringRedisSerializer);
// hash的key也采用String的序列化方式
template.setHashKeySerializer(stringRedisSerializer);
// value序列化方式采用jackson
template.setValueSerializer(jackson2JsonRedisSerializer);
// hash的value序列化方式采用jackson
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
}

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

@ -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 = "操作异常";
}

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

@ -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";
}

23
bwie-common/src/main/java/com/bwie/common/constants/MqConstans.java 100644
View File

@ -0,0 +1,23 @@
package com.bwie.common.constants;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:41
*/
public class MqConstans {
/**
* 添加日志
*/
public static final String SENDCODEQUEUE = "insert_log_queue";
public static final String SENDCODEEXCHANGE = "insert_log_exchange";
public static final String SENDCODEKEY = "insert_log_key";
/**
* 发送短信
*/
public static final String SENDQUEUE = "send_queue";
public static final String SENDEXCHANGE = "send_exchange";
public static final String SENDTELKEY = "send_tel_key";
}

5
bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java 100644
View File

@ -0,0 +1,5 @@
package com.bwie.common.constants;
public class RabbitMQConstants {
public static final String SEND_SMS_QUEUE = "send_sms_queue";
}

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

@ -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";
}

33
bwie-common/src/main/java/com/bwie/common/domain/Item.java 100644
View File

@ -0,0 +1,33 @@
package com.bwie.common.domain;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:46
*/
@Data
public class Item {
private Integer itemId;
private String itemName;
private String itemEncod;
private String itemCustomer;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApproval;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemCome;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemBecompl;
private Integer userId;
private String itemImage;
private Integer itemState;
private String username;
private Double middleMoney;
private Double middleFinally;
}

34
bwie-common/src/main/java/com/bwie/common/domain/Log.java 100644
View File

@ -0,0 +1,34 @@
package com.bwie.common.domain;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:46
*/
@Data
public class Log {
private Integer logId;
private Integer itemId;
private Integer userId;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date logDate;
/**
* 是否通知审核结果
*/
private Integer logOr;
private String itemName;
private String itemCustomer;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApproval;
private String userName;
}

28
bwie-common/src/main/java/com/bwie/common/domain/Middle.java 100644
View File

@ -0,0 +1,28 @@
package com.bwie.common.domain;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:46
*/
@Data
public class Middle {
private Integer middleId;
private Integer itemId;
private Integer typeId;
private Double middleMoney;
private Double middleFinally;
private Integer middleState;
private String itemName;
/**
* 估算价格
*/
private Double estimatemoney;
/**
* 最终价格
*/
private Double finallymoney;
private String typeName;
}

14
bwie-common/src/main/java/com/bwie/common/domain/Type.java 100644
View File

@ -0,0 +1,14 @@
package com.bwie.common.domain;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 11:18
*/
@Data
public class Type {
private Integer typeId;
private String typeName;
}

17
bwie-common/src/main/java/com/bwie/common/domain/User.java 100644
View File

@ -0,0 +1,17 @@
package com.bwie.common.domain;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:46
*/
@Data
public class User {
private Integer userId;
private String username;
private String password;
private String tel;
private Integer role;
}

36
bwie-common/src/main/java/com/bwie/common/domain/request/Insertitem.java 100644
View File

@ -0,0 +1,36 @@
package com.bwie.common.domain.request;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 11:54
*/
@Data
public class Insertitem {
private Integer itemId;
private String itemName;
private String itemEncod;
private String itemCustomer;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApproval;
private String itemImage;
/**
* 成本类型
*/
private List<String> types;
/**
* 成本金额
*/
private List<Double> prices;
private Integer userId;
}

31
bwie-common/src/main/java/com/bwie/common/domain/request/ItemRequest.java 100644
View File

@ -0,0 +1,31 @@
package com.bwie.common.domain.request;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:29
*/
@Data
public class ItemRequest {
//项目名称、项目客户方精确查询 （1分）
// 立项时间区间查询（3分）
private Integer userId;
private Integer role;
private String itemName;
private String itemCustomer;
/**
* 立项时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApproval;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApprovals;
}

30
bwie-common/src/main/java/com/bwie/common/domain/request/LogRequest.java 100644
View File

@ -0,0 +1,30 @@
package com.bwie.common.domain.request;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:44
*/
@Data
public class LogRequest {
private String itemName;
private String itemCustomer;
/**
* 立项时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApproval;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date itemApprovals;
/**
* 多角色
*/
private Integer userId;
}

17
bwie-common/src/main/java/com/bwie/common/domain/request/SendTel.java 100644
View File

@ -0,0 +1,17 @@
package com.bwie.common.domain.request;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 17:58
*/
@Data
public class SendTel {
/**
* 发送修改提示
*/
private String phone;
private String code;
}

16
bwie-common/src/main/java/com/bwie/common/domain/request/Update.java 100644
View File

@ -0,0 +1,16 @@
package com.bwie.common.domain.request;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:09
*/
@Data
public class Update {
private Integer middleId;
private Double middleMoney;
private Double middleFinally;
private Integer middleState;
}

14
bwie-common/src/main/java/com/bwie/common/domain/request/UserRequest.java 100644
View File

@ -0,0 +1,14 @@
package com.bwie.common.domain.request;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:06
*/
@Data
public class UserRequest {
private String username;
private String password;
}

15
bwie-common/src/main/java/com/bwie/common/domain/response/JwtResponse.java 100644
View File

@ -0,0 +1,15 @@
package com.bwie.common.domain.response;
import lombok.AllArgsConstructor;
import lombok.Data;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:06
*/
@Data
@AllArgsConstructor
public class JwtResponse {
private String token;
}

30
bwie-common/src/main/java/com/bwie/common/exception/auth/AuthException.java 100644
View File

@ -0,0 +1,30 @@
package com.bwie.common.exception.auth;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:44
*/
public class AuthException extends RuntimeException{
/**
* 状态码
*/
private int code;
/**
* 错误信息
*/
private String message;
public AuthException() {
}
public AuthException(String message) {
super(message);
}
public AuthException(int code, String message) {
this.code = code;
this.message = message;
}
}

78
bwie-common/src/main/java/com/bwie/common/handle/GlodExceptionHandle.java 100644
View File

@ -0,0 +1,78 @@
package com.bwie.common.handle;
import com.bwie.common.exception.auth.AuthException;
import com.bwie.common.result.Result;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.messaging.handler.annotation.support.MethodArgumentTypeMismatchException;
import org.springframework.stereotype.Component;
import org.springframework.validation.FieldError;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import javax.servlet.http.HttpServletRequest;
import javax.validation.ConstraintViolationException;
import java.util.stream.Collectors;
/**
* @author gxb
* @description TODO
* @date 2023-12-26 19:14
*/
@RestControllerAdvice
public class GlodExceptionHandle {
private static final Logger logger= LoggerFactory.getLogger(GlodExceptionHandle.class);
/**
* 处理Auth
* @param request
* @param authException
* @return
*/
@ExceptionHandler(AuthException.class)
public Result authException(HttpServletRequest request,AuthException authException){
StringBuffer requestURL = request.getRequestURL();
logger.error("请求URL：{}，出现了异常，异常信息：{}"
,requestURL,authException.getMessage());
return Result.error(authException.getMessage());
}
/**
* 自定义验证异常
*/
@ExceptionHandler(MethodArgumentNotValidException.class)
public Object handleMethodArgumentTypeMismatchException(MethodArgumentNotValidException e) {
logger.error(e.getMessage(),e);
return Result.error(
e.getBindingResult().getFieldErrors()
.stream()
.map(FieldError::getDefaultMessage)
.collect(Collectors.joining(","))
);
}
/**
* 请求参数类型不匹配
*/
@ExceptionHandler(MethodArgumentTypeMismatchException.class)
public Result handleMethodArgumentTypeMismatchException(MethodArgumentTypeMismatchException e, HttpServletRequest request) {
String requestURI = request.getRequestURI();
logger.error("请求参数类型不匹配'{}',发生系统异常.", requestURI, e);
return Result.error(
String.format("请求参数类型不匹配，参数[%s]要求类型为：'%s'，但输入值为：'%s'"
, e.getCause()
, e.getRootCause().getCause()
, e.getCause()));
}
/**
* 自定义验证异常
*/
@ExceptionHandler(ConstraintViolationException.class)
public Object handleConstraintViolationException(ConstraintViolationException e) {
logger.error(e.getMessage(), e);
return Result.error(e.getMessage());
}
}

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

@ -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<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
bwie-common/src/main/java/com/bwie/common/result/Result.java 100644
View File

@ -0,0 +1,76 @@
package com.bwie.common.result;
import com.bwie.common.constants.Constants;
import lombok.Data;
import java.io.Serializable;
/**
* @author DongZl
* @description: 响应信息主体
*/
@Data
public class Result<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;
}
}

253
bwie-common/src/main/java/com/bwie/common/utils/AESUtils.java 100644
View File

@ -0,0 +1,253 @@
package com.bwie.utils;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.Base64Utils;
import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
/**
* @ClassName AESUtils
* @Description 描述
* @Author WenSha.Wan
* @Date 2023/7/8 上午7:48
*/
public class AESUtils {
/**
* 日志相关
*/
private static final Logger LOGGER = LoggerFactory.getLogger(AESUtils.class);
/**
* 编码
*/
private static final String ENCODING = "UTF-8";
/**
* 算法定义
*/
private static final String AES_ALGORITHM = "AES";
/**
* 指定填充方式
*/
private static final String CIPHER_PADDING = "AES/ECB/PKCS5Padding";
private static final String CIPHER_CBC_PADDING = "AES/CBC/PKCS5Padding";
/**
* 偏移量(CBC中使用，增强加密算法强度)
*/
private static final String IV_SEED = "1234567812345678";
/**
* AES加密
* @param content 待加密内容
* @param aesKey 密码
* @return
*/
public static String encrypt(String content, String aesKey){
if(StringUtils.isBlank(content)){
LOGGER.info("AES encrypt: the content is null!");
return null;
}
//判断秘钥是否为16位
if(StringUtils.isNotBlank(aesKey) && aesKey.length() == 16){
try {
//对密码进行编码
byte[] bytes = aesKey.getBytes(ENCODING);
//设置加密算法，生成秘钥
SecretKeySpec skeySpec = new SecretKeySpec(bytes, AES_ALGORITHM);
// "算法/模式/补码方式"
Cipher cipher = Cipher.getInstance(CIPHER_PADDING);
//选择加密
cipher.init(Cipher.ENCRYPT_MODE, skeySpec);
//根据待加密内容生成字节数组
byte[] encrypted = cipher.doFinal(content.getBytes(ENCODING));
//返回base64字符串
return Base64Utils.encodeToString(encrypted);
} catch (Exception e) {
LOGGER.info("AES encrypt exception:" + e.getMessage());
throw new RuntimeException(e);
}
}else {
LOGGER.info("AES encrypt: the aesKey is null or error!");
return null;
}
}
/**
* 解密
*
* @param content 待解密内容
* @param aesKey 密码
* @return
*/
public static String decrypt(String content, String aesKey){
if(StringUtils.isBlank(content)){
LOGGER.info("AES decrypt: the content is null!");
return null;
}
//判断秘钥是否为16位
if(StringUtils.isNotBlank(aesKey) && aesKey.length() == 16){
try {
//对密码进行编码
byte[] bytes = aesKey.getBytes(ENCODING);
//设置解密算法，生成秘钥
SecretKeySpec skeySpec = new SecretKeySpec(bytes, AES_ALGORITHM);
// "算法/模式/补码方式"
Cipher cipher = Cipher.getInstance(CIPHER_PADDING);
//选择解密
cipher.init(Cipher.DECRYPT_MODE, skeySpec);
//先进行Base64解码
byte[] decodeBase64 = Base64Utils.decodeFromString(content);
//根据待解密内容进行解密
byte[] decrypted = cipher.doFinal(decodeBase64);
//将字节数组转成字符串
return new String(decrypted, ENCODING);
} catch (Exception e) {
LOGGER.info("AES decrypt exception:" + e.getMessage());
throw new RuntimeException(e);
}
}else {
LOGGER.info("AES decrypt: the aesKey is null or error!");
return null;
}
}
/**
* AES_CBC加密
*
* @param content 待加密内容
* @param aesKey 密码
* @return
*/
public static String encryptCBC(String content, String aesKey){
if(StringUtils.isBlank(content)){
LOGGER.info("AES_CBC encrypt: the content is null!");
return null;
}
//判断秘钥是否为16位
if(StringUtils.isNotBlank(aesKey) && aesKey.length() == 16){
try {
//对密码进行编码
byte[] bytes = aesKey.getBytes(ENCODING);
//设置加密算法，生成秘钥
SecretKeySpec skeySpec = new SecretKeySpec(bytes, AES_ALGORITHM);
// "算法/模式/补码方式"
Cipher cipher = Cipher.getInstance(CIPHER_CBC_PADDING);
//偏移
IvParameterSpec iv = new IvParameterSpec(IV_SEED.getBytes(ENCODING));
//选择加密
cipher.init(Cipher.ENCRYPT_MODE, skeySpec, iv);
//根据待加密内容生成字节数组
byte[] encrypted = cipher.doFinal(content.getBytes(ENCODING));
//返回base64字符串
return Base64Utils.encodeToString(encrypted);
} catch (Exception e) {
LOGGER.info("AES_CBC encrypt exception:" + e.getMessage());
throw new RuntimeException(e);
}
}else {
LOGGER.info("AES_CBC encrypt: the aesKey is null or error!");
return null;
}
}
/**
* AES_CBC解密
*
* @param content 待解密内容
* @param aesKey 密码
* @return
*/
public static String decryptCBC(String content, String aesKey){
if(StringUtils.isBlank(content)){
LOGGER.info("AES_CBC decrypt: the content is null!");
return null;
}
//判断秘钥是否为16位
if(StringUtils.isNotBlank(aesKey) && aesKey.length() == 16){
try {
//对密码进行编码
byte[] bytes = aesKey.getBytes(ENCODING);
//设置解密算法，生成秘钥
SecretKeySpec skeySpec = new SecretKeySpec(bytes, AES_ALGORITHM);
//偏移
IvParameterSpec iv = new IvParameterSpec(IV_SEED.getBytes(ENCODING));
// "算法/模式/补码方式"
Cipher cipher = Cipher.getInstance(CIPHER_CBC_PADDING);
//选择解密
cipher.init(Cipher.DECRYPT_MODE, skeySpec, iv);
//先进行Base64解码
byte[] decodeBase64 = Base64Utils.decodeFromString(content);
//根据待解密内容进行解密
byte[] decrypted = cipher.doFinal(decodeBase64);
//将字节数组转成字符串
return new String(decrypted, ENCODING);
} catch (Exception e) {
LOGGER.info("AES_CBC decrypt exception:" + e.getMessage());
throw new RuntimeException(e);
}
}else {
LOGGER.info("AES_CBC decrypt: the aesKey is null or error!");
return null;
}
}
public static void main(String[] args) {
// AES支持三种长度的密钥：128位、192位、256位。
// 代码中这种就是128位的加密密钥，16字节 * 8位/字节 = 128位。
// String random = RandomStringUtils.random(16, "abcdefghijklmnopqrstuvwxyz1234567890");
// String random = RandomStringUtils.random(16, "123456");
// System.out.println("随机key:" + random);
// System.out.println();
//
// System.out.println("---------加密---------");
// String aesResult = encrypt("测试AES加密12", random);
// System.out.println("aes加密结果:" + aesResult);
// System.out.println();
//
// System.out.println("---------解密---------");
// String decrypt = decrypt(aesResult, random);
// System.out.println("aes解密结果:" + decrypt);
// System.out.println();
//
//
// System.out.println("--------AES_CBC加密解密---------");
// String cbcResult = encryptCBC("测试AES加密12456", random);
// System.out.println("aes_cbc加密结果:" + cbcResult);
// System.out.println();
//
// System.out.println("---------解密CBC---------");
// String cbcDecrypt = decryptCBC(cbcResult, random);
// System.out.println("aes解密结果:" + cbcDecrypt);
// System.out.println();
//加密
String encrypt1 = encrypt ("12345", "1234567890004422");
System.out.println ("12345加密后 1====================={"+encrypt1);
String encrypt2 = encrypt ("23456", "1234567890004422");
System.out.println ("23456加密后 1====================={"+encrypt2);
String encrypt3 = encrypt ("56789", "1234567890004422");
System.out.println ("56789加密后 1====================={"+encrypt3);
//解密
// decrypt ("/83VCGvDN+C5pvYN/19pBQ==")
}
}

87
bwie-common/src/main/java/com/bwie/common/utils/GenCodeUtils.java 100644
View File

@ -0,0 +1,87 @@
package com.bwie.common.utils;
import java.util.Random;
/**
* @author DongZl
* @description: 生成验证码工具类
* @Date 2023-5-11 上午 10:09
*/
public class GenCodeUtils {
/**
* 数字类型
*/
private static final String NUMBER_STR = "0123456789";
/**
* 字母类型
*/
private static final String LETTERS_STR = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
/**
* 短信验证码长度
*/
private static final Integer SMS_CODE_LENGTH = 4;
/**
* 生成短信四位验证码
* @return 验证码
*/
public static String genLetterStrSms(){
return genCode(LETTERS_STR, SMS_CODE_LENGTH);
}
/**
* 生成短信四位验证码
* @return 验证码
*/
public static String genNumberCodeSms(){
return genCode(NUMBER_STR, SMS_CODE_LENGTH);
}
/**
* 生成验证码
* @param codeLength 验证码长度
* @return 验证码
*/
public static String genLetterStr(int codeLength){
return genCode(LETTERS_STR, codeLength);
}
/**
* 生成验证码
* @param codeLength 验证码长度
* @return 验证码
*/
public static String genNumberCode( int codeLength){
return genCode(NUMBER_STR, codeLength);
}
/**
* 生成验证码
* @param str 验证码字符串
* @param codeLength 验证码长度
* @return 验证码
*/
public static String genCode (String str, int codeLength){
//将字符串转换为一个新的字符数组。
char[] verificationCodeArray = str.toCharArray();
Random random = new Random();
//计数器
int count = 0;
StringBuilder stringBuilder = new StringBuilder();
do {
//随机生成一个随机数
int index = random.nextInt(verificationCodeArray.length);
char c = verificationCodeArray[index];
//限制四位不重复数字
if (stringBuilder.indexOf(String.valueOf(c)) == -1) {
stringBuilder.append(c);
//计数器加1
count++;
}
//当count等于4时结束，随机生成四位数的验证码
} while (count != codeLength);
return stringBuilder.toString();
}
}

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

@ -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<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();
}
}

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

@ -0,0 +1,153 @@
package com.bwie.common.utils;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.PutObjectRequest;
import lombok.extern.log4j.Log4j2;
import org.springframework.web.multipart.MultipartFile;
import java.io.*;
import java.time.LocalDateTime;
import java.util.UUID;
/**
* Oss服务调用
*/
@Log4j2
public class OssUtil {
/**
* Endpoint 存储对象概述 阿里云主账号AccessKey，accessKeySecret拥有所有API的访问权限 访问路径前缀 存储对象概述
*/
private static String endPoint = "oss-cn-shanghai.aliyuncs.com";
private static String accessKeyId = "LTAI5tD2tppzLQ4Rb6yKYyph";
private static String accessKeySecret = "KEKNKwVvDq7PZLjE63NPBouqHXox4Q";
private static String accessPre = "https://dzlmuyu.oss-cn-shanghai.aliyuncs.com/";
/**
* bucket名称
* @return
*/
private static String bucketName = "dzlmuyu";
private static OSS ossClient ;
static {
ossClient = new OSSClientBuilder().build(
endPoint,
accessKeyId,
accessKeySecret);
log.info("oss服务连接成功！");
}
/**
* 默认路径上传本地文件
* @param filePath
*/
public static String uploadFile(String filePath){
return uploadFileForBucket(bucketName,getOssFilePath(filePath) ,filePath);
}
/**
* 默认路径上传multipartFile文件
* @param multipartFile
*/
public static String uploadMultipartFile(MultipartFile multipartFile) {
return uploadMultipartFile(bucketName,getOssFilePath(multipartFile.getOriginalFilename()),multipartFile);
}
/**
* 上传 multipartFile 类型文件
* @param bucketName
* @param ossPath
* @param multipartFile
*/
public static String uploadMultipartFile(String bucketName , String ossPath , MultipartFile multipartFile){
InputStream inputStream = null;
try {
inputStream = multipartFile.getInputStream();
} catch (IOException e) {
e.printStackTrace();
}
uploadFileInputStreamForBucket(bucketName, ossPath, inputStream);
return accessPre+ossPath;
}
/**
* 使用File上传PutObject上传文件 ** 程序默认使用次方法上传
* @param bucketName 实例名称
* @param ossPath oss存储路径
* @param filePath 本地文件路径
*/
public static String uploadFileForBucket(String bucketName , String ossPath , String filePath) {
// 创建PutObjectRequest对象。
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, ossPath, new File(filePath));
// 上传
ossClient.putObject(putObjectRequest);
return accessPre+ossPath;
}
/**
* 使用文件流上传到指定的bucket实例
* @param bucketName 实例名称
* @param ossPath oss存储路径
* @param filePath 本地文件路径
*/
public static String uploadFileInputStreamForBucket(String bucketName , String ossPath , String filePath){
// 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
InputStream inputStream = null;
try {
inputStream = new FileInputStream(filePath);
} catch (FileNotFoundException e) {
e.printStackTrace();
}
// 填写Bucket名称和Object完整路径。Object完整路径中不能包含Bucket名称。
uploadFileInputStreamForBucket(bucketName, ossPath, inputStream);
return accessPre+ossPath;
}
public static void uploadFileInputStreamForBucket(String bucketName , String ossPath , InputStream inputStream ){
ossClient.putObject(bucketName, ossPath, inputStream);
}
/**
* 下载
* @param ossFilePath
* @param filePath
*/
public static void downloadFile(String ossFilePath , String filePath ){
downloadFileForBucket(bucketName , ossFilePath , filePath);
}
/**
* 下载
* @param bucketName 实例名称
* @param ossFilePath oss存储路径
* @param filePath 本地文件路径
*/
public static void downloadFileForBucket(String bucketName , String ossFilePath , String filePath ){
ossClient.getObject(new GetObjectRequest(bucketName, ossFilePath), new File(filePath));
}
/**
*
* @return
*/
public static String getOssDefaultPath(){
LocalDateTime now = LocalDateTime.now();
String url =
now.getYear()+"/"+
now.getMonth()+"/"+
now.getDayOfMonth()+"/"+
now.getHour()+"/"+
now.getMinute()+"/";
return url;
}
public static String getOssFilePath(String filePath){
String fileSuf = filePath.substring(filePath.indexOf(".") + 1);
return getOssDefaultPath() + UUID.randomUUID().toString() + "." + fileSuf;
}
}

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

@ -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<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);
}
}

88
bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java 100644
View File

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

2
bwie-common/src/main/resources/META-INF/spring.factories 100644
View File

@ -0,0 +1,2 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.bwie.common.handle.GlodExceptionHandle

38
bwie-es/pom.xml 100644
View File

@ -0,0 +1,38 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-es</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
</project>

20
bwie-es/src/main/java/com/bwie/EsAppliction.java 100644
View File

@ -0,0 +1,20 @@
package com.bwie;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.scheduling.annotation.EnableScheduling;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:40
*/
@SpringBootApplication
@EnableFeignClients(basePackages = {"com.bwie"})
@EnableScheduling
public class EsAppliction {
public static void main(String[] args) {
SpringApplication.run(EsAppliction.class,args);
}
}

32
bwie-es/src/main/java/com/bwie/config/EsConfig.java 100644
View File

@ -0,0 +1,32 @@
package com.bwie.config;
/**
* @author gxb
* @description TODO
* @date 2023-11-29 11:50
*/
import lombok.Data;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 配置
*/
@Configuration
@ConfigurationProperties(prefix = "es")
@Data
public class EsConfig {
private String host;
private int port;
private String scheme;
//初始化
@Bean
public RestHighLevelClient restHighLevelClient(){
return new RestHighLevelClient(RestClient.builder(new HttpHost(host,port,scheme)));
}
}

31
bwie-es/src/main/java/com/bwie/controller/EsController.java 100644
View File

@ -0,0 +1,31 @@
package com.bwie.controller;
import com.bwie.common.domain.Log;
import com.bwie.common.domain.request.LogRequest;
import com.bwie.common.result.PageResult;
import com.bwie.common.result.Result;
import com.bwie.service.impl.EsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:38
*/
@RestController
public class EsController {
@Autowired
private EsService esService;
/**
* 多条件ES列表
*/
@PostMapping("/loglist")
public Result<List<Log>> loglist(@RequestBody LogRequest logRequest){
return esService.loglist(logRequest);
}
}

23
bwie-es/src/main/java/com/bwie/feign/EsFeign.java 100644
View File

@ -0,0 +1,23 @@
package com.bwie.feign;
import com.bwie.common.domain.Log;
import com.bwie.common.result.Result;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:38
*/
@FeignClient("bwie-item")
public interface EsFeign {
/**
* 日志列表
*
*/
@GetMapping("/LogList")
public Result<List<Log>> LogList();
}

20
bwie-es/src/main/java/com/bwie/service/impl/EsService.java 100644
View File

@ -0,0 +1,20 @@
package com.bwie.service.impl;
import com.bwie.common.domain.Log;
import com.bwie.common.domain.request.LogRequest;
import com.bwie.common.result.PageResult;
import com.bwie.common.result.Result;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:38
*/
public interface EsService {
void addBulk(List<Log> data);
Result<List<Log>> loglist(LogRequest logRequest);
}

150
bwie-es/src/main/java/com/bwie/service/impl/EsServicelmpl.java 100644
View File

@ -0,0 +1,150 @@
package com.bwie.service.impl;
import com.alibaba.fastjson.JSON;
import com.bwie.common.constants.TokenConstants;
import com.bwie.common.domain.Log;
import com.bwie.common.domain.User;
import com.bwie.common.domain.request.LogRequest;
import com.bwie.common.result.PageResult;
import com.bwie.common.result.Result;
import com.bwie.common.utils.JwtUtils;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.text.Text;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.*;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:38
*/
@Service
public class EsServicelmpl implements EsService{
@Autowired
private RestHighLevelClient client;
@Autowired
private HttpServletRequest request;
@Autowired
private StringRedisTemplate redisTemplate;
/**
* 增量同步
* @param data
*/
@Override
public void addBulk(List<Log> data) {
BulkRequest bulkRequest = new BulkRequest();
for (Log datum : data) {
String s = JSON.toJSONString(datum);
bulkRequest.add(new IndexRequest("log").id(datum.getLogId().toString())
.source(s, XContentType.JSON));
}
try {
client.bulk(bulkRequest, RequestOptions.DEFAULT);
} catch (IOException e) {
throw new RuntimeException(e);
}
}
/**
* 多条件列表
* @param logRequest
* @return
*/
@Override
public Result<List<Log>> loglist(LogRequest logRequest) {
SearchRequest searchRequest = new SearchRequest("log");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
//项目名称模糊查
if (null!=logRequest.getItemName() && ""!=logRequest.getItemName()){
MatchQueryBuilder name = QueryBuilders.matchQuery("itemName", logRequest.getItemName());
boolQuery.must(name);
}
//项目客户方模糊查
if (null!=logRequest.getItemCustomer() && ""!=logRequest.getItemCustomer()){
MatchQueryBuilder Cusname = QueryBuilders.matchQuery("itemCustomer", logRequest.getItemCustomer());
boolQuery.must(Cusname);
}
//区间
RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("itemApproval");
if (null!=logRequest.getItemApproval()){
RangeQueryBuilder gte = rangeQuery.gte(logRequest.getItemApproval().getTime());
boolQuery.must(gte);
}
if (null!=logRequest.getItemApprovals()){
RangeQueryBuilder lte = rangeQuery.lte(logRequest.getItemApprovals().getTime());
boolQuery.must(lte);
}
//多角色登录
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSON.parseObject(s, User.class);
logRequest.setUserId(user.getUserId());
//精确查询
if (null!=logRequest.getUserId()){
TermQueryBuilder id = QueryBuilders.termQuery("userId", logRequest.getUserId());
boolQuery.must(id);
}
//设置高亮
HighlightBuilder highlightBuilder = new HighlightBuilder();
highlightBuilder.field("itemName");
highlightBuilder.preTags("<span style=\"color: red\">");
highlightBuilder.postTags("</span>");
sourceBuilder.highlighter(highlightBuilder);
sourceBuilder.query(boolQuery);
ArrayList<Log> logs = new ArrayList<>();
searchRequest.source(sourceBuilder);
try {
SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
SearchHits hits = search.getHits();
for (SearchHit hit : hits.getHits()) {
String source = hit.getSourceAsString();
Log log = JSON.parseObject(source, Log.class);
//获取高亮
Map<String, HighlightField> highlightFields = hit.getHighlightFields();
HighlightField name = highlightFields.get("itemName");
StringBuffer stringBuffer = new StringBuffer();
if (null!=name){
for (Text fragment : name.getFragments()) {
stringBuffer.append(fragment);
}
log.setItemName(stringBuffer.toString());
}
logs.add(log);
}
} catch (IOException e) {
throw new RuntimeException(e);
}
return Result.success(logs,"Es列表");
}
}

33
bwie-es/src/main/java/com/bwie/take/Mytake.java 100644
View File

@ -0,0 +1,33 @@
package com.bwie.take;
import com.bwie.common.domain.Log;
import com.bwie.common.result.Result;
import com.bwie.feign.EsFeign;
import com.bwie.service.impl.EsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 16:39
*/
@Component
public class Mytake {
@Autowired
private EsService esService;
@Autowired
private EsFeign esFeign;
@Scheduled(cron = "10 * * * * ?")
public void take(){
Result<List<Log>> listResult = esFeign.LogList();
List<Log> data = listResult.getData();
if (data!=null){
System.out.println("定时器启动~~");
esService.addBulk(data);
}
}
}

39
bwie-es/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,39 @@
# Tomcat
server:
port: 9005
# Spring
spring:
elasticsearch:
rest:
uris: http://43.143.161.183:9200
main:
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: bwie-es
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 43.143.161.183:8848
config:
# 配置中心地址
server-addr: 43.143.161.183:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
es:
host: 43.143.161.183
port: 9200
scheme: http

42
bwie-gateway/pom.xml 100644
View File

@ -0,0 +1,42 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-gateway</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 公共模块 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-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>
</project>

17
bwie-gateway/src/main/java/com/bwie/gateway/GateWayAppliction.java 100644
View File

@ -0,0 +1,17 @@
package com.bwie.gateway;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.stereotype.Service;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 13:22
*/
@SpringBootApplication
public class GateWayAppliction {
public static void main(String[] args) {
SpringApplication.run(GateWayAppliction.class,args);
}
}

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

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

96
bwie-gateway/src/main/java/com/bwie/gateway/filters/AuthFilters.java 100644
View File

@ -0,0 +1,96 @@
package com.bwie.gateway.filters;
import com.bwie.common.constants.TokenConstants;
import com.bwie.common.utils.JwtUtils;
import com.bwie.common.utils.StringUtils;
import com.bwie.gateway.config.IgnoreWhiteConfig;
import com.bwie.gateway.utils.GatewayUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
import java.util.List;
import java.util.concurrent.TimeUnit;
/**
* @author gxb
* @description TODO
* @date 2023-12-14 19:37
*/
@Component
public class AuthFilters implements GlobalFilter, Ordered {
@Autowired
private StringRedisTemplate redisTemplate;
@Autowired
private IgnoreWhiteConfig ignoreWhiteConfig;
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
/**
* 获取白名单
*/
List<String> whites = ignoreWhiteConfig.getWhites();
/**
* 获取请求路径
*/
ServerHttpRequest request = exchange.getRequest();
String path = request.getURI().getPath();
/**
* 打印
*/
System.out.println("路径>>>>>>>>>>>>>"+path);
/**
* 判断是否存在白名单
*/
boolean matches = StringUtils.matches(path, whites);
/**
* 放行
*/
if (matches){
return chain.filter(exchange);
}
/**
* 判断token是否为空
*/
String token = request.getHeaders().getFirst(TokenConstants.TOKEN);
/**
* 非空判断
*/
if (null==token){
return GatewayUtils.errorResponse(exchange,"未携带token");
}
/**
* 解析token
*/
try {
JwtUtils.parseToken(token);
} catch (Exception e) {
return GatewayUtils.errorResponse(exchange,"token格式错误");
}
/**
* 判断token时效性
*/
String userKey = JwtUtils.getUserKey(token);
if (!redisTemplate.hasKey(TokenConstants.LOGIN_TOKEN_KEY+userKey)){
return GatewayUtils.errorResponse(exchange,"token过期了");
}
/**
* 续期
*/
redisTemplate.expire(TokenConstants.LOGIN_TOKEN_KEY+userKey,15, TimeUnit.MINUTES);
/**
* 放行
*/
return chain.filter(exchange);
}
@Override
public int getOrder() {
return 0;
}
}

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

@ -0,0 +1,98 @@
package com.bwie.gateway.utils;
import com.alibaba.fastjson.JSONObject;
import com.bwie.common.result.Result;
import com.bwie.common.utils.StringUtils;
import lombok.extern.log4j.Log4j2;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
/**
* @author DongZl
* @description: 网关处理工具类
*/
@Log4j2
public class GatewayUtils {
/**
* 添加请求头参数
* @param mutate 修改对象
* @param key 键
* @param value 值
*/
public static void addHeader(ServerHttpRequest.Builder mutate, String key, Object value) {
if (StringUtils.isEmpty(key)){
log.warn("添加请求头参数键不可以为空");
return;
}
if (value == null) {
log.warn("添加请求头参数：[{}]值为空",key);
return;
}
String valueStr = value.toString();
mutate.header(key, valueStr);
log.info("添加请求头参数成功 - 键:[{}] , 值:[{}]", key , value);
}
/**
* 删除请求头参数
* @param mutate 修改对象
* @param key 键
*/
public static void removeHeader(ServerHttpRequest.Builder mutate, String key) {
if (StringUtils.isEmpty(key)){
log.warn("删除请求头参数键不可以为空");
return;
}
mutate.headers(httpHeaders -> httpHeaders.remove(key)).build();
log.info("删除请求头参数 - 键:[{}]",key);
}
/**
* 错误结果响应
* @param exchange 响应上下文
* @param msg 响应消息
* @return
*/
public static Mono<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
bwie-gateway/src/main/resources/bootstrap.yml 100644
View File

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

92
bwie-modules/bwie-item/pom.xml 100644
View File

@ -0,0 +1,92 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>bwie-modules</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-item</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</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>
<!--fastDfs文件上传-->
<dependency>
<groupId>com.github.tobato</groupId>
<artifactId>fastdfs-client</artifactId>
<version>1.26.5</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.15</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.13</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.4.15</version>
</dependency>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
</dependency>
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-util</artifactId>
<version>9.3.7.v20160115</version>
</dependency>
</dependencies>
</project>

18
bwie-modules/bwie-item/src/main/java/com/bwie/item/ItemAppliction.java 100644
View File

@ -0,0 +1,18 @@
package com.bwie.item;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:44
*/
@SpringBootApplication
@EnableFeignClients(basePackages = {"com.bwie"})
public class ItemAppliction {
public static void main(String[] args) {
SpringApplication.run(ItemAppliction.class,args);
}
}

90
bwie-modules/bwie-item/src/main/java/com/bwie/item/controller/ItemController.java 100644
View File

@ -0,0 +1,90 @@
package com.bwie.item.controller;
import com.bwie.common.domain.Log;
import com.bwie.common.domain.request.Insertitem;
import com.bwie.common.domain.request.ItemRequest;
import com.bwie.common.domain.request.Update;
import com.bwie.common.result.Result;
import com.bwie.item.service.impl.ItemService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:27
*/
@RestController
public class ItemController {
@Autowired
private ItemService itemService;
/**
* 列表
*/
@PostMapping("/ItemList")
public Result ItemList(@RequestBody ItemRequest itemRequest){
return itemService.ItemList(itemRequest);}
/**
* 上传图片
* @param myFile
* @return
*/
@PostMapping("/getImage")
public Result getImage(@RequestParam("file")MultipartFile myFile){
return itemService.getImage(myFile);
}
/**
* 添加
*/
@PostMapping("Insertitem")
public Result Insertitem(@RequestBody Insertitem insertitem){
return itemService.Insertitem(insertitem);
}
/**
* 成本类型
*/
@PostMapping("/type")
public Result type(){
return itemService.type();
}
/**
* 获取当前登录人
*/
@GetMapping("/getInfo")
public Result getInfo(){
return itemService.getInfo();
}
/**
* 回显
*/
@PostMapping("/findBy/{itemId}")
public Result findBy(@PathVariable Integer itemId){
return itemService.findBy(itemId);
}
/**
* 修改
*/
@PostMapping("/upd")
public Result upd(@RequestBody Update update){
return itemService.upd(update);
}
/**
* 审核
*/
@PostMapping("/upState/{middleId}/{state}")
public Result upState(@PathVariable Integer middleId,@PathVariable Integer state){
return itemService.upState(middleId,state);
}
/**
* 日志列表
*
*/
@GetMapping("/LogList")
public Result<List<Log>> LogList(){
return itemService.LogList();
}
}

61
bwie-modules/bwie-item/src/main/java/com/bwie/item/feign/Counser.java 100644
View File

@ -0,0 +1,61 @@
package com.bwie.item.feign;
import com.bwie.common.constants.MqConstans;
import com.bwie.common.domain.Log;
import com.bwie.item.mapper.ItemMapper;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.io.IOException;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:44
*/
@Component
@RabbitListener(queues = MqConstans.SENDCODEQUEUE)
public class Counser {
@Autowired
private ItemMapper itemMapper;
@Autowired
private StringRedisTemplate redisTemplate;
@RabbitHandler
public void Coumer(Channel channel, Log log, Message message) throws IOException {
long deliveryTag = message.getMessageProperties().getDeliveryTag();
String messageId = message.getMessageProperties().getMessageId();
//消息不丢失
if (!redisTemplate.hasKey(messageId)){
redisTemplate.opsForValue().set(messageId,deliveryTag+"");
}
//重复消费
Long add = redisTemplate.opsForSet().add("cf" + messageId, messageId);
try {
if (add==1){
System.out.println("开始添加日志");
itemMapper.Ilog(log);
channel.basicAck(deliveryTag,false);
}else {
System.out.println("重复消费");
channel.basicReject(deliveryTag,false);
}
} catch (IOException e) {
String s = redisTemplate.opsForValue().get(messageId);
long l = Long.parseLong(s);
if (deliveryTag==(l+2)){
System.out.println("实在消费不了了");
channel.basicNack(deliveryTag,false,false);
}else {
System.out.println("再次消费");
channel.basicNack(deliveryTag,false,true);
}
}
}
}

66
bwie-modules/bwie-item/src/main/java/com/bwie/item/feign/CounserSend.java 100644
View File

@ -0,0 +1,66 @@
package com.bwie.item.feign;
import com.bwie.common.constants.MqConstans;
import com.bwie.common.domain.request.SendTel;
import com.bwie.item.mapper.ItemMapper;
import com.bwie.item.util.MsgUtil;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.io.IOException;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:44
*/
@Component
@RabbitListener(queues = MqConstans.SENDQUEUE)
public class CounserSend {
@Autowired
private ItemMapper itemMapper;
@Autowired
private MsgUtil msgUtil;
@Autowired
private StringRedisTemplate redisTemplate;
@RabbitHandler
public void Coumer(Channel channel, SendTel sendTel, Message message) throws IOException {
long deliveryTag = message.getMessageProperties().getDeliveryTag();
String messageId = message.getMessageProperties().getMessageId();
//消息不丢失
if (!redisTemplate.hasKey(messageId)){
redisTemplate.opsForValue().set(messageId,deliveryTag+"");
}
//重复消费
Long add = redisTemplate.opsForSet().add("cf" + messageId, messageId);
try {
if (add==1){
System.out.println("开始消费");
System.out.println("消费内容为："+sendTel.getCode());
msgUtil.sendMsg(sendTel.getPhone(),sendTel.getCode());
channel.basicAck(deliveryTag,false);
}else {
System.out.println("重复消费");
channel.basicReject(deliveryTag,false);
}
} catch (IOException e) {
String s = redisTemplate.opsForValue().get(messageId);
long l = Long.parseLong(s);
if (deliveryTag==(l+2)){
System.out.println("实在消费不了了");
channel.basicNack(deliveryTag,false,false);
}else {
System.out.println("再次消费");
channel.basicNack(deliveryTag,false,true);
}
}
}
}

92
bwie-modules/bwie-item/src/main/java/com/bwie/item/feign/MqConfig.java 100644
View File

@ -0,0 +1,92 @@
package com.bwie.item.feign;
import com.bwie.common.constants.MqConstans;
import lombok.extern.log4j.Log4j2;
import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
/**
* @author gxb
* @description TODO
* @date 2023-12-22 17:19
*/
@Configuration
@Log4j2
public class MqConfig implements RabbitTemplate.ConfirmCallback,RabbitTemplate.ReturnsCallback {
private RabbitTemplate rabbitTemplate;
//消息转换
@Bean
public MessageConverter messageConverter(){
return new Jackson2JsonMessageConverter();
}
//创建队列
@Bean
public Queue queue(){
return new Queue(MqConstans.SENDCODEQUEUE,true);
}
//创建交换机
@Bean
public DirectExchange directExchange(){
return new DirectExchange(MqConstans.SENDCODEEXCHANGE);
}
//绑定交换机和队列
@Bean
public Binding binding(){
return BindingBuilder.bind(queue()).to(directExchange()).with(MqConstans.SENDCODEKEY);
}
//创建队列
@Bean
public Queue queue01(){
return new Queue(MqConstans.SENDQUEUE,true);
}
//创建交换机
@Bean
public DirectExchange directExchange01(){
return new DirectExchange(MqConstans.SENDEXCHANGE);
}
//绑定交换机和队列
@Bean
public Binding binding01(){
return BindingBuilder.bind(queue01()).to(directExchange01()).with(MqConstans.SENDTELKEY);
}
@Primary
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
RabbitTemplate rabbitTemplate1 = new RabbitTemplate(connectionFactory);
this.rabbitTemplate=rabbitTemplate1;
rabbitTemplate.setMessageConverter(messageConverter());
RabbitTemplate();
return rabbitTemplate1;
}
//初始化
public void RabbitTemplate(){
rabbitTemplate.setConfirmCallback(this);
rabbitTemplate.setReturnsCallback(this);
}
@Override
public void confirm(CorrelationData correlationData, boolean b, String s) {
if (b){
log.info("{}消息成功到达交换机",correlationData.getId());
}else {
log.error("{}消息丢失",correlationData.getId());
}
}
@Override
public void returnedMessage(ReturnedMessage returnedMessage) {
log.error("{}消息为进入队列",returnedMessage.getMessage().getMessageProperties().getMessageId());
}
}

49
bwie-modules/bwie-item/src/main/java/com/bwie/item/mapper/ItemMapper.java 100644
View File

@ -0,0 +1,49 @@
package com.bwie.item.mapper;
import com.bwie.common.domain.Item;
import com.bwie.common.domain.Log;
import com.bwie.common.domain.Middle;
import com.bwie.common.domain.Type;
import com.bwie.common.domain.request.Insertitem;
import com.bwie.common.domain.request.ItemRequest;
import com.bwie.common.domain.request.Update;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:28
*/
@Component
@Mapper
public interface ItemMapper {
List<Item> ItemList(ItemRequest itemRequest);
void Insertitem(Insertitem insertitem);
void InsertType(Insertitem insertitem);
List<Type> type();
List<Middle> findBy(Integer itemId);
void upd(Update update);
void Ilog(Log log);
Integer upState(@Param("middleId") Integer middleId, @Param("state") Integer state);
Middle findMiddle(Integer middleId);
void upds(Update update);
List<Log> LogList();
}

38
bwie-modules/bwie-item/src/main/java/com/bwie/item/service/impl/ItemService.java 100644
View File

@ -0,0 +1,38 @@
package com.bwie.item.service.impl;
import com.bwie.common.domain.Log;
import com.bwie.common.domain.request.Insertitem;
import com.bwie.common.domain.request.ItemRequest;
import com.bwie.common.domain.request.Update;
import com.bwie.common.result.Result;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:28
*/
public interface ItemService {
Result ItemList(ItemRequest itemRequest);
Result getImage(MultipartFile myFile);
Result Insertitem(Insertitem insertitem);
Result type();
Result getInfo();
Result findBy(Integer itemId);
Result upd(Update update);
Result upState(Integer middleId, Integer state);
Result<List<Log>> LogList();
}

211
bwie-modules/bwie-item/src/main/java/com/bwie/item/service/impl/ItemServicelmpl.java 100644
View File

@ -0,0 +1,211 @@
package com.bwie.item.service.impl;
import com.alibaba.fastjson.JSON;
import com.bwie.common.constants.MqConstans;
import com.bwie.common.constants.TokenConstants;
import com.bwie.common.domain.*;
import com.bwie.common.domain.request.Insertitem;
import com.bwie.common.domain.request.ItemRequest;
import com.bwie.common.domain.request.SendTel;
import com.bwie.common.domain.request.Update;
import com.bwie.common.exception.auth.AuthException;
import com.bwie.common.result.Result;
import com.bwie.common.utils.JwtUtils;
import com.bwie.item.mapper.ItemMapper;
import com.bwie.item.util.FastUtil;
import com.bwie.item.util.MsgUtil;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.UUID;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:28
*/
@Service
public class ItemServicelmpl implements ItemService{
@Autowired
private ItemMapper itemMapper;
@Autowired
private HttpServletRequest request;
@Autowired
private StringRedisTemplate redisTemplate;
@Autowired
private FastUtil fastUtil;
@Autowired
private RabbitTemplate rabbitTemplate;
@Override
public Result ItemList(ItemRequest itemRequest) {
//获取当前登录人
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSON.parseObject(s, User.class);
itemRequest.setRole(user.getRole());
itemRequest.setUserId(user.getUserId());
System.out.println("查询条件"+itemRequest);
//查询列表
List<Item> itemList = itemMapper.ItemList(itemRequest);
return Result.success(itemList,"项目列表");
}
/**
* 上传图片
* @param myFile
* @return
*/
@Override
public Result getImage(MultipartFile myFile) {
String url = "";
try {
url = fastUtil.upload(myFile);
if (url.equals("")){
throw new AuthException("上传失败！！");
}
} catch (Exception e) {
throw new RuntimeException(e);
}
return Result.success("http://43.143.161.183:8888/"+url,"上传成功~~");
}
/**
* 添加
* @param insertitem
* @return
*/
@Override
public Result Insertitem(Insertitem insertitem) {
//获取当前登录人
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSON.parseObject(s, User.class);
insertitem.setUserId(user.getUserId());
//添加项目
itemMapper.Insertitem(insertitem);
//添加中间表
//成本类型
itemMapper.InsertType(insertitem);
return Result.success("提交成功！！");
}
@Override
public Result type() {
List<Type> typeList = itemMapper.type();
return Result.success(typeList);
}
/**
* 获取当前登录人
* @return
*/
@Override
public Result getInfo() {
//获取当前登录人
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSON.parseObject(s, User.class);
return Result.success(user);
}
/**
* 回显
* @param itemId
* @return
*/
@Override
public Result findBy(Integer itemId) {
List<Middle> middleList = itemMapper.findBy(itemId);
return Result.success(middleList);
}
/**
* 修改
* @param update
* @return
*/
@Override
public Result upd(Update update) {
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSON.parseObject(s, User.class);
//判断是否为审核员
if (user.getRole()==2){
SendTel sendTel = new SendTel();
sendTel.setPhone(user.getTel());
//修改前
Middle middle = itemMapper.findMiddle(update.getMiddleId());
itemMapper.upds(update);
//修改后
Middle middle02 = itemMapper.findMiddle(update.getMiddleId());
//[项目名称]的估算类型[类型名称]金额未审核通过，金额：[估算金额]变更为[概算金额]
String code = "项目编号：【"+middle02.getItemId()+"】，的估算类型【"+middle02.getTypeName()+"】" +
"金额未通过，金额：【"+middle.getFinallymoney()+"】变更为【"+update.getMiddleFinally()+"】";
System.out.println("输出内容："+code);
sendTel.setCode(code);
rabbitTemplate.convertAndSend(MqConstans.SENDEXCHANGE,MqConstans.SENDTELKEY
,sendTel,message -> {
message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
return message;
},new CorrelationData(UUID.randomUUID().toString()));
}
itemMapper.upd(update);
return Result.success("修改成功");
}
/**
* 审核
* @param middleId
* @param state
* @return
*/
@Override
public Result upState(Integer middleId, Integer state) {
Integer i = itemMapper.upState(middleId,state);
//调用MQ添加日志
String token = request.getHeader(TokenConstants.TOKEN);
String userKey = JwtUtils.getUserKey(token);
String s = redisTemplate.opsForValue().get(TokenConstants.LOGIN_TOKEN_KEY + userKey);
User user = JSON.parseObject(s, User.class);
Middle middle = itemMapper.findMiddle(middleId);
Log log = new Log();
log.setItemId(middle.getItemId());
log.setUserId(user.getUserId());
/**
* 审核日志
*/
rabbitTemplate.convertAndSend(MqConstans.SENDCODEEXCHANGE,MqConstans.SENDCODEKEY,
log,message -> {
message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
return message;
},new CorrelationData(UUID.randomUUID().toString()));
return Result.success("审核成功");
}
/**
* 日志列表
* @return
*/
@Override
public Result<List<Log>> LogList() {
List<Log> logList = itemMapper.LogList();
return Result.success(logList);
}
}

55
bwie-modules/bwie-item/src/main/java/com/bwie/item/util/FastUtil.java 100644
View File

@ -0,0 +1,55 @@
package com.bwie.item.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.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 "删除成功";
}
}

312
bwie-modules/bwie-item/src/main/java/com/bwie/item/util/HttpUtils.java 100644
View File

@ -0,0 +1,312 @@
package com.bwie.item.util;
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.commons.lang.StringUtils;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.conn.ClientConnectionManager;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.SSLSocketFactory;
import org.apache.http.entity.ByteArrayEntity;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
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() {
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);
}
}
}

54
bwie-modules/bwie-item/src/main/java/com/bwie/item/util/MsgUtil.java 100644
View File

@ -0,0 +1,54 @@
package com.bwie.item.util;
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;
@Component
public class MsgUtil {
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 = "dfc474d253d2470daebd5edc0d2f52ed";
Map<String, String> headers = new HashMap<String, String>();
//最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
headers.put("Authorization", "APPCODE " + appcode);
Map<String, String> querys = new HashMap<String, String>();
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<String, String> bodys = new HashMap<String, String>();
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);
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}

42
bwie-modules/bwie-item/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,42 @@
# Tomcat
server:
port: 9003
# Spring
spring:
main:
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: bwie-item
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 43.143.161.183:8848
config:
# 配置中心地址
server-addr: 43.143.161.183: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: 43.143.161.183:22122
web-server-url: 43.143.161.183:8888
pool:
jmx-enabled: false
# 生成缩略图
thumb-image:
height: 500
width: 500

73
bwie-modules/bwie-item/src/main/resources/mapper/ItemMapper.xml 100644
View File

@ -0,0 +1,73 @@
<?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.bwie.item.mapper.ItemMapper">
<insert id="Insertitem" useGeneratedKeys="true" keyProperty="itemId">
INSERT INTO `item`.`t_item` ( `item_name`, `item_encod`, `item_customer`, `item_approval` ,`user_id`,`item_image`) VALUES
(#{itemName}, #{itemEncod}, #{itemCustomer}, #{itemApproval}, #{userId},#{itemImage});
</insert>
<insert id="InsertType">
INSERT INTO `item`.`item_type`
(`item_id`, `type_id`, `middle_money`) VALUES
<foreach collection="types" item="ty" separator=",">
<foreach collection="prices" item="price" separator=",">
(#{itemId},#{ty},#{price})
</foreach>
</foreach>
</insert>
<insert id="Ilog">
INSERT INTO `item`.`log`
( `item_id`, `user_id`, `log_date`) VALUES
( #{itemId}, #{userId}, now());
</insert>
<update id="upd">
update item_type set middle_money = #{middleMoney},middle_state = 1 where middle_id = #{middleId}
</update>
<update id="upState">
update item_type set middle_state = #{state} where middle_id = #{middleId}
</update>
<update id="upds">
update item_type set middle_money = #{middleMoney},middle_state = 3 where middle_id = #{middleId}
</update>
<select id="ItemList" resultType="com.bwie.common.domain.Item">
SELECT t.*,sum(y.middle_money) as middleMoney ,sum(y.middle_finally) middleFinally,u.username username FROM t_item t
LEFT JOIN user u ON t.user_id=u.user_id
left JOIN item_type y on t.item_id=y.item_id
<where>
<if test="null!=itemName and ''!=itemName">
item_name like concat('%',#{itemName},'%')
</if>
<if test="null!=itemCustomer and ''!=itemCustomer">
and item_customer = #{itemCustomer}
</if>
<if test="null!=itemApproval">
and item_approval >#{itemApproval}
</if>
<if test="null!=itemApprovals">
and item_approval &lt;#{itemApprovals}
</if>
<if test="role==2">
and t.item_state = 1
</if>
<if test="role==3">
and t.user_id=#{userId}
</if>
</where>
GROUP BY t.item_id
</select>
<select id="type" resultType="com.bwie.common.domain.Type">
select type_id,type_name from type
</select>
<select id="findBy" resultType="com.bwie.common.domain.Middle">
SELECT * FROM item_type m LEFT JOIN type t on m.type_id=t.type_id where item_id=#{itemId} GROUP BY t.type_id
</select>
<select id="findMiddle" resultType="com.bwie.common.domain.Middle">
select * from item_type where middle_id=#{middleId}
</select>
<select id="LogList" resultType="com.bwie.common.domain.Log">
SELECT * FROM log l LEFT JOIN t_item i on l.item_id=i.item_id
LEFT JOIN user u on l.user_id=u.user_id
</select>
</mapper>

60
bwie-modules/bwie-user/pom.xml 100644
View File

@ -0,0 +1,60 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>bwie-modules</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-user</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- SpringBoot Web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</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>
</dependencies>
</project>

16
bwie-modules/bwie-user/src/main/java/com/bwie/user/UserAppliction.java 100644
View File

@ -0,0 +1,16 @@
package com.bwie.user;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 10:20
*/
@SpringBootApplication
public class UserAppliction {
public static void main(String[] args) {
SpringApplication.run(UserAppliction.class,args);
}
}

27
bwie-modules/bwie-user/src/main/java/com/bwie/user/controller/UserController.java 100644
View File

@ -0,0 +1,27 @@
package com.bwie.user.controller;
import com.bwie.common.domain.User;
import com.bwie.common.result.Result;
import com.bwie.user.service.impl.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:58
*/
@RestController
public class UserController {
@Autowired
private UserService userService;
/**
* 查询姓名
*/
@PostMapping("/findName/{username}")
public Result<User> findName(@PathVariable String username){
return userService.findName(username);
}
}

16
bwie-modules/bwie-user/src/main/java/com/bwie/user/mapper/UserMapper.java 100644
View File

@ -0,0 +1,16 @@
package com.bwie.user.mapper;
import com.bwie.common.domain.User;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:58
*/
@Component
@Mapper
public interface UserMapper {
User findName(String username);
}

14
bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserService.java 100644
View File

@ -0,0 +1,14 @@
package com.bwie.user.service.impl;
import com.bwie.common.domain.User;
import com.bwie.common.result.Result;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:58
*/
public interface UserService {
Result<User> findName(String username);
}

29
bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserServicelmpl.java 100644
View File

@ -0,0 +1,29 @@
package com.bwie.user.service.impl;
import com.bwie.common.domain.User;
import com.bwie.common.result.Result;
import com.bwie.user.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 9:59
*/
@Service
public class UserServicelmpl implements UserService{
@Autowired
private UserMapper userMapper;
/**
* 查询姓名
* @param username
* @return
*/
@Override
public Result<User> findName(String username) {
User user = userMapper.findName(username);
return Result.success(user);
}
}

42
bwie-modules/bwie-user/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,42 @@
# Tomcat
server:
port: 9002
# Spring
spring:
main:
allow-circular-references: true
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
application:
# 应用名称
name: bwie-user
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 43.143.161.183:8848
config:
# 配置中心地址
server-addr: 43.143.161.183: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: 121.40.42.67:22122
web-server-url: 121.40.42.67:8888
pool:
jmx-enabled: false
# 生成缩略图
thumb-image:
height: 500
width: 500

14
bwie-modules/bwie-user/src/main/resources/mapper/UserMapper.xml 100644
View File

@ -0,0 +1,14 @@
<?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.bwie.user.mapper.UserMapper">
<sql id="user">
user_id,
username,
password,
tel,
role
</sql>
<select id="findName" resultType="com.bwie.common.domain.User">
select <include refid="user"></include> from user where username = #{username}
</select>
</mapper>

25
bwie-modules/pom.xml 100644
View File

@ -0,0 +1,25 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-modules</artifactId>
<packaging>pom</packaging>
<modules>
<module>bwie-user</module>
<module>bwie-item</module>
</modules>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>

41
bwie-mq/pom.xml 100644
View File

@ -0,0 +1,41 @@
<?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>
<parent>
<groupId>com.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>bwie-mq</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- 系统公共 依赖 -->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-item</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project>

20
bwie-mq/src/main/java/com/com/bwie/MqAppliction.java 100644
View File

@ -0,0 +1,20 @@
package com.com.bwie;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:45
*/
@SpringBootApplication(
scanBasePackages = {"com.bwie"}
)
@EnableFeignClients
public class MqAppliction {
public static void main(String[] args) {
SpringApplication.run(MqAppliction.class,args);
}
}

35
bwie-mq/src/main/java/com/com/bwie/controller/ProController.java 100644
View File

@ -0,0 +1,35 @@
package com.com.bwie.controller;
import com.bwie.common.constants.MqConstans;
import com.bwie.common.domain.Log;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.UUID;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:42
*/
@RestController
public class ProController {
@Autowired
private RabbitTemplate rabbitTemplate;
@PostMapping("/InsertLog")
public void InsertLog(@RequestBody Log log){
System.out.println("开始创建对列");
rabbitTemplate.convertAndSend(MqConstans.SENDCODEEXCHANGE,MqConstans.SENDCODEKEY,log,message -> {
message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
return message;
},new CorrelationData(UUID.randomUUID().toString()));
}
}

61
bwie-mq/src/main/java/com/com/bwie/mq/config/Counser.java 100644
View File

@ -0,0 +1,61 @@
package com.com.bwie.mq.config;
import com.bwie.common.constants.MqConstans;
import com.bwie.common.domain.Log;
import com.bwie.item.mapper.ItemMapper;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.io.IOException;
/**
* @author gxb
* @description TODO
* @date 2024-01-03 14:44
*/
@Component
@RabbitListener(queues = MqConstans.SENDCODEQUEUE)
public class Counser {
@Autowired
private ItemMapper itemMapper;
@Autowired
private StringRedisTemplate redisTemplate;
@RabbitHandler
public void Coumer(Channel channel, Log log, Message message) throws IOException {
long deliveryTag = message.getMessageProperties().getDeliveryTag();
String messageId = message.getMessageProperties().getMessageId();
//消息不丢失
if (!redisTemplate.hasKey(messageId)){
redisTemplate.opsForValue().set(messageId,deliveryTag+"");
}
//重复消费
Long add = redisTemplate.opsForSet().add("cf" + messageId, messageId);
try {
if (add==1){
System.out.println("开始添加日志");
itemMapper.Ilog(log);
channel.basicAck(deliveryTag,false);
}else {
System.out.println("重复消费");
channel.basicReject(deliveryTag,false);
}
} catch (IOException e) {
String s = redisTemplate.opsForValue().get(messageId);
long l = Long.parseLong(s);
if (deliveryTag==(l+2)){
System.out.println("实在消费不了了");
channel.basicNack(deliveryTag,false,false);
}else {
System.out.println("再次消费");
channel.basicNack(deliveryTag,false,true);
}
}
}
}

79
bwie-mq/src/main/java/com/com/bwie/mq/config/MqConfig.java 100644
View File

@ -0,0 +1,79 @@
package com.com.bwie.mq.config;
import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.C;
import com.bwie.common.constants.MqConstans;
import lombok.extern.log4j.Log4j;
import lombok.extern.log4j.Log4j2;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.web.bind.annotation.ExceptionHandler;
/**
* @author gxb
* @description TODO
* @date 2023-12-22 17:19
*/
@Configuration
@Log4j2
public class MqConfig implements RabbitTemplate.ConfirmCallback,RabbitTemplate.ReturnsCallback {
private RabbitTemplate rabbitTemplate;
//消息转换
@Bean
public MessageConverter messageConverter(){
return new Jackson2JsonMessageConverter();
}
//创建队列
@Bean
public Queue queue(){
return new Queue(MqConstans.SENDCODEQUEUE,true);
}
//创建交换机
@Bean
public DirectExchange directExchange(){
return new DirectExchange(MqConstans.SENDCODEEXCHANGE);
}
//绑定交换机和队列
@Bean
public Binding binding(){
return BindingBuilder.bind(queue()).to(directExchange()).with(MqConstans.SENDCODEKEY);
}
@Primary
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
RabbitTemplate rabbitTemplate1 = new RabbitTemplate(connectionFactory);
this.rabbitTemplate=rabbitTemplate1;
rabbitTemplate.setMessageConverter(messageConverter());
RabbitTemplate();
return rabbitTemplate1;
}
//初始化
public void RabbitTemplate(){
rabbitTemplate.setConfirmCallback(this);
rabbitTemplate.setReturnsCallback(this);
}
@Override
public void confirm(CorrelationData correlationData, boolean b, String s) {
if (b){
log.info("{}消息成功到达交换机",correlationData.getId());
}else {
log.error("{}消息丢失",correlationData.getId());
}
}
@Override
public void returnedMessage(ReturnedMessage returnedMessage) {
log.error("{}消息为进入队列",returnedMessage.getMessage().getMessageProperties().getMessageId());
}
}

30
bwie-mq/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,30 @@
# 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: bwie-mq
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: 43.143.161.183:8848
config:
# 配置中心地址
server-addr: 43.143.161.183:8848
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}

74
pom.xml 100644
View File

@ -0,0 +1,74 @@
<?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.bwie</groupId>
<artifactId>Guoxubao-yuekao</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>pom</packaging>
<modules>
<module>bwie-common</module>
<module>bwie-auth</module>
<module>bwie-gateway</module>
<module>bwie-modules</module>
<module>bwie-mq</module>
<module>bwie-es</module>
<module>bwie-api</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>
<!-- 系统公共 依赖 版本号定义-->
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!-- servlet -api -->
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.5</version>
</dependency>
<dependency>
<groupId>com.bwie</groupId>
<artifactId>bwie-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
</dependencyManagement>
</project>