package com.iplatform.chat.util.ws;

import com.iplatform.base.PlatformRuntimeException;
import com.iplatform.chat.Constants;
import com.iplatform.chat.util.ChatUtils;
import com.iplatform.model.vo.ChatVo;
import com.walker.infrastructure.utils.JsonUtils;
import com.walker.tcp.TcpRequest;
import com.walker.tcp.data.AbstractStringRequest;

/**
 * 聊天请求对象定义。
 * <p>前端传递数据格式如下：</p>
 * <pre>
 *     {
 *         "protocol":"chat",
 *         "data":{
 *             "me":12345,
 *             "customerService":0,  // 客服人员ID，0 表示机器人
 *             "customerServiceSend":false,
 *             "msgType":"t",
 *             "message":"你好！",
 *             "bizId":"业务id"
 *         }
 *
 *     }
 * </pre>
 */
@TcpRequest("chat")
public class ChatRequest extends AbstractStringRequest {

    public ChatVo getChatVo() {
        return chatVo;
    }

    private ChatVo chatVo;

    public ChatRequest(){}

    @Override
    protected void translateData(String source) {
        ChatData chatData = null;
        try {
            chatData = JsonUtils.jsonStringToObject(source, ChatData.class);
            if(chatData == null){
                throw new PlatformRuntimeException("ChatData转换为空");
            }
            this.chatVo = ChatUtils.acquireChatVo(chatData.getData());
        } catch (Exception e) {
            throw new RuntimeException("请求转ChatVo错误:" + e.getMessage(), e);
        }
    }

    @Override
    public String getProtocolNum() {
        return Constants.PROTOCOL_CHAT;
    }

//    private class ChatData implements Serializable {
//        public String getProtocol() {
//            return protocol;
//        }
//
//        public void setProtocol(String protocol) {
//            this.protocol = protocol;
//        }
//
//        public ChatViewVo getData() {
//            return data;
//        }
//
//        public void setData(ChatViewVo data) {
//            this.data = data;
//        }
//
//        private String protocol;
//        private ChatViewVo data;
//    }
}