【Io开发笔记】机智云智能浇花器实战(3)-自动生成代码移植

机智云 · 发表于 2022-7-25 16:47:28

第一篇内容：总体设计/系统功能介绍/机智云自助开发平台-开发利器GAgent等等
点击下载：【Io开发笔记】机智云智能浇花器实战(1)-基础Demo实现

第二篇内容：
继电器实现/功能测试/DHT11驱动代码实现/OLED屏幕显示传感器数据/中文字模制作等等
点击下载：机智云智能浇花器实战(2)-基础Demo实现

一，BH1750光照传感器原理图

二，BH1750传感器代码

#include "bh1750.h"
#include "delay.h"
uint8_t BUF[8]; //接收数据缓存区
int mcy; //进位标志
/**开始信号**/
void BH1750_Start()
{
BH1750_SDA_H; //拉高数据线
BH1750_SCL_H; //拉高时钟线
Delay_nus(5); //延时
GPIO_ResetBits(BH1750_PORT, BH1750_SDA_PIN); //产生下降沿
Delay_nus(5); //延时
GPIO_ResetBits(BH1750_PORT, BH1750_SCL_PIN); //拉低时钟线
}
/***停止信号***/
void BH1750_Stop()
{
BH1750_SDA_L; //拉低数据线
BH1750_SCL_H; //拉高时钟线
Delay_nus(5); //延时
GPIO_SetBits(BH1750_PORT, BH1750_SDA_PIN); //产生上升沿
Delay_nus(5); //延时
}
/******************
发送应答信号
入口参数:ack (0:ACK 1:NAK)
******************/
void BH1750_SendACK(int ack)
{
GPIO_InitTypeDef GPIO_InitStruct;
GPIO_InitStruct.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_InitStruct.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_InitStruct.GPIO_Pin = BH1750_SDA_PIN;
GPIO_Init(BH1750_PORT, &GPIO_InitStruct);
if(ack == 1) //写应答信号
BH1750_SDA_H;
else if(ack == 0)
BH1750_SDA_L;
else
return;
BH1750_SCL_H; //拉高时钟线
Delay_nus(5); //延时
BH1750_SCL_L; //拉低时钟线
Delay_nus(5); //延时
}
/******************
接收应答信号
******************/
int BH1750_RecvACK()
{
GPIO_InitTypeDef GPIO_InitStruct;
GPIO_InitStruct.GPIO_Mode=GPIO_Mode_IPU; /*这里一定要设成输入上拉，否则不能读出数据*/
GPIO_InitStruct.GPIO_Speed=GPIO_Speed_50MHz;
GPIO_InitStruct.GPIO_Pin=BH1750_SDA_PIN;
GPIO_Init(BH1750_PORT,&GPIO_InitStruct);
BH1750_SCL_H; //拉高时钟线
Delay_nus(5); //延时
if(GPIO_ReadInputDataBit(BH1750_PORT,BH1750_SDA_PIN)==1)//读应答信号
mcy = 1 ;
else
mcy = 0 ;
BH1750_SCL_L; //拉低时钟线
Delay_nus(5); //延时
GPIO_InitStruct.GPIO_Mode=GPIO_Mode_Out_PP;
GPIO_Init(BH1750_PORT,&GPIO_InitStruct);
return mcy;
}
/******************
向IIC总线发送一个字节数据
******************/
void BH1750_SendByte(uint8_t dat)
{
uint8_t i;
for (i=0; i<8; i++) //8位计数器
{
if( 0X80 & dat )
GPIO_SetBits(BH1750_PORT,BH1750_SDA_PIN);
else
GPIO_ResetBits(BH1750_PORT,BH1750_SDA_PIN);
dat <<= 1;
BH1750_SCL_H; //拉高时钟线
Delay_nus(5); //延时
BH1750_SCL_L; //拉低时钟线
Delay_nus(5); //延时
}
BH1750_RecvACK();
}
uint8_t BH1750_RecvByte()
{
uint8_t i;
uint8_t dat = 0;
uint8_t bit;
GPIO_InitTypeDef GPIO_InitStruct;
GPIO_InitStruct.GPIO_Mode = GPIO_Mode_IPU; /*这里一定要设成输入上拉，否则不能读出数据*/
GPIO_InitStruct.GPIO_Pin = BH1750_SDA_PIN;
GPIO_InitStruct.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_Init(BH1750_PORT,&GPIO_InitStruct );
GPIO_SetBits(BH1750_PORT,BH1750_SDA_PIN); //使能内部上拉,准备读取数据,
for (i=0; i<8; i++) //8位计数器
{
dat <<= 1;
BH1750_SCL_H; //拉高时钟线
Delay_nus(5); //延时
if( SET == GPIO_ReadInputDataBit(BH1750_PORT,BH1750_SDA_PIN))
bit = 0X01;
else
bit = 0x00;
dat |= bit; //读数据
BH1750_SCL_L; //拉低时钟线
Delay_nus(5); //延时
}
GPIO_InitStruct.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_Init(BH1750_PORT, &GPIO_InitStruct );
return dat;
}
void Single_Write_BH1750(uint8_t REG_Address)
{
BH1750_Start(); //起始信号
BH1750_SendByte(SlaveAddress); //发送设备地址+写信号
BH1750_SendByte(REG_Address); //内部寄存器地址，请参考中文pdf22页
// BH1750_SendByte(REG_data); //内部寄存器数据，请参考中文pdf22页
BH1750_Stop(); //发送停止信号
}
//初始化BH1750，根据需要请参考pdf进行修改**
void BH1750_Init()
{
GPIO_InitTypeDef GPIO_InitStruct;
/*开启GPIOB的外设时钟*/
RCC_APB2PeriphClockCmd( RCC_APB2Periph_GPIOB, ENABLE);
GPIO_InitStruct.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_InitStruct.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_InitStruct.GPIO_Pin = BH1750_SDA_PIN | BH1750_SCL_PIN ;
GPIO_Init(BH1750_PORT,&GPIO_InitStruct);
Single_Write_BH1750(0x01);
Delay_nms(180); //延时180ms
}
//连续读出BH1750内部数据
void mread(void)
{
uint8_t i;
BH1750_Start(); //起始信号
BH1750_SendByte(SlaveAddress+1); //发送设备地址+读信号
for (i=0; i<3; i++) //连续读取6个地址数据，存储中BUF
{
BUF = BH1750_RecvByte(); //BUF[0]存储0x32地址中的数据
if (i == 3)
{
BH1750_SendACK(1); //最后一个数据需要回NOACK
}
else
{
BH1750_SendACK(0); //回应ACK
}
}
BH1750_Stop(); //停止信号
Delay_nms(5);
}
float Read_BH1750(void)
{
int dis_data; //变量
float temp1;
float temp2;
Single_Write_BH1750(0x01); // power on
Single_Write_BH1750(0x10); // H- resolution mode
Delay_nms(180); //延时180ms
mread(); //连续读出数据，存储在BUF中
dis_data=BUF[0];
dis_data=(dis_data<<8)+BUF[1]; //合成数据
temp1=dis_data/1.2;
temp2=10*dis_data/1.2;
temp2=(int)temp2%10;
return temp1;
}

[color=rgb(0, 0, 0) !important]复制代码

#ifndef __BH1750_H__
#define __BH1750_H__
#include "STM32f10x.h"
/*
      定义器件在IIC总线中的从地址,根据ALT  ADDRESS地址引脚不同修改
      ALT  ADDRESS引脚接地时地址为0x46，接电源时地址为0xB8
*/
#define       SlaveAddress    0x46
#define BH1750_PORT    GPIOB
#define BH1750_SCL_PIN GPIO_Pin_1
#define BH1750_SDA_PIN GPIO_Pin_0
#define BH1750_SCL_H    GPIO_SetBits(BH1750_PORT,BH1750_SCL_PIN)
#define BH1750_SCL_L    GPIO_ResetBits(BH1750_PORT,BH1750_SCL_PIN)
#define BH1750_SDA_H    GPIO_SetBits(BH1750_PORT,BH1750_SDA_PIN)
#define BH1750_SDA_L    GPIO_ResetBits(BH1750_PORT,BH1750_SDA_PIN)
extern uint8_t BUF[8];                      //接收数据缓存区
extern int       dis_data;                      //变量
extern int       mcy;                         //表示进位标志位
void BH1750_Init(void);
void conversion(uint32_t temp_data);
void  Single_Write_BH1750(uint8_t REG_Address); //单个写入数据
uint8_t Single_Read_BH1750(uint8_t REG_Address); //单个读取内部寄存器数据
void  mread(void);                               //连续的读取内部寄存器数据
float Read_BH1750(void);
#endif

[color=rgb(0, 0, 0) !important]复制代码

BH1750传感器代码说明

核心板单独测试程序在PB0PB1管脚是完全正常，不知道是不是核心板的PB2上接了什么暂时还未排查出来问题，如果你是用开发板或者是自己设计的项目板的话，那么程序是直接可以使用的程序依然按照PB0PB1保留。

三，机智云自助开发平台数据点创建
机智云官方网站：https://www.gizwits.com/
步骤1，创建产品

创建好后就会有基本信息

步骤2，填写机智云产品ProductKey

这两个信息比较重要最好是保存下来

Product Key ：9c8a5a8e38344fb4af14b6db0f5b1df7
Product Secret ：45c86d8c6a2a4b1dac7d68df54f6e4f0

[color=rgb(0, 0, 0) !important]复制代码

步骤3，定义自己的数据点

只读：就是只允许赋值数据传感器赋值给平台平台只能读取
可写：就是数据可以被修改继电器的开关状态平台可以修改

四，MCU开发

mcu开发注意事项平台选Common其实就是STM32F103x平台

1，生成代码包

2，下载自动生成的代码包

3，机智云Gizwits协议移植

这两个文件夹要添加到自己的工程

这是添加的文件夹以及文件的目录

4，修改gizwits_product.c

