增加部门负责人

blade-service/logpm-supervise/src/main/java/com/logpm/supervise/service/impl/ClassifyServiceImpl.java

@@ -48,10 +48,12 @@ import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.BeanUtil;
 import org.springblade.core.tool.utils.Func;
+import org.springblade.core.tool.utils.ObjectUtil;
 import org.springblade.core.tool.utils.StringUtil;
 import org.springblade.system.entity.Dept;
 import org.springblade.system.entity.User;
 import org.springblade.system.feign.IDeptClient;
+import org.springblade.system.feign.ISysClient;
 import org.springblade.system.feign.IUserClient;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -86,6 +88,8 @@ public class ClassifyServiceImpl extends BaseServiceImpl<ClassifyMapper, Classif
 
 	private final IUserClient userClient;
 
+	private final ISysClient sysClient;
+
 
 	@Override
 	public IPage<ClassifyVO> pageList(IPage<Object> page, Map<String, Object> classify) {
@@ -243,9 +247,36 @@ public class ClassifyServiceImpl extends BaseServiceImpl<ClassifyMapper, Classif
 
 		//保存考核内容
 		IndicatorsEntity indicatorsEntity = Func.copy(instanceofDTO, IndicatorsEntity.class);
-		indicatorsEntity.setIndicatorsStatus(1);
-		indicatorsEntity.setAssessUserId(user.getUserId());
-		indicatorsEntity.setAssessDeptName(user.getNickName());
+        assert indicatorsEntity != null;
+        indicatorsEntity.setIndicatorsStatus(1);
+//		indicatorsEntity.setAssessUserId(user.getUserId());
+//		indicatorsEntity.setAssessDeptName(user.getNickName());
+		// 增加当前选择部门的负责人
+
+		R<List<User>> listR = userClient.userInfoByDept(user.getTenantId(), instanceofDTO.getAssessDept());
+		Long userId=null;
+		String userName=null;
+		if(listR.isSuccess()){
+			List<User> data = listR.getData();
+			// 获取仓库经理ID
+			R<String> roleIs = sysClient.getRoleIds(user.getTenantId(), "仓库经理");
+			if(roleIs.isSuccess()){
+				String roleId = roleIs.getData();
+				for (User datum : data) {
+					if(datum.getPostId().contains(roleId)){
+						userId=datum.getId();
+						userName=datum.getRealName();
+					}
+				}
+			}
+		}
+		if(ObjectUtil.isEmpty(userId)){
+			return R.fail(403,"选择节点不存在仓库负责人");
+		}
+		indicatorsEntity.setAssessUserId(userId);
+		indicatorsEntity.setAssessUserName(userName);
+
+
 		iIndicatorsService.save(indicatorsEntity);
 
 		if (Func.isNotEmpty(instanceofDTO.getResourceList())) {