• 035——从GUI-＞Client-＞Server-＞driver实现SPI控制DAC芯片

    目录

    1、修改GUI

    2、修改client

    3、server编写

    4、driver_handle

    5、test

    6、 项目管理

    1、修改GUI

    我想让DAC控制是个滑动条

    1. import PySimpleGUI as sg
    3. def slider_callback(slider_value):
    4.     print(f'Current value: {slider_value}')
    6. layout = [
    7.     [sg.Text('Select a value:')],
    8.     [sg.Slider(range=(1, 100), orientation='h', size=(20, 15), default_value=50, key='-SLIDER-', enable_events=True)],
    9.     [sg.Button('OK')]
    10. ]
    11.  
    12. window = sg.Window('Slider Example', layout)
    13.  
    14. while True:
    15.     event, values = window.read()
    16.  
    17.     if event == 'Close' or event == 'OK':
    18.         break
    19.     elif event == '-SLIDER-':
    20.         slider_value = values['-SLIDER-']
    21.         slider_callback(slider_value)
    22.  
    23. window.close()

     

    现在滑动条的event可以获取了但是有个问题就是和后面DAC之间匹配不上，太丑啦

    1. import PySimpleGUI as sg  
    2.   
    3. layout = [  
    4.     [sg.Text('居中对齐', size=(10, 1), justification='c', pad=(10, 5))],  # 水平和垂直填充，居中对齐  
    5.     [sg.Text('左对齐偏下', size=(10, 1), justification='l', pad=((10, 0), (5, 0)))],  # 上边填充使文本偏下，左对齐  
    6.     [sg.Text('右对齐偏下', size=(10, 1), justification='r', pad=((0, 10), (5, 0)))],  # 上边填充使文本偏下，右对齐  
    7. ]  
    8.   
    9. window = sg.Window('文本对齐示例', layout)  
    10.   
    11. while True:  
    12.     event, values = window.read()  
    13.     if event == sg.WIN_CLOSED:  
    14.         break  
    15.   
    16. window.close()

    分开测试都好使，放在一起就不行，里普瓦

    好像可以，之前给的值太小了导致看不出来，给了个20现在看着还算是协调

    1. '''
    2. fuction : 客户端界面
    3. author  : 辛天宇
    4. date    : 2024-4-12
    5. -------------------------------
    6. author date  modify
    7.  
    8. '''
    9. import PySimpleGUI as sg
    10. import tool
    11. import global_var
    12.  
    13. # 调用显示框架
    14. def show_window(theme):
    15.     # 是否使用自定义标题栏
    16.     use_custom_titlebar = False
    17.     # 设置主题
    18.     sg.theme(theme)
    19.     # 创建菜单
    20.     Menu = sg.Menu
    21.     # 左部layout
    22.     layout_l =  [
    23.                     [tool.name('NetWork'), sg.Button('Connect', key='Connect')],
    24.                     [tool.name('NetWork'), sg.Button('Disconnect', key='Disconnect')],
    25.                     [tool.name('NetWork'), sg.Output(size=(32, 1), key='IP')],
    26.                     [sg.Checkbox('Input', use_custom_titlebar, enable_events=True, key='input')],
    27.                     [sg.InputText(disabled=True, key='txbuff'), sg.Button('SEND', key='send')],
    28.                     [sg.Slider(range=(0, 100), orientation='h', size=(29, 20), default_value=0, key='DAC', enable_events=True), sg.Text('DAC', size=(5,2), justification='c',pad=(0,(20,0)), font='Courier 14')],
    29.                     [sg.InputText(key='AT24C02_I', default_text=''), sg.Button('AT24C02 WRITE', key='AT24C02_W')],
    30.                 ]
    31.     # 右部layout
    32.     layout_r  = [
    33.                     [sg.Output(size=(16, 1), key='LED_O'), sg.Button('LED', key='LED')],
    34.                     [sg.Output(size=(16, 1), key='SR501_O'), sg.Button('SR501', key='SR501')],
    35.                     [sg.Output(size=(16, 1), key='SR04_O'), sg.Button('SR04', key='SR04')],
    36.                     [sg.Output(size=(16, 1), key='IRDA_O'), sg.Button('IRDA', key='IRDA')],
    37.                     [sg.Output(size=(16, 1), key='DHT11_O'), sg.Button('DHT11', key='dht11')],
    38.                     [sg.Output(size=(16, 1), key='DS18B20_O'), sg.Button('DS18B20', key='ds18b20')],
    39.                     [sg.Output(size=(16, 1), key='AT24C02_O'), sg.Button('AT24C02 READ', key='AT24C02_R')],
    40.                     #[tool.name('Text'), sg.Button('IIC', key='IIC')],
    41.                 ]
    42.     # 修饰
    43.     topic = tool.add_stars_to_string(global_var.TOPIC, 5)
    44.     # 设置字体为14号，无特殊样式，通常字体名称和大小用元组表示  
    45.     topic_font = ('_', 24)
    46.     # 整体layout
    47.     layout = [
    48.                 [sg.T(topic, text_color='blue', justification='c', font=topic_font)],
    49.                 [sg.Col(layout_l), sg.Col(layout_r)],
    50.                 [sg.Text('Output:', size=(7,1), justification='r',pad=(0,0), font='Courier 10'),],
    51.                 [sg.Output(size=(96, 8), key='Output')],
    52.                 [sg.Button('Clean', key='Clean'), sg.Button('Quit', key='Quit')]
    53.             ]
    54.  
    55.     window = sg.Window('The PySimpleGUI Element List', layout, finalize=True, keep_on_top=True)
    56.     return window
    57.  
    58. # 处理事件
    59. def event_handle():
    60.     window = show_window('DefaultNoMoreNagging')
    61.     # 事件循环  
    62.     while True:  
    63.         try:
    64.             event, values = window.read()
    65.             if event == 'Exit':  
    66.                 break
    67.             if event == 'dht11':
    68.                 message = f"{global_var.TEM}°C   {global_var.HUM}%"
    69.                 window['Getvalue'].update(message)
    70.             if event == 'ds18b20':
    71.                 message = f"{global_var.TEM}°C"
    72.                 window['Getvalue'].update(message)
    73.             if event == 'input': 
    74.                 print(f"INPUT-----------------") 
    75.             elif event == 'Quit':  
    76.                 print(f"See you.............")
    77.                 break
    78.             # elif event == 'Connect':
    79.             #     global_var.SERVER_IP = "192.168.5.10"
    80.             #     window['IP'].update(global_var.SERVER_IP)
    81.             # elif event == 'Disconnect':  
    82.             #     global_var.SERVER_IP = "connectionless network service"
    83.             #     window['IP'].update(global_var.SERVER_IP)
    84.             elif event is None:
    85.                 print(f"xxxxxxxxxxxxxxxxxxxx")
    86.                 break
    87.             elif event == 'LED':  
    88.                 print(f"LED-----------------") 
    89.             # 处理其他事件...
    90.         except Exception as e:
    91.             window.close()
    92.             print(f"An error occurred: {e}")
    93.             return 0
    94.     window.close()
    95.     return 0  
    96.  
    97. def main():
    98.     # theme参考/client/README
    99.     event_handle()
    100.  
    101. if __name__ == '__main__':
    102.     main()

    2、修改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())
    24.     # 接收服务器的响应
    25.     data = client_socket.recv(512)
    26.     # 将字节字符串转化为字符串
    27.     global_var.RX_BUF = data.decode('utf-8')
    28.     # print(f"rx......{global_var.RX_BUF}") 
    29.  
    30. def quit_handel(client_socket):
    31.     cmd='Q'
    32.     client_socket.sendall(cmd.encode())
    33.     tcp.disconnect_to_server(client_socket)
    34.  
    35. def motor_handel(window, client_socket, values):
    36.     i = int(values['MOTOR_I'])
    37.     global_var.MOTOR_DATA = str(abs(i)%360)
    38.     if i >= 0:
    39.         global_var.MOTOR_DIRECTION='0'
    40.     else:
    41.         global_var.MOTOR_DIRECTION='1'
    42.     message = 's'+global_var.MOTOR_DIRECTION+global_var.MOTOR_DATA
    43.     # 清理input
    44.     window['MOTOR_I'].update(value='0')
    45.     set_tx_buf('motor', message)
    46.     send_cmd(client_socket)
    47.     # 接收服务器的响应
    48.     data = client_socket.recv(512)
    49.     # 将字节字符串转化为字符串
    50.     global_var.RX_BUF = data.decode('utf-8')
    51.     # print(f"rx......{global_var.RX_BUF}") 
    52.  
    53. # 进行一次发送
    54. def send_cmd(client_socket):
    55.     data = global_var.TX_BUF
    56.     client_socket.sendall(data.encode())
    57.     # 接收服务器的响应
    58.     data = client_socket.recv(512)
    59.     # 将字节字符串转化为字符串
    60.     global_var.RX_BUF = data.decode('utf-8')
    61.     # print(f"rx......{global_var.RX_BUF}") 
    62.  
    63. # 设置发送消息
    64. def set_tx_buf(device, message): 
    65.     if device == 'sr04':
    66.         global_var.TX_BUF = '@002'+message
    67.     if device == 'led':
    68.         global_var.TX_BUF = '@000'+message
    69.     elif device == 'sr501':
    70.         global_var.TX_BUF = '@001'+message
    71.     elif device == 'irda':
    72.         global_var.TX_BUF = '@003'+message
    73.     elif device == 'motor':
    74.         global_var.TX_BUF = '@004'+message
    75.     elif device == 'dht11':
    76.         global_var.TX_BUF = '@005'+message
    77.     elif device == 'ds18b20':
    78.         global_var.TX_BUF = '@006'+message
    79.     elif device == 'AT24C02':
    80.         global_var.TX_BUF = '@007'+message
    81.     elif device == 'dac':
    82.         global_var.TX_BUF = '@008'+message
    83.  
    84. # 解析IRDA传入的数据
    85. def irda_data_analysis(cmd):
    86.     if cmd[5] == 'r':
    87.         global_var.IRDA_DATA = "RED"
    88.     elif cmd[5] == 'm':
    89.         global_var.IRDA_DATA = "MENU"
    90.     elif cmd[5] == 't':
    91.         global_var.IRDA_DATA = "TEST"
    92.     elif cmd[5] == '+':
    93.         global_var.IRDA_DATA = "+"
    94.     elif cmd[5] == 'b':
    95.         global_var.IRDA_DATA = "BACK"
    96.     elif cmd[5] == 'l':
    97.         global_var.IRDA_DATA = "LEFT"
    98.     elif cmd[5] == 'p':
    99.         global_var.IRDA_DATA = "START"
    100.     elif cmd[5] == 'r':
    101.         global_var.IRDA_DATA = "RIGHT"
    102.     elif cmd[5] == '0':
    103.         global_var.IRDA_DATA = "0"
    104.     elif cmd[5] == '1':
    105.         global_var.IRDA_DATA = "1"
    106.     elif cmd[5] == '2':
    107.         global_var.IRDA_DATA = "2"
    108.     elif cmd[5] == '-':
    109.         global_var.IRDA_DATA = "-"
    110.     elif cmd[5] == 'c':
    111.         global_var.IRDA_DATA = "c"
    112.     elif cmd[5] == '3':
    113.         global_var.IRDA_DATA = "3"
    114.     elif cmd[5] == '4':
    115.         global_var.IRDA_DATA = "4"
    116.     elif cmd[5] == '5':
    117.         global_var.IRDA_DATA = "5"
    118.     elif cmd[5] == '6':
    119.         global_var.IRDA_DATA = "6"
    120.     elif cmd[5] == '7':
    121.         global_var.IRDA_DATA = "7"
    122.     elif cmd[5] == '8':
    123.         global_var.IRDA_DATA = "8"
    124.     elif cmd[5] == '9':
    125.         global_var.IRDA_DATA = "9"
    126.  
    127. # 处理数据
    128. def cmd_handle(window):
    129.     cmd = global_var.RX_BUF
    130.     global_var.RX_BUF="#000"
    131.     if len(cmd) < 4:
    132.         print("cmd ERROR")
    133.         return -1
    134.     if '@' == cmd[0]:
    135.         # 目前驱动设备数量只有两位数
    136.         if cmd[1] == '0':
    137.             # LED: @000+1位命令位+1位数据位
    138.             if cmd[2] == '0' and cmd[3] == '0':
    139.                 if cmd[5] == '1':
    140.                     print("LED Status change success")
    141.                 elif cmd[5] == '0':
    142.                     print("LED Status change failure")
    143.                 else:
    144.                     print("message ERROR")
    145.             # SR501:@001+1位数据位
    146.             elif cmd[2] == '0' and cmd[3] == '1':
    147.                 if cmd[5] == '1':
    148.                     print("有人")
    149.                     message='有人'
    150.                     window['SR501_O'].update(message)
    151.                 elif cmd[5] == '0':
    152.                     print("无人")
    153.                     message='无人'
    154.                     window['SR501_O'].update(message)
    155.                 else:
    156.                     print("message ERROR")
    157.             # SR04
    158.             elif cmd[2] == '0' and cmd[3] == '2':
    159.                 if cmd[4] == 'g':
    160.                     global_var.SR04_DATA = cmd[5:8]
    161.                     message = f"{global_var.SR04_DATA}cm"
    162.                     window['SR04_O'].update(message)
    163.                 else:
    164.                     print("SR04: message ERROR")               
    165.             # irda
    166.             elif cmd[2] == '0' and cmd[3] == '3':
    167.                 # message = cmd[5]
    168.                 # print(message)
    169.                 if cmd[4] == 'g':
    170.                     irda_data_analysis(cmd)
    171.                     window['IRDA_O'].update(global_var.IRDA_DATA)
    172.             # motor
    173.             elif cmd[2] == '0' and cmd[3] == '4':
    174.                 if cmd[4] == 's':
    175.                     print("MOTOR: message SCUESS") 
    176.                 else:
    177.                     print("MOTOR: message ERROR")  
    178.             # dht11
    179.             elif cmd[2] == '0' and cmd[3] == '5':
    180.                 if cmd[4] == 'g':
    181.                     try:
    182.                         global_var.TEM=cmd[5]+cmd[6]
    183.                         global_var.HUM=cmd[7]+cmd[8]
    184.                         message = f"{global_var.TEM}°C   {global_var.HUM}%"
    185.                         window['DHT11_O'].update(message)
    186.                     except:
    187.                         message = "ERROR"
    188.                         window['DHT11_O'].update(message)
    189.                         print("DHT11: message ERROR")
    190.                 else:
    191.                     message = "ERROR"
    192.                     window['DHT11_O'].update(message)
    193.                     print("DHT11: message ERROR")  
    194.             # ds18b20
    195.             elif cmd[2] == '0' and cmd[3] == '6':
    196.                 if cmd[4] == 'g':
    197.                     try:
    198.                         global_var.TEM=cmd[5]+cmd[6]
    199.                         message = f"{global_var.TEM}°C"
    200.                         window['DS18B20_O'].update(message)
    201.                     except:
    202.                         message = "ERROR"
    203.                         window['DS18B20_O'].update(message)
    204.                         print("DS18B20: message ERROR")
    205.                 else:
    206.                     message = "ERROR"
    207.                     window['DS18B20_O'].update(message)
    208.                     print("DS18B20: message ERROR")
    209.             # AT24C02
    210.             elif cmd[2] == '0' and cmd[3] == '7':
    211.                 if cmd[4] == 'g':
    212.                     try:
    213.                         message = cmd[5:]
    214.                         window['AT24C02_O'].update(message)
    215.                     except:
    216.                         message = "ERROR"
    217.                         window['AT24C02_O'].update(message)
    218.                         print("AT24C02: message ERROR")
    219.                 elif cmd[4] == 'p':
    220.                     window['AT24C02_I'].update(value='')
    221.                     print("AT24C02: write SUCCESS")
    222.                 else:
    223.                     message = "ERROR"
    224.                     window['AT24C02_O'].update(message)
    225.                     print("AT24C02: message ERROR")
    226.             # DAC&&spi
    227.             elif cmd[2] == '0' and cmd[3] == '8':
    228.                 if cmd[4] == 'p':
    229.                     print("DAC: SUCCESS")
    230.                 else:
    231.                     print("DAC: message ERROR")
    232.  
    233. # 处理事件
    234. def event_handle(window, client_socket):
    235.     led = 0
    236.     # 事件循环
    237.     while True:  
    238.         try:
    239.             cmd_handle(window)
    240.             event, values = window.read()
    241.             if event == 'input':
    242.                 window['txbuff'].update(disabled=not values['input'])
    243.             elif event == 'send':
    244.                 send_handle(window, client_socket, values)
    245.             elif event == 'Clean':
    246.                 window['Output'].update(value='')
    247.                 window['AT24C02_O'].update(value='')
    248.             elif event == 'dht11':
    249.                 window['DHT11_O'].update(value=' ')
    250.                 set_tx_buf('dht11', 'g')
    251.                 send_cmd(client_socket)
    252.             elif event == 'ds18b20':
    253.                 window['DS18B20_O'].update(value=' ')
    254.                 set_tx_buf('ds18b20', 'g')
    255.                 send_cmd(client_socket)
    256.             elif event == 'Quit': 
    257.                 quit_handel(client_socket) 
    258.                 print(f"See you.............")
    259.                 break
    260.             elif event is None:
    261.                 print(f"xxxxxxxxxxxxxxxxxxxx")
    262.                 break
    263.             elif event == 'LED':
    264.                 if led % 2 == 0:
    265.                     set_tx_buf('led','p1')
    266.                 else:
    267.                     set_tx_buf('led','p0')
    268.                 led+=1
    269.                 if led > 100:
    270.                     led = 0
    271.                 send_cmd(client_socket)
    272.             elif event == 'SR501':
    273.                 set_tx_buf('sr501','g')
    274.                 send_cmd(client_socket)
    275.             elif event == 'SR04':
    276.                 set_tx_buf('sr04','g')
    277.                 send_cmd(client_socket)
    278.             elif event == 'IRDA':
    279.                 set_tx_buf('irda','g')
    280.                 send_cmd(client_socket)
    281.             elif event == 'MOTOR':
    282.                 motor_handel(window, client_socket, values)
    283.             elif event == 'AT24C02_R':
    284.                 window['AT24C02_O'].update(value='')
    285.                 set_tx_buf('AT24C02','g')
    286.                 send_cmd(client_socket)
    287.             elif event == 'AT24C02_W':
    288.                 global_var.AT24C02_DATA = values['AT24C02_I']
    289.                 set_tx_buf('AT24C02','p'+global_var.AT24C02_DATA)
    290.                 print(global_var.TX_BUF)
    291.                 window['AT24C02_I'].update(value='')
    292.                 send_cmd(client_socket)
    293.             elif event == 'DAC':
    294.                 set_tx_buf('dac','p'+values['DAC'])
    295.                 send_cmd(client_socket)
    296.             # 处理其他事件...
    297.         except Exception as e:
    298.             window.close()
    299.             print(f"An error occurred: {e}")
    300.             return 0
    301.     window.close()
    302.     return 0  
    303.  
    304. def main():
    305.     # 创建GUI对象
    306.     window = show.show_window('DefaultNoMoreNagging')
    307.     # 尝试连接到服务器  
    308.     client_socket = tcp.connect_to_server()
    309.     if client_socket is not None: 
    310.         event_handle(window, client_socket)
    311.  
    312. if __name__ == '__main__':
    313.     main()

    3、server编写

    1.             case 8:
    2.                 printf("DAC!!!\n");
    3.                 if ('p' == cmd[4])
    4.                 {
    5.                     direction = direction_put;
    6.                     get_data = extract_digit_number(cmd, 5, (strlen(&cmd[5])));
    7.                     if (NOERROR == dac_handle(&get_data))
    8.                     {
    9.                         tx_buffer = "@008p";
    10.                     }
    11.                     else
    12.                     {
    13.                         tx_buffer = "@008e";
    14.                     }
    15.  
    16.                 }
    17.                 else
    18.                 {
    19.                     tx_buffer = "@008e";
    20.                 }
    21.                 
    22.                 if (send(acceptfd, tx_buffer, strlen(tx_buffer), 0) < 0)
    23.                 {
    24.                     perror("send failed");  
    25.                 }
    26.                 break;
    27.             default:
    28.                 printf("Unknown equipment!!!\n");

    4、driver_handle

    1. /*
    2. *author   : xintianyu
    3. *function : Handle dac Settings
    4. *date     : 2024-4-24
    5. -----------------------
    6. author date  modify
    8. */
    9. int dac_handle(int *data)
    10. {
    11. 	/*传入参数后面要做通用处理使用空指针*/
    12. 	/*路径宏定义*/
    13.     char *device = "/dev/cebss_dac";
    14.     int ret = NOERROR;
    15. 	int dac_val = 0;
    16. 	static int fd;
    17.  
    18.     /* 打开文件 */
    19. 	fd = open(device, O_RDWR);
    20. 	if (fd == -1)
    21. 	{
    22. 		printf("can not open file %s\n", device);
    23. 		return ERROR;
    24. 	}
    25.  
    26.     /*0~1023*/
    27.     dac_val = *data*1023/100+1;
    28. 	printf("dac_val == %d\n", dac_val);
    29. 	write(fd, &dac_val, 2);
    30. 	dac_val += 50;
    31.  
    32. 	close(fd);
    33. 	return ret;
    34. }

    5、test

    非常的丝滑。

    6、 项目管理

  • 相关阅读:
    高性价比 ESP32 网络收音机：OLED 显示+编码器控制 (源码开源)
    inner join left join 什么情况效果相同
    深入理解注解驱动配置与XML配置的融合与区别
    剑指offer 38：字符串的排列
    架构设计系列5：如何设计高可用架构
    2022牛客暑期多校训练营（加赛）（EGHJM）
    【SLAM】4李群&李代数
    说一下v-model的理解双向绑定 vue响应式原理
    跨境电商:外贸企业做海外社媒营销的优势
    NAOMI代码详解
  • 原文地址：https://blog.csdn.net/qq_52479948/article/details/138166165