xyzshop/helper/refill/policy/lingzh/policy.php

<?php


namespace refill;

use Log;
use mtopcard;

class policy extends ProviderManager implements IPolicy
{
    protected $mChannelControl;
    protected $mQuality;
    protected $mPrices;
    protected $mGroupCtl;

    public function __construct()
    {
        parent::__construct();
        $this->mChannelControl = new chctl();
        $this->mQuality = new quality_ploy();
        $this->mPrices = new merchant_price();
        $this->mGroupCtl = new rgroup_ctl();
    }

    public function load()
    {
        parent::load();

        $this->mChannelControl->load();
        $this->mChannelControl->update_price($this);

        $this->mQuality->load();
        $this->mPrices->load();
        $this->mGroupCtl->load();
    }

    public function find_providers(int $mchid, int $spec, int $card_type, int $org_quality, int $quality, $regin_no, $pcode, $order_time, $commit_times): array
    {
        $providers = parent::get_providers($mchid,$spec,$card_type,$quality,$regin_no);

        if(empty($providers)) {
            return [$providers,false];
        }

        $names = [];
        foreach ($providers as $provider) {
            $names[] = $provider->name();
        }

        Log::record("ProviderManager::get_providers result=" . implode(',',$names),Log::DEBUG);
        [$hasGroup,$can_others,$channels] = $this->mGroupCtl->find_providers($mchid, $spec, $card_type, $quality);
        if($hasGroup)
        {
            if(empty($channels))
            {
                if(!$can_others) {
                    return [[],false];
                }
            }
            else
            {
                $ret = array_intersect($names, $channels);
                if (empty($ret)) {
                    return [[],false];
                }
                else {
                    $names = $ret;
                }
            }
        }
        Log::record("GroupControl result=" . implode(',',$names),Log::DEBUG);

        $price = $this->mPrices->price($mchid,$card_type,$spec,$quality,$pcode);
        if($price === false) {
            return [[],false];
        }

        global $config;
        $auto_find = $config['auto_find_channels'];

        $mobile_types = [mtopcard\ChinaMobileCard,mtopcard\ChinaUnicomCard,mtopcard\ChinaTelecomCard];
        $qualities = [Quality::Normal];
        if($auto_find && in_array($card_type,$mobile_types) && in_array($quality,$qualities))
        {
            $names = $this->mChannelControl->auto_match($names, $spec, $card_type, $quality, $price, time() - $order_time);
            return [$names,false];
        }
        else
        {
            $name_overloads = $this->mChannelControl->match($names,$spec,$card_type,$quality);
            Log::record("policy::find_providers ChannelControl match result=" . implode(',',$name_overloads),Log::DEBUG);

            $result = [];
            foreach ($name_overloads as $name => $overload)
            {
                if(!isset($first)) {
                    $first = $overload;
                }

                if($overload) continue;
                foreach ($providers as $provider)
                {
                    if($name == $provider->name()) {
                        $result[] = $provider;
                    }
                }
            }

            if(!isset($first)) {
                $first = false;
            }

            return [$result,$first];
        }
    }

    public function price($mchid,$spec,$card_type,$quality,$pcode)
    {
        return $this->mPrices->price($mchid,$card_type,$spec,$quality,$pcode);
    }

    public function channeles(int $mchid, int $spec, int $card_type, int $quality, $regin_no)
    {
        $providers = parent::get_providers($mchid, $spec, $card_type, $quality, $regin_no);
        return count($providers);
    }

    public function find_quality($mchid,$spec,$card_type,$org_quality,$cur_quality,$times,$used_time,$pcode,$regin_no): array
    {
        if($card_type == mtopcard\SinopecCard || $card_type == mtopcard\PetroChinaCard) {
            $caller = new times_caller($mchid,$spec,$card_type,-1,$this);
        } else {
            $caller = null;
        }

        [$org_quality,$qualities] = $this->mQuality->find_quality($mchid,$card_type,$org_quality,$cur_quality,$times,$used_time,$caller);
        if(empty($qualities)) {
            return [$org_quality,0];
        }

        $namer = function ($providers)
        {
            $result = [];
            foreach ($providers as $provider) {
                $result[] = $provider->name();
            }
            return $result;
        };

        foreach ($qualities as $quality)
        {
            $price = $this->mPrices->price($mchid,$card_type,$spec,$quality,$pcode);
            if($price === false) {
                Log::record("{$mchid} 没有协商 quality = {$quality} 价格",Log::DEBUG);
                continue;
            }

            $providers = parent::get_providers($mchid, $spec, $card_type, $quality, $regin_no);
            if(empty($providers)) continue;

            $names = $namer($providers);
            $names_overload = $this->mChannelControl->match($names, $spec, $card_type, $quality);

            if (!empty($names_overload)) {
                return [$org_quality, $quality];
            } else {
                Log::record("Policy::find_quality:{$quality}-{$spec}-{$card_type} is fail", Log::DEBUG);
            }
        }

        return [$org_quality,0];
    }

    public function allow($mchid, $card_type, $amount, $quality): bool
    {
        return true;
    }

    public function notify($order_info, $refill_info) : bool
    {
        $order_state = $order_info['order_state'];
        if ($order_state == ORDER_STATE_CANCEL) {
            $state = 2;
        } else {
            $state = 1;
        }

        $mchid = $refill_info['mchid'];
        $mch_info = Model('merchant')->getMerchantInfo(['mchid' => $mchid]);

        [$params, $sign] = $this->body($state, $refill_info, $mch_info);
        $params['sgn'] = $sign;

        $notify_url = $refill_info['notify_url'];
        $resp = http_request($notify_url, $params, 'GET');

        return $resp == "ok";
    }

    private function body($state, $refill_info, $mch_info)
    {
        $params = [
            "usr" => $refill_info['mchid'],
            "ord" => $refill_info['mch_order'],
            'bz' => $refill_info['official_sn'] ?? "",
            "state" => $state];
        $secure_key = $mch_info['secure_key'];

        $card_type = $refill_info['card_type'];
        if($card_type == mtopcard\ThirdRefillCard)
        {
            $mod_third = Model('thrid_refill');
            $thrid_info = $mod_third->getThird($refill_info['order_id']);

            if (!empty($thrid_info))
            {
                $card_info = $thrid_info['card_info'];
                if (!empty($card_info)) {
                    $encrypt = openssl_encrypt($card_info,'AES-128-CBC',$secure_key);
                    if($encrypt != false) {
                        $params['card_info'] = $encrypt;
                    }
                }
            }
        }

        $sign = $this->sign($params, $secure_key);
        return [$params, $sign];
    }

    private function sign($params, $key)
    {
        $body = "{$params['ord']}{$params['state']}{$key}";
        Log::record("notify body={$body}",Log::DEBUG);
        return strtoupper(md5($body));
    }
    public function update_ratios($ratios)
    {

    }
}