bydauto/web-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove push_missing
All checks were successful
Deploy to Production / deploy (push) Successful in 15s
Details

Browse Source
This commit is contained in:
珂珂 2024-11-29 14:52:08 +08:00
parent 8fc89088e4
commit cd10b62e27
1 changed files with 38 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

79
packages/bydauto/src/Commands/BYDAutoCommand.php
View File

@ -43,47 +43,44 @@ public function action_init()
} }
// 漏发试驾数据 // 漏发试驾数据
public function action_push_missing() // public function action_push_missing()
{ // {
$items = Testdrive::query() // $items = Testdrive::query()
->where('date_updated', '>', '2024-11-21 09:06:00') // ->where('date_updated', '>', '2024-11-21 09:06:00')
->get(); // ->get();
// $contacts = Contact::query()
$contacts = Contact::query() // ->where('status', Contact::STATUS_PUBLISHED)
->where('status', Contact::STATUS_PUBLISHED) // ->orderBy('id')
->orderBy('id') // ->get();
->get(); // $count = $contacts->count();
// $offset = cache()->get('push2contact:offset', 0);
$count = $contacts->count(); // $sendList = [];
$offset = cache()->get('push2contact:offset', 0); // foreach ($items as $item) {
$sendList = []; // if ($this->isDirtyName($item->name)) {
// info("试驾数据 {$item->id} 姓名异常 {$item->name}");
foreach ($items as $item) { // $this->info("试驾数据 {$item->id} 姓名异常 {$item->name}");
if ($this->isDirtyName($item->name)) { // $item->update(['status' => Testdrive::STATUS_REJECTED]);
info("试驾数据 {$item->id} 姓名异常 {$item->name}"); // continue;
$this->info("试驾数据 {$item->id} 姓名异常 {$item->name}"); // }
$item->update(['status' => Testdrive::STATUS_REJECTED]); // $contact = $contacts[$offset];
continue; // $item->update(['status' => Testdrive::STATUS_PUBLISHED, 'contact_id' => $contact->id, 'contact_info' => $contact->toArray()]);
} // if (!isset($sendList[$contact->id])) {
$contact = $contacts[$offset]; // $sendList[$contact->id] = [$item];
$item->update(['status' => Testdrive::STATUS_PUBLISHED, 'contact_id' => $contact->id, 'contact_info' => $contact->toArray()]); // } else {
if (!isset($sendList[$contact->id])) { // $sendList[$contact->id][] = $item;
$sendList[$contact->id] = [$item]; // }
} else { // $offset = ($offset + 1) % $count;
$sendList[$contact->id][] = $item; // }
} // cache()->forever('push2contact:offset', $offset);
$offset = ($offset + 1) % $count; // // 开始发送
} // foreach ($sendList as $contactId => $items) {
cache()->forever('push2contact:offset', $offset); // $contact = $contacts->firstWhere('id', $contactId);
// 开始发送 // $this->info("发送试驾数据给联系人 {$contact->id} 总数 " . count($items));
foreach ($sendList as $contactId => $items) { // info("发送试驾数据给联系人 {$contact->id} 总数 " . count($items));
$contact = $contacts->firstWhere('id', $contactId); // $contact->notify(new TestdirveNotification($items));
$this->info("发送试驾数据给联系人 {$contact->id} 总数 " . count($items)); // }
info("发送试驾数据给联系人 {$contact->id} 总数 " . count($items)); // return Command::SUCCESS;
$contact->notify(new TestdirveNotification($items)); // }
}
return Command::SUCCESS;
}
// 同步试驾数据给到经销商联系人 按顺序每个联系人分配一个试驾数据 // 同步试驾数据给到经销商联系人 按顺序每个联系人分配一个试驾数据
public function action_push2contact() public function action_push2contact()