xyzshop/helper/refill/policy/quaility.php

<?php

namespace refill;

use Log;
use mtopcard;

class Quality
{
    const LowestQuality  = 1;
    const HighestQuality = 7;

    const Normal = 1;
    const Quick = 2;
    const CardKey = 3;
    const ThirdShop = 4;
    const SlowTwentyFour = 5;
    const SlowSix = 6;
    const SlowTwo = 7;

    const SlowNormal  = 11;  // 7 -> 1
    const ThirdNormal  = 12; // 4 -> 1
    const DefSuccess = 13;   // 4 -> 3 -> 1 -> 2
    const NormalQuick = 14;

    const OilWithoutSN = 1;
    const OilWithSN    = 5;
    const OilSN_NONE_HAS   = 20;
    const OilSN_HAS_NONE   = 21;

    protected $mMchPhonectl;
    protected $mMchoilctl;
    protected $mSpeeds;
    protected $mQualities;

    public function __construct()
    {
        $this->mMchPhonectl = new mchctl();
        $this->mMchoilctl = new mchoilctl();
    }

    public function load()
    {
        $this->mMchPhonectl->load();
        $this->mMchoilctl->load();
    }

    public function find_quality($mchid, $card_type, $quality, $times, $used_time, $caller): array
    {
        if($card_type == mtopcard\ChinaMobileCard || $card_type == mtopcard\ChinaUnicomCard || $card_type == mtopcard\ChinaTelecomCard) {
            return $this->mobile_quality($mchid, $quality, $times, $used_time);
        }
        elseif($card_type == mtopcard\PetroChinaCard || $card_type == mtopcard\SinopecCard) {
            return $this->oil_quality($mchid, $quality, $times,$used_time,$caller);
        }
        else {
            return [0, []];
        }
    }

    private function oil_quality($mchid, $quality, $times,$used_time,$caller): array
    {
        Log::record("oil_quality mchid={$mchid},quality={$quality},times={$times}",Log::DEBUG);
        if($quality == 0)
        {
            [$success,$setting_quality,$time_out] = $this->mMchoilctl->getCtls($mchid);
            if($success)
            {
                if(array_key_exists($setting_quality,$this->mQualities)) {
                    $org = $setting_quality;
                    $qualities = $this->mQualities[$setting_quality];
                }
                else {
                    $org = $setting_quality;
                    $qualities = [$setting_quality];
                }
            }
            else {
                $org = self::ThirdNormal;
                $qualities = $this->mQualities[$org];
            }
        }
        elseif(array_key_exists($quality,$this->mQualities)) {
            $org = $quality;
            $qualities = $this->mQualities[$quality];
        }
        else {
            Log::record("find_quality: cannot find any quality",Log::DEBUG);
            return [0,[]];
        }

        Log::record("oil_quality find qualities = " . implode(',',$qualities),Log::DEBUG);
        $qualities = $this->calc_oil_quality($qualities,$times,$used_time,$caller);

        return [$org,$qualities];
    }

    //通过每种类型通道耗时，倒推当前可用通道，并优先走推荐通道.
    private function calc_oil_quality($qualities, $times, $used_time, $caller)
    {
        $result = [];
        if($used_time > 900) {
            return $result;
        }

        $total_times = 0;
        foreach ($qualities as $quality)
        {
            $cur_times = $caller->calc_times($quality);
            if($cur_times <= 0) continue;

            $total_times += $cur_times;
            if($total_times > $times) {
                $result[] = $quality;
            }
        }

        Log::record("calc_oil_quality result = " . implode(',',$result),Log::DEBUG);
        return $result;
    }


    private function mobile_quality($mchid,$quality,$times,$used_time): array
    {
        if($quality == 0)
        {
            [$success,$setting_quality,$time_out] = $this->mMchPhonectl->getCtls($mchid);
            if($success)
            {
                if(array_key_exists($setting_quality,$this->mQualities)) {
                    $org = $setting_quality;
                    $qualities = $this->mQualities[$setting_quality];
                }
                else {
                    $org = $setting_quality;
                    $qualities = [$setting_quality];
                }
            }
            else {
                $org = self::ThirdNormal;
                $qualities = $this->mQualities[$org];
                $time_out = $this->mSpeeds[$org]['retry_timeout'];
            }
        }
        elseif(array_key_exists($quality,$this->mQualities)) {
            $org = $quality;
            $qualities = $this->mQualities[$quality];
            [$success, $setting_quality, $time_out] = $this->mMchPhonectl->getCtls($mchid);
        }
        else {
            Log::record("find_quality: cannot find any quality",Log::DEBUG);
            return [0,[]];
        }

        if($time_out <= 0) {
            $time_out = $this->mSpeeds[$org]['retry_timeout'];
        }

        $max_times = $this->mSpeeds[$org]['retry_times'];
        $qualities = $this->calc_phone_quality($qualities,$times,$used_time,$time_out,$max_times);

        return [$org,$qualities];
    }

    //通过每种类型通道耗时，倒推当前可用通道，并优先走推荐通道.
    private function calc_phone_quality($qualities, $times, $used_time, $time_out, $max_times)
    {
        $left_time = $time_out - $used_time;
        if($left_time <= 0 || $max_times <= $times) return [];

        Log::record("calc_quality begin qualities = " . implode(',',$qualities),Log::DEBUG);
        $times_checker = function($qualities, $times)
        {
            $result = [];
            $pre_times = 0;
            foreach ($qualities as $quality)
            {
                $pre_times += $this->mSpeeds[$quality]['retry_times'];
                if($times < $pre_times) {
                    $result[] = $quality;
                }
            }

            return $result;
        };

        $timeout_checker = function ($qualities, $left_time)
        {
            $qualities = array_reverse($qualities);
            $result = [];
            foreach ($qualities as $quality)
            {
                $per_secs = $this->mSpeeds[$quality]['per_secs'];
                $left_time -= $per_secs;
                if($left_time > 0) {
                    $result[] = $quality;
                } else {
                    break;
                }
            }

            if(count($qualities) > 0 && empty($result)) {
                $result[] = $quality;
            }
            $result = array_reverse($result);

            return $result;
        };

        if($times > 0) {
            $qualities = $times_checker($qualities,$times);
            Log::record("calc_quality times_checker result = " . implode($qualities),Log::DEBUG);
            $qualities = $timeout_checker($qualities,$left_time);
            Log::record("calc_quality timeout_checker result = " . implode($qualities),Log::DEBUG);
        }

        return $qualities;
    }
}