ball/app/adminapi/logic/master_worker/EngineerSettlementPermanentlyLogic.php

<?php
// +----------------------------------------------------------------------
// | likeadmin快速开发前后端分离管理后台（PHP版）
// +----------------------------------------------------------------------
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
// | 开源版本可自由商用，可去除界面版权logo
// | gitee下载：https://gitee.com/likeshop_gitee/likeadmin
// | github下载：https://github.com/likeshop-github/likeadmin
// | 访问官网：https://www.likeadmin.cn
// | likeadmin团队 版权所有 拥有最终解释权
// +----------------------------------------------------------------------
// | author: likeadminTeam
// +----------------------------------------------------------------------

namespace app\adminapi\logic\master_worker;


use app\common\model\dict\DictData;
use app\common\model\master_worker\EngineerSettlementPermanently;
use app\common\logic\BaseLogic;
use app\common\model\master_worker\MasterWorker;
use app\common\model\master_worker\SalaryItemPermanently;
use think\facade\Db;
use think\facade\Log;


/**
 * EngineerSettlementPermanently逻辑
 * Class EngineerSettlementPermanentlyLogic
 * @package app\adminapi\logic
 */
class EngineerSettlementPermanentlyLogic extends BaseLogic
{
    protected static int $conf_step_days = 7;
    protected static string $conf_days = '2025-06-09 23:59:59';

    /**
     * @notes 添加
     * @param array $params
     * @return bool
     * @author likeadmin
     * @date 2025/06/09 10:33
     */
    public static function add(array $params): bool
    {
        Db::startTrans();
        try {
            EngineerSettlementPermanently::create([
                'master_worker_id' => $params['master_worker_id'],
                'last_settlement_time' => $params['last_settlement_time'],
                'settlement_time' => $params['settlement_time'],
                'step_days' => $params['step_days'],
                'status' => $params['status'],
                'admin_id' => $params['admin_id'],
                'remark' => $params['remark']
            ]);

            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }


    /**
     * @notes 编辑
     * @param array $params
     * @return bool
     * @author likeadmin
     * @date 2025/06/09 10:33
     */
    public static function edit(array $params): bool
    {
        Db::startTrans();
        try {
            EngineerSettlementPermanently::where('id', $params['id'])->update([
//                'master_worker_id' => $params['master_worker_id'],
//                'last_settlement_time' => $params['last_settlement_time'],
//                'settlement_time' => $params['settlement_time'],
//                'step_days' => $params['step_days'],
                'amount' => $params['amount']??0,
                'payment_time' => $params['payment_time']??'',
                'deduction_amount' => $params['deduction_amount']??0,
                'deduction_describe' => $params['deduction_describe']??'',
                'status' => 1,
                'admin_id' => $params['admin_id']??0,
                //'remark' => $params['remark']
            ]);

            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }


    /**
     * @notes 删除
     * @param array $params
     * @return bool
     * @author likeadmin
     * @date 2025/06/09 10:33
     */
    public static function delete(array $params): bool
    {
        return EngineerSettlementPermanently::destroy($params['id']);
    }


    /**
     * @notes 获取详情
     * @param $params
     * @return array
     * @author likeadmin
     * @date 2025/06/09 10:33
     */
    public static function detail($params): array
    {
         function getAllSalary($salaryItemPermanently): float {
            $all_salary = 0.00;
            foreach ($salaryItemPermanently as $item) {
                $all_salary += $item['term_amount'];
            }
            return $all_salary;
        }
        $item = EngineerSettlementPermanently::with(['bankAccount','workerInfo','salaryItemPermanently'])->findOrEmpty($params['id'])->toArray();
        $item['all_salary'] = getAllSalary($item['salaryItemPermanently']);
        return $item;
    }

    /**
     * @notes 执行结算
     * @param $params
     * @author likeadmin
     * @date 2025/06/09 10:33
     */
    public static function settlement($params)
    {
        Db::startTrans();
        try {

            $settlementPermanently = EngineerSettlementPermanently::where('id', $params['id'])->findOrEmpty();
            if($settlementPermanently->isEmpty()){
                throw new \Exception('结算记录不存在');
            }
            $amount = SalaryItemPermanently::where('permanently_settlement_id', $params['id'])->sum('term_amount');
            $settlementPermanently->status = $params['status']??0;
            $settlementPermanently->admin_id = $params['admin_id']??0;
            $settlementPermanently->amount = $amount;
            $settlementPermanently->save();

            Db::commit();

            // 删除该日期步进天数内的之前的快照
            $ids = EngineerSettlementPermanently::where('status',0)->
            where('settlement_time','between',[$settlementPermanently->last_settlement_time,$settlementPermanently->settlement_time])->column('id')??[];
            if(!empty($ids)){
                EngineerSettlementPermanently::where('id',$ids)->delete();
                SalaryItemPermanently::where('permanently_settlement_id',$ids)->delete();
            }

            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getMessage());
            return false;
        }
    }

    /**
     * @notes 定时任务
     * @author likeadmin
     * @date 2025/06/09 10:33
     */
    public static function settlementRegular($masterWorker_id = 0)
    {
        Db::startTrans();
        try {
            $wh =  ['type' => 2];
            $masterWorker_id && $wh['id'] = $masterWorker_id;
            //$masterWorker_id
            // audit_state = 1
            $masterWorkers = MasterWorker::where($wh)->select()->toArray();
            foreach ($masterWorkers as $masterWorker) {
                $last_settlement_time = self::getLastSettlementTime($masterWorker['id']);
                $settlement_time = strtotime(date("Y-m-d",time())) + 86399;
                $settlementPermanently = EngineerSettlementPermanently::create([
                    'master_worker_id' => $masterWorker['id'],
                    'last_settlement_time' => date('Y-m-d',$last_settlement_time),
                    'settlement_time' => date('Y-m-d',$settlement_time),
                    'step_days' => self::$conf_step_days,
                    'status' => 0,
                    'admin_id' => 0,
                    'remark' => ''
                ]);
                //$settlementPermanently->id

                $salary_item_data = DictData::where('type_value','salary_item')->column('name','value');
                $salaryItemPermanently = new SalaryItemPermanently();
                foreach ($salary_item_data as $salary_item => $item_name) {
                    $fu_name = 'salary_item_'.$salary_item;
                    if(!method_exists(SalaryItemPermanently::class,$fu_name)){
                        continue;
                    }
                    $salaryItemPermanently->$fu_name($settlementPermanently['id'],$masterWorker['id'],[
                        'start_time'=>$last_settlement_time,
                        'end_time'=>$settlement_time,
                        'step_days'=>self::$conf_step_days,'item_name'=>$item_name
                    ]);
                }
            }
            Db::commit();
            return true;
        } catch (\Exception $e) {
            Db::rollback();
            self::setError($e->getFile().':'.$e->getLine().':'.$e->getMessage());
            return false;
        }
    }


    public static function getLastSettlementTime($master_worker_id)
    {
        //查询该工程师上个结算日期
        $last_settlement_time = EngineerSettlementPermanently::where('master_worker_id',$master_worker_id)->where('status',1)->order('settlement_time','desc')->value('settlement_time');
        if(empty($last_settlement_time) || $last_settlement_time === '0000-00-00'){
            return strtotime(self::$conf_days);
        }
        $current_time = strtotime(date("Y-m-d",time()));
        $last_st_time = $current_time - (self::$conf_step_days * 86400);
        if(strtotime($last_settlement_time) < $last_st_time){
            return $last_st_time;
        }else{
            return strtotime($last_settlement_time);
        }
    }
}