package com.dy.common.mw.protocol.p206V1_0_0;

import com.dy.common.util.ByteUtil;
import com.dy.common.util.ByteUtilUnsigned;


public class CommonV1_0_1 {
	/**
	 * 检查头
	 * @param bs 上行字节数组
	 * @return true是,false否
	 * @throws Exception  异常
	 */
	public Boolean isThisProtocolHead(byte[] bs) throws Exception{
		if(bs == null){
			return null ;
		}else if(bs.length >= (ProtocolConstantV206V1_0_0.ctrlIndex - 1)
				&& bs[0] == ProtocolConstantV206V1_0_0.P_Head_Byte
				&& bs[2] == ProtocolConstantV206V1_0_0.P_Head_Byte){
			//String vs = this.parseVersion(bs) ;
			//return vs.equals(ProtocolConstantV206V1_0_0.version);
			return true ;
		}else{
			return false ;
		}
	}
	
	/**
	 * 检查头
	 * @param bs 上行字节数组
	 * @throws Exception 异常
	 */
	public void checkHead(byte[] bs) throws Exception{
		if(bs.length < 13 || bs[0] != ProtocolConstantV206V1_0_0.P_Head_Byte || bs[2] != ProtocolConstantV206V1_0_0.P_Head_Byte){
			throw new Exception("上行数据帧头不正确！") ;
		}
	}
	
	/**
	 * 检查尾
	 * @param bs 上行字节数组
	 * @throws Exception 异常
	 */
	public void checkTail(byte[] bs) throws Exception{
		if(bs.length < 1 || bs[bs.length - 1] != ProtocolConstantV206V1_0_0.P_Tail_Byte){
			throw new Exception("上行数据尾不正确！") ;
		}
	}


	/**
	 * 分析数据字节数
	 * @param bs 上行字节数组
	 * @return 数据长度
	 * @throws Exception 异常
	 */
	public int parseDataLen(byte[] bs)throws Exception{
		return ByteUtilUnsigned.bytes2Short_BE(bs, ProtocolConstantV206V1_0_0.dataLenIndex) ;
	}


	/**
	 * 分析Rtu地址
	 * @param bs 上行字节数组
	 * @return 控制器地址
	 * @throws Exception 异常
	 */
	public String parseRtuAddr(byte[] bs)throws Exception{
		String rtuAddrBCD = "" + ByteUtil.BCD2Long_BE(bs, ProtocolConstantV206V1_0_0.rtuAddr1Index_start, ProtocolConstantV206V1_0_0.rtuAddr1Index_end) ;
		String rtuAddrStr = "" + ByteUtilUnsigned.bytes2Short_BE(bs, ProtocolConstantV206V1_0_0.rtuAddr2Index_start) ;
		while(rtuAddrStr.length() < 6){
			rtuAddrStr = "0" + rtuAddrStr ;
		}
		return rtuAddrBCD + rtuAddrStr ;
	}

	/**
	 * 分析功能码
	 * @param bs 上行字节数组
	 * @return 功能码
	 */
	public String parseCode(byte[] bs){
		return ByteUtil.bytes2Hex(bs, false, ProtocolConstantV206V1_0_0.codeIndex, 1) ;
	}


	/**
	 * 校验和检查
	 * @param bs 上行字节数组
	 * @return 通过true,未通过false
	 */
	public boolean checkCrc(byte[] bs) {
		byte he = 0 ;
		for(int i = 0 ; i <= bs.length - 3 ; i++){
			he = (byte)(he + bs[i]) ;
		}
		return bs[bs.length - 2] == he ;
	}

	/**
	 * 校验和检查
	 * @param bs  上行字节数组
	 * @return 通过null，未通过返回原因
	 * @throws Exception 异常
	 */
	public String checkCrc_str(byte[] bs) throws Exception {
		byte[] he = new byte[1] ;
		for(int i = 0 ; i <= bs.length - 3 ; i++){
			he[0] = (byte)(he[0] + bs[i]) ;
		}
		short hes = ByteUtilUnsigned.byte2Byte(he, 0);
		short heOrg = ByteUtilUnsigned.byte2Byte(bs, bs.length - 2);
		if(hes == heOrg){
			return null ;
		}else{
			return "计算校验和是:" + hes + "，上传校验和是" + heOrg ;
		}
	}


	/*
	构造控制域
	D7                  D6                  D5～D4            D3～D0
	传输方向位 DIR        拆分标志位 DIV       帧计数位 FCB       功能码
	*/
	public byte createCtrl(byte funcCode){
		byte b = 0 ;
		b = (byte)(b | funcCode) ;
		//FCB == 3
		b = (byte)(b | (byte)60) ;
		//DIV = 0
		//DIR = 0
		return b ;
	}

	/**
	 * 得到关开阀类型名称
	 * @param type 字节
	 * @return 名称
	 */
	public static String openCloseValveType(byte type){
		return switch (type) {
			case 1 -> "刷卡开阀";
			case 2 -> "刷卡关阀";
			case 3 -> "中心站开阀";
			case 4 -> "中心站关阀";
			case 5 -> "欠费关阀";
			case 6 -> "流量计故障关阀";
			case 7 -> "紧急关阀";
			case 8 -> "用户远程开阀";
			case 9 -> "用户远程关阀";
			default -> "未知";
		};
	}
	
	/*
	 * 分析版本号
	 * @param bs  上行字节数组
	 * @return 版本号
	 * @throws Exception 异常
	public String parseVersion(byte[] bs)throws Exception{
		short ver = ByteUtilUnsigned.byte2Byte(bs, ProtocolConstantV206V1_0_0.versionIndex) ;
		char[] cs = ("" + ver).toCharArray() ;
		StringBuilder vs = new StringBuilder() ;
		for(byte i = 0 ; i < cs.length; i++){
			if(i == 0){
				vs.append(cs[i]) ;
			}else{
				vs.append(".").append(cs[i]) ;
			}
		}
		return vs.toString() ;
	}
	*/

}