wenkong_junshi/Template/mcu_sdk/protocol.c

/**
 * @file  protocol.c
 * @brief this file contains protocol analysis and construct response function when received zigbee module send message
 * @author qinlang
 * @date 2022.05.06
 * @par email:qinlang.chen@tuya.com
 * @copyright HANGZHOU TUYA INFORMATION TECHNOLOGY CO.,LTD
 * @par company
 * http://www.tuya.com
 */
////must  modify
#include "./mcu_sdk/zigbee.h" //directory by ddw
//#include "GLOBAL.h"
#include <SIM_EEPROM.h>
#include "systick.h"
#include "gd32f30x.h"
#include "GLOBAL.h"
#include "gpio_ctl.h"
#include "uart.h"
#include "key_proc.h"
#include "lcd_task.h"
#include "key_operate.h"
#include "MB_RTU_deal_task.h"
#include "gd32f30x_it.h"
#include "All_define.h"
#include "modbus.h"
#include "MB_RTU_deal_task.h"
#include "led.h"
#include "MB_RTU_task.h"
Zigbee_cmd 	zigbee_cmd;
// #include "../uart.h"
extern unsigned char gRelayOnOff;
////must  modify
/******************************************************************************
                                移植须知:
1:MCU必须在while中直接调用mcu_api.c内的zigbee_uart_service()函数
2:程序正常初始化完成后,建议不进行关串口中断,如必须关中断,关中断时间必须短,关中断会引起串口数据包丢失
3:请勿在中断/定时器中断内调用上报函数
******************************************************************************/
/******************************************************************************
                              第一步:初始化
1:在需要使用到zigbee相关文件的文件中include "zigbee.h"
2:在MCU初始化中调用mcu_api.c文件中的zigbee_protocol_init()函数
3:将MCU串口单字节发送函数填入protocol.c文件中uart_transmit_output函数内,并删除#error
4:在MCU串口接收函数中调用mcu_api.c文件内的uart_receive_input函数,并将接收到的字节作为参数传入
5:单片机进入while循环后调用mcu_api.c文件内的zigbee_uart_service()函数

6:mcu何时开启zigbee模块配网，当zigbee模块查询到mcu的产品信息之后，或者zigbee模块发送了当前网络状态
给到mcu，查询pid信息会在上电5秒之后发送,对接部分zigbee老版本通用对接固件低功耗版本尤其需要注意不要
在第一次确认波特率的时候提前唤醒或者发送串口给zigbee模组，有概率导致zigbee模组波特率存储失败。

	7：上电之后，mcu何时上报数据给网关合适，在收到网络状态为已配网，或者接收到读取dp数据的时候。
8: 在mcu ota过程中发送固件内容请求未收到zigbee模块的应答时，需要mcu端做好超时重新请求的处理，和存储image
处理，校验和可以自行设计或者使用参考。
******************************************************************************/

/******************************************************************************
                        1:dp数据点序列类型对照表
          **此为自动生成代码,如在开发平台有相关修改请重新下载MCU_SDK**
******************************************************************************/
#ifdef ZIGBEE_ZS_T4
const DOWNLOAD_CMD_S download_cmd[] =
    {
        {DPID_SWITCH, DP_TYPE_BOOL},
        {DPID_MODE, DP_TYPE_ENUM},
        {DPID_WORK_STATE, DP_TYPE_ENUM},
        {DPID_TEMP_SET, DP_TYPE_VALUE},
        {DPID_TEMP_CURRENT, DP_TYPE_VALUE},
        {DPID_LEVEL, DP_TYPE_ENUM},
		{DPID_WORK_STATE1, DP_TYPE_ENUM},
		{DPID_TEMP_DN, DP_TYPE_VALUE},
        {DPID_SWITCH_FLOOR_HEAT, DP_TYPE_BOOL},
		{DPID_SWITCH_FAN, DP_TYPE_BOOL},
		{DPID_LEVEL_FAN, DP_TYPE_ENUM},
};
#endif
#ifdef FLOORHEATER_T4_CS
const DOWNLOAD_CMD_S download_cmd[] =
    {
        {DPID_SWITCH, DP_TYPE_BOOL},
        {DPID_MODE, DP_TYPE_ENUM},
        {DPID_WORK_STATE, DP_TYPE_ENUM},
        {DPID_TEMP_SET, DP_TYPE_VALUE},
        {DPID_TEMP_CURRENT, DP_TYPE_VALUE},
        {DPID_LEVEL, DP_TYPE_ENUM},
        {DPID_SET_LIGHT_3, DP_TYPE_ENUM},
};
#endif
/******************************************************************************
                           2:串口单字节发送函数
请将MCU串口发送函数填入该函数内,并将接收到的数据作为参数传入串口发送函数
******************************************************************************/
////must  modify
extern void start_usart0_tx(unsigned char tx_buffer[], unsigned char length);
////must  modify
static void report_mcu_ota_result(unsigned char res);

/**
 * @brief encapsulates a generic send function, developer should use their own function to completing this fuction
 * @param[in] {value} send signle data
 * @return  void
 */
////must  modify
void uart_transmit_output(unsigned char value)
{
	//printf("uart_transmit_output 0x%x\r\n",value);
    static unsigned char buf;
    buf = value;
    //  #error "please use your own uart send fuction complete this fuction, exmaple"
    /*
     *  //demo:
     *  extern void Uart_PutChar(unsigned char value);
     *  Uart_PutChar(value);
     */
    start_usart0_tx(&buf, 1); // 串口发送单字节函数
}
////must  modify
/******************************************************************************
                           第二步:实现具体用户函数
1:APP下发数据处理
2:数据上报处理
******************************************************************************/

/******************************************************************************
                            1:所有数据上报处理
当前函数处理全部数据上报(包括可下发/可上报和只上报)
  需要用户按照实际情况实现:
  1:需要实现可下发/可上报数据点上报
  2:需要实现只上报数据点上报
此函数为MCU内部必须调用
用户也可调用此函数实现全部数据上报
******************************************************************************/

