PDD-订单奖励-未完成

app/common/dao/user/UserBillDao.php

@@ -242,6 +242,29 @@ class UserBillDao extends BaseDao
     }
 
     /**
+     * @param string $typeShop
+     * @param string $orderSn
+     * @return UserBillEntity
+     */
+    public function getUserBillEntityByTypeShopAndOrderSn(string $typeShop, string $orderSn): UserBillEntity
+    {
+        $entity = UserBillEntity::newInstance();
+        try {
+            $dataRes = UserBill::getDB()
+                ->where('type_shop', '=', $typeShop)
+                ->where('order_sn', '=', $orderSn)
+                ->find()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entity = UserBillEntity::newInstance($dataRes);
+            }
+        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {
+
+        }
+        return $entity;
+    }
+
+    /**
      * 批量更新
      * @param $dataList
      * @return array

app/common/enum/CommonEnum.php

@@ -23,7 +23,7 @@ class CommonEnum
     // 订单类型：根据业务需要进一步扩展
     const ORDER_TYPE = [
         'Platform' => ['code' => 0, 'name' => '平台'],
-        'DuoduoJinbao' => ['code' => 1, 'name' => '多多进宝'],
+        'DuoduoJinbao' => ['code' => 1, 'name' => '拼多多'],
         'Vipshop' => ['code' => 2, 'name' => '唯品会'],
         'SuningYigou' => ['code' => 3, 'name' => '苏宁易购'],
         'NetEaseKaola' => ['code' => 4, 'name' => '网易考拉'],
@@ -278,7 +278,29 @@ class CommonEnum
             ],
             'Thank' => ['code' => 0.1, 'name' => '感恩奖分配比例，10%'],
             'Hierarchy' => ['code' => 5, 'name' => '会员层级，5层'],
-        ]
+        ],
+        'Pdd' => [
+            'CommissionDistributionRatio' => [
+                'Ratio' => ['code' => 1, 'name' => '拼多多的佣金分配比例']
+            ],
+            'Pv' => [
+                'Ratio' => ['code' => 0.7, 'name' => '将订单利润的70%作为PV值']
+            ],
+            'Self' => [
+                'YangLaoJin' => [
+                    'Ratio' => ['code' => 0.3, 'name' => '将订单利润的30%，当做养老金分配给下单人']
+                ]
+            ],
+            'Spread' => [
+                'YangLaoJin' => [
+                    'Ratio' => ['code' => 0.05, 'name' => '将订单PV的百分之5，当做养老金分配给推荐人']
+                ], 'BrokeragePrice' => [
+                    'Ratio' => ['code' => 0.9, 'name' => '将商品利润中 用户身份对应分配比例 的推荐人可分配利润中 90% ，直推奖励的佣金部分'],
+                ], 'Fugou' => [
+                    'Ratio' => ['code' => 0.1, 'name' => '将商品利润中 用户身份对应分配比例 的推荐人可分配利润中 10% ，直推奖励的复购部分'],
+                ]
+            ]
+        ],
     ];
 
 }

app/common/repositories/user/UserBillRepository.php

@@ -397,12 +397,12 @@ class UserBillRepository extends BaseRepository
      * @param int $orderId
      * @param string $mark
      * @param string $title
+     * @param string $orderSn
      * @return UserBillEntity
      */
