huahuibao/biz-hd/distribution/classes/DistributionUserClass.php

<?php
/**
 * 用途：分销用户统计（xhDistributionUser）
 * 谁用：hdApp 客户详情-分销板块
 */

namespace bizHd\distribution\classes;

use bizHd\base\classes\BaseClass;
use bizHd\custom\classes\CustomClass;
use common\components\dateUtil;
use Yii;
use yii\db\Query;

class DistributionUserClass extends BaseClass
{
    public static $baseFile = '\bizHd\distribution\models\DistributionUser';

    /**
     * 获取客户分销统计（无记录返回默认 0）
     * @param int $shopId 门店ID
     * @param int $customId 客户 xhCustom.id
     * @return array
     * @throws \Exception
     */
    public static function getUserStat($shopId, $customId)
    {
        $customId = (int)$customId;
        if ($customId <= 0) {
            throw new \Exception('客户ID无效');
        }

        $row = self::getByCondition(['shopId' => (int)$shopId, 'id' => $customId]);
        if (empty($row)) {
            return self::defaultStat($customId);
        }

        return [
            'customId' => $customId,
            'totalCommission' => $row['totalCommission'],
            'inviteCount' => (int)$row['inviteCount'],
            'orderCount' => (int)$row['orderCount'],
            'pendingCommission' => $row['pendingCommission'],
            'settledCommission' => $row['settledCommission'],
        ];
    }

    /**
     * 商城 C 端我的分红汇总
     * @param int $shopId
     * @param int $customId
     * @return array
     * @throws \Exception
     */
    public static function getMallMyStat($shopId, $customId)
    {
        $stat = self::getUserStat($shopId, $customId);
        $row = self::getByCondition(['shopId' => (int)$shopId, 'id' => (int)$customId]);
        $stat['availDeposit'] = round((float)(!empty($row) ? ($row['availDeposit'] ?? 0) : 0), 2);

        $period = dateUtil::formatTime('thisMonth', '', '');
        $monthCommission = 0;
        if (!empty($period['startTime']) && !empty($period['endTime'])) {
            $monthCommission = (float)(new Query())
                ->from('xhDistributionFlow')
                ->where([
                    'shopId' => (int)$shopId,
                    'xhCustomId' => (int)$customId,
                    'flowType' => 1,
                ])
                ->andWhere(['between', 'flowTime', $period['startTime'], $period['endTime']])
                ->sum('amount');
        }
        $stat['monthCommission'] = round($monthCommission, 2);
        return $stat;
    }

    /**
     * 新建 xhCustom 时初始化 xhDistributionUser
     * 规则：customId 无记录则创建；有邀请人则写 inviterId、inviteTime，并给邀请人 inviteCount +1；已有记录则不操作
     * @param int $shopId 门店 ID
     * @param int $inviteeCustomId 被邀请人 xhCustom.id
     * @param int $inviterCustomId 邀请人 xhCustom.id，0 表示无邀请人
     * @return int 0未操作 1已创建且完成邀请绑定
     * @throws \Throwable
     */
    public static function bindInviteOnRegister($shopId, $inviteeCustomId, $inviterCustomId = 0)
    {
        $shopId = (int)$shopId;
        $inviteeCustomId = (int)$inviteeCustomId;
        $inviterCustomId = (int)$inviterCustomId;

        if ($shopId <= 0 || $inviteeCustomId <= 0) {
            return 0;
        }

        // 按 customId 查是否已有分销记录，有则不做任何操作
        $inviteeRow = self::getByCondition(['customId' => $inviteeCustomId]);
        if (!empty($inviteeRow)) {
            return 0;
        }

        // 校验邀请人（无效则仍创建被邀请人记录，但不绑定）
        $canBindInviter = false;
        if ($inviterCustomId > 0 && $inviterCustomId !== $inviteeCustomId) {
            $inviter = CustomClass::getById($inviterCustomId, true);
            if (!empty($inviter) && (int)$inviter->shopId === $shopId) {
                $canBindInviter = true;
            }
        }

        $createData = [
            'id' => $inviteeCustomId,
            'customId' => $inviteeCustomId,
            'shopId' => $shopId,
        ];
        if ($canBindInviter) {
            $createData['inviterId'] = $inviterCustomId;
            $createData['inviteTime'] = date('Y-m-d H:i:s');
        }

        $transaction = Yii::$app->db->beginTransaction();
        try {
            try {
                self::add($createData, true);
            } catch (\yii\db\IntegrityException $e) {
                // 并发下记录已被创建，不做任何操作
                if (strpos($e->getMessage(), 'Duplicate entry') !== false) {
                    $transaction->rollBack();
                    return 0;
                }
                throw $e;
            }

            // 绑定邀请人成功后，邀请人拉新数量 +1
            if ($canBindInviter) {
                $inviterRow = self::getByCondition(['customId' => $inviterCustomId]);
                if (empty($inviterRow)) {
                    self::add([
                        'id' => $inviterCustomId,
                        'customId' => $inviterCustomId,
                        'shopId' => $shopId,
                        'inviteCount' => 1,
                    ], true);
                } else {
                    static::$baseFile::updateAllCounters(
                        ['inviteCount' => 1],
                        ['customId' => $inviterCustomId]
                    );
                }
            }

            $transaction->commit();
            return $canBindInviter ? 1 : 0;
        } catch (\Throwable $e) {
            $transaction->rollBack();
            throw $e;
        }
    }

