Compare commits
No commits in common. 'develop' and 'soul2/mobile_api' have entirely different histories.
develop
...
soul2/mobi
66 changed files with 111 additions and 2518 deletions
@ -1,18 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.annotation; |
||||
|
||||
import java.lang.annotation.ElementType; |
||||
import java.lang.annotation.Retention; |
||||
import java.lang.annotation.RetentionPolicy; |
||||
import java.lang.annotation.Target; |
||||
|
||||
/** |
||||
* 跳过加解密 |
||||
* |
||||
* @author Soul2 |
||||
* @date 2024-04-08 |
||||
*/ |
||||
@Target({ElementType.METHOD, ElementType.TYPE}) |
||||
@Retention(RetentionPolicy.RUNTIME) |
||||
public @interface SkinEncrypt { |
||||
|
||||
} |
||||
@ -1,15 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.annotation; |
||||
|
||||
import java.lang.annotation.ElementType; |
||||
import java.lang.annotation.Retention; |
||||
import java.lang.annotation.RetentionPolicy; |
||||
import java.lang.annotation.Target; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-04-02 |
||||
*/ |
||||
@Target({ElementType.METHOD, ElementType.TYPE}) |
||||
@Retention(RetentionPolicy.RUNTIME) |
||||
public @interface SkinLogin { |
||||
} |
||||
@ -1,99 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.bean; |
||||
|
||||
import cn.soul2.jyjc.admin.entity.UserLoginOutDO; |
||||
import org.apache.commons.lang3.StringUtils; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.util.Collection; |
||||
import java.util.concurrent.ConcurrentHashMap; |
||||
|
||||
@Component |
||||
public class UserLoginStatusBean { |
||||
|
||||
private ConcurrentHashMap<String, UserLoginOutDO> loginStatusMap = new ConcurrentHashMap<>(); |
||||
|
||||
public void loadUserLoginStatus(Collection<UserLoginOutDO> caches) { |
||||
for (UserLoginOutDO cache : caches) { |
||||
loginStatusMap.put(cache.getId(), cache); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 缓存登录信息 |
||||
* |
||||
* @param token token |
||||
* @param loginOutStatus 登录信息 |
||||
*/ |
||||
public void login(String token, UserLoginOutDO loginOutStatus) { |
||||
loginStatusMap.put(token, loginOutStatus); |
||||
} |
||||
|
||||
/** |
||||
* 从缓存读取登录信息 |
||||
* |
||||
* @param token token |
||||
* @return {@link UserLoginOutDO} |
||||
*/ |
||||
public UserLoginOutDO getStatus(String token) { |
||||
UserLoginOutDO loginStatus = loginStatusMap.getOrDefault(token, null); |
||||
if (loginStatus.getLapseTime() != null) { |
||||
LocalDateTime now = LocalDateTime.now(); |
||||
if (now.isAfter(loginStatus.getLapseTime())) { |
||||
logout(token); |
||||
return null; |
||||
} |
||||
} |
||||
return loginStatus; |
||||
} |
||||
|
||||
/** |
||||
* 为key设置登出 |
||||
* |
||||
* @param token token |
||||
* @return {@link Boolean} |
||||
*/ |
||||
public Boolean logout(String token) { |
||||
if (StringUtils.isNotBlank(token) && loginStatusMap.containsKey(token)) { |
||||
UserLoginOutDO removedUser = loginStatusMap.remove(token); |
||||
// 返回true表示成功登出，返回false表示未成功登出
|
||||
return removedUser != null; |
||||
} |
||||
return Boolean.TRUE; |
||||
} |
||||
|
||||
public Boolean logoutByUserId(String userId) { |
||||
final String[] targetKey = {null}; |
||||
loginStatusMap.forEach((k, v) -> { |
||||
if (targetKey[0] == null && v.getUserId().equals(userId)) { |
||||
targetKey[0] = k; |
||||
} |
||||
}); |
||||
return logout(targetKey[0]); |
||||
} |
||||
|
||||
public String getTokenByUsername(String username) { |
||||
final String[] token = {null}; |
||||
loginStatusMap.forEach((k, v) -> { |
||||
if (token[0] == null && v.getUserName().equals(username)) { |
||||
token[0] = k; |
||||
} |
||||
}); |
||||
return token[0]; |
||||
} |
||||
|
||||
public Boolean containsToken(String token) { |
||||
if (StringUtils.isBlank(token)) { |
||||
return Boolean.FALSE; |
||||
} |
||||
UserLoginOutDO loginStatus = loginStatusMap.getOrDefault(token, null); |
||||
if (loginStatus != null && loginStatus.getLapseTime() != null) { |
||||
LocalDateTime now = LocalDateTime.now(); |
||||
if (now.isAfter(loginStatus.getLapseTime())) { |
||||
logout(token); |
||||
} |
||||
} |
||||
return loginStatusMap.containsKey(token); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,65 @@ |
||||
package cn.soul2.jyjc.admin.config; |
||||
|
||||
import org.springframework.beans.factory.annotation.Value; |
||||
import org.springframework.context.annotation.Configuration; |
||||
import org.springframework.web.servlet.config.annotation.CorsRegistry; |
||||
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; |
||||
|
||||
import java.util.ArrayList; |
||||
import java.util.Arrays; |
||||
import java.util.List; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-25 |
||||
*/ |
||||
@Configuration |
||||
public class CorsConfig implements WebMvcConfigurer { |
||||
|
||||
@Value("${cors.allow-origins}") |
||||
private String[] allowOriginArray; |
||||
|
||||
/** |
||||
* 将数组转换为List进行动态添加 |
||||
*/ |
||||
private final List<String> allowOriginList = new ArrayList<>(); |
||||
|
||||
// private static boolean isLocalV4Address(String ipAddress) {
|
||||
// // todo 为进行手机测试而增加的读取内网IP,正式上线时须注释掉
|
||||
// String[] parts = ipAddress.split("\\.");
|
||||
// // 判断是否是有效的IPv4地址并且属于局域网
|
||||
// return parts.length == 4 && parts[0].equals("192") && parts[1].equals("168");
|
||||
// }
|
||||
|
||||
@Override |
||||
public void addCorsMappings(CorsRegistry registry) { |
||||
allowOriginList.addAll(Arrays.asList(allowOriginArray)); |
||||
// // todo 为进行手机测试而增加的读取内网IP,正式上线时须注释掉
|
||||
// try {
|
||||
// Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces();
|
||||
// while (networkInterfaces.hasMoreElements()) {
|
||||
// NetworkInterface networkInterface = networkInterfaces.nextElement();
|
||||
// Enumeration<InetAddress> inetAddresses = networkInterface.getInetAddresses();
|
||||
// while (inetAddresses.hasMoreElements()) {
|
||||
// InetAddress inetAddress = inetAddresses.nextElement();
|
||||
// if (isLocalV4Address(inetAddress.getHostAddress())) {
|
||||
// System.out.println("Local IPv4 Address: " + inetAddress.getHostAddress());
|
||||
// allowOriginList.add("http://" + inetAddress.getHostAddress() + ":7620");
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
// } catch (Exception e) {
|
||||
// e.printStackTrace();
|
||||
// }
|
||||
|
||||
// 打印 allowOriginList 到控制台
|
||||
// System.out.println("allowOriginList: " + allowOriginList);
|
||||
|
||||
registry.addMapping("/**") |
||||
.allowedOrigins(allowOriginList.toArray(new String[0])) |
||||
.allowCredentials(true) |
||||
.allowedMethods("POST") |
||||
.maxAge(3600); |
||||
} |
||||
|
||||
} |
||||
@ -1,41 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.config; |
||||
|
||||
import cn.soul2.jyjc.admin.filter.ReplaceStreamFilter; |
||||
import org.springframework.boot.web.servlet.FilterRegistrationBean; |
||||
import org.springframework.context.annotation.Bean; |
||||
import org.springframework.context.annotation.Configuration; |
||||
|
||||
import javax.servlet.Filter; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @description 过滤器配置类 |
||||
* @date 2024-04-08 |
||||
* <p>照抄自 <a href="https://blog.csdn.net/shaoduo/article/details/122322578">Shao duo</a></p> |
||||
*/ |
||||
@Configuration |
||||
public class FilterConfig { |
||||
/** |
||||
* 注册过滤器 |
||||
* |
||||
* @return FilterRegistrationBean |
||||
*/ |
||||
@Bean |
||||
public FilterRegistrationBean someFilterRegistration() { |
||||
FilterRegistrationBean registration = new FilterRegistrationBean(); |
||||
registration.setFilter(replaceStreamFilter()); |
||||
registration.addUrlPatterns("/*"); |
||||
registration.setName("streamFilter"); |
||||
return registration; |
||||
} |
||||
|
||||
/** |
||||
* 实例化StreamFilter |
||||
* |
||||
* @return Filter |
||||
*/ |
||||
@Bean(name = "replaceStreamFilter") |
||||
public Filter replaceStreamFilter() { |
||||
return new ReplaceStreamFilter(); |
||||
} |
||||
} |
||||
@ -1,67 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.config; |
||||
|
||||
import cn.soul2.jyjc.admin.interceptor.FinallyInterceptor; |
||||
import org.springframework.beans.factory.annotation.Value; |
||||
import org.springframework.context.annotation.Bean; |
||||
import org.springframework.context.annotation.Configuration; |
||||
import org.springframework.web.cors.CorsConfiguration; |
||||
import org.springframework.web.cors.UrlBasedCorsConfigurationSource; |
||||
import org.springframework.web.filter.CorsFilter; |
||||
import org.springframework.web.servlet.config.annotation.InterceptorRegistry; |
||||
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; |
||||
|
||||
/** |
||||
* 注册拦截器 |
||||
* |
||||
* @author Soul2 |
||||
* @date 2024-04-02 |
||||
*/ |
||||
|
||||
@Configuration |
||||
public class WebMvcConfig implements WebMvcConfigurer { |
||||
|
||||
@Value("${cors.allow-origin}") |
||||
private String[] allowOrigin; |
||||
|
||||
@Bean |
||||
public CorsFilter corsFilter() { |
||||
CorsConfiguration config = new CorsConfiguration(); |
||||
// 设置允许跨域请求的域名
|
||||
for (String url : allowOrigin) { |
||||
config.addAllowedOrigin(url); |
||||
} |
||||
// 是否允许证书 不再默认开启
|
||||
// config.setAllowCredentials(true);
|
||||
// 设置允许的方法
|
||||
config.addAllowedMethod("*"); |
||||
// 允许任何头
|
||||
config.addAllowedHeader("*"); |
||||
config.addExposedHeader("token"); |
||||
config.setMaxAge(3600L); |
||||
UrlBasedCorsConfigurationSource configSource = new UrlBasedCorsConfigurationSource(); |
||||
configSource.registerCorsConfiguration("/**", config); |
||||
return new CorsFilter(configSource); |
||||
} |
||||
|
||||
// @Override
|
||||
// public void addCorsMappings(CorsRegistry registry) {
|
||||
// registry.addMapping("/**")
|
||||
// .allowedHeaders("*")
|
||||
// .allowedOrigins(allowOrigin)
|
||||
// .allowCredentials(true)
|
||||
// .allowedMethods("POST")
|
||||
// .maxAge(3600);
|
||||
// }
|
||||
|
||||
@Bean |
||||
FinallyInterceptor createFinallyInterceptor() { |
||||
return new FinallyInterceptor(); |
||||
} |
||||
|
||||
@Override |
||||
public void addInterceptors(InterceptorRegistry registry) { |
||||
registry.addInterceptor(createFinallyInterceptor()) |
||||
// 拦截所有路径
|
||||
.addPathPatterns("/**"); |
||||
} |
||||
} |
||||
@ -1,41 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.controller; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.AnswerPageQueryDTO; |
||||
import cn.soul2.jyjc.admin.dto.AnswerSubmitDTO; |
||||
import cn.soul2.jyjc.admin.service.IAnswerService; |
||||
import cn.soul2.jyjc.admin.utils.base.BackUtils; |
||||
import cn.soul2.jyjc.admin.vo.AnswerSheetVO; |
||||
import cn.soul2.jyjc.admin.vo.base.Back; |
||||
import cn.soul2.jyjc.admin.vo.base.VPage; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.web.bind.annotation.PostMapping; |
||||
import org.springframework.web.bind.annotation.RequestBody; |
||||
import org.springframework.web.bind.annotation.RequestMapping; |
||||
import org.springframework.web.bind.annotation.RestController; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-27 13:24 |
||||
*/ |
||||
|
||||
@Slf4j |
||||
@RestController |
||||
@RequestMapping("/answer") |
||||
public class AnswerController { |
||||
|
||||
@Autowired |
||||
private IAnswerService answerService; |
||||
|
||||
@PostMapping("submit") |
||||
public Back<Boolean> submit(@RequestBody AnswerSubmitDTO dto) { |
||||
return BackUtils.success(answerService.handleSubmit(dto)); |
||||
} |
||||
|
||||
@PostMapping("page") |
||||
public Back<VPage<AnswerSheetVO>> page(@RequestBody AnswerPageQueryDTO dto) { |
||||
return BackUtils.success(answerService.page(dto)); |
||||
} |
||||
|
||||
|
||||
} |
||||
@ -1,47 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.controller; |
||||
|
||||
import cn.soul2.jyjc.admin.annotation.SkinLogin; |
||||
import cn.soul2.jyjc.admin.dto.UserLoginDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLogoutDTO; |
||||
import cn.soul2.jyjc.admin.service.IUserService; |
||||
import cn.soul2.jyjc.admin.utils.base.BackUtils; |
||||
import cn.soul2.jyjc.admin.vo.UserVO; |
||||
import cn.soul2.jyjc.admin.vo.base.Back; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.web.bind.annotation.PostMapping; |
||||
import org.springframework.web.bind.annotation.RequestBody; |
||||
import org.springframework.web.bind.annotation.RequestMapping; |
||||
import org.springframework.web.bind.annotation.RestController; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-31 15:48 |
||||
*/ |
||||
|
||||
@Slf4j |
||||
@RestController |
||||
@RequestMapping("/user") |
||||
public class UserController { |
||||
|
||||
@Autowired |
||||
private IUserService userService; |
||||
|
||||
@PostMapping("login") |
||||
@SkinLogin |
||||
public Back<UserVO> login(@RequestBody UserLoginDTO dto) { |
||||
return BackUtils.success(userService.login(dto)); |
||||
} |
||||
|
||||
@PostMapping("register") |
||||
@SkinLogin |
||||
public Back<UserVO> register(@RequestBody UserLoginDTO dto) { |
||||
return BackUtils.success(userService.register(dto)); |
||||
} |
||||
|
||||
@PostMapping("logout") |
||||
public Back<Boolean> logout(@RequestBody UserLogoutDTO dto) { |
||||
return BackUtils.success(userService.logout(dto)); |
||||
} |
||||
|
||||
} |
||||
@ -1,45 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-27 13:31 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class AnswerDetailDTO { |
||||
|
||||
/** |
||||
* 回答内容(文字/选项id,多选时以,分隔) |
||||
*/ |
||||
private String content; |
||||
|
||||
/** |
||||
* 得分 |
||||
*/ |
||||
private Integer points; |
||||
|
||||
/** |
||||
* 题目id |
||||
*/ |
||||
private String subjectId; |
||||
|
||||
/** |
||||
* 题目类型:0-单选;1-多选;2-文字 |
||||
*/ |
||||
private Integer subjectType; |
||||
|
||||
/** |
||||
* 题目分值 |
||||
*/ |
||||
private Integer subjectPoints; |
||||
|
||||
/** |
||||
* 权重 |
||||
*/ |
||||
private Double weights; |
||||
|
||||
} |
||||
@ -1,21 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.base.PageParams; |
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-05-10 11:48 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class AnswerSheetQueryDTO extends PageParams { |
||||
|
||||
/** |
||||
* sheet id |
||||
*/ |
||||
private String sheetId; |
||||
|
||||
} |
||||
@ -1,37 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-27 13:26 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class AnswerSubmitDTO { |
||||
|
||||
/** |
||||
* 二维码id |
||||
*/ |
||||
private String qrId; |
||||
|
||||
/** |
||||
* 问卷Id |
||||
*/ |
||||
private String qnId; |
||||
|
||||
/** |
||||
* openid, 即答卷人 |
||||
*/ |
||||
private String openid; |
||||
|
||||
/** |
||||
* 答题内容 |
||||
*/ |
||||
private List<AnswerDetailDTO> details; |
||||
|
||||
} |
||||
@ -1,21 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-05-10 15:06 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class QnOptionsDTO { |
||||
|
||||
/** |
||||
* 查询状态 -1 or null: 所有 |
||||
*/ |
||||
private Integer status; |
||||
|
||||
|
||||
} |
||||
@ -1,30 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 21:55 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class UserLoginDTO { |
||||
|
||||
/** |
||||
* userName |
||||
*/ |
||||
private String username; |
||||
|
||||
/** |
||||
* password |
||||
*/ |
||||
private String password; |
||||
|
||||
/** |
||||
* 密码错误次数(暂未使用) |
||||
*/ |
||||
private Integer pswErrorCount; |
||||
|
||||
} |
||||
@ -1,21 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.base.PageParams; |
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 21:50 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class UserLoginOutPageDTO extends PageParams { |
||||
|
||||
/** |
||||
* userId |
||||
*/ |
||||
private String userId; |
||||
|
||||
} |
||||
@ -1,25 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 21:56 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class UserLogoutDTO { |
||||
|
||||
/** |
||||
* userName |
||||
*/ |
||||
private String username; |
||||
|
||||
/** |
||||
* token |
||||
*/ |
||||
private String token; |
||||
|
||||
} |
||||
@ -1,37 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.base.PageParams; |
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
import java.time.LocalDateTime; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 20:50 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class UserPageDTO extends PageParams { |
||||
|
||||
/** |
||||
* id |
||||
*/ |
||||
private String id; |
||||
/** |
||||
* 用户名 |
||||
*/ |
||||
private String username; |
||||
/** |
||||
* 状态;0(默认)：正常；4：封号；9：异常； |
||||
*/ |
||||
private Integer status; |
||||
|
||||
/** |
||||
* 注册时间 |
||||
*/ |
||||
private LocalDateTime startTime; |
||||
private LocalDateTime endTime; |
||||
|
||||
} |
||||
@ -1,45 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.dto; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 20:50 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class UserSaveDTO { |
||||
|
||||
/** |
||||
* id |
||||
*/ |
||||
private String id; |
||||
|
||||
/** |
||||
* 用户名 |
||||
*/ |
||||
private String username; |
||||
|
||||
/** |
||||
* 密码 |
||||
*/ |
||||
private String password; |
||||
|
||||
/** |
||||
* 状态;0(默认)：正常；4：封号；9：异常； |
||||
*/ |
||||
private Integer status; |
||||
|
||||
/** |
||||
* 权限等级,默认200 |
||||
*/ |
||||
private Integer authorityLevel; |
||||
|
||||
/** |
||||
* 密码修改次数 |
||||
*/ |
||||
private Integer pswChange; |
||||
|
||||
} |
||||
@ -1,93 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.entity; |
||||
|
||||
import com.baomidou.mybatisplus.annotation.*; |
||||
import com.baomidou.mybatisplus.extension.activerecord.Model; |
||||
import lombok.Getter; |
||||
import lombok.Setter; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
import java.io.Serializable; |
||||
import java.time.LocalDateTime; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户表 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-30 14:34:13 |
||||
*/ |
||||
@Getter |
||||
@Setter |
||||
@Accessors(chain = true) |
||||
@TableName("tb_user") |
||||
public class UserDO extends Model<UserDO> { |
||||
|
||||
private static final long serialVersionUID = 1L; |
||||
|
||||
/** |
||||
* id |
||||
*/ |
||||
@TableId(value = "id", type = IdType.ASSIGN_UUID) |
||||
private String id; |
||||
|
||||
/** |
||||
* 用户名 |
||||
*/ |
||||
@TableField("username") |
||||
private String username; |
||||
|
||||
/** |
||||
* 密码 |
||||
*/ |
||||
@TableField("password") |
||||
private String password; |
||||
|
||||
/** |
||||
* 状态;0(默认)：正常；4：封号；9：异常； |
||||
*/ |
||||
@TableField("status") |
||||
private Integer status; |
||||
|
||||
/** |
||||
* 权限等级,默认200 |
||||
*/ |
||||
@TableField("authority_level") |
||||
private Integer authorityLevel; |
||||
|
||||
/** |
||||
* 密码修改次数 |
||||
*/ |
||||
@TableField("psw_change") |
||||
private Integer pswChange; |
||||
|
||||
/** |
||||
* 更新时间 |
||||
*/ |
||||
@TableField(value = "updated_time", fill = FieldFill.INSERT_UPDATE) |
||||
private LocalDateTime updatedTime; |
||||
|
||||
/** |
||||
* 创建时间 |
||||
*/ |
||||
@TableField(value = "created_time", fill = FieldFill.INSERT) |
||||
private LocalDateTime createdTime; |
||||
|
||||
/** |
||||
* 删除标记 |
||||
*/ |
||||
@TableField("removed") |
||||
@TableLogic |
||||
private Integer removed; |
||||
|
||||
/** |
||||
* 盐,用于密码加密,未启用 |
||||
*/ |
||||
@TableField("salt") |
||||
private String salt; |
||||
|
||||
@Override |
||||
public Serializable pkVal() { |
||||
return this.id; |
||||
} |
||||
} |
||||
@ -1,87 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.entity; |
||||
|
||||
import com.baomidou.mybatisplus.annotation.*; |
||||
import com.baomidou.mybatisplus.extension.activerecord.Model; |
||||
import lombok.Getter; |
||||
import lombok.Setter; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
import java.io.Serializable; |
||||
import java.time.LocalDateTime; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户登入登出表 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-30 13:57:00 |
||||
*/ |
||||
@Getter |
||||
@Setter |
||||
@Accessors(chain = true) |
||||
@TableName("tb_user_login_out") |
||||
public class UserLoginOutDO extends Model<UserLoginOutDO> { |
||||
|
||||
private static final long serialVersionUID = 1L; |
||||
|
||||
/** |
||||
* id |
||||
*/ |
||||
@TableId(value = "id", type = IdType.ASSIGN_UUID) |
||||
private String id; |
||||
|
||||
/** |
||||
* 用户id |
||||
*/ |
||||
@TableField("user_id") |
||||
private String userId; |
||||
|
||||
/** |
||||
* 用户名称 |
||||
*/ |
||||
@TableField("user_name") |
||||
private String userName; |
||||
|
||||
/** |
||||
* 登录时间,登录成功才写入 |
||||
*/ |
||||
@TableField("login_time") |
||||
private LocalDateTime loginTime; |
||||
|
||||
/** |
||||
* 登录失效时间 |
||||
*/ |
||||
@TableField("lapse_time") |
||||
private LocalDateTime lapseTime; |
||||
|
||||
/** |
||||
* 用户操作登出时间 |
||||
*/ |
||||
@TableField("logout_time") |
||||
private LocalDateTime logoutTime; |
||||
|
||||
/** |
||||
* 密码错误次数 |
||||
*/ |
||||
@TableField("psw_error_count") |
||||
private Integer pswErrorCount; |
||||
|
||||
/** |
||||
* 创建时间 |
||||
*/ |
||||
@TableField(value = "created_time", fill = FieldFill.INSERT) |
||||
private LocalDateTime createdTime; |
||||
|
||||
/** |
||||
* 1=删除;0=未删除 |
||||
*/ |
||||
@TableField("removed") |
||||
@TableLogic |
||||
private Integer removed; |
||||
|
||||
@Override |
||||
public Serializable pkVal() { |
||||
return this.id; |
||||
} |
||||
} |
||||
@ -1,60 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.filter; |
||||
|
||||
import cn.soul2.jyjc.admin.utils.EncryptUtils; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.apache.tomcat.util.http.fileupload.servlet.ServletFileUpload; |
||||
|
||||
import javax.servlet.*; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.io.IOException; |
||||
import java.io.PrintWriter; |
||||
|
||||
/** |
||||
* @author shaoduo |
||||
* @description 替换HttpServletRequest |
||||
* @since 1.0 |
||||
**/ |
||||
@Slf4j |
||||
public class ReplaceStreamFilter implements Filter { |
||||
@Override |
||||
public void init(FilterConfig filterConfig) throws ServletException { |
||||
log.info("StreamFilter初始化..."); |
||||
} |
||||
|
||||
@Override |
||||
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { |
||||
//如果是文件上传则会报错可以判断是否是文件上传不读取流即可
|
||||
if (ServletFileUpload.isMultipartContent((HttpServletRequest) request)) { |
||||
chain.doFilter(request, response); |
||||
} else if ("OPTIONS".equalsIgnoreCase(((HttpServletRequest) request).getMethod())) { |
||||
chain.doFilter(request, response); |
||||
} else { |
||||
ServletRequest requestWrapper = new ShaoduoRequestWrapper((HttpServletRequest) request); |
||||
// System.out.printf("ReplaceStreamFilter触发, Method: %s, URI: %s%n", ((HttpServletRequest) request).getMethod(), ((HttpServletRequest) request).getRequestURI());
|
||||
HttpServletResponse httpResponse = (HttpServletResponse) response; |
||||
Soul2ResponseWrapper soul2ResponseWrapper = new Soul2ResponseWrapper(httpResponse); |
||||
chain.doFilter(requestWrapper, soul2ResponseWrapper); |
||||
try { |
||||
byte[] data = soul2ResponseWrapper.getResponseData(); |
||||
log.debug("原始返回 -> " + new String(data)); |
||||
String encryptBody = EncryptUtils.encrypt(new String(data)); |
||||
log.debug("加密返回 -> " + encryptBody); |
||||
soul2ResponseWrapper.setHeader("encrypt", "1"); |
||||
soul2ResponseWrapper.setHeader("Access-Control-Expose-Headers", "encrypt"); |
||||
PrintWriter out = response.getWriter(); |
||||
out.print(encryptBody); |
||||
out.flush(); |
||||
out.close(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
} |
||||
} |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void destroy() { |
||||
log.info("StreamFilter销毁..."); |
||||
} |
||||
} |
||||
@ -1,130 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.filter; |
||||
|
||||
import lombok.extern.slf4j.Slf4j; |
||||
|
||||
import javax.servlet.ReadListener; |
||||
import javax.servlet.ServletInputStream; |
||||
import javax.servlet.ServletRequest; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletRequestWrapper; |
||||
import java.io.*; |
||||
import java.nio.charset.Charset; |
||||
import java.nio.charset.StandardCharsets; |
||||
|
||||
/** |
||||
* @author shaoduo |
||||
* @description 包装HttpServletRequest，目的是让其输入流可重复读 |
||||
* @since <a href="https://blog.csdn.net/shaoduo/article/details/122322578">shaoduo</a> |
||||
**/ |
||||
@Slf4j |
||||
public class ShaoduoRequestWrapper extends HttpServletRequestWrapper { |
||||
/** |
||||
* 存储body数据的容器 |
||||
*/ |
||||
private byte[] body; |
||||
|
||||
public ShaoduoRequestWrapper(HttpServletRequest request) { |
||||
super(request); |
||||
|
||||
// 将body数据存储起来
|
||||
String bodyStr = getBodyString(request); |
||||
body = bodyStr.getBytes(Charset.defaultCharset()); |
||||
} |
||||
|
||||
/** |
||||
* 获取请求Body |
||||
* |
||||
* @param request request |
||||
* @return String |
||||
*/ |
||||
public String getBodyString(final ServletRequest request) { |
||||
try { |
||||
return inputStream2String(request.getInputStream()); |
||||
} catch (IOException e) { |
||||
log.error("", e); |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* 获取请求Body |
||||
* |
||||
* @return String |
||||
*/ |
||||
public String getBodyString() throws IOException { |
||||
InputStream inputStream = new ByteArrayInputStream(body); |
||||
return inputStream2String(inputStream); |
||||
} |
||||
|
||||
/** |
||||
* 修改body 将json 重新设置成body |
||||
* |
||||
* @param val |
||||
*/ |
||||
public void setBody(String val) { |
||||
body = val.getBytes(StandardCharsets.UTF_8); |
||||
} |
||||
|
||||
/** |
||||
* 将inputStream里的数据读取出来并转换成字符串 |
||||
* |
||||
* @param inputStream inputStream |
||||
* @return String |
||||
*/ |
||||
private String inputStream2String(InputStream inputStream) throws IOException { |
||||
StringBuilder sb = new StringBuilder(); |
||||
BufferedReader reader = null; |
||||
|
||||
try { |
||||
reader = new BufferedReader(new InputStreamReader(inputStream, Charset.defaultCharset())); |
||||
String line; |
||||
while ((line = reader.readLine()) != null) { |
||||
sb.append(line); |
||||
} |
||||
} catch (IOException e) { |
||||
log.error("", e); |
||||
throw new RuntimeException(e); |
||||
} finally { |
||||
if (reader != null) { |
||||
try { |
||||
reader.close(); |
||||
} catch (IOException e) { |
||||
log.error("", e); |
||||
} |
||||
} |
||||
} |
||||
return sb.toString(); |
||||
} |
||||
|
||||
@Override |
||||
public BufferedReader getReader() throws IOException { |
||||
return new BufferedReader(new InputStreamReader(getInputStream())); |
||||
} |
||||
|
||||
@Override |
||||
public ServletInputStream getInputStream() { |
||||
|
||||
final ByteArrayInputStream inputStream = new ByteArrayInputStream(body); |
||||
|
||||
return new ServletInputStream() { |
||||
@Override |
||||
public int read() { |
||||
return inputStream.read(); |
||||
} |
||||
|
||||
@Override |
||||
public boolean isFinished() { |
||||
return false; |
||||
} |
||||
|
||||
@Override |
||||
public boolean isReady() { |
||||
return false; |
||||
} |
||||
|
||||
@Override |
||||
public void setReadListener(ReadListener readListener) { |
||||
} |
||||
}; |
||||
} |
||||
} |
||||
@ -1,120 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.filter; |
||||
|
||||
import lombok.SneakyThrows; |
||||
|
||||
import javax.servlet.ServletOutputStream; |
||||
import javax.servlet.WriteListener; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import javax.servlet.http.HttpServletResponseWrapper; |
||||
import java.io.*; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @description 包装ServletResponse, 照抄自 <a href="https://blog.csdn.net/temp_44/article/details/107762290">temp_44</a> |
||||
* @date 2024-04-15 |
||||
*/ |
||||
public class Soul2ResponseWrapper extends HttpServletResponseWrapper { |
||||
private ByteArrayOutputStream buffer = null; |
||||
private ServletOutputStream out = null; |
||||
private PrintWriter writer = null; |
||||
|
||||
public Soul2ResponseWrapper(HttpServletResponse resp) throws IOException { |
||||
super(resp); |
||||
// 真正存储数据的流
|
||||
buffer = new ByteArrayOutputStream(); |
||||
out = new WapperedOutputStream(buffer); |
||||
writer = new PrintWriter(new OutputStreamWriter(buffer, |
||||
this.getCharacterEncoding())); |
||||
} |
||||
|
||||
/** |
||||
* 重载父类获取outputstream的方法 |
||||
*/ |
||||
@Override |
||||
public ServletOutputStream getOutputStream() throws IOException { |
||||
return out; |
||||
} |
||||
|
||||
/** |
||||
* 重载父类获取writer的方法 |
||||
*/ |
||||
@Override |
||||
public PrintWriter getWriter() throws UnsupportedEncodingException { |
||||
return writer; |
||||
} |
||||
|
||||
/** |
||||
* The default behavior of this method is to call |
||||
* setCharacterEncoding(String charset) on the wrapped response object. |
||||
* |
||||
* @param charset |
||||
* @since 2.4 |
||||
*/ |
||||
@SneakyThrows |
||||
@Override |
||||
public void setCharacterEncoding(String charset) { |
||||
super.setCharacterEncoding(charset); |
||||
writer = new PrintWriter(new OutputStreamWriter(buffer, |
||||
this.getCharacterEncoding())); |
||||
} |
||||
|
||||
/** |
||||
* 重载父类获取flushBuffer的方法 |
||||
*/ |
||||
@Override |
||||
public void flushBuffer() throws IOException { |
||||
if (out != null) { |
||||
out.flush(); |
||||
} |
||||
if (writer != null) { |
||||
writer.flush(); |
||||
} |
||||
} |
||||
|
||||
@Override |
||||
public void reset() { |
||||
buffer.reset(); |
||||
} |
||||
|
||||
/** |
||||
* 将out、writer中的数据强制输出到WapperedResponse的buffer里面，否则取不到数据 |
||||
*/ |
||||
public byte[] getResponseData() throws IOException { |
||||
flushBuffer(); |
||||
return buffer.toByteArray(); |
||||
} |
||||
|
||||
/** |
||||
* 内部类，对ServletOutputStream进行包装 |
||||
*/ |
||||
private class WapperedOutputStream extends ServletOutputStream { |
||||
private ByteArrayOutputStream bos = null; |
||||
|
||||
public WapperedOutputStream(ByteArrayOutputStream stream) |
||||
throws IOException { |
||||
bos = stream; |
||||
} |
||||
|
||||
@Override |
||||
public void write(int b) throws IOException { |
||||
bos.write(b); |
||||
} |
||||
|
||||
@Override |
||||
public void write(byte[] b) throws IOException { |
||||
bos.write(b, 0, b.length); |
||||
} |
||||
|
||||
@Override |
||||
public boolean isReady() { |
||||
// TODO Auto-generated method stub
|
||||
return false; |
||||
} |
||||
|
||||
@Override |
||||
public void setWriteListener(WriteListener writeListener) { |
||||
// TODO Auto-generated method stub
|
||||
|
||||
} |
||||
} |
||||
} |
||||
@ -1,137 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.interceptor; |
||||
|
||||
import cn.soul2.jyjc.admin.annotation.SkinEncrypt; |
||||
import cn.soul2.jyjc.admin.annotation.SkinLogin; |
||||
import cn.soul2.jyjc.admin.bean.UserLoginStatusBean; |
||||
import cn.soul2.jyjc.admin.filter.ShaoduoRequestWrapper; |
||||
import cn.soul2.jyjc.admin.service.IUserService; |
||||
import cn.soul2.jyjc.admin.utils.EncryptUtils; |
||||
import cn.soul2.jyjc.admin.vo.base.Back; |
||||
import com.fasterxml.jackson.databind.ObjectMapper; |
||||
import lombok.extern.slf4j.Slf4j; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.web.method.HandlerMethod; |
||||
import org.springframework.web.servlet.HandlerInterceptor; |
||||
|
||||
import javax.annotation.Resource; |
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.io.PrintWriter; |
||||
import java.lang.reflect.Method; |
||||
|
||||
/** |
||||
* Token拦截器 |
||||
* |
||||
* @author Soul2 |
||||
* @date 2024-04-02 15:31 |
||||
*/ |
||||
@Slf4j |
||||
public class FinallyInterceptor implements HandlerInterceptor { |
||||
|
||||
@Resource |
||||
private UserLoginStatusBean userLoginStatusBean; |
||||
|
||||
@Autowired |
||||
private IUserService userService; |
||||
|
||||
private boolean load = true; |
||||
|
||||
private void loadUserLoginStatus() { |
||||
userLoginStatusBean.loadUserLoginStatus(userService.getLoginedUser()); |
||||
} |
||||
|
||||
@Override |
||||
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { |
||||
if (load) { |
||||
loadUserLoginStatus(); |
||||
load = false; |
||||
} |
||||
boolean pass = false; |
||||
// 允许OPTIONS请求通过
|
||||
if ("OPTIONS".equalsIgnoreCase(request.getMethod())) { |
||||
return true; |
||||
} |
||||
// 如果不是映射到方法直接通过
|
||||
if (!(handler instanceof HandlerMethod)) { |
||||
return true; |
||||
} |
||||
HandlerMethod handlerMethod = (HandlerMethod) handler; |
||||
Method method = handlerMethod.getMethod(); |
||||
String httpMethod = request.getMethod(); |
||||
SkinEncrypt skinEncrypt = handlerMethod.getMethodAnnotation(SkinEncrypt.class); |
||||
// 检查方法上是否存在SkinLogin注解
|
||||
boolean hasSkinLogin = handlerMethod.getMethodAnnotation(SkinLogin.class) != null; |
||||
// 从请求头中获取 token
|
||||
String token = request.getHeader("jyjc-Token"); |
||||
try { |
||||
/* |
||||
加解密 |
||||
*/ |
||||
// 不拦截get请求
|
||||
if ("GET".equals(httpMethod)) { |
||||
pass = true; |
||||
// 如果是post请求且是json
|
||||
} else if ("POST".equals(httpMethod)) { |
||||
// 如果类型为空就放行
|
||||
if (request.getContentType() == null) { |
||||
pass = true; |
||||
} |
||||
} |
||||
// 跳过使用 @SkinEncrypt 的情况
|
||||
if (skinEncrypt != null) { |
||||
pass = true; |
||||
} |
||||
|
||||
if (!pass) { |
||||
ShaoduoRequestWrapper shaoduoRequestWrapper; |
||||
try { |
||||
shaoduoRequestWrapper = (ShaoduoRequestWrapper) request; |
||||
} catch (Exception e) { |
||||
System.out.printf("request.ClassTypeError: %s%n", request.getClass().getName()); |
||||
return true; |
||||
} |
||||
String sourceParamBody = shaoduoRequestWrapper.getBodyString(); |
||||
String afterBody = EncryptUtils.decrypt(sourceParamBody); |
||||
shaoduoRequestWrapper.setBody(afterBody); |
||||
log.debug(String.format("解密: %s -> %s", sourceParamBody, afterBody)); |
||||
|
||||
} |
||||
|
||||
/* token验证 */ |
||||
if (hasSkinLogin) { |
||||
// 跳过使用 @SkinLogin 的情况
|
||||
pass = true; |
||||
} else { |
||||
// 验证token
|
||||
// 检查 token 是否存在并且有效
|
||||
if (token == null) { |
||||
// 没有Token，拒绝请求
|
||||
response.setStatus(40401); |
||||
pass = false; |
||||
} else if (userLoginStatusBean != null) { |
||||
if (!userLoginStatusBean.containsToken(token)) { |
||||
// Token 无效，拒绝请求
|
||||
response.setContentType("application/json"); |
||||
Back<String> back = new Back<String>().setCode(40401).setMessage("Token invalid!"); |
||||
|
||||
// 转换为 JSON 字符串
|
||||
ObjectMapper objectMapper = new ObjectMapper(); |
||||
String responseBody = objectMapper.writeValueAsString(back); |
||||
|
||||
// 输出错误信息到响应中
|
||||
PrintWriter writer = response.getWriter(); |
||||
writer.print(responseBody); |
||||
writer.flush(); |
||||
pass = false; |
||||
} else { |
||||
// token存在, 通过拦截器
|
||||
pass = true; |
||||
} |
||||
} |
||||
} |
||||
} catch (Exception e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
return pass; |
||||
} |
||||
} |
||||
@ -1,16 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.mapper; |
||||
|
||||
import cn.soul2.jyjc.admin.entity.UserLoginOutDO; |
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户登入登出表 Mapper 接口 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-29 20:46:42 |
||||
*/ |
||||
public interface UserLoginOutMapper extends BaseMapper<UserLoginOutDO> { |
||||
|
||||
} |
||||
@ -1,16 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.mapper; |
||||
|
||||
import cn.soul2.jyjc.admin.entity.UserDO; |
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户表 Mapper 接口 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-29 20:46:42 |
||||
*/ |
||||
public interface UserMapper extends BaseMapper<UserDO> { |
||||
|
||||
} |
||||
@ -1,71 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.repository; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.UserLoginDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLoginOutPageDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLogoutDTO; |
||||
import cn.soul2.jyjc.admin.entity.UserDO; |
||||
import cn.soul2.jyjc.admin.entity.UserLoginOutDO; |
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import com.baomidou.mybatisplus.extension.service.IService; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户登入登出表 服务类 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-29 20:46:42 |
||||
*/ |
||||
public interface IUserLoginOutRepository extends IService<UserLoginOutDO> { |
||||
|
||||
/** |
||||
* 分页查询 |
||||
* |
||||
* @param dto 查询条件 |
||||
* @return {@link IPage}<{@link UserLoginOutDO}> |
||||
*/ |
||||
IPage<UserLoginOutDO> page(UserLoginOutPageDTO dto); |
||||
|
||||
/** |
||||
* 用户登录 |
||||
* |
||||
* @param dto 用户信息 |
||||
* @param user 用户 |
||||
* @return {@link String} |
||||
*/ |
||||
String login(UserLoginDTO dto, UserDO user); |
||||
|
||||
/** |
||||
* 用户登出 |
||||
* |
||||
* @param dto 用户信息 |
||||
* @return {@link String} |
||||
*/ |
||||
String logout(UserLogoutDTO dto); |
||||
|
||||
/** |
||||
* 用户登出 |
||||
* |
||||
* @param userId 用户id |
||||
* @return {@link String} |
||||
*/ |
||||
Boolean logoutByUserId(String userId); |
||||
|
||||
/** |
||||
* 删除目标用户的所有登录记录 |
||||
* |
||||
* @param userId 用户id |
||||
* @return {@link Boolean} |
||||
*/ |
||||
Boolean removeByUserId(String userId); |
||||
|
||||
/** |
||||
* 重建当前登录的用户 |
||||
* |
||||
* @return {@link List}<{@link UserLoginOutDO}> |
||||
*/ |
||||
List<UserLoginOutDO> getLoginedUser(); |
||||
|
||||
} |
||||
@ -1,54 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.repository; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.UserPageDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserSaveDTO; |
||||
import cn.soul2.jyjc.admin.dto.base.UpdateStatusDTO; |
||||
import cn.soul2.jyjc.admin.entity.UserDO; |
||||
import cn.soul2.jyjc.admin.vo.base.VPage; |
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import com.baomidou.mybatisplus.extension.service.IService; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户表 服务类 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-29 20:46:42 |
||||
*/ |
||||
public interface IUserRepository extends IService<UserDO> { |
||||
|
||||
/** |
||||
* 分页查询 |
||||
* |
||||
* @param dto 查询条件 |
||||
* @return {@link VPage}<{@link UserDO}> |
||||
*/ |
||||
IPage<UserDO> page(UserPageDTO dto); |
||||
|
||||
/** |
||||
* 保存或更新 |
||||
* |
||||
* @param dto 有/无id区分更新/新增 |
||||
* @return {@link Boolean} |
||||
*/ |
||||
Boolean saveOrUpdate(UserSaveDTO dto); |
||||
|
||||
/** |
||||
* 更新状态 |
||||
* |
||||
* @param dto 新状态 |
||||
* @return {@link Boolean} |
||||
*/ |
||||
Boolean updateStatus(UpdateStatusDTO dto); |
||||
|
||||
/** |
||||
* 读取指定名字的用户 |
||||
* |
||||
* @param username 用户名 |
||||
* @return {@link UserDO} |
||||
*/ |
||||
UserDO getOneByUsername(String username); |
||||
|
||||
|
||||
} |
||||
@ -1,126 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.repository.impl; |
||||
|
||||
import cn.soul2.jyjc.admin.bean.UserLoginStatusBean; |
||||
import cn.soul2.jyjc.admin.dto.UserLoginDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLoginOutPageDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLogoutDTO; |
||||
import cn.soul2.jyjc.admin.entity.UserDO; |
||||
import cn.soul2.jyjc.admin.entity.UserLoginOutDO; |
||||
import cn.soul2.jyjc.admin.mapper.UserLoginOutMapper; |
||||
import cn.soul2.jyjc.admin.repository.IUserLoginOutRepository; |
||||
import cn.soul2.jyjc.admin.utils.base.PageUtils; |
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; |
||||
import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.time.LocalDateTime; |
||||
import java.util.ArrayList; |
||||
import java.util.Comparator; |
||||
import java.util.List; |
||||
import java.util.function.BinaryOperator; |
||||
import java.util.function.Function; |
||||
import java.util.stream.Collectors; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户登入登出表 服务实现类 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-29 20:46:42 |
||||
*/ |
||||
@Service |
||||
public class UserLoginOutRepositoryImpl extends ServiceImpl<UserLoginOutMapper, UserLoginOutDO> implements IUserLoginOutRepository { |
||||
|
||||
@Autowired |
||||
private UserLoginStatusBean userLoginStatusBean; |
||||
|
||||
@Override |
||||
public IPage<UserLoginOutDO> page(UserLoginOutPageDTO dto) { |
||||
LambdaQueryWrapper<UserLoginOutDO> query = Wrappers.lambdaQuery(); |
||||
query.eq(StringUtils.isNotBlank(dto.getUserId()), UserLoginOutDO::getUserId, dto.getUserId()) |
||||
.orderByDesc(UserLoginOutDO::getCreatedTime); |
||||
return super.page(PageUtils.build(dto), query); |
||||
} |
||||
|
||||
@Override |
||||
public String login(UserLoginDTO dto, UserDO user) { |
||||
UserLoginOutDO loginOutDO; |
||||
boolean saved; |
||||
LocalDateTime now = LocalDateTime.now(); |
||||
// 判断是否登陆过,在缓存无法读取到目标用户名时即未登录,若登录过则令之前的登录记录失效
|
||||
String token = userLoginStatusBean.getTokenByUsername(dto.getUsername()); |
||||
if (token != null) { |
||||
userLoginStatusBean.logout(token); |
||||
UserLoginOutDO oldLoginOut = super.getById(token); |
||||
oldLoginOut.setLapseTime(now).setLogoutTime(now); |
||||
super.updateById(oldLoginOut); |
||||
} |
||||
loginOutDO = new UserLoginOutDO(); |
||||
loginOutDO.setUserId(user.getId()) |
||||
.setUserName(user.getUsername()) |
||||
.setLoginTime(now) |
||||
.setLapseTime(now.plusHours(2)) |
||||
; |
||||
saved = super.save(loginOutDO); |
||||
if (saved) { |
||||
userLoginStatusBean.login(loginOutDO.getId(), loginOutDO); |
||||
return loginOutDO.getId(); |
||||
} |
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public String logout(UserLogoutDTO dto) { |
||||
// 清除缓存内的登录信息
|
||||
Boolean logout = userLoginStatusBean.logout(dto.getToken()); |
||||
// 保存退出登录的时间
|
||||
LocalDateTime now = LocalDateTime.now(); |
||||
UserLoginOutDO oldLoginOut = super.getById(dto.getToken()); |
||||
oldLoginOut.setLogoutTime(now); |
||||
super.updateById(oldLoginOut); |
||||
|
||||
return logout ? dto.getUsername() : null; |
||||
} |
||||
|
||||
@Override |
||||
public Boolean logoutByUserId(String userId) { |
||||
return userLoginStatusBean.logoutByUserId(userId); |
||||
} |
||||
|
||||
@Override |
||||
public Boolean removeByUserId(String userId) { |
||||
if (org.apache.commons.lang3.StringUtils.isBlank(userId)) { |
||||
return Boolean.TRUE; |
||||
} |
||||
LambdaUpdateWrapper<UserLoginOutDO> update = Wrappers.lambdaUpdate(); |
||||
update.eq(UserLoginOutDO::getUserId, userId); |
||||
return super.remove(update); |
||||
} |
||||
|
||||
@Override |
||||
public List<UserLoginOutDO> getLoginedUser() { |
||||
LocalDateTime now = LocalDateTime.now(); |
||||
LambdaQueryWrapper<UserLoginOutDO> query = Wrappers.lambdaQuery(); |
||||
query |
||||
.isNull(UserLoginOutDO::getLogoutTime) |
||||
.gt(UserLoginOutDO::getLapseTime, now); |
||||
List<UserLoginOutDO> list = super.list(query); |
||||
if (CollectionUtils.isEmpty(list)) { |
||||
return new ArrayList<>(); |
||||
} |
||||
|
||||
return new ArrayList<>(list |
||||
.stream() |
||||
.collect(Collectors.toMap(UserLoginOutDO::getUserId, |
||||
Function.identity(), |
||||
BinaryOperator.maxBy(Comparator.comparing(UserLoginOutDO::getLoginTime)))) |
||||
.values()); |
||||
} |
||||
} |
||||
@ -1,60 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.repository.impl; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.UserPageDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserSaveDTO; |
||||
import cn.soul2.jyjc.admin.dto.base.UpdateStatusDTO; |
||||
import cn.soul2.jyjc.admin.entity.UserDO; |
||||
import cn.soul2.jyjc.admin.mapper.UserMapper; |
||||
import cn.soul2.jyjc.admin.repository.IUserRepository; |
||||
import cn.soul2.jyjc.admin.utils.base.PageUtils; |
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
||||
import com.baomidou.mybatisplus.core.metadata.IPage; |
||||
import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
||||
import org.springframework.beans.BeanUtils; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
/** |
||||
* <p> |
||||
* 用户表 服务实现类 |
||||
* </p> |
||||
* |
||||
* @author Soul2 |
||||
* @since 2024-03-29 20:46:42 |
||||
*/ |
||||
@Service |
||||
public class UserRepositoryImpl extends ServiceImpl<UserMapper, UserDO> implements IUserRepository { |
||||
|
||||
@Override |
||||
public IPage<UserDO> page(UserPageDTO dto) { |
||||
LambdaQueryWrapper<UserDO> query = Wrappers.lambdaQuery(); |
||||
query.eq(dto.getStatus() != null, UserDO::getStatus, dto.getStatus()) |
||||
.like(StringUtils.isNotBlank(dto.getUsername()), UserDO::getUsername, dto.getUsername()) |
||||
.orderByDesc(UserDO::getUpdatedTime); |
||||
return super.page(PageUtils.build(dto), query); |
||||
} |
||||
|
||||
@Override |
||||
public Boolean saveOrUpdate(UserSaveDTO dto) { |
||||
UserDO user = new UserDO(); |
||||
BeanUtils.copyProperties(dto, user); |
||||
return super.saveOrUpdate(user); |
||||
} |
||||
|
||||
@Override |
||||
public Boolean updateStatus(UpdateStatusDTO dto) { |
||||
LambdaUpdateWrapper<UserDO> update = Wrappers.lambdaUpdate(); |
||||
update.set(UserDO::getStatus, dto.getStatus()) |
||||
.eq(UserDO::getId, dto.getId()); |
||||
return super.update(update); |
||||
} |
||||
|
||||
@Override |
||||
public UserDO getOneByUsername(String username) { |
||||
LambdaQueryWrapper<UserDO> query = Wrappers.lambdaQuery(); |
||||
query.eq(UserDO::getUsername, username); |
||||
return super.getOne(query, false); |
||||
} |
||||
} |
||||
@ -1,31 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.service; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.AnswerPageQueryDTO; |
||||
import cn.soul2.jyjc.admin.dto.AnswerSubmitDTO; |
||||
import cn.soul2.jyjc.admin.vo.AnswerSheetVO; |
||||
import cn.soul2.jyjc.admin.vo.base.VPage; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-27 14:43 |
||||
*/ |
||||
|
||||
public interface IAnswerService { |
||||
|
||||
/** |
||||
* 提交答卷 |
||||
* |
||||
* @param dto 答卷内容 |
||||
* @return {@link Boolean} |
||||
*/ |
||||
Boolean handleSubmit(AnswerSubmitDTO dto); |
||||
|
||||
/** |
||||
* 分页查询 |
||||
* |
||||
* @param dto 查询条件 |
||||
* @return {@link VPage}<{@link AnswerSheetVO}> |
||||
*/ |
||||
VPage<AnswerSheetVO> page(AnswerPageQueryDTO dto); |
||||
|
||||
} |
||||
@ -1,56 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.service; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.UserLoginDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLogoutDTO; |
||||
import cn.soul2.jyjc.admin.entity.UserLoginOutDO; |
||||
import cn.soul2.jyjc.admin.vo.UserVO; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 20:47 |
||||
*/ |
||||
|
||||
public interface IUserService { |
||||
|
||||
/** |
||||
* 注册一个用户 |
||||
* |
||||
* @param dto 用户名和密码 |
||||
* @return {@link UserVO} |
||||
*/ |
||||
UserVO register(UserLoginDTO dto); |
||||
|
||||
/** |
||||
* 用户登录 |
||||
* |
||||
* @param dto 用户名和密码 |
||||
* @return {@link UserVO} |
||||
*/ |
||||
UserVO login(UserLoginDTO dto); |
||||
|
||||
/** |
||||
* 用户退出登录 |
||||
* |
||||
* @param dto 登录key |
||||
* @return {@link Boolean} |
||||
*/ |
||||
Boolean logout(UserLogoutDTO dto); |
||||
|
||||
/** |
||||
* 删除用户并退出登录,同时将登录记录一并删除 |
||||
* |
||||
* @param userId 用户id |
||||
* @return {@link Boolean} |
||||
*/ |
||||
Boolean remove(String userId); |
||||
|
||||
/** |
||||
* 重建当前登录的用户 |
||||
* |
||||
* @return {@link List}<{@link UserLoginOutDO}> |
||||
*/ |
||||
List<UserLoginOutDO> getLoginedUser(); |
||||
|
||||
} |
||||
@ -1,66 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.service.impl; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.AnswerPageQueryDTO; |
||||
import cn.soul2.jyjc.admin.dto.AnswerSubmitDTO; |
||||
import cn.soul2.jyjc.admin.entity.AnswerDetailsDO; |
||||
import cn.soul2.jyjc.admin.entity.AnswerSheetDO; |
||||
import cn.soul2.jyjc.admin.repository.IAnswerDetailsRepository; |
||||
import cn.soul2.jyjc.admin.repository.IAnswerSheetRepository; |
||||
import cn.soul2.jyjc.admin.service.IAnswerService; |
||||
import cn.soul2.jyjc.admin.vo.AnswerSheetVO; |
||||
import cn.soul2.jyjc.admin.vo.base.VPage; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.stereotype.Service; |
||||
import org.springframework.transaction.annotation.Transactional; |
||||
import org.springframework.transaction.interceptor.TransactionAspectSupport; |
||||
|
||||
import java.util.List; |
||||
import java.util.stream.Collectors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-27 14:43 |
||||
*/ |
||||
|
||||
@Service |
||||
public class AnswerServiceImpl implements IAnswerService { |
||||
|
||||
@Autowired |
||||
private IAnswerSheetRepository sheetRepository; |
||||
|
||||
@Autowired |
||||
private IAnswerDetailsRepository detailsRepository; |
||||
|
||||
@Override |
||||
@Transactional |
||||
public Boolean handleSubmit(AnswerSubmitDTO dto) { |
||||
AnswerSheetDO sheet = new AnswerSheetDO(); |
||||
sheet.setRespondent(dto.getOpenid()) |
||||
.setQnId(dto.getQnId()) |
||||
.setQrId(dto.getQrId()); |
||||
boolean sheetSaved = sheetRepository.save(sheet); |
||||
if (sheetSaved) { |
||||
List<AnswerDetailsDO> details = dto.getDetails().stream().map(d -> { |
||||
AnswerDetailsDO detail = new AnswerDetailsDO(); |
||||
detail.setAnswerContent(d.getContent()) |
||||
.setAnswerSheetId(sheet.getId()) |
||||
.setSubjectType(d.getSubjectType()) |
||||
.setSubjectId(d.getSubjectId()); |
||||
return detail; |
||||
}).collect(Collectors.toList()); |
||||
boolean detailsSaved = detailsRepository.saveBatch(details); |
||||
if (!detailsSaved) { |
||||
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
||||
return Boolean.FALSE; |
||||
} |
||||
} else { |
||||
return Boolean.FALSE; |
||||
} |
||||
return Boolean.TRUE; |
||||
} |
||||
|
||||
@Override |
||||
public VPage<AnswerSheetVO> page(AnswerPageQueryDTO dto) { |
||||
return sheetRepository.page(dto); |
||||
} |
||||
} |
||||
@ -1,95 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.service.impl; |
||||
|
||||
import cn.soul2.jyjc.admin.dto.UserLoginDTO; |
||||
import cn.soul2.jyjc.admin.dto.UserLogoutDTO; |
||||
import cn.soul2.jyjc.admin.entity.UserDO; |
||||
import cn.soul2.jyjc.admin.entity.UserLoginOutDO; |
||||
import cn.soul2.jyjc.admin.repository.IUserLoginOutRepository; |
||||
import cn.soul2.jyjc.admin.repository.IUserRepository; |
||||
import cn.soul2.jyjc.admin.service.IUserService; |
||||
import cn.soul2.jyjc.admin.utils.Md5Utils; |
||||
import cn.soul2.jyjc.admin.vo.UserVO; |
||||
import org.springframework.beans.BeanUtils; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-29 20:47 |
||||
*/ |
||||
|
||||
@Service |
||||
public class UserServiceImpl implements IUserService { |
||||
|
||||
@Autowired |
||||
private IUserRepository userRepository; |
||||
|
||||
@Autowired |
||||
private IUserLoginOutRepository loginOutRepository; |
||||
|
||||
@Override |
||||
public UserVO register(UserLoginDTO dto) { |
||||
UserVO vo = new UserVO(); |
||||
if (userRepository.getOneByUsername(dto.getUsername()) == null) { |
||||
UserDO user = new UserDO(); |
||||
user.setUsername(dto.getUsername()) |
||||
.setPassword(Md5Utils.md5(dto.getPassword())); |
||||
boolean saved = userRepository.save(user); |
||||
if (!saved) { |
||||
vo.setLoginFail("注册失败!"); |
||||
} else { |
||||
String loginKey = loginOutRepository.login(dto, user); |
||||
if (loginKey != null) { |
||||
BeanUtils.copyProperties(user, vo); |
||||
vo.setToken(loginKey); |
||||
} else { |
||||
vo.setLoginFail("注册成功但登录失败!"); |
||||
} |
||||
} |
||||
} else { |
||||
vo.setLoginFail("用户名已存在!"); |
||||
} |
||||
return vo; |
||||
} |
||||
|
||||
@Override |
||||
public UserVO login(UserLoginDTO dto) { |
||||
UserVO vo = new UserVO(); |
||||
UserDO user = userRepository.getOneByUsername(dto.getUsername()); |
||||
if (user != null) { |
||||
if (Md5Utils.verify(user.getPassword(), dto.getPassword())) { |
||||
String loginKey = loginOutRepository.login(dto, user); |
||||
if (loginKey != null) { |
||||
BeanUtils.copyProperties(user, vo); |
||||
vo.setToken(loginKey); |
||||
} else { |
||||
vo.setLoginFail("登录失败!"); |
||||
} |
||||
} else { |
||||
vo.setLoginFail("密码错误!"); |
||||
} |
||||
} else { |
||||
vo.setLoginFail("该用户尚未注册!"); |
||||
} |
||||
return vo; |
||||
} |
||||
|
||||
@Override |
||||
public Boolean logout(UserLogoutDTO dto) { |
||||
return loginOutRepository.logout(dto) != null; |
||||
} |
||||
|
||||
@Override |
||||
public Boolean remove(String userId) { |
||||
loginOutRepository.logoutByUserId(userId); |
||||
loginOutRepository.removeByUserId(userId); |
||||
return userRepository.removeById(userId); |
||||
} |
||||
|
||||
@Override |
||||
public List<UserLoginOutDO> getLoginedUser() { |
||||
return loginOutRepository.getLoginedUser(); |
||||
} |
||||
} |
||||
@ -1,48 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.utils; |
||||
|
||||
import javax.crypto.Cipher; |
||||
import javax.crypto.spec.SecretKeySpec; |
||||
import java.util.Base64; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-30 14:02 |
||||
*/ |
||||
|
||||
public class AesUtils { |
||||
|
||||
private static final String AES_KEY = "98478f8a45887eda446501bcb44010520c3f53c7b45ff36215e86ce4f049b0f2"; |
||||
|
||||
private static final String AES_ALGORITHM = "AES"; |
||||
|
||||
private static SecretKeySpec generateKey(String key) { |
||||
return new SecretKeySpec(key.getBytes(), AES_ALGORITHM); |
||||
} |
||||
|
||||
public static String encrypt(String source) throws Exception { |
||||
return encrypt(source, AES_KEY); |
||||
} |
||||
|
||||
public static String decrypt(String encrypted) throws Exception { |
||||
return decrypt(encrypted, AES_KEY); |
||||
} |
||||
|
||||
public static String encrypt(String source, String key) throws Exception { |
||||
Cipher cipher = Cipher.getInstance(AES_ALGORITHM); |
||||
cipher.init(Cipher.ENCRYPT_MODE, generateKey(key)); |
||||
byte[] encryptedBytes = cipher.doFinal(source.getBytes()); |
||||
return Base64.getEncoder().encodeToString(encryptedBytes); |
||||
} |
||||
|
||||
public static String decrypt(String encrypted, String key) throws Exception { |
||||
Cipher cipher = Cipher.getInstance(AES_ALGORITHM); |
||||
cipher.init(Cipher.DECRYPT_MODE, generateKey(key)); |
||||
byte[] decryptedBytes = cipher.doFinal(Base64.getDecoder().decode(encrypted)); |
||||
return new String(decryptedBytes); |
||||
} |
||||
|
||||
public static void main(String[] args) { |
||||
} |
||||
|
||||
|
||||
} |
||||
@ -1,132 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.utils; |
||||
|
||||
import org.apache.tomcat.util.codec.binary.Base64; |
||||
|
||||
import javax.crypto.Cipher; |
||||
import javax.crypto.KeyGenerator; |
||||
import javax.crypto.spec.SecretKeySpec; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-04-08 15:00 |
||||
* <p>照抄自 <a href="https://blog.csdn.net/shaoduo/article/details/122322578">Shao duo</a></p> |
||||
*/ |
||||
|
||||
public class EncryptUtils { |
||||
|
||||
private static final String KEY = "620b8d3c3be1e725"; |
||||
|
||||
//参数分别代表 算法名称/加密模式/数据填充方式
|
||||
private static final String ALGORITHMSTR = "AES/ECB/PKCS5Padding"; |
||||
|
||||
/** |
||||
* 加密 |
||||
* |
||||
* @param content 加密的字符串 |
||||
* @param encryptKey key值 |
||||
* @return {@link String} |
||||
*/ |
||||
public static String encrypt(String content, String encryptKey) throws Exception { |
||||
KeyGenerator kgen = KeyGenerator.getInstance("AES"); |
||||
kgen.init(128); |
||||
Cipher cipher = Cipher.getInstance(ALGORITHMSTR); |
||||
cipher.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(encryptKey.getBytes(), "AES")); |
||||
byte[] b = cipher.doFinal(content.getBytes("utf-8")); |
||||
// 采用base64算法进行转码,避免出现中文乱码
|
||||
return Base64.encodeBase64String(b); |
||||
} |
||||
|
||||
/** |
||||
* 解密 |
||||
* |
||||
* @param encryptStr 解密的字符串 |
||||
* @param decryptKey 解密的key值 |
||||
* @return {@link String} |
||||
*/ |
||||
public static String decrypt(String encryptStr, String decryptKey) throws Exception { |
||||
KeyGenerator kgen = KeyGenerator.getInstance("AES"); |
||||
kgen.init(128); |
||||
Cipher cipher = Cipher.getInstance(ALGORITHMSTR); |
||||
cipher.init(Cipher.DECRYPT_MODE, new SecretKeySpec(decryptKey.getBytes("utf-8"), "AES")); |
||||
// 采用base64算法进行转码,避免出现中文乱码
|
||||
|
||||
//byte[] b = hex2Bytes(encryptStr) ;
|
||||
byte[] encryptBytes = Base64.decodeBase64(encryptStr); |
||||
byte[] decryptBytes = cipher.doFinal(encryptBytes); |
||||
return new String(decryptBytes); |
||||
} |
||||
|
||||
/** |
||||
* @param content 加密的字符串 |
||||
* @return {@link String} |
||||
*/ |
||||
public static String encrypt(String content) throws Exception { |
||||
return encrypt(content, KEY); |
||||
} |
||||
|
||||
/** |
||||
* @param encryptStr 解密的字符串 |
||||
* @return {@link String} |
||||
*/ |
||||
public static String decrypt(String encryptStr) throws Exception { |
||||
return decrypt(encryptStr, KEY); |
||||
} |
||||
|
||||
|
||||
/* public static void main(String[] args) throws Exception { |
||||
Map map=new HashMap<String,String>(); |
||||
map.put("key","value"); |
||||
map.put("中文","汉字"); |
||||
String content = JSONObject.toJSONString(map); |
||||
System.out.println("加密前：" + content); |
||||
String encrypt = encrypt(content, KEY); |
||||
System.out.println("加密后：" + encrypt); |
||||
String decrypt = decrypt(encrypt, KEY); |
||||
System.out.println("解密后：" + decrypt); |
||||
}*/ |
||||
|
||||
/** |
||||
* byte数组 转换成 16进制小写字符串 |
||||
*/ |
||||
public static String bytes2Hex(byte[] bytes) { |
||||
if (bytes == null || bytes.length == 0) { |
||||
return null; |
||||
} |
||||
|
||||
StringBuilder hex = new StringBuilder(); |
||||
|
||||
for (byte b : bytes) { |
||||
hex.append(HEXES[(b >> 4) & 0x0F]); |
||||
hex.append(HEXES[b & 0x0F]); |
||||
} |
||||
|
||||
return hex.toString(); |
||||
} |
||||
|
||||
/** |
||||
* 16进制字符串 转换为对应的 byte数组 |
||||
*/ |
||||
public static byte[] hex2Bytes(String hex) { |
||||
if (hex == null || hex.length() == 0) { |
||||
return null; |
||||
} |
||||
|
||||
char[] hexChars = hex.toCharArray(); |
||||
// 如果 hex 中的字符不是偶数个, 则忽略最后一个
|
||||
byte[] bytes = new byte[hexChars.length / 2]; |
||||
|
||||
for (int i = 0; i < bytes.length; i++) { |
||||
bytes[i] = (byte) Integer.parseInt("" + hexChars[i * 2] + hexChars[i * 2 + 1], 16); |
||||
} |
||||
|
||||
return bytes; |
||||
} |
||||
|
||||
private static final char[] HEXES = { |
||||
'0', '1', '2', '3', |
||||
'4', '5', '6', '7', |
||||
'8', '9', 'a', 'b', |
||||
'c', 'd', 'e', 'f' |
||||
}; |
||||
|
||||
} |
||||
@ -1,33 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.utils; |
||||
|
||||
import org.springframework.util.DigestUtils; |
||||
|
||||
import java.nio.charset.StandardCharsets; |
||||
import java.util.Objects; |
||||
|
||||
/** |
||||
* @author fuzongyao |
||||
* @date 2021/10/14 11:19 |
||||
* @since 1.0 |
||||
*/ |
||||
public class Md5Utils { |
||||
|
||||
/** |
||||
* 加盐 |
||||
*/ |
||||
private static final String SALT = "4v6dKAOn+tEiVH58/XKeUw=="; |
||||
|
||||
public static String md5(String body) { |
||||
body += SALT; |
||||
return DigestUtils.md5DigestAsHex(body.getBytes(StandardCharsets.UTF_8)).toUpperCase(); |
||||
} |
||||
|
||||
public static boolean verify(String md5, String body) { |
||||
return Objects.equals(md5, md5(body)); |
||||
} |
||||
|
||||
public static void main(String[] args) { |
||||
System.out.println(md5("123456")); |
||||
} |
||||
|
||||
} |
||||
@ -1,35 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.utils; |
||||
|
||||
import java.security.SecureRandom; |
||||
import java.util.Base64; |
||||
|
||||
/** |
||||
* 盐值生成 |
||||
* |
||||
* @author Soul2 |
||||
* @date 2024-03-30 14:30 |
||||
*/ |
||||
|
||||
public class SaltUtils { |
||||
|
||||
/** |
||||
* 生成指定长度的盐值 |
||||
* |
||||
* @param length 盐值长度 |
||||
* @return {@link String} |
||||
*/ |
||||
public static String generateSalt(int length) { |
||||
SecureRandom random = new SecureRandom(); |
||||
byte[] salt = new byte[length]; |
||||
random.nextBytes(salt); |
||||
return Base64.getEncoder().encodeToString(salt); |
||||
} |
||||
|
||||
public static void main(String[] args) { |
||||
// 设置盐值长度
|
||||
int saltLength = 16; |
||||
String salt = generateSalt(saltLength); |
||||
System.out.println("Generated Salt: " + salt); |
||||
} |
||||
|
||||
} |
||||
@ -1,32 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.vo; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
import java.util.List; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-05-10 12:46 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class AnswerPageVO { |
||||
|
||||
/** |
||||
* qnId |
||||
*/ |
||||
private String qnId; |
||||
|
||||
/** |
||||
* qnName |
||||
*/ |
||||
private String qnName; |
||||
|
||||
/** |
||||
* sheets |
||||
*/ |
||||
private List<AnswerSheetVO> sheets; |
||||
|
||||
} |
||||
@ -1,38 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.vo; |
||||
|
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-03-30 14:40 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class UserVO { |
||||
|
||||
/** |
||||
* username |
||||
*/ |
||||
private String username; |
||||
|
||||
/** |
||||
* token |
||||
* 其实就是'UserLoginOut'表的id |
||||
*/ |
||||
private String token; |
||||
|
||||
/** |
||||
* 权限等级 |
||||
*/ |
||||
private String authorityLevel; |
||||
|
||||
/** |
||||
* 状态;0(默认)：正常；4：封号；9：异常； |
||||
*/ |
||||
private Integer status; |
||||
|
||||
private String loginFail; |
||||
|
||||
} |
||||
@ -1,34 +0,0 @@ |
||||
package cn.soul2.jyjc.admin.vo.base; |
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat; |
||||
import lombok.Data; |
||||
import lombok.experimental.Accessors; |
||||
|
||||
import java.time.LocalDateTime; |
||||
|
||||
/** |
||||
* @author Soul2 |
||||
* @date 2024-05-10 15:07 |
||||
*/ |
||||
|
||||
@Data |
||||
@Accessors(chain = true) |
||||
public class OptionsVO { |
||||
|
||||
/** |
||||
* code |
||||
*/ |
||||
private String code; |
||||
|
||||
/** |
||||
* label |
||||
*/ |
||||
private String label; |
||||
|
||||
/** |
||||
* date time |
||||
*/ |
||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") |
||||
private LocalDateTime time; |
||||
|
||||
} |
||||
@ -1,127 +0,0 @@ |
||||
<?xml version="1.0" encoding="UTF-8"?> |
||||
<configuration scan="true" scanPeriod="10 seconds"> |
||||
|
||||
<!--<include resource="org/springframework/boot/logging/logback/base.xml" />--> |
||||
|
||||
<contextName>logback</contextName> |
||||
<!-- name的值是变量的名称，value的值时变量定义的值。通过定义的值会被插入到logger上下文中。定义变量后，可以使“${}”来使用变量。 --> |
||||
<!-- <property name="log.path" value=".logs/"/>--> |
||||
<springProperty scope="context" name="log.path" source="logging.path" defaultValue="./logs/"/> |
||||
<property name="log.pattern" |
||||
value="%cyan(%d{HH:mm:ss}) %green(%-5level) %blue(%logger{50}) - %boldMagenta(%msg) \t\t ---- %yellow([%thread] %d{yyyy-MM-dd HH:mm:ss.SSS}) %n" |
||||
/> |
||||
<property name="debug.path" value="${log.path}/%d{yyyyMM,aux}/%d{dd,aux}/debug-%d{yyyyMMdd}.%i.log.gz"/> |
||||
<property name="info.path" value="${log.path}/%d{yyyyMM,aux}/%d{dd,aux}/info-%d{yyyyMMdd}.%i.log.gz"/> |
||||
<property name="error.path" value="${log.path}/%d{yyyyMM,aux}/%d{dd,aux}/error-%d{yyyyMMdd}.%i.log.gz"/> |
||||
|
||||
<!--输出到控制台--> |
||||
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender"> |
||||
<!-- 控制台输出的日志级别是大于或等于此级别的日志信息 --> |
||||
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> |
||||
<level>DEBUG</level> |
||||
</filter> |
||||
<!--日志文件输出格式与字符集--> |
||||
<encoder> |
||||
<Pattern>${log.pattern}</Pattern> |
||||
<charset>UTF-8</charset> |
||||
</encoder> |
||||
</appender> |
||||
|
||||
<!--输出到文件--> |
||||
<!-- 时间滚动输出 level为 DEBUG 日志 --> |
||||
<appender name="DEBUG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> |
||||
<!-- 正在记录的日志文件的路径及文件名 --> |
||||
<file>${log.path}/debug.log</file> |
||||
<!--日志文件输出格式与字符集--> |
||||
<encoder> |
||||
<pattern>${log.pattern}</pattern> |
||||
<charset>UTF-8</charset> |
||||
</encoder> |
||||
<!-- 日志记录器的滚动策略，按日期，按大小记录 --> |
||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> |
||||
<!-- 日志归档 --> |
||||
<fileNamePattern>${debug.path}</fileNamePattern> |
||||
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> |
||||
<maxFileSize>10MB</maxFileSize> |
||||
</timeBasedFileNamingAndTriggeringPolicy> |
||||
<!--日志文件保留天数--> |
||||
<maxHistory>7</maxHistory> |
||||
</rollingPolicy> |
||||
<!-- 此日志文件记录debug级别以上的 --> |
||||
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> |
||||
<level>DEBUG</level> |
||||
</filter> |
||||
</appender> |
||||
|
||||
<!-- 时间滚动输出 level为 INFO 日志 --> |
||||
<appender name="INFO_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> |
||||
<!-- 正在记录的日志文件的路径及文件名 --> |
||||
<file>${log.path}/info.log</file> |
||||
<!--日志文件输出格式--> |
||||
<encoder> |
||||
<pattern>${log.pattern}</pattern> |
||||
<charset>UTF-8</charset> |
||||
</encoder> |
||||
<!-- 日志记录器的滚动策略，按日期，按大小记录 --> |
||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> |
||||
<!-- 每天日志归档路径以及格式 --> |
||||
<fileNamePattern>${info.path}</fileNamePattern> |
||||
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> |
||||
<maxFileSize>100MB</maxFileSize> |
||||
</timeBasedFileNamingAndTriggeringPolicy> |
||||
<!--日志文件保留天数--> |
||||
<maxHistory>60</maxHistory> |
||||
</rollingPolicy> |
||||
<!-- 此日志文件记录info级别以上的 --> |
||||
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> |
||||
<level>INFO</level> |
||||
</filter> |
||||
</appender> |
||||
|
||||
<!-- 时间滚动输出 level为 ERROR 日志 --> |
||||
<appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> |
||||
<!-- 正在记录的日志文件的路径及文件名 --> |
||||
<file>${log.path}/error.log</file> |
||||
<!--日志文件输出格式--> |
||||
<encoder> |
||||
<pattern>${log.pattern}</pattern> |
||||
<charset>UTF-8</charset> <!-- 此处设置字符集 --> |
||||
</encoder> |
||||
<!-- 日志记录器的滚动策略，按日期，按大小记录 --> |
||||
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> |
||||
<fileNamePattern>${error.path}</fileNamePattern> |
||||
<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP"> |
||||
<maxFileSize>10MB</maxFileSize> |
||||
</timeBasedFileNamingAndTriggeringPolicy> |
||||
<!--日志文件保留天数--> |
||||
<maxHistory>60</maxHistory> |
||||
</rollingPolicy> |
||||
<!-- 此日志文件记录error级别以上的 --> |
||||
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> |
||||
<level>ERROR</level> |
||||
</filter> |
||||
</appender> |
||||
|
||||
<!--开发环境:打印控制台--> |
||||
<springProfile name="local,dev,test"> |
||||
<logger level="DEBUG" additivity="false" name="cn.soul2"> |
||||
<appender-ref ref="CONSOLE"/> |
||||
<appender-ref ref="DEBUG_FILE"/> |
||||
<appender-ref ref="INFO_FILE"/> |
||||
<appender-ref ref="ERROR_FILE"/> |
||||
</logger> |
||||
<root level="INFO"> |
||||
<appender-ref ref="CONSOLE"/> |
||||
<appender-ref ref="INFO_FILE"/> |
||||
<appender-ref ref="ERROR_FILE"/> |
||||
</root> |
||||
</springProfile> |
||||
|
||||
<!--生产环境:输出到文件--> |
||||
<springProfile name="pre,prod,prod-yun"> |
||||
<root level="INFO"> |
||||
<appender-ref ref="INFO_FILE"/> |
||||
<appender-ref ref="ERROR_FILE"/> |
||||
</root> |
||||
</springProfile> |
||||
</configuration> |
||||
Loading…
Reference in new issue