Commit b7f8eba4 authored by hangjun83's avatar hangjun83

openapi 震坤行

parent 5ebe3d86
...@@ -180,6 +180,7 @@ class RhawnOrdersService ...@@ -180,6 +180,7 @@ class RhawnOrdersService
$orderItemsArray['si_vamount'] = 0; $orderItemsArray['si_vamount'] = 0;
$orderItemsArray['si_nodes'] = ''; $orderItemsArray['si_nodes'] = '';
$orderItemsArray['si_notes'] = ''; $orderItemsArray['si_notes'] = '';
$orderItemsArray['si_sales_note'] = '';
$dbConnect->table('soitems')->insert($orderItemsArray); $dbConnect->table('soitems')->insert($orderItemsArray);
} }
......
...@@ -105,7 +105,7 @@ class ZhenKhService ...@@ -105,7 +105,7 @@ class ZhenKhService
$sendContent = []; $sendContent = [];
$postParams = [ $postParams = [
'start_time' => date('Y-m-d H:i:s',(time() - 86400)), 'start_time' => date('Y-m-d H:i:s',(time() - 86400)),
'end_time' => date('Y-m-d H:i:s'), 'end_time' => date('Y-m-d H:i:s',strtotime(date('Y-m-d',time())." 23:59:59")),
'page_size' => 0, 'page_size' => 0,
'page_no' => 0, 'page_no' => 0,
]; ];
...@@ -116,14 +116,15 @@ class ZhenKhService ...@@ -116,14 +116,15 @@ class ZhenKhService
$orderList = $this->apiService->getUpdateOrders($postParams,$this->getToken()); $orderList = $this->apiService->getUpdateOrders($postParams,$this->getToken());
if($orderList && count($orderList['list']) > 0){ if($orderList && count($orderList['list']) > 0){
foreach($orderList['list']['data'] as $order){ foreach($orderList['list']['data'] as $order){
SimpleKafka::produerSend([ if($order['orderStatus'] == 0){
'params' => ['orders' => $order], SimpleKafka::produerSend([
'consumer' => __CLASS__, 'params' => ['orders' => $order],
'method' => 'consumerBatchUpdateOrdersList' 'consumer' => __CLASS__,
]); 'method' => 'consumerBatchUpdateOrdersList'
]);
}
} }
} }
exit;
$page ++; $page ++;
if($page > $orderList['total_page']){ if($page > $orderList['total_page']){
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment