好友接口

game-api/pom.xml

@@ -23,6 +23,12 @@
             <artifactId>common</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+
+        <dependency>
+            <groupId>com.easemob.im</groupId>
+            <artifactId>im-sdk-core</artifactId>
+            <version>0.5.2</version>
+        </dependency>
     </dependencies>
 
     <build>

game-api/src/main/java/com/antai/sport/http/server/game/api/business/sport/social/controller/FriendsController.java

+package com.antai.sport.http.server.game.api.business.sport.social.controller;
+
+import com.antai.sport.http.server.common.annotation.LoginSportUser;
+import com.antai.sport.http.server.common.base.Result;
+import com.antai.sport.http.server.game.api.business.sport.social.service.FriendsService;
+import com.antai.sport.http.server.repository.sport.entity.SportUser;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+import static com.antai.sport.http.server.common.util.ResultUtil.success;
+
+@RestController
+@Api(tags = {"社交相关接口"})
+@RequestMapping("/friends")
+public class FriendsController {
+
+    @Resource
+    private FriendsService friendsService;
+
+    @ApiOperation(value = "获取好友列表", notes = "结果为好友id数组")
+    @GetMapping
+    public ResponseEntity<Result<List<Long>>> getFriends(@LoginSportUser SportUser loginUser) {
+        return success(friendsService.getFriends(loginUser));
+    }
+}

game-api/src/main/java/com/antai/sport/http/server/game/api/business/sport/social/mapper/SportUserFriendsBusinessMapper.java

+package com.antai.sport.http.server.game.api.business.sport.social.mapper;
+
+import java.util.List;
+
+public interface SportUserFriendsBusinessMapper {
+    List<Long> getFriends(Long sportUserId);
+}

game-api/src/main/java/com/antai/sport/http/server/game/api/business/sport/social/service/FriendsService.java

+package com.antai.sport.http.server.game.api.business.sport.social.service;
+
+import com.antai.sport.http.server.common.annotation.LoginSportUser;
+import com.antai.sport.http.server.game.api.business.sport.social.mapper.SportUserFriendsBusinessMapper;
+import com.antai.sport.http.server.repository.sport.entity.SportUser;
+import com.antai.sport.http.server.repository.sport.mapper.SportUserFriendsMapper;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Service
+public class FriendsService {
+
+    @Resource
+    private SportUserFriendsMapper sportUserFriendsMapper;
+    @Resource
+    private SportUserFriendsBusinessMapper sportUserFriendsBusinessMapper;
+
+    public List<Long> getFriends(@LoginSportUser SportUser loginUser) {
+        return sportUserFriendsBusinessMapper.getFriends(loginUser.getId());
+    }
+
+}

game-api/src/main/java/com/antai/sport/http/server/game/api/business/test/TestController.java

+package com.antai.sport.http.server.game.api.business.test;
+
+import com.easemob.im.server.EMException;
+import com.easemob.im.server.EMService;
+import com.easemob.im.server.model.EMUser;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+@RestController
+@RequestMapping("test")
+public class TestController {
+
+    @Resource
+    private EMService emService;
+
+    @GetMapping("/create/{username}/{password}")
+    public void testCreateUser(@PathVariable String username, @PathVariable String password) {
+        try {
+            EMUser user = emService.user().create(username, password).block();
+            System.out.println(emService.token().getAppToken().block().getValue());
+            System.out.println(emService.token().getAppToken().block().getExpireAt());
+        } catch (EMException e) {
+            e.getMessage();
+        }
+    }
+
+}

game-api/src/main/java/com/antai/sport/http/server/game/api/config/MessageConfig.java

+package com.antai.sport.http.server.game.api.config;
+
+import com.easemob.im.server.EMProperties;
+import com.easemob.im.server.EMService;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class MessageConfig {
+
+    @Bean
+    public EMService emService() {
+        EMProperties properties = EMProperties.builder()
+                .setAppkey("1108220328100529#lobofit")
+                .setClientId("YXA6v5gWa6s7QeeXXRw51KcwiQ")
+                .setClientSecret("YXA6vn7qiYnSvz87ediPGHCDE_GDcPM")
+                .setAgoraTokenExpireInSeconds(100)
+                .build();
+
+        return new EMService(properties);
+    }
+}

