作者 刘锟

update

... ... @@ -10,7 +10,7 @@ use App\Models\Product\Keyword;
use App\Models\Product\KeywordRelated;
use App\Models\Product\Product;
use App\Models\Project\Project;
use App\Models\SyncSubmitTask\SyncSubmitTaskTemp;
use App\Models\SyncSubmitTask\SyncSubmitTask;
use App\Models\WebSetting\WebLanguage;
use App\Services\BatchExportService;
use App\Services\ProjectServer;
... ... @@ -39,15 +39,20 @@ class Temp extends Command
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();
}
});
$list = SyncSubmitTask::where('project_id', 0)->where('data', 'like', '%m.m.%')->limit(5000)->get();
foreach ($list as $item){
dump($item->id);
$data = $item->data;
$item_data = $data['data'];
$item_data = str_replace('m.m.', 'm.',$item_data);
$data['data'] = $item_data;
$data = str_replace('m.m.', 'm.', $data);
$item->data = $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;
}
}