From fdbe4e0626104c0201bd62b2566531676d58cda8 Mon Sep 17 00:00:00 2001
From: luofei <604446095@qq.com>
Date: Thu, 22 Feb 2024 16:40:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E6=97=B6=E6=BF=80?=
 =?UTF-8?q?=E6=B4=BB=E5=95=86=E6=88=B7=E8=A1=A5=E8=B4=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../order/StoreOrderCreateRepository.php      |  4 ++
 crmeb/listens/ActivateConsumptionListen.php   | 44 +++++++++++++++++++
 crmeb/listens/OrderDeliveryListen.php         |  2 +-
 3 files changed, 49 insertions(+), 1 deletion(-)
 create mode 100644 crmeb/listens/ActivateConsumptionListen.php

diff --git a/app/common/repositories/store/order/StoreOrderCreateRepository.php b/app/common/repositories/store/order/StoreOrderCreateRepository.php
index 0f485c72..20d4fc0f 100755
--- a/app/common/repositories/store/order/StoreOrderCreateRepository.php
+++ b/app/common/repositories/store/order/StoreOrderCreateRepository.php
@@ -89,6 +89,10 @@ class StoreOrderCreateRepository extends StoreOrderRepository
             $isPlatformCard = true;
         }
         if ($isPlatformCard) {
+            $merchantTypeId = Merchant::where('uid', $uid)->value('type_id');
+            if ($merchantTypeId != 21) {
+                throw new ValidateException('大礼包仅限种养殖户购买');
+            }
             //平台购物卡仅能购买一次
             $productIds = ProductCate::where('mer_cate_id', env('PLATFORM_CARD_CATE_ID'))->column('product_id');
             $orderRecord = StoreOrder::alias('t1')
diff --git a/crmeb/listens/ActivateConsumptionListen.php b/crmeb/listens/ActivateConsumptionListen.php
new file mode 100644
index 00000000..32bcc825
--- /dev/null
+++ b/crmeb/listens/ActivateConsumptionListen.php
@@ -0,0 +1,44 @@
+<?php
+
+namespace crmeb\listens;
+
+use app\common\model\store\consumption\StoreConsumption;
+use app\common\model\store\consumption\StoreConsumptionUser;
+use app\common\model\store\order\StoreOrder;
+use app\common\model\system\merchant\Merchant;
+use crmeb\interfaces\ListenerInterface;
+use crmeb\services\TimerService;
+
+/**
+ * 定时任务：激活商户补贴
+ */
+class ActivateConsumptionListen extends TimerService implements ListenerInterface
+{
+
+    public function handle($event): void
+    {
+        $this->tick(1000 * 60 * 10, function () {
+            $couponId = StoreConsumption::where('type', StoreConsumption::TYPE_RECHARGE)->value('coupon_id');
+            if (empty($couponId)) {
+                return;
+            }
+            $storeConsumptionUser = StoreConsumptionUser::where('coupon_id', $couponId)
+                ->where('status', StoreConsumptionUser::STATUS_REPEAL)
+                ->select();
+            foreach ($storeConsumptionUser as $item) {
+                $isUsed = StoreConsumptionUser::where('order_id_set', $item['order_id_set'])
+                    ->where('balance', 0)
+                    ->count();
+                $merchantId = Merchant::where('uid', $item['uid'])->value('mer_id');
+                $saleTotal = StoreOrder::where('mer_id', $merchantId)->whereIn('status', [2, 3])->sum('pay_price');
+                if ($saleTotal >= $item['order_amount'] && $isUsed > 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();
+                }
+            }
+        });
+    }
+
+}
diff --git a/crmeb/listens/OrderDeliveryListen.php b/crmeb/listens/OrderDeliveryListen.php
index 87f5c440..f400a1f4 100644
--- a/crmeb/listens/OrderDeliveryListen.php
+++ b/crmeb/listens/OrderDeliveryListen.php
@@ -31,7 +31,7 @@ class OrderDeliveryListen implements ListenerInterface
             $repo->send($consumption, 1, $order['uid'], $order['group_order_id'], $order->total_price, StoreConsumptionUser::STATUS_UNUSED);
 
             //TODO 当商户销售和购买达到指定金额后，激活抵扣补贴
-            $consumption = StoreConsumption::where('type', StoreConsumption::TYPE_OWNER_CONSUMPTION)->find();
+            $consumption = StoreConsumption::where('type', StoreConsumption::TYPE_RECHARGE)->find();
             $repo->startTime = date('Y-m-d H:i:s');
             $repo->endTime = '2025-07-01';
             $rate = $this->getRate($order->total_price);