import { InjectClient, Provide, Inject } from '@midwayjs/core'; import { BaseService } from '@cool-midway/core'; import { InjectEntityModel } from '@midwayjs/typeorm'; import { Repository } from 'typeorm'; import { PushWeightEntity } from '../entity/weight'; import { PushSiteweightEntity } from '../entity/siteweight'; import { PushAuditlogEntity } from '../entity/auditlog'; import { PushCameraGpsEntity } from '../entity/cameragps'; import { PushVehicleGpsEntity } from '../entity/vehiclegps'; import { PushDeviceOnoffEntity } from '../entity/deviceonoff'; import { PushDevicealarmEntity } from '../entity/devicealarm'; import { PluginService } from '../../plugin/service/info'; import { CachingFactory, MidwayCache } from '@midwayjs/cache-manager'; /** * 开放接口业务逻辑服务 */ @Provide() export class PushOpenService extends BaseService { @InjectEntityModel(PushWeightEntity) pushWeightEntity: Repository; @InjectEntityModel(PushSiteweightEntity) pushSiteweightEntity: Repository; @InjectEntityModel(PushCameraGpsEntity) pushCameraGpsEntity: Repository; @InjectEntityModel(PushVehicleGpsEntity) pushVehicleGpsEntity: Repository; @InjectEntityModel(PushDeviceOnoffEntity) pushDeviceOnoffEntity: Repository; @InjectEntityModel(PushDevicealarmEntity) pushDevicealarmEntity: Repository; @InjectEntityModel(PushAuditlogEntity) pushAuditlogEntity: Repository; @Inject() pluginService: PluginService; @InjectClient(CachingFactory, 'default') midwayCache: MidwayCache; /** * 上报称重数据核心业务 */ async reportWeight(data: any) { const logTime = new Date(); try { // 1. 保存原始称重数据 const rawWeight = new PushWeightEntity(); rawWeight.deviceNo = data.deviceNo; rawWeight.uploadTime = data.uploadTime ? new Date(data.uploadTime) : new Date(); rawWeight.garbageType = data.garbageType; rawWeight.weight = data.garbageWeight || 0; rawWeight.extraData = typeof data.extraData === 'object' ? JSON.stringify(data.extraData) : data.extraData; await this.pushWeightEntity.save(rawWeight); // 2. 模拟关联基础数据模块查询获取商户信息并写入业务称重表 const siteWeight = new PushSiteweightEntity(); siteWeight.deviceNo = data.deviceNo; siteWeight.uploadTime = rawWeight.uploadTime; siteWeight.garbageType = data.garbageType; siteWeight.weight = data.garbageWeight || 0; siteWeight.extraData = rawWeight.extraData; // 动态查询设备基础数据关联信息 const iotDevices = await this.nativeQuery( 'SELECT businessId, departmentId FROM t_basicdata_iot WHERE iotCode = ? LIMIT 1', [data.deviceNo], ); if (iotDevices && iotDevices.length > 0) { siteWeight.businessId = iotDevices[0].businessId; siteWeight.departmentId = iotDevices[0].departmentId; await this.pushSiteweightEntity.save(siteWeight); } else { siteWeight.businessId = 'UNKNOWN'; siteWeight.departmentId = -1; await this.writePushAuditLog("weight", { "deviceNo": data.deviceNo, "requestContent": data, "errorMessage": "电子秤还未分配到垃圾收集点." }); } } catch (err) { await this.writePushAuditLog("weight", { "deviceNo": data.deviceNo || "UNKNOW", "requestContent": data, "errorMessage": err }); } } /** * 接收萤石云 消息并缓存 */ async saveYingshiyunMessage(body: any) { const messageId = body?.header?.messageId || Math.random().toString(36).substring(2); await this.midwayCache.set(`push:yingshiyun:queue:${messageId}`, JSON.stringify(body), 24 * 3600); this.processYingshiyunAsync(messageId).catch(err => { console.error('异步处理GPS消息失败:', err); }); return messageId; } /** * 异步解析萤石云消息，按照消息类型 入库 */ async processYingshiyunAsync(messageId: string) { const dataStr = await this.midwayCache.get(`push:yingshiyun:queue:${messageId}`) as string | null; if (!dataStr) return; const body = JSON.parse(dataStr); const type = body?.header?.type; console.log(`---------------------------------${type}`); try { switch (type) { // 设备上下线 case 'ys.onoffline': { const onoffData: any = { deviceId: body.header.deviceId, channelNo: Number(body.header.channelNo) || 0, messageId: body.header.messageId, messageTime: new Date(Number(body.header.messageTime)), msgType: body.body.msgType, devType: body.body.devType || '', deviceName: body.body.deviceName || '', subSerial: body.body.subSerial || '', dasId: body.body.dasId || '', natIp: body.body.natIp || '', occurTime: body.body.occurTime ? new Date(body.body.occurTime.replace(' ', 'T')) : null, regTime: body.body.regTime ? new Date(body.body.regTime.replace(' ', 'T')) : null, }; await this.pushDeviceOnoffEntity.save(onoffData); break; } // 萤石告警 case 'ys.alarm': { const alarmData: any = { devSerial: body.body.devSerial, alarmId: body.body.alarmId, alarmTime: body.body.alarmTime ? new Date(body.body.alarmTime.replace('T', ' ')) : new Date(), alarmType: body.body.alarmType, channelName: body.body.channelName, channelType: Number(body.body.channelType) || 1, customInfo: body.body.customInfo || '', customType: body.body.customType || '', describe: body.body.describe || '', location: body.body.location || '', relationId: body.body.relationId || '', status: Number(body.body.status) || 1, channelNo: String(body.body.channel ?? body.body.channelNo ?? ''), }; if (body.body.checksum) alarmData.checksum = body.body.checksum; if (body.body.crypt !== undefined) alarmData.crypt = Number(body.body.crypt); // 图片处理（有则处理，无则跳过） const localUrls: Record[] = []; if (body.body.pictureList?.length) { try { const filePlugin = await this.pluginService.getInstance('upload'); for (const item of body.body.pictureList) { try { const result = await filePlugin.downAndUpload(item.url); localUrls.push({ url: result, id: item.id }); } catch (err) { console.error(`图片下载失败: ${item.url}`, err); } } } catch (err) { console.error('filePlugin init failed:', err); } } alarmData.pictureList = localUrls; await this.pushDevicealarmEntity.save(alarmData); break; } //海康 ISAPI case 'ys.open.isapi': { console.log(`---------start ys.isapi-------------------------------`); console.log(body); //TODO: 解析海康 ISAPI 消息，入库 // 消息类型: ys.open.isapi | messageId: 6a69a482d05a3d0d7cdb5c83 打印内容如下： // ---------------------------------ys.open.isapi // ---------start ys.isapi------------------------------- // { // body: { // payload: '{"ipAddress": "10.83.239.158", "protocol": "HTTP", "dateTime": "2026-07-29T14:58:07+08:00", "activePostCount": 1, "eventType": "deviceStatus", "deviceID": "RkYmx96HhzkQHnK+te7tNB89AAHahWc=", "eventState": "active", "eventDescription": "device Status", "DeviceStatus": {"sleepStatus": "sleep", "batteryList": [{"id": 1, "voltage": 3595, "current": 137, "batteryPercentage": 33, "temperature": 36, "remainingBattery": 16.829, "state": "charing", "protocolType": "ADC", "lowTemperatureHeatingStatus": "stop", "protocolVersion": "1.0"}], "solarPanelStatus": {"voltage": 4.919, "current": 918, "power": 4.509, "powerGeneration": 3.790}, "powerConsumptionStatus": {"voltage": 0.000, "current": 0, "power": 0.000, "powerConsumption": 0.220}, "dialStatusList": [{"dialSignalStrength": 5, "band": "B39", "PCI": 63}]}}' // }, // header: { // channelNo: 0, // deviceId: 'GN3665733', // messageId: '6a69a482d05a3d0d7cdb5c83', // messageTime: 1785308290000, // type: 'ys.open.isapi' // } // } // processCameraGpsAsync(body) // await this.pushIsapiRepo.save({ // messageId, // raw: JSON.stringify(body), // createTime: new Date(), // }); break; } default: console.warn('Unknown yingshi webhook type:', type); } } catch (err) { await this.writePushAuditLog(type || 'unknown', { deviceNo: body?.sn || 'UNKNOWN', requestContent: body, errorMessage: err, }); } // 不管成功与否，删除缓存中的任务队列 await this.midwayCache.del(`push:yingshiyun:queue:${messageId}`); } /** * 异步解析车载监控的GPS数据，存储并添加业务表 */ async processCameraGpsAsync(body: any) { try { let vehicleNo = ''; if (body.sn) { const gpsData = body.data || {}; const statusVal = gpsData.status === 'A' ? 'A' : 'B'; await this.pushCameraGpsEntity.save({ sn: body.sn, msgSeq: body.msgSeq, createDate: body.createDate && !isNaN(Number(body.createDate)) ? new Date(Number(body.createDate)) : new Date(), gpsTime: gpsData.gpsTime ? new Date(gpsData.gpsTime.replace(' ', 'T')) : new Date(), longitude: gpsData.longitude, latitude: gpsData.latitude, speed: gpsData.speed, direction: gpsData.direction, elevation: gpsData.elevation, status: statusVal, }); const iotDevice: any[] = await this.nativeQuery( 'SELECT businessId FROM t_basicdata_iot WHERE iotCode = ? LIMIT 1', [body.sn] ); if (iotDevice && iotDevice.length > 0 && iotDevice[0].businessId) { vehicleNo = `vehicle_${iotDevice[0].businessId}`; await this.pushVehicleGpsEntity.save({ sn: body.sn, msgSeq: body.msgSeq, createDate: body.createDate && !isNaN(Number(body.createDate)) ? new Date(Number(body.createDate)) : new Date(), vehicleNo, gpsTime: gpsData.gpsTime ? new Date(gpsData.gpsTime.replace(' ', 'T')) : new Date(), longitude: gpsData.longitude, latitude: gpsData.latitude, speed: gpsData.speed, direction: gpsData.direction, elevation: gpsData.elevation, status: statusVal, }); } else { await this.writePushAuditLog("camera_gps", { "deviceNo": body.sn, "requestContent": body, "errorMessage": "车载监控还未分配到车辆" }); } } else { await this.writePushAuditLog("camera_gps", { "deviceNo": "UNKOWN", "requestContent": body, "errorMessage": "未包含设备号SN" }); } } catch (err: any) { await this.writePushAuditLog("camera_gps", { "deviceNo": body.sn || "UNKNOW", "requestContent": body, "errorMessage": err }); } } async writePushAuditLog(pushType: string, data: any) { let isSuccess = true; let errorMsg = ''; try { const auditLog = new PushAuditlogEntity(); auditLog.logTime = new Date(); auditLog.pushType = pushType; auditLog.deviceNo = data.deviceNo || 'unknown-device'; auditLog.requestContent = JSON.stringify(data.requestContent); auditLog.errorMessage = data.errorMessage || 'unknown-erroe'; await this.pushAuditlogEntity.save(auditLog); } catch (err) { isSuccess = false; } } /** * 保存摄像头主动上报告警事件 * @param alarmData */ async saveCameraAlarmEvent(alarmData: any) { const { eventType, targetType, ipAddress, dateTime } = alarmData; if (eventType === 'VMD') { console.log(`【移动侦测告警】设备${ipAddress}，时间：${dateTime},目标类型:${targetType}`); // TODO: 完成摄像机侦测数据保存 } else { console.log(`【未知摄像头事件类型】type:${eventType}`); } return Date.now(); } }