mkm/multi-store
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'feat(process/Task.php): 修改订单删除逻辑及定时任务' (#212) from dev into main

Browse Source 
Reviewed-on: #212
This commit is contained in:
mkm 2024-09-18 11:16:19 +08:00
commit f2224ebe3d
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
process/Task.php
View File

@ -23,7 +23,7 @@ class Task
new Crontab('0 */10 * * * *', function () { new Crontab('0 */10 * * * *', function () {
$where = ['paid' => 0]; $where = ['paid' => 0];
$where[] = ['create_time', '<', time() - 600]; // 10分钟前创建的订单 $where[] = ['create_time', '<', time() - 600]; // 10分钟前创建的订单
$where[] = ['source', '<',2]; $where[] = ['source', '<=',1];
// 删除10分钟未支付的订单 // 删除10分钟未支付的订单
$oid = StoreOrder::where($where)->column('id'); // 删除时间设置为当前时间，即删除 $oid = StoreOrder::where($where)->column('id'); // 删除时间设置为当前时间，即删除
if ($oid) { if ($oid) {
@ -39,17 +39,6 @@ class Task
//删除未充值的订单 //删除未充值的订单
UserRecharge::where('paid', 0)->where('status', 1)->where('create_time', '<', $oneHourAgo)->update(['delete_time' => time()]); 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秒执行一次 //每10秒执行一次
new Crontab('*/10 * * * * *', function () { new Crontab('*/10 * * * * *', function () {
$select=Db::name('wechat_micropay')->limit(100)->select(); $select=Db::name('wechat_micropay')->limit(100)->select();