【OK210试用体验】项目篇+物联仓库管理系统+前端数据中心 +客户请求处理06 - 在线问答 - 电子威廉希尔官方网站 论坛 - 最好最受欢迎电子论坛!

电子发烧友官网论坛在线研讨会活动客服QQ:3144539146
开启辅助访问 收藏本站切换到宽版

电子威廉希尔官方网站 论坛»论坛 › 在线问答

【OK210试用体验】项目篇+物联仓库管理系统+前端数据中心 +客户请求处理06

himol ( 楼主 ) 2015-10-24 10:00:26  只看该作者 倒序浏览
本帖最后由 himol 于 2015-10-24 10:07 编辑

PS：
    在正式介绍前简单给大家说下：因为时间原因和其他因素在之后的介绍中将不再介绍LED模块、摄像头模块、SMS模块、wifi模块、希望大家理解。


第六节:处理客户请求模块(设备控制)

1. 功能描述
接收CGI,QT以及别的线程检测到异常发送设备控制请求的线程。
2. 数据描述
结构体名称
成员类型
成员名称
功能
struct setEnv
int
temMAX
温度上限
temMIN
温度下限
humMAX
湿度上限
humMIN
湿度下限
illMAX
光感上限
illMIN
光感下限
数据类型
数据名称
功能
unsigned char
dev_led_mask
led设备操作掩码
dev_camera_mask
摄像头设备操作掩码
dev_buzzer_mask
蜂鸣器设备操作掩码
dev_uart_mask
串口发送命令掩码
pthread_cond_t
cond_led
LED设备被唤醒条件变量
cond_camera
摄像头设备被唤醒条件变量
cond_buzzer
蜂鸣器设备被唤醒条件变量
cond_refresh
内存刷新线程被唤醒条件变量
cond_uart_cmd
串口发送命令线程被唤醒条件变量
cond_sqlite
数据库线程被唤醒条件变量
pthread_mutex_t
mutex_global
仓库实时信息变量保护互斥锁
mutex_uart_cmd
串口发送命令模块互斥锁
mutex_led
LED模块互斥锁
mutex_buzzer
蜂鸣器模块互斥锁
mutex_camera
摄像头模块互斥锁
mutex_slinklist
数据库数据缓存链表互斥锁
int
msgid
消息队列ID
struct env_info_clien_addr
all_info_RT
实时仓库信息全局变量
3. 流程图



4. 详细说明
本线程主要用来接收从消息队列里传入的请求,主要是硬件设备的操作,包括A8与M0上的硬件资源的操作,同时也能接收CGI与QT修改仓库各种上下限的值,本线程大部分完成的是一个数据的转发过程,因为通信的结构在发送线程与设备之间已经定义好了相应的协议。
#include "dota_cache.h"
#include "sqlite_link_list.h"
extern unsigned char dev_led_mask;
extern unsigned char dev_camera_mask;
extern unsigned char dev_buzzer_mask;
extern unsigned char dev_uart_mask;
extern pthread_cond_t cond_led;
extern pthread_cond_t cond_camera;
extern pthread_cond_t cond_buzzer;
extern pthread_cond_t cond_refresh;
extern pthread_cond_t cond_uart_cmd;
extern pthread_cond_t cond_sqlite;
extern pthread_mutex_t mutex_global;
extern pthread_mutex_t mutex_uart_cmd;
extern pthread_mutex_t mutex_led;
extern pthread_mutex_t mutex_buzzer;
extern pthread_mutex_t mutex_camera;
extern pthread_mutex_t mutex_slinklist;
extern char cgi_status;
extern int msgid;
extern struct env_info_clien_addr all_info_RT;
extern dota_cache_list m0_cache_head, m0_cache_tail;
struct setEnv
{
        int temMAX;
        int temMIN;
        int humMAX;
        int humMIN;
        int illMAX;
        int illMIN;
};
void *pthread_client_request (void *arg)
{
        key_t key;
        ssize_t msgsize;
        struct msg msgbuf;
        struct setEnv new;
        int sto_no;
        if ((key = ftok ("/app", 'g')) < 0)
        {
                perror ("ftok msgqueue");
                exit (-1);
        }
        if ((msgid = msgget (key, IPC_CREAT | IPC_EXCL | 0666)) < 0)
        {
                perror ("msgget msgid");
                exit (-1);
        }
        m0_cache_head = CreateEmptyCacheList ();
        m0_cache_tail = m0_cache_head;
        unsigned char *m0_temp;
        printf ("pthread_client_request is okn");
        while (1)
        {
                bzero (&msgbuf, sizeof (msgbuf));
                msgsize = msgrcv (msgid, &msgbuf, sizeof (msgbuf) - sizeof (long), 1L, 0);
                switch (msgbuf.msgtype)
                {
                        case 1L:
                                {
                                        pthread_mutex_lock (&mutex_led);
                                        dev_led_mask = msgbuf.text[0];
                                        pthread_cond_signal (&cond_led);
                                        pthread_mutex_unlock (&mutex_led);
                                        break;
                                }
                        case 2L:
                                {
                                        pthread_mutex_lock (&mutex_buzzer);
                                        dev_buzzer_mask = msgbuf.text[0];
                                        pthread_cond_signal (&cond_buzzer);
                                        pthread_mutex_unlock (&mutex_buzzer);
                                        break;
                                }
                        case 3L:
                                {
                                        pthread_mutex_lock (&mutex_camera);
                                        dev_camera_mask = msgbuf.text[0];
                                        pthread_cond_signal (&cond_camera);
                                        pthread_mutex_unlock (&mutex_camera);
                                        break;
                                }
                        case 4L:
                                {
                                        pthread_mutex_lock (&mutex_uart_cmd);        
                                        m0_temp = (unsigned char *)malloc (sizeof (unsigned char));
                                        *m0_temp = msgbuf.text[0];
                                        InsertCacheNode (&m0_cache_tail, m0_temp);
                                        pthread_mutex_unlock (&mutex_uart_cmd);
                                        pthread_cond_signal (&cond_uart_cmd);
                                        break;
                                }
                        case 5L:
                                {
                                        memcpy (&new, msgbuf.text + 1, 24);
                                        sto_no = msgbuf.text[0] - 48;
                                        printf ("sto_no = %d temMAX = %d, temMIN = %d, humMAX = %d, hunMIN = %d, illMAX = %d, illMIN = %dn",
                                                        sto_no, new.temMAX, new.temMIN, new.humMAX, new.humMIN, new.illMAX, new.illMIN);
                                        pthread_mutex_lock (&mutex_global);
                                        if (new.temMAX > 0 && new.temMAX > all_info_RT.storage_no[sto_no].temperatureMIN)
                                        {
                                                all_info_RT.storage_no[sto_no].temperatureMAX = new.temMAX;
                                        }
                                        if (new.temMIN > 0 && new.temMIN < all_info_RT.storage_no[sto_no].temperatureMAX)
                                        {
                                                all_info_RT.storage_no[sto_no].temperatureMIN = new.temMIN;
                                        }
                                        if (new.humMAX > 0 && new.humMAX > all_info_RT.storage_no[sto_no].humidityMIN)
                                        {
                                                all_info_RT.storage_no[sto_no].humidityMAX = new.humMAX;
                                        }
                                        if (new.humMIN > 0 && new.humMIN < all_info_RT.storage_no[sto_no].temperatureMAX)
                                        {
                                                all_info_RT.storage_no[sto_no].humidityMIN = new.humMIN;
                                        }
                                        if (new.illMAX > 0 && new.illMAX > all_info_RT.storage_no[sto_no].illuminationMIN)
                                        {
                                                all_info_RT.storage_no[sto_no].illuminationMAX = new.illMAX;
                                        }
                                        if (new.illMIN > 0 && new.illMIN < all_info_RT.storage_no[sto_no].illuminationMAX)
                                        {
                                                all_info_RT.storage_no[sto_no].illuminationMIN = new.illMIN;
                                        }
                                        pthread_mutex_lock (&mutex_slinklist);
                                        sqlite_InsertLinknode (ENV_UPDATE, all_info_RT, sto_no, 0);
                                        pthread_mutex_unlock (&mutex_slinklist);
                                        pthread_cond_signal (&cond_sqlite);
                                        pthread_mutex_unlock (&mutex_global);
                                        pthread_cond_signal (&cond_refresh);
                                        break;
                                }
#if 1
                case 10L:
                        {
                                int i = 0 , j = 0 ;
                                for(i = 0  ; i < 11; i++)
                                {
                                        recive_phone = msgbuf.text;         
                                }
                                recive_phone = '';
                                printf("**************************recive:%sn",recive_phone);
                                for(j = 0 ;msgbuf.text != '' && j < 12; i++, j++)
                                {
                                        center_phone[j] =  msgbuf.text;
                                }
                                center_phone[j] = '';
                                printf("**************************center:%sn",center_phone);
                                printf("**************************num change overn");
                                break;
                        }
#endif
#if 1
                case 11L:
                        {
                                char tmp[100] ={0};
strcpy(tmp,msgbuf.text);
        char tmp1[100] = {0};
        char tmp2[100] = {0};
        int i = 0, j= 0;
        for(i = 0 ; tmp != 'f'; i++)
        {
                tmp1 = tmp;        
        }
        tmp1 = '';
        printf("tmp1 : %sn",tmp1);
        i++;
        for(j=0 ; tmp != ''; i++, j++)
        {
                tmp2[j] = tmp;
        }
        tmp2[j] = '';
        printf("tmp2 : %sn",tmp2);
        system("mkdir /var/run/wpa_supplicant -p");
        char ifcon[100] = "ifconfig wlan0 ";
        strcat(ifcon,tmp1);
        printf("string : %sn",ifcon);
             system(ifcon);
        char gw[100] = "route add default gw ";
        strcat(gw,tmp2);
        system(gw);
        printf("gw : %sn",gw);
                system("wpa_supplicant -B -iwlan0 -c /etc/wpa-psk-tkip.conf");
        printf("wifi is okn");
                                break;
                        }
#endif
                        default : break;
                }
        }
}
【新技能】那些你不知道的红外热像“隐形”功能
回复 赞

举报 使用道具

0个回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

相关帖子


关闭

站长推荐上一条 /6 下一条

小黑屋|手机版|Archiver|电子发烧友 ( 湘ICP备2023018690号 )

GMT+8, 2024-9-22 05:26 , Processed in 0.349756 second(s), Total 33, Slave 24 queries .

Powered by 电子发烧友网

© 2015 bbs.elecfans.com

微信扫描
快速回复 返回顶部 返回列表