ClientId   61df9a6bc7fb24029b0c160d_1126626497_0_0_2022011303
Username   61df9a6bc7fb24029b0c160d_1126626497
Password   20618c172eb24418e0910804889c7d2074a5847e9e7205a41a8bf5adeec399f9

端口: 1883
域名: a161a58a78.iot-mqtts.cn-north-4.myhuaweicloud.com
IP地址: 121.36.42.100

格式: $oc/devices/{device_id}/sys/messages/down
//订阅主题: 平台下发消息给设备
$oc/devices/61df9a6bc7fb24029b0c160d_1126626497/sys/messages/down

格式: $oc/devices/{device_id}/sys/properties/report
//设备上报主题请求
$oc/devices/61df9a6bc7fb24029b0c160d_1126626497/sys/properties/report


//上报的数据格式如下
{"services": [{"service_id": "healthy","properties":{"HeartRate":127}},{"service_id": "healthy","properties":{"motion":2000}},{"service_id": "healthy","properties":{"temperature":36.2}}]}

请求方法 GET
URI地址  /v5/iot/{project_id}/devices/{device_id}/properties
传输协议 HTTPS

拼接好的地址: 
https://iotda.cn-north-4.myhuaweicloud.com/v5/iot/0e5957be8a00f53c2fa7c0045e4d8fbf/devices/61df9a6bc7fb24029b0c160d_1126626497/properties?service_id=1126626497

其中的project_id和device_id需要根据自己的设备信息修改。


请求头:
{
 "User-Agent": "API Explorer",
 "X-Auth-Token": "******",   这个是鉴权用的token
 "Content-Type": "application/json"
}


响应体(设备上传的数据)
{
 "response": {
  "services": [
   {
    "service_id": "healthy",
    "properties": {
     "HeartRate": 127
    }
   },
   {
    "service_id": "healthy",
    "properties": {
     "motion": 2000
    }
   },
   {
    "service_id": "healthy",
    "properties": {
     "temperature": 36.2
    }
   }
  ]
 }
}

$oc/devices/61df9a6bc7fb24029b0c160d_1126626497/sys/properties/get/request_id=336bcb57-0e0a-44d0-90f7-31386cb54a3c{"service_id":"1126626497"}

主题格式: $oc/devices/{device_id}/sys/properties/get/response/request_id={request_id}

示    例:
$oc/devices/61df9a6bc7fb24029b0c160d_1126626497/sys/properties/get/response/request_id=336bcb57-0e0a-44d0-90f7-31386cb54a3c

响应的数据格式:
{"services": [{"service_id": "healthy","properties":{"HeartRate":127}},{"service_id": "healthy","properties":{"motion":2000}},{"service_id": "healthy","properties":{"temperature":36.2}}]}

/*
功能: 获取token
*/
void Widget::GetToken()
{
    //表示获取token
    function_select=3;

    QString requestUrl;
    QNetworkRequest request;

    //设置请求地址
    QUrl url;

    //获取token请求地址
    requestUrl = QString("https://iam.%1.myhuaweicloud.com/v3/auth/tokens")
                 .arg(SERVER_ID);

    //自己创建的TCP服务器,测试用
    //requestUrl="http://10.0.0.6:8080";

    //设置数据提交格式
    request.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("application/json;charset=UTF-8"));

    //构造请求
    url.setUrl(requestUrl);

    request.setUrl(url);

    QString text =QString("{\"auth\":{\"identity\":{\"methods\":[\"password\"],\"password\":"
    "{\"user\":{\"domain\": {"
    "\"name\":\"%1\"},\"name\": \"%2\",\"password\": \"%3\"}}},"
    "\"scope\":{\"project\":{\"name\":\"%4\"}}}}")
            .arg(MAIN_USER)
            .arg(IAM_USER)
            .arg(IAM_PASSWORD)
            .arg(SERVER_ID);

    //发送请求
    manager->post(request, text.toUtf8());
}

