腾讯商品库

app/Console/Commands/Temp/GenAMSXmlFile.php

@@ -0,0 +1,257 @@
+<?php
+
+namespace App\Console\Commands\Temp;
+
+use App\Modules\Book\Models\BookConfig;
+use Illuminate\Console\Command;
+use Hashids;
+use Matrix\Exception;
+use OSS\OssClient;
+use OSS\Core\OssException;
+use DB;
+
+class GenAMSXmlFile extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'gen_ams_xml_file';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '腾讯商品库xml生成';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    private $emails = [
+        'lisy@zw88.net',
+//        'songdb@iqiyoo.com',
+       'zhoulj@iqiyoo.com',
+//        'zhaoy@zw88.net'
+    ];
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        $this->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 version='1.0' encoding='utf-8'?>
+<product_set>
+</product_set>
+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("/&/", '&amp', $char);
+        $char = preg_replace("/'/", '&apos', $char);
+        $char = preg_replace("/\"/", '&quot', $char);
+        $char = preg_replace("/</", '&lt', $char);
+        $char = preg_replace("/>/", '&gt', $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);
+            $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;
+    }
+
+}

app/Console/Kernel.php

@@ -160,6 +160,7 @@ class Kernel extends ConsoleKernel
         // temp
         Commands\Temp\NewBookTestType::class,
         Commands\Temp\CheckCidError::class,
+        Commands\Temp\GenAMSXmlFile::class,
 
     ];
 
@@ -186,6 +187,9 @@ class Kernel extends ConsoleKernel
 
         //每日商务渠道数据报表
         $schedule->command('BusinessChannelStat_task')->dailyAt("02:30");
+        
+        //腾讯商品库
+        $schedule->command('gen_ams_xml_file')->hourly()->between('6:00', '21:00');
 
         //点击率
         $schedule->command('book:clicknumupdate')->dailyAt('01:00');

app/Http/Controllers/Outer/TencentAd/TencentProduct/TencentProductController.php

@@ -0,0 +1,29 @@
+<?php
+namespace App\Http\Controllers\Outer\TencentAd\TencentProduct;
+use Illuminate\Http\Request;
+use Illuminate\Routing\Controller;
+use DB;
+
+class TencentProductController extends Controller
+{
+    public function siteMapXml(Request $request)
+    {
+        $product_index_info = DB::
+        table('tencent_product_configs')
+            ->where('type','SITE_MAP_XML_URL')
+            ->first();
+        
+            \Log::info('siteMapXml:'.json_encode($product_index_info));
+         
+        $xml = <<<XML
+<?xml version='1.0' encoding='utf-8'?>
+<sitemapindex>
+    <sitemap>
+        <loc>{$product_index_info->value}</loc>
+        <lastmod>{$product_index_info->updated_at}</lastmod>
+    </sitemap>
+</sitemapindex>
+XML;
+        return response($xml,200)->header("Content-type","text/xml");
+    }
+}

app/Http/Routes/Outer/GdtRoutes.php

@@ -0,0 +1,7 @@
+<?php
+
+Route::group(['domain'=>env('GDT_DOMAIN'),'namespace'=>'App\Http\Controllers\Outer\TencentAd\TencentProduct'],function(){
+    Route::get('tencent/siteMapXmlIndex','TencentProductController@siteMapXml');
+});
+
+

app/Providers/RouteServiceProvider.php

@@ -37,6 +37,7 @@ class RouteServiceProvider extends ServiceProvider
      */
     public function map(Router $router)
     {
+        $this->mapGdtRoutes($router);
         //         $this->mapFinanceRoutes($router);
         //         $this->mapBookRoutes($router);
         //         $this->mapUserRoutes($router);
@@ -62,6 +63,15 @@ class RouteServiceProvider extends ServiceProvider
         });
     }
 
+    protected function mapGdtRoutes(Router $router)
+    {
+        $router->group([
+            'middleware' => 'web',
+        ], function ($router) {
+            require app_path('Http/Routes/Outer/GdtRoutes.php');
+        });
+    }
+    
     protected function mapBookRoutes(Router $router)
     {
         $router->group([