package com.ots.framework.shiro.session;
import com.ots.framework.manager.AsyncManager;
import com.ots.framework.manager.factory.AsyncFactory;
import com.ots.project.monitor.online.domain.OnlineSession;
import com.ots.project.monitor.online.domain.UserOnline;
import com.ots.project.monitor.online.service.IUserOnlineService;
import org.apache.shiro.session.Session;
import org.apache.shiro.session.UnknownSessionException;
import org.apache.shiro.session.mgt.eis.EnterpriseCacheSessionDAO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import java.io.Serializable;
import java.util.Date;

public class OnlineSessionDAO extends EnterpriseCacheSessionDAO {
    
    @Value("${shiro.session.dbSyncPeriod}")
    private int dbSyncPeriod;
    
    private static final String LAST_SYNC_DB_TIMESTAMP = OnlineSessionDAO.class.getName() + "LAST_SYNC_DB_TIMESTAMP";
    @Autowired
    private IUserOnlineService onlineService;
    @Autowired
    private OnlineSessionFactory onlineSessionFactory;
    public OnlineSessionDAO() {
        super();
    }
    public OnlineSessionDAO(long expireTime) {
        super();
    }
    
    @Override
    protected Session doReadSession(Serializable sessionId) {
        UserOnline userOnline = onlineService.selectOnlineById(String.valueOf(sessionId));
        if (userOnline == null) {
            return null;
        }
        return onlineSessionFactory.createSession(userOnline);
    }
    @Override
    public void update(Session session) throws UnknownSessionException {
        super.update(session);
    }
    
    public void syncToDb(OnlineSession onlineSession) {
        Date lastSyncTimestamp = (Date) onlineSession.getAttribute(LAST_SYNC_DB_TIMESTAMP);
        if (lastSyncTimestamp != null) {
            boolean needSync = true;
            long deltaTime = onlineSession.getLastAccessTime().getTime() - lastSyncTimestamp.getTime();
            if (deltaTime < dbSyncPeriod * 60 * 1000) {
                
                needSync = false;
            }
            
            boolean isGuest = onlineSession.getUserId() == null || onlineSession.getUserId() == 0L;
            
            if (isGuest == false && onlineSession.isAttributeChanged()) {
                needSync = true;
            }
            if (needSync == false) {
                return;
            }
        }
        
        onlineSession.setAttribute(LAST_SYNC_DB_TIMESTAMP, onlineSession.getLastAccessTime());
        
        if (onlineSession.isAttributeChanged()) {
            onlineSession.resetAttributeChanged();
        }
        AsyncManager.me().execute(AsyncFactory.syncSessionToDb(onlineSession));
    }
    
    @Override
    protected void doDelete(Session session) {
        OnlineSession onlineSession = (OnlineSession) session;
        if (null == onlineSession) {
            return;
        }
        onlineSession.setStatus(OnlineSession.OnlineStatus.off_line);
        onlineService.deleteOnlineById(String.valueOf(onlineSession.getId()));
    }
}