game-api/src/main/resources/application.yaml

@@ -49,6 +49,7 @@ project:
     - /match/bicycle/*
     - /match/bicycle/player/record
     - /match/bicycle/auto/create
+    - /test/**
 
 swagger:
   enable: false

game-api/src/main/resources/mapper/sport/social/SportUserFriendsBusinessMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.antai.sport.http.server.game.api.business.sport.social.mapper.SportUserFriendsBusinessMapper">
+    <select id="getFriends"
+            resultType="java.lang.Long">
+        select friend_id
+        from sport_user_friends
+        where deleted = 0
+          and sport_user_id = #{sportUserId}
+    </select>
+
+</mapper>

profile/src/main/resources/application-common-db-dev.yml

@@ -11,4 +11,5 @@ logging:
   level:
     root: info
     com.antai.sport.http.server.repository: debug
+    com.easemob.im.http: debug
 

repository/src/main/java/com/antai/sport/http/server/repository/sport/entity/SportUserFriendRequest.java

+package com.antai.sport.http.server.repository.sport.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author liming
+ * @since 2022-03-30
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class SportUserFriendRequest implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 发起人
+     */
+    private Long sportUserId;
+
+    /**
+     * 目标用户id
+     */
+    private Long targetUserId;
+
+    /**
+     * 状态 10:待接收 20:已接受 30:已拒绝
+     */
+    private Integer status;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 排序号
+     */
+    private Integer showOrder;
+
+    /**
+     * 数据版本号
+     */
+    private Integer version;
+
+    /**
+     * 删除标记
+     */
+    private Integer deleted;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime ctDate;
+
+    /**
+     * 最后修改人
+     */
+    private Integer lmUserId;
+
+    /**
+     * 最后修改时间
+     */
+    private LocalDateTime lmDate;
+
+
+}

repository/src/main/java/com/antai/sport/http/server/repository/sport/entity/SportUserFriends.java

+package com.antai.sport.http.server.repository.sport.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author liming
+ * @since 2022-03-30
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class SportUserFriends implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 用户id
+     */
+    private Long sportUserId;
+
+    /**
+     * 好友id
+     */
+    private Long friendId;
+
+    /**
+     * 状态 1:单方面好友 2:互为好友
+     */
+    private Integer status;
+
+    /**
+     * 排序号
+     */
+    private Integer showOrder;
+
+    /**
+     * 数据版本号
+     */
+    private Integer version;
+
+    /**
+     * 删除标记
+     */
+    private Integer deleted;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime ctDate;
+
+    /**
+     * 最后修改人
+     */
+    private Integer lmUserId;
+
+    /**
+     * 最后修改时间
+     */
+    private LocalDateTime lmDate;
+
+
+}

repository/src/main/java/com/antai/sport/http/server/repository/sport/mapper/SportUserFriendRequestMapper.java

+package com.antai.sport.http.server.repository.sport.mapper;
+
+import com.antai.sport.http.server.repository.sport.entity.SportUserFriendRequest;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author liming
+ * @since 2022-03-30
+ */
+public interface SportUserFriendRequestMapper extends BaseMapper<SportUserFriendRequest> {
+
+}

repository/src/main/java/com/antai/sport/http/server/repository/sport/mapper/SportUserFriendsMapper.java

+package com.antai.sport.http.server.repository.sport.mapper;
+
+import com.antai.sport.http.server.repository.sport.entity.SportUserFriends;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author liming
+ * @since 2022-03-30
+ */
+public interface SportUserFriendsMapper extends BaseMapper<SportUserFriends> {
+
+}

repository/src/main/resources/mapper/sport/SportUserFriendRequestMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.antai.sport.http.server.repository.sport.mapper.SportUserFriendRequestMapper">
+
+</mapper>

repository/src/main/resources/mapper/sport/SportUserFriendsMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.antai.sport.http.server.repository.sport.mapper.SportUserFriendsMapper">
+
+</mapper>