laravel框架实现商品订单加入到rabbitMQ队列

一、

创建一个任务类

1. php artisan make:job QueuedTest  //执行之后app/Jobs目录下生成一个QueuedTest.php

二、创建控制器

1. php artisan make:controller QueuedController
2. 执行之后生成app/Http/Controllers/QueuedController.php文件
   修改内容

   <?php
   namespace AppHttpControllers;
   use AppHttpControllersController;
   use AppUsersModel;
   use AppCustemorModel;
   use AppProductModel;
   use IlluminateHttpRequest;
   use AppHttpRequests;
   use AppJobsQueue;
   use IlluminateSupportFacadesDB;
   use IlluminateSupportFacadesRedis;
   use IxudraCurlFacadesCurl;
   class QueuedController extends Controller
   {
   
   //点击商品订购跳转
    public function goods(Request $request){
           $id=$request['id'];
           $goods=DB::table('product')->where('id',$id)->get();
           $good=json_decode($goods,true);
           $data['name']=$good[0]['name'];
           $data['price']=$good[0]['price'];
           $data['created_at']=time();
           $data['updated_at']=time();
           DB::table('custemor')->insert($data);
           $arr=DB::table('product')->where('id',$id)->get();
           $arr1=json_decode($arr,true);
           $this->dispatch(new Queue($arr1));//进入队列
       }
   
   
   
   }
   
   
   

3. //进入jop/queue.php
   
   <?php
   
   namespace AppJobs;
   use AppUsersModel;
   use AppCustemorModel;
   use AppProductModel;
   use IlluminateSupportFacadesDB;
   use IlluminateBusQueueable;
   use IlluminateFoundationBusDispatchable;
   use IlluminateQueueSerializesModels;
   use IlluminateQueueInteractsWithQueue;
   use IlluminateContractsQueueShouldQueue;
   use IlluminateSupportFacadesRedis;
   
   class Queue  implements ShouldQueue
   {
       use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
   
       private $data;
   
       /**
        * Queue constructor.
        * @param $data
        */
       public function __construct($data)
       {
           $this->data = $data;
   
       }
   
       /**
        * Execute the job.
        *
        * @return void
        */
   
       public function handle()
       {
            $id=$this->data[0]['id'];
         //  var_dump($id);die;
            $query=new ProductModel();
            $model=$query->info($id); //减去库存
            $ids= Redis::get('id');//获取用户id
            if($model){
               $users = DB::table('users')
                            ->select('balance')
                            ->where('id',$ids)
                            ->get();
               $user=json_decode($users,true);
   
               $pro = DB::table('product')
                            ->select('price')
                             ->where('id',$id)
                            ->get();
               $pros=json_decode($pro,true);
                //var_dump($pros);die;
               $edit=DB::table('users')->where('id', $ids)->update(['balance' =>(int)$user[0]['balance']-(int)$pros[0]['price']]);//下单进行扣费操作
               $cus=new CustemorModel();
               $status=$cus->status($id);//更改状态
               if($edit && $status){
                     echo "下单成功";
               }else{
                   echo "余额不足";
               }
             
          }
   
       }
   
   }

   //更改订单状态

4. <?php
   
   namespace App;
   use IlluminateSupportFacadesDB;
   use IlluminateDatabaseEloquentModel;
   
   class CustemorModel extends Model
   {
        protected $table="product";
        public function status($id){
            $query=DB::table('custemor')->where('pid',$id)->update(['status'=>1]);
            return $query;
        }
   }

   //减去商品库存

5. <?php
   namespace App;
   use IlluminateSupportFacadesDB;
   use IlluminateDatabaseEloquentModel;
   class ProductModel extends Model
   {
       protected $table="product";
       public function show(){
           $data= DB::table('product')->get();
           return $data;
       }
       //查询商品是否有库存
       public function info($id){
          $users = DB::table('product')
                   ->select('stock_num','price')
                   ->where('id',$id)
                   ->get();
           $user=json_decode($users,true);
           if($users <= '0'){
                   return "库存不足";
            }else{
               $edit=DB::table('product')->where('id', $id)->update(['stock_num'=>(int)$user[0]['stock_num']-1]);
               return $edit;
            }
          return $user; 
       }
       //商品添加
       public function add($data){
            $query=DB::table('product')->insert($data);
            return $query;
       }
       
   }