|
|
|
@ -28,6 +28,7 @@ import com.epmet.commons.tools.utils.ConvertUtils; |
|
|
|
import com.epmet.commons.tools.constant.FieldConstant; |
|
|
|
import com.epmet.commons.tools.utils.Result; |
|
|
|
import com.epmet.dto.form.UserResiInfoFormDTO; |
|
|
|
import com.epmet.dto.form.UserResiInfoListFormDTO; |
|
|
|
import com.epmet.dto.result.UserResiInfoResultDTO; |
|
|
|
import com.epmet.modules.feign.EpmetUserFeignClient; |
|
|
|
import com.epmet.modules.group.dao.ResiGroupDao; |
|
|
|
@ -253,21 +254,26 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
if (null == tokenDto) { |
|
|
|
return new Result().error(ModuleConstant.USER_NOT_NULL); |
|
|
|
} |
|
|
|
if(StringUtils.isBlank(groupId)){ |
|
|
|
if (StringUtils.isBlank(groupId)) { |
|
|
|
return new Result<List<ResiTopicInfoResultDTO>>().error(); |
|
|
|
} |
|
|
|
|
|
|
|
//1.查询话题列表
|
|
|
|
List<ResiTopicInfoResultDTO> lastestTenTopics = |
|
|
|
baseDao.getLatestTenTopics(groupId,tokenDto.getUserId()); |
|
|
|
baseDao.getLatestTenTopics(groupId, tokenDto.getUserId()); |
|
|
|
|
|
|
|
//2.遍历存储用户信息
|
|
|
|
ResiGroupEntity group = resiGroupDao.selectById(groupId); |
|
|
|
if(null != group && ModuleConstant.DEL_FLAG.equals(group.getDelFlag())){ |
|
|
|
if(null != lastestTenTopics && lastestTenTopics.size() > 0) { |
|
|
|
|
|
|
|
//2.遍历存储用户信息
|
|
|
|
List<String> userIdList = new ArrayList<>(); |
|
|
|
for (ResiTopicInfoResultDTO topic : lastestTenTopics) { |
|
|
|
userIdList.add(topic.getUserId()); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
UserResiInfoListFormDTO formDTO = new UserResiInfoListFormDTO(); |
|
|
|
formDTO.setUserIdList(userIdList); |
|
|
|
Result<List<UserResiInfoResultDTO>> userResiInfoDTOListResult = epmetUserFeignClient.getUserResiInfoList(formDTO); |
|
|
|
setUserInfo(userResiInfoDTOListResult, lastestTenTopics); |
|
|
|
} |
|
|
|
return new Result<List<ResiTopicInfoResultDTO>>().ok(lastestTenTopics); |
|
|
|
} |
|
|
|
|
|
|
|
@ -294,9 +300,19 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
List<ResiTopicInfoResultDTO> pastTopics = |
|
|
|
baseDao.getPastTopics(topicPageFormDTO); |
|
|
|
|
|
|
|
//2.遍历用户信息
|
|
|
|
|
|
|
|
if (null != pastTopics && pastTopics.size() > 0) { |
|
|
|
|
|
|
|
//2.遍历用户信息
|
|
|
|
List<String> userIdList = new ArrayList<>(); |
|
|
|
for (ResiTopicInfoResultDTO topic : pastTopics) { |
|
|
|
userIdList.add(topic.getUserId()); |
|
|
|
} |
|
|
|
UserResiInfoListFormDTO formDTO = new UserResiInfoListFormDTO(); |
|
|
|
formDTO.setUserIdList(userIdList); |
|
|
|
Result<List<UserResiInfoResultDTO>> userResiInfoDTOListResult = epmetUserFeignClient.getUserResiInfoList(formDTO); |
|
|
|
setUserInfo(userResiInfoDTOListResult, pastTopics); |
|
|
|
} |
|
|
|
return new Result<List<ResiTopicInfoResultDTO>>().ok(pastTopics); |
|
|
|
} |
|
|
|
|
|
|
|
@ -445,7 +461,6 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
//2.查询话题附件
|
|
|
|
QueryWrapper<ResiTopicAttachmentEntity> wrapper = new QueryWrapper<>(); |
|
|
|
wrapper.eq(TopicConstant.TOPIC_ID,topicId); |
|
|
|
//wrapper.eq(TopicConstant.DEL_FLAG,NumConstant.ZERO_STR);
|
|
|
|
wrapper.orderByAsc(TopicConstant.SORT); |
|
|
|
List<ResiTopicAttachmentEntity> attachments = resiTopicAttachmentDao.selectList(wrapper); |
|
|
|
List<String> attachmentUrls = new ArrayList<>(); |
|
|
|
@ -553,4 +568,19 @@ public class ResiTopicServiceImpl extends BaseServiceImpl<ResiTopicDao, ResiTopi |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public void setUserInfo(Result<List<UserResiInfoResultDTO>> userResiInfoDTOListResult,List<ResiTopicInfoResultDTO> topics){ |
|
|
|
if(userResiInfoDTOListResult.success() && null != userResiInfoDTOListResult.getData()){ |
|
|
|
if(userResiInfoDTOListResult.getData().size() > 0){ |
|
|
|
for(UserResiInfoResultDTO resiUser : userResiInfoDTOListResult.getData()){ |
|
|
|
for(ResiTopicInfoResultDTO topic : topics){ |
|
|
|
if(StringUtils.equals(topic.getUserId(),resiUser.getUserId())){ |
|
|
|
topic.setReleaseUserHeadPhoto(resiUser.getHeadPhoto()); |
|
|
|
topic.setReleaseUserName(resiUser.getShowName()); |
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|