//查询设备属性
void Widget::Get_device_properties()
{
    //表示获取token
    function_select=0;

    QString requestUrl;
    QNetworkRequest request;

    //设置请求地址
    QUrl url;

    //获取token请求地址
    requestUrl = QString("https://iotda.%1.myhuaweicloud.com/v5/iot/%2/devices/%3/properties?service_id=%4")
                 .arg(SERVER_ID)
            .arg(PROJECT_ID)
            .arg(device_id)
            .arg(service_id);

    //自己创建的TCP服务器,测试用
    //requestUrl="http://10.0.0.6:8080";

    //设置数据提交格式
    request.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("application/json"));

    //设置token
    request.setRawHeader("X-Auth-Token",Token);

    //构造请求
    url.setUrl(requestUrl);

    request.setUrl(url);

    //发送请求
    manager->get(request);
}

int BPM;                   			 // 用于保存脉冲速率
int Signal;               			 // 持有的原始数据
int IBI = 600;            			 
unsigned char Pulse = false;    
unsigned char QS = false;        
int rate[10];                    
unsigned long sampleCounter = 0; 
unsigned long lastBeatTime = 0;  
int P =512;                      
int T = 512;                     
int thresh = 512;               
int amp = 100;                  
unsigned char firstBeat = true;  
unsigned char secondBeat = false;
/*
	定时器2中断服务函数 用于周期性采集心率值
*/
void TIM2_IRQHandler(void)
{
	uint16_t runningTotal=0;
	uint8_t i;
	uint16_t Num;
	
	if(TIM2->SR&1<<0)
	{
			//读取到的值右移2位，12位-->10位
		Signal = Get_AdcCHx_DATA(1)>>2;     	
		sampleCounter += 2;                          
		Num = sampleCounter - lastBeatTime; 

		//发现脉冲波的波峰和波谷
		//  find the peak and trough of the pulse wave
		if(Signal < thresh && Num > (IBI/5)*3)
		{   
			if (Signal < T)
			{                       			 				
				T = Signal;  
			}
		}

		if(Signal > thresh && Signal > P)
		{ 
			P = Signal; 
		}  

		//开始寻找心跳
		//当脉冲来临的时候，signal的值会上升
		if (Num > 250)
		{                            
			if ( (Signal > thresh) && (Pulse == false) && (Num > (IBI/5)*3) )
			{        
				Pulse = true;                         
				//LED0(0); 
				IBI = sampleCounter - lastBeatTime;       
				lastBeatTime = sampleCounter;              

				if(secondBeat)
				{                       
					secondBeat = false;             
					for(i=0; i<=9; i++)
					{               
						rate[i] = IBI;              
					}
				}

				if(firstBeat)
				{                         						
					firstBeat = false;                   	
					secondBeat = true;                   	
					return;                              	
				}   

				for(i=0; i<=8; i++)
				{                    							
					rate[i] = rate[i+1];                
					runningTotal += rate[i];           
				}

				rate[9] = IBI;                       
				runningTotal += rate[9];                
				runningTotal /= 10;                     
				BPM = 60000/runningTotal;               
				QS = true;                            
			}                       
		}

		//脉冲开始下降
		if (Signal < thresh && Pulse == true)
		{
			Pulse = false;                        
			amp = P - T;                          
			thresh = amp/2 + T;                    
			P = thresh;                         
			T = thresh;
		}

		//没有检测到脉冲，设置默认值
		if (Num > 2500)
		{                       
			thresh = 512;                       
			P = 512;                              
			T = 512;                              
			lastBeatTime = sampleCounter;               
			firstBeat = true;                      
			secondBeat = false;                    
		}   
	}
	TIM2->SR&=0x0; //清中断标志
}

//向SSD1106写入一个字节。
//dat:要写入的数据/命令
//cmd:数据/命令标志 0,表示命令;1,表示数据;
void OLED_WR_Byte(u8 dat,u8 cmd)
{	
	u8 i;			  
	if(cmd)
	  OLED_DC_Set();
	else 
	  OLED_DC_Clr();		  
	OLED_CS_Clr();
	for(i=0;i<8;i++)
	{			  
		OLED_SCLK_Clr();
		if(dat&0x80)
		   OLED_SDIN_Set();
		else 
		   OLED_SDIN_Clr();
		OLED_SCLK_Set();
		dat<<=1;   
	}				 		  
	OLED_CS_Set();
	OLED_DC_Set();   	  
} 

