/**
|
* 服务池配置文件
|
* 注册系统中所有服务的事件处理回调，处理来自各模块的事件
|
*/
|
import pool from '../dxmodules/dxWorkerPool.js'
|
import face from '../dxmodules/dxFace.js'
|
import driver from './driver.js'
|
import bus from '../dxmodules/dxEventBus.js'
|
import faceService from './service/faceService.js'
|
import net from '../dxmodules/dxNet.js'
|
import config from '../dxmodules/dxConfig.js'
|
import nfc from '../dxmodules/dxNfc.js'
|
import mqtt from '../dxmodules/dxMqtt.js'
|
import map from '../dxmodules/dxMap.js'
|
import mqttService from './service/mqttService.js'
|
import accessService from './service/accessService.js'
|
import nfcService from './service/nfcService.js'
|
import common from '../dxmodules/dxCommon.js'
|
import log from '../dxmodules/dxLogger.js'
|
import dxGpioKey from '../dxmodules/dxGpioKey.js'
|
import uart from '../dxmodules/dxUart.js'
|
import uart485Service from './service/uart485Service.js'
|
import configService from './service/configService.js'
|
import grainService from './service/grainService.js'
|
import gpiokeyService from './service/gpiokeyService.js'
|
import codeService from './service/codeService.js'
|
|
/**
|
* 服务池回调函数
|
* 处理来自各模块的事件消息，根据事件主题分发到相应的服务处理
|
* @param {object} data - 事件数据
|
* @param {string} data.topic - 事件主题
|
* @param {any} data.data - 事件数据
|
*/
|
pool.callback((data) => {
|
let topic = data.topic
|
let msg = data.data
|
switch (topic) {
|
case face.RECEIVE_MSG:
|
// 处理人脸识别消息
|
faceService.receiveMsg(msg)
|
break;
|
case dxGpioKey.RECEIVE_MSG:
|
// 处理GPIO按键消息
|
gpiokeyService.receiveMsg(msg)
|
break;
|
case "netGetWifiSsidList":
|
// 获取WiFi列表
|
let wifiList = driver.net.netGetWifiSsidList()
|
bus.fire("netWifiSsidList", wifiList)
|
break;
|
case "switchNetworkType":
|
// 切换网络类型
|
config.setAndSave("net.type", msg)
|
console.log("切换网络", msg);
|
driver.net.changeNetType()
|
break;
|
case "setConfig":
|
// 配置验证和保存
|
configService.configVerifyAndSave(msg)
|
break;
|
case "access":
|
// 处理通行验证
|
accessService.access(msg.data, msg.fileName, msg.similarity)
|
break;
|
case nfc.RECEIVE_MSG:
|
// 处理NFC卡片消息
|
nfcService.receiveMsg(msg)
|
break;
|
case net.STATUS_CHANGE:
|
// 网络状态变化
|
map.get("NET").put("status", msg.status)
|
bus.fire("netStatus", msg)
|
break;
|
case mqtt.CONNECTED_CHANGED:
|
// MQTT连接状态变化
|
bus.fire("mqttStatus", msg)
|
// mqtt连接上报
|
if (msg == "connected") {
|
mqttService.report()
|
}
|
break;
|
case mqtt.RECEIVE_MSG:
|
// 处理MQTT消息
|
mqttService.receiveMsg(msg)
|
break;
|
case uart.VG.RECEIVE_MSG + driver.uart485.id:
|
// 处理UART485指令消息
|
uart485Service.receive(msg, 'instruction')
|
break;
|
case uart.VG.RECEIVE_MSG + driver.uartCode.id:
|
// 处理UART码消息
|
uart485Service.receive(msg, 'code')
|
break;
|
case "getCode":
|
// 处理条码数据
|
codeService.code(msg)
|
break;
|
case "trackResult":
|
// 处理人脸识别结果事件（由mainView.js处理）
|
break;
|
|
default:
|
// 未知主题
|
log.error("No such topic ", topic)
|
break;
|
}
|
})
|
