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

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

@@ -3992,7 +3992,15 @@ class StoreOrderRepository extends BaseRepository
         //推荐养老金添加
         $pvfee = bcmul($order['total_price'], $sanfangfenpei['pv'], 2);
         $zijiUser = Db::name("user")->where('uid', $order["uid"])->find();
-        $sprerdUser = Db::name("user")->where('uid', $zijiUser['spread_uid'])->find();
+        $spreadUid = $zijiUser['spread_uid'];
+        /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+        $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+        $sharedProsperityUserEntity = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($order["uid"]);
+        // 判断推广者 如果推广者 是共富体系会员
+        if (!empty($sharedProsperityUserEntity->getId())) {
+            $spreadUid = $sharedProsperityUserEntity->getParentId();
+        }
+        $sprerdUser = Db::name("user")->where('uid', $spreadUid)->find();
         //不为空的时候进行添加推荐奖励
         if ($sprerdUser) {
             //奖励推荐用户养老金

app/common/repositories/user/UserThirdRepository.php

@@ -11,9 +11,12 @@
 namespace app\common\repositories\user;
 
 use app\common\dao\user\UserThirdDao;
+use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\model\user\User;
 use app\common\repositories\BaseRepository;
 
+use app\common\repositories\shared\SharedProsperityRewardRecordRepository;
+use app\common\repositories\shared\SharedProsperityUserRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
 use app\common\repositories\store\product\ProductRepository;
 use app\model\common\TbOrderModel;
@@ -833,17 +836,35 @@ class UserThirdRepository extends BaseRepository
             Db::name("user_sign_gongxian")->insert($gongxian_data);//添加贡献记录
             log::info("===添加完积分和贡献值");
 
-            // 添加pv记录
-            $pv_data = [
-                "uid"           =>$user_id,
-                "pv"            =>$gongxian,
-                "addtime"       =>time(),
-                "status"        =>-1,
-                "order_type"    =>$type_shop,
-                "order_id"      =>$order_id,
-                "mark"          =>"购买{$make}商品获得的PV",
-            ];
-            Db::name("user_pv_log")->insert($pv_data);//添加pv记录
+            /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+            $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+            $sharedProsperityUserEntity = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($user_id);
+            // 判断推广者 如果推广者 是共富体系会员
+            if (empty($sharedProsperityUserEntity->getId())) {
+                // 添加pv记录
+                $pv_data = [
+                    "uid"           =>$user_id,
+                    "pv"            =>$gongxian,
+                    "addtime"       =>time(),
+                    "status"        =>-1,
+                    "order_type"    =>$type_shop,
+                    "order_id"      =>$order_id,
+                    "mark"          =>"购买{$make}商品获得的PV",
+                ];
+                Db::name("user_pv_log")->insert($pv_data);//添加pv记录
+            } else {
+                /** @var SharedProsperityRewardRecordRepository $sharedProsperityRewardRecordRepository */
+                $sharedProsperityRewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
+                $sharedProsperityRewardRecordRepository->addSharedProsperityRewardRecord(
+                    $sharedProsperityUserEntity->getUserId(),
+                    SharedProsperityRewardRecordEnum::TYPE['PV']['code'],
+                    SharedProsperityRewardRecordEnum::PM['INCOME']['code'],
+                    $gongxian,
+                    $type_shop,
+                    $order_sn,
+                    "购买{$make}商品获得的PV"
+                );
+            }
 
             //判断是否是老用户  is_old=1是1.0的用户，1.0的用户要总pv*45%的红包
             if($user["is_old"]==1){