99这里都是精品这里有精品,日韩无国内精品,亚洲100不卡论理片

/*********************************************************************
* INCLUDES
*/
#include <stdio.h>
#include <string.h>
#include "AF.h"
#include "OnBoard.h"
#include "OSAL_Tasks.h"
#include "SampleApp.h"
#include "ZDApp.h"
#include "ZDObject.h"
#include "ZDProfile.h"
#include "hal_drivers.h"
#include "hal_key.h"
#if defined ( LCD_SUPPORTED )
#include "hal_lcd.h"
#endif
#include "hal_led.h"
#include "hal_uart.h"
#include "hal_adc.h"
#include "MT_UART.h"
#include "MT_APP.h"
#include "MT.h"
#include "pm2.5.h"
#if !defined( SERIAL_APP_TX_MAX )
#define SERIAL_APP_TX_MAX 80
#endif
/*********************************************************************
* MACROS
*/
/*********************************************************************
* CONSTANTS
*/
#if !defined( SAMPLE_APP_PORT )
#define SAMPLE_APP_PORT 0
#endif
#if !defined( SAMPLE_APP_BAUD )
#define SAMPLE_APP_BAUD HAL_UART_BR_115200
#endif
// When the Rx buf space is less than this threshold, invoke the Rx callback.
#if !defined( SAMPLE_APP_THRESH )
#define SAMPLE_APP_THRESH 64
#endif
#if !defined( SAMPLE_APP_RX_SZ )
#define SAMPLE_APP_RX_SZ 128
#endif
#if !defined( SAMPLE_APP_TX_SZ )
#define SAMPLE_APP_TX_SZ 128
#endif
// Millisecs of idle time after a byte is received before invoking Rx callback.
#if !defined( SAMPLE_APP_IDLE )
#define SAMPLE_APP_IDLE 6
#endif
// Loopback Rx bytes to Tx for throughput testing.
#if !defined( SAMPLE_APP_LOOPBACK )
#define SAMPLE_APP_LOOPBACK FALSE
#endif
// This is the max byte count per OTA message.
#if !defined( SAMPLE_APP_TX_MAX )
#define SAMPLE_APP_TX_MAX 80
#endif
#define SAMPLE_APP_RSP_CNT 4
// This list should be filled with Application specific Cluster IDs.
const cId_t SampleApp_ClusterList[SAMPLE_MAX_CLUSTERS] =
{
SAMPLEAPP_P2P_CLUSTERID,
SAMPLEAPP_PERIODIC_CLUSTERID,
};
const SimpleDescriptionFormat_t SampleApp_SimpleDesc =
{
SAMPLEAPP_ENDPOINT, // int Endpoint;
SAMPLEAPP_PROFID, // uint16 AppProfId[2];
SAMPLEAPP_DEVICEID, // uint16 AppDeviceId[2];
SAMPLEAPP_DEVICE_VERSION, // int AppDevVer:4;
SAMPLEAPP_FLAGS, // int AppFlags:4;
SAMPLE_MAX_CLUSTERS, // byte AppNumInClusters;
(cId_t *)SampleApp_ClusterList, // byte *pAppInClusterList;
SAMPLE_MAX_CLUSTERS, // byte AppNumOutClusters;
(cId_t *)SampleApp_ClusterList // byte *pAppOutClusterList;
};
endPointDesc_t SampleApp_epDesc =
{
SAMPLEAPP_ENDPOINT,
&SampleApp_TaskID,
(SimpleDescriptionFormat_t *)&SampleApp_SimpleDesc,
noLatencyReqs
};
/*********************************************************************
* TYPEDEFS
*/
/*********************************************************************
* GLOBAL VARIABLES
*/
devStates_t SampleApp_NwkState;
uint8 SampleApp_TaskID; // Task ID for internal task/event processing.
/*********************************************************************
* EXTERNAL VARIABLES
*/
/*********************************************************************
* EXTERNAL FUNCTIONS
*/
/*********************************************************************
* LOCAL VARIABLES
*/
uint16 PM25_TH=500;
uint8 buff[20]={0};
static uint8 SampleApp_MsgID;
afAddrType_t SampleApp_Periodic_DstAddr; //廣播
afAddrType_t SampleApp_Flash_DstAddr; //組播
afAddrType_t SampleApp_P2P_DstAddr; //點(diǎn)播
static afAddrType_t SampleApp_TxAddr;
static uint8 SampleApp_TxSeq;
static uint8 SampleApp_TxBuf[SAMPLE_APP_TX_MAX+1];
uint8 SerialApp_TxBuf[SERIAL_APP_TX_MAX+1];
uint8 SerialApp_TxLen;
static uint8 SampleApp_TxLen;
static afAddrType_t SampleApp_RxAddr;
static uint8 SampleApp_RxSeq;
static uint8 SampleApp_RspBuf[SAMPLE_APP_RSP_CNT];
/*********************************************************************
* LOCAL FUNCTIONS
*/
static void SampleApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt );
void SampleApp_CallBack(uint8 port, uint8 event);
static void SampleApp_Send_P2P_Message( void );
static void packDataAndSend(uint8 fc, uint8* data, uint8 len);
/*********************************************************************
* @fn SampleApp_Init
*
* @brief This is called during OSAL tasks' initialization.
*
* @param task_id - the Task ID assigned by OSAL.
*
* @return none
*/
void SampleApp_Init( uint8 task_id )
{
halUARTCfg_t uartConfig;
SampleApp_TaskID = task_id;
SampleApp_RxSeq = 0xC3;
SampleApp_NwkState = DEV_INIT;
MT_UartInit(); //串口初始化
MT_UartRegisterTaskID(task_id); //注冊(cè)串口任務(wù)
afRegister( (endPointDesc_t *)&SampleApp_epDesc );
RegisterForKeys( task_id );
#ifdef ZDO_COORDINATOR
//協(xié)調(diào)器初始化
//逢蜂鳴器初始化
P0SEL &= ~0x80; //設(shè)置P07為普通IO口
P0DIR |= 0x80; //P07定義為輸出口
//默認(rèn)蜂鳴器不響
P0_7=1;
#endif
SampleApp_Periodic_DstAddr.addrMode = (afAddrMode_t)AddrBroadcast;//廣播
SampleApp_Periodic_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_Periodic_DstAddr.addr.shortAddr = 0xFFFF;
// Setup for the flash command's destination address - Group 1
SampleApp_Flash_DstAddr.addrMode = (afAddrMode_t)afAddrGroup;//組播
SampleApp_Flash_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_Flash_DstAddr.addr.shortAddr = SAMPLEAPP_FLASH_GROUP;
SampleApp_P2P_DstAddr.addrMode = (afAddrMode_t)Addr16Bit; //點(diǎn)播
SampleApp_P2P_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_P2P_DstAddr.addr.shortAddr = 0x0000; //發(fā)給協(xié)調(diào)器
}
/*********************************************************************
* @fn SampleApp_ProcessEvent
*
* @brief Generic Application Task event processor.
*
* @param task_id - The OSAL assigned task ID.
* @param events - Bit map of events to process.
*
* @return Event flags of all unprocessed events.
*/
UINT16 SampleApp_ProcessEvent( uint8 task_id, UINT16 events )
{
(void)task_id; // Intentionally unreferenced parameter
if ( events & SYS_EVENT_MSG )
{
afIncomingMSGPacket_t *MSGpkt;
while ( (MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID )) )
{
switch ( MSGpkt->hdr.event )
{
case AF_INCOMING_MSG_CMD:
SampleApp_ProcessMSGCmd( MSGpkt );
break;
case ZDO_STATE_CHANGE:
SampleApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
if (//(SampleApp_NwkState == DEV_ZB_COORD)||
(SampleApp_NwkState == DEV_ROUTER)
|| (SampleApp_NwkState == DEV_END_DEVICE))
{
osal_start_timerEx( SampleApp_TaskID,
SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT );//采集PM2.5
}
break;
default:
break;
}
osal_msg_deallocate( (uint8 *)MSGpkt );
}
return ( events ^ SYS_EVENT_MSG );
}
//定時(shí)器時(shí)間到
if ( events & SAMPLEAPP_SEND_PERIODIC_MSG_EVT )
{
// PM2.5采集
SampleApp_Send_P2P_Message();
// Setup to send message again in normal period (+ a little jitter)
osal_start_timerEx( SampleApp_TaskID, SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
2000);
// return unprocessed events
return (events ^ SAMPLEAPP_SEND_PERIODIC_MSG_EVT);
}
return ( 0 ); // Discard unknown events.
}
/*********************************************************************
* @fn SerialApp_ProcessMSGCmd
*
* @brief Data message processor callback. This function processes
* any incoming data - probably from other devices. Based
* on the cluster ID, perform the intended action.
*
* @param pkt - pointer to the incoming message packet
*
* @return TRUE if the 'pkt' parameter is being used and will be freed later,
* FALSE otherwise.
*/
void SampleApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt )
{
switch ( pkt->clusterId )
{
// 接收終端上傳的溫度數(shù)據(jù)
case SAMPLEAPP_P2P_CLUSTERID:
break;
case 2://報(bào)警閾值信息下發(fā)的簇
break;
default:
break;
}
}
/*********************************************************************
* @fn SampleApp_CallBack
*
* @brief Send data OTA.
*
* @param port - UART port.
* @param event - the UART port event flag.
*
* @return none
*/
void SampleApp_CallBack(uint8 port, uint8 event)
{
(void)port;
if ((event & (HAL_UART_RX_FULL | HAL_UART_RX_ABOUT_FULL | HAL_UART_RX_TIMEOUT)) &&
#if SAMPLE_APP_LOOPBACK
(SampleApp_TxLen < SAMPLE_APP_TX_MAX))
#else
!SampleApp_TxLen)
#endif
{
SampleApp_TxLen += HalUARTRead(SAMPLE_APP_PORT, SampleApp_TxBuf+SampleApp_TxLen+1,
SAMPLE_APP_TX_MAX-SampleApp_TxLen);
}
}
/*********************************************************************
* @fn SampleApp_Send_P2P_Message
*
* @brief point to point.
*
* @param none
*
* @return none
*/
void SampleApp_Send_P2P_Message( void )
{
uint16 Pm25;
uint8 str[10]={0};
int len=0;
Pm25=GetPm25(); //取PM25數(shù)據(jù)
str[0] = 3; //增加一個(gè)ID，如果是多個(gè)終端就增加這個(gè)值
str[1] = LO_UINT16( Pm25 );
str[2] = HI_UINT16( Pm25 );
len=3;
P1SEL &= ~0x13; //設(shè)置0、1、4為普通IO口
P1DIR |= 0x13; //0、1、4定義為輸出口
/******閾值報(bào)警處理*****/
if( Pm25>PM25_TH )
{
P1_0=0;//板子上LED燈D1亮表示粉塵濃度報(bào)警
}
else
{
P1_0=1;
}
//無(wú)線發(fā)送到協(xié)調(diào)器
if ( AF_DataRequest( &SampleApp_P2P_DstAddr, &SampleApp_epDesc,
SAMPLEAPP_P2P_CLUSTERID,
len,
str,
&SampleApp_MsgID,
AF_DISCV_ROUTE,
AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )
{
}
else
{
// Error occurred in request to send.
}
}
uint8 CheckSum(uint8 *pdata, uint8 len)
{
uint8 i;
uint8 check_sum=0;
for(i=0; i<len; i++)
{
check_sum += pdata[i];
}
return check_sum;
}
//數(shù)據(jù)打包發(fā)送
/**
*fc:功能碼
*data:上傳的數(shù)據(jù)
*len:數(shù)據(jù)長(zhǎng)度
格式:len,校驗(yàn),fc,內(nèi)容,$,@,
*/
void packDataAndSend(uint8 fc, uint8* data, uint8 len)
{
osal_memset(SampleApp_TxBuf, 0, SAMPLE_APP_TX_MAX+1);
//數(shù)據(jù)包長(zhǎng)度
SampleApp_TxBuf[0]=3+len;
//功能碼
SampleApp_TxBuf[2]=fc;
//發(fā)送的數(shù)據(jù)
if(len>0)
{
osal_memcpy(SampleApp_TxBuf+3, data, len);
}
//校驗(yàn)和,從fc開(kāi)始，
SampleApp_TxBuf[1]=CheckSum(SampleApp_TxBuf+2, len+1);
//數(shù)據(jù)結(jié)尾
SampleApp_TxBuf[3+len]='
SampleApp_TxBuf[4+len]='@';
SampleApp_TxBuf[5+len]='\r';
SampleApp_TxBuf[6+len]='\n';
//發(fā)送長(zhǎng)度
SampleApp_TxLen=7+len;
//接著發(fā)數(shù)據(jù)包
HalUARTWrite(0,SampleApp_TxBuf, SampleApp_TxLen);
}
溫濕度節(jié)點(diǎn)源碼：
/*********************************************************************
* INCLUDES
*/
#include <stdio.h>
#include <string.h>
#include "AF.h"
#include "OnBoard.h"
#include "OSAL_Tasks.h"
#include "SampleApp.h"
#include "ZDApp.h"
#include "ZDObject.h"
#include "ZDProfile.h"
#include "hal_drivers.h"
#include "hal_key.h"
#if defined ( LCD_SUPPORTED )
#include "hal_lcd.h"
#endif
#include "hal_led.h"
#include "hal_uart.h"
#include "hal_adc.h"
#include "dht11.h"
/*********************************************************************
* MACROS
*/
/*********************************************************************
* CONSTANTS
*/
#if !defined( SAMPLE_APP_PORT )
#define SAMPLE_APP_PORT 0
#endif
#if !defined( SAMPLE_APP_BAUD )
#define SAMPLE_APP_BAUD HAL_UART_BR_115200
#endif
// When the Rx buf space is less than this threshold, invoke the Rx callback.
#if !defined( SAMPLE_APP_THRESH )
#define SAMPLE_APP_THRESH 64
#endif
#if !defined( SAMPLE_APP_RX_SZ )
#define SAMPLE_APP_RX_SZ 128
#endif
#if !defined( SAMPLE_APP_TX_SZ )
#define SAMPLE_APP_TX_SZ 128
#endif
// Millisecs of idle time after a byte is received before invoking Rx callback.
#if !defined( SAMPLE_APP_IDLE )
#define SAMPLE_APP_IDLE 6
#endif
// Loopback Rx bytes to Tx for throughput testing.
#if !defined( SAMPLE_APP_LOOPBACK )
#define SAMPLE_APP_LOOPBACK FALSE
#endif
// This is the max byte count per OTA message.
#if !defined( SAMPLE_APP_TX_MAX )
#define SAMPLE_APP_TX_MAX 80
#endif
#define SAMPLE_APP_RSP_CNT 4
// This list should be filled with Application specific Cluster IDs.
const cId_t SampleApp_ClusterList[SAMPLE_MAX_CLUSTERS] =
{
SAMPLEAPP_P2P_CLUSTERID,
SAMPLEAPP_PERIODIC_CLUSTERID,
};
const SimpleDescriptionFormat_t SampleApp_SimpleDesc =
{
SAMPLEAPP_ENDPOINT, // int Endpoint;
SAMPLEAPP_PROFID, // uint16 AppProfId[2];
SAMPLEAPP_DEVICEID, // uint16 AppDeviceId[2];
SAMPLEAPP_DEVICE_VERSION, // int AppDevVer:4;
SAMPLEAPP_FLAGS, // int AppFlags:4;
SAMPLE_MAX_CLUSTERS, // byte AppNumInClusters;
(cId_t *)SampleApp_ClusterList, // byte *pAppInClusterList;
SAMPLE_MAX_CLUSTERS, // byte AppNumOutClusters;
(cId_t *)SampleApp_ClusterList // byte *pAppOutClusterList;
};
endPointDesc_t SampleApp_epDesc =
{
SAMPLEAPP_ENDPOINT,
&SampleApp_TaskID,
(SimpleDescriptionFormat_t *)&SampleApp_SimpleDesc,
noLatencyReqs
};
/*********************************************************************
* TYPEDEFS
*/
/*********************************************************************
* GLOBAL VARIABLES
*/
devStates_t SampleApp_NwkState;
uint8 SampleApp_TaskID; // Task ID for internal task/event processing.
/*********************************************************************
* EXTERNAL VARIABLES
*/
/*********************************************************************
* EXTERNAL FUNCTIONS
*/
/*********************************************************************
* LOCAL VARIABLES
*/
uint8 Temp_Hth=30,Temp_Lth=10;
uint8 Humi_Hth=80,Humi_Lth=10;
uint8 AO_Hth=70,AO_Lth=10;
uint8 buff[20]={0};
uint8 Motor_state=0x05,LED_state=1;
static uint8 SampleApp_MsgID;
afAddrType_t SampleApp_Periodic_DstAddr; //廣播
afAddrType_t SampleApp_Flash_DstAddr; //組播
afAddrType_t SampleApp_P2P_DstAddr; //點(diǎn)播
static afAddrType_t SampleApp_TxAddr;
static uint8 SampleApp_TxSeq;
static uint8 SampleApp_TxBuf[SAMPLE_APP_TX_MAX+1];
static uint8 SampleApp_TxLen;
static afAddrType_t SampleApp_RxAddr;
static uint8 SampleApp_RxSeq;
static uint8 SampleApp_RspBuf[SAMPLE_APP_RSP_CNT];
/*********************************************************************
* LOCAL FUNCTIONS
*/
static void SampleApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt );
void SampleApp_CallBack(uint8 port, uint8 event);
static void SampleApp_Send_P2P_Message( void );
static void packDataAndSend(uint8 fc, uint8* data, uint8 len);
/*********************************************************************
* @fn SampleApp_Init
*
* @brief This is called during OSAL tasks' initialization.
*
* @param task_id - the Task ID assigned by OSAL.
*
* @return none
*/
void SampleApp_Init( uint8 task_id )
{
halUARTCfg_t uartConfig;
SampleApp_TaskID = task_id;
SampleApp_RxSeq = 0xC3;
SampleApp_NwkState = DEV_INIT;
MT_UartInit(); //串口初始化
MT_UartRegisterTaskID(task_id); //注冊(cè)串口任務(wù)
afRegister( (endPointDesc_t *)&SampleApp_epDesc );
RegisterForKeys( task_id );
#ifdef ZDO_COORDINATOR
//協(xié)調(diào)器初始化
//逢蜂鳴器初始化
P0SEL &= ~0x80; //設(shè)置P07為普通IO口
P0DIR |= 0x80; //P07定義為輸出口
//默認(rèn)蜂鳴器不響
P0_7=1;
#endif
SampleApp_Periodic_DstAddr.addrMode = (afAddrMode_t)AddrBroadcast;//廣播
SampleApp_Periodic_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_Periodic_DstAddr.addr.shortAddr = 0xFFFF;
// Setup for the flash command's destination address - Group 1
SampleApp_Flash_DstAddr.addrMode = (afAddrMode_t)afAddrGroup;//組播
SampleApp_Flash_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_Flash_DstAddr.addr.shortAddr = SAMPLEAPP_FLASH_GROUP;
SampleApp_P2P_DstAddr.addrMode = (afAddrMode_t)Addr16Bit; //點(diǎn)播
SampleApp_P2P_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_P2P_DstAddr.addr.shortAddr = 0x0000; //發(fā)給協(xié)調(diào)器
}
/*********************************************************************
* @fn SampleApp_ProcessEvent
*
* @brief Generic Application Task event processor.
*
* @param task_id - The OSAL assigned task ID.
* @param events - Bit map of events to process.
*
* @return Event flags of all unprocessed events.
*/
UINT16 SampleApp_ProcessEvent( uint8 task_id, UINT16 events )
{
(void)task_id; // Intentionally unreferenced parameter
if ( events & SYS_EVENT_MSG )
{
afIncomingMSGPacket_t *MSGpkt;
while ( (MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID )) )
{
switch ( MSGpkt->hdr.event )
{
case AF_INCOMING_MSG_CMD:
SampleApp_ProcessMSGCmd( MSGpkt );
break;
case ZDO_STATE_CHANGE:
SampleApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
if ( //(SampleApp_NwkState == DEV_ZB_COORD)||
(SampleApp_NwkState == DEV_ROUTER)
|| (SampleApp_NwkState == DEV_END_DEVICE) )
{
//連網(wǎng)成功后，啟動(dòng)一個(gè)定時(shí)器
osal_start_timerEx( SampleApp_TaskID,
SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT );
}
else
{
// Device is no longer in the network
}
break;
default:
break;
}
osal_msg_deallocate( (uint8 *)MSGpkt );
}
return ( events ^ SYS_EVENT_MSG );
}
//定時(shí)器時(shí)間到
if ( events & SAMPLEAPP_SEND_PERIODIC_MSG_EVT )
{
// DHT11采集
SampleApp_Send_P2P_Message();
// Setup to send message again in normal period (+ a little jitter)
osal_start_timerEx( SampleApp_TaskID, SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT);
// return unprocessed events
return (events ^ SAMPLEAPP_SEND_PERIODIC_MSG_EVT);
}
return ( 0 ); // Discard unknown events.
}
/*********************************************************************
* @fn SerialApp_ProcessMSGCmd
*
* @brief Data message processor callback. This function processes
* any incoming data - probably from other devices. Based
* on the cluster ID, perform the intended action.
*
* @param pkt - pointer to the incoming message packet
*
* @return TRUE if the 'pkt' parameter is being used and will be freed later,
* FALSE otherwise.
*/
void SampleApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt )
{
switch ( pkt->clusterId )
{
// 接收終端上傳的溫度數(shù)據(jù)
case SAMPLEAPP_P2P_CLUSTERID:
#ifdef ZDO_COORDINATOR
{
uint8 id=pkt->cmd.Data[0];//終端id
uint8 t=pkt->cmd.Data[1]; //終端溫度
uint8 h=pkt->cmd.Data[2]; //終端濕度
if(id==1)
{
sprintf(buff, "%d T&H:%d %d", id, t, h);
HalLcdWriteString(buff, HAL_LCD_LINE_2); //LCD顯示
}
else if(id==2)
{
sprintf(buff, "%d T&H:%d %d", id, t, h);
HalLcdWriteString(buff, HAL_LCD_LINE_3); //LCD顯示
}
else if(id==3)
{
sprintf(buff, "%d T&H:%d %d", id, t, h);
HalLcdWriteString(buff, HAL_LCD_LINE_4); //LCD顯示
}
//蜂鳴器報(bào)警
if(t>35)//溫度高于35度報(bào)警
{
P0_7=0;
}
else if(h<30)//濕度低于30報(bào)警
{
P0_7=0;
}
else
{
P0_7=1;//不報(bào)警
}
//串口輸出可以看得見(jiàn)的字符，就把"#if 0"改為"#if 1"
//默認(rèn)是輸出16進(jìn)制數(shù)據(jù)，使用我們寫的PC工具或者手機(jī)軟件查看
#if 0
HalUARTWrite(0, buff, osal_strlen(buff)); //串口輸出提示信息
HalUARTWrite(0, "\r\n",2);
#else
//打包無(wú)線發(fā)送的數(shù)據(jù)
buff[0]=id;//終端id
buff[1]=t; //終端溫度
buff[2]=h; //終端濕度
//打包數(shù)據(jù)用于發(fā)送到wifi網(wǎng)關(guān)，或者串口
packDataAndSend(FUN_CODE_UPDATA_DATA, buff, 3);
#endif
}
#endif
break;
case 2://報(bào)警閾值信息下發(fā)的簇
Temp_Hth=pkt->cmd.Data[0]; //溫度上限
Humi_Hth=pkt->cmd.Data[1]; //濕度上限
AO_Hth=pkt->cmd.Data[2]; //光照上限
Temp_Lth=pkt->cmd.Data[3]; //溫度下限
Humi_Lth=pkt->cmd.Data[4]; //濕度下限
AO_Lth=pkt->cmd.Data[5]; //光照下限
break;
default:
break;
}
}
/*********************************************************************
* @fn SampleApp_CallBack
*
* @brief Send data OTA.
*
* @param port - UART port.
* @param event - the UART port event flag.
*
* @return none
*/
void SampleApp_CallBack(uint8 port, uint8 event)
{
(void)port;
if ((event & (HAL_UART_RX_FULL | HAL_UART_RX_ABOUT_FULL | HAL_UART_RX_TIMEOUT)) &&
#if SAMPLE_APP_LOOPBACK
(SampleApp_TxLen < SAMPLE_APP_TX_MAX))
#else
!SampleApp_TxLen)
#endif
{
SampleApp_TxLen += HalUARTRead(SAMPLE_APP_PORT, SampleApp_TxBuf+SampleApp_TxLen+1,
SAMPLE_APP_TX_MAX-SampleApp_TxLen);
}
}
/*********************************************************************
* @fn SampleApp_Send_P2P_Message
*
* @brief point to point.
*
* @param none
*
* @return none
*/
void SampleApp_Send_P2P_Message( void )
{
uint8 str[10]={0};
int len=0;
DHT11(); //獲取溫濕度
str[0] = 1; //增加一個(gè)ID，如果是多個(gè)終端就增加這個(gè)值
str[1] = wendu; //溫度
str[2] = shidu; //濕度
len=3;
P1SEL &= ~0x13; //設(shè)置0、1、4為普通IO口
P1DIR |= 0x13; //0、1、4定義為輸出口
/******閾值報(bào)警處理*****/
if((str[1]>=Temp_Lth)&&(str[1]<=Temp_Hth))
{
P1_0=1;
}
else
{
P1_0=0;//板子上LED燈D1亮表示溫度報(bào)警
}
if((str[2]>=Humi_Lth)&&(str[2]<=Humi_Hth))
{
P1_1=1;
}
else
{
P1_1=0;//板子上LED燈D2亮表示濕度報(bào)警
}
//無(wú)線發(fā)送到協(xié)調(diào)器
if ( AF_DataRequest( &SampleApp_P2P_DstAddr, &SampleApp_epDesc,
SAMPLEAPP_P2P_CLUSTERID,
len,
str,
&SampleApp_MsgID,
AF_DISCV_ROUTE,
AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )
{
}
else
{
// Error occurred in request to send.
}
}
uint8 CheckSum(uint8 *pdata, uint8 len)
{
uint8 i;
uint8 check_sum=0;
for(i=0; i<len; i++)
{
check_sum += pdata[i];
}
return check_sum;
}
//數(shù)據(jù)打包發(fā)送
/**
*fc:功能碼
*data:上傳的數(shù)據(jù)
*len:數(shù)據(jù)長(zhǎng)度
格式:len,校驗(yàn),fc,內(nèi)容,$,@,
*/
void packDataAndSend(uint8 fc, uint8* data, uint8 len)
{
osal_memset(SampleApp_TxBuf, 0, SAMPLE_APP_TX_MAX+1);
//數(shù)據(jù)包長(zhǎng)度
SampleApp_TxBuf[0]=3+len;
//功能碼
SampleApp_TxBuf[2]=fc;
//發(fā)送的數(shù)據(jù)
if(len>0)
{
osal_memcpy(SampleApp_TxBuf+3, data, len);
}
//校驗(yàn)和,從fc開(kāi)始，
SampleApp_TxBuf[1]=CheckSum(SampleApp_TxBuf+2, len+1);
//數(shù)據(jù)結(jié)尾
SampleApp_TxBuf[3+len]='
SampleApp_TxBuf[4+len]='@';
SampleApp_TxBuf[5+len]='\r';
SampleApp_TxBuf[6+len]='\n';
//發(fā)送長(zhǎng)度
SampleApp_TxLen=7+len;
//接著發(fā)數(shù)據(jù)包
HalUARTWrite(0,SampleApp_TxBuf, SampleApp_TxLen);
}
紫外線+網(wǎng)關(guān)源碼：
/*********************************************************************
* INCLUDES
*/
#include <stdio.h>
#include <string.h>
#include "AF.h"
#include "OnBoard.h"
#include "OSAL_Tasks.h"
#include "SampleApp.h"
#include "ZDApp.h"
#include "ZDObject.h"
#include "ZDProfile.h"
#include "hal_drivers.h"
#include "hal_key.h"
#include "hal_lcd.h"
#include "hal_led.h"
#include "hal_uart.h"
#include "hal_adc.h"
/*********************************************************************
* MACROS
*/
/*********************************************************************
* CONSTANTS
*/
#if !defined( SAMPLE_APP_PORT )
#define SAMPLE_APP_PORT 0
#endif
#if !defined( SAMPLE_APP_BAUD )
#define SAMPLE_APP_BAUD HAL_UART_BR_115200
#endif
// When the Rx buf space is less than this threshold, invoke the Rx callback.
#if !defined( SAMPLE_APP_THRESH )
#define SAMPLE_APP_THRESH 64
#endif
#if !defined( SAMPLE_APP_RX_SZ )
#define SAMPLE_APP_RX_SZ 128
#endif
#if !defined( SAMPLE_APP_TX_SZ )
#define SAMPLE_APP_TX_SZ 128
#endif
// Millisecs of idle time after a byte is received before invoking Rx callback.
#if !defined( SAMPLE_APP_IDLE )
#define SAMPLE_APP_IDLE 6
#endif
// Loopback Rx bytes to Tx for throughput testing.
#if !defined( SAMPLE_APP_LOOPBACK )
#define SAMPLE_APP_LOOPBACK FALSE
#endif
// This is the max byte count per OTA message.
#if !defined( SAMPLE_APP_TX_MAX )
#define SAMPLE_APP_TX_MAX 80
#endif
#define SAMPLE_APP_RSP_CNT 4
// This list should be filled with Application specific Cluster IDs.
const cId_t SampleApp_ClusterList[SAMPLE_MAX_CLUSTERS] =
{
SAMPLEAPP_P2P_CLUSTERID,
SAMPLEAPP_PERIODIC_CLUSTERID,
};
const SimpleDescriptionFormat_t SampleApp_SimpleDesc =
{
SAMPLEAPP_ENDPOINT, // int Endpoint;
SAMPLEAPP_PROFID, // uint16 AppProfId[2];
SAMPLEAPP_DEVICEID, // uint16 AppDeviceId[2];
SAMPLEAPP_DEVICE_VERSION, // int AppDevVer:4;
SAMPLEAPP_FLAGS, // int AppFlags:4;
SAMPLE_MAX_CLUSTERS, // byte AppNumInClusters;
(cId_t *)SampleApp_ClusterList, // byte *pAppInClusterList;
SAMPLE_MAX_CLUSTERS, // byte AppNumOutClusters;
(cId_t *)SampleApp_ClusterList // byte *pAppOutClusterList;
};
endPointDesc_t SampleApp_epDesc =
{
SAMPLEAPP_ENDPOINT,
&SampleApp_TaskID,
(SimpleDescriptionFormat_t *)&SampleApp_SimpleDesc,
noLatencyReqs
};
/*********************************************************************
* TYPEDEFS
*/
/*********************************************************************
* GLOBAL VARIABLES
*/
devStates_t SampleApp_NwkState;
uint8 SampleApp_TaskID; // Task ID for internal task/event processing.
/*********************************************************************
* EXTERNAL VARIABLES
*/
/*********************************************************************
* EXTERNAL FUNCTIONS
*/
/*********************************************************************
* LOCAL VARIABLES
*/
uint8 Temp_Hth=30,Temp_Lth=10;
uint8 Humi_Hth=80,Humi_Lth=10;
uint8 AO_Hth=70,AO_Lth=10;
uint8 buff[20]={0};
uint8 header3[17]="AT+CIPSEND=0,28";
uint8 Temperature=0,Humidity=0,AO=0;
uint16 PM25;
static uint8 SampleApp_MsgID;
afAddrType_t SampleApp_Periodic_DstAddr; //廣播
afAddrType_t SampleApp_Flash_DstAddr; //組播
afAddrType_t SampleApp_P2P_DstAddr; //點(diǎn)播
static afAddrType_t SampleApp_TxAddr;
static uint8 SampleApp_TxSeq;
static uint8 SampleApp_TxBuf[SAMPLE_APP_TX_MAX+1];
static uint8 SampleApp_TxLen;
static afAddrType_t SampleApp_RxAddr;
static uint8 SampleApp_RxSeq;
static uint8 SampleApp_RspBuf[SAMPLE_APP_RSP_CNT];
/*********************************************************************
* LOCAL FUNCTIONS
*/
static void SampleApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt );
void SampleApp_CallBack(uint8 port, uint8 event);
static void SampleApp_Send_P2P_Message( void );
static void packDataAndSend(uint8 fc, uint8* data, uint8 len);
//取光照值,接在P06上
uint8 GetLight()
{
uint8 temp=0;//百分比的整數(shù)值
float vol=0.0; //adc采樣電壓
uint16 adc= HalAdcRead(HAL_ADC_CHANNEL_6, HAL_ADC_RESOLUTION_14); //ADC 采樣值 P06口
//最大采樣值8192(因?yàn)樽罡呶皇欠?hào)位)
if(adc>=8192)
{
return 0;
}
//轉(zhuǎn)化為百分比
vol=(float)((float)adc)/8192.0;
//取百分比兩位數(shù)字
temp=vol*100;
return temp;
}
/*********************************************************************
* @fn SampleApp_Init
*
* @brief This is called during OSAL tasks' initialization.
*
* @param task_id - the Task ID assigned by OSAL.
*
* @return none
*/
void SampleApp_Init( uint8 task_id )
{
halUARTCfg_t uartConfig;
SampleApp_TaskID = task_id;
SampleApp_RxSeq = 0xC3;
SampleApp_NwkState = DEV_INIT;
MT_UartInit(); //串口初始化
MT_UartRegisterTaskID(task_id); //注冊(cè)串口任務(wù)
afRegister( (endPointDesc_t *)&SampleApp_epDesc );
RegisterForKeys( task_id );
#ifdef ZDO_COORDINATOR
//協(xié)調(diào)器初始化
//逢蜂鳴器初始化
P0SEL &= ~0x80; //設(shè)置P07為普通IO口
P0DIR |= 0x80; //P07定義為輸出口
//默認(rèn)蜂鳴器不響
P0_7=1;
#endif
SampleApp_Periodic_DstAddr.addrMode = (afAddrMode_t)AddrBroadcast;//廣播
SampleApp_Periodic_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_Periodic_DstAddr.addr.shortAddr = 0xFFFF;
// Setup for the flash command's destination address - Group 1
SampleApp_Flash_DstAddr.addrMode = (afAddrMode_t)afAddrGroup;//組播
SampleApp_Flash_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_Flash_DstAddr.addr.shortAddr = SAMPLEAPP_FLASH_GROUP;
SampleApp_P2P_DstAddr.addrMode = (afAddrMode_t)Addr16Bit; //點(diǎn)播
SampleApp_P2P_DstAddr.endPoint = SAMPLEAPP_ENDPOINT;
SampleApp_P2P_DstAddr.addr.shortAddr = 0x0000; //發(fā)給協(xié)調(diào)器
}
/*********************************************************************
* @fn SampleApp_ProcessEvent
*
* @brief Generic Application Task event processor.
*
* @param task_id - The OSAL assigned task ID.
* @param events - Bit map of events to process.
*
* @return Event flags of all unprocessed events.
*/
UINT16 SampleApp_ProcessEvent( uint8 task_id, UINT16 events )
{
(void)task_id; // Intentionally unreferenced parameter
if ( events & SYS_EVENT_MSG )
{
afIncomingMSGPacket_t *MSGpkt;
while ( (MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID )) )
{
switch ( MSGpkt->hdr.event )
{
case AF_INCOMING_MSG_CMD:
SampleApp_ProcessMSGCmd( MSGpkt );
break;
case ZDO_STATE_CHANGE:
SampleApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
if (SampleApp_NwkState == DEV_ZB_COORD)
{
uint8 header1[13]="AT+CIPMUX=1";
header1[11]='\r';header1[12]='\n';
header3[15]='\r';header3[16]='\n';
HalUARTWrite(0,header1,13);
osal_start_timerEx( SampleApp_TaskID,
SAMPLEAPP_SEND_WIFI_MSG1_EVT,
2*1000 );
osal_start_timerEx( SampleApp_TaskID, SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT);
}
break;
default:
break;
}
osal_msg_deallocate( (uint8 *)MSGpkt );
}
return ( events ^ SYS_EVENT_MSG );
}
//定時(shí)器時(shí)間到
if ( events & SAMPLEAPP_SEND_PERIODIC_MSG_EVT )
{
// 光照采集
SampleApp_Send_P2P_Message();
// Setup to send message again in normal period (+ a little jitter)
osal_start_timerEx( SampleApp_TaskID, SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT);
// return unprocessed events
return (events ^ SAMPLEAPP_SEND_PERIODIC_MSG_EVT);
}
if ( events & SAMPLEAPP_SEND_WIFI_MSG1_EVT )
{
uint8 header2[21]="AT+CIPSERVER=1,2020";
header2[19]='\r';header2[20]='\n';
HalUARTWrite(0,header2,21);
LCD_Fill(0x00); //初始清屏
LCD_Set_Pos(0,0);
HalLcdWriteString( "ZigBee環(huán)境監(jiān)測(cè)", HAL_LCD_LINE_1 );
return (events ^ SAMPLEAPP_SEND_WIFI_MSG1_EVT);
}
if ( events & SAMPLEAPP_UPDATE_EVT )
{
uint8 str[6]={0};
str[0] = Temp_Hth;
str[1] = Temp_Lth;
str[2] = Humi_Hth;
str[3] = Humi_Lth;
str[4] = AO_Hth;
str[5] = AO_Lth;
if ( AF_DataRequest( &SampleApp_Periodic_DstAddr, &SampleApp_epDesc,
2,
6,
str,
&SampleApp_MsgID,
AF_DISCV_ROUTE,
AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )
{
}
return (events ^ SAMPLEAPP_UPDATE_EVT);
}
return ( 0 ); // Discard unknown events.
}
/*********************************************************************
* @fn SerialApp_ProcessMSGCmd
*
* @brief Data message processor callback. This function processes
* any incoming data - probably from other devices. Based
* on the cluster ID, perform the intended action.
*
* @param pkt - pointer to the incoming message packet
*
* @return TRUE if the 'pkt' parameter is being used and will be freed later,
* FALSE otherwise.
*/
void SampleApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt )
{
uint8 id,PM25_L,PM25_H;
switch ( pkt->clusterId )
{
// 接收終端上傳的溫度數(shù)據(jù)
case SAMPLEAPP_P2P_CLUSTERID:
#ifdef ZDO_COORDINATOR
{
id=pkt->cmd.Data[0];
if(id == 1)//終端1，溫濕度
{
Temperature=pkt->cmd.Data[1]; //終端溫度
Humidity=pkt->cmd.Data[2]; //終端濕度
buff[0]=id;
buff[1]=Temperature;
buff[2]=Humidity;
}
else if(id == 3)//終端3，PM25
{
PM25_L=pkt->cmd.Data[1];
PM25_H=pkt->cmd.Data[2];
PM25=BUILD_UINT16(PM25_L, PM25_H);
buff[0]=id;
buff[1]=PM25_L;
buff[2]=PM25_H;
}
#if 0
HalUARTWrite(0, buff, osal_strlen(buff)); //串口輸出提示信息
HalUARTWrite(0, "\r\n",2);
#else
//打包數(shù)據(jù)用于發(fā)送到wifi網(wǎng)關(guān)
HalUARTWrite(0,header3,17);
packDataAndSend(FUN_CODE_UPDATA_DATA, buff, 3);
#endif
}
#endif
break;
case 2://報(bào)警閾值信息下發(fā)的簇
Temp_Hth=pkt->cmd.Data[0]; //溫度上限
Temp_Lth=pkt->cmd.Data[1]; //溫度下限
Humi_Hth=pkt->cmd.Data[2]; //濕度上限
Humi_Lth=pkt->cmd.Data[3]; //濕度下限
AO_Hth=pkt->cmd.Data[4]; //光照上限
AO_Lth=pkt->cmd.Data[5]; //光照下限
break;
default:
break;
}
}
/*********************************************************************
* @fn SampleApp_CallBack
*
* @brief Send data OTA.
*
* @param port - UART port.
* @param event - the UART port event flag.
*
* @return none
*/
void SampleApp_CallBack(uint8 port, uint8 event)
{
(void)port;
if ((event & (HAL_UART_RX_FULL | HAL_UART_RX_ABOUT_FULL | HAL_UART_RX_TIMEOUT)) &&
#if SAMPLE_APP_LOOPBACK
(SampleApp_TxLen < SAMPLE_APP_TX_MAX))
#else
!SampleApp_TxLen)
#endif
{
SampleApp_TxLen += HalUARTRead(SAMPLE_APP_PORT, SampleApp_TxBuf+SampleApp_TxLen+1,
SAMPLE_APP_TX_MAX-SampleApp_TxLen);
}
}
/*********************************************************************
* @fn SampleApp_Send_P2P_Message
*
* @brief point to point.
*
* @param none
*
* @return none
*/
void SampleApp_Send_P2P_Message( void )
{
uint8 str[10]={0};
uint8 strTemp[30]={0};
AO = GetLight(); //光照AO口數(shù)據(jù)，然后轉(zhuǎn)成百分比0~100，數(shù)據(jù)越高，光照越強(qiáng)
int len=0;
str[0] = 2; //增加一個(gè)ID，如果是多個(gè)終端就增加這個(gè)值
str[1] = AO;
str[2] = 0;
len=3;
//LCD顯示pm2.5
sprintf(strTemp, "PM2.5:%d ug/m3",PM25);
HalLcdWriteString( strTemp, HAL_LCD_LINE_4 );
//LCD顯示溫濕度
sprintf(strTemp, "溫:%02d 濕:%02d",Temperature,Humidity);
HalLcdWriteString( strTemp, HAL_LCD_LINE_3 );
//LCD顯示光照強(qiáng)度
sprintf(strTemp, "光照:%02d",AO);
HalLcdWriteString( strTemp, HAL_LCD_LINE_2 );
/******閾值報(bào)警處理*****/
P1SEL &= ~0x13; //設(shè)置0、1、4為普通IO口
P1DIR |= 0x13; //0、1、4定義為輸出口
if((str[3]>=AO_Lth)&&(str[3]<=AO_Hth))
{
P1_4=1;
}
else
{
P1_4=0;//板子上LED燈D3亮表示光照?qǐng)?bào)警
}
//串口發(fā)送到WiFi
HalUARTWrite(0,header3,17);
packDataAndSend(FUN_CODE_UPDATA_DATA, str, len);
}
uint8 CheckSum(uint8 *pdata, uint8 len)
{
uint8 i;
uint8 check_sum=0;
for(i=0; i<len; i++)
{
check_sum += pdata[i];
}
return check_sum;
}
//數(shù)據(jù)打包發(fā)送
/**
*fc:功能碼
*data:上傳的數(shù)據(jù)
*len:數(shù)據(jù)長(zhǎng)度
格式:len,校驗(yàn),fc,內(nèi)容,$,@,
*/
void packDataAndSend(uint8 fc, uint8* data, uint8 len)
{
osal_memset(SampleApp_TxBuf, 0, SAMPLE_APP_TX_MAX+1);
//數(shù)據(jù)包長(zhǎng)度
SampleApp_TxBuf[0]=3+len;
//功能碼
SampleApp_TxBuf[2]=fc;
//發(fā)送的數(shù)據(jù)
if(len>0)
{
osal_memcpy(SampleApp_TxBuf+3, data, len);
}
//校驗(yàn)和,從fc開(kāi)始，
SampleApp_TxBuf[1]=CheckSum(SampleApp_TxBuf+2, len+1);
//數(shù)據(jù)結(jié)尾
SampleApp_TxBuf[3+len]='
SampleApp_TxBuf[4+len]='@';
SampleApp_TxBuf[5+len]='\r';
SampleApp_TxBuf[6+len]='\n';
//發(fā)送長(zhǎng)度
SampleApp_TxLen=7+len;
//接著發(fā)數(shù)據(jù)包
HalUARTWrite(0,SampleApp_TxBuf, SampleApp_TxLen);
}

復(fù)制代碼