bot-28/app/Services/BetService.php

<?php


namespace App\Services;

use App\Services\BaseService;
use App\Models\Bet;
use App\Models\Config;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Log;

use App\Services\GameplayRuleService;
use App\Services\WalletService;
use App\Services\IssueService;
use App\Services\UserService;
use App\Services\BalanceLogService;

/**
 * 投注
*/
class BetService extends BaseService 
{
    /**
     * @description: 模型
     * @return {string}
     */    
    public static function model() :string
    {
        return Bet::class;
    }

    /**
     * @description: 枚举
     * @return {*}
     */    
    public static function enum() :string
    {
        return '';
    }

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

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

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

    /**
     * @description: 分页查询
     * @param array $search
     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
     */
    public static function paginate(array $search = [])
    {
        $limit = isset($search['limit'])?$search['limit']:15;
        $paginator = self::model()::where(self::getWhere($search))->paginate($limit);
        return ['total' => $paginator->total(), 'data' => $paginator->items()];
    }

    /**
     * @description: 投注操作
     * @param {string} $memberId
     * @param {string} $input
     * @return {*}
     */    
    public static function bet(string $memberId,string $input ,$messageId = 0)
    {
        $msg = [];
        $msg['chat_id'] = $memberId;

        // 钱包生成
        // $walletInfo = WalletService::getUserWallet($memberId);
        

        // 分解投注的内容
        $betResult = GameplayRuleService::bettingRuleVerify($input);

        $serviceAccount = Config::where('field', 'service_account')->first()->val;
        if($betResult == null){
            $text = "消息格式错误！\n";
            $text .= "任何疑问都可以联系唯一财务：@{$serviceAccount}";
            $msg['text'] = $text;
            if($messageId){
                $msg['reply_to_message_id'] = $messageId;
            }
            return $msg;
        }

        $keywords = $betResult['rule'];  // 玩法
        $amount = $betResult['amount'];    // 投注金额

        $gameplayRuleInfo = GameplayRuleService::getGameplayRules($keywords);
        if($gameplayRuleInfo == null){
            $text = "玩法未配置！\n";
            $text .= "任何疑问都可以联系唯一财务：@{$serviceAccount}";
            $msg['text'] = $text;
            if($messageId){
                $msg['reply_to_message_id'] = $messageId;
            }
            return $msg;
        }

        // 期数验证
        $issueInfo = IssueService::model()::where('status',IssueService::model()::STATUS_BETTING)->orderBy('id','desc')->first();
        if(empty($issueInfo)){
            $issueCloseInfo = IssueService::model()::where('status',IssueService::model()::STATUS_CLOSE)->orderBy('id','desc')->first();
            if(empty($issueCloseInfo)){
                $text = "暂无可下注期数，本次下注无效！\n";

                $msg['text'] = $text;
                if($messageId){
                    $msg['reply_to_message_id'] = $messageId;
                }
                return $msg;
            }else{
                $text = "封盘中，本次下注无效！\n";

                $msg['text'] = $text;
                if($messageId){
                    $msg['reply_to_message_id'] = $messageId;
                }
                return $msg;
            }
        }


        if(!is_numeric($amount) || $amount <= 0){
            $text = "投注金额格式不正确！\n";
            $text .= "任何疑问都可以联系唯一财务：@{$serviceAccount}";
            $msg['text'] = $text;
            if($messageId){
                $msg['reply_to_message_id'] = $messageId;
            }
            return $msg;
        }

        // 投注限制校验
        if($amount < $gameplayRuleInfo['mininum']){
            $text = "下注失败，最小金额限制{$gameplayRuleInfo['mininum']}\n";
            $msg['text'] = $text;
            if($messageId){
                $msg['reply_to_message_id'] = $messageId;
            }
            return $msg;
        }

        // 投注限制校验
        if($amount > $gameplayRuleInfo['maxinum']){
            $text = "下注失败，最大金额限制{$gameplayRuleInfo['maxinum']}\n";
            $msg['text'] = $text;
            if($messageId){
                $msg['reply_to_message_id'] = $messageId;
            }
            return $msg;
        }

        // 获取用户余额
        $walletInfo = WalletService::findOne(['member_id' => $memberId]);
        $balance = $walletInfo['available_balance']; 

        // 余额计算
        if($balance < $amount){
            $text = "余额不足，本次下注无效！\n";
            $msg['text'] = $text;
            if($messageId){
                $msg['reply_to_message_id'] = $messageId;
            }
            return $msg;
        }


        

        $userInfo = UserService::findOne(['member_id' => $memberId]);

        $data = [];
        $data['amount'] = $amount; // 分数
        $data['keywords'] = $keywords;  // 玩法
        $data['member_id'] = $memberId; 
        $data['user_id'] = $userInfo->id; 
        $data['issue_no'] = $issueInfo->issue_no; 
        $data['issue_id'] = $issueInfo->id; 
        $data['odds'] = $gameplayRuleInfo['odds'];
        $newBet = self::model()::create($data);

        WalletService::updateBalance($memberId,-$amount);

        BalanceLogService::addLog($memberId,-$amount,$balance,($balance-$amount),'投注',$newBet->id,'');

        $text = "下注期数：{$issueInfo->issue_no}\n";
        $text .= "下注内容\n";
        $text .= "--------\n";
        $text .= "{$input}\n";
        $text .= "--------\n";
        $text .= "下注成功\n";
        $msg['text'] = $text;

        $groupText = "";
        $groupText .= "私聊下注 【xxxxxx】 \n";
        $groupText .= "下注期数：{$issueInfo->issue_no} \n";
        $groupText .= "下注内容： \n";
        $groupText .= "----------- \n";
        $groupText .= "{$input} \n";
        $groupText .= "----------- \n";

        $username = config('services.telegram.username');
        $serviceAccount = Config::where('field', 'service_account')->first()->val;
        $inlineButton = [];
        $inlineButton[] = [
            ['text' => "查看余额", 'callback_data' => 'balanceAlert'],
            ['text' => "✅唯一财务", 'url' => "https://t.me/{$serviceAccount}"]
        ];
        $inlineButton[] = [
            ['text' => "近期注单", 'callback_data' => 'betsAlert'],
            ['text' => "今日流水", 'callback_data' => 'todayFlowAlert']
        ];
        $inlineButton[] = [
            ['text' => "私聊下注", 'url' => "https://t.me/{$username}"]
        ];
        $inlineButton[] = [
            ['text' => "官方频道", 'url' => 'https://t.me/xxx']
        ];
         // 群通知
        self::bettingGroupNotice($groupText,$inlineButton);   // 群通知

        return $msg;
    }

