init

app/Mail/HelloMail.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace App\Mail;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Mail\Mailable;
+use Illuminate\Mail\Mailables\Content;
+use Illuminate\Mail\Mailables\Envelope;
+use Illuminate\Queue\SerializesModels;
+
+class HelloMail extends Mailable
+{
+    use Queueable, SerializesModels;
+
+    public function __construct(protected $name)
+    {
+        //
+    }
+
+    public function envelope(): Envelope
+    {
+        return new Envelope(
+            subject: '邮件功能测试',
+        );
+    }
+
+    public function content(): Content
+    {
+        return new Content(htmlString: "<p>您好，{$this->name}</p><p>这是一封测试邮件，请勿回复。<br><br>祝，工作顺利！</p>");
+    }
+
+    public function attachments(): array
+    {
+        return [];
+    }
+}

app/Notifications/HelloNotification.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace App\Notifications;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Notifications\Notification;
+
+class HelloNotification extends Notification
+{
+    use Queueable;
+
+    public function __construct(protected $name)
+    {
+        //
+    }
+
+    /**
+     * Get the notification's delivery channels.
+     *
+     * @return array<int, string>
+     */
+    public function via(object $notifiable): array
+    {
+        return ['mail'];
+    }
+
+    /**
+     * Get the mail representation of the notification.
+     */
+    public function toMail(object $notifiable): MailMessage
+    {
+        return (new MailMessage())
+            ->subject("消息测试")
+            ->greeting("您好，{$this->name}")
+            ->line("这是一条测试邮件")
+            ->line("=====")
+            ->salutation("祝，工作愉快！");
+    }
+
+    /**
+     * Get the array representation of the notification.
+     *
+     * @return array<string, mixed>
+     */
+    public function toArray(object $notifiable): array
+    {
+        return [
+            //
+        ];
+    }
+}

packages/bydauto/config/bydauto.php

@@ -1,4 +1,13 @@
 <?php
 
 return [
+    'alipay' => [
+        'app_id' => '2021004168614440',
+        'merchant_private_key' => 'app/pkg/app-2021004168614440/app_key_private_RSA2048.txt',
+        'alipay_public_key' => 'app/pkg/app-2021004168614440/alipay_pub.txt',
+    ],
+    'adops' => [
+        'biz_token' => env('ADOPS_BIZ_TOKEN'),
+        'principal_tag' => env('ADOPS_PRINCIPAL_TAG'),
+    ],
 ];

packages/bydauto/migrations/2024_11_13_160651_create_bydauto_tables.php

@@ -16,6 +16,17 @@ public function up(): void
             $table->string('remark')->nullable();
         });
 
+        Schema::create('bydauto_activity', function (Blueprint $table) {
+            $table->id();
+            $table->timestamp('date_created');
+            $table->timestamp('date_updated');
+            $table->string('status')->nullable();
+            $table->string('name')->nullable();
+            $table->string('content')->nullable();
+            $table->unsignedBigInteger('related_id')->nullable();
+            $table->string('related_type')->nullable();
+        });
+
         Schema::create('bydauto_testdrive', function (Blueprint $table) {
             $table->id();
             $table->timestamp('date_created');
@@ -26,9 +37,18 @@ public function up(): void
             $table->string('platform')->nullable();
             $table->string('source')->nullable();
             $table->string('request_id')->nullable();
+            $table->string('external_id')->nullable();
             $table->jsonb('meta')->nullable();
             $table->jsonb('rawdata')->nullable();
         });
+
+        Schema::create('bydauto_promote_page', function (Blueprint $table) {
+            $table->id();
+            $table->string('page_id')->nullable();
+            $table->string('name')->nullable();
+            $table->string('type')->nullable();
+            $table->string('property_list')->nullable();
+        });
     }
 
     public function down(): void

packages/bydauto/routes/api.php

@@ -14,4 +14,5 @@
     Route::post('isaas', [BYDAutoController::class, 'isaas']);
     Route::post('cluepackage', [BYDAutoController::class, 'cluepackage']);
     Route::post('notice', [BYDAutoController::class, 'notice']);
+    Route::any('leads-data-send', [BYDAutoController::class, 'leadsDataSend']);
 });

packages/bydauto/src/BYDAutoServiceProvider.php

@@ -2,9 +2,9 @@
 
 namespace BYDAuto;
 
+use BYDAuto\Commands\AliPromotepageCommand;
 use BYDAuto\Commands\BYDAutoCommand;
 use BYDAuto\Commands\BYDAutoNoticeCommand;
