订单奖励-如果消费者是共富体系会员则将PV值和推荐人更换为共富体系对应信息

app/common/enum/CommonEnum.php

@@ -54,7 +54,6 @@ class CommonEnum
         'EQUITY_DIVIDEND' => ['code' => 13, 'name' => '股权分红'],
         'SHARE_EARNINGS' => ['code' => 20, 'name' => '分享收益'],
         'COMMISSION_RECORD_V1.0' => ['code' => 21, 'name' => '1.0佣金记录'],
-        'SHARED_PROSPERITY_DIRECT_COMMISSION' => ['code' => 100, 'name' => '共富体系直推佣金奖励'],
         'SHARED_PROSPERITY_PARTNER_COMMISSION' => ['code' => 101, 'name' => '共富体系合伙人分红佣金奖励'],
         'SHARED_PROSPERITY_THANK_COMMISSION' => ['code' => 102, 'name' => '共富体系感恩奖佣金奖励'],
         'SHARED_PROSPERITY_RICH_COMMISSION' => ['code' => 103, 'name' => '共富体系共富奖佣金奖励'],

app/common/repositories/store/order/StoreOrderRepository.php

@@ -11086,6 +11086,10 @@ class StoreOrderRepository extends BaseRepository
             throw new ValidateException('未查询到订单所属用户');
         }
 
+        /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+        $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+        $sharedProsperityUserEntity = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($userEntity->getUid());
+
         // 精彩生活区
         if ($storeOrderEntity->getMerId() == CommonEnum::DESIGN_MERCHANT_ID['WonderfulLiving']['code']) {
             // 为消费者 初始化 添加养老金记录
@@ -11119,17 +11123,31 @@ class StoreOrderRepository extends BaseRepository
                 $storeOrderEntity->getOrderId()
             );
 
-            // 初始化 PV
+            // 初始化 PV  如果用户 在共富体系中存在 则 将此PV统计到 共富体系中
             $pv = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['WonderfulLiving']['Self']['Pv']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
-            /** @var UserPvLogRepository $userPvLogRepository */
-            $userPvLogRepository = app()->make(UserPvLogRepository::class);
-            $userPvLogRepository->addUserPvLog(
-                $storeOrderEntity->getUid(),
-                $pv,
-                '购买精彩生活商品获得PV值',
-                UserPvLogEnum::ORDER_TYPE['Platform']['code'],
-                $storeOrderEntity->getOrderId()
-            );
+            if (empty($sharedProsperityUserEntity->getId())) {
+                /** @var UserPvLogRepository $userPvLogRepository */
+                $userPvLogRepository = app()->make(UserPvLogRepository::class);
+                $userPvLogRepository->addUserPvLog(
+                    $storeOrderEntity->getUid(),
+                    $pv,
+                    '购买精彩生活商品获得PV值',
+                    UserPvLogEnum::ORDER_TYPE['Platform']['code'],
+                    $storeOrderEntity->getOrderId()
+                );
+            } else {
+                /** @var SharedProsperityRewardRecordRepository $sharedProsperityRewardRecordRepository */
+                $sharedProsperityRewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
+                $sharedProsperityRewardRecordRepository->addSharedProsperityRewardRecord(
+                    $sharedProsperityUserEntity->getUserId(),
+                    SharedProsperityRewardRecordEnum::TYPE['PV']['code'],
+                    SharedProsperityRewardRecordEnum::PM['INCOME']['code'],
+                    $pv,
+                    SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'],
+                    $storeOrderEntity->getOrderSn(),
+                    '购买精彩生活商品获得PV值'
+                );
+            }
 
             // 初始化积分
             $score = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['WonderfulLiving']['Self']['Score']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
@@ -11160,9 +11178,13 @@ class StoreOrderRepository extends BaseRepository
                 );
             }
 
-            // 给推荐人的奖励
-            if (!empty($userEntity->getSpreadUid())) {
-                $userEntityBySpreadUid = $userRepository->getUserEntityByUid($userEntity->getSpreadUid());
+            // 给推荐人的奖励 如果消费者 存在共富体系中，则推荐人采用共富体系内的 推荐人
+            $spreadUid = $userEntity->getSpreadUid();
+            if (!empty($sharedProsperityUserEntity->getId())) {
+                $spreadUid = $sharedProsperityUserEntity->getParentId();
+            }
+            if (!empty($spreadUid)) {
+                $userEntityBySpreadUid = $userRepository->getUserEntityByUid($spreadUid);
                 if (!empty($userEntityBySpreadUid->getUid()) && $userEntityBySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
                     // 后台设置中 可以设置 推荐人 直推收益 的比例
                     $rate = static::getUserGroupRate($userEntityBySpreadUid->getUserGroup());
@@ -11564,9 +11586,7 @@ class StoreOrderRepository extends BaseRepository
             //     }
             // }
         } else if ($storeOrderEntity->getMerId() == CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code']) {
-            /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
-            $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
-            $sharedProsperityUserEntity = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($userEntity->getUid());
+
             // 如果当前 共富体系内 没有该用户信息，则需要为其创建 共富体系用户数据
             if (empty($sharedProsperityUserEntity->getId())) {
                 // 生成 共富体系用户实体
@@ -11701,7 +11721,7 @@ class StoreOrderRepository extends BaseRepository
                         $userBillRepository = app()->make(UserBillRepository::class);
                         $userBillRepository->addUserBill(
                             $sharedProsperityUserEntityByParent->getUserId(),
-                            UserBillEnum::COMMISSION_TYPE['SHARED_PROSPERITY_DIRECT_COMMISSION']['code'],
+                            UserBillEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code'],
                             UserBillEnum::PM['INCOME']['code'],
                             $brokeragePriceBySpreadUid,
                             UserBillEnum::CATEGORY['NowMoney']['code'],
@@ -11751,17 +11771,31 @@ class StoreOrderRepository extends BaseRepository
                 $storeOrderEntity->getOrderId()
             );
 
-            // 初始化 PV
+            // 初始化 PV  如果用户 在共富体系中存在 则 将此PV统计到 共富体系中
             $pv = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['CommercialDistrict']['Self']['Pv']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
-            /** @var UserPvLogRepository $userPvLogRepository */
-            $userPvLogRepository = app()->make(UserPvLogRepository::class);
-            $userPvLogRepository->addUserPvLog(
-                $storeOrderEntity->getUid(),
-                $pv,
-                '购买商贸区商品获得PV值',
-                UserPvLogEnum::ORDER_TYPE['Platform']['code'],
-                $storeOrderEntity->getOrderId()
-            );
+            if (empty($sharedProsperityUserEntity->getId())) {
+                /** @var UserPvLogRepository $userPvLogRepository */
+                $userPvLogRepository = app()->make(UserPvLogRepository::class);
+                $userPvLogRepository->addUserPvLog(
+                    $storeOrderEntity->getUid(),
+                    $pv,
+                    '购买商贸区商品获得PV值',
+                    UserPvLogEnum::ORDER_TYPE['Platform']['code'],
+                    $storeOrderEntity->getOrderId()
+                );
+            } else {
+                /** @var SharedProsperityRewardRecordRepository $sharedProsperityRewardRecordRepository */
+                $sharedProsperityRewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
+                $sharedProsperityRewardRecordRepository->addSharedProsperityRewardRecord(
+                    $sharedProsperityUserEntity->getUserId(),
+                    SharedProsperityRewardRecordEnum::TYPE['PV']['code'],
+                    SharedProsperityRewardRecordEnum::PM['INCOME']['code'],
+                    $pv,
+                    SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'],
+                    $storeOrderEntity->getOrderSn(),
+                    '购买商贸区商品获得PV值'
+                );
+            }
 
             // 初始化积分
             $score = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['CommercialDistrict']['Self']['Score']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
@@ -11805,9 +11839,13 @@ class StoreOrderRepository extends BaseRepository
                 );
             }
 
-            // 给推荐人的奖励
-            if (!empty($userEntity->getSpreadUid())) {
-                $userEntityBySpreadUid = $userRepository->getUserEntityByUid($userEntity->getSpreadUid());
+            // 给推荐人的奖励 如果消费者 存在共富体系中，则推荐人采用共富体系内的 推荐人
+            $spreadUid = $userEntity->getSpreadUid();
+            if (!empty($sharedProsperityUserEntity->getId())) {
+                $spreadUid = $sharedProsperityUserEntity->getParentId();
+            }
+            if (!empty($spreadUid)) {
+                $userEntityBySpreadUid = $userRepository->getUserEntityByUid($spreadUid);
                 if (!empty($userEntityBySpreadUid->getUid()) && $userEntityBySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
                     // 后台设置中 可以设置 推荐人 直推收益 的比例
                     $rate = static::getUserGroupRate($userEntityBySpreadUid->getUserGroup());