diff --git a/app/Controller/CouponController.php b/app/Controller/CouponController.php
index 409c2cf..5152e63 100644
--- a/app/Controller/CouponController.php
+++ b/app/Controller/CouponController.php
@@ -67,6 +67,7 @@ class CouponController extends BaseController
             ['u.end_time','>',$nowTime],
             ['u.start_time','<=',$nowTime],
             ['u.status','=',1],
+            ['u.active_type','=',1],
         ];
 
         if (env('SUB_CHANNEL') == 1) {
diff --git a/app/Controller/CouponRebateController.php b/app/Controller/CouponRebateController.php
index 3f90802..89e1cd3 100644
--- a/app/Controller/CouponRebateController.php
+++ b/app/Controller/CouponRebateController.php
@@ -17,6 +17,10 @@ use Hyperf\Utils\ApplicationContext;
 use App\CouponRebate\CouponRebateInterface;
 use http\Client\Curl\User;
 use Hyperf\Di\Annotation\Inject;
+use App\Model\Coupon;
+use App\Model\CouponUserRecType;
+use App\Model\CouponRec;
+use App\Request\CouponRebateReceiveRequest;
 class CouponRebateController extends BaseController
 {
     /**
@@ -30,4 +34,93 @@ class CouponRebateController extends BaseController
         $res = $this->CouponRebate->isCouponRebate($user_id);
         return $this->success($res);
     }
+
+    /**
+     * 用户领取优惠券
+    */
+    public function userReceiveCouponA(CouponRebateReceiveRequest $validator)
+    {
+        $userId      = $this->request->input("user_id", 0);
+        $receiveType = $this->request->input("receive_type", 0);
+        $ids         = $this->request->input("ids", '');
+        $sendUserId  = $this->request->input("send_user_id", 0);
+        $phone       = $this->request->input("phone", '');
+        $ids     = explode(',', $ids);
+        $now     = time();
+        
+        // mock 数据 给前端用
+        $test       = $this->request->input("test", 0);
+        if($test){
+            $cps     = Coupon::whereIn('id', $ids)->lockForUpdate()
+            ->select('id','title','status','inventory','inventory_use','start_time','end_time')
+            ->first();
+            return $this->success([
+                'success' => [$cps],
+                'fail'    => [],
+            ]);
+        }
+
+        $success = [];
+        $fail    = [];
+
+        Db::transaction( function () use ($ids,$receiveType,$userId,$sendUserId,$phone,&$success,&$fail,$now) {
+            //读写锁，完全控制，性能低
+            $cps   = Coupon::whereIn('id', $ids)->lockForUpdate()
+                    ->select('id','title','status','inventory','inventory_use','start_time','end_time')
+                    ->get();
+
+            foreach ($cps as $key => $cp) {
+
+                $where = [
+                    'system_coupon_user_id' => $cp->id,
+                ];
+
+                if (env('SUB_CHANNEL') == 1) {
+                    $where['receive_type'] = $receiveType;
+                }
+
+                $crt = CouponUserRecType::where($where)->first();
+
+                $cr                        = new CouponRec;
+                $cr->user_id               = $userId;
+                $cr->system_coupon_user_id = $cp->id;
+                $cr->order_main_id         = 0;
+                $cr->receive_time          = $now;
+                $cr->number                = $crt->one_receive_number;
+                $cr->number_remain         = $crt->one_receive_number;
+                $cr->status                = 0;
+                $cr->update_time           = $now;
+                $cr->receive_type          = $receiveType;
+                $cr->send_user_id          = $sendUserId;
+                $cr->phone                 = $phone;
+                //如果优惠卷库存小于等于已领取的数量 或者 未在活动时间内, 则返回领取失败的优惠券
+                if ( 
+                    $cp->status != 1
+                    ||
+                    $cp->inventory <= $cp->inventory_use
+                    ||
+                    $cp->inventory < ($cp->inventory_use+$cr->number)
+                    ||
+                    $cp->start_time < $now
+                    ||
+                    $cp->end_time > $now
+                    )
+                {
+                    $fail[] = $cp;
+                }else{
+                    $cp->inventory_use += $cr->number;//记录已领取的数量
+                    if ( $cr->save() && $cp->save() ) {
+                        $success[] = $cp;
+                    } else {
+                        $fail[] = $cp;
+                    }
+                }
+            }
+        });
+
+        return $this->success([
+            'success' => $success,
+            'fail'    => $fail,
+        ]);
+    }
 }
diff --git a/app/Request/CouponRebateReceiveRequest.php b/app/Request/CouponRebateReceiveRequest.php
new file mode 100644
index 0000000..4c4beed
--- /dev/null
+++ b/app/Request/CouponRebateReceiveRequest.php
@@ -0,0 +1,48 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Request;
+
+use Hyperf\Validation\Request\FormRequest;
+
+class CouponRebateReceiveRequest extends FormRequest
+{
+    /**
+     * Determine if the user is authorized to make this request.
+     */
+    public function authorize(): bool
+    {
+        return true;
+    }
+
+    /**
+     * Get the validation rules that apply to the request.
+     */
+    public function rules(): array
+    {
+        return [
+            'user_id' => 'required|nonempty|integer|exists_enable:ims_cjdc_user,id',
+            'receive_type' => 'required|nonempty|integer',
+            'ids' => 'required|nonempty',
+        ];
+    }
+
+    public function messages(): array
+    {
+        return [
+            'user_id.*' => ':attribute信息不正确',
+            'receive_type.*' => ':attribute必须',
+            'ids.*' => ':attribute必须',
+        ];
+    }
+
+    public function attributes(): array
+    {
+        return [
+            'user_id' => '领取用户ID',
+            'receive_type' => '领取方式',
+            'ids' => '优惠券',
+        ];
+    }
+}
diff --git a/config/routes.php b/config/routes.php
index 83a8e13..0b238a6 100644
--- a/config/routes.php
+++ b/config/routes.php
@@ -26,5 +26,6 @@ Router::addGroup('/v1/',function (){
     Router::post('ParamsToken/generate', 'App\Controller\ParamsTokenController@generate');
     Router::post('ParamsToken/analyze', 'App\Controller\ParamsTokenController@analyze');
     Router::post('Ad/banners', 'App\Controller\AdController@banners');
-	Router::post('CouponRebate/isCouponRebate', 'App\Controller\CouponRebateController@isCouponRebate');
+    Router::post('CouponRebate/isCouponRebate', 'App\Controller\CouponRebateController@isCouponRebate');
+    Router::post('CouponRebate/userReceiveCoupon', 'App\Controller\CouponRebateController@userReceiveCouponA');
 });
\ No newline at end of file