bot-28/app/Services/BalanceLogService.php

<?php

namespace App\Services;

use App\Models\BalanceLog;

// 余额额变动记录
class BalanceLogService extends BaseService
{
    public static string $MODEL = BalanceLog::class;
    //后台充值可选择的类型
    public static array $manualRecharge = ['人工充值', '注册赠送', '优惠活动'];
    //需要计算回水的类型
    public static array $computeBackFlowChangeTypes = ['充值', '人工充值', '三方充值', '提现', '人工扣款', '三方提现'];
    //全部类型
    public static array $RW = [
        '充值', '人工充值', '三方充值', '注册赠送', '优惠活动',
        '提现', '人工扣款', '三方提现', 
        '体彩投注','体彩退款','体彩和局退款','体彩中奖',
        '六合彩投注','六合彩退款','六合彩和局退款','六合彩中奖','PC28投注','极速28投注',
        '投注','中奖', '资产转移', '比比返', '返水', '回水', '笔笔返', '投注退分'
    ];

    public static function init($telegram, $data, $chatId, $firstName, $messageId, $callbackId): void
    {
        switch ($data) {
            case"todayFlowAlert":// 今日流水弹窗
                $alertText = BalanceLogService::getTodayFlowing($chatId)['text'];
                BalanceLogService::alertNotice($callbackId, $alertText);
                break;
            default:
                //流水列表，下一页
                $pattern = "/^FlowingHistoryPage@@\d+$/";
                if (preg_match($pattern, $data)) {
                    $page = preg_replace('/^FlowingHistoryPage@@/', '', $data);
                    $page = intval($page);
                    $returnMsg = BalanceLogService::getFlowingHistory($chatId, $messageId, $page);
                    $telegram->editMessageText($returnMsg);
                }
                break;
        }
    }


    /**
     * @description: 获取查询条件
     * @param {array} $search 查询内容
     * @return {array}
     */
    public static function getWhere(array $search = []): array
    {
        $where = [];
        if (isset($search['coin']) && !empty($search['coin'])) {
            $where[] = ['coin', '=', $search['coin']];
        }
        if (isset($search['net']) && !empty($search['net'])) {
            $where[] = ['net', '=', $search['net']];
        }
        if (isset($search['address']) && !empty($search['address'])) {
            $where[] = ['address', '=', $search['address']];
        }
        if (isset($search['id']) && !empty($search['id'])) {
            $where[] = ['id', '=', $search['id']];
        }
        if (isset($search['member_id']) && !empty($search['member_id'])) {
            $where[] = ['member_id', '=', $search['member_id']];
        }

        if (isset($search['change_type']) && !empty($search['change_type'])) {
            $where[] = ['change_type', '=', $search['change_type']];
        }

        if (isset($search['start_time']) && !empty($search['start_time'])) {
            $where[] = ['created_at', '>=', "{$search['start_time']} 00:00:00"];
            $where[] = ['created_at', '<=', "{$search['end_time']} 23:59:59"];
        }

        return $where;
    }

    /**
     * @description: 查询单条数据
     * @param array $search
     * @return \App\Models\Coin|null
     */
    public static function findOne(array $search): ?BalanceLog
    {
        return static::model()::where(static::getWhere($search))->first();
    }

    /**
     * @description: 查询所有数据
     * @param array $search
     * @return \Illuminate\Database\Eloquent\Collection
     */
    public static function findAll(array $search = [])
    {
        return static::model()::where(static::getWhere($search))->get();
    }

    /**
     * @description: 分页查询
     * @param array $search
     * @return array
     */
    public static function paginate(array $search = []): array
    {

        $limit = isset($search['limit']) ? $search['limit'] : 15;
        $paginator = static::model()::where(static::getWhere($search))
            ->when(isset($search['change_types']) && !empty($search['change_types']), function ($query) use ($search) {
                return $query->whereIn('change_type', $search['change_types']);
            })
            ->orderBy('updated_at', 'desc')
            ->paginate($limit);
        return ['total' => $paginator->total(), 'data' => $paginator->items()];
    }

    /**
     * @description: 生成资金变动日志
     * @param {*} $memberId
     * @param {*} $amount
     * @param {*} $before_balance
     * @param {*} $after_balance
     * @param {*} $change_type
     * @param {*} $related_id
     * @param {*} $remark
     * @return {*}
     */
    public static function addLog($memberId, $amount, $before_balance, $after_balance, $change_type, $related_id, $remark, $room_id = null)
    {
        //回水相关
        if (in_array($change_type, static::$computeBackFlowChangeTypes)) {
            BackflowService::updateOrCreate((string)$memberId, floatval($amount));
        }


        $data = [];
        $data['member_id'] = $memberId;
        $data['amount'] = $amount;
        $data['before_balance'] = $before_balance;
        $data['after_balance'] = $after_balance;
        $data['change_type'] = $change_type;
        $data['related_id'] = $related_id;
        $data['remark'] = $remark;
        if ($room_id) $data['room_id'] = $room_id;
        return static::$MODEL::create($data);
    }

