设为首页收藏本站
开启辅助访问 切换到宽版

 找回密码
 立即注册

QQ登录

只需一步，快速开始

热门： 51单片机 | 24小时必答区 | 单片机教程 | 单片机DIY制作 | STM32 | Cortex M3 | 模数电子 | 电子DIY制作 | 音响/功放 | 拆机乐园 | Arduino | 嵌入式OS | 程序设计

搜索
»论坛 › 嵌入式/单片机论坛 › STM32/8 › 基于STM32单片机SIM800C的MQTT实现源码
返回列表 发新帖
查看: 733|回复: 4
收起左侧

基于STM32单片机SIM800C的MQTT实现源码

[复制链接]
ID:389262 发表于 2023-11-16 11:02 | 显示全部楼层 |阅读模式
  1. #include "./sys/sys.h"
  2. #include "./delay/delay.h"
  3. #include "./usart/usart.h"
  4. #include "./LED/led.h"                           
  5. #include "./LCD/lcd.h"  
  6. #include "./KEY/key.h"  
  7. #include "./RTC/rtc.h"
  8. //#include "./RTC/bsp_rtc.h"
  9. #include "./BEEP/beep.h"
  10. #include "usmart.h"
  11. #include "malloc.h"
  12. #include "./SDIO/sdio_sdcard.h"  
  13. #include "./W25QXX/w25qxx.h"   
  14. #include "./src/ff.h"  
  15. #include "./exfuns/exfuns.h"   
  16. #include "text.h"       
  17. #include "piclib.h"
  18. #include "./TOUCH/touch.h"        
  19. #include "./USART2/usart2.h"
  20. #include "./USART3/usart3.h"
  21. #include "./MPU6050/mpu6050.h"
  22. #include "sim800c.h"
  23. #include "./gps.h"
  24. #include "./OV7670/ov7670.h"
  25. #include "./NRF24L01/24l01.h"
  26. #include "./TIMER/timer.h"                         
  27. //#include "./OV7670/sccb.h"       
  28. #include "./OV2640/ov2640.h"
  29. #include "MQTTPacket.h"
  30. #include "StackTrace.h"
  31. #include "inv_mpu.h"
  32. #include "inv_mpu_dmp_motion_driver.h"

  34. #include "./T9INPUT/t9input.h"
  35. #include "stdarg.h"
  36. #include <string.h>
  37. #include <stdio.h>  
  38. #include <stdlib.h>

  40. /* 私有变量 ------------------------------------------------------------------*/
  41. FATFS mfs;                                                                                                        /* FatFs文件系统对象 */
  42. FIL mfile;                                                                                                        /* 文件对象 */
  43. FRESULT mf_res;                    /* 文件操作结果 */
  44. char mfpath[] = "0:TEXT";                  /* 保存当前扫描路径 */
  45. BYTE WriteBuffer[100] = "欢迎使用智能终端\r\n";
  46. UINT file_num;

  48. nmea_msg gpsx;                                                                                                                                                                                                        //GPS信息

  50. const u8 *port = (u8 *)"1883";                                                                                                                                        //端口固定为1883
  51. const u8 *ipaddr = (u8 *)"118.190.146.251";
  52. typedef struct
  53. {
  54.         float temp[3];
  55.         float humi[3];
  56.         float gps[3];
  57.         uint8_t door[4];
  58.         short mpu[6];
  59. }menu_message,*menu_message_;

  61. uint16_t screen_w = 800;                                                                                                                                                                //屏幕宽度
  62. uint16_t screen_h = 480;                                                                                                                                                                //屏幕高度
  63. uint8_t line_w = 3;                                                                                                                                                                                        //分界线宽
  64. uint8_t menu_num = 4;                                                                                                                                                                                //菜单组数
  65. uint8_t cur_menu_item,old_menu_item;                                                                                                                //当前菜单

  67. uint8_t tmp_buf[33];                                                                                                                                                                                //NRF缓存

  69. u8 mqtt_msg[200]={0};                                                                                                                                                                                //MQTT消息包缓存
  70. u16 len;                                                                                                                                                                                                                                //消息包有效长度
  71. u8 gprs_tcp_flag;                                                                                                                                                                                                //TCP连接标志
  72. u8 mqtt_data_flag;                                                                                                                                                                                        //MQTT消息类型标志
  73. u8 send_data_flag;                                                                                                                                                                                        //发布消息标志

  75. u8 temp_data[] = "##################------000000000000";                                //36字节 MQTT消息内容缓存
  76. u8 message_type;                                                                                                                                                                                //消息类型,区别TOPIC主题
  77. u8 about_text_size = 24;                                                                                                                                                                //关于字体大小
  78. u8* const Info_Show[13]=
  79.         {
  80.                 "温度1","温度2","温度3",
  81.                 "湿度1","湿度2","湿度3",
  82.                 "GPS经度","GPS纬度",
  83.                 "车门信息","陀螺仪状态",
  84.                 "服务器IP","蓝牙地址","阈值设置"
  85.         };

  87. menu_message menu_mess;
  88. //_t9_obj * t9in;                                                                                                                                                                                                //输入法
  89. //私有函数声明
  90. void sim800c_init(void);                                                                                                                                                                //SIM800C初始化

  92. void gprs_send_data(u8 * data,u8 lenth);                                                                                                        //GPRS发送数据
  93. u8 *my_strstr(const u8 *s1,u16 n1,const u8 *s2,u16 n2);                                                //字符串查找
  94. void Start_Gprs_TCP(void);                                                                                                                                                                //GPRS建立TCP连接
  95. void Stop_Gprs_Connect(void);                                                                                                                                                        //关闭GPRS连接
  96. void Gps_Msg_Show(void);                                                                                                                                                                        //显示GPS定位信息
  97. void send_model_temp_humi(menu_message * mes,u8 * space,u8 type);        //MQTT发送内容包装

  99. int main(void)
  100. {
  101.         int sys_run_times=0;
  102.         unsigned char valtest=0;
  103.         u8 key,fontok=0;           

  105.         u8 *p1,*p2,*p3;
  106.         u8 hbeaterrcnt=0;                                                                                                                                //心跳错误计数器,连续5次心跳信号无应答,则重新连接
  107.        
  108. //        t9in = 0;
  109.         gprs_tcp_flag = 0;
  110.         mqtt_data_flag = 0;
  111.         send_data_flag = 0;
  112.         message_type = 0;

  114.         delay_init();                                                                                                                                                //延时函数初始化          
  115.   NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2); //设置中断优先级分组为组2：2位抢占优先级，2位响应优先级
  116.         uart_init(115200);                                                                                                                        //串口初始化为115200
  117.         usmart_dev.init(72);                                                                                                                //初始化USMART               
  118.        
  119.   GENERAL_TIMx_Configuration();                                                                                //通用定时器初始化：1ms中断一次
  120.         LED_Init();                                                                                                                                                        //初始化与LED连接的硬件接口
  121.         KEY_Init();                                                                                                                                                        //初始化按键
  122.         LCD_Init();                                                                                                                                                        //初始化LCD  
  123.         BEEP_Init();                                                                                                                                                //蜂鸣器初始化
  124.         W25QXX_Init();                                                                                                                                        //初始化W25Q128
  125.         tp_dev.init();                                                                                                                                        //初始化触摸屏
  126.         usart3_init(115200);                                                                                                                //初始化串口3
  127.         my_mem_init(SRAMIN);                                                                                                                //初始化内部内存池
  128.         exfuns_init();                                                                                                                                        //为fatfs相关变量申请内存  
  129.         f_mount(fs[0],"0:",1);                                 //挂载SD卡
  130.         f_mount(fs[1],"1:",1);                                 //挂载FLASH.
  131.         key=KEY_Scan(0);  
  132.         if(key==KEY0_PRES&&((tp_dev.touchtype&0X80)==0))//强制校准
  133.         {
  134.                 LCD_Clear(WHITE);                                                                                                                        //清屏0
  135.                 TP_Adjust();                                                                                                                                        //屏幕校准
  136.                 TP_Save_Adjdata();          
  137.                 LCD_Clear(WHITE);                                                                                                                        //清屏
  138.         }
  139.         fontok=font_init();                                                                                                                        //检查字库是否OK
  140.         if(fontok||key==KEY1_PRES)                            //需要更新字库                                 
  141.         {
  142.                 LCD_Clear(WHITE);                                                                                                                        //清屏
  143.                 POINT_COLOR=RED;                                                                                                                        //设置字体为红色                                
  144.                 LCD_ShowString(60,50,200,16,16,(u8 *)"ALIENTEK STM32");
  145.                 while(SD_Init())                                                                                                                        //检测SD卡
  146.                 {
  147.                         LCD_ShowString(60,70,200,16,16,(u8 *)"SD Card Failed!");
  148.                         delay_ms(200);
  149.                         LCD_Fill(60,70,200+60,70+16,WHITE);
  150.                         delay_ms(200);                    
  151.                 }
  152.                 LCD_ShowString(60,70,200,16,16,(u8 *)"SD Card OK");
  153.                 LCD_ShowString(60,90,200,16,16,(u8 *)"Font Updating...");
  154.                 key=update_font(20,110,16,(u8 *)"0:");                                //从SD卡更新
  155.                 while(key)                                                                                                                                                //更新失败               
  156.                 {                                           
  157.                         LCD_ShowString(60,110,200,16,16,(u8 *)"Font Update Failed!");
  158.                         delay_ms(200);
  159.                         LCD_Fill(20,110,200+20,110+16,WHITE);
  160.                         delay_ms(200);                       
  161.                 }                   
  162.                 LCD_ShowString(60,110,200,16,16,(u8 *)"Font Update Success!");
  163.                 delay_ms(1500);       
  164.                 LCD_Clear(WHITE);                                                                                                                        //清屏               
  165.         }
  166.        
  167.         //RTC_CheckAndConfig(&systmtime);
  168.         RTC_Init();                                                                                                                                                        //RTC初始化
  169.         delay_ms(1000);
  170.         RTC_Get();
  171.         printf("time:%02d-%02d-%02d.%02d:%02d:%02d\r\n",calendar.w_year%100,calendar.w_month,calendar.w_date,calendar.hour,calendar.min,calendar.sec);
  172.        
  173.         init_gps();
  174.        
  175.         NRF24L01_Init();
  176.         while(NRF24L01_Check()){;}
  177.         NRF24L01_RX_Mode();
  178.        
  179.         LCD_Clear(BLACK);
  180.         key = 0;
  181.        
  182.         piclib_init();                                                                                                                                        //初始化画图
  183.        
  184.         //I2C初始化
  185.         i2c_CfgGpio();
  186.   //MPU6050初始化
  187.         MPU6050_Init();

  189.         //检测MPU6050
  190. //        while(!MPU6050ReadID()){;}

  192.         while(sim800c_send_cmd((u8 *)"AT",(u8 *)"OK",100))//检测是否应答AT指令
  193.         {
  194.                 Show_Str(40,55,200,16,(u8 *)"未检测到模块!!!",16,0);
  195.                 delay_ms(800);
  196.                 Show_Str(40,55,200,16,(u8 *)"尝试连接模块...",16,0);
  197.                 delay_ms(400);  
  198.         }
  199.         printf("SIM800C Check OK\r\n");

  201.         p1=mymalloc(SRAMIN,100);                                                                                                //申请100字节内存
  202.        
  203.         while(1)
  204.         {
  205.                 if(NRF24L01_RxPacket(tmp_buf)==0)
  206.     {
  207.       printf("NRF24L01:%s\r\n",(char *)tmp_buf);
  208.                         switch(tmp_buf[17])
  209.                         {
  210.                                 case '0'://终端1
  211.                                         menu_mess.temp[0] = tmp_buf[19] == '+' ? ((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01) : \
  212.                                                                                                                                                                                                         -((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01);
  213.                                         if(tmp_buf[27] != '#')
  214.                                         menu_mess.humi[0] = (tmp_buf[27] - '0') * 10 + (tmp_buf[28] - '0') * 1;
  215.                                         break;
  216.                                 case '1'://终端2
  217.                                         menu_mess.temp[1] = tmp_buf[19] == '+' ? ((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01) : \
  218.                                                                                                                                                                                                         -((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01);
  219.                                         if(tmp_buf[27] != '#')
  220.                                         menu_mess.humi[1] = (tmp_buf[27] - '0') * 10 + (tmp_buf[28] - '0') * 1;
  221.                                         break;
  222.                                 case '2'://终端3
  223.                                         menu_mess.temp[2] = tmp_buf[19] == '+' ? ((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01) : \
  224.                                                                                                                                                                                                         -((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01);
  225.                                         if(tmp_buf[27] != '#')
  226.                                         menu_mess.humi[2] = (tmp_buf[27] - '0') * 10 + (tmp_buf[28] - '0') * 1;
  227.                                         break;
  228.                                 case '3'://终端4
  229.                                         menu_mess.door[0] = tmp_buf[19] == 0x17 ? 0x11 : 0x10;
  230.                                         break;
  231.                                 default :
  232.                                         break;
  233.                         }
  234.     }
  235.        
  236.                 sys_run_times++;
  237.                 if(gprs_tcp_flag == 17)
  238.                 {
  239.                         //构建MQTT连接
  240.                         switch(mqtt_data_flag)
  241.                         {
  242.                                 case 0:
  243.                                         sim800c_send_cmd("AT+CIPSTATUS","OK",500);        //查询连接状态
  244.                                         if(strstr((const char*)USART3_RX_BUF,"CONNECT OK"))
  245.                                         {
  246.                                                 len=mqtt_connect_message(mqtt_msg,"STM32","admin","public");//id=123456,用户名和密码为空
  247.                                                 gprs_send_data((u8 *)mqtt_msg,len);
  248.                                                 delay_ms(600);
  249.                                                 len=mqtt_subscribe_message(mqtt_msg,"home/temp",1,1);                        //订阅test主题
  250.                                                 gprs_send_data((u8 *)mqtt_msg,len);
  251.                                                 printf("MQTT Connect and subscribe OK\r\n");
  252.                                         }
  253.                                         mqtt_data_flag = 1;
  254.                                         break;
  255.                                 case 1:
  256.                                         if(17 == send_data_flag)
  257.                                         {
  258.                                                 MQTTString topicString = MQTTString_initializer;
  259.                                                
  260.                                                 RTC_Get();
  261.                                                 send_model_temp_humi(&menu_mess,(u8 *)temp_data,message_type);
  262.                                                
  263.                                                 temp_data[24] = calendar.w_year%100/10+'0';
  264.                                                 temp_data[25] = calendar.w_year%10+'0';
  265.                                                
  266.                                                 temp_data[26] = calendar.w_month%100/10+'0';
  267.                                                 temp_data[27] = calendar.w_month%10+'0';
  268.                                                
  269.                                                 temp_data[28] = calendar.w_date%100/10+'0';
  270.                                                 temp_data[29] = calendar.w_date%10+'0';
  271.                                                
  272.                                                 temp_data[30] = calendar.hour%100/10+'0';
  273.                                                 temp_data[31] = calendar.hour%10+'0';
  274.                                        
  275.                                                 temp_data[32] = calendar.min%100/10+'0';
  276.                                                 temp_data[33] = calendar.min%10+'0';
  277.                                                
  278.                                                 temp_data[34] = calendar.sec%100/10+'0';
  279.                                                 temp_data[35] = calendar.sec%10+'0';
  280.                                                
  281.                                                 printf("数据发送中...\r\n");                                                //提示数据发送中
  282.                                                 if(0 == message_type)
  283.                                                 {
  284.                                                         topicString.cstring = "L180309001/YY0118050001/Temp";                                                                                                //发送的主题
  285.                                                 }
  286.                                                 else if(1 == message_type)
  287.                                                 {
  288.                                                         topicString.cstring = "L180309001/YY0118050001/EGps";
  289.                                                 }
  290.                                                 else if(2 == message_type)
  291.                                                 {
  292.                                                         topicString.cstring = "L180309001/YY0118050001/Gyro";
  293.                                                 }
  294.                                                 else if(3 == message_type)
  295.                                                 {
  296.                                                         topicString.cstring = "L180309001/YY0118050001/Door";
  297.                                                 }
  298.                                                 else if(4 == message_type)
  299.                                                 {
  300.                                                         topicString.cstring = "L180309001/YY0118050001/Point";
  301.                                                 }
  302.                                                 message_type++;
  303.                                                 if(message_type>=5)
  304.                                                         message_type = 0;
  305.                                                 len = MQTTSerialize_publish(mqtt_msg, 200, 0, 0, 0, 0, topicString, (u8 *)temp_data, strlen((const char *)temp_data)); /* 2 */
  306.                                                 gprs_send_data((u8 *)mqtt_msg,len);
  307.                                                 printf("MQTT Send data OK\r\n");
  308.                                                 send_data_flag = 0;GPIOB -> ODR ^= GPIO_Pin_5;
  309.                                         }
  310.                                         break;
  311.                         }
  312.                         if(USART3_RX_STA&0X8000)                                                                                                                                                                        //接收到一次数据了
  313.                         {
  314.                                 USART3_RX_BUF[USART3_RX_STA&0X7FFF]=0;                                                                                                        //添加结束符
  315.                                 printf("%s",USART3_RX_BUF);                                                                                                                                                        //发送到串口  
  316.                                 if(hbeaterrcnt)                                                                                                                                                                                                        //需要检测心跳应答
  317.                                 {
  318.                                         if(strstr((const char*)USART3_RX_BUF,"SEND OK"))hbeaterrcnt=0;//心跳正常
  319.                                 }
  320.                                 p2=(u8*)strstr((const char*)USART3_RX_BUF,"+IPD");
  321.                                 if(p2)                                                                                                                                                                                                                                        //接收到TCP/UDP数据
  322.                                 {
  323.                                         p3=(u8*)strstr((const char*)p2,",");
  324.                                         p2=(u8*)strstr((const char*)p2,":");
  325.                                         p2[0]=0;                                                                                                                                                                                                                        //加入结束符
  326.                                         sprintf((char*)p1,"收到%s字节",p3+1);                                                                                                        //接收到的字节数
  327.                                         printf("%s\r\n",(char*)p1);
  328.                                 }
  329.                                 USART3_RX_STA=0;
  330.                         }
  331.                        
  332.                 }
  333.                 else
  334.                 {
  335.                         Start_Gprs_TCP();                                                                                                                                                                                                        //创建TCP连接
  336.                 }
  337.                 if(17 == (sys_run_times%100))
  338.                 {
  339.                         menu_mess.gps[0] = (float)(gpsx.longitude/100000);
  340.                         menu_mess.gps[1] = (float)(gpsx.latitude/100000);
  341.                         menu_mess.gps[2] = (float)(gpsx.speed/1000);

  343.                         send_data_flag = 17;
  344.                         printf("Send flag OK\r\n");
  345.                         hbeaterrcnt++;
  346.                         printf("hbeaterrcnt:%d\r\n",hbeaterrcnt);                                                                                                        //方便调试代码
  347.                 }
  348.                 else if(27 == (sys_run_times%5000))
  349.                 {
  350.                         len = mqtt_ping_message(mqtt_msg);                                                                                                                                /* 2 */
  351.                         gprs_send_data((u8 *)mqtt_msg,len);
  352.                         printf("heart Send OK\r\n");
  353.                 }
  354.                 switch(KEY_Scan(0))
  355.                 {
  356.                         case KEY0_PRES:
  357.                                 f_close(&mfile);
  358.                                 while(1)
  359.                                 {
  360.                                         printf("System Stop\r\n");
  361.                                         delay_ms(1000);
  362.                                 }
  363.                                 break;
  364.                         default:
  365.                                 break;
  366.                 }
  367.                
  368.                 delay_ms(6);
  369. //                printf("Sys_Time:%d \r\n",sys_run_times);
  370.         }
  371.        
  372.         while(1)
  373.         {
  374.                 printf("Error\r\n");
  375.                 delay_ms(500);
  376.         }
  377.           
  378. }

  380. void Start_Gprs_TCP(void)
  381. {
  382.         //
  383.         u8 *p1,p2[100];
  384.         u8 res=0;
  385.         p1=mymalloc(SRAMIN,100);                                                                                                                                                                        //申请50个字节的内存
  386.         sim800c_send_cmd((u8 *)"ATE0",(u8 *)"OK",200);                                                                                //不回显
  387.         USART3_RX_STA=0;
  388.         sim800c_send_cmd("AT+SAPBR=3,1,\"Contype\",\"GPRS\"","OK",200);                //配置承载场景1
  389.         sim800c_send_cmd("AT+SAPBR=3,1,\"APN\",\"CMNET\"","OK",200);
  390.         sim800c_send_cmd("AT+SAPBR=1,1",0,200);                                                                                                                //激活一个GPRS上下文
  391.         delay_ms(5);
  392.         sim800c_send_cmd("AT+CNTPCID=1","OK",200);                                                                                                //设置CNTP使用的CID
  393.         sim800c_send_cmd("AT+CNTP=\"202.120.2.101\",32","OK",200);                                //设置NTP服务器和本地时区(32时区 时间最准确)
  394.         sim800c_send_cmd("AT+CNTP","+CNTP: 1",600);                                                                                                //同步网络时间
  395.        
  396.         USART3_RX_STA=0;
  397.         if(sim800c_send_cmd("AT+CPIN?","OK",200))res|=1<<0;                                                                //查询SIM卡是否在位
  398.         USART3_RX_STA=0;
  399.          
  400.         if(0 == res)
  401.         {
  402.                 sim800c_send_cmd("AT+CIPCLOSE=1","CLOSE OK",100);                                                                //关闭连接
  403.                 sim800c_send_cmd("AT+CIPSHUT","SHUT OK",100);                                                                                //关闭移动场景
  404.                 if(sim800c_send_cmd("AT+CGCLASS=\"B\"","OK",1000))                                                        printf("SIM800C Init1 FAIL\r\n");        //设置GPRS移动台类别为B,支持包交换和数据交换
  405.                 if(sim800c_send_cmd("AT+CGDCONT=1,\"IP\",\"CMNET\"","OK",1000))        printf("SIM800C Init2 FAIL\r\n");        //设置PDP上下文,互联网接协议,接入点等信息
  406.                 if(sim800c_send_cmd("AT+CGATT=1","OK",500))                                                                                        printf("SIM800C Init3 FAIL\r\n");        //附着GPRS业务
  407.                 if(sim800c_send_cmd("AT+CIPCSGP=1,\"CMNET\"","OK",500))                                        printf("SIM800C Init4 FAIL\r\n");        //设置为GPRS连接模式
  408.                 if(sim800c_send_cmd("AT+CIPHEAD=1","OK",500))                                                                                printf("SIM800C Init5 FAIL\r\n");        //设置接收数据显示IP头(方便判断数据来源)
  409.                 printf("SIM800C Start OK\r\n");
  410.                
  411.                 USART3_RX_STA=0;
  412.                 sprintf((char*)p2,"AT+CIPSTART=\"%s\",\"%s\",\"%s\"","TCP",ipaddr,port);
  413.                
  414.                 if(0==sim800c_send_cmd(p2,"OK",500))                                                                                                                //发起连接
  415.                 {
  416.                         delay_ms(1500);delay_ms(1000);
  417.                         sim800c_send_cmd("AT+CIPSTATUS","OK",500);                                                                                //查询连接状态
  418.                         USART3_RX_STA = 0;
  419.                         if(strstr((const char*)USART3_RX_BUF,"CONNECT OK"))
  420.                         {
  421.                                 gprs_tcp_flag = 17;
  422.                                 printf("SIM800C TCP Connect OK\r\n");
  423.                         }
  424.                         else
  425.                         {
  426.                                 gprs_tcp_flag = 0;
  427.                                 printf("SIM800C TCP Connect Fail\r\n");
  428.                         }
  429.                 }
  430.         }
  431.         myfree(SRAMIN,p2);
  432. }
  433. void Stop_Gprs_Connect(void)
  434. {
  435.         sim800c_send_cmd("AT+CIPCLOSE=1","CLOSE OK",100);                                                                        //关闭连接
  436.         sim800c_send_cmd("AT+CIPSHUT","SHUT OK",100);                                                                                        //关闭移动场景
  437. }

  439. void send_model_temp_humi(menu_message * mes,u8 * space,u8 type)
  440. {
  441.         long val;
  442.         u8 t;
  443.         //if(strlen(space)<36)return;
  444.         switch(type)
  445.         {
  446.                 case 0:                                                                                                                                                                //温湿度+RTC
  447.                         for(t = 0;t < 3;t ++)
  448.                         {
  449.                                 val = (int)(mes->temp[t] * 100);
  450.                                 if(val<0)
  451.                                 {
  452.                                         space[t * 6] = '-';
  453.                                 }
  454.                                 else
  455.                                 {
  456.                                         space[t * 6] = '+';
  457.                                 }
  458.                                 val = val >= 0 ? val : -val;
  459.                                 space[t * 6 + 1] = val % 10000 /1000 + '0';
  460.                                 space[t * 6 + 2] = val % 1000 /100 + '0';
  461.                                 space[t * 6 + 3] = '.';
  462.                                 space[t * 6 + 4] = val % 100 /10 + '0';
  463.                                 space[t * 6 + 5] = val % 10 /1 + '0';
  464.                                
  465.                                 val = (int)(mes->humi[t]);
  466.                                 space[18 + t * 2] = val % 100 / 10 + '0';
  467.                                 space[18 + t * 2 + 1] = val % 10 / 1 + '0';
  468.                         }
  469.                         printf("Temp_Data:%s\r\n",(u8 *)space);
  470.                         break;
  471.                 case 1:                                                                                                                                                                //GPS+RTC
  472.                         for(t = 0;t < 2;t ++)
  473.                         {
  474.                                 val = (long)(mes->gps[t] * 100000);
  475.                                 if(val<0)
  476.                                 {
  477.                                         space[t * 10] = '-';
  478.                                 }
  479.                                 else
  480.                                 {
  481.                                         space[t * 10] = '+';
  482.                                 }
  483.                                 val = val >= 0 ? val : -val;
  484.                                 space[t * 10 + 1] = val % 100000000 /10000000 + '0';
  485.                                 space[t * 10 + 2] = val % 10000000 /1000000 + '0';
  486.                                 space[t * 10 + 3] = val % 1000000 /100000 + '0';
  487.                                 space[t * 10 + 5] = val % 100000 /10000 + '0';
  488.                                 space[t * 10 + 6] = val % 10000 /1000 + '0';
  489.                                 space[t * 10 + 7] = val % 1000 /100 + '0';
  490.                                 space[t * 10 + 8] = val % 100 /10 + '0';
  491.                                 space[t * 10 + 9] = val % 10 /1 + '0';
  492.                                 space[t * 10 + 4] = '.';
  493.                         }
  494.                         val = (int)(mes->gps[2] * 10);
  495.                         space[20] = val % 10000 / 1000 + '0';
  496.                         space[21] = val % 1000 / 100 + '0';
  497.                         space[22] = val % 100 / 10 + '0';
  498.                         space[23] = val % 10 / 1 + '0';
  499.                         printf("Gps_Data:%s\r\n",(u8 *)space);
  500.                         break;
  501.                 case 2:                                                                                                                                                                //陀螺仪+RTC
  502.                         MPU6050ReadAcc((short *)(mes->mpu));
  503.                         for(t = 0;t < 3;t ++)
  504.                         {
  505.                                 space[t * 2] = ((mes -> mpu[t]) >> 8) & 0xFF;
  506.                                 space[t * 2 + 1] = (mes -> mpu[t]) & 0xFF;
  507.                         }
  508.                         MPU6050ReadGyro((short *)(mes->mpu));
  509.                         for(t = 0;t < 3;t ++)
  510.                         {
  511.                                 space[6 + t * 2] = ((mes -> mpu[t]) >> 8) & 0xFF;
  512.                                 space[6 + t * 2 + 1] = (mes -> mpu[t]) & 0xFF;
  513.                         }
  514.                        
  515.                         for(t = 12;t < 24;t ++)
  516.                         {
  517.                                 space[t] = '#';
  518.                         }
  519.                         printf("Gyro_Data:%s\r\n",(u8 *)space);
  520.                         break;
  521.                 case 3:                                                                                                                                                                //开关门+RTC
  522.                         space[0] = mes->door[0] + '0';
  523.                         for(t = 1;t < 24;t ++)
  524.                         {
  525.                                 space[t] = '#';
  526.                         }
  527.                         printf("Door_Data:%s\r\n",(u8 *)space);
  528.                         break;
  529.                 case 4:                                                                                                                                                                //点熄火+RTC
  530.                         space[0] = mes->door[1] + '0';
  531.                         for(t = 1;t < 24;t ++)
  532.                         {
  533.                                 space[t] = '#';
  534.                         }
  535.                         printf("Point_Data:%s\r\n",(u8 *)space);
  536.                         break;
  537.                 default :
  538.                         break;
  539.         }
  540.        
  541. }


  544. //在str1字符串中找出str2字符串(不包括str2的串结束符,忽略str中的\0)
  545. //返回该位置的指针,如找不到,返回空指针
  546. u8 *my_strstr(const u8 *s1,u16 n1,const u8 *s2,u16 n2)  
  547. {  
  548.         int n,x=0,y=0;  
  549.         if (*s2)          
  550.         {
  551.                 while(1)                 
  552.                 {
  553.                         if(*s1==*s2)//找到s2第一次出现，两种情况考虑
  554.                         {
  555.                                 for (n=0;n<n2;n++)  
  556.                                 {
  557.                                         if (*(s1+n)==*(s2+n))
  558.                                         {
  559.                                                 y++;
  560.                                                 if (y>=n2)
  561.                                                 //if (!*(s2+n+1))        //s2下一个字符是否为'\0'  
  562.                                                 {  
  563.                                                         return (u8 *)s1;  
  564.                                                 }
  565.                                                 if (x+n>=n1-1)        //防止数组越界
  566.                                                 {  
  567.                                                         return NULL;  
  568.                                                 }
  569.                                                 if (*(s1+n+1)!=*(s2+n+1))//查找的下一个字符不相等,一个字符相等
  570.                                                 {
  571.                                                         break;
  572.                                                 }
  573.                                         }
  574.                                         else
  575.                                         {  
  576.                                                 break;
  577.                                         }
  578.                                 }  
  579.                         }
  580.                         s1++;
  581.                         x++;
  582.                         if(x>=n1)
  583.                         {
  584.                                 break;
  585.                         }
  586.                 }  
  587.                 return NULL;  
  588.         }  
  589.         else  
  590.         {  
  591.                 return (u8*)s1;  
  592.         }  
  593. }


  596. void gprs_send_data(u8 *data,u8 lenth)
  597. {
  598.         if(sim800c_send_cmd("AT+CIPSEND",">",500)==0)                //发送数据
  599.         {
  600.                 //u3_printf("%s",(u8 *)data);
  601.                 my_u3_send((char *)mqtt_msg,lenth);
  602.                 delay_ms(10);
  603.                 if(sim800c_send_cmd((u8*)0X1A,"SEND OK",5000)==0)
  604.                         printf("GPRS数据发送成功!\r\n");//最长等待10s
  605.         }
  606.         else
  607.                 sim800c_send_cmd((u8*)0X1B,0,0);        //ESC,取消发送
  608. }
复制代码

原理图: 无
仿真: 无
代码: GPRS MQTT STM32.7z (1.56 MB, 下载次数: 28)

评分

参与人数 1黑币 +50 收起 理由
admin + 50 共享资料的黑币奖励！

查看全部评分

回复

使用道具 举报

ID:1057978 发表于 2023-11-17 08:03 | 显示全部楼层
厉害领了，stm32也能搞mqtt了啊，是以太网通讯解析字符吗？
回复

使用道具 举报

ID:59738 发表于 2023-11-21 10:59 | 显示全部楼层
现在很多Dtu固件的 4G卡 比较方便
回复

使用道具 举报

ID:1057978 发表于 2023-12-12 15:51 | 显示全部楼层
STM32怎么进行TCP通讯呢老哥
回复

使用道具 举报

ID:499508 发表于 2024-1-18 21:03 | 显示全部楼层
这是AT指令GSM模块里的MQTT，不能做MQTT透传
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表