package com.landtool.lanbase.modules.sys.redis;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.BiConsumer;
import java.util.function.Consumer;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;

import org.apache.shiro.SecurityUtils;
import org.apache.shiro.session.Session;
import org.apache.shiro.session.mgt.eis.MemorySessionDAO;
import org.apache.shiro.subject.SimplePrincipalCollection;
import org.apache.shiro.subject.Subject;
import org.apache.shiro.subject.support.DefaultSubjectContext;
import org.apache.shiro.web.mgt.DefaultWebSecurityManager;
import org.apache.shiro.web.session.mgt.DefaultWebSessionManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.landtool.lanbase.common.shiro.ShiroToken;
import com.landtool.lanbase.common.utils.RedisUtils;
import com.landtool.lanbase.common.utils.ShiroUtils;
import com.landtool.lanbase.modules.log.entity.LogAction;
import com.landtool.lanbase.modules.log.service.LogActionService;
/**
 * redis人员在线
 * @author zsx
 *
 */
@Component
public class OnlineUserRedis {
	
	private static final String NAME = "onlineuser";

	@Autowired
	private RedisUtils redisUtils;
	


	
	@Autowired
	private LogActionService logservice;
	
	SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

//	/**
//	 * 从session中获取记录的验证码
//	 */
//	private Session getSessionByUsername(String username) {
//		DefaultWebSecurityManager securityManager=(DefaultWebSecurityManager) SecurityUtils.getSecurityManager();
//		DefaultWebSessionManager sessionManager=(DefaultWebSessionManager) securityManager.getSessionManager();
//		Collection<Session> sessions=sessionManager.getSessionDAO().getActiveSessions();
//		Object attribute;
//		String user;
//		Session ses = null;
//	     for(Session session:sessions){
//	    	 attribute=session.getAttribute(DefaultSubjectContext.PRINCIPALS_SESSION_KEY);
//	    	 user=((SimplePrincipalCollection) attribute).toString();
//	    	 if(user.equals(username)){
//	    		 ses=session;
//	    		 session.stop();
//	    		 break;
//	    		
//	    	 }
//	     }
//	     return ses;
//	}
//	
	public void removeDownlineUser(){

		
		if(redisUtils.exists(NAME)){
			ConcurrentHashMap infos=redisUtils.get(NAME,ConcurrentHashMap.class );	
			 Iterator it=  infos.keySet().iterator();
			 while(it.hasNext()){
			    Object key=	 it.next();
			    String sessioninfo=   (String) infos.get(key);
			    JSONObject json=JSON.parseObject(sessioninfo);
			    Double temp=json.getDouble("time");
			    //这里与用户最后一次操作时间进行判断
			    Map<String,Object>  map=new HashMap<>();
			    map.put("UserName", json.getString("username"));
			    map.put("appid", 1);
			    map.put("lowerOffset", 0);
			    map.put("limit", 1);
			 List<LogAction>  list= logservice.queryList(map);
			 if(list!=null&!list.isEmpty()){
				 if((System.currentTimeMillis()-list.get(0).getDodate().getTime())>10*1000 && 
						 (System.currentTimeMillis()-temp)>10*1000 ){
					 infos.remove(key);
					 
			     }
			 }
			 }
				redisUtils.set(NAME, infos);
		}
	}
	
	public void saveOnlineUser(String username,Session session){
		if(redisUtils.exists("onlineuser")){
			ConcurrentHashMap<String,Object> infos=redisUtils.get("onlineuser",ConcurrentHashMap.class );
			JSONObject json=new JSONObject();
			List<String> needtoremove=new ArrayList<String>();
			 json.put("time", new Long(System.currentTimeMillis()));
			 json.put("username",username);
				
				infos.forEach(new BiConsumer<String, Object>() {

					@Override
					public void accept(String t, Object u) {
						JSONObject json=JSONObject.parseObject(u.toString());
						if(json.getString("username").equals(username)){
  						needtoremove.add(t);
						}
						
					}
				});
				if(!needtoremove.isEmpty()){
					needtoremove.forEach(new Consumer<String>() {

						@Override
						public void accept(String t) {
							infos.remove(t);
							
						}
					});
				
				}
				infos.put(session.getId().toString(), json.toJSONString());	
				redisUtils.set("onlineuser", infos);
		}else{
		ConcurrentHashMap<String,Object> onlineuser=new ConcurrentHashMap<String,Object>();	
		JSONObject json=new JSONObject();
		 json.put("time", new Long(System.currentTimeMillis()));
		 json.put("username",username);
		 onlineuser.put(session.getId().toString(), json.toJSONString());	
			redisUtils.set("onlineuser", onlineuser);
		}

	}
	
	public void cleanLogoutUser(Session session){
		if(redisUtils.exists("onlineuser")){
			ConcurrentHashMap infos=redisUtils.get("onlineuser",ConcurrentHashMap.class );
				infos.remove(session.getId().toString());	
				redisUtils.set("onlineuser", infos);
		}

	}
	
	
}