package com.ld.igds.protocol.zldz.server;

import com.ld.igds.protocol.zldz.mq.PublisherControl;
import com.ld.igds.protocol.zldz.util.ServerUtils;
import com.ld.igds.util.BytesUtil;
import com.ld.igds.util.SpringUtil;
import com.ld.io.api.IoMsgConsumer;
import com.ld.io.api.IoSession;

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

	// private AnalysisService analysisService;

	private PublisherControl publisherControl;

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

		// 调用解析接口开始解析
		// if(null == analysisService){
		// analysisService = (AnalysisService)
		// SpringUtil.getBean(AnalysisService.BEAN_ID);
		// }
		// analysisService.analysis(session.getAddress(),session.getPort(),bytes);

		// 2021年6月9日 调整为消息队列处理
		if (null == publisherControl) {
			publisherControl = SpringUtil.getBean(PublisherControl.class);
		}

		String strMsg = BytesUtil.bytesToString(bytes) + ServerUtils.MSG_END;

		// 二次调整报文
		if (!strMsg.startsWith(ServerUtils.MSG_START)) {
			strMsg = strMsg.substring(strMsg.indexOf(ServerUtils.MSG_START));
		}

		publisherControl.publishMessage(session.getBusinessKey() + "_" + strMsg);
	}

}