Commit b190d409 authored by jiaorz's avatar jiaorz

添加积分消息队列接口

parent cf3cb901
...@@ -93,7 +93,7 @@ public class ImPraiseBiz extends BaseBiz<ImPraiseMapper, ImPraise> { ...@@ -93,7 +93,7 @@ public class ImPraiseBiz extends BaseBiz<ImPraiseMapper, ImPraise> {
return list; return list;
} }
public boolean isExist(Long userId, Long questionId) { public boolean isExist(Integer userId, Long questionId) {
Map<String, Object> map = new HashedMap<>(); Map<String, Object> map = new HashedMap<>();
map.put("userId", userId); map.put("userId", userId);
map.put("questionId",questionId); map.put("questionId",questionId);
......
...@@ -40,7 +40,11 @@ public class ImQuestionBiz extends BaseBiz<ImQuestionMapper, ImQuestion> { ...@@ -40,7 +40,11 @@ public class ImQuestionBiz extends BaseBiz<ImQuestionMapper, ImQuestion> {
public ObjectRestResponse getList(QuestionParamDto questionParamDto) { public ObjectRestResponse getList(QuestionParamDto questionParamDto) {
Query query = new Query(questionParamDto); Query query = new Query(questionParamDto);
PageDataVO<QuestionListVo> pageDataVO = PageDataVO.pageInfo(query, () -> mapper.getQuestionList(query.getSuper())); PageDataVO<QuestionListVo> pageDataVO = PageDataVO.pageInfo(query, () -> mapper.getQuestionList(query.getSuper()));
pageDataVO.getData().forEach((a) -> a.setPraise(imPraiseBiz.isExist(a.getUserId(), a.getId()))); AppUserDTO appUserDTO = userBiz.getUserInfo();
if(appUserDTO != null) {
pageDataVO.getData().forEach((a) -> a.setPraise(imPraiseBiz.isExist(appUserDTO.getUserid(), a.getId())));
}
return new ObjectRestResponse<>().data(pageDataVO); return new ObjectRestResponse<>().data(pageDataVO);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment