jcstruct解析與反解析解決方案

介紹

描述：基于配置解決java與C結(jié)構(gòu)體解析與反解析的靈活方案。

功能說明

1. 基于spring框架開發(fā)
   

2. 對(duì)于結(jié)構(gòu)體定義采用可視化XML配置，便于維護(hù)與調(diào)試，防止協(xié)議多次修改帶來的麻煩。
   

3. 所有關(guān)健解析操作都基于接口開發(fā)，有默認(rèn)實(shí)現(xiàn)，也可以用于自定義實(shí)現(xiàn)，能滿足所有特殊業(yè)務(wù)解析需求。
   

4. 配置簡單，使用方便、易上手。

使用實(shí)例

1、全局配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xmlns:cjava="http://www.haoyu.com/schema/cjava"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.haoyu.com/schema/cjava
        http://www.haoyu.com/schema/cjava/cjava-1.0.xsd
		"
	default-lazy-init="false">

 <!-- 對(duì)于ByteArray類型的特殊處理，該類需要繼承com.haoyu.module.jcstruct.opt.AbstractJFieldOpt-->	
	<bean id="byteArrayJFieldOpt" class="com.haoyu.module.jcstruct.opt.ByteArrayJFieldOpt"></bean>
  
	<!-- 加入模板容器處理，默認(rèn)實(shí)現(xiàn)類com.haoyu.module.jcstruct.template.DefaultTemplateContainer -->
	<cjava:templateContainer/>
  
  <!-- 解析管理類，默認(rèn)com.haoyu.module.jcstruct.opt.DefaultOptManager，繼承com.haoyu.module.jcstruct.opt.AbstractOptManager-->
	<cjava:optManager class="com.haoyu.module.jcstruct.opt.OptManagerForDebug">
   <!-- 對(duì)于ByteArray類型的解析的特殊處理->	
  <cjava:optManagerOne key="bytearray" value-ref="byteArrayJFieldOpt"/>
  </cjava:optManager>
  
  <!-- 調(diào)度中心配置，該類主要用于處理不同協(xié)議的業(yè)務(wù)處理，并返回處理結(jié)果。默認(rèn)實(shí)現(xiàn)類:com.haoyu.module.jcstruct.dispatch.DefaultDispatchCenterServiceImpl，自定義實(shí)現(xiàn)需要繼承AbstractDispatchCenterService-->	
	<cjava:dispatchCenterService/>
  
  <!-- 啟動(dòng)加載完成后的自定義刷新管理類，用于加載完成后從spring集合里取出指定類型或者指定KEY的對(duì)象，具體刷新類需要實(shí)現(xiàn)RefreshService接口，默認(rèn)實(shí)現(xiàn)類:com.haoyu.module.jcstruct.refresh.RefreshServiceManager-->
	<cjava:refreshManager/>
	
  <!-- 測(cè)試類的包路徑加入到spring-->
	<context:component-scan base-package="com.haoyu.module.jcstruct.test" />
	
  <!-- 解析的輔助類加入到spring-->
	<context:component-scan base-package="com.haoyu.module.jcstruct.resolve" />

  <!-- 啟動(dòng)檢查字段-->
	<cjava:check/> 

  <!-- 接收C結(jié)構(gòu)體定義XML-->
  <import resource="spring-cjava-fc.xml"/>
    
  <!-- 返回C結(jié)構(gòu)體的協(xié)議定義XML->
  <import resource="spring-cjava-tc.xml"/>
	
</beans>

說明：
spring頭文件需要加入
xmlns:cjava="http://www.haoyu.com/schema/cjava"
xsi:schemaLocation中需要加入
http://www.haoyu.com/schema/cjava
http://www.haoyu.com/schema/cjava/cjava-1.0.xsd
對(duì)自定義cjava標(biāo)簽支持。

