moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改为使用云信返回在线标识

Browse Source
This commit is contained in:
liaozetao
2023-08-28 16:29:24 +08:00
parent 4d9b5365c1
commit fb8c30976f
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
accompany-business/accompany-business-web/src/main/java/com/accompany/business/controller/recharge/RechargeUserController.java
View File

@@ -1,5 +1,8 @@
package com.accompany.business.controller.recharge;
import cn.hutool.core.collection.CollectionUtil;
import com.accompany.business.service.room.RoomService;
import com.accompany.common.constant.Constant;
import com.accompany.common.result.BusiResult;
import com.accompany.core.service.common.JedisService;
import com.accompany.payment.service.RechargeUserService;
@@ -12,7 +15,9 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.Comparator;
import java.util.List;
import java.util.stream.Collectors;
/**
* @author: liaozetao
@@ -28,7 +33,7 @@ public class RechargeUserController {
private RechargeUserService rechargeUserService;
@Autowired
private JedisService jedisService;
private RoomService roomService;
/**
* 列表
@@ -39,7 +44,14 @@ public class RechargeUserController {
@ApiOperation("列表")
@GetMapping("list")
public BusiResult<List<RechargeUserVo>> list(@RequestParam("regionCode") String regionCode) {
return BusiResult.success(rechargeUserService.selectList(regionCode));
List<RechargeUserVo> list = rechargeUserService.selectList(regionCode);
if (CollectionUtil.isNotEmpty(list)) {
for (RechargeUserVo user : list) {
user.setIsOnline(roomService.isOnline(user.getRoomId(), user.getUid()) ? Constant.Yes1No0.YES : Constant.Yes1No0.NO);
}
}
return BusiResult.success(list.stream().sorted(Comparator.comparing(RechargeUserVo::getIsOnline).reversed().thenComparing(RechargeUserVo::getSeq)).collect(Collectors.toList()));
}
}