<?php

namespace addons\shopro\service\partner;

use app\admin\model\shopro\order\Order as OrderModel;

/**
 * 30 日活跃：含今天共 N 个自然日有本人合格订单
 */
class ActiveService
{
    public function windowStart($endTime = null)
    {
        $days = PartnerConfig::activeDays();
        $end = $endTime ?: time();
        $endDay = strtotime(date('Y-m-d 00:00:00', $end));
        return $endDay - ($days - 1) * 86400;
    }

    public function isActive($agent, $atTime = null)
    {
        if (!$agent) {
            return false;
        }
        $last = is_array($agent) ? ($agent['last_self_order_time'] ?? null) : ($agent->last_self_order_time ?? null);
        $userId = is_array($agent) ? ($agent['user_id'] ?? 0) : ($agent->user_id ?? 0);
        $at = $atTime ?: time();
        $start = $this->windowStart($at);

        if ($last) {
            return intval($last) >= $start;
        }
        if (!$userId) {
            return false;
        }
        return $this->hasQualifiedOrder($userId, $start, $at);
    }

    public function hasQualifiedOrder($userId, $start, $end)
    {
        $order = OrderModel::where('user_id', $userId)
            ->where('type', '<>', 'score')
            ->where('pay_fee', '>', 0)
            ->paid()
            ->where('paid_time', '>=', $start)
            ->where('paid_time', '<=', $end)
            ->find();
        return (bool) $order;
    }

    public function activeUserIds($start, $end, $extraWhere = [])
    {
        $createBaseQuery = function () use ($extraWhere) {
            $q = \think\Db::name('shopro_commission_agent')
                ->where('status', 'in', ['normal', 'freeze'])
                ->where('level', '>=', 1);
            foreach ($extraWhere as $field => $value) {
                $q->where($field, $value);
            }
            return $q;
        };

        // 1. 优先通过 last_self_order_time 索引快速命中
        $hitUserIds = $createBaseQuery()->where(function ($q) use ($start, $end) {
            $q->where('last_self_order_time', '>=', $start)
                ->where('last_self_order_time', '<=', $end);
        })->column('user_id');

        // 2. 容错：查找 last_self_order_time 为空或为 0 的代理商
        $nullUserIds = $createBaseQuery()->where(function ($q) {
            $q->whereNull('last_self_order_time')->whereOr('last_self_order_time', 0);
        })->column('user_id');

        if (!empty($nullUserIds)) {
            $orderHits = \think\Db::name('shopro_order')
                ->whereIn('user_id', $nullUserIds)
                ->where('type', '<>', 'score')
                ->where('pay_fee', '>', 0)
                ->whereIn('status', ['paid', 'completed'])
                ->where('paid_time', '>=', $start)
                ->where('paid_time', '<=', $end)
                ->group('user_id')
                ->column('max(paid_time)', 'user_id');

            foreach ($orderHits as $uId => $lastTime) {
                \think\Db::name('shopro_commission_agent')->where('user_id', $uId)->update(['last_self_order_time' => $lastTime]);
                $hitUserIds[] = intval($uId);
            }
        }

        return array_values(array_unique(array_map('intval', $hitUserIds)));
    }
}