-use BYDAuto\Commands\CheryTransferCommand;
 use BYDAuto\Commands\GeocodingCommand;
 use Illuminate\Console\Scheduling\Schedule;
 use Illuminate\Support\ServiceProvider;
@@ -19,7 +19,7 @@ public function register()
         $this->loadMigrationsFrom($root . '/migrations');
 
         $this->commands([
-            CheryTransferCommand::class,
+            AliPromotepageCommand::class,
             BYDAutoCommand::class,
             GeocodingCommand::class,
             BYDAutoNoticeCommand::class,
@@ -32,9 +32,9 @@ public function register()
 
     public function boot()
     {
-        $this->app->booted(function () {
+        // $this->app->booted(function () {
-            $schedule = $this->app->make(Schedule::class);
+        //     $schedule = $this->app->make(Schedule::class);
-            $schedule->command('BYDAuto:notice')->dailyAt('09:00');
+        //     $schedule->command('bydauto:notice')->dailyAt('09:00');
-        });
+        // });
     }
 }

packages/bydauto/src/CheryClueApi.php

@@ -1,71 +0,0 @@
-<?php
-
-namespace BYDAuto;
-
-use GuzzleHttp\Client;
-
-class CheryClueApi
-{
-    protected $appId;
-
-    protected $appSecret;
-
-    protected $endpoint;
-
-    protected $httpClient;
-
-    private static $instance;
-
-    private function __construct()
-    {
-        $this->appId = config('chery-crm.scrm.app_id');
-        $this->appSecret = config('chery-crm.scrm.secret');
-        $this->endpoint = config('chery-crm.scrm.endpoint');
-        $this->httpClient = new Client(['base_uri' => $this->endpoint, 'timeout' => 10]);
-    }
-
-    public static function getInstance(): self
-    {
-        if (!self::$instance) {
-            self::$instance = new self();
-        }
-        return self::$instance;
-    }
-
-    /**
-     * 线索推送
-     *
-     * @param array $data
-     * @return CheryResult
-     */
-    public function cluePush($data)
-    {
-        $token = $this->getToken();
-        $response = $this->httpClient->post('/api/app/chery-clue/api/clue/push/channel', ['json' => $data, 'headers' => ['x-csrf-token' => $token]]);
-        $content = json_decode($response->getBody()->getContents(), true);
-        $result = new CheryResult($content);
-        if ($result->code !== '0') {
-            $message = $result->get('msg', '推送线索失败');
-            throw new \Exception($message);
-        }
-        return $result;
-    }
-
-    public function getToken($force = false)
-    {
-        $token = cache('pkg:chery-scrm-token');
-        if ($force || !$token) {
-            $response = $this->httpClient->get('/api/app/chery-clue/api/clue/channel/getToken', ['query' => ['appId' => $this->appId, 'appSecret' => $this->appSecret]]);
-            $json = json_decode($response->getBody()->getContents(), true);
-            if ($json['code'] === '0') {
-                $token = $json['data'];
-                // 有效期4小时，提前10分钟刷新
-                cache(['pkg:chery-scrm-token' => $token], now()->addSeconds(4 * 3600 - 600));
-            } else {
-                $message = $json['msg'] ?? 'pkg:chery-scrm-token 获取失败';
-                throw new \Exception($message);
-            }
-        }
-        return $token;
-    }
-}

packages/bydauto/src/CheryResult.php

@@ -1,26 +0,0 @@
-<?php
-
-namespace BYDAuto;
-
-use BYDAuto\Foundation\DataTransfer;
-use Illuminate\Support\Arr;
-
-class CheryResult extends DataTransfer
-{
-    public $code;
-
-    public $msg;
-
-    public $data;
-
-    public $reqId;
-
-    public function __construct($attributes)
-    {
-        $this->code = Arr::get($attributes, 'code');
-        $this->msg = Arr::get($attributes, 'msg');
-        $this->data = Arr::get($attributes, 'data');
-        $this->reqId = Arr::get($attributes, 'reqId');
-        $this->attributes = $attributes;
-    }
-}

packages/bydauto/src/Commands/AliPromotepageCommand.php

@@ -0,0 +1,134 @@
+<?php
+
+namespace BYDAuto\Commands;
+
+use Carbon\Carbon;
+use BYDAuto\Foundation\AlipayEasySDKFactory;
+use BYDAuto\Models\PromotePage;
+use BYDAuto\Models\Testdrive;
+use Illuminate\Console\Command;
+
+/**
+ * 支付宝自建推广页留资数据查询.
+ */
+class AliPromotepageCommand extends Command
+{
+    protected $signature = 'bydauto:promotepage';
+
+    protected $description = '查询自建推广页列表';
+
+    public function handle()
+    {
+        $this->sync();
+    }
+
+    public function sync()
+    {
+        $this->info('===== 开始同步推广页列表');
+        info('===== 开始同步推广页列表');
+        $this->batchquery();
+        $pages = PromotePage::query()->get();
+        foreach ($pages as $page) {
+            $this->download($page->page_id);
+        }
+        return Command::SUCCESS;
+    }
+
+    /**
+     * 自建推广页留资数据查询
+     * https://opendocs.alipay.com/open/1df3222a_alipay.data.dataservice.ad.promotepage.download?scene=common&pathHash=734c25f8.
+     * @param mixed $promote_page_id
+     */
+    public function download($promote_page_id)
+    {
+        $textParams = [];
+        $bizParams['principal_tag'] = config('bydauto.adops.principal_tag');
+        $bizParams['biz_token'] = config('bydauto.adops.biz_token');
+        $bizParams['page_no'] = 1;
+        $bizParams['page_size'] = 1000;
+        $bizParams['promote_page_id'] = $promote_page_id;
+        $bizParams['start_date'] = Carbon::now()->subDays(2)->format('Y-m-d');
+        $bizParams['end_date'] = Carbon::now()->format('Y-m-d');
+
+        $message = sprintf('===== 开始同步推广页留资数据：[页面ID] %s [开始日期] %s [结束日期] %s', $promote_page_id, $bizParams['start_date'], $bizParams['end_date']);
+        $this->info($message);
+        info($message);
+
+        try {
+            $this->info('===== 正在查询第 1 页');
+            info('===== 正在查询第 1 页');
+            $result = (new AlipayEasySDKFactory())->execute('alipay.data.dataservice.ad.promotepage.download', $textParams, $bizParams);
+            if ($result->code === '10000') {
+                $body = json_decode($result->httpBody, true);
+                $resp = $body['alipay_data_dataservice_ad_promotepage_download_response'] ?? [];
+
+                $respTotal = $resp['total'] ?? 0;
+                $respList = $resp['list'] ?? [];
+                if ($respTotal > 0) {
+                    $items = collect($respList);
+                    $items->each(fn($item) => Testdrive::syncFromAliPromote($item, $promote_page_id));
+                    $this->info('===== 同步完成, 共 ' . $items->count() . ' 条数据');
+                    info('===== 同步完成, 共 ' . $items->count() . ' 条数据');
+                }
+
+                // Check if there are more pages to query
+                $respTotal = $body['alipay_data_dataservice_ad_promotepage_download_response']['total'];
+                $totalPages = ceil($respTotal / $bizParams['page_size']);
+                if ($totalPages > 1) {
+                    for ($page = 2; $page <= $totalPages; ++$page) {
+                        $this->info('===== 正在查询第 ' . $page . ' 页');
+                        info('===== 正在查询第 ' . $page . ' 页');
+                        $bizParams['page_no'] = $page;
+                        $result = (new AlipayEasySDKFactory())->execute('alipay.data.dataservice.ad.promotepage.download', $textParams, $bizParams);
+                        if ($result->code === '10000') {
+                            $body = json_decode($result->httpBody, true);
+                            $items = collect($body['alipay_data_dataservice_ad_promotepage_download_response']['list']);
+                            $items->each(fn($item) => Testdrive::syncFromAliPromote($item, $promote_page_id));
+                            $this->info('===== 同步完成, 共 ' . $items->count() . ' 条数据');
+                            info('===== 同步完成, 共 ' . $items->count() . ' 条数据');
+                        }
+                    }
+                }
+            }
+        } catch (\Throwable $th) {
+            info('===== 自建推广页留资数据查询失败：');
+            info($th->getMessage());
+            $this->error($th->getMessage());
+        }
+    }
+
+    /**
+     * 自建推广页查询
+     * https://opendocs.alipay.com/open/e060c7d1_alipay.data.dataservice.ad.promotepage.batchquery?scene=common&pathHash=ecc1df2f.
+     */
+    public function batchquery()
+    {
+        $textParams = [];
+        $bizParams['principal_tag'] = config('bydauto.adops.principal_tag');
+        $bizParams['biz_token'] = config('bydauto.adops.biz_token');
+        $bizParams['page_no'] = 1;
+        $bizParams['type'] = "COLLECT_INFO";
+        $bizParams['page_size'] = 100;
+
+        try {
+            $result = (new AlipayEasySDKFactory())->execute('alipay.data.dataservice.ad.promotepage.batchquery', $textParams, $bizParams);
+            if ($result->code === '10000') {
+                $body = json_decode($result->httpBody, true);
+                $pages = collect($body['alipay_data_dataservice_ad_promotepage_batchquery_response']['list']);
+                $pages->map(function ($page) {
+                    PromotePage::query()->updateOrCreate(['page_id' => $page['id']], [
+                        'name' => $page['name'],
+                        'type' => $page['type'],
+                        'property_list' => json_encode($page['property_list'], JSON_UNESCAPED_UNICODE),
+                    ]);
+                });
+                $this->table(['id', 'name', 'type'], $pages->map(function ($page) {
+                    return ['id' => $page['id'], 'name' => $page['name'], 'type' => $page['type']];
+                }));
+            }
+        } catch (\Exception $e) {
+            // ...
+            $this->error($e->getMessage());
+        }
+    }
+}

packages/bydauto/src/Commands/BYDAutoCommand.php

@@ -2,9 +2,13 @@
 
 namespace BYDAuto\Commands;
 
+use App\Mail\HelloMail;
+use App\Notifications\HelloNotification;
 use BYDAuto\Models\Contact;
 use BYDAuto\Models\Testdrive;
 use Illuminate\Console\Command;
+use Illuminate\Notifications\Messages\MailMessage;
+use Illuminate\Support\Facades\Mail;
 
 class BYDAutoCommand extends Command
 {
@@ -23,6 +27,31 @@ public function handle()
         }
     }
 
