qimall/addons/YunfastPay/common/services/SettingService.php

<?php

namespace addons\YunfastPay\common\services;

use Yii;
use yii\helpers\Json;
use addons\YunfastPay\common\enums\YunfastPayEnum;
use addons\YunfastPay\common\enums\YunfastPayTypeEnum;

/**
 * 设置
 * @package addons\YunfastPay\common\services
 */
class SettingService extends BaseService
{
    const BASIC = 'basic';

    /**
     * @var array
     */
    protected $setting; 

    /**
     * @var array
     */
    protected $json_fields = [
        'trade_channel', 'channel_alternative'
    ];

    /**
     * @var array
     */
    protected $open_fields = [
        YunfastPayTypeEnum::WEIXIN_GZH          => 'wechat_open',
        YunfastPayTypeEnum::WEIXIN_XCX          => 'mp_wx_open',
        YunfastPayTypeEnum::WEIXIN_H5           => 'wechat_h5_open',
        YunfastPayTypeEnum::ALIPAY_APP          => 'alipay_app_open',
        YunfastPayTypeEnum::ALIPAY_SCAN         => 'alipay_scan_open',
        YunfastPayTypeEnum::WEIXIN_SCAN         => 'wechat_scan_open',
        YunfastPayTypeEnum::W_MINI_PROGRAM_SCAN => 'wechat_mp_scan_open',
    ];

    /**
     * 设置配置
     *
     * @param array $setting 设置
     * @return boolean
     */
    public function setSetting(array $setting)
    {
        try {
            Yii::$app->services->setting->addons->set(
                $this->mall_id, YunfastPayEnum::ADDONS_NAME_YUNFAST_PAY, [static::BASIC => $setting]
            );
            $this->setCacheSetting($setting);
        } catch (\Exception $e) {
            return $this->error($e->getMessage());
        }

        return true;
    }

    /**
     * 获取配置信息
     *
     * @param string $key
     * @return array
     */
    public function getSetting()
    {
        if (empty($this->setting)) {
            $this->setting = $this->getCacheSetting();
            $this->jsonFormat();
        }

        return $this->setting;
    }

    /**
     * @return array
     */
    public function getDbSetting()
    {
        return Yii::$app->services->setting->addons->get(
            $this->mall_id, YunfastPayEnum::ADDONS_NAME_YUNFAST_PAY, static::BASIC
        );
    }

    /**
     * @return string
     */
    private function getCacheField()
    {
        return YunfastPayEnum::YUNFAST_PAY . $this->mall_id . 'ceche';
    }

    /**
     * 商户编号
     *
     * @return string
     */
    public function getMchtCd()
    {
        $config = $this->getSetting();

        return !empty($config['mcht_cd'])
            ? $config['mcht_cd']
            : '';
    }

    /**
     * 商户编号
     *
     * @return string
     */
    public function getOnlineMchtCd()
    {
        $config = $this->getSetting();

        return !empty($config['online_mcht_cd'])
            ? $config['online_mcht_cd']
            : '';
    }

    /**
     * 组织机构代码
     *
     * @return string
     */
    public function getOrgCd()
    {
        $config = $this->getSetting();

        return !empty($config['org_cd'])
            ? $config['org_cd']
            : '';
    }

    /**
     * @return array
     */
    private function getCacheSetting()
    {
        $redis      = Yii::$app->redis;
        $setting    = $redis->get($this->getCacheField());
        if (empty($setting)) {
            $setting = $this->getDbSetting();
            $this->setCacheSetting($setting);
        } else {
            $setting = Json::decode($setting);
        }

        return $setting;
    }

    /**
     * @param array $setting
     * @return void
     */
    private function setCacheSetting(array $setting)
    {
        $redis = Yii::$app->redis;
        $redis->setex($this->getCacheField(), 60, Json::encode($setting));
    }

    /**
     * 格式化json数据
     *
     * @return void
     */
    private function jsonFormat()
    {
        foreach ($this->json_fields as $field) {
            $this->setting[$field] = !empty($this->setting[$field]) 
                && is_string($this->setting[$field])
                ? Json::decode($this->setting[$field])
                : ($this->setting[$field] ?? []);
        }
    }

    /**
     * 是否开启
     *
     * @return boolean
     */
    public function isOpen()
    {
        $config = $this->getSetting();

        return (!empty($config['switch']) && $config['switch'])
            ? true
            : false;
    }

    /**
     * 代付是否开启
     *
     * @return boolean
     */
    public function isOpenAgent()
    {
        $config = $this->getSetting();
        
        return (!empty($config['alternative_open']) && $config['alternative_open'])
            ? true
            : false;
    }

    /**
     * 获取支付渠道
     *
     * @return array
     */
    public function getTradeChannel()
    {
        $config = $this->getSetting();

        return $config['trade_channel'];
    }

    /**
     * 是否选择该渠道
     *
     * @param integer $channel
     * @return boolean
     */
    public function isSelectChannel(int $channel)
    {
        return in_array($channel, $this->getTradeChannel());
    }

    /**
     * 获取开始的支付
     *
     * @param array $payments
     * @return array
     */
    public function getOpenPayment(array $payments)
    {
        $result = [];
        foreach ($payments as $payment) {
            // 支付方式开启
            if ($this->currentPaymentIsOpen($payment['trade_type'])) {
                // 使用小写字母作为下标
                $field = strtolower($payment['trade_type']);
                $result[$field] = $payment;
            }
        }

        return $result;
    }

    /**
     * 检查当前支付方式是否开启
     *
     * @param string $trade_type
     * @return boolean
     */
    public function currentPaymentIsOpen(string $trade_type)
    {
        $open_field = $this->open_fields[$trade_type];

        return (boolean)$this->setting[$open_field];
    }
}