package com.zhujizheng.IHome.user.net; import com.zhujizheng.IHome.user.dto.PYQueryUserInfoDTO; import com.zhujizheng.IHome.user.service.PYUserService; import com.zhujizheng.IHome.user.vo.PYUserVO; import com.zhujizheng.IHome.websocket.Net.Base.NetProtocolBase; import lombok.extern.slf4j.Slf4j; import net.sf.json.JSONObject; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Slf4j @Component public class NetQueryFriendInfo extends NetProtocolBase { @Autowired private PYUserService userService; @Override public void dealWithJSONAndSid(JSONObject json, String sid) { super.dealWithJSONAndSid(json, sid); PYQueryUserInfoDTO dto = (PYQueryUserInfoDTO)JSONObject.toBean(json, PYQueryUserInfoDTO.class); int userId = Integer.parseInt(sid); int friendId = dto.getFriendId(); PYUserVO userVO = userService.selectInfo(friendId); if (userVO != null) { // 统一用NetFriendInfoChanged协议下发好友数据 NetFriendInfoChanged friendInfoChanged = new NetFriendInfoChanged(); friendInfoChanged.sendObject(userVO, sid); } else { log.warn("查询用户信息为空,userId:" + userId); } } }