// 自动化生成数据上报函数

/**
 * @brief Upload all dp information of the system, and realize the synchronization of APP and muc data
 * @param[in] {void}
 * @return  void
 */

////must  modify
#if (defined ZIGBEE_ZS_T4) || (defined ZIGBEE_ZS_T4_CS)
// #if (defined ZIGBEE_ZS_T4) || (defined ZIGBEE_ZS_T3) || (defined ZIGBEE_ZS_T2) || (defined ZIGBEE_ZS_T1)
void all_data_update(void)
{
    /*dis_air_Conditioning = 0,
	dis_floor_heating ,		 
	dis_fresh_air ,
     * these fucntion will be generated by cloud platform, but when use these function must reference the function in  mcu_api.c
     */
	//zigbee_cmd.Is_From_485=0;
	uint16_t	level;	
	if(zigbee_cmd.Is_From_485==1||zigbee_cmd.Is_zigbee_cmd==0)
		zigbee_cmd.work_state_cur=dis_page_num.display_page ;
	mcu_dp_enum_update(DPID_WORK_STATE1, zigbee_cmd.work_state_cur);
	zigbee_cmd.work_state_info.air_condition.switch_onoff=dis_page_param.face_plate_param.Air_condition_switch;
	zigbee_cmd.work_state_info.air_condition.mode=dis_page_param.face_plate_param.Air_condition_mode;
	zigbee_cmd.work_state_info.air_condition.temp_set=dis_page_param.face_plate_param.Air_set_temp;
	switch(dis_page_param.face_plate_param.Air_wind_speed)
    {
		case 0x0100:
			zigbee_cmd.work_state_info.air_condition.level=0x0100;
		    level=0x00;
		break;
		case 0x0001:
			zigbee_cmd.work_state_info.air_condition.level=0x0001;
		    level=0x01;
		break;
		case 0x0002:
			zigbee_cmd.work_state_info.air_condition.level=0x0002;
			level=0x02;
		break;
		case 0x0003:
			zigbee_cmd.work_state_info.air_condition.level=0x0003;
			level=0x03;
		break;
	    default:
				break;    
			
	}
	//zigbee_cmd.work_state_info.air_condition.level=dis_page_param.face_plate_param.Air_wind_speed;
	zigbee_cmd.work_state_info.floor_condition.switch_onoff=dis_page_param.face_plate_param.Floor_heating_switch;
	zigbee_cmd.work_state_info.floor_condition.temp_set=dis_page_param.face_plate_param.Floor_heating_set_temp;
	zigbee_cmd.work_state_info.fresh_air_condition.switch_onoff=dis_page_param.face_plate_param.Fresh_air_switch;
	zigbee_cmd.work_state_info.fresh_air_condition.level=dis_page_param.face_plate_param.Fresh_air_speed;
	 switch(zigbee_cmd.work_state_cur)
	   {
		   case 0:
		       mcu_dp_bool_update(DPID_SWITCH, zigbee_cmd.work_state_info.air_condition.switch_onoff);
		       mcu_dp_enum_update(DPID_MODE, zigbee_cmd.work_state_info.air_condition.mode);
		       mcu_dp_value_update(DPID_TEMP_SET, zigbee_cmd.work_state_info.air_condition.temp_set);
		       mcu_dp_enum_update(DPID_LEVEL, level); 
			    break;
		   case 1:
			   mcu_dp_bool_update(DPID_SWITCH_FLOOR_HEAT, zigbee_cmd.work_state_info.floor_condition.switch_onoff);
		       mcu_dp_value_update(DPID_TEMP_DN, zigbee_cmd.work_state_info.floor_condition.temp_set);
		       break;
		   case 2:
			   mcu_dp_bool_update(DPID_SWITCH_FAN, zigbee_cmd.work_state_info.fresh_air_condition.switch_onoff);
		       mcu_dp_enum_update(DPID_LEVEL_FAN, zigbee_cmd.work_state_info.fresh_air_condition.level); 
		       break;
		  default:
				break;    	   
	   }
    mcu_dp_value_update(DPID_TEMP_CURRENT, dis_page_param.face_plate_param.Real_time_Temp);
   /* mcu_dp_bool_update(DPID_SWITCH, Smartbox_On_Off_State); // BOOL型数据上报;
    if (ModeType != 0)
    {
        mcu_dp_enum_update(DPID_MODE, ModeType - 1); // 枚举型数据上报;
    }
    else
    {
        mcu_dp_enum_update(DPID_MODE, ModeType); // 枚举型数据上报;
    }
    if (DeviceType != 0)
    {
        mcu_dp_enum_update(DPID_WORK_STATE, DeviceType - 1); // 枚举型数据上报;
    }
    else
    {
        mcu_dp_enum_update(DPID_WORK_STATE, DeviceType); // 枚举型数据上报;
    }
    mcu_dp_value_update(DPID_TEMP_SET, Set_Temperature_IntegerData / 2); // VALUE型数据上报;

   // mcu_dp_value_update(DPID_TEMP_CURRENT, Now_Temperature_IntegerData); // VALUE型数据上报;
	 mcu_dp_value_update(DPID_TEMP_CURRENT, dis_page_param.face_plate_param.Real_time_Temp); // VALUE型数据上报;
    if (WindSpeedData != 0)
    {
        mcu_dp_enum_update(DPID_LEVEL, WindSpeedData - 1); // 枚举型数据上报;
    }
    else
    {
        mcu_dp_enum_update(DPID_LEVEL, WindSpeedData); // 枚举型数据上报;
    }
    mcu_dp_enum_update(DPID_WORK_STATE1,zigbee_cmd.work_state); //枚举型数据上报;*/
}
#endif
/******************************************************************************
                                WARNING!!!
                            2:所有数据上报处理
自动化代码模板函数,具体请用户自行实现数据处理
******************************************************************************/

