feat(profit): 计算用户业绩 PV

- 新增 ProductPvDao 和 ProductPvModel 类，用于获取商品 PV 配置
- 重构 Pv 类，实现用户业绩 PV 的计算逻辑
- 修改 StoreOrderDao 类，增加 getDataForPv 方法获取订单数据- 更新 UserDao 类，增加 getTestUser 方法获取测试用户列表
- 调整 ProfitsRepository 类，优化日志记录和错误处理

app/common/dao/profit/ProductPvDao.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace app\common\dao\profit;
+
+use app\common\dao\BaseDao;
+use app\common\model\profit\ProductPvModel;
+
+class ProductPvDao extends BaseDao
+{
+    protected function getModel(): string
+    {
+        return ProductPvModel::class;
+    }
+
+    /**
+     * @param $productId
+     * @return mixed
+     * 获取商品业绩
+     */
+    public function getData($productId = 0)
+    {
+        $where = [];
+        if($productId != 0) {
+            $where['product_id'] = $productId;
+        }
+
+        return $this->getModel()::getDB()->where($where)->column('pv','product_id');
+    }
+}

app/common/dao/store/order/StoreCartDao.php

@@ -218,4 +218,11 @@ class StoreCartDao extends BaseDao
             ->whereIn('cart_id', $cartIdList)
             ->update(['is_pay' => $isPay]);
     }
+
+    public function getDataByIds(array $cartIds)
+    {
+        /** @var StoreCart $model */
+        $model = $this->getModel();
+        return $model::getDB()->whereIn('cart_id', $cartIds)->select()->toArray();
+    }
 }

app/common/dao/store/order/StoreOrderDao.php

@@ -637,19 +637,49 @@ class StoreOrderDao extends BaseDao
      * @return array
      * 获取pv
      */
-    public function getPv($userId, $price)
+    public function getDataForPv(array $userId = [], string $startTime = '', string $endTime = '', int $merId = 0, array $status = [], array $removeUserList = []): array
     {
+        // 创建where数组，依据默认值判断组成where条件
+        $where = [];
+
+        // mer_id条件：默认496表示特定商户，不等于496时添加条件
+        if ($merId != 0) {
+            $where[] = ['mer_id', '=', $merId];
+        }
+        
+        // uid条件：用户ID数组不为空时添加条件
+        if (!empty($userId)) {
+            $where[] = ['uid', 'in', $userId];
+        }
+        
+        // status条件：状态数组不为空时添加条件
+        if (!empty($status)) {
+            $where[] = ['status', 'in', $status];
+        }
+        
+        // removeUserList条件：排除用户列表不为空时添加条件
+        if (!empty($removeUserList)) {
+            $where[] = ['uid', 'not in', $removeUserList];
+        }
+        
+        // pay_time不为null条件：始终添加
+        $where[] = ['pay_time', 'not null'];
+        
+        // 时间范围条件：开始时间和结束时间都不为空时添加
+        if (!empty($startTime) && !empty($endTime)) {
+            $where[] = ['pay_time', 'between', [$startTime, $endTime]];
+        }
+
         $model = $this->getModel();
-        $oldPvData = $model::getDB()
-            ->where('mer_id', 496)
-            ->whereIn('uid', $userId)
-            ->whereIn('total_price', $price)
-            ->whereIn('status', [0, 1, 2, 3])
-            ->whereNotNull("pay_time")
-            ->group('total_price')
-            ->field('total_price,count(1) as count')
-            ->select()
-            ->toArray();
-        return array_column($oldPvData,'count','total_price');
+        $query = $model::getDB();
+        
+        // 应用where数组中的所有条件
+        foreach ($where as $condition) {
+            if (count($condition) === 3) {
+                $query->where($condition[0], $condition[1], $condition[2]);
+            }
+        }
+
+        return $query->select()->toArray();
     }
 }

app/common/dao/user/UserDao.php

@@ -470,4 +470,13 @@ class UserDao extends BaseDao
     {
         return $this::getModel()::getDB()->whereIn('uid', $uids)->where(['user_group'=>$userGroup])->column('uid');
     }
+
+    /**
+     * @return array
+     * 获取测试用户
+     */
+    public function getTestUser(): array
+    {
+        return $this::getModel()::getDB()->where('test_user', '=', 1)->column('uid');
+    }
 }

app/common/model/profit/ProductPvModel.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\model\profit;
+
+use app\common\model\BaseModel;
+
+class ProductPvModel extends BaseModel
+{
+    public static function tablePk(): ?string
+    {
+        return 'product_id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'product_pv';
+    }
+}

app/common/repositories/profits/ProfitsRepository.php

@@ -4,12 +4,11 @@ namespace app\common\repositories\profits;
 
 
 use app\common\dao\profit\ZeroUserProfitDao;
-use app\common\dao\store\order\OldUserOfGoodsDao;
-use app\common\dao\store\order\StoreOrderDao;
 use app\common\dao\user\UserDao;
 use app\common\dao\user\ZeroUserLineDao;
 use app\common\enum\user\ZeroUserEnum;
 use app\common\model\profit\ZeroUserProfitsDetail;
