物联网实战--平台篇之(十一)设备管理后台

目录

一、设备数据库

二、添加设备

三、排序设备

四、重命名设备

五、删除设备

六、移动设备


本项目的交流QQ群:701889554

物联网实战--入门篇https://blog.csdn.net/ypp240124016/category_12609773.html

物联网实战--驱动篇https://blog.csdn.net/ypp240124016/category_12631333.html

一、设备数据库

        上图是设备管理数据库,跟分组管理同一个数据库,库表为设备表device_tb,放在不同的应用下,内容主要是设备sn,父设备sn和设备名称,对于跟mqtt服务器直连的设备,父设备sn为0;对于节点设备,它所在的网关就是它的父设备,这在设备组网的时候经常会用到。下面是数据库的主要代码:

bool GroupSqlite::createDeviceTable(void)
{QString str_query = QString::asprintf("CREATE TABLE If Not Exists device_tb (""devSn bigint  NOT NULL,""devStr varchar(20)  NOT NULL,""parentSn bigint  DEFAULT 0,""parentStr varchar(20)  DEFAULT 0,""devName varchar(10000)  DEFAULT 0,""createTime timestamp DEFAULT (datetime(\'now\',\'localtime\')),""PRIMARY KEY (devSn)"")");
//    qDebug()<<"str_query= "<<str_query;if(runSqlQuery(str_query)==false){qDebug()<<"createDeviceTable error";return false;}else{qDebug()<<"createDeviceTable ok:  ";}return true;
}bool GroupSqlite::insertDeviceNode(u32 devSn, u32 parentSn)
{QString dev_str=QString::asprintf("%08X", devSn);QString parent_str=QString::asprintf("%08X", parentSn);QString str_query = QString::asprintf("INSERT INTO device_tb (devSn, parentSn, devStr, parentStr) VALUES ( %u, %u, \"%s\", \"%s\")",devSn, parentSn, dev_str.toLatin1().data(), parent_str.toLatin1().data());//    qDebug()<<str_query;if( runSqlQuery(str_query)){qDebug("insertDeviceNode ok 001!");return true;}else   {createDeviceTable();if( runSqlQuery(str_query)){qDebug("insertDeviceNode ok 002!");return true;}}return false;
}bool GroupSqlite::updateDeviceName(u32 devSn, QString devName)
{QString str_query = QString::asprintf("UPDATE device_tb SET  devName=\"%s\"   WHERE devSn=%u",devName.toUtf8().data(), devSn);//    qDebug()<<str_query;if( runSqlQuery(str_query)){qDebug("updateDeviceName ok!");return true;}return false;
}bool GroupSqlite::updateDeviceParentSn(u32 devSn, u32 parentSn)
{QString parent_str=QString::asprintf("%08X", parentSn);QString str_query = QString::asprintf("UPDATE device_tb SET  parentSn=%u, parentStr=\"%s\"   WHERE devSn=%u",parentSn, parent_str.toLatin1().data(),devSn);//    qDebug()<<str_query;if( runSqlQuery(str_query)){qDebug("updateDeviceParentSn ok!");return true;}return false;
}bool GroupSqlite::selectDeviceNode(u32 devSn, DeviceNodeStruct &workNode)
{QString str_query = QString::asprintf("SELECT devSn, parentSn, devName, createTime  FROM  device_tb WHERE devSn=%u" , devSn);//    qDebug()<<str_query;if(runSqlQuery(str_query)==false){qDebug("selectDeviceNode error_01!");return false;}while(m_sqlQuery.next()){int ptr=0;workNode.devSn=m_sqlQuery.value(ptr++).toUInt();workNode.parentSn=m_sqlQuery.value(ptr++).toUInt();workNode.devName=m_sqlQuery.value(ptr++).toString();   workNode.createTime=m_sqlQuery.value(ptr++).toString();break;}m_sqlQuery.finish();    return true;  
}bool GroupSqlite::selectDeviceList(QList<DeviceNodeStruct> &workList)
{QString str_query = QString::asprintf("SELECT devSn, parentSn,  devName, createTime  FROM  device_tb");//    qDebug()<<str_query;if(runSqlQuery(str_query)==false){qDebug("selectDeviceList error_01!");return false;}while(m_sqlQuery.next()){int ptr=0;DeviceNodeStruct workNode;workNode.devSn=m_sqlQuery.value(ptr++).toUInt();workNode.parentSn=m_sqlQuery.value(ptr++).toUInt();workNode.devName=m_sqlQuery.value(ptr++).toString();   workNode.createTime=m_sqlQuery.value(ptr++).toString();workList.append(workNode);}m_sqlQuery.finish();    return true;  
}bool GroupSqlite::delDeviceNode(u32 devSn)
{QString str_query = QString::asprintf("DELETE FROM device_tb WHERE devSn=%u", devSn);//    qDebug()<<str_query;if( runSqlQuery(str_query)){qDebug("delDeviceNode ok!");return true;}return false;
}

二、添加设备

        添加设备一般是由用户发起的,主要通过扫码或者手动输入SN,跟设备联动完成添加,在这里因为扫码这块后续要单独讲解,而且还没有设备可以联动配合,所以我们先程序内部直接添加,其用户端APP添加函数如下:

void CenterMan::requestAddDevice(u32 dev_sn, u32 parent_sn)
{QJsonObject root_obj;QJsonDocument json_doc;root_obj.insert("account", m_loginAccount);root_obj.insert("rand_num", m_randNum);root_obj.insert("mac", m_macStr); root_obj.insert("cmd_type", "add_dev");root_obj.insert("app_id", (qint64)m_currAppWork.appID); root_obj.insert("dev_sn", (qint64)dev_sn); root_obj.insert("parent_sn", (qint64)parent_sn); json_doc.setObject(root_obj);QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);QString topic=makePubTopic("device");emit sigMqttPushMessage(topic, msg_ba);
}

        在定时器里每秒添加一个,添加10个为止,这里的序列号是0xA1010001~0xA101000A十个,其中A101代表型号,这是自定义,我这里就是定义为一种净化器设备,0001~000A就是地址码了,至于这个设备的具体定义,实际上是一个物模型,包含C++文件和QML文件,这个后面跟硬件结合起来要单独讲解,在这里也先保留,只展示一些文件信息,了解结构:

        由上图可知,在手机APP项目里,我们对物模型进行了单独的定义和存放,modelCpp和modelQml分别存放后端程序和前端代码,这样,在手机APP的主体结构完成后,对于要增加新的硬件产品,只需要对应增加物模型的代码就行了,其它不变,这也是物联网 端到端开发的核心所在。

        在服务器后台,接收到请求后会将设备添加到数据库,并返回反馈信息。

    else if(cmd_type=="add_dev"){u32 dev_sn=0, parent_sn=0;if(root_obj.contains("dev_sn")){QJsonValue value = root_obj.value("dev_sn");dev_sn=value.toDouble();}if(root_obj.contains("parent_sn")){QJsonValue value = root_obj.value("parent_sn");parent_sn=value.toDouble();}tag_groupSqlite.insertDeviceNode(dev_sn, parent_sn);//添加设备到数据库ack_str=QString::asprintf("设备%08X 添加成功!", dev_sn);ackAddDevice(account, mac_str, rand_num, app_id, dev_sn, parent_sn, result, ack_str);}

        用户端收到后将新设备添加到工作列表和"全部"分组,这样一个完整的添加流程就完成了。

        else if(cmd_type=="add_dev")//新增设备{u32 dev_sn=root_obj.value("dev_sn").toDouble();u32 parent_sn=root_obj.value("parent_sn").toDouble();addWorkDevice(dev_sn, parent_sn, "");//添加到工作列表emit siqAddDevice2Group("全部", dev_sn);//添加到全部分组}

三、排序设备

        用户在界面调整每个分组设备的顺序后,需要发送到后台服务器进行更新,以下的请求代码和后台更新代码:

void CenterMan::requestSortDevice(QString group_name, QList<qint64> dev_list)
{QJsonArray dev_array;QJsonObject root_obj;QJsonDocument json_doc;qDebug()<<"group_name="<<group_name;qDebug()<<"dev_list="<<dev_list;int nSize=dev_list.size();for(int i=0; i<nSize; i++){u32 dev_sn=dev_list.at(i);if(dev_sn>0){dev_array.append((qint64)dev_sn);}}root_obj.insert("account", m_loginAccount);root_obj.insert("rand_num", m_randNum);root_obj.insert("mac", m_macStr); root_obj.insert("app_id", (qint64)m_currAppWork.appID); root_obj.insert("group_name", group_name); root_obj.insert("dev_list", dev_array); root_obj.insert("cmd_type", "sort_dev");json_doc.setObject(root_obj);QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);QString topic=makePubTopic("device");emit sigMqttPushMessage(topic, msg_ba);
}

    if(cmd_type=="sort_dev"){QString group_name="";if(root_obj.contains("group_name")){QJsonValue value = root_obj.value("group_name");group_name=value.toString();}QJsonArray dev_array;QList<u32>dev_list;if(root_obj.contains("dev_list")){QJsonValue value = root_obj.value("dev_list");dev_array=value.toArray();}int nSize=dev_array.size();for(int i=0; i<nSize; i++){u32 dev_sn=dev_array.at(i).toDouble();dev_list.append((qint64)dev_sn);}tag_groupSqlite.updateDevList(group_name, dev_list);//更新数据库ack_str="排序成功!";ackSortDevice(account, mac_str, rand_num, app_id, group_name, dev_array, result, ack_str);}

        排序完成后会返回到用户端,以下是用户端代码,主要是更新该分组在前端显示的顺序,完成最终的排序任务。

        else if(cmd_type=="sort_dev")//重新排序分组内的设备{QString group_name="";if(root_obj.contains("group_name")){QJsonValue value = root_obj.value("group_name");group_name=value.toString();}GroupNodeStruct *pGroupNode=searchGroupNode(group_name);if(pGroupNode)//更新分组内的设备{QJsonArray dev_array;if(root_obj.contains("dev_list")){QJsonValue value = root_obj.value("dev_list");dev_array=value.toArray();}emit siqClearDevice(group_name);pGroupNode->devList.clear();int nSize=dev_array.size();for(int i=0; i<nSize; i++){u32 dev_sn=dev_array.at(i).toDouble();pGroupNode->devList.append(dev_sn);emit siqAddDevice2Group(group_name, dev_sn);//添加设备到分组}  emit siqUpdateGroupTotalNum(group_name, pGroupNode->devList.size());//更新设备数量}}        

四、重命名设备

        设备重命名流程与分组重命名类似,首先是用户端请求,服务器更新返回,最后用户端更新显示,下面是请求代码,

void CenterMan::requestRenameDevice(u32 dev_sn, QString new_name)
{QJsonObject root_obj;QJsonDocument json_doc;root_obj.insert("account", m_loginAccount);root_obj.insert("rand_num", m_randNum);root_obj.insert("mac", m_macStr); root_obj.insert("cmd_type", "rename_dev");root_obj.insert("app_id", (qint64)m_currAppWork.appID); root_obj.insert("dev_sn", (qint64)dev_sn); root_obj.insert("new_name", new_name); json_doc.setObject(root_obj);QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);QString topic=makePubTopic("device");emit sigMqttPushMessage(topic, msg_ba);
}

        服务器更新数据库设备名称:

    else if(cmd_type=="rename_dev"){u32 dev_sn=0;if(root_obj.contains("dev_sn")){QJsonValue value = root_obj.value("dev_sn");dev_sn=value.toDouble();}QString new_name;if(root_obj.contains("new_name")){QJsonValue value = root_obj.value("new_name");new_name=value.toString();}if(dev_sn>0 &&!new_name.isEmpty()){tag_groupSqlite.updateDeviceName(dev_sn, new_name);ack_str="重命名成功!";}else{ack_str="重命名失败!";result=1;}ackRenameDevice(account, mac_str, rand_num, app_id, dev_sn, new_name, result, ack_str);}

        用户端更新前端显示:

        else if(cmd_type=="rename_dev")//重命名设备{u32 dev_sn=root_obj.value("dev_sn").toDouble();QString new_name=root_obj.value("new_name").toString();updateWorkName(dev_sn, new_name);//更新设备名称}
五、删除设备

        删除设备可以是多个的,所以参数是一个设备列表:

void CenterMan::requestDelDevice(QList<qint64> dev_list)
{QJsonArray dev_array;QJsonObject root_obj;QJsonDocument json_doc;qDebug()<<"del dev_list="<<dev_list;int nSize=dev_list.size();for(int i=0; i<nSize; i++){u32 dev_sn=dev_list.at(i);if(dev_sn>0){dev_array.append((qint64)dev_sn);}}root_obj.insert("account", m_loginAccount);root_obj.insert("rand_num", m_randNum);root_obj.insert("mac", m_macStr); root_obj.insert("app_id", (qint64)m_currAppWork.appID); root_obj.insert("dev_list", dev_array); root_obj.insert("cmd_type", "del_dev");json_doc.setObject(root_obj);QByteArray msg_ba = json_doc.toJson(QJsonDocument::Indented);QString topic=makePubTopic("device");emit sigMqttPushMessage(topic, msg_ba);
}

        服务器解析后从数据库中一个个删除设备:

    else if(cmd_type=="del_dev"){QJsonArray dev_array;if(root_obj.contains("dev_list")){QJsonValue value = root_obj.value("dev_list");dev_array=value.toArray();}int nSize=dev_array.size();for(int i=0; i<nSize; i++){u32 dev_sn=dev_array.at(i).toDouble();tag_groupSqlite.delDeviceNode(dev_sn);//删除设备}ack_str="删除成功!";ackDelDevice(account, mac_str, rand_num, app_id, dev_array, result, ack_str);}

        用户端也要删除对应的前端显示,在删除最后一个后,需要重新排序设备,这样才能更新服务器内的分组信息。

        else if(cmd_type=="del_dev")//移除设备{QJsonArray dev_array;if(root_obj.contains("dev_list")){QJsonValue value = root_obj.value("dev_list");dev_array=value.toArray();}int nSize=dev_array.size();for(int i=0; i<nSize; i++){u32 dev_sn=dev_array.at(i).toDouble();delWorkDevice(dev_sn);//删除工作设备emit siqDelDevice(dev_sn, i==nSize-1);//删除显示设备}}

六、移动设备

        移动设备相对来讲是比较复杂的,首先有两个分组,一个是源分组,就是设备要移出的分组;另一个是目标分组,就是设备要移到的分组,设备是多个的。所以,对于源分组,我们要删除要移出的设备,这里排除“全部”这个分组;对于目标分组,我们要新增移出来的设备,这里对于重复的设备要检查,各自任务完成后就是请求重新排序就可以了,具体代码如下:

void CenterMan::requestMoveDevice(QString src_group, QString dst_group, QList<qint64> dev_list)
{GroupNodeStruct *pGroupNodeSrc=searchGroupNode(src_group);GroupNodeStruct *pGroupNodeDst=searchGroupNode(dst_group);int nSize=dev_list.size();if(pGroupNodeSrc==nullptr || pGroupNodeDst==nullptr || nSize<=0)return;qDebug()<<"move src_group="<<src_group;qDebug()<<"move dst_group="<<dst_group;qDebug()<<"move dev_list="<<dev_list;qDebug()<<"src dev list="<<pGroupNodeSrc->devList;qDebug()<<"dst dev list="<<pGroupNodeDst->devList;if(src_group!="全部"){for(auto iter : dev_list)//先移除源分组设备{qDebug()<<"will remove dev sn="<<iter<<", dev_list="<<pGroupNodeSrc->devList;for(int i=0; i<pGroupNodeSrc->devList.size(); i++){if(iter==pGroupNodeSrc->devList.at(i)){qDebug()<<"remove dev_sn="<<iter;pGroupNodeSrc->devList.removeAt(i);break;}}}requestSortDevice(src_group, pGroupNodeSrc->devList);//重新排序}if(dst_group!="全部"){for(auto iter : dev_list)//添加到目标分组{bool flag=false;for(int i=0; i<pGroupNodeDst->devList.size(); i++){if(iter==pGroupNodeDst->devList.at(i))//重复,不能添加{flag=true;break;}}if(flag==false){pGroupNodeDst->devList.append(iter);}}requestSortDevice(dst_group, pGroupNodeDst->devList);//重新排序}
}

        这里有几点需要提一下,首先,"全部"分组是比较特殊的,它是包含所有设备的,所以设备从"全部"分组移出后自身不会删除;反过来,如果其它分组的设备想移除,但不是删除,那么可以将设备 移动到"全部"分组即可。另外一点,米家APP的每一个设备只能存放在一个分组内,那我们这边对这个没做限制,用户可以根据自己的需求和习惯,将一个设备放在不同分组内。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/846017.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

港科夜闻 | 香港科大于首尔高峰论坛分享三十载发展里程,并与韩国知名机构学府加强交流...

关注并星标 每周阅读港科夜闻 建立新视野 开启新思维 1、香港科大于首尔高峰论坛分享三十载发展里程&#xff0c;并与韩国知名机构学府加强交流。香港科大致力加强与韩国机构和产业的联系&#xff0c;大学高层管理人员于5月29-30日出席首尔一个备受瞩目的论坛&#xff0c;并与当…

Codeforces Round 949 (Div. 2 ABCD) 视频讲解

A. Turtle and Piggy Are Playing a Game Problem Statement Turtle and Piggy are playing a number game. First, Turtle will choose an integer x x x, such that l ≤ x ≤ r l \le x \le r l≤x≤r, where l , r l, r l,r are given. It’s also guaranteed that …

OpenAI 的 GPT-4o 是目前最先进的人工智能模型!如何在工作或日常生活中高效利用它?

OpenAI 的 GPT-4o 是目前最先进的人工智能模型&#xff01;如何在工作或日常生活中高效利用它&#xff1f; 博主猫头虎的技术世界 &#x1f31f; 欢迎来到猫头虎的博客 — 探索技术的无限可能&#xff01; 专栏链接&#xff1a; &#x1f517; 精选专栏&#xff1a; 《面试题大…

RabbitMQ延时队列

一、RabbitMQ下载并使用插件 1、查看RabbitMQ插件的文件路径 docker inspect rabbitmq 找到Mounts下面Name:rabbitmq_plugin的Source即为插件路径 使用 cd 进入到该目录 2、下载插件 wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download…

vue-el-steps 使用1(上一步、下一步)

vue代码 <template> <div class"app-container"> <el-steps :active"active" finish-status"success" simple style"margin-top: 20px"> <el-step title"选择分类"></el-step> <el-step t…

字典树,AcWing 5726. 连续子序列

一、题目 1、题目描述 2、输入输出 2.1输入 2.2输出 3、原题链接 5726. 连续子序列 - AcWing题库 二、解题报告 1、思路分析 字典树存储前缀和 考虑边遍历计算前缀和&#xff0c;边查询字典树 查询流程&#xff1a; 记当前前缀和为s 如果当前位k为1&#xff0c;那么s …

苹果电脑如何清理最近打开的文稿记录 Mac如何移除浏览痕迹保护隐私

日常使用苹果电脑的过程中&#xff0c;我们经常会打开各种文稿&#xff0c;浏览网页等操作。然而&#xff0c;这些操作可能会留下一些记录&#xff0c;涉及到个人隐私和数据安全问题。下面我们来看看苹果电脑如何清理最近打开的文稿记录&#xff0c;Mac如何移除浏览痕迹保护隐私…

C++进阶篇章:set与map(pair , multiset , multimap)

目录 1.关联式容器与序列式容器 2.pair&#xff08;键值对&#xff09; 3.set 构造函数 find函数 count函数&#xff1a; insert函数 4.multiset 5.map insert函数 operator[] 1.关联式容器与序列式容器 C中关联式容器与序列式容器是两种不同的容器 1.关联式容器 关…

力扣--双指针15.三数之和

详细思路 排序数组&#xff1a;首先对数组 nums 进行排序&#xff0c;目的是为了方便后续使用双指针查找和避免重复结果。遍历数组&#xff1a;使用一个 for 循环从头遍历到倒数第三个元素。i 表示当前固定的元素。 跳过重复元素&#xff1a;如果当前元素 nums[i] 与前一个元素…

SpringBoot项目实现自定义注解方式的接口限流

一&#xff0c;实现原理 该限流方式使用的是令牌桶算法&#xff0c;令牌桶算法是基于漏桶算法的一种改进&#xff0c;主要在于令牌桶算法能够在限制服务调用的平均速率的同时&#xff0c;还能够允许一定程度内的突发调用。 系统以固定的速率向桶中添加令牌当有请求到来时&#…

张大哥笔记:你卖什么,就反着来卖

普通人打工的一生&#xff0c;就是努力工作&#xff0c;买房&#xff0c;买车&#xff0c;送孩子上好的学校&#xff0c;为了孩子不要输在起跑线上&#xff0c;拼命报各种补习班等&#xff0c;这些都是普通人认为的主流价值观文化&#xff0c;也造就了一批批的赚钱机器&#xf…

带DSP音效处理D类数字功放TAS5805M中文资料

国产替代D类数字功放中文资料访问下方链接 ACM8628 241W立体声182W单通道数字功放中文寄存器表 内置DSP多种音频处理效果ACM8628M-241W立体声或182W单通道数字功放 1 特性 具有增强处理能力和低功率损耗的 TAS5805M 23W、无电感器、数字输入、立体声、闭环 D 类音频放大器 …

华为设备配置静态路由和默认路由

华为设备配置静态路由和默认路由 理论部分知识&#xff1a; 路由分为两个大类&#xff1a;静态路由-----动态路由 静态路由&#xff1a;手工指定&#xff0c;适用于小规模的网络应用场景&#xff0c;如果网络规模变大&#xff0c;这样的方式非常不适合而且容易出错。 语法&…

Java之IO流

一、引言 &#xff08;1&#xff09;解释&#xff1a; i&#xff1a;input &#xff08;输入&#xff09; o&#xff1a;output &#xff08;输出&#xff09; &#xff08;2&#xff09;图解 注意&#xff1a; 1、Xxx 这个程序一旦在桌面关闭掉了&#xff0c;也就是运行完…

动态路由OSPF单区域和多区域配置实验

动态路由OSPF的配置 OSPF分类两种情况&#xff1a;单区域 多区域路由 OSPF单区域路由配置 OSPF&#xff1a;开放最短路径优先的路由协议。属于大型动态路由协议&#xff0c;适用于中大型的园区网。 网络拓扑&#xff1a; 配置步骤&#xff1a; 1.完成基本配置&#xff08;略&…

能耗监测系统在上海交通大学闵行校区理科实验楼群的设计与应用

引言 建筑能耗系统&#xff0c;除了基本的电力参数监测、配电系统的运行状况&#xff0c;更加关注能耗的去向。除了常规的园区楼层出线电能计量&#xff0c;还会涉及水&#xff0c;气等能耗计量。 针对上海交通大学闵行校区理科实验楼群能耗监测系统的具体要求&#xff0c;以…

依赖管理包介绍

文章目录 1. 概念介绍2. 思路与方法2.1 实现思路2.2 相关组件 3. 示例代码4. 内容总结 我们在上一章回中介绍了"使用get进行依赖管理"相关的内容&#xff0c;本章回中将介绍如何使用get进行状态管理一.闲话休提&#xff0c;让我们一起Talk Flutter吧。 1. 概念介绍 …

C语言:如何在微软VS环境下使用C库?

技术答疑流程 扫描二维码&#xff0c;添加个人微信&#xff1b;支付一半费用&#xff0c;获取答案&#xff1b;如果满意&#xff0c;则支付另一半费用&#xff1b; 知识点费用&#xff1a;10元 项目费用&#xff1a;如果有项目任务外包需求&#xff0c;可以微信私聊

IP路由策略1

控制层面:路由协议传递路由信息的流量--对应的方向 数据层面:设备间具体访问时请求的流量--对应方向 控制层面方向与数据层面方向一定相反 在控制层面流量进或出的接口上&#xff0c;抓取流量后&#xff0c;修改其中参数或删除该信息&#xff0c;最终起到影响路由器路由表的生…