"use strict";
|
|
const { DeviceConnection } = require("./device-connection");
|
|
class DeviceManager {
|
constructor({ config, dataCache, logger, uploadManager }) {
|
this.config = config;
|
this.dataCache = dataCache;
|
this.logger = logger;
|
this.uploadManager = uploadManager;
|
this._connections = new Map();
|
}
|
|
startAll() {
|
const enabled = this.config.devices.filter((d) => d.enabled !== false);
|
const disabled = this.config.devices.length - enabled.length;
|
|
for (const device of this.config.devices) {
|
this.dataCache.update(device.ip, {
|
serialNumber: device.serialNumber,
|
status: device.enabled === false ? "disabled" : "pending",
|
lastPollAt: null, lastDataAt: null,
|
rawFrame: null, parsed: null, errorMessage: null, reconnectCount: 0,
|
});
|
}
|
|
this.logger.sys(`启动 ${enabled.length} 台设备` + (disabled > 0 ? ` (${disabled} 台已禁用)` : ""));
|
|
for (const device of enabled) {
|
const conn = new DeviceConnection({
|
ip: device.ip,
|
port: device.port,
|
serialNumber: device.serialNumber,
|
config: this.config,
|
dataCache: this.dataCache,
|
logger: this.logger,
|
uploadManager: this.uploadManager,
|
});
|
this._connections.set(device.ip, conn);
|
conn.start();
|
}
|
}
|
|
stopAll() {
|
this.logger.sys(`停止 ${this._connections.size} 台设备连接`);
|
for (const [, conn] of this._connections) {
|
conn.stop();
|
}
|
this._connections.clear();
|
}
|
|
restart(ip) {
|
const conn = this._connections.get(ip);
|
if (conn) {
|
this.logger.sys(`${ip} 手动重启`);
|
conn.stop();
|
conn.start();
|
}
|
}
|
}
|
|
module.exports = { DeviceManager };
|