    /**
     * 无分销记录时的默认统计
     */
    protected static function defaultStat($customId)
    {
        return [
            'customId' => (int)$customId,
            'totalCommission' => '0.00',
            'inviteCount' => 0,
            'orderCount' => 0,
            'pendingCommission' => '0.00',
            'settledCommission' => '0.00',
            'availDeposit' => '0.00',
            'monthCommission' => '0.00',
        ];
    }

    /**
     * 拉新客户列表（xhDistributionUser + xhCustom）
     * 条件：du.inviterId = 当前分销员；绑定时间取 inviteTime
     * @param int $shopId
     * @param int $inviterId 邀请人 xhCustom.id
     * @return array
     * @throws \Exception
     */
    public static function getInviteList($shopId, $inviterId)
    {
        $shopId = (int)$shopId;
        $inviterId = (int)$inviterId;
        if ($inviterId <= 0) {
            throw new \Exception('客户ID无效');
        }

        $get = Yii::$app->request->get();
        $keyword = isset($get['keyword']) ? trim($get['keyword']) : '';
        $sortField = isset($get['sortField']) ? trim($get['sortField']) : 'inviteTime';
        $sortOrder = isset($get['sortOrder']) && strtolower($get['sortOrder']) === 'asc' ? 'ASC' : 'DESC';
        $page = isset($get['page']) ? max(1, (int)$get['page']) : 1;
        $pageSize = isset($get['pageSize']) && (int)$get['pageSize'] > 0
            ? (int)$get['pageSize']
            : (int)Yii::$app->params['pageSize'];

        $query = (new Query())
            ->from(['du' => 'xhDistributionUser'])
            ->leftJoin(['c' => 'xhCustom'], 'c.id = du.id')
            ->where(['du.shopId' => $shopId, 'du.inviterId' => $inviterId])
            ->select([
                'du.id',
                'du.inviteTime',
                'du.upOrderCount',
                'du.upCommissionAmount',
                'c.name',
                'c.mobile',
                'c.avatar',
            ]);

        if ($keyword !== '') {
            $query->andWhere([
                'or',
                ['like', 'c.name', $keyword],
                ['like', 'c.mobile', $keyword],
            ]);
        }

        // 排序：贡献字段取 up*（本人下单给上级的贡献）
        $orderMap = [
            'inviteTime' => 'du.inviteTime',
            'commission' => 'du.upCommissionAmount',
            'orderCount' => 'du.upOrderCount',
        ];
        $orderColumn = isset($orderMap[$sortField]) ? $orderMap[$sortField] : 'du.inviteTime';
        $query->orderBy([$orderColumn => $sortOrder === 'ASC' ? SORT_ASC : SORT_DESC, 'du.id' => SORT_DESC]);

        $total = (int)(clone $query)->count('*', Yii::$app->db);
        $totalPage = $pageSize > 0 ? (int)ceil($total / $pageSize) : 0;
        $rows = $query->offset(($page - 1) * $pageSize)->limit($pageSize)->all(Yii::$app->db);

        $customRows = [];
        foreach ($rows as $row) {
            $customRows[] = [
                'id' => (int)$row['id'],
                'name' => $row['name'] ?: '',
                'mobile' => $row['mobile'] ?: '',
                'avatar' => $row['avatar'] ?: '',
            ];
        }
        $avatarMap = [];
        if (!empty($customRows)) {
            foreach (CustomClass::groupBaseInfo($customRows) as $customItem) {
                $avatarMap[(int)$customItem['id']] = $customItem;
            }
        }

        $list = [];
        foreach ($rows as $row) {
            $custom = $avatarMap[(int)$row['id']] ?? [];
            $bindTime = $row['inviteTime'];
            $list[] = [
                'customId' => (int)$row['id'],
                'name' => $custom['name'] ?? ($row['name'] ?: ''),
                'mobile' => $custom['mobile'] ?? ($row['mobile'] ?: ''),
                'smallAvatar' => $custom['smallAvatar'] ?? '',
                'bindTime' => $bindTime,
                'bindDays' => self::calcBindDays($bindTime),
                'bindDaysText' => self::buildBindDaysText($bindTime),
                'contribCommission' => round((float)$row['upCommissionAmount'], 2),
                'contribOrderCount' => (int)$row['upOrderCount'],
            ];
        }

        return [
            'list' => $list,
            'totalPage' => $totalPage,
            'moreData' => $page < $totalPage ? 1 : 0,
        ];
    }

