芯圣云米WIFI处理&OTA升级 51单片机源程序

[复制链接]
查看1 | 回复0 | 2021-7-6 17:07:51 | 显示全部楼层 |阅读模式
本工程使用了云米的WIFI模块,OTA通过XMODEM协议进行通信
单片机源程序如下:
  1. //================================================================================
  2. #define  ALLOCATE_EXTERN
  3. #include "Include.h"


  4. //================================================================================
  5. void main()
  6. {
  7.     IO_Init();
  8.     SystemInit();
  9.     IO_Init();
  10.     Timer0_Init();
  11.     Uart1_Init();
  12.     EA = 1;

  13.     WDT_INIT();

  14.     Power_Up();

  15.     //LVD_Init();//上电读取完Flash数据再打开低压检测,以免上一次数据未读取出来,就进入掉电而写入正确数据
  16.     RSTFR = 0x00;

  17.     while(1)
  18.     {
  19.         CLR_WDT;

  20.         /* User code */
  21.         Task_Handle();
  22.     }
  23. }
复制代码
  1. #include "Mi_Wifi.h"


  2. //命令
  3. #define COM_NULL            0       //无命令
  4. #define COM_MODEL           1       //发送设备型号
  5. #define COM_VERSION         2       //发送设备版本
  6. #define COM_BLE             3       //发送蓝牙配置
  7. #define COM_GET_DOWN        4       //获取下发指令
  8. #define COM_RESET           5       //发送复位指令
  9. #define COM_CONFIG          6       //发送配网指令
  10. #define COM_TEST            7       //发送产测指令
  11. #define COM_NET             8       //发送网络查询指令
  12. #define COM_GET_TIME        9       //发送获取网络时间指令
  13. #define COM_ACTIVE_UPLOAD   10      //主动上报

  14. #define COM_PASSIVE_UPLOAD  0X81    //被动上报,(查询或设置设置)
  15. #define COM_ERROR           0X82    //错误上报

  16. //串口发送相关变量
  17. u8 xdata Tx_Buf[TX_BUF_LENGTH];     //发送缓冲区
  18. u8 idata Tx_Index;                  //发送索引(中断发送时需要)
  19. u8 idata Tx_En;                     //发送允许状态,1=发送中,0=发送停止


  20. //命令处理相关变量
  21. u8 xdata Rx_Buf[RX_BUF_LENGTH];     //接收数据处理缓冲区
  22. u8 idata Rx_Index;                  //接收索引
  23. u8 idata Rx_Ok;                     //接收完成


  24. //其他变量
  25. u8 xdata Cur_Tx_Com;                //当前发送的命令或数据
  26. u8 xdata Tx_Time;                   //发送循环时间
  27. u8 xdata Resend_Count;              //重发计数
  28. u8 xdata Wifi_Status;               //WIFI网络状态
  29. u8 xdata Wifi_Init_Flag;            //WIFI初始化状态位
  30. u8 xdata Tx_Com_Loop;               //发送命令循环,get_down,net,time


  31. //命令字符串
  32. u8 code Com_Null[] = "null";                        //无指令
  33. u8 code Com_Ble[] = "ble_config set 4529 0005";     //蓝牙配置
  34. u8 code Com_Get_Down[] = "get_down";                //获取下行指令
  35. u8 code Com_Reset[] = "reboot";                     //WIFI重启
  36. u8 code Com_Config[] = "restore";                   //清除WIFI配置信息(配网)
  37. u8 code Com_Test[] = "factory";                     //进入厂测模式
  38. u8 code Com_Net[] = "net";                          //主动获取网络状态(注:该命令即将废弃。获取网络状态变化的更好方法,请见MIIO_net_change)
  39. u8 code Com_Get_Time[] = "time";                    //获取网络时间


  40. //普通字符串
  41. u8 code str_ok[] = "ok";
  42. u8 code str_none[] = "none";
  43. u8 code str_down[] = "down";
  44. u8 code str_get_properties[] = "get_properties";
  45. u8 code str_set_properties[] = "set_properties";
  46. u8 code str_MIIO_net_change[] = "MIIO_net_change";
  47. u8 code str_error[] = "error";
  48. u8 code str_update_fw[] = "update_fw";
  49. u8 code str_result[] = "result";
  50. u8 code str_properties_changed[] = "properties_changed";
  51. u8 code str_result_error[] = "result "error"";


  52. //网络状态
  53. u8 code str_unprov[] = "unprov";        //未配置
  54. u8 code str_offline[] = "offline";      //离线
  55. u8 code str_local[] = "local";          //本地链接
  56. u8 code str_cloud[] = "cloud";          //连上云
  57. u8 code str_updating[] = "updating";    //升级中
  58. u8 code str_uap[] = "uap";              //UAP模式


  59. //命令表,方便发送命令
  60. u8 code * code Com_Table[] =
  61. {
  62.     Com_Null,       //下标0
  63.     Com_Model,      //下标1
  64.     Com_Version,    //下标2
  65.     Com_Ble,        //下标3
  66.     Com_Get_Down,   //下标4
  67.     Com_Reset,      //下标5
  68.     Com_Config,     //下标6
  69.     Com_Test,       //下标7
  70.     Com_Net,        //下标8
  71.     Com_Get_Time,   //下标9
  72. };


  73. //串口TX中调内调用
  74. void Uart_Tx()
  75. {
  76.     if(Tx_En == 0)
  77.     {
  78.         return;
  79.     }
  80.    
  81.     SBUF = Tx_Buf[Tx_Index];
  82.    
  83.     //判断发送结束,不作越界判断,自行把握发送数据长度
  84.     if(Tx_Buf[Tx_Index] == '\r')
  85.     {
  86.         Tx_En = 0;
  87.     }
  88.     Tx_Index++;
  89. }


  90. //串口RX中断内调用,因为是一问一答通信方式,所以使用这种方式接收
  91. void Uart_Rx(u8 Data)
  92. {
  93.     if(Rx_Ok)
  94.     {
  95.         return ;
  96.     }
  97.    
  98.     Rx_Buf[Rx_Index] = Data;//保存数据
  99.     Rx_Index++;

  100.     //防止溢出,主动在接收缓冲区添加添加'\r'以结束接收,(一般不会出现此情况)
  101.     if(Rx_Index == RX_BUF_LENGTH)
  102.     {
  103.         Rx_Buf[RX_BUF_LENGTH - 1] = '\r';
  104.     }

  105.     //判断帧接收完成(数据帧以字符'\r'结尾)
  106.     if(Rx_Buf[Rx_Index - 1] == '\r')
  107.     {
  108.         Rx_Ok = 1;
  109.     }
  110. }


  111. //wifi配置,需要时调用
  112. void Wifi_Config(u8 Config)
  113. {
  114.     switch(Config)
  115.     {
  116.         case WIFI_CONFIG_NET:
  117.             Wifi_Init_Flag |= 0x08;//进入配网
  118.             break;
  119.         case WIFI_CONFIG_TEST:
  120.             Wifi_Init_Flag |= 0x04;//进入产测
  121.             break;
  122.         case WIFI_CONFIG_RESET:
  123.             Wifi_Init_Flag |= 0x10;//复位
  124.             break;
  125.         default:
  126.             break;
  127.     }
  128. }



  129. //启动发送,利用串口发送中断发送,提高CPU使用率
  130. void Begin_Send()
  131. {
  132.     Tx_Time = 11;//重置发送间隔时间n*10 ms
  133.     Tx_En = 1;//置位发送中
  134.     Tx_Index = 0;//清除发送索引
  135.     TI = 1;//人为设置跳入中断,以启动发送
  136. }


  137. //布尔,整形,浮点值填充
  138. u8 Value_Fill(u8 xdata * data Tx_Ptr, Upload_Down data * data St_Temp)
  139. {
  140.     if(St_Temp->Type == TYPE_BOOL)
  141.     {
  142.         //布尔类型数据填充上报
  143.         if(St_Temp->Value.Long_Data)
  144.         {
  145.             return sprintf(Tx_Ptr, " true");
  146.         }
  147.         else
  148.         {
  149.             return sprintf(Tx_Ptr, " false");
  150.         }
  151.     }
  152.     else if(St_Temp->Type == TYPE_INT)
  153.     {
  154.         //整形数据填充上报
  155.         return sprintf(Tx_Ptr, " %lu", St_Temp->Value.Long_Data);
  156.     }

  157.     //浮点数据填充上报
  158.     return sprintf(Tx_Ptr, " %g", St_Temp->Value.Float_Data);
  159. }


  160. //下发,查询属性处理,填写发送数据时,自行把握发送长度,否则缓冲区溢出
  161. void Attribute_Handle(u8 Oper, Upload_Down data * data St_Temp, u8 xdata * data Str)
  162. {
  163.     u8 i;
  164.     u8 xdata * data Tx_Ptr = &Tx_Buf;

  165.     WIFI_DEBUG_OUT();//功能测试时使用,挂逻辑分析仪,看什么时候接收到数据,处理后返回什么数据,正常工程可屏蔽
  166.     St_Temp->Siid = 0;
  167.     St_Temp->Piid = 0;
  168.     Tx_Ptr += sprintf(Tx_Ptr, str_result);

  169.     while(*Str != '\r')//判断字符串结束
  170.     {
  171.         //查找字符' '(空格)
  172.         if(*Str == ' ')
  173.         {
  174.             if(St_Temp->Siid == 0)
  175.             {
  176.                 St_Temp->Siid = atol(Str);
  177.                 Str++;
  178.                 continue;
  179.             }

  180.             if(St_Temp->Piid == 0)
  181.             {
  182.                 St_Temp->Piid = atol(Str);
  183.                 Str++;

  184.                 //设置字符串 down set_proterties 2 1 true\r
  185.                 //获取字符串 down set_proterties 2 1\r
  186.                 //设置值时2 1后面会有' '+参数,所以需要返回重新查找' ',而获取值时2 1结束,所以不能再返回查找' ',而是直接去处理
  187.                 if(Oper == SET_VALUE)
  188.                 {
  189.                     continue;
  190.                 }
  191.             }

  192.             St_Temp->Error = 0;//清除错误

  193.             //遍历回调函数表,查找正确的处理函数
  194.             i = 0;

  195.             while(1)
  196.             {
  197.                 if(Wifi_Handle_Table[i] == 0)//判断回调函数表结束
  198.                 {
  199.                     i = 0xff;
  200.                     break;//查找不到处理函数返回
  201.                 }

  202.                 if(Wifi_Handle_Table[i](Oper, St_Temp, Str + 1)) //回调函数调用
  203.                 {
  204.                     break;//正确处理后返回
  205.                 }

  206.                 i++;//指向下一个功能处理函数
  207.             }

  208.             Tx_Ptr += sprintf(Tx_Ptr, " %bu %bu", St_Temp->Siid, St_Temp->Piid); //填充SIID PIID

  209.             if(i == 0xff)
  210.             {
  211.                 //无此属性上报,格式:result siid piid -4003
  212.                 Tx_Ptr += sprintf(Tx_Ptr, " -4003");
  213.             }
  214.             else
  215.             {
  216.                 //查询,成功格式:result siid piid 0 value   失败格式:result siid piid code(错误码)
  217.                 //下发,成功格式:result siid piid 0         失败格式:result siid piid code(错误码)
  218.                 Tx_Ptr += sprintf(Tx_Ptr, " %d", (s16)St_Temp->Error);//错误码填写

  219.                 if(Oper == GET_VALUE)
  220.                 {
  221.                     Tx_Ptr += Value_Fill(Tx_Ptr,St_Temp);//布尔,整形,浮点值填充
  222.                 }
  223.             }

  224.             //清除以重新获取SIID PIID
  225.             St_Temp->Siid = 0;
  226.             St_Temp->Piid = 0;
  227.         }

  228.         Str++;//指向下一个字符
  229.     }

  230.     Cur_Tx_Com = COM_PASSIVE_UPLOAD;//被动上报
  231.     Resend_Count = 0;//重发计数清零
  232.     *Tx_Ptr = '\r';//协议结束符
  233.     Begin_Send();
  234. }


  235. //主动上报处理,填写发送数据时,自行把握发送长度,否则缓冲区溢出
  236. void Upload_Handle()
  237. {
  238.     u8 i = 0;
  239.     u8 Tx = 0;
  240.     Upload_Down St_Temp;
  241.     u8 xdata * data Tx_Ptr = &Tx_Buf;

  242.     while(1)
  243.     {
  244.         if(Wifi_Handle_Table[i] == 0x00)//判断回调函数表结束
  245.         {
  246.             break;
  247.         }

  248.         if(Wifi_Handle_Table[i](SCAN_VALUE, &St_Temp, 0x00))//回调函数调用
  249.         {
  250.             //主动上报格式:properties_changed siid piid value
  251.             if(Tx == 0)
  252.             {
  253.                 Tx = 1;
  254.                 Tx_Ptr += sprintf(Tx_Ptr, str_properties_changed); //填充properties_changed
  255.             }

  256.             Tx_Ptr += sprintf(Tx_Ptr, " %bu %bu", St_Temp.Siid, St_Temp.Piid); //填充SIID PIID
  257.             Tx_Ptr += Value_Fill(Tx_Ptr,&St_Temp);//布尔,整形,浮点值填充
  258.         }

  259.         i++;//指向下一个功能处理函数
  260.     }

  261.     if(Tx == 0)
  262.     {
  263.         return ;//无填充数据不进行数据发送
  264.     }

  265.     Cur_Tx_Com = COM_ACTIVE_UPLOAD;//主动上报
  266.     Resend_Count = 0;//重发计数清零
  267.     *Tx_Ptr = '\r';//协议结束符
  268.     Begin_Send();//启动发送
  269. }





  270. //WIFI状态处理
  271. void Wifi_Status_Handle(u8 xdata * data String)
  272. {
  273.     if(My_Strcmp(String, str_cloud, 5))
  274.     {
  275.         //连接上服务器
  276.         Wifi_Status = NET_CLOUD;
  277.     }
  278.     else if(My_Strcmp(String, str_local, 5))
  279.     {
  280.         //本地连接
  281.         Wifi_Status = NET_LOCAL;
  282.     }
  283.     else if(My_Strcmp(String, str_unprov, 6))
  284.     {
  285.         //未配置
  286.         Wifi_Status = NET_UNPROV;
  287.     }
  288.     else if(My_Strcmp(String, str_offline, 7))
  289.     {
  290.         //离线
  291.         Wifi_Status = NET_OFFLINE;
  292.     }
  293.     else if(My_Strcmp(String, str_uap, 3))
  294.     {
  295.         //UAP模式
  296.         Wifi_Status = NET_UAP;
  297.     }
  298.     else if(My_Strcmp(String, str_updating, 8))
  299.     {
  300.         //升级中
  301.         Wifi_Status = NET_UPDATEING;
  302.     }
  303. }


  304. //WIFI下发指令处理
  305. void Rx_Handle()
  306. {
  307.     Upload_Down St_Temp;

  308.     u8 xdata * data Str = Rx_Buf;

  309.     //Tx_Time = 0;//接收到回复后可以立即发送下一次数据,不管回复的是什么,,,正常使用没问题,但使用固件协议检测会失败,限制get_down指令间隔时间需要大于100ms

  310.     if(My_Strcmp(Str, str_ok, 2))
  311.     {
  312.         switch(Cur_Tx_Com)
  313.         {
  314.             case COM_MODEL:
  315.                 Wifi_Init_Flag |= 0x80;//model
  316.                 break;

  317.             case COM_VERSION:
  318.                 Wifi_Init_Flag |= 0x40;//版本应答
  319.                 break;

  320.             case COM_BLE:
  321.                 Wifi_Init_Flag |= 0x20;//蓝牙应答
  322.                 break;

  323.             case COM_RESET:
  324.                 Wifi_Init_Flag &= ~0x10;//复位应答
  325.                 break;

  326.             case COM_CONFIG:
  327.                 Wifi_Init_Flag &= ~0x08;//配网应答
  328.                 break;

  329.             case COM_TEST:
  330.                 Wifi_Init_Flag &= ~0x04;//测试应答
  331.                 break;
  332.         }

  333.         Cur_Tx_Com = COM_NULL;//清除当前发送命令
  334.     }
  335.     else if(My_Strcmp(Str, str_down, 4))
  336.     {
  337.         //下发命令解析
  338.         Cur_Tx_Com = COM_NULL;

  339.         Str += 5;//跳过"down "

  340.         if(My_Strcmp(Str, str_none, 4))
  341.         {
  342.             //无指令
  343.         }
  344.         else if(My_Strcmp(Str, str_update_fw, 9))
  345.         {
  346.             //进入升级模式
  347.             To_Update();
  348.         }
  349.         else if(My_Strcmp(Str, str_set_properties, 14))
  350.         {
  351.             //设置属性
  352.             Str += 14;//跳过"set_properties "
  353.             Attribute_Handle(SET_VALUE, &St_Temp, Str);
  354.         }
  355.         else if(My_Strcmp(Str, str_get_properties, 14))
  356.         {
  357.             //获取属性
  358.             Str += 14;//跳过"get_properties"
  359.             Attribute_Handle(GET_VALUE, &St_Temp, Str);
  360.         }
  361.         else if(My_Strcmp(Str, str_MIIO_net_change, 15))
  362.         {
  363.             //被动获取网络状态
  364.             Wifi_Status_Handle(&Rx_Buf[21]);
  365.         }
  366.         else
  367.         {
  368.             //错误
  369.             Cur_Tx_Com = COM_ERROR;//发送错误命令
  370.             Resend_Count = 0;//重发计数清零
  371.             sprintf (&Tx_Buf, "%s\r", str_result_error);
  372.             Begin_Send();//启动发送
  373.         }
  374.     }
  375.     else if(My_Strcmp(Str, str_error, 5))
  376.     {
  377.         if(Cur_Tx_Com == COM_BLE)
  378.         {
  379.             Wifi_Init_Flag |= 0x04;//蓝牙配置错误或WIFI单模跳过蓝牙配置
  380.         }
  381.     }
  382.     else if(Cur_Tx_Com == COM_NET)
  383.     {
  384.         //主动获取网络状态
  385.         Cur_Tx_Com = COM_NULL;//清除当前发送命令
  386.         Wifi_Status_Handle(Str);
  387.     }
  388.     else if(Cur_Tx_Com == COM_GET_TIME)
  389.     {
  390.         //主动获取当前时间(一般不需要处理,如果有北京时间显示或其他依赖网络时间的应用时才需处理)
  391.         Cur_Tx_Com = COM_NULL;//清除当前发送命令
  392.     }
  393. }


  394. //WIFI服务程序--10毫秒调用一次
  395. void Wifi_Service()
  396. {
  397.     if(Rx_Ok)
  398.     {
  399.         Rx_Handle();//调用处理
  400.         Rx_Index = 0;
  401.         Rx_Ok = 0;
  402.     }

  403.     //发送间隔时间控制
  404.     if(Tx_Time)
  405.     {
  406.         Tx_Time--;
  407.         return;
  408.     }

  409.     Tx_Com_Loop++;//循环

  410.     //重发次数控制,
  411.     if(Resend_Count >= 10)
  412.     {
  413.         Cur_Tx_Com = COM_NULL;//重发n次无响应后清除
  414.     }

  415.     if(Cur_Tx_Com != COM_NULL)
  416.     {
  417.         Resend_Count++;//重发计数增加
  418.         Begin_Send();//直接重发Tx_Buf内的数据
  419.         return ;
  420.     }

  421.     //发送相关信息
  422.     if((Wifi_Init_Flag & 0x80) == 0)
  423.     {
  424.         Cur_Tx_Com = COM_MODEL;//发送设备MODEL
  425.     }
  426.     else if((Wifi_Init_Flag & 0x40) == 0)
  427.     {
  428.         Cur_Tx_Com = COM_VERSION;//发送程序版本号
  429.     }
  430.     else if((Wifi_Init_Flag & 0x20) == 0)
  431.     {
  432.         Cur_Tx_Com = COM_BLE;//发送ble相关
  433.     }
  434.     else if(Wifi_Init_Flag & 0x10)
  435.     {
  436.         Cur_Tx_Com = COM_RESET;//发送复位
  437.     }
  438.     else if(Wifi_Init_Flag & 0x08)
  439.     {
  440.         Cur_Tx_Com = COM_CONFIG;//发送WIFI重置,进入配网模式
  441.     }
  442.     else if(Wifi_Init_Flag & 0x04)
  443.     {
  444.         Cur_Tx_Com = COM_TEST;//发送WIFI进入产测模式
  445.     }
  446.     else if(Tx_Com_Loop >= 10)
  447.     {
  448.         Tx_Com_Loop = 0;
  449.         Cur_Tx_Com = COM_NET;//主动获取网络状态
  450.     }
  451.     else if(Tx_Com_Loop == 5)
  452.     {
  453.         Cur_Tx_Com = COM_GET_TIME;//获取时间
  454.     }
  455.     else
  456.     {
  457.         Cur_Tx_Com = COM_GET_DOWN;
  458.         //检测数据变化并上报数据,连接上网络才检测(连接上本地或者网络)
  459.         if((Wifi_Status == NET_LOCAL) || (Wifi_Status == NET_CLOUD))
  460.         {
  461.             Upload_Handle();//调用后如果需要主动上报数据的话,Cur_Tx_Com的值应该是COM_ACTIVE_UPLOAD,并且数据已经填充进发送缓冲区了
  462.         }
  463.     }
  464.    
  465.     Resend_Count = 0;//重发计数清零
  466.     if(Cur_Tx_Com == COM_ACTIVE_UPLOAD)
  467.     {
  468.         Begin_Send();//启动发送
  469.         return;
  470.     }
  471.     sprintf(&Tx_Buf, "%s\r", Com_Table[Cur_Tx_Com]);//填充指令
  472.     Begin_Send();//启动发送
  473. }
复制代码
HC89F3541(BOOTLOAD部分).7z (54.02 KB, 售价: 1 工控币) HC89F3541-20210702(APP部分).7z (150.46 KB, 售价: 1 工控币)
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 注册

本版积分规则