待完善

app/common/dao/shared/SharedProsperityRecommendConfigDao.php

@@ -26,7 +26,7 @@ class SharedProsperityRecommendConfigDao extends BaseDao
         try {
             /** @var SharedProsperityRecommendConfig $model */
             $model = $this->getModel();
-            $dataRes =  $model::getDB()
+            $dataRes = $model::getDB()
                 ->select()
                 ->toArray();
             if (!empty($dataRes)) {
@@ -51,7 +51,32 @@ class SharedProsperityRecommendConfigDao extends BaseDao
         /** @var SharedProsperityRecommendConfig $model */
         $model = $this->getModel();
         return $model::getDB()
-            ->where(['id'=>$id])
+            ->where(['id' => $id])
             ->find();
     }
+
+    /**
+     * @param array $levelList
+     * @return SharedProsperityRecommendConfigEntity[]
+     */
+    public function getSharedProsperityRecommendConfigEntityListByLevelList(array $levelList): array
+    {
+        $entityList = [];
+        try {
+            /** @var SharedProsperityRecommendConfig $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('level', $levelList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return SharedProsperityRecommendConfigEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
 }

app/common/enum/CommonEnum.php

@@ -10,6 +10,7 @@ class CommonEnum
         'MemberZone' => ['code' => 496, 'name' => '会员专区'],
         'WonderfulLiving' => ['code' => 439, 'name' => '精彩生活区'],
         'Repurchase' => ['code' => 491, 'name' => '复购区'],
+        'SharedProsperity' => ['code' => 3447, 'name' => '共富区']
     ];
 
 
@@ -113,7 +114,7 @@ class CommonEnum
                     'Ratio' => ['code' => 0.35, 'name' => '将商品利润中 用户身份对应分配比例 的推荐人可分配利润中 35%，当做积分值分配给推荐人']
                 ],
                 'YangLaoJin' => [
-                    'Ratio' => ['code' => 0.35 * 0.5, 'name' => '将利润的35%中的5%，当做养老金分配给推荐人']
+                    'Ratio' => ['code' => 0.35 * 0.05, 'name' => '将利润的35%中的5%，当做养老金分配给推荐人']
                 ]
             ],
             'Share' => [
@@ -239,7 +240,7 @@ class CommonEnum
                     'Ratio' => ['code' => 0.35, 'name' => '将商品利润中 用户身份对应分配比例 的推荐人可分配利润中 35%，当做积分值分配给推荐人']
                 ],
                 'YangLaoJin' => [
-                    'Ratio' => ['code' => 0.35 * 0.5, 'name' => '将利润的35%中的5%，当做养老金分配给推荐人']
+                    'Ratio' => ['code' => 0.35 * 0.05, 'name' => '将利润的35%中的5%，当做养老金分配给推荐人']
                 ]
             ],
             'Lock' => [
@@ -250,6 +251,19 @@ class CommonEnum
                     'Ratio' => ['code' => 0.35 * 0.05 * 0.1, 'name' => '将利润的 35% 中的 5% 中的 10%，做为锁客奖励的复购部分'],
                 ]
             ]
+        ],
+        // 共富区
+        'SharedProsperity' => [
+            'Self' => [
+                'YangLaoJin' => [ // 钱
+                    'Ratio' => ['code' => 0.7 * 0.1, 'name' => '将利润（PV）的70%中的10%，当做养老金分配给下单人']
+                ]
+            ],
+            'Spread' => [
+                'YangLaoJin' => [
+                    'Ratio' => ['code' => 0.7 * 0.05, 'name' => '将利润（PV）的70%中的5%，当做养老金分配给推荐人']
+                ]
+            ]
         ]
     ];
 

app/common/repositories/shared/SharedProsperityRecommendConfigRepository.php

@@ -68,9 +68,34 @@ class SharedProsperityRecommendConfigRepository extends BaseRepository
     {
         $id = $params['id'];
         unset($params['id']);
-        if (!$this->dao->update($id, $params)){
+        if (!$this->dao->update($id, $params)) {
             return false;
         }
         return true;
     }
+
+    /**
+     * @param int $level
+     * @return SharedProsperityRecommendConfigEntity
+     */
+    public function getSharedProsperityRecommendConfigEntityByLevel(int $level): SharedProsperityRecommendConfigEntity
+    {
+        $entityList = $this->getSharedProsperityRecommendConfigEntityListByLevelList([$level]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof SharedProsperityRecommendConfigEntity) {
+            return $entity;
+        } else {
+            /** @var SharedProsperityRecommendConfigEntity */
+            return SharedProsperityRecommendConfigEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $levelList
+     * @return SharedProsperityRecommendConfigEntity[]
+     */
+    public function getSharedProsperityRecommendConfigEntityListByLevelList(array $levelList): array
+    {
+        return $this->dao->getSharedProsperityRecommendConfigEntityListByLevelList($levelList);
+    }
 }

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

@@ -52,6 +52,8 @@ use app\common\repositories\merchant\order\OrderMerchantRepository;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\product\ProductSeckillRepository;
 use app\common\repositories\product\ShareRepository;
+use app\common\repositories\shared\SharedProsperityRecommendConfigRepository;
+use app\common\repositories\shared\SharedProsperityUserRepository;
 use app\common\repositories\store\coupon\StoreCouponProductRepository;
 use app\common\repositories\store\coupon\StoreCouponRepository;
 use app\common\repositories\store\coupon\StoreCouponUserRepository;
@@ -88,6 +90,7 @@ use app\controller\api\user\Volunteer;
 use app\entity\data\merchant\MerchantEntity;
 use app\entity\data\product\ProductSeckillEntity;
 use app\entity\data\product\ShareEntity;
+use app\entity\data\shared\SharedProsperityUserEntity;
 use app\entity\data\store\CartEntity;
 use app\entity\data\store\StoreProductAttrValueEntity;
 use app\entity\data\store\StoreProductEntity;
@@ -11513,6 +11516,98 @@ class StoreOrderRepository extends BaseRepository
                     }
                 }
             }
+        } else if ($storeOrderEntity->getMerId() == CommonEnum::DESIGN_MERCHANT_ID['SharedProsperity']['code']) {
+            /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+            $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+            $sharedProsperityUserEntity = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($userEntity->getUid());
+            // 如果当前 共富体系内 没有该用户信息，则需要为其创建 共富体系用户数据
+            if (empty($sharedProsperityUserEntity->getId())) {
+                // 生成 共富体系用户实体
+                $sharedProsperityUserEntityByNewCreate = SharedProsperityUserEntity::newInstance()
+                    ->setUserId($userEntity->getUid());
+                // 查看分享人是否为 共富体系会员 如果是，则绑定共富体系的推荐关系，如果没有，则当前消费者则为 共富体系内的自然消费者，上级绑定为平台（因为文档内说明了，推荐人只能是共富会员）
+                if (!empty($storeOrderEntity->getShareUid())) {
+                    $sharedProsperityUserEntityByShareUid = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($storeOrderEntity->getShareUid());
+                    if (!empty($sharedProsperityUserEntityByShareUid->getId())) {
+                        $sharedProsperityUserEntityByNewCreate->setParentId($sharedProsperityUserEntityByShareUid->getUserId());
+                    }
+                }
+                $sharedProsperityUserEntity = $sharedProsperityUserRepository->createByEntity($sharedProsperityUserEntityByNewCreate);
+            }
+
+            if (empty($sharedProsperityUserEntity->getId())) {
+                Db::name('log')->insert(['data' => '共富区奖励发放，用户创建失败，订单ID：' . $storeOrderEntity->getOrderId()]);
+                return;
+            }
+
+            // 为消费者 初始化 添加养老金记录
+            $yanglaojin = bcmul($storeOrderEntity->getConPri(), 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(
+                $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(),
+                '购买共富区商品获得养老金'
+            );
+
+            // 消费股 TODO 该做这里了
+
+            if (!empty($sharedProsperityUserEntity->getParentId())) {
+                // 如果 共富区推荐人 不是平台，则为 推荐人发放 推荐奖励
+                $sharedProsperityUserEntityByParent = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($sharedProsperityUserEntity->getParentId());
+                if (!empty($sharedProsperityUserEntityByParent->getId())) {
+                    // 为 共富体系推荐人 发放养老金
+                    $yanglaojinBySpreadUid = bcmul($storeOrderEntity->getConPri(), CommonEnum::ORDER_EARNING_ALLOCATION['SharedProsperity']['Spread']['YangLaoJin']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+                    /** @var UserBillRepository $userBillRepository */
+                    $userBillRepository = app()->make(UserBillRepository::class);
+                    $userBillRepository->addUserBill(
+                        $sharedProsperityUserEntityByParent->getUserId(),
+                        UserBillEnum::COMMISSION_TYPE['PENSION']['code'],
+                        UserBillEnum::PM['INCOME']['code'],
+                        $yanglaojinBySpreadUid,
+                        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(),
+                        '推广共富区会员消费获得养老金'
+                    );
+
+                    // 计算 推广佣金
+                    /** @var SharedProsperityRecommendConfigRepository $sharedProsperityRecommendConfigRepository */
+                    $sharedProsperityRecommendConfigRepository = app()->make(SharedProsperityRecommendConfigRepository::class);
+                    $sharedProsperityRecommendConfigEntityByParentPartnerLevel = $sharedProsperityRecommendConfigRepository->getSharedProsperityRecommendConfigEntityByLevel($sharedProsperityUserEntityByParent->getPartnerLevel());
+                    if (!empty($sharedProsperityRecommendConfigEntityByParentPartnerLevel->getId())) {
+                        $rewardRatio = bcdiv($sharedProsperityRecommendConfigEntityByParentPartnerLevel->getRewardRatio(), 100, 2);
+                        $brokeragePriceBySpreadUid = bcmul($storeOrderEntity->getConPri(), $rewardRatio, CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+                        // 添加佣金记录
+                        /** @var UserBillRepository $userBillRepository */
+                        $userBillRepository = app()->make(UserBillRepository::class);
+                        $userBillRepository->addUserBill(
+                            $sharedProsperityUserEntityByParent->getUid(),
+                            UserBillEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code'],
+                            UserBillEnum::PM['INCOME']['code'],
+                            $brokeragePriceBySpreadUid,
+                            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 {
             /** @var MerchantRepository $merchantRepository */
             $merchantRepository = app()->make(MerchantRepository::class);

app/controller/api/store/order/StoreOrder.php

@@ -109,10 +109,12 @@ class StoreOrder extends BaseController
     public function createOrder(StoreCartRepository $cartRepository)
     {
         $uid = $this->request->uid();
-        if (in_array($uid, [1592, 766])) {
+        if (in_array($uid, [1592, 766, 6, 783, 7, 1166])) {
             $request = new Request();
             $storeOrderCreateValidate = new StoreOrderCreateValidate($request);
-            return $this->createOrderNew($storeOrderCreateValidate);
+            /** @var StoreGroupOrder $storeGroupOrderController */
+            $storeGroupOrderController = app()->make(StoreGroupOrder::class);
+            return $storeGroupOrderController->createStoreGroupOrder($storeOrderCreateValidate);
         }
 
         $cartId = (array)$this->request->param('cart_id', []);