feat(api): 添加共富感恩奖功能

- 新增共富感恩奖API路由接口
- 在CommonEnum中添加感恩奖分配比例配置
- 创建SharedProsperityPointEntity实体类用于积分数据管理
- 新增SharedProsperityPointLog模型和数据访问层
- 实现感恩奖计算和发放逻辑，按10%比例向上级用户发放积分
- 添加通过用户ID更新数据的方法
- 完善事务处理确保数据一致性

app/common/dao/shared/SharedProsperityPointLogDao.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\dao\shared;
+
+use app\common\dao\BaseDao;
+use app\common\model\BaseModel;
+use app\common\model\shared\SharedProsperityPointLog;
+
+class SharedProsperityPointLogDao extends BaseDao
+{
+    /**
+     * @return BaseModel
+     */
+    protected function getModel(): string
+    {
+        return SharedProsperityPointLog::class;
+    }
+}

app/common/enum/CommonEnum.php

@@ -279,7 +279,8 @@ class CommonEnum
                 'ConsumerStocks' => [
                     'Ratio' => ['code' => 0.5, 'name' => '在共富区推广者获得购买商品赠送商品额50%的消费股']
                 ]
-            ]
+            ],
+            'Thank' => ['code' => 0.1, 'name' => '感恩奖分配比例，10%']
         ]
     ];
 

app/common/model/shared/SharedProsperityPointLog.php

@@ -0,0 +1,17 @@
+<?php
+namespace app\common\model\shared;
+
+use app\common\model\BaseModel;
+
+class SharedProsperityPointLog extends BaseModel
+{
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'shared_prosperity_point_log';
+    }
+}

app/common/repositories/shared/SharedProsperityTaskRepository.php

@@ -3,12 +3,14 @@
 namespace app\common\repositories\shared;
 
 use app\common\dao\shared\SharedProsperityBalanceLogDao;
+use app\common\dao\shared\SharedProsperityPointLogDao;
 use app\common\dao\shared\SharedProsperityRecommendConfigDao;
 use app\common\dao\shared\SharedProsperityUserDao;
-use app\common\dao\store\order\StoreOrderDao;
 use app\common\enum\CommonEnum;
 use app\common\repositories\BaseRepository;
+use think\Collection;
 use think\facade\Db;
+use think\facade\Log;
 
 class SharedProsperityTaskRepository extends BaseRepository
 {
@@ -123,4 +125,91 @@ class SharedProsperityTaskRepository extends BaseRepository
             throw new \Exception($e->getMessage());
         }
     }
+
+    /**
+     * @param $data
+     * @return true
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author 史晨
+     * @date 2026/2/10 15:22
+     * 感恩奖
+     */
+    public function thank($data)
+    {
+        // 获取时间范围内订单
+        $start = $data['startTime'];
+        $end = $data['endTime'];
+
+        // 获取pv
+        /** @var SharedProsperityRewardRecordRepository $rewardRecordRepository */
+        $rewardRecordRepository = app()->make(SharedProsperityRewardRecordRepository::class);
+        $rewardList = $rewardRecordRepository->getListByTime($start, $end);
+        if (empty($rewardList)) {
+            throw new \Exception('没有订单');
+        }
+
+        // user_id分区求和 [id]=>[number]
+        $groupedResult = array_reduce($rewardList, function ($carry, $item) {
+            $userId = $item['user_id'];
+            $number = floatval($item['number']);
+
+            if (!isset($carry[$userId])) {
+                $carry[$userId] = 0;
+            }
+
+            $carry[$userId] += $number;
+
+            return $carry;
+        }, []);
+
+        if (empty($groupedResult)) {
+            throw new \Exception('分组求和错误');
+        }
+
+        /** @var SharedProsperityUserRepository $userRepository */
+        $userRepository = app()->make(SharedProsperityUserRepository::class);
+
+        /** @var SharedProsperityPointLogDao $balanceDao */
+        $logDao = app()->make(SharedProsperityPointLogDao::class);
+
+        DB::startTrans();
+        try {
+            foreach ($groupedResult as $key => $value) {
+                // 获取感恩奖比例
+                $radio = CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Thank']['code'];
+                // 计算积分
+                $points = floor($value * $radio * 100) / 100;
+                // 获取上级
+                $userData = $userRepository->getSharedProsperityUserEntityByUserId($key);
+                $parentId = $userData->getParentId();
+                if ($parentId == 0) {
+                    Log::info('共富感恩奖发放：' . $key . '的上级是0，不发放感恩奖');
+                }
+                // 给上级发积分，记录日志
+                if ($parentId > 0) {
+                    $parentData = $userRepository->getSharedProsperityUserEntityByUserId($parentId);
+                    // 记录日志
+                    $logDao->create([
+                        'user_id' => $parentId,
+                        'total' => $value,
+                        'radio' => $radio,
+                        'old' => $parentData->getPoints(),
+                        'number' => $points,
+                        'after' => $parentData->getPoints() + $points
+                    ]);
+
+                    // 发放积分
+                    $userRepository->updateByUserId($parentId, ['points' => ['inc', $points]]);
+                }
+            }
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            DB::rollback();
+            throw new \Exception($e->getMessage());
+        }
+    }
 }

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -90,6 +90,15 @@ class SharedProsperityUserRepository extends BaseRepository
         }
     }
 
