diff --git a/crmeb/listens/ActivateConsumptionListen.php b/crmeb/listens/ActivateConsumptionListen.php
index a4f22625..d496b22b 100644
--- a/crmeb/listens/ActivateConsumptionListen.php
+++ b/crmeb/listens/ActivateConsumptionListen.php
@@ -20,23 +20,28 @@ class ActivateConsumptionListen extends TimerService implements ListenerInterfac
     {
         $this->tick(1000 * 60, function () {
             Log::info('定时任务：激活商户补贴');
+            $count = 0;
             $couponId = StoreConsumption::where('type', StoreConsumption::TYPE_RECHARGE)->value('coupon_id');
             if (empty($couponId)) {
                 return;
             }
+            $buyCouponId = StoreConsumption::where('type', StoreConsumption::TYPE_PULL_CONSUMPTION)->value('coupon_id');
             $storeConsumptionUser = StoreConsumptionUser::where('coupon_id', $couponId)
                 ->where('status', StoreConsumptionUser::STATUS_REPEAL)
                 ->select();
             foreach ($storeConsumptionUser as $item) {
                 $saleTotal = Merchant::where('uid', $item['uid'])->value('sale_amount');
-                if ($saleTotal >= $item['order_amount'] && $item['balance'] <= 0) {
+                $balance = StoreConsumptionUser::where('coupon_id', $buyCouponId)->where('uid', $item['uid'])->value('balance');
+                if ($saleTotal >= $item['order_amount'] && $balance <= 0) {
                     $item->status = StoreConsumptionUser::STATUS_UNUSED;
                     $item->start_time = date('Y-m-d H:i:s');
                     $item->end_time = date('Y-m-d H:i:s', strtotime('+1 year'));
                     $item->save();
                     UserBill::where('link_id', $item['coupon_user_id'])->where('type', 'red_pack_2')->update(['status', 1]);
+                    $count++;
                 }
             }
+            Log::info('定时任务：激活商户补贴，执行数量：' . $count);
         });
     }