添加商品毛利率计算

app/common/dao/store/product/ProductAttrDao.php

@@ -41,6 +41,9 @@ class ProductAttrDao extends BaseDao
      */
     public function insert(array $data)
     {
+        foreach ($data as &$item) {
+            $item['profit_rate'] = bcdiv(bcsub($item['price'], $item['procure_price'], 2), $item['price'], 2) * 100;
+        }
         return ($this->getModel()::getDB())->insertAll($data);
     }
 

app/event.php

@@ -57,6 +57,7 @@ return [
              \crmeb\listens\SendSvipCouponListen::class,
              \crmeb\listens\AutoCheckCreditBuyListen::class,
              \crmeb\listens\ActivateConsumptionListen::class,
+             \crmeb\listens\SetProductProfitRateListen::class,
         ] : [],
         'pay_success_user_recharge' => [\crmeb\listens\pay\UserRechargeSuccessListen::class],
         'pay_success_user_order' => [\crmeb\listens\pay\UserOrderSuccessListen::class],

crmeb/listens/SetProductProfitRateListen.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace crmeb\listens;
+
+use app\common\model\store\product\ProductAttrValue;
+use crmeb\interfaces\ListenerInterface;
+use crmeb\services\TimerService;
+use think\facade\Log;
+
+/**
+ * 定时任务：激活商户补贴
+ */
+class SetProductProfitRateListen extends TimerService implements ListenerInterface
+{
+
+    public function handle($event): void
+    {
+        $this->tick(1000 * 60, function () {
+            Log::info('定时任务：更新商品利润率');
+            try {
+                $storeProducts = ProductAttrValue::where('profit_rate', 0)
+                    ->where('procure_price', '>', 0)
+                    ->whereRaw('price>procure_price')
+                    ->limit(100)
+                    ->select();
+                foreach ($storeProducts as $storeProduct) {
+                    $storeProduct->profit_rate = bcdiv(bcsub($storeProduct->price, $storeProduct->procure_price, 2), $storeProduct->price, 2) * 100;
+                    $storeProduct->save();
+                }
+            } catch (\Throwable $e) {
+                Log::info('定时任务：更新商品利润率，error => ' . $e->getMessage());
+            }
+        });
+    }
+
+}