Compare commits

...

9 Commits

Author SHA1 Message Date
176yunxuan
84d3ccc5af fix:我负责我管理我参与的项目查询重构以及项目增加,系统模块数据表增加截止时间和状态字段 2024-04-17 17:03:35 +08:00
0516e8dce4
perf(配置): 添加启动项
添加启动项 wyj 配置文件
2024-04-17 15:20:10 +08:00
80478baf76
fix(service): 修复获取不到用户信息
All checks were successful
代码检查 / 代码检查 (push) Successful in 18s
修复对于 token 的解析获取无法获取到 userDO 的情况进行异常返回
2024-04-17 11:20:40 +08:00
a10fbce2f8
Merge branch 'refs/heads/develop'
All checks were successful
代码检查 / 代码检查 (push) Successful in 20s
2024-04-17 11:12:01 +08:00
6b0c58dea9 Merge pull request 'bug:消息分页返回增加总数等字段' (#18) from feature-jie into develop
Reviewed-on: #18
Reviewed-by: 筱锋xiao_lfeng <gm@x-lf.cn>
2024-04-17 11:11:40 +08:00
3e67b5b94c
fix(总体、控制层): 修复错误内容
- 对权限登出的 Redis 进行处理
- 修复接口漏洞
2024-04-17 11:10:15 +08:00
045147dc30
patch: 补丁
All checks were successful
代码检查 / 代码检查 (push) Successful in 16s
2024-04-17 01:13:57 +08:00
75d471b1b6
patch: 补丁
All checks were successful
代码检查 / 代码检查 (push) Successful in 19s
2024-04-17 01:09:42 +08:00
65a13ff549 Merge pull request 'Merge 推送至业务' (#17) from develop into master
All checks were successful
代码检查 / 代码检查 (push) Successful in 27s
Reviewed-on: #17
2024-04-17 00:55:36 +08:00
21 changed files with 236 additions and 50 deletions

View File

@ -8,14 +8,14 @@
<option name="environmentProperties">
<map />
</option>
<option name="jreName" value="corretto-17" />
<option name="jreName" value="#USE_PROJECT_JDK" />
<option name="mavenProperties">
<map />
</option>
<option name="passParentEnv" value="true" />
<option name="runMavenInBackground" value="true" />
<option name="skipTests" value="false" />
<option name="vmOptions" value="-Dfile.encoding=GB2312" />
<option name="vmOptions" value="" />
</MavenRunnerSettings>
</option>
<option name="myRunnerParameters">

View File

@ -0,0 +1,48 @@
<component name="ProjectRunConfigurationManager">
<configuration default="false" name="wyj [clean,spring-boot:run]" type="MavenRunConfiguration" factoryName="Maven" nameIsGenerated="true">
<MavenSettings>
<option name="myGeneralSettings" />
<option name="myRunnerSettings">
<MavenRunnerSettings>
<option name="delegateBuildToMaven" value="false" />
<option name="environmentProperties">
<map />
</option>
<option name="jreName" value="corretto-17" />
<option name="mavenProperties">
<map />
</option>
<option name="passParentEnv" value="true" />
<option name="runMavenInBackground" value="true" />
<option name="skipTests" value="false" />
<option name="vmOptions" value="-Dfile.encoding=GB2312" />
</MavenRunnerSettings>
</option>
<option name="myRunnerParameters">
<MavenRunnerParameters>
<option name="cmdOptions" />
<option name="profiles">
<set />
</option>
<option name="goals">
<list>
<option value="clean" />
<option value="spring-boot:run" />
</list>
</option>
<option name="multimoduleDir" />
<option name="pomFileName" />
<option name="profilesMap">
<map />
</option>
<option name="projectsCmdOptionValues">
<list />
</option>
<option name="resolveToWorkspace" value="false" />
<option name="workingDirPath" value="$PROJECT_DIR$" />
</MavenRunnerParameters>
</option>
</MavenSettings>
<method v="2" />
</configuration>
</component>

View File

@ -17,6 +17,7 @@
<java.version>1.8</java.version>
<skipTests>true</skipTests>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
@ -166,10 +167,12 @@
<goal>timestamp-property</goal>
</goals>
<configuration>
<name>buildDate</name>
<pattern>yyyy-MM-dd HH:mm:ss</pattern>
<locale>en_US</locale>
<timeZone>GMT+8</timeZone>
</configuration>
</execution>
</executions>

View File

@ -3,11 +3,14 @@ package com.jsl.oa.aspect;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import com.jsl.oa.annotations.NeedPermission;
import com.jsl.oa.common.constant.BusinessConstants;
import com.jsl.oa.dao.RoleDAO;
import com.jsl.oa.exception.library.NotLoginException;
import com.jsl.oa.exception.library.PermissionDeniedException;
import com.jsl.oa.exception.library.TokenNotFoundedException;
import com.jsl.oa.model.dodata.RoleDO;
import com.jsl.oa.utils.Processing;
import com.jsl.oa.utils.redis.TokenRedisUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
@ -37,6 +40,7 @@ public class CheckUserPermissionAspect {
private final RoleDAO roleDAO;
private final Gson gson;
private final TokenRedisUtil<String> tokenRedisUtil;
/**
* 检查权限
@ -58,6 +62,9 @@ public class CheckUserPermissionAspect {
if (getUserId == null) {
throw new NotLoginException("用户信息不存在");
}
if (tokenRedisUtil.getData(BusinessConstants.BUSINESS_LOGIN, getUserId.toString()) == null) {
throw new TokenNotFoundedException("用户未登录");
}
// 获取方法签名
MethodSignature signature = (MethodSignature) pjp.getSignature();
NeedPermission checkAccountPermission = signature.getMethod().getAnnotation(NeedPermission.class);

View File

@ -19,19 +19,16 @@ public class PermissionList {
public PermissionList() {
permissionList.add(new PermissionVO("auth:logout", "账户登出"));
permissionList.add(new PermissionVO("auth:change_password", "修改密码"));
permissionList.add(new PermissionVO("info:get_header_image", "获取头部图片"));
permissionList.add(new PermissionVO("info:edit_header_image", "编辑头部图片"));
permissionList.add(new PermissionVO("info:delete_header_image", "删除头部图片"));
permissionPrincipal.add(new PermissionVO("auth:logout", "账户登出"));
permissionPrincipal.add(new PermissionVO("auth:change_password", "修改密码"));
permissionPrincipal.add(new PermissionVO("info:get_header_image", "获取头部图片"));
permissionPrincipal.add(new PermissionVO("info:edit_header_image", "编辑头部图片"));
permissionPrincipal.add(new PermissionVO("info:delete_header_image", "删除头部图片"));
permissionDeveloper.add(new PermissionVO("auth:logout", "账户登出"));
permissionDeveloper.add(new PermissionVO("auth:change_password", "修改密码"));
permissionDeveloper.add(new PermissionVO("info:get_header_image", "获取头部图片"));
permissionDeveloper.add(new PermissionVO("info:edit_header_image", "编辑头部图片"));

View File

@ -147,7 +147,6 @@ public class AuthController {
* @since v1.1.0
*/
@GetMapping("/auth/logout")
@NeedPermission("auth:logout")
public BaseResponse authLogout(HttpServletRequest request) {
return authService.authLogout(request);
}

View File

@ -54,9 +54,9 @@ public class ProjectController {
* @param id 要查询的 id
* @return {@link BaseResponse}
*/
@GetMapping("/project/getwork/id")
public BaseResponse projectWorkGetById(@RequestParam Integer id) {
return projectService.getWorkById(id);
@GetMapping("/project/module/id")
public BaseResponse projectModuleGetById(@RequestParam Integer id) {
return projectService.getModuleById(id);
}
/**
@ -110,7 +110,7 @@ public class ProjectController {
* @return {@link BaseResponse}
*/
@GetMapping("/project/child/get")
public BaseResponse projectWorkGet(
public BaseResponse projectModuleGet(
@RequestParam(required = false) List<String> tags,
@RequestParam(required = false) List<String> isFinish,
@RequestParam(required = false) Integer is,
@ -179,6 +179,42 @@ public class ProjectController {
return projectService.projectEdit(request, projectEdit, projectId);
}
/**
* 获取我负责的项目
*
* @param page 页数
* @param pageSize 每页大小
* @param request
* @return
*/
@GetMapping("/project/my/get")
public BaseResponse projectMyGet(
@RequestParam(required = false, defaultValue = "1") Integer page,
@RequestParam(required = false, defaultValue = "10") Integer pageSize,
HttpServletRequest request) {
return projectService.getPrincipalProject(page, pageSize, request);
}
/**
*
* 获取我参与的项目
*
* @param page 页数
* @param pageSize 每页大小
* @param request
* @return
*/
@GetMapping("/project/participate/get")
public BaseResponse projectParticipateGet(
@RequestParam(required = false, defaultValue = "1") Integer page,
@RequestParam(required = false, defaultValue = "10") Integer pageSize,
HttpServletRequest request) {
return projectService.getParticipateProject(page, pageSize, request);
}
/**
* 子系统子模块的增加
*
@ -219,7 +255,7 @@ public class ProjectController {
if (bindingResult.hasErrors()) {
return ResultUtil.error(ErrorCode.PARAMETER_ERROR, Processing.getValidatedErrorList(bindingResult));
}
return ResultUtil.success(projectService.projectAdd(request, projectInfoVO));
return projectService.projectAdd(request, projectInfoVO);
}
/**

View File

@ -45,17 +45,27 @@ public class PermissionDAO {
public List<String> getPermission(@NotNull Long uid) {
// 查询用户所在角色组
RoleDO getRole = roleMapper.getRoleByUserId(uid);
List<String> getPermissionForString;
String permissionRedisString = roleRedisUtil.getData(BusinessConstants.NONE, uid.toString());
if (permissionRedisString == null) {
String permissionList = permissionMapper.getPermissionByRole(getRole.getRoleName());
getPermissionForString = gson.fromJson(permissionList, new TypeToken<List<String>>() { }.getType());
// 存入 Redis
roleRedisUtil.setData(BusinessConstants.NONE, uid.toString(), gson.toJson(getPermissionForString), 1440);
if (getRole != null) {
List<String> getPermissionForString;
String permissionRedisString = roleRedisUtil.getData(BusinessConstants.NONE, uid.toString());
if (permissionRedisString == null) {
String permissionList = permissionMapper.getPermissionByRole(getRole.getRoleName());
getPermissionForString = gson.fromJson(permissionList, new TypeToken<List<String>>() { }.getType());
// 存入 Redis
roleRedisUtil.setData(
BusinessConstants.NONE,
uid.toString(),
gson.toJson(getPermissionForString),
1440
);
} else {
getPermissionForString = gson
.fromJson(permissionRedisString, new TypeToken<List<String>>() { }.getType());
}
return getPermissionForString;
} else {
getPermissionForString = gson.fromJson(permissionRedisString, new TypeToken<List<String>>() { }.getType());
return null;
}
return getPermissionForString;
}
public List<String> getAllPermissionBuildString() {
@ -69,7 +79,7 @@ public class PermissionDAO {
roleRedisUtil.setData(
BusinessConstants.ALL_PERMISSION,
"string",
gson.toJson(permissionList),
gson.toJson(getPermission),
1440);
} else {
getPermission = gson.fromJson(getRedisData, new TypeToken<List<String>>() { }.getType());

View File

@ -1,6 +1,7 @@
package com.jsl.oa.exception;
import com.jsl.oa.exception.library.PermissionDeniedException;
import com.jsl.oa.exception.library.TokenNotFoundedException;
import com.jsl.oa.utils.BaseResponse;
import com.jsl.oa.utils.ErrorCode;
import com.jsl.oa.utils.ResultUtil;
@ -110,4 +111,10 @@ public class ProcessException {
log.warn("[EXCEPTION] 无权限操作,需要权限: {}", e.getNeedPermission());
return ResultUtil.error("需要权限: " + e.getNeedPermission(), ErrorCode.PERMISSION_NOT_EXIST);
}
@ExceptionHandler(value = TokenNotFoundedException.class)
public BaseResponse businessTokenNotFoundedException(TokenNotFoundedException e) {
log.warn("[EXCEPTION] {}", e.getMessage());
return ResultUtil.error(e.getMessage(), ErrorCode.TOKEN_NOT_EXIST);
}
}

View File

@ -0,0 +1,7 @@
package com.jsl.oa.exception.library;
public class TokenNotFoundedException extends RuntimeException {
public TokenNotFoundedException(String message) {
super(message);
}
}

View File

@ -108,7 +108,7 @@ public interface ProjectMapper {
List <Long> getMemberBySystemId(Integer id);
@Select("select * from organize_oa.oa_project_modules "
+ "where DATE(deadline) = DATE(#{threeDayLater}) and status = 0")
+ "where DATE(dead_line) = DATE(#{threeDayLater}) and status != 'complete' ")
List<ProjectModuleDO> getProjectWorkByTime(LocalDateTime threeDayLater);
@ -126,11 +126,14 @@ public interface ProjectMapper {
@Select("select * from organize_oa.oa_project_child where "
+ "DATE (created_at) = DATE (#{threeDaysLater}) ")
+ "DATE (dead_line) = DATE (#{threeDaysLater}) and status != 'complete' ")
List<ProjectChildDO> getProjectChildByTime(LocalDateTime threeDaysLater);
@Select("select * from organize_oa.oa_project_child where "
+ "id = #{id} and is_delete = 0")
ProjectChildDO getProjectChildById(Integer id);
List<ProjectDO> getParticipateProject(Long userId);
}

View File

@ -23,6 +23,7 @@ public class ProjectInfoVO {
private String files;
private Timestamp beginTime;
private Timestamp completeTime;
@NotNull(message = "截止时间不能为空")
private Timestamp deadLine;
private String status;

View File

@ -4,6 +4,8 @@ import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.Data;
import lombok.experimental.Accessors;
import java.sql.Date;
@Data
@Accessors(chain = true)
@JsonInclude(JsonInclude.Include.NON_NULL)
@ -14,5 +16,8 @@ public class ProjectSimpleVO {
private Long cycle;
private Long workLoad;
private Long id;
private String files;
private String status;
private Date deadLine;
private String tags;
}

View File

@ -41,9 +41,9 @@ public interface ProjectService {
BaseResponse projectFileGet(HttpServletRequest request, Long projectId);
BaseResponse getById(Integer id);
BaseResponse getProjectModuleById(Integer id);
BaseResponse getWorkById(Integer id);
BaseResponse getModuleById(Integer id);
BaseResponse projectPrincipalGet();
@ -57,4 +57,10 @@ public interface ProjectService {
* @return 根据用户所属角色组的不同返回不同的内容
*/
BaseResponse getProjectById(HttpServletRequest request, Long projectId);
BaseResponse getById(Integer id);
BaseResponse getPrincipalProject(Integer page, Integer pageSize, HttpServletRequest request);
BaseResponse getParticipateProject(Integer page, Integer pageSize, HttpServletRequest request);
}

View File

@ -209,11 +209,15 @@ public class AuthServiceImpl implements AuthService {
public BaseResponse authLogout(HttpServletRequest request) {
// 获取用户
UserDO userDO = userMapper.getUserById(Processing.getAuthHeaderToUserId(request));
// 删除Token
if (tokenRedisUtil.delData(BusinessConstants.BUSINESS_LOGIN, userDO.getId().toString())) {
return ResultUtil.success("登出成功");
if (userDO != null) {
// 删除Token
if (tokenRedisUtil.delData(BusinessConstants.BUSINESS_LOGIN, userDO.getId().toString())) {
return ResultUtil.success("登出成功");
} else {
return ResultUtil.error(ErrorCode.TOKEN_NOT_EXIST);
}
} else {
return ResultUtil.error(ErrorCode.DATABASE_DELETE_ERROR);
return ResultUtil.error(ErrorCode.TOKEN_NOT_EXIST);
}
}

View File

@ -1,4 +1,6 @@
package com.jsl.oa.services.impl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.jsl.oa.dao.UserDAO;
import com.jsl.oa.mapper.MessageMapper;
import com.jsl.oa.mapper.ProjectMapper;
@ -7,7 +9,6 @@ import com.jsl.oa.model.dodata.ProjectChildDO;
import com.jsl.oa.model.dodata.ProjectModuleDO;
import com.jsl.oa.model.vodata.MessageAddVO;
import com.jsl.oa.model.vodata.MessageGetVO;
import com.jsl.oa.model.vodata.PageBean;
import com.jsl.oa.services.MessageService;
import com.jsl.oa.utils.*;
import lombok.RequiredArgsConstructor;
@ -67,6 +68,7 @@ public class MessageServiceImpl implements MessageService {
endTime = LocalDateTime.now();
beginTime = endTime.minusDays(30);
}
PageHelper.startPage(page, pageSize);
List<MessageDO> messageDOList = messageMapper.page(beginTime, endTime, uid);
//封装返回数据
List<MessageGetVO> messageGetVOList = new ArrayList<>();
@ -89,16 +91,8 @@ public class MessageServiceImpl implements MessageService {
}
//分页返回
int start = (page - 1) * pageSize;
int end = start + pageSize;
List<MessageGetVO> pageData = messageGetVOList.subList(start,
Math.min(end, messageGetVOList.size()));
PageBean<MessageGetVO> pageBean = new PageBean<>();
pageBean.setTotalCount(messageGetVOList.size());
pageBean.setCurrentPage(page);
pageBean.setPageSize(pageSize);
pageBean.setList(pageData);
return ResultUtil.success(pageBean);
PageInfo<MessageGetVO> pageInfo = new PageInfo<>(messageGetVOList);
return ResultUtil.success(pageInfo);
}
/**

View File

@ -3,6 +3,8 @@ package com.jsl.oa.services.impl;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.jsl.oa.annotations.NeedPermission;
import com.jsl.oa.dao.ProjectDAO;
import com.jsl.oa.dao.RoleDAO;
@ -54,10 +56,15 @@ public class ProjectServiceImpl implements ProjectService {
@Override
public BaseResponse projectAdd(HttpServletRequest request, ProjectInfoVO projectAdd) {
// 判断权限
if (!Processing.checkUserIsPrincipal(request, roleDAO)) {
return ResultUtil.error(ErrorCode.NOT_PERMISSION);
}
if (projectAdd.getDescription().isEmpty()) {
projectAdd.setDescription("{}");
} else {
projectAdd.setDescription("{\"description\":\" " + projectAdd.getDescription() + "\"}");
projectAdd.setDescription("{\"描述\":\" " + projectAdd.getDescription() + "\"}");
}
String tags = projectAdd.getTags();
String[] split = tags.split(",");
@ -147,6 +154,11 @@ public class ProjectServiceImpl implements ProjectService {
}
@Override
public BaseResponse getProjectModuleById(Integer id) {
return null;
}
@Override
public BaseResponse getById(Integer id) {
ProjectDO projectDO = projectMapper.tgetProjectById(id);
@ -154,7 +166,45 @@ public class ProjectServiceImpl implements ProjectService {
}
@Override
public BaseResponse getWorkById(Integer id) {
public BaseResponse getPrincipalProject(Integer page, Integer pageSize, HttpServletRequest request) {
//获取用户id
Long userId = Processing.getAuthHeaderToUserId(request);
PageHelper.startPage(page, pageSize);
List<ProjectDO> projectDOList = projectDAO.get(userId, null, null);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
projectSimpleVOList.add(projectSimpleVO1);
}
//分页返回
PageInfo<ProjectSimpleVO> pageInfo = new PageInfo<>(projectSimpleVOList);
return ResultUtil.success(pageInfo);
}
@Override
public BaseResponse getParticipateProject(Integer page, Integer pageSize, HttpServletRequest request) {
//获取用户id
Long userId = Processing.getAuthHeaderToUserId(request);
PageHelper.startPage(page, pageSize);
List<ProjectDO> projectDOList = projectMapper.getParticipateProject(userId);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
projectSimpleVOList.add(projectSimpleVO1);
}
//分页返回
PageInfo<ProjectSimpleVO> pageInfo = new PageInfo<>(projectSimpleVOList);
return ResultUtil.success(pageInfo);
}
@Override
public BaseResponse getModuleById(Integer id) {
ProjectWorkSimpleVO projectWorkSimpleVO = projectMapper.getWorkById(id);
projectWorkSimpleVO.setPrincipalUser(userDAO.getUserById(projectMapper.getPid(id)).getUsername());
@ -312,9 +362,10 @@ public class ProjectServiceImpl implements ProjectService {
Integer page,
Integer pageSize
) {
//获取用户
//获取用户id
Long userId = Processing.getAuthHeaderToUserId(request);
PageHelper.startPage(page, pageSize);
List<ProjectDO> projectDOList = projectDAO.workget(userId, tags, isFinish, is);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
@ -323,12 +374,8 @@ public class ProjectServiceImpl implements ProjectService {
projectSimpleVOList.add(projectSimpleVO1);
}
//分页返回
int start = (page - 1) * pageSize;
int end = start + pageSize;
List<ProjectSimpleVO> pageData = projectSimpleVOList.subList(start,
Math.min(end, projectSimpleVOList.size()));
return ResultUtil.success(pageData);
PageInfo<ProjectSimpleVO> pageInfo = new PageInfo<>(projectSimpleVOList);
return ResultUtil.success(pageInfo);
}

View File

@ -341,6 +341,9 @@ public class Processing {
projectSimpleVO.setTags(projectDO.getTags());
projectSimpleVO.setCycle(projectDO.getCycle().longValue());
projectSimpleVO.setWorkLoad(projectDO.getWorkLoad().longValue());
projectSimpleVO.setFiles(projectDO.getFiles());
projectSimpleVO.setStatus(projectDO.getStatus());
projectSimpleVO.setDeadLine(projectDO.getDeadline());
projectSimpleVO.setPrincipalUser(userDAO.getUserById(projectDO.getPrincipalId()).getUsername());
// 解析JSON字符串
JsonNode rootNode = null;

View File

@ -151,7 +151,12 @@
#{Finish}
</foreach>
</select>
<select id="getParticipateProject" resultType="com.jsl.oa.model.dodata.ProjectDO">
select * from organize_oa.oa_project where id in
(select project_id from organize_oa.oa_project_child where id in
(select project_child_id from organize_oa.oa_project_modules
where oa_project_modules.principal_id=#{userId} and is_delete=false) )
</select>
</mapper>

View File

@ -13,6 +13,8 @@ create table oa_project_child
created_at timestamp default CURRENT_TIMESTAMP not null comment '创建时间',
updated_at timestamp null comment '更新时间',
is_delete tinyint(1) default 0 not null comment '项目是否删除',
dead_line timestamp not null comment '子系统的截止时间',
status varchar(8) default 'progress' not null comment '系统状态draft: 草稿progress: 进行pause: 暂停abnormal: 异常complete: 完成)',
constraint oa_project_child_oa_user_id_fk
foreign key (principal_id) references oa_user (id)
on update cascade

View File

@ -11,6 +11,8 @@ create table oa_project_modules
created_at timestamp default CURRENT_TIMESTAMP not null comment '创建时间',
updated_at timestamp null comment '更新时间',
is_delete tinyint(1) default 0 not null comment '项目是否删除',
dead_line timestamp not null comment '子模块的截止时间',
status varchar(8) default 'progress' not null comment '模块状态draft: 草稿progress: 进行pause: 暂停abnormal: 异常complete: 完成)',
constraint oa_project_modules_oa_user_id_fk
foreign key (principal_id) references oa_user (id)
on update cascade