// #ifdef ZIGBEE_ZS_T4
/*****************************************************************************
函数名称 : dp_download_switch_1_handle
功能描述 : 针对DPID_SWITCH_1的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_switch_handle(const unsigned char value[], unsigned short length)
{
	zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为BOOL
    unsigned char ret;
    // 0:off/1:on
    unsigned char switch_1;
	//zigbee_cmd.Is_Out_sleep=1;
	//zigbee_cmd.Is_Wakeup=1;
	PullOutOf_SleepPage();
	zigbee_cmd.Is_zigbee_cmd=1;
    switch_1 = mcu_get_dp_download_bool(value, length);
   /* if (switch_1 == 0)
    {
       switch(zigbee_cmd.work_state_cur)
	   {
		   case 0:
			    dis_page_param.face_plate_param.Open_device_mode = 0x00;
		        dis_page_param.face_plate_param.Air_condition_switch = 0;
			    Air_Open_data_Send();
		        zigbee_cmd.work_state_info.air_condition.switch_onoff=0;
			    break;
		   case 1:
			   dis_page_param.face_plate_param.Floor_heating_switch =0;
		       Floor_heating_Open_data_Send();
		   zigbee_cmd.work_state_info.floor_condition.switch_onoff=0;
		       break;
		   case 2:
			   dis_page_param.face_plate_param.Fresh_air_switch=0;
		       Fresh_air_Open_data_Send();
		   zigbee_cmd.work_state_info.fresh_air_condition.switch_onoff=0;
		       break;
		  default:
				break;    	   
	   }
    }
    else
    {
       switch(zigbee_cmd.work_state_cur)
	   {
		   case 0:
			   dis_page_param.face_plate_param.Open_device_mode = 0x00;
		        dis_page_param.face_plate_param.Air_condition_switch = 1;
			    Air_Open_data_Send();
		       zigbee_cmd.work_state_info.air_condition.switch_onoff=1;
			    break;
		   case 1:
			   dis_page_param.face_plate_param.Floor_heating_switch =1;
		       Floor_heating_Open_data_Send();
		   zigbee_cmd.work_state_info.floor_condition.switch_onoff=1;
		       break;
		   case 2:
			   dis_page_param.face_plate_param.Fresh_air_switch=1;
		       Fresh_air_Open_data_Send();
		   zigbee_cmd.work_state_info.fresh_air_condition.switch_onoff=1;
		       break;
		  default:
				break;    	   
	   }
		
    }*/
	 if (switch_1 == 0)
    {
       
			    dis_page_param.face_plate_param.Open_device_mode = 0x00;
		        dis_page_param.face_plate_param.Air_condition_switch = 0;
			    Air_Open_data_Send();
		        zigbee_cmd.work_state_info.air_condition.switch_onoff=0;
			   
    }
    else
    {
        zigbee_cmd.Is_clear_lcd=1;
			   dis_page_param.face_plate_param.Open_device_mode = 0x00;
		        dis_page_param.face_plate_param.Air_condition_switch = 1;
			    Air_Open_data_Send();
		       zigbee_cmd.work_state_info.air_condition.switch_onoff=1;
	
		
    }
	xTaskNotify((TaskHandle_t	)LEDTask_Handler,
			(uint32_t		)Wake_up,			
			(eNotifyAction	)eSetBits);
    // There should be a report after processing the DP
    ret = mcu_dp_bool_update(DPID_SWITCH, switch_1);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
}

