sports_dapi/app/Logic/UnSettmatchLogic.php

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/7/15
 * Time: 16:51
 */

namespace App\Logic;

use App\Models\Account;
use Illuminate\Database\Capsule\Manager as DB;
use datainf\pplus\Instance;
use datainf\lib\GlobConfigs;

use App\Lib\ModelBase;
use App\Http\Response\Response;
use App\Models\SportsNoteList as MoneyBuySimplexModel;
use App\Models\MoneyBuyStr as MoneyBuyStrModel;
use App\Models\MoneyBuyMatch as MoneyBuyMatchModel;
use App\Models\Money_details as MoneyDetailsModel;
use App\Models\Setinfo as SetinfoModel;


//按赛事撤销操作(批量优化版)
class UnSettmatchLogic
{
    use Instance;
    protected $redis = '';
    private $fanshui = 0.1;       //默认返水比例

    protected $game_code = '';
    protected $match_id = 0;
    protected $resultObj = ''; //比赛结果记录对像

    public function doUnsetMatch($request, $response, $datas)
    {
        $match_id = isset($datas['match_id']) ? intval($datas['match_id']) : 0;
        $game_code = isset($datas['game_code']) ? trim($datas['game_code']) : '';
        $result = $this->getResult($game_code, $match_id);

        if (empty($match_id) || empty($game_code) || empty($result) || !in_array($game_code, ['zq', 'lq', 'bq', 'wq'])) {
            $msg = date("Y-m-d H:i:s") . " 取消赛事处理--参数错误!\n";
            $this->backandret($response, 0, $msg, $datas);
            return false;
        }
        $this->game_code = $game_code;
        $this->match_id = $match_id;
        $this->resultObj = $request;

        if (!in_array($result->status, [3])) {
            $msg = date("Y-m-d H:i:s") . " 取消赛事处理--数据状态值不为[3]!\n";
            $this->backandret($response, 0, $msg, $datas);
            return false;
        }

        if ($this->optFlag($game_code, $match_id, 2)) {
            $msg = date("Y-m-d H:i:s") . " 正在处理中，不能重复提交!\n";
            $this->backandret($response, 0, $msg, $datas);
            return false;
        }

        $this->getFanshui();
        $this->optFlag($game_code, $match_id, 1);
        $msg = date("Y-m-d H:i:s") . " 取消赛事处理--开始begin：game_code= $game_code  match_id= $match_id \n";
        $this->backandret($response, 1, $msg, $datas, 1);

        DB::beginTransaction();
        try {
            $this->doSimple();
            $this->doStr();
            $this->changeStatus($game_code, $match_id);

            DB::commit();
        } catch (\Exception $e) {

            DB::rollBack();

            $this->optFlag($game_code, $match_id, 0);
            $msg = date("Y-m-d H:i:s") . " 取消赛事处理--异常结束：game_code= $game_code  match_id= $match_id Emsg: " . $e->getMessage();
            $this->backandret($response, 0, '撤单失败!' . $msg, $datas);
            return;
        }

        $this->optFlag($game_code, $match_id, 0);
        $msg = date("Y-m-d H:i:s") . " 取消赛事处理--结束end：game_code= $game_code  match_id= $match_id \n";
        $this->backandret($response, 1, '撤销成功!' . $msg, []);
        return;
    }

    //返回消息和写日志
    public function backandret($response, $code, $msg, $data, $onlylog = 0)
    {
        $dataRet = Response::generate('', $code, $data, $msg);
        echo $dataRet . "\n";
        if ($onlylog) {
            return;
        }
        $response->end($dataRet);
        return;
    }

    //得到返水的比例
    public function getFanshui()
    {
        $ret = (new SetinfoModel())->getInfo(1001);
        if (is_array($ret)) {
            $val = floatval($ret->infocontent);
            $this->fanshui = $val;
            return $val;
        }
    }