2、結(jié)構(gòu)體協(xié)議配置(舉例)
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cjava="http://www.haoyu.com/schema/cjava"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.haoyu.com/schema/cjava
        http://www.haoyu.com/schema/cjava/cjava-1.0.xsd
		"
	default-lazy-init="false">
	
    <!-- 協(xié)議頭-->
	<cjava:fch key="Package_Type"><!-- key用來定位協(xié)議ID的標(biāo)識(shí) -->
		<cjava:field name="Constant_Up" type="ushort" desc="2字節(jié)，前導(dǎo)字符，固定為0XAAAA，表示為上行數(shù)據(jù)包-" />
		<cjava:field name="Gateway_Id" type="unsigendint" desc="4字節(jié)，網(wǎng)關(guān)id號(hào)" />
		<cjava:field name="Package_Type" type="char" desc="具體根據(jù)每個(gè)協(xié)議ID決定" />
	</cjava:fch>
	
	
	<cjava:fct name="ACK" id="1" desc="通訊確認(rèn)協(xié)議號(hào)0x01">
		<cjava:field name="Version" type="char" desc="1字節(jié),網(wǎng)關(guān)軟件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字節(jié)數(shù)據(jù)包長度，單位字節(jié)，從Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="字節(jié)，包序號(hào)，copy接收到的上行數(shù)據(jù)包包序號(hào) " />
		<cjava:field name="command_properties" type="char" desc="
		 =0x01,表示傳感節(jié)點(diǎn)測(cè)試通信 
		=0x02，數(shù)據(jù)接收正確
		=0x03，數(shù)據(jù)接收錯(cuò)誤，要求重發(fā)
        =0x04，數(shù)據(jù)接收錯(cuò)誤，不要求重發(fā)
        =0X05，終止傳輸（多包傳輸時(shí)使用）。
        =0X06，接收正確，命令無法執(zhí)行。"/>
		<cjava:field name="BCC" type="char" desc="1個(gè)字節(jié)，前面所有數(shù)據(jù)含前導(dǎo)，異或運(yùn)算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字節(jié)，固定為0XAA55，表示為上行數(shù)據(jù)包結(jié)束 " />
	</cjava:fct>
	
	<cjava:fct name="HeartBeat" id="5" desc="心跳 協(xié)議號(hào)0x05">
	    <cjava:field name="Package_Number" type="ushort" desc="字節(jié)，包序號(hào)，copy接收到的上行數(shù)據(jù)包包序號(hào) " />
	    <cjava:field name="BCC" type="char" desc="1個(gè)字節(jié)，前面所有數(shù)據(jù)含前導(dǎo)，異或運(yùn)算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字節(jié)，固定為0XAA55，表示為上行數(shù)據(jù)包結(jié)束 " />
	</cjava:fct>
	
	<cjava:fct name="Character" id="2" desc="特征值  0x02">
	
	  <cjava:field name="Sensor_Id" type="unsigendint" desc="4字節(jié)，傳感器ID  " />
		<cjava:field name="Version" type="char" desc="1字節(jié),網(wǎng)關(guān)軟件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字節(jié)數(shù)據(jù)包長度，單位字節(jié)，從Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="字節(jié)，包序號(hào)，copy接收到的上行數(shù)據(jù)包包序號(hào) " />
		<cjava:field name="command_properties" type="char" desc="
		 1字節(jié)，=0x01,表示傳感器霍爾觸發(fā)上傳數(shù)據(jù)=0x02，表示傳感器定時(shí)上傳數(shù)據(jù)"/>
		 
		 
		 <cjava:field name="Recver_Riss" type="char" desc="接收到這包數(shù)據(jù)的場(chǎng)強(qiáng) " />
		 <cjava:field name="Battery" type="char" desc="電池電量,百分?jǐn)?shù)  " />
		 <cjava:field name="Temperature" type="short" realValueRule="{*}{0.01}" desc="2字節(jié)，溫度值,真實(shí)值等于該值*0.01" />
		 <cjava:field name="Character_Attribute" type="char" desc="1字節(jié)，數(shù)據(jù)類型，即后面一組數(shù)據(jù)的類型。1加速度 2速度  " />
		 <cjava:field name="Data_coefficient" type="ushort" desc="系數(shù), 計(jì)算方法見5.11中Data_ coefficient字段  " />
		 
 		 <cjava:field name="Data_x_Rms" type="ushort" desc="2字節(jié)，x方向RMS值 " />
 		 <cjava:field name="Data_x_PP" type="ushort" desc="2字節(jié)，x方向峰峰值" />
 		 <cjava:field name="Data_x_P" type="ushort" desc="2字節(jié)，x方向峰值 " />
 		 
 		 <cjava:field name="Data_y_Rms" type="ushort" desc="2字節(jié)，y方向RMS值 " />
 		 <cjava:field name="Data_y_PP" type="ushort" desc="2字節(jié)，y方向峰峰值" />
 		 <cjava:field name="Data_y_P" type="ushort" desc="2字節(jié)，y方向峰值 " />
 
 		 <cjava:field name="Data_z_Rms" type="ushort" desc="2字節(jié)，z方向RMS值 " />
 		 <cjava:field name="Data_z_PP" type="ushort" desc="2字節(jié)，z方向峰峰值" />
 		 <cjava:field name="Data_z_P" type="ushort" desc="2字節(jié)，z方向峰值 " />
		 
		<cjava:field name="BCC" type="char" desc="1個(gè)字節(jié)，前面所有數(shù)據(jù)含前導(dǎo)，異或運(yùn)算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字節(jié)，固定為0XAA55，表示為上行數(shù)據(jù)包結(jié)束 " />
		
	</cjava:fct>
	
	<cjava:fct name="Sensor" id="3" desc="傳感器組網(wǎng)信息上傳（0X03">
	  <cjava:field name="Sensor_Id" type="unsigendint" desc="4字節(jié)，傳感器ID  " />
		<cjava:field name="Version" type="char" desc="1字節(jié),網(wǎng)關(guān)軟件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字節(jié)數(shù)據(jù)包長度，單位字節(jié)，從Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="2字節(jié)，包序號(hào)，copy接收到的上行數(shù)據(jù)包包序號(hào) " />
		<cjava:field name="command_properties" type="char" desc="
		1字節(jié)，=0x01,表示傳感器霍爾觸發(fā)上傳數(shù)據(jù)=0x02，表示傳感器定時(shí)上傳數(shù)據(jù)"/>
		<cjava:field name="Recver_Riss" type="char" desc="接收到這包數(shù)據(jù)的場(chǎng)強(qiáng) " />
		<cjava:field name="BCC" type="char" desc="1個(gè)字節(jié)，前面所有數(shù)據(jù)含前導(dǎo)，異或運(yùn)算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字節(jié)，固定為0XAA55，表示為上行數(shù)據(jù)包結(jié)束 " />
	</cjava:fct>
	
	<cjava:fct name="Wave" id="4" desc="波形數(shù)據(jù) ">
	  <cjava:field name="Sensor_Id" type="unsigendint" desc="4字節(jié)，傳感器ID  " />
		<cjava:field name="Version" type="char" desc="1字節(jié),網(wǎng)關(guān)軟件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字節(jié)數(shù)據(jù)包長度，單位字節(jié)，從Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="2字節(jié)，包序號(hào)，copy接收到的上行數(shù)據(jù)包包序號(hào) " />
		<cjava:field name="command_properties" type="char" desc="
		1字節(jié)，命令屬性為0X04，表示傳感節(jié)點(diǎn)申請(qǐng)波形上傳
		1字節(jié)，命令屬性為0X05，表示中間包
		1字節(jié)，命令屬性為0X06，表示結(jié)束包
		"/>
		
		
		<cjava:branchs key="command_properties"><!-- 特殊情況，對(duì)于二級(jí)KEY定位的標(biāo)識(shí) -->
		
			<cjava:branch keyValue="4" desc="表示傳感節(jié)點(diǎn)申請(qǐng)波形上傳"> <!-- 二級(jí)KEY的分支協(xié)議-->
				<cjava:field name="Wave_attribute" type="char" desc="當(dāng)前數(shù)據(jù)屬性" />
				<cjava:field name="Wave_long" type="char" desc="波形長度=0  512點(diǎn)  =1  1024點(diǎn) =2 	2048點(diǎn)	=3	4096點(diǎn) =4	8192點(diǎn)" />
				<cjava:field name="Temperature" type="short" realValueRule="{*}{0.01}" desc="真實(shí)值等于該值*0.01" />
				<cjava:field name="Sample_Frequency" type="ushort"  desc="采樣頻率 " />
				<cjava:field name="Wave_coefficient" type="ushort"  desc="后續(xù)發(fā)送值*系數(shù)/100得到真實(shí)值 " />
			</cjava:branch>
			
			<cjava:branch keyValue="5" desc="波形結(jié)束包數(shù)據(jù) "> <!-- 二級(jí)KEY的分支協(xié)議-->
				<cjava:field name="Wave_data" type="bytearray" realLengthRule="{Package_length}{-}{6}" desc="1024個(gè)數(shù)據(jù)，每包1024個(gè)數(shù)據(jù)，最后一包按實(shí)際剩余數(shù)據(jù)量 " />
			</cjava:branch>
			
			<cjava:branch keyValue="6" desc="波形結(jié)束包數(shù)據(jù) "> <!-- 二級(jí)KEY的分支協(xié)議-->
			</cjava:branch>
			
		</cjava:branchs><!-- 二級(jí)KEY的分支結(jié)束-->

		<cjava:field name="BCC" type="char" desc="1個(gè)字節(jié)，前面所有數(shù)據(jù)含前導(dǎo)，異或運(yùn)算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字節(jié)，固定為0XAA55，表示為上行數(shù)據(jù)包結(jié)束 " />
	</cjava:fct>
	
