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['keywords']) && !empty($search['keywords'])){
            $where[] = ['keywords', '=', $search['keywords']];
        }
        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;
        }

        if($gameplayRuleInfo['odds'] <= 0){
            $text = "赔率为0 庄家通吃 禁止投注！\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]);

        $betInfo = self::findOne(['member_id' => $memberId,'issue_no' => $issueInfo->issue_no,'keywords' => $keywords]); // 相同下注

        if($betInfo){
            $betInfo->amount = $betInfo->amount + $amount;
            $bet_id = $betInfo->id;
            $betInfo->save();
        }else{
            $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);
            $bet_id = $newBet->id;
        }
        

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

        BalanceLogService::addLog($memberId,-$amount,$balance,($balance-$amount),'投注',$bet_id,'');

        // // 返利
        // $rebate = Config::where('field', 'rebate')->first()->val;
        // if($rebate > 0){
        //     $rebateAmount = bcmul($amount, $rebate, 2); // 返利金额
        //     if($rebateAmount > 0){
        //         WalletService::updateBalance($memberId,$rebateAmount);

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

        //         BalanceLogService::addLog($memberId,$rebateAmount,$balance,($balance+$rebateAmount),'返水',$bet_id,'');
        //     }

        // }

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

        $lastStr = self::getLastChar($userInfo->first_name,1);

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

        
        $inlineButton = self::getOperateButton();
        
         // 群通知
        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();
        $issue_no = '';
        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){
            $profit = $v['profit'] - $v['amount'];
            // $text .= $v['issue_no']." ".$v['keywords']." ".$v['amount']." ".$v['profit']."\n";
            $item = $v['issue_no']."==".$v['keywords'].rtrim(rtrim(number_format($v['amount'], 2, '.', ''), '0'), '.')."==".rtrim(rtrim(number_format($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){
            $phase = $v->profit - $v->amount;
            $text .= "-------------------------------------\n";
            $text .= "期数：{$v->issue_no} \n";
            $text .= "内容：{$v->keywords} \n";
            $text .= "金额：{$v->amount} \n";
            $text .= "盈亏：{$phase} \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 = [];
        $text = $issue_no."期开奖结果 \n";
        $text .= "-----本期开奖账单----- \n";

        $bet_num = 0;
        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'];
                if($profit > 880000){
                    $profit = 880000; // 单注最高奖金880000
                }
                $item['profit'] = $profit;

                $yl = $profit - $v['amount'];
                if($k+1 <= 15){
                    $text .= "私聊下注 【******】 {$yl}\n";
                    $bet_num++;
                }
                // 结算
                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'],'');
            }else{
                if($k+1 <= 15){
                    $text .= "私聊下注 【******】 -{$v['amount']}\n";
                    $bet_num++;
                }
            }

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

        $rand_num = 30 - $bet_num;
        for($i=0;$i<$rand_num;$i++){
            // 生成 -100000 到 100000 的随机数，但排除 -10 到 10 的范围
            $randomNumber = random_int(-1000000, 1000000) / 100;
            if ($randomNumber >= -10 && $randomNumber <= 10) {
                // 如果落在 -10 到 10 之间，重新生成或调整
                $randomNumber = $randomNumber < 0 ? -random_int(10, 100000) : random_int(10, 100000);
            }
            $text .= "私聊下注 【******】 {$randomNumber}\n";
        }

         // 群通知
        self::bettingGroupNotice($text, $inlineButton, '');
    }
}