src/Biz/User/Dao/Impl/InviteRecordDaoImpl.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Biz\User\Dao\Impl;

use Biz\User\Dao\InviteRecordDao;
use Codeages\Biz\Framework\Dao\GeneralDaoImpl;

class InviteRecordDaoImpl extends GeneralDaoImpl implements InviteRecordDao
{
    protected $table = 'invite_record';

    public function findByInviteUserId($userId)
    {
        return $this->findInField('inviteUserId', array($userId));
    }

    public function findByInviteUserIds($userIds)
    {
        return $this->findInField('inviteUserId', $userIds);
    }

    public function findByInvitedUserIds($invitedUserIds)
    {
        return $this->findInField('invitedUserId', $invitedUserIds);
    }

    public function getByInvitedUserId($invitedUserId)
    {
        return $this->getByFields(array('invitedUserId' => $invitedUserId));
    }

    public function updateByInvitedUserId($invitedUserId, $fields)
    {
        return $this->db()->update($this->table, $fields, array('invitedUserId' => $invitedUserId));
    }

    public function sumCouponRateByInviteUserId($userId)
    {
        $sql = 'SELECT sum(`rate`) as rate from `coupon` where id in(SELECT `inviteUserCardId` FROM `invite_record` WHERE `inviteUserId` = ?)';

        return $this->db()->fetchColumn($sql, array($userId));
    }

    public function searchRecordGroupByInviteUserId($conditions, $start, $limit)
    {
        $builder = $this->createQueryBuilder($conditions)
                ->select('inviteUserId, count(`invitedUserId`) as countInvitedUserId, sum(`amount`) as amount, sum(`cashAmount`) as cashAmount, sum(`coinAmount`) as coinAmount')
                ->setFirstResult($start)
                ->setMaxResults($limit)
                ->groupBy('`inviteUserId`');

        return $builder->execute()->fetchAll();
    }

    public function countInviteUser($conditions)
    {
        $builder = $this->createQueryBuilder($conditions)
            ->select('count(distinct `inviteUserId`)');

        return $builder->execute()->fetchColumn();