package com.dy.aceMw.server.forTcp;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.dy.common.mw.protocol.MidResult;
import com.dy.common.mw.protocol.MidResultAction;
import com.dy.common.mw.protocol.MidResultFromRtu;
import com.dy.common.mw.protocol.MidResultToRtu;

public class MidResultActionFromRtu implements MidResultAction {

	private static Logger log = LogManager.getLogger(MidResultActionFromRtu.class) ;

	@Override
	public void doAction(MidResult result) {
		if(result != null && result instanceof MidResultFromRtu){
			//如果此处需要更多的逻辑处理，可以生成一个任务类（实现CoreTask）对象进行处理
			//当前，处理直接进行
			MidResultFromRtu resFromRtu = (MidResultFromRtu)result ;
			if(!resFromRtu.reportOrResponse_trueOrFalse){
				//命令应答
				//此处实现，与以前不一样，
				//以前实现：匹配命令是从后向前匹配，
				//当前实现，匹配命令是从前向后匹配，原因：举例，当批量下发补召命令，如果从后匹配，则前面命令会下发多次，即一个上报次数据会补召多次
				MidResultToRtu resToRtu = TcpDownCommandCach.matchFromHead(resFromRtu) ;
				if(resToRtu != null){
					//匹配到下发的命令
					resFromRtu.setCommandId(resToRtu.commandId) ;
					this.sendResult(false, resFromRtu);
				}else{
					this.sendResult(false, resFromRtu);
					//未匹配到下发的命令，命令在缓存因超时被清除了
					RtuStatusDealer.commandFail2Success(resFromRtu.rtuAddr) ;
				}
			}else{
				//主动上报数据
				this.sendResult(true, resFromRtu);
			}
		}
	}
	private void sendResult(boolean reportOrResponse_trueOrFalse, MidResultFromRtu resFromRtu){
		try{
			String json = resFromRtu.data.toJson() ;
//			if(reportOrResponse_trueOrFalse){
//				ToMqMessageCach.cachObj(MessageType.RtuAutoReport, json);
//			}else{
//				ToMqMessageCach.cachObj(MessageType.RtuCmdResponse, json);
//			}
		}catch(Exception e){
			log.error(e.getMessage(), e);
		}
		
	}
}