This commit is contained in:
wangliwen 2022-04-22 14:31:31 +08:00
parent 292b800a6a
commit 9c39989591
1 changed files with 8 additions and 8 deletions

View File

@ -48,27 +48,27 @@ public class CorrectionListener implements TaskListener, ExecutionListener, Acti
@Override @Override
public void notify(DelegateTask delegateTask) { public void notify(DelegateTask delegateTask) {
logger.info("-------------------------进入部门动态审批人流程-------------------------------"); logger.error("-------------------------进入部门动态审批人流程-------------------------------");
Map<String, Object> kv = delegateTask.getVariables(); Map<String, Object> kv = delegateTask.getVariables();
Gson gson = new Gson(); Gson gson = new Gson();
JsonElement jsonElement = gson.toJsonTree(kv); JsonElement jsonElement = gson.toJsonTree(kv);
TAbilityApplicationDTO abilityApplicationDTO = gson.fromJson(jsonElement, TAbilityApplicationDTO.class); TAbilityApplicationDTO abilityApplicationDTO = gson.fromJson(jsonElement, TAbilityApplicationDTO.class);
SysRoleDTO roleDTO = sysRoleService.getByName(roleName); SysRoleDTO roleDTO = sysRoleService.getByName(roleName);
logger.info("roleDTOId:" + roleDTO.getId()); logger.error("roleDTOId:" + roleDTO.getId());
ResourceDTO resourceEntityDto = null; ResourceDTO resourceEntityDto = null;
Long deptId = null; Long deptId = null;
if (abilityApplicationDTO != null) { if (abilityApplicationDTO != null) {
logger.info("abilityApplicationDTO:" + abilityApplicationDTO.toString()); logger.error("abilityApplicationDTO:" + abilityApplicationDTO.toString());
resourceEntityDto = resourceService.get(Long.valueOf(abilityApplicationDTO.getResourceId())); resourceEntityDto = resourceService.get(Long.valueOf(abilityApplicationDTO.getResourceId()));
} }
if (resourceEntityDto != null && resourceEntityDto.getDeptId() != null) { if (resourceEntityDto != null && resourceEntityDto.getDeptId() != null) {
deptId = resourceEntityDto.getDeptId(); deptId = resourceEntityDto.getDeptId();
} else { } else {
logger.info("表单内单位名称:" + abilityApplicationDTO.getUnit()); logger.error("表单内单位名称:" + abilityApplicationDTO.getUnit());
SysDeptDTO deptDTO = sysDeptService.getByName(abilityApplicationDTO.getUnit()); SysDeptDTO deptDTO = sysDeptService.getByName(abilityApplicationDTO.getUnit());
if (deptDTO != null) { if (deptDTO != null) {
logger.info("deptDTOId:" + deptDTO.getId()); logger.error("deptDTOId:" + deptDTO.getId());
deptId = deptDTO.getId(); deptId = deptDTO.getId();
} }
@ -78,13 +78,13 @@ public class CorrectionListener implements TaskListener, ExecutionListener, Acti
userDTO = sysUserService.getByDeptIdAndRoleId(deptId, roleDTO.getId()); // 搜出审批人 userDTO = sysUserService.getByDeptIdAndRoleId(deptId, roleDTO.getId()); // 搜出审批人
} }
if (userDTO != null) { if (userDTO != null) {
logger.info("审批人id:" + userDTO.getId()); logger.error("审批人id:" + userDTO.getId());
taskService.setAssignee(delegateTask.getId(), userDTO.getId().toString()); taskService.setAssignee(delegateTask.getId(), userDTO.getId().toString());
} else { } else {
logger.info("未查到该部门对应的 " + roleName); logger.error("未查到该部门对应的 " + roleName);
taskService.setAssignee(delegateTask.getId(), "1513432847327199233"); taskService.setAssignee(delegateTask.getId(), "1513432847327199233");
} }
logger.info("-------------------------结束部门动态审批人流程-------------------------------"); logger.error("-------------------------结束部门动态审批人流程-------------------------------");
} }
@Override @Override