|
|
@@ -39,7 +39,7 @@ class SyncWMSOrderTask extends Command
|
|
|
public function handle()
|
|
|
{
|
|
|
$is_enabled= config('sync.order_sync.cache_prefix.enabled');
|
|
|
- sleep(rand(5,10));
|
|
|
+ sleep(rand(2,3));
|
|
|
if($is_enabled=='false')return;
|
|
|
$this->syncCreatedOrder();
|
|
|
$this->syncUpdatedOrder();
|
|
|
@@ -59,7 +59,7 @@ class SyncWMSOrderTask extends Command
|
|
|
$orderService = app('OrderService');
|
|
|
$oracleDOCOrderHeaderService = app('OracleDocOrderHeaderService');
|
|
|
|
|
|
- $last_date = $orderService->getOrderSyncAt($newest,'newest'); // 获取时间点
|
|
|
+ $last_date = $orderService->getOrderSyncAt($newest,'newest'); // 获取创建时间点
|
|
|
|
|
|
$orderHeaders = $oracleDOCOrderHeaderService->getWMSOrderOnStartDate($last_date); // WMS订单
|
|
|
if($orderHeaders->count()==0)return;
|
|
|
@@ -75,7 +75,7 @@ class SyncWMSOrderTask extends Command
|
|
|
$orderService->pushOrderCache($newest_orders,$prefixKey,$hasKey,$newest_list); // 添加缓存
|
|
|
$orderService->setOrderSyncAt($newest,$last_order->addtime,count($orderHeaders)>0); // 更新时间
|
|
|
}
|
|
|
-
|
|
|
+ unset($orderHeaders,$newest_orders,$last_order);
|
|
|
}
|
|
|
|
|
|
public function syncUpdatedOrder()
|
|
|
@@ -93,7 +93,7 @@ class SyncWMSOrderTask extends Command
|
|
|
$orderService = app('OrderService');
|
|
|
$oracleDOCOrderHeaderService = app('OracleDocOrderHeaderService');
|
|
|
|
|
|
- $last_date = $orderService->getOrderSyncAt($renewal,'renewal'); // 获取时间点
|
|
|
+ $last_date = $orderService->getOrderSyncAt($renewal,'renewal'); // 获取更新时间点
|
|
|
|
|
|
$orderHeaders = $oracleDOCOrderHeaderService->getWMSOrderOnEditDate($last_date); // WMS订单
|
|
|
|
|
|
@@ -110,5 +110,6 @@ class SyncWMSOrderTask extends Command
|
|
|
$orderService->pushOrderCache($renewal_orders,$prefixKey,$hasKey,$renewal_list); // 添加缓存
|
|
|
$orderService->setOrderSyncAt($renewal,$renewal_order->edittime,count($orderHeaders)>0); // 更新时间
|
|
|
}
|
|
|
+ unset($orderHeaders,$renewal_orders,$renewal_order);
|
|
|
}
|
|
|
}
|