package com.tc.chat.controller;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.http.cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.google.gson.Gson;
import com.tc.chat.domain.Message;
import com.tc.chat.domain.User;
import com.tc.chat.service.FriendService;
import com.tc.chat.service.MessageService;
import com.tc.chat.service.UserService;
import com.tc.chat.vo.ChatFriend;
import com.tc.chat.websocket.WebSocketUtils;
@Controller
public class FriendController {
@Autowired
private FriendService friendService;
@Autowired
private UserService userService;
@Autowired
private MessageService messageService;
@RequestMapping("/list")
public String friendList(Long userId,Model model,HttpServletRequest request) throws Exception{
User user=userService.getUserById(userId);
ArrayList<User> friendList=friendService.getFriendList(userId);
ArrayList<ChatFriend> chatFriends=messageService.getChatFriends(userId);
model.addAttribute("friendList", friendList);
model.addAttribute("chatFriends", chatFriends);
model.addAttribute("user",user);
return "main";
}
@RequestMapping("/online")
public @ResponseBody void getonline(Long loginId) throws Exception{
ArrayList<User> users=friendService.getFriendList(loginId);
for (User user : users) {
if(WebSocketUtils.hasConnection(user.getUserId()+"")){
Message message=new Message();
message.setMessageType("2");
message.setMessageInfo(user.getUserId()+"");
Gson gson=new Gson();
WebSocketUtils.get(loginId+"").getBasicRemote().sendText(gson.toJson(message));
}
}
}
@RequestMapping("/noticeFriends")
public @ResponseBody void noticeFriends(Long loginId) throws Exception{
ArrayList<User> users=friendService.getFriendList(loginId);
for (User user : users) {
if(WebSocketUtils.hasConnection(user.getUserId()+"")){
Message message=new Message();
message.setMessageType("2");
message.setMessageInfo(loginId+"");
Gson gson=new Gson();
WebSocketUtils.get(user.getUserId()+"").getBasicRemote().sendText(gson.toJson(message));
}
本文地址：http://ww.kub2b.com/news/9667.html
企库往 http://ww.kub2b.com/ , 查看更多