diff --git a/project/src/main/java/com/sdm/project/service/impl/LyricInternalServiceImpl.java b/project/src/main/java/com/sdm/project/service/impl/LyricInternalServiceImpl.java index a79bfe2d..a6e0e3c2 100644 --- a/project/src/main/java/com/sdm/project/service/impl/LyricInternalServiceImpl.java +++ b/project/src/main/java/com/sdm/project/service/impl/LyricInternalServiceImpl.java @@ -13,6 +13,7 @@ import com.sdm.common.entity.enums.NodeTypeEnum; import com.sdm.common.entity.req.data.*; import com.sdm.common.entity.req.lyric.SpdmAcceptTodoInfoReq; import com.sdm.common.entity.req.project.SpdmNodeListReq; +import com.sdm.common.entity.req.system.DeptQueryReq; import com.sdm.common.entity.req.system.UserListReq; import com.sdm.common.entity.req.system.UserQueryReq; import com.sdm.common.entity.resp.PageDataResp; @@ -21,6 +22,7 @@ import com.sdm.common.entity.resp.data.FileMetadataInfoResp; import com.sdm.common.entity.resp.system.CIDUserResp; import com.sdm.common.entity.resp.system.SysDeptUserResp; import com.sdm.common.feign.impl.data.DataClientFeignClientImpl; +import com.sdm.common.feign.impl.system.SysDeptFeignClientImpl; import com.sdm.common.feign.impl.system.SysUserFeignClientImpl; import com.sdm.common.log.CoreLogger; import com.sdm.common.utils.FilesUtil; @@ -162,6 +164,9 @@ public class LyricInternalServiceImpl implements ILyricInternalService { @Autowired SysUserFeignClientImpl sysUserFeignClient; + @Autowired + SysDeptFeignClientImpl sysDeptFeignClient; + @Autowired private CacheManager cacheManager; @@ -3876,6 +3881,14 @@ public class LyricInternalServiceImpl implements ILyricInternalService { threedDemandRelateMemberReq.setCreator(userId); allMemberList.add(threedDemandRelateMemberReq); + SpdmDemandRelateMemberReq attentionDemandRelateMemberReq = new SpdmDemandRelateMemberReq(); + attentionDemandRelateMemberReq.setDemandId(uuid); + attentionDemandRelateMemberReq.setType(MemberTypeEnum.ATTENTION.getCode()); + attentionDemandRelateMemberReq.setUserId(userId); + attentionDemandRelateMemberReq.setCreateTime(curDateStr); + attentionDemandRelateMemberReq.setCreator(userId); + allMemberList.add(attentionDemandRelateMemberReq); + if (CollectionUtils.isNotEmpty(allMemberList)) { if (demandMapper.addDemandMember(allMemberList) <= 0) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); @@ -4036,7 +4049,17 @@ public class LyricInternalServiceImpl implements ILyricInternalService { deptName = projectUndertaker + "-" + TECHNOLOGY_CENTER + "-" + STRUCTURE; } // 待调用system的查询部门用户feign接口 - return null; + DeptQueryReq req = new DeptQueryReq(); + req.setDeptName(deptName); + req.setCurrent(1); + req.setSize(1); + log.info("listDept params:{}",req); + SdmResponse>> pageDataRespSdmResponse = sysDeptFeignClient.listDept(req); + SysDeptUserResp sysDeptUserResp = null; + if (pageDataRespSdmResponse.isSuccess()) { + sysDeptUserResp = pageDataRespSdmResponse.getData().getData().get(0); + } + return sysDeptUserResp; } private List syncProjectInfo(LyricVProjectToDM lyricVProjectToDM, Long tenantId, Long userId, String jobNumber, String userName) {