From 432dc7b3e73fd400eeb881f0b3eeddfe03b9fc17 Mon Sep 17 00:00:00 2001
From: denghy <denghy@fxft.net>
Date: Wed, 23 Jan 2019 19:05:12 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B6=85=E6=97=B6=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Domains/Real/Jobs/MongoSyncJob.php   | 5 +++++
 app/Domains/Virtual/Jobs/CardSyncJob.php | 5 +++++
 app/Domains/Virtual/Jobs/LogSyncJob.php  | 6 ++++++
 3 files changed, 16 insertions(+)

diff --git a/app/Domains/Real/Jobs/MongoSyncJob.php b/app/Domains/Real/Jobs/MongoSyncJob.php
index 66d09220..1ea7defa 100644
--- a/app/Domains/Real/Jobs/MongoSyncJob.php
+++ b/app/Domains/Real/Jobs/MongoSyncJob.php
@@ -38,6 +38,9 @@ class MongoSyncJob implements ShouldQueue
         $this->page = $page;
         $this->limit = $limit;
         $this->utcDateTime = $utcDateTime;
+        set_time_limit(0);
+        ini_set('memory_limit', '4096m');
+        ini_set('default_socket_timeout', -1);
     }
 
     /**
@@ -98,5 +101,7 @@ class MongoSyncJob implements ShouldQueue
         $builder->connection->insert($sql, Arr::flatten($values, 1));
 
         app(CardRepository::class)->forgetCached();
+
+        Log::info("MongoSyncJob  END #: utcDateTime {$this->utcDateTime} - page {$this->page}");
     }
 }
diff --git a/app/Domains/Virtual/Jobs/CardSyncJob.php b/app/Domains/Virtual/Jobs/CardSyncJob.php
index 41742c2e..a9dafa37 100644
--- a/app/Domains/Virtual/Jobs/CardSyncJob.php
+++ b/app/Domains/Virtual/Jobs/CardSyncJob.php
@@ -40,6 +40,9 @@ class CardSyncJob implements ShouldQueue
         $this->page = $page;
         $this->limit = $limit;
         $this->maxId = $maxId;
+        set_time_limit(0);
+        ini_set('memory_limit', '4096m');
+        ini_set('default_socket_timeout', -1);
     }
 
     /**
@@ -101,5 +104,7 @@ class CardSyncJob implements ShouldQueue
         $builder->connection->insert($sql, Arr::flatten($array, 1));
 
         app(CardRepository::class)->forgetCached();
+
+        Log::info("CardSyncJob END #: maxId {$this->maxId} - page {$this->page}");
     }
 }
diff --git a/app/Domains/Virtual/Jobs/LogSyncJob.php b/app/Domains/Virtual/Jobs/LogSyncJob.php
index 632895bb..d4d6111f 100644
--- a/app/Domains/Virtual/Jobs/LogSyncJob.php
+++ b/app/Domains/Virtual/Jobs/LogSyncJob.php
@@ -64,6 +64,9 @@ class LogSyncJob implements ShouldQueue
         $this->page = $page;
         $this->limit = $limit;
         $this->maxId = $maxId;
+        set_time_limit(0);
+        ini_set('memory_limit', '4096m');
+        ini_set('default_socket_timeout', -1);
     }
 
     /**
@@ -175,6 +178,7 @@ class LogSyncJob implements ShouldQueue
 
         } catch (\Exception $e) {
             DB::rollback();
+            Log::info("LogSyncJob ERROR #: maxId {$this->maxId} - page {$this->page}");
             throw $e;
         }
 
@@ -186,6 +190,8 @@ class LogSyncJob implements ShouldQueue
         app(OrderRenewalPackageCardRepository::class)->forgetCached();
         app(OrderFlowPackageCardsRepository::class)->forgetCached();
         app(OrderCardPartitionRepository::class)->forgetCached();
+
+        Log::info("LogSyncJob END #: maxId {$this->maxId} - page {$this->page}");
     }
 
     /**