From b09064fdc47e055bfe307880f3f20453f8658e23 Mon Sep 17 00:00:00 2001
From: denghy <denghy@fxft.net>
Date: Wed, 16 Jan 2019 11:20:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8C=BA=E5=88=86=E9=98=9F=E5=88=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Domains/Real/Commands/Sync/MongoSync.php   | 4 ++--
 app/Domains/Virtual/Commands/Sync/CardSync.php | 4 ++--
 app/Domains/Virtual/Commands/Sync/LogSync.php  | 4 ++--
 etc/supervisor.conf                            | 9 +++++++++
 4 files changed, 15 insertions(+), 6 deletions(-)
 create mode 100644 etc/supervisor.conf

diff --git a/app/Domains/Real/Commands/Sync/MongoSync.php b/app/Domains/Real/Commands/Sync/MongoSync.php
index 841548ee..25182dd2 100644
--- a/app/Domains/Real/Commands/Sync/MongoSync.php
+++ b/app/Domains/Real/Commands/Sync/MongoSync.php
@@ -47,11 +47,11 @@ class MongoSync extends Command
                 break;
             }
 
-            $jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime));
+            $jobs->push((new MongoSyncJob($page, $this->limit, $utcDateTime))->onQueue('sync'));
         }
 
         app(ConfigService::class)->set(self::CURSOR_KEY, intval($nextMicrotime));
 
-        MongoSyncJob::withChain($jobs->toArray())->dispatch(1, $this->limit, $utcDateTime);
+        MongoSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $utcDateTime);
     }
 }
diff --git a/app/Domains/Virtual/Commands/Sync/CardSync.php b/app/Domains/Virtual/Commands/Sync/CardSync.php
index 9b9fd21f..d38e48bc 100644
--- a/app/Domains/Virtual/Commands/Sync/CardSync.php
+++ b/app/Domains/Virtual/Commands/Sync/CardSync.php
@@ -50,11 +50,11 @@ class CardSync extends Command
                 break;
             }
 
-            $jobs->push(new CardSyncJob($page, $this->limit, $maxId));
+            $jobs->push((new CardSyncJob($page, $this->limit, $maxId))->onQueue('sync'));
         }
 
         app(ConfigService::class)->set(self::CURSOR_KEY, $nextId);
 
-        CardSyncJob::withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId);
+        CardSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId);
     }
 }
diff --git a/app/Domains/Virtual/Commands/Sync/LogSync.php b/app/Domains/Virtual/Commands/Sync/LogSync.php
index 53b0fd5e..0b554111 100644
--- a/app/Domains/Virtual/Commands/Sync/LogSync.php
+++ b/app/Domains/Virtual/Commands/Sync/LogSync.php
@@ -55,11 +55,11 @@ class LogSync extends Command
                 break;
             }
 
-            $jobs->push(new LogSyncJob($page, $this->limit, $maxId));
+            $jobs->push((new LogSyncJob($page, $this->limit, $maxId))->onQueue('sync'));
         }
 
         app(ConfigService::class)->set(self::CURSOR_KEY, $nextId);
 
-        LogSyncJob::withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId);
+        LogSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId);
     }
 }
diff --git a/etc/supervisor.conf b/etc/supervisor.conf
new file mode 100644
index 00000000..987e0c4d
--- /dev/null
+++ b/etc/supervisor.conf
@@ -0,0 +1,9 @@
+[program:vd-worker]
+process_name=%(program_name)s_%(process_num)02d
+command=php /www/vd/artisan queue:work --queue=default,sync --sleep=3 --tries=1 --memory=4096
+autostart=true
+autorestart=true
+user=denghy
+numprocs=2
+redirect_stderr=true
+stdout_logfile=/dev/null