</beans>
注：返回給C結(jié)構(gòu)的協(xié)議類同參考包下面的spring-cjava-tc.xml

3、自定義業(yè)務(wù)實(shí)現(xiàn)（舉例，對(duì)特征值解析以后的處理）
package com.sg2k.dtu.handle;

import java.util.Date;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.alibaba.fastjson.JSONObject;
import com.haoyu.module.jcstruct.annotation.HandleMessageProtocol;
import com.haoyu.module.jcstruct.handle.HandleMessageService;
import com.haoyu.module.jcstruct.model.DefaultResponseResult;
import com.sg2k.consts.DefaultConsts;
import com.sg2k.dtu.cache.DataCache;
import com.sg2k.dtu.common.GatewayServerCodeType;
import com.sg2k.service.ReceiveDataService;

/**
 * 處理特征值顯示
 * 
 * @author haoyu
 *
 */
//spring注解
@Service("handleCharacterMessage")
//待處理的協(xié)議注解，解析出數(shù)據(jù)后的主鍵KEY(協(xié)議號(hào)標(biāo)識(shí))與根據(jù)此注解id匹配，如果匹配成功，在此做協(xié)議的處理并返回處理結(jié)果
@HandleMessageProtocol(id = GatewayServerCodeType.Gateway_Server_Character)
//處理類必須要實(shí)現(xiàn)HandleMessageService接口
public class HandleCharacterMessage  implements HandleMessageService
{
	Logger LOG = Logger.getLogger(this.getClass());

