hydrz/vd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MongoCardJob

Browse Source
This commit is contained in:
邓皓元 2019-03-25 17:25:57 +08:00
parent ddeafedd8a
commit 56607abee1
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/Console/Kernel.php
View File

@ -27,6 +27,7 @@ class Kernel extends ConsoleKernel
{ {
$logPath = storage_path('logs/artisan.log'); $logPath = storage_path('logs/artisan.log');
$schedule->command('real:sync-activated')->cron('* */4 * * *')->withoutOverlapping()->appendOutputTo($logPath); $schedule->command('real:sync-activated')->cron('* */4 * * *')->withoutOverlapping()->appendOutputTo($logPath);
$schedule->command('real:sync-cancelled')->cron('* */4 * * *')->withoutOverlapping()->appendOutputTo($logPath);
} }
/** /**

3
app/Domains/Real/Commands/Sync/OrderBaseSync.php
View File

@ -5,6 +5,7 @@ namespace App\Domains\Real\Commands\Sync;
use Carbon\Carbon; use Carbon\Carbon;
use App\Models\Real\Order; use App\Models\Real\Order;
use Illuminate\Support\Facades\DB; use Illuminate\Support\Facades\DB;
use App\Domains\Card\Jobs\MongoCardJob;
use App\Models\Real\OrderCardPartition; use App\Models\Real\OrderCardPartition;
use App\Domains\Real\Repositories\OrderRepository; use App\Domains\Real\Repositories\OrderRepository;
use App\Domains\Real\Repositories\CompanyRepository; use App\Domains\Real\Repositories\CompanyRepository;
@ -53,6 +54,8 @@ class OrderBaseSync extends Command
$value['virtual_order_id'] = $orders[$value['sim']] ?? 0; $value['virtual_order_id'] = $orders[$value['sim']] ?? 0;
} }
MongoCardJob::dispatch(array_pluck($data, 'sim'));
DB::table('real_order_cards')->upsert($data, ['sim', 'deleted_at'], []); DB::table('real_order_cards')->upsert($data, ['sim', 'deleted_at'], []);
} }
app(OrderCardPartitionRepository::class)->forgetCached(); app(OrderCardPartitionRepository::class)->forgetCached();