Browse Source

Merge pull request '同步增量订单改为5分钟' (#5) from 20220708_incr_orders_interval_five_minute into master

Reviewed-on: #5
pull/10/head
liuyu 3 years ago
parent
commit
34a1fb86fa
  1. 3
      model/mShop.php
  2. 2
      queue/deal/sync_increment_orders.php

3
model/mShop.php

@ -32,7 +32,6 @@ class mShop extends mBase {
} else {
$uobj = new mUser();
$uid = $uobj->addUser();
var_dump($uid);
if (!$uid) {
$this->setError('uid创建失败');
return false;
@ -68,7 +67,7 @@ var_dump($uid);
// 同步增量订单开始时间
if ($date == date("Y-m-d")) {
$rdobj->lpush(_RQ_SYNC_INCREMENT_ORDERS, json_encode(array('name'=>$name, 'start_date'=>date("Y-m-d H:i:s"), 'end_date'=>date("Y-m-d H:i:s", strtotime("+30 minute")))));
$rdobj->lpush(_RQ_SYNC_INCREMENT_ORDERS, json_encode(array('name'=>$name, 'start_date'=>date("Y-m-d H:i:s"), 'end_date'=>date("Y-m-d H:i:s", strtotime("+5 minute")))));
}
}

2
queue/deal/sync_increment_orders.php

@ -46,7 +46,7 @@ class syncIncrementOrders extends dealBase {
}
$rdobj->lpush(_RQ_SYNC_INCREMENT_ORDERS, json_encode(array('name'=>$name, 'start_date'=>$end_date, 'end_date'=>date("Y-m-d H:i:s", strtotime($end_date." +30 minute")))));
$rdobj->lpush(_RQ_SYNC_INCREMENT_ORDERS, json_encode(array('name'=>$name, 'start_date'=>$end_date, 'end_date'=>date("Y-m-d H:i:s", strtotime($end_date." +5 minute")))));
}

Loading…
Cancel
Save