|
|
@@ -589,10 +589,9 @@ sql;
|
|
|
$service = new OracleDOCOrderHeaderService();
|
|
|
$orderService = new OrderService();
|
|
|
$start_data = Carbon::make('2021-10-12 06:23:37');
|
|
|
- for ($i = 0;$i < 4;$i++){
|
|
|
+ for ($i = 0;$i < 7;$i++){
|
|
|
$last_start_data= Carbon::now();
|
|
|
- $end_data = $start_data->addHours(1);
|
|
|
-
|
|
|
+ $end_data = Carbon::parse($start_data)->addHours(1);
|
|
|
$editHeaders = $service->getQuery()->where('DOC_Order_Header.EditTime','>=',$start_data)
|
|
|
->where('DOC_Order_Header.EditTime',"<=",$end_data)
|
|
|
->orderByDesc('DOC_Order_Header.EditTime')
|
|
|
@@ -610,6 +609,7 @@ sql;
|
|
|
foreach ($addHeadersArray as &$array){
|
|
|
$orderService->syncOrder($array);
|
|
|
}
|
|
|
+
|
|
|
$start_data = $end_data;
|
|
|
$last_end_data = Carbon::now();
|
|
|
|
|
|
@@ -619,6 +619,8 @@ sql;
|
|
|
Cache::put($last_end_key,$last_end_data);
|
|
|
ValueStore::query()->where('name','order_last_updated_sync_at')->update(['value' => $editHeaders->first()->edittime]);
|
|
|
ValueStore::query()->where('name','last_order_sync_task_end_at')->update(['value' => $last_end_data]);
|
|
|
+ unset($editHeaderArray,$editHeaders);
|
|
|
+ unset($addHeadersArray,$addHeaders);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -629,6 +631,5 @@ sql;
|
|
|
$orderService = new OrderService();
|
|
|
$orderHeaders = $service->getQuery()->where('DOC_Order_Header.WaveNo',$code)->get();
|
|
|
$orderService->syncOrder($orderHeaders);
|
|
|
- dd('该订单同步完成');
|
|
|
}
|
|
|
}
|