diff --git a/src/main/java/com/lz/common/emun/WorkMsgTypeEnum.java b/src/main/java/com/lz/common/emun/WorkMsgTypeEnum.java index 7d8f2b6f..625d6c41 100644 --- a/src/main/java/com/lz/common/emun/WorkMsgTypeEnum.java +++ b/src/main/java/com/lz/common/emun/WorkMsgTypeEnum.java @@ -9,7 +9,7 @@ public enum WorkMsgTypeEnum { //绩效提交审核的通知(自己提交给领导,自己提交给人事,人事提交给老板) SUBMIT(0, "绩效提交", "去审核", "# 绩效提交\n ## @的绩效已经提交"), //绩效打回审核的通知 - REJECT(1, "绩效驳回", "去修改", "# 绩效驳回\n ## @的绩效已经驳回"), + REJECT(1, "绩效驳回", "去修改", "# 绩效驳回\n ## @的绩效被驳回"), //绩效通过领导审核的通知,这一步提交到HR,提交的type LEADER_PASS(2, "绩效已打分", "去提交给人事", "# 绩效已打分\n ## 你的绩效已经打分"), //绩效通过人事,老板审核的最终审核通知 diff --git a/src/main/java/com/lz/modules/app/controller/ResultRecordController.java b/src/main/java/com/lz/modules/app/controller/ResultRecordController.java index 48297b8d..2b11e14f 100644 --- a/src/main/java/com/lz/modules/app/controller/ResultRecordController.java +++ b/src/main/java/com/lz/modules/app/controller/ResultRecordController.java @@ -387,9 +387,10 @@ public class ResultRecordController extends AbstractController { staffs.addAll(departManagers.getManagers()); } } - /*if(staffs.size() == 0){ - return R.error("找不到有效的评分人,设置的评分人不存在"); - }*/ + if(staffs.size() == 0){ + log.info("无法找到评分人员,开始找绩效管理人员"); + staffs = staffService.findManger(resultRecord.getId(), 4); + } for (StaffEntity staff:staffs ) { diff --git a/src/main/java/com/lz/modules/app/dao/StaffDao.java b/src/main/java/com/lz/modules/app/dao/StaffDao.java index 70f7b8c8..8a367679 100644 --- a/src/main/java/com/lz/modules/app/dao/StaffDao.java +++ b/src/main/java/com/lz/modules/app/dao/StaffDao.java @@ -98,4 +98,6 @@ public interface StaffDao extends BaseMapper { List selectNamesByIds(@Param("list") List sIds); List selectStaffsByGroupId(@Param("copyId") Long copyId); + + List findManger(@Param("recordId") Long recordId, @Param("flowProcess") int flowProcess); } diff --git a/src/main/java/com/lz/modules/app/service/StaffService.java b/src/main/java/com/lz/modules/app/service/StaffService.java index dad4c18f..936f6f45 100644 --- a/src/main/java/com/lz/modules/app/service/StaffService.java +++ b/src/main/java/com/lz/modules/app/service/StaffService.java @@ -103,5 +103,7 @@ public interface StaffService extends IService { List selectNamesByIds(List sIds); //获取绩效考核管理员 List selectStaffsByGroupId(Long copyId); + + List findManger(Long recordId, int flowProcess); } diff --git a/src/main/java/com/lz/modules/app/service/impl/StaffServiceImpl.java b/src/main/java/com/lz/modules/app/service/impl/StaffServiceImpl.java index d2a37b33..a15333aa 100644 --- a/src/main/java/com/lz/modules/app/service/impl/StaffServiceImpl.java +++ b/src/main/java/com/lz/modules/app/service/impl/StaffServiceImpl.java @@ -529,5 +529,10 @@ public class StaffServiceImpl extends ServiceImpl impleme return staffDao.selectStaffsByGroupId(copyId); } + @Override + public List findManger(Long recordId, int flowProcess){ + return staffDao.findManger(recordId, flowProcess); + } + } diff --git a/src/main/java/com/lz/modules/flow/service/EvaluationGroupService.java b/src/main/java/com/lz/modules/flow/service/EvaluationGroupService.java index 3e3a4513..2a6c15d4 100644 --- a/src/main/java/com/lz/modules/flow/service/EvaluationGroupService.java +++ b/src/main/java/com/lz/modules/flow/service/EvaluationGroupService.java @@ -58,4 +58,5 @@ public interface EvaluationGroupService extends IService { String getEvaluationCopyIdsByEvaluationIds(String evaluationIds,Long startId); + EvaluationGroup selectEvaluationGroupByCopyId(Long copyId, Long startId); } \ No newline at end of file diff --git a/src/main/java/com/lz/modules/flow/service/impl/EvaluationGroupServiceImpl.java b/src/main/java/com/lz/modules/flow/service/impl/EvaluationGroupServiceImpl.java index 7dd6d7ee..4e82a9cd 100644 --- a/src/main/java/com/lz/modules/flow/service/impl/EvaluationGroupServiceImpl.java +++ b/src/main/java/com/lz/modules/flow/service/impl/EvaluationGroupServiceImpl.java @@ -353,7 +353,8 @@ public class EvaluationGroupServiceImpl extends ServiceImpl stringCollect = staffIdsByGroup.stream().distinct().collect(toList()); @@ -378,18 +379,28 @@ public class EvaluationGroupServiceImpl extends ServiceImpl ids,EvaluationGroup group) { String staffIds = group.getStaffIds(); - if(StringUtil.isNotBlank(staffIds)){ - String[] split = staffIds.split(","); - Set set = new HashSet(Arrays.asList(split)); - set.removeAll(new HashSet(ids)); //set.addAll(new HashSet(ids)); - String join = StringUtils.join(set, ","); - group.setStaffIds(join); - int i = evaluationGroupMapper.updateCoverEvaluationGroupById(group); - return i; + String outIds = group.getOutIds(); + //删除选中人员 + if(StringUtil.isNotBlank(staffIds)){ + String[] staffs = staffIds.split(","); + Set staffsSet = new HashSet(Arrays.asList(staffs)); + staffsSet.removeAll(ids); + group.setStaffIds(StringUtils.join(staffsSet, ",")); } - return 0; - } + //增加排除人员 + if(StringUtil.isBlank(outIds)){ + group.setOutIds(StringUtils.join(ids, ",")); + } + else { + String[] outs = outIds.split(","); + Set outsSet = new HashSet(Arrays.asList(outs)); + outsSet.addAll(ids); + group.setOutIds(StringUtils.join(outsSet, ",")); + } + + return evaluationGroupMapper.updateById(group); + } @Override public String getEvaluationCopyIdsByEvaluationIds(String evaluationIds,Long startId) { @@ -402,4 +413,9 @@ public class EvaluationGroupServiceImpl extends ServiceImpl> staffManages, List staffIds, - Map> mustRole, Map> selfMustRole){ + Map> mustRole, Map> selfMustRole, boolean isInsert){ List resultModelDtos = resultModelService.selectResultDtoByGroupId(evaluationGroup.getId()); @@ -340,7 +341,7 @@ public class FlowStartServiceImpl extends ServiceImpl evaluationStartStaffs = new ArrayList<>(); + List resultDetails = new ArrayList(); + //下面初始化参与人员 + for (StaffSimpleInfo staffInfo:staffIds + ) { + staffInfo.setStartId(flowStart.getId()); + + EvaluationStartStaff evaluationStartStaff = new EvaluationStartStaff(); + evaluationStartStaff.setEvaluationId(evaluationGroup.getId()); + evaluationStartStaff.setEvaluationName(evaluationGroup.getName()); + evaluationStartStaff.setStaffId(staffInfo.getId()); + evaluationStartStaff.setStartId(flowStart.getId()); + evaluationStartStaff.setDepartmentId(staffInfo.getDepartmentId()); + evaluationStartStaff.setType(CheckStaffType.STAFF.getCode()); + evaluationStartStaffs.add(evaluationStartStaff); + + + //初始化lz_result_records数据 + ResultRecord resultRecord = new ResultRecord(); + resultRecord.setDepartmentId(staffInfo.getDepartmentId()); + resultRecord.setDepartmentName(staffInfo.getDepartmentName()); + resultRecord.setStaffId(staffInfo.getId()); + resultRecord.setStaffName(staffInfo.getName()); + resultRecord.setType(1);//设置为提交目标 + resultRecord.setStatus(0);//设置为新建 + resultRecord.setStartId(flowStart.getId()); + resultRecord.setEvaluationId(evaluationGroup.getId()); + resultRecord.setFlowProcess(0);//设置为目标制定 + + //设置当前审批员工id current_approval_staff_id + resultRecord.setCurrentApprovalStaffId(staffInfo.getId()); + //设置当前审批员工姓名 current_approval_staff_name + resultRecord.setCurrentApprovalStaffName(staffInfo.getName()); + + resultRecordService.insertResultRecord(resultRecord); + staffInfo.setRecordId(resultRecord.getId()); + + for (ResultModelDto modelDto:resultModelDtos + ) { + + + if(modelDto.getTagetLibs() != null && modelDto.getTagetLibs().size() > 0){//模板里面有添加指标 + for (ResultTagetLibDto libDto: + modelDto.getTagetLibs()) { + + ResultDetail resultDetail = new ResultDetail(); + resultDetail.setRecordId(resultRecord.getId()); + resultDetail.setTarget(libDto.getName()); + resultDetail.setType(modelDto.getType()); + resultDetail.setKeyResult(libDto.getKeyResult()); + resultDetail.setCheckWeight(libDto.getWeight()); + resultDetail.setStaffId(staffInfo.getId()); + resultDetail.setPriority(libDto.getOrderBy()); + resultDetails.add(resultDetail); + } + } + } + + //如果有数据插入lz_result_detail表 + if(resultDetails.size() > 0){ + // + resultDetailService.insertResultDetails(resultDetails); + + } + + //下面生成实际的考核流程 + resultRecordService.initFlowRecord(resultRecord.getId()); + } + evaluationStartStaffService.insertEvaluationStartStaffs(evaluationStartStaffs); + return 0; } diff --git a/src/main/java/com/lz/modules/job/business/DingtalkBusiness.java b/src/main/java/com/lz/modules/job/business/DingtalkBusiness.java index 7163f141..593d8ae1 100644 --- a/src/main/java/com/lz/modules/job/business/DingtalkBusiness.java +++ b/src/main/java/com/lz/modules/job/business/DingtalkBusiness.java @@ -13,10 +13,14 @@ import com.lz.modules.app.service.DepartmentsService; import com.lz.modules.app.service.DepartmentsStaffRelateService; import com.lz.modules.app.service.StaffOccupationService; import com.lz.modules.app.service.StaffService; +import com.lz.modules.flow.entity.FlowRecord; +import com.lz.modules.flow.service.FlowRecordService; import com.lz.modules.job.model.responseBo.DepartmentInfosBo; import com.lz.modules.job.model.responseBo.DepartmentStaffBo; import com.lz.modules.sys.dao.SysUserTokenDao; import com.lz.modules.sys.entity.SysUserTokenEntity; +import com.lz.modules.sys.entity.app.ResultRecord; +import com.lz.modules.sys.service.app.ResultRecordService; import com.lz.modules.third.entity.ThirdAppConfig; import com.lz.modules.third.service.ThirdAppConfigService; import org.slf4j.LoggerFactory; @@ -26,6 +30,7 @@ import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.net.URLEncoder; +import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.function.Function; @@ -63,9 +68,16 @@ public class DingtalkBusiness { @Autowired private SysUserTokenDao sysUserTokenDao; + @Autowired + private ResultRecordService resultRecordService; + + @Autowired + private FlowRecordService flowRecordService; + @Resource StaffDao staffDao; + @Value("${dingtalk.appid}") private String appid; @@ -194,10 +206,33 @@ public class DingtalkBusiness { } - + //流程流转发送消息 public String sendWorkMSGWithAsyn(Long resultRecordId , int type) { + ResultRecord resultRecord = resultRecordService.selectResultRecordById(resultRecordId); + if(resultRecord != null){ + StaffSimpleInfo fromStaff = staffService.selectStaffSimpleInfo(resultRecord.getStaffId()); + List toStaffids; + if(type == WorkMsgTypeEnum.REJECT.getType()){ + toStaffids = new ArrayList<>(); + toStaffids.add(fromStaff); + sendWorkMSGWithAsyn(fromStaff, toStaffids, WorkMsgTypeEnum.REJECT.getType()); + }else{ + List flowRecords = + flowRecordService.selectFlowRecordByRecordIdStatus(resultRecordId, 2); + List ids = flowRecords.stream().map(new Function() { + @Override + public Long apply(FlowRecord flowRecord) { + return flowRecord.getApprovalStaffId(); + } + }).collect(Collectors.toList()); + toStaffids = staffService.selectStaffSimpleInfos(ids); + sendWorkMSGWithAsyn(fromStaff, toStaffids, WorkMsgTypeEnum.PROCESS.getType()); + } - return null; + + + } + return "error"; } @@ -337,7 +372,12 @@ public class DingtalkBusiness { if(fromStaff == null){ content = workMsgTypeEnum.getContent().replace("@", info.getName()); }else{ - content = workMsgTypeEnum.getContent().replace("@", fromStaff.getName()); + if(fromStaff.getId() == info.getId()){ + content = workMsgTypeEnum.getContent().replace("@", "您"); + }else{ + content = workMsgTypeEnum.getContent().replace("@", fromStaff.getName()); + } + } StaffEntity entity = new StaffEntity(); diff --git a/src/main/java/com/lz/modules/performance/controller/AssessManagerController.java b/src/main/java/com/lz/modules/performance/controller/AssessManagerController.java index 53e9105c..10b148b6 100644 --- a/src/main/java/com/lz/modules/performance/controller/AssessManagerController.java +++ b/src/main/java/com/lz/modules/performance/controller/AssessManagerController.java @@ -3,6 +3,7 @@ package com.lz.modules.performance.controller; import com.lz.common.utils.PageUtils; import com.lz.common.utils.R; import com.lz.common.utils.StringUtil; +import com.lz.modules.app.dto.StaffSimpleDto; import com.lz.modules.flow.dao.FlowStartMapper; import com.lz.modules.flow.entity.FlowStart; import com.lz.modules.performance.req.AssessChangeReq; @@ -56,7 +57,8 @@ public class AssessManagerController extends AbstractController{ PageUtils pageUtils = assessManagerService.assessList(req); return R.ok().put("data",pageUtils); } catch (Exception e) { - return R.error(); + log.error("获取考核列表异常,",e); + return R.error(e.getMessage()); } } @@ -64,17 +66,14 @@ public class AssessManagerController extends AbstractController{ @ApiOperation("获取考核详情列表") @ApiResponses({@ApiResponse(code = 200,message = "成功",response = AssessManagerDetailRes.class)}) public R assessDetail(@RequestBody AssessDetailReq req){ - if(req.getStartId()==null){ - return R.error("考核id不能为空"); - } - PageUtils pageUtils = null; + PageUtils pageUtils; try { Long userId = getUserId(); req.setLoginUserId(userId); pageUtils = assessManagerService.assessDetail(req); } catch (Exception e) { log.error("获取考核详情列表异常" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok().put("data",pageUtils); @@ -86,17 +85,14 @@ public class AssessManagerController extends AbstractController{ @ApiOperation("获取考核详情列表人数统计") @ApiResponses({@ApiResponse(code = 200,message = "成功",response = ChartStatistical.class)}) public R assessChart(@RequestBody AssessDetailReq req){ - if(req.getStartId()==null){ - return R.error("考核id不能为空"); - } - List process = null; + List process; try { Long userId = getUserId(); req.setLoginUserId(userId); process = chartResultService.countAssessNumByFlowProcess(req); } catch (Exception e) { log.error("获取详情顶部人数统计异常" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok().put("data",process); @@ -105,17 +101,8 @@ public class AssessManagerController extends AbstractController{ @PostMapping("assess/manager/change") @ApiOperation("考核管理组管理变更") - @ApiResponses({@ApiResponse(code = 200,message = "成功"),@ApiResponse(code = 503,message = "去设置")}) + @ApiResponses({@ApiResponse(code = 200,message = "成功"),@ApiResponse(code = 503,message = "去设置",response = StaffSimpleDto.class)}) public R assessChange(@RequestBody AssessChangeReq req){ - if(req.getStartId()==null){ - return R.error("考核id不能为空"); - } - if(req.getChangeType()==null){ - return R.error("变动类型无效"); - } - if(StringUtil.isBlank(req.getStaffIds())){ - return R.error("变动人员不能为空"); - } try { return assessManagerService.assessChange(req); } catch (Exception e) { @@ -141,7 +128,7 @@ public class AssessManagerController extends AbstractController{ assessManagerService.accessDelete(flowStart); } catch (Exception e) { log.error("删除考核任务异常, id:" + assessId ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok(); } @@ -154,7 +141,7 @@ public class AssessManagerController extends AbstractController{ assessManagerService.toScore(req); } catch (Exception e) { log.error("开始评分异常" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok(); } diff --git a/src/main/java/com/lz/modules/performance/controller/ChartController.java b/src/main/java/com/lz/modules/performance/controller/ChartController.java index 062cb7a6..16d2a884 100644 --- a/src/main/java/com/lz/modules/performance/controller/ChartController.java +++ b/src/main/java/com/lz/modules/performance/controller/ChartController.java @@ -52,7 +52,7 @@ public class ChartController extends AbstractController{ chartStatisticalRes = chartResultService.chartReport(startId,userId); } catch (Exception e) { log.error("获取绩效报表统计异常" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok().put("data",chartStatisticalRes); } @@ -62,12 +62,12 @@ public class ChartController extends AbstractController{ @ApiOperation("获取考核类型列表") @ApiResponses({@ApiResponse(code = 200,message = "成功",response = ChartStartsRes.class)}) public R chartStarts(@RequestBody @ApiParam(name = "body",value = "body请求体",required = true)ChartStartsReq req){ - PageUtils pageUtils = null; + PageUtils pageUtils; try { pageUtils = chartResultService.chartStarts(req); } catch (Exception e) { log.error("获取考核类型列表异常" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok().put("data",pageUtils); } @@ -77,14 +77,14 @@ public class ChartController extends AbstractController{ @ApiOperation("获取报表等级详情") @ApiResponses({@ApiResponse(code = 200,message = "成功",response = ResultRankListRes.class)}) public R chartDetailList(@RequestBody @ApiParam(name = "body",value = "body请求体",required = true) ChartResultReq req){ - PageUtils pageUtils = null; + PageUtils pageUtils; try { Long userId = getUserId(); req.setLoginUserId(userId); pageUtils = chartResultService.selectChartDetailList(req); } catch (Exception e) { log.error("获取报表等级详情异常" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok().put("data",pageUtils); } diff --git a/src/main/java/com/lz/modules/performance/controller/EvaluationGroupController.java b/src/main/java/com/lz/modules/performance/controller/EvaluationGroupController.java index 6412221e..7580c83a 100644 --- a/src/main/java/com/lz/modules/performance/controller/EvaluationGroupController.java +++ b/src/main/java/com/lz/modules/performance/controller/EvaluationGroupController.java @@ -171,15 +171,17 @@ public class EvaluationGroupController extends AbstractController { return Long.parseLong(s); } }).collect(Collectors.toMap(Long::longValue, Function.identity(), (e, replace) -> e)); + if(staffRoles != null && staffRoles.size() > 0){ + for (StaffRole staffRole:staffRoles + ) {//去掉已经在管理本组的管理员 + if(mapIds.containsKey(staffRole.getStaffId())){ + mapIds.remove(staffRole.getStaffId()); + }else{//删除管理的组信息 + staffRoleEvaluationGroupService.deleteStaffRoleEvaluationGroupByRoleId(staffRole.getId()); + } + } + } - for (StaffRole staffRole:staffRoles - ) {//去掉已经在管理本组的管理员 - if(mapIds.containsKey(staffRole.getStaffId())){ - mapIds.remove(staffRole.getStaffId()); - }else{//删除管理的组信息 - staffRoleEvaluationGroupService.deleteStaffRoleEvaluationGroupByRoleId(staffRole.getId()); - } - } //去掉管理全考评组 staffRoles = staffRoleService.selectAllGroupManageRoles(); @@ -224,7 +226,7 @@ public class EvaluationGroupController extends AbstractController { @PostMapping("/checkStaff") @ApiOperation("校验是否有跨组人员") - @ApiResponses({@ApiResponse(code = 200,message = "成功"),@ApiResponse(code = 504,message = "已跨组")}) + @ApiResponses({@ApiResponse(code = 200,message = "成功"),@ApiResponse(code = 504,message = "已跨组",response = StaffSimpleDto.class)}) public R checkStaff(@RequestBody @ApiParam(required = true,name = "body") CheckStaffReq checkStaffReq) { return evaluationGroupService.checkStaff(checkStaffReq); } diff --git a/src/main/java/com/lz/modules/performance/controller/UserTaskController.java b/src/main/java/com/lz/modules/performance/controller/UserTaskController.java index 5c59eafc..d1277728 100644 --- a/src/main/java/com/lz/modules/performance/controller/UserTaskController.java +++ b/src/main/java/com/lz/modules/performance/controller/UserTaskController.java @@ -31,13 +31,13 @@ public class UserTaskController extends AbstractController{ @ApiOperation("获取待办/处理事项") @ApiResponses({@ApiResponse(code = 200,message = "成功",response = TaskListRes.class)}) public R list(@RequestBody @ApiParam(name = "body",value = "body请求体",required = true) AssessTaskReq req){ - PageUtils pageUtils = null; + PageUtils pageUtils; try { Long userId = getUserId(); pageUtils = assessService.userTaskList(req, userId); } catch (Exception e) { log.error("获取用户事项异常 userId:" ,e); - return R.error(); + return R.error(e.getMessage()); } return R.ok().put("data",pageUtils); } diff --git a/src/main/java/com/lz/modules/performance/service/impl/AssessManagerServiceImpl.java b/src/main/java/com/lz/modules/performance/service/impl/AssessManagerServiceImpl.java index 475f164d..2d27b116 100644 --- a/src/main/java/com/lz/modules/performance/service/impl/AssessManagerServiceImpl.java +++ b/src/main/java/com/lz/modules/performance/service/impl/AssessManagerServiceImpl.java @@ -138,6 +138,9 @@ public class AssessManagerServiceImpl implements AssessManagerService { @Override public PageUtils assessDetail(AssessDetailReq req) { + if(req.getStartId() == null ){ + throw new RRException("考核id不能为空"); + } //拼接拷贝组 if(StringUtil.isNotBlank(req.getEvaluationIds())){ req.setCopyEvaluationIds(evaluationGroupService.getEvaluationCopyIdsByEvaluationIds(req.getEvaluationIds(),req.getStartId())); @@ -180,6 +183,15 @@ public class AssessManagerServiceImpl implements AssessManagerService { @Override public R assessChange(AssessChangeReq req) { + if(req.getStartId()==null){ + throw new RRException("考核id不能为空"); + } + if(req.getChangeType()==null){ + throw new RRException("变动类型无效"); + } + if(StringUtil.isBlank(req.getStaffIds())){ + throw new RRException("变动人员不能为空"); + } FlowStart flowStart = flowStartMapper.selectFlowStartById(req.getStartId()); if(flowStart == null){ throw new RRException("暂无此考核组信息"); @@ -218,7 +230,7 @@ public class AssessManagerServiceImpl implements AssessManagerService { notInGroupNames = notInGroupNames + dto.getName() + " "; } - return R.error(503,notInGroupNames + "未加入月度类型考评组,被考核人需要加入月度考评组后才能参与当前月度考核。"); + return R.error(503,notInGroupNames + "未加入月度类型考评组,被考核人需要加入月度考评组后才能参与当前月度考核。").put("data",staffSimpleDtos); } //初始化添加用户的数据 @@ -322,9 +334,10 @@ public class AssessManagerServiceImpl implements AssessManagerService { //通知评分 try { - dingtalkBusiness.sendWorkMSGWithAsyn(toStaffids, WorkMsgTypeEnum.START_SCORE.getType()); + String s = dingtalkBusiness.sendWorkMSGWithAsyn(toStaffids, WorkMsgTypeEnum.START_SCORE.getType()); + log.info("钉钉评分响应返回,res:" + s); } catch (Exception e) { - log.error("通知评分异常:",e); + log.error("通知评分异常:ids: " + JSON.toJSONString(toStaffids) + " ,e: " ,e); } diff --git a/src/main/java/com/lz/modules/performance/service/impl/ChartResultServiceImpl.java b/src/main/java/com/lz/modules/performance/service/impl/ChartResultServiceImpl.java index 05b77272..c0319d69 100644 --- a/src/main/java/com/lz/modules/performance/service/impl/ChartResultServiceImpl.java +++ b/src/main/java/com/lz/modules/performance/service/impl/ChartResultServiceImpl.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.google.common.collect.Lists; import com.google.common.collect.Maps; +import com.lz.common.exception.RRException; import com.lz.common.utils.PageUtils; import com.lz.common.utils.R; import com.lz.common.utils.StringUtil; @@ -230,6 +231,9 @@ public class ChartResultServiceImpl implements ChartResultService { @Override public List countAssessNumByFlowProcess(AssessDetailReq req) { + if(req.getStartId()==null){ + throw new RRException("考核id不能为空"); + } req.setCopyEvaluationIds(evaluationGroupService.getEvaluationCopyIdsByEvaluationIds(req.getEvaluationIds(),req.getStartId())); //获取自己管理的部门 List mandepartmentIds = assessService.roleDepartments(req.getLoginUserId()); diff --git a/src/main/resources/mapper/generator/StaffDao.xml b/src/main/resources/mapper/generator/StaffDao.xml index 187511c6..102b4ab8 100644 --- a/src/main/resources/mapper/generator/StaffDao.xml +++ b/src/main/resources/mapper/generator/StaffDao.xml @@ -545,4 +545,11 @@ ) and is_delete=0) as staff join lz_staff_occupation as occupation on staff.id = occupation.staff_id where occupation.staff_status=0 + +