添加积分消息队列接口

xx-im/xx-im-api/src/main/java/com/xxfc/platform/im/vo/QuestionListVo.java

@@ -11,4 +11,5 @@ import java.util.List;
 public class QuestionListVo extends ImQuestion {
     List<ImComment> imComment;
     List<ImPraise> imPraise;
+    private boolean isPraise;
 }

xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/biz/ImPraiseBiz.java

@@ -10,11 +10,13 @@ import com.xxfc.platform.im.entity.ImPraise;
 import com.xxfc.platform.im.entity.ImQuestion;
 import com.xxfc.platform.im.mapper.ImPraiseMapper;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.map.HashedMap;
 import org.joda.time.DateTime;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.Map;
 
 @Slf4j
 @Service
@@ -91,4 +93,12 @@ public class ImPraiseBiz extends BaseBiz<ImPraiseMapper, ImPraise> {
         return list;
     }
 
+    public boolean isExist(Long userId, Long questionId) {
+        Map<String, Object> map = new HashedMap<>();
+        map.put("userId", userId);
+        map.put("questionId",questionId);
+        List<ImPraise> list = mapper.selectByUserIdAndQuestionId(map);
+        return list.size() > 0 ? true : false;
+    }
+
 }

xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/biz/ImQuestionBiz.java

@@ -12,6 +12,7 @@ import com.xxfc.platform.im.dto.QuestionParamDto;
 import com.xxfc.platform.im.dto.UpdateTypeEnum;
 import com.xxfc.platform.im.entity.ImQuestion;
 import com.xxfc.platform.im.mapper.ImQuestionMapper;
+import com.xxfc.platform.im.vo.QuestionListVo;
 import com.xxfc.platform.universal.feign.MQSenderFeign;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,6 +29,8 @@ public class ImQuestionBiz extends BaseBiz<ImQuestionMapper, ImQuestion> {
     @Autowired
     MQSenderFeign mqSenderFeign;
 
+    @Autowired
+    ImPraiseBiz imPraiseBiz;
     /**
      * 获取列表
      *
@@ -36,8 +39,9 @@ public class ImQuestionBiz extends BaseBiz<ImQuestionMapper, ImQuestion> {
      */
     public ObjectRestResponse getList(QuestionParamDto questionParamDto) {
         Query query = new Query(questionParamDto);
-        PageDataVO pageDataVO = PageDataVO.pageInfo(query, () -> mapper.getQuestionList(query.getSuper()));
-        return new ObjectRestResponse<>().data(pageDataVO);
+        PageDataVO<QuestionListVo> pageDataVO = PageDataVO.pageInfo(query, () -> mapper.getQuestionList(query.getSuper()));
+        pageDataVO.getData().forEach((a) -> a.setPraise(imPraiseBiz.isExist(a.getUserId(), a.getId())));
+    return new ObjectRestResponse<>().data(pageDataVO);
     }
 
 

xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/mapper/ImPraiseMapper.java

@@ -4,6 +4,7 @@ import com.xxfc.platform.im.entity.ImPraise;
 import tk.mybatis.mapper.common.Mapper;
 
 import java.util.List;
+import java.util.Map;
 
 public interface ImPraiseMapper extends Mapper<ImPraise> {
 
@@ -11,4 +12,6 @@ public interface ImPraiseMapper extends Mapper<ImPraise> {
 
     List<ImPraise> selectByQuestionIdAndTime(ImPraise imPraise);
 
+    List<ImPraise> selectByUserIdAndQuestionId(Map<String, Object> param);
+
 }
\ No newline at end of file

xx-im/xx-im-server/src/main/resources/mapper/ImPraiseMapper.xml

@@ -24,4 +24,10 @@
         where question_id = #{questionId} and is_del = 0 and visible = 1
         and time between #{startTime} and #{endTime}
   </select>
+
+  <select id="selectByUserIdAndQuestionId" resultType="com.xxfc.platform.im.entity.ImPraise" parameterType="java.util.Map">
+      select * from im_praise
+        where question_id = #{questionId} and is_del = 0 and visible = 1
+        and user_id = #{userId}
+  </select>
 </mapper>
\ No newline at end of file