package com.ld.igds.protocol.bhzn.verb.builder;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SimplePropertyPreFilter;
import com.ld.igds.io.request.BaseRequest;
import com.ld.igds.protocol.bhzn.verb.dto.IoMessage;
import com.ld.igds.protocol.bhzn.verb.server.BhznVerbServerUtils;


/**
 * 命令生成
 *
 * @author Andy
 */
public abstract class CommandBuilder {

    public IoMessage buildMessage(BaseRequest request) {
        IoMessage message = new IoMessage();
        message.setIp(request.getIp());
        message.setPort(request.getPort());
        message.setBegin(BhznVerbServerUtils.MSG_START1);
        // 调整信息
        buildInfo(message, request);
        message.setSign("0000");
        message.setStNum(Integer.parseInt(request.getDepotId()));
        message.setVersion("V1.0000000");
        message.setCmd(248);
        message.setResult("");
        message.setOrderId(request.getOrderId());
        message.setContent(null);
        message.setEnd(BhznVerbServerUtils.MSG_END);

        // 生成整体命令信息和BYte信息
        build(message);

        return message;
    }

    public void buildInfo(IoMessage message, BaseRequest request) {


    }

    /**
     * 根据生成的命令，进行调整
     *
     * @param message
     */
    public void build(IoMessage message) {
        StringBuffer hexSb = new StringBuffer();
        hexSb.append(message.getBegin());
        SimplePropertyPreFilter filter = new SimplePropertyPreFilter();
        filter.getExcludes().add("ip");
        filter.getExcludes().add("port");
        filter.getExcludes().add("companyId");
        filter.getExcludes().add("strMsg");
        filter.getExcludes().add("begin");
        filter.getExcludes().add("end");
        filter.getExcludes().add("byteMsg");
        filter.getExcludes().add("contentSr");
        message.setContent(JSONObject.parseObject(message.getContentStr()));
        message.setStrMsg(JSONObject.toJSONString(message,filter));
        hexSb.append(message.getStrMsg());
        hexSb.append(message.getEnd());
        message.setByteMsg(hexSb.toString().getBytes());
    }

}