TaskSystem/app/job/TaskInformationJob.php

<?php

namespace app\job;

use app\api\controller\RemoteController;
use app\common\logic\finance\ShareProfit;
use app\common\model\task\Task;
use Symfony\Component\HttpClient\HttpClient;
use think\queue\Job;
use think\facade\Log;
use app\common\model\Company;
use app\common\model\informationg\UserInformationg;
use think\facade\App;
use app\common\model\task_scheduling_plan\TaskSchedulingPlan;

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

    public function fire(Job $job, $data)
    {
        // if ($job->attempts() > 1) {
        //     //通过这个方法可以检查这个任务已经重试了几次了
        // }
        try {
            TaskSchedulingPlan::where('id', $data['id'])->update(['is_pay' => 1]);
            $company = Company::where('id', $data['company_id'])->field('id,deposit,company_money,shareholder_money,user_id,day_count,company_type,province,city,area,street,village,brigade')->find(); // 可能要判断预存金是否满足
            $arr['status'] = 0;
            $arr['company_account_type'] = 1;
            //信息更新
            if ($data['template_info']['type'] == 31) {
                if ($data['template_info']['information_count'] < $data['template_info']['information_day_count']) {
                    Log::info('信息更新任务，信息更新未达到要求：' . json_encode($data));
                    Task::where('id', $data['task_id'])->update(['status' => 5]);
                    return false;
                }
                $name = '小组队长';
                $arr['status'] = 1;
                $task = Task::where('id', $data['task_id'])->field('director_uid,money')->where('status', 3)->find();
                $arr['money'] = $task['money'];
                Task::where('id', $data['task_id'])->update(['status' => 3]);
            } elseif
            //交易金额
            ($data['template_info']['type'] == 33) {
                $shang_date_total_price = App(RemoteController::class)->shang_date_total_price($company);
                if ($shang_date_total_price == false) {
                    Log::info('交易金额任务，交易金额未达到要求：' . json_encode($data));
                    Task::where('id', $data['task_id'])->update(['status' => 5]);
                    return false;
                }
                if($shang_date_total_price['arr']['total_price']>$shang_date_total_price['arr']['day_money']){
                    Task::where('id', $data['task_id'])->update(['status' => 3,'extend'=>json_encode($shang_date_total_price)]);
                }
                $name = $shang_date_total_price['name'];
                $arr['status'] = $shang_date_total_price['arr']['status'];
                $task = Task::where('id', $data['task_id'])->field('money')->find();
                $arr['money'] = $task['money'];
            } elseif
            //三轮车
            ($data['template_info']['type'] == 32){
                $task = Task::where('id', $data['task_id'])->field('director_uid,money')->where('status', 3)->with('director_info')->find();
                if(empty($task)){
                    Log::info('三轮车任务 ' . $data['template_info']['title'] . '结算失败，任务为空：' . json_encode($data));
                    Task::where('id', $data['task_id'])->update(['status' => 5]);
                    return true;
                }
                $name=$task['director_info']['nickname'];
                $arr['status'] = 1;
                $arr['money'] = $task['money'];
            }elseif
            //入股任务
            ($data['template_info']['type'] == 35){
                $task_35 = Task::where('id', $data['task_id'])->field('stage_day_one,stage_day_two,status,recharge,day_count,over_decimal')->with('director_info')->find();
                if($task_35){
                    $day= $task_35['stage_day_one'] + $task_35['stage_day_two'];
                    if($task_35['status']==3 && $day<=$task_35['day_count']){
                        $name = $task_35['director_info']['nickname'];
                        $arr['status'] = 1;
                        $arr['money'] = $task_35['over_decimal'];
                        $arr['company_account_type'] = 2;
                    }else{
                        Log::info('入股任务 ' . $data['template_info']['title'] . '结算失败：' . json_encode($data));
                        Task::where('id', $data['task_id'])->update(['status' => 5]);
                        return false;
                    }
                }
            }
            else {
                //其他类型任务
                $task_count = Task::where('id', $data['task_id'])->field('director_uid,money')->where('status', 3)->with('director_info')->find();
                if (empty($task_count)) {
                    Log::info('其他任务 ' . $data['template_info']['title'] . '结算失败，任务为空：' . json_encode($data));
                    Task::where('id', $data['task_id'])->update(['status' => 5]);
                    return false;
                }
                $name = $task_count['director_info']['nickname'];
                $arr['status'] = 1;
                $arr['money'] = $task_count['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'];
        } catch (\Exception $e) {
            Log::error('异常报错：任务结算失败：' . $data['template_info']['title'] . $e->getMessage() . json_encode($data));
            return false;
        }
        if ($arr['status'] == 1) {
            (new ShareProfit())->first($arr, $company);
        } else {
            Task::where('id', $data['task_id'])->update(['status' => 5,'extend'=>json_encode($shang_date_total_price)]);
            Log::info('任务status=0结算失败：' . $data['template_info']['title'] . '未完成' . json_encode($data));
        }
        //如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
        $job->delete();
    }
    public function failed($data)
    {
        Log::error('任务结算失败' . $data);
        // ...任务达到最大重试次数后，失败了
    }
}