+    public function updateByUserId($userId,$data)
+    {
+        try {
+            return $this->dao->updateByUserId($userId, $data);
+        } catch (DbException $e) {
+            return 0;
+        }
+    }
+
     /**
      * @param SharedProsperityUserEntity $sharedProsperityUserEntity
      * @return SharedProsperityUserEntity

app/controller/api/shareProsperity/Task.php

@@ -14,4 +14,13 @@ class Task
         $repository->partner($get);
         return app('json')->success();
     }
+
+    public function thankProfits()
+    {
+        $get = app()->request->get();
+        /** @var SharedProsperityTaskRepository $repository */
+        $repository = app()->make(SharedProsperityTaskRepository::class);
+        $repository->thank($get);
+        return app('json')->success();
+    }
 }

app/entity/data/shared/SharedProsperityPointEntity.php

@@ -0,0 +1,118 @@
+<?php
+
+namespace app\entity\data\shared;
+
+use app\entity\data\DataEntity;
+
+class SharedProsperityPointEntity extends DataEntity
+{
+    public $id = null;  // 主键
+    public $userId = null;  // 用户id
+    public $total = null;  // 总计
+    public $radio = null;  // 比例
+    public $old = null;  // 变更前佣金
+    public $number = null;  // 操作佣金
+    public $after = null;  // 变更后佣金
+    public $pm = null;  // 类型 1增加
+    public $createTime = null;  // 创建时间
+
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    public function setId($id): SharedProsperityPointEntity
+    {
+        $this->id = $id;
+        return $this;
+    }
+
+    public function getUserId()
+    {
+        return $this->userId;
+    }
+
+    public function setUserId($userId): SharedProsperityPointEntity
+    {
+        $this->userId = $userId;
+        return $this;
+    }
+
+    public function getTotal()
+    {
+        return $this->total;
+    }
+
+    public function setTotal($total): SharedProsperityPointEntity
+    {
+        $this->total = $total;
+        return $this;
+    }
+
+    public function getRadio()
+    {
+        return $this->radio;
+    }
+
+    public function setRadio($radio): SharedProsperityPointEntity
+    {
+        $this->radio = $radio;
+        return $this;
+    }
+
+    public function getOld()
+    {
+        return $this->old;
+    }
+
+    public function setOld($old): SharedProsperityPointEntity
+    {
+        $this->old = $old;
+        return $this;
+    }
+
+    public function getNumber()
+    {
+        return $this->number;
+    }
+
+    public function setNumber($number): SharedProsperityPointEntity
+    {
+        $this->number = $number;
+        return $this;
+    }
+
+    public function getAfter()
+    {
+        return $this->after;
+    }
+
+    public function setAfter($after): SharedProsperityPointEntity
+    {
+        $this->after = $after;
+        return $this;
+    }
+
+    public function getPm()
+    {
+        return $this->pm;
+    }
+
+    public function setPm($pm): SharedProsperityPointEntity
+    {
+        $this->pm = $pm;
+        return $this;
+    }
+
+    public function getCreateTime()
+    {
+        return $this->createTime;
+    }
+
+    public function setCreateTime($createTime): SharedProsperityPointEntity
+    {
+        $this->createTime = $createTime;
+        return $this;
+    }
+
+}

route/api.php

@@ -1381,3 +1381,5 @@ Route::group('/pages', function () {
 
 // 共富分红
 Route::get('share_prosperity_partner', 'api.shareProsperity.Task/partnerProfits');
+// 共富感恩奖
+Route::get('share_prosperity_thank', 'api.shareProsperity.Task/thankProfits');