合并分支 'akun' 到 'master'

Akun



查看合并请求 !1015

@@ -10,6 +10,7 @@ use App\Models\Product\Keyword;
 use App\Models\Product\KeywordRelated;
 use App\Models\Product\KeywordRelated;
 use App\Models\Product\Product;
 use App\Models\Product\Product;
 use App\Models\Project\Project;
 use App\Models\Project\Project;
+use App\Models\SyncSubmitTask\SyncSubmitTaskTemp;
 use App\Models\WebSetting\WebLanguage;
 use App\Models\WebSetting\WebLanguage;
 use App\Services\BatchExportService;
 use App\Services\BatchExportService;
 use App\Services\ProjectServer;
 use App\Services\ProjectServer;
@@ -33,7 +34,22 @@ class Temp extends Command
 
 
     public function handle()
     public function handle()
     {
     {
-        $this->create_all_amp_notify();
+        $this->check_m_visit();
+    }
+
+    public function check_m_visit()
+    {
+        SyncSubmitTaskTemp::where('id',1594736)->where('project_id', 0)->where('data', 'like', '%m.m.%')->chunk(500, function ($query) {
+            foreach ($query as $item) {
+                $item->data = str_replace('m.m.', 'm.', $item->data);
+                $item->status = 0;
+                $item->retry = 0;
+                $item->remark = '';
+                $item->save();
+            }
+        });
+
+        $this->output('success');
     }
     }
 
 
     /**
     /**

+<?php
+
+namespace App\Models\SyncSubmitTask;
+
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Redis;
+
+/**
+ * @method static where(string $string, mixed $ip)
+ * @method static create(array $data)
+ */
+class SyncSubmitTaskTemp extends Model
+{
+
+    const TYPE_INQUIRY = 'inquiry';
+    const TYPE_VISIT = 'visit';
+
+    const TRAFFIC_DEFAULT = 0;
+    const TRAFFIC_TRUE = 1;
+
+    //设置关联表名
+    /**
+     * @var mixed
+     */
+    protected $table = 'gl_sync_submit_task_backup_20250108';
+
+    protected $casts = [
+        'data' => 'array',
+    ];
+
+    /**
+     * @param $type
+     * @param $data
+     * @return bool
+     * @author zbj
+     * @date 2023/11/28
+     */
+    public static function addTask($type, $data): bool
+    {
+        if (empty($data)) {
+            return false;
+        }
+        try {
+            $data = [
+                'data' => $data['data'],
+                'domain' => !empty($data['domain']) ? $data['domain'] : request()->getHost(),
+                'ip' => !empty($data['ip']) ? $data['ip'] : request()->getClientIp(),
+                'referer' => !empty($data['referer']) ? $data['referer'] : request()->header('Referer'),
+                'user_agent' => !empty($data['user_agent']) ? $data['user_agent'] : request()->header('user_agent'),
+            ];
+
+            if(empty($data['referer']) || empty($data['user_agent']) || empty($data['data'])){
+                return false;
+            }
+
+            $model = new self();
+            $model->type = $type;
+            $model->data = $data;
+            !empty($data['submit_time']) && $model->created_at = $data['submit_time'];
+            $model->save();
+
+        } catch (\Exception $e) {
+            Log::error('SyncSubmitTask addTask error', ['msg' => $e->getMessage(), 'data' => $data]);
+            return false;
+        }
+        return true;
+    }
+}