待完善

app/common/dao/shared/SharedProsperityRewardRecordDao.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace app\common\dao\shared;
+
+use app\common\dao\BaseDao;
+use app\common\model\shared\SharedProsperityRewardRecord;
+use app\entity\data\shared\SharedProsperityRewardRecordEntity;
+
+class SharedProsperityRewardRecordDao extends BaseDao
+{
+
+    protected function getModel(): string
+    {
+        return SharedProsperityRewardRecord::class;
+    }
+
+    /**
+     * @param array $idList
+     * @return SharedProsperityRewardRecordEntity[]
+     */
+    public function getSharedProsperityRewardRecordEntityListByIdList(array $idList): array
+    {
+        $entityList = [];
+        try {
+            /** @var SharedProsperityRewardRecord $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('id', $idList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return SharedProsperityRewardRecordEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
+}

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

@@ -639,6 +639,31 @@ class StoreOrderDao extends BaseDao
     }
 
     /**
+     * @param array $orderSnList
+     * @return CommonEntity[]
+     */
+    public function getStoreOrderEntityListByOrderSnList(array $orderSnList): array
+    {
+        $entityList = [];
+        try {
+            /** @var StoreOrder $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('order_sn', $orderSnList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return StoreOrderEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
+
+    /**
      * @param array $groupOrderIdList
      * @return CommonEntity[]
      */

app/common/enum/CommonEnum.php

@@ -255,13 +255,25 @@ class CommonEnum
         // 共富区
         'SharedProsperity' => [
             'Self' => [
-                'YangLaoJin' => [ // 钱
-                    'Ratio' => ['code' => 0.7 * 0.1, 'name' => '将利润（PV）的70%中的10%，当做养老金分配给下单人']
+                'YangLaoJin' => [
+                    'Ratio' => ['code' => 0.05, 'name' => '将订单消费金额的5%，当做养老金分配给下单人']
+                ],
+                'Pv' => [
+                    'Ratio' => ['code' => 1, 'name' => '将利润的100%，作为PV值分配给下单人']
+                ],
+                'ConsumerStocks' => [
+                    'Ratio' => ['code' => 0.5, 'name' => '在共富区消费者获得购买商品赠送商品额50%的消费股']
+                ],
+                'WithdrawalLimit' => [
+                    'Ratio' => ['code' => 5, 'name' => '消费配额1:5提现（需要提现的会员，需有提现配额才能提现，例：消费1000，配5000的提现额度）']
                 ]
             ],
             'Spread' => [
                 'YangLaoJin' => [
-                    'Ratio' => ['code' => 0.7 * 0.05, 'name' => '将利润（PV）的70%中的5%，当做养老金分配给推荐人']
+                    'Ratio' => ['code' => 0.03, 'name' => '将订单消费金额的3%，当做养老金分配给推荐人']
+                ],
+                'ConsumerStocks' => [
+                    'Ratio' => ['code' => 0.5, 'name' => '在共富区推广者获得购买商品赠送商品额50%的消费股']
                 ]
             ]
         ]

app/common/enum/shared/SharedProsperityRewardRecordEnum.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace app\common\enum\shared;
+
+use app\common\enum\CommonEnum;
+
+class SharedProsperityRewardRecordEnum extends CommonEnum
+{
+    // 明细类型  commission佣金
+    const TYPE = [
+        'CONSUMER_STOCKS' => ['code' => 1001, 'name' => '共富体系消费股'],
+        'WITHDRAWAL_LIMIT' => ['code' => 1002, 'name' => '共富体系提现额度'],
+        'PV' => ['code' => 1003, 'name' => '共富体系PV值'],
+    ];
+
+    // 状态
+    const STATUS = [
+        'PENDING' => ['code' => 0, 'name' => '待确定'],
+        'VALID' => ['code' => 1, 'name' => '有效'],
+        'INVALID' => ['code' => -1, 'name' => '无效'],
+    ];
+
+    // 类型商店
+    const TYPE_SHOP = parent::ORDER_TYPE;
+}

app/common/enum/user/UserBillEnum.php

@@ -14,7 +14,8 @@ class UserBillEnum extends CommonEnum
 
     // 明细种类
     const CATEGORY = [
-        'NowMoney' => ['code' => 'now_money', 'name' => 'now_money']
+        'NowMoney' => ['code' => 'now_money', 'name' => 'now_money'],
+        'OfflineRechargeMoney' => ['code' => 'offline_recharge_money', 'name' => 'offline_recharge_money'],
     ];
 
     // 明细类型  commission佣金

app/common/model/shared/SharedProsperityRewardRecord.php

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

app/common/repositories/shared/SharedProsperityRewardRecordRepository.php

@@ -0,0 +1,266 @@
+<?php
+
+namespace app\common\repositories\shared;
+
+use app\common\dao\shared\SharedProsperityRewardRecordDao;
+use app\common\enum\shared\SharedProsperityRewardRecordEnum;
+use app\common\repositories\BaseRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
+use app\entity\data\shared\SharedProsperityRewardRecordEntity;
+use app\entity\data\shared\SharedProsperityUserEntity;
+use think\db\exception\DbException;
+use think\exception\ValidateException;
+
+class SharedProsperityRewardRecordRepository extends BaseRepository
+{
+
+    protected $dao;
+
+    /**
+     * SharedProsperityRewardRecordRepository constructor.
+     * @param SharedProsperityRewardRecordDao $dao
+     */
+    public function __construct(SharedProsperityRewardRecordDao $dao)
+    {
+        $this->dao = $dao;
+    }
+
+    /**
+     * @param int $id
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function getSharedProsperityRewardRecordEntityById(int $id): SharedProsperityRewardRecordEntity
+    {
+        $entityList = $this->getSharedProsperityRewardRecordEntityListByIdList([$id]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof SharedProsperityRewardRecordEntity) {
+            return $entity;
+        } else {
+            /** @var SharedProsperityRewardRecordEntity */
+            return SharedProsperityRewardRecordEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $idList
+     * @return SharedProsperityRewardRecordEntity[]
+     */
+    public function getSharedProsperityRewardRecordEntityListByIdList(array $idList): array
+    {
+        return $this->dao->getSharedProsperityRewardRecordEntityListByIdList($idList);
+    }
+
+    public function create($data)
+    {
+        return $this->dao->create($data);
+    }
+
+    /**
+     * @param SharedProsperityRewardRecordEntity $sharedProsperityRewardRecordEntity
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function createByEntity(SharedProsperityRewardRecordEntity $sharedProsperityRewardRecordEntity): SharedProsperityRewardRecordEntity
+    {
+        $result = $this->create($sharedProsperityRewardRecordEntity->toUnderlineArray())->toArray();
+        /** @var SharedProsperityRewardRecordEntity $entity */
+        $entity = SharedProsperityRewardRecordEntity::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 SharedProsperityRewardRecordEntity $sharedProsperityRewardRecordEntity
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function updateByEntity(SharedProsperityRewardRecordEntity $sharedProsperityRewardRecordEntity): SharedProsperityRewardRecordEntity
+    {
+        if (empty($sharedProsperityRewardRecordEntity->getId())) {
+            return SharedProsperityRewardRecordEntity::newInstance();
+        }
+        $result = $this->update($sharedProsperityRewardRecordEntity->getId(), $sharedProsperityRewardRecordEntity->toUnderlineArray());
+        if ($result > 0) {
+            return $this->getSharedProsperityRewardRecordEntityById($sharedProsperityRewardRecordEntity->getId());
+        }
+        return SharedProsperityRewardRecordEntity::newInstance();
+    }
+
+    /**
+     * 添加 共富体系奖励记录
+     * @param int $uid
+     * @param int $type
+     * @param float $number
+     * @param int $typeShop
+     * @param string $orderSn
+     * @param string $remark
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function addSharedProsperityRewardRecord(int $uid, int $type, float $number, int $typeShop = 0, string $orderSn = '', string $remark = ''): SharedProsperityRewardRecordEntity
+    {
+        if ($typeShop == SharedProsperityRewardRecordEnum::TYPE_SHOP['Platform']['code']) {
+            /** @var StoreOrderRepository $storeOrderRepository */
+            $storeOrderRepository = app()->make(StoreOrderRepository::class);
+            $storeOrderEntity = $storeOrderRepository->getStoreOrderEntityByOrderSn($orderSn);
+            if (empty($storeOrderEntity->getOrderId())) {
+                throw new ValidateException('未查询到订单信息');
+            }
+        }
+
+        /** @var SharedProsperityRewardRecordEntity $sharedProsperityRewardRecordEntity */
+        $sharedProsperityRewardRecordEntity = SharedProsperityRewardRecordEntity::newInstance();
+        $sharedProsperityRewardRecordEntity->setUserId($uid)
+            //UserBillEnum::PM['INCOME']['code']
+            ->setType($type)
+            ->setNumber($number)
+            ->setStatus(SharedProsperityRewardRecordEnum::STATUS['PENDING']['code'])
+            ->setTypeShop($typeShop)
+            ->setOrderSn($orderSn)
+            ->setRemark($remark);
+
+        return $this->createByEntity($sharedProsperityRewardRecordEntity);
+    }
+
+    /**
+     * 结算 共富体系奖励记录
+     * @param array $idList
+     * @return array
+     */
+    public function executeByIdList(array $idList): array
+    {
+        $sharedProsperityRewardRecordEntityList = $this->getSharedProsperityRewardRecordEntityListByIdList($idList);
+        // 忽略 已经生效的 记录
+        $sharedProsperityRewardRecordEntityList = array_filter($sharedProsperityRewardRecordEntityList, function($entity) {
+            return $entity->getStatus() != SharedProsperityRewardRecordEnum::STATUS['VALID']['code'];
+        });
+
+        if (!empty($sharedProsperityRewardRecordEntityList)) {
+            // 获取所有记录的 归属人
+            $userIdList = array_map(function ($sharedProsperityRewardRecordEntity) {
+                return $sharedProsperityRewardRecordEntity->getUserId();
+            }, $sharedProsperityRewardRecordEntityList);
+
+            // 获取用户 映射信息
+            /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+            $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+            /** @var SharedProsperityUserEntity[] $sharedProsperityUserEntityMapByUserId */
+            $sharedProsperityUserEntityMapByUserId = [];
+            if (!empty($userIdList)) {
+                $sharedProsperityUserEntityMapByUserId = $sharedProsperityUserRepository->getSharedProsperityUserEntityMapByUserIdList($userIdList);
+            }
+
+            $updateSharedProsperityUserEntityList = [];
+            $updateSharedProsperityRewardRecordEntityList = [];
+            foreach ($sharedProsperityRewardRecordEntityList as $sharedProsperityRewardRecordEntity) {
+                if (empty($sharedProsperityRewardRecordEntity->getId()) || empty($sharedProsperityRewardRecordEntity->getUserId())) {
+                    // throw new ValidateException('无效的账单记录');
+                    continue;
+                }
+                if (!empty($sharedProsperityRewardRecordEntity->getTakeTime())) {
+                    throw new ValidateException("该奖励记录已更新，请勿重复操作({$sharedProsperityRewardRecordEntity->getId()})");
+                }
+
+                $sharedProsperityUserEntity = $sharedProsperityUserEntityMapByUserId[$sharedProsperityRewardRecordEntity->getUserId()];
+                if (empty($sharedProsperityUserEntity) || empty($sharedProsperityUserEntity->getUserId())) {
+                    throw new ValidateException("未查询到用户信息({$sharedProsperityRewardRecordEntity->getId()})");
+                }
+
+                // 更新 用户信息
+                /** @var SharedProsperityUserEntity $updateSharedProsperityUserEntity */
+                $updateSharedProsperityUserEntity = $updateSharedProsperityUserEntityList[$sharedProsperityUserEntity->getUserId()] ?? SharedProsperityUserEntity::newInstance();
+                $updateSharedProsperityUserEntity->setId();
+
+                // 更新 账单 记录
+                /** @var SharedProsperityRewardRecordEntity $updateSharedProsperityRewardRecord */
+                $updateSharedProsperityRewardRecord = $updateSharedProsperityRewardRecordEntityList[$sharedProsperityRewardRecordEntity->getId()] ?? SharedProsperityRewardRecordEntity::newInstance();
+                // 更新 账单记录 状态
+                $updateSharedProsperityRewardRecord
+                    ->setId($sharedProsperityRewardRecordEntity->getBillId())
+                    ->setStatus(UserBillEnum::STATUS['VALID']['code'])
+                    ->setTakeTime(time());
+
+                if ($sharedProsperityRewardRecordEntity->getCommissionType() == UserBillEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code']) {
+                    // 直推奖
+                    if (is_null($updateSharedProsperityUserEntity->getBrokeragePrice())) {
+                        $updateSharedProsperityUserEntity->setBrokeragePrice($sharedProsperityUserEntity->getBrokeragePrice());
+                    }
+                    // 更新用户 佣金 信息
+                    if ($sharedProsperityRewardRecordEntity->getPm() == UserBillEnum::PM['EXPEND']['code']) {
+                        if ($updateSharedProsperityUserEntity->getBrokeragePrice() < $sharedProsperityRewardRecordEntity->getNumber()) {
+                            throw new ValidateException('用户佣金不足');
+                        }
+                        $updateSharedProsperityUserEntity->setBrokeragePrice(bcsub($updateSharedProsperityUserEntity->getBrokeragePrice(), $sharedProsperityRewardRecordEntity->getNumber(), 2));
+                    } else {
+                        $updateSharedProsperityUserEntity->setBrokeragePrice(bcadd($updateSharedProsperityUserEntity->getBrokeragePrice(), $sharedProsperityRewardRecordEntity->getNumber(), 2));
+                    }
+
+                } else if ($sharedProsperityRewardRecordEntity->getCommissionType() == UserBillEnum::COMMISSION_TYPE['PENSION']['code']) {
+
+                    if ($sharedProsperityRewardRecordEntity->getGzc() == UserBillEnum::GZC_STATUS['NOT_ENTERED']['code']) {
+                        if (!empty($userCertificationEntityMapByUid[$sharedProsperityRewardRecordEntity->getUid()])) {
+                            $userCertificationEntity = $userCertificationEntityMapByUid[$sharedProsperityRewardRecordEntity->getUid()];
+                            // 创建公证处记录
+                            $gzcLogRepository->addGzcLog(
+                                $userCertificationEntity->getUid(),
+                                $userCertificationEntity->getUserName(),
+                                $userCertificationEntity->getMobile(),
+                                $userCertificationEntity->getUserCard(),
+                                $sharedProsperityRewardRecordEntity->getTypeShop(),
+                                $sharedProsperityRewardRecordEntity->getLinkId(),
+                                $sharedProsperityRewardRecordEntity->getNumber()
+                            );
+
+                            // 养老金
+                            if (is_null($updateSharedProsperityUserEntity->getAnnuity())) {
+                                $updateSharedProsperityUserEntity->setAnnuity($sharedProsperityUserEntity->getAnnuity());
+                            }
+                            $updateSharedProsperityUserEntity->setAnnuity(bcadd($updateSharedProsperityUserEntity->getAnnuity(), $sharedProsperityRewardRecordEntity->getNumber(), 2));
+
+                            // 几笔养老金
+                            if (is_null($updateSharedProsperityUserEntity->getAnnuityNum())) {
+                                $updateSharedProsperityUserEntity->setAnnuityNum($sharedProsperityUserEntity->getAnnuityNum());
+                            }
+                            $updateSharedProsperityUserEntity->setAnnuityNum(bcadd($updateSharedProsperityUserEntity->getAnnuityNum(), 1));
+
+                            // 更新佣金记录
+                            $updateSharedProsperityRewardRecord
+                                ->setGzc(UserBillEnum::GZC_STATUS['ENTERED']['code'])
+                                ->setIsGzc(UserBillEnum::IS_GZC['NOT_STARTED']['code']);
+                        }
+                    }
+                }
+
+                $updateSharedProsperityUserEntityList[$sharedProsperityUserEntity->getUid()] = $updateSharedProsperityUserEntity;
+                $updateSharedProsperityRewardRecordEntityList[$sharedProsperityRewardRecordEntity->getBillId()] = $updateSharedProsperityRewardRecord;
+            }
+            if (!empty($updateSharedProsperityUserEntityList)) {
+                $sharedProsperityUserRepository->batchUpdateUserDataByDataList(
+                    array_map(function (UserEntity $updateUserEntity) {
+                        return $updateUserEntity->toUnderlineArray();
+                    }, $updateSharedProsperityUserEntityList)
+                );
+            }
+
+            if (!empty($updateSharedProsperityRewardRecordEntityList)) {
+                $this->batchUpdateUserBillDataByDataList(
+                    array_map(function (UserBillEntity $updateUserBillEntity) {
+                        return $updateUserBillEntity->toUnderlineArray();
+                    }, $updateSharedProsperityRewardRecordEntityList)
+                );
+            }
+        }
+
+        return $idList;
+    }
+}

app/common/repositories/shared/SharedProsperityUserRepository.php

@@ -46,6 +46,18 @@ class SharedProsperityUserRepository extends BaseRepository
         return $this->dao->getSharedProsperityUserEntityListByUserIdList($userIdList);
     }
 
+    /**
+     * @param array $userIdList
+     * @return SharedProsperityUserEntity[]
+     */
+    public function getSharedProsperityUserEntityMapByUserIdList(array $userIdList): array
+    {
+        $sharedProsperityUserEntityList = $this->dao->getSharedProsperityUserEntityListByUserIdList($userIdList);
+        /** @var SharedProsperityUserEntity[] $sharedProsperityUserEntityMapByUserId */
+        $sharedProsperityUserEntityMapByUserId = array_column($sharedProsperityUserEntityList, null, 'userId');
+        return $sharedProsperityUserEntityMapByUserId;
+    }
+
     public function create($data)
     {
         return $this->dao->create($data);

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

@@ -10775,6 +10775,31 @@ class StoreOrderRepository extends BaseRepository
         return $this->dao->getStoreOrderEntityListByOrderIdList($orderIdList);
     }
 
+    /**
+     * @param string $orderSn
+     * @return StoreOrderEntity
+     */
+    public function getStoreOrderEntityByOrderSn(string $orderSn): StoreOrderEntity
+    {
+        $entityList = $this->getStoreOrderEntityListByOrderSnList([$orderSn]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof StoreOrderEntity) {
+            return $entity;
+        } else {
+            /** @var StoreOrderEntity */
+            return StoreOrderEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $orderSnList
+     * @return StoreOrderEntity[]
+     */
+    public function getStoreOrderEntityListByOrderSnList(array $orderSnList): array
+    {
+        return $this->dao->getStoreOrderEntityListByOrderSnList($orderSnList);
+    }
+
 
     /**
      * @param int $groupOrderId
@@ -11471,51 +11496,52 @@ class StoreOrderRepository extends BaseRepository
                 '购买复购区获得养老金'
             );
 
-            // 给推荐人的奖励
-            if (!empty($userEntity->getSpreadUid())) {
-                $userEntityBySpreadUid = $userRepository->getUserEntityByUid($userEntity->getSpreadUid());
-                if (!empty($userEntityBySpreadUid->getUid()) && $userEntityBySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
-                    $yanglaojinBySpreadDirectly = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['Repurchase']['SpreadDirectly']['YangLaoJin']['Ratio']['code'],CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
-                    /** @var UserBillRepository $userBillRepository */
-                    $userBillRepository = app()->make(UserBillRepository::class);
-                    $userBillRepository->addUserBill(
-                        $userEntityBySpreadUid->getUid(),
-                        UserBillEnum::COMMISSION_TYPE['PENSION']['code'],
-                        UserBillEnum::PM['INCOME']['code'],
-                        $yanglaojinBySpreadDirectly,
-                        UserBillEnum::CATEGORY['NowMoney']['code'],
-                        UserBillEnum::TYPE['Commission']['code'],
-                        UserBillEnum::SOURCE['ONLINE']['code'],
-                        UserBillEnum::ORDER_TYPE['SELF_OPERATED']['code'],
-                        UserBillEnum::TYPE_SHOP['Platform']['code'],
-                        $storeOrderEntity->getOrderId(),
-                        '推荐复购区商品获得养老金'
-                    );
-
-                    // 给间接推荐人的奖励
-                    if (!empty($userEntityBySpreadUid->getSpreadUid())) {
-                        $userEntityByIndirectlySpreadUid = $userRepository->getUserEntityByUid($userEntityBySpreadUid->getSpreadUid());
-                        if (!empty($userEntityByIndirectlySpreadUid->getUid()) && $userEntityByIndirectlySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
-                            $yanglaojinBySpreadIndirectly = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['Repurchase']['SpreadIndirectly']['YangLaoJin']['Ratio']['code'],CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
-                            /** @var UserBillRepository $userBillRepository */
-                            $userBillRepository = app()->make(UserBillRepository::class);
-                            $userBillRepository->addUserBill(
-                                $userEntityByIndirectlySpreadUid->getUid(),
-                                UserBillEnum::COMMISSION_TYPE['PENSION']['code'],
-                                UserBillEnum::PM['INCOME']['code'],
-                                $yanglaojinBySpreadIndirectly,
-                                UserBillEnum::CATEGORY['NowMoney']['code'],
-                                UserBillEnum::TYPE['Commission']['code'],
-                                UserBillEnum::SOURCE['ONLINE']['code'],
-                                UserBillEnum::ORDER_TYPE['SELF_OPERATED']['code'],
-                                UserBillEnum::TYPE_SHOP['Platform']['code'],
-                                $storeOrderEntity->getOrderId(),
-                                '间推复购区商品获得养老金'
-                            );
-                        }
-                    }
-                }
-            }
+            // 复购区不再向推荐人发放养老金
+            // // 给推荐人的奖励
+            // if (!empty($userEntity->getSpreadUid())) {
+            //     $userEntityBySpreadUid = $userRepository->getUserEntityByUid($userEntity->getSpreadUid());
+            //     if (!empty($userEntityBySpreadUid->getUid()) && $userEntityBySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
+            //         $yanglaojinBySpreadDirectly = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['Repurchase']['SpreadDirectly']['YangLaoJin']['Ratio']['code'],CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+            //         /** @var UserBillRepository $userBillRepository */
+            //         $userBillRepository = app()->make(UserBillRepository::class);
+            //         $userBillRepository->addUserBill(
+            //             $userEntityBySpreadUid->getUid(),
+            //             UserBillEnum::COMMISSION_TYPE['PENSION']['code'],
+            //             UserBillEnum::PM['INCOME']['code'],
+            //             $yanglaojinBySpreadDirectly,
+            //             UserBillEnum::CATEGORY['NowMoney']['code'],
+            //             UserBillEnum::TYPE['Commission']['code'],
+            //             UserBillEnum::SOURCE['ONLINE']['code'],
+            //             UserBillEnum::ORDER_TYPE['SELF_OPERATED']['code'],
+            //             UserBillEnum::TYPE_SHOP['Platform']['code'],
+            //             $storeOrderEntity->getOrderId(),
+            //             '推荐复购区商品获得养老金'
+            //         );
+            //
+            //         // 给间接推荐人的奖励
+            //         if (!empty($userEntityBySpreadUid->getSpreadUid())) {
+            //             $userEntityByIndirectlySpreadUid = $userRepository->getUserEntityByUid($userEntityBySpreadUid->getSpreadUid());
+            //             if (!empty($userEntityByIndirectlySpreadUid->getUid()) && $userEntityByIndirectlySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
+            //                 $yanglaojinBySpreadIndirectly = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['Repurchase']['SpreadIndirectly']['YangLaoJin']['Ratio']['code'],CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+            //                 /** @var UserBillRepository $userBillRepository */
+            //                 $userBillRepository = app()->make(UserBillRepository::class);
+            //                 $userBillRepository->addUserBill(
+            //                     $userEntityByIndirectlySpreadUid->getUid(),
+            //                     UserBillEnum::COMMISSION_TYPE['PENSION']['code'],
+            //                     UserBillEnum::PM['INCOME']['code'],
+            //                     $yanglaojinBySpreadIndirectly,
+            //                     UserBillEnum::CATEGORY['NowMoney']['code'],
+            //                     UserBillEnum::TYPE['Commission']['code'],
+            //                     UserBillEnum::SOURCE['ONLINE']['code'],
+            //                     UserBillEnum::ORDER_TYPE['SELF_OPERATED']['code'],
+            //                     UserBillEnum::TYPE_SHOP['Platform']['code'],
+            //                     $storeOrderEntity->getOrderId(),
+            //                     '间推复购区商品获得养老金'
+            //                 );
+            //             }
+            //         }
+            //     }
+            // }
         } else if ($storeOrderEntity->getMerId() == CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code']) {
             /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
             $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
@@ -11541,7 +11567,7 @@ class StoreOrderRepository extends BaseRepository
             }
 
             // 为消费者 初始化 添加养老金记录
-            $yanglaojin = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Self']['YangLaoJin']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+            $yanglaojin = bcmul($storeOrderEntity->getTotalPrice(), CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Self']['YangLaoJin']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
             /** @var UserBillRepository $userBillRepository */
             $userBillRepository = app()->make(UserBillRepository::class);
             $userBillRepository->addUserBill(
@@ -11558,7 +11584,23 @@ class StoreOrderRepository extends BaseRepository
                 '购买共富区商品获得养老金'
             );
 
-            // 消费股 TODO 该做这里了
+            // 发放消费股
+            $userBillRepository->addUserBill(
+                $sharedProsperityUserEntity->getUserId(),
+                UserBillEnum::COMMISSION_TYPE['PENSION']['code'],
+                UserBillEnum::PM['INCOME']['code'],
+                $yanglaojin,
+                UserBillEnum::CATEGORY['NowMoney']['code'],
+                UserBillEnum::TYPE['Commission']['code'],
+                UserBillEnum::SOURCE['ONLINE']['code'],
+                UserBillEnum::ORDER_TYPE['SELF_OPERATED']['code'],
+                UserBillEnum::TYPE_SHOP['Platform']['code'],
+                $storeOrderEntity->getOrderId(),
+                '购买共富区商品获得养老金'
+            );
+
+
+            // 发放提现额度
 
             if (!empty($sharedProsperityUserEntity->getParentId())) {
                 // 如果 共富区推荐人 不是平台，则为 推荐人发放 推荐奖励

app/entity/data/shared/SharedProsperityRewardRecordEntity.php

@@ -0,0 +1,237 @@
+<?php
+
+namespace app\entity\data\shared;
+
+use app\entity\data\DataEntity;
+
+class SharedProsperityRewardRecordEntity extends DataEntity
+{
+    public $id = null;  // ID
+    public $userId = null;  // 用户ID
+    public $type = null;  // 奖励类型
+    public $number = null;  // 明细数字
+    public $balance = null;  // 剩余
+    public $status = null;  // 状态
+    public $typeShop = null;  // 类型商店
+    public $orderSn = null;  // 订单号
+    public $takeTime = null;  // 结算时间
+    public $remark = null;
+    public $createTime = null;  // 添加时间
+    public $updateTime = null;  // 更新时间
+
+    /**
+     * @return mixed
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * @param mixed $id
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setId($id): SharedProsperityRewardRecordEntity
+    {
+        $this->id = $id;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUserId()
+    {
+        return $this->userId;
+    }
+
+    /**
+     * @param mixed $userId
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setUserId($userId): SharedProsperityRewardRecordEntity
+    {
+        $this->userId = $userId;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getType()
+    {
+        return $this->type;
+    }
+
+    /**
+     * @param mixed $type
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setType($type): SharedProsperityRewardRecordEntity
+    {
+        $this->type = $type;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getNumber()
+    {
+        return $this->number;
+    }
+
+    /**
+     * @param mixed $number
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setNumber($number): SharedProsperityRewardRecordEntity
+    {
+        $this->number = $number;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getBalance()
+    {
+        return $this->balance;
+    }
+
+    /**
+     * @param mixed $balance
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setBalance($balance): SharedProsperityRewardRecordEntity
+    {
+        $this->balance = $balance;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getStatus()
+    {
+        return $this->status;
+    }
+
+    /**
+     * @param mixed $status
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setStatus($status): SharedProsperityRewardRecordEntity
+    {
+        $this->status = $status;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getTypeShop()
+    {
+        return $this->typeShop;
+    }
+
+    /**
+     * @param mixed $typeShop
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setTypeShop($typeShop): SharedProsperityRewardRecordEntity
+    {
+        $this->typeShop = $typeShop;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getOrderSn()
+    {
+        return $this->orderSn;
+    }
+
+    /**
+     * @param mixed $orderSn
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setOrderSn($orderSn): SharedProsperityRewardRecordEntity
+    {
+        $this->orderSn = $orderSn;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getTakeTime()
+    {
+        return $this->takeTime;
+    }
+
+    /**
+     * @param mixed $takeTime
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setTakeTime($takeTime): SharedProsperityRewardRecordEntity
+    {
+        $this->takeTime = $takeTime;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getRemark()
+    {
+        return $this->remark;
+    }
+
+    /**
+     * @param mixed $remark
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setRemark($remark): SharedProsperityRewardRecordEntity
+    {
+        $this->remark = $remark;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getCreateTime()
+    {
+        return $this->createTime;
+    }
+
+    /**
+     * @param mixed $createTime
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setCreateTime($createTime): SharedProsperityRewardRecordEntity
+    {
+        $this->createTime = $createTime;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUpdateTime()
+    {
+        return $this->updateTime;
+    }
+
+    /**
+     * @param mixed $updateTime
+     * @return SharedProsperityRewardRecordEntity
+     */
+    public function setUpdateTime($updateTime): SharedProsperityRewardRecordEntity
+    {
+        $this->updateTime = $updateTime;
+        return $this;
+    }
+}

app/entity/data/shared/SharedProsperityUserEntity.php

@@ -10,7 +10,7 @@ class SharedProsperityUserEntity extends DataEntity
     public $userId = null;  // 用户id
     public $parentId = null;  // 推荐人用户id
     public $pv = null;  // pv
-    public $teamPv = null;  // 团队pv
+    public $consumerStocks = null; // 消费股
     public $withdrawalLimit = null;  // 提现额度
     public $partnerLevel = null;  // 合伙人等级
     public $createTime = null;  // 创建时间
@@ -91,18 +91,18 @@ class SharedProsperityUserEntity extends DataEntity
     /**
      * @return mixed
      */
-    public function getTeamPv()
+    public function getConsumerStocks()
     {
-        return $this->teamPv;
+        return $this->consumerStocks;
     }
 
     /**
-     * @param mixed $teamPv
+     * @param mixed $consumerStocks
      * @return SharedProsperityUserEntity
      */
-    public function setTeamPv($teamPv): SharedProsperityUserEntity
+    public function setConsumerStocks($consumerStocks): SharedProsperityUserEntity
     {
-        $this->teamPv = $teamPv;
+        $this->consumerStocks = $consumerStocks;
         return $this;
     }