package com.fzzy.protocol.zldz.server;

import com.fzzy.api.utils.BytesUtil;
import com.fzzy.api.utils.SpringUtil;
import com.fzzy.protocol.bhzn.cmd.ReMessageBuilder;
import com.fzzy.protocol.bhzn.data.IoMessage;
import com.fzzy.protocol.bhzn.server.BhznGrainV2ServerUtils;
import com.fzzy.protocol.zldz.analysis.AnalysisService;
import com.ld.io.api.IoMsgConsumer;
import com.ld.io.api.IoSession;
import lombok.extern.slf4j.Slf4j;

/**
 * 接收终端返回回来的信息。
 *
 * @author Andy
 */
@Slf4j
public class MsgConsumer implements IoMsgConsumer {


    private AnalysisService analysis;

    @Override
    public void consume(IoSession session, byte[] bytes) {

        try {
            String hexStr = BytesUtil.bytesToString(bytes);

            log.debug("【" + session.getAddress() + "】主机------->>平台：报文：" + hexStr);
           // hexStr = hexStr.substring(ZldzServerUtil.MSG_START.length());

            if (null == analysis) {
                analysis = (AnalysisService) SpringUtil.getBean(AnalysisService.BEAN_ID);
            }

            analysis.analysis(session.getAddress(),session.getPort(), hexStr);

        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }

}