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