sports_dapi/datainf/logic/HttpServerSettelement.php

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/6/26
 * Time: 12:03
 */

namespace datainf\logic;

use App\Lib\ModelBase;
use App\Http\Response\Response;

use App\Logic\WinfailLogic;
use datainf\lib\GlobConfigs;
use Illuminate\Database\Capsule\Manager as DB;
use swoole;
use App\Logic\SettelementLogic;


class HttpServerSettelement
{
    private $httpserver;
    private $config;
    private $dbpooleconfig = [];
    private $redisonfig = [];
    const   SQLKEY = 'ALLSQLKEY';
    const   TASKQNUM = 'TASKQNUM';
    private $TaskSqlQueue;


    public function __construct($config)
    {
        $this->httpserver = new \swoole\http\server($config['host'], $config['port']);
        $this->httpserver->set($config['sets']);
        $this->config = $config;
        $this->dbpooleconfig = GlobConfigs::getKey('pgsqlpoole');
        $this->redisonfig = GlobConfigs::getKey('redis');

        $this->httpserver->account = new \swoole\Atomic();
        $this->httpserver->taskWorkingNum = new \swoole\Atomic();

        $this->httpserver->on('request', array($this, 'OnRequest'));
        $this->httpserver->on('WorkerStart', array($this, 'onWorkerStart'));
        $this->httpserver->on('task', array($this, 'onTask'));
        $this->httpserver->on('finish', array($this, 'onFinish'));

    }

    public function onWorkerStart($serv, $worker_id)
    {
        /*
        $name = $serv->taskworker ? 'Task_' : 'Worker_';
        $name = 'Settelement_' . $name . ($serv->worker_id < 10 ? '0' . $serv->worker_id : $serv->worker_id);
        swoole_set_process_name($name);
        */

        $this->TaskSqlQueue = new \SplQueue();

        $GLOBALS['model'] = '';
        $GLOBALS['modeltime'] = 0;

        if (!$serv->taskworker) {
            $this->InitDb();
        }
        if ($serv->worker_id == 0) {
            \Swoole\Timer::tick(60000, function () {
                $this->logRunStatus();
                if ($this->httpserver->taskWorkingNum->get() > 1) {
                    $this->httpserver->taskWorkingNum->sub();
                }
            });
        }

    }


    private function logRunStatus()
    {
        echo date('Y-m-d H:i:s') . " 总请求数：" . $this->httpserver->account->get() . '  运行任务数：' . $this->httpserver->taskWorkingNum->get();
        echo ' work_id:' . $this->httpserver->worker_id . " 内存使用量：" . (memory_get_usage() / 1000) . 'k  峰值：' . (memory_get_peak_usage() / 1000) . "k\n";
    }


    public function OnRequest($request, $response)
    {
        $response->header('Content-Type', 'text/html; charset=utf-8');
        $response->header('Server', 'DataInfaceServer');
        $paras = array_merge(['request_time' => date("H:i:s")], !empty($request->get) ? $request->get : [], !empty($request->post) ? $request->post : []);

        $request_uri = substr($request->server['request_uri'], 1);
        $urls = ['WinFail', 'Settelement'];

        $this->httpserver->account->add();

        echo "现在任务数：" . $this->httpserver->taskWorkingNum->get() . "\n";


        if (!in_array($request_uri, $urls)) {
            $data = Response::generate('', 0, '', '无效的url');
            $response->end($data);
            return;
        }

        if ($this->httpserver->taskWorkingNum->get() > intval($this->config['sets']['worker_num'])) {
            $data = Response::generate('', 9, '', '还有未完成任务请稍等...' . $this->httpserver->taskWorkingNum->get());
            $response->end($data);
            return;
        }

        $check_token = true;
        if ($check_token) {
            $token = isset($paras['token']) ? $paras['token'] : '';
            if (empty($token) || empty($this->Tokencheck($token))) {
                $data = Response::generate('', 6, '', '安全验证失败!');
                $response->end($data);
                return;
            }
        }

        echo "计数器值：" . $this->httpserver->taskWorkingNum->get() . "\n";


        if ($request_uri == 'WinFail') {
            return $this->doWinFailse($request, $response, $paras);
        }

        if ($request_uri == 'Settelement') {
            return $this->doSettelementIntoRedis($request, $response, $paras);
        }

        return;
    }