//设置坐标的位置(x范围: 0~127   ,   y的范围:0~63)
//注意: 8 行为一页,共 64 行即 8 页
void OLED_Set_Pos(unsigned char x, unsigned char y) 
{ 
	OLED_WR_Byte(0xb0+y,OLED_CMD);
	OLED_WR_Byte(((x&0xf0)>>4)|0x10,OLED_CMD);
	OLED_WR_Byte((x&0x0f)|0x01,OLED_CMD); 
}

u8 Receive_ok;
u8 rebuf[20]={0};
void RxTempInfo(void)
{
	 static uint8_t i=0;
	if(USART2->SR&1<<5)     //判断接收标志
	{
		rebuf[i++]=USART2->DR;//读取串口数据，同时清接收标志
		if(rebuf[0]!=0x5a)    //帧头不对
			i=0;	
		if((i==2)&&(rebuf[1]!=0x5a))//帧头不对
			i=0;
	
		if(i>3)//i等于4时，已经接收到数据量字节rebuf[3]
		{
			if(i!=(rebuf[3]+5))//判断是否接收一帧数据完毕
				return ;	
			switch(rebuf[2])   //接收完毕后处理
			{
				case 0x45:
					if(!Receive_ok)//当数据处理完成后才接收新的数据
					{
						 Receive_ok=1;//接收完成标志
					}
					break;
				case 0x15:break;
				case 0x35:break;
			}
			i=0;//缓存清0
		}
	}
}

void GetTempInfo(void)
{
	float TO=0,TA=0;
    u8 sum=0,i=0;
	for(sum=0,i=0;i<(rebuf[3]+4);i++)
	{
	  	sum+=rebuf[i];  
	}
	if(sum==rebuf[i])//校验和判断
	{
		TO=(float)((rebuf[4]<<8)|rebuf[5])/100;  //得到真实温度
		TA=(float)((rebuf[6]<<8)|rebuf[7])/100;  //得到真实温度	
	}
	printf("TO: %f\r\n",TO);
	printf("TA: %f\r\n",TA);
}

/*******************************************************************************
* LOCAL VARIABLES
*/
//存放三轴数据  
float oriValues[3] = {0};    
//用于存放计算阈值的波峰波谷差值  
float tempValue[VALUE_NUM] ={0};  
int tempCount = 0;  
//是否上升的标志位  
u8 isDirectionUp = FALSE;  
//持续上升次数  
int continueUpCount = 0;  
//上一点的持续上升的次数，为了记录波峰的上升次数  
int continueUpFormerCount = 0;  
//上一点的状态，上升还是下降  
u8 lastStatus = FALSE;  
//波峰值  
float peakOfWave = 0;  
//波谷值  
float valleyOfWave = 0;  
//此次波峰的时间  
long timeOfThisPeak = 0;  
//上次波峰的时间  
long timeOfLastPeak = 0;  
//当前的时间  
long timeOfNow = 0;  
//当前传感器的值  
float gravityNew = 0;  
//上次传感器的值  
float gravityOld = 0;  
//动态阈值需要动态的数据，这个值用于这些动态数据的阈值  
float initialValue = (float) 1.3;  
//初始阈值  
float ThreadValue = (float) 2.0;
//三轴轴值
accValue_t accValue;
//行走信息:卡路里、里程、步数
static sportsInfo_t sportsInfo;
//计步缓存
static u8 stepTempCount =0;