    //处理单式订单相关逻辑
    public function doSimple()
    {
        $simples = $this->getSimpleOrders($this->game_code, $this->match_id);
        if (empty($simples)) {
            return;
        }
        $useraccs = [];
        foreach ($simples as $item) {
            if (!isset($useraccs[$item->account_identity])) {
                $useraccs[$item->account_identity] = $item->account_identity;
            }
        }
        //关联用户
        $userInents = $this->getAccountIdents($useraccs);
        //用户资金变化记录，以后好一次性更新用户余额
        $userInents_money = [];
        foreach ($simples as $item) {
            $gain_money = $item->gain_money;
            if ($gain_money <= 0.01) {
                $return_money = $item->money * (1 - $this->fanshui);
            } else {
                $return_money = $gain_money - $item->money * (1 - $this->fanshui);
            }


        }


    }


    //处理串式订单相关逻辑
    public function doStr()
    {
        $simples = $this->getStrOrders($this->game_code, $this->match_id);
        if (empty($simples)) {
            return;
        }


    }

    //得到某个账户的信息，主要是余额情况
    public function getAccountIdents($account_identity_array)
    {
        $model = new Account();
        $ret = [];
        $return = $model->with('detail')->whereIn('identity', $account_identity_array)->get();
        if ($return) {
            foreach ($return as $item) {
                $ret[$item->identity] = $item;
            }
        }
        return $ret;
    }


    public function changeStatus($game_code, $match_id)
    {
        $table = 'st_' . $game_code . '_result';
        $ret = DB::name($table)->where('match_id', $match_id)->update(['status' => 4]);
        return $ret;
    }

    //得到比赛结果 ，看是不已结算等信息
    public function getResult($game_code, $match_id)
    {
        $table = 'st_' . $game_code . '_result';
        $ret = DB::table($table)->where(['match_id', $match_id])->first();
        return $ret;
    }

    //得到 有此赛事的单式订单
    public function getSimpleOrders($game_code, $match_id)
    {
        $model = new MoneyBuySimplexModel();
        $rets = $model->with('matchdatas')->where(['game_code' => $game_code, 'match_id' => $match_id])->get();
        return $rets;
    }

    //得到 有此赛事的串式订单
    public function getStrOrders($game_code, $match_id)
    {
        $model = new MoneyBuyStrModel();
        $model2 = new MoneyBuyMatchModel();
        $rets2 = $model2->getByAttrs(['match_id' => $match_id, 'bet_type' => 2, 'game_code' => $game_code]);
        $orders = [];
        if ($rets2) {
            foreach ($rets2 as $item) {
                $orders[] = $item->order_id;
            }
        } else {
            return [];
        }

        $rets = $model->with('matchdatas')->where(['game_code' => $game_code, 'match_id' => $match_id])->whereIn('order_id', $orders)->get();
        return $rets;
    }

    //获取相关的订单费用及系统赚送的钱(用于返还)
    public function getMoneyDetail($ordesArray)
    {
        $model = new MoneyDetailsModel();
        $ret = $model->whereIn('trace_id', $ordesArray)->get();
        return $ret;
    }

    //设置操作标志位，防止事务未处理完，再次提交的情况
    //opt 0删除  1设置 2查询
    public function optFlag($game_code, $match_id, $opt = 2)
    {
        $key = 'Unsetmatch:' . $game_code . '_' . $match_id;
        $redis = $this->getRedis();
        if ($opt == 0) {
            $redis->del($key);
            return true;
        }
        if ($opt == 1) {
            $redis->setex($key, 300, time());
            return;
        }

        if ($opt == 2) {
            $ret = $redis->get($key);
            return $ret;
        }
    }

    public function getRedis()
    {
        if ($this->redis) {
            return $this->redis;
        }
        $config = GlobConfigs::getKey('redis');
        $redis = new \Redis();
        $redis->connect($config['host'], $config['port']);
        $redis->auth($config['auth']);
        $redis->select($config['db']);

        $this->redis = $redis;
        return $redis;
    }


}