xyzshop/helper/rbridge/RBridgeFactory.php

<?php

namespace rbridge;

require_once(BASE_HELPER_PATH . '/refill_proxy.php');

require_once(BASE_HELPER_PATH . '/rbridge/IBridge.php');
require_once(BASE_HELPER_PATH . '/rbridge/IBridgeEx.php');
require_once(BASE_HELPER_PATH . '/rbridge/BridgeTrait.php');
require_once(BASE_HELPER_PATH . '/rbridge/wsd/Bridge.php');
require_once(BASE_HELPER_PATH . '/rbridge/fulu/Bridge.php');
require_once(BASE_HELPER_PATH . '/rbridge/fulu_ylyw/Bridge.php');
require_once(BASE_HELPER_PATH . '/rbridge/fulu_youjun/Bridge.php');
require_once(BASE_HELPER_PATH . '/rbridge/fulu_qdw/Bridge.php');
require_once(BASE_HELPER_PATH . '/rbridge/gy/Bridge.php');

use Exception;
use Log;

class RBridgeFactory
{
    private static $stInstance = null;

    public static function instance()
    {
        if (self::$stInstance == null) {
            self::$stInstance = new RBridgeFactory();
        }
        return self::$stInstance;
    }

    private $mMerchants;

    private function __construct()
    {
        $this->mMerchants = [];
    }

    public function add($mch_name,$parmas)
    {
        $bridge = $this->find($mch_name);
        if(is_null($bridge)) {
            return false;
        }

        $ret = $bridge->add($parmas);
        return $ret;
    }

    public function notify($mch_name,$parmas)
    {
        $bridge = $this->find($mch_name);
        if(is_null($bridge)) {
            return false;
        }

        $ret = $bridge->notify($parmas);
        if($ret) {
            return "SUCCESS";
        }
        else {
            return "ERROR";
        }
    }

    public function query($mch_name,$parmas)
    {
        $bridge = $this->find($mch_name);
        if(is_null($bridge)) {
            return false;
        }

        $ret = $bridge->query($parmas);
        return $ret;
    }

    public function balance($mch_name,$parmas)
    {
        $bridge = $this->find($mch_name);
        if(is_null($bridge)) {
            return false;
        }

        $ret = $bridge->balance($parmas);
        return $ret;
    }

    private function find($name)
    {
        try
        {
            if(array_key_exists($name,$this->mMerchants)) {
                return $this->mMerchants[$name];
            }

            $class = "rbridge\\{$name}\\Bridge";
            if(class_exists($class,false)) {
                $merchant = new $class();
                $this->mMerchants[$name] = $merchant;
                return $merchant;
            } else {
                $error = "Error: class {$class} isn't exists!";
                throw new Exception($error);
            }
        }
        catch (Exception $ex)
        {
            Log::record($ex->getMessage(),Log::ERR);
        }

        return null;
    }
}