#include <stdio.h>
#include <string.h>
#include "gizwits_product.h"
#include "usart3.h"
static uint32_t timerMsCount;
uint8_t aRxBuffer;
dataPoint_t currentDataPoint;
uint8_t wifi_flag;
//存放事件处理API接口函数
int8_t gizwitsEventProcess(eventInfo_t *info, uint8_t *gizdata, uint32_t len)
{
  uint8_t i = 0;
  dataPoint_t *dataPointPtr = (dataPoint_t *)gizdata;
  moduleStatusInfo_t *wifiData = (moduleStatusInfo_t *)gizdata;
  protocolTime_t *ptime = (protocolTime_t *)gizdata;
#if MODULE_TYPE
  gprsInfo_t *gprsInfoData = (gprsInfo_t *)gizdata;
#else
  moduleInfo_t *ptModuleInfo = (moduleInfo_t *)gizdata;
#endif
  if((NULL == info) || (NULL == gizdata))
  {
return -1;
  }
  for(i=0; i<info->num; i++)
  {
switch(info->event)
{
   case EVENT_Relay_1:
      currentDataPoint.valueRelay_1 = dataPointPtr->valueRelay_1;
      GIZWITS_LOG("Evt: EVENT_Relay_1 %d \n", currentDataPoint.valueRelay_1);
      if(0x01 == currentDataPoint.valueRelay_1)
      {
         currentDataPoint.valueRelay_1 = 1;
      }
      else
      {
         currentDataPoint.valueRelay_1 = 0;
      }
      break;
   case WIFI_SOFTAP:
      break;
   case WIFI_AIRLINK:
      break;
   case WIFI_STATION:
      break;
   case WIFI_CON_ROUTER:
      break;
   case WIFI_DISCON_ROUTER:
      break;
   case WIFI_CON_M2M:
            wifi_flag = 1; //WiFi连接标志
      break;
   case WIFI_DISCON_M2M:
            wifi_flag = 0; //WiFi断开标志
      break;
   case WIFI_RSSI:
      GIZWITS_LOG("RSSI %d\n", wifiData->rssi);
      break;
   case TRANSPARENT_DATA:
      GIZWITS_LOG("TRANSPARENT_DATA \n");
      //user handle , Fetch data from [data] , size is [len]
      break;
   case WIFI_NTP:
      GIZWITS_LOG("WIFI_NTP : [%d-%d-%d %02d:%02d:%02d][%d] \n",ptime->year,ptime->month,ptime->day,ptime->hour,ptime->minute,ptime->second,ptime->ntp);
      break;
   case MODULE_INFO:
         GIZWITS_LOG("MODULE INFO ...\n");
   #if MODULE_TYPE
         GIZWITS_LOG("GPRS MODULE ...\n");
         //Format By gprsInfo_t
   #else
         GIZWITS_LOG("WIF MODULE ...\n");
         //Format By moduleInfo_t
         GIZWITS_LOG("moduleType : [%d] \n",ptModuleInfo->moduleType);
   #endif
break;
   default:
      break;
}
  }
  return 0;
}
void userHandle(void)
{
/*
currentDataPoint.valueTemp = ;//Add Sensor Data Collection
currentDataPoint.valueHumi = ;//Add Sensor Data Collection
currentDataPoint.valueLight_Intensity = ;//Add Sensor Data Collection
*/
}
void userInit(void)
{
memset((uint8_t*)¤tDataPoint, 0, sizeof(dataPoint_t));
            currentDataPoint.valueRelay_1       = 0;
            currentDataPoint.valueTemp          = 0;
            currentDataPoint.valueHumi          = 0;
            currentDataPoint.valueLight_Intensity = 0;
}
void gizTimerMs(void)
{
timerMsCount++;
}
uint32_t gizGetTimerCount(void)
{
return timerMsCount;
}
void mcuRestart(void)
{
      __set_FAULTMASK(1);
      NVIC_SystemReset();
}
void TIMER_IRQ_FUN(void)
{
  gizTimerMs();
}
void UART_IRQ_FUN(void)
{
  uint8_t value = 0;
  gizPutData(&value, 1);
}
int32_t uartWrite(uint8_t *buf, uint32_t len)
{
uint32_t i = 0;
if(NULL == buf)
{
      return -1;
}
for(i=0; i<len; i++)
{
      USART_SendData(USART3,buf);
      while(USART_GetFlagStatus(USART3, USART_FLAG_TC) == RESET); //循环发送,直到发送完毕
      if(i >=2 && buf == 0xFF)
      {
         USART_SendData(USART3, 0x55);
         while (USART_GetFlagStatus(USART3, USART_FLAG_TC) == RESET); //循环发送,直到发送完毕
      }
}
return len;
}

[color=rgb(0, 0, 0) !important]复制代码
5，修改

#ifndef _GIZWITS_PRODUCT_H
#define _GIZWITS_PRODUCT_H
#ifdef __cplusplus
extern "C" {
#endif
#include <stdint.h>
//#include "stm32f1xx.h"
#include "gizwits_protocol.h"
/**
* MCU software version
*/
#define SOFTWARE_VERSION "03030000"
/**
* MCU hardware version
*/
#define HARDWARE_VERSION "03010100"
/**
* Communication module model
*/
#define MODULE_TYPE 0 //0,WIFI ;1,GPRS
/**@name TIM3 related macro definition
* @{
*/
#define TIMER                                           TIM3
#define TIMER_IRQ                                  TIM3_IRQn
#define TIMER_RCC                                  RCC_APB1Periph_TIM3
#define TIMER_IRQ_FUN                      TIM3_IRQHandler
/**@} */
/**@name USART related macro definition
* @{
*/
#define UART_BAUDRATE                      9600
#define UART_PORT                            2
#define UART                               USART2
#define UART_IRQ                            USART2_IRQn
#define UART_IRQ_FUN                         USART2_IRQHandler
#if (UART_PORT == 1)
#define UART_GPIO_Cmd       RCC_APB2PeriphClockCmd
#define UART_GPIO_CLK       RCC_APB2Periph_GPIOA
#define UART_AFIO_Cmd       RCC_APB2PeriphClockCmd
#define UART_AFIO_CLK       RCC_APB2Periph_AFIO
#define UART_CLK_Cmd          RCC_APB2PeriphClockCmd
#define UART_CLK             RCC_APB2Periph_USART1
#define UART_GPIO_PORT       GPIOA
#define UART_RxPin          GPIO_Pin_10
#define UART_TxPin          GPIO_Pin_9
#endif
#if (UART_PORT == 2)
#define UART_GPIO_Cmd       RCC_APB2PeriphClockCmd
#define UART_GPIO_CLK       RCC_APB2Periph_GPIOA
#define UART_AFIO_Cmd       RCC_APB2PeriphClockCmd
#define UART_AFIO_CLK       RCC_APB2Periph_AFIO
#define UART_CLK_Cmd          RCC_APB1PeriphClockCmd
#define UART_CLK             RCC_APB1Periph_USART2
#define UART_GPIO_PORT       GPIOA
#define UART_RxPin          GPIO_Pin_3
#define UART_TxPin          GPIO_Pin_2
#endif
#if (UART_PORT == 3)
#define UART_GPIO_Cmd       RCC_APB2PeriphClockCmd
#define UART_GPIO_CLK       RCC_APB2Periph_GPIOC
#define UART_AFIO_Cmd       RCC_APB2PeriphClockCmd
#define UART_AFIO_CLK       RCC_APB2Periph_AFIO
#define UART_CLK_Cmd          RCC_APB1PeriphClockCmd
#define UART_CLK             RCC_APB1Periph_USART3
#define UART_GPIO_PORT       GPIOC
#define UART_RxPin          GPIO_Pin_11
#define UART_TxPin          GPIO_Pin_10
#endif
/**@} */
/** User area the current device state structure*/
extern dataPoint_t currentDataPoint;
void gizTimerMs(void);
uint32_t gizGetTimerCount(void);
void timerInit(void);
void uartInit(void);
void userInit(void);
void userHandle(void);
void mcuRestart(void);
int32_t uartWrite(uint8_t *buf, uint32_t len);
int8_t gizwitsEventProcess(eventInfo_t *info, uint8_t *data, uint32_t len);
#ifdef __cplusplus
}
#endif
#endif

[color=rgb(0, 0, 0) !important]复制代码

5，修改gizwits_product.h
Listitem
Listitem
Listitem
Listitem
Listitem

