作者 刘锟

update

@@ -10,8 +10,7 @@ use App\Models\Product\Keyword; @@ -10,8 +10,7 @@ use App\Models\Product\Keyword;
10 use App\Models\Product\KeywordRelated; 10 use App\Models\Product\KeywordRelated;
11 use App\Models\Product\Product; 11 use App\Models\Product\Product;
12 use App\Models\Project\Project; 12 use App\Models\Project\Project;
13 -use App\Models\SyncSubmitTask\SyncSubmitTask;  
14 -use App\Models\SyncSubmitTask\SyncSubmitTaskZbj; 13 +use App\Models\SyncSubmitTask\SyncSubmitTaskTemp;
15 use App\Models\WebSetting\WebLanguage; 14 use App\Models\WebSetting\WebLanguage;
16 use App\Services\BatchExportService; 15 use App\Services\BatchExportService;
17 use App\Services\ProjectServer; 16 use App\Services\ProjectServer;
@@ -40,7 +39,7 @@ class Temp extends Command @@ -40,7 +39,7 @@ class Temp extends Command
40 39
41 public function check_m_visit() 40 public function check_m_visit()
42 { 41 {
43 - SyncSubmitTaskZbj::where('id',1594736)->where('project_id', 0)->where('data', 'like', '%m.m.%')->chunk(500, function ($query) { 42 + SyncSubmitTaskTemp::where('id',1594736)->where('project_id', 0)->where('data', 'like', '%m.m.%')->chunk(500, function ($query) {
44 foreach ($query as $item) { 43 foreach ($query as $item) {
45 $item->data = str_replace('m.m.', 'm.', $item->data); 44 $item->data = str_replace('m.m.', 'm.', $item->data);
46 $item->status = 0; 45 $item->status = 0;
  1 +<?php
  2 +
  3 +namespace App\Models\SyncSubmitTask;
  4 +
  5 +use Illuminate\Database\Eloquent\Model;
  6 +use Illuminate\Support\Facades\Log;
  7 +use Illuminate\Support\Facades\Redis;
  8 +
  9 +/**
  10 + * @method static where(string $string, mixed $ip)
  11 + * @method static create(array $data)
  12 + */
  13 +class SyncSubmitTaskTemp extends Model
  14 +{
  15 +
  16 + const TYPE_INQUIRY = 'inquiry';
  17 + const TYPE_VISIT = 'visit';
  18 +
  19 + const TRAFFIC_DEFAULT = 0;
  20 + const TRAFFIC_TRUE = 1;
  21 +
  22 + //设置关联表名
  23 + /**
  24 + * @var mixed
  25 + */
  26 + protected $table = 'gl_sync_submit_task_backup_20250108';
  27 +
  28 + protected $casts = [
  29 + 'data' => 'array',
  30 + ];
  31 +
  32 + /**
  33 + * @param $type
  34 + * @param $data
  35 + * @return bool
  36 + * @author zbj
  37 + * @date 2023/11/28
  38 + */
  39 + public static function addTask($type, $data): bool
  40 + {
  41 + if (empty($data)) {
  42 + return false;
  43 + }
  44 + try {
  45 + $data = [
  46 + 'data' => $data['data'],
  47 + 'domain' => !empty($data['domain']) ? $data['domain'] : request()->getHost(),
  48 + 'ip' => !empty($data['ip']) ? $data['ip'] : request()->getClientIp(),
  49 + 'referer' => !empty($data['referer']) ? $data['referer'] : request()->header('Referer'),
  50 + 'user_agent' => !empty($data['user_agent']) ? $data['user_agent'] : request()->header('user_agent'),
  51 + ];
  52 +
  53 + if(empty($data['referer']) || empty($data['user_agent']) || empty($data['data'])){
  54 + return false;
  55 + }
  56 +
  57 + $model = new self();
  58 + $model->type = $type;
  59 + $model->data = $data;
  60 + !empty($data['submit_time']) && $model->created_at = $data['submit_time'];
  61 + $model->save();
  62 +
  63 + } catch (\Exception $e) {
  64 + Log::error('SyncSubmitTask addTask error', ['msg' => $e->getMessage(), 'data' => $data]);
  65 + return false;
  66 + }
  67 + return true;
  68 + }
  69 +}
@@ -23,7 +23,7 @@ class SyncSubmitTaskZbj extends Model @@ -23,7 +23,7 @@ class SyncSubmitTaskZbj extends Model
23 /** 23 /**
24 * @var mixed 24 * @var mixed
25 */ 25 */
26 - protected $table = 'gl_sync_submit_task_backup_20250108'; 26 + protected $table = 'gl_sync_submit_task_20240516';
27 27
28 protected $casts = [ 28 protected $casts = [
29 'data' => 'array', 29 'data' => 'array',