package com.zhujizheng.IHome.remark.net; import com.zhujizheng.IHome.remark.dto.PYRemarkFriendDTO; import com.zhujizheng.IHome.remark.dto.PYRemarkUpdateDTO; import com.zhujizheng.IHome.remark.service.PYRemarkService; import com.zhujizheng.IHome.remark.vo.PYRemarkVO; import com.zhujizheng.IHome.user.net.NetFriendInfoChanged; 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 NetRemarkFriend extends NetProtocolBase { @Autowired private PYUserService userService; @Autowired private PYRemarkService remarkService; @Override public void dealWithJSONAndSid(JSONObject json, String sid) { super.dealWithJSONAndSid(json, sid); PYRemarkFriendDTO dto = (PYRemarkFriendDTO) JSONObject.toBean(json, PYRemarkFriendDTO.class); int userId = Integer.parseInt(sid); int friendId = dto.getFriendId(); String remark = dto.getRemark(); PYRemarkUpdateDTO updateDTO = new PYRemarkUpdateDTO(); updateDTO.setFriendId(friendId); updateDTO.setUserId(userId); updateDTO.setRemark(remark); int result = remarkService.changeRemark(updateDTO); if (result == 0) { log.info("备注失败"); this.sendServerError(sid); return; } PYUserVO userVO = userService.selectInfoWithFriendId(userId, friendId); if (userVO == null) { log.info("查询用户信息为空,userId:" + userId); return; } // 通知自己,有好友信息变更 NetFriendInfoChanged friendInfoChanged = new NetFriendInfoChanged(); friendInfoChanged.sendObject(userVO, sid); PYRemarkVO remarkVO = remarkService.getRemark(userId, friendId); if (remarkVO == null) { log.info("查询备注信息为空,userId:" + userId + ",friendId = " + friendId); return; } // 通知自己,备注成功 this.sendObject(remarkVO, sid); } }