"use strict";
|
|
const { requestTuple } = require("./tuple-api");
|
|
class AliyunUploader {
|
constructor({ config, logger }) {
|
this.config = config;
|
this.logger = logger;
|
this._devices = new Map(); // deviceNo → { iotDevice, tuple, lastTupleFailedAt }
|
this._aliyunIot = null;
|
}
|
|
start() {
|
if (!this.config.enabled) {
|
this.logger.upload("aliyun", "init", "", "阿里云未启用，跳过");
|
return;
|
}
|
try {
|
this._aliyunIot = require("alibabacloud-iot-device-sdk");
|
this.logger.upload("aliyun", "init", "", "阿里云 IoT SDK 已加载");
|
} catch (err) {
|
this.logger.upload("aliyun", "init", "", `阿里云 IoT SDK 加载失败: ${err.message}`);
|
}
|
}
|
|
async upload(deviceNo, parsedData) {
|
if (!this.config.enabled) {
|
return { enabled: false, ok: true, tuple: { ok: true, code: "ALIYUN_DISABLED" }, props: { ok: true, code: "ALIYUN_DISABLED" } };
|
}
|
|
if (!deviceNo || String(deviceNo).trim() === "") {
|
return { enabled: true, ok: false, tuple: { ok: false, code: "ALIYUN_DEVICE_NO_MISSING" }, props: { ok: false, code: "ALIYUN_PROPS_SKIP", reason: "设备号为空" } };
|
}
|
|
const tupleResult = await this._ensureDevice(deviceNo);
|
|
if (!tupleResult.ok) {
|
return { enabled: true, ok: false, tuple: tupleResult, props: { ok: false, code: "ALIYUN_PROPS_SKIP", reason: "tuple not ready" } };
|
}
|
|
const propsResult = await this._postProps(deviceNo, parsedData);
|
|
return { enabled: true, ok: propsResult.ok, tuple: tupleResult, props: propsResult };
|
}
|
|
async _ensureDevice(deviceNo) {
|
const cached = this._devices.get(deviceNo);
|
if (cached && cached.iotDevice) {
|
return { ok: true, code: "ALIYUN_TUPLE_OK", reason: "device already registered" };
|
}
|
|
// 三元组冷却检查
|
if (cached && cached.lastTupleFailedAt) {
|
const cooldown = this.config.tupleRetryCooldownMs || 60000;
|
if (Date.now() - cached.lastTupleFailedAt < cooldown) {
|
return { ok: false, code: "ALIYUN_TUPLE_RETRY_COOLDOWN", reason: cached.lastTupleFailedReason || "冷却中" };
|
}
|
}
|
|
if (!this._aliyunIot) {
|
return { ok: false, code: "ALIYUN_DEVICE_CREATE_FAIL", reason: "阿里云 SDK 未加载" };
|
}
|
|
const result = await requestTuple({
|
baseUrl: this.config.tupleApiBaseUrl,
|
path: this.config.tupleApiPath,
|
autoRegister: this.config.autoRegister !== false,
|
deviceNo,
|
logger: this.logger,
|
});
|
|
if (!result.ok) {
|
this._devices.set(deviceNo, {
|
lastTupleFailedAt: Date.now(),
|
lastTupleFailedReason: result.reason,
|
});
|
return result;
|
}
|
|
const tuple = result.data;
|
let iotDevice;
|
try {
|
iotDevice = this._aliyunIot.device({
|
ProductKey: tuple.productKey,
|
DeviceName: tuple.deviceName,
|
DeviceSecret: tuple.deviceSecret,
|
});
|
} catch (err) {
|
this.logger.upload("aliyun", "device", deviceNo, `创建 SDK 实例失败: ${err.message}`);
|
return { ok: false, code: "ALIYUN_DEVICE_CREATE_FAIL", reason: err.message };
|
}
|
|
iotDevice.on("connect", () => {
|
this.logger.upload("aliyun", "connect", deviceNo, "阿里云 SDK 已连接");
|
});
|
|
iotDevice.on("error", (err) => {
|
this.logger.upload("aliyun", "error", deviceNo, `阿里云 SDK 错误: ${err.message || err}`);
|
});
|
|
this._devices.set(deviceNo, { iotDevice, tuple, lastTupleFailedAt: null, lastTupleFailedReason: null });
|
|
this.logger.upload("aliyun", "device", deviceNo, "阿里云设备实例创建成功");
|
return { ok: true, code: "ALIYUN_TUPLE_OK", reason: "success" };
|
}
|
|
_postProps(deviceNo, parsedData) {
|
const POSTPROPS_TIMEOUT_MS = 10000;
|
return new Promise((resolve) => {
|
const cached = this._devices.get(deviceNo);
|
if (!cached || !cached.iotDevice) {
|
resolve({ ok: false, code: "ALIYUN_PROPS_SKIP", reason: "没有可用 SDK 实例" });
|
return;
|
}
|
|
let done = false;
|
const timer = setTimeout(() => {
|
if (done) return;
|
done = true;
|
this.logger.upload("aliyun", "postProps", deviceNo, "属性上报超时");
|
resolve({ ok: false, code: "ALIYUN_PROPS_TIMEOUT", reason: "postProps timeout" });
|
}, POSTPROPS_TIMEOUT_MS);
|
|
cached.iotDevice.postProps(parsedData, (res) => {
|
if (done) return;
|
done = true;
|
clearTimeout(timer);
|
if (res && res.message === "success") {
|
this.logger.upload("aliyun", "postProps", deviceNo, "属性上报成功");
|
resolve({ ok: true, code: "ALIYUN_PROPS_OK", reason: "success" });
|
} else {
|
const reason = res ? JSON.stringify(res) : "无响应";
|
this.logger.upload("aliyun", "postProps", deviceNo, `属性上报失败: ${reason}`);
|
resolve({ ok: false, code: "ALIYUN_PROPS_FAIL", reason });
|
}
|
});
|
});
|
}
|
|
getStatus() {
|
let connectedCount = 0;
|
for (const [, dev] of this._devices) {
|
if (dev.iotDevice && dev.iotDevice._mqttClient && dev.iotDevice._mqttClient.connected) {
|
connectedCount++;
|
}
|
}
|
return {
|
enabled: !!this.config.enabled,
|
deviceCount: this._devices.size,
|
connectedCount,
|
};
|
}
|
|
stop() {
|
this._devices.clear();
|
}
|
}
|
|
module.exports = { AliyunUploader };
|