    public function onTask($serv, $task)
    {
        $this->httpserver->taskWorkingNum->add();
        $this->httpserver->taskWorkingNum->sub();
    }


    private function Tokencheck($token)
    {
        $tokenvel = DB::table('system_user')->where(['token' => $token])->first();
        return $tokenvel;
    }


    //胜负计算
    private function doWinFailse($request, $response, $paras)
    {
        $this->httpserver->taskWorkingNum->add();

        $logic_obj = new WinfailLogic();
        $notice = isset($paras['noticeid']) ? $paras['noticeid'] : 0;
        $id = intval($notice);

        try {
            $noticeModel = $logic_obj->getNoticeDate($id);
            $result = $logic_obj->getCompResult($noticeModel->game_code, $noticeModel->match_id);
            $moneySimples = $logic_obj->getSimplexData($noticeModel->game_code, $noticeModel->match_id);
            $matchs_1 = $logic_obj->getMatchRecords($noticeModel->game_code, $noticeModel->match_id, 1);
            $matchs_2 = $logic_obj->getMatchRecords($noticeModel->game_code, $noticeModel->match_id, 2);

            $match_firstModel = isset($matchs_1['0']) ? $matchs_1['0'] : (isset($matchs_2['0']) ? $matchs_2['0'] : false);
            if (!$match_firstModel) {
                throw  new  \Exception('无数据异常-1!');
                return true;
            }
            $gjModel = $logic_obj->getGjDatas($match_firstModel);

            if (count($matchs_1) > 0 && count($moneySimples) <= 0) {
                throw  new  \Exception('数据异常-2!');
            }

            if (strtolower($match_firstModel->p_code) == 'gj') {
                if (empty($gjModel)) {
                    throw new  \Exception("没有冠军数据数据--match_id" . $noticeModel->match_id);
                }
                $result = [$gjModel];
            }

            $grpDatas = $logic_obj->getOddsTypeData($noticeModel->game_code, $noticeModel->match_id);
            if (empty($grpDatas)) {
                goto ENDLABLE;
            }

            $logic_obj->doLogic($noticeModel, $result);

            ENDLABLE:
            unset($logic_obj, $noticeModel, $AdapterObj, $result, $moneySimples, $matchs_1, $matchs_2, $RefClass);
            $data = Response::generate('', 1, ['cost' => (microtime(true) - $request->server['request_time_float'])], 'succes ');
            $response->end($data);
        } catch (\Exception $e) {
            unset($logic_obj);
            $data = Response::generate('', 10, '', $e->getMessage() . '--' . $e->getFile() . '--' . $e->getLine());
            $response->end($data);
        }

        $this->httpserver->taskWorkingNum->sub();

        return;
    }


    private function doSettelementIntoRedis($request, $response, $paras)
    {
        $this->httpserver->taskWorkingNum->add();

        try {
            list($order_ids, $bettype, $settype, $game_code, $match_id, $change_status) = $this->requestpara($request, $response, $paras);

            if (empty($order_ids)) {
                goto LABRETURN;
            }

            if ($bettype == 1) {
                $chekArr = $this->Match_check($order_ids, $bettype);
                if (empty($chekArr) || count($chekArr) != 1) {
                    throw  new \Exception('不同场比赛不能同时结算!');
                }
                unset($chekArr);
            }

            //分页处理数据
            $PageOrder_ids_1 = array_chunk($order_ids, 100);
            $tcount = ceil(count($order_ids) / 500);
            $i = 1;
            unset($order_ids);

            $redisconfig = $this->redisonfig;
            foreach ($PageOrder_ids_1 as $p_order_ids) {
                $nowchange_status = ($tcount == $i) ? $change_status : 0;
                $data = json_encode(['ids' => $p_order_ids, 'bettype' => $bettype, 'settype' => $settype, 'game_code' => $game_code, 'match_id' => $match_id, 'change_status' => $nowchange_status], 256);
                go(function () use ($data, $redisconfig) {
                    $redis = new Swoole\Coroutine\Redis();
                    $redis->connect($redisconfig['host'], $redisconfig['port']);
                    if (!empty($redis['passwd'])) {
                        $redis->auth($redis['passwd']);
                    }
                    $redis->select($redis['db']);

                    $redis->lpush(self::TASKQNUM, $data);
                    return;
                });
                unset($data);
                $i++;
            }

            LABRETURN:
            $data = Response::generate('', 1, ['cost' => (microtime(true) - $request->server['request_time_float'])], 'succes ');
            $response->end($data);

        } catch (\Exception $e) {

            $data = Response::generate('', 10, '', $e->getMessage() . '--' . $e->getFile() . '--' . $e->getLine());
            $response->end($data);
            unset($data);

        }

        $this->httpserver->taskWorkingNum->sub();
    }

