package cn.stylefeng.roses.kernel.im.business.controller;
|
|
import cn.hutool.core.lang.Assert;
|
import cn.stylefeng.roses.kernel.im.api.ImServerApi;
|
import cn.stylefeng.roses.kernel.im.api.pojo.request.ImUserModelRequest;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.ResponseData;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.SuccessResponseData;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.ApiResource;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.GetResource;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.PostResource;
|
import io.rong.models.Result;
|
import io.rong.models.response.*;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
|
@Api(tags = "IM接口")
|
@RestController
|
@ApiResource(name = "IM接口")
|
@RequestMapping("/im/server")
|
public class ImServerController {
|
|
@Resource
|
ImServerApi imServerApi;
|
|
@ApiOperation("IM-用户注册")
|
@PostResource(name = "IM-用户注册", path = "/userRegister")
|
public ResponseData<TokenResult> userRegister(@RequestBody ImUserModelRequest req) {
|
TokenResult o = imServerApi.userRegister(req.getId(), req.getName(), req.getPortrait());
|
return new SuccessResponseData(o);
|
}
|
|
@ApiOperation("IM-用户获取")
|
@GetResource(name = "IM-用户获取", path = "/userGet")
|
public ResponseData<UserResult> userGet(String id) {
|
UserResult o = imServerApi.userGet(id);
|
return new SuccessResponseData(o);
|
}
|
|
@ApiOperation("IM-用户更新")
|
@PostResource(name = "IM-用户更新", path = "/userUpdate")
|
public ResponseData<Result> userUpdate(@RequestBody ImUserModelRequest req) {
|
Result o = imServerApi.userUpdate(req.getId(), req.getName(), req.getPortrait());
|
return new SuccessResponseData(o);
|
}
|
|
@ApiOperation("IM-用户在线状态查询")
|
@GetResource(name = "IM用户-在线状态查询", path = "/userCheckOnline")
|
public ResponseData<CheckOnlineResult> userCheckOnline(String id) {
|
CheckOnlineResult o = imServerApi.userCheckOnline(id);
|
return new SuccessResponseData(o);
|
}
|
|
@ApiOperation(value = "IM-获取用户加入的群组")
|
@PostResource(name = "IM-获取用户加入的群组", path = "/groupGetUserGroups")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "userId", value = "用户ID", dataTypeClass = Long.class),
|
})
|
public ResponseData<UserGroupQueryResult> groupGetUserGroups(Long userId) {
|
Assert.notNull(userId, "用户ID不能为空！");
|
UserGroupQueryResult result = imServerApi.groupGetUserGroups(userId.toString());
|
return new SuccessResponseData(result);
|
}
|
|
//@ApiOperation("IM-历史消息")
|
@GetResource(name = "IM-用户历史消息", path = "/historyMessage")
|
public ResponseData<HistoryMessageResult> historyMessage(String date) {
|
HistoryMessageResult o = imServerApi.historyMessage(date);
|
return new SuccessResponseData(o);
|
}
|
|
}
|