	@Override
	public void handle(JSONObject message, DefaultResponseResult responseResult)
	{

		LOG.info("接收特征值信息:" + message);
		// 更新特征值公共緩存
		DataCache.getInstance().setPubCharacter(message);
		// 往趨勢(shì)圖加入數(shù)據(jù)
		try {
			String Sensor_Id = message.getLong("Sensor_Id").toString();
			// 獲取溫度
			float Temperature = message.getFloatValue("Temperature");
			// 獲取電量
			int Battery = message.getIntValue("Battery");
			// 接收端數(shù)據(jù)= 數(shù)據(jù)/Data_coefficient
			float Data_coefficient = message.getIntValue("Data_coefficient");

			float Data_x_Rms = message.getIntValue("Data_x_Rms") / Data_coefficient;
			float Data_x_PP = message.getIntValue("Data_x_PP") / Data_coefficient;
			float Data_x_P = message.getIntValue("Data_x_P") / Data_coefficient;
			float Data_y_Rms = message.getIntValue("Data_y_Rms") / Data_coefficient;
			float Data_y_PP = message.getIntValue("Data_y_PP") / Data_coefficient;
			float Data_y_P = message.getIntValue("Data_y_P") / Data_coefficient;
			float Data_z_Rms = message.getIntValue("Data_z_Rms") / Data_coefficient;
			float Data_z_PP = message.getIntValue("Data_z_PP") / Data_coefficient;
			float Data_z_P = message.getIntValue("Data_z_P") / Data_coefficient;

			JSONObject receiveData = new JSONObject();
			receiveData.put("temperature", Temperature);
			receiveData.put("battery", Battery);
			// receiveData.put("datatime", new Date());
			receiveData.put("datatime", System.currentTimeMillis());
			LOG.info("特征值上傳時(shí)間:mills:" + receiveData.get("datatime") + "->times:" + new Date());
			// 用于判斷是否為速度、加速度
			int type = message.getIntValue("Character_Attribute");
			if (type == DefaultConsts.DATA_TYPE_ADD_SPEED) {
				receiveData.put("dataType", DefaultConsts.DATA_TYPE_ADD_SPEED);
				receiveData.put("xValue", Data_x_P);
				receiveData.put("yValue", Data_y_P);
				receiveData.put("zValue", Data_z_P);
			} else {
				// 速度
				receiveData.put("dataType", DefaultConsts.DATA_TYPE);
				receiveData.put("xValue", Data_x_Rms);
				receiveData.put("yValue", Data_y_Rms);
				receiveData.put("zValue", Data_z_Rms);
			}
			// 調(diào)用接口
			//receiveDataService.receiveFromSimulative(ReceiveDataService.HIS_DATA, Sensor_Id, receiveData);
			buildDefaultSuccess(message, responseResult);
		} catch (Exception e) {
			LOG.error("處理接收后的特征值信息接口異常:" + e.getMessage(), e);
			buildDefaultFail(message, responseResult);
		}
	}
  
