From 5068d7e8eec99d2d7c7739f94a5be863fb5f9912 Mon Sep 17 00:00:00 2001 From: LitterDryFish <45481685+LitterDryFish@users.noreply.github.com> Date: Mon, 19 Aug 2019 18:41:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0z-stack=E5=8D=8F=E8=AE=AE?= =?UTF-8?q?=E6=A0=88=E5=9F=BA=E7=A1=80=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- zigbee/ex01_RoomPowerManage/roomPwrManSys.c | 191 ++++++++++++++++++++ zigbee/ex01_RoomPowerManage/roomPwrManSys.h | 29 +++ 2 files changed, 220 insertions(+) create mode 100644 zigbee/ex01_RoomPowerManage/roomPwrManSys.c create mode 100644 zigbee/ex01_RoomPowerManage/roomPwrManSys.h diff --git a/zigbee/ex01_RoomPowerManage/roomPwrManSys.c b/zigbee/ex01_RoomPowerManage/roomPwrManSys.c new file mode 100644 index 0000000..80a44d3 --- /dev/null +++ b/zigbee/ex01_RoomPowerManage/roomPwrManSys.c @@ -0,0 +1,191 @@ +#include "roomPwrManSys.h" +#include "hal_io.h" +#include + +/********************************/ +/* 协调器代码 */ +/********************************/ +#if defined(ZDO_COORDINATOR) +uint8 descPkg[] = { + 0x03, DevIRPers, 0 +}; + +static uint16 nodeNwkAddr[Devmax]; +static uint8 nodeEndPoint[Devmax]; + +static uint8 irPersStatus = 0; +static uint8 illumStatus = 0; +static uint8 controlStatus = 0; +void roomPwrManSys_StaChgRt(struct ep_info_t *ep); +void roomPwrManSys_StaChgRt(struct ep_info_t *ep) +{ + // 寻找人体红外节点 + descPkg[1] = DevIRPers; + SendData(ep->ep, descPkg, 0xFFFF, CONTROL_ENDPOINT, sizeof(descPkg)); +} +void roomPwrManSys_IncmRt(struct ep_info_t *ep, uint16 addr, uint8 endPoint, afMSGCommandFormat_t *msg); +void roomPwrManSys_IncmRt(struct ep_info_t *ep, uint16 addr, uint8 endPoint, afMSGCommandFormat_t *msg) +{ + //msg->Data[], msg->DataLength, msg->TransSeqNumber + if((endPoint == CONTROL_ENDPOINT) && (msg->Data[0] == 0x03)) + { + // endPoint: msg->Data[1], rCycle: msg->Data[2] + // 将上一次寻找的节点地址和端点号保存起来 + nodeNwkAddr[descPkg[1]] = addr; + nodeEndPoint[descPkg[1]] = msg->Data[1]; + // 准备寻找下一个节点 + descPkg[1] = descPkg[1] + 1; + // 所有节点是否都已经寻找完毕? + if(descPkg[1] < Devmax) + SendData(ep->ep, descPkg, 0xFFFF, CONTROL_ENDPOINT, sizeof(descPkg)); + } + else + { + if(addr == nodeNwkAddr[DevIllum]) + { + // 接收到光照度传感器数据 + uint16 i = 0; + memcpy(&i, msg->Data, 2); + illumStatus = i < 1000; + HalUARTWrite(HAL_UART_PORT_0, msg->Data, 2); + } + else if(addr == nodeNwkAddr[DevIRPers]) + { + // 接收到人体红外传感器数据 + irPersStatus = !!(msg->Data[0]); + } + if(nodeNwkAddr[DevExecuter] != 0xFFFF) + { + // 如果执行节点存在 + uint8 ctrl = 0; + if(irPersStatus && illumStatus) + ctrl = 1; + // 如果灯光的当前状态与需要设置的状态不一样则发送数据 + if(controlStatus != ctrl) + SendData(ep->ep, &ctrl, nodeNwkAddr[DevExecuter], nodeEndPoint[DevExecuter], 1); + controlStatus = ctrl; + } + } +} +void roomPwrManSys_ToRt(struct ep_info_t *ep); +void roomPwrManSys_ToRt(struct ep_info_t *ep) +{ + // 超时函数,用于检查节点搜索是否完成 + // 如果没有完成,则继续搜索 + if(descPkg[1] < Devmax) + { + SendData(ep->ep, descPkg, 0xFFFF, CONTROL_ENDPOINT, sizeof(descPkg)); + } +} +void roomPwrManSys_ResAvbRt(struct ep_info_t *ep, RES_TYPE type, void *res); +void roomPwrManSys_ResAvbRt(struct ep_info_t *ep, RES_TYPE type, void *res) +{ + switch(type) + { + case ResInit: + memset(nodeNwkAddr, 0xFF, sizeof(nodeNwkAddr)); + memset(nodeEndPoint, 0xFF, sizeof(nodeEndPoint)); + break; + case ResUserTimer: + break; + case ResControlPkg: + break; + } +} +#else +/********************************/ +/* 人体红外节点代码 */ +/********************************/ +#if defined(IRPERS_NODE) +#define SAFTY_IO_GROUP 1 +#define SAFTY_IO_BIT 0 +void sensorIRPersResAvailable(struct ep_info_t *ep, RES_TYPE type, void *res); +void sensorIRPersResAvailable(struct ep_info_t *ep, RES_TYPE type, void *res) +{ + if(type == ResInit) + { + HalIOSetInput(SAFTY_IO_GROUP, SAFTY_IO_BIT, Pull_Down); + HalIOIntSet(ep->ep, SAFTY_IO_GROUP, SAFTY_IO_BIT, IOInt_Rising, 0); + } + //IO端口中断触发，中断源检测 + if(type == ResIOInt) + { + uint8 IRPersValue = 1; + SendData(ep->ep, &IRPersValue, 0x0000, TRANSFER_ENDPOINT, sizeof(IRPersValue)); + } +} +#endif +/********************************/ +/* 光照度节点代码 */ +/********************************/ +#if defined(ILLUM_NODE) +void sensorILLumTimeout(struct ep_info_t *ep); +void sensorILLumTimeout(struct ep_info_t *ep) +{ + uint16 LightValue = 256 - (HalAdcRead(0, HAL_ADC_RESOLUTION_14) >> 3); + // 将AD值变换为光照度的100倍 + LightValue = LightValue * 39;// * 10000 / 256; + SendData(ep->ep, &LightValue, 0x0000, TRANSFER_ENDPOINT, sizeof(LightValue)); +} +#endif +/********************************/ +/* 执行节点代码 */ +/********************************/ +#if defined(EXECUTER_NODE) +#define ControlInit() do { HalIOSetOutput(1,4);HalIOSetOutput(1,5);HalIOSetOutput(1,6);HalIOSetOutput(1,7);Control(0); } while(0) +#define Control(mask) do { HalIOSetLevel(1,4,mask&0x01);HalIOSetLevel(1,5,mask&0x02);HalIOSetLevel(1,6,mask&0x04);HalIOSetLevel(1,7,mask&0x08); } while(0) +void OutputExecuteBResAvailable(struct ep_info_t *ep, RES_TYPE type, void *res); +void OutputExecuteBResAvailable(struct ep_info_t *ep, RES_TYPE type, void *res) +{ + if(type == ResInit) + ControlInit(); +} +void outputExecuteB(struct ep_info_t *ep, uint16 addr, uint8 endPoint, afMSGCommandFormat_t *msg); +void outputExecuteB(struct ep_info_t *ep, uint16 addr, uint8 endPoint, afMSGCommandFormat_t *msg) +{ + //msg->Data[], msg->DataLength, msg->TransSeqNumber + Control(msg->Data[0]); + SendData(ep->ep, &msg->Data[0], 0x0000, TRANSFER_ENDPOINT, 1); +} +void outputExecuteBTimeout(struct ep_info_t *ep); +void outputExecuteBTimeout(struct ep_info_t *ep) +{ + uint8 value = P1 >> 4; + SendData(ep->ep, &value, 0x0000, TRANSFER_ENDPOINT, sizeof(value)); +} +#endif +#endif + +struct ep_info_t funcList[] = { +#if defined(ZDO_COORDINATOR) + { + roomPwrManSys_StaChgRt, + roomPwrManSys_IncmRt, + roomPwrManSys_ToRt, + roomPwrManSys_ResAvbRt, + { DevPwrmanSys, 0, 3 }, + }, +#else +# if defined(IRPERS_NODE) + { + NULL, NULL, sensorIRPersTimeout, sensorIRPersResAvailable, + { DevIRPers, 0, 2 }, // type, id, refresh cycle + }, +# elif defined(ILLUM_NODE) + { + NULL, NULL, sensorILLumTimeout, NULL, + { DevIllum, 0, 5 }, // type, id, refresh cycle + }, +# elif defined(EXECUTER_NODE) + { + NULL, outputExecuteB, outputExecuteBTimeout, OutputExecuteBResAvailable, + { DevExecuter, 0, 7 }, // type, id, refresh cycle + }, +# else +# error You must define one device +# endif +#endif +}; + +// 不能修改下面的内容!!! +const uint8 funcCount = sizeof(funcList) / sizeof(funcList[0]); diff --git a/zigbee/ex01_RoomPowerManage/roomPwrManSys.h b/zigbee/ex01_RoomPowerManage/roomPwrManSys.h new file mode 100644 index 0000000..ba386e1 --- /dev/null +++ b/zigbee/ex01_RoomPowerManage/roomPwrManSys.h @@ -0,0 +1,29 @@ +#ifndef _SAPP_SAMPLE_H_ +#define _SAPP_SAMPLE_H_ +#include "SAPP_FrameWork.h" +#ifdef __cplusplus +extern "C" +{ +#endif + +enum { + DevIRPers, + DevIllum, + DevExecuter, + + Devmax, + DevPwrmanSys +}; + +#if !defined(ZDO_COORDINATOR) + +//#define ILLUM_NODE +//#define IRPERS_NODE +#define EXECUTER_NODE + +#endif + +#ifdef __cplusplus +} +#endif +#endif//_SAPP_SAMPLE_H_ \ No newline at end of file