    /**
     * @description: 当期下注
     * @param {*} $memberId
     * @return {*}
     */    
    public static function currentBet($memberId)
    {
        $msg['chat_id'] = $memberId;
         // 期数验证
        $issueInfo = IssueService::model()::where('status',IssueService::model()::STATUS_BETTING)->orderBy('id','desc')->first();
        if(!empty($issueInfo)){
            $issue_no = $issueInfo->issue_no;
        }else{
            $issueCloseInfo = IssueService::model()::where('status',IssueService::model()::STATUS_CLOSE)->orderBy('id','desc')->first();
            if(empty($issueCloseInfo)){
                $issue_no = $issueCloseInfo->issue_no;
            }
        }

        if($issue_no){
            $text = "当前期号：{$issue_no} \n";
            $text .= "\n";
            $text .= "----------\n";
            $list = self::findAll(['member_id' => $memberId ,'issue_no' => $issue_no]);
            foreach($list->toArray() as $k => $v){
                $text .= "{$v['keywords']}{$v['amount']} \n";
            }

            $text .= "\n";
            $text .= "----------\n";
            $msg['text'] = $text;
        }else{
            $msg['text'] = "当前没有开放的投注期数！ \n";
        }

        return $msg;
    }

    /**
     * @description: 近期投注
     * @param {*} $memberId
     * @return {*}
     */    
    public static function recentlyRecord($memberId ,$page = 1 ,$limit = 5)
    {
        $list = self::model()::where('member_id',$memberId)->whereIn('status',[self::model()::STATUS_STAY,self::model()::STATUS_SETTLED])->orderBy('id','desc')->forPage($page, $limit)->get();

        // $text = "```\n";
        $text = "";
        $text .= "内容--盈亏 \n";
        foreach($list->toArray() as $k => $v){
            // $text .= $v['issue_no']." ".$v['keywords']." ".$v['amount']." ".$v['profit']."\n";
            $item = $v['keywords'].rtrim(rtrim(number_format($v['amount'], 2, '.', ''), '0'), '.')."--".rtrim(rtrim(number_format($v['profit'], 2, '.', ''), '0'), '.')."\n";
            $text .= $item;
        }
        // $text .= "```\n";

        return $text;
    }