  public void buildDefault(JSONObject message, DefaultResponseResult responseResult, RtnCommandProperties commandProperties)
	{
		// 發(fā)送確認(rèn)包
		JSONObject config = new JSONObject();
		if (!message.containsKey("Package_Number") || null == message.get("Package_Number")) {
			config.put("Package_Number", DEFAULT_PACKAGE_NUM);
		} else {
			config.put("Package_Number", message.get("Package_Number"));
		}
		config.put("Gateway_Id", message.get("Gateway_Id"));
		config.put("command_properties", commandProperties.ID);
		responseResult.buildReturnData(config).buildId(RtnCodeType.Server_Gateway_ACK.ID);
	}

	public void buildDefaultSuccess(JSONObject message, DefaultResponseResult responseResult)
	{
		// 發(fā)送確認(rèn)包
		buildDefault(message, responseResult, RtnCommandProperties.SUCCESS);
	}

	public void buildDefaultFail(JSONObject message, DefaultResponseResult responseResult)
	{
		buildDefault(message, responseResult, RtnCommandProperties.ERROR_NOT_RETRY);
	}

	public void buildDefaultRetry(JSONObject message, DefaultResponseResult responseResult)
	{
		buildDefault(message, responseResult, RtnCommandProperties.ERROR_AND_RETRY);
	}

}

4、測(cè)試代碼
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:spring-cjava.xml")
public class AppTest
{

	@Autowired
	private TemplateContainer templateContainer;

	@Autowired
	private OptManager optManager;

	@Autowired
	private DispatchCenterService dispatchCenterService;

	@Autowired
	private DefaultResolve defaultResolve;

