genProductXml(); } /** * genProductXml */ public function genProductXml() { //筛选出上架状态为2的书籍上传 $now = date('Y-m-d H:i:s'); $gdt_new_bids = DB::table('gdt_new_books')->where('is_deleted', 0)->where('start_time', '<=', $now)->where('end_time', '>=', $now)->pluck('bid')->toArray(); $books = BookConfig::join('books', 'book_configs.bid', '=', 'Books.id') ->leftjoin('book_categories', 'book_categories.id', 'books.category_id') ->leftjoin('chapters', 'books.last_cid', 'chapters.id') ->select( 'books.intro', 'books.status', 'books.size', 'books.chapter_count', 'books.last_chapter', 'book_configs.book_name', 'book_configs.bid', 'book_configs.cover', 'book_configs.vip_seq', 'book_configs.cover', 'book_configs.is_on_shelf', 'book_categories.id as second_category_id', 'book_categories.pid as first_category_id', 'book_categories.channel_name as first_category_name', 'book_categories.category_name as second_category_name', 'chapters.recent_update_at as latest_renew_time', 'chapters.sequence as latest_renew_chapter' ) //->where('book_configs.is_on_shelf','2') ->where(function ($query) { $query->where('book_configs.is_on_shelf', '2'); // ->orWhereIn('book_configs.bid', []);//豁免名单 }) ->get(); $string = << XML; $xml = new \SimpleXMLElement($string); foreach ($books as $book) { //在管理后台设置为新书的书籍标记成新书 $is_new_book = in_array($book->bid, $gdt_new_bids) ? '是' : '否'; $bid = Hashids::encode($book->bid); $data = array( 'product_id' => $bid, 'product_name' => $book->book_name, 'first_category_id' => $book->first_category_id, 'second_category_id' => $book->second_category_id, 'first_category_name' => $book->first_category_name, 'second_category_name' => $book->second_category_name, 'expiration_time' => '2022-05-19 23:59:59', 'target_url_mobile' => 'https://site8y1vm7kwvv850opx.wd.amanbook.com/detail?id=' . $bid, 'target_url_wechat' => 'https://site8y1vm7kwvv850opx.wd.amanbook.com/detail?id=' . $bid, 'description' => $this->special_filter(htmlspecialchars($book->intro)), 'image_url' => $book->cover, 'word_count' => $book->size, 'serial_status' => $book->status == 1 ? '完结' : '连载', 'chapter_count' => $book->chapter_count, 'started_pay_chapter' => $book->vip_seq, 'latest_renew_time' => $book->latest_renew_time, 'latest_renew_chapter' => $book->latest_renew_chapter, 'if_new_book' => $is_new_book, 'pay_status' => '付费', ); $item = $xml->addChild('product'); if (is_array($data)) { foreach ($data as $key => $row) { //生成子节点 try { $node = $item->addChild($key, $row); } catch (\Exception $e) { $msg = "======腾讯商品库xml生成出错=====" . date("y-m-d H:i:s" . "\n"); \Log::info($msg); \Log::info($e->getMessage()); $notify = MessageNotify::mail([ 'to_emails' => implode(",", $this->emails), 'subject' => $msg, 'body' => $e->getMessage(), 'delay_times' => 0, ]); $notify->notify(); exit(); } } } } $file_path = 'storage/tx_product.xml'; echo $xml->asXML($file_path); //上传到OSS $ori_file = DB::table('tencent_product_configs')->where('type', 'SITE_MAP_XML_URL')->first(); $verify_code = md5_file($file_path); if ($ori_file && $ori_file->verify_code == $verify_code) { \Log::info("======腾讯商品库xml已是最新=====" . date("y-m-d H:i:s" . "\n")); } else { $file_name = 'tx_product_wdy.xml'; //解析一遍看是否出错 try { $load＿xml = simplexml_load_file($file_path); } catch (\Exception $e) { $msg = "======腾讯商品库xml解析出错=====" . date("y-m-d H:i:s" . "\n"); \Log::info($msg); \Log::info($e->getMessage()); $notify = MessageNotify::mail([ 'to_emails' => implode(",", $this->emails), 'subject' => $msg, 'body' => $e->getMessage(), 'delay_times' => 0, ]); $notify->notify(); //删除文件以防权限问题 if (file_exists($file_path)) unlink($file_path); exit(); } $url = $this->saveXmlToOss($file_name, $file_path); DB::table('tencent_product_configs') ->updateOrInsert( ['type' => 'SITE_MAP_XML_URL'], [ 'value' => $url, 'updated_at' => date('Y-m-d H:i:s'), 'verify_code' => $verify_code, ] ); } //上传到OSS后删除,防止权限问题 if (file_exists($file_path)) unlink($file_path); \Log::info("======腾讯商品库xml生成=====" . date("y-m-d H:i:s" . "\n")); return; } public function dealSpecialCharacters($char) { $char = preg_replace("[\\x00-\\x08\\x0b-\\x0c\\x0e-\\x1f]", '', $char); $char = preg_replace("/&/", '&', $char); $char = preg_replace("/'/", '&apos', $char); $char = preg_replace("/\"/", '"', $char); $char = preg_replace("//", '>', $char); return $char; } private function special_filter($string) { if (!$string) return ''; $new_string = ''; for ($i = 0; isset($string[$i]); $i++) { $asc_code = ord($string[$i]); //得到其asc码 // 以下代码旨在过滤非法字符 // ** 数值 8、9、10 和 13 可以分别转换为退格符、制表符、换行符和回车符。 // 这些字符都没有图形表示，但是对于不同的应用程序，这些字符可能会影响文本的显示效果。 if (in_array($asc_code, [8, 9, 10, 13], true)) { $new_string .= ''; } else { $new_string .= $string[$i]; } } return trim($new_string); } /** * 将xml保存到oss * @return string */ function saveXmlToOss($file_name, $file) { $accessKeyId = env('OSS_ACCESS_ID'); $accessKeySecret = env('OSS_ACCESS_KEY'); $endpoint = env('OSS_END_POINT'); $bucket = env('OSS_BUCKET'); try { $ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint); $upload_res = $ossClient->uploadFile($bucket, $file_name, $file); \Log::info('saveXmlToOss:'.$bucket.' $file_name:'.$file_name.' $file:'.$file); $url = str_ireplace('wangduyun.oss-cn-hangzhou.aliyuncs.com', 'cdn-novel.wd.amanbook.com', $upload_res['oss-request-url']); $url = str_ireplace('http://', 'https://', $url); } catch (OssException $e) { \Log::info($e->getMessage()); } return $url; } }