package com.jsjty.task;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.bairuitech.anychat.AnyChatOutParam;
import com.jsjty.bean.ChatCmd;
import com.jsjty.bean.CmdConsts;
import com.jsjty.bean.MsgBean;
import com.jsjty.core.BusinessServer;

/**
 * 消息发送任务
 * 
 * @author 袁晓冬
 *
 */
public class MessageSendService implements Runnable {

    private Logger logger = LoggerFactory.getLogger(MessageSendService.class);
    private BusinessServer businessServer;

    public BusinessServer getBusinessServer() {
        return businessServer;
    }

    public void setBusinessServer(BusinessServer businessServer) {
        this.businessServer = businessServer;
    }

    private MsgBean msg = null;

    public MsgBean getMsg() {
        return msg;
    }

    public void setMsg(MsgBean msg) {
        this.msg = msg;
    }

    @Override
    public void run() {
        logger.info("run message send to user {} :{}", msg.getChatid(), msg.getId());
        ChatCmd send = new ChatCmd();
        send.setCode(CmdConsts.MSG_REMIND);
        send.setData(msg);
        AnyChatOutParam outParam = new AnyChatOutParam();
        byte[] bytes = send.toBytes();
        businessServer.transBufferEx(msg.getChatid(), bytes, bytes.length, 0, 0, 0, outParam);
    }
}