|
@@ -3,6 +3,7 @@ package com.diagbot.facade;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -10,15 +11,21 @@ import org.springframework.beans.factory.annotation.Qualifier;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
+import com.diagbot.client.UserServiceClient;
|
|
|
+import com.diagbot.dto.RelationContactListDTO;
|
|
|
import com.diagbot.dto.RelationNodeDTO;
|
|
|
+import com.diagbot.dto.RespDTO;
|
|
|
import com.diagbot.entity.Relation;
|
|
|
import com.diagbot.exception.CommonErrorCode;
|
|
|
import com.diagbot.exception.CommonException;
|
|
|
import com.diagbot.service.RelationService;
|
|
|
import com.diagbot.service.impl.RelationServiceImpl;
|
|
|
import com.diagbot.util.DateUtil;
|
|
|
+import com.diagbot.util.RespDTOUtil;
|
|
|
import com.diagbot.util.UserUtils;
|
|
|
import com.diagbot.vo.RelationContactDetailVO;
|
|
|
+import com.diagbot.vo.RelationContactListVO;
|
|
|
import com.diagbot.vo.RelationNodeVO;
|
|
|
import com.diagbot.vo.RemoveRelationContactVO;
|
|
|
|
|
@@ -31,10 +38,28 @@ import com.diagbot.vo.RemoveRelationContactVO;
|
|
|
public class RelationContactFacade extends RelationServiceImpl {
|
|
|
|
|
|
@Autowired
|
|
|
- private RelationFacade relationFacade;
|
|
|
- @Autowired
|
|
|
@Qualifier("relationServiceImpl")
|
|
|
private RelationService relationService;
|
|
|
+ @Autowired
|
|
|
+ private UserServiceClient userServiceClient;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 医学术语关联维护-列表
|
|
|
+ * @param relationContactListVO
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public IPage<RelationContactListDTO> relationContactList(RelationContactListVO relationContactListVO) {
|
|
|
+ IPage<RelationContactListDTO> ipage = this.baseMapper.relationContactList(relationContactListVO);
|
|
|
+ if (ipage.getRecords().size() > 0) {
|
|
|
+ List<String> ids = ipage.getRecords().stream().map(i -> i.getOperName()).distinct().collect(Collectors.toList());
|
|
|
+ RespDTO<Map<String, String>> respDTO = userServiceClient.getUserInfoByIds(ids);
|
|
|
+ RespDTOUtil.respNGDealCover(respDTO, "获取用户信息失败");
|
|
|
+ ipage.getRecords().forEach(i -> {
|
|
|
+ i.setOperName(respDTO.data.get(i.getOperName()));
|
|
|
+ });
|
|
|
+ }
|
|
|
+ return ipage;
|
|
|
+ }
|
|
|
|
|
|
/**
|
|
|
* 医学术语关联维护/医学术语多层关联维护/化验子项维护-添加或者编辑
|
|
@@ -74,7 +99,7 @@ public class RelationContactFacade extends RelationServiceImpl {
|
|
|
}else{
|
|
|
relationQe.in("relation_id", relationNodeVO.getNodeList().stream().map(i->i.getRelationId()).distinct().collect(Collectors.toList()));
|
|
|
}
|
|
|
- relationFacade.remove(relationQe);
|
|
|
+ remove(relationQe);
|
|
|
|
|
|
relationNodeVO.getNodeList().forEach(i->{
|
|
|
i.setParentConceptId(relationNodeVO.getConceptId());
|
|
@@ -111,7 +136,7 @@ public class RelationContactFacade extends RelationServiceImpl {
|
|
|
* @return
|
|
|
*/
|
|
|
private List<RelationNodeDTO> repairRelationDataForQuery(Long conceptId,Long relationId){
|
|
|
- List<RelationNodeDTO> relationNodeDTOList = relationFacade.getBaseMapper().getRelationNodeDTOs(conceptId, relationId);
|
|
|
+ List<RelationNodeDTO> relationNodeDTOList = this.baseMapper.getRelationNodeDTOs(conceptId, relationId);
|
|
|
|
|
|
relationNodeDTOList.forEach(i->{
|
|
|
i.setNodeList(repairRelationDataForQuery(i.getConceptId(), relationId));
|
|
@@ -140,7 +165,7 @@ public class RelationContactFacade extends RelationServiceImpl {
|
|
|
QueryWrapper<Relation> relationQe = new QueryWrapper<>();
|
|
|
relationQe.eq("end_id", conceptId);
|
|
|
relationQe.eq(relationId!=null,"relation_id", relationId);
|
|
|
- List<Relation> relationList = relationFacade.list(relationQe);
|
|
|
+ List<Relation> relationList = list(relationQe);
|
|
|
|
|
|
if(relationList.size()==0){
|
|
|
return;
|
|
@@ -162,7 +187,7 @@ public class RelationContactFacade extends RelationServiceImpl {
|
|
|
|
|
|
Relation relation = new Relation();
|
|
|
relation.setIsDeleted(isDeleted);
|
|
|
- if(!relationFacade.update(relation, relationQe)){
|
|
|
+ if(!update(relation, relationQe)){
|
|
|
throw new CommonException(CommonErrorCode.SERVER_IS_ERROR);
|
|
|
}
|
|
|
|