package com.ruoyi.quartz.task;
|
|
import com.ruoyi.app.position.domain.ArdAppPosition;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.rongcloud.service.RongCloudService;
|
import com.ruoyi.system.service.ISysUserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @Description: 融云任务类
|
* @ClassName: RongCloudTask
|
* @Author: 刘苏义
|
* @Date: 2023年07月28日13:18:22
|
* @Version: 1.0
|
**/
|
@Component("RongCloudTask")
|
@Slf4j
|
public class RongCloudTask {
|
|
@Resource
|
ISysUserService sysUserService;
|
@Resource
|
RongCloudService rongCloudService;
|
/**
|
* 定时获取app用户在线状态
|
* 刘苏义
|
* 2023/8/9 9:17:48
|
*/
|
public void getAppUserOnlineStateTask() {
|
|
try {
|
List<SysUser> SysUserList = sysUserService.selectAllAppUserList(new SysUser());
|
if (SysUserList.size() > 0) {
|
for (SysUser sysUser : SysUserList) {
|
Boolean online = rongCloudService.checkOnline(sysUser.getUserId());
|
if (online) {
|
sysUser.setAppOnlineState("1");
|
} else {
|
sysUser.setAppOnlineState("0");
|
}
|
sysUserService.updateUserProfile(sysUser);
|
}
|
}
|
} catch (Exception ex) {
|
log.error("融云在线接口异常：" + ex.getMessage());
|
}
|
}
|
}
|
