<?php

namespace App\Repositories\Deposit;

use App\Interfaces\Deposit\DepositRepositoryInterface;
use App\Models\Deposit\Deposit;
use App\Models\User\User;
use Illuminate\Support\Facades\DB;

class DepositRepository implements DepositRepositoryInterface
{
    /**
     * @var Deposit
     */
    protected $deposit;

    /**
     * DepositRepository constructor.
     *
     */
    public function __construct()
    {
        $this->deposit = new Deposit();
    }

    public function get() {

        $deposit = Deposit::query();

        $deposit->with('currency.file');

        $deposit->has('currency');

        $deposit->orderBy('created_at', 'desc');

        $deposit->limit(10);

        return $deposit->get();
    }

    public function getReport() {

        $deposit = Deposit::query();

        $deposit->filter(request()->only(['search', 'type', 'referrer']))->orderByLatest();

        $deposit->has('currency')->has('user');

        $deposit->with(['currency', 'network', 'user']);

        return $deposit->paginate(50)->withQueryString();
    }

    public function getStatReport($period) {
        return DB::table('deposits')
            ->selectRaw('currencies.symbol as name, SUM(deposits.amount) as volume, SUM(deposits.system_fee) as income, COUNT(*) as total')
            ->join('currencies', 'currencies.id', 'deposits.currency_id')
            ->where('deposits.status', DEPOSIT_CONFIRMED)
            ->whereBetween('deposits.created_at', $period)
            ->groupByRaw('currencies.symbol')->get();
    }

    public function getReportUser(User $user, $pagination = true, $limit = 1000, $start = false, $end = false, $simplePagination = false) {

        $deposit = Deposit::query();

        $deposit->filterUser(request()->only(['currency','txn','status']))->orderByLatest();

        $deposit->has('currency');

        $deposit->with(['currency.file']);

        $deposit->where('status', '!=', DEPOSIT_IGNORED);

        $deposit->where('user_id', $user->id);

        if($start && $end) {
            $deposit->whereBetween('created_at', [$start, $end]);
        }

        if($simplePagination) {
            return $deposit->simplePaginate($limit);
        }

        if(!$pagination) {

            if($limit == 0 || $limit > 1000)
                $limit = 1000;

            $deposit->limit($limit);
            return $deposit->get();
        }

        return $deposit->paginate(50)->withQueryString();
    }

    public function count() {

        $deposit = Deposit::query();

        return $deposit->count();
    }

    public function getDeposit($id) {
        return Deposit::with('currency')->whereId($id)->first();
    }

    public function store($data) {
        return $this->deposit->create($data);
    }

    public function update($deposit, $data) {
        return $deposit->update($data);
    }

    public function getBySource($source_id, $network) {
        return Deposit::with('currency')->where('source_id', $source_id)->where('network_id', $network)->first();
    }

    public function getByTxn($txn, $network) {
        return Deposit::with('currency')->where('txn', $txn)->where('network_id', $network)->first();
    }

    public function getByNetwork($network, $status = 'pending') {
        return Deposit::with('currency')->whereStatus($status)->where('network_id', $network)->get();
    }

    public function getByNetworks($networks, $status = 'pending') {

        return Deposit::with('currency')->whereStatus($status)->where(function ($query) use ($networks) {
            $query->where('network_id', $networks[0]);
            $query->orWhere('network_id', $networks[1]);
        })->get();
    }
}