/*****************************************************************************
函数名称 : dp_download_mode_handle
功能描述 : 针对DPID_MODE的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_mode_handle(const unsigned char value[], unsigned short length)
{
	zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为ENUM
    unsigned char ret;
    unsigned char mode;
PullOutOf_SleepPage();
    mode = mcu_get_dp_download_enum(value, length);
	zigbee_cmd.Is_zigbee_cmd=1;
	//zigbee_cmd.mode=mode;
	zigbee_cmd.Is_Out_sleep=1;
	switch(zigbee_cmd.work_state_cur)
	{
		case 0:
			zigbee_cmd.work_state_info.air_condition.mode=(uint32_t)mode;
		    dis_page_param.face_plate_param.Air_condition_mode = (uint16_t)mode;
			 Air_Mode_data_Send();
		    break;
		default:
				break;  
	}
	if(mode==2&&dis_page_param.face_plate_param.Air_wind_speed==0x0100)
		dis_page_param.face_plate_param.Air_wind_speed=0x0001;
  all_data_update();
	return SUCCESS;
   // ModeType = mode + 1; // 模式图标显示 value:1-制冷，2-制热，3-除湿，4-吹风， 0-关闭

    // There should be a report after processing the DP
   /* ret = mcu_dp_enum_update(DPID_MODE, mode);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;*/
}
/*****************************************************************************
函数名称 : dp_download_temp_set_handle
功能描述 : 针对DPID_TEMP_SET的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_temp_set_handle(const unsigned char value[], unsigned short length)
{
	zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为VALUE
    unsigned char ret;
    unsigned long temp_set;
    zigbee_cmd.Is_Out_sleep=1;
    temp_set = mcu_get_dp_download_value(value, length);
	PullOutOf_SleepPage();
	zigbee_cmd.Is_zigbee_cmd=1;
    /*
    //VALUE type data processing

    */
	switch(zigbee_cmd.work_state_cur)
	{
		case 0:
			zigbee_cmd.work_state_info.air_condition.temp_set=(uint32_t)temp_set;
		    dis_page_param.face_plate_param.Air_set_temp=(uint16_t)temp_set;
	        Air_set_temp_data_Send();
		    break;
		case 1:
			//zigbee_cmd.work_state_info.floor_condition.temp_set=(uint32_t)temp_set;
		   // dis_page_param.face_plate_param.Floor_heating_set_temp=(uint32_t)temp_set;
	     	//Floor_heating_set_temp_data_Send();
		    break;
		default:
				break;  
	}
	
   // Set_Temperature_IntegerData = temp_set * 2; ////设置温度整数部分
	 // switchState.setcounter = 20; // 2秒倒计时		
    // There should be a report after processing the DP
    ret = mcu_dp_value_update(DPID_TEMP_SET, temp_set);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
}
/*****************************************************************************
函数名称 : dp_download_level_handle
功能描述 : 针对DPID_LEVEL的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_level_handle(const unsigned char value[], unsigned short length)
{
	zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为ENUM
    unsigned char ret;
    unsigned char level;
zigbee_cmd.Is_Out_sleep=1;
	zigbee_cmd.Is_zigbee_cmd=1;
	PullOutOf_SleepPage();
    level = mcu_get_dp_download_enum(value, length);
	//printf("\r\n112122331\r\n");
   switch(zigbee_cmd.work_state_cur)
  {
	   case 0:
		   dis_page_num.display_page=dis_air_Conditioning;
		   zigbee_cmd.work_state_info.air_condition.level=level;
		   switch(level)
		   {
			    case 0:
				zigbee_cmd.work_state_info.air_condition.level=0x0100;
				dis_page_param.face_plate_param.Air_wind_speed=0x0100;
				Air_speed_data_Send();
			   // Air_speed_data_Sendtemp(0x01,0x00);
			    break;
				case 1:
					zigbee_cmd.work_state_info.air_condition.level=0x0001;
				dis_page_param.face_plate_param.Air_wind_speed=0x0001;
				Air_speed_data_Send();
			   // Air_speed_data_Sendtemp(0x00,0x01);
		        break;
				case 2:
					zigbee_cmd.work_state_info.air_condition.level=0x0002;
				dis_page_param.face_plate_param.Air_wind_speed=0x0002;
				Air_speed_data_Send();
			   // Air_speed_data_Sendtemp(0x00,0x02);
		        break;
		        case 3:
					zigbee_cmd.work_state_info.air_condition.level=0x0003;
				dis_page_param.face_plate_param.Air_wind_speed=0x0003;
				Air_speed_data_Send();
			   // Air_speed_data_Sendtemp(0x00,0x03);
		        break;
		        default:
				break;    
		   }
		   break;
	  
		case 2:
			zigbee_cmd.work_state_info.fresh_air_condition.level=level;
			switch(level)
		    {
			    case 0:
				dis_page_param.face_plate_param.Fresh_air_speed=0;
			    Fresh_air_speed_data_Sendtemp(0x01,0x00);
			    break;
				case 1:
				dis_page_param.face_plate_param.Fresh_air_speed=1;
			    Fresh_air_speed_data_Sendtemp(0x00,0x01);
		        break;
				case 2:
				dis_page_param.face_plate_param.Fresh_air_speed=2;
			    Fresh_air_speed_data_Sendtemp(0x00,0x02);
		        break;
		        case 3:
				dis_page_param.face_plate_param.Fresh_air_speed=3;
			    Fresh_air_speed_data_Sendtemp(0x00,0x03);
		        break;
		        default:
				break;    
		   }
			break;
		
		 default:
				break;     
		   	   
	 }
   // WindSpeedData = level + 1; // 风速显示界面，  value，1-自动，2-低，3-中，4-高，0-关闭所有图标
    // There should be a report after processing the DP
    ret = mcu_dp_enum_update(DPID_LEVEL, level);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
}

/*****************************************************************************
函数名称 : dp_download_work_state1_handle
功能描述 : 针对DPID_WORK_STATE1的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_work_state1_handle(const unsigned char value[], unsigned short length)
{
	zigbee_cmd.Is_From_485=0;
   unsigned char ret;
    unsigned char work_state1;
	zigbee_cmd.Is_Out_sleep=1;
    work_state1 = mcu_get_dp_download_enum(value, length);
	zigbee_cmd.Is_zigbee_cmd=1;
	PullOutOf_SleepPage();
	zigbee_cmd.work_state_cur=work_state1;
    switch (work_state1)
    {
    case 0:
        break;

    case 1:
        break;

    case 2:
        break;

    case 3:
        break;

    default:

        break;
    }
	 all_data_update();
     return SUCCESS;
    //There should be a report after processing the DP
  //  ret = mcu_dp_enum_update(DPID_WORK_STATE1, work_state1);
  //  if(ret == SUCCESS)
      //  return SUCCESS;
  //  else
   //     return ERROR;
}


/*****************************************************************************
函数名称 : dp_download_temp_dn_handle
功能描述 : 针对DPID_TEMP_DN的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_temp_dn_handle(const unsigned char value[], unsigned short length)
{
	// 示例:当前DP类型为VALUE
    unsigned char ret;
    unsigned long temp_set;
    zigbee_cmd.Is_Out_sleep=1;
	zigbee_cmd.Is_zigbee_cmd=1;
    temp_set = mcu_get_dp_download_value(value, length);
	PullOutOf_SleepPage();
    /*
    //VALUE type data processing

    */
	switch(zigbee_cmd.work_state_cur)
	{
		case 0:
			//zigbee_cmd.work_state_info.air_condition.temp_set=(uint32_t)temp_set;
		   // dis_page_param.face_plate_param.Air_set_temp=(uint16_t)temp_set;
	       // Air_set_temp_data_Send();
		    break;
		case 1:
			zigbee_cmd.work_state_info.floor_condition.temp_set=(uint32_t)temp_set;
		    dis_page_param.face_plate_param.Floor_heating_set_temp=(uint32_t)temp_set;
	     	Floor_heating_set_temp_data_Send();
		    break;
		default:
				break;  
	}
	
   // Set_Temperature_IntegerData = temp_set * 2; ////设置温度整数部分
	 // switchState.setcounter = 20; // 2秒倒计时		
    // There should be a report after processing the DP
    ret = mcu_dp_value_update(DPID_TEMP_DN, temp_set);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
	
}


/*****************************************************************************
函数名称 : dp_download_switch_floor_heat_handle
功能描述 : 针对DPID_SWITCH_FLOOR_HEAT的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_switch_floor_heat_handle(const unsigned char value[], unsigned short length)
{
 
	zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为BOOL
    unsigned char ret;
    // 0:off/1:on
    unsigned char switch_1;
	//zigbee_cmd.Is_Out_sleep=1;
	//zigbee_cmd.Is_Wakeup=1;
	PullOutOf_SleepPage();
	zigbee_cmd.Is_zigbee_cmd=1;
    switch_1 = mcu_get_dp_download_bool(value, length);
    if (switch_1 == 0)
    {
		   
			   dis_page_param.face_plate_param.Floor_heating_switch =0;
		       Floor_heating_Open_data_Send();
		   zigbee_cmd.work_state_info.floor_condition.switch_onoff=0;
    }
    else
    {
		  zigbee_cmd.Is_clear_lcd=1;
			   dis_page_param.face_plate_param.Floor_heating_switch =1;
		       Floor_heating_Open_data_Send();
		   zigbee_cmd.work_state_info.floor_condition.switch_onoff=1;
		       
    }
	xTaskNotify((TaskHandle_t	)LEDTask_Handler,
			(uint32_t		)Wake_up,			
			(eNotifyAction	)eSetBits);
    // There should be a report after processing the DP
    ret = mcu_dp_bool_update(DPID_SWITCH_FLOOR_HEAT, switch_1);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
}
/*****************************************************************************
函数名称 : dp_download_switch_fan_handle
功能描述 : 针对DPID_SWITCH_FAN的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_switch_fan_handle(const unsigned char value[], unsigned short length)
{
	
	zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为BOOL
    unsigned char ret;
    // 0:off/1:on
    unsigned char switch_1;
	//zigbee_cmd.Is_Out_sleep=1;
	//zigbee_cmd.Is_Wakeup=1;
	PullOutOf_SleepPage();
	zigbee_cmd.Is_zigbee_cmd=1;
    switch_1 = mcu_get_dp_download_bool(value, length);
    if (switch_1 == 0)
    {
			   dis_page_param.face_plate_param.Fresh_air_switch=0;
		       Fresh_air_Open_data_Send();
		   zigbee_cmd.work_state_info.fresh_air_condition.switch_onoff=0;
		       	   
	   
    }
    else
    {
		  zigbee_cmd.Is_clear_lcd=1;
			   dis_page_param.face_plate_param.Fresh_air_switch=1;
		       Fresh_air_Open_data_Send();
		   zigbee_cmd.work_state_info.fresh_air_condition.switch_onoff=1;
		     
		
    }
	xTaskNotify((TaskHandle_t	)LEDTask_Handler,
			(uint32_t		)Wake_up,			
			(eNotifyAction	)eSetBits);
    // There should be a report after processing the DP
    ret = mcu_dp_bool_update(DPID_SWITCH_FAN, switch_1);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
}
/*****************************************************************************
函数名称 : dp_download_level_fan_handle
功能描述 : 针对DPID_LEVEL_FAN的处理函数
输入参数 : value:数据源数据
        : length:数据长度
返回参数 : 成功返回:SUCCESS/失败返回:ERROR
使用说明 : 可下发可上报类型,需要在处理完数据后上报处理结果至app
*****************************************************************************/
static unsigned char dp_download_level_fan_handle(const unsigned char value[], unsigned short length)
{
   zigbee_cmd.Is_From_485=0;
    // 示例:当前DP类型为ENUM
    unsigned char ret;
    unsigned char level;
   zigbee_cmd.Is_Out_sleep=1;
	zigbee_cmd.Is_zigbee_cmd=1;
	PullOutOf_SleepPage();
    level = mcu_get_dp_download_enum(value, length);
	//printf("\r\n112122331\r\n");
  
			zigbee_cmd.work_state_info.fresh_air_condition.level=level;
			switch(level)
		    {
			    case 0:
				dis_page_param.face_plate_param.Fresh_air_speed=0;
			    Fresh_air_speed_data_Sendtemp(0x01,0x00);
			    break;
				case 1:
				dis_page_param.face_plate_param.Fresh_air_speed=1;
			    Fresh_air_speed_data_Sendtemp(0x00,0x01);
		        break;
				case 2:
				dis_page_param.face_plate_param.Fresh_air_speed=2;
			    Fresh_air_speed_data_Sendtemp(0x00,0x02);
		        break;
		        case 3:
				dis_page_param.face_plate_param.Fresh_air_speed=3;
			    Fresh_air_speed_data_Sendtemp(0x00,0x03);
		        break;
		        default:
				break;    
		      
		   	   
	      }
			zigbee_cmd.work_state_info.fresh_air_condition.level=level;
   // WindSpeedData = level + 1; // 风速显示界面，  value，1-自动，2-低，3-中，4-高，0-关闭所有图标
    // There should be a report after processing the DP
    ret = mcu_dp_enum_update(DPID_LEVEL_FAN, level);
    if (ret == SUCCESS)
        return SUCCESS;
    else
        return ERROR;
}


#if (defined ZIGBEE_ZS_T4) || (defined ZIGBEE_ZS_T4_CS)

#endif

#ifdef SUPPORT_MCU_RTC_CHECK
/**
 * @brief mcu check local RTC time
 * @param[in] {time} timestamp
 * @return  void
 */
void mcu_write_rtctime(unsigned char time[])
{
#error "mcu should realize RTC time wtriting fuction, and delete this line"
    /*
	    time[0]~time[3]：standard time
    time[4]~time[7]: Local time
   */
    my_memcpy((void *)timestamp, (const char *)time, 4); // get timestamp
    zigbee_timestamp_to_time();
    /*
        year = _time.w_year;	//year
        month = _time.w_month;	//month
        date = _time.w_date;	//date
        hour = _time.hour + 8;	//hour(8:BeiJing time)
        min = _time.min;	//minute
        sec = _time.sec;	//second
    */
}
#endif

