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);
    }

}