电表接入2

src/service/mqttInit.ts

-import { processDeviceData} from "../biz/mqttClient";
+import { electricDeviceData} from "../biz/mqttClient";
 import { systemConfig } from "../config/serverConfig";
 
 const mqtt = require('mqtt');
@@ -35,7 +35,7 @@ export async function startMqttClient() {
     client.on('message', (topic, message) => {
         // 只处理配置的上行主题
         if (topic === systemConfig.mqttsrv.topic_env) {
-            processDeviceData(message);
+            electricDeviceData(message);
         }
     });