    /**
     * 门店获佣人数明细（报表跳转）
     * @param int $shopId
     * @return array
     */
    public static function getShopDistList($shopId)
    {
        $shopId = (int)$shopId;
        $get = Yii::$app->request->get();
        $keyword = isset($get['keyword']) ? trim($get['keyword']) : '';
        $page = isset($get['page']) ? max(1, (int)$get['page']) : 1;
        $pageSize = isset($get['pageSize']) && (int)$get['pageSize'] > 0
            ? (int)$get['pageSize']
            : (int)Yii::$app->params['pageSize'];
        $period = self::buildReportPeriod($get);

        $orderQuery = (new Query())
            ->from('xhDistributionOrder')
            ->where(['shopId' => $shopId])
            ->andWhere(['>', 'distId', 0]);
        if ($period) {
            $orderQuery->andWhere(['between', 'orderTime', $period[0], $period[1]]);
        }
        if ($keyword !== '') {
            $orderQuery->innerJoin(['c' => 'xhCustom'], 'c.id = xhDistributionOrder.distId')
                ->andWhere([
                    'or',
                    ['like', 'c.name', $keyword],
                    ['like', 'c.mobile', $keyword],
                ]);
        }

        $subQuery = (clone $orderQuery)
            ->select([
                'distId',
                'orderCount' => 'COUNT(*)',
                'commissionAmount' => 'SUM(commissionAmount)',
                'distName' => 'MAX(distName)',
            ])
            ->groupBy('distId');

        $total = (int)(new Query())->from(['t' => $subQuery])->count('*', Yii::$app->db);
        $totalPage = $pageSize > 0 ? (int)ceil($total / $pageSize) : 0;
        $rows = (new Query())
            ->from(['t' => $subQuery])
            ->orderBy(['commissionAmount' => SORT_DESC, 'distId' => SORT_DESC])
            ->offset(($page - 1) * $pageSize)
            ->limit($pageSize)
            ->all(Yii::$app->db);

        $distIds = [];
        foreach ($rows as $row) {
            $distIds[] = (int)$row['distId'];
        }
        $avatarMap = [];
        if (!empty($distIds)) {
            // groupBaseInfo 仅处理头像，需先 getCustomByIds 拉取 name/mobile
            foreach (CustomClass::getCustomByIds($distIds) as $customItem) {
                $avatarMap[(int)$customItem['id']] = $customItem;
            }
        }

        $list = [];
        foreach ($rows as $row) {
            $distId = (int)$row['distId'];
            $custom = $avatarMap[$distId] ?? [];
            $list[] = [
                'customId' => $distId,
                'name' => $custom['name'] ?? ($row['distName'] ?? ''),
                'mobile' => $custom['mobile'] ?? '',
                'smallAvatar' => $custom['smallAvatar'] ?? '',
                'orderCount' => (int)$row['orderCount'],
                'commissionAmount' => round((float)$row['commissionAmount'], 2),
            ];
        }

        return [
            'list' => $list,
            'totalPage' => $totalPage,
            'moreData' => $page < $totalPage ? 1 : 0,
        ];
    }

