diff --git a/app/common/repositories/user/UserRepository.php b/app/common/repositories/user/UserRepository.php index 5df3a6f..5b92173 100644 --- a/app/common/repositories/user/UserRepository.php +++ b/app/common/repositories/user/UserRepository.php @@ -8,6 +8,7 @@ namespace app\common\repositories\user; use app\common\dao\BaseDao; use app\common\dao\user\UserDao; use app\common\model\user\User; +use app\common\model\user\UserBrokerageApplyFormal; use app\common\model\wechat\WechatUser; use app\common\repositories\BaseRepository; use app\common\repositories\community\CommunityRepository; @@ -916,9 +917,11 @@ class UserRepository extends BaseRepository * @author xaboy * @day 2020/6/22 */ - public function bindSpread(User $user, int $spreadUid) - { - if ($spreadUid && !$user->spread_uid && $user->uid != $spreadUid && ($spread = $this->dao->get($spreadUid)) && $spread->spread_uid != $user->uid && !$spread->cancel_time) { + public function bindSpread(User $user, int $spreadUid){ + // 获取邀请人 分销商转正申请信息 + $formalStatus = (int)UserBrokerageApplyFormal::where('uid', $spreadUid)->value('status'); + + if ($formalStatus == 1 && $spreadUid && !$user->spread_uid && $user->uid != $spreadUid && ($spread = $this->dao->get($spreadUid)) && $spread->spread_uid != $user->uid && !$spread->cancel_time) { $config = systemConfig(['extension_limit', 'extension_limit_day', 'integral_user_give']); event('user.spread.before', compact('user','spreadUid')); Db::transaction(function () use ($spread, $spreadUid, $user, $config) {