import { Provide } from '@midwayjs/core';
|
import { BaseService, CoolCommException } from '@cool-midway/core';
|
import { InjectEntityModel } from '@midwayjs/typeorm';
|
import { Repository } from 'typeorm';
|
import { BasicdataSorterEntity } from '../../basicdata/entity/sorter';
|
import { PushSorterHealthEntity } from '../entity/sorterhealth';
|
import { PushSorterGpsEntity } from '../entity/sortergps';
|
import { PushSiteweightEntity } from '../entity/siteweight';
|
import { BasicdataSiteEntity } from '../../basicdata/entity/site';
|
|
/**
|
* 分拣员上报（健康、GPS、压缩站称重）
|
*/
|
@Provide()
|
export class PushSorterAppService extends BaseService {
|
@InjectEntityModel(BasicdataSorterEntity)
|
basicdataSorterEntity: Repository<BasicdataSorterEntity>;
|
|
@InjectEntityModel(PushSorterHealthEntity)
|
pushSorterHealthEntity: Repository<PushSorterHealthEntity>;
|
|
@InjectEntityModel(PushSorterGpsEntity)
|
pushSorterGpsEntity: Repository<PushSorterGpsEntity>;
|
|
@InjectEntityModel(PushSiteweightEntity)
|
pushSiteweightEntity: Repository<PushSiteweightEntity>;
|
|
@InjectEntityModel(BasicdataSiteEntity)
|
basicdataSiteEntity: Repository<BasicdataSiteEntity>;
|
|
async getSorter(sorterId: string) {
|
const sorter = await this.basicdataSorterEntity.findOneBy({
|
businessId: String(sorterId || '').trim(),
|
});
|
if (!sorter || sorter.status !== 0) {
|
throw new CoolCommException('分拣员账号不可用');
|
}
|
return sorter;
|
}
|
|
async reportHealth(param: any) {
|
const sorter = await this.getSorter(param.sorterId);
|
const row = await this.pushSorterHealthEntity.save({
|
idCard: sorter.businessId,
|
departmentId: sorter.departmentId,
|
uploadTime: param.uploadTime ? new Date(param.uploadTime) : new Date(),
|
temperature: param.temperature,
|
heartRate: param.heartRate,
|
bloodPressureHigh: param.bloodPressureHigh,
|
bloodPressureLow: param.bloodPressureLow,
|
bloodOxygen: param.bloodOxygen,
|
stepCount: param.stepCount || 0,
|
dataType: param.dataType || '周期',
|
});
|
return row;
|
}
|
|
async reportGps(param: any) {
|
const sorter = await this.getSorter(param.sorterId);
|
if (param.longitude == null || param.latitude == null) {
|
throw new CoolCommException('缺少定位信息');
|
}
|
return this.pushSorterGpsEntity.save({
|
idCard: sorter.businessId,
|
name: sorter.businessName,
|
departmentId: sorter.departmentId,
|
uploadTime: param.uploadTime ? new Date(param.uploadTime) : new Date(),
|
longitude: Number(param.longitude),
|
latitude: Number(param.latitude),
|
height: Number(param.height || 0),
|
speed: Number(param.speed || 0),
|
accuracy: Number(param.accuracy || 0),
|
});
|
}
|
|
async addSiteweight(param: any) {
|
const sorter = await this.getSorter(param.sorterId);
|
if (!param.businessId) {
|
throw new CoolCommException('请选择压缩站');
|
}
|
const weight = Number(param.weight);
|
if (!weight || weight <= 0) {
|
throw new CoolCommException('请填写垃圾重量');
|
}
|
const site = await this.basicdataSiteEntity.findOneBy({
|
businessId: String(param.businessId),
|
});
|
return this.pushSiteweightEntity.save({
|
businessId: param.businessId,
|
departmentId: param.departmentId || site?.departmentId || sorter.departmentId,
|
deviceNo: param.deviceNo || '人工填报',
|
uploadTime: param.uploadTime ? new Date(param.uploadTime) : new Date(),
|
garbageType: param.garbageType || 'SW64',
|
weight,
|
remark: param.remark,
|
extraData: JSON.stringify({
|
source: 'sorter-app',
|
sorterId: sorter.businessId,
|
}),
|
});
|
}
|
|
async siteweightPage(query: any) {
|
const { sorterId, page = 1, size = 10 } = query || {};
|
const sorter = await this.getSorter(sorterId);
|
const find = this.pushSiteweightEntity
|
.createQueryBuilder('a')
|
.select([
|
'a.*',
|
'd.businessName AS businessName',
|
'd.siteType AS siteType',
|
])
|
.leftJoin(BasicdataSiteEntity, 'd', 'a.businessId = d.businessId')
|
.where('d.siteType = :st', { st: '压缩站' })
|
.andWhere('a.deviceNo = :dn', { dn: '人工填报' });
|
if (sorter.departmentId) {
|
find.andWhere('a.departmentId = :deptId', {
|
deptId: sorter.departmentId,
|
});
|
}
|
find.orderBy('a.uploadTime', 'DESC');
|
return this.entityRenderPage(find, { ...query, page, size }, false);
|
}
|
}
|
