package com.tianbo.warehouse.heartbeat;

import com.tianbo.warehouse.dao.USERSMapper;
import com.tianbo.warehouse.model.USERS;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * 清理心跳超时的在线用户,判定为离线
 * @author xyh
 * @date
 * 记得给用户ID，用户名称，用户心跳时间，用户登录ip，用户在线状态的数据库字段设置索引。
 */
@Slf4j
@Component
public class OfflineUserTask {


    @Resource
    private USERSMapper userMapper;

    @Scheduled(fixedRate = 60000)
    private void offlineUserHeartBeat(){

        //初始化线程池
        ThreadPoolExecutor threadPool = XMLThreadPoolFactory.instance();

        List<USERS> userList = userMapper.selectOnlineUser();
        if (userList!=null &&  !userList.isEmpty()){
            log.trace("用户掉线判定开始,共需判定{}个在线标识用户",userList.size());
            for (USERS user:userList) {
                OfflineTheardJob offlineTheardJob = new OfflineTheardJob(user);
                threadPool.execute(offlineTheardJob);
            }
        }

    }
}