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<PushWeightEntity>;
|
|
@InjectEntityModel(PushSiteweightEntity)
|
pushSiteweightEntity: Repository<PushSiteweightEntity>;
|
|
@InjectEntityModel(PushCameraGpsEntity)
|
pushCameraGpsEntity: Repository<PushCameraGpsEntity>;
|
|
@InjectEntityModel(PushVehicleGpsEntity)
|
pushVehicleGpsEntity: Repository<PushVehicleGpsEntity>;
|
|
@InjectEntityModel(PushDeviceOnoffEntity)
|
pushDeviceOnoffEntity: Repository<PushDeviceOnoffEntity>;
|
|
@InjectEntityModel(PushDevicealarmEntity)
|
pushDevicealarmEntity: Repository<PushDevicealarmEntity>;
|
|
@InjectEntityModel(PushAuditlogEntity)
|
pushAuditlogEntity: Repository<PushAuditlogEntity>;
|
|
@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<string, string>[] = [];
|
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();
|
}
|
|
}
|