    private function requestpara($request, $response, $paras)
    {
        $bettype = isset($paras['bettype']) ? $paras['bettype'] : 0;
        $settype = isset($paras['settype']) ? $paras['settype'] : 0;
        $game_code = isset($paras['game_code']) ? $paras['game_code'] : '';
        $match_id = isset($paras['match_id']) ? $paras['match_id'] : 0;
        $change_status = isset($paras['change_status']) ? $paras['change_status'] : 0;

        if (empty($paras['order_ids'])) {
            $idoarr = $this->getOrders($bettype, $game_code, $match_id);
        } else {
            $idoarr = explode(",", $paras['order_ids']);
        }

        $order_ids = array_map(function ($i) {
            return strval($i);
        }, $idoarr);

        if (intval($match_id) <= 0) {
            throw  new \Exception('赛事ID不能为空!');
            return;
        }

        if (empty($game_code)) {
            throw  new \Exception('赛事类型不能为空!');
        }

        if (!in_array($bettype, [1, 2])) {
            throw  new \Exception('订单类型参数错误!');
        }

        if (!in_array($settype, [1, 2])) {
            throw  new \Exception('结算参数错误');
        }

        $ret = [$order_ids, $bettype, $settype, $game_code, $match_id, $change_status];

        unset($bettype, $idoarr, $settype, $game_code, $match_id, $change_status);
        return $ret;
    }

    private function getOrders($bet_type, $game_code, $match_id)
    {
        if ($bet_type == 1) {
            $table = 'money_buy_simplex';
            $ret = DB::table($table)->select('order_id')->where(['game_code' => $game_code, 'match_id' => $match_id])->get();
        } else {
            $table = 'money_buy_str';
            $ret = DB::table($table)->select('order_id')->whereRaw(" batch_id in ( select batch_id  from  money_buy_match where match_id=$match_id and  game_code='$game_code' and bet_type=2 )")->get();
        }
        $return = [];
        if ($ret) {
            foreach ($ret as $val) {
                $return[] = $val->order_id;
            }
        }
        return $return;
    }


    private function Match_check($idsArray, $betType)
    {
        array_walk($idsArray, function (&$item, $key) {
            $item = "'" . $item . "'";
        });

        $idString = implode(",", $idsArray);

        $table = "money_buy_simplex";
        $sql = "select game_code,match_id   from  $table  where  status=1 and  order_id in ($idString)  group by  game_code,match_id ";

        $ret = DB::select($sql);

        return $ret;

    }


    public function onFinish($serv, int $task_id, $data)
    {

    }


    private function InitDb()
    {
        $over_time = 60 * 5;
        $now = microtime(true);

        if (!$GLOBALS['modeltime']) {
            $GLOBALS['modeltime'] = $now;
            $GLOBALS['model'] = $this->httpserver->worker_id;
            ModelBase::init();
            return;
        }

        if (($now - $GLOBALS['modeltime']) > $over_time) {
            $GLOBALS['modeltime'] = $now;
            $GLOBALS['model'] = $this->httpserver->worker_id;
            ModelBase::close();
            ModelBase::init();
            return;
        }
    }

    public function start()
    {
        $this->httpserver->start();
    }

}