import { Provide } from '@midwayjs/core';
|
import { BaseService, CoolCommException } from '@cool-midway/core';
|
import { InjectEntityModel } from '@midwayjs/typeorm';
|
import { Repository } from 'typeorm';
|
import { OperationWastesaleEntity } from '../entity/wastesale';
|
import { BasicdataSorterEntity } from '../../basicdata/entity/sorter';
|
import { BasicdataWastetypeEntity } from '../../basicdata/entity/wastetype';
|
import { BasicdataBuyerEntity } from '../../basicdata/entity/buyer';
|
import { BasicdataSiteEntity } from '../../basicdata/entity/site';
|
|
/**
|
* 可回收物收益服务
|
*/
|
@Provide()
|
export class OperationWastesaleService extends BaseService {
|
@InjectEntityModel(OperationWastesaleEntity)
|
operationWastesaleEntity: Repository<OperationWastesaleEntity>;
|
|
@InjectEntityModel(BasicdataSorterEntity)
|
basicdataSorterEntity: Repository<BasicdataSorterEntity>;
|
|
@InjectEntityModel(BasicdataWastetypeEntity)
|
basicdataWastetypeEntity: Repository<BasicdataWastetypeEntity>;
|
|
@InjectEntityModel(BasicdataBuyerEntity)
|
basicdataBuyerEntity: Repository<BasicdataBuyerEntity>;
|
|
@InjectEntityModel(BasicdataSiteEntity)
|
basicdataSiteEntity: Repository<BasicdataSiteEntity>;
|
|
/**
|
* 写入前计算总价
|
*/
|
async modifyBefore(data: any, type: 'add' | 'update') {
|
if (type === 'add' || type === 'update') {
|
if (data.weight !== undefined && data.unitPrice !== undefined) {
|
data.totalPrice = Number(
|
(Number(data.weight) * Number(data.unitPrice)).toFixed(2)
|
);
|
}
|
}
|
}
|
|
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 appAdd(param: any) {
|
const sorter = await this.getSorter(param.sorterId);
|
const weight = Number(param.weight);
|
let unitPrice = Number(param.unitPrice);
|
if (!weight || weight <= 0) {
|
throw new CoolCommException('请填写重量');
|
}
|
if (!param.wasteCode) {
|
throw new CoolCommException('请选择垃圾种类');
|
}
|
if (!param.buyerCode) {
|
throw new CoolCommException('请选择收购方');
|
}
|
if (!unitPrice) {
|
const waste = await this.basicdataWastetypeEntity.findOneBy({
|
code: param.wasteCode,
|
});
|
unitPrice = Number(waste?.price || 0);
|
}
|
const data: any = {
|
departmentId: param.departmentId || sorter.departmentId,
|
siteId: param.siteId,
|
wasteCode: param.wasteCode,
|
dateTime: param.dateTime || new Date(),
|
weight,
|
unitPrice,
|
totalPrice: Number((weight * unitPrice).toFixed(2)),
|
handlerId: sorter.businessId,
|
buyerCode: param.buyerCode,
|
};
|
await this.operationWastesaleEntity.save(data);
|
return data;
|
}
|
|
/**
|
* 查看当前分拣员的销售记录
|
*/
|
async appPage(query: any) {
|
const { sorterId, page = 1, size = 10 } = query || {};
|
const sorter = await this.getSorter(sorterId);
|
const find = this.operationWastesaleEntity
|
.createQueryBuilder('a')
|
.select([
|
'a.*',
|
'c.businessName AS siteName',
|
'd.name AS wasteName',
|
'f.name AS buyerName',
|
])
|
.leftJoin(BasicdataSiteEntity, 'c', 'a.siteId = c.businessId')
|
.leftJoin(BasicdataWastetypeEntity, 'd', 'a.wasteCode = d.code')
|
.leftJoin(BasicdataBuyerEntity, 'f', 'a.buyerCode = f.code')
|
.where('a.handlerId = :hid', { hid: sorter.businessId })
|
.orderBy('a.dateTime', 'DESC');
|
return this.entityRenderPage(find, { ...query, page, size }, false);
|
}
|
}
|
