package com.zhujizheng.IHome.chatsetting.net;

import com.zhujizheng.IHome.chatsetting.dto.PYChatSettingDTO;
import com.zhujizheng.IHome.chatsetting.service.PYChatSettingService;
import com.zhujizheng.IHome.chatsetting.vo.PYChatSettingVO;
import com.zhujizheng.IHome.generator.dao.PYChatSetting;
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 NetChatSetting extends NetProtocolBase {

    @Autowired
    private PYChatSettingService service;

    @Override
    public void dealWithJSONAndSid(JSONObject json, String sid) {
        super.dealWithJSONAndSid(json, sid);

        PYChatSettingDTO dto = (PYChatSettingDTO) JSONObject.toBean(json, PYChatSettingDTO.class);
        PYChatSetting chatSetting = service.getChatSetting(Integer.parseInt(sid));
        if (chatSetting == null) {
            return;
        }
        long updateTime = chatSetting.getUpdateTime().getTime();
        log.info("聊天设置更新时间, " + updateTime);
        long dtoUpdateTime = dto.getUpdateTime();
        if (updateTime > dtoUpdateTime) {
            PYChatSettingVO vo = PYChatSettingVO.createVO(dtoUpdateTime, chatSetting.getJsonStr());
            this.sendObject(vo, sid);
        }
    }
}