package com.tianbo.warehouse.heatbeat;


import com.tianbo.warehouse.dao.KakoUserMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import com.tianbo.warehouse.model.KakoUser;

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

@Component
@Slf4j
public class OfflineTheardJob implements Runnable {

    private static OfflineTheardJob offlineTheardJob;

    private KakoUser user;

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

    @Resource
    private KakoUserMapper userMapper;

    OfflineTheardJob() {

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

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

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

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


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

    private void setOffline(){
        user.setOnline(false);
        int i = offlineTheardJob.userMapper.updateByPrimaryKeySelective(user);
        if (i>0){
            log.info("用户id:{},用户名称:{}，从IP:{}掉线",user.getId(),user.getName(),user.getLoginIp());
        }
    }
}