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"> <option name="environmentProperties">
<map /> <map />
</option> </option>
<option name="jreName" value="corretto-17" /> <option name="jreName" value="#USE_PROJECT_JDK" />
<option name="mavenProperties"> <option name="mavenProperties">
<map /> <map />
</option> </option>
<option name="passParentEnv" value="true" /> <option name="passParentEnv" value="true" />
<option name="runMavenInBackground" value="true" /> <option name="runMavenInBackground" value="true" />
<option name="skipTests" value="false" /> <option name="skipTests" value="false" />
<option name="vmOptions" value="-Dfile.encoding=GB2312" /> <option name="vmOptions" value="" />
</MavenRunnerSettings> </MavenRunnerSettings>
</option> </option>
<option name="myRunnerParameters"> <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> <java.version>1.8</java.version>
<skipTests>true</skipTests> <skipTests>true</skipTests>
</properties> </properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
@ -166,10 +167,12 @@
<goal>timestamp-property</goal> <goal>timestamp-property</goal>
</goals> </goals>
<configuration> <configuration>
<name>buildDate</name> <name>buildDate</name>
<pattern>yyyy-MM-dd HH:mm:ss</pattern> <pattern>yyyy-MM-dd HH:mm:ss</pattern>
<locale>en_US</locale> <locale>en_US</locale>
<timeZone>GMT+8</timeZone> <timeZone>GMT+8</timeZone>
</configuration> </configuration>
</execution> </execution>
</executions> </executions>

View File

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

View File

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

View File

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

View File