/**
 * @brief Zigbee functional test feedback
 * @param[in] {void}
 * @return  void
 */
void zigbee_test_result(void)
{
    ////must  modify
    //	#error "this test is makesure the rf fuction of zigbee module, if test pass or not should do something, mcu should realize"
    unsigned char rssi = zigbee_uart_rx_buf[DATA_START + 1];

    if (zigbee_uart_rx_buf[DATA_START] == 0x01)
    {
        if (rssi > 0x3C)
        {
            // test sucess the range of rssi is 0% ~ 100%
        }
        else
        {
            // test failure
        }
    }
    else
    {
        // test failure
    }
}

/******************************************************************************
                                WARNING!!!
以下函数用户请勿修改!!
******************************************************************************/

/**
 * @brief this function will handle uart received frame data
 * @param[in] {dpid}   dp id
 * @param[in] {value}  dp data
 * @param[in] {length} lenght of dp data
 * @return  handle result
 */

// #ifdef ZIGBEE_ZS_T4
#if (defined ZIGBEE_ZS_T4) || (defined ZIGBEE_ZS_T4_CS)
unsigned char dp_download_handle(unsigned char dpid, const unsigned char value[], unsigned short length)
{
    /* only list of function, mcu need realize these fuction*/
    unsigned char ret;
  switch(dpid){
          case DPID_SWITCH:
            //开关处理函数
            ret = dp_download_switch_handle(value,length);
        break;
        case DPID_MODE:
            //工作模式处理函数
            ret = dp_download_mode_handle(value,length);
        break;
        case DPID_TEMP_SET:
            //目标温度处理函数
            ret = dp_download_temp_set_handle(value,length);
        break;
        case DPID_LEVEL:
            //档位处理函数
            ret = dp_download_level_handle(value,length);
        break;
        case DPID_WORK_STATE1:
            //工作状态处理函数
            ret = dp_download_work_state1_handle(value,length);
        break;
		case DPID_TEMP_DN:
            //地暖目标温度处理函数
            ret = dp_download_temp_dn_handle(value,length);
        break;
		case DPID_SWITCH_FLOOR_HEAT:
            //地暖开关处理函数
            ret = dp_download_switch_floor_heat_handle(value,length);
        break;
        case DPID_SWITCH_FAN:
            //新风开关处理函数
            ret = dp_download_switch_fan_handle(value,length);
        break;
        case DPID_LEVEL_FAN:
            //新风风速档位处理函数
            ret = dp_download_level_fan_handle(value,length);
        break;
 default:
    break;}
    return ret;
}
#endif

/**
 * @brief get received cmd total number
 * @param[in] {void}
 * @return  received cmd total number
 */
unsigned char get_download_cmd_total(void)
{
    return (sizeof(download_cmd) / sizeof(download_cmd[0]));
}

/**
 * @brief received zigbee net_work state handle
 * @param[in] {zigbee_work_state}  zigbee current network state
 * @return  void
 */
void zigbee_work_state_event(unsigned char zigbee_work_state)
{
    unsigned short length = 0;
    zigbee_uart_write_frame(ZIGBEE_STATE_CMD, length);

    switch (zigbee_work_state)
    {
    case ZIGBEE_NOT_JION: // 设备不在网
		//	if(ZG_Joining == CONDITION_BEFOR_JOINING_TO_JOINING)
			//	{
        // switchState.zigbee_work_state = 0;
        // switchState.time = 1000; // 10秒
       //  ledSetParam(25, 200);
			//	}
        break;

    case ZIGBEE_JOIN_GATEWAY:  // 入网成功
		Is_blink=0;
       // ZG_JoinCounter = 1000; // 入网成功，入网计数器置最大值
        //switchState.zigbee_work_state = 1;
        break;

    case ZIGBEE_JOIN_ERROR:
        switchState.zigbee_work_state = 0;
        switchState.time = 1000; // 10秒
        ledSetParam(25, 200);
        break;

    case ZIGBEE_JOINING:

        break;

    default:
        break;
    }
}

/**
 * @brief received reset zigbee response
 * @param[in] {state} response state
 * @return  void
 */
void mcu_reset_zigbee_event(unsigned char state)
{
    switch (state)
    {
    case RESET_ZIGBEE_OK:

        break;

    case RESET_ZIGBEE_ERROR:

        break;

    default:
        break;
    }
}

/**
 * @brief check mcu version response
 * @param[in] {void}
 * @return  void
 */
void response_mcu_ota_version_event(void)
{
    unsigned short length = 0;
    length = set_zigbee_uart_byte(length, get_current_mcu_fw_ver()); // current fw version
    zigbee_uart_write_frame(MCU_OTA_VERSION_CMD, length);
}

#ifdef SUPPORT_MCU_OTA
/**
 * @brief mcu ota update notify response
 * @param[in] {offset} data offset
 * @return  void
 */
