<?php
namespace app\service;
use app\model\Account;
use app\model\ClockLog;
use app\model\Log;
use app\model\OvertimeLog;
use app\model\PayLog;
use app\model\PayMonthLog;
use think\facade\Db;
use think\Model;
/**
* 薪资计算
*
* Class Pay
* @package app\service
*/
class Pay
{
// 基本逻辑 工人工资=基本工资+加班工资 一个月的工资=有效打卡的天数*基本工资+加班工资（=天工资/6*加班小时）
//基本工资在员工入职就要填入
//基本工资按天计算，打卡确认一天算一天
//加班工资按6小时为一天：天工资÷6小时=每小时工资
/*
基本工资按天计算，打卡确认一天算一天，可能会出现的漏洞(本期暂不考虑)：
晚上加班，如23:10打上班卡，第二天03:10打下班卡，这样就会认为上班2天。
若正常一天，必须至少要有上班和下班两次打卡的话，上述则两天都不算上班
*/
// $sql = "
// insert into bee_pay_log(`account_id`, `worksite_id`,`time`, `year`, `month`, `day`)
// select ".$item['account_id'].",".$item['worksite_id'].",".$item['day'].",".$year.",".$month.",".$day." from DUAL
// where not exists (select `account_id`, `worksite_id`,`time` from bee_pay_log where `account_id` = ".$item['account_id']." AND `worksite_id` = ".$item['worksite_id']." AND `time` = ".$item['day'].")
//";
// Db::execute($sql);
// 生成工人每个工地月薪资汇总
/**
* 汇总指定日期间的工资
* 汇总到pay_log表
*
* @param int $begin 开始时间 为0则不限制 格式为Ymd 如20221103
* @param int $end 结束时间 为0则不限制 格式为Ymd 如20221103
*/
public static function statistic(int $begin = 0, int $end = 0)
{
set_time_limit(0);
$where = [];
if ($begin) {
$where[] = ['l.day', '>=', $begin];
}
if ($end) {
$where[] = ['l.day', '<=', $end];
}
// 打卡记录表 每300条处理一次 打卡记录表中同一个indexs只计算一次
ClockLog::alias('l')
->leftJoin('account a', 'a.id = l.account_id')
->leftJoin('pay_log pl', 'pl.indexs = l.indexs')
->where('l.is_statistic', ClockLog::COMMON_OFF)
->where('l.status', ClockLog::COMMON_ON)
->where('l.need_statistic', ClockLog::COMMON_ON)
->where('l.role', ClockLog::COMMON_ON)//工人
->where('a.pay', '>', 0)
->where('l.handle_count', '<=', 10) //查询处理次数10次以下
->where($where)
->group('l.indexs')
->fieldRaw('count(l.id),l.id,l.account_id,l.worksite_id,l.created_at,l.day,l.indexs,a.pay,pl.id as pay_log_id,pl.base_amount_count')
->chunk(300, function ($items) {
$update = [];
$indexsList = [];
$ids = $items->column('id');
\think\facade\Log::write($ids);
// 每查询一次就增加一次handle_count 避免未处理成功后 死循环一直查询
(new ClockLog)->whereIn('id', $ids)->save([
'handle_count' => Db::raw('`handle_count` + 1')
]);
foreach ($items as $item) {
if ($item['pay_log_id'] && $item['base_amount_count'] == 0) {
$update[] = [
'id' => $item['pay_log_id'],
'amount' => Db::raw('`amount` + '.$item['pay']),
'base_amount' => Db::raw('`base_amount` + '.$item['pay']),
'remarks' => Db::raw('CONCAT_WS(char(10), `remarks`,"基本工资入账 '.$item['pay'].'元")'),
'base_amount_count' => 1,
];
$indexsList[] = $item['indexs'];
}
}
if (!empty($update)) {
// \think\facade\Log::write($update);
// 启动事务
Db::startTrans();
try {
(new PayLog())->saveAll($update);
ClockLog::whereIn('indexs', $indexsList)->update(['is_statistic' => ClockLog::COMMON_ON]);
Db::commit();
} catch (\Exception $e) {
Db::rollback();
\think\facade\Log::error('批量统计基本工资失败'.$e->getMessage().' file:'.$e->getFile().' line:'.$e->getLine());
}
}
}, 'pl.id', 'desc');
// 加班记录表 每300条处理一次
OvertimeLog::alias('l')
->leftJoin('account a', 'a.id = l.account_id')
->leftJoin('pay_log pl', 'pl.indexs = l.indexs')
->where('l.is_statistic', ClockLog::COMMON_OFF)
->where('l.status', ClockLog::COMMON_ON)
->where('a.pay', '>', 0)
->where('l.handle_count', '<=', 10) //查询处理次数10次以下
->where($where)
->fieldRaw('l.id,l.account_id,l.worksite_id,l.created_at,l.`day`,l.time,l.indexs,a.pay,pl.id as pay_log_id,pl.overtime_amount_count')
->chunk(300, function ($items) {
$update = [];
$ids = [];
$handleIds = $items->column('id');
// 每查询一次就增加一次handle_count 避免未处理成功后 死循环一直查询
(new OvertimeLog)->whereIn('id', $handleIds)->save([
'handle_count' => Db::raw('`handle_count` + 1')
]);
foreach ($items as $item) {
if ($item['pay_log_id']) {
// 加班工资=基本工资/6小时 * 加班小时
$overtimeAmount = round(Math::mul(Math::div($item['pay'], 6), $item['time']), 2);
$update[] = [
'id' => $item['pay_log_id'],
'amount' => Db::raw('`amount` + '.$overtimeAmount),
'overtime_amount' => Db::raw('`overtime_amount` + '.$overtimeAmount),
'remarks' => Db::raw('CONCAT_WS(char(10), `remarks`,"加班工资入账 '.$overtimeAmount.'元")'),
'overtime_amount_count' => Db::raw('`overtime_amount_count` + 1'),
];
$ids[] = $item['id'];
}
}
// \think\facade\Log::write($update);
if (!empty($update)) {
Db::startTrans();
try {
(new PayLog())->saveAll($update);
OvertimeLog::whereIn('id', $ids)->update(['is_statistic' => OvertimeLog::COMMON_ON]);
Db::commit();
} catch (\Exception $e) {
Db::rollback();
\think\facade\Log::error('批量统计加班工资失败'.$e->getMessage().' file:'.$e->getFile().' line:'.$e->getLine());
}
}
}, 'l.id', 'desc');
}
/**
* 生成月份工资记录
*
* @param int $time 生成时间 按月份 格式为年月 如202209 date('Ym')
* @return bool
*/
public static function generateMonthLog(int $time = 0): bool
{
if ($time == 0) {
// 默认生成上个月
$time = date('Ym', strtotime('last month'));
}
$timestamp = strtotime($time.'01');
$year = date('Y', $timestamp);
$month = date('m', $timestamp);
$where = [
['year', '=', $year],
['month', '=', $month],
['role', '=', Account::ROLE_WORKER],
];
// 每次统计 都讲之前的结果清理，插入新计算结果
$insert = [];
// 每日工资记录（基本工资和加班工资）
PayLog::where($where)
->chunk(300, function ($items) use (&$insert, $time, $year, $month) {
foreach ($items as $item) {
$indexs = $item['account_id'].'-'.$item['worksite_id'].'-'.$time;
if (!isset($insert[$indexs])) {
$insert[$indexs] = [
'account_id' => $item['account_id'],
'worksite_id' => $item['worksite_id'],
'indexs' => $indexs,
'time' => $time,
'year' => $year,
'month' => $month,
'created_at' => date('Y-m-d H:i:s'),
'amount' => $item['amount'],
'base_amount' => $item['base_amount'],
'overtime_amount' => $item['overtime_amount'],
];
} else {
$insert[$indexs]['amount'] = $insert[$indexs]['amount'] + $item['amount'];
$insert[$indexs]['base_amount'] = $insert[$indexs]['base_amount'] + $item['base_amount'];
$insert[$indexs]['overtime_amount'] = $insert[$indexs]['overtime_amount'] + $item['overtime_amount'];
}
}
});
if (!empty($insert)) {
// \think\facade\Log::write($insert);
// 启动事务
Db::startTrans();
try {
PayMonthLog::where('time', $time)->delete();
(new PayMonthLog())->insertAll($insert);
Db::commit();
} catch (\Exception $e) {
Db::rollback();
\think\facade\Log::error('统计['.$time.']工资失败'.$e->getMessage().' file:'.$e->getFile().' line:'.$e->getLine());
}
}
return true;
}
}