ball/app/Job/AddServiceWorkJob.php

<?php
namespace app\job;

use think\facade\Db;
use think\queue\Job;
use think\facade\Log;
use app\common\enum\WorkEnum;
use app\common\model\equity\UserEquity;
use app\common\model\works\ServiceWork;
use app\common\model\equity\UserEquityLog;
use app\common\model\group_activity\GroupUserOrder;

class AddServiceWorkJob
{
    public function fire(Job $job, $data)
    {
        try {
            Log::info('执行队列任务：'.json_encode($data));

            //查询拼团用户订单
            $userOrder = GroupUserOrder::alias('a')->leftJoin('user b','a.user_id=b.id')
                        ->where('group_order_id', $data['id'])
                        ->where('pay_status', 1)
                        ->where('refund_status', 0)
                        ->field('a.*,b.mobile')
                        ->select()
                        ->toArray();
            try {
                Db::startTrans();
                foreach ($userOrder as $k => $item) {
                    if (empty($goods)) {
                        $goods = UserEquity::alias('a')->leftJoin('goods b','a.goods_id=b.id')
                            ->where('a.id', $item['user_equity_id'])
                            ->field('b.goods_name,b.category_type,b.goods_category_ids,b.goods_category_id,b.base_service_fee')
                            ->find();
                    }
                    //生成服务工单
                    $work_data = [
                        'work_sn' => generate_sn(ServiceWork::class, 'work_sn'),
                        'real_name' => '',
                        'mobile' => $item['mobile'],
                        'address' => $item['area'].$item['address'],
                        'province' => 0,
                        'city' => 0,
                        'area_name' => '',
                        'title' => $goods['goods_name'],
                        'category_type' => $goods['category_type'],
                        'goods_category_ids' => $goods['goods_category_ids'],
                        'goods_category_id' => $goods['goods_category_id'],
                        'base_service_fee' => $goods['base_service_fee'],
                        'service_fee' => $item['paid_amount'],
                        'work_pay_status'=>WorkEnum::IS_PAY_STATUS,
                        'appointment_time' => time(),
                        'user_id'=>$item['user_id'],
                        'lon'=>'',
                        'lat'=>'',
                        'property_activity_id'=>0,
                        'user_equity_id'=>0,
                        'third_type'=>1,
                        'work_total'=>$item['paid_amount'],
                        'work_amount'=>$item['paid_amount'],
                        'work_status' => 5,
                        'user_confirm_status' => 3,
                        'service_status' => 1,
                        'master_worker_id' => 7,
                        'remark' => '拼团单：'.$item['id'],
                        'user_equity_id' => $item['user_equity_id'],
                        'group_order_id' => $item['id'],
                    ];
                    ServiceWork::create($work_data);
    
                    UserEquityLog::create([
                        'user_id' => $item['user_id'],
                        'number' => 1,
                        'user_equity_id' => $item['user_equity_id'],
                        'create_time' => time(),
                    ]);
                }
                Db::commit();
            } catch (\Exception $e) {
                Db::rollback();
                Log::error('执行队列任务失败：'.$e->getMessage());
            }
            // 任务执行成功，删除任务
            $job->delete();
        } catch (\Exception $e) {
            // 任务执行失败，重试任务
            if ($job->attempts() > 3) {
                // 超过最大重试次数，删除任务
                $job->delete();
            } else {
                $job->release(10); // 10 秒后重试
            }
        }
    }
}