ar mongoose = require(‘mongoose’); var Schema = mongoose.Schema; var Connection = require(’./connection’) var DeviceACL = require("…/models/device_acl") const emqxService = require("…/services/emqx_service") const influxDBService = require("…/services/influxdb_service") const ObjectId = require(‘bson’).ObjectID;

const deviceSchema = new Schema({ //ProductName product_name: { type: String, required: true }, //DeviceName device_name: { type: String, required: true, }, //接入EMQX时使用的username broker_username: { type: String, required: true }, //secret secret: { type: String, required: true, },

//可接入状态
status: String,
device_status: {
    type: String,
    default: "{}"
},
last_status_update: Number,

tags: {
    type: Array,
    default: []
},

tags_version: {
    type: Number,
    default: 1
},
shadow: {
    type: String,
    default: JSON.stringify({
        "state": {},
        "metadata": {},
        "version": 0
    })
}

})

deviceSchema.methods.toJSONObject = function () { return { product_name: this.product_name, device_name: this.device_name, secret: this.secret, device_status: JSON.parse(this.device_status), tags: this.tags, shadow: JSON.parse(this.shadow), } }

deviceSchema.statics.addConnection = function (event) { if(event.username != null) { var username_arr = event.username.split("/") let productName = username_arr[0]; let deviceName = username_arr[1]; this.findOne({product_name: productName, device_name: deviceName}, function (err, device) { if (err == null && device != null) { Connection.findOneAndUpdate({ client_id: event.client_id, device: device._id }, { connected: true, client_id: event.client_id, keepalive: event.keepalive, ipaddress: event.ipaddress, proto_ver: event.proto_ver, connected_at: event.connected_at, conn_ack: event.conn_ack, device: device._id }, {upsert: true, useFindAndModify: false, new: true}).exec() influxDBService.writeConnectionData({ productName: productName, deviceName: deviceName, connected: true, ts: event.connected_at }) } }) }

}

deviceSchema.statics.removeConnection = function (event) { if(event.username != null) { var username_arr = event.username.split("/") let productName = username_arr[0]; let deviceName = username_arr[1]; this.findOne({product_name: productName, device_name: deviceName}, function (err, device) { if (err == null && device != null) { Connection.findOneAndUpdate({client_id: event.client_id, device: device._id}, { connected: false, disconnect_at: Math.floor(Date.now() / 1000) }, {useFindAndModify: false}).exec() influxDBService.writeConnectionData({ productName: productName, deviceName: deviceName, connected: false }) } }) } }

