package com.ld.igds.io.fzzy.server;

import com.ld.igds.io.fzzy.ServerUtils;
import com.ld.igds.io.fzzy.analysis.AnalysisService;
import com.ld.igds.io.fzzy.dto.IoMessage;
import com.ld.io.api.IoMsgConsumer;
import com.ld.io.api.IoSession;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
@Slf4j
public class BhznQuantityMessageConsumer implements IoMsgConsumer {


    @Autowired
    private AnalysisService analysisService;

    /**
     * 处理消息
     *
     * @param ioSession
     * @param bytes
     */
    @Override
    public void consume(IoSession ioSession, byte[] bytes) {
        if (null == bytes) {
            log.error("Reply bytes is null");
            return;
        }
        try {
            String message = new String(bytes, ServerUtils.CHARSET);
            message = message.substring(message.indexOf(ServerUtils.MSG_BEGIN) + ServerUtils.MSG_BEGIN.length());

            log.info("数量检测---->>平台：报文信息：" + message);
            IoMessage ioMessage = ServerUtils.buildMessage(message);

            analysisService.analysis(ioSession.getBusinessKey(), ioMessage);

        } catch (Exception e) {

            log.error("数量检测---->>平台：报文异常：" + e.getMessage());
        }
    }
}