找回密碼
 立即注冊(cè)

QQ登錄

只需一步，快速開始

搜索
查看: 4023|回復(fù): 1
收起左側(cè)

stm32發(fā)送到onenet的方法(程序+資料)

[復(fù)制鏈接]
ID:522430 發(fā)表于 2019-4-26 17:37 | 顯示全部樓層 |閱讀模式
內(nèi)容詳細(xì)講解STM32如何向onenet發(fā)送數(shù)據(jù)
0.png

單片機(jī)源程序如下:
  1. /**********************************************************
  2.                                                                                                
  3. 接線說明：
  4. STM32                 SIM868
  5. GND                <----->        GND
  6. PA2/TX2------>        RXD
  7. PA3/RX2<------        TXD
  8. RX1/PA10<------ GPS-T

  10. //用于調(diào)試可不接
  11. STM32                USB-TTL模塊
  12. GND                ------>        GND
  13. TX1/PA9------>        RXD

  15. ***********************************************************/

  17. #include "stm32f10x.h"
  18. #include "delay.h"
  19. #include "usart.h"
  20. #include "led.h"
  21. #include "usart2.h"


  24. //常量
  25. #define Success 1U
  26. #define Failure 0U

  28. //定義變量
  29. unsigned long  Time_Cont = 0;       //定時(shí)器計(jì)數(shù)器


  32. char OneNetServer[] = "api.heclouds.com";       //不需要修改


  35. char device_id[] = "10252516";    //修改為自己的設(shè)備ID
  36. char API_KEY[] = "MI0I=4cUrvBA=brbvheeAMgNqTk=";    //修改為自己的API_KEY

  38. //char device_id[] = "10129834";    //修改為自己的設(shè)備ID
  39. //char API_KEY[] = "pkIGh8Qgk8QmVrlbNzMxRR4pKvk=";    //修改為自己的API_KEY
  40. char sensor_gps[] = "location";                                //不需要修改

  42. unsigned int count = 0;

  44. void errorLog(int num);
  45. void phone(char *number);
  46. unsigned int sendCommand(char *Command, char *Response, unsigned long Timeout, unsigned char Retry);
  47. void sendMessage(char *number,char *msg);
  48. void Sys_Soft_Reset(void);
  49. void parseGpsBuffer(void);
  50. void printGpsBuffer(void);
  51. void postGpsDataToOneNet(char* API_VALUE_temp, char* device_id_temp, char* sensor_id_temp, char* lon_temp, char* lat_temp);
  52. char* longitudeToOnenetFormat(char *lon_str_temp);
  53. char* latitudeToOnenetFormat(char *lat_str_temp);
  54. int Digcount(long num);

  56. int main(void)
  57. {       
  58.         delay_init();
  59.        
  60.         NVIC_Configuration();          //設(shè)置NVIC中斷分組2:2位搶占優(yōu)先級(jí)，2位響應(yīng)優(yōu)先級(jí)
  61.         uart_init(115200);         //串口初始化為115200
  62.         USART2_Init(9600);        //串口2波特率9600
  63.         u2_printf("AT\r\n");
  64.         Init_LEDpin();
  65.        
  66.        
  67.        
  68.         printf("Welcome to use!\r\n");
  69.         printf("ILoveMcu.taobao.com!\r\n");
  70.        
  71.         if (sendCommand("AT\r\n", "OK\r\n", 3000, 10) == Success);
  72.         else errorLog(1);
  73.         delay_ms(100);

  75.         if (sendCommand("AT+CGCLASS=\"B\"\r\n", "OK\r\n", 3000, 2) == Success);
  76.         else errorLog(3);
  77.         delay_ms(100);

  79.         if (sendCommand("AT+CGDCONT=1,\"IP\",\"CMNET\"\r\n", "OK", 3000, 2) == Success);
  80.         else errorLog(4);
  81.         delay_ms(100);

  83.         if (sendCommand("AT+CGATT=1\r\n", "OK\r\n", 3000, 2) == Success);
  84.         else errorLog(5);
  85.         delay_ms(100);
  86.    
  87.     if (sendCommand("AT+SAPBR=0,1\r\n", "AT+SAPBR", 3000, 5) == Success);//關(guān)閉承載，再重新打開
  88.         else errorLog(22);
  89.         delay_ms(100);
  90.    
  91.     if (sendCommand("AT+SAPBR=3,1,\"Contype\",\"GPRS\"\r\n", "OK\r\n", 3000, 2) == Success);
  92.         else errorLog(20);
  93.         delay_ms(100);
  94.    
  95.     if (sendCommand("AT+SAPBR=3,1,\"APN\",\"CMNET\"\r\n", "OK\r\n", 3000, 2) == Success);
  96.         else errorLog(21);
  97.         delay_ms(100);
  98.    
  99.     if (sendCommand("AT+SAPBR=1,1\r\n", "OK\r\n", 3000, 5) == Success);
  100.         else errorLog(22);
  101.         delay_ms(100);
  102.    
  103.     if (sendCommand("AT+SAPBR=2,1\r\n", "OK\r\n", 3000, 3) == Success);
  104.         else errorLog(23);
  105.         delay_ms(100);
  106.    
  107.     if (sendCommand("AT+CLBSCFG=0,3\r\n", "OK\r\n", 3000, 2) == Success);
  108.         else errorLog(24);
  109.         delay_ms(100);


  112.         clrStruct();
  113.         while(1)
  114.         {
  115.                 parseGpsBuffer();
  116.                 printGpsBuffer();
  117.         delay_ms(1000);
  118.         delay_ms(1000);
  119.         delay_ms(1000);
  120.         delay_ms(1000);
  121.         delay_ms(1000);
  122.         }
  123. }

  125. void parseGpsBuffer()
  126. {
  127.         char *subString;
  128.         char *subStringNext;
  129.         char i = 0;
  130.    
  131.     if (sendCommand("AT+CLBS=1,1\r\n", "OK", 15000, 1) == Success)
  132.     {
  133.         printf("**************\r\n");
  134.                 printf(USART2_RX_BUF);
  135.         //+CLBS: 0,113.516557,22.269830,550
  136.         if ((subString = strstr((char *)USART2_RX_BUF, "+CLBS: 0")) != NULL)
  137.         {
  138.             for (i = 0 ; i <= 2 ; i++)
  139.             {
  140.                 if (i == 0)
  141.                 {
  142.                     if ((subString = strstr((char *)subString, ",")) == NULL)
  143.                     {   
  144.                         Save_Data.isUsefull = false;
  145.                         errorLog(1);        //解析錯(cuò)誤
  146.                     }
  147.                 }
  148.                 else
  149.                 {
  150.                     subString++;
  151.                     if ((subStringNext = strstr(subString, ",")) != NULL)
  152.                     {
  153.                         switch(i)
  154.                         {
  155.                             case 1:memcpy(Save_Data.longitude, subString, subStringNext - subString);break;        //獲取經(jīng)度信息
  156.                             case 2:memcpy(Save_Data.latitude, subString, subStringNext - subString);break;        //獲取緯度信息
  157.                             case 3:memcpy(Save_Data.UTCTime, subString, subStringNext - subString);break;        //獲取UTC時(shí)間
  158.                             default:break;
  159.                         }
  160.                         
  161.                         subString = subStringNext;
  162.                     }
  163.                     else
  164.                     {
  165.                         Save_Data.isUsefull = false;
  166.                         errorLog(2);        //解析錯(cuò)誤
  167.                     }
  168.                     Save_Data.isUsefull = true;
  169.                 }


  172.             }
  173.         }else
  174.         {
  175.             Save_Data.isUsefull = false;
  176.             errorLog(25);
  177.         }
  178.         USART2_CLR_Buf();
  179.     }
  180.         else
  181.     {
  182.         Save_Data.isUsefull = false;
  183.         errorLog(25);
  184.     }
  185. }

  187. void printGpsBuffer()
  188. {
  189.                 if(Save_Data.isUsefull)
  190.                 {
  191.                         Save_Data.isUsefull = false;
  192.                         printf("Save_Data.latitude = ");
  193.                         printf(Save_Data.latitude);
  194.                         printf("\r\n");

  196.                         printf("Save_Data.longitude = ");
  197.                         printf(Save_Data.longitude);
  198.                         printf("\r\n");
  199.                        
  200.                         postGpsDataToOneNet(API_KEY, device_id, sensor_gps, Save_Data.longitude, Save_Data.latitude);                //發(fā)送數(shù)據(jù)到Onenet
  201.                        
  202.                         LED1 = 0;
  203.                         delay_ms(100);
  204.                         LED1 = 1;
  205.                 }
  206.                 else
  207.                 {
  208.                         printf("GPS DATA is not usefull!\r\n");
  209.                 }
  210. }

  212. int Digcount(long num)
  213. {
  214.         int i=0;       
  215.         while(num>0)
  216.         {
  217.                 i++;
  218.                 num=num/10;
  219.         }
  220.   return i;
  221. }

  223. char* longitudeToOnenetFormat(char *lon_str_temp)                 //經(jīng)度
  224. {
  225.         unsigned long lon_Onenet = 0;
  226.         unsigned int dd_int = 0;
  227.         unsigned long mm_int = 0;
  228.         float lon_Onenet_double = 0;
  229.         int i = 0;

  231.         unsigned long tempInt = 0;
  232.         unsigned long tempPoint = 0;
  233.         char result[20];
  234.         char point_result[15];
  235.         int pointLength = 0;

  237.         //51單片機(jī)沒有double，double和float，精度不夠，這里只能分開整數(shù)和小數(shù)換算。
  238.         sscanf(lon_str_temp, "%ld.%ld", &tempInt,&tempPoint);
  239.         lon_Onenet = tempInt%100;
  240.         pointLength = strlen(lon_str_temp) - 1 - Digcount(tempInt);               
  241.         for( i = 0 ; i < pointLength ; i++)        //小數(shù)點(diǎn)幾位，整數(shù)部分就放大10的幾次方
  242.         {
  243.                 lon_Onenet *= 10;        
  244.         }

  246.         dd_int = tempInt / 100; //取出dd

  248.         mm_int = lon_Onenet + tempPoint; //取出MM部分

  250.         mm_int = mm_int*10/6;                         //本來是除以60，這里*10/6為了多2位小數(shù)點(diǎn)有有效數(shù)字


  253.            sprintf(result,"%d.",dd_int);
  254.         for( i = 0 ; i < pointLength + 2 - Digcount(mm_int) ; i++)
  255.         {
  256.                 strcat(result, "0");       
  257.         }
  258.         sprintf(point_result,"%ld",mm_int);
  259.         strcat(result, point_result);

  261. //        SendString("\r\n==========ONENET FORMART==========\r\n");
  262. //        SendString(result);
  263.         return result;
  264. }



  268. char* latitudeToOnenetFormat(char *lat_str_temp)                 //緯度
  269. {
  270.         unsigned long lat_Onenet = 0;
  271.         int dd_int = 0;
  272.         unsigned long mm_int = 0;

  274.         int i = 0;

  276.         unsigned long tempInt = 0;
  277.         unsigned long tempPoint = 0;
  278.         char result[20];
  279.         char  point_result[15];
  280.         int pointLength = 0;
  281. //        char xdata debugTest[30];
  282.        
  283.         //51單片機(jī)沒有double，double和float，精度不夠，這里只能分開整數(shù)和小數(shù)換算。
  284.         sscanf(lat_str_temp, "%ld.%ld", &tempInt,&tempPoint);
  285.         lat_Onenet = tempInt%100;
  286.        
  287. //        SendString("\r\n==========ONENET FORMART strlen(lat_str_temp)==========\r\n");
  288. //        sprintf(debugTest,"%d",strlen(lat_str_temp));
  289. //        SendString(debugTest);

  291.         pointLength = strlen(lat_str_temp) - 1 - Digcount(tempInt);       

  293. //        SendString("\r\n==========ONENET FORMART pointLength==========\r\n");
  294. //        sprintf(debugTest,"%d",pointLength);
  295. //        SendString(debugTest);
  296.         for( i = 0 ; i < pointLength ; i++)        //小數(shù)點(diǎn)幾位，整數(shù)部分就放大10的幾次方
  297.         {
  298.                 lat_Onenet *= 10;        
  299.         }

  301. //        SendString("\r\n==========ONENET FORMART tempPoint==========\r\n");
  302. //        sprintf(debugTest,"%ld",tempPoint);
  303. //        SendString(debugTest);
  304. //
  305. //        SendString("\r\n==========ONENET FORMART tempInt==========\r\n");
  306. //        sprintf(debugTest,"%ld",tempInt);
  307. //        SendString(debugTest);
  308. //
  309. //        SendString("\r\n==========ONENET FORMART lat_Onenet==========\r\n");
  310. //        sprintf(debugTest,"%ld",lat_Onenet);
  311. //        SendString(debugTest);

  313.         dd_int = tempInt / 100; //取出dd

  315.         mm_int = lat_Onenet + tempPoint; //取出MM部分

  317.         mm_int = mm_int*10/6;                         //本來是除以60，這里*10/6為了多2位小數(shù)點(diǎn)有有效數(shù)字

  319. //        SendString("\r\n==========ONENET FORMART mm_int==========\r\n");
  320. //        sprintf(debugTest,"%ld",mm_int);
  321. //        SendString(debugTest);

  323.        
  324.         sprintf(result,"%d.",dd_int);
  325.         for( i = 0 ; i < pointLength + 2 - Digcount(mm_int) ; i++)
  326.         {
  327.                 strcat(result, "0");       
  328.         }
  329.         sprintf(point_result,"%ld",mm_int);
  330.         strcat(result, point_result);

  332. //        SendString("\r\n==========ONENET FORMART==========\r\n");
  333. //        SendString(result);
  334.         return result;
  335. }

  337. void postGpsDataToOneNet(char* API_VALUE_temp, char* device_id_temp, char* sensor_id_temp, char* lon_temp, char* lat_temp)
  338. {
  339.         char send_buf[400] = {0};
  340.         char text[200] = {0};
  341.         char tmp[25] = {0};

  343.         char sendCom[2] = {0x1A};

  345. //        dtostrf(longitudeToOnenetFormat(lon_temp), 3, 6, lon_str_end); //轉(zhuǎn)換成字符串輸出
  346. //        dtostrf(latitudeToOnenetFormat(lat_temp), 2, 6, lat_str_end); //轉(zhuǎn)換成字符串輸出

  348. //        lon_temp = "11224.4992";
  349. //        lat_temp = "3438.1633";

  351.         //sprintf(lon_str_end,"%s", longitudeToOnenetFormat(lon_temp));
  352.         //sprintf(lat_str_end,"%s", latitudeToOnenetFormat(lat_temp));

  354.         //連接服務(wù)器
  355.         memset(send_buf, 0, 400);    //清空
  356.         strcpy(send_buf, "AT+CIPSTART=\"TCP\",\"");
  357.         strcat(send_buf, OneNetServer);
  358.         strcat(send_buf, "\",80\r\n");
  359.         if (sendCommand(send_buf, "CONNECT", 10000, 3) == Success);
  360.         else errorLog(7);

  362.         //發(fā)送數(shù)據(jù)
  363.         if (sendCommand("AT+CIPSEND\r\n", ">", 3000, 1) == Success);
  364.         else errorLog(8);

  366.         memset(send_buf, 0, 400);    //清空

  368.         /*準(zhǔn)備JSON串*/
  369.         //ARDUINO平臺(tái)不支持sprintf的double的打印，只能轉(zhuǎn)換到字符串然后打印
  370. //        sprintf(text, "{\"datastreams\":[{\"id\":\"%s\",\"datapoints\":[{\"value\":{\"lon\":%s,\"lat\":%s}}]}]}"
  371. //                , sensor_id_temp, lon_str_end, lat_str_end);
  372.     sprintf(text, "{\"datastreams\":[{\"id\":\"%s\",\"datapoints\":[{\"value\":{\"lon\":%s,\"lat\":%s}}]}]}"
  373.                 , sensor_id_temp, lon_temp, lat_temp);

  375.         /*準(zhǔn)備HTTP報(bào)頭*/
  376.         send_buf[0] = 0;
  377.         strcat(send_buf, "POST /devices/");
  378.         strcat(send_buf, device_id_temp);
  379.         strcat(send_buf, "/datapoints HTTP/1.1\r\n"); //注意后面必須加上\r\n
  380.         strcat(send_buf, "api-key:");
  381.         strcat(send_buf, API_VALUE_temp);
  382.         strcat(send_buf, "\r\n");
  383.         strcat(send_buf, "Host:");
  384.         strcat(send_buf, OneNetServer);
  385.         strcat(send_buf, "\r\n");
  386.         sprintf(tmp, "Content-Length:%d\r\n\r\n", strlen(text)); //計(jì)算JSON串長(zhǎng)度
  387.         strcat(send_buf, tmp);
  388.         strcat(send_buf, text);

  390.         if (sendCommand(send_buf, send_buf, 3000, 1) == Success);
  391.         else errorLog(9);

  393.        
  394.         if (sendCommand(sendCom, "\"succ\"}", 6000, 1) == Success);
  395.         else errorLog(10);

  397.         delay_ms(100);
  398.         if (sendCommand("AT+CIPCLOSE\r\n", "CLOSE OK", 3000, 1) == Success);
  399.         else errorLog(11);
  400.         delay_ms(100);

  402.         if (sendCommand("AT+CIPSHUT\r\n", "SHUT OK", 3000, 1) == Success);
  403.         else errorLog(11);
  404.         delay_ms(100);

  406. }


  409. void sendMessage(char *number,char *msg)
  410. {
  411.         char send_buf[20] = {0};
  412.         memset(send_buf, 0, 20);    //清空
  413.         strcpy(send_buf, "AT+CMGS=\"");
  414.         strcat(send_buf, number);
  415.         strcat(send_buf, "\"\r\n");
  416.         if (sendCommand(send_buf, ">", 3000, 10) == Success);
  417.         else errorLog(6);


  420.         if (sendCommand(msg, msg, 3000, 1) == Success);
  421.         else errorLog(7);
  422.         delay_ms(100);

  424.         memset(send_buf, 0, 100);    //清空
  425.         send_buf[0] = 0x1a;
  426.         if (sendCommand(send_buf, "OK\r\n", 10000, 5) == Success);
  427.         else errorLog(8);
  428.         delay_ms(100);
  429. }

  431. void errorLog(int num)
  432. {
  433.         printf("ERROR%d\r\n",num);
  434.         while (1)
  435.         {
  436.                 if (sendCommand("AT\r\n", "OK", 100, 10) == Success)
  437.                 {
  438.                         Sys_Soft_Reset();
  439.                 }
  440.                 delay_ms(200);
  441. ……………………

  443. …………限于本文篇幅 余下代碼請(qǐng)從51黑下載附件…………
復(fù)制代碼

所有資料51hei提供下載:
OneNet平臺(tái)應(yīng)用資料.7z (798.71 KB, 下載次數(shù): 58)


評(píng)分

參與人數(shù) 1黑幣 +50 收起 理由
admin + 50 共享資料的黑幣獎(jiǎng)勵(lì)！

查看全部評(píng)分

回復(fù)

使用道具 舉報(bào)

ID:193811 發(fā)表于 2019-6-20 22:35 | 顯示全部樓層
為啥那兩個(gè)工程的資料包在keil5里打不開呢？
回復(fù)

使用道具 舉報(bào)

本版積分規(guī)則

手機(jī)版|小黑屋|51黑電子論壇 |51黑電子論壇6群 QQ 管理員QQ:125739409;技術(shù)交流QQ群281945664

Powered by 單片機(jī)教程網(wǎng)

快速回復(fù) 返回頂部 返回列表