摘要：
phpnamespaceAppJobs；使用AppUsersModel；使用应用客户记忆模型；使用AppProductModel；使用照明支持面板DB；useIlluminateBusQueueable；useIlluminationFoundationBusDispatchable；useIlluminateQueueSerializesModels；使用照明队列与队列交互；使用IlluminationContractsQueueShouldQueue；使用照明支持面板显示；classQueueimplementsShouldQueue｛useDispatchable，InteractisWithQueue，Queueable，SerializesModels；private$data；/***队列构造函数。*@param$data*/publicfunction__construct｛$this-˃data=$data；｝/***执行作业。**@Returnvoid*/publicfunctionhandle（）{$id=$this-˃data[0]['id']；//var_dump（$id）；die；$query=newProductModel（）；$model=$query-˃info（$id; $pro=json_decode//变量泵；死亡$edit=DB:：table-˃where-˃update//下订单扣除费用$cus=newCusterModel（）；$status=$cus-˃状态（$id）；//如果｛echo“订单已成功下单”，则更改状态；｝否则｛echo“余额不足”；｝｝｝｝//变更单状态˂？
一、
创建一个任务类
- php artisan make:job QueuedTest //执行之后app/Jobs目录下生成一个QueuedTest.php
二、创建控制器
- php artisan make:controller QueuedController
- 执行之后生成app/Http/Controllers/QueuedController.php文件
修改内容1 <?php 2 namespace AppHttpControllers; 3 use AppHttpControllersController; 4 use AppUsersModel; 5 use AppCustemorModel; 6 use AppProductModel; 7 use IlluminateHttpRequest; 8 use AppHttpRequests; 9 use AppJobsQueue; 10 use IlluminateSupportFacadesDB; 11 use IlluminateSupportFacadesRedis; 12 use IxudraCurlFacadesCurl; 13 class QueuedController extends Controller 14 { 15 16 //点击商品订购跳转 17 public function goods(Request $request){ 18 $id=$request['id']; 19 $goods=DB::table('product')->where('id',$id)->get(); 20 $good=json_decode($goods,true); 21 $data['name']=$good[0]['name']; 22 $data['price']=$good[0]['price']; 23 $data['created_at']=time(); 24 $data['updated_at']=time(); 25 DB::table('custemor')->insert($data); 26 $arr=DB::table('product')->where('id',$id)->get(); 27 $arr1=json_decode($arr,true); 28 $this->dispatch(new Queue($arr1));//进入队列 29 } 30 31 32 33 }
//进入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 "余额不足"; } } } }//更改订单状态
<?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; } }//减去商品库存
1 <?php 2 namespace App; 3 use IlluminateSupportFacadesDB; 4 use IlluminateDatabaseEloquentModel; 5 class ProductModel extends Model 6 { 7 protected $table="product"; 8 public function show(){ 9 $data= DB::table('product')->get(); 10 return $data; 11 } 12 //查询商品是否有库存 13 public function info($id){ 14 $users = DB::table('product') 15 ->select('stock_num','price') 16 ->where('id',$id) 17 ->get(); 18 $user=json_decode($users,true); 19 if($users <= '0'){ 20 return "库存不足"; 21 }else{ 22 $edit=DB::table('product')->where('id', $id)->update(['stock_num'=>(int)$user[0]['stock_num']-1]); 23 return $edit; 24 } 25 return $user; 26 } 27 //商品添加 28 public function add($data){ 29 $query=DB::table('product')->insert($data); 30 return $query; 31 } 32 33 }