-    public function addUserBill(int $uid, int $commissionType, int $pm, float $number, string $category, string $type, string $source, int $orderType, int $typeShop = 0, int $orderId = 0, string $mark = '', string $title = ''): UserBillEntity
+    public function addUserBill(int $uid, int $commissionType, int $pm, float $number, string $category, string $type, string $source, int $orderType, int $typeShop = 0, int $orderId = 0, string $mark = '', string $title = '', string $orderSn = ''): UserBillEntity
     {
 
-        $orderSn = '';
         $merId = 0;
         if ($typeShop == UserBillEnum::TYPE_SHOP['Platform']['code']) {
             /** @var StoreOrderRepository $storeOrderRepository */
@@ -493,6 +493,16 @@ class UserBillRepository extends BaseRepository
     }
 
     /**
+     * @param string $typeShop
+     * @param string $orderSn
+     * @return UserBillEntity
+     */
+    public function getUserBillEntityByTypeShopAndOrderSn(string $typeShop, string $orderSn): UserBillEntity
+    {
+        return $this->dao->getUserBillEntityByTypeShopAndOrderSn($typeShop, $orderSn);
+    }
+
+    /**
      * @param $dataList
      * @return array
      */

app/controller/api/store/product/TaoKe.php

@@ -2,9 +2,17 @@
 
 namespace app\controller\api\store\product;
 
+use app\common\enum\CommonEnum;
+use app\common\enum\user\UserBillEnum;
+use app\common\enum\user\UserEnum;
+use app\common\enum\user\UserSignFugouEnum;
 use app\common\model\user\UserThird;
+use app\common\repositories\shared\SharedProsperityUserRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
 use app\common\repositories\store\product\ProductRepository;
+use app\common\repositories\user\UserBillRepository;
 use app\common\repositories\user\UserRepository;
+use app\common\repositories\user\UserSignFugouRepository;
 use app\common\repositories\user\UserThirdRepository;
 use app\model\common\PddOrderModel;
 use crmeb\services\JwtTokenService;
@@ -896,6 +904,7 @@ class TaoKe extends BaseController
 
     public function operatePinOrder($orderLists)
     {
+        /** @var UserThirdRepository $orderThird */
         $orderThird = app()->make(UserThirdRepository::class);
         foreach ($orderLists as $k => $order) {
             if (empty($order)) continue;
@@ -957,6 +966,149 @@ class TaoKe extends BaseController
         }
     }
 
+    public function operatePinOrderNew($orderLists)
+    {
+        foreach ($orderLists as $order) {
+            if (empty($order)) continue;
+            $localOrder = PddOrderModel::getInstance()->getOne(['order_sn' => $order['order_sn']]);
+            if (empty($localOrder)) {
+                /** @var UserRepository $userRepository */
+                $userRepository = app()->make(UserRepository::class);
+                $userEntity = $userRepository->getUserEntityByUid($order['uid']);
+                if (empty($userEntity->getUid())) {
+                    Db::name('log')->insert(['data' => '拼多多订单号：' . $order['order_sn'] . '，未查询到相应用户信息：' . $order['uid']]);
+                    continue;
+                }
+                /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+                $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+                $sharedProsperityUserEntity = $sharedProsperityUserRepository->getSharedProsperityUserEntityByUserId($userEntity->getUid());
+
+                $localOrder = PddOrderModel::create($order);
+
+                // 发放养老金
+                // 收益
+                $commission = $localOrder['commission'] ?? 0.00;
+                // 手续费
+                $huifuCommissionCharge = bcmul((string)$commission, (string)CommonEnum::HUIFU_COMMISSION_CHARGE, CommonEnum::CALCULATE_THE_NUMBER_OF_DECIMAL_PLACES);
+                // 可支配金额
+                $profit = bcsub((string)$commission, $huifuCommissionCharge, CommonEnum::CALCULATE_THE_NUMBER_OF_DECIMAL_PLACES);
+                $profit = bcmul($profit, CommonEnum::ORDER_EARNING_ALLOCATION['Pdd']['CommissionDistributionRatio']['Ratio']['code'], CommonEnum::CALCULATE_THE_NUMBER_OF_DECIMAL_PLACES);
+
+                $pv = bcmul((string)$commission, (string)CommonEnum::ORDER_EARNING_ALLOCATION['Pdd']['Pv']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+
+                // 为消费者 发放养老金
+                /** @var UserBillRepository $userBillRepository */
+                $userBillRepository = app()->make(UserBillRepository::class);
+                $yanglaojin = bcmul((string)$commission, CommonEnum::ORDER_EARNING_ALLOCATION['Pdd']['Self']['YangLaoJin']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+                if ($yanglaojin >= 0.01) {
+                    $userBillRepository->addUserBill(
+                        $userEntity->getUid(),
+                        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['THIRD_PARTY']['code'],
+                        UserBillEnum::TYPE_SHOP['DuoduoJinbao']['code'],
+                        $localOrder['order_pdd_id'],
+                        CommonEnum::ORDER_TYPE['DuoduoJinbao']['name'] . '消费获得养老金' . $yanglaojin,
+                        '',
+                        $localOrder['order_sn']
+                    );
+                } else {
+                    Db::name('log')->insert(['data' => '订单号：' . $localOrder['order_sn'] . '付款额度较低或 商家、平台设置的返佣比例较低，养老金低于0.01无法入库 特此记录！']);
+                }
+
+                $spreadUid = $userEntity->getSpreadUid();
+                // 判断推广者 如果推广者 是共富体系会员
+                if (!empty($sharedProsperityUserEntity->getId())) {
+                    $spreadUid = $sharedProsperityUserEntity->getParentId();
+                }
+                if (!empty($spreadUid)) {
+                    $userEntityBySpreadUid = $userRepository->getUserEntityByUid($spreadUid);
+                    if (!empty($userEntityBySpreadUid->getUid()) && $userEntityBySpreadUid->getIsDel() == UserEnum::IS_DEL['No']['code']) {
+                        // 发放养老金
+                        // 如果用户的身份 不是 普通用户 （高于普通用户） 则发放养老金
+                        if ($userEntityBySpreadUid->getUserGroup() != CommonEnum::USER_GROUP['RegularUser']['code']) {
+                            $yanglaojinBySpreadUid = bcmul($pv, CommonEnum::ORDER_EARNING_ALLOCATION['Pdd']['Spread']['YangLaoJin']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+                            if ($yanglaojin >= 0.01) {
+                                /** @var UserBillRepository $userBillRepository */
+                                $userBillRepository = app()->make(UserBillRepository::class);
+                                $userBillRepository->addUserBill(
+                                    $userEntityBySpreadUid->getUid(),
+                                    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['THIRD_PARTY']['code'],
+                                    UserBillEnum::TYPE_SHOP['DuoduoJinbao']['code'],
+                                    $localOrder['order_pdd_id'],
+                                    "推荐消费获得养老金" . $yanglaojinBySpreadUid,
+                                    '',
+                                    $localOrder['order_sn']
+                                );
+                            } else {
+                                Db::name('log')->insert(['data' => '订单号：' . $localOrder['order_sn'] . '付款额度较低，推荐养老金低于0.01无法入库 特此记录！']);
+                            }
+                        }
+
+                        // 后台设置中 可以设置 推荐人 直推收益 的比例
+                        $rate = StoreOrderRepository::getUserGroupRate($userEntityBySpreadUid->getUserGroup());
+                        // 推荐 奖金 目前需要将 奖金按比例 分成佣金和复购金
+                        $directReferralBonus = bcmul($pv, $rate, CommonEnum::CALCULATE_THE_NUMBER_OF_DECIMAL_PLACES);
+
+                        // 计算 复购金
+                        $fugouBySpreadUid = bcmul($directReferralBonus, CommonEnum::ORDER_EARNING_ALLOCATION['Pdd']['Spread']['Fugou']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+                        if ($fugouBySpreadUid >= 0.01) {
+                            // 添加复购金记录
+                            /** @var UserSignFugouRepository $userSignFugouRepository */
+                            $userSignFugouRepository = app()->make(UserSignFugouRepository::class);
+                            $userSignFugouRepository->addUserSingFugou(
+                                $userEntityBySpreadUid->getUid(),
+                                UserSignFugouEnum::TYPE['Give']['code'],
+                                $fugouBySpreadUid,
+                                UserSignFugouEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code'],
+                                '推荐消费' . CommonEnum::ORDER_TYPE['DuoduoJinbao']['name'] . '商品赠送复购金',
+                                UserSignFugouEnum::ORDER_TYPE['DuoduoJinbao']['code'],
+                                $localOrder['order_pdd_id']
+                            );
+                        } else {
+                            Db::name('log')->insert(['data' => '订单号：' .  $localOrder['order_sn'] . '付款额度较低或 商家、平台设置的返佣比例较低，复购金低于0.01无法入库 特此记录！']);
+                        }
+
+                        // 计算 佣金
+                        $brokeragePriceBySpreadUid = bcmul($directReferralBonus, CommonEnum::ORDER_EARNING_ALLOCATION['Pdd']['Spread']['BrokeragePrice']['Ratio']['code'], CommonEnum::DECIMAL_PLACES_OF_THE_AMOUNT);
+                        if ($brokeragePriceBySpreadUid >= 0.01) {
+                            // 添加佣金记录
+                            /** @var UserBillRepository $userBillRepository */
+                            $userBillRepository = app()->make(UserBillRepository::class);
+                            $userBillRepository->addUserBill(
+                                $userEntityBySpreadUid->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['THIRD_PARTY']['code'],
+                                UserBillEnum::TYPE_SHOP['DuoduoJinbao']['code'],
+                                $localOrder['order_pdd_id'],
+                                '推荐消费获得佣金' . $brokeragePriceBySpreadUid,
+                                '',
+                                $localOrder['order_sn']
+                            );
+                        } else {
+                            Db::name('log')->insert(['data' => '订单号：' . $localOrder['order_sn'] . '付款额度较低或 商家、平台设置的返佣比例较低，佣金低于0.01无法入库 特此记录！']);
+                        }
+                    }
+                }
+            }
+        }
+    }
+
 
     //将拼多多订单列表中的订单写入第三方平台订单表
     public function operatePinOrderOld($orderLists)