//GroovyUtils為通用解析工具
import com.zlgcloud.iotplatform.iotmapping.commons.GroovyUtils
import java.nio.ByteBuffer;




/**
 * 將二進(jìn)制報文解析成物模型的map數(shù)據(jù)
 *
 * @param rawData 二進(jìn)制報文
 * @return 物模型數(shù)據(jù)
 * @description 方法名必須為rawDataToJson，參數(shù)必須是byte[]類型
 */
static Map rawDataToJson(byte[] rawData) {
  Map map = new HashMap<>();
  Map dataMap = new HashMap<>();
  //定義解析數(shù)據(jù)的map，key固定為data，用于存放對應(yīng)事件內(nèi)字段的數(shù)據(jù)
  map.put("data", dataMap);
  //設(shè)置數(shù)據(jù)模型配置中定義的數(shù)據(jù)點(diǎn)
  map.put("event_name", "MX_TEMP_fn.raw");


  //初始溫度、濕度為0
  float temperature = 0;
  float humidity = 0;


  //開始解析數(shù)據(jù)
  ByteBuffer byteBuffer = ByteBuffer.wrap(rawData);
  //從第0個字節(jié)開始讀取
  int offset = 0;
  //讀取長度
  int dataLen = byteBuffer.get(offset);
  offset += 1;
  //如果長度為4，則同時解析溫度和濕度數(shù)據(jù)；否則長度就為2，只解析溫度數(shù)據(jù)
  if (dataLen == 4) {
    // 解析溫度
    temperature = byteBuffer.getShort(offset);
    if (temperature >= 4096) {
      // 負(fù)值
      temperature = -1 * (temperature - 4096);
    }
    temperature = temperature / 100;
    //解析濕度
    offset += 2;
    humidity = byteBuffer.getShort(offset);
    humidity = humidity / 100;
  } else {
    //解析溫度
    temperature = byteBuffer.getShort(offset);
    if (temperature >= 4096) {
      // 負(fù)值
      temperature = -1 * (temperature - 4096);
    }
    temperature = temperature / 100;
  }


  //將數(shù)據(jù)按數(shù)據(jù)模型配置定義的格式放入返回值中
  dataMap.put("temperature", temperature);
  dataMap.put("humidity", humidity);


  return map;
}