订单结算-修改佣金结算发放体系

app/common/enum/shared/SharedProsperityBalanceLogEnum.php

@@ -16,5 +16,16 @@ class SharedProsperityBalanceLogEnum extends CommonEnum
     const TYPE = [
         'PARTNER' => ['code' => 1, 'name' => '合伙人分红'],
         'GROUP' => ['code' => 2, 'name' => '共富奖'],
+        'DIRECT_REFERRAL' => ['code' => 3, 'name' => '直推奖'],
+        'LOCKED_CUSTOMER' => ['code' => 7, 'name' => '锁客收益'],
+        'PLATFORM_REWARD' => ['code' => 8, 'name' => '平台奖励'],
+        'SHARE_EARNINGS' => ['code' => 20, 'name' => '分享收益'],
+    ];
+
+    // 状态
+    const STATUS = [
+        'PENDING' => ['code' => 0, 'name' => '待确定'],
+        'VALID' => ['code' => 1, 'name' => '有效'],
+        'INVALID' => ['code' => -1, 'name' => '无效'],
     ];
 }

app/common/repositories/user/UserBillRepository.php

@@ -12,14 +12,19 @@ namespace app\common\repositories\user;
 
 
 use app\common\dao\BaseDao;
+use app\common\dao\shared\SharedProsperityBalanceLogDao;
 use app\common\dao\user\UserBillDao;
 use app\common\enum\CommonEnum;
+use app\common\enum\shared\SharedProsperityBalanceLogEnum;
 use app\common\enum\user\UserBillEnum;
 use app\common\enum\user\UserCertificationEnum;
 use app\common\model\user\UserBill;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\gzc\GzcLogRepository;
+use app\common\repositories\shared\SharedProsperityUserRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
+use app\entity\data\shared\SharedProsperityBalanceLogEntity;
+use app\entity\data\shared\SharedProsperityUserEntity;
 use app\entity\data\user\UserBillEntity;
 use app\entity\data\user\UserCertificationEntity;
 use app\entity\data\user\UserEntity;
@@ -544,6 +549,15 @@ class UserBillRepository extends BaseRepository
             if (!empty($userIdList)) {
                 $userEntityMapByUid = $userRepository->getUserEntityMapByUidList($userIdList);
             }
+
+            // 获取所有用户是否有 共富身份
+            /** @var SharedProsperityUserRepository $sharedProsperityUserRepository */
+            $sharedProsperityUserRepository = app()->make(SharedProsperityUserRepository::class);
+            $sharedProsperityUserEntityMapUserId = [];
+            if (!empty($sharedProsperityUserIdList)) {
+                $sharedProsperityUserEntityMapUserId = $sharedProsperityUserRepository->getSharedProsperityUserEntityMapByUserIdList($userIdList);
+            }
+
             // 获取实名认证 映射信息 (养老金记录 结算时 需要确定 所属人是否已经实名认证 如果实名认证了 需要推到养老金公证处明细表里 并修改养老金记录的推送状态)
             /** @var UserCertificationEntity[] $userCertificationEntityMapByUid */
             $userCertificationEntityMapByUid = [];
@@ -555,7 +569,13 @@ class UserBillRepository extends BaseRepository
             /** @var GzcLogRepository $gzcLogRepository */
             $gzcLogRepository = app()->make(GzcLogRepository::class);
 
+            // 需要更新的 用户信息-基础信息- 会员身份信息
             $updateUserEntityList = [];
+            // 需要更新的 共富体系身份信息
+            $updateSharedProsperityUserEntityList = [];
+            // 共富区 佣金收入支出记录
+            /** @var SharedProsperityBalanceLogEntity[] $insertSharedProsperityBalanceLogEntityList */
+            $insertSharedProsperityBalanceLogEntityList = [];
             $updateUserBillEntityList = [];
             foreach ($userBillEntityList as $userBillEntity) {
                 if (empty($userBillEntity->getBillId()) || empty($userBillEntity->getUid())) {
@@ -566,15 +586,16 @@ class UserBillRepository extends BaseRepository
                     throw new ValidateException("该账单记录已更新，请勿重复操作({$userBillEntity->getBillId()})");
                 }
 
+                // 判断用户是否存在
                 $userEntity = $userEntityMapByUid[$userBillEntity->getUid()];
                 if (empty($userEntity) || empty($userEntity->getUid())) {
                     throw new ValidateException("未查询到用户信息({$userBillEntity->getBillId()})");
                 }
 
-                // 更新 用户信息
-                /** @var UserEntity $updateUserEntity */
-                $updateUserEntity = $updateUserEntityList[$userEntity->getUid()] ?? UserEntity::newInstance();
-                $updateUserEntity->setUid($userEntity->getUid());
+                // 要更新的用户信息
+                $updateUserEntity = null;
+                // 要更新的 共富用户信息
+                $updateSharedProsperityUserEntity = null;
                 // 更新 账单 记录
                 /** @var UserBillEntity $updateUserBillEntity */
                 $updateUserBillEntity = $updateUserBillEntityList[$userBillEntity->getBillId()] ?? UserBillEntity::newInstance();
@@ -583,22 +604,97 @@ class UserBillRepository extends BaseRepository
                     ->setBillId($userBillEntity->getBillId())
                     ->setStatus(UserBillEnum::STATUS['VALID']['code'])
                     ->setTakeTime(time());
+                // 直推佣金 锁客佣金 平台奖励佣金 分享佣金
+                if (in_array($userBillEntity->getCommissionType(), [
+                    UserBillEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code'],
+                    UserBillEnum::COMMISSION_TYPE['LOCKED_CUSTOMER']['code'],
+                    UserBillEnum::COMMISSION_TYPE['PLATFORM_REWARD']['code'],
+                    UserBillEnum::COMMISSION_TYPE['SHARE_EARNINGS']['code']
+                ])) {
+                    // 首先判断 是否有共富会员身份
+                    $sharedProsperityUserEntity = $sharedProsperityUserEntityMapUserId[$userBillEntity->getUid()] ?? null;
+                    // 如果拥有共富身份 并且非 会员专区 专属奖励 则发放到 共富身份中
+                    if (
+                        $userBillEntity->getMerId() != CommonEnum::DESIGN_MERCHANT_ID['MemberZone']['code']
+                        && !empty($sharedProsperityUserEntity)
+                        && $sharedProsperityUserEntity instanceof SharedProsperityUserEntity
+                        && !empty($sharedProsperityUserEntity->getId())
+                    ) {
+                        // 更新 共富用户信息
+                        /** @var SharedProsperityUserEntity $updateSharedProsperityUserEntity */
+                        $updateSharedProsperityUserEntity = $updateSharedProsperityUserEntityList[$userBillEntity->getUid()] ?? SharedProsperityUserEntity::newInstance();
+                        $updateSharedProsperityUserEntity
+                            ->setId($sharedProsperityUserEntity->getId())
+                            ->setUserId($sharedProsperityUserEntity->getUserId());
+                        // 佣金
+                        if (is_null($updateSharedProsperityUserEntity->getBalance())) {
+                            $updateSharedProsperityUserEntity->setBalance($sharedProsperityUserEntity->getBalance());
+                        }
 
-                if ($userBillEntity->getCommissionType() == UserBillEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code']) {
-                    // 直推奖
-                    if (is_null($updateUserEntity->getBrokeragePrice())) {
-                        $updateUserEntity->setBrokeragePrice($userEntity->getBrokeragePrice());
-                    }
-                    // 更新用户 佣金 信息
-                    if ($userBillEntity->getPm() == UserBillEnum::PM['EXPEND']['code']) {
-                        if ($updateUserEntity->getBrokeragePrice() < $userBillEntity->getNumber()) {
-                            throw new ValidateException('用户佣金不足');
+                        switch ($userBillEntity->getCommissionType()) {
+                            case UserBillEnum::COMMISSION_TYPE['DIRECT_REFERRAL']['code']:
+                                $sharedProsperityBalanceLogType = SharedProsperityBalanceLogEnum::TYPE['DIRECT_REFERRAL']['code'];
+                                break;
+
+                            case UserBillEnum::COMMISSION_TYPE['LOCKED_CUSTOMER']['code']:
+                                $sharedProsperityBalanceLogType = SharedProsperityBalanceLogEnum::TYPE['LOCKED_CUSTOMER']['code'];
+                                break;
+
+                            case UserBillEnum::COMMISSION_TYPE['PLATFORM_REWARD']['code']:
+                                $sharedProsperityBalanceLogType = SharedProsperityBalanceLogEnum::TYPE['PLATFORM_REWARD']['code'];
+                                break;
+
+                            case UserBillEnum::COMMISSION_TYPE['SHARE_EARNINGS']['code']:
+                                $sharedProsperityBalanceLogType = SharedProsperityBalanceLogEnum::TYPE['SHARE_EARNINGS']['code'];
+                                break;
+
+                            default:
+                                $sharedProsperityBalanceLogType = null;
+                                break;
+                        }
+                        $sharedProsperityBalanceLogEntity = SharedProsperityBalanceLogEntity::newInstance()
+                            ->setUserId($sharedProsperityUserEntity->getUserId())
+                            ->setType($sharedProsperityBalanceLogType)
+                            ->setLevel($sharedProsperityUserEntity->getPartnerLevel())
+                            ->setNumber($userBillEntity->getNumber())
+                            ->setStatus(SharedProsperityBalanceLogEnum::STATUS['VALID']['code'])
+                        ;
+
+                        // 更新用户 佣金 信息
+                        if ($userBillEntity->getPm() == UserBillEnum::PM['EXPEND']['code']) {
+                            if ($updateSharedProsperityUserEntity->getBalance() < $userBillEntity->getNumber()) {
+                                throw new ValidateException('用户佣金不足');
+                            }
+                            $updateSharedProsperityUserEntity->setBalance(bcsub($updateSharedProsperityUserEntity->getBalance(), $userBillEntity->getNumber(), 2));
+
+                            $sharedProsperityBalanceLogEntity->setPm(SharedProsperityBalanceLogEnum::PM['EXPEND']['code']);
+                        } else {
+                            $updateSharedProsperityUserEntity->setBalance(bcadd($updateSharedProsperityUserEntity->getBalance(), $userBillEntity->getNumber(), 2));
+
+                            $sharedProsperityBalanceLogEntity->setPm(SharedProsperityBalanceLogEnum::PM['INCOME']['code']);
                         }
-                        $updateUserEntity->setBrokeragePrice(bcsub($updateUserEntity->getBrokeragePrice(), $userBillEntity->getNumber(), 2));
+                        // 插入 共富区 佣金记录 变动表
+                        $insertSharedProsperityBalanceLogEntityList[] = $sharedProsperityBalanceLogEntity
+                            ->setAfter($updateSharedProsperityUserEntity->getBalance());
                     } else {
-                        $updateUserEntity->setBrokeragePrice(bcadd($updateUserEntity->getBrokeragePrice(), $userBillEntity->getNumber(), 2));
+                        // 更新 用户信息
+                        /** @var UserEntity $updateUserEntity */
+                        $updateUserEntity = $updateUserEntityList[$userEntity->getUid()] ?? UserEntity::newInstance();
+                        $updateUserEntity->setUid($userEntity->getUid());
+                        // 直推奖
+                        if (is_null($updateUserEntity->getBrokeragePrice())) {
+                            $updateUserEntity->setBrokeragePrice($userEntity->getBrokeragePrice());
+                        }
+                        // 更新用户 佣金 信息
+                        if ($userBillEntity->getPm() == UserBillEnum::PM['EXPEND']['code']) {
+                            if ($updateUserEntity->getBrokeragePrice() < $userBillEntity->getNumber()) {
+                                throw new ValidateException('用户佣金不足');
+                            }
+                            $updateUserEntity->setBrokeragePrice(bcsub($updateUserEntity->getBrokeragePrice(), $userBillEntity->getNumber(), 2));
+                        } else {
+                            $updateUserEntity->setBrokeragePrice(bcadd($updateUserEntity->getBrokeragePrice(), $userBillEntity->getNumber(), 2));
+                        }
                     }
-
                 } else if ($userBillEntity->getCommissionType() == UserBillEnum::COMMISSION_TYPE['PENSION']['code']) {
 
                     if ($userBillEntity->getGzc() == UserBillEnum::GZC_STATUS['NOT_ENTERED']['code']) {
@@ -614,7 +710,10 @@ class UserBillRepository extends BaseRepository
                                 $userBillEntity->getLinkId(),
                                 $userBillEntity->getNumber()
                             );
-
+                            // 更新 用户信息
+                            /** @var UserEntity $updateUserEntity */
+                            $updateUserEntity = $updateUserEntityList[$userEntity->getUid()] ?? UserEntity::newInstance();
+                            $updateUserEntity->setUid($userEntity->getUid());
                             // 养老金
                             if (is_null($updateUserEntity->getAnnuity())) {
                                 $updateUserEntity->setAnnuity($userEntity->getAnnuity());
@@ -635,7 +734,12 @@ class UserBillRepository extends BaseRepository
                     }
                 }
 
-                $updateUserEntityList[$userEntity->getUid()] = $updateUserEntity;
+                if (!empty($updateUserEntity)) {
+                    $updateUserEntityList[$userEntity->getUid()] = $updateUserEntity;
+                }
+                if (!empty($updateSharedProsperityUserEntity)) {
+                    $updateSharedProsperityUserEntityList[$updateSharedProsperityUserEntity->getUserId()] = $updateSharedProsperityUserEntity;
+                }
                 $updateUserBillEntityList[$userBillEntity->getBillId()] = $updateUserBillEntity;
             }
             if (!empty($updateUserEntityList)) {
@@ -646,6 +750,21 @@ class UserBillRepository extends BaseRepository
                 );
             }
 
+            if (!empty($updateSharedProsperityUserEntityList)) {
+                $sharedProsperityUserRepository->batchUpdateSharedProsperityUserDataByDataList(
+                    array_map(function (SharedProsperityUserEntity $updateSharedProsperityUserEntity) {
+                        return $updateSharedProsperityUserEntity->toUnderlineArray();
+                    }, $updateSharedProsperityUserEntityList)
+                );
+            }
+            if (!empty($insertSharedProsperityBalanceLogEntityList)) {
+                /** @var SharedProsperityBalanceLogDao $balanceDao */
+                $balanceDao = app()->make(SharedProsperityBalanceLogDao::class);
+                $balanceDao->insertAll(array_map(function ($insertSharedProsperityBalanceLogEntity) {
+                    return $insertSharedProsperityBalanceLogEntity->toUnderlineArray();
+                }, $insertSharedProsperityBalanceLogEntityList));
+            }
+
             if (!empty($updateUserBillEntityList)) {
                 $this->batchUpdateUserBillDataByDataList(
                     array_map(function (UserBillEntity $updateUserBillEntity) {