+    public function action_mail_test()
+    {
+        $users = [
+            ['remark' => '陈结婷', 'email' => '402917192@qq.com'],
+            ['remark' => '何汝立', 'email' => '136111753@qq.com'],
+            ['remark' => '刘梦吉', 'email' => '842681856@qq.com'],
+            ['remark' => '詹林钦', 'email' => '1908995103@qq.com'],
+            ['remark' => '王迎迎', 'email' => '1123724727@qq.com'],
+            ['remark' => '曾嘉威', 'email' => '2951015145@qq.com'],
+            ['remark' => '刘甜甜', 'email' => '941605227@qq.com'],
+            ['remark' => '符志勇', 'email' => '583493528@qq.com'],
+            ['remark' => '廖瑞莹', 'email' => '42794345@qq.com'],
+            ['remark' => '刘志伟', 'email' => '857284399@qq.com'],
+            ['remark' => '张光东', 'email' => '543396628@qq.com'],
+            ['remark' => '赖俊文', 'email' => '591908300@qq.com'],
+            ['remark' => '刘星宇', 'email' => '1776807891@qq.com'],
+            ['remark' => '郑立佳', 'email' => '315783857@qq.com'],
+            ['remark' => '郑广勇', 'email' => '973978463@qq.com'],
+            ['remark' => '湛善栋', 'email' => '838406377@qq.com']
+        ];
+
+        $message = new HelloMail(name: '张三');
+        Mail::to('sam@ifme.in')->send($message);
+    }
+
     public function action_init()
     {
         $this->call('db:wipe');

packages/bydauto/src/Commands/CheryTransferCommand.php

@@ -1,80 +0,0 @@
-<?php
-
-namespace BYDAuto\Commands;
-
-use BYDAuto\Jobs\TestdrivePushJob;
-use BYDAuto\Models\Testdrive;
-use BYDAuto\Models\Vehicle;
-use Illuminate\Console\Command;
-
-class CheryTransferCommand extends Command
-{
-    // php artisan BYDAuto:transfer vehicle_alias_update
-    // php artisan BYDAuto:transfer dispatch_by_mobile
-    // php artisan BYDAuto:transfer dispatch_all_draft
-    protected $signature = 'bydauto:transfer {action}';
-
-    protected $description = '奇瑞SCRM数据传输';
-
-    public function handle()
-    {
-        $action = $this->argument('action');
-        $this->{'action_' . $action}();
-    }
-
-    public function action_dispatch_all_draft()
-    {
-        $items = Testdrive::query()
-            ->where('status', Testdrive::STATUS_DRAFT)
-            ->get();
-        $this->showTable($items);
-
-        $confirm = $this->confirm('是否确认推送？', true);
-        if (!$confirm) {
-            return Command::SUCCESS;
-        }
-        foreach ($items as $model) {
-            TestdrivePushJob::dispatch($model);
-        }
-        return Command::SUCCESS;
-    }
-
-    public function action_vehicle_alias_update()
-    {
-        $items = Vehicle::query()->get();
-        $items->each(function ($item) {
-            $cleanName = preg_replace('/\s+/', '', $item->name);
-            $alias = [$item->name];
-            if ($item->name !== $cleanName) {
-                $alias[] = $cleanName;
-            }
-            $item->update(['alias' => $alias]);
-        });
-    }
-
-    public function action_dispatch_by_mobile()
-    {
-        $mobiles = $this->ask('请输入手机号码，多个用逗号分隔');
-        $mobiles = explode(',', $mobiles);
-
-        $items = Testdrive::query()
-            ->whereIn('mobile', $mobiles)
-            ->get();
-        $this->showTable($items);
-
-        $confirm = $this->confirm('是否确认推送？', true);
-        if (!$confirm) {
-            return Command::SUCCESS;
-        }
-        foreach ($items as $model) {
-            TestdrivePushJob::dispatch($model);
-        }
-        return Command::SUCCESS;
-    }
-
-    protected function showTable($items)
-    {
-        $columns = ['id', 'status', 'name', 'mobile'];
-        $this->table($columns, $items->map(fn ($item) => $item->only($columns)));
-    }
-}

packages/bydauto/src/Controllers/BYDAutoController.php

@@ -29,6 +29,34 @@ public function testdrive(Request $request)
         return response()->json(['code' => 0, 'message' => '提交成功', 'request_id' => $requestId]);
     }
 
