最近浏览的板块
搜索
返回列表 发新帖我要提问

[RT-Thread作品秀] 基于RT-Thread和腾讯云Iot平台的智能停车平台

[复制链接]
1996|3
cszzlsw
 楼主 | 2020-7-12 22:28 | 显示全部楼层 |阅读模式
[#] [#]
RT-Thread, IOT, 腾讯云, 智能停车, TI
本帖最后由 cszzlsw 于 2020-7-13 22:56 编辑
项目背景:
都说科技改变生活,今天来聊的这个作品可以真实的改变生活相信有车的朋友最头疼的莫过于停车问题,其他小城市还好,像深圳这样的大城市,停车问题一直困扰着有车一族:- 不知道哪里有车位可以停- 好不容易找到停车场因为方向错误或者技术不好车位被别人占了- 随意停路边容易吃罚单对于其他地方,停车场多于车辆的,停车场主面临收入问题:- 怎么让更多的车停到我这里增加收入- 我的停车场到底收入如何,如何简化做账流程- 我新建了一个停车场怎么让别人知道呢...基于以上几个痛点本人设计了一款基于腾讯云以及RT-Thread实时系统打造的智能停车平台,依靠智能车位锁,智能抬杆,以及平台的管理能力,解决以上几个生活中的问题,并具有一定及广阔的商业价值
作品构成:
作品由设备,服务器及小程序组成:
  • 设备:设备采用雅特力ATF403A高性能MCU搭载TRT-Thread系统,实现云服务及外围设备搭建,支持本地控制和远程控制双通道
  • 服务器:服务器有云开发和本地服务器,本地服务器采用Go语言+MongoDB,开发快速高效
  • 小程序:微信小程序有用户端和商家端两种界面展示,真正构成平台的作用,商家发布停车场,用户使用停车场
具体系统框架图可以看下图:

智能停车平台架构设计图

项目商业价值:
  • 解决传统停车场停车难问题:传统停车场用户停车凭运气,有了预约平台线上查看附近哪里有停车场和车位后提前预约好车位,由于有车位锁的加持别人没法抢占,用户也不用兜兜转转找停车位浪费时间,随意停在路边还有爱车被破坏或者罚款等风险
  • 帮助商家更好的管理:传统停车场依靠人力手动管理,现在依靠平台的能力商家可以随时随地进行管理,并且根据后台数据商家可以灵活调整自己的宣传,收费策略,
  • 设备厂家新出路:传统的设备厂家靠卖产品盈利,新型停车平台厂家可以依靠服务,比如免费给商家安装设备,然后从停车收益中进行抽成来进行二次获利
商业价值展望:
  • 增加盈利:商家可以跟周围其他品类商家合作,比如小吃,车行,休闲场所合作推广,比如用户停好车后可以在小程序上发布某些吃喝玩乐的信息,用户通过推荐的链接进行消费商家会有分成
  • 构建生态:从停车平台出发,可以构建关于车相关的一系列生态,比如车辆美容,汽车保养,买车建议等等内容,打造汽车业内生态圈


具体实现:
设备端:
设备端采用RT-Thread驱动,利用SDK里的demo程序可以快速上云,代码片段如下:
关于上云部分可以参考本人以前的帖子:https://bbs.21ic.com/icview-2966620-1-1,https://bbs.21ic.com/icview-2966932-1-1.html
系统启动,上云:


  2. static void data_template_light_thread(void)
  3. {  
  4.         DeviceProperty *pReportDataList[TOTAL_PROPERTY_COUNT];
  5.         int ReportCont;
  6.         Timer reportTimer;
  7.         int rc;
  8.         sReplyPara      replyPara;

  10.     //init connection
  11.     TemplateInitParams init_params = DEFAULT_TEMPLATE_INIT_PARAMS;
  12.     rc = _setup_connect_init_params(&init_params);
  13.     if (rc != QCLOUD_RET_SUCCESS) {
  14.                 Log_e("init params err,rc=%d", rc);
  15.                 return ;
  16.         }

  18.     void *client = IOT_Template_Construct(&init_params, NULL);
  19.     if (client != NULL) {
  20.         Log_i("Cloud Device Construct Success");
  21.     } else {
  22.         Log_e("Cloud Device Construct Failed");
  23.         return;
  24.     }

  26.     //init data template
  27.     _init_data_template();

  29. #ifdef EVENT_POST_ENABLED
  30.         rc = IOT_Event_Init(client);
  31.         if (rc < 0)
  32.         {
  33.                 Log_e("event init failed: %d", rc);
  34.                 return ;
  35.         }
  36. #endif
  37.         
  38.         

  40.     //register data template propertys here
  41.     rc = _register_data_template_property(client);
  42.     if (rc == QCLOUD_RET_SUCCESS) {
  43.         Log_i("Register data template propertys Success");
  44.     } else {
  45.         Log_e("Register data template propertys Failed: %d", rc);
  46.         return ;
  47.     }
  48.         
  49.                 //register data template actions here
  50. #ifdef ACTION_ENABLED
  51.     rc = _register_data_template_action(client);
  52.     if (rc == QCLOUD_RET_SUCCESS) {
  53.         Log_i("Register data template actions Success");
  54.     } else {
  55.         Log_e("Register data template actions Failed: %d", rc);
  56.         return ;
  57.     }
  58. #endif

  60.         //鍚屾绂荤嚎鏁版嵁
  61.         rc = IOT_Template_GetStatus_sync(client, QCLOUD_IOT_MQTT_COMMAND_TIMEOUT);
  62.         if (rc != QCLOUD_RET_SUCCESS) {
  63.                 Log_e("get device shadow failed, err: %d", rc);
  64.                 return;
  65.         }

  67.         //灞炴€у畾鏃朵笂鎶imer锛屽彲浠ユ牴鎹笟鍔￠渶瑕佽鍓€?        InitTimer(&reportTimer);
  68.         running_state = 1;
  69.     while (IOT_Template_IsConnected(client) || rc == QCLOUD_ERR_MQTT_ATTEMPTING_RECONNECT
  70.                 || rc == QCLOUD_RET_MQTT_RECONNECTED || QCLOUD_RET_SUCCESS == rc) {

  72.                 if(0 == running_state)
  73.                 {
  74.                         break;
  75.                 }
  76.                
  77.         rc = IOT_Template_Yield(client, 2000);

  79.         if (rc == QCLOUD_ERR_MQTT_ATTEMPTING_RECONNECT) {
  80.             HAL_SleepMs(1000);
  81.             continue;
  82.         }
  83.                 else if (rc != QCLOUD_RET_SUCCESS) {
  84.                         Log_e("Exit loop caused of errCode: %d", rc);
  85.                 }


  88.                 /*鏈嶅姟绔笅琛屾秷鎭紝涓氬姟澶勭悊閫昏緫1鍏ュ彛*/
  89.                 if (sg_delta_arrived) {                                                                                                        

  91.                         deal_down_stream_user_logic(&sg_ProductData);
  92.                         
  93.                         /*涓氬姟閫昏緫澶勭悊瀹屽悗闇€瑕佸悓姝ラ€氱煡鏈嶅姟绔?璁惧鏁版嵁宸叉洿鏂帮紝鍒犻櫎dseire鏁版嵁*/        
  94.                          memset((char *)&replyPara, 0, sizeof(sReplyPara));
  95.             replyPara.code          = eDEAL_SUCCESS;
  96.             replyPara.timeout_ms    = QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;
  97.             replyPara.status_msg[0] = '\0';  // add extra info to replyPara.status_msg when error occured

  99.             rc = IOT_Template_ControlReply(client, sg_data_report_buffer, sg_data_report_buffersize, &replyPara);
  100.             if (rc == QCLOUD_RET_SUCCESS) {
  101.              //   rc = IOT_Shadow_Update_Sync(client, sg_data_report_buffer, sg_data_report_buffersize, QCLOUD_IOT_MQTT_COMMAND_TIMEOUT);
  102.                 sg_delta_arrived = false;
  103. //                if (rc == QCLOUD_RET_SUCCESS) {
  104. //                    Log_i("shadow update(desired) success");
  105. //                } else {
  106. //                    Log_e("shadow update(desired) failed, err: %d", rc);
  107. //                }

  109.             } else {
  110.                 Log_e("construct desire failed, err: %d", rc);
  111.             }        

  113.                 }        else{
  114.                         //Log_d("No delta msg received...");
  115.                 }

  117.                 /*璁惧涓婅娑堟伅,涓氬姟閫昏緫2鍏ュ彛*/
  118.                 /*delta娑堟伅鏄睘鎬х殑desire鍜屽睘鎬х殑report鐨勫樊寮傞泦锛屾敹鍒癲eseire娑堟伅澶勭悊鍚庯紝瑕乺eport灞炴€х殑鐘舵€?/
  119.                 if(QCLOUD_RET_SUCCESS == deal_up_stream_user_logic(pReportDataList, &ReportCont)){
  120.                         Log_d("report:%s",sg_data_report_buffer);
  121.                          rc = IOT_Template_JSON_ConstructReportArray(client, sg_data_report_buffer, sg_data_report_buffersize,
  122.                                                         ReportCont, pReportDataList);
  123.                 if (rc == QCLOUD_RET_SUCCESS) {
  124.                      rc = IOT_Template_Report(client, sg_data_report_buffer, sg_data_report_buffersize,
  125.                                          OnReportReplyCallback, NULL, QCLOUD_IOT_MQTT_COMMAND_TIMEOUT);
  126.                     if (rc == QCLOUD_RET_SUCCESS) {
  127.                         Log_i("IOT_Template_Report success");
  128.                     } else {
  129.                         Log_e("IOT_Template_Report failed, err: %d", rc);
  130.                     }
  131.                 } else {
  132.                     Log_e("construct reported failed, err: %d", rc);
  133.                 }

  135.                 }else{
  136.                          Log_d("no data need to be reported");
  137.                         ReportCont = TOTAL_PROPERTY_COUNT;
  138.                 }
  139.         
  140.                 /*cycle report, just for example*/
  141.                 if(QCLOUD_RET_SUCCESS == cycle_report(pReportDataList, &reportTimer)){                                
  142.                          rc = IOT_Template_JSON_ConstructReportArray(client, sg_data_report_buffer, sg_data_report_buffersize,
  143.                                                         ReportCont, pReportDataList);
  144.                 if (rc == QCLOUD_RET_SUCCESS) {
  145.                      rc = IOT_Template_Report(client, sg_data_report_buffer, sg_data_report_buffersize,
  146.                                          OnReportReplyCallback, NULL, QCLOUD_IOT_MQTT_COMMAND_TIMEOUT);
  147.                     if (rc == QCLOUD_RET_SUCCESS) {
  148.                         Log_i("IOT_Template_Report success");
  149.                     } else {
  150.                         Log_e("IOT_Template_Report failed, err: %d", rc);
  151.                     }
  152.                 } else {
  153.                     Log_e("construct reported failed, err: %d", rc);
  154.                 }

  156.                 }

  158. #ifdef EVENT_POST_ENABLED        
  159.         
  160.                 extern int32_t g_temp;

  162.                 sg_ProductData.m_temp = g_temp;
  163.                 sg_temp = g_temp;
  164.                 IOT_Event_setFlag(client,FLAG_EVENT0);
  165.                
  166.                 eventPostCheck(client);
  167. #endif
  168.                
  169.         HAL_SleepMs(5000);
  170.     }

  172.     rc = IOT_Template_Destroy(client);
  173.         running_state = 0;
  174.         Log_e("Something goes wrong or stoped");  
  175.         //rt_thread_delete(rt_thread_self());

  177.     return ;
  178. }

  180. static int tc_data_template_light_example(int argc, char **argv)
  181. {
  182.     rt_thread_t tid;
  183.     int stack_size = DATA_TEMPLATE_LIGHT_THREAD_STACK_SIZE;
  184.         
  185.     //init log level
  186.         IOT_Log_Set_Level(eLOG_DEBUG);
  187.         
  188.         if (2 == argc)
  189.         {
  190.                 if (!strcmp("start", argv[1]))
  191.                 {
  192.                         if (1 == running_state)
  193.                         {
  194.                                 Log_d("tc_data_template_light_example is already running\n");
  195.                                 return 0;
  196.                         }                        
  197.                 }
  198.                 else if (!strcmp("stop", argv[1]))
  199.                 {
  200.                         if (0 == running_state)
  201.                         {
  202.                                 Log_d("tc_data_template_light_example is already stopped\n");
  203.                                 return 0;
  204.                         }
  205.                         running_state = 0;
  206.                         return 0;
  207.                 }
  208.                 else
  209.                 {
  210.                         Log_d("Usage: tc_data_template_light_example start/stop");
  211.                         return 0;                          
  212.                 }
  213.         }
  214.         else
  215.         {
  216.                 Log_e("Para err, usage: tc_data_template_light_example start/stop");
  217.                 return 0;
  218.         }
  219.          
  220.         tid = rt_thread_create("data_template_light", (void (*)(void *))data_template_light_thread,
  221.                                                         NULL, stack_size, RT_THREAD_PRIORITY_MAX / 2 - 1, 10);  

  223.     if (tid != RT_NULL)
  224.     {
  225.         rt_thread_startup(tid);
  226.     }

  228.     return 0;
  229. }
复制代码

下发指令操作设备行为:

  2. static void OnControlLockActionCallback(void *pClient, const char *pClientToken, DeviceAction *pAction){
  3.         int i;
  4.         sReplyPara replyPara;
  5.         printf("__%s__\n",__func__);

  7.         //do something base on input, just print as an sample
  8.         DeviceProperty *pActionInput = pAction->pInput;
  9.         for (i = 0; i < pAction->input_num; i++) {
  10.                 if (JSTRING == pActionInput[i].type) {
  11.                         Log_i("Input:[%s], data:[%s]",  pActionInput[i].key, pActionInput[i].data);
  12.                         HAL_Free(pActionInput[i].data);
  13.                 } else {
  14.                         if(JINT32 == pActionInput[i].type) {
  15.                                 Log_i("Input:[%s], data:[%d]",  pActionInput[i].key, *((int*)pActionInput[i].data));
  16.                         } else if( JFLOAT == pActionInput[i].type) {
  17.                                 Log_i("Input:[%s], data:[%f]",  pActionInput[i].key, *((float*)pActionInput[i].data));
  18.                         } else if( JUINT32 == pActionInput[i].type) {
  19.                                 Log_i("Input:[%s], data:[%u]",  pActionInput[i].key, *((uint32_t*)pActionInput[i].data));
  20.                         }
  21.                 }
  22.                
  23.         //        sg_action_msg_arrived = true;
  24.         }

  26.         // construct output
  27.         memset((char *)&replyPara, 0, sizeof(sReplyPara));
  28.         replyPara.code = eDEAL_SUCCESS;
  29.         replyPara.timeout_ms = QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;
  30.         strcpy(replyPara.status_msg, "action execute success!"); //add the message about the action resault


  33.         DeviceProperty *pActionOutnput = pAction->pOutput;
  34.         //(void)pActionOutnput; //elimate warning
  35.         //TO DO: add your aciont logic here and set output properties which will be reported by action_reply
  36. //        pole *p=getPole();
  37. //        if(p == NULL){
  38. //                sg_control_pole_out_result = 1;
  39. //        }
  40.         
  41.         int road=*(int *)(pActionInput[0].data);
  42.         int direction=*(int *)(pActionInput[1].data);
  43.         printf("control %dth lock direction=%s\n",road,direction?"up":"down");
  44.         
  45.         lock *l=getLock(road);
  46.         printf("get lock  %p\n",l);
  47.         if(l == NULL){
  48.                
  49.                 sg_control_lock_out_result = 1;
  50.         }

  52.         IOT_ACTION_REPLY(pClient, pClientToken, sg_data_report_buffer, sg_data_report_buffersize, pAction, &replyPara);
  53. //        DeviceProperty *actionInput_control_pole=&pAction->pInput[0];
  54. //        int direction=*(int *)actionInput_control_pole->data;
  55. //        printf("control pole direction=%s\n",direction?"up":"down");
  56.         
  57.         
  58. //        if(p){
  59. //                poleAction(direction,p);
  60. //        }
  61.         if(l){
  62.                 lockAction(direction,l);
  63.         }
  64.         //smotor_start(direction);
  65. }

  67. static void OnControlPoleActionCallback(void *pClient, const char *pClientToken, DeviceAction *pAction)
  68. {
  69.         int i;
  70.         sReplyPara replyPara;
  71.         printf("__%s__\n",__func__);

  73.         //do something base on input, just print as an sample
  74.         DeviceProperty *pActionInput = pAction->pInput;
  75.         for (i = 0; i < pAction->input_num; i++) {
  76.                 if (JSTRING == pActionInput[i].type) {
  77.                         Log_i("Input:[%s], data:[%s]",  pActionInput[i].key, pActionInput[i].data);
  78.                         HAL_Free(pActionInput[i].data);
  79.                 } else {
  80.                         if(JINT32 == pActionInput[i].type) {
  81.                                 Log_i("Input:[%s], data:[%d]",  pActionInput[i].key, *((int*)pActionInput[i].data));
  82.                         } else if( JFLOAT == pActionInput[i].type) {
  83.                                 Log_i("Input:[%s], data:[%f]",  pActionInput[i].key, *((float*)pActionInput[i].data));
  84.                         } else if( JUINT32 == pActionInput[i].type) {
  85.                                 Log_i("Input:[%s], data:[%u]",  pActionInput[i].key, *((uint32_t*)pActionInput[i].data));
  86.                         }
  87.                 }
  88.                
  89.         //        sg_action_msg_arrived = true;
  90.         }

  92.         // construct output
  93.         memset((char *)&replyPara, 0, sizeof(sReplyPara));
  94.         replyPara.code = eDEAL_SUCCESS;
  95.         replyPara.timeout_ms = QCLOUD_IOT_MQTT_COMMAND_TIMEOUT;
  96.         strcpy(replyPara.status_msg, "action execute success!"); //add the message about the action resault


  99.         DeviceProperty *pActionOutnput = pAction->pOutput;
  100.         //(void)pActionOutnput; //elimate warning
  101.         //TO DO: add your aciont logic here and set output properties which will be reported by action_reply
  102.         
  103.         pole *p=getPole();
  104.         printf("get pole  %p\n",p);
  105.         if(p == NULL){
  106.                 sg_control_pole_out_result = 1;
  107.         }
  108.         


  111.         IOT_ACTION_REPLY(pClient, pClientToken, sg_data_report_buffer, sg_data_report_buffersize, pAction, &replyPara);
  112.         DeviceProperty *actionInput_control_pole=&pAction->pInput[0];
  113.         int direction=*(int *)actionInput_control_pole->data;
  114.         printf("control pole direction=%s\n",direction?"up":"down");
  115.         
  116.         
  117.         if(p){
  118.                 poleAction(direction,p);
  119.         }

  121.         //smotor_start(direction);
  122.         
  123. }
复制代码


注册的时候会把每一个adction都注册一个回调函数.

服务器端:
服务器端代码太多了,直接贴一个图片显示一下启动流程:

服务器代码启动流程
小程序端:
小程序涉及的东西比较多,这里贴几个图片代表一下,具体所以的界面可以在下方PPT和视频里看到:


个人用户首页
商家首页



视频:
视频分为两个,一个是ppt讲解,还有一个项目演示视频,不喜欢听PPT废话的童鞋可以直接看演示视频
PPT讲解视频:https://www.bilibili.com/video/av841360131,ppt见附件
完整演示视频:https://www.bilibili.com/video/av583817164
致谢:
最后感谢21IC家提供的这个机会,让我有机会能使用上RT-Thread去实现心中的想法,感谢雅特力提供的开发板和技术支持.
感谢观看.另,开发板所用的程序见附件.采用7z算法压缩,附件不能上传改为rar格式,如果不能正常解压请修改为.7z结尾





RT-Thread应用创新大赛作品-智能停车平台 .zip

3.99 MB, 下载次数: 39

附件PPT

at32f403a-lock_tencentIoT.rar

9.08 MB, 下载次数: 41

代码附件

使用特权

评论回复 赏

相关下载

相关帖子
zeshoufx
| 2020-7-13 08:35 | 显示全部楼层
谢谢分享

使用特权

评论回复 赏
若梦似明
| 2020-12-29 13:58 | 显示全部楼层
可以的，楼主很有想法，这个的话商业化的前景还是很不错的

使用特权

评论回复 赏
cszzlsw
 楼主 | 2020-12-31 11:41 | 显示全部楼层
若梦似明 发表于 2020-12-29 13:58
可以的，楼主很有想法，这个的话商业化的前景还是很不错的

感谢支持

使用特权

评论回复 赏
扫描二维码，随时随地手机跟帖
返回列表 发新帖 我要提问
高级模式
B Color Image Link Quote Code 收费 Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

我要发帖 我要提问 投诉建议 申请版主

快速回复

您需要登录后才可以回帖
登录 | 注册
高级模式

论坛热帖

在线客服 快速回复 返回顶部 返回列表