From 80bf6eaf4fb9db121f4310a3d4b987cbb9c441b1 Mon Sep 17 00:00:00 2001 From: mkm <727897186@qq.com> Date: Wed, 18 Sep 2024 11:13:38 +0800 Subject: [PATCH] =?UTF-8?q?feat(process/Task.php):=20=E4=BF=AE=E6=94=B9?= =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=88=A0=E9=99=A4=E9=80=BB=E8=BE=91=E5=8F=8A?= =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- process/Task.php | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) diff --git a/process/Task.php b/process/Task.php index a25bda15..198660c6 100644 --- a/process/Task.php +++ b/process/Task.php @@ -23,7 +23,7 @@ class Task new Crontab('0 */10 * * * *', function () { $where = ['paid' => 0]; $where[] = ['create_time', '<', time() - 600]; // 10分钟前创建的订单 - $where[] = ['source', '<',2]; + $where[] = ['source', '<=',1]; // 删除10分钟未支付的订单 $oid = StoreOrder::where($where)->column('id'); // 删除时间设置为当前时间,即删除 if ($oid) { @@ -39,17 +39,6 @@ class Task //删除未充值的订单 UserRecharge::where('paid', 0)->where('status', 1)->where('create_time', '<', $oneHourAgo)->update(['delete_time' => time()]); }); - - new Crontab('0 */1 * * * *', function () { - $endTime = time(); - - // 计算10分钟前的时间戳 - $startTime = $endTime - 10 * 60; - $arr = UserRecharge::where('paid', 0)->where('status', 1)->whereBetweenTime('create_time', $startTime, $endTime)->column('order_id'); - foreach ($arr as $v) { - Redis::send('task-recharge-query', ['order_id' => $v]); - } - }); //每10秒执行一次 new Crontab('*/10 * * * * *', function () { $select=Db::name('wechat_micropay')->limit(100)->select();