TaskSystem/app/job/TaskInformationJob.php

<?php

namespace app\job;

use app\common\logic\finance\ShareProfit;
use app\common\model\task\Task;
use think\queue\Job;
use think\facade\Log;

/**
 * 任务结算执行的具体逻辑
 */
class TaskInformationJob
{

    public function fire(Job $job, $data)
    {
        if ($job->attempts() > 3) {
            //通过这个方法可以检查这个任务已经重试了几次了
        }
        $task_id=explode(',',$data['task_id']);
        $task_count=Task::where('id','in',$task_id)->field('director_uid')->with('director_info')->select();
        if(empty($task_count)){
            Log::error('任务结算失败，任务id：'.$task_id);
        }
        if(count($task_count)==count($task_id)){
            $name_arr=[];
            foreach ($task_count as $key => $value) {
                $name_arr[$key]=$value['director_info']['nickname'];
            }
            $name=implode('、',$name_arr);
            $arr['money']=$data['template_info']['money'];
            $arr['company_id']=$data['scheduling']['company_id'];
            $arr['msg']='来自任务【'.$data['template_info']['title'].'】,执行人：'.$name.',的任务结算';
            $arr['proportion_one']=$data['template_info']['proportion_one'];
            $arr['proportion_two']=$data['template_info']['proportion_two'];
            $arr['sn']=$data['sn'];
            $arr['id']=$data['id'];
            (new ShareProfit())->first($arr);
        }

        //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
        $job->delete();
    }
    public function failed($data){
        Log::error('任务结算失败'.$data);
        // ...任务达到最大重试次数后，失败了
    }
}