diff --git a/src/main/java/com/lz/modules/flow/dao/FlowChartMapper.java b/src/main/java/com/lz/modules/flow/dao/FlowChartMapper.java index 4dbb61ea..110deb97 100644 --- a/src/main/java/com/lz/modules/flow/dao/FlowChartMapper.java +++ b/src/main/java/com/lz/modules/flow/dao/FlowChartMapper.java @@ -43,4 +43,5 @@ public interface FlowChartMapper extends BaseMapper { List selectFlowChartsByGroupId(Long groupId); + List selectCanSetChartRoleByChartId(Long id); } \ No newline at end of file diff --git a/src/main/java/com/lz/modules/flow/dao/ResultTagetLibMapper.java b/src/main/java/com/lz/modules/flow/dao/ResultTagetLibMapper.java index 3c7cae1c..5c3d8f1d 100644 --- a/src/main/java/com/lz/modules/flow/dao/ResultTagetLibMapper.java +++ b/src/main/java/com/lz/modules/flow/dao/ResultTagetLibMapper.java @@ -37,7 +37,7 @@ public interface ResultTagetLibMapper extends BaseMapper { int deleteResultTagetLibById(@Param("id")Long id); - List selectResultTagetLibByModelId(Long id); + List selectResultTagetLibByModelId(Long id); List selectByCondition(@Param("page") IPage page, @Param("req") ResultTagetLibSearchReq req); diff --git a/src/main/java/com/lz/modules/flow/service/FlowChartService.java b/src/main/java/com/lz/modules/flow/service/FlowChartService.java index c3a3e84a..7ad4b0ab 100644 --- a/src/main/java/com/lz/modules/flow/service/FlowChartService.java +++ b/src/main/java/com/lz/modules/flow/service/FlowChartService.java @@ -41,4 +41,6 @@ public interface FlowChartService extends IService { List selectFlowChartDtoByFlowManagerId(Long id); List selectFlowChartsByGroupId(Long groupId); + + List selectCanSetChartRoleByChartId(Long id); } \ No newline at end of file diff --git a/src/main/java/com/lz/modules/flow/service/impl/FlowChartServiceImpl.java b/src/main/java/com/lz/modules/flow/service/impl/FlowChartServiceImpl.java index 57865106..d3539334 100644 --- a/src/main/java/com/lz/modules/flow/service/impl/FlowChartServiceImpl.java +++ b/src/main/java/com/lz/modules/flow/service/impl/FlowChartServiceImpl.java @@ -82,6 +82,12 @@ public class FlowChartServiceImpl extends ServiceImpl selectCanSetChartRoleByChartId(Long id) + { + return flowChartMapper.selectCanSetChartRoleByChartId(id); + } + } diff --git a/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java b/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java index 54756f5f..230044e9 100644 --- a/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java +++ b/src/main/java/com/lz/modules/flow/service/impl/FlowStartServiceImpl.java @@ -383,9 +383,21 @@ public class FlowStartServiceImpl extends ServiceImpl resultTagetLibDtos = resultTagetLibService.selectResultTagetLibDtoByModelId(modelDto.getId()); + modelDto.setTagetLibs(resultTagetLibDtos); + } + //以下代码没必要更新,因为这个拷贝分用不到。正确的对应关系清查看lz_evaluation_start_staff //evaluationGroup.setStaffIds(evaluationGroup.getStaffIds() + ","); @@ -424,6 +436,8 @@ public class FlowStartServiceImpl extends ServiceImpl flowChartDtos = flowChartService.selectFlowChartDtoByFlowManagerId(flowManager.getId()); for (FlowChartDto dto:flowChartDtos ) { - List flowCharts = flowChartService.selectChartRoleByChartId(dto.getId()); - dto.setRoleDtos(flowCharts); + List flowChartRoles = flowChartService.selectCanSetChartRoleByChartId(dto.getId()); + dto.setRoleDtos(flowChartRoles); if(groupId > 0){ //获取节点已保存的数据 FlowChartDetailRecordListDto flowChartDetailRecordListDto = new FlowChartDetailRecordListDto(); diff --git a/src/main/java/com/lz/modules/performance/service/ResultTagetLibService.java b/src/main/java/com/lz/modules/performance/service/ResultTagetLibService.java index a0158ed0..b530a852 100644 --- a/src/main/java/com/lz/modules/performance/service/ResultTagetLibService.java +++ b/src/main/java/com/lz/modules/performance/service/ResultTagetLibService.java @@ -37,7 +37,7 @@ public interface ResultTagetLibService extends IService { int deleteResultTagetLibById(Long id); - List selectResultTagetLibByModelId(Long id); + List selectResultTagetLibByModelId(Long id); PageUtils selectResultTagetLibByReq(ResultTagetLibSearchReq req); 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 2d27b116..938b61b2 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 @@ -292,33 +292,34 @@ public class AssessManagerServiceImpl implements AssessManagerService { log.info("更新evaluationStartStaff 数据 为已评分 " + i); List dtos = resultRecordMapper.selectToScoreList(req.getStartId(), evaluation); - if(CollectionUtils.isEmpty(dtos)){ - log.info("该考评组无数据 evaluationId:" + evaluation); - continue; + if(CollectionUtils.isNotEmpty(dtos)){ + log.info("本次评分更新操作 num: " + dtos.size()); + dtos.forEach(dto -> { + Long recordId = dto.getId(); + //更新流程绩效 + ApprovalDto approvalDto = new ApprovalDto(); + approvalDto.setStatus(1); + approvalDto.setResultRecordId(recordId); + approvalDto.setMenuName("开始评分"); + try { + R r = resultRecordService.newApproval(approvalDto); + log.info("绩效id aLong :" + recordId + " ,res" + JSON.toJSONString(r)); + } catch (Exception e) { + log.error("执行中状态跳过失败 recorId:" + recordId,e); + } + //钉钉通知评分构建 + StaffSimpleInfo staffSimpleInfo = new StaffSimpleInfo(); + staffSimpleInfo.setId(dto.getStaffId()); + staffSimpleInfo.setRecordId(recordId); + staffSimpleInfo.setStartId(req.getStartId()); + toStaffids.add(staffSimpleInfo); + + }); + } + else { + log.info("该考评组无数据 evaluationId:" + evaluation); } - log.info("本次评分更新操作 num: " + dtos.size()); - dtos.forEach(dto -> { - Long recordId = dto.getId(); - //更新流程绩效 - ApprovalDto approvalDto = new ApprovalDto(); - approvalDto.setStatus(1); - approvalDto.setResultRecordId(recordId); - approvalDto.setMenuName("开始评分"); - try { - R r = resultRecordService.newApproval(approvalDto); - log.info("绩效id aLong :" + recordId + " ,res" + JSON.toJSONString(r)); - } catch (Exception e) { - log.error("执行中状态跳过失败 recorId:" + recordId,e); - } - //钉钉通知评分构建 - StaffSimpleInfo staffSimpleInfo = new StaffSimpleInfo(); - staffSimpleInfo.setId(dto.getStaffId()); - staffSimpleInfo.setRecordId(recordId); - staffSimpleInfo.setStartId(req.getStartId()); - toStaffids.add(staffSimpleInfo); - - }); //更新flowRecord记录 List objects = resultRecordService.listObjs(new QueryWrapper() .eq("is_delete", 0) @@ -331,15 +332,16 @@ public class AssessManagerServiceImpl implements AssessManagerService { log.info("更新flowRecord记录,i:" + updateExecution); } - - //通知评分 - try { - String s = dingtalkBusiness.sendWorkMSGWithAsyn(toStaffids, WorkMsgTypeEnum.START_SCORE.getType()); - log.info("钉钉评分响应返回,res:" + s); - } catch (Exception e) { - log.error("通知评分异常:ids: " + JSON.toJSONString(toStaffids) + " ,e: " ,e); - } + if(CollectionUtils.isNotEmpty(toStaffids)){ + //通知评分 + try { + String s = dingtalkBusiness.sendWorkMSGWithAsyn(toStaffids, WorkMsgTypeEnum.START_SCORE.getType()); + log.info("钉钉评分响应返回,res:" + s); + } catch (Exception e) { + log.error("通知评分异常:ids: " + JSON.toJSONString(toStaffids) + " ,e: " ,e); + } + } } diff --git a/src/main/java/com/lz/modules/performance/service/impl/AssessServiceImpl.java b/src/main/java/com/lz/modules/performance/service/impl/AssessServiceImpl.java index bc991250..3d5c58db 100644 --- a/src/main/java/com/lz/modules/performance/service/impl/AssessServiceImpl.java +++ b/src/main/java/com/lz/modules/performance/service/impl/AssessServiceImpl.java @@ -102,6 +102,7 @@ public class AssessServiceImpl implements AssessService { log.info("获取 roleDepartment,staffRole: " + JSON.toJSONString(staffRole)); // 0 标识全部部门 if (staffRole.getDepartmentId() == 0) { + log.info("staffRole 为0,管理全部部门"); return null; } else { diff --git a/src/main/java/com/lz/modules/performance/service/impl/ResultTagetLibServiceImpl.java b/src/main/java/com/lz/modules/performance/service/impl/ResultTagetLibServiceImpl.java index 341f6aa2..50370d6b 100644 --- a/src/main/java/com/lz/modules/performance/service/impl/ResultTagetLibServiceImpl.java +++ b/src/main/java/com/lz/modules/performance/service/impl/ResultTagetLibServiceImpl.java @@ -55,7 +55,7 @@ public class ResultTagetLibServiceImpl extends ServiceImpl resultTagetLibDtos = selectResultTagetLibByModelId(resultModel.getId()); + List resultTagetLibDtos = selectResultTagetLibDtoByModelId(resultModel.getId()); BigDecimal weight = BigDecimal.ZERO; for(int i = 0; i < resultTagetLibDtos.size(); i++){ ResultTagetLibDto dto = resultTagetLibDtos.get(i); @@ -92,7 +92,7 @@ public class ResultTagetLibServiceImpl extends ServiceImpl selectResultTagetLibByModelId(Long id){ + public List selectResultTagetLibByModelId(Long id){ return resultTagetLibMapper.selectResultTagetLibByModelId(id); } diff --git a/src/main/resources/mapper/flow/FlowChartMapper.xml b/src/main/resources/mapper/flow/FlowChartMapper.xml index 7cf2e556..948bfa61 100644 --- a/src/main/resources/mapper/flow/FlowChartMapper.xml +++ b/src/main/resources/mapper/flow/FlowChartMapper.xml @@ -119,5 +119,11 @@ ) and is_delete=0 order by step_index asc + + diff --git a/src/main/resources/mapper/flow/ResultTagetLibMapper.xml b/src/main/resources/mapper/flow/ResultTagetLibMapper.xml index f4a1edd6..bf1fd63e 100644 --- a/src/main/resources/mapper/flow/ResultTagetLibMapper.xml +++ b/src/main/resources/mapper/flow/ResultTagetLibMapper.xml @@ -89,7 +89,7 @@ update lz_result_taget_lib set is_delete = 1 where id=#{id} limit 1 - select * from lz_result_taget_lib where model_id=#{id} and is_delete = 0 order by order_by desc