wenpai
e9d28817fe
74 文件 14,082 处自动修复：空格→Tab 缩进、括号间距、 函数声明空格、前置自增、尾逗号等纯格式化改动。 零逻辑变更，php -l + token 级对比验证通过。 新增 phpcs.xml.dist / phpstan.neon.dist 项目配置。 Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
464 lines
11 KiB
PHP
464 lines
11 KiB
PHP
<?php
|
||
/**
|
||
* 供应商管理器
|
||
*
|
||
* 管理所有第三方 GPL 插件供应商
|
||
*
|
||
* @package WPBridge
|
||
* @since 0.9.7
|
||
*/
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace WPBridge\Commercial\Vendors;
|
||
|
||
use WPBridge\Core\Settings;
|
||
use WPBridge\Core\Logger;
|
||
use WPBridge\Security\Encryption;
|
||
|
||
// 防止直接访问
|
||
if ( ! defined( 'ABSPATH' ) ) {
|
||
exit;
|
||
}
|
||
|
||
/**
|
||
* VendorManager 类
|
||
*/
|
||
class VendorManager {
|
||
|
||
/**
|
||
* 设置实例
|
||
*
|
||
* @var Settings
|
||
*/
|
||
private Settings $settings;
|
||
|
||
/**
|
||
* 已注册的供应商
|
||
*
|
||
* @var VendorInterface[]
|
||
*/
|
||
private array $vendors = [];
|
||
|
||
/**
|
||
* 单例实例
|
||
*
|
||
* @var VendorManager|null
|
||
*/
|
||
private static ?VendorManager $instance = null;
|
||
|
||
/**
|
||
* 获取单例实例
|
||
*
|
||
* @param Settings|null $settings 设置实例
|
||
* @return VendorManager
|
||
*/
|
||
public static function get_instance( ?Settings $settings = null ): VendorManager {
|
||
if ( self::$instance === null ) {
|
||
self::$instance = new self( $settings ?? new Settings() );
|
||
}
|
||
return self::$instance;
|
||
}
|
||
|
||
/**
|
||
* 构造函数
|
||
*
|
||
* @param Settings $settings 设置实例
|
||
*/
|
||
public function __construct( Settings $settings ) {
|
||
$this->settings = $settings;
|
||
$this->load_vendors();
|
||
}
|
||
|
||
/**
|
||
* 需要加密的敏感配置字段
|
||
*/
|
||
private const SENSITIVE_FIELDS = [ 'api_key', 'api_secret', 'license_key', 'consumer_key', 'consumer_secret' ];
|
||
|
||
/**
|
||
* 加载已配置的供应商
|
||
*/
|
||
private function load_vendors(): void {
|
||
$vendor_configs = $this->settings->get( 'vendors', [] );
|
||
|
||
foreach ( $vendor_configs as $vendor_id => $config ) {
|
||
if ( empty( $config['enabled'] ) ) {
|
||
continue;
|
||
}
|
||
|
||
// 解密敏感字段（兼容 secure option 存储）
|
||
$config = self::decrypt_config( $config, $vendor_id );
|
||
|
||
$vendor = $this->create_vendor( $vendor_id, $config );
|
||
if ( $vendor !== null ) {
|
||
$this->vendors[ $vendor_id ] = $vendor;
|
||
}
|
||
}
|
||
|
||
// 允许通过 hook 注册额外供应商
|
||
do_action( 'wpbridge_register_vendors', $this );
|
||
}
|
||
|
||
/**
|
||
* 创建供应商实例
|
||
*
|
||
* @param string $vendor_id 供应商 ID
|
||
* @param array $config 配置
|
||
* @return VendorInterface|null
|
||
*/
|
||
private function create_vendor( string $vendor_id, array $config ): ?VendorInterface {
|
||
$type = $config['type'] ?? 'woocommerce';
|
||
$name = $config['name'] ?? $vendor_id;
|
||
|
||
switch ( $type ) {
|
||
case 'woocommerce':
|
||
case 'wc_am':
|
||
return new WooCommerceVendor( $vendor_id, $name, $config );
|
||
|
||
case 'bridge_api':
|
||
return new BridgeApiVendor( $vendor_id, $name, $config );
|
||
|
||
default:
|
||
Logger::warning(
|
||
'Unknown vendor type',
|
||
[
|
||
'vendor_id' => $vendor_id,
|
||
'type' => $type,
|
||
]
|
||
);
|
||
return null;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 注册供应商
|
||
*
|
||
* @param VendorInterface $vendor 供应商实例
|
||
*/
|
||
public function register( VendorInterface $vendor ): void {
|
||
$this->vendors[ $vendor->get_id() ] = $vendor;
|
||
}
|
||
|
||
/**
|
||
* 获取供应商
|
||
*
|
||
* @param string $vendor_id 供应商 ID
|
||
* @return VendorInterface|null
|
||
*/
|
||
public function get_vendor( string $vendor_id ): ?VendorInterface {
|
||
return $this->vendors[ $vendor_id ] ?? null;
|
||
}
|
||
|
||
/**
|
||
* 获取所有供应商
|
||
*
|
||
* @param bool $only_available 只返回可用的供应商
|
||
* @return VendorInterface[]
|
||
*/
|
||
public function get_vendors( bool $only_available = false ): array {
|
||
if ( ! $only_available ) {
|
||
return $this->vendors;
|
||
}
|
||
|
||
return array_filter(
|
||
$this->vendors,
|
||
fn( VendorInterface $vendor ) => $vendor->is_available()
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 获取所有供应商信息
|
||
*
|
||
* @return array
|
||
*/
|
||
public function get_vendors_info(): array {
|
||
$info = [];
|
||
foreach ( $this->vendors as $vendor ) {
|
||
$info[ $vendor->get_id() ] = array_merge(
|
||
$vendor->get_info(),
|
||
[ 'available' => $vendor->is_available() ]
|
||
);
|
||
}
|
||
return $info;
|
||
}
|
||
|
||
/**
|
||
* 从所有供应商搜索插件
|
||
*
|
||
* @param string $keyword 关键词
|
||
* @param string $vendor_id 指定供应商（可选）
|
||
* @return array
|
||
*/
|
||
public function search_plugins( string $keyword, string $vendor_id = '' ): array {
|
||
$results = [];
|
||
|
||
$vendors = ! empty( $vendor_id )
|
||
? [ $this->get_vendor( $vendor_id ) ]
|
||
: $this->get_vendors( true );
|
||
|
||
foreach ( $vendors as $vendor ) {
|
||
if ( $vendor === null ) {
|
||
continue;
|
||
}
|
||
|
||
try {
|
||
$vendor_results = $vendor->search_plugins( $keyword );
|
||
foreach ( $vendor_results as $plugin ) {
|
||
$plugin['vendor_id'] = $vendor->get_id();
|
||
$plugin['vendor_name'] = $vendor->get_info()['name'] ?? '';
|
||
$results[] = $plugin;
|
||
}
|
||
} catch ( \Exception $e ) {
|
||
Logger::error(
|
||
'Vendor search failed',
|
||
[
|
||
'vendor' => $vendor->get_id(),
|
||
'error' => $e->getMessage(),
|
||
]
|
||
);
|
||
}
|
||
}
|
||
|
||
return $results;
|
||
}
|
||
|
||
/**
|
||
* 从所有供应商获取插件
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @return array|null 包含插件信息和供应商信息
|
||
*/
|
||
public function get_plugin( string $slug ): ?array {
|
||
foreach ( $this->get_vendors( true ) as $vendor ) {
|
||
$plugin = $vendor->get_plugin( $slug );
|
||
if ( $plugin !== null ) {
|
||
$plugin['vendor_id'] = $vendor->get_id();
|
||
$plugin['vendor_name'] = $vendor->get_info()['name'] ?? '';
|
||
return $plugin;
|
||
}
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* 检查插件更新（从所有供应商）
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @param string $current_version 当前版本
|
||
* @return array|null
|
||
*/
|
||
public function check_update( string $slug, string $current_version ): ?array {
|
||
foreach ( $this->get_vendors( true ) as $vendor ) {
|
||
$update = $vendor->check_update( $slug, $current_version );
|
||
if ( $update !== null ) {
|
||
$update['vendor_id'] = $vendor->get_id();
|
||
$update['vendor_name'] = $vendor->get_info()['name'] ?? '';
|
||
return $update;
|
||
}
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* 获取下载链接
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @param string $vendor_id 供应商 ID（可选，自动查找）
|
||
* @param string $version 版本号（可选）
|
||
* @return string|null
|
||
*/
|
||
public function get_download_url( string $slug, string $vendor_id = '', string $version = '' ): ?string {
|
||
if ( ! empty( $vendor_id ) ) {
|
||
$vendor = $this->get_vendor( $vendor_id );
|
||
if ( $vendor !== null ) {
|
||
return $vendor->get_download_url( $slug, $version );
|
||
}
|
||
}
|
||
|
||
// 自动查找
|
||
foreach ( $this->get_vendors( true ) as $vendor ) {
|
||
$plugin = $vendor->get_plugin( $slug );
|
||
if ( $plugin !== null ) {
|
||
return $vendor->get_download_url( $slug, $version );
|
||
}
|
||
}
|
||
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* 添加供应商配置
|
||
*
|
||
* @param string $vendor_id 供应商 ID
|
||
* @param array $config 配置
|
||
* @return bool
|
||
*/
|
||
public function add_vendor_config( string $vendor_id, array $config ): bool {
|
||
$vendors = $this->settings->get( 'vendors', [] );
|
||
// 加密敏感字段后存储
|
||
$vendors[ $vendor_id ] = self::encrypt_config( $config );
|
||
|
||
$result = $this->settings->set( 'vendors', $vendors );
|
||
|
||
if ( $result ) {
|
||
// 用明文 config 创建运行时实例
|
||
$vendor = $this->create_vendor( $vendor_id, $config );
|
||
if ( $vendor !== null ) {
|
||
$this->vendors[ $vendor_id ] = $vendor;
|
||
}
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 移除供应商配置
|
||
*
|
||
* @param string $vendor_id 供应商 ID
|
||
* @return bool
|
||
*/
|
||
public function remove_vendor_config( string $vendor_id ): bool {
|
||
$vendors = $this->settings->get( 'vendors', [] );
|
||
|
||
if ( ! isset( $vendors[ $vendor_id ] ) ) {
|
||
return false;
|
||
}
|
||
|
||
unset( $vendors[ $vendor_id ] );
|
||
unset( $this->vendors[ $vendor_id ] );
|
||
|
||
return $this->settings->set( 'vendors', $vendors );
|
||
}
|
||
|
||
/**
|
||
* 测试供应商连接
|
||
*
|
||
* @param string $vendor_id 供应商 ID
|
||
* @return array
|
||
*/
|
||
public function test_vendor( string $vendor_id ): array {
|
||
$vendor = $this->get_vendor( $vendor_id );
|
||
|
||
if ( $vendor === null ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => __( '供应商不存在', 'wpbridge' ),
|
||
];
|
||
}
|
||
|
||
$available = $vendor->is_available();
|
||
|
||
if ( ! $available ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => __( '供应商连接失败，请检查配置', 'wpbridge' ),
|
||
];
|
||
}
|
||
|
||
// 尝试获取插件列表
|
||
$plugins = $vendor->get_plugins( 1, 10 );
|
||
|
||
return [
|
||
'success' => true,
|
||
'message' => __( '连接成功', 'wpbridge' ),
|
||
'plugin_count' => $plugins['total'] ?? count( $plugins['plugins'] ),
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 获取所有供应商的全部插件
|
||
*
|
||
* @return array slug => plugin info
|
||
*/
|
||
public function get_all_plugins(): array {
|
||
$all_plugins = [];
|
||
|
||
foreach ( $this->get_vendors( true ) as $vendor ) {
|
||
$result = $vendor->get_plugins();
|
||
$plugins = $result['plugins'] ?? [];
|
||
$vendor_info = $vendor->get_info();
|
||
|
||
foreach ( $plugins as $plugin ) {
|
||
$slug = $plugin['slug'] ?? '';
|
||
if ( empty( $slug ) || isset( $all_plugins[ $slug ] ) ) {
|
||
continue;
|
||
}
|
||
|
||
$plugin['source'] = 'vendor';
|
||
$plugin['vendor'] = $vendor_info['name'] ?? $vendor->get_id();
|
||
$plugin['vendor_id'] = $vendor->get_id();
|
||
$all_plugins[ $slug ] = $plugin;
|
||
}
|
||
}
|
||
|
||
return $all_plugins;
|
||
}
|
||
|
||
/**
|
||
* 获取统计信息
|
||
*
|
||
* @return array
|
||
*/
|
||
public function get_stats(): array {
|
||
$total_vendors = count( $this->vendors );
|
||
$active_vendors = count( $this->get_vendors( true ) );
|
||
$total_plugins = 0;
|
||
|
||
foreach ( $this->get_vendors( true ) as $vendor ) {
|
||
$plugins = $vendor->get_plugins( 1, 1 );
|
||
$total_plugins += $plugins['total'] ?? 0;
|
||
}
|
||
|
||
return [
|
||
'total_vendors' => $total_vendors,
|
||
'active_vendors' => $active_vendors,
|
||
'total_plugins' => $total_plugins,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 加密配置中的敏感字段
|
||
*
|
||
* @param array $config 明文配置
|
||
* @return array 加密后的配置
|
||
*/
|
||
private static function encrypt_config( array $config ): array {
|
||
foreach ( self::SENSITIVE_FIELDS as $field ) {
|
||
if ( ! empty( $config[ $field ] ) && ! Encryption::is_encrypted( $config[ $field ] ) ) {
|
||
$config[ $field ] = Encryption::encrypt( $config[ $field ] );
|
||
}
|
||
}
|
||
return $config;
|
||
}
|
||
|
||
/**
|
||
* 解密配置中的敏感字段
|
||
*
|
||
* 支持两种存储方式：
|
||
* 1. 直接加密存储在 config 中（旧版）
|
||
* 2. ***encrypted*** 占位符 + secure option（新版）
|
||
*
|
||
* @param array $config 加密配置
|
||
* @param string $vendor_id 供应商 ID（用于读取 secure option）
|
||
* @return array 明文配置
|
||
*/
|
||
private static function decrypt_config( array $config, string $vendor_id = '' ): array {
|
||
foreach ( self::SENSITIVE_FIELDS as $field ) {
|
||
if ( empty( $config[ $field ] ) ) {
|
||
continue;
|
||
}
|
||
|
||
// 新版：占位符 + secure option
|
||
if ( $config[ $field ] === '***encrypted***' && $vendor_id !== '' ) {
|
||
$config[ $field ] = Encryption::get_secure( "vendor_{$vendor_id}_{$field}", '' );
|
||
continue;
|
||
}
|
||
|
||
// 旧版：直接加密存储
|
||
if ( Encryption::is_encrypted( $config[ $field ] ) ) {
|
||
$config[ $field ] = Encryption::decrypt( $config[ $field ] );
|
||
}
|
||
}
|
||
return $config;
|
||
}
|
||
}
|