+use app\common\utils\QueueLogger;
 use app\jobs\ZeroUserProfits;
 use think\db\exception\DataNotFoundException;
 use think\db\exception\DbException;
@@ -142,16 +141,18 @@ class ProfitsRepository
                 // 获取初，中，高用户
                 unset($groupData);
                 $groupData = $this->getUserByGroup($userIds, $key);
-                if (!empty($groupData)) {
-                    // 获取初中高用户直推和团队业绩
-                    $profitDetail = $this->getDirect($groupData, $amount * $value);
-                    $directUids[$key] = $profitDetail;
-                    $this->recordLog($param, $amount, $profitDetail);
+                if (empty($groupData)) {
+                    QueueLogger::info('0号线合伙人分红：0号线用户：'.$param['zeroUserId'].',暂无'.$key.'级别用户' );
+                    continue;
                 }
+                // 获取初中高用户直推和团队业绩
+                $profitDetail = $this->getDirect($groupData, $amount * $value);
+                $directUids[$key] = $profitDetail;
+                $this->recordLog($param, $amount, $profitDetail);
             }
             return true;
         } catch (\Exception $e) {
-            return false;
+            return $e->getMessage();
         }
     }
 
@@ -202,15 +203,6 @@ class ProfitsRepository
             return [];
         }
 
-        // // 循环获取0号线用户团队
-        // $resArr = [];
-        // foreach ($zeroUserIds as $zeroUserId) {
-        //     $zeroUid = $zeroUserId['team_uid'];
-        //     $sql = "select getUserLevelId($zeroUid) as teamUids";
-        //     $teamUids = Db::query($sql)[0]['teamUids'];
-        //     $resArr[$zeroUid] = $teamUids;
-        // }
-
         return $zeroUserIds;
     }
 

app/common/utils/Pv.php

@@ -2,53 +2,195 @@
 
 namespace app\common\utils;
 
+use app\common\dao\profit\ProductPvDao;
+use app\common\dao\store\order\StoreCartDao;
 use app\common\dao\store\order\StoreOrderDao;