    /**
     * @description: 投注记录
     * @param {*} $memberId
     * @param {*} $page
     * @param {*} $limit
     * @return {*}
     */    
    public static function record($memberId ,$messageId = null ,$page = 1 ,$limit = 5)
    {
        $msg['chat_id'] = $memberId;
        $list = self::model()::where('member_id',$memberId)->whereIn('status',[self::model()::STATUS_STAY,self::model()::STATUS_SETTLED])->orderBy('id','desc')->forPage($page, $limit)->get();
        $count = self::model()::where('member_id',$memberId)->whereIn('status',[self::model()::STATUS_STAY,self::model()::STATUS_SETTLED])->count();

        $keyboard = [];

        $text = "历史注单 \n";

        foreach($list as $k => $v){
            $text .= "-------------------------------------\n";
            $text .= "期数：{$v->issue_no} \n";
            $text .= "内容：{$v->keywords} \n";
            $text .= "金额：{$v->amount} \n";
            $text .= "盈亏：{$v->profit} \n";
        }

        $msg['text'] = $text;

        if ($page > 1) {
            $keyboard[] = [
                ['text' => "👆上一页", 'callback_data' => "betRecordNextPage@@" . ($page - 1)]
            ];
        }
        $allPage = ceil($count / $limit);
        if ($allPage > $page) {
            if ($page > 1) {
                $keyboard[count($keyboard) - 1][] = ['text' => "👇下一页", 'callback_data' => "betRecordNextPage@@" . ($page + 1)];
            } else {
                $keyboard[] = [
                    ['text' => "👇下一页", 'callback_data' => "betRecordNextPage@@" . ($page + 1)]
                ];
            }
        }
        if($messageId){
            $msg['message_id'] = $messageId;
        }
        if($keyboard){
            $msg['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
        }
        return $msg;
    }

    /**
     * @description: 中奖结算
     * @param {*} $issue_no
     * @param {*} $awards
     * @return {*}
     */    
    public static function betSettled($issue_no,$awards)
    {
        $list = self::findAll(['issue_no' => $issue_no ,'status' => self::model()::STATUS_STAY]);

        $data = [];

        foreach($list->toArray() as $k => $v){
            $item = [];
            $item['id'] = $v['id'];
            $item['status'] =  self::model()::STATUS_SETTLED;

            if(in_array($v['keywords'],$awards)){
                $profit = $v['amount'] * $v['odds'];
                $item['profit'] = $profit;

                // 结算
                WalletService::updateBalance($v['member_id'],$profit);

                $walletInfo = WalletService::findOne(['member_id' => $v['member_id']]);
                $balance = $walletInfo['available_balance']; 

                BalanceLogService::addLog($v['member_id'],$profit,$balance,($balance+$profit),'中奖',$v['id'],'');
            }

            self::model()::where('id',$v['id'])->update($item);
        }

    }
}