智能家居（smarthome）调试代码（未完全）

#include "controlDevices.h" #include "inputCmd.h" struct Devices *pDevicesHead = NULL; struct InputCmd *pCmdHead = NULL; struct Devices *Devicetmp = NULL; struct InputCmd *Cmdtmp = NULL; struct InputCmd *serverHandle = NULL; int c_fd; pthread_t sendData_pid; int firetype = 0; //火灾发生标志，1为发生 int shocktype = 0; //地震发生标志，1为发生 char sensorToStr[128]; //空气的温湿度数据存储地址 char sensorToStr1[128]; char sensorToStr2[128]; //遍历产品工厂的设备，找到对应名字的设备 struct Devices* findDeviceByName(char *name,struct Devices *phead) { struct Devices *tmp = phead; if (phead == NULL) { return NULL; } else { while(tmp != NULL) { if (strcmp(tmp->devicesName, name) == 0) { return tmp; } tmp = tmp->next; } return NULL; } } //遍历指令工厂的设备，找到对应名字的设备 struct InputCmd* findCmdByName(char *name,struct InputCmd *phead) { struct InputCmd *tmp = phead; if(phead == NULL){ return NULL; }else{ while(tmp != NULL){ if(strcmp(tmp->cmdName,name) == 0){ return tmp; } tmp = tmp->next; } return NULL; } } /* 发送数据线程执行函数 */ void *sendData_thread(void *data){ while(1){ write(c_fd,"1",1); //随便发个数据与客户端进行响应 delay(1000); write(c_fd,sensorToStr,strlen(sensorToStr)); //write(c_fd,sensorHStr,strlen(sensorHStr)); } } // 语音串口接收 void *voice_thread(void *data) { struct InputCmd *voiceHandle = NULL; struct Devices *devicesHandle = NULL; char behavior[32]; char room[32]; char *tmp; int n_read = 0; voiceHandle = findCmdByName("voice",pCmdHead); //找到指令工厂的语音控制设备 if(voiceHandle == NULL){ printf("find voiceHandle error\n"); pthread_exit(NULL); }else{ if(voiceHandle->Init(voiceHandle,NULL,NULL) < 0){ printf("voice Init error\n"); pthread_exit(NULL); } while(1){ n_read = voiceHandle->getCmd(voiceHandle); if(n_read == 0){ printf("no data from voice\n"); }else{ /* 获取命令和设备名称 */ memset(behavior,'\0',sizeof(behavior)); tmp = strtok(voiceHandle->cmd," "); strcat(behavior,tmp); //命令:open or close printf("behavior:%s\n",behavior); memset(room,'\0',sizeof(room)); tmp = strtok(NULL," "); strcat(room,tmp); //产品工厂的设备名称 printf("room:%s\n",room); devicesHandle = findDeviceByName(room,pDevicesHead); //找到产品工厂的设备 if(devicesHandle != NULL && strcmp(behavior,"open") == 0){ devicesHandle->devicesInit(devicesHandle->pinNum); devicesHandle->open(devicesHandle->pinNum); printf("open success\n"); } else if(devicesHandle != NULL && strcmp(behavior,"close") == 0){ devicesHandle->devicesInit(devicesHandle->pinNum); devicesHandle->close(devicesHandle->pinNum); } else { printf("error\n"); } } } } } // 串口发送数据 void *voiceToUart_thread(void *data) { struct InputCmd *voiceHandle = NULL; struct Devices *devicesHandle = NULL; voiceHandle = findCmdByName("voice",pCmdHead); //找到指令工厂的语音控制设备 if(voiceHandle == NULL){ printf("find voiceHandle error\n"); pthread_exit(NULL); }else{ if(voiceHandle->Init(voiceHandle,NULL,NULL) < 0){ printf("receive msg Init error\n"); pthread_exit(NULL); } while(1){ printf("receive msg success\n"); write(voiceHandle->fd,sensorToStr1,strlen(sensorToStr1)); serialPrintf(voiceHandle->fd,"\r\n"); if(firetype == 1 || shocktype == 1) { serialPrintf(voiceHandle->fd,"buzzer_On\r\n"); } else if (firetype == 0 || shocktype == 0) { serialPrintf(voiceHandle->fd,"buzzer_Off\r\n"); } delay(500); // printf("RH:%d.%d\n", (sensorHandle->databuf >> 24) & 0xff, (sensorHandle->databuf >> 16) & 0xff); // printf("TMP:%d.%d\n", (sensorHandle->databuf >> 8) & 0xff, sensorHandle->databuf & 0xff); } } } /* 客户端连接后处理线程执行函数 */ void *connect_thread(void *data) { int n_read; struct Devices *devicesHandle = NULL; char behavior[32]; char room[32]; char *tmp; pthread_create(&sendData_pid,NULL,sendData_thread,NULL); //建立发送数据线程 n_read = read(c_fd,serverHandle->cmd,sizeof(serverHandle->cmd)); //读取客户端的数据 if(n_read == -1){ perror("read"); }else if(n_read > 0){ printf("cmd: %s\n",serverHandle->cmd); /* 获取命令和设备名称 */ memset(behavior,'\0',sizeof(behavior)); tmp = strtok(serverHandle->cmd," "); //命令:open or close strcat(behavior,tmp); printf("behavior:%s\n",behavior); memset(room,'\0',sizeof(room)); tmp = strtok(NULL," "); strcat(room,tmp); //产品工厂的设备名称 printf("room:%s\n",room); devicesHandle = findDeviceByName(room,pDevicesHead); //找到产品工厂的设备 if(devicesHandle != NULL && strcmp(behavior,"open") == 0){ devicesHandle->devicesInit(devicesHandle->pinNum); devicesHandle->open(devicesHandle->pinNum); printf("open success\n"); } else if(devicesHandle != NULL && strcmp(behavior,"close") == 0){ devicesHandle->devicesInit(devicesHandle->pinNum); devicesHandle->close(devicesHandle->pinNum); printf("close success\n"); } else { printf("error\n"); } }else{ printf("client is quit\n"); } } /* sever控制线程执行函数 */ void *server_thread(void *data) { int clen = sizeof(struct sockaddr_in); struct sockaddr_in c_addr; memset(&c_addr,0,sizeof(struct sockaddr_in)); pthread_t connect_pid; serverHandle = findCmdByName("server",pCmdHead); //找到指令工厂的server控制设备 if(serverHandle == NULL){ printf("find serverHandle error\n"); pthread_exit(NULL); }else{ if(serverHandle->Init(serverHandle,NULL,NULL) < 0){ printf("server Init error\n"); pthread_exit(NULL); } while(1){ c_fd = accept(serverHandle->sfd,(struct sockaddr *)&c_addr,&clen); printf("have people\n"); pthread_create(&connect_pid,NULL,connect_thread,NULL); //建立客户端连接后处理线程 } } } /* 火灾监测线程执行函数 */ void *fire_thread(void *data) { struct Devices *fireHandle = NULL; struct Devices *devicesHandle = NULL; int fireStatus = 1; fireHandle = findDeviceByName("fire",pDevicesHead); //找到产品工厂的火灾设备 if(fireHandle == NULL){ printf("find fireHandle error\n"); pthread_exit(NULL); }else{ fireHandle->devicesInit(fireHandle->pinNum); while(1){ fireStatus = fireHandle->readStatus(fireHandle->pinNum); //printf("fireStatus:%d\n",fireStatus); delay(125); if((fireStatus) == 0){ firetype = 1; /* 开启警报，调试时嫌吵我就把他关了 devicesHandle = findDeviceByName("buzzer",pDevicesHead); //找到指令工厂的报警器设备 if(devicesHandle != NULL){ devicesHandle->open(devicesHandle->pinNum); } */ }else if(fireStatus == 1){ firetype = 0; /* devicesHandle = findDeviceByName("buzzer",pDevicesHead); //找到指令工厂的报警器设备 if(devicesHandle != NULL){ devicesHandle->close(devicesHandle->pinNum); } */ } } } } /* 地震监测线程执行函数 */ void *shock_thread(void *data) { struct Devices *shockHandle = NULL; struct Devices *devicesHandle = NULL; int shockStatus = 1; shockHandle = findDeviceByName("shock",pDevicesHead); //找到产品工厂的地震监测设备 if(shockHandle == NULL){ printf("find shockHandle error\n"); pthread_exit(NULL); }else{ shockHandle->devicesInit(shockHandle->pinNum); while(1){ shockStatus = shockHandle->readStatus(shockHandle->pinNum); //printf("sh