+    // https://vm1112app.arsk.net/pkg/bydauto/leads-data-send
+    // 车主频道车主认证功能：线索数据发送
+    // spi.alipay.eco.mycar.leads.data.send
+    // https://opendocs.alipay.com/pre-open/86118bff_spi.alipay.eco.mycar.leads.data.send?pathHash=d19083e7
+    public function leadsDataSend(Request $request)
+    {
+        $input = $request->all();
+        info('===== leadsDataSend', $input);
+        $biz_content = $input['biz_content'] ?? '';
+        throw_if(empty($biz_content), ValidationException::withMessages(['biz_content' => 'missing biz_content']));
+
+        $key = 'f4LNNKURSfT4/p5ne4xXdW45vcUahojQDEb+dejxUq8=';
+        try {
+            $iv = str_repeat("\0", 16);
+            $data = openssl_decrypt(base64_decode($biz_content), 'AES-256-CBC', base64_decode($key), OPENSSL_RAW_DATA, $iv);
+            $data = json_decode($data, true);
+            info('===== [leadsDataSend]', $data);
+            // Testdrive::leadsDataSend($data);
+        } catch (\Throwable $th) {
+            info('===== [biz_content decrypt fail]', [$th->getMessage()]);
+        }
+        // 留咨成功 success 留咨失败 failed 重复留咨 duplicate submit 系统异常 system error
+        $response = ['msg' => 'success', 'code' => '10000'];
+        $output['response'] = json_encode($response);
+        $output['sign'] = $this->sign($response);
+        return response()->json($output);
+    }
+
     // 行业云留资SPI接口 实现
     // https://vm1112app.arsk.net/pkg/bydauto/isaas
     public function isaas(Request $request)

