新增互关关系判断

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/MessageServiceImpl.java

@@ -9,14 +9,18 @@ import com.wwdz.ch.core.util.CacheUtil;
 import com.wwdz.ch.core.util.DateTimeUtil;
 import com.wwdz.ch.core.util.MediaUtil;
 import com.wwdz.ch.core.util.StringUtil;
+import com.wwdz.ch.db.dao.FollowFansRecordDao;
 import com.wwdz.ch.db.dao.ItemDao;
 import com.wwdz.ch.db.dao.MessageContentDao;
 import com.wwdz.ch.db.dao.MessageRecordDao;
+import com.wwdz.ch.db.domain.FollowFansRecord;
 import com.wwdz.ch.db.domain.Item;
 import com.wwdz.ch.db.domain.MessageContent;
 import com.wwdz.ch.db.domain.MessageRecord;
 import com.wwdz.ch.db.dto.MessageRecordRequestDto;
+import com.wwdz.ch.db.dto.request.FollowFansRecordRequestDto;
 import com.wwdz.ch.wx.entity.request.MessageRequestDto;
+import com.wwdz.ch.wx.entity.vo.FollowFansRecordVo;
 import com.wwdz.ch.wx.entity.vo.MessageVo;
 import com.wwdz.ch.wx.service.MessageService;
 import com.xxdxxs.entity.Entity;
@@ -48,6 +52,9 @@ public class MessageServiceImpl implements MessageService {
     @Autowired
     MessageContentDao messageContentDao;
 
+    @Autowired
+    FollowFansRecordDao followFansRecordDao;
+
     @Autowired
     ItemDao itemDao;
 
@@ -142,6 +149,18 @@ public class MessageServiceImpl implements MessageService {
                 }
                 else if (MessageEnum.TypeEnum.FOLLOW.getCode() == m.getType().intValue()) {
                     contentMap.put("msg", "关注了您");
+                    //查询关注的人
+                    FollowFansRecordRequestDto dto = new FollowFansRecordRequestDto();
+                    dto.setFansId(messageRequestDto.getReceiverId());
+                    List<FollowFansRecord> followFansRecordList = followFansRecordDao.findList(dto);
+                    List<Long> followerIdList = followFansRecordList.stream().map(FollowFansRecord::getFollowerId).collect(Collectors.toList());
+                    if (followerIdList.contains(messageContentMap.get(m.getMessageId()).getSenderId())) {
+                        contentMap.put("relation", "互相关注");
+                        contentMap.put("isFollowed", true);
+                    } else {
+                        contentMap.put("relation", "回关");
+                        contentMap.put("isFollowed", false);
+                    }
                 }
                 contentMap.put("time", time);
                 messageVo.setContent(contentMap);