|
|
@@ -120,4 +120,36 @@ class TestCommand extends TestCase
|
|
|
{
|
|
|
QueueClient::push("QueryRefund", ['order_id' => 8987841]);
|
|
|
}
|
|
|
+
|
|
|
+ public function testQueryAllRefund()
|
|
|
+ {
|
|
|
+ $mod = Model();
|
|
|
+
|
|
|
+ $start = 0;
|
|
|
+ $inter = 0;
|
|
|
+ while (true)
|
|
|
+ {
|
|
|
+ $cond = ['inner_status' => 0,
|
|
|
+ 'order_state' => ORDER_STATE_SUCCESS,
|
|
|
+ 'vr_order.order_id' => ['gt', $start],
|
|
|
+ 'store_id' => 33
|
|
|
+ ];
|
|
|
+
|
|
|
+ $items = $mod->table('refill_order,vr_order')
|
|
|
+ ->field('refill_order.order_id')
|
|
|
+ ->where($cond)
|
|
|
+ ->join('inner')->on('refill_order.order_id=vr_order.order_id')
|
|
|
+ ->limit("$start,100")
|
|
|
+ ->select();
|
|
|
+ if(empty($items)) break;
|
|
|
+
|
|
|
+ $inter += 1;
|
|
|
+
|
|
|
+ foreach ($items as $item) {
|
|
|
+ $order_id = intval($item['order_id']);
|
|
|
+ $start = $order_id;
|
|
|
+ QueueClient::async_push("QueryRefund", ['order_id' => $order_id],$inter);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
