Merge 推送至业务 #17

Merged
XiaoLFeng merged 46 commits from develop into master 2024-04-17 00:55:37 +08:00
17 changed files with 238 additions and 316 deletions
Showing only changes of commit 55cd033a7e - Show all commits

View File

@ -74,5 +74,19 @@ public class MessageController {
return messageService.messageGet(begin, end, page, pageSize, uid); return messageService.messageGet(begin, end, page, pageSize, uid);
} }
} }
@GetMapping("/message/get/id")
public BaseResponse messageGetById(
@RequestParam Long id,
HttpServletRequest request) {
log.info("请求接口[GET]:/message/get/id");
String token = request.getHeader("Authorization").replace("Bearer ", "");
Long uid = JwtUtil.getUserId(token);
if (uid == null) {
return ResultUtil.error(ErrorCode.USER_NOT_EXIST);
} else {
return messageService.messageGetById(id, uid);
}
}
} }

View File

@ -48,17 +48,10 @@ public class ProjectController {
return projectService.getHeader(id); return projectService.getHeader(id);
} }
/**
* @param id 获取项目 id
* @return {@link BaseResponse}
*/
@GetMapping("/project/get/id")
public BaseResponse projectGetById(@RequestParam Integer id) {
return projectService.getById(id);
}
/** /**
* @param id 获取项目 id * @param id 要查询的 id
* @return {@link BaseResponse} * @return {@link BaseResponse}
*/ */
@GetMapping("/project/getwork/id") @GetMapping("/project/getwork/id")
@ -66,19 +59,28 @@ public class ProjectController {
return projectService.getWorkById(id); return projectService.getWorkById(id);
} }
/**
* @param id 要查询项目的 id
* @return {@link BaseResponse}
*/
@GetMapping("/project/get/id")
public BaseResponse projectGetById(@RequestParam Integer id) {
return projectService.getById(id);
}
/** /**
* 游客获取项目 * 游客获取项目
* *
* @return {@link BaseResponse} * @return {@link BaseResponse}
*/ */
@GetMapping("/project/get/custom") @GetMapping("/project/get/custom")
public BaseResponse projectGetCustom(@RequestParam(required = false) Integer id, public BaseResponse projectGetCustom(
@RequestParam(required = false) List<String> tags, @RequestParam(required = false) List<String> tags,
@RequestParam(required = false) List<Integer> isFinish, @RequestParam(required = false) List<String> isFinish,
@RequestParam(required = false, defaultValue = "1") Integer page, @RequestParam(required = false, defaultValue = "1") Integer page,
@RequestParam(required = false, defaultValue = "10") Integer pageSize) { @RequestParam(required = false, defaultValue = "10") Integer pageSize) {
log.info("请求接口[GET]: /project/all/get"); log.info("请求接口[GET]: /project/get/custom");
return projectService.tget(id, tags, isFinish, page, pageSize); return projectService.tget(tags, isFinish, page, pageSize);
} }
/** /**
@ -87,31 +89,31 @@ public class ProjectController {
* @return {@link BaseResponse} * @return {@link BaseResponse}
*/ */
@GetMapping("/project/get") @GetMapping("/project/get")
public BaseResponse projectGet(@RequestParam(required = false) Integer listAll, public BaseResponse projectGet(
@RequestParam(required = false) List<String> tags, @RequestParam(required = false) List<String> tags,
@RequestParam(required = false) List<Integer> isFinish, @RequestParam(required = false) List<String> isFinish,
@RequestParam(required = false, defaultValue = "1") Integer page, @RequestParam(required = false, defaultValue = "1") Integer page,
@RequestParam(required = false, defaultValue = "10") Integer pageSize, @RequestParam(required = false, defaultValue = "10") Integer pageSize,
HttpServletRequest request) { HttpServletRequest request) {
log.info("请求接口[GET]: /project/get"); log.info("请求接口[GET]: /project/get");
return projectService.get(listAll, request, tags, isFinish, page, pageSize); return projectService.get(request, tags, isFinish, page, pageSize);
} }
/** /**
* 我管理的查询 * 我管理的页面的项目查询
* *
* @return {@link BaseResponse} * @return {@link BaseResponse}
*/ */
@GetMapping("/project/work/get") @GetMapping("/project/child/get")
public BaseResponse projectWorkGet(@RequestParam(required = false) Integer listAll, public BaseResponse projectWorkGet(
@RequestParam(required = false) List<String> tags, @RequestParam(required = false) List<String> tags,
@RequestParam(required = false) List<Integer> isFinish, @RequestParam(required = false) List<String> isFinish,
@RequestParam(required = false) Integer is, @RequestParam(required = false) Integer is,
@RequestParam(required = false, defaultValue = "1") Integer page, @RequestParam(required = false, defaultValue = "1") Integer page,
@RequestParam(required = false, defaultValue = "10") Integer pageSize, @RequestParam(required = false, defaultValue = "10") Integer pageSize,
HttpServletRequest request) { HttpServletRequest request) {
log.info("请求接口[GET]: /project/work/get"); log.info("请求接口[GET]: /project/work/get");
return projectService.workget(listAll, request, tags, isFinish, is, page, pageSize); return projectService.workget(request, tags, isFinish, is, page, pageSize);
} }
/** /**
@ -191,6 +193,15 @@ public class ProjectController {
} }
/**
* 项目添加
*
* @param request 请求
* @param projectInfoVO 项目信息
* @param bindingResult 参数校验
* @return {@link BaseResponse}
*/
@PostMapping("/project/add") @PostMapping("/project/add")
public BaseResponse projectAdd(HttpServletRequest request, public BaseResponse projectAdd(HttpServletRequest request,
@RequestBody @Validated ProjectInfoVO projectInfoVO, @RequestBody @Validated ProjectInfoVO projectInfoVO,

View File

@ -2,7 +2,7 @@ package com.jsl.oa.dao;
import com.google.gson.Gson; import com.google.gson.Gson;
import com.jsl.oa.mapper.ProjectMapper; import com.jsl.oa.mapper.ProjectMapper;
import com.jsl.oa.model.dodata.ProjectDO; import com.jsl.oa.model.dodata.ProjectDO;
import com.jsl.oa.model.dodata.ProjectWorkDO; import com.jsl.oa.model.dodata.ProjectModuleDO;
import com.jsl.oa.model.dodata.info.ProjectShowDO; import com.jsl.oa.model.dodata.info.ProjectShowDO;
import com.jsl.oa.model.vodata.ProjectEditVO; import com.jsl.oa.model.vodata.ProjectEditVO;
import com.jsl.oa.model.vodata.ProjectInfoVO; import com.jsl.oa.model.vodata.ProjectInfoVO;
@ -115,7 +115,7 @@ public class ProjectDAO {
return projectMapper.getProjectById(id); return projectMapper.getProjectById(id);
} }
public List<ProjectDO> get(Long userId, Integer listAll, List<String> tags, List<Integer> isFinish) { public List<ProjectDO> get(Long userId, List<String> tags, List<String> isFinish) {
log.info("\t> 执行 DAO 层 ProjectDAO.get 方法"); log.info("\t> 执行 DAO 层 ProjectDAO.get 方法");
log.info("\t\t> 从 MySQL 获取数据"); log.info("\t\t> 从 MySQL 获取数据");
if (tags != null && !tags.isEmpty()) { if (tags != null && !tags.isEmpty()) {
@ -128,15 +128,11 @@ public class ProjectDAO {
return projectMapper.getByIsfinish(userId, isFinish); return projectMapper.getByIsfinish(userId, isFinish);
} }
if (listAll == 0) { return projectMapper.get(userId);
return projectMapper.get(userId);
} else {
return projectMapper.get1(userId);
}
} }
public List<ProjectDO> workget(Long userId, Integer listAll, public List<ProjectDO> workget(Long userId, List<String> tags, List<String> isFinish, Integer is) {
List<String> tags, List<Integer> isFinish, Integer is) {
log.info("\t> 执行 DAO 层 ProjectDAO.workget 方法"); log.info("\t> 执行 DAO 层 ProjectDAO.workget 方法");
log.info("\t\t> 从 MySQL 获取数据"); log.info("\t\t> 从 MySQL 获取数据");
if (tags != null && !tags.isEmpty()) { if (tags != null && !tags.isEmpty()) {
@ -146,12 +142,8 @@ public class ProjectDAO {
if (isFinish != null && !isFinish.isEmpty()) { if (isFinish != null && !isFinish.isEmpty()) {
return projectMapper.workgetByIsfinish(userId, isFinish, is); return projectMapper.workgetByIsfinish(userId, isFinish, is);
} }
return projectMapper.workget(userId, is);
if (listAll == 0) {
return projectMapper.workget(userId, is);
} else {
return projectMapper.workget1(userId, is);
}
} }
public ProjectDO getByName(String name) { public ProjectDO getByName(String name) {
@ -181,7 +173,7 @@ public class ProjectDAO {
} }
public List<ProjectDO> tget(Integer id, List<Integer> isFinish, List<String> tags) { public List<ProjectDO> tget(List<String> isFinish, List<String> tags) {
log.info("DAO层tget"); log.info("DAO层tget");
if (tags != null && !tags.isEmpty()) { if (tags != null && !tags.isEmpty()) {
@ -191,11 +183,10 @@ public class ProjectDAO {
if (isFinish != null && !isFinish.isEmpty()) { if (isFinish != null && !isFinish.isEmpty()) {
return projectMapper.tgetByIsfinish(isFinish); return projectMapper.tgetByIsfinish(isFinish);
} }
return projectMapper.getAllProject();
return projectMapper.tget(id);
} }
public ProjectWorkDO getProjectWorkerById(Long id) { public ProjectModuleDO getProjectWorkerById(Long id) {
return projectMapper.getProjectWorkById(id); return projectMapper.getProjectWorkById(id);
} }
@ -205,13 +196,13 @@ public class ProjectDAO {
return projectMapper.getProjectByPrincipalUser(uid); return projectMapper.getProjectByPrincipalUser(uid);
} }
public List<ProjectWorkDO> getAllSubsystemByUserId(Long uid) { public List<ProjectModuleDO> getAllSubsystemByUserId(Long uid) {
log.info("\t> 执行 DAO 层 ProjectDAO.getAllSubsystemByUserId 方法"); log.info("\t> 执行 DAO 层 ProjectDAO.getAllSubsystemByUserId 方法");
log.info("\t\t> 从 MySQL 获取数据"); log.info("\t\t> 从 MySQL 获取数据");
return projectMapper.getAllSubsystemByUserId(uid); return projectMapper.getAllSubsystemByUserId(uid);
} }
public List<ProjectWorkDO> getAllSubmoduleByUserId(Long uid) { public List<ProjectModuleDO> getAllSubmoduleByUserId(Long uid) {
log.info("\t> 执行 DAO 层 ProjectDAO.getAllSubmoduleByUserId 方法"); log.info("\t> 执行 DAO 层 ProjectDAO.getAllSubmoduleByUserId 方法");
log.info("\t\t> 从 MySQL 获取数据"); log.info("\t\t> 从 MySQL 获取数据");
return projectMapper.getAllSubmoduleByUserId(uid); return projectMapper.getAllSubmoduleByUserId(uid);

View File

@ -1,6 +1,6 @@
package com.jsl.oa.mapper; package com.jsl.oa.mapper;
import com.jsl.oa.model.dodata.ProjectWorkDO; import com.jsl.oa.model.dodata.ProjectModuleDO;
import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
@ -12,9 +12,9 @@ public interface ModuleMapper {
List<ProjectWorkDO> getByProjectId(Integer projectId, Long userId, int is); List<ProjectModuleDO> getByProjectId(Integer projectId, Long userId, int is);
List<ProjectWorkDO> getBySysId(Integer sysId, Long userId, int is); List<ProjectModuleDO> getBySysId(Integer sysId, Long userId, int is);
@Select("select principal_id from organize_oa.oa_project where id=#{projectId}") @Select("select principal_id from organize_oa.oa_project where id=#{projectId}")
Long getPidByProjectid(Integer projectId); Long getPidByProjectid(Integer projectId);
@ -26,7 +26,7 @@ public interface ModuleMapper {
void deleteMoudule(Long id); void deleteMoudule(Long id);
@Select("select * from organize_oa.oa_project_work where pid=#{id} and is_delete=0 and type=1 ") @Select("select * from organize_oa.oa_project_work where pid=#{id} and is_delete=0 and type=1 ")
List<ProjectWorkDO> getAllMoudleByPid(Long id); List<ProjectModuleDO> getAllMoudleByPid(Long id);
@Select("select principal_id from organize_oa.oa_project where id=(select project_id " @Select("select principal_id from organize_oa.oa_project where id=(select project_id "
+ "from organize_oa.oa_project_work where oa_project_work.id = #{sysId})") + "from organize_oa.oa_project_work where oa_project_work.id = #{sysId})")

View File

@ -1,7 +1,7 @@
package com.jsl.oa.mapper; package com.jsl.oa.mapper;
import com.jsl.oa.model.dodata.ProjectCuttingDO; import com.jsl.oa.model.dodata.ProjectChildDO;
import com.jsl.oa.model.dodata.ProjectDO; import com.jsl.oa.model.dodata.ProjectDO;
import com.jsl.oa.model.dodata.ProjectWorkDO; import com.jsl.oa.model.dodata.ProjectModuleDO;
import com.jsl.oa.model.vodata.ProjectInfoVO; import com.jsl.oa.model.vodata.ProjectInfoVO;
import com.jsl.oa.model.vodata.ProjectWorkSimpleVO; import com.jsl.oa.model.vodata.ProjectWorkSimpleVO;
import com.jsl.oa.model.vodata.ProjectWorkVO; import com.jsl.oa.model.vodata.ProjectWorkVO;
@ -17,10 +17,10 @@ import java.util.List;
public interface ProjectMapper { public interface ProjectMapper {
@Insert("insert into organize_oa.oa_project " @Insert("insert into organize_oa.oa_project "
+ "(name, description, principal_id, cycle,file,complete_time," + "(name, description, principal_id, cycle,files,complete_time,"
+ "deadline,status,is_finish,tags,work_load) " + "dead_line,status,tags,work_load) "
+ "value (#{name},#{description},#{principalId},#{cycle},#{file}" + "value (#{name},#{description},#{principalId},#{cycle},#{files}"
+ ",#{completeTime},#{deadline},#{status},#{isFinish},#{tags},#{workLoad})") + ",#{completeTime},#{deadLine},#{status},#{tags},#{workLoad})")
void projectAdd(ProjectInfoVO projectAdd); void projectAdd(ProjectInfoVO projectAdd);
@Insert("insert into organize_oa.oa_project_work (project_id, pid, name, principal_id," @Insert("insert into organize_oa.oa_project_work (project_id, pid, name, principal_id,"
@ -37,8 +37,8 @@ public interface ProjectMapper {
@Select("select * from organize_oa.oa_project where id=#{id}") @Select("select * from organize_oa.oa_project where id=#{id}")
ProjectDO tgetProjectById(Integer id); ProjectDO tgetProjectById(Integer id);
@Select("select * from organize_oa.oa_project_work where principal_id=#{uid}") @Select("select * from organize_oa.oa_project where is_delete=false")
List<ProjectCuttingDO> projectGetUserInCutting(Long uid); List<ProjectDO> getAllProject();
@Select("select data from organize_oa.oa_config where value='project_show'") @Select("select data from organize_oa.oa_config where value='project_show'")
String getHeader(); String getHeader();
@ -50,11 +50,11 @@ public interface ProjectMapper {
+ " updated_at = CURRENT_TIMESTAMP WHERE value = 'project_show'") + " updated_at = CURRENT_TIMESTAMP WHERE value = 'project_show'")
boolean setProjectShow(String setProjectShow); boolean setProjectShow(String setProjectShow);
List<ProjectDO> getByIsfinish(Long userId, List<Integer> isFinish); List<ProjectDO> getByIsfinish(Long userId, List<String> isFinish);
List<ProjectDO> getByTags(Long userId, List<String> tags, List<Integer> isFinish); List<ProjectDO> getByTags(Long userId, List<String> tags, List<String> isFinish);
@Select("select * from organize_oa.oa_project where is_delete=false and status=1 and principal_id=#{userId}") @Select("select * from organize_oa.oa_project where is_delete=false and principal_id=#{userId}")
List<ProjectDO> get(Long userId); List<ProjectDO> get(Long userId);
@Select("select * from organize_oa.oa_project where status =1 and principal_id=#{userId}") @Select("select * from organize_oa.oa_project where status =1 and principal_id=#{userId}")
@ -66,9 +66,9 @@ public interface ProjectMapper {
@Update("UPDATE organize_oa.oa_project SET is_delete = 1 where id=#{id}") @Update("UPDATE organize_oa.oa_project SET is_delete = 1 where id=#{id}")
boolean deleteProject(Long id); boolean deleteProject(Long id);
List<ProjectDO> workgetByIsfinish(Long userId, List<Integer> isFinish, Integer is); List<ProjectDO> workgetByIsfinish(Long userId, List<String> isFinish, Integer is);
List<ProjectDO> workgetByTags(Long userId, List<String> tags, Integer is, List<Integer> isFinish); List<ProjectDO> workgetByTags(Long userId, List<String> tags, Integer is, List<String> isFinish);
//@Select("select * from organize_oa.oa_project where id in(select project_id from " + //@Select("select * from organize_oa.oa_project where id in(select project_id from " +
//"organize_oa.oa_project_work where is_delete=false and status =1 and principal_id=#{userId} and type=0)") //"organize_oa.oa_project_work where is_delete=false and status =1 and principal_id=#{userId} and type=0)")
@ -80,37 +80,44 @@ public interface ProjectMapper {
List<ProjectDO> tget(Integer id); List<ProjectDO> tget(Integer id);
List<ProjectDO> tgetByIsfinish(List<Integer> isFinish); List<ProjectDO> tgetByIsfinish(List<String> isFinish);
List<ProjectDO> tgetBytags(List<String> tags, List<Integer> isFinish); List<ProjectDO> tgetBytags(List<String> tags, List<String> isFinish);
@Select("select * from organize_oa.oa_project_work where id=#{id}") @Select("select * from organize_oa.oa_project_child where id=#{id}")
ProjectWorkSimpleVO getWorkById(Integer id); ProjectWorkSimpleVO getWorkById(Integer id);
@Select("select * from organize_oa.oa_project_modules where id=#{id}")
ProjectModuleDO getModuleById(Integer id);
@Select("select principal_id from organize_oa.oa_project_work where id=#{pid}") @Select("select principal_id from organize_oa.oa_project_work where id=#{pid}")
Long getPirIdbyWorkid(Long pid); Long getPirIdbyWorkid(Long pid);
@Select("select principal_id from organize_oa.oa_project_work where id=#{id} " @Select("select principal_id from organize_oa.oa_project_modules where project_child_id=#{id} "
+ "AND is_delete = 0") + "AND is_delete = 0")
Long getPid(Integer id); Long getPid(Integer id);
@Select("select * from organize_oa.oa_project_work where id=#{id} " @Select("select * from organize_oa.oa_project_work where id=#{id} "
+ "AND is_delete = 0") + "AND is_delete = 0")
ProjectWorkDO getProjectWorkById(Long id); ProjectModuleDO getProjectWorkById(Long id);
@Select("select principal_id from organize_oa.oa_project_work where project_id=#{id}") @Select("select principal_id from organize_oa.oa_project_child where project_id=#{id}")
List <Long> getMemberByProjectId(Integer id); List <Long> getMemberByProjectId(Integer id);
@Select("select principal_id from organize_oa.oa_project_work where pid=#{id}") @Select("select principal_id from organize_oa.oa_project_modules where project_child_id=#{id}")
List <Long> getMemberBySystemId(Integer id); List <Long> getMemberBySystemId(Integer id);
@Select("select * from organize_oa.oa_project_work " @Select("select * from organize_oa.oa_project_modules "
+ "where DATE(deadline) = DATE(#{threeDayLater}) and is_finish != 1") + "where DATE(deadline) = DATE(#{threeDayLater}) and status = 0")
List<ProjectWorkDO> getProjectWorkByTime(LocalDateTime threeDayLater); List<ProjectModuleDO> getProjectWorkByTime(LocalDateTime threeDayLater);
List<ProjectWorkDO> getAllSubmoduleByUserId(Long uid); List<ProjectModuleDO> getAllSubmoduleByUserId(Long uid);
List<ProjectDO> getProjectByPrincipalUser(Long uid); List<ProjectDO> getProjectByPrincipalUser(Long uid);
List<ProjectWorkDO> getAllSubsystemByUserId(Long uid); List<ProjectModuleDO> getAllSubsystemByUserId(Long uid);
@Select("select * from organize_oa.oa_project_child where "
+ "DATE (created_at) = DATE (#{threeDaysLater}) and status = 0")
List<ProjectChildDO> getProjectChildByTime(LocalDateTime threeDaysLater);
} }

View File

@ -18,19 +18,17 @@ import java.sql.Timestamp;
@Data @Data
@Accessors(chain = true) @Accessors(chain = true)
@JsonInclude(JsonInclude.Include.NON_NULL) @JsonInclude(JsonInclude.Include.NON_NULL)
public class ProjectCuttingDO { public class ProjectChildDO {
private Long id; private Long id;
private Long principalId; private Long principalId;
private Long projectId; private Long projectId;
private Long pid; private Integer workLoad;
private Long workLoad; private Integer cycle;
private Long cycle;
private String name; private String name;
private String description; private String description;
private Integer isDelete; private Integer isDelete;
private Integer isFinish; private String files;
private Integer status; private Timestamp createdAt;
private boolean type;
private Timestamp beginTime;
private Timestamp completeTime; private Timestamp completeTime;
private Timestamp updatedAt;
} }

View File

@ -23,20 +23,19 @@ public class ProjectDO {
private Long id; private Long id;
private Long principalId; private Long principalId;
private String tags; private String tags;
private Long cycle; private Integer cycle;
private String name; private String name;
private String file; private String file;
private String description; private String description;
private Integer isDelete; private Integer isDelete;
private Integer isFinish; private Integer workLoad;
private Long workLoad; private String status;
private Integer status;
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "UTC") @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "UTC")
private Timestamp beginTime; private Timestamp beginTime;
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "UTC") @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "UTC")
private Timestamp completeTime; private Timestamp completeTime;
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "UTC") @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "UTC")
private Timestamp deadline; private Timestamp deadline;
private Timestamp createdAt;
private Timestamp updatedAt;
} }

View File

@ -9,19 +9,15 @@ import java.sql.Timestamp;
@Data @Data
@Accessors(chain = true) @Accessors(chain = true)
@JsonInclude(JsonInclude.Include.NON_NULL) @JsonInclude(JsonInclude.Include.NON_NULL)
public class ProjectWorkDO { public class ProjectModuleDO {
private Long id; private Long id;
private Long pid; private Long projectChildId;
private Long projectId;
private Long principalId; private Long principalId;
private Integer cycle;
private Integer workLoad; private Integer workLoad;
private Integer type;
private String name;
private String description; private String description;
private String name;
private Integer isDelete; private Integer isDelete;
private Integer isFinish; private Timestamp createdAt;
private boolean status; private Timestamp updatedAt;
private Timestamp beginTime;
private Timestamp completeTime; private Timestamp completeTime;
} }

View File

@ -20,10 +20,10 @@ public class ProjectInfoVO {
@NotNull(message = "工作量不能为空") @NotNull(message = "工作量不能为空")
private Long workLoad; private Long workLoad;
private String tags; private String tags;
private String file; private String files;
private Timestamp beginTime;
private Timestamp completeTime; private Timestamp completeTime;
private Timestamp deadline; private Timestamp deadLine;
private Integer status; private String status;
private Integer isFinish;
} }

View File

@ -25,11 +25,17 @@ public interface MessageService {
Integer pageSize, Integer pageSize,
Long uid); Long uid);
void messageAdd(Integer pId, Integer systemId, Integer moddleId, Long uid, HttpServletRequest request); void messageAdd(Integer pId, Integer systemId, Integer moddleId, Long uid,
void messageAdd(Integer pId, Integer systemId, Integer moddleId, Long uid, Long isPass, HttpServletRequest request); HttpServletRequest request);
void messageAdd(Integer pId, Integer type, Integer systemId, HttpServletRequest request); void messageAdd(Integer pId, Integer systemId, Integer moddleId, Long uid, Long isPass,
void messageAdd(Integer pId, Integer systmeId, Integer moddleId, Integer type, HttpServletRequest request); HttpServletRequest request);
void messageAdd(Integer pId, Integer type, Integer systemId,
HttpServletRequest request);
void messageAdd(Integer pId, Integer systmeId, Integer moddleId, Integer type,
HttpServletRequest request);
void messageAdd(Integer pId, Integer systemId, Integer moddleId); void messageAdd(Integer pId, Integer systemId, Integer moddleId);
void messageRemind(); void messageRemind();
BaseResponse messageGetById(Long id, Long uid);
} }

View File

@ -19,10 +19,10 @@ public interface ProjectService {
BaseResponse editHeader(HttpServletRequest request, ProjectShowVO projectShowVO, Integer id); BaseResponse editHeader(HttpServletRequest request, ProjectShowVO projectShowVO, Integer id);
BaseResponse get(Integer listAll, BaseResponse get(
HttpServletRequest request, HttpServletRequest request,
List<String> tags, List<String> tags,
List<Integer> isFinish, List<String> isFinish,
Integer page, Integer page,
Integer pageSize); Integer pageSize);
@ -34,17 +34,17 @@ public interface ProjectService {
BaseResponse projectToOtherUserForCutting(HttpServletRequest request, Long oldUid, Long pid, Long newUid); BaseResponse projectToOtherUserForCutting(HttpServletRequest request, Long oldUid, Long pid, Long newUid);
BaseResponse workget(Integer listAll, BaseResponse workget(
HttpServletRequest request, HttpServletRequest request,
List<String> tags, List<String> tags,
List<Integer> isFinish, List<String> isFinish,
Integer is, Integer is,
Integer page, Integer page,
Integer pageSize); Integer pageSize);
BaseResponse projecWorktAdd(HttpServletRequest request, ProjectWorkVO projectWorkVO); BaseResponse projecWorktAdd(HttpServletRequest request, ProjectWorkVO projectWorkVO);
BaseResponse tget(Integer id, List<String> tags, List<Integer> isFinish, Integer page, Integer pageSize); BaseResponse tget(List<String> tags, List<String> isFinish, Integer page, Integer pageSize);
BaseResponse projectFileGet(HttpServletRequest request, Long projectId); BaseResponse projectFileGet(HttpServletRequest request, Long projectId);

View File

@ -4,7 +4,8 @@ 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;
import com.jsl.oa.model.dodata.MessageDO; import com.jsl.oa.model.dodata.MessageDO;
import com.jsl.oa.model.dodata.ProjectWorkDO; 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.MessageAddVO;
import com.jsl.oa.model.vodata.MessageGetVO; import com.jsl.oa.model.vodata.MessageGetVO;
import com.jsl.oa.services.MessageService; import com.jsl.oa.services.MessageService;
@ -117,13 +118,14 @@ public class MessageServiceImpl implements MessageService {
if (moddleId == null) { if (moddleId == null) {
messageAddVO.setText(senderName + "指派了" + projectName + "项目的" + systemName + "子系统给您"); messageAddVO.setText(senderName + "指派了" + projectName + "项目的" + systemName + "子系统给您");
} else { } else {
String moddleName = projectMapper.getWorkById(moddleId).getName(); String moddleName = projectMapper.getModuleById(moddleId).getName();
messageAddVO.setText(senderName + "指派了" + projectName + "项目的" + systemName + "子系统的" + moddleName + "子模块给您"); messageAddVO.setText(senderName + "指派了" + projectName + "项目的" + systemName + "子系统的" + moddleName + "子模块给您");
} }
messageAddVO.setType("跳转审批页"); messageAddVO.setType("跳转审批页");
messageMapper.messageAdd(messageAddVO); messageMapper.messageAdd(messageAddVO);
} }
/** /**
* 添加审批消息 * 添加审批消息
* *
@ -149,7 +151,7 @@ public class MessageServiceImpl implements MessageService {
MessageAddVO messageAddVO = new MessageAddVO(); MessageAddVO messageAddVO = new MessageAddVO();
messageAddVO.setUid(uid); messageAddVO.setUid(uid);
messageAddVO.setTitle("审批消息"); messageAddVO.setTitle("审批消息");
String moddleName = projectMapper.getWorkById(moddleId).getName(); String moddleName = projectMapper.getModuleById(moddleId).getName();
if (isPass == 1) { if (isPass == 1) {
messageAddVO.setText("您申请的" + projectName + "项目的" + systemName + "系统的" + moddleName + "模块负责人已通过"); messageAddVO.setText("您申请的" + projectName + "项目的" + systemName + "系统的" + moddleName + "模块负责人已通过");
} else { } else {
@ -216,7 +218,7 @@ public class MessageServiceImpl implements MessageService {
String projectName = projectMapper.tgetProjectById(pId).getName(); String projectName = projectMapper.tgetProjectById(pId).getName();
String senderName = userDAO.getUserById(Processing.getAuthHeaderToUserId(request)).getUsername(); String senderName = userDAO.getUserById(Processing.getAuthHeaderToUserId(request)).getUsername();
String systemName = projectMapper.getWorkById(systmeId).getName(); String systemName = projectMapper.getWorkById(systmeId).getName();
String moddleName = projectMapper.getWorkById(moddleId).getName(); String moddleName = projectMapper.getModuleById(moddleId).getName();
// 添加消息 // 添加消息
// 1:删除模块 2:修改简介 3:修改周期 // 1:删除模块 2:修改简介 3:修改周期
if (type == 1) { if (type == 1) {
@ -261,7 +263,7 @@ public class MessageServiceImpl implements MessageService {
// 获取项目名,系统名,模块名,负责人名 // 获取项目名,系统名,模块名,负责人名
String projectName = projectMapper.tgetProjectById(pId).getName(); String projectName = projectMapper.tgetProjectById(pId).getName();
String systemName = projectMapper.getWorkById(systemId).getName(); String systemName = projectMapper.getWorkById(systemId).getName();
String moddleName = projectMapper.getWorkById(moddleId).getName(); String moddleName = projectMapper.getModuleById(moddleId).getName();
String principalName = userDAO.getUserById(projectMapper.getPid(moddleId)).getUsername(); String principalName = userDAO.getUserById(projectMapper.getPid(moddleId)).getUsername();
// 添加消息 // 添加消息
MessageAddVO messageAddVO = new MessageAddVO(); MessageAddVO messageAddVO = new MessageAddVO();
@ -285,62 +287,87 @@ public class MessageServiceImpl implements MessageService {
LocalDateTime threeDaysLater = now.plusDays(3); LocalDateTime threeDaysLater = now.plusDays(3);
// 七天后时间 // 七天后时间
LocalDateTime sevenDaysLater = now.plusDays(7); LocalDateTime sevenDaysLater = now.plusDays(7);
// 获取三天后到期的系统/模块 // 获取三天后到期的模块
List<ProjectWorkDO> projectWorkDOList = projectMapper.getProjectWorkByTime(threeDaysLater); List<ProjectModuleDO> projectWorkDOList = projectMapper.getProjectWorkByTime(threeDaysLater);
// 获取七天后到期的系统/模块 // 获取七天后到期的模块
List<ProjectWorkDO> projectWorkDOList1 = projectMapper.getProjectWorkByTime(sevenDaysLater); List<ProjectModuleDO> projectWorkDOList1 = projectMapper.getProjectWorkByTime(sevenDaysLater);
if (!projectWorkDOList1.isEmpty()) { if (!projectWorkDOList1.isEmpty()) {
for (ProjectWorkDO projectWorkDO : projectWorkDOList) { for (ProjectModuleDO projectWorkDO : projectWorkDOList) {
// 添加消息 // 添加消息
MessageAddVO messageAddVO = new MessageAddVO(); MessageAddVO messageAddVO = new MessageAddVO();
messageAddVO.setUid(projectWorkDO.getPrincipalId()); messageAddVO.setUid(projectWorkDO.getPrincipalId());
messageAddVO.setTitle("提醒消息"); messageAddVO.setTitle("提醒消息");
// 0:系统 1:模块
String projectName = projectMapper String projectName = projectMapper
.tgetProjectById(projectWorkDO.getProjectId().intValue()).getName(); .tgetProjectById(projectMapper.getWorkById(projectWorkDO.getProjectChildId().intValue())
String systemName; .getProjectId().intValue()).getName();
if (projectWorkDO.getType() == 1) {
systemName = projectMapper.getWorkById(projectWorkDO.getPid().intValue()).getName(); String systemName = projectMapper.getWorkById(projectWorkDO.getProjectChildId().intValue()).getName();
String moddleName = projectMapper.getWorkById(projectWorkDO.getId().intValue()).getName(); String moddleName = projectWorkDO.getName();
messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统的" + moddleName + "模块" messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统的" + moddleName + "模块"
+ "还有七天就要到期了,请及时处理"); + "还有七天就要到期了,请及时处理");
messageAddVO.setType("跳转模块页"); messageAddVO.setType("跳转模块页");
} else {
systemName = projectMapper.getWorkById(projectWorkDO.getId().intValue()).getName();
messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统"
+ "还有七天就要到期了,请及时处理");
messageAddVO.setType("跳转系统页");
}
messageAddVO.setToId(projectWorkDO.getId().intValue()); messageAddVO.setToId(projectWorkDO.getId().intValue());
messageMapper.messageAdd(messageAddVO); messageMapper.messageAdd(messageAddVO);
} }
} }
if (!projectWorkDOList.isEmpty()) { if (!projectWorkDOList.isEmpty()) {
for (ProjectWorkDO projectWorkDO : projectWorkDOList) { for (ProjectModuleDO projectWorkDO : projectWorkDOList) {
// 添加消息 // 添加消息
MessageAddVO messageAddVO = new MessageAddVO(); MessageAddVO messageAddVO = new MessageAddVO();
messageAddVO.setUid(projectWorkDO.getPrincipalId()); messageAddVO.setUid(projectWorkDO.getPrincipalId());
messageAddVO.setTitle("提醒消息"); messageAddVO.setTitle("提醒消息");
// 0:系统 1:模块
String projectName = projectMapper String projectName = projectMapper
.tgetProjectById(projectWorkDO.getProjectId().intValue()).getName(); .tgetProjectById(projectMapper.getWorkById(projectWorkDO.getProjectChildId().intValue())
String systemName; .getPrincipalId().intValue()).getName();
if (projectWorkDO.getType() == 1) {
systemName = projectMapper.getWorkById(projectWorkDO.getPid().intValue()).getName(); String systemName = projectMapper.getWorkById(projectWorkDO.getProjectChildId().intValue()).getName();
String moddleName = projectMapper.getWorkById(projectWorkDO.getId().intValue()).getName(); String moddleName = projectWorkDO.getName();
messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统的" + moddleName + "模块" messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统的" + moddleName + "模块"
+ "还有三天就要到期了,请及时处理"); + "还有三天就要到期了,请及时处理");
messageAddVO.setType("跳转模块页"); messageAddVO.setType("跳转模块页");
} else {
systemName = projectMapper.getWorkById(projectWorkDO.getId().intValue()).getName();
messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统"
+ "还有三天就要到期了,请及时处理");
messageAddVO.setType("跳转系统页");
}
messageAddVO.setToId(projectWorkDO.getId().intValue()); messageAddVO.setToId(projectWorkDO.getId().intValue());
messageMapper.messageAdd(messageAddVO); messageMapper.messageAdd(messageAddVO);
} }
} }
// 获取七天后到期的系统
List<ProjectChildDO> projectChildDOList = projectMapper.getProjectChildByTime(sevenDaysLater);
if (!projectChildDOList.isEmpty()) {
for (ProjectChildDO projectChildDO : projectChildDOList) {
// 添加消息
MessageAddVO messageAddVO = new MessageAddVO();
messageAddVO.setUid(projectChildDO.getPrincipalId());
messageAddVO.setTitle("提醒消息");
String projectName = projectMapper.tgetProjectById(projectChildDO.getProjectId().intValue()).getName();
String systemName = projectChildDO.getName();
messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统还有七天就要到期了,请及时处理");
messageAddVO.setType("跳转系统页");
messageAddVO.setToId(projectChildDO.getId().intValue());
messageMapper.messageAdd(messageAddVO);
}
}
// 获取三天后到期的系统
List<ProjectChildDO> projectChildDOList1 = projectMapper.getProjectChildByTime(threeDaysLater);
if (!projectChildDOList1.isEmpty()) {
for (ProjectChildDO projectChildDO : projectChildDOList1) {
// 添加消息
MessageAddVO messageAddVO = new MessageAddVO();
messageAddVO.setUid(projectChildDO.getPrincipalId());
messageAddVO.setTitle("提醒消息");
String projectName = projectMapper.tgetProjectById(projectChildDO.getProjectId().intValue()).getName();
String systemName = projectChildDO.getName();
messageAddVO.setText("您负责的" + projectName + "项目的" + systemName + "系统还有三天就要到期了,请及时处理");
messageAddVO.setType("跳转系统页");
messageAddVO.setToId(projectChildDO.getId().intValue());
messageMapper.messageAdd(messageAddVO);
}
}
}
@Override
public BaseResponse messageGetById(Long id, Long uid) {
return ResultUtil.success(messageMapper.getMessageById(id));
} }
} }

View File

@ -4,7 +4,7 @@ import com.jsl.oa.dao.ProjectDAO;
import com.jsl.oa.dao.RoleDAO; import com.jsl.oa.dao.RoleDAO;
import com.jsl.oa.dao.UserDAO; import com.jsl.oa.dao.UserDAO;
import com.jsl.oa.mapper.ModuleMapper; import com.jsl.oa.mapper.ModuleMapper;
import com.jsl.oa.model.dodata.ProjectWorkDO; import com.jsl.oa.model.dodata.ProjectModuleDO;
import com.jsl.oa.model.vodata.ProjectWorkAndNameVO; import com.jsl.oa.model.vodata.ProjectWorkAndNameVO;
import com.jsl.oa.services.ModuleService; import com.jsl.oa.services.ModuleService;
import com.jsl.oa.utils.BaseResponse; import com.jsl.oa.utils.BaseResponse;
@ -42,7 +42,7 @@ public class ModuleServiceImpl implements ModuleService {
is = 0; is = 0;
} }
List<ProjectWorkDO> projectWorkDOList = moduleMapper.getByProjectId(projectId, userId, is); List<ProjectModuleDO> projectWorkDOList = moduleMapper.getByProjectId(projectId, userId, is);
return ResultUtil.success(projectWorkDOList); return ResultUtil.success(projectWorkDOList);
} }
@ -61,10 +61,10 @@ public class ModuleServiceImpl implements ModuleService {
is = 0; is = 0;
} }
List<ProjectWorkDO> projectWorkDOList = moduleMapper.getBySysId(sysId, userId, is); List<ProjectModuleDO> projectWorkDOList = moduleMapper.getBySysId(sysId, userId, is);
// 封装VO类 // 封装VO类
List<ProjectWorkAndNameVO> projectWorkAndNameVOS = new ArrayList<>(); List<ProjectWorkAndNameVO> projectWorkAndNameVOS = new ArrayList<>();
for (ProjectWorkDO projectWorkDO : projectWorkDOList) { for (ProjectModuleDO projectWorkDO : projectWorkDOList) {
ProjectWorkAndNameVO projectWorkAndNameVO = new ProjectWorkAndNameVO(); ProjectWorkAndNameVO projectWorkAndNameVO = new ProjectWorkAndNameVO();
Processing.copyProperties(projectWorkDO, projectWorkAndNameVO); Processing.copyProperties(projectWorkDO, projectWorkAndNameVO);
// 添加负责人和子系统名称 // 添加负责人和子系统名称
@ -94,9 +94,9 @@ public class ModuleServiceImpl implements ModuleService {
// 删除子模块方法 // 删除子模块方法
public void deleteMoudule(Long id) { public void deleteMoudule(Long id) {
//获取所有父Id=id的子模块 //获取所有父Id=id的子模块
List<ProjectWorkDO> projectWorkDOS = moduleMapper.getAllMoudleByPid(id); List<ProjectModuleDO> projectWorkDOS = moduleMapper.getAllMoudleByPid(id);
for (ProjectWorkDO workDO : projectWorkDOS) { for (ProjectModuleDO workDO : projectWorkDOS) {
deleteMoudule(workDO.getId()); deleteMoudule(workDO.getId());
} }

View File

@ -13,6 +13,7 @@ import com.jsl.oa.model.dodata.UserDO;
import com.jsl.oa.model.dodata.info.ProjectShowDO; import com.jsl.oa.model.dodata.info.ProjectShowDO;
import com.jsl.oa.model.vodata.*; import com.jsl.oa.model.vodata.*;
import com.jsl.oa.model.vodata.business.info.ProjectShowVO; import com.jsl.oa.model.vodata.business.info.ProjectShowVO;
import com.jsl.oa.services.MessageService;
import com.jsl.oa.services.ProjectService; import com.jsl.oa.services.ProjectService;
import com.jsl.oa.utils.BaseResponse; import com.jsl.oa.utils.BaseResponse;
import com.jsl.oa.utils.ErrorCode; import com.jsl.oa.utils.ErrorCode;
@ -22,7 +23,6 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.sql.Timestamp; import java.sql.Timestamp;
import java.util.ArrayList; import java.util.ArrayList;
@ -50,6 +50,7 @@ public class ProjectServiceImpl implements ProjectService {
private final UserDAO userDAO; private final UserDAO userDAO;
private final ObjectMapper objectMapper; private final ObjectMapper objectMapper;
private final RoleDAO roleDAO; private final RoleDAO roleDAO;
private final MessageService messageService;
@Override @Override
public BaseResponse projectAdd(HttpServletRequest request, ProjectInfoVO projectAdd) { public BaseResponse projectAdd(HttpServletRequest request, ProjectInfoVO projectAdd) {
@ -71,7 +72,7 @@ public class ProjectServiceImpl implements ProjectService {
tag = new StringBuilder(tag.substring(0, tag.length() - 2)); tag = new StringBuilder(tag.substring(0, tag.length() - 2));
} }
projectAdd.setTags(open + tag + close); projectAdd.setTags(open + tag + close);
projectAdd.setFile("{\"URI\":\"" + projectAdd.getFile() + "\"}"); projectAdd.setFiles("{\"URI\":\"" + projectAdd.getFiles() + "\"}");
projectDAO.projectAdd(projectAdd); projectDAO.projectAdd(projectAdd);
@ -109,54 +110,11 @@ public class ProjectServiceImpl implements ProjectService {
} }
@Override @Override
public BaseResponse tget(Integer id, List<String> tags, List<Integer> isFinish, Integer page, Integer pageSize) { public BaseResponse tget(List<String> tags, List<String> isFinish, Integer page, Integer pageSize) {
log.info("\t> 执行 Service 层 ProjectService.tget 方法"); log.info("\t> 执行 Service 层 ProjectService.tget 方法");
//根据id查询
if (id != null) {
ProjectDO projectDO = projectMapper.tgetProjectById(id);
ProjectSimpleVO projectSimpleVO = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO, projectDO, userDAO, objectMapper);
return ResultUtil.success(projectSimpleVO);
}
//根据标签查询 List<ProjectDO> projectDOList = projectDAO.tget(isFinish, tags);
if (tags != null && !tags.isEmpty()) {
List<ProjectDO> projectDOList = projectDAO.tget(id, isFinish, tags);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
}
//根据状态查询
if (isFinish != null && !isFinish.isEmpty()) {
List<ProjectDO> projectDOList = projectDAO.tget(id, isFinish, tags);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
}
List<ProjectDO> projectDOList = projectDAO.tget(id, isFinish, tags);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>(); List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) { for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO(); ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
@ -169,6 +127,7 @@ public class ProjectServiceImpl implements ProjectService {
List<ProjectSimpleVO> pageData = projectSimpleVOList.subList(start, List<ProjectSimpleVO> pageData = projectSimpleVOList.subList(start,
Math.min(end, projectSimpleVOList.size())); Math.min(end, projectSimpleVOList.size()));
return ResultUtil.success(pageData); return ResultUtil.success(pageData);
} }
@Override @Override
@ -342,10 +301,9 @@ public class ProjectServiceImpl implements ProjectService {
@Override @Override
public BaseResponse get( public BaseResponse get(
Integer listAll,
HttpServletRequest request, HttpServletRequest request,
List<String> tags, List<String> tags,
List<Integer> isFinish, List<String> isFinish,
Integer page, Integer page,
Integer pageSize Integer pageSize
) { ) {
@ -355,7 +313,7 @@ public class ProjectServiceImpl implements ProjectService {
Long userId = Processing.getAuthHeaderToUserId(request); Long userId = Processing.getAuthHeaderToUserId(request);
//根据标签查询 //根据标签查询
if (tags != null && !tags.isEmpty()) { if (tags != null && !tags.isEmpty()) {
List<ProjectDO> projectDOList = projectDAO.get(userId, listAll, tags, isFinish); List<ProjectDO> projectDOList = projectDAO.get(userId, tags, isFinish);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>(); List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) { for (ProjectDO projectDO : projectDOList) {
@ -373,40 +331,7 @@ public class ProjectServiceImpl implements ProjectService {
//根据状态查询 //根据状态查询
if (isFinish != null && !isFinish.isEmpty()) { if (isFinish != null && !isFinish.isEmpty()) {
List<ProjectDO> projectDOList = projectDAO.get(userId, listAll, tags, isFinish); List<ProjectDO> projectDOList = projectDAO.get(userId, tags, isFinish);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
}
//判断是否是老师(项目负责人)
if (listAll != null && Processing.checkUserIsTeacher(request, roleDAO)) {
List<ProjectDO> projectDOList = projectDAO.get(userId, listAll, tags, isFinish);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
} else {
listAll = 0;
List<ProjectDO> projectDOList = projectDAO.get(userId, listAll, tags, isFinish);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>(); List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) { for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO(); ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
@ -420,90 +345,38 @@ public class ProjectServiceImpl implements ProjectService {
Math.min(end, projectSimpleVOList.size())); Math.min(end, projectSimpleVOList.size()));
return ResultUtil.success(pageData); return ResultUtil.success(pageData);
} }
return ResultUtil.success(projectMapper.get(userId));
} }
@Override @Override
public BaseResponse workget( public BaseResponse workget(
Integer listAll,
HttpServletRequest request, HttpServletRequest request,
List<String> tags, List<String> tags,
List<Integer> isFinish, List<String> isFinish,
Integer is, Integer is,
Integer page, Integer page,
Integer pageSize Integer pageSize
) { ) {
log.info("\t> 执行 Service 层 ProjectService.workget 方法"); log.info("\t> 执行 Service 层 ProjectService.workget 方法");
//获取用户 //获取用户
Long userId = Processing.getAuthHeaderToUserId(request); Long userId = Processing.getAuthHeaderToUserId(request);
//根据标签查询 List<ProjectDO> projectDOList = projectDAO.workget(userId, tags, isFinish, is);
if (tags != null && !tags.isEmpty()) { List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
List<ProjectDO> projectDOList = projectDAO.workget(userId, listAll, tags, isFinish, is); for (ProjectDO projectDO : projectDOList) {
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>(); ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
for (ProjectDO projectDO : projectDOList) { Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO(); projectSimpleVOList.add(projectSimpleVO1);
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
} }
//分页返回
int start = (page - 1) * pageSize;
int end = start + pageSize;
List<ProjectSimpleVO> pageData = projectSimpleVOList.subList(start,
Math.min(end, projectSimpleVOList.size()));
//根据状态查询 return ResultUtil.success(pageData);
if (isFinish != null && !isFinish.isEmpty()) {
List<ProjectDO> projectDOList = projectDAO.workget(userId, listAll, tags, isFinish, is);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
}
//判断是否是老师(项目负责人)
if (listAll != null && Processing.checkUserIsTeacher(request, roleDAO)) {
List<ProjectDO> projectDOList = projectDAO.workget(userId, listAll, tags, isFinish, is);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
} else {
listAll = 0;
List<ProjectDO> projectDOList = projectDAO.workget(userId, listAll, tags, isFinish, is);
List<ProjectSimpleVO> projectSimpleVOList = new ArrayList<>();
for (ProjectDO projectDO : projectDOList) {
ProjectSimpleVO projectSimpleVO1 = new ProjectSimpleVO();
Processing.projectTosimply(projectSimpleVO1, projectDO, userDAO, objectMapper);
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);
}
} }

View File

@ -7,7 +7,7 @@ import com.jsl.oa.dao.UserDAO;
import com.jsl.oa.mapper.ReviewMapper; import com.jsl.oa.mapper.ReviewMapper;
import com.jsl.oa.mapper.UserMapper; import com.jsl.oa.mapper.UserMapper;
import com.jsl.oa.model.dodata.ProjectDO; import com.jsl.oa.model.dodata.ProjectDO;
import com.jsl.oa.model.dodata.ProjectWorkDO; import com.jsl.oa.model.dodata.ProjectModuleDO;
import com.jsl.oa.model.dodata.ReviewDO; import com.jsl.oa.model.dodata.ReviewDO;
import com.jsl.oa.model.vodata.ReviewVO; import com.jsl.oa.model.vodata.ReviewVO;
import com.jsl.oa.services.ReviewService; import com.jsl.oa.services.ReviewService;
@ -58,7 +58,7 @@ public class ReviewServiceImpl implements ReviewService {
} }
//在从用户为 子系统负责人 的项目中获取对应 审核信息 //在从用户为 子系统负责人 的项目中获取对应 审核信息
for (ProjectWorkDO projectWorkDO : projectDAO.getAllSubsystemByUserId(userId)) { for (ProjectModuleDO projectWorkDO : projectDAO.getAllSubsystemByUserId(userId)) {
//查询每个项目下所有的审核信息 //查询每个项目下所有的审核信息
List<ReviewDO> reviewDOS = reviewMapper. List<ReviewDO> reviewDOS = reviewMapper.
selectReviewFromSubsystem(projectWorkDO.getId()); selectReviewFromSubsystem(projectWorkDO.getId());
@ -68,7 +68,7 @@ public class ReviewServiceImpl implements ReviewService {
//在从用户为 子模块负责人 的项目中获取对应 审核信息 //在从用户为 子模块负责人 的项目中获取对应 审核信息
for (ProjectWorkDO projectWorkDO : projectDAO.getAllSubmoduleByUserId(userId)) { for (ProjectModuleDO projectWorkDO : projectDAO.getAllSubmoduleByUserId(userId)) {
//查询每个项目下所有的审核信息 //查询每个项目下所有的审核信息
List<ReviewDO> reviewDOS = reviewMapper. List<ReviewDO> reviewDOS = reviewMapper.
selectReviewFromSubmodule(projectWorkDO.getId()); selectReviewFromSubmodule(projectWorkDO.getId());

View File

@ -5,14 +5,14 @@
<mapper namespace="com.jsl.oa.mapper.ModuleMapper"> <mapper namespace="com.jsl.oa.mapper.ModuleMapper">
<select id="getByProjectId" resultType="com.jsl.oa.model.dodata.ProjectWorkDO"> <select id="getByProjectId" resultType="com.jsl.oa.model.dodata.ProjectModuleDO">
select * from organize_oa.oa_project_work where project_id=#{projectId} and type=0 select * from organize_oa.oa_project_work where project_id=#{projectId} and type=0
<if test="is != 1 "> <if test="is != 1 ">
and (principal_id=#{userId} or principal_id is null) and (principal_id=#{userId} or principal_id is null)
</if> </if>
</select> </select>
<select id="getBySysId" resultType="com.jsl.oa.model.dodata.ProjectWorkDO"> <select id="getBySysId" resultType="com.jsl.oa.model.dodata.ProjectModuleDO">
select * from organize_oa.oa_project_work where pid=#{sysId} and type=1 select * from organize_oa.oa_project_work where pid=#{sysId} and type=1
<if test="is != 1 "> <if test="is != 1 ">
and (principal_id=#{userId} or principal_id is null) and (principal_id=#{userId} or principal_id is null)

View File

@ -49,10 +49,10 @@
<select id="getByTags" resultType="com.jsl.oa.model.dodata.ProjectDO"> <select id="getByTags" resultType="com.jsl.oa.model.dodata.ProjectDO">
<if test="tags != null"> <if test="tags != null">
select * from organize_oa.oa_project where is_delete=false and principal_id=#{userId} and status=1 and select * from organize_oa.oa_project where is_delete=false and principal_id=#{userId} and
<if test="isFinish != null and isFinish.size() > 0"> <if test="isFinish != null and isFinish.size() > 0">
is_finish in status in
<foreach collection="isFinish" item="Finish" separator="," open="(" close=") and"> <foreach collection="isFinish" item="Finish" separator="," open="(" close=") and">
#{Finish} #{Finish}
</foreach> </foreach>
@ -67,7 +67,7 @@
</select> </select>
<select id="getByIsfinish" resultType="com.jsl.oa.model.dodata.ProjectDO"> <select id="getByIsfinish" resultType="com.jsl.oa.model.dodata.ProjectDO">
select * from organize_oa.oa_project where is_delete=false and principal_id =#{userId} and status=1 and is_finish in select * from organize_oa.oa_project where is_delete=false and principal_id =#{userId} and status in
<foreach collection="isFinish" item="Finish" separator="," open="(" close=")"> <foreach collection="isFinish" item="Finish" separator="," open="(" close=")">
#{Finish} #{Finish}
</foreach> </foreach>
@ -80,10 +80,10 @@
<if test="is != null"> <if test="is != null">
(principal_id = #{userId} and is_delete=false) or (principal_id = #{userId} and is_delete=false) or
</if> </if>
id in(select project_id from organize_oa.oa_project_work id in(select project_id from organize_oa.oa_project_child
where is_delete=false and (principal_id=#{userId} ) and where is_delete=false and principal_id=#{userId} ) and
<if test="isFinish != null and isFinish.size() > 0"> <if test="isFinish != null and isFinish.size() > 0">
is_finish in oa_project.status in
<foreach collection="isFinish" item="Finish" separator="," open="(" close=") and"> <foreach collection="isFinish" item="Finish" separator="," open="(" close=") and">
#{Finish} #{Finish}
</foreach> </foreach>
@ -102,7 +102,7 @@
<if test="is != null"> <if test="is != null">
(principal_id = #{userId} and is_delete=false) or (principal_id = #{userId} and is_delete=false) or
</if> </if>
id in(select project_id from organize_oa.oa_project_work where is_delete=false and (principal_id=#{userId}) and is_finish in id in(select project_id from organize_oa.oa_project_child where is_delete=false and (principal_id=#{userId}) and oa_project.status in
<foreach collection="isFinish" item="Finish" separator="," open="(" close="))"> <foreach collection="isFinish" item="Finish" separator="," open="(" close="))">
#{Finish} #{Finish}
</foreach> </foreach>
@ -113,7 +113,7 @@
<if test="is != null"> <if test="is != null">
(principal_id = #{userId} and is_delete=false) or (principal_id = #{userId} and is_delete=false) or
</if> </if>
id in(select project_id from organize_oa.oa_project_work where is_delete=false and principal_id=#{userId}) id in(select project_id from organize_oa.oa_project_child where is_delete=false and principal_id=#{userId})
</select> </select>
<select id="workget1" resultType="com.jsl.oa.model.dodata.ProjectDO"> <select id="workget1" resultType="com.jsl.oa.model.dodata.ProjectDO">
@ -130,9 +130,9 @@
</select> </select>
<select id="tgetBytags" resultType="com.jsl.oa.model.dodata.ProjectDO"> <select id="tgetBytags" resultType="com.jsl.oa.model.dodata.ProjectDO">
select * from organize_oa.oa_project where is_delete=false and status=1 and select * from organize_oa.oa_project where is_delete=false and
<if test="isFinish != null and isFinish.size() > 0"> <if test="isFinish != null and isFinish.size() > 0">
is_finish in oa_project.status in
<foreach collection="isFinish" item="Finish" separator="," open="(" close=") and"> <foreach collection="isFinish" item="Finish" separator="," open="(" close=") and">
#{Finish} #{Finish}
</foreach> </foreach>