void response_mcu_ota_notify_event(unsigned char offset)
{
    unsigned char i = 0;
    unsigned short length = 0;
    unsigned char update = 0;
    unsigned long app_newcode_add = 0;
    unsigned char j = 0;
    uint32_t temp_buff[256];
    int k=0;

    current_mcu_fw_pid(); // current PID

    while (i < 8)
    {
        ota_fw_info.mcu_ota_pid[i] = zigbee_uart_rx_buf[offset + DATA_START + i]; // ota fw PID
        i++;
    }
    ota_fw_info.mcu_ota_ver = zigbee_uart_rx_buf[offset + DATA_START + 8]; // ota fw version
    ota_fw_info.mcu_ota_fw_size = zigbee_uart_rx_buf[offset + DATA_START + 9] << 24 |
                                  zigbee_uart_rx_buf[offset + DATA_START + 10] << 16 |
                                  zigbee_uart_rx_buf[offset + DATA_START + 11] << 8 |
                                  zigbee_uart_rx_buf[offset + DATA_START + 12]; // ota fw size
    ota_fw_info.mcu_ota_checksum = zigbee_uart_rx_buf[offset + DATA_START + 13] << 24 |
                                   zigbee_uart_rx_buf[offset + DATA_START + 14] << 16 |
                                   zigbee_uart_rx_buf[offset + DATA_START + 15] << 8 |
                                   zigbee_uart_rx_buf[offset + DATA_START + 16]; // ota fw checksum

    if ((!strcmp_barry(&ota_fw_info.mcu_ota_pid[0], &current_mcu_pid[0], 8)) &&
        (ota_fw_info.mcu_ota_ver > get_current_mcu_fw_ver() &&
         ota_fw_info.mcu_ota_fw_size > 0))
    {                                                // check fw pid and fw version and fw size
        length = set_zigbee_uart_byte(length, 0x00); // OK
        update = 1;                                  // 校验通过，可进行固件升级
    }
    else
    {
        length = set_zigbee_uart_byte(length, 0x01); // error
    }
    ota_fw_info.mcu_current_offset = 0;
    zigbee_uart_write_frame(MCU_OTA_NOTIFY_CMD, length);
    
		delay_1ms(20);
    // add by zzw 升级通知接收成功，第一次调用接收固件命令
    if (update)
    {
        // 在读取数据之前先对FLASH进行擦除，从第38页开始
        app_newcode_add = OTA_NEW_CODE_START_ADD;
        fmc_unlock();
       
        /*for (k = 0; k < 256; k++)
        {
            temp_buff[k] = flash_word_read(OTA_STATE_DATA_ADD + (4 * k)); // 1.取出程序运行区代码数据
        }
        temp_buff[0] = 0;//参数初始化
        //delay_1ms(10);
        flash_page_write(OTA_STATE_DATA_ADD, temp_buff); // 2.将取出的运行区代码写入临时区
        delay_1ms(20);*/
        for (i = 0; i < 26; i++)
        {
            fmc_page_erase(app_newcode_add + i * 1024);
        }
        fmc_lock();
        mcu_ota_fw_request(); // 固件升级
    }
}

/**
 * @brief received mcu ota data request response
 * @param[in] {fw_offset}  offset of file
 * @param[in] {data}  received data
 * @return  void
 */
/*void reveived_mcu_ota_data_handle(unsigned int fw_offset, char *data)
{
// "received frame data, should save in flash, mcu should realize this fuction, and delete this line "
//未使用
}*/

/**
 * @brief mcu send ota data request
 * @param[in] {void}
 * @return  void
 */
void mcu_ota_fw_request_event(unsigned char offset)
{
    unsigned int fw_offset = 0;
    char fw_data[FW_SINGLE_PACKET_SIZE] = {-1}; //
    unsigned char i = 0;
    unsigned char last_package_len = 0;
    static unsigned int current_checksum = 0;

    if (zigbee_uart_rx_buf[offset + DATA_START] == 0x01) // status check
        return;
    while (i < 8)
    {
        if (current_mcu_pid[i] != zigbee_uart_rx_buf[offset + DATA_START + 1 + i]) // pid check
            return;
        i++;
    }
    if (ota_fw_info.mcu_ota_ver != zigbee_uart_rx_buf[offset + DATA_START + 9]) // version check
        return;

    i = 0;
    while (i < 4)
    {
        fw_offset |= (zigbee_uart_rx_buf[offset + DATA_START + 10 + i] << (24 - i * 8)); // offset
        i++;
    }
    i = 0;
    if (ota_fw_info.mcu_current_offset == fw_offset)
    {
        // if ((ota_fw_info.mcu_ota_fw_size - fw_offset) / FW_SINGLE_PACKET_SIZE != 0)
        if (((ota_fw_info.mcu_ota_fw_size - fw_offset) / FW_SINGLE_PACKET_SIZE != 0) && (ota_fw_info.mcu_ota_fw_size != (fw_offset + FW_SINGLE_PACKET_SIZE)))
        // if (((ota_fw_info.mcu_ota_fw_size - fw_offset) / FW_SINGLE_PACKET_SIZE != 0)&&((ota_fw_info.mcu_ota_fw_size - fw_offset) % FW_SINGLE_PACKET_SIZE != 0))
        {
            if (ota_fw_info.mcu_current_offset == 0)
            {
                current_checksum = 0;
            }
            while (i < FW_SINGLE_PACKET_SIZE)
            {
                fw_data[i] = zigbee_uart_rx_buf[offset + DATA_START + 14 + i]; // fw data
                current_checksum += fw_data[i];
                i++;
            }
            ota_fw_info.mcu_current_offset += FW_SINGLE_PACKET_SIZE;
            ota_fw_data_handle(fw_offset, &fw_data[0], FW_SINGLE_PACKET_SIZE); // OTA paket data handle
        }
        else
        {
            i = 0;
            // last_package_len = ota_fw_info.mcu_ota_fw_size - fw_offset;
            if ((ota_fw_info.mcu_ota_fw_size - fw_offset) % FW_SINGLE_PACKET_SIZE != 0)
            {
                last_package_len = ota_fw_info.mcu_ota_fw_size - fw_offset;
            }
            else
            {
                last_package_len = FW_SINGLE_PACKET_SIZE;
            }
            while (i < last_package_len)
            {
                fw_data[i] = zigbee_uart_rx_buf[offset + DATA_START + 14 + i];
                current_checksum += fw_data[i];
                i++;
            }
            ota_fw_info.mcu_current_offset += last_package_len;
            if (ota_fw_info.mcu_ota_checksum != current_checksum)
            {
                // ota failure report ota failure and clear ota struct
                mcu_ota_result_report(1); // failed
            }
            else
            {
                // ota sucess
                mcu_ota_result_report(0); // seccess
            }
            ota_fw_data_handle(fw_offset, &fw_data[0], last_package_len); // OTA paket data handle
            current_checksum = 0;
        }
    }
    else
    {
        // ota request timeout, then restart ota request from  ota_fw_info.mcu_ota_fw_size
    }
}