packages/bydauto/src/Foundation/AlipayEasySDKFactory.php

@@ -23,10 +23,10 @@ protected function getOptions()
         $options->protocol = 'https';
         $options->gatewayHost = 'openapi.alipay.com';
         $options->signType = 'RSA2';
-        $options->appId = config('chery-crm.alipay.app_id');
+        $options->appId = config('bydauto.alipay.app_id');
-        $merchantPrivateKey = file_get_contents(storage_path(config('chery-crm.alipay.merchant_private_key')));
+        $merchantPrivateKey = file_get_contents(storage_path(config('bydauto.alipay.merchant_private_key')));
         $options->merchantPrivateKey = $merchantPrivateKey;
-        $alipayPublicKey = file_get_contents(storage_path(config('chery-crm.alipay.alipay_public_key')));
+        $alipayPublicKey = file_get_contents(storage_path(config('bydauto.alipay.alipay_public_key')));
         $options->alipayPublicKey = $alipayPublicKey;
         return $options;
     }

packages/bydauto/src/Models/PromotePage.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace BYDAuto\Models;
+
+use Carbon\Carbon;
+use Illuminate\Database\Eloquent\Model;
+
+/**
+ * PromotePage.
+ *
+ * @property int $id
+ * @property string $page_id
+ * @property string $name
+ * @property string $type
+ * @property array $property_list
+ * @property null|Carbon $created_at
+ * @property null|Carbon $updated_at
+ */
+class PromotePage extends Model
+{
+    public $timestamps = false;
+    protected $table = 'bydauto_promote_page';
+    protected $fillable = ['id', 'page_id', 'name', 'type', 'property_list'];
+}

