【探花交友】day06—即时通信（四）

1. /**
2.  * 回复陌生人问题
3.  */
4. @PostMapping("/strangerQuestions")
5. public ResponseEntity replyQuestions(@RequestBody Map map) {
6. //前端传递的userId:是Integer类型的
7. String obj = map.get("userId").toString();
8. Long userId = Long.valueOf(obj);
9. String reply = map.get("reply").toString();
10.     tanhuaService.replyQuestions(userId,reply);
11. return ResponseEntity.ok(null);
12. }

1. //回复陌生人问题
2. public void replyQuestions(Long userId, String reply) {
3. //1、构造消息数据
4. Long currentUserId = UserHolder.getUserId();
5. UserInfo userInfo = userInfoApi.findById(currentUserId);
6. Map map = new HashMap();
7.     map.put("userId",currentUserId);
8.     map.put("huanXinId", Constants.HX_USER_PREFIX+currentUserId);
9.     map.put("nickname",userInfo.getNickname());
10.     map.put("strangerQuestion",strangerQuestions(userId));
11.     map.put("reply",reply);
12. String message = JSON.toJSONString(map);
13. //2、调用template对象，发送消息
14. Boolean aBoolean = template.sendMsg(Constants.HX_USER_PREFIX + userId, message);//1、接受方的环信id，2、消息
15. if(!aBoolean) {
16. throw  new BusinessException(ErrorResult.error());
17.     }
18. }

1. /**
2.  * 添加好友
3.  */
4. @PostMapping("/contacts")
5. public ResponseEntity contacts(@RequestBody Map map) {
6. Long friendId = Long.valueOf(map.get("userId").toString());
7.     messagesService.contacts(friendId);
8. return ResponseEntity.ok(null);
9. }

1. //添加好友关系
2. public void contacts(Long friendId) {
3. //1、将好友关系注册到环信
4. Boolean aBoolean = huanXinTemplate.addContact(Constants.HX_USER_PREFIX + UserHolder.getUserId(),
5.             Constants.HX_USER_PREFIX + friendId);
6. if(!aBoolean) {
7. throw new BusinessException(ErrorResult.error());
8.     }
9. //2、如果注册成功，记录好友关系到mongodb
10.     friendApi.save(UserHolder.getUserId(),friendId);
11. }

1. @Override
2. public void save(Long userId, Long friendId) {
3. //1、保存自己的好友数据
4. Query query1 = Query.query(Criteria.where("userId").is(userId).and("frinedId").is(friendId));
5. //1.1 判断好友关系是否存在
6. if(!mongoTemplate.exists(query1, Friend.class)) {
7. //1.2 如果不存在，保存
8. Friend friend1 = new Friend();
9.         friend1.setUserId(userId);
10.         friend1.setFriendId(friendId);
11.         friend1.setCreated(System.currentTimeMillis());
12.         mongoTemplate.save(friend1);
13.     }
14. //2、保存好友的数据
15. Query query2 = Query.query(Criteria.where("userId").is(friendId).and("frinedId").is(userId));
16. //2.1 判断好友关系是否存在
17. if(!mongoTemplate.exists(query2, Friend.class)) {
18. //2.2 如果不存在，保存
19. Friend friend1 = new Friend();
20.         friend1.setUserId(friendId);
21.         friend1.setFriendId(userId);
22.         friend1.setCreated(System.currentTimeMillis());
23.         mongoTemplate.save(friend1);
24.     }
25. }

1. package com.tanhua.domain.vo;
2. 
3. import lombok.AllArgsConstructor;
4. import lombok.Data;
5. import lombok.NoArgsConstructor;
6. 
7. import java.io.Serializable;
8. 
9. @Data
10. @NoArgsConstructor
11. @AllArgsConstructor
12. public class ContactVo implements Serializable {
13. 
14. private Long id;
15. private String userId;
16. private String avatar;
17. private String nickname;
18. private String gender;
19. private Integer age;
20. private String city;
21. 
22. public static ContactVo init(UserInfo userInfo) {
23. ContactVo vo = new ContactVo();
24. if(userInfo != null) {
25.           BeanUtils.copyProperties(userInfo,vo);
26.           vo.setUserId("hx"+userInfo.getId().toString());
27.         }
28. return vo;
29.     }
30. }

1. /**
2.  * 分页查询联系人列表
3.  */
4. @GetMapping("/contacts")
5. public ResponseEntity contacts(@RequestParam(defaultValue = "1") Integer page,
6.                                @RequestParam(defaultValue = "10") Integer pagesize,
7.                                String keyword) {
8. PageResult pr = messagesService.findFriends(page,pagesize,keyword);
9. return ResponseEntity.ok(pr);
10. }

1. //分页查询联系人列表
2. public PageResult findFriends(Integer page, Integer pagesize, String keyword) {
3. //1、调用API查询当前用户的好友数据 -- List<Friend>
4.     List<Friend> list = friendApi.findByUserId(UserHolder.getUserId(),page,pagesize);
5. if(CollUtil.isEmpty(list)) {
6. return new PageResult();
7.     }
8. //2、提取数据列表中的好友id
9.     List<Long> userIds = CollUtil.getFieldValues(list, "friendId", Long.class);
10. //3、调用UserInfoAPI查询好友的用户详情
11. UserInfo info = new UserInfo();
12.     info.setNickname(keyword);
13.     Map<Long, UserInfo> map = userInfoApi.findByIds(userIds, info);
14. //4、构造VO对象
15.     List<ContactVo> vos = new ArrayList<>();
16. for (Friend friend : list) {
17. UserInfo userInfo = map.get(friend.getFriendId());
18. if(userInfo != null) {
19. ContactVo vo = ContactVo.init(userInfo);
20.             vos.add(vo);
21.         }
22.     }
23. return new PageResult(page,pagesize,0l,vos);
24. }

1. @Override
2. public List<Friend> findByUserId(Long userId, Integer page, Integer pagesize) {
3. Criteria criteria = Criteria.where("userId").is(userId);
4. Query query = Query.query(criteria).skip((page - 1) * pagesize).limit(pagesize)
5.             .with(Sort.by(Sort.Order.desc("created")));
6. return mongoTemplate.find(query,Friend.class);
7. }