"use strict";
|
|
const { mapItemsToUploadData } = require("./field-mapper");
|
const { MqttUploader } = require("./mqtt-uploader");
|
const { AliyunUploader } = require("./aliyun-uploader");
|
|
class UploadManager {
|
constructor({ mqttConfig, aliyunConfig, logger }) {
|
this.logger = logger;
|
|
this.mqtt = new MqttUploader({ config: mqttConfig, logger });
|
this.aliyun = new AliyunUploader({ config: aliyunConfig, logger });
|
|
this._lastUpload = null; // { deviceNo, timestamp, mqttResult, aliyunResult }
|
}
|
|
start() {
|
this.mqtt.start();
|
this.aliyun.start();
|
this.logger.upload("system", "start", "", "上传模块已启动");
|
}
|
|
getStatus() {
|
return {
|
mqtt: this.mqtt.getStatus(),
|
aliyun: this.aliyun.getStatus(),
|
lastUpload: this._lastUpload,
|
};
|
}
|
|
stop() {
|
this.mqtt.stop();
|
this.aliyun.stop();
|
}
|
|
async upload({ serialNumber, ip, items }) {
|
const deviceNo = String(serialNumber || "").trim();
|
|
if (!deviceNo) {
|
this.logger.upload("system", "validate", "", "设备序列号为空，跳过上传");
|
return { ok: false, deviceNo: null, code: "DEVICE_NO_MISSING", reason: "serialNumber is required" };
|
}
|
|
// 将 items [{id, value}] 映射为阿里云字段格式
|
const deviceData = mapItemsToUploadData(items);
|
|
// suedtime: yyyy-MM-dd HH:mm:ss
|
const now = new Date();
|
const suedtime = now.getFullYear() + "-" +
|
String(now.getMonth() + 1).padStart(2, "0") + "-" +
|
String(now.getDate()).padStart(2, "0") + " " +
|
String(now.getHours()).padStart(2, "0") + ":" +
|
String(now.getMinutes()).padStart(2, "0") + ":" +
|
String(now.getSeconds()).padStart(2, "0");
|
|
// 构建上传 payload
|
const payload = {
|
msgType: "device_data",
|
clientCode: this.mqtt.config.clientCode || null,
|
n: deviceNo,
|
deviceType: "GC-110N",
|
suedtime,
|
IPAddress: ip || "",
|
...deviceData,
|
timestamp: now.toISOString(),
|
};
|
|
this.logger.upload("system", "upload", deviceNo, `开始上传 IP=${ip}`);
|
|
// 顺序执行：先 MQTT 再阿里云（互不影响）
|
const mqttResult = await this.mqtt.publish(deviceNo, payload);
|
const aliyunResult = await this.aliyun.upload(deviceNo, payload);
|
|
const result = {
|
ok: (mqttResult.ok || !mqttResult.enabled) && (aliyunResult.ok || !aliyunResult.enabled),
|
deviceNo,
|
mqtt: mqttResult,
|
aliyun: aliyunResult,
|
};
|
|
this._lastUpload = {
|
deviceNo,
|
timestamp: now.toISOString(),
|
mqttOk: mqttResult.ok,
|
aliyunOk: aliyunResult.ok,
|
};
|
|
return result;
|
}
|
}
|
|
module.exports = { UploadManager };
|
