作者 刘锟

update

... ... @@ -61,8 +61,8 @@ class SyncInquiryProject extends Command
*/
public function handle()
{
$this->output('开始同步v5');
$this->syncGloV5();
// $this->output('开始同步v5');
// $this->syncGloV5();
$this->output('开始同步v6');
$this->syncGloV6();
return true;
... ... @@ -107,7 +107,7 @@ class SyncInquiryProject extends Command
}
// 保存项目 以及 获取路由信息
$project = InquiryProject::saveProject($date, $val['v'], $val['postid'], $val['company'], implode(',', $channel_tmp), $val['main_url'], $recent_inquiry, $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 {
$result = http_get($route_domain . 'k_u_api.php');
... ... @@ -140,13 +140,14 @@ class SyncInquiryProject extends Command
$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')
->leftJoin('gl_project_deploy_optimize', 'gl_project.id', '=', 'gl_project_deploy_optimize.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);
})
->get(['gl_project.id', 'gl_project.title', 'gl_project.level', 'gl_project.channel', 'gl_project.is_upgrade']);
->get(['gl_project.id', 'gl_project.title', 'gl_project.level', 'gl_project.channel', 'gl_project_deploy_optimize.inquiry_prompt']);
// 获取所有项目域名
$domains = DomainInfo::whereIn('project_id', $project->pluck('id')->toArray())->pluck('domain', 'project_id')->toArray();
$form_api = new FormGlobalsoApi();
... ... @@ -157,13 +158,13 @@ class SyncInquiryProject extends Command
continue;
$domain = $domains[$val->id] ?? '';
if(!$domain){
if (!$domain) {
continue;
}
//判断项目7天之内是否有询盘
$recent_inquiry = 0;
$inquiry_list = $form_api->getInquiryList('https://' . $domain . '/', $val->is_upgrade);
$inquiry_list = $form_api->getInquiryList('https://' . $domain . '/');
$last_inquiry_time = $inquiry_list['data']['data'][0]['submit_time'] ?? '';
if ($last_inquiry_time > $last_week_time) {
$recent_inquiry = 1;
... ... @@ -177,8 +178,8 @@ class SyncInquiryProject extends Command
DB::disconnect('custom_mysql');
}
$project = InquiryProject::saveProject($date, InquiryProject::VERSION_SIX, $val->id, $val->title, $val->channel['channel_id'], 'https://' . $domain . '/', $recent_inquiry);
$this->pushTask($project->id);
$project = InquiryProject::saveProject($date, InquiryProject::VERSION_SIX, $val->id, $val->title, $val->channel['channel_id'], 'https://' . $domain . '/', $recent_inquiry, $val->inquiry_prompt ?? '');
// $this->pushTask($project->id);
}
$ids = InquiryProject::where('date', '<', $date)->where('version', '=', InquiryProject::VERSION_SIX)->pluck('id')->toArray();
... ...
... ... @@ -5,6 +5,7 @@
* Date: 2025/2/17
* Time: 11:49
*/
namespace App\Models\Inquiry;
use App\Models\Base;
... ... @@ -34,16 +35,20 @@ class InquiryProject extends Base
* @param $channel
* @param $domain
* @param $recent_inquiry
* @param $remark
* @param int $is_split
* @param string $test_domain
* @return InquiryProject
*/
public static function saveProject($date, $version, $primary_id, $project, $channel, $domain,$recent_inquiry, $is_split = 0, $test_domain = '')
public static function saveProject($date, $version, $primary_id, $project, $channel, $domain, $recent_inquiry, $remark = '', $is_split = 0, $test_domain = '')
{
$log = self::where(compact('version', 'primary_id'))->first();
if ($log) {
$log->date = $date;
$log->project = $project;
$log->domain = $domain;
$log->recent_inquiry = $recent_inquiry;
$log->remark = $remark;
$log->save();
return $log;
}
... ...