【文章內容簡介】 ptions)。 //讀取終端參數 |= ( CLOCAL | CREAD )。 //忽略調制調解器線路狀態(tài),使用接收器 amp。= ~CSIZE。 //清目前字符長度 amp。= ~CRTSCTS。 //不實用RTS/CTS流控制 |= CS8。 //字符長度設置為8 amp。= ~CSTOPB。 //設置1個標志位 |= IGNPAR。 //允許輸入奇偶校驗 amp。= ~(ICRNL | IXON)。 //回車不轉為換行,不允許輸入時對XON/XOFF流進行控制 = 0。 = 0。 cfsetispeed(amp。options, B115200)。 //設置波特率為115200 cfsetospeed(amp。options, B115200)。 tcsetattr(fd,TCSANOW,amp。options)。 //設置終端參數}void *pthread_transfer (void *arg){ int i = 0, len。 char flag = 0, check。 link_datatype buf。 linkHead = CreateEmptyLinklist ()。 if ((dev_uart_fd = open (DEV_ZIGBEE, O_RDWR)) 0) { perror (open ttyUSB0)。 exit (1)。 } serial_init (dev_uart_fd)。 printf (pthread_transfer is ok\n)。 while (1) { memset (amp。buf, 0, sizeof (link_datatype))。 read (dev_uart_fd, amp。check, 1)。 if (check == 39。s39。) { check = 0。 read (dev_uart_fd, amp。check, 1)。 if (check == 39。t39。) { check = 0。 read (dev_uart_fd, amp。check, 1)。 if (check == 39。:39。) { check = 0。 read (dev_uart_fd, amp。check, 1)。 if (check == 39。e39。) { = 39。e39。 usleep(1)。 if ((len = read (dev_uart_fd, , LEN_ENV)) != LEN_ENV) { for (i = len。 i LEN_ENV。 i++) { read (dev_uart_fd, +i, 1)。 } } flag = 1。 } else if (check == 39。r39。) { = 39。r39。 usleep(1)。 if ((len = read (dev_uart_fd, , LEN_RFID)) != LEN_RFID) { for (i = len。 i LEN_RFID。 i++) { read (dev_uart_fd, +i, 1)。 } } flag = 1。 } } } } if (1 == flag) { pthread_mutex_lock (amp。mutex_linklist)。 if ((InsertLinknode (buf)) == 1) { pthread_mutex_unlock (amp。mutex_linklist)。 printf (NONMEM\n)。 } pthread_mutex_unlock (amp。mutex_linklist)。 flag = 0。 pthread_cond_signal (amp。cond_analysis)。 } } return 0。}第五節(jié):數據處理模塊1. 功能描述處理接收到的信息,因為接收到的信息是按一定規(guī)律進行編碼的,所以進行解碼后,激活數據庫線程,保存數據,激活內存刷新數據,更新實時環(huán)境信息,判斷數據是否越界,若越界則激活設備控制線程進行相應的控制。2. 數據描述結構體名成員類型成員名稱功能struct getEnvMsgunsigned charsto_no倉庫號tem[2]溫度hum[2]濕度x三軸yzunsigned intill光照battery電池電壓比例adcADC電壓比例struct getGoodsMsgunsigned charsto_no倉庫號io進出標志goodsno貨物編號goodsnum貨物數量類型名稱功能linklistlinkHead數據緩存鏈表頭,用來讀取數據slinkHead數據庫數據緩存鏈表頭,用來插入數據pthread_mutex_tmutex_linklist數據緩存鏈表互斥鎖mutex_slinklist數據庫數據緩存鏈表互斥鎖mutex_analysis數據處理線程互斥鎖mutex_global實時倉庫信息數據互斥鎖mutex_sms短信模塊互斥鎖mutex_buzzer蜂鳴器模塊互斥鎖pthread_cond_tcond_analysis數據處理模塊被喚醒條件變量cond_sqlite數據庫模塊被喚醒條件變量cond_refresh內存刷新線程被喚醒條件變量cond_buzzer蜂鳴器模塊喚醒條件變量cond_smsSMS模塊喚醒條件變量chartem_alarm_status[STORAGE_NUM]各倉庫溫度是否超標標志位hum_alarm_status[STORAGE_NUM]各倉庫溫度是否超標標志位ill_alarm_status[STORAGE_NUM]各倉庫光照是否超標標志位beep_status[STORAGE_NUM]A8主蜂鳴器狀態(tài)標志位unsigned chardev_sms_masksms模塊操作標志位intmsgid消息隊列號dev_buzzer_mask蜂鳴器模塊操作標志位struct env_info_clien_addrall_info_RT實時環(huán)境信息全局變量3. 程圖4. 詳細說明在本線程中,進行了大量的工作,如數據的解析,激活數據庫線程,以及設置各倉庫設備的標志位,并進行檢查,同時對接收的數據進行臨界檢測,主要功能代碼如下:include include include struct getEnvMsg{ unsigned char sto_no。 unsigned char tem[2]。 unsigned char hum[2]。 unsigned char x。 unsigned char y。 unsigned char z。 unsigned int ill。 unsigned int battery。 unsigned int adc。}。struct getGoodsMsg{ unsigned char sto_no。 unsigned char io。 unsigned char goodsno。 unsigned char goodsnum。}。extern linklist linkHead。extern linklist slinkHead。extern pthread_mutex_t mutex_linklist。extern pthread_mutex_t mutex_slinklist。extern pthread_mutex_t mutex_analysis。extern pthread_mutex_t mutex_global。extern pthread_mutex_t mutex_sms。extern pthread_mutex_t mutex_buzzer。extern pthread_cond_t cond_analysis。extern pthread_cond_t cond_sqlite。extern pthread_cond_t cond_refresh。extern pthread_cond_t cond_buzzer。extern pthread_cond_t cond_sms。char tem_alarm_status[STORAGE_NUM] = {0}。char hum_alarm_status[STORAGE_NUM] = {0}。char ill_alarm_status[STORAGE_NUM] = {0}。char beep_status[STORAGE_NUM] = {0}。extern unsigned char dev_sms_mask。extern int msgid。extern int dev_buzzer_mask。extern struct env_info_clien_addr all_info_RT。float dota_atof (char unitl){ if (unitl 100) { return unitl / 。 } else if (unitl 10) { return unitl / 。 } else { return unitl / 。 }}int dota_atoi (const char * cDecade){ int result = 0。 if (39。 39。 != cDecade[0]) { result = (cDecade[0] 48) * 10。 } result += cDecade[1] 48。 return result。}float dota_adc (unsigned int ratio){ return ((ratio * ) / 1024)。}int storageAllgood (int sto_no){ if ((tem_alarm_status[sto_no] + hum_alarm_status[sto_no] + ill_alarm_status[sto_no]) == 0) { return 0。 } return 1。}int checkEnv (int sto_no, struct storage_info *p){ char flag = 0。 static char a8_beep_status = 0。 if (0 == tem_alarm_status[sto_no]) { if (ptemperature ptemperatureMAX) { sendMsgQueue (MSG_LED, MSG_LED_TEM_ON)。 sendMsgQueue (MSG_M0, MSG_M0_FAN_ON3 | sto_no 6)。 pfan_status = 3。 tem_alarm_status[sto_no] = 2。 flag = 1。 } else if (ptemperature ptemperatureMIN) { sendMsgQueue (MSG_LED, MSG_LED_TEM_ON)。 sendMsgQueue (MSG_M0, MSG_M0_FAN_OFF | sto_no 6)。 pfan_status = 0。 tem_alarm_status[sto_no] = 1。 flag = 1。 } if (flag) { pthread_mutex_lock (amp。mutex_sms)。 dev_sms_mask = SMS_TEM。 pthread_mutex_unlock (amp。mutex_sms)。 pthread_cond_signal (amp。cond_sms)。 flag = 0。 if (beep_status[sto_no] == 0) { beep_status[sto_no] = 1。 sendMsgQueue (MSG_M0, MSG_M0_BEEP_ON | sto_no 6)。 } if (a8_beep_status == 0) { a8_beep_status = 1。 sendMsgQueue (MSG_BEEP, MSG_M0_BEEP_ON)。 } } } else { if (ptemperature ptemperatureMAX