【探花交友】day07—搜附近（二）

1. package com.tanhua.dubbo.api;
2. 
3. public interface UserLikeApi {
4. 
5. //保存或者更新
6.     Boolean saveOrUpdate(Long userId, Long likeUserId, boolean isLike);
7. }

1. @DubboService
2. public class UserLikeApiImpl implements UserLikeApi{
3. 
4. @Autowired
5. private MongoTemplate mongoTemplate;
6. 
7. @Override
8. public Boolean saveOrUpdate(Long userId, Long likeUserId, boolean isLike) {
9. try {
10. //1、查询数据
11. Query query = Query.query(Criteria.where("userId").is(userId).and("likeUserId").is(likeUserId));
12. UserLike userLike = mongoTemplate.findOne(query, UserLike.class);
13. //2、如果不存在，保存
14. if(userLike == null) {
15.                 userLike = new UserLike();
16.                 userLike.setUserId(userId);
17.                 userLike.setLikeUserId(likeUserId);
18.                 userLike.setCreated(System.currentTimeMillis());
19.                 userLike.setUpdated(System.currentTimeMillis());
20.                 userLike.setIsLike(isLike);
21.                 mongoTemplate.save(userLike);
22.             }else {
23. //3、更新
24. Update update = Update.update("isLike", isLike)
25.                         .set("updated",System.currentTimeMillis());
26.                 mongoTemplate.updateFirst(query,update,UserLike.class);
27.             }
28. return true;
29.         } catch (Exception e) {
30.             e.printStackTrace();
31. return false;
32.         }
33.     }
34. }

1. /**
2.  * 喜欢
3.  */
4. @GetMapping("{id}/love")
5. public ResponseEntity<Void> likeUser(@PathVariable("id") Long likeUserId) {
6. this.tanhuaService.likeUser(likeUserId);
7. return ResponseEntity.ok(null);
8. }
9. 
10. /**
11.  * 不喜欢
12.  */
13. @GetMapping("{id}/unlove")
14. public ResponseEntity<Void> notLikeUser(@PathVariable("id") Long likeUserId) {
15. this.tanhuaService.notLikeUser(likeUserId);
16. return ResponseEntity.ok(null);
17. }

1. @Autowired
2. private MessagesService messagesService;
3. 
4. //探花喜欢 106 -  2
5. public void likeUser(Long likeUserId) {
6. //1、调用API，保存喜欢数据(保存到MongoDB中)
7. Boolean save = userLikeApi.saveOrUpdate(UserHolder.getUserId(),likeUserId,true);
8. if(!save) {
9. //失败
10. throw new BusinessException(ErrorResult.error());
11.         }
12. //2、操作redis，写入喜欢的数据，删除不喜欢的数据 (喜欢的集合，不喜欢的集合)
13.         redisTemplate.opsForSet().remove(Constants.USER_NOT_LIKE_KEY+UserHolder.getUserId(),likeUserId.toString());
14.         redisTemplate.opsForSet().add(Constants.USER_LIKE_KEY+UserHolder.getUserId(),likeUserId.toString());
15. //3、判断是否双向喜欢
16. if(isLike(likeUserId,UserHolder.getUserId())) {
17. //4、添加好友
18.             messagesService.contacts(likeUserId);
19.         }
20.     }
21. 
22. public Boolean isLike(Long userId,Long likeUserId) {
23. String key = Constants.USER_LIKE_KEY+userId;
24. return redisTemplate.opsForSet().isMember(key,likeUserId.toString());
25.     }
26. 
27. //不喜欢
28. public void notLikeUser(Long likeUserId) {
29. //1、调用API，保存喜欢数据(保存到MongoDB中)
30. Boolean save = userLikeApi.saveOrUpdate(UserHolder.getUserId(),likeUserId,false);
31. if(!save) {
32. //失败
33. throw new BusinessException(ErrorResult.error());
34.         }
35. //2、操作redis，写入喜欢的数据，删除不喜欢的数据 (喜欢的集合，不喜欢的集合)
36.         redisTemplate.opsForSet().add(Constants.USER_NOT_LIKE_KEY+UserHolder.getUserId(),likeUserId.toString());
37.         redisTemplate.opsForSet().remove(Constants.USER_LIKE_KEY+UserHolder.getUserId(),likeUserId.toString());
38. //3、判断是否双向喜欢，删除好友(各位自行实现)
39.     }

{ type: "Point", coordinates: [ 40, 5 ] }

{ type: "LineString", coordinates: [ [ 40, 5 ], [ 41, 6 ] ] }

1. {
2.   type: "Polygon",
3.   coordinates: [ [ [ 0 , 0 ] , [ 3 , 6 ] , [ 6 , 1 ] , [ 0 , 0  ] ] ]
4. }

1. @Test
2. public void testNear() {
3. //构造坐标点
4. GeoJsonPoint point = new GeoJsonPoint(116.404, 39.915);
5. //构造半径
6. Distance distanceObj = new Distance(1, Metrics.KILOMETERS);
7. //画了一个圆圈
8. Circle circle = new Circle(point, distanceObj);
9. //构造query对象
10. Query query = Query.query(Criteria.where("location").withinSphere(circle));
11. //省略其他内容
12.     List<Places> list = mongoTemplate.find(query, Places.class);
13.     list.forEach(System.out::println);
14. }

1. //查询附近且获取间距
2. @Test
3. public void testNear1() {
4. //1、构造中心点(圆点)
5. GeoJsonPoint point = new GeoJsonPoint(116.404, 39.915);
6. //2、构建NearQuery对象
7. NearQuery query = NearQuery.near(point, Metrics.KILOMETERS).maxDistance(1, Metrics.KILOMETERS);
8. //3、调用mongoTemplate的geoNear方法查询
9.     GeoResults<Places> results = mongoTemplate.geoNear(query, Places.class);
10. //4、解析GeoResult对象，获取距离和数据
11. for (GeoResult<Places> result : results) {
12. Places places = result.getContent();
13. double value = result.getDistance().getValue();
14.         System.out.println(places+"---距离："+value + "km");
15.     }
16. }