packages/bydauto/src/Models/Testdrive.php

@@ -31,7 +31,7 @@ class Testdrive extends Model
 
     protected $table = 'bydauto_testdrive';
 
-    protected $fillable = ['status', 'name', 'mobile', 'platform', 'source', 'meta', 'rawdata', 'request_id'];
+    protected $fillable = ['status', 'name', 'mobile', 'platform', 'source', 'meta', 'rawdata', 'request_id', 'external_id'];
 
     protected $casts = ['meta' => 'json', 'rawdata' => 'json'];
 
@@ -119,4 +119,71 @@ public static function cluepackage($data)
 
         return $model;
     }
+
+
+    public static function syncFromAliPromote($data, $pageId)
+    {
+        // {
+        //     "biz_no":"PROMOTE_PAGE#COLLECT_INFO#99800024#22f01c68c22e0572dbbf48e5abddce9f_1200811224",
+        //     "encrypt_uid":"g0uZivSfdAauU6JcY6qU5zUYbPJAZusYEhYlBjWoD10=",
+        //     "property_list":[
+        //         {"key":"phone", "name":"手机号", "value":"13823496047"},
+        //         {"key":"name", "name":"姓名", "value":"罗"},
+        //         {"key":"tree_option_1", "name":"意向车型", "value":"瑞虎8L"},
+        //         {"key":"tree_option_2", "name":"所在城市", "value":"黑龙江省-佳木斯市"},
+        //         {"key":"principal_name", "name":"商家名称", "value":"安徽奇瑞汽车销售有限公司"},
+        //         {"key":"market_target_name", "name":"营销目标", "value":"销售线索搜集"},
+        //         {"key":"plan_name", "name":"计划名称", "value":"cpa-瑞虎8L-0823-1"},
+        //         {"key":"plan_id", "name":"计划ID", "value":"131702876"},
+        //         {"key":"group_name", "name":"单元名称", "value":"cpa-瑞虎8L-0823-1"},
+        //         {"key":"group_id", "name":"单元ID", "value":"144611104"},
+        //         {"key":"ad_name", "name":"创意名称", "value":"cpa-瑞虎8L-0823-1"},
+        //         {"key":"creative_id", "name":"创意ID", "value":"170187992"},
+        //         {"key":"interested_desc", "name":"意向线索", "value":"空白"},
+        //         {"key":"click_id", "name":"点击ID", "value":"7f9685e2edf3a48996fbc444473035a4"}
+        //     ]
+        // }
+
+        $externalId = $data['biz_no'];
+        $model = static::query()->where('external_id', $externalId)->first();
+        if ($model) {
+            return $model;
+        }
+        $model = new static(['source' => 'alipromote:' . $pageId, 'rawdata' => $data, 'external_id' => $externalId]);
+        foreach ($data['property_list'] as $prop) {
+            // 手机号
+            if ($prop['key'] === 'phone') {
+                $model->mobile = $prop['value'];
+            }
+            // 姓名
+            if ($prop['key'] === 'name') {
+                $model->name = $prop['value'];
+            }
+            // // 意向车型
+            // if (Str::contains($prop['name'], '车型')) {
+            //     $model->vehicle = $prop['value'];
+            // }
+            // // 城市: 黑龙江省-哈尔滨市
+            // if (Str::contains($prop['name'], '城市')) {
+            //     if (Str::contains($prop['value'], '-')) {
+            //         [$model->province, $model->city] = explode('-', $prop['value']);
+            //     } else {
+            //         $model->city = $prop['value'];
+            //     }
+            // }
+            // // 门店：黑龙江省-哈尔滨市-哈尔滨若冲
+            // if (Str::contains($prop['name'], '门店')) {
+            //     if (Str::contains($prop['value'], '-')) {
+            //         $value = explode('-', $prop['value']);
+            //         $model->province = $value[0] ?? '';
+            //         $model->city = $value[1] ?? '';
+            //         $model->dealer = $value[2] ?? '';
+            //     } else {
+            //         $model->dealer = $prop['value'];
+            //     }
+            // }
+        }
+        $model->save();
+        return $model;
+    }
 }