import { Provide } from '@midwayjs/core';
|
import { BaseService, CoolCommException } from '@cool-midway/core';
|
import { InjectEntityModel } from '@midwayjs/typeorm';
|
import { Repository } from 'typeorm';
|
import * as moment from 'moment';
|
import { PushSorterAttendanceEntity } from '../entity/sorterattendance';
|
import { BasicdataSorterEntity } from '../../basicdata/entity/sorter';
|
|
/**
|
* 分拣员签到签退
|
*/
|
@Provide()
|
export class PushSorterAttendanceService extends BaseService {
|
@InjectEntityModel(PushSorterAttendanceEntity)
|
pushSorterAttendanceEntity: Repository<PushSorterAttendanceEntity>;
|
|
@InjectEntityModel(BasicdataSorterEntity)
|
basicdataSorterEntity: Repository<BasicdataSorterEntity>;
|
|
async getSorter(sorterId: string) {
|
const sorter = await this.basicdataSorterEntity.findOneBy({
|
businessId: String(sorterId || '').trim(),
|
});
|
if (!sorter || sorter.status !== 0) {
|
throw new CoolCommException('分拣员账号不可用');
|
}
|
return sorter;
|
}
|
|
private locationOf(param: any) {
|
if (param.longitude == null || param.latitude == null) {
|
throw new CoolCommException('缺少定位信息');
|
}
|
return `${Number(param.longitude)},${Number(param.latitude)}`;
|
}
|
|
private today() {
|
return moment().format('YYYY-MM-DD');
|
}
|
|
private async todayRow(idCard: string) {
|
return this.pushSorterAttendanceEntity
|
.createQueryBuilder('a')
|
.where('a.idCard = :idCard', { idCard })
|
.andWhere('a.workDate = :workDate', { workDate: this.today() })
|
.getOne();
|
}
|
|
async checkIn(param: any) {
|
const sorter = await this.getSorter(param.sorterId);
|
const loc = this.locationOf(param);
|
const now = new Date();
|
const workDate = this.today();
|
let row = await this.todayRow(sorter.businessId);
|
if (row?.checkInTime) {
|
throw new CoolCommException('今日已签到');
|
}
|
if (!row) {
|
row = this.pushSorterAttendanceEntity.create({
|
idCard: sorter.businessId,
|
departmentId: sorter.departmentId,
|
uploadTime: now,
|
workDate: workDate as any,
|
checkInTime: now,
|
checkInLocation: loc,
|
workHours: 0,
|
status: '缺卡',
|
});
|
} else {
|
row.departmentId = sorter.departmentId;
|
row.uploadTime = now;
|
row.checkInTime = now;
|
row.checkInLocation = loc;
|
}
|
await this.pushSorterAttendanceEntity.save(row);
|
return {
|
message: '签到成功',
|
workDate,
|
checkInTime: now,
|
checkInLocation: loc,
|
};
|
}
|
|
async checkOut(param: any) {
|
const sorter = await this.getSorter(param.sorterId);
|
const loc = this.locationOf(param);
|
const now = new Date();
|
const workDate = this.today();
|
const row = await this.todayRow(sorter.businessId);
|
if (!row?.checkInTime) {
|
throw new CoolCommException('请先上班签到');
|
}
|
if (row.checkOutTime) {
|
throw new CoolCommException('今日已签退');
|
}
|
const start = new Date(row.checkInTime).getTime();
|
const hours = Math.max(0, (now.getTime() - start) / 3600000);
|
row.uploadTime = now;
|
row.checkOutTime = now;
|
row.checkOutLocation = loc;
|
row.workHours = Math.round(hours * 100) / 100;
|
row.status = '正常';
|
await this.pushSorterAttendanceEntity.save(row);
|
return {
|
message: '签退成功',
|
workDate,
|
checkOutTime: now,
|
checkOutLocation: loc,
|
workHours: row.workHours,
|
};
|
}
|
}
|