+use app\common\dao\user\UserDao;
 
 /**
- * 业绩计算
+ * PV业绩计算工具类
+ *
+ * 用于计算用户的业绩(PV)值，基于订单和购物车数据进行统计
+ * PV值根据商品配置的PV系数和购买数量计算得出
  */
 class Pv
 {
-    public $pv = [];
+    /**
+     * 商户ID，默认为496
+     * @var int
+     */
+    private $merId = 496;
+
+    /**
+     * 订单状态数组，包含有效的订单状态值
+     * 0,1,2,3 可能代表：待付款、已付款、已发货、已完成等状态
+     * @var array
+     */
+    private $status = [0, 1, 2, 3];
+
+    /**
+     * 需要排除的测试用户ID列表
+     * 在计算业绩时需要过滤掉的测试用户
+     * @var array
+     */
+    private $removeUserIdList;
+
+    /**
+     * 订单数据访问对象
+     * @var StoreOrderDao
+     */
     public $storeOrderDao;
+
+    /**
+     * 购物车数据访问对象
+     * @var StoreCartDao
+     */
+    public $cartDao;
+
+    /**
+     * 用户数据访问对象
+     * @var UserDao
+     */
+    public $userDao;
+
+    public $pvDao;
+
+    /**
+     * 构造函数
+     * 初始化数据访问对象和测试用户列表
+     */
     public function __construct()
     {
-        $this->pv = $this->getPvConfig();
         $this->storeOrderDao = new StoreOrderDao();
+        $this->cartDao = new StoreCartDao();
+        $this->userDao = new UserDao();
+        $this->pvDao = new ProductPvDao();
+        $this->removeUserIdList = $this->getRemoveUserIdList();
     }
 
-    public function getPvConfig()
+    /**
+     * 获取商品PV配置
+     *
+     * 返回商品ID到PV系数的映射数组
+     * PV系数表示每个商品对应的业绩值
+     *
+     * @return int[] 商品PV配置数组，格式：[商品ID => PV系数]
+     */
+    public function getPvConfig(): array
     {
-        return [
-            1 => 2,
-            2 => 3
-        ];
+        return  $this->pvDao->getData();
     }
 
-    // 计算业绩
-    public function countPv($userId = 0,$startTime = 0,$endTime = 0)
+    /**
+     * 计算用户业绩(PV)
+     *
+     * 根据用户ID和时间范围计算业绩值
+     * 流程：获取订单数据 → 获取购物车数据 → 统计商品数量 → 计算PV总值
+     *
+     * @param array $userId 用户ID数组，默认为空数组
+     * @param int $startTime 开始时间戳，0表示无限制
+     * @param int $endTime 结束时间戳，0表示无限制
+     * @return void 直接输出计算结果（使用dd函数）
+     */
+    public function countPv($userId = [], $startTime = 0, $endTime = 0): void
     {
-        $orderData = $this->storeOrderDao->getDataForPv($userId = 0,$startTime = 0,$endTime = 0);
+        // 测试用户id（硬编码，实际应该使用传入的参数）
+        // $userId = [1592];
+        
+        // 时间范围示例（注释掉的代码）
+        // $startTime = '2025-9-8';
+        // $endTime = '2025-9-11';
+        
+        // 获取订单数据（过滤掉测试用户）
+        $orderData = $this->storeOrderDao->getDataForPv(
+            $userId,
+            $startTime,
+            $endTime,
+            $this->merId,
+            $this->status,
+            $this->removeUserIdList
+        );
+        
+        // 提取所有购物车ID
+        $cartIds = array_column($orderData, 'cart_id');
 
-
-
-        $cartData = $this->getCartData();
+        // 根据购物车ID获取购物车数据
+        $cartData = $this->cartDao->getDataByIds($cartIds);
+        
+        // 统计每个商品的出现次数
+        $productCount = $this->countProductIds($cartData);
+        
+        // 根据商品数量和PV配置计算总PV值
+        $pv = $this->countResult($productCount);
+        
+        // 输出计算结果（调试用）
+        dd($pv);
     }
 
-    // 获取订单数据
-    public function getOrderData($userId,$startTime,$endTime){
+    /**
+     * 获取需要排除的测试用户ID列表
+     *
+     * 从用户DAO获取标记为测试用户的ID列表
+     * 这些用户在计算业绩时会被排除
+     *
+     * @return array 测试用户ID数组
+     */
+    private function getRemoveUserIdList(): array
+    {
+        return $this->userDao->getTestUser();
+    }
 
-        dd($this->storeOrderDao::getModel()::getDB());
+    /**
+     * 统计购物车数据中商品ID的出现次数
+     *
+     * 遍历购物车数据，统计每个商品ID的购买次数
+     *
+     * @param array $cartData 购物车数据数组，包含商品信息
+     * @return array 商品ID统计结果，格式：[商品ID => 购买次数]
+     */
+    private function countProductIds(array $cartData): array
+    {
+        $productIdCounts = [];
+        
+        foreach ($cartData as $cartItem) {
+            $productId = $cartItem['product_id'];
+            
+            if (isset($productIdCounts[$productId])) {
+                // 如果商品已存在，增加计数
+                $productIdCounts[$productId]++;
+            } else {
+                // 如果商品不存在，初始化计数为1
+                $productIdCounts[$productId] = 1;
+            }
+        }
 
-        return [
-            1=>[],
-            2=>[]
-        ];
+        return $productIdCounts;
     }
 
-    public function getCartData(){
-        return [
-
-        ];
+    /**
+     * 计算最终PV结果
+     *
+     * 根据商品购买次数和PV配置计算总业绩值
+     * 公式：总PV = Σ(商品购买次数 × 商品PV系数)
+     *
+     * @param array $productCount 商品购买次数数组，格式：[商品ID => 购买次数]
+     * @return float|int 总PV值
+     */
+    private function countResult(array $productCount)
+    {
+        // 获取PV配置
+        $pvConfig = $this->getPvConfig();
+        $totalPv = 0;
+        
+        // 遍历每个商品计算PV贡献
+        foreach ($productCount as $productId => $count) {
+            if (isset($pvConfig[$productId])) {
+                // 如果商品有配置PV系数，计算该商品的PV贡献
+                $totalPv += $count * $pvConfig[$productId];
+            }
+            // 如果没有配置PV系数的商品，不计入业绩
+        }
+        
+        return $totalPv;
     }
 }

app/controller/admin/profits/ShareProfits.php

@@ -3,6 +3,7 @@
 namespace app\controller\admin\profits;
 
 use app\common\repositories\profits\ProfitsRepository;
+use app\common\utils\Pv;
 use app\controller\admin\BaseController;
 use app\entity\admin\request\profits\PartnerProfitsRequestEntity;
 use app\entity\admin\response\profits\ZeroUserProfitResponseEntity;
@@ -32,6 +33,12 @@ class ShareProfits extends BaseController
      */
     public function partnerProfits(PartnerProfitsValidate $validate)
     {
+
+        $a = new Pv();
+        $a->countPv();
+        die;
+
+
         $validationResult = $this->validateRequest($validate, PartnerProfitsRequestEntity::class);
         $res = $this->repository->getZeroUser($validationResult->toArray());
         // $res = $this->repository->profits($validationResult->toArray());

app/jobs/ZeroUserProfits.php

@@ -25,13 +25,13 @@ class ZeroUserProfits implements JobInterface
             // 执行业务
             $res = $repository->profits($data);
             
-            if ($res) {
+            if (!is_string($res)) {
                 // 记录成功日志
                 QueueLogger::success('ZeroUserProfits', $job, $data, $res);
                 $job->delete();
             } else {
                 // 记录业务执行失败但未异常的情况
-                QueueLogger::warning('ZeroUserProfits', $job, $data, '业务执行返回false');
+                QueueLogger::warning('ZeroUserProfits', $job, $data, '业务执行返回false,错误信息：' . $res);
                 
                 if ($job->attempts() > 3) {
                     // 超过重试次数，调用failed方法记录异常状态