    /**
     * @description: 获取今日流水
     * @param int $memberId
     * @param string|null $date
     * @return {*}
     */
    public static function getTodayFlowing($memberId, $date = null)
    {
        if (!$date) {
            $date = date('Y-m-d');
        }
        $startTime = date('Y-m-d H:i:s', strtotime($date . ' 00:00:00'));
        $endTime = date('Y-m-d H:i:s', strtotime($date . ' 23:59:59'));


        $flow = static::model()::where('member_id', $memberId)
            ->whereBetween('created_at', [$startTime, $endTime])
            ->where('change_type', '投注')
            ->sum('amount');
        $refund = static::model()::where('member_id', $memberId)
            ->whereBetween('created_at', [$startTime, $endTime])
            ->where('change_type', '返水')
            ->sum('amount');

        $profit = static::model()::where('member_id', $memberId)
            ->whereBetween('created_at', [$startTime, $endTime])
            ->where('change_type', '中奖') //嬴正数 输负数
            ->sum('amount');

        $walletInfo = WalletService::model()::where('member_id', $memberId)->first();
        $text = '';
        $text .= "当日流水: " . number_format((0 - $flow), 2) . "\n";
        $text .= "返水额度: " . number_format($refund, 2) . "\n";
        $text .= "当日盈亏: " . number_format(($profit + $refund + $flow), 2) . "\n";
        $text .= "余额: " . number_format($walletInfo['available_balance'], 2) . "\n";
        return [
            'chat_id' => $memberId,
            'text' => $text
        ];
    }

    public static function getFlowingHistory($memberId, $messageId = null, $page = 1, $limit = 5)
    {
        $dateTime = date('Y-m-d 00:00:00');
        $list = [];
        for ($i = 0; $i < $limit; $i++) {
            $newIndex = ($page - 1) * $limit + $i;
            $date = date('Y-m-d', strtotime($dateTime . " -{$newIndex} day"));
            $startTime = date('Y-m-d H:i:s', strtotime($date . ' 00:00:00'));
            $endTime = date('Y-m-d H:i:s', strtotime($date . ' 23:59:59'));


            $flow = static::model()::where('member_id', $memberId)
                ->whereBetween('created_at', [$startTime, $endTime])
                ->where('change_type', '投注')
                ->sum('amount');
            $refund = static::model()::where('member_id', $memberId)
                ->whereBetween('created_at', [$startTime, $endTime])
                ->where('change_type', '返水')
                ->sum('amount');

            $profit = static::model()::where('member_id', $memberId)
                ->whereBetween('created_at', [$startTime, $endTime])
                ->where('change_type', '中奖') //嬴正数 输负数
                ->sum('amount');

            $list[] = [
                'date' => $date,
                'flow' => number_format($flow, 2),
                'refund' => number_format($refund, 2),
                'profit' => number_format(($profit + $refund + $flow), 2)
            ];
        }
        // $startTime = date('Y-m-d H:i:s',strtotime($date . ' 00:00:00'));
        // $endTime = date('Y-m-d H:i:s',strtotime($date . ' 23:59:59'));


        // $list = static::model()::where('member_id', $memberId)
        //     ->whereBetween('created_at', [$startTime, $endTime])
        //     ->orderBy('created_at', 'desc')
        //     ->get();

        $text = lang("流水历史") . " \n";
        foreach ($list as $item) {
            $text .= "---------------------\n";
            $text .= lang("日期") . "： {$item['date']} \n";
            $text .= lang("流水") . "： {$item['flow']} \n";
            $text .= lang("返水") . "： {$item['refund']} \n";
            $text .= lang("盈利") . "： {$item['profit']} \n";
        }

        $keyboard = [[
            ['text' => "👇" . lang("下一页"), 'callback_data' => "FlowingHistoryPage@@" . ($page + 1)]
        ]];
        if ($page > 1) {
            array_unshift($keyboard[0], ['text' => "👆" . lang("上一页"), 'callback_data' => "FlowingHistoryPage@@" . ($page - 1)]);
        }
        return [
            'chat_id' => $memberId,
            'text' => $text,
            'message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard]),
        ];
    }

}