/*******************************************************************************
* 函数名：DetectorNewStep
* 功能描述： 
*		  步伐更新：如果检测到了波峰，并且符合时间差以及阈值的条件，则判定为1步 		
*		  阀值更新：符合时间差条件，波峰波谷差值大于initialValue，则将该差值纳入阈值的计算中 		
* 参数说明：  
输入：
values：经过处理的G-sensor数据
timeStamp_p：时间戳
* 返回值说明：
* 修改记录：sportsInfo_t *onSensorChanged(accValue_t *pAccValue,timeStamp_t *timeStamp_p,personInfo_t * personInfo)
*******************************************************************************/
sportsInfo_t *DetectorNewStep(float values,timeStamp_t *timeStamp_p,personInfo_t * personInfo) 
{  
  static u32 time_old;
  personInfo_t *userInfo = personInfo;
  static u32 step_per_2_second;  //每两秒所走的步数
  float step_lenth,walk_speed,walk_distance,Calories;//步长
  u32 time_now;
  timeStamp_t *time_p = timeStamp_p;
  if (gravityOld == 0) 
  {  
    gravityOld = values;  
  } 
  else 
  {  
    if (DetectorPeak(values, gravityOld))//检测到波峰
    {  
      timeOfLastPeak = timeOfThisPeak;//更新上次波峰的时间  
      //将时间戳转换为以毫秒ms为单位
      time_now = timeOfNow = ((time_p->hour*60+time_p->minute)*60+time_p->second)*1000+time_p->twentyMsCount*20; //获取时间 ,并转化为毫秒
      //如果检测到了波峰，并且符合时间差以及阈值的条件，则判定为1步 
      if (  (timeOfNow - timeOfLastPeak >= 250 )//Jahol Fan 修改为300，防止轻微动都也会检测步子
          //&& (timeOfNow - timeOfLastPeak <= 2000)
          &&(peakOfWave - valleyOfWave >= ThreadValue)
            )
      {  
        timeOfThisPeak = timeOfNow; //更新此次波峰时间 
        
        
       	stepTempCount++;//Jahol:加1为两步
        step_per_2_second ++;
        //Jahol:这样计算卡路里，不能滤除人为的误操作，导致的结果是:里程和卡路里偏大
        if((time_now - time_old) >= 2000 )    //如果时间过了2秒
        {

          if( 1 == step_per_2_second )				   
          {
            step_lenth = userInfo->height/5;
          }
          else if( 2 == step_per_2_second )
          {
            step_lenth = userInfo->height/4;
          }
          else if( 3 == step_per_2_second )
          {
            step_lenth = userInfo->height/3;
          }
          else if( 4 == step_per_2_second )
          {
            step_lenth = userInfo->height/2;
          }
          else if(5 == step_per_2_second)			  //Jahol：为了使计步准确，设置上限值为5步，牺牲卡路里准确性
          {
            step_lenth = userInfo->height/1.2f;
          }
          else if( 7 == step_per_2_second )
          {
            step_lenth = userInfo->height;
          }
          else if(step_per_2_second >= 8)				//		step_diff>8
          {
            step_lenth = userInfo->height*1.2f;
          }
          else 
          {
            step_lenth = 0;
          }
          walk_speed = step_per_2_second*step_lenth/2;   //速度 ，单位：米/秒
          walk_distance  = step_per_2_second*step_lenth; //行走距离，单位：米
          Calories = 4.5f*walk_speed*(userInfo->weight/2)/1800;  //Jahol:weight是以kg为单位
          sportsInfo.calories  += Calories;
          sportsInfo.distance  += walk_distance;		
          time_old = time_now;         //更新时间
          step_per_2_second = 0;
          
        }   
        else 
        {
          //do nothing
        }		
        /* 
        * 处理无效运动： 
        * 1.连续记录5才开始计步 
        * 2.例如记录的步用户停住超过3秒，则前面的记录失效，下次从头开始 
        * 3.连续4记录了步用户还在运动，之前的数据才有效 
        * */  				
        if ((stepTempCount< 5 )&&(timeOfNow - timeOfLastPeak >= 3000))          
        {
          stepTempCount = 0;
        }
        else if((stepTempCount>= 5)&&(timeOfNow - timeOfLastPeak <= 3000))
        {
          sportsInfo.stepCount += stepTempCount;          
          stepTempCount         = 0; 				
        }
        else
        {
          //do nothing
        }
        
        
      }  
      //Jahol:更新阀值,问题:阀值不会一直变大，不能变小?
      if (timeOfNow - timeOfLastPeak >= 250  
          && (peakOfWave - valleyOfWave >= initialValue)) 
      {  
        timeOfThisPeak = timeOfNow;  
        ThreadValue = Peak_Valley_Thread(peakOfWave - valleyOfWave);//更新阀值  
      }  
    }  
  }  
  gravityOld = values;  
  return &sportsInfo;
}