static void report_mcu_ota_result(unsigned char res)
{
    unsigned short length;
    if ((res == 0) || (res == 1))
    {
        length = set_zigbee_uart_byte(length, res);
        zigbee_uart_write_frame(MCU_OTA_NOTIFY_CMD, length);
    }
}

/**
 * @brief mcu ota data result notify
 * @param[in] {void}
 * @return  void
 */
void mcu_ota_result_event(unsigned char offset)
{
    unsigned short k, Ret;
    uint32_t temp_buff[256];
    unsigned char status = zigbee_uart_rx_buf[offset + DATA_START];

    if (status == 0x00)
    {
        // 升级成功，用户提示
        IAPUpdateFlag = 1;

        /*for (k = 0; k < 256; k++)
        {
            temp_buff[k] = flash_word_read(OTA_STATE_DATA_ADD + (4 * k)); // 1.取出程序运行区代码数据
        }
        temp_buff[0] = IAPUpdateFlag;
        delay_1ms(10);
        Ret = flash_page_write(OTA_STATE_DATA_ADD, temp_buff); // 2.将取出的运行区代码写入临时区
        delay_1ms(20);*/
        flash_word_write((OTA_STATE_DATA_ADD), IAPUpdateFlag);
        /*if(Ret == 0)
        {
            Ret = 0;
        }*/

        // flash_word_write (OTA_STATE_DATA_ADD,IAPUpdateFlag);
        delay_1ms(500);
        NVIC_SystemReset(); // add by  zzw 系统复位函数
    }
    else if (status == 0x01)
    {
    }
}

/**
 * @brief mcu ota data handle
 * @param[in] {fw_offset} frame offset
 * @param[in] {data} received data
 * @return  void
 */
void ota_fw_data_handle(unsigned int fw_offset, char *data, unsigned char data_len) // 一整包数据48字节
{
    unsigned short i = 0;
    unsigned short update = 1;
    unsigned long app_newcode_add = 0; // 读flash的时候的地址变量,新代码区
    unsigned short temp = 0;
    unsigned long write_data;
    //"请在该函数处理固件包数据"
    //"received frame data, should save in flash, mcu should realize this fuction, and delete this line "
    // 取出数据存入falsh,建议延用‘ota_fw_info’全局变量，不需定义其他全局变量，可维护数据包长度等
    if (fw_offset == 0)
    {
        app_newcode_add = OTA_NEW_CODE_START_ADD;
        /*fmc_unlock();
        for (i = 0; i < 26; i++)
        {
            fmc_page_erase(app_newcode_add + i * 1024);
        }
        fmc_lock();*/
    }

    OTA_Reciv_Datalen = OTA_Reciv_Datalen + data_len;
    app_newcode_add = OTA_NEW_CODE_START_ADD + fw_offset;
    if (data_len == FW_SINGLE_PACKET_SIZE) // 整包数据
    {
        for (i = 0; i < (FW_SINGLE_PACKET_SIZE / 4); i++)
        {
            write_data = 0;
            write_data = data[i * 4 + 3];
            write_data = (write_data << 8) + data[i * 4 + 2];
            write_data = (write_data << 8) + data[i * 4 + 1];
            write_data = (write_data << 8) + data[i * 4];
            flash_word_write(app_newcode_add, write_data);
            app_newcode_add = app_newcode_add + 4;
        }
    }
    else // 最后一包非整包数据
    {
        temp = data_len % 4;
        if (temp == 0)
        {
            for (i = 0; i < (data_len / 4); i++)
            {
                write_data = 0;
                write_data = data[i * 4 + 3];
                write_data = (write_data << 8) + data[i * 4 + 2];
                write_data = (write_data << 8) + data[i * 4 + 1];
                write_data = (write_data << 8) + data[i * 4];
                flash_word_write(app_newcode_add, write_data);
                app_newcode_add = app_newcode_add + 4;
            }
        }
    }
    //	  if(OTA_Reciv_Datalen == ota_fw_info.mcu_ota_fw_size)  //接收数据完成停止获取
    //		{
    //			update = 0;
    //		}
    if (update) // 数据存储完毕，继续调用获取数据命令
    {
        mcu_ota_fw_request(); // 固件升级
    }
}
#endif

#ifdef BEACON_TEST
/**
 * @brief beacon test notify,which used in testing
 * @param[in] {void}
 * @return  void
 */
void mcu_received_beacon_test_handle(void)
{
    unsigned short length = 0;
    length = set_zigbee_uart_byte(length, 0x00);
    zigbee_uart_write_frame(SEND_BEACON_NOTIFY_CMD, length);
    // then start test
}
#endif

#ifdef CHECK_ZIGBEE_NETWORK
/**
 * @brief check zigbee nwkstate,before start join nwk, check nwk if state is not 0x02,can start jion,
 * else delay 5s
 *
 * @param[in] {void}
 * @return  void
 */
void mcu_check_zigbee_nwk_state(void)
{
    unsigned short length = 0;
    zigbee_uart_write_frame(CHECK_ZIGBEE_NETWORK_CMD, length);
    // then start test
}
#endif

void zigbee_notify_factory_new_hanlde(void)
{
    unsigned short length = 0;
    length = set_zigbee_uart_byte(length, 0x01);
    zigbee_uart_write_frame(ZIGBEE_FACTORY_NEW_CMD, length);
    // then start test
}

#ifdef READ_DP_DATA_NOTIFY
/**
 * @brief when gateway repower or relink clould, or zigbee module join sucess, repower, this commod will notify
 * mcu, to sys dp data, mcu itself decide whether report.
 *
 * @param[in] {void}
 * @return  void
 */
void read_dp_data_notify_hanlde(void)
{
    unsigned short length = 0;
    length = set_zigbee_uart_byte(length, 0x01);
    zigbee_uart_write_frame(ZIGBEE_FACTORY_NEW_CMD, length);
    // then start test
}
#endif