修改同步订单的任务调度

app/Console/Commands/SyncWMSOrderTask.php

@@ -43,17 +43,35 @@ class SyncWMSOrderTask extends Command
          * @var OrderService $orderService
          */
         $oracleDOCOrderHeaderService = app('OracleDOCOrderHeaderService');
-
         $orderService = app('OrderService');
-        $start_date = Carbon::now()->subSeconds(60+5);
+        $this->syncCreatedOrder($orderService,$oracleDOCOrderHeaderService);
+        $this->syncUpdateOrder($orderService,$oracleDOCOrderHeaderService);
+
+    }
 
+    public function syncCreatedOrder(OrderService $orderService,OracleDOCOrderHeaderService $oracleDOCOrderHeaderService)
+    {
+        $key = 'order_last_created_sync_at';
+        $last_date = $orderService->getOrderSyncAt($key);
         // 这段时间段内的新增
-        $orderHeaders_addTime = $oracleDOCOrderHeaderService->getWMSOrderOnStartDate($start_date);
-        // 这段时间段内的修改
-        $orderHeaders_editTime = $oracleDOCOrderHeaderService->getWMSOrderOnEditDate($start_date);
-        // 创建
-        $orderService->syncOrder($orderHeaders_addTime);
+        $orderHeaders = $oracleDOCOrderHeaderService->getWmsOrderOnStartDateEdit($last_date); // 根据时间获取OrderHeader
+        $last_order = $orderHeaders->first();
+        $last_created_order = $orderHeaders->where('addTime',$last_order->addtime);          // 最后时间插入的数据
         // 创建
-        $orderService->syncOrder($orderHeaders_editTime);
+        $orderService->syncOrder($orderHeaders);
+        $orderService->pushOrderCreatedCache($last_created_order);                       //
+    }
+
+    public function syncUpdateOrder(OrderService $orderService,OracleDOCOrderHeaderService $oracleDOCOrderHeaderService)
+    {
+        $key = 'order_last_updated_sync_at';
+        $last_date = $orderService->getOrderSyncAt($key);
+        $orderHeaders = $oracleDOCOrderHeaderService->getWMSOrderOnStartDate($last_date);
+        $last_order = $orderHeaders->first();
+        $last_updated_order =  $orderHeaders->where('addTime',$last_order->addtime);
+
+        // 更新
+        $orderService->syncOrder($orderHeaders);
+        $orderService->pushOrderUpdatedCache($last_updated_order);
     }
 }