/**
***************************
* @file       gizwits_protocol.c
* @brief       Corresponding gizwits_product.c header file (including product hardware and software version definition)
* @author    Gizwits
* @date       2017-07-19
* @version    V03030000
* @copyright Gizwits
*
* @note       机智云.只为智能硬件而生
*             Gizwits Smart Cloud  for Smart Products
*             链接|增值ֵ|开放|中立|安全|自有|自由|生态
*             www.gizwits.com
*
***************************/
//#include "ringBuffer.h"
//#include "gizwits_product.h"
//#include "dataPointTools.h"
#include "delay.h"
/** Protocol global variables **/
//gizwitsProtocol_t gizwitsProtocol;
//extern dataPoint_t currentDataPoint;
//extern uint8_t wifi_flag;
/**@name The serial port receives the ring buffer implementation
* @{
*/
rb_t pRb;                                              ///< Ring buffer structure variable
static uint8_t rbBuf[RB_MAX_LEN];                      ///< Ring buffer data cache buffer
/**@} */
/**
* @brief Write data to the ring buffer
* @param [in] buf       : buf adress
* @param [in] len       : byte length
* @return correct : Returns the length of the written data
         failure : -1
*/
int32_t gizPutData(uint8_t *buf, uint32_t len)
{
int32_t count = 0;
if(NULL == buf)
{
      GIZWITS_LOG("ERR: gizPutData buf is empty \n");
      return -1;
}
count = rbWrite(&pRb, buf, len);
if(count != len)
{
      GIZWITS_LOG("ERR: Failed to rbWrite \n");
      return -1;
}
return count;
}
/**
* @brief Protocol header initialization
*
* @param [out] head       : Protocol header pointer
*
* @return 0， success; other， failure
*/
static int8_t gizProtocolHeadInit(protocolHead_t *head)
{
if(NULL == head)
{
      GIZWITS_LOG("ERR: gizProtocolHeadInit head is empty \n");
      return -1;
}
memset((uint8_t *)head, 0, sizeof(protocolHead_t));
head->head[0] = 0xFF;
head->head[1] = 0xFF;
return 0;
}
/**
* @brief Protocol ACK check processing function
*
* @param [in] data          : data adress
* @param [in] len          : data length
*
* @return 0， suceess; other， failure
*/
static int8_t gizProtocolWaitAck(uint8_t *gizdata, uint32_t len)
{
if(NULL == gizdata)
{
      GIZWITS_LOG("ERR: data is empty \n");
      return -1;
}
memset((uint8_t *)&gizwitsProtocol.waitAck, 0, sizeof(protocolWaitAck_t));
memcpy((uint8_t *)gizwitsProtocol.waitAck.buf, gizdata, len);
gizwitsProtocol.waitAck.dataLen = (uint16_t)len;
gizwitsProtocol.waitAck.flag = 1;
gizwitsProtocol.waitAck.sendTime = gizGetTimerCount();
return 0;
}
/**
* @brief generates "controlled events" according to protocol
* @param [in] issuedData: Controlled data
* @param [out] info: event queue
* @param [out] dataPoints: data point data
* @return 0, the implementation of success, non-0, failed
*/
static int8_t ICACHE_FLASH_ATTR gizDataPoint2Event(gizwitsIssued_t *issuedData, eventInfo_t *info, dataPoint_t *dataPoints)
{
if((NULL == issuedData) || (NULL == info) ||(NULL == dataPoints))
{
      GIZWITS_LOG("gizDataPoint2Event Error , Illegal Param\n");
      return -1;
}
/** Greater than 1 byte to do bit conversion **/
if(sizeof(issuedData->attrFlags) > 1)
{
      if(-1 == gizByteOrderExchange((uint8_t *)&issuedData->attrFlags,sizeof(attrFlags_t)))
      {
         GIZWITS_LOG("gizByteOrderExchange Error\n");
         return -1;
      }
}
if(0x01 == issuedData->attrFlags.flagRelay_1)
{
      info->event[info->num] = EVENT_Relay_1;
      info->num++;
      dataPoints->valueRelay_1 = gizStandardDecompressionValue(Relay_1_BYTEOFFSET,Relay_1_BITOFFSET,Relay_1_LEN,(uint8_t *)&issuedData->attrVals.wBitBuf,sizeof(issuedData->attrVals.wBitBuf));
}
return 0;
}
/**
* @brief contrasts the current data with the last data
*
* @param [in] cur: current data point data
* @param [in] last: last data point data
*
* @return: 0, no change in data; 1, data changes
*/
static int8_t ICACHE_FLASH_ATTR gizCheckReport(dataPoint_t *cur, dataPoint_t *last)
{
int8_t ret = 0;
static uint32_t lastReportTime = 0;
uint32_t currentTime = 0;
if((NULL == cur) || (NULL == last))
{
      GIZWITS_LOG("gizCheckReport Error , Illegal Param\n");
      return -1;
}
currentTime = gizGetTimerCount();
if(last->valueRelay_1 != cur->valueRelay_1)
{
      GIZWITS_LOG("valueRelay_1 Changed\n");
      ret = 1;
}
if(last->valueTemp != cur->valueTemp)
{
      if(currentTime - lastReportTime >= REPORT_TIME_MAX)
      {
         GIZWITS_LOG("valueTemp Changed\n");
         ret = 1;
      }
}
if(last->valueHumi != cur->valueHumi)
{
      if(currentTime - lastReportTime >= REPORT_TIME_MAX)
      {
         GIZWITS_LOG("valueHumi Changed\n");
         ret = 1;
      }
}
if(last->valueLight_Intensity != cur->valueLight_Intensity)
{
      if(currentTime - lastReportTime >= REPORT_TIME_MAX)
      {
         GIZWITS_LOG("valueLight_Intensity Changed\n");
         ret = 1;
      }
}
if(1 == ret)
{
      lastReportTime = gizGetTimerCount();
}
return ret;
}
/**
* @brief User data point data is converted to wit the cloud to report data point data
*
* @param [in] dataPoints: user data point data address
* @param [out] devStatusPtr: wit the cloud data point data address
*
* @return 0, the correct return; -1, the error returned
*/
static int8_t ICACHE_FLASH_ATTR gizDataPoints2ReportData(dataPoint_t *dataPoints , devStatus_t *devStatusPtr)
{
if((NULL == dataPoints) || (NULL == devStatusPtr))
{
      GIZWITS_LOG("gizDataPoints2ReportData Error , Illegal Param\n");
      return -1;
}
gizMemset((uint8_t *)devStatusPtr->wBitBuf,0,sizeof(devStatusPtr->wBitBuf));
gizStandardCompressValue(Relay_1_BYTEOFFSET,Relay_1_BITOFFSET,Relay_1_LEN,(uint8_t *)devStatusPtr,dataPoints->valueRelay_1);
gizByteOrderExchange((uint8_t *)devStatusPtr->wBitBuf,sizeof(devStatusPtr->wBitBuf));
devStatusPtr->valueTemp = gizY2X(Temp_RATIO,  Temp_ADDITION, dataPoints->valueTemp);
devStatusPtr->valueHumi = gizY2X(Humi_RATIO,  Humi_ADDITION, dataPoints->valueHumi);
devStatusPtr->valueLight_Intensity = gizY2X(Light_Intensity_RATIO,  Light_Intensity_ADDITION, dataPoints->valueLight_Intensity);
return 0;
}
/**
* @brief This function is called by the GAgent module to receive the relevant protocol data from the cloud or APP
* @param [in] inData The protocol data entered
* @param [in] inLen Enter the length of the data
* @param [out] outData The output of the protocol data
* @param [out] outLen The length of the output data
* @return 0, the implementation of success, non-0, failed
*/
static int8_t gizProtocolIssuedProcess(char *did, uint8_t *inData, uint32_t inLen, uint8_t *outData, uint32_t *outLen)
{
uint8_t issuedAction = inData[0];
if((NULL == inData)||(NULL == outData)||(NULL == outLen))
{
      GIZWITS_LOG("gizProtocolIssuedProcess Error , Illegal Param\n");
      return -1;
}
if(NULL == did)
{
      memset((uint8_t *)&gizwitsProtocol.issuedProcessEvent, 0, sizeof(eventInfo_t));
      switch(issuedAction)
      {
         case ACTION_CONTROL_DEVICE:
            gizDataPoint2Event((gizwitsIssued_t *)&inData[1], &gizwitsProtocol.issuedProcessEvent,&gizwitsProtocol.gizCurrentDataPoint);
            gizwitsProtocol.issuedFlag = ACTION_CONTROL_TYPE;
            outData = NULL;
            *outLen = 0;
            break;
         case ACTION_READ_DEV_STATUS:
            if(0 == gizDataPoints2ReportData(&gizwitsProtocol.gizLastDataPoint,&gizwitsProtocol.reportData.devStatus))
            {
                  memcpy(outData+1, (uint8_t *)&gizwitsProtocol.reportData.devStatus, sizeof(gizwitsReport_t));
                  outData[0] = ACTION_READ_DEV_STATUS_ACK;
                  *outLen = sizeof(gizwitsReport_t)+1;
            }
            else
            {
                  return -1;
            }
            break;
         case ACTION_W2D_TRANSPARENT_DATA:
            memcpy(gizwitsProtocol.transparentBuff, &inData[1], inLen-1);
            gizwitsProtocol.transparentLen = inLen - 1;
            gizwitsProtocol.issuedProcessEvent.event[gizwitsProtocol.issuedProcessEvent.num] = TRANSPARENT_DATA;
            gizwitsProtocol.issuedProcessEvent.num++;
            gizwitsProtocol.issuedFlag = ACTION_W2D_TRANSPARENT_TYPE;
            outData = NULL;
            *outLen = 0;
            break;
            default:
                  break;
      }
}
return 0;
}
/**
* @brief The protocol sends data back , P0 ACK
*
* @param [in] head                : Protocol head pointer
* @param [in] data                : Payload data
* @param [in] len                : Payload data length
* @param [in] proFlag             : DID flag ,1 for Virtual sub device did ,0 for single product or gateway
*
* @return : 0,Ack success;
*          -1，Input Param Illegal
*          -2，Serial send faild
*/
static int32_t gizProtocolIssuedDataAck(protocolHead_t *head, uint8_t *gizdata, uint32_t len, uint8_t proFlag)
{
int32_t ret = 0;
uint8_t tx_buf[RB_MAX_LEN];
uint32_t offset = 0;
uint8_t sDidLen = 0;
uint16_t data_len = 0;
      uint8_t *pTxBuf = tx_buf;
if(NULL == gizdata)
{
      GIZWITS_LOG("[ERR]  data Is Null \n");
      return -1;
}
if(0x1 == proFlag)
{
      sDidLen = *((uint8_t *)head + sizeof(protocolHead_t));
      data_len = 5 + 1 + sDidLen + len;
}
else
{
      data_len = 5 + len;
}
GIZWITS_LOG("len = %d , sDidLen = %d ,data_len = %d\n", len,sDidLen,data_len);
*pTxBuf ++= 0xFF;
*pTxBuf ++= 0xFF;
*pTxBuf ++= (uint8_t)(data_len>>8);
*pTxBuf ++= (uint8_t)(data_len);
*pTxBuf ++= head->cmd + 1;
*pTxBuf ++= head->sn;
*pTxBuf ++= 0x00;
*pTxBuf ++= proFlag;
offset = 8;
if(0x1 == proFlag)
{
      *pTxBuf ++= sDidLen;
      offset += 1;
      memcpy(&tx_buf[offset],(uint8_t *)head+sizeof(protocolHead_t)+1,sDidLen);
      offset += sDidLen;
      pTxBuf += sDidLen;
}
if(0 != len)
{
      memcpy(&tx_buf[offset],gizdata,len);
}
tx_buf[data_len + 4 - 1 ] = gizProtocolSum( tx_buf , (data_len+4));
ret = uartWrite(tx_buf, data_len+4);
if(ret < 0)
{
      GIZWITS_LOG("uart write error %d \n", ret);
      return -2;
}
return 0;
}
/**
* @brief Report data interface
*
* @param [in] action          : PO action
* @param [in] data             : Payload data
* @param [in] len             : Payload data length
*
* @return : 0,Ack success;
*          -1，Input Param Illegal
*          -2，Serial send faild
*/
static int32_t gizReportData(uint8_t action, uint8_t *gizdata, uint32_t len)
{
int32_t ret = 0;
protocolReport_t protocolReport;
if(NULL == gizdata)
{
      GIZWITS_LOG("gizReportData Error , Illegal Param\n");
      return -1;
}
gizProtocolHeadInit((protocolHead_t *)&protocolReport);
protocolReport.head.cmd = CMD_REPORT_P0;
protocolReport.head.sn = gizwitsProtocol.sn++;
protocolReport.action = action;
protocolReport.head.len = exchangeBytes(sizeof(protocolReport_t)-4);
memcpy((gizwitsReport_t *)&protocolReport.reportData, (gizwitsReport_t *)gizdata,len);
protocolReport.sum = gizProtocolSum((uint8_t *)&protocolReport, sizeof(protocolReport_t));
ret = uartWrite((uint8_t *)&protocolReport, sizeof(protocolReport_t));
if(ret < 0)
{
      GIZWITS_LOG("ERR: uart write error %d \n", ret);
      return -2;
}
gizProtocolWaitAck((uint8_t *)&protocolReport, sizeof(protocolReport_t));
return ret;
}/**
* @brief Datapoints reporting mechanism
*
* 1. Changes are reported immediately
* 2. Data timing report , 600000 Millisecond
*
*@param [in] currentData    : Current datapoints value
* @return : NULL
*/
static void gizDevReportPolicy(dataPoint_t *currentData)
{
static uint32_t lastRepTime = 0;
uint32_t timeNow = gizGetTimerCount();
if((1 == gizCheckReport(currentData, (dataPoint_t *)&gizwitsProtocol.gizLastDataPoint)))
{
      GIZWITS_LOG("changed, report data\n");
      if(0 == gizDataPoints2ReportData(currentData,&gizwitsProtocol.reportData.devStatus))
      {
         gizReportData(ACTION_REPORT_DEV_STATUS, (uint8_t *)&gizwitsProtocol.reportData.devStatus, sizeof(devStatus_t));       }
      memcpy((uint8_t *)&gizwitsProtocol.gizLastDataPoint, (uint8_t *)currentData, sizeof(dataPoint_t));
}
if((0 == (timeNow % (600000))) && (lastRepTime != timeNow))
{
      GIZWITS_LOG("Info: 600S report data\n");
      if(0 == gizDataPoints2ReportData(currentData,&gizwitsProtocol.reportData.devStatus))
      {
         gizReportData(ACTION_REPORT_DEV_STATUS, (uint8_t *)&gizwitsProtocol.reportData.devStatus, sizeof(devStatus_t));
      }
      memcpy((uint8_t *)&gizwitsProtocol.gizLastDataPoint, (uint8_t *)currentData, sizeof(dataPoint_t));
      lastRepTime = timeNow;
}
}
/**
* @brief Get a packet of data from the ring buffer
*
* @param [in]  rb                : Input data address
* @param [out] data             : Output data address
* @param [out] len                : Output data length
*
* @return : 0,Return correct ;-1，Return failure;-2，Data check failure
*/
static int8_t gizProtocolGetOnePacket(rb_t *rb, uint8_t *gizdata, uint16_t *len)
{
int32_t ret = 0;
uint8_t sum = 0;
int32_t i = 0;
uint8_t tmpData;
uint8_t tmpLen = 0;
uint16_t tmpCount = 0;
static uint8_t protocolFlag = 0;
static uint16_t protocolCount = 0;
static uint8_t lastData = 0;
static uint8_t debugCount = 0;
uint8_t *protocolBuff = gizdata;
protocolHead_t *head = NULL;
if((NULL == rb) || (NULL == gizdata) ||(NULL == len))
{
      GIZWITS_LOG("gizProtocolGetOnePacket Error , Illegal Param\n");
      return -1;
}
tmpLen = rbCanRead(rb);
if(0 == tmpLen)
{
      return -1;
}
for(i=0; i<tmpLen; i++)
{
      ret = rbRead(rb, &tmpData, 1);
      if(0 != ret)
      {
         if((0xFF == lastData) && (0xFF == tmpData))
         {
            if(0 == protocolFlag)
            {
                  protocolBuff[0] = 0xFF;
                  protocolBuff[1] = 0xFF;
                  protocolCount = 2;
                  protocolFlag = 1;
            }
            else
            {
                  if((protocolCount > 4) && (protocolCount != tmpCount))
                  {
                     protocolBuff[0] = 0xFF;
                     protocolBuff[1] = 0xFF;
                     protocolCount = 2;
                  }
            }
         }
         else if((0xFF == lastData) && (0x55 == tmpData))
         {
         }
         else
         {
            if(1 == protocolFlag)
            {
                  protocolBuff[protocolCount] = tmpData;
                  protocolCount++;
                  if(protocolCount > 4)
                  {
                     head = (protocolHead_t *)protocolBuff;
                     tmpCount = exchangeBytes(head->len)+4;
                     if(protocolCount == tmpCount)
                     {
                        break;
                     }
                  }
            }
         }
         lastData = tmpData;
         debugCount++;
      }
}
if((protocolCount > 4) && (protocolCount == tmpCount))
{
      sum = gizProtocolSum(protocolBuff, protocolCount);
      if(protocolBuff[protocolCount-1] == sum)
      {
         memcpy(gizdata, protocolBuff, tmpCount);
         *len = tmpCount;
         protocolFlag = 0;
         protocolCount = 0;
         debugCount = 0;
         lastData = 0;
         return 0;
      }
      else
      {
         return -2;
      }
}
return 1;
}
/**
* @brief Protocol data resend
* The protocol data resend when check timeout and meet the resend limiting
* @param none
*
* @return none
*/
static void gizProtocolResendData(void)
{
int32_t ret = 0;
if(0 == gizwitsProtocol.waitAck.flag)
{
      return;
}
GIZWITS_LOG("Warning: timeout, resend data \n");
ret = uartWrite(gizwitsProtocol.waitAck.buf, gizwitsProtocol.waitAck.dataLen);
if(ret != gizwitsProtocol.waitAck.dataLen)
{
      GIZWITS_LOG("ERR: resend data error\n");
}
gizwitsProtocol.waitAck.sendTime = gizGetTimerCount();
}
/**
* @brief Clear the ACK protocol message
*
* @param [in] head : Protocol header address
*
* @return 0， success; other， failure
*/
static int8_t gizProtocolWaitAckCheck(protocolHead_t *head)
{
protocolHead_t *waitAckHead = (protocolHead_t *)gizwitsProtocol.waitAck.buf;
if(NULL == head)
{
      GIZWITS_LOG("ERR: data is empty \n");
      return -1;
}
if(waitAckHead->cmd+1 == head->cmd)
{
      memset((uint8_t *)&gizwitsProtocol.waitAck, 0, sizeof(protocolWaitAck_t));
}
return 0;
}
/**
* @brief Send general protocol message data
*
* @param [in] head             : Protocol header address
*
* @return : Return effective data length;-1，return failure
*/
static int32_t gizProtocolCommonAck(protocolHead_t *head)
{
int32_t ret = 0;
protocolCommon_t ack;
if(NULL == head)
{
      GIZWITS_LOG("ERR: gizProtocolCommonAck data is empty \n");
      return -1;
}
memcpy((uint8_t *)&ack, (uint8_t *)head, sizeof(protocolHead_t));
ack.head.cmd = ack.head.cmd+1;
ack.head.len = exchangeBytes(sizeof(protocolCommon_t)-4);
ack.sum = gizProtocolSum((uint8_t *)&ack, sizeof(protocolCommon_t));
ret = uartWrite((uint8_t *)&ack, sizeof(protocolCommon_t));
if(ret < 0)
{
      GIZWITS_LOG("ERR: uart write error %d \n", ret);
}
return ret;
}
/**
* @brief ACK processing function
* Time-out 200ms no ACK resend，resend two times at most
* @param none
*
* @return none
*/
static void gizProtocolAckHandle(void)
{
if(1 == gizwitsProtocol.waitAck.flag)
{
      if(SEND_MAX_NUM > gizwitsProtocol.waitAck.num)
      {
         // Time-out no ACK resend
         if(SEND_MAX_TIME < (gizGetTimerCount() - gizwitsProtocol.waitAck.sendTime))
         {
            GIZWITS_LOG("Warning:gizProtocolResendData %d %d %d\n", gizGetTimerCount(), gizwitsProtocol.waitAck.sendTime, gizwitsProtocol.waitAck.num);
            gizProtocolResendData();
            gizwitsProtocol.waitAck.num++;
         }
      }
      else
      {
         memset((uint8_t *)&gizwitsProtocol.waitAck, 0, sizeof(protocolWaitAck_t));
      }
}
}
/**
* @brief Protocol 4.1 WiFi module requests device information
*
* @param[in] head : Protocol header address
*
* @return Return effective data length;-1，return failure
*/
static int32_t gizProtocolGetDeviceInfo(protocolHead_t * head)
{
int32_t ret = 0;
protocolDeviceInfo_t deviceInfo;
if(NULL == head)
{
      GIZWITS_LOG("gizProtocolGetDeviceInfo Error , Illegal Param\n");
      return -1;
}
gizProtocolHeadInit((protocolHead_t *)&deviceInfo);
deviceInfo.head.cmd = ACK_GET_DEVICE_INFO;
deviceInfo.head.sn = head->sn;
memcpy((uint8_t *)deviceInfo.protocolVer, protocol_VERSION, 8);
memcpy((uint8_t *)deviceInfo.p0Ver, P0_VERSION, 8);
memcpy((uint8_t *)deviceInfo.softVer, SOFTWARE_VERSION, 8);
memcpy((uint8_t *)deviceInfo.hardVer, HARDWARE_VERSION, 8);
memcpy((uint8_t *)deviceInfo.productKey, PRODUCT_KEY, strlen(PRODUCT_KEY));
memcpy((uint8_t *)deviceInfo.productSecret, PRODUCT_SECRET, strlen(PRODUCT_SECRET));
memset((uint8_t *)deviceInfo.devAttr, 0, 8);
deviceInfo.devAttr[7] |= DEV_IS_GATEWAY<<0;
deviceInfo.devAttr[7] |= (0x01<<1);
deviceInfo.ninableTime = exchangeBytes(NINABLETIME);
deviceInfo.head.len = exchangeBytes(sizeof(protocolDeviceInfo_t)-4);
deviceInfo.sum = gizProtocolSum((uint8_t *)&deviceInfo, sizeof(protocolDeviceInfo_t));
ret = uartWrite((uint8_t *)&deviceInfo, sizeof(protocolDeviceInfo_t));
if(ret < 0)
{
      GIZWITS_LOG("ERR: uart write error %d \n", ret);
}
return ret;
}
/**
* @brief Protocol 4.7 Handling of illegal message notification
* @param[in] head  : Protocol header address
* @param[in] errno : Illegal message notification type
* @return 0， success; other， failure
*/
static int32_t gizProtocolErrorCmd(protocolHead_t *head,errorPacketsType_t errno)
{
int32_t ret = 0;
protocolErrorType_t errorType;
if(NULL == head)
{
      GIZWITS_LOG("gizProtocolErrorCmd Error , Illegal Param\n");
      return -1;
}
gizProtocolHeadInit((protocolHead_t *)&errorType);
errorType.head.cmd = ACK_ERROR_PACKAGE;
errorType.head.sn = head->sn;
errorType.head.len = exchangeBytes(sizeof(protocolErrorType_t)-4);
errorType.error = errno;
errorType.sum = gizProtocolSum((uint8_t *)&errorType, sizeof(protocolErrorType_t));
ret = uartWrite((uint8_t *)&errorType, sizeof(protocolErrorType_t));
if(ret < 0)
{
      GIZWITS_LOG("ERR: uart write error %d \n", ret);
}
return ret;
}
/**
* @brief Protocol 4.13 Get and process network time
*
* @param [in] head : Protocol header address
*
* @return 0， success; other， failure
*/
static int8_t gizProtocolNTP(protocolHead_t *head)
{
protocolUTT_t *UTTInfo = (protocolUTT_t *)head;
if(NULL == head)
{
      GIZWITS_LOG("ERR: NTP is empty \n");
      return -1;
}
memcpy((uint8_t *)&gizwitsProtocol.TimeNTP,(uint8_t *)UTTInfo->time, (7 + 4));
gizwitsProtocol.TimeNTP.year = exchangeBytes(gizwitsProtocol.TimeNTP.year);
gizwitsProtocol.TimeNTP.ntp =exchangeWord(gizwitsProtocol.TimeNTP.ntp);
gizwitsProtocol.NTPEvent.event[gizwitsProtocol.NTPEvent.num] = WIFI_NTP;
gizwitsProtocol.NTPEvent.num++;
gizwitsProtocol.issuedFlag = GET_NTP_TYPE;
return 0;
}
/**
* @brief Protocol 4.4 Device MCU restarts function
* @param none
* @return none
*/
static void gizProtocolReboot(void)
{
uint32_t timeDelay = gizGetTimerCount();
/*Wait 600ms*/
while((gizGetTimerCount() - timeDelay) <= 600);
mcuRestart();
}
/**
* @brief Protocol 4.5 :The WiFi module informs the device MCU of working status about the WiFi module
* @param[in] status WiFi module working status
* @return none
*/
static int8_t gizProtocolModuleStatus(protocolWifiStatus_t *status)
{
static wifiStatus_t lastStatus;
if(NULL == status)
{
      GIZWITS_LOG("gizProtocolModuleStatus Error , Illegal Param\n");
      return -1;
}
status->ststus.value = exchangeBytes(status->ststus.value);
//OnBoarding mode status
if(lastStatus.types.onboarding != status->ststus.types.onboarding)
{
      if(1 == status->ststus.types.onboarding)
      {
         if(1 == status->ststus.types.softap)
         {
            gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_SOFTAP;
            gizwitsProtocol.wifiStatusEvent.num++;
            GIZWITS_LOG("OnBoarding: SoftAP or Web mode\n");
         }
         if(1 == status->ststus.types.station)
         {
            gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_AIRLINK;
            gizwitsProtocol.wifiStatusEvent.num++;
            GIZWITS_LOG("OnBoarding: AirLink mode\n");
         }
      }
      else
      {
         if(1 == status->ststus.types.softap)
         {
            gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_SOFTAP;
            gizwitsProtocol.wifiStatusEvent.num++;
            GIZWITS_LOG("OnBoarding: SoftAP or Web mode\n");
         }
         if(1 == status->ststus.types.station)
         {
            gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_STATION;
            gizwitsProtocol.wifiStatusEvent.num++;
            GIZWITS_LOG("OnBoarding: Station mode\n");
         }
      }
}
//binding mode status
if(lastStatus.types.binding != status->ststus.types.binding)
{
      lastStatus.types.binding = status->ststus.types.binding;
      if(1 == status->ststus.types.binding)
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_OPEN_BINDING;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: in binding mode\n");
      }
      else
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_CLOSE_BINDING;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: out binding mode\n");
      }
}
//router status
if(lastStatus.types.con_route != status->ststus.types.con_route)
{
      lastStatus.types.con_route = status->ststus.types.con_route;
      if(1 == status->ststus.types.con_route)
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_CON_ROUTER;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: connected router\n");
      }
      else
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_DISCON_ROUTER;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: disconnected router\n");
      }
}
//M2M server status
if(lastStatus.types.con_m2m != status->ststus.types.con_m2m)
{
      lastStatus.types.con_m2m = status->ststus.types.con_m2m;
      if(1 == status->ststus.types.con_m2m)
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_CON_M2M;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: connected m2m\n");
      }
      else
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_DISCON_M2M;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: disconnected m2m\n");
      }
}
//APP status
if(lastStatus.types.app != status->ststus.types.app)
{
      lastStatus.types.app = status->ststus.types.app;
      if(1 == status->ststus.types.app)
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_CON_APP;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: app connect\n");
      }
      else
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_DISCON_APP;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: no app connect\n");
      }
}
//test mode status
if(lastStatus.types.test != status->ststus.types.test)
{
      lastStatus.types.test = status->ststus.types.test;
      if(1 == status->ststus.types.test)
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_OPEN_TESTMODE;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: in test mode\n");
      }
      else
      {
         gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_CLOSE_TESTMODE;
         gizwitsProtocol.wifiStatusEvent.num++;
         GIZWITS_LOG("WiFi status: out test mode\n");
      }
}
gizwitsProtocol.wifiStatusEvent.event[gizwitsProtocol.wifiStatusEvent.num] = WIFI_RSSI;
gizwitsProtocol.wifiStatusEvent.num++;
gizwitsProtocol.wifiStatusData.rssi = status->ststus.types.rssi;
GIZWITS_LOG("RSSI is %d \n", gizwitsProtocol.wifiStatusData.rssi);
gizwitsProtocol.issuedFlag = WIFI_STATUS_TYPE;
return 0;
}
/**@name Gizwits User API interface
* @{
*/
/**
* @brief gizwits Protocol initialization interface
* Protocol-related timer, serial port initialization
* Datapoint initialization
* @param none
* @return none
*/
void gizwitsInit(void)
{
pRb.rbCapacity = RB_MAX_LEN;
pRb.rbBuff = rbBuf;
if(0 == rbCreate(&pRb))
      {
            GIZWITS_LOG("rbCreate Success \n");
      }
      else
      {
            GIZWITS_LOG("rbCreate Faild \n");
      }
memset((uint8_t *)&gizwitsProtocol, 0, sizeof(gizwitsProtocol_t));
}
/**
* @brief WiFi configure interface
* Set the WiFi module into the corresponding configuration mode or reset the module
* @param[in] mode ：0x0， reset the module ;0x01， SoftAp mode ;0x02， AirLink mode ;0x03， Production test mode; 0x04:allow users to bind devices
* @return Error command code
*/
int32_t gizwitsSetMode(uint8_t mode)
{
int32_t ret = 0;
protocolCfgMode_t cfgMode;
protocolCommon_t setDefault;
switch(mode)
{
      case WIFI_RESET_MODE:
         gizProtocolHeadInit((protocolHead_t *)&setDefault);
         setDefault.head.cmd = CMD_SET_DEFAULT;
         setDefault.head.sn = gizwitsProtocol.sn++;
         setDefault.head.len = exchangeBytes(sizeof(protocolCommon_t)-4);
         setDefault.sum = gizProtocolSum((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         ret = uartWrite((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         if(ret < 0)
         {
            GIZWITS_LOG("ERR: uart write error %d \n", ret);
         }
         gizProtocolWaitAck((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         break;
      case WIFI_SOFTAP_MODE:
         gizProtocolHeadInit((protocolHead_t *)&cfgMode);
         cfgMode.head.cmd = CMD_WIFI_CONFIG;
         cfgMode.head.sn = gizwitsProtocol.sn++;
         cfgMode.cfgMode = mode;
         cfgMode.head.len = exchangeBytes(sizeof(protocolCfgMode_t)-4);
         cfgMode.sum = gizProtocolSum((uint8_t *)&cfgMode, sizeof(protocolCfgMode_t));
         ret = uartWrite((uint8_t *)&cfgMode, sizeof(protocolCfgMode_t));
         if(ret < 0)
         {
            GIZWITS_LOG("ERR: uart write error %d \n", ret);
         }
         gizProtocolWaitAck((uint8_t *)&cfgMode, sizeof(protocolCfgMode_t));
         break;
      case WIFI_AIRLINK_MODE:
         gizProtocolHeadInit((protocolHead_t *)&cfgMode);
         cfgMode.head.cmd = CMD_WIFI_CONFIG;
         cfgMode.head.sn = gizwitsProtocol.sn++;
         cfgMode.cfgMode = mode;
         cfgMode.head.len = exchangeBytes(sizeof(protocolCfgMode_t)-4);
         cfgMode.sum = gizProtocolSum((uint8_t *)&cfgMode, sizeof(protocolCfgMode_t));
         ret = uartWrite((uint8_t *)&cfgMode, sizeof(protocolCfgMode_t));
         if(ret < 0)
         {
            GIZWITS_LOG("ERR: uart write error %d \n", ret);
         }
         gizProtocolWaitAck((uint8_t *)&cfgMode, sizeof(protocolCfgMode_t));
         break;
      case WIFI_PRODUCTION_TEST:
         gizProtocolHeadInit((protocolHead_t *)&setDefault);
         setDefault.head.cmd = CMD_PRODUCTION_TEST;
         setDefault.head.sn = gizwitsProtocol.sn++;
         setDefault.head.len = exchangeBytes(sizeof(protocolCommon_t)-4);
         setDefault.sum = gizProtocolSum((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         ret = uartWrite((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         if(ret < 0)
         {
            GIZWITS_LOG("ERR: uart write error %d \n", ret);
         }
         gizProtocolWaitAck((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         break;
      case WIFI_NINABLE_MODE:
         gizProtocolHeadInit((protocolHead_t *)&setDefault);
         setDefault.head.cmd = CMD_NINABLE_MODE;
         setDefault.head.sn = gizwitsProtocol.sn++;
         setDefault.head.len = exchangeBytes(sizeof(protocolCommon_t)-4);
         setDefault.sum = gizProtocolSum((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         ret = uartWrite((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         if(ret < 0)
         {
            GIZWITS_LOG("ERR: uart write error %d \n", ret);
         }
         gizProtocolWaitAck((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         break;
      case WIFI_REBOOT_MODE:
         gizProtocolHeadInit((protocolHead_t *)&setDefault);
         setDefault.head.cmd = CMD_REBOOT_MODULE;
         setDefault.head.sn = gizwitsProtocol.sn++;
         setDefault.head.len = exchangeBytes(sizeof(protocolCommon_t)-4);
         setDefault.sum = gizProtocolSum((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         ret = uartWrite((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         if(ret < 0)
         {
            GIZWITS_LOG("ERR: uart write error %d \n", ret);
         }
         gizProtocolWaitAck((uint8_t *)&setDefault, sizeof(protocolCommon_t));
         break;
      default:
         GIZWITS_LOG("ERR: CfgMode error!\n");
         break;
}
return ret;
}
/**
* @brief Get the the network time
* Protocol 4.13:"Device MCU send" of "the MCU requests access to the network time"
* @param[in] none
* @return none
*/
void gizwitsGetNTP(void)
{
int32_t ret = 0;
protocolCommon_t getNTP;
gizProtocolHeadInit((protocolHead_t *)&getNTP);
getNTP.head.cmd = CMD_GET_NTP;
getNTP.head.sn = gizwitsProtocol.sn++;
getNTP.head.len = exchangeBytes(sizeof(protocolCommon_t)-4);
getNTP.sum = gizProtocolSum((uint8_t *)&getNTP, sizeof(protocolCommon_t));
ret = uartWrite((uint8_t *)&getNTP, sizeof(protocolCommon_t));
if(ret < 0)
{
      GIZWITS_LOG("ERR[NTP]: uart write error %d \n", ret);
}
gizProtocolWaitAck((uint8_t *)&getNTP, sizeof(protocolCommon_t));
}
/**
* @brief Get Module Info
*
* @param[in] none
* @return none
*/
void gizwitsGetModuleInfo(void)
{
int32_t ret = 0;
protocolGetModuleInfo_t getModuleInfo;
gizProtocolHeadInit((protocolHead_t *)&getModuleInfo);
getModuleInfo.head.cmd = CMD_ASK_MODULE_INFO;
getModuleInfo.head.sn = gizwitsProtocol.sn++;
getModuleInfo.type = 0x0;
getModuleInfo.head.len = exchangeBytes(sizeof(protocolGetModuleInfo_t)-4);
getModuleInfo.sum = gizProtocolSum((uint8_t *)&getModuleInfo, sizeof(protocolGetModuleInfo_t));
ret = uartWrite((uint8_t *)&getModuleInfo, sizeof(protocolGetModuleInfo_t));
if(ret < 0)
{
      GIZWITS_LOG("ERR[NTP]: uart write error %d \n", ret);
}
gizProtocolWaitAck((uint8_t *)&getModuleInfo, sizeof(protocolGetModuleInfo_t));
}
/**
* @brief Module Info Analyse
*
* @param [in] head :
*
* @return 0, Success， , other,Faild
*/
static int8_t gizProtocolModuleInfoHandle(protocolHead_t *head)
{
protocolModuleInfo_t *moduleInfo = (protocolModuleInfo_t *)head;
if(NULL == head)
{
      GIZWITS_LOG("NTP is empty \n");
      return -1;
}
memcpy((uint8_t *)&gizwitsProtocol.wifiModuleNews,(uint8_t *)&moduleInfo->wifiModuleInfo, sizeof(moduleInfo_t));
gizwitsProtocol.moduleInfoEvent.event[gizwitsProtocol.moduleInfoEvent.num] = MODULE_INFO;
gizwitsProtocol.moduleInfoEvent.num++;
gizwitsProtocol.issuedFlag = GET_MODULEINFO_TYPE;
return 0;
}
/**
* @brief Protocol handling function
*
* @param [in] currentData :The protocol data pointer
* @return none
*/
int32_t gizwitsHandle(dataPoint_t *currentData)
{
int8_t ret = 0;
#ifdef PROTOCOL_DEBUG
uint16_t i = 0;
#endif
uint8_t ackData[RB_MAX_LEN];
uint16_t protocolLen = 0;
uint32_t ackLen = 0;
protocolHead_t *recvHead = NULL;
char *didPtr = NULL;
uint16_t offset = 0;
if(NULL == currentData)
{
      GIZWITS_LOG("GizwitsHandle Error , Illegal Param\n");
      return -1;
}
/*resend strategy*/
gizProtocolAckHandle();
ret = gizProtocolGetOnePacket(&pRb, gizwitsProtocol.protocolBuf, &protocolLen);
if(0 == ret)
{
      GIZWITS_LOG("Get One Packet!\n");
#ifdef PROTOCOL_DEBUG
      GIZWITS_LOG("WiFi2MCU[%4d:%4d]: ", gizGetTimerCount(), protocolLen);
      for(i=0; i<protocolLen;i++)
      {
         GIZWITS_LOG("%02x ", gizwitsProtocol.protocolBuf);
      }
      GIZWITS_LOG("\n");
#endif
      recvHead = (protocolHead_t *)gizwitsProtocol.protocolBuf;
      switch (recvHead->cmd)
      {
         case CMD_GET_DEVICE_INTO:
            gizProtocolGetDeviceInfo(recvHead);
            break;
         case CMD_ISSUED_P0:
            GIZWITS_LOG("flag %x %x \n", recvHead->flags[0], recvHead->flags[1]);
            //offset = 1;
            if(0 == gizProtocolIssuedProcess(didPtr, gizwitsProtocol.protocolBuf+sizeof(protocolHead_t)+offset, protocolLen-(sizeof(protocolHead_t)+offset+1), ackData, &ackLen))
            {
                  gizProtocolIssuedDataAck(recvHead, ackData, ackLen,recvHead->flags[1]);
                  GIZWITS_LOG("AckData : \n");
            }
            break;
         case CMD_HEARTBEAT:
            gizProtocolCommonAck(recvHead);
            break;
         case CMD_WIFISTATUS:
            gizProtocolCommonAck(recvHead);
            gizProtocolModuleStatus((protocolWifiStatus_t *)recvHead);
            break;
         case ACK_REPORT_P0:
         case ACK_WIFI_CONFIG:
         case ACK_SET_DEFAULT:
         case ACK_NINABLE_MODE:
         case ACK_REBOOT_MODULE:
            gizProtocolWaitAckCheck(recvHead);
            break;
         case CMD_MCU_REBOOT:
            gizProtocolCommonAck(recvHead);
            GIZWITS_LOG("report:MCU reboot!\n");
            gizProtocolReboot();
            break;
         case CMD_ERROR_PACKAGE:
            break;
         case ACK_PRODUCTION_TEST:
            gizProtocolWaitAckCheck(recvHead);
            GIZWITS_LOG("Ack PRODUCTION_MODE success \n");
            break;
         case ACK_GET_NTP:
            gizProtocolWaitAckCheck(recvHead);
            gizProtocolNTP(recvHead);
            GIZWITS_LOG("Ack GET_UTT success \n");
            break;
         case ACK_ASK_MODULE_INFO:
            gizProtocolWaitAckCheck(recvHead);
            gizProtocolModuleInfoHandle(recvHead);
            GIZWITS_LOG("Ack GET_Module success \n");
         break;
         default:
            gizProtocolErrorCmd(recvHead,ERROR_CMD);
            GIZWITS_LOG("ERR: cmd code error!\n");
            break;
      }
}
else if(-2 == ret)
{
      //Check failed, report exception
      recvHead = (protocolHead_t *)gizwitsProtocol.protocolBuf;
      gizProtocolErrorCmd(recvHead,ERROR_ACK_SUM);
      GIZWITS_LOG("ERR: check sum error!\n");
      return -2;
}
switch(gizwitsProtocol.issuedFlag)
{
      case ACTION_CONTROL_TYPE:
         gizwitsProtocol.issuedFlag = STATELESS_TYPE;
         gizwitsEventProcess(&gizwitsProtocol.issuedProcessEvent, (uint8_t *)&gizwitsProtocol.gizCurrentDataPoint, sizeof(dataPoint_t));
         memset((uint8_t *)&gizwitsProtocol.issuedProcessEvent,0x0,sizeof(gizwitsProtocol.issuedProcessEvent));
         break;
      case WIFI_STATUS_TYPE:
         gizwitsProtocol.issuedFlag = STATELESS_TYPE;
         gizwitsEventProcess(&gizwitsProtocol.wifiStatusEvent, (uint8_t *)&gizwitsProtocol.wifiStatusData, sizeof(moduleStatusInfo_t));
         memset((uint8_t *)&gizwitsProtocol.wifiStatusEvent,0x0,sizeof(gizwitsProtocol.wifiStatusEvent));
         break;
      case ACTION_W2D_TRANSPARENT_TYPE:
         gizwitsProtocol.issuedFlag = STATELESS_TYPE;
         gizwitsEventProcess(&gizwitsProtocol.issuedProcessEvent, (uint8_t *)gizwitsProtocol.transparentBuff, gizwitsProtocol.transparentLen);
         break;
      case GET_NTP_TYPE:
         gizwitsProtocol.issuedFlag = STATELESS_TYPE;
         gizwitsEventProcess(&gizwitsProtocol.NTPEvent, (uint8_t *)&gizwitsProtocol.TimeNTP, sizeof(protocolTime_t));
         memset((uint8_t *)&gizwitsProtocol.NTPEvent,0x0,sizeof(gizwitsProtocol.NTPEvent));
         break;
      case GET_MODULEINFO_TYPE:
         gizwitsProtocol.issuedFlag = STATELESS_TYPE;
         gizwitsEventProcess(&gizwitsProtocol.moduleInfoEvent, (uint8_t *)&gizwitsProtocol.wifiModuleNews, sizeof(moduleInfo_t));
         memset((uint8_t *)&gizwitsProtocol.moduleInfoEvent,0x0,sizeof(moduleInfo_t));
         break;
      default:
         break;
}
gizDevReportPolicy(currentData);
return 0;
}
/**
* @brief gizwits report transparent data interface
* The user can call the interface to complete the reporting of private protocol data
* @param [in] data rivate protocol data
* @param [in] len  rivate protocol data length
* @return 0，success ;other，failure
*/
int32_t gizwitsPassthroughData(uint8_t * gizdata, uint32_t len)
{
      int32_t ret = 0;
      uint8_t tx_buf[MAX_PACKAGE_LEN];
      uint8_t *pTxBuf = tx_buf;
      uint16_t data_len = 6+len;
if(NULL == gizdata)
{
      GIZWITS_LOG("[ERR] gizwitsPassthroughData Error \n");
      return (-1);
}
      *pTxBuf ++= 0xFF;
      *pTxBuf ++= 0xFF;
      *pTxBuf ++= (uint8_t)(data_len>>8);//len
      *pTxBuf ++= (uint8_t)(data_len);
      *pTxBuf ++= CMD_REPORT_P0;//0x1b cmd
      *pTxBuf ++= gizwitsProtocol.sn++;//sn
      *pTxBuf ++= 0x00;//flag
      *pTxBuf ++= 0x00;//flag
      *pTxBuf ++= ACTION_D2W_TRANSPARENT_DATA;//P0_Cmd
memcpy(&tx_buf[9],gizdata,len);
tx_buf[data_len + 4 - 1 ] = gizProtocolSum( tx_buf , (data_len+4));
      ret = uartWrite(tx_buf, data_len+4);
if(ret < 0)
{
      GIZWITS_LOG("ERR: uart write error %d \n", ret);
}
gizProtocolWaitAck(tx_buf, data_len+4);
return 0;
}
void gziwits_Task(dataPoint_t * currentDataPoint)
{
      static uint32_t Timer=0;
      if(SoftTimer(Timer,5000))
      {
            gizwitsHandle(currentDataPoint);
            Timer=GetSoftTimer();
      }
}
/**@} */

[color=rgb(0, 0, 0) !important]复制代码

修改gizwits_protocol.h

#ifndef _GIZWITS_PROTOCOL_H
#define _GIZWITS_PROTOCOL_H
#ifdef __cplusplus
extern "C" {
#endif
#include <stdint.h>
#include <stdbool.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "common.h"
#define SEND_MAX_TIME    200                   ///< 200ms resend
#define SEND_MAX_NUM       2                      ///< resend times
#define protocol_VERSION "00000004"             ///< protocol version
#define P0_VERSION       "00000002"             ///< P0 protocol version
/**@name Product Key
* @{
*/
#define PRODUCT_KEY "9c8a5a8e38344fb4af14b6db0f5b1df7"
/**@} */
/**@name Product Secret
* @{
*/
#define PRODUCT_SECRET "45c86d8c6a2a4b1dac7d68df54f6e4f0"
/**@name Device status data reporting interval
* @{
*/
#define REPORT_TIME_MAX 6000 //6S
/**@} */
#define CELLNUMMAX 7
/**@name Whether the device is in the control class, 0 means no, 1 means yes
* @{
*/
#define DEV_IS_GATEWAY 0
/**@} */
/**@name Binding time
* @{
*/
#define NINABLETIME  0
/**@} */
#define MAX_PACKAGE_LEN (sizeof(devStatus_t)+sizeof(attrFlags_t)+20)                ///< Data buffer maximum length
#define RB_MAX_LEN       (MAX_PACKAGE_LEN*2)    ///< Maximum length of ring buffer
/**@name Data point related definition
* @{
*/
#define Relay_1_BYTEOFFSET                   0
#define Relay_1_BITOFFSET                   0
#define Relay_1_LEN                         1
#define Temp_RATIO                      1
#define Temp_ADDITION                   0
#define Temp_MIN                         0
#define Temp_MAX                         100
#define Humi_RATIO                      1
#define Humi_ADDITION                   0
#define Humi_MIN                         0
#define Humi_MAX                         100
#define Light_Intensity_RATIO                      1
#define Light_Intensity_ADDITION                   0
#define Light_Intensity_MIN                         0
#define Light_Intensity_MAX                         100
/**@} */
/** Writable data points Boolean and enumerated variables occupy byte size */
#define COUNT_W_BIT 1
/** Event enumeration */
typedef enum
{
  WIFI_SOFTAP = 0x00,                            ///< WiFi SOFTAP configuration event
  WIFI_AIRLINK,                                  ///< WiFi module AIRLINK configuration event
  WIFI_STATION,                                  ///< WiFi module STATION configuration event
  WIFI_OPEN_BINDING,                               ///< The WiFi module opens the binding event
  WIFI_CLOSE_BINDING,                            ///< The WiFi module closes the binding event
  WIFI_CON_ROUTER,                               ///< The WiFi module is connected to a routing event
  WIFI_DISCON_ROUTER,                            ///< The WiFi module has been disconnected from the routing event
  WIFI_CON_M2M,                                  ///< The WiFi module has a server M2M event
  WIFI_DISCON_M2M,                               ///< The WiFi module has been disconnected from the server M2M event
  WIFI_OPEN_TESTMODE,                            ///< The WiFi module turns on the test mode event
  WIFI_CLOSE_TESTMODE,                            ///< The WiFi module turns off the test mode event
  WIFI_CON_APP,                                  ///< The WiFi module connects to the APP event
  WIFI_DISCON_APP,                               ///< The WiFi module disconnects the APP event
  WIFI_RSSI,                                     ///< WiFi module RSSI event
  WIFI_NTP,                                        ///< Network time event
  MODULE_INFO,                                     ///< Module information event
  TRANSPARENT_DATA,                               ///< Transparency events
  EVENT_Relay_1,
  EVENT_TYPE_MAX                                  ///< Enumerate the number of members to calculate (user accidentally deleted)
} EVENT_TYPE_T;
/** P0 Command code */
typedef enum
{
ACTION_CONTROL_DEVICE    = 0x01,          ///< Protocol 4.10 WiFi Module Control Device WiFi Module Send
ACTION_READ_DEV_STATUS    = 0x02,          ///< Protocol 4.8 WiFi Module Reads the current status of the device WiFi module sent
ACTION_READ_DEV_STATUS_ACK  = 0x03,          ///< Protocol 4.8 WiFi Module Read Device Current Status Device MCU Reply
ACTION_REPORT_DEV_STATUS = 0x04,          ///< Protocol 4.9 device MCU to the WiFi module to actively report the current status of the device to send the MCU
ACTION_W2D_TRANSPARENT_DATA = 0x05,          ///< WiFi to device MCU transparent
ACTION_D2W_TRANSPARENT_DATA = 0x06,          ///< Device MCU to WiFi
} actionType_t;
/** Protocol network time structure */
typedef struct
{
uint16_t year;
uint8_t month;
uint8_t day;
uint8_t hour;
uint8_t minute;
uint8_t second;
uint32_t ntp;
}protocolTime_t;
/** WiFi Module configuration parameters*/
typedef enum
{
  WIFI_RESET_MODE = 0x00,                         ///< WIFI module reset
  WIFI_SOFTAP_MODE,                               ///< WIFI module softAP modeF
  WIFI_AIRLINK_MODE,                               ///< WIFI module AirLink mode
  WIFI_PRODUCTION_TEST,                            ///< MCU request WiFi module into production test mode
  WIFI_NINABLE_MODE,                               ///< MCU request module to enter binding mode
  WIFI_REBOOT_MODE,                               ///< MCU request module reboot
}WIFI_MODE_TYPE_T;
/** The protocol event type*/
typedef enum
{
  STATELESS_TYPE = 0x00,                         ///< Stateless type
  ACTION_CONTROL_TYPE,                            ///< Protocol 4.10 :WiFi module control device event
  WIFI_STATUS_TYPE,                               ///< Protocol 4.5 :WiFi module inform the device MCU of the change event of the WiFi module status
  ACTION_W2D_TRANSPARENT_TYPE,                   ///< Protocol WiFi to device MCU transparent event
  GET_NTP_TYPE,                                  ///< Protocol 4.13 :The MCU requests access to the network time event
  GET_MODULEINFO_TYPE,                            ///< Protocol 4.9 :The MCU get module information event
  PROTOCOL_EVENT_TYPE_MAX                         ///< Count enumerated member (User donot delete)
} PROTOCOL_EVENT_TYPE_T;
/** Protocol command code */
typedef enum
{
CMD_GET_DEVICE_INTO          = 0x01,       ///< Protocol：3.1
ACK_GET_DEVICE_INFO          = 0x02,       ///< Protocol：3.1
CMD_ISSUED_P0                = 0x03,       ///< Protocol：3.2 3.3
ACK_ISSUED_P0                = 0x04,       ///< Protocol：3.2 3.3
CMD_REPORT_P0                = 0x05,       ///< Protocol：3.4
ACK_REPORT_P0                = 0x06,       ///< Protocol：3.4
CMD_HEARTBEAT                = 0x07,       ///< Protocol：3.5
ACK_HEARTBEAT                = 0x08,       ///< Protocol：3.5
CMD_WIFI_CONFIG                = 0x09,       ///< Protocol：3.6
ACK_WIFI_CONFIG                = 0x0A,       ///< Protocol：3.6
CMD_SET_DEFAULT                = 0x0B,       ///< Protocol：3.7
ACK_SET_DEFAULT                = 0x0C,       ///< Protocol：3.7
CMD_WIFISTATUS                = 0x0D,       ///< Protocol：3.8
ACK_WIFISTATUS                = 0x0E,       ///< Protocol：3.8
CMD_MCU_REBOOT                = 0x0F,       ///< Protocol：4.1
ACK_MCU_REBOOT                = 0x10,       ///< Protocol：4.1
CMD_ERROR_PACKAGE             = 0x11,       ///< Protocol：3.9
ACK_ERROR_PACKAGE             = 0x12,       ///< Protocol：3.9
CMD_PRODUCTION_TEST          = 0x13,       ///< Protocol：
ACK_PRODUCTION_TEST          = 0x14,       ///< Protocol：
CMD_NINABLE_MODE             = 0x15,       ///< Protocol：3.10
ACK_NINABLE_MODE             = 0x16,       ///< Protocol：3.10
CMD_GET_NTP                   = 0x17,       ///< Protocol：4.3
ACK_GET_NTP                   = 0x18,       ///< Protocol：4.3
CMD_ASK_BIGDATA                = 0x19,       ///< Protocol：4.4
ACK_ASK_BIGDATA                = 0x1A,       ///< Protocol：4.4
CMD_BIGDATA_READY             = 0x1B,       ///< Protocol：4.5
ACK_BIGDATA_READY             = 0x1C,       ///< Protocol：4.5
CMD_BIGDATA_SEND             = 0x1D,       ///< Protocol：4.6
ACK_BIGDATA_SEND             = 0x1E,       ///< Protocol：4.6
CMD_S_STOP_BIGDATA_SEND       = 0x1F,       ///< Protocol：4.7
ACK_S_STOP_BIGDATA_SEND       = 0x20,       ///< Protocol：4.7
CMD_D_STOP_BIGDATA_SEND       = 0x27,       ///< Protocol：4.8
ACK_D_STOP_BIGDATA_SEND       = 0x28,       ///< Protocol：4.8
CMD_ASK_MODULE_INFO          = 0x21,       ///< Protocol：4.9
ACK_ASK_MODULE_INFO          = 0x22,       ///< Protocol：4.9
CMD_ASK_AFFAIR_HANDLE          = 0x23,       ///< Protocol：4.10
ACK_ASK_AFFAIR_HANDLE          = 0x24,       ///< Protocol：4.10
CMD_AFFAIR_RESULT             = 0x25,       ///< Protocol：4.10
ACK_AFFAIR_RESULT             = 0x26,       ///< Protocol：4.10
CMD_REBOOT_MODULE             = 0x29,       ///< Protocol：3.11
ACK_REBOOT_MODULE             = 0x2A,       ///< Protocol：3.11
CMD_CONNECT_M2M                = 0x2D,       ///< Protocol：for Virtualization
ACK_CONNECT_M2M                = 0x2E,       ///< Protocol：for Virtualization
CMD_CONNECT_M2M_BACK          = 0x2F,       ///< Protocol：for Virtualization
ACK_CONNECT_M2M_BACK          = 0x30,       ///< Protocol：for Virtualization
CMD_UPLOAD_DATA                = 0x31,       ///< Protocol：for Virtualization
ACK_UPLOAD_DATA                = 0x32,       ///< Protocol：for Virtualization
CMD_UPLOAD_DATA_BACK          = 0x33,       ///< Protocol：for Virtualization
ACK_UPLOAD_DATA_BACK          = 0x34,       ///< Protocol：for Virtualization
CMD_DISCONNECT_M2M             = 0x35,       ///< Protocol：for Virtualization
ACK_DISCONNECT_M2M             = 0x36,       ///< Protocol：for Virtualization
CMD_DISCONNECT_M2M_BACK       = 0x37,       ///< Protocol：for Virtualization
ACK_DISCONNECT_M2M_BACK       = 0x38,       ///< Protocol：for Virtualization
CMD_RESET_SIMULATOR          = 0x39,       ///< Protocol：for Virtualization
ACK_RESET_SIMULATOR          = 0x3A,       ///< Protocol：for Virtualization
CMD_RESET_SIMULATOR_BACK       = 0x3B,       ///< Protocol：for Virtualization
ACK_RESET_SIMULATOR_BACK       = 0x3C,       ///< Protocol：for Virtualization
} PROTOCOL_CMDTYPE;
/** Illegal message type*/
typedef enum
{
ERROR_ACK_SUM = 0x01,                         ///< check error
ERROR_CMD    = 0x02,                         ///< Command code error
ERROR_OTHER = 0x03,                         ///< other
} errorPacketsType_t;
typedef enum
{
EXE_SUCESS                   = 0x00,
EXE_FAILE                      = 0x01,
} execute_result;
#pragma pack(1)
/** User Area Device State Structure */
typedef struct {
  bool valueRelay_1;
  uint32_t valueTemp;
  uint32_t valueHumi;
  uint32_t valueLight_Intensity;
} dataPoint_t;
/** Corresponding to the protocol "4.10 WiFi module control device" in the flag " attr_flags" */
typedef struct {
  uint8_t flagRelay_1:1;
} attrFlags_t;
/** Corresponding protocol "4.10 WiFi module control device" in the data value "attr_vals" */
typedef struct {
  uint8_t wBitBuf[COUNT_W_BIT];
} attrVals_t;
/** The flag "attr_flags (1B)" + data value "0 protocol area" in the corresponding protocol "4.10 WiFi module control device"attr_vals(6B)" */
typedef struct {
attrFlags_t attrFlags;
attrVals_t  attrVals;
}gizwitsIssued_t;
/** Corresponding protocol "4.9 Device MCU to the WiFi module to actively report the current state" in the device status "dev_status(11B)" */
typedef struct {
  uint8_t wBitBuf[COUNT_W_BIT];
  uint8_t valueTemp;
  uint8_t valueHumi;
  uint8_t valueLight_Intensity;
} devStatus_t;
/** Event queue structure */
typedef struct {
uint8_t num;                                  ///< Number of queue member
uint8_t event[EVENT_TYPE_MAX];                ///< Queue member event content
}eventInfo_t;
/** wifiSignal strength structure */
typedef struct {
uint8_t rssi;                                  ///< WIFI signal strength
}moduleStatusInfo_t;
/** Protocol standard header structure */
typedef struct
{
uint8_t                head[2];             ///< The head is 0xFFFF
uint16_t             len;                   ///< From cmd to the end of the entire packet occupied by the number of bytes
uint8_t                cmd;                   ///< command
uint8_t                sn;                   ///<
uint8_t                flags[2];             ///< flag,default is 0
} protocolHead_t;
/** 4.1 WiFi module requests the device information protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                protocolVer[8];       ///< Protocol version
uint8_t                p0Ver[8];             ///< p0 Protocol version
uint8_t                hardVer[8];          ///< Hardware version
uint8_t                softVer[8];          ///< Software version
uint8_t                productKey[32];       ///< Product key
uint16_t             ninableTime;          ///< Binding time(second)
uint8_t                devAttr[8];          ///< Device attribute
uint8_t                productSecret[32];    ///< Product secret
uint8_t                sum;                   ///< checksum
} protocolDeviceInfo_t;
/** Protocol common data frame(4.2、4.4、4.6、4.9、4.10) protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                sum;                   ///< checksum
} protocolCommon_t;
/** 4.3 The device MCU informs the WiFi module of the configuration mode  protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                cfgMode;             ///< Configuration parameters
uint8_t                sum;                   ///< checksum
} protocolCfgMode_t;
/** 4.13 The MCU requests the network time  protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                time[7];             ///< Hardware version
uint8_t                ntp_time[4];          ///< Software version
uint8_t                sum;                   ///< checksum
} protocolUTT_t;
/** WiFi module working status*/
typedef union
{
uint16_t             value;
struct
{
      uint16_t          softap:1;
      uint16_t          station:1;
      uint16_t          onboarding:1;
      uint16_t          binding:1;
      uint16_t          con_route:1;
      uint16_t          con_m2m:1;
      uint16_t          reserve1:2;
      uint16_t          rssi:3;
      uint16_t          app:1;
      uint16_t          test:1;
      uint16_t          reserve2:3;
}types;
} wifiStatus_t;
/** WiFi status type :protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
wifiStatus_t          ststus;                ///< WIFI status
uint8_t                sum;                   ///< checksum
} protocolWifiStatus_t;
/** Protocol common data frame(4.9) :protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                type;                ///< Information Type
uint8_t                sum;                   ///< checksum
} protocolGetModuleInfo_t;
typedef struct
{
uint8_t                moduleType;          ///< Information Type
uint8_t                serialVer[8];          ///< Serial port protocol version
uint8_t                hardVer[8];          ///< Hardware version
uint8_t                softVer[8];          ///< Software version
uint8_t                mac[16];             ///< mac
uint8_t                ip[16];                ///< ip
uint8_t                devAttr[8];          ///< Device attribute
} moduleInfo_t;
/** Protocol common data frame(4.9) :protocol structure */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
moduleInfo_t          wifiModuleInfo;       ///< WIFI module information
uint8_t                sum;                   ///< checksum
} protocolModuleInfo_t;
/** GPRS information of base station */
typedef struct
{
uint16_t                   LAC_ID;          ///<LAC area ID
uint16_t                   CellID;          ///<Base station ID
uint8_t                   RSSI;             ///<Signal strength of base station
} gprsCellInfo_t;
/** 3.19 The basic information of the GPRS communication module  */
typedef struct
{
uint8_t                Type;//2G/3g/4g
uint8_t                Pro_ver[8];//Universal serial port protocol version
uint8_t                Hard_ver[8];//Hardware version
uint8_t                Soft_ver[8];//Software version
uint8_t                Device_attribute[8];//Device attribute
uint8_t                IMEI[16];//string
uint8_t                IMSI[16];//string
uint8_t                MCC[8];//Mobile country code
uint8_t                MNC[8];//Mobile network code
uint8_t                CellNum;//Number of base station
uint8_t                CellInfoLen;//Information length of base station
gprsCellInfo_t       GPRS_CellINFO[CELLNUMMAX];
}gprsInfo_t;
/** 4.7 Illegal message notification :protocol structure*/
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                error;                ///< error value
uint8_t                sum;                   ///< checksum
} protocolErrorType_t;
/** P0 message header */
typedef struct
{
protocolHead_t       head;                ///< Protocol standard header structure
uint8_t                action;                ///< p0 command
} protocolP0Head_t;
/** protocol “4.9 The device MCU reports the current status to the WiFi module” device status "dev_status(11B)"  */
typedef struct {
devStatus_t devStatus;                         ///< Stores the device status data
}gizwitsReport_t;
/** resend strategy structure */
typedef struct {
uint8_t                num;                   ///< resend times
uint8_t                flag;                ///< 1,Indicates that there is a need to wait for the ACK;0,Indicates that there is no need to wait for the ACK
uint8_t                buf[MAX_PACKAGE_LEN]; ///< resend data buffer
uint16_t             dataLen;             ///< resend data length
uint32_t             sendTime;             ///< resend time
} protocolWaitAck_t;
/** 4.8 WiFi read device datapoint value , device ack use this struct */
typedef struct
{
protocolHead_t       head;                ///< Protocol head
uint8_t                action;                ///< p0 action
gizwitsReport_t       reportData;          ///< p0 data
uint8_t                sum;                   ///< Checksum
} protocolReport_t;
/** Protocol main and very important struct */
typedef struct
{
uint8_t issuedFlag;                            ///< P0 action type
uint8_t protocolBuf[MAX_PACKAGE_LEN];          ///< Protocol data handle buffer
uint8_t transparentBuff[MAX_PACKAGE_LEN];    ///< Transparent data storage area
uint32_t transparentLen;                      ///< Transmission data length
uint32_t sn;                                  ///< Message SN
uint32_t timerMsCount;                         ///< Timer Count
protocolWaitAck_t waitAck;                   ///< Protocol wait ACK data structure
eventInfo_t issuedProcessEvent;                ///< Control events
eventInfo_t wifiStatusEvent;                   ///< WIFI Status events
eventInfo_t NTPEvent;                         ///< NTP events
eventInfo_t moduleInfoEvent;                   ///< Module Info events
      gizwitsReport_t reportData;                   ///< The protocol reports data for standard product
dataPoint_t gizCurrentDataPoint;             ///< Current device datapoints status
dataPoint_t gizLastDataPoint;                ///< Last device datapoints status
moduleStatusInfo_t wifiStatusData;             ///< WIFI signal intensity
protocolTime_t TimeNTP;                      ///< Network time information
#if MODULE_TYPE
gprsInfo_t gprsInfoNews;
#else
moduleInfo_t  wifiModuleNews;                ///< WIFI module Info
#endif
}gizwitsProtocol_t;
#pragma pack()
/**@name Gizwits user API interface
* @{
*/
extern uint32_t gizGetTimerCount(void);
void gizwitsInit(void);
int32_t gizwitsSetMode(uint8_t mode);
void gizwitsGetNTP(void);
int32_t gizwitsHandle(dataPoint_t *currentData);
int32_t gizwitsPassthroughData(uint8_t * gizdata, uint32_t len);
void gizwitsGetModuleInfo(void);
int32_t gizPutData(uint8_t *buf, uint32_t len);
/*添加用户自定义的函数**/
void gziwits_Task(dataPoint_t * currentDataPoint);
/**@} */
#ifdef __cplusplus
}
#endif
#endif

[color=rgb(0, 0, 0) !important]复制代码

6，Utils直接移植无需修改

7，添加TIM3定时器代码驱动

#include "tim3.h"
#include "gizwits_product.h"
void TIM3_Config(uint16_t psc,uint16_t arr)
{
      RCC_APB1PeriphClockCmd(RCC_APB1Periph_TIM3, ENABLE);
      TIM_TimeBaseInitTypeDef TIM_TimeBaseStructure;
      TIM_TimeBaseStructure.TIM_Period                   = arr;
      TIM_TimeBaseStructure.TIM_Prescaler                = psc;
      TIM_TimeBaseStructure.TIM_ClockDivision             = TIM_CKD_DIV1;
      TIM_TimeBaseStructure.TIM_CounterMode             = TIM_CounterMode_Up;
      TIM_TimeBaseInit(TIM3, &TIM_TimeBaseStructure);
      TIM_ITConfig(TIM3,TIM_IT_Update,ENABLE );
  NVIC_InitTypeDef NVIC_InitStructure;
      NVIC_InitStructure.NVIC_IRQChannel                = TIM3_IRQn;
      NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 0;
      NVIC_InitStructure.NVIC_IRQChannelSubPriority       = 3;
      NVIC_InitStructure.NVIC_IRQChannelCmd             = ENABLE;
      NVIC_Init(&NVIC_InitStructure);
      TIM_Cmd(TIM3, ENABLE);
}
/*用户实现的定时器接口*/
void TIM3_IRQHandler(void)
{
      if(TIM_GetITStatus(TIM3, TIM_IT_Update) != RESET)
      {
            TIM_ClearITPendingBit(TIM3, TIM_IT_Update  );
            gizTimerMs();
      }
}
/*******************/
//void TIMER_IRQ_FUN(void)
//{
//  gizTimerMs();
//}
/*******************/
## 添加UART3串口通信代码驱动
```c
#include "usart3.h"
#include "gizwits_product.h"
void USART3_Init(uint32_t BaudRate)
{
      RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOB, ENABLE);                            //GPIOB时钟
      RCC_APB1PeriphClockCmd(RCC_APB1Periph_USART3,ENABLE);                         //串口3时钟使能
      USART_DeInit(USART3);  //复位串口3
      GPIO_InitTypeDef GPIO_InitStructure;
  GPIO_InitStructure.GPIO_Pin = GPIO_Pin_10;                                  //PB10
      GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;                            //USART3_TX PB10
      GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP;                                     //复用推挽输出
      GPIO_Init(GPIOB, &GPIO_InitStructure);                                        //初始化PB10
      GPIO_InitStructure.GPIO_Pin = GPIO_Pin_11;                                           //USART3_RX       PB11
      GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;                         //浮空输入
      GPIO_Init(GPIOB, &GPIO_InitStructure);
      USART_InitTypeDef                USART_InitStructure;
      USART_InitStructure.USART_BaudRate          = BaudRate;                                  //波特率一般设置为9600;
      USART_InitStructure.USART_WordLength       = USART_WordLength_8b;                   //字长为8位数据格式
      USART_InitStructure.USART_StopBits          = USART_StopBits_1;                      //一个停止位
      USART_InitStructure.USART_Parity             = USART_Parity_No;                         //无奇偶校验位
      USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None;//无硬件数据流控制
      USART_InitStructure.USART_Mode             = USART_Mode_Rx | USART_Mode_Tx;                      //收发模式
      USART_Init(USART3, &USART_InitStructure);    //初始化串口3
      USART_Cmd(USART3, ENABLE);                   //使能串口
  USART_ITConfig(USART3, USART_IT_RXNE, ENABLE);    //开启中断
  NVIC_InitTypeDef NVIC_InitStructure;
      NVIC_InitStructure.NVIC_IRQChannel                = USART3_IRQn;
      NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 2;
      NVIC_InitStructure.NVIC_IRQChannelSubPriority       = 3;
      NVIC_InitStructure.NVIC_IRQChannelCmd             = ENABLE;
      NVIC_Init(&NVIC_InitStructure);
}
/*用户实现的中断服务函数接口*/
void USART3_IRQHandler(void)
{
      uint8_t Recv_Data;
      if(USART_GetITStatus(USART3, USART_IT_RXNE) != RESET)//接收到数据
      {
               Recv_Data = USART_ReceiveData(USART3);
               gizPutData(&Recv_Data, 1);
      }
}
/*********************/
//void UART_IRQ_FUN(void)
//{
//  uint8_t value = 0;
//  gizPutData(&value, 1);
//}
/*********************/

[color=rgb(0, 0, 0) !important]复制代码

8，修改关键函数的函数体，封装各模块的初始化

五，机智云初始化函数封装
成功联网

设备上线显示

效果展示

【Io开发笔记】机智云智能浇花器实战(3)-自动生成代码移植

站长推荐 /1