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);
|
}
|
}
|
|
}
|
