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 appOnlineState = sysUser.getAppOnlineState().equals("1");
                    Boolean online = rongCloudService.checkOnline(sysUser.getUserId());
                    if (!appOnlineState.equals(online)) {
                        sysUser.setAppOnlineState(online ? "1" : "0");
                        sysUserService.updateUserProfile(sysUser);
                    }
                }
            }
        } catch (Exception ex) {
            log.error("融云在线接口异常：" + ex.getMessage());
        }
    }
}