@ -54,9 +54,9 @@ public class ProjectController {
* @param id 要查询的 id * @param id 要查询的 id
* @return {@link BaseResponse} * @return {@link BaseResponse}
*/ */
@GetMapping("/project/getwork/id") @GetMapping("/project/module/id")
public BaseResponse projectWorkGetById(@RequestParam Integer id) { public BaseResponse projectModuleGetById(@RequestParam Integer id) {
return projectService.getWorkById(id); return projectService.getModuleById(id);
} }
/** /**
@ -110,7 +110,7 @@ public class ProjectController {
* @return {@link BaseResponse} * @return {@link BaseResponse}
*/ */
@GetMapping("/project/child/get") @GetMapping("/project/child/get")
public BaseResponse projectWorkGet( public BaseResponse projectModuleGet(
@RequestParam(required = false) List<String> tags, @RequestParam(required = false) List<String> tags,
@RequestParam(required = false) List<String> isFinish, @RequestParam(required = false) List<String> isFinish,
@RequestParam(required = false) Integer is, @RequestParam(required = false) Integer is,
@ -179,6 +179,42 @@ public class ProjectController {
return projectService.projectEdit(request, projectEdit, projectId); 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()) { if (bindingResult.hasErrors()) {
return ResultUtil.error(ErrorCode.PARAMETER_ERROR, Processing.getValidatedErrorList(bindingResult)); 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) { public List<String> getPermission(@NotNull Long uid) {
// 查询用户所在角色组 // 查询用户所在角色组
RoleDO getRole = roleMapper.getRoleByUserId(uid); RoleDO getRole = roleMapper.getRoleByUserId(uid);
List<String> getPermissionForString; if (getRole != null) {
String permissionRedisString = roleRedisUtil.getData(BusinessConstants.NONE, uid.toString()); List<String> getPermissionForString;
if (permissionRedisString == null) { String permissionRedisString = roleRedisUtil.getData(BusinessConstants.NONE, uid.toString());
String permissionList = permissionMapper.getPermissionByRole(getRole.getRoleName()); if (permissionRedisString == null) {
getPermissionForString = gson.fromJson(permissionList, new TypeToken<List<String>>() { }.getType()); String permissionList = permissionMapper.getPermissionByRole(getRole.getRoleName());
// 存入 Redis getPermissionForString = gson.fromJson(permissionList, new TypeToken<List<String>>() { }.getType());
roleRedisUtil.setData(BusinessConstants.NONE, uid.toString(), gson.toJson(getPermissionForString), 1440); // 存入 Redis
roleRedisUtil.setData(
BusinessConstants.NONE,
uid.toString(),
gson.toJson(getPermissionForString),
1440
);
} else {
getPermissionForString = gson
.fromJson(permissionRedisString, new TypeToken<List<String>>() { }.getType());
}
return getPermissionForString;
} else { } else {
getPermissionForString = gson.fromJson(permissionRedisString, new TypeToken<List<String>>() { }.getType()); return null;
} }
return getPermissionForString;
} }
public List<String> getAllPermissionBuildString() { public List<String> getAllPermissionBuildString() {
@ -69,7 +79,7 @@ public class PermissionDAO {
roleRedisUtil.setData( roleRedisUtil.setData(
BusinessConstants.ALL_PERMISSION, BusinessConstants.ALL_PERMISSION,
"string", "string",
gson.toJson(permissionList), gson.toJson(getPermission),
1440); 1440);
} else { } else {
getPermission = gson.fromJson(getRedisData, new TypeToken<List<String>>() { }.getType()); getPermission = gson.fromJson(getRedisData, new TypeToken<List<String>>() { }.getType());

View File

@ -1,6 +1,7 @@
package com.jsl.oa.exception; package com.jsl.oa.exception;
import com.jsl.oa.exception.library.PermissionDeniedException; 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.BaseResponse;
import com.jsl.oa.utils.ErrorCode; import com.jsl.oa.utils.ErrorCode;
import com.jsl.oa.utils.ResultUtil; import com.jsl.oa.utils.ResultUtil;
@ -110,4 +111,10 @@ public class ProcessException {
log.warn("[EXCEPTION] 无权限操作,需要权限: {}", e.getNeedPermission()); log.warn("[EXCEPTION] 无权限操作,需要权限: {}", e.getNeedPermission());
return ResultUtil.error("需要权限: " + e.getNeedPermission(), ErrorCode.PERMISSION_NOT_EXIST); 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); List <Long> getMemberBySystemId(Integer id);
@Select("select * from organize_oa.oa_project_modules " @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); List<ProjectModuleDO> getProjectWorkByTime(LocalDateTime threeDayLater);
@ -126,11 +126,14 @@ public interface ProjectMapper {
@Select("select * from organize_oa.oa_project_child where " @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); List<ProjectChildDO> getProjectChildByTime(LocalDateTime threeDaysLater);
@Select("select * from organize_oa.oa_project_child where " @Select("select * from organize_oa.oa_project_child where "
+ "id = #{id} and is_delete = 0") + "id = #{id} and is_delete = 0")
ProjectChildDO getProjectChildById(Integer id); ProjectChildDO getProjectChildById(Integer id);
List<ProjectDO> getParticipateProject(Long userId);
} }

View File

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

View File

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

View File

@ -41,9 +41,9 @@ public interface ProjectService {
BaseResponse projectFileGet(HttpServletRequest request, Long projectId); BaseResponse projectFileGet(HttpServletRequest request, Long projectId);
BaseResponse getById(Integer id); BaseResponse getProjectModuleById(Integer id);
BaseResponse getWorkById(Integer id); BaseResponse getModuleById(Integer id);
BaseResponse projectPrincipalGet(); BaseResponse projectPrincipalGet();
@ -57,4 +57,10 @@ public interface ProjectService {
* @return 根据用户所属角色组的不同返回不同的内容 * @return 根据用户所属角色组的不同返回不同的内容
*/ */
BaseResponse getProjectById(HttpServletRequest request, Long projectId); 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) { public BaseResponse authLogout(HttpServletRequest request) {
// 获取用户 // 获取用户
UserDO userDO = userMapper.getUserById(Processing.getAuthHeaderToUserId(request)); UserDO userDO = userMapper.getUserById(Processing.getAuthHeaderToUserId(request));
// 删除Token if (userDO != null) {
if (tokenRedisUtil.delData(BusinessConstants.BUSINESS_LOGIN, userDO.getId().toString())) { // 删除Token
return ResultUtil.success("登出成功"); if (tokenRedisUtil.delData(BusinessConstants.BUSINESS_LOGIN, userDO.getId().toString())) {
return ResultUtil.success("登出成功");
} else {
return ResultUtil.error(ErrorCode.TOKEN_NOT_EXIST);
}
} else { } 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; 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.dao.UserDAO;
import com.jsl.oa.mapper.MessageMapper; import com.jsl.oa.mapper.MessageMapper;
import com.jsl.oa.mapper.ProjectMapper; 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.dodata.ProjectModuleDO;
import com.jsl.oa.model.vodata.MessageAddVO; import com.jsl.oa.model.vodata.MessageAddVO;
import com.jsl.oa.model.vodata.MessageGetVO; import com.jsl.oa.model.vodata.MessageGetVO;
import com.jsl.oa.model.vodata.PageBean;
import com.jsl.oa.services.MessageService; import com.jsl.oa.services.MessageService;
import com.jsl.oa.utils.*; import com.jsl.oa.utils.*;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
@ -67,6 +68,7 @@ public class MessageServiceImpl implements MessageService {
endTime = LocalDateTime.now(); endTime = LocalDateTime.now();
beginTime = endTime.minusDays(30); beginTime = endTime.minusDays(30);
} }
PageHelper.startPage(page, pageSize);
List<MessageDO> messageDOList = messageMapper.page(beginTime, endTime, uid); List<MessageDO> messageDOList = messageMapper.page(beginTime, endTime, uid);
//封装返回数据 //封装返回数据
List<MessageGetVO> messageGetVOList = new ArrayList<>(); List<MessageGetVO> messageGetVOList = new ArrayList<>();
@ -89,16 +91,8 @@ public class MessageServiceImpl implements MessageService {
} }
//分页返回 //分页返回
int start = (page - 1) * pageSize; PageInfo<MessageGetVO> pageInfo = new PageInfo<>(messageGetVOList);
int end = start + pageSize; return ResultUtil.success(pageInfo);
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);
} }
/** /**

View File

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

View File

@ -341,6 +341,9 @@ public class Processing {
projectSimpleVO.setTags(projectDO.getTags()); projectSimpleVO.setTags(projectDO.getTags());
projectSimpleVO.setCycle(projectDO.getCycle().longValue()); projectSimpleVO.setCycle(projectDO.getCycle().longValue());
projectSimpleVO.setWorkLoad(projectDO.getWorkLoad().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()); projectSimpleVO.setPrincipalUser(userDAO.getUserById(projectDO.getPrincipalId()).getUsername());
// 解析JSON字符串 // 解析JSON字符串
JsonNode rootNode = null; JsonNode rootNode = null;

View File

@ -151,7 +151,12 @@
#{Finish} #{Finish}
</foreach> </foreach>
</select> </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> </mapper>

View File

@ -13,6 +13,8 @@ create table oa_project_child
created_at timestamp default CURRENT_TIMESTAMP not null comment '创建时间', created_at timestamp default CURRENT_TIMESTAMP not null comment '创建时间',
updated_at timestamp null comment '更新时间', updated_at timestamp null comment '更新时间',
is_delete tinyint(1) default 0 not 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 constraint oa_project_child_oa_user_id_fk
foreign key (principal_id) references oa_user (id) foreign key (principal_id) references oa_user (id)
on update cascade on update cascade

View File

@ -11,6 +11,8 @@ create table oa_project_modules
created_at timestamp default CURRENT_TIMESTAMP not null comment '创建时间', created_at timestamp default CURRENT_TIMESTAMP not null comment '创建时间',
updated_at timestamp null comment '更新时间', updated_at timestamp null comment '更新时间',
is_delete tinyint(1) default 0 not 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 constraint oa_project_modules_oa_user_id_fk
foreign key (principal_id) references oa_user (id) foreign key (principal_id) references oa_user (id)
on update cascade on update cascade