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 { 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(PushAuditlogEntity)
|
pushAuditlogEntity: Repository<PushAuditlogEntity>;
|
|
|
@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 });
|
}
|
|
}
|
|
/**
|
* 接收GPS消息并缓存
|
*/
|
async receiveCameraGpsMessage(body: any) {
|
const messageId = body.msgSeq || Math.random().toString(36).substring(2);
|
await this.midwayCache.set(`push:cameragps:queue:${messageId}`, JSON.stringify(body), 24 * 3600);
|
this.processCameraGpsAsync(messageId).catch(err => {
|
console.error('异步处理GPS消息失败:', err);
|
});
|
return messageId ;
|
}
|
|
/**
|
* 异步解析车载监控视频的位置数据并入库
|
*/
|
async processCameraGpsAsync(messageId: string) {
|
const dataStr = await this.midwayCache.get(`push:cameragps:queue:${messageId}`) as string | null;
|
if (!dataStr) return;
|
const body = JSON.parse(dataStr);
|
|
try {
|
let vehicleNo = '';
|
if (body.sn) {
|
|
const gpsData = body.data || {};
|
const statusVal = gpsData.status === 'A' ? 0 : 1;
|
|
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" });
|
}
|
|
await this.midwayCache.del(`push:gps:queue:${messageId}`);
|
|
} 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;
|
}
|
|
}
|
|
|
|
|
|
}
|