  //測(cè)試解析特征值，協(xié)議號(hào)0x02
	private void testCharacterResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] {-86,-86,-3,79,-6,-119,2,18,-85,-51,-17,1,0,31,101,-61,3,83,0,10,-26,2,0,10,1,87,6,69,3,-80,0,-18,3,98,1,-59,1,-114,7,66,4,104,31,-86,85};
		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);
		System.out.println(json.getId() + "->" + json.getResult());
	}
	
   //測(cè)試解析波形，協(xié)議號(hào)0x04
	private void testWaveResolve() throws DtuMessageException, IOException
	{
		//申請(qǐng)上傳波形
		byte[] data = new byte[]{-86,-86,-3,79,-6,-119,4,18,-85,-51,-17,1,0,14,102,72,4,2,1,10,-26,0,0,0,100,-16,-86,85};
		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);
		System.out.println(json.getId() + "->" + json.getResult());
		//中間波形
	  data = new byte[] {-86,-86,-3,79,-6,-119,4,18,-85,-51,-17,1,4,6,102,73,5,-17,-61,-18,-5,-10,-71,4,-94,16,30,22,14,22,110,19,119,15,67,6,111,-1,85,-4,72,-4,89,5,64,13,-15,17,-89,13,-29,6,66,-2,-55,-10,59,-17,-103,-30,108,-38,-22,-33,29,-19,-62,-3,42,8,94,6,-13,5,-79,4,-78,2,-50,-6,-127,-14,-21,-16,114,-6,46,7,56,16,62,18,93,13,-3,8,-15,1,66,-6,-76,0,46,-3,-57,-5,-17,2,40,13,-116,21,-63,23,-82,18,19,12,49,6,57,-4,30,-6,13,-10,35,-8,-37,3,97,11,118,14,-83,9,54,2,122,-6,-83,-13,64,-20,-8,-27,-7,-28,14,-22,-64,-7,83,5,114,13,75,13,-11,12,-39,10,1,3,121,-7,74,-11,-37,-11,-20,-1,-35,10,-96,16,123,14,-8,8,-117,2,3,-7,-24,-13,-54,-25,-37,-34,73,-32,72,-19,69,-3,88,8,-16,8,-75,5,110,4,56,2,-83,-5,1,-15,89,-19,56,-11,117,3,-96,13,-25,18,114,14,-39,10,-91,3,-121,-4,-78,-6,-22,-8,-118,-10,101,-3,39,9,-96,19,-75,24,35,21,-46,17,15,11,-84,2,47,0,-125,-3,91,-3,-90,6,58,14,76,17,68,12,-102,4,-78,-4,-53,-12,-87,-19,-30,-29,-50,-33,50,-28,91,-14,-34,0,88,9,-51,8,63,7,49,5,103,2,20,-8,-4,-13,40,-14,21,-5,-57,7,-9,15,-5,17,6,12,15,6,-125,-2,-88,-8,91,-3,-97,-7,12,-9,-79,-2,-40,10,-84,18,-29,19,-19,13,-79,7,-12,2,-94,-8,-28,-11,70,-15,11,-11,31,0,-20,9,-49,13,-32,8,-61,2,-15,-5,98,-12,78,-18,80,-22,-105,-23,-123,-16,-128,-2,-113,10,21,17,11,17,-112,15,-65,12,78,4,-104,-7,-12,-10,53,-10,110,0,43,10,109,15,-39,13,-26,7,55,0,-108,-8,125,-14,70,-27,-47,-36,-95,-33,52,-20,-29,-3,3,8,-106,8,19,4,-2,3,-82,2,35,-6,103,-15,22,-19,34,-11,-71,3,-63,13,-12,18,102,14,-54,10,-107,3,-94,-3,0,-1,-93,-3,-121,-5,1,0,-59,12,78,21,-91,25,24,21,-77,16,55,10,121,0,-97,-2,-69,-5,-127,-4,49,4,-21,12,-2,15,-10,11,75,3,114,-5,-18,-13,-13,-19,80,-29,31,-34,-58,-28,32,-14,-37,0,123,9,-22,8,51,6,-56,4,-65,1,104,-8,-113,-14,-44,-15,-57,-5,-86,8,2,16,47,17,38,11,-15,6,44,-2,125,-8,31,-4,55,-9,10,-11,-62,-3,100,9,-85,18,85,19,-100,13,94,7,-8,2,-63,-7,84,-14,-65,-19,127,-15,-62,-2,102,8,98,13,66,8,-13,3,-122,-4,87,-11,-92,-17,-46,-20,105,-21,69,-14,67,0,21,11,-112,18,97,18,-89,16,-90,13,9,5,-124,-6,-50,-10,-23,-10,-27,0,121,10,-35,16,116,14,-70,8,8,1,102,-7,50,-14,-41,-25,116,-34,59,-32,50,-19,59,-3,62,8,-81,8,-82,5,1,3,53,1,-111,-7,-16,-16,-12,-20,106,-12,106,2,-115,12,-27,17,-81,14,41,9,-9,3,28,-4,-77,-5,118,-8,-9,-10,-38,-3,54,9,-84,19,-22,24,-128,22,-39,18,109,13,37,3,-93,-3,2,-6,12,-6,-65,3,-64,12,97,15,-40,11,-118,4,12,-4,-8,-11,55,-18,-42,-30,13,-37,-115,-32,86,-17,98,-2,59,8,-46,7,10,5,90,4,57,2,8,-7,-20,-14,49,-16,7,-7,-13,7,20,15,-7,18,33,13,-107,8,79,0,-26,-6,-110,0,69,-4,50,-6,124,1,39,12,-46,21,111,23,81,17,106,11,-116,5,-93,-5,-104,-6,25,-10,-109,-7,56,3,-66,12,41,15,108,9,-6,3,1,-5,53,-13,-76,-19,89,-25,-81,-26,20,-20,120,-6,-71,6,-104,14,55,13,-10,12,-121,9,109,3,30,-8,-14,-12,111,-12,83,-2,74,9,97,15,-7,15,24,8,-43,2,118,-6,69,-12,19,-23,24,-33,-99,-31,53,-19,-20,-3,-26,9,103,10,3,6,29,3,-5,1,-40,-6,57,-15,1,-20,8,-13,-122,1,-64,12,-121,17,-67,13,-24,9,-110,2,-74,-4,27,-6,-27,-8,-128,-10,43,-4,86,8,-104,19,45,24,65,23,45,19,26,14,12,4,-102,-3,98,-6,4,-6,108,3,102,12,75,15,-17,12,46,4,-85,-3,-120,-11,-81,-17,99,-31,-16,-38,-85,-33,60,-18,43,-3,117,8,-121,6,-28,5,49,4,58,2,95,-6,124,-14,36,-17,-115,-7,55,6,-112,15,-57,18,76,14,54,9,83,1,-53,-5,89,1,71,-3,120,-5,109,1,-57,13,97,21,-17,23,-46,18,56,12,95,6,126,-4,29,-5,5,-8,9,-6,-111,4,-59,12,-112,15,125,9,-50,2,-56,-6,-21,-13,58,-20,-33,-27,-117,-29,103,-23,-42,-8,82,4,-77,12,-50,12,-52,11,-88,9,4,2,-23,-8,-41,-12,1,-12,4,-2,49,9,124,16,8,15,21,8,-26,2,-87,-6,76,-37,-86,85};
		
		 json = defaultResolve.resolve(data, null);
		 System.out.println(json.getId() + "->" + json.getResult());
		//最后一組上傳波形
		data = new byte[]{-86,-86,-3,79,-6,-119,4,18,-85,-51,-17,1,0,6,102,83,6,106,-86,85};
		json = defaultResolve.resolve(data, null);
		System.out.println(json.getId() + "->" + json.getResult());

	}
	
   //測(cè)試解析確認(rèn)信息協(xié)議，協(xié)議號(hào)0x01
	private void testACKResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] {-86,-86,-3,79,-6,-119,2,18,-85,-51,-17,1,0,31,101,-61,3,83,0,10,-26,2,0,10,1,87,6,69,3,-80,0,-18,3,98,1,-59,1,-114,7,66,4,104,31,-86,85};
		
		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}
	
	//測(cè)試解析心跳信息協(xié)議，協(xié)議號(hào)0x05
	private void testHeartBeatResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] {-86,-86,-3,79,-6,-119,2,18,-85,-51,-17,1,0,31,101,-61,3,83,0,10,-26,2,0,10,1,87,6,69,3,-80,0,-18,3,98,1,-59,1,-114,7,66,4,104,31,-86,85};
		
		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}
	
  //測(cè)試解析組網(wǎng)上傳協(xié)議，協(xié)議號(hào)0x03
	private void testSensorResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] {-86,-86,-3,79,-6,-119,2,18,-85,-51,-17,1,0,31,101,-61,3,83,0,10,-26,2,0,10,1,87,6,69,3,-80,0,-18,3,98,1,-59,1,-114,7,66,4,104,31,-86,85};
		
		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}
	
  //測(cè)試反解析
	private void testUnResolve() throws DtuMessageException, IOException{
		//反解析
		JSONObject ack = new JSONObject();
		ack.put("Package_Type", 1);
		ack.put("Gateway_Id", 4249877129L);
		ack.put("Package_Number", 0);
		ack.put("command_properties", 2);
		ack.put("BCC", 1);
		
		byte[] data = defaultResolve.unresolve("1",ack);//參數(shù)：協(xié)議號(hào)、協(xié)議屬性對(duì)象。
		
		//[85, 85, -3, 79, -6, -119, 1, 0, 6, 0, 0, 2, 1, 85, -86]
		//打印16進(jìn)制
		System.out.println(HexUtils.bytesToHexString(data));
		
	}
  
	 //測(cè)試反解析組網(wǎng)下傳
	private void testUnResolveSensorConfig() throws DtuMessageException, IOException{
		
		String s = "{\"Gateway_Id\":\"4249877129\",\"Upload_Sensor_Type\":\"9\",\"Sensor_Id\":\"313249263\","
				+ "\"HP_Filter\":\"2\",\"X_Angle\":\"0\",\"Sample_Character_Time\":\"1\",\"Upload_Wave_Type\":\"113\","
				+ "\"Upload_Character_Time\":\"1\",\"Upload_Wave_Time\":\"2\",\"Wave_long\":\"1\",\"Sample_Frequency\":\"800\","
				+ "\"Temperature_alarm_diff\":\"35\",\"Temperature_alarm_HH\":\"80\",\"Temperature_alarm_Change\":\"5\","
				+ "\"Acc_X_alarm_HH\":\"1\",\"Acc_X_alarm_H\":\"0.8\",\"Acc_Y_alarm_HH\":\"1\",\"Acc_Y_alarm_H\":\"0.8\","
				+ "\"Acc_Z_alarm_HH\":\"1\",\"Acc_Z_alarm_H\":\"0.8\",\"Speed_X_alarm_HH\":\"1\",\"Speed_X_alarm_H\":\"0.8\","
				+ "\"Speed_Y_alarm_HH\":\"1\",\"Speed_Y_alarm_H\":\"0.8\",\"Speed_Z_alarm_HH\":\"1\",\"Speed_Z_alarm_H\":\"0.8\"}";
		
		JSONObject sensorConfig = JSONObject.parseObject(s);
		
		sensorConfig.put("Package_Type", 6);
		
		sensorConfig.put("Package_Number", 0);
		
		sensorConfig.put("BCC", 1);
		
		byte[] data = defaultResolve.unresolve("6",sensorConfig);
		
		System.out.println(HexUtils.bytesToHexString(data));
		
	}
	

	//@Test
	public void test()
	{
		try {
			testCharacterResolve();
			
			testWaveResolve();
			
			testUnResolve();
			
			testUnResolveSensorConfig();
			
			JSONObject content = new JSONObject();
			dispatchCenterService.handle("5",content);
			
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	private void testother()
	{
    //獲取讀取BYTEARRAY類的操作類
		JFieldOpt jReadArray = optManager.getJFieldOpt(BaseDataType.BYTEARRAY);
		try {
			// jRead.read(null, null);
      //調(diào)用read方法
			jReadArray.read(null, null, 512);

		} catch (IOException e) {
			e.printStackTrace();
		}
   //獲取讀取SHORTARRAY類的操作類
		JFieldOpt jReadShortArray = optManager.getJFieldOpt(BaseDataType.SHORTARRAY);
		try {
			// jRead.read(null, null);
			jReadShortArray.read(null, null, 520);

		} catch (IOException e) {
			e.printStackTrace();
		}
    
   //根據(jù)返回C協(xié)議號(hào)ID獲取模板類
		Template tm = templateContainer.getFCTemplate("1");
		System.out.println(tm.toString());
    
    //測(cè)試處理業(yè)務(wù)類
		JSONObject content = new JSONObject();
		dispatchCenterService.handle("5",content);
	}

}