订单结算-共富区-结算共富奖励，消费者是用户身份购买共富区总金额>=升级限制金额自动升一星合伙人

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

@@ -664,6 +664,32 @@ class StoreOrderDao extends BaseDao
     }
 
     /**
+     * @param int $uid
+     * @param int $merId
+     * @return float
+     */
+    public function getSumTotalPriceByUidAndMerId(int $uid, int $merId = 0): float
+    {
+        $res = 0.00;
+        try {
+            /** @var StoreOrder $model */
+            $model = $this->getModel();
+            $res = $model::getDB()
+                ->where('uid', '=', $uid)
+                ->when($merId != 0, function ($query) use ($merId) {
+                    $query->where('mer_id', '=', $merId);
+                })
+                ->where('is_settlement', '=', StoreOrderEnum::IS_SETTLEMENT['YES']['code'])
+                ->where('is_del', '=', StoreOrderEnum::IS_DEL['No']['code'])
+                ->where('is_system_del', '=', StoreOrderEnum::IS_SYSTEM_DEL['No']['code'])
+                ->sum("total_price");
+        } catch (\Exception $e) {
+
+        }
+        return $res;
+    }
+
+    /**
      * @param array $groupOrderIdList
      * @return CommonEntity[]
      */

app/common/enum/store/StoreOrderEnum.php

@@ -6,6 +6,10 @@ use app\common\enum\CommonEnum;
 
 class StoreOrderEnum extends CommonEnum
 {
+    const IS_DEL = parent::IS_DEL;
+
+    const IS_SYSTEM_DEL = parent::IS_DEL;
+
     // 配送方式
     const DISTRIBUTION_MODE = [
         'ExpressDelivery' => ['code' => 1, 'name' => '快递'],

app/common/repositories/shared/SharedProsperityRewardRecordRepository.php

@@ -4,9 +4,11 @@ namespace app\common\repositories\shared;
 
 use app\common\dao\shared\SharedProsperityRewardRecordDao;
 use app\common\dao\shared\SharedProsperityUserDao;
+use app\common\enum\CommonEnum;
 use app\common\enum\shared\SharedProsperityRewardRecordEnum;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
+use app\entity\data\shared\SharedProsperityRecommendConfigEntity;
 use app\entity\data\shared\SharedProsperityRewardRecordEntity;
 use app\entity\data\shared\SharedProsperityUserEntity;
 use think\db\exception\DbException;
@@ -202,6 +204,7 @@ class SharedProsperityRewardRecordRepository extends BaseRepository
                 $updateSharedProsperityUserEntity = $updateSharedProsperityUserEntityList[$sharedProsperityUserEntity->getUserId()] ?? SharedProsperityUserEntity::newInstance();
                 $updateSharedProsperityUserEntity
                     ->setId($sharedProsperityUserEntity->getId())
+                    ->setUserId($sharedProsperityUserEntity->getUserId())
                     ->setPartnerLevel($sharedProsperityUserEntity->getPartnerLevel());
 
                 // 更新 账单 记录
@@ -258,12 +261,26 @@ class SharedProsperityRewardRecordRepository extends BaseRepository
                     }
 
                     // 暂时新增加逻辑 用户购买 298 商品后，自动升级为1星合伙人，目前只有消费者 能够获得PV值，在奖励结算时，判断订单金额 是否大于 298 并且 用户身份为 用户，则升级为一星合伙人
+                    // 逻辑修改，如果用户的身份 是普通用户，则统计他在共富区内 所有消费的金额，是否超 每天自增的 升级限制金额，如果超过则升级为1星合伙人
                     if ($updateSharedProsperityUserEntity->getPartnerLevel() == 0 && $sharedProsperityRewardRecordEntity->getTypeShop() == SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code']) {
                         /** @var StoreOrderRepository $storeOrderRepository */
                         $storeOrderRepository = app()->make(StoreOrderRepository::class);
-                        $storeOrderEntity = $storeOrderRepository->getStoreOrderEntityByOrderSn($sharedProsperityRewardRecordEntity->getOrderSn());
-                        if ($storeOrderEntity->getTotalPrice() >= 298) {
-                            $updateSharedProsperityUserEntity->setPartnerLevel(1);
+                        $sumTotalPrice = $storeOrderRepository->getSumTotalPriceByUidAndMerId($updateSharedProsperityUserEntity->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()) {
+                                    $updateSharedProsperityUserEntity->setPartnerLevel($sharedProsperityRecommendConfigEntity->getLevel());
+                                }
+                            }
                         }
                     }
                 }

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

@@ -10830,6 +10830,16 @@ class StoreOrderRepository extends BaseRepository
         return $this->dao->getStoreOrderEntityListByOrderSnList($orderSnList);
     }
 
+    /**
+     * @param int $uid
+     * @param int $merId
+     * @return float
+     */
+    public function getSumTotalPriceByUidAndMerId(int $uid, int $merId): float
+    {
+        return $this->dao->getSumTotalPriceByUidAndMerId($uid, $merId);
+    }
+
 
     /**
      * @param int $groupOrderId

app/entity/data/shared/SharedProsperityRecommendConfigEntity.php

@@ -12,6 +12,7 @@ class SharedProsperityRecommendConfigEntity extends DataEntity
     public $rewardRatio = null;  // 推荐奖励占比
     public $profitRatio = null;  // 分红奖励占比
     public $pv = null;  // 业绩
+    public $consume = null;  // 业绩
     public $createTime = null;  // 创建时间
     public $updateTime = null;  // 更新时间
 
@@ -123,6 +124,24 @@ class SharedProsperityRecommendConfigEntity extends DataEntity
     /**
      * @return mixed
      */
+    public function getConsume()
+    {
+        return $this->consume;
+    }
+
+    /**
+     * @param mixed $consume
+     * @return SharedProsperityRecommendConfigEntity
+     */
+    public function setConsume($consume): SharedProsperityRecommendConfigEntity
+    {
+        $this->consume = $consume;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
     public function getCreateTime()
     {
         return $this->createTime;