• 030——从GUI-＞Client-＞Server-＞driver实现对红外遥控的控制

    目录

    1、 解决韦东山老师irda模块中断申请失败的bug

    2、 client添加处理程序

    3、 添加服务器处理程序和驱动处理句柄

    4、 处理数据读出不准确问题

    5、 修改后的展示

    1、 解决韦东山老师irda模块中断申请失败的bug

            irda需要通过中断来触发读操作，申请中断需要引脚是输入模式，但是先插入电机后引脚会变成输出模式，所以插入驱动会报错。只要在init时加上一个引脚方向调整就好了。

     

    1. /* 在入口函数 */
    2. static int __init irda_init(void)
    3. {
    4.     int err;
    5.     int i;
    6.     int count = sizeof(gpios)/sizeof(gpios[0]);
    7.     
    8. 	printk("%s %s line %d\n", __FILE__, __FUNCTION__, __LINE__);
    9. 	/*设置GPIO为输入方向*/
    10.     err = gpio_direction_input(gpios[i].gpio);
    11. 	for (i = 0; i < count; i++)
    12. 	{		
    13. 		gpios[i].irq  = gpio_to_irq(gpios[i].gpio);
    14.  
    15. 		setup_timer(&gpios[i].key_timer, key_timer_expire, (unsigned long)&gpios[i]);
    16. 	 	//timer_setup(&gpios[i].key_timer, key_timer_expire, 0);
    17. 		err = request_irq(gpios[i].irq, gpio_key_isr, IRQF_TRIGGER_RISING | IRQF_TRIGGER_FALLING, gpios[i].name, &gpios[i]);
    18. 	}
    19.  
    20. 	/* 注册file_operations 	*/
    21. 	major = register_chrdev(0, "cebss_irda", &gpio_key_drv);  /* /dev/gpio_desc */
    22.  
    23. 	gpio_class = class_create(THIS_MODULE, "cebss_irda_class");
    24. 	if (IS_ERR(gpio_class)) {
    25. 		printk("%s %s line %d\n", __FILE__, __FUNCTION__, __LINE__);
    26. 		unregister_chrdev(major, "cebss_gpio_key");
    27. 		return PTR_ERR(gpio_class);
    28. 	}
    29.  
    30. 	device_create(gpio_class, NULL, MKDEV(major, 0), NULL, "CEBSS_irda"); /* /dev/irda */
    31. 	
    32. 	return err;
    33. }

    2、 client添加处理程序

    3、 添加服务器处理程序和驱动处理句柄

    1. /* TODO 传递参数后需改为使用通信结构体 */
    2. /* TODO 所有的魔鬼数字都要进行定义 */
    3. int select_driver(char * cmd, int acceptfd)
    4. {
    5.     int opt = 0;
    6.     int get_data = 0;
    7.     MSG drv_msg;
    8.     char *tx_buffer;
    9.     char buf[32];
    10.     char *irda_data="";
    11.     DIRECTION direction;
    12.     CMD drv_cmd;
    13.  
    14.     if('@' == cmd[0])
    15.     {
    16. #if (STD_ON == DEBUG)
    17.         printf("cmd[0] = @\n");
    18. #endif/*STD_ON == DEBUG*/
    19.         drv_msg.device = extract_digit_number(cmd, 1, 3);
    20.         printf("device is %d\n", drv_msg.device);
    21.         /*TODO 后续需升级为多线程模式调用驱动*/
    22.         switch(drv_msg.device)
    23.         {
    24.             case 0:
    25.                 /*TODO 日志打印等级控制*/
    26.                 /*TODO用设备结构体后这里要封装一下*/
    27.                 printf("LED!!!\n");
    28.                 if ('g' == cmd[4])
    29.                 {
    30.                     direction = direction_get;
    31.                     drv_cmd = cmd_no;
    32.                     led_handle(direction, &drv_cmd);
    33.                     if (cmd_close == drv_cmd)
    34.                     {
    35.                         tx_buffer = "@000g0";
    36.                     }
    37.                     else if(cmd_open == drv_cmd)
    38.                     {
    39.                         tx_buffer = "@000g1";
    40.                     }
    41.                 }
    42.                 else
    43.                 {
    44.                     if ('1' == cmd[5])
    45.                         drv_cmd = cmd_open;
    46.                     else if ('0' == cmd[5])
    47.                         drv_cmd = cmd_close;
    48.                     direction = direction_put;
    49.                     if (NOERROR == led_handle(direction, &drv_cmd))
    50.                     {
    51.                         tx_buffer = "@000p1";
    52.                     }
    53.                     else
    54.                     {
    55.                         tx_buffer = "@000p0";
    56.                     }
    57.                 }               
    58.                 if (send(acceptfd, tx_buffer, strlen(tx_buffer), 0) < 0)
    59.                 {
    60.                     perror("send failed");  
    61.                 }
    62.                 break;
    63.             case 1:
    64.                 printf("SR501!!!\n");
    65.                 /*TODO 这里封装成带回调函数的处理函数通过传入处理函数做数据处理*/
    66.                 if ('g' == cmd[4])
    67.                 {
    68.                     
    69.                     sr501_handle(&get_data);
    70.                     if (sr501_some == get_data)
    71.                     {
    72.                         tx_buffer = "@001g1";
    73.                     }
    74.                     else if(sr501_nobody == get_data)
    75.                     {
    76.                         tx_buffer = "@001g0";
    77.                     }
    78.                 }              
    79.                 if (send(acceptfd, tx_buffer, strlen(tx_buffer), 0) < 0)
    80.                 {
    81.                     perror("send failed");  
    82.                 }
    83.                 break;
    84.             case 2:
    85.                 printf("SR04!!!\n");
    86.                 if ('g' == cmd[4])
    87.                 {
    88.                     opt = sr04_handle(&get_data);
    89.                     if (NOERROR == opt)
    90.                     {
    91.                         sprintf(buf,"@002g%03d", get_data);
    92.                         tx_buffer = buf;
    93.                     }
    94.                     else
    95.                     {
    96.                         tx_buffer = "@002e";
    97.                     }
    98.                 }
    99.                 printf(">>>>>>%s\n",tx_buffer);         
    100.                 if (send(acceptfd, tx_buffer, strlen(tx_buffer), 0) < 0)
    101.                 {
    102.                     perror("send failed");  
    103.                 }
    104.                 break;
    105.             case 3:
    106.                 printf("IRDA!!!\n");
    107.                 if ('g' == cmd[4])
    108.                 {
    109.                     opt = irda_handle(irda_data);
    110.                     if (NOERROR == opt)
    111.                     {
    112.                         sprintf(buf,"@003g%s", irda_data);
    113.                         tx_buffer = buf;
    114.                     }
    115.                     else
    116.                     {
    117.                         tx_buffer = "@003e";
    118.                     }
    119.                 }
    120.                 printf(">>>>>>%s\n",tx_buffer);         
    121.                 if (send(acceptfd, tx_buffer, strlen(tx_buffer), 0) < 0)
    122.                 {
    123.                     perror("send failed");  
    124.                 }
    125.                 break;
    126.             case 4:
    127.                 printf("motor!!!\n");
    128.                 if ('s' == cmd[4])
    129.                 {
    130.                     if(0 == cmd[5])
    131.                     {
    132.                         /*/0 /n*/
    133.                         get_data = extract_digit_number(cmd, 6, (strlen(&cmd[5])-2));
    134.                     }
    135.                     else
    136.                     {
    137.                         get_data = -extract_digit_number(cmd, 6, (strlen(&cmd[5])-2));
    138.                     }
    139.                     printf("getdata == %d\n",get_data);
    140.                     opt = motor_handle(get_data);
    141.                     if (NOERROR == opt)
    142.                     {
    143.                         tx_buffer = "@004s";
    144.                     }
    145.                     else
    146.                     {
    147.                         tx_buffer = "@004e";
    148.                     }
    149.                 }      
    150.                 if (send(acceptfd, tx_buffer, strlen(tx_buffer), 0) < 0)
    151.                 {
    152.                     perror("send failed");  
    153.                 }
    154.                 break;
    155.             case 5:
    156.                 printf("dht11!!!\n");
    157.                 break;
    158.             case 6:
    159.                 printf("ds18b20!!!\n");
    160.                 break;
    161.             case 7:
    162.                 printf("IIC!!!\n");
    163.                 break;
    164.             case 8:
    165.                 printf("SPI!!!\n");
    166.                 break;
    167.             default:
    168.                 printf("Unknown equipment!!!\n");
    169.         }
    170.     }
    171.     else
    172.     {
    173.         printf("cmd[0] ERROR!!!\n");
    174.         opt = ERROR;
    175.     }
    176.     opt = atoi(&cmd[1]);
    177.     return opt;
    178. }
    1. /*
    2. *author   : xintianyu
    3. *function : Handle irda Settings
    4. *date     : 2024-4-19
    5. -----------------------
    6. author date  modify
    8. */
    9. int irda_handle(char *data)
    10. {
    11. 	/*传入参数后面要做通用处理使用空指针*/
    12.     char *device = "/dev/CEBSS_irda";
    13. 	int buf[2];
    14.     int ret = NOERROR;
    15. 	static int fd;
    16.     /* 打开文件 */
    17. 	fd = open(device, O_RDWR);
    18. 	if (fd == -1)
    19. 	{
    20. 		printf("can not open file %s\n", device);
    21. 		return ERROR;
    22. 	}
    23. read:
    24. 	if (read(fd, buf, 2) == 2)
    25. 	{
    26. 		printf("get irda: deivce 0x%02x, data 0x%02x\n", buf[0], buf[1]);
    27. 		switch(buf[1])
    28. 		{
    29.             case 0x00: goto read;
    30. 			case 0xa2: data="RED";break;
    31. 			case 0xe2: data="MENU";break;
    32. 			case 0x22: data="TEST";break;
    33. 			case 0x02: data="+";break;
    34. 			case 0xe0: data="back";break;
    35. 			default:data="";printf("no this key!!!\n");break;
    36. 		}
    37. 	}
    38. 	else
    39. 	{
    40. 		printf("get irda: -1\n");
    41. 	    ret = ERROR;
    42. 	}
    43. 	close(fd);
    44.     return ret;
    45. }

    4、 处理数据读出不准确问题

    除非一直读不然会导致读出的数据都堆积

    正常应该每个都是2位的，现在都导device里了

    1. /*
    2. *author   : xintianyu
    3. *function : Handle irda Settings
    4. *date     : 2024-4-19
    5. -----------------------
    6. author date  modify
    8. */
    9. int irda_handle(char *data)
    10. {
    11. 	/*传入参数后面要做通用处理使用空指针*/
    12.     char *device = "/dev/CEBSS_irda";
    13. 	unsigned char buf[2];
    14.     int ret = NOERROR;
    15. 	static int fd;
    16.     /* 打开文件 */
    17. 	fd = open(device, O_RDWR);
    18. 	if (fd == -1)
    19. 	{
    20. 		printf("can not open file %s\n", device);
    21. 		return ERROR;
    22. 	}
    23. read:
    24. 	if (read(fd, buf, 2) == 2)
    25. 	{
    26. 		printf("get irda: deivce 0x%02x, data 0x%02x\n", buf[0], buf[1]);
    27. 		switch(buf[1])
    28. 		{
    29.             case 0x00: goto read;
    30. 			case 0xa2: data="RED";break;
    31. 			case 0xe2: data="MENU";break;
    32. 			case 0x22: data="TEST";break;
    33. 			case 0x02: data="+";break;
    34. 			case 0xe0: data="back";break;
    35. 			default:data="";printf("no this key!!!\n");break;
    36. 		}
    37. 	}
    38. 	else
    39. 	{
    40. 		printf("get irda: -1\n");
    41. 	    ret = ERROR;
    42. 	}
    43.  
    44. 	close(fd);
    45.     return ret;
    46. }

    找到问题了，我的buf是整型的因为是直接从上面copy的

    驱动这面是char

    现在这面可以读到了

    但是拿到的是空数据

    应该是作用域的问题

    我不想用数组就用**好了

    果然可以拿到了，我在来处理一下数据

    5、 修改后的展示

    client

    1. '''
    2. fuction : 客户端程序
    3. author  : 辛天宇
    4. date    : 2024-4-13
    5. -------------------------------
    6. author     date      modify
    7. 辛天宇   2024-4-15   结合GUI和网络通信
    8.  
    9. '''
    10. import show
    11. import tcp
    12. import tool
    13. import socket
    14. import global_var
    17. def send_handle(window, client_socket, values):
    18.     global_var.TX_BUF = values['txbuff'] 
    19.     print(f"txbuff={global_var.TX_BUF}")
    20.     # 清理input
    21.     window['txbuff'].update(value='')
    22.     data = global_var.TX_BUF
    23.     client_socket.sendall(data.encode())
    25. def quit_handel(client_socket):
    26.     cmd='Q'
    27.     client_socket.sendall(cmd.encode())
    28.     tcp.disconnect_to_server(client_socket)
    29.  
    30. def motor_handel(window, client_socket, values):
    31.     i = int(values['MOTOR_I'])
    32.     global_var.MOTOR_DATA = str(abs(i)%360)
    33.     if i >= 0:
    34.         global_var.MOTOR_DIRECTION='0'
    35.     else:
    36.         global_var.MOTOR_DIRECTION='1'
    37.     message = 's'+global_var.MOTOR_DIRECTION+global_var.MOTOR_DATA
    38.     # 清理input
    39.     window['MOTOR_I'].update(value='0')
    40.     set_tx_buf('motor', message)
    41.     send_cmd(client_socket)
    42.  
    43. # 进行一次发送
    44. def send_cmd(client_socket):
    45.     data = global_var.TX_BUF
    46.     client_socket.sendall(data.encode())
    47.  
    48. # 设置发送消息
    49. def set_tx_buf(device, message): 
    50.     if device == 'sr04':
    51.         global_var.TX_BUF = '@002'+message
    52.     if device == 'led':
    53.         global_var.TX_BUF = '@000'+message
    54.     elif device == 'sr501':
    55.         global_var.TX_BUF = '@001'+message
    56.     elif device == 'irda':
    57.         global_var.TX_BUF = '@003'+message
    58.     elif device == 'motor':
    59.         global_var.TX_BUF = '@004'+message
    60.     elif device == 'dht11':
    61.         global_var.TX_BUF = '@005'+message
    62.         print(f"dht11={global_var.TX_BUF}")
    63.     elif device == 'ds18b20':
    64.         global_var.TX_BUF = '@006'
    65.     elif device == 'iic':
    66.         global_var.TX_BUF = '@007'
    67.     elif device == 'spi':
    68.         global_var.TX_BUF = '@008'
    69.     
    70.  
    71. # 处理数据
    72. def cmd_handle(window):
    73.     cmd = global_var.RX_BUF
    74.     if len(cmd) < 4:
    75.         print("cmd ERROR")
    76.         return -1
    77.     if '@' == cmd[0]:
    78.         # 目前驱动设备数量只有两位数
    79.         if cmd[1] == '0':
    80.             # LED: @000+1位命令位+1位数据位
    81.             if cmd[2] == '0' and cmd[3] == '0':
    82.                 if cmd[5] == '1':
    83.                     print("LED Status change success")
    84.                 elif cmd[5] == '0':
    85.                     print("LED Status change failure")
    86.                 else:
    87.                     print("message ERROR")
    88.             # SR501:@001+1位数据位
    89.             elif cmd[2] == '0' and cmd[3] == '1':
    90.                 if cmd[5] == '1':
    91.                     print("有人")
    92.                     message='有人'
    93.                     window['SR501_O'].update(message)
    94.                 elif cmd[5] == '0':
    95.                     print("无人")
    96.                     message='无人'
    97.                     window['SR501_O'].update(message)
    98.                 else:
    99.                     print("message ERROR")
    100.             # SR04
    101.             elif cmd[2] == '0' and cmd[3] == '2':
    102.                 if cmd[4] == 'g':
    103.                     global_var.SR04_DATA = cmd[5:8]
    104.                     message = f"{global_var.SR04_DATA}cm"
    105.                     window['SR04_O'].update(message)
    106.                 else:
    107.                     print("SR04: message ERROR")               
    108.             #irda
    109.             elif cmd[2] == '0' and cmd[3] == '3':
    110.                 # message = cmd[5]
    111.                 # print(message)
    112.                 if cmd[4] == 'g':
    113.                     if cmd[5] == 'r':
    114.                         global_var.IRDA_DATA = "RED"
    115.                     elif cmd[5] == 'm':
    116.                         global_var.IRDA_DATA = "MENU"
    117.                     elif cmd[5] == 't':
    118.                         global_var.IRDA_DATA = "TEST"
    119.                     elif cmd[5] == '+':
    120.                         global_var.IRDA_DATA = "+"
    121.                     elif cmd[5] == 'b':
    122.                         global_var.IRDA_DATA = "BACK"
    123.                     elif cmd[5] == 'l':
    124.                         global_var.IRDA_DATA = "LEFT"
    125.                     elif cmd[5] == 'p':
    126.                         global_var.IRDA_DATA = "START"
    127.                     elif cmd[5] == 'r':
    128.                         global_var.IRDA_DATA = "RIGHT"
    129.                     elif cmd[5] == '0':
    130.                         global_var.IRDA_DATA = "0"
    131.                     elif cmd[5] == '1':
    132.                         global_var.IRDA_DATA = "1"
    133.                     elif cmd[5] == '2':
    134.                         global_var.IRDA_DATA = "2"
    135.                     elif cmd[5] == '-':
    136.                         global_var.IRDA_DATA = "-"
    137.                     elif cmd[5] == 'c':
    138.                         global_var.IRDA_DATA = "c"
    139.                     elif cmd[5] == '3':
    140.                         global_var.IRDA_DATA = "3"
    141.                     elif cmd[5] == '4':
    142.                         global_var.IRDA_DATA = "4"
    143.                     elif cmd[5] == '5':
    144.                         global_var.IRDA_DATA = "5"
    145.                     elif cmd[5] == '6':
    146.                         global_var.IRDA_DATA = "6"
    147.                     elif cmd[5] == '7':
    148.                         global_var.IRDA_DATA = "7"
    149.                     elif cmd[5] == '8':
    150.                         global_var.IRDA_DATA = "8"
    151.                     elif cmd[5] == '9':
    152.                         global_var.IRDA_DATA = "9"
    153.                     window['IRDA_O'].update(global_var.IRDA_DATA)
    154.             #motor
    155.             elif cmd[2] == '0' and cmd[3] == '4':
    156.                 if cmd[4] == 's':
    157.                     print("MOTOR: message SCUESS") 
    158.                 else:
    159.                     print("MOTOR: message ERROR")  
    160.             #dht11
    161.             elif cmd[2] == '0' and cmd[3] == '5':
    162.                 print(cmd[4:])
    163.                 global_var.TEM=cmd[4]+cmd[5]
    164.                 global_var.HUM=cmd[6]+cmd[7]
    165.             #ds18b20
    166.             elif cmd[2] == '0' and cmd[3] == '6':
    167.                 print(cmd[4:])
    168.             #iic
    169.             elif cmd[2] == '0' and cmd[3] == '7':
    170.                 print(cmd[4:])
    171.             #spi
    172.             elif cmd[2] == '0' and cmd[3] == '8':
    173.                 print(cmd[4:])
    174.  
    175. # 处理事件
    176. def event_handle(window, client_socket):
    177.     led = 0
    178.     # 事件循环  
    179.     while True:  
    180.         try:
    181.             cmd_handle(window)
    182.             event, values = window.read()
    183.             if event == 'input':
    184.                 window['txbuff'].update(disabled=not values['input'])
    185.             elif event == 'send':
    186.                 send_handle(window, client_socket, values)
    187.             elif event == 'Clean':
    188.                 window['Output'].update(value='')
    189.             elif event == 'dht11':
    190.                 set_tx_buf('dht11', '2525')
    191.                 send_cmd(client_socket)
    192.                 message = f"{global_var.TEM}°C   {global_var.HUM}%"
    193.                 window['Getvalue'].update(message)
    194.             elif event == 'ds18b20':
    195.                 set_tx_buf('ds18b20')
    196.                 send_cmd(client_socket)
    197.                 message = f"{global_var.TEM}°C"
    198.                 window['Getvalue'].update(message)
    199.             elif event == 'Quit': 
    200.                 quit_handel(client_socket) 
    201.                 print(f"See you.............")
    202.                 break
    203.             elif event is None:
    204.                 print(f"xxxxxxxxxxxxxxxxxxxx")
    205.                 break
    206.             elif event == 'LED':
    207.                 if led % 2 == 0:
    208.                     set_tx_buf('led','p1')
    209.                 else:
    210.                     set_tx_buf('led','p0')
    211.                 led+=1
    212.                 if led > 100:
    213.                     led = 0
    214.                 send_cmd(client_socket)
    215.             elif event == 'SR501':
    216.                 set_tx_buf('sr501','g')
    217.                 send_cmd(client_socket)
    218.             elif event == 'SR04':
    219.                 set_tx_buf('sr04','g')
    220.                 send_cmd(client_socket)
    221.             elif event == 'IRDA':
    222.                 set_tx_buf('irda','g')
    223.                 send_cmd(client_socket)
    224.             elif event == 'MOTOR':
    225.                 motor_handel(window, client_socket, values)
    226.             # 处理其他事件...
    227.         except Exception as e:
    228.             window.close()
    229.             print(f"An error occurred: {e}")
    230.             return 0
    231.         # 接收服务器的响应
    232.         data = client_socket.recv(512)
    233.         # 将字节字符串转化为字符串
    234.         global_var.RX_BUF = data.decode('utf-8')
    235.         # print(f"rx......{global_var.RX_BUF}") 
    236.     window.close()
    237.     return 0  
    238.  
    239. def main():
    240.     # 创建GUI对象
    241.     window = show.show_window('DefaultNoMoreNagging')
    242.     # 尝试连接到服务器  
    243.     client_socket = tcp.connect_to_server()
    244.     if client_socket is not None: 
    245.         event_handle(window, client_socket)
    246.  
    247. if __name__ == '__main__':
    248.     main()

    按下IRDA会阻塞按下遥控器上的按键解析后会更新。

  • 相关阅读:
    ATF源码篇（九）：docs文件夹-Components组件（8）固件升级
    初阶C语言 - 分支语句（if、switch）
    使用远程桌面软件改善工作与生活的平衡
    企业网络自动化配置
    浏览器原生JavaScript离线文字转语音TTS播放，支持Windows自带TTS语音和移动端（安卓、IOS）
    Pinia（二）了解和使用Store
    C++: 冒泡排序（Bubble Sort）
    Pytorch中实例化一个数据集的类，用于网络训练
    MATALAB绘制色图变换和Voronoi图
    redis 实现互相关注功能
  • 原文地址：https://blog.csdn.net/qq_52479948/article/details/137966306