From 4ffe14b68f7bb9b996e2f8b01b6d2f78151e62ed Mon Sep 17 00:00:00 2001 From: weizong song Date: Fri, 28 May 2021 10:58:33 +0800 Subject: [PATCH] up --- app/Console/Commands/SyncAlipayRechargeState.php | 4 +--- app/Console/Commands/SyncWeixinRechargeState.php | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/app/Console/Commands/SyncAlipayRechargeState.php b/app/Console/Commands/SyncAlipayRechargeState.php index bb83399..e80c1da 100644 --- a/app/Console/Commands/SyncAlipayRechargeState.php +++ b/app/Console/Commands/SyncAlipayRechargeState.php @@ -42,7 +42,7 @@ class SyncAlipayRechargeState extends Command { $threshold = 5; $offset_seconds = 40; //支付发起后多少秒开始轮询 - $due_minutes = 101; //支付发起后第一次开始轮询的时间往后延迟5分钟后不再轮询 + $due_minutes = 110; //支付发起后第一次开始轮询的时间往后延迟5分钟后不再轮询 $last_id = cache("last_sync_alipay_recharge_id", 0); DB::enableQueryLog(); @@ -53,8 +53,6 @@ class SyncAlipayRechargeState extends Command ->whereRaw("(" . time() . " between (UNIX_TIMESTAMP(`created_at`) + {$offset_seconds}) and (UNIX_TIMESTAMP(`created_at`) + " . ($due_minutes * 60) . " + {$offset_seconds}))") ->limit($threshold) ->get(); - dump(DB::getQueryLog()); - dd($recharges); if (!$recharges->count()) { cache(['last_sync_alipay_recharge_id' => null], now()->addSeconds(90)); echo "nothing"; diff --git a/app/Console/Commands/SyncWeixinRechargeState.php b/app/Console/Commands/SyncWeixinRechargeState.php index 329f06a..49e8b6f 100644 --- a/app/Console/Commands/SyncWeixinRechargeState.php +++ b/app/Console/Commands/SyncWeixinRechargeState.php @@ -50,7 +50,7 @@ class SyncWeixinRechargeState extends Command ->where("id", ">", $last_id) ->whereNull("paid_at") ->where("payment", "weixin") - ->whereRaw("UNIX_TIMESTAMP(`created_at`) between " . (time() + $offset_seconds) . " and " . (time() + $due_minutes * 60 + $offset_seconds)) + ->whereRaw("(" . time() . " between (UNIX_TIMESTAMP(`created_at`) + {$offset_seconds}) and (UNIX_TIMESTAMP(`created_at`) + " . ($due_minutes * 60) . " + {$offset_seconds}))") ->limit($threshold) ->get(); if (!$recharges->count()) {