package com.dy.common.mw.protocol.pMeterV1_0_1.parse;

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

import com.dy.common.mw.protocol.AnnotationCodeUp;
import com.dy.common.mw.protocol.CodeParse;
import com.dy.common.mw.protocol.CodeParseCallback;
import com.dy.common.mw.protocol.CodeParseParams;
import com.dy.common.mw.protocol.Data;
import com.dy.common.mw.protocol.MidResult;
import com.dy.common.mw.protocol.MidResultFromRtu;
import com.dy.common.mw.protocol.pMeterV1_0_1.*;
import com.dy.common.util.ByteUtil;

@AnnotationCodeUp(ifAny={
		CodeV1_0_1.cd_04,
		CodeV1_0_1.cd_05
})
public class Cd_0405_Up implements CodeParse{

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

	/**
	 * 分析上行数据
	 */
	@Override
	public MidResult[] parse(Boolean isLowPower, CodeParseParams params, CodeParseCallback callback)throws Exception {
		ParseParamsForUpV1_0_1 para = (ParseParamsForUpV1_0_1)params ;
		int bsLen = new CommonV1_0_1().parseDataLen(para.upBuffer) ;
		if(bsLen > 0){
			this.doParse(para.upBuffer, 
					bsLen,
					para.upCode, 
					para.data) ;
		}
		log.info("分析上行数据<" + CodeV1_0_1.getCodeName(para.upCode) + " 水表号=" + para.meterNo + ">:\n" + para.data.toString());

		MidResultFromRtu midRs = new MidResultFromRtu() ;
		midRs.protocolName = para.protocolName ;//协议名称
		midRs.rtuAddr = para.rtuAddr ;//IMEI号
		midRs.meterNo = para.meterNo ;//水表号
		midRs.productId = para.productId ;//电信平台产品ID，当不在电信平台运行时，为null
		midRs.deviceId = para.deviceId ;//电信平台设备ID，当不在电信平台运行时，为null
		midRs.upCode = para.upCode ;//上行数据中的功能码
		midRs.upHex = para.upHex ;//上行数据十六进制形式
		midRs.upBuffer = para.upBuffer ;//上行数据字节数组
		midRs.data = para.data ;//解析后的数据
		
		midRs.reportOrResponse_trueOrFalse = false ;//命令回扫
		
		callback.callback(midRs.reportOrResponse_trueOrFalse);
		return new MidResult[]{midRs} ;
	}
	/**
	 * 执行分析
	 * @param bs 
	 * @param bsLen字节长度（总包长，包括包头和包尾）
	 * @param dataCode
	 * @param index
	 * @param contentDataEndIndex
	 * @param data
	 * @throws Exception
	 */
	protected void doParse(byte[] bs, int bsLen, String dataCode, Data data) throws Exception {
		DataV1_0_1 dV1 = (DataV1_0_1)data.getSubData() ;
		DataCd0405Vo cdData = new DataCd0405Vo() ;
		dV1.dataCd0405Vo = cdData ;
		
		if(dataCode.equals(CodeV1_0_1.cd_04)){
			cdData.open1_close2 = 1 ;
		} else if(dataCode.equals(CodeV1_0_1.cd_05)){
			cdData.open1_close2 = 2 ;
		}
		
		int index = ProtocolConstantV1_0_1.codeIndex + 1 ;
		cdData.dt = "20" + ByteUtil.BCD2String_BE(bs, index, index++)
				+ "-" + ByteUtil.BCD2String_BE(bs, index, index++)
				+ "-" + ByteUtil.BCD2String_BE(bs, index, index++)
				+ " " + ByteUtil.BCD2String_BE(bs, index, index++)
				+ ":" + ByteUtil.BCD2String_BE(bs, index, index++)
				+ ":" + ByteUtil.BCD2String_BE(bs, index, index) ;
		
		index ++ ;
		cdData.state = bs[index] ;
		
	}
}