共富体系-增加用户升级功能

app/common/dao/shared/SharedProsperityRecommendConfigDao.php

@@ -15,7 +15,7 @@ class SharedProsperityRecommendConfigDao extends BaseDao
     }
 
     /**
-     * @return array
+     * @return SharedProsperityRecommendConfigEntity[]
      * @author 史晨
      * @date 2026/2/5 14:43
      * 获取推荐配置

app/common/repositories/shared/SharedProsperityRecommendConfigRepository.php

@@ -38,7 +38,7 @@ class SharedProsperityRecommendConfigRepository extends BaseRepository
     }
 
     /**
-     * @return array
+     * @return SharedProsperityRecommendConfigEntity[]
      * @author 史晨
      * @date 2026/2/5 14:12
      */

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -5,6 +5,7 @@ namespace app\common\repositories\shared;
 use app\common\dao\shared\SharedProsperityUserDao;
 use app\common\dao\user\UserDao;
 use app\common\repositories\BaseRepository;
+use app\entity\data\shared\SharedProsperityRecommendConfigEntity;
 use app\entity\data\shared\SharedProsperityUserEntity;
 use think\db\exception\DbException;
 
@@ -245,4 +246,39 @@ class SharedProsperityUserRepository extends BaseRepository
     {
         return $this->dao->saveAll($dataList);
     }
+
+    /**
+     * 用户身份升级
+     * @param array $userIdList
+     * @return void
+     */
+    public function identityUpgrade(array $userIdList)
+    {
+        $sharedProsperityUserEntityList = $this->getSharedProsperityUserEntityListByUserIdList($userIdList);
+
+        /** @var SharedProsperityRecommendConfigRepository $sharedProsperityRecommendConfigRepository */
+        $sharedProsperityRecommendConfigRepository = app()->make(SharedProsperityRecommendConfigRepository::class);
+        $sharedProsperityRecommendConfigEntityList = $sharedProsperityRecommendConfigRepository->getList();
+        usort($sharedProsperityRecommendConfigEntityList, function (SharedProsperityRecommendConfigEntity $a, SharedProsperityRecommendConfigEntity $b) {
+            return $a->getPv() <=> $b->getPv();  // 从小到大排序
+        });
+        foreach ($sharedProsperityUserEntityList as $sharedProsperityUserEntity) {
+            $partnerLevel = 0;
+            foreach ($sharedProsperityRecommendConfigEntityList as $sharedProsperityRecommendConfigEntity) {
+                if ($sharedProsperityUserEntity->getPv() >= $sharedProsperityRecommendConfigEntity->getPv()) {
+                    $partnerLevel = $sharedProsperityRecommendConfigEntity->getLevel();
+                } else {
+                    // 如果本次验证的等级结果大于 之前的等级，说明用户升级了 需要更新等级
+                    if ($partnerLevel > $sharedProsperityUserEntity->getPartnerLevel()) {
+                        $this->updateByEntity(
+                            SharedProsperityUserEntity::newInstance()
+                                ->setId($sharedProsperityUserEntity->getId())
+                                ->setPartnerLevel($partnerLevel)
+                        );
+                    }
+                    break;
+                }
+            }
+        }
+    }
 }

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

@@ -948,11 +948,6 @@ class StoreGroupOrderRepository extends BaseRepository
         if (!empty($settlementOrderIdList)) {
             // 将订单 生成的奖励数据 立即结算（发放） 并更新这些订单的 结算字段以及结算时间
             $storeOrderRepository->settlementOrderByOrderIdList($settlementOrderIdList);
-
-            // 结算完成后更新用户的身份信息 设置用户 身份
-            /** @var UserRepository $userRepository */
-            $userRepository = app()->make(UserRepository::class);
-            $userRepository->setUserIdentity($storeGroupOrderEntity->getUid());
         }
 
         // 9、订单 分账 将收入的现金 商户部分 发放给 商户

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

@@ -11999,10 +11999,22 @@ class StoreOrderRepository extends BaseRepository
                 $userSignGongxianRepository = app()->make(UserSignGongxianRepository::class);
                 $userSignGongxianEntityList = $userSignGongxianRepository->getUserSignGongxianEntityListByOrderIdListAndPending(UserSignGongxianEnum::ORDER_TYPE['Platform']['code'], $unsettledOrderIdList);
                 if (!empty($userSignGongxianEntityList)) {
-                    $userSignGongxianIdList = array_map(function ($userSignGongxianEntity) {
+                    $affectedUserIdListByMember = [];
+                    $userSignGongxianIdList = array_map(function ($userSignGongxianEntity) use (&$affectedUserIdListByMember) {
+                        $affectedUserIdListByMember[] = $userSignGongxianEntity->getUid();
                         return $userSignGongxianEntity->getId();
                     }, $userSignGongxianEntityList);
                     $userSignGongxianRepository->executeByIdList($userSignGongxianIdList);
+                    // 会员体系结构 依靠贡献值变化而升级，所以当贡献值产生变化时 需记录用户ID 进行升级
+                    if (!empty($affectedUserIdListByMember)) {
+                        $affectedUserIdListByMember = array_unique($affectedUserIdListByMember);
+                        // 结算完成后更新用户的身份信息 设置用户 身份
+                        /** @var UserRepository $userRepository */
+                        $userRepository = app()->make(UserRepository::class);
+                        foreach ($affectedUserIdListByMember as $userId) {
+                            $userRepository->setUserIdentity($userId);
+                        }
+                    }
                 }
 
                 /** 结算 PV */
@@ -12032,10 +12044,21 @@ class StoreOrderRepository extends BaseRepository
                 $sharedProsperityRewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
                 $sharedProsperityRewardRecordEntityList = $sharedProsperityRewardRecordRepository->getSharedProsperityRewardRecordEntityListByOrderSnListAndPending(SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code'], $unsettledOrderSnList);
                 if (!empty($sharedProsperityRewardRecordEntityList)) {
-                    $sharedProsperityRewardRecordIdList = array_map(function ($sharedProsperityRewardRecordEntity) {
+                    $affectedUserIdListBySharedProsperity = [];
+                    $sharedProsperityRewardRecordIdList = array_map(function ($sharedProsperityRewardRecordEntity) use (&$affectedUserIdListBySharedProsperity) {
+                        if ($sharedProsperityRewardRecordEntity->getType() == SharedProsperityRewardRecordEnum::TYPE['PV']['code']) {
+                            $affectedUserIdListBySharedProsperity[] = $sharedProsperityRewardRecordEntity->getUserId();
+                        }
                         return $sharedProsperityRewardRecordEntity->getId();
                     }, $sharedProsperityRewardRecordEntityList);
                     $sharedProsperityRewardRecordRepository->executeByIdList($sharedProsperityRewardRecordIdList);
+                    // 当用户PV产生变化时，需要更新产生变化用户的 共富体系等级
+                    if (!empty($affectedUserIdListBySharedProsperity)) {
+                        $affectedUserIdListBySharedProsperity = array_unique($affectedUserIdListBySharedProsperity);
+                        /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+                        $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+                        $sharedProsperityUserRepository->identityUpgrade($affectedUserIdListBySharedProsperity);
+                    }
                 }
 
                 // 订单奖励结算时 更新订单自身 结算字段

app/entity/data/shared/SharedProsperityUserEntity.php

@@ -11,6 +11,7 @@ class SharedProsperityUserEntity extends DataEntity
     public $parentId = null;  // 推荐人用户id
     public $pv = null;  // pv
     public $consumerStocks = null; // 消费股
+    public $balance = null; // 余额
     public $withdrawalLimit = null;  // 提现额度
     public $partnerLevel = null;  // 合伙人等级
     public $createTime = null;  // 创建时间
@@ -109,6 +110,24 @@ class SharedProsperityUserEntity extends DataEntity
     /**
      * @return mixed
      */
+    public function getBalance()
+    {
+        return $this->balance;
+    }
+
+    /**
+     * @param mixed $balance
+     * @return SharedProsperityUserEntity
+     */
+    public function setBalance($balance): SharedProsperityUserEntity
+    {
+        $this->balance = $balance;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
     public function getWithdrawalLimit()
     {
         return $this->withdrawalLimit;