合并分支 'zhl' 到 'master'

同步项目和路由



查看合并请求 !1133

+<?php
+/**
+ * Created by PhpStorm.
+ * User: zhl
+ * Date: 2025/2/17
+ * Time: 11:24
+ */
+namespace App\Console\Commands\Inquiry;
+
+use App\Models\Channel\Channel;
+use App\Models\Domain\DomainInfo;
+use App\Models\Inquiry\InquiryProject;
+use App\Models\Inquiry\InquiryProjectRoute;
+use App\Models\Product\Category;
+use App\Models\Product\Product;
+use App\Models\Project\OnlineCheck;
+use App\Models\Project\Project;
+use App\Services\ProjectServer;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+
+/**
+ * Class SyncInquiryProject
+ * @package App\Console\Commands\Inquiry
+ */
+class SyncInquiryProject extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'sync_inquiry_project';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '同步询盘信息：项目以及对应路由，';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * 同步优化项目及路由
+     * TODO 同步v4 v5 v6项目以及路由， 删除过期项目及路由
+     * @return bool
+     */
+    public function handle()
+    {
+        $this->syncGloV5();
+        $this->syncGloV6();
+        $this->deleteExpire();
+        return true;
+    }
+
+    /**
+     * 同步v4 、 v5项目
+     * @return bool
+     */
+    public function syncGloV5()
+    {
+        $result = http_get('https://www.quanqiusou.cn/extend_api/webs/globalso_v5_tg.php');
+        $channel = Channel::pluck('contact_mobile', 'id')->toArray();
+        foreach ($result as $key=>$val)
+        {
+            // 记录渠道商, 如果渠道有问题， 记录日志， 跳过当前项目， 处理数据后， 第二天再重新同步
+            $channel_flag = false;
+            $channel_tmp = [];
+            foreach ($val['agent'] as $v) {
+                $channel_id = array_search($v, $channel);
+                if (empty($channel_id)) {
+                    $channel_flag = true;
+                    break;
+                }
+                array_push($channel_tmp, $channel_id);
+            }
+
+            if ($channel_flag || empty($channel_tmp)) {
+                $this->log('ERROR 代理商找不到不记录当前项目, 项目ID：' . $val['postid']);
+                continue;
+            }
+
+            // 保存项目 以及路由
+            $project = InquiryProject::saveProject($val['v'], $val['postid'], $val['company'], implode(',', $channel_tmp), $val['main_url'], $val['is_split'], $val['test_url']);
+            $route_domain = $val['is_split'] && $val['test_url'] ? $val['test_url'] : $val['main_url'];
+            $this->syncGloV5Route($project->id, $route_domain);
+        }
+        return true;
+    }
+
+    /**
+     * 同步v4 v5项目路由
+     * @param $project_id
+     * @param $route_domain
+     * @return bool
+     */
+    public function syncGloV5Route($project_id, $route_domain)
+    {
+        $result = http_get($route_domain . 'k_u_api.php');
+        foreach ($result as $key=>$val) {
+            try {
+                $tmp = explode('|', $val);
+                $url_tmp = parse_url($tmp[0]);
+                $route = trim($url_tmp['path'], '/');
+                $title = str_replace('+', ' ', $tmp[1]);
+                InquiryProjectRoute::saveProjectRoute($project_id, $title, $route);
+            } catch (\Exception $e) {
+                $this->log('syncGloV5Route 解析路径：' . $val . ', 错误信息：' . $e->getMessage());
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 同步v6项目
+     * @return bool
+     */
+    public function syncGloV6()
+    {
+        // 获取优化中台项目
+        $project = Project::leftJoin('gl_project_online_check', 'gl_project.id', '=', 'gl_project_online_check.project_id')
+            ->where('gl_project.type', Project::TYPE_TWO)
+            ->where('gl_project.extend_type', '!=', 5)
+            ->where(function ($query) {
+                $query->orwhere('gl_project_online_check.qa_status', OnlineCheck::STATUS_ONLINE_TRUE)
+                    ->orwhere('gl_project.is_upgrade', Project::IS_UPGRADE_TRUE);
+            })
+            ->limit(5)
+            ->get(['gl_project.id', 'gl_project.title', 'gl_project.level', 'gl_project.channel']);
+        // 获取所有项目域名
+        $domains = DomainInfo::whereIn('project_id', $project->pluck('id')->toArray())->pluck('domain', 'project_id')->toArray();
+        foreach ($project as $key=>$val) {
+            // 过滤暂停优化项目, 映射类型2， model没有定义常量
+            if (in_array(2, $val->level))
+                continue;
+            $project = InquiryProject::saveProject(InquiryProject::VERSION_SIX, $val->id, $val->title, $val->channel['channel_id'], $domains[$val->id]);
+            $this->syncGloV6Route($project->id, $val->id);
+        }
+        return true;
+    }
+
+    /**
+     * 同步v6项目路由
+     * @param $project_id
+     * @param $origin_project_id
+     * @return bool
+     */
+    public function syncGloV6Route($project_id, $origin_project_id)
+    {
+        ProjectServer::useProject($origin_project_id);
+        // TODO 产品分类标题、路由， 产品标题、路由， 同步到路由表
+        $category = Category::where('status', Category::STATUS_ACTIVE)->get(['title', 'route']);
+        foreach ($category as $key=>$val) {
+            InquiryProjectRoute::saveProjectRoute($project_id, $val->title, $val->route);
+        }
+
+        // 产品数量会比较多， 所以使用分页 同步数据
+        $id = 0;
+        while (true) {
+            $product = Product::where('status', Product::STATUS_ON)->where('id', '>', $id)->orderBy('id', 'asc')->limit(1000)->get(['id', 'title', 'route']);
+            if ($product->isEmpty())
+                break;
+
+            foreach ($product as $key=>$val) {
+                $id = $val->id;
+                InquiryProjectRoute::saveProjectRoute($project_id, $val->title, $val->route);
+            }
+        }
+
+        DB::disconnect('custom_mysql');
+        return true;
+    }
+
+    /**
+     * 删除过期数据， 非当日更新数据， 都删除， 误删第二天再重新同步更新
+     * @return bool
+     */
+    public function deleteExpire()
+    {
+        $date = intval(date('Ymd'));
+        $project_num = InquiryProject::where('date', '<', $date)->delete();
+        $project_route_num = InquiryProjectRoute::where('date', '<', $date)->delete();
+        $this->log('删除过期项目数量：' . $project_num . ', 删除过期路由数量：' . $project_route_num);
+        return true;
+    }
+
+    /**
+     * 输出日志到特定的文件内， 这个文件需要定时排除内容
+     * @param $message
+     * @return bool
+     */
+    public function log($message)
+    {
+        $message = date('Y-m-d H:i:s') . ' ' . $message . PHP_EOL;
+        file_put_contents(storage_path('logs/zhl/output') . date('Y-m-d') . '.log', $message, FILE_APPEND);
+        return true;
+    }
+}

+<?php
+/**
+ * Created by PhpStorm.
+ * User: zhl
+ * Date: 2025/2/17
+ * Time: 11:49
+ */
+namespace App\Models\Inquiry;
+
+use App\Models\Base;
+
+/**
+ * Class InquiryProject
+ * @package App\Models\Inquiry
+ */
+class InquiryProject extends Base
+{
+    /**
+     * @var string 数据表
+     */
+    protected $table = 'gl_inquiry_project';
+
+    // 对应系统版本号
+    const VERSION_FOUR = 4;
+    const VERSION_FIVE = 5;
+    const VERSION_SIX = 6;
+
+    /**
+     * 保存项目信息
+     * @param $version
+     * @param $primary_id
+     * @param $project
+     * @param $channel
+     * @param $domain
+     * @param int $is_split
+     * @param string $test_domain
+     * @return InquiryProject
+     */
+    public static function saveProject($version, $primary_id, $project, $channel, $domain, $is_split = 0, $test_domain = '')
+    {
+        $date = date('Ymd');
+        $log = self::where(compact('version', 'primary_id'))->first();
+        if ($log) {
+            $log->date = $date;
+            $log->save();
+            return $log;
+        }
+        $self = new self();
+        $self->version = $version;
+        $self->primary_id = $primary_id;
+        $self->project = $project;
+        $self->channel = $channel;
+        $self->domain = $domain;
+        $self->is_split = $is_split;
+        $self->test_domain = $test_domain;
+        $self->date = $date;
+        $self->save();
+        return $self;
+    }
+}

+<?php
+/**
+ * Created by PhpStorm.
+ * User: zhl
+ * Date: 2025/2/17
+ * Time: 15:04
+ */
+namespace App\Models\Inquiry;
+
+use App\Models\Base;
+
+/**
+ * Class InquiryProjectRoute
+ * @package App\Models\Inquiry
+ */
+class InquiryProjectRoute extends Base
+{
+    /**
+     * @var string 数据表
+     */
+    protected $table = 'gl_inquiry_project_route';
+
+    /**
+     * 保存路由信息
+     * @param int $project_id   gl_inquiry_project 表ID
+     * @param $title
+     * @param $route
+     * @return InquiryProjectRoute
+     */
+    public static function saveProjectRoute($project_id, $title, $route)
+    {
+        $date = date('Ymd');
+        $log = self::where(compact('project_id', 'title'))->first();
+        if ($log) {
+            $log->date = $date;
+            $log->save();
+            return $log;
+        }
+
+        $self = new self();
+        $self->project_id = $project_id;
+        $self->title = $title;
+        $self->route = $route;
+        $self->date = $date;
+        $self->save();
+        return $self;
+    }
+}