    /**
     * 门店拉新明细（报表跳转）
     * @param int $shopId
     * @return array
     */
    public static function getShopInviteList($shopId)
    {
        $shopId = (int)$shopId;
        $get = Yii::$app->request->get();
        $keyword = isset($get['keyword']) ? trim($get['keyword']) : '';
        $page = isset($get['page']) ? max(1, (int)$get['page']) : 1;
        $pageSize = isset($get['pageSize']) && (int)$get['pageSize'] > 0
            ? (int)$get['pageSize']
            : (int)Yii::$app->params['pageSize'];
        $period = self::buildReportPeriod($get);

        $query = (new Query())
            ->from(['du' => 'xhDistributionUser'])
            ->leftJoin(['c' => 'xhCustom'], 'c.id = du.id')
            ->leftJoin(['inv' => 'xhCustom'], 'inv.id = du.inviterId')
            ->where(['du.shopId' => $shopId])
            ->andWhere(['>', 'du.inviterId', 0])
            ->select([
                'du.id',
                'du.inviterId',
                'du.inviteTime',
                'du.upOrderCount',
                'du.upCommissionAmount',
                'c.name',
                'c.mobile',
                'c.avatar',
                'inv.name AS inviterName',
                'inv.mobile AS inviterMobile',
            ]);

        if ($period) {
            $query->andWhere(['between', 'du.inviteTime', $period[0], $period[1]]);
        }
        if ($keyword !== '') {
            $query->andWhere([
                'or',
                ['like', 'c.name', $keyword],
                ['like', 'c.mobile', $keyword],
                ['like', 'inv.name', $keyword],
            ]);
        }

        $total = (int)(clone $query)->count('*', Yii::$app->db);
        $totalPage = $pageSize > 0 ? (int)ceil($total / $pageSize) : 0;
        $rows = $query
            ->orderBy(['du.inviteTime' => SORT_DESC, 'du.id' => SORT_DESC])
            ->offset(($page - 1) * $pageSize)
            ->limit($pageSize)
            ->all(Yii::$app->db);

        $customRows = [];
        foreach ($rows as $row) {
            $customRows[] = [
                'id' => (int)$row['id'],
                'name' => $row['name'] ?: '',
                'mobile' => $row['mobile'] ?: '',
                'avatar' => $row['avatar'] ?: '',
            ];
        }
        $avatarMap = [];
        if (!empty($customRows)) {
            foreach (CustomClass::groupBaseInfo($customRows) as $customItem) {
                $avatarMap[(int)$customItem['id']] = $customItem;
            }
        }

        $list = [];
        foreach ($rows as $row) {
            $custom = $avatarMap[(int)$row['id']] ?? [];
            $bindTime = $row['inviteTime'];
            $list[] = [
                'customId' => (int)$row['id'],
                'inviterId' => (int)$row['inviterId'],
                'inviterName' => $row['inviterName'] ?: '',
                'inviterMobile' => $row['inviterMobile'] ?: '',
                'name' => $custom['name'] ?? ($row['name'] ?: ''),
                'mobile' => $custom['mobile'] ?? ($row['mobile'] ?: ''),
                'smallAvatar' => $custom['smallAvatar'] ?? '',
                'bindTime' => $bindTime,
                'bindDaysText' => self::buildBindDaysText($bindTime),
                'contribCommission' => round((float)$row['upCommissionAmount'], 2),
                'contribOrderCount' => (int)$row['upOrderCount'],
            ];
        }

        return [
            'list' => $list,
            'totalPage' => $totalPage,
            'moreData' => $page < $totalPage ? 1 : 0,
        ];
    }

    /** 报表页时间范围 */
    protected static function buildReportPeriod($get)
    {
        $searchTime = isset($get['searchTime']) ? trim($get['searchTime']) : 'today';
        $startTime = isset($get['startTime']) ? trim($get['startTime']) : '';
        $endTime = isset($get['endTime']) ? trim($get['endTime']) : '';
        $period = dateUtil::formatTime($searchTime, $startTime, $endTime);
        if (empty($period['startTime']) || empty($period['endTime'])) {
            return null;
        }
        return [$period['startTime'], $period['endTime']];
    }

    /** 计算绑定天数 */
    protected static function calcBindDays($bindTime)
    {
        if (empty($bindTime) || $bindTime === '0000-00-00 00:00:00') {
            return 0;
        }
        $time = strtotime($bindTime);
        if ($time <= 0) {
            return 0;
        }
        return max(0, (int)floor((time() - $time) / 86400));
    }

    /** 绑定天数文案 */
    protected static function buildBindDaysText($bindTime)
    {
        $days = self::calcBindDays($bindTime);
        return '已绑定' . $days . '天';
    }
}