deviceSchema.methods.getACLRule = function () { const publish = [ upload_data/${this.product_name}/${this.device_name}/+/+, update_status/${this.product_name}/${this.device_name}/+, cmd_resp/${this.product_name}/${this.device_name}/+/+/+, rpc_resp/${this.product_name}/${this.device_name}/+/+/+, get/${this.product_name}/${this.device_name}/+/+, m2m/${this.product_name}/+/${this.device_name}/+, update_ota_status/${this.product_name}/${this.device_name}/+, ] const subscribe = [tags/${this.product_name}/+/cmd/+/+/+/#] const pubsub = [] return { publish: publish, subscribe: subscribe, pubsub: pubsub } }

deviceSchema.methods.disconnect = function () { Connection.find({device: this._id}).exec(function (err, connections) { connections.forEach(function (conn) { emqxService.disconnectClient(conn.client_id) }) }) }

deviceSchema.post(“remove”, function (device, next) { Connection.deleteMany({device: device._id}).exec() DeviceACL.deleteMany({broker_username: device.broker_username}).exec() next() })

deviceSchema.methods.sendCommand = function ({commandName, data, encoding = “plain”, ttl = undefined, commandType = “cmd”, qos = 1}) { return Device.sendCommand({ productName: this.product_name, deviceName: this.device_name, commandName: commandName, data: data, encoding: encoding, ttl: ttl, commandType: commandType, qos: qos }) }

deviceSchema.statics.sendCommand = function ({productName, deviceName, commandName, data, encoding = “plain”, ttl = undefined, commandType = “cmd”, qos = 1}) { var requestId = new ObjectId().toHexString() var topic = ${commandType}/${productName}/${deviceName}/${commandName}/${encoding}/${requestId} if (ttl != null) { topic = ${topic}/${Math.floor(Date.now() / 1000) + ttl} } emqxService.publishTo({topic: topic, payload: data, qos: qos}) return requestId }

deviceSchema.statics.sendCommandByTag = function ({productName, tag, commandName, data, encoding = “plain”, ttl = undefined, qos = 1}) { var requestId = new ObjectId().toHexString() var topic = tags/${productName}/${tag}/cmd/${commandName}/${encoding}/${requestId} if (ttl != null) { topic = ${topic}/${Math.floor(Date.now() / 1000) + ttl} } emqxService.publishTo({topic: topic, payload: data, qos: qos}) }

deviceSchema.methods.sendTags = function () { this.sendCommand({ commandName: “$set_tags”, data: JSON.stringify({tags: this.tags || [], tags_version: this.tags_version || 1}), qos: 0 }) }

deviceSchema.methods.updateShadowDesired = function (desired, version) { var ts = Math.floor(Date.now() / 1000) var shadow = JSON.parse(this.shadow) if (version > shadow.version) { shadow.state.desired = shadow.state.desired || {} shadow.metadata.desired = shadow.metadata.desired || {} for (var key in desired) { shadow.state.desired[key] = desired[key] shadow.metadata.desired[key] = {timestamp: ts} } shadow.version = version shadow.timestamp = ts this.shadow = JSON.stringify(shadow) this.save() this.sendUpdateShadow() return true } else { return false } }

deviceSchema.methods.sendUpdateShadow = function () { this.sendCommand({ commandName: “$update_shadow”, data: this.shadow, qos: 0 }) }

deviceSchema.methods.updateShadow = function (shadowUpdated) { var ts = Math.floor(Date.now() / 1000) var shadow = JSON.parse(this.shadow) if (shadow.version == shadowUpdated.version) { if (shadowUpdated.state.desired == null) { shadow.state.desired = shadow.state.desired || {} shadow.state.reported = shadow.state.reported || {} shadow.metadata.reported = shadow.metadata.reported || {} for (var key in shadow.state.desired) { if (shadow.state.desired[key] != null) { shadow.state.reported[key] = shadow.state.desired[key] shadow.metadata.reported[key] = {timestamp: ts} } else { delete(shadow.state.reported[key]) delete(shadow.metadata.reported[key]) } } shadow.timestamp = ts shadow.version = shadow.version + 1 delete(shadow.state.desired) delete(shadow.metadata.desired) this.shadow = JSON.stringify(shadow) this.save() this.sendCommand({ commandName: “$shadow_reply”, data: JSON.stringify({status: “success”, timestamp: ts, version: shadow.version}), qos: 0 }) } } else { this.sendUpdateShadow() } }

deviceSchema.methods.reportShadow = function (shadowReported) { var ts = Math.floor(Date.now() / 1000) var shadow = JSON.parse(this.shadow) if (shadow.version == shadowReported.version) { shadow.state.reported = shadow.state.reported || {} shadow.metadata.reported = shadow.metadata.reported || {} for (var key in shadowReported.state.reported) { if (shadowReported.state.reported[key] != null) { shadow.state.reported[key] = shadowReported.state.reported[key] shadow.metadata.reported[key] = {timestamp: ts} } else { delete(shadow.state.reported[key]) delete(shadow.metadata.reported[key]) } } shadow.timestamp = ts shadow.version = shadow.version + 1 this.shadow = JSON.stringify(shadow) this.save() this.sendCommand({ commandName: “$shadow_reply”, data: JSON.stringify({status: “success”, timestamp: ts, version: shadow.version}), qos: 0 }) } else { this.sendUpdateShadow() } }

const Device = mongoose.model(“Device”, deviceSchema);

module.exports = Device; 那个大神能教我一下，什么情况下导出的模块是不带操作的，什么样的情况下是带操作导出的，我有点搞不清楚，标准在什么地方，就是我想知道我导出模块的内容包括哪些，比如这个代码的deviceSchesma做为模块导出后，什么它定义下面的操作都能在其它文件中引用了，我并没有导出这样对模块的操作，比如上面的这个操作deviceSchema.methods.toJSONObject，我在其它文件和中就能直接用。