mirror of
https://gitee.com/beecue/fastbee.git
synced 2025-12-17 08:25:53 +08:00
Merge branch 'master' of https://gitee.com/iot.adu/wumei-smart
This commit is contained in:
DuXingJie
104
README.md
104
README.md
@@ -1,18 +1,17 @@
|
||||
|
||||
### 一、项目简介
|
||||
|
||||
#### 1. 物美智能 [wumei-smart](http://wumei.live/) 是一个简单易用的生活物联网平台。可用于搭建物联网平台以及二次开发和学习。
|
||||
#### 1. WumeiSmart是一个简单易用的生活物联网平台。可用于搭建物联网平台以及二次开发和学习。[演示地址>>](https://iot.wumei.live/)
|
||||
|
||||
#### 2. 设备接入使用EMQX消息服务器，加密认证；后端采用Spring boot；前端采用Vue；移动端采用Uniapp；数据库采用Mysql、TDengine和Redis；设备端支持ESP32、ESP8266、树莓派等；系统架构图如下：
|
||||
#### 2. 项目采用AGPL3协议，可用于个人学习和使用，商业用途需要赞助项目，获得授权。[查看详情 >>](https://wumei.live/doc/pages/sponsor/)
|
||||
|
||||
#### 3. 设备接入使用EMQX消息服务器，加密认证；后端采用Spring boot；前端采用Vue；移动端采用Uniapp；数据库采用Mysql、TDengine和Redis；设备端支持ESP32、ESP8266、树莓派等；系统架构图如下：
|
||||
<img src="https://oscimg.oschina.net/oscnet/up-98eefff896394066a60d664b875a3d05d1d.png" max-width="800" />
|
||||
|
||||
#### 3. 项目采用AGPL3协议，可用于个人学习和使用，商业用途需要赞助项目，获得授权。[查看详情 >>](https://wumei.live/doc/pages/sponsor/)
|
||||
|
||||
#### 4. 参考设备
|
||||
| [空气检测仪](https://wumei.live/doc/pages/hardware/) | [Wifi通断器](https://wumei.live/doc/pages/hardware/) | [智能插座](https://wumei.live/doc/pages/hardware/) | [智能开关](https://wumei.live/doc/pages/hardware/) | [Wifi通断器](https://wumei.live/doc/pages/hardware/) |
|
||||
#### 4. 相关硬件
|
||||
|[空气检测仪](https://wumei.live/doc/pages/hardware/) | [物联网开发板](https://wumei.live/doc/pages/hardware/) | [Air724开发板](https://wumei.live/doc/pages/hardware/) | [智能开关](https://wumei.live/doc/pages/hardware/) | [查看更多>>](https://wumei.live/doc/pages/hardware/) |
|
||||
| :----: | :----------: |:----------: |:----------: |:----------: |
|
||||
|  |  |  |  |  |
|
||||
|
||||
|  |  |  | |  |
|
||||
|
||||
|
||||
|
||||
@@ -20,15 +19,15 @@
|
||||
- 权限管理： 用户管理、部门管理、岗位管理、菜单管理、角色管理、字典和参数管理等
|
||||
- 系统监控： 操作日志、登录日志、系统日志、在线用户、服务监控、连接池监控、缓存监控等
|
||||
- 产品管理： 产品、产品物模型、产品分类、产品固件、设备授权码等
|
||||
- 设备管理： 控制、分组、定时、日志、统计、定位、分享、配置、配网、禁用、OTA升级、实时状态、自动注册、影子模式、实时监测、加密认证等
|
||||
- 设备管理： 设备控制、设备分组、设备定时、设备日志、监测统计、设备定位、设备分享、智能配网、设备禁用、OTA升级、实时状态、影子模式、实时监测、加密认证等
|
||||
- EMQ管理： Mqtt客户端、监听器、消息主题、消息订阅、插件管理、规则引擎、资源
|
||||
- 硬件 SDK： 支持WIFI和MQTT连接、物模型响应、实时监测、定时上报监测数据、AES加密、NTP时间等
|
||||
- 物模型管理： 属性（设备状态和监测数据），功能（执行特定任务），事件（设备主动上报给云端）
|
||||
- 其他功能：多租户、统计、新闻资讯、通知公告、支持TDengine时序数据库
|
||||
- 计划开发完善功能：设备告警、场景联动、云云对接智能音箱、第三方登录、短信登录、APP界面自定义、视频流处理等
|
||||
- 开发中功能：设备告警、场景联动、云云对接智能音箱、第三方登录、短信登录、APP界面自定义、视频流处理等
|
||||
|
||||
|
||||
### 四、技术栈
|
||||
### 三、技术栈
|
||||
* 服务端
|
||||
- 相关技术：Spring boot、MyBatis、Spring Security、Jwt、Mysql、Redis、TDengine、EMQX、Mqtt等
|
||||
- 开发工具：IDEA
|
||||
@@ -39,97 +38,52 @@
|
||||
- 相关技术：uniapp、[uView](https://www.uviewui.com/)、[uChart](https://www.ucharts.cn/)
|
||||
- 开发工具：HBuilder
|
||||
* 硬件端
|
||||
- 相关技术： ESP-IDF、Arduino、FreeRTOS等
|
||||
- 开发工具：Visual Studio Code 和 Arduino
|
||||
|
||||
### 五、硬件接入
|
||||
1. 设备认证
|
||||
* 加密认证（推荐）
|
||||
* 简单认证
|
||||
* EMQX支持的其他认证方式
|
||||
2. 设备交互
|
||||
* 发布物模型、设备信息、时钟同步相关Mqtt主题
|
||||
* 订阅物模型、设备升级、时钟同步相关Mqtt主题
|
||||
|
||||
###### 项目提供了示例SDK，使用ESP8266芯片，基于Arduino开发。（设备烧录使用串口模块，例如Ch340，大部分开发板自带了）接线图如下：
|
||||
|
||||
- 相关技术： ESP-IDF、Arduino、FreeRTOS、Python、Lua等
|
||||
- 开发工具：Visual Studio Code 和 Arduino等
|
||||
|
||||
|
||||
### 六、项目目录
|
||||
### 四、项目目录
|
||||
spring-boot --------------- 后端<br/>
|
||||
vue ----------------------- 前端<br />
|
||||
docker -------------------- docker部署文件<br />
|
||||
sdk ----------------------- 硬件SDK<br />
|
||||
sdk ----------------------- 硬件SDK，不同设备的SDK示例在不断增加<br />
|
||||
app ----------------------- 移动端打包文件
|
||||
|
||||
###### 移动端适配多端
|
||||
|安卓/Android|苹果/IOS|微信小程序| 网页/H5|Vue2.0
|
||||
| :---: | :---: | :---: | :---: |:---: |
|
||||
| √ | √| √ | √ | √ |
|
||||
|
||||
|
||||
### 七、相关文档
|
||||
### 五、相关文档
|
||||
##### 权限管理基于ruoyi-vue系统，Mqtt消息服务器基于EMQX4.0开源版，SDK示例使用ESP8266 Core For Arduino开发
|
||||
* [项目文档](https://wumei.live/doc/)
|
||||
* [物美智能官网](http://wumei.live/)
|
||||
* [若依权限管理系统ruoyi-vue](https://gitee.com/y_project/RuoYi-Vue)
|
||||
* [Mqtt消息服务器EMQX4.0](https://github.com/emqx/emqx)
|
||||
* [ESP8266 Core For Arduino](https://github.com/esp8266/Arduino)
|
||||
* [uCharts高性能跨平台图表库](https://www.ucharts.cn)
|
||||
* [TDengine时序数据库](https://www.taosdata.com/?zh)
|
||||
|
||||
|
||||
### 八、其他
|
||||
* 互助交流群：946029159 1073236354
|
||||
* [演示地址>>](https://iot.wumei.live/)
|
||||
* 小程序演示
|
||||
|
||||
|
||||
|
||||
##### 项目贡献者
|
||||
|
||||
|[小驿物联](https://gitee.com/iot-xiaoyi) |[Guanshubiao](https://gitee.com/guanshubiao)|[CrazyDull](https://gitee.com/crazyDull) |[Kami0314](https://github.com/kami0314)|[YBZX](https://github.com/YBZX)
|
||||
|--|--|--|--|--|
|
||||
|
||||
| [SXH](https://gitee.com/sixiaohu) | [Redamancy_zxp](https://gitee.com/redamancy-zxp) | [LEE](https://gitee.com/yueming188) | [LemonTree](https://gitee.com/fishhunterplus) | [Tang](https://gitee.com/mexiaotang)
|
||||
|--|--|--|--|--|
|
||||
|
||||
| [xxmfl](https://gitee.com/xxmfl) |
|
||||
|--|
|
||||
### 六、其他
|
||||
1. QQ交流群：🚀946029159 🚀1073236354
|
||||
2. 项目贡献者
|
||||
- [小驿物联](https://gitee.com/iot-xiaoyi)、 [Guanshubiao](https://gitee.com/guanshubiao)、[CrazyDull](https://gitee.com/crazyDull)、 [Kami0314](https://github.com/kami0314)、 [YBZX](https://github.com/YBZX)
|
||||
- [SXH](https://gitee.com/sixiaohu)、 [Redamancy_zxp](https://gitee.com/redamancy-zxp)、 [LEE](https://gitee.com/yueming188)、 [LemonTree](https://gitee.com/fishhunterplus)、 [Tang](https://gitee.com/mexiaotang)、 [Tang](https://gitee.com/mexiaotang)、 [xxmfl](https://gitee.com/xxmfl)
|
||||
|
||||
|
||||
### 九、部分图片
|
||||
### 七、部分图片
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
<table>
|
||||
<tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-60ff517f5362f4c7b98bb4cb3df543e4ecb.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-d9dd014cec34b6424eb6d768e362356a622.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-a0c864679be6c4f9bb5547244aeb19657b4.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-9cc3bc5abe8dd95cb3924e5f7b6864a0342.png"/></td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-cefbaf28d2ea5438b17dbad53638852519b.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-20672c691106771f3a38168c0f6c6a7bf20.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-ec8c6251884d81f234487d3e25d459ce302.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-e5e7ef5027723051e97d6861d4296c08da5.png"/></td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-75e099216e1fa33f5e83989838ffd1b16fa.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-51d2ae913a83a542fc2c3b6f802dc34369f.png"/></td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-287864587ec8116ee8be115a94d1d6f9302.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-2b0a744a83f939b6694dc33c7b80193029b.png"/></td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-c8c388b20e70f6a668749aab94d214b8270.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-cc512e6367b55a3afa78bee7e1cd8c8cab9.png"/></td>
|
||||
</tr>
|
||||
<tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-457424f66db64e5e66d200d94a0d42358ad.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-bf47113b636fa96ceaf9607df795f8b3a17.png"/></td>
|
||||
</tr>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-e05690366e11fb173cebafcba57b5567e38.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-f7856cca6a3dd60afafd1cb0e1ae67c596e.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-3ae8cef86db794ff37d9186e83b12b88958.png"/></td>
|
||||
<td><img src="https://oscimg.oschina.net/oscnet/up-e20900a12e3781467d05163665ca04645fa.png"/></td>
|
||||
</tr>
|
||||
</table>
|
||||
|
||||
|
||||
@@ -69,8 +69,9 @@ void connectWifi()
|
||||
{
|
||||
if (isApMode)
|
||||
{
|
||||
// 关闭AP配网模式
|
||||
// 关闭AP配网模式，延迟2秒确保返回状态码给手机
|
||||
isApMode = false;
|
||||
delay(2000);
|
||||
server.stop();
|
||||
ledStatus(false);
|
||||
}
|
||||
|
||||
@@ -64,19 +64,19 @@ public class Product extends BaseEntity
|
||||
}
|
||||
|
||||
/** 状态（1-未发布，2-已发布，不能修改） */
|
||||
@Excel(name = "状态", readConverterExp = "1=-未发布，2-已发布，不能修改")
|
||||
@Excel(name = "状态", readConverterExp = "1==未发布，2=已发布，不能修改")
|
||||
private Integer status;
|
||||
|
||||
/** 设备类型（1-直连设备、2-网关子设备、3-网关设备） */
|
||||
@Excel(name = "设备类型", readConverterExp = "1=-直连设备、2-网关子设备、3-网关设备")
|
||||
@Excel(name = "设备类型", readConverterExp = "1=直连设备、2=网关子设备、3=网关设备")
|
||||
private Integer deviceType;
|
||||
|
||||
/** 联网方式（1-wifi、2-蓝牙、3-wifi+蓝牙） */
|
||||
@Excel(name = "联网方式", readConverterExp = "1=-wifi、2-蓝牙、3-wifi+蓝牙")
|
||||
/** 联网方式（1=-wifi、2-蜂窝(2G/3G/4G/5G)、3-以太网、4-其他） */
|
||||
@Excel(name = "联网方式", readConverterExp = "1=-wifi、2=蜂窝(2G/3G/4G/5G)、3=以太网、4=其他")
|
||||
private Integer networkMethod;
|
||||
|
||||
/** 认证方式（1-账号密码、2-证书、3-Http） */
|
||||
@Excel(name = "认证方式", readConverterExp = "1=-账号密码、2-证书、3-Http")
|
||||
@Excel(name = "认证方式", readConverterExp = "1=账号密码、2=证书、3=Http")
|
||||
private Integer vertificateMethod;
|
||||
|
||||
/** 图片地址 */
|
||||
|
||||
@@ -574,7 +574,7 @@ public class DeviceServiceImpl implements IDeviceService {
|
||||
return AjaxResult.error("用户已经拥有设备：" + existDevice.getDeviceName() + ", 设备编号：" + existDevice.getSerialNumber());
|
||||
}
|
||||
// 先删除设备的所有用户
|
||||
deviceUserMapper.deleteDeviceUserByDeviceId(new UserIdDeviceIdModel(null,existDevice.getDeviceId()));
|
||||
deviceUserMapper.deleteDeviceUserByDeviceId(new UserIdDeviceIdModel(null, existDevice.getDeviceId()));
|
||||
// 添加新的设备用户
|
||||
DeviceUser deviceUser = new DeviceUser();
|
||||
deviceUser.setUserId(sysUser.getUserId());
|
||||
@@ -902,6 +902,7 @@ public class DeviceServiceImpl implements IDeviceService {
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public int reportDevice(Device device, Device deviceEntity) {
|
||||
// 未采用设备定位则清空定位，定位方式(1=ip自动定位，2=设备定位，3=自定义)
|
||||
if (deviceEntity.getLocationWay() != 2) {
|
||||
@@ -910,11 +911,38 @@ public class DeviceServiceImpl implements IDeviceService {
|
||||
}
|
||||
int result = 0;
|
||||
if (deviceEntity != null) {
|
||||
// 更新设备信息
|
||||
// 联网方式为Wifi的需要更新用户信息（1=wifi、2=蜂窝(2G/3G/4G/5G)、3=以太网、4=其他）
|
||||
Product product = productService.selectProductByProductId(deviceEntity.getProductId());
|
||||
if (product.getNetworkMethod() == 1) {
|
||||
if (deviceEntity.getUserId().longValue() != device.getUserId().longValue()) {
|
||||
// 先删除设备的所有用户
|
||||
deviceUserMapper.deleteDeviceUserByDeviceId(new UserIdDeviceIdModel(null, deviceEntity.getDeviceId()));
|
||||
// 添加新的设备用户
|
||||
SysUser sysUser = userService.selectUserById(device.getUserId());
|
||||
DeviceUser deviceUser = new DeviceUser();
|
||||
deviceUser.setUserId(sysUser.getUserId());
|
||||
deviceUser.setUserName(sysUser.getUserName());
|
||||
deviceUser.setPhonenumber(sysUser.getPhonenumber());
|
||||
deviceUser.setDeviceId(deviceEntity.getDeviceId());
|
||||
deviceUser.setDeviceName(deviceEntity.getDeviceName());
|
||||
deviceUser.setTenantId(deviceEntity.getTenantId());
|
||||
deviceUser.setTenantName(deviceEntity.getTenantName());
|
||||
deviceUser.setIsOwner(1);
|
||||
deviceUser.setCreateTime(DateUtils.getNowDate());
|
||||
deviceUserMapper.insertDeviceUser(deviceUser);
|
||||
// 更新设备用户信息
|
||||
device.setUserId(device.getUserId());
|
||||
device.setUserName(sysUser.getUserName());
|
||||
}
|
||||
}else{
|
||||
// 其他联网设备不更新用户信息
|
||||
device.setUserId(null);
|
||||
}
|
||||
device.setUpdateTime(DateUtils.getNowDate());
|
||||
if (deviceEntity.getActiveTime() == null || deviceEntity.getActiveTime().equals("")) {
|
||||
device.setActiveTime(DateUtils.getNowDate());
|
||||
}
|
||||
// 不更新物模型
|
||||
device.setThingsModelValue(null);
|
||||
result = deviceMapper.updateDeviceBySerialNumber(device);
|
||||
}
|
||||
|
||||
@@ -230,7 +230,7 @@
|
||||
</div>
|
||||
<div style="display:table;">
|
||||
<div style="width:70px;font-weight: bold;display:table-cell;">赞助用户：</div>
|
||||
<div style="display:table-cell;line-height:22px;"><b style="color:#F56C6C">可用于商业用途，并提供移动端源码，包含一年的更新。</b>但是不能低价或批量转售源码，不能随意分发源码。目前赞助费为3000元，项目不断完善后会对应增加费用。</div>
|
||||
<div style="display:table-cell;line-height:22px;"><b style="color:#F56C6C">可用于商业用途，并提供移动端源码，包含一年的更新。</b>但是不能低价或批量转售源码，不能随意分发源码。目前赞助费为3500元，项目不断完善后会对应增加费用。</div>
|
||||
</div>
|
||||
</el-card>
|
||||
<el-card shadow="hover" style="padding:20px 0;margin-bottom:40px;font-size:14px;">
|
||||
|
||||
@@ -15,7 +15,7 @@
|
||||
<template slot="label">
|
||||
<span style="color:red;">* </span>设备编号
|
||||
</template>
|
||||
<el-input v-model="form.serialNumber" placeholder="请输入设备编号" :disabled="form.status!=1">
|
||||
<el-input v-model="form.serialNumber" placeholder="请输入设备编号" :disabled="form.status!=1" maxlength="32">
|
||||
<el-button slot="append" @click="generateNum" :loading="genDisabled" :disabled="form.status!=1">生成</el-button>
|
||||
</el-input>
|
||||
</el-form-item>
|
||||
@@ -152,7 +152,7 @@
|
||||
</el-col>
|
||||
<el-col :span="10">
|
||||
<div style="border:1px solid #ccc;width:200px;text-align: center;margin-left:20px;margin-top:-10px;">
|
||||
<vue-qr :text="qrText" :size="200" ></vue-qr>
|
||||
<vue-qr :text="qrText" :size="200"></vue-qr>
|
||||
<div style="padding-bottom:10px;">设备二维码</div>
|
||||
</div>
|
||||
</el-col>
|
||||
@@ -232,7 +232,7 @@ export default {
|
||||
data() {
|
||||
return {
|
||||
// 二维码内容
|
||||
qrText:'wumei-smart',
|
||||
qrText: 'wumei-smart',
|
||||
// 打开设备配置对话框
|
||||
openSummary: false,
|
||||
// 是否加载完成
|
||||
@@ -271,6 +271,11 @@ export default {
|
||||
required: true,
|
||||
message: "设备名称不能为空",
|
||||
trigger: "blur"
|
||||
}, {
|
||||
min: 2,
|
||||
max: 32,
|
||||
message: '设备名称长度在 2 到 32 个字符',
|
||||
trigger: 'blur'
|
||||
}],
|
||||
firmwareVersion: [{
|
||||
required: true,
|
||||
@@ -294,61 +299,61 @@ export default {
|
||||
},
|
||||
destroyed() {
|
||||
// 取消订阅主题
|
||||
this.mqttUnSubscribe(this.form);
|
||||
this.mqttUnSubscribe(this.form);
|
||||
},
|
||||
methods: {
|
||||
/* 连接Mqtt消息服务器 */
|
||||
async connectMqtt() {
|
||||
if (this.$mqttTool.client == null) {
|
||||
await this.$mqttTool.connect(this.vuex_token);
|
||||
}
|
||||
this.mqttCallback();
|
||||
},
|
||||
async connectMqtt() {
|
||||
if (this.$mqttTool.client == null) {
|
||||
await this.$mqttTool.connect(this.vuex_token);
|
||||
}
|
||||
this.mqttCallback();
|
||||
},
|
||||
/* Mqtt回调处理 */
|
||||
mqttCallback() {
|
||||
this.$mqttTool.client.on('message', (topic, message, buffer) => {
|
||||
let topics = topic.split('/');
|
||||
let productId = topics[1];
|
||||
let deviceNum = topics[2];
|
||||
message = JSON.parse(message.toString());
|
||||
if (topics[3] == 'status') {
|
||||
console.log('接收到【设备状态-详情】主题：', topic);
|
||||
console.log('接收到【设备状态-详情】内容：', message);
|
||||
// 更新列表中设备的状态
|
||||
if (this.form.serialNumber == deviceNum) {
|
||||
mqttCallback() {
|
||||
this.$mqttTool.client.on('message', (topic, message, buffer) => {
|
||||
let topics = topic.split('/');
|
||||
let productId = topics[1];
|
||||
let deviceNum = topics[2];
|
||||
message = JSON.parse(message.toString());
|
||||
if (topics[3] == 'status') {
|
||||
console.log('接收到【设备状态-详情】主题：', topic);
|
||||
console.log('接收到【设备状态-详情】内容：', message);
|
||||
// 更新列表中设备的状态
|
||||
if (this.form.serialNumber == deviceNum) {
|
||||
this.oldDeviceStatus = message.status;
|
||||
this.form.status = message.status;
|
||||
this.form.isShadow = message.isShadow;
|
||||
this.form.rssid = message.rssid;
|
||||
}
|
||||
}
|
||||
});
|
||||
},
|
||||
this.form.isShadow = message.isShadow;
|
||||
this.form.rssid = message.rssid;
|
||||
}
|
||||
}
|
||||
});
|
||||
},
|
||||
/** Mqtt订阅主题 */
|
||||
mqttSubscribe(device) {
|
||||
// 订阅当前设备状态和实时监测
|
||||
let topicStatus = '/' + device.productId + '/' + device.serialNumber + '/status/post';
|
||||
let topicProperty = '/' + device.productId + '/' + device.serialNumber + '/property/post';
|
||||
let topicFunction = '/' + device.productId + '/' + device.serialNumber + '/function/post';
|
||||
let topics = [];
|
||||
topics.push(topicStatus);
|
||||
topics.push(topicProperty);
|
||||
topics.push(topicFunction);
|
||||
this.$mqttTool.subscribe(topics);
|
||||
},
|
||||
/** Mqtt取消订阅主题 */
|
||||
mqttUnSubscribe(device) {
|
||||
// 订阅当前设备状态和实时监测
|
||||
let topicStatus = '/' + device.productId + '/' + device.serialNumber + '/status/post';
|
||||
let topicProperty = '/' + device.productId + '/' + device.serialNumber + '/property/post';
|
||||
let topicFunction = '/' + device.productId + '/' + device.serialNumber + '/function/post';
|
||||
let topics = [];
|
||||
topics.push(topicStatus);
|
||||
topics.push(topicProperty);
|
||||
topics.push(topicFunction);
|
||||
console.log('取消订阅', topics);
|
||||
this.$mqttTool.unsubscribe(topics);
|
||||
},
|
||||
mqttSubscribe(device) {
|
||||
// 订阅当前设备状态和实时监测
|
||||
let topicStatus = '/' + device.productId + '/' + device.serialNumber + '/status/post';
|
||||
let topicProperty = '/' + device.productId + '/' + device.serialNumber + '/property/post';
|
||||
let topicFunction = '/' + device.productId + '/' + device.serialNumber + '/function/post';
|
||||
let topics = [];
|
||||
topics.push(topicStatus);
|
||||
topics.push(topicProperty);
|
||||
topics.push(topicFunction);
|
||||
this.$mqttTool.subscribe(topics);
|
||||
},
|
||||
/** Mqtt取消订阅主题 */
|
||||
mqttUnSubscribe(device) {
|
||||
// 订阅当前设备状态和实时监测
|
||||
let topicStatus = '/' + device.productId + '/' + device.serialNumber + '/status/post';
|
||||
let topicProperty = '/' + device.productId + '/' + device.serialNumber + '/property/post';
|
||||
let topicFunction = '/' + device.productId + '/' + device.serialNumber + '/function/post';
|
||||
let topics = [];
|
||||
topics.push(topicStatus);
|
||||
topics.push(topicProperty);
|
||||
topics.push(topicFunction);
|
||||
console.log('取消订阅', topics);
|
||||
this.$mqttTool.unsubscribe(topics);
|
||||
},
|
||||
|
||||
// 获取子组件订阅的设备状态
|
||||
getDeviceStatus(status) {
|
||||
@@ -374,7 +379,7 @@ export default {
|
||||
this.oldDeviceStatus = this.form.status;
|
||||
this.loadMap();
|
||||
//Mqtt订阅
|
||||
this.mqttSubscribe(this.form);
|
||||
this.mqttSubscribe(this.form);
|
||||
});
|
||||
},
|
||||
/**加载地图*/
|
||||
@@ -429,6 +434,20 @@ export default {
|
||||
},
|
||||
/** 提交按钮 */
|
||||
submitForm() {
|
||||
if (this.form.serialNumber == null || this.form.serialNumber == 0) {
|
||||
this.$modal.alertError("设备编号不能为空");
|
||||
return;
|
||||
}
|
||||
let reg = /^[0-9a-zA-Z]+$/;
|
||||
if (!reg.test(this.form.serialNumber)) {
|
||||
this.$modal.alertError("设备编号只能是字母和数字");
|
||||
return;
|
||||
}
|
||||
if (this.form.productId == null || this.form.productId == 0) {
|
||||
this.$modal.alertError("所属产品不能为空");
|
||||
return;
|
||||
}
|
||||
|
||||
this.$refs["form"].validate(valid => {
|
||||
if (valid) {
|
||||
if (this.form.deviceId != 0) {
|
||||
@@ -444,7 +463,8 @@ export default {
|
||||
} else {
|
||||
addDevice(this.form).then(response => {
|
||||
this.form = response.data;
|
||||
this.oldDeviceStatus = this.from.status;
|
||||
console.log(response);
|
||||
this.oldDeviceStatus = this.form.status;
|
||||
if (this.form.deviceId == null || this.form.deviceId == 0) {
|
||||
this.$modal.alertError("设备编号已经存在，添加设备失败");
|
||||
} else {
|
||||
@@ -475,13 +495,13 @@ export default {
|
||||
},
|
||||
/**关闭物模型 */
|
||||
openSummaryDialog() {
|
||||
let json={
|
||||
type:1,// 1=扫码关联设备
|
||||
deviceNumber:this.form.serialNumber,
|
||||
productId:this.form.productId,
|
||||
productName:this.form.productName,
|
||||
let json = {
|
||||
type: 1, // 1=扫码关联设备
|
||||
deviceNumber: this.form.serialNumber,
|
||||
productId: this.form.productId,
|
||||
productName: this.form.productName,
|
||||
};
|
||||
this.qrText=JSON.stringify(json);
|
||||
this.qrText = JSON.stringify(json);
|
||||
this.openSummary = true;
|
||||
},
|
||||
/**关闭物模型 */
|
||||
|
||||
@@ -217,6 +217,7 @@ export default {
|
||||
this.MonitorChart();
|
||||
});
|
||||
});
|
||||
this.connectMqtt();
|
||||
}
|
||||
}
|
||||
},
|
||||
@@ -259,10 +260,16 @@ export default {
|
||||
}
|
||||
},
|
||||
created() {
|
||||
// 回调处理
|
||||
this.mqttCallback();
|
||||
|
||||
},
|
||||
methods: {
|
||||
/* 连接Mqtt消息服务器 */
|
||||
async connectMqtt() {
|
||||
if (this.$mqttTool.client == null) {
|
||||
await this.$mqttTool.connect(this.vuex_token);
|
||||
}
|
||||
this.mqttCallback();
|
||||
},
|
||||
/* Mqtt回调处理 */
|
||||
mqttCallback() {
|
||||
this.$mqttTool.client.on('message', (topic, message, buffer) => {
|
||||
|
||||
Reference in New Issue
Block a user