共富区-第一次促销升级活动

app/common/dao/shared/SharedProsperityGroupUserDao.php

@@ -5,6 +5,7 @@ namespace app\common\dao\shared;
 use app\common\dao\BaseDao;
 use app\common\model\BaseModel;
 use app\common\model\shared\SharedProsperityGroupUser;
+use app\entity\data\shared\SharedProsperityGroupUserEntity;
 use think\db\exception\DbException;
 
 class SharedProsperityGroupUserDao extends BaseDao
@@ -57,4 +58,55 @@ class SharedProsperityGroupUserDao extends BaseDao
             return [];
         }
     }
+
+    /**
+     * @param array $idList
+     * @return SharedProsperityGroupUserEntity[]
+     */
+    public function getSharedProsperityGroupUserEntityListByIdList(array $idList): array
+    {
+        $entityList = [];
+        try {
+            /** @var SharedProsperityGroupUser $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('id', $idList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return SharedProsperityGroupUserEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
+
+    /**
+     * @param array $userIdList
+     * @return SharedProsperityGroupUserEntity[]
+     */
+    public function getSharedProsperityGroupUserEntityListByUserIdList(array $userIdList): array
+    {
+        $entityList = [];
+        try {
+            /** @var SharedProsperityGroupUser $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('user_id', $userIdList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return SharedProsperityGroupUserEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
+
 }

app/common/repositories/shared/SharedProsperityGroupUserRepository.php

@@ -0,0 +1,121 @@
+<?php
+
+namespace app\common\repositories\shared;
+
+use app\common\dao\shared\SharedProsperityGroupUserDao;
+use app\common\repositories\BaseRepository;
+use app\entity\data\shared\SharedProsperityGroupUserEntity;
+use think\db\exception\DbException;
+
+class SharedProsperityGroupUserRepository extends BaseRepository
+{
+
+    protected $dao;
+
+    /**
+     * SharedProsperityGroupUserRepository constructor.
+     * @param SharedProsperityGroupUserDao $dao
+     */
+    public function __construct(SharedProsperityGroupUserDao $dao)
+    {
+        $this->dao = $dao;
+    }
+
+    /**
+     * @param int $id
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function getSharedProsperityGroupUserEntityById(int $id): SharedProsperityGroupUserEntity
+    {
+        $entityList = $this->getSharedProsperityGroupUserEntityListByIdList([$id]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof SharedProsperityGroupUserEntity) {
+            return $entity;
+        } else {
+            /** @var SharedProsperityGroupUserEntity */
+            return SharedProsperityGroupUserEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $idList
+     * @return SharedProsperityGroupUserEntity[]
+     */
+    public function getSharedProsperityGroupUserEntityListByIdList(array $idList): array
+    {
+        return $this->dao->getSharedProsperityGroupUserEntityListByIdList($idList);
+    }
+
+    /**
+     * @param int $userId
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function getSharedProsperityGroupUserEntityByUserId(int $userId): SharedProsperityGroupUserEntity
+    {
+        $entityList = $this->getSharedProsperityGroupUserEntityListByIdList([$userId]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof SharedProsperityGroupUserEntity) {
+            return $entity;
+        } else {
+            /** @var SharedProsperityGroupUserEntity */
+            return SharedProsperityGroupUserEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $userIdList
+     * @return SharedProsperityGroupUserEntity[]
+     */
+    public function getSharedProsperityGroupUserEntityListByUserIdList(array $userIdList): array
+    {
+        return $this->dao->getSharedProsperityGroupUserEntityListByUserIdList($userIdList);
+    }
+
+    public function create($data)
+    {
+        return $this->dao->create($data);
+    }
+
+
+    /**
+     * @param SharedProsperityGroupUserEntity $SharedProsperityGroupUserEntity
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function createByEntity(SharedProsperityGroupUserEntity $SharedProsperityGroupUserEntity): SharedProsperityGroupUserEntity
+    {
+        $result = $this->create($SharedProsperityGroupUserEntity->toUnderlineArray())->toArray();
+        /** @var SharedProsperityGroupUserEntity $entity */
+        $entity = SharedProsperityGroupUserEntity::newInstance($result);
+        return $entity;
+    }
+
+    /**
+     * @param $id
+     * @param $data
+     * @return int
+     */
+    public function update($id, $data): int
+    {
+        try {
+            return $this->dao->update($id, $data);
+        } catch (DbException $e) {
+            return 0;
+        }
+    }
+
+    /**
+     * @param SharedProsperityGroupUserEntity $SharedProsperityGroupUserEntity
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function updateByEntity(SharedProsperityGroupUserEntity $SharedProsperityGroupUserEntity): SharedProsperityGroupUserEntity
+    {
+        if (empty($SharedProsperityGroupUserEntity->getId())) {
+            return SharedProsperityGroupUserEntity::newInstance();
+        }
+        $result = $this->update($SharedProsperityGroupUserEntity->getId(), $SharedProsperityGroupUserEntity->toUnderlineArray());
+        if ($result > 0) {
+            return $this->getSharedProsperityGroupUserEntityById($SharedProsperityGroupUserEntity->getId());
+        }
+        return SharedProsperityGroupUserEntity::newInstance();
+    }
+}

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -10,6 +10,7 @@ use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\enum\shared\SharedProsperityUserEnum;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
+use app\entity\data\shared\SharedProsperityGroupUserEntity;
 use app\entity\data\shared\SharedProsperityRecommendConfigEntity;
 use app\entity\data\shared\SharedProsperityUserEntity;
 use think\db\exception\DbException;
@@ -225,9 +226,9 @@ class SharedProsperityUserRepository extends BaseRepository
         $maxPv = 0;
         $maxPvIndex = -1;
         foreach ($list as $index => &$item) {
-            $teamUserIds = $this->dao->getAllSubordinateUserIds($item['user_id'],false,4);
+            $teamUserIds = $this->dao->getAllSubordinateUserIds($item['user_id'], false, 4);
             $teamTotalCount = count($teamUserIds);
-            $teamPvSum = $this->dao->getTeamPvSum($item['user_id'],4);
+            $teamPvSum = $this->dao->getTeamPvSum($item['user_id'], 4);
             $item['team_total_count'] = $teamTotalCount;
             $item['team_pv_sum'] = $teamPvSum;
             // 补充用户信息
@@ -364,7 +365,52 @@ class SharedProsperityUserRepository extends BaseRepository
             //     );
             // }
 
+
+            // 暂时新增加逻辑 用户购买 298 商品后，自动升级为1星合伙人，目前只有消费者 能够获得PV值，在奖励结算时，判断订单金额 是否大于 298 并且 用户身份为 用户，则升级为一星合伙人
+            // 逻辑修改，如果用户的身份 是普通用户，则统计他在共富区内 所有消费的金额，是否超 每天自增的 升级限制金额，如果超过则升级为1星合伙人
+            if ($sharedProsperityUserEntity->getPartnerLevel() == 0) {
+                /** @var StoreOrderRepository $storeOrderRepository */
+                $storeOrderRepository = app()->make(StoreOrderRepository::class);
+                $sumTotalPrice = $storeOrderRepository->getSumTotalPriceByUidAndMerId($sharedProsperityUserEntity->getUserId(), CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code']);
+                if (!empty($sumTotalPrice)) {
+                    $partnerLevel = $sharedProsperityUserEntity->getPartnerLevel();
+                    /** @var SharedProsperityRecommendConfigRepository $sharedProsperityRecommendConfigRepository */
+                    $sharedProsperityRecommendConfigRepository = app()->make(SharedProsperityRecommendConfigRepository::class);
+                    $sharedProsperityRecommendConfigEntityList = $sharedProsperityRecommendConfigRepository->getList();
+                    usort($sharedProsperityRecommendConfigEntityList, function (SharedProsperityRecommendConfigEntity $a, SharedProsperityRecommendConfigEntity $b) {
+                        return $a->getLevel() <=> $b->getLevel();  // 从小到大排序
+                    });
+                    foreach ($sharedProsperityRecommendConfigEntityList as $sharedProsperityRecommendConfigEntity) {
+                        if (is_null($sharedProsperityRecommendConfigEntity->getConsume())) {
+                            continue;
+                        }
+                        if ($sumTotalPrice >= $sharedProsperityRecommendConfigEntity->getConsume() && $sharedProsperityUserEntity->getPartnerLevel() < $sharedProsperityRecommendConfigEntity->getLevel()) {
+                            // 修改用户的等级
+                            $sharedProsperityUserEntity->setPartnerLevel($sharedProsperityRecommendConfigEntity->getLevel());
+                        }
+                    }
+                    // 也就是说 升级了 保存到数据库
+                    if ($partnerLevel != $sharedProsperityUserEntity->getPartnerLevel()) {
+                        $this->updateByEntity(
+                            SharedProsperityUserEntity::newInstance()
+                                ->setId($sharedProsperityUserEntity->getId())
+                                ->setPartnerLevel($sharedProsperityUserEntity->getPartnerLevel())
+                        );
+                    }
+                }
+            }
+
+            // 根据原来的团队升级规则，去升级推荐人等级
             $this->upgradeUpperLevels($sharedProsperityUserEntity->getUserId(), $sharedProsperityRecommendConfigEntityList);
+
+            // 新的升级规则
+            // 如果当前用户升级了 那要看一下他的上级 是否也需要升级
+            if (!empty($sharedProsperityUserEntity->getParentId())) {
+                $sharedProsperityUserEntityByParent = $this->getSharedProsperityUserEntityByUserId($sharedProsperityUserEntity->getParentId());
+                if (!empty($sharedProsperityUserEntityByParent->getId()) && $sharedProsperityUserEntityByParent->getPartnerLevel() < 2) {
+                    $this->upgradeUpperLevelsByPromotionOne($sharedProsperityUserEntityByParent);
+                }
+            }
         }
     }
 
@@ -422,30 +468,6 @@ class SharedProsperityUserRepository extends BaseRepository
         // 计算新等级
         $newLevel = $this->calculateLevelByTeamPv($teamPvBySmallSum, $sharedProsperityRecommendConfigEntityList);
 
-        // 暂时新增加逻辑 用户购买 298 商品后，自动升级为1星合伙人，目前只有消费者 能够获得PV值，在奖励结算时，判断订单金额 是否大于 298 并且 用户身份为 用户，则升级为一星合伙人
-        // 逻辑修改，如果用户的身份 是普通用户，则统计他在共富区内 所有消费的金额，是否超 每天自增的 升级限制金额，如果超过则升级为1星合伙人
-        if ($sharedProsperityUserEntity->getPartnerLevel() == 0) {
-            /** @var StoreOrderRepository $storeOrderRepository */
-            $storeOrderRepository = app()->make(StoreOrderRepository::class);
-            $sumTotalPrice = $storeOrderRepository->getSumTotalPriceByUidAndMerId($sharedProsperityUserEntity->getUserId(), CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code']);
-            if (!empty($sumTotalPrice)) {
-                /** @var SharedProsperityRecommendConfigRepository $sharedProsperityRecommendConfigRepository */
-                $sharedProsperityRecommendConfigRepository = app()->make(SharedProsperityRecommendConfigRepository::class);
-                $sharedProsperityRecommendConfigEntityList = $sharedProsperityRecommendConfigRepository->getList();
-                usort($sharedProsperityRecommendConfigEntityList, function (SharedProsperityRecommendConfigEntity $a, SharedProsperityRecommendConfigEntity $b) {
-                    return $a->getLevel() <=> $b->getLevel();  // 从小到大排序
-                });
-                foreach ($sharedProsperityRecommendConfigEntityList as $sharedProsperityRecommendConfigEntity) {
-                    if (is_null($sharedProsperityRecommendConfigEntity->getConsume())) {
-                        continue;
-                    }
-                    if ($sumTotalPrice >= $sharedProsperityRecommendConfigEntity->getConsume() && $newLevel < $sharedProsperityRecommendConfigEntity->getLevel()) {
-                        $newLevel = $sharedProsperityRecommendConfigEntity->getLevel();
-                    }
-                }
-            }
-        }
-
         // 如果新等级大于当前等级，则更新
         if ($newLevel > $sharedProsperityUserEntity->getPartnerLevel()) {
             $this->updateByEntity(
@@ -557,13 +579,13 @@ class SharedProsperityUserRepository extends BaseRepository
     {
         /** @var SharedProsperityUserDao $shareUserDao */
         $shareUserDao = app()->make(SharedProsperityUserDao::class);
-        
+
         // 获取所有下级用户ID（包括自己）
         $subordinateIds = $shareUserDao->getAllSubordinateUserIds($userId, true);
         if (empty($subordinateIds)) {
             return [];
         }
-        
+
         // 获取这些共富用户的基本信息（包含parent_id）
         $sharedUsers = $shareUserDao->getSharedProsperityUserEntityListByUserIdList($subordinateIds);
 
@@ -592,9 +614,9 @@ class SharedProsperityUserRepository extends BaseRepository
         $idToName = [];
         foreach ($userInfos as $userInfo) {
             $sharedUserInfo = $shareUserDao->getSharedProsperityUserEntityListByUserIdList([$userInfo->getUid()]);
-            $idToName[$userInfo->getUid()] = $userInfo->getNickname()  . '(' . $userInfo->account .')(身份：' . $partnerLevel[$sharedUserInfo[0]->getPartnerLevel()] . ')' ?? ('用户' . $userInfo->getUid());
+            $idToName[$userInfo->getUid()] = $userInfo->getNickname() . '(' . $userInfo->account . ')(身份：' . $partnerLevel[$sharedUserInfo[0]->getPartnerLevel()] . ')' ?? ('用户' . $userInfo->getUid());
         }
-        
+
         // 构建节点数组
         $nodes = [];
         foreach ($sharedUsers as $sharedUser) {
@@ -604,7 +626,7 @@ class SharedProsperityUserRepository extends BaseRepository
                 'name' => $idToName[$sharedUser->getUserId()] ?? ('用户' . $sharedUser->getUserId()),
             ];
         }
-        
+
         // 构建树，以传入的用户为根节点
         $rootNode = $this->findNode($nodes, $userId);
         if (!$rootNode) {
@@ -617,7 +639,7 @@ class SharedProsperityUserRepository extends BaseRepository
         ];
         return [$tree];
     }
-    
+
     /**
      * 递归构建共富用户树
      * @param array $nodes 节点数组，每个节点包含 user_id, parent_id, name
@@ -639,7 +661,7 @@ class SharedProsperityUserRepository extends BaseRepository
         }
         return $branch;
     }
-    
+
     /**
      * 根据user_id查找节点名称
      * @param array $nodes
@@ -655,7 +677,7 @@ class SharedProsperityUserRepository extends BaseRepository
         }
         return null;
     }
-    
+
     /**
      * 根据user_id查找节点
      * @param array $nodes
@@ -685,7 +707,7 @@ class SharedProsperityUserRepository extends BaseRepository
             $userData = $userDao->accountLikeByUser($params['account']);
             $uids = [];
             if ($userData) {
-                $uids = array_column($userData,'uid');
+                $uids = array_column($userData, 'uid');
             }
 
             $where[] = ['a.user_id', 'in', $uids];
@@ -697,7 +719,7 @@ class SharedProsperityUserRepository extends BaseRepository
             $userData = $userDao->nicknameLikeByUser($params['nickname']);
             $uids = [];
             if ($userData) {
-                $uids = array_column($userData,'uid');
+                $uids = array_column($userData, 'uid');
             }
             $where[] = ['a.user_id', 'in', $uids];
         }
@@ -824,4 +846,66 @@ class SharedProsperityUserRepository extends BaseRepository
             return false;
         }
     }
+
+    /**
+     * 第一次促销的 身份 升级方法
+     * @param SharedProsperityUserEntity $sharedProsperityUserEntity
+     * @return void
+     */
+    public function upgradeUpperLevelsByPromotionOne(SharedProsperityUserEntity $sharedProsperityUserEntity)
+    {
+        // 判断当前用户 是否在共富区的消费值 > 298,如果不满足则不能升级
+        /** @var StoreOrderRepository $storeOrderRepository */
+        $storeOrderRepository = app()->make(StoreOrderRepository::class);
+        $sumTotalPrice = $storeOrderRepository->getSumTotalPriceByUidAndMerId($sharedProsperityUserEntity->getUserId(), CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code']);
+        if ($sumTotalPrice < 298) {
+            return;
+        }
+
+        // 查询当前用户的直属下级
+        $sharedProsperityUserEntityListByChild = $this->getSharedProsperityUserEntityListByParentId($sharedProsperityUserEntity->getUserId());
+        // 一星合伙人数量
+        $oneStarPartner = 0;
+        // 二星合伙人数量
+        $twoStarPartner = 0;
+        foreach ($sharedProsperityUserEntityListByChild as $sharedProsperityUserEntityByChild) {
+            if ($sharedProsperityUserEntityByChild->getPartnerLevel() >= 1) {
+                $oneStarPartner++;
+                if ($sharedProsperityUserEntityByChild->getPartnerLevel() >= 2) {
+                    $twoStarPartner++;
+                }
+            }
+        }
+
+        // 推荐 6 个 2星以上的合伙人 增加万人团身份
+        if ($twoStarPartner >= 6) {
+            /** @var SharedProsperityGroupUserRepository $sharedProsperityGroupUserRepository */
+            $sharedProsperityGroupUserRepository = app()->make(SharedProsperityGroupUserRepository::class);
+            $sharedProsperityGroupUserEntity = $sharedProsperityGroupUserRepository->getSharedProsperityGroupUserEntityByUserId($sharedProsperityUserEntity->getUserId());
+            if (empty($sharedProsperityGroupUserEntity->getId())) {
+                // 如果没有共富团身份 则增加共富团 万人团身份
+                $sharedProsperityGroupUserRepository->createByEntity(
+                    SharedProsperityGroupUserEntity::newInstance()
+                        ->setUserId($sharedProsperityUserEntity->getUserId())
+                        ->setGroupId(1)
+                        ->setStatus(1)
+                );
+            }
+        }
+        // 推荐 6 个 1星以上的合伙人 则升级为 2 星合伙人
+        if ($sharedProsperityUserEntity->getPartnerLevel() < 2 && $oneStarPartner >= 6) {
+            $this->updateByEntity(
+                SharedProsperityUserEntity::newInstance()
+                    ->setId($sharedProsperityUserEntity->getId())
+                    ->setPartnerLevel(2)
+            );
+            // 如果当前用户升级了 那要看一下他的上级 是否也需要升级
+            if (!empty($sharedProsperityUserEntity->getParentId())) {
+                $sharedProsperityUserEntityByParent = $this->getSharedProsperityUserEntityByUserId($sharedProsperityUserEntity->getParentId());
+                if (!empty($sharedProsperityUserEntityByParent->getId()) && $sharedProsperityUserEntityByParent->getPartnerLevel() < 2) {
+                    $this->upgradeUpperLevelsByPromotionOne($sharedProsperityUserEntityByParent);
+                }
+            }
+        }
+    }
 }

app/entity/data/shared/SharedProsperityGroupUserEntity.php

@@ -0,0 +1,123 @@
+<?php
+
+namespace app\entity\data\shared;
+
+use app\entity\data\DataEntity;
+
+class SharedProsperityGroupUserEntity extends DataEntity
+{
+    public $id = null;          // 记录ID
+    public $groupId = null;     // 等级 1万人团 2千人团 3百人团
+    public $userId = null;      // 用户id
+    public $status = null;      // 状态 0失效 1有效
+    public $createTime = null;  // 创建时间
+    public $updateTime = null;  // 更新时间
+
+    /**
+     * @return mixed
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * @param mixed $id
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function setId($id): SharedProsperityGroupUserEntity
+    {
+        $this->id = $id;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getGroupId()
+    {
+        return $this->groupId;
+    }
+
+    /**
+     * @param mixed $groupId
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function setGroupId($groupId): SharedProsperityGroupUserEntity
+    {
+        $this->groupId = $groupId;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUserId()
+    {
+        return $this->userId;
+    }
+
+    /**
+     * @param mixed $userId
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function setUserId($userId): SharedProsperityGroupUserEntity
+    {
+        $this->userId = $userId;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getStatus()
+    {
+        return $this->status;
+    }
+
+    /**
+     * @param mixed $status
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function setStatus($status): SharedProsperityGroupUserEntity
+    {
+        $this->status = $status;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getCreateTime()
+    {
+        return $this->createTime;
+    }
+
+    /**
+     * @param mixed $createTime
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function setCreateTime($createTime): SharedProsperityGroupUserEntity
+    {
+        $this->createTime = $createTime;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUpdateTime()
+    {
+        return $this->updateTime;
+    }
+
+    /**
+     * @param mixed $updateTime
+     * @return SharedProsperityGroupUserEntity
+     */
+    public function setUpdateTime($updateTime): SharedProsperityGroupUserEntity
+    {
+        $this->updateTime = $updateTime;
+        return $this;
+    }
+}