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.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.Date;

@Component
@Slf4j
public class OfflineTheardJob implements Runnable {

    private static OfflineTheardJob offlineTheardJob;

    private USERS user;

    //用户掉线判定时间差
    static final long OFFLINE_= 120L;

    @Resource
    private USERSMapper userMapper;

    OfflineTheardJob() {

    }
    OfflineTheardJob(USERS user) {
        this.user = user;
    }

    @PostConstruct
    public void init(){
        offlineTheardJob = this;
    }

    @Override
    public void run(){
        Date userLoginTime = user.loginDate;
        if(userLoginTime!=null){
            long diff= Math.abs(System.currentTimeMillis() - userLoginTime.getTime());
            long s =  diff / 1000;

            log.info("[HEAT-BEAT]-用户{}心跳-时间相差{}秒",user.getUsername(),s);


            if (s > OFFLINE_){
                setOffline();
            }
        }else {
            setOffline();
        }
    }

    private void setOffline(){
        user.setUserStatus(2);
        int i = offlineTheardJob.userMapper.updateByPrimaryKeySelective(user);
        if (i>0){
            log.info("用户id:{},用户名称:{}，从IP:{}掉线",user.getUserId(),user.getUsername(),user.loginIp);
        }
    }
}