" . self::_arr2xml($data) . ""; } /** * XML内容生成 * @param array $data 数据 * @param string $content * @return string */ private static function _arr2xml($data, $content = '') { foreach ($data as $key => $val) { $content .= "<{$key}>"; if (is_array($val) || is_object($val)) { $content .= self::_arr2xml($val); } elseif (is_string($val)) { $content .= ''; } else { $content .= $val; } $content .= ""; } return $content; } /** * 解析XML内容到数组 * @param string $xml * @return array */ public static function xml2arr($xml) { return json_decode(self::arr2json(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true); } /** * 数组转xml内容 * @param array $data * @return null|string|string */ public static function arr2json($data) { return preg_replace_callback('/\\\\u([0-9a-f]{4})/i', function ($matches) { return mb_convert_encoding(pack("H*", $matches[1]), "UTF-8", "UCS-2BE"); }, json_encode($data)); } /** * 解析JSON内容到数组 * @param string $json * @return array * @throws InvalidResponseException */ public static function json2arr($json) { $result = json_decode($json, true); if (empty($result)) { throw new InvalidResponseException('invalid response.', '0'); } if (!empty($result['errcode'])) { throw new InvalidResponseException($result['errmsg'], $result['errcode'], $result); } return $result; } /** * CURL模拟网络请求 * @param string $method 请求方法 * @param string $url 请求方法 * @param array $options 请求参数[headers,data,ssl_cer,ssl_key] * @return bool|string */ protected static function doRequest($method, $url, $options = []) { $curl = curl_init(); // GET参数设置 if (!empty($options['query'])) { $url .= (stripos($url, '?') !== false ? '&' : '?') . http_build_query($options['query']); } // CURL头信息设置 if (!empty($options['headers'])) { curl_setopt($curl, CURLOPT_HTTPHEADER, $options['headers']); } // POST数据设置 if (strtolower($method) === 'post') { curl_setopt($curl, CURLOPT_POST, true); curl_setopt($curl, CURLOPT_POSTFIELDS, $options['data']); } // 证书文件设置 if (!empty($options['ssl_cer'])) { if (file_exists($options['ssl_cer'])) { curl_setopt($curl, CURLOPT_SSLCERTTYPE, 'PEM'); curl_setopt($curl, CURLOPT_SSLCERT, $options['ssl_cer']); } else { throw new InvalidArgumentException("Certificate files that do not exist. --- [{$options['ssl_cer']}]"); } } // 证书文件设置 if (!empty($options['ssl_key'])) { if (file_exists($options['ssl_key'])) { curl_setopt($curl, CURLOPT_SSLKEYTYPE, 'PEM'); curl_setopt($curl, CURLOPT_SSLKEY, $options['ssl_key']); } else { throw new InvalidArgumentException("Certificate files that do not exist. --- [{$options['ssl_key']}]"); } } curl_setopt($curl, CURLOPT_URL, $url); curl_setopt($curl, CURLOPT_TIMEOUT, 60); curl_setopt($curl, CURLOPT_HEADER, false); curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); list($content, $status) = [curl_exec($curl), curl_getinfo($curl), curl_close($curl)]; return (intval($status["http_code"]) === 200) ? $content : false; } /** * 缓存配置与存储 * @param string $name 缓存名称 * @param string $value 缓存内容 * @param int $expired 缓存时间(0表示永久缓存) * @throws LocalCacheException */ public static function setCache($name, $value = '', $expired = 3600) { $cache_file = self::getCacheName($name); $content = serialize(['name' => $name, 'value' => $value, 'expired' => time() + intval($expired)]); if (!file_put_contents($cache_file, $content)) { throw new LocalCacheException('local cache error.', '0'); } } /** * 获取缓存内容 * @param string $name 缓存名称 * @return null|mixed */ public static function getCache($name) { $cache_file = self::getCacheName($name); if (file_exists($cache_file) && ($content = file_get_contents($cache_file))) { $data = unserialize($content); if (isset($data['expired']) && (intval($data['expired']) === 0 || intval($data['expired']) >= time())) { return $data['value']; } self::delCache($name); } return null; } /** * 移除缓存文件 * @param string $name 缓存名称 * @return bool */ public static function delCache($name) { $cache_file = self::getCacheName($name); return file_exists($cache_file) ? unlink($cache_file) : true; } /** * 应用缓存目录 * @param string $name * @return string */ private static function getCacheName($name) { if (empty(self::$cache_path)) { self::$cache_path = dirname(__DIR__) . DIRECTORY_SEPARATOR . 'Cache' . DIRECTORY_SEPARATOR; } self::$cache_path = rtrim(self::$cache_path, '/\\') . DIRECTORY_SEPARATOR; file_exists(self::$cache_path) || mkdir(self::$cache_path, 0755, true); return self::$cache_path . md5($name); } }