package com.nome.plugin.layim;

import static org.hamcrest.CoreMatchers.nullValue;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;

import com.sun.org.apache.bcel.internal.generic.NEW;

import net.sf.json.JSONObject;
//userName猜测是个任意字符串
import oracle.net.aso.a;
@ServerEndpoint("/LL_ws/{userName}")
public class LLWebSocket {
    private static int onlineCount = 0;
   // public static Map<String,Session> mapUS=new HashMap<String,Session>();//根据用户找session
   // public static Map<Session,String> mapSU=new HashMap<Session,String>();//根据session找用户
    //ConcurrentHashMap是线程安全的，而HashMap是线程不安全的。
    public static ConcurrentHashMap<String,Session> mapUS = new ConcurrentHashMap<String,Session>(); 
    private static ConcurrentHashMap<Session,String> mapSU = new ConcurrentHashMap<Session,String>();

/**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session,@PathParam("userName") String userName){
     //this.session=session;
     mapUS.put(userName,session);
     mapSU.put(session,userName);
     //上线通知由客户端自主发起
     onlineCount++;           //在线数加1
        System.out.println("用户"+userName+"进入wsll！当前在线人数为" + onlineCount);
       
       
    }
    
    /**
     * 连接关闭调用的方法
     */
 @OnClose
    public void onClose(Session session){
     String userName=mapSU.get(session);
     if(userName!=null&&userName!=""){
         //下线通知
         JSONObject jsonObject=new JSONObject();
         jsonObject.put("type", 3);
         jsonObject.put("userName", userName);
         jsonObject.put("contentType", "offline");
         jsonObject.put("to", "all");
         String jsonString=jsonObject.toString();
         for(Session s:session.getOpenSessions()){//循环发给所有在线的人
       s.getAsyncRemote().sendText(jsonString);
      }
         onlineCount--;           //在线数减1   
            System.out.println("用户"+userName+"退出wsll！当前在线人数为" + onlineCount);
         mapUS.remove(userName);
         mapSU.remove(session);
     }
    }
    /**
     * 收到客户端消息后调用的方法
     */
 static Map offLineDB = new HashMap();
 
 @OnMessage
    public void onMessage(String message,Session session) {
        //System.out.println("来自客户端的消息:" + message);
        JSONObject jsonObject=JSONObject.fromObject(message);
        int type = jsonObject.getInt("type");
        String to=jsonObject.getString("to");
        jsonObject.remove("to");
        //if(type==0||to==null||to==""){return ;}
       
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式
        String time=df.format(new Date());// new Date()为获取当前系统时间
        jsonObject.put("time", time);
       
        Session socketoffline_to=mapUS.get(to);
        if(socketoffline_to==null||"".equals(socketoffline_to))
        {
         //离线消息，A给B发的消息格式
         //以下内容来自message这个代码
         //{"type":1,"userName":"贤心_100001","contentType":"online","to":"纸飞机_100000","from":{"username":"贤心","avatar":"http://cdn.firstlinkapp.com/upload/2016_6/1465575923433_33812.jpg","id":"100001","mine":true,"content":"4444444444444444"}}
            //离线表：ID 内容 就是上面那个message   接收人就是 to   状态未读
         //当B进入页面在线的时候，通过ajax获取自己的维度消息表，这时候吧状态改成已读
         //ajax未读消息返回 格式如上寸的那个{"type":1,"userName":"....
         
/*         ("username":鲁涛，内容：123，to：小黄，state：1)
         ("username":鲁涛，内容：456，to：小黄)
         ("username":鲁涛，内容：444，to：小黄)
         
         
         ("username":123，内容：456，to：ZZ黄)
         */
         List offcontentList =null;
         String userName = jsonObject.getString("userName");
         String from = jsonObject.getString("from");
           JSONObject fromObject=JSONObject.fromObject(from);
           String content=fromObject.getString("content");
         offcontentList=(List) offLineDB.get(userName);
         if(offcontentList==null)
         {
          offcontentList=new ArrayList<String>();
          
         }
          offcontentList.add(content);
          
   
         offLineDB.put(userName, offcontentList);
         
         
         return;
        }
       
 
      switch (type) {
  case 1://单聊
   Session session_to=mapUS.get(to);
         if(session_to!=null){
          session_to.getAsyncRemote().sendText(jsonObject.toString());
          //System.out.println("发给"+to+"："+jsonObject.toString());
         }
   break;
  case 2://群聊
   String[] members=to.split(",");
   //发送到在线用户
   for(String member:members){
    session=mapUS.get(member);
    if(session!=null){
     session.getAsyncRemote().sendText(jsonObject.toString());
     //System.out.println("发给群里所有在线的人"+member+"："+jsonObject.toString());
    }
   }
   break;
  case 3:
    //所有人
   for(Session s:session.getOpenSessions()){//循环发给所有在线的人
    s.getAsyncRemote().sendText(jsonObject.toString());
    //System.out.println("发给系统所有在线的人"+session.getOpenSessions()+"："+jsonObject.toString());
   }
   break;
  default:
   break;
  }
    }
    /**
     * 发生错误时调用
     * @param session
     * @param error
     */
    @OnError
    public void onError(Throwable error){
        System.out.println("llws发生错误");
        error.printStackTrace();
    }

}