同步询盘项目

刘锟
app/Console/Commands/Inquiry/SyncInquiryProject.php
app/Models/Inquiry/InquiryProject.php
--- a/app/Console/Commands/Inquiry/SyncInquiryProject.php
查看文件 @5302f05
+++ b/app/Console/Commands/Inquiry/SyncInquiryProject.php
查看文件 @5302f05
@@ -5,10 +5,13 @@
  * Date: 2025/2/17
  * Time: 11:24
  */
+
 namespace App\Console\Commands\Inquiry;
+use App\Helper\FormGlobalsoApi;
 use App\Models\Channel\Channel;
 use App\Models\Domain\DomainInfo;
+use App\Models\Inquiry\InquiryFormData;
 use App\Models\Inquiry\InquiryProject;
 use App\Models\Inquiry\InquiryProjectRoute;
 use App\Models\Product\Category;
@@ -72,10 +75,11 @@ class SyncInquiryProject extends Command
     public function syncGloV5()
     {
         $date = intval(date('Ymd'));
+        $last_week_time = date('Y-m-d H:i:s', strtotime('-1 week'));
         $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)
-        {
+        $form_api = new FormGlobalsoApi();
+        foreach ($result as $key => $val) {
             echo '同步项目：' . $val['postid'] . ' - ' . $val['company'] . PHP_EOL;
             // 记录渠道商, 如果渠道有问题， 记录日志， 跳过当前项目， 处理数据后， 第二天再重新同步
             $channel_tmp = [];
@@ -94,10 +98,18 @@ class SyncInquiryProject extends Command
                 continue;
             }
+            //判断项目7天之内是否有询盘
+            $recent_inquiry = 0;
+            $inquiry_list = $form_api->getInquiryAll($val['main_url']);
+            $last_inquiry_time = $inquiry_list['data']['data'][0]['submit_time'] ?? '';
+            if ($last_inquiry_time >= $last_week_time) {
+                $recent_inquiry = 1;
+            }
+
             // 保存项目 以及 获取路由信息
-            $project = InquiryProject::saveProject($date, $val['v'], $val['postid'], $val['company'], implode(',', $channel_tmp), $val['main_url'], $val['is_split'], $val['test_url']);
+            $project = InquiryProject::saveProject($date, $val['v'], $val['postid'], $val['company'], implode(',', $channel_tmp), $val['main_url'], $recent_inquiry, $val['is_split'], $val['test_url']);
             $route_domain = $val['is_split'] && $val['test_url'] ? $val['test_url'] : $val['main_url'];
-            try{
+            try {
                 $result = http_get($route_domain . 'k_u_api.php');
                 if (empty($result)) {
                     $this->log('syncGloV5Route 未获取到路由信息：' . $project->id . ', 路由获取地址：' . $route_domain . 'k_u_api.php');
@@ -125,6 +137,7 @@ class SyncInquiryProject extends Command
     public function syncGloV6()
     {
         $date = intval(date('Ymd'));
+        $last_week_time = date('Y-m-d H:i:s', strtotime('-1 week'));
         // 获取优化中台项目
         $project = Project::leftJoin('gl_project_online_check', 'gl_project.id', '=', 'gl_project_online_check.project_id')
             ->where('gl_project.type', Project::TYPE_TWO)
@@ -133,15 +146,33 @@ class SyncInquiryProject extends Command
                 $query->orwhere('gl_project_online_check.qa_status', OnlineCheck::STATUS_ONLINE_TRUE)
                     ->orwhere('gl_project.is_upgrade', Project::IS_UPGRADE_TRUE);
             })
-            ->get(['gl_project.id', 'gl_project.title', 'gl_project.level', 'gl_project.channel']);
+            ->get(['gl_project.id', 'gl_project.title', 'gl_project.level', 'gl_project.channel', 'gl_project.is_upgrade']);
         // 获取所有项目域名
         $domains = DomainInfo::whereIn('project_id', $project->pluck('id')->toArray())->pluck('domain', 'project_id')->toArray();
-        foreach ($project as $key=>$val) {
+        $form_api = new FormGlobalsoApi();
+        foreach ($project as $key => $val) {
             echo '同步项目：' . $val->id . ' - ' . $val->title . PHP_EOL;
             // 过滤暂停优化项目, 映射类型2， model没有定义常量
             if (in_array(2, $val->level))
                 continue;
-            $project = InquiryProject::saveProject($date,InquiryProject::VERSION_SIX, $val->id, $val->title, $val->channel['channel_id'], 'https://'.$domains[$val->id].'/');
+
+            //判断项目7天之内是否有询盘
+            $recent_inquiry = 0;
+            $inquiry_list = $form_api->getInquiryAll('https://' . $domains[$val->id] . '/', $val->is_upgrade);
+            $last_inquiry_time = $inquiry_list['data']['data'][0]['submit_time'] ?? '';
+            if ($last_inquiry_time > $last_week_time) {
+                $recent_inquiry = 1;
+            } else {
+                //自定义询盘也加入判断
+                ProjectServer::useProject($val->id);
+                $last_inquiry_time = InquiryFormData::orderBy('submit_at', 'desc')->value('submit_at');
+                if ($last_inquiry_time > $last_week_time) {
+                    $recent_inquiry = 1;
+                }
+                DB::disconnect('custom_mysql');
+            }
+
+            $project = InquiryProject::saveProject($date, InquiryProject::VERSION_SIX, $val->id, $val->title, $val->channel['channel_id'], 'https://' . $domains[$val->id] . '/', $recent_inquiry);
             $this->pushTask($project->id);
         }
--- a/app/Models/Inquiry/InquiryProject.php
查看文件 @5302f05
+++ b/app/Models/Inquiry/InquiryProject.php
查看文件 @5302f05
@@ -33,15 +33,17 @@ class InquiryProject extends Base
      * @param $project
      * @param $channel
      * @param $domain
+     * @param $recent_inquiry
      * @param int $is_split
      * @param string $test_domain
      * @return InquiryProject
      */
-    public static function saveProject($date, $version, $primary_id, $project, $channel, $domain, $is_split = 0, $test_domain = '')
+    public static function saveProject($date, $version, $primary_id, $project, $channel, $domain,$recent_inquiry, $is_split = 0, $test_domain = '')
     {
         $log = self::where(compact('version', 'primary_id'))->first();
         if ($log) {
             $log->date = $date;
+            $log->recent_inquiry = $recent_inquiry;
             $log->save();
             return $log;
         }
@@ -54,6 +56,7 @@ class InquiryProject extends Base
         $self->is_split = $is_split;
         $self->test_domain = $test_domain;
         $self->date = $date;
+        $self->recent_inquiry = $recent_inquiry;
         $self->save();
         return $self;
     }