package com.system.online.service.internal;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;

import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.apache.shiro.session.Session;
import org.apache.shiro.session.mgt.eis.EnterpriseCacheSessionDAO;
import org.apache.shiro.subject.PrincipalCollection;
import org.apache.shiro.subject.SimplePrincipalCollection;
import org.apache.shiro.subject.support.DefaultSubjectContext;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.app.base.data.ApiResponseResult;
import com.app.base.data.DataGrid;
import com.system.online.entity.OnlineUser;
import com.system.online.service.OnlineService;
import com.system.user.entity.SysUser;


@Service(value = "onlineService")
@Transactional(propagation = Propagation.REQUIRED)
public class OnlineImpl implements OnlineService {

    @Autowired
    private EnterpriseCacheSessionDAO enterCacheSessionDAO;

    /**
     * 获取在线用户列表
     * @param keyword
     * @param pageRequest
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getlist(String keyword, PageRequest pageRequest) throws Exception{
    	 //获取当前在线session
    	  Collection<Session> sessions = enterCacheSessionDAO.getActiveSessions();
    	  
    	  System.out.println(sessions.size());
    	  List<OnlineUser> list = new ArrayList<>();
    	  Iterator<Session> it = sessions.iterator() ;

    	  while(it.hasNext()) {
    		  try{
    			  Session session = it.next() ;
        		  if (session == null) continue;
        		  SysUser user = new SysUser();
        		  OnlineUser o = new OnlineUser();
        		  //principalCollection 身份
        		  SimplePrincipalCollection principalCollection = new SimplePrincipalCollection();
        		  if (session.getAttribute(DefaultSubjectContext.PRINCIPALS_SESSION_KEY) == null) {
        			  continue;
        		  } else {
        			  principalCollection = (SimplePrincipalCollection) session
        					  .getAttribute(DefaultSubjectContext.PRINCIPALS_SESSION_KEY);
        			  user = (SysUser) principalCollection.getPrimaryPrincipal();
        			  boolean flag = true;//根据查询条件判断是否需要添加到列表
        			  if(StringUtils.isBlank(keyword)){
        				  flag = true;
        			  }else{
//        				  int result1 = user.getUserName().indexOf(keyword);
//        				  int result2 = user.getUserMobile().indexOf(keyword);
                          int result1 = user.getFcode().indexOf(keyword);
                          int result2 = user.getFname().indexOf(keyword);
        				  if((result1 == -1) &&(result2 == -1)){
        					  flag = false;
        				  }else{
        					  flag = true;
        				  }
        			  }
        			  if(flag){
//        				  o.setBsCode(user.getUserCode());
//            			  o.setBsName(user.getUserName());
//            			  o.setId(user.getId());
//            			  o.setMobile(user.getUserMobile());
                          o.setBsCode(user.getFcode());
                          o.setBsName(user.getFname());
                          o.setId(Long.parseLong(user.getFid()));
                          o.setMobile(user.getFcode());
            			  
            			  o.setSessionId(session.getId().toString());
            			  o.setHost(session.getHost());
            			  o.setLastAccessTime(session.getLastAccessTime());
            			  o.setStartTimestamp(session.getStartTimestamp());
            			  list.add(o);
        			  }
        			  
        		  }
        		  
        		  
    		  }catch(Exception e){
    			  continue;
    		  }
    		  
    	  }
    	  DataGrid s = DataGrid.create(list, (int)list.size(), pageRequest.getPageNumber() + 1, pageRequest.getPageSize());
          return ApiResponseResult.success().data(DataGrid.create(list, (int)list.size(), pageRequest.getPageNumber() + 1, pageRequest.getPageSize()));
    }

	@Override
	public ApiResponseResult delete(String sessionId) throws Exception {
		// TODO Auto-generated method stub
		//通过readSession读取session，然后调用delete删除
		 Session session = enterCacheSessionDAO.readSession(sessionId);
		 enterCacheSessionDAO.delete(session);
		return ApiResponseResult.success();
	}
    
}