gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改优惠卷过期队列，去除数据库事物

Browse Source
This commit is contained in:
wucongxing 2024-01-19 09:12:30 +08:00
parent dca495db1a
commit fd555d167f
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php
View File

@ -72,7 +72,6 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
// 检测优惠卷过期时间 // 检测优惠卷过期时间
$valid_end_time = strtotime($user_coupon['valid_end_time']); $valid_end_time = strtotime($user_coupon['valid_end_time']);
Db::beginTransaction();
try { try {
// 处理未过期事件 // 处理未过期事件
// 先删除-重新添加队列 // 先删除-重新添加队列
@ -80,14 +79,13 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
$time = $valid_end_time - time(); $time = $valid_end_time - time();
$queue_data = array(); $queue_data = array();
$queue_data['order_inquiry_id'] = $data['order_inquiry_id']; $queue_data['user_coupon_id'] = $user_coupon['user_coupon_id'];
$message = new UserCouponExpiredDelayDirectProducer($queue_data); $message = new UserCouponExpiredDelayDirectProducer($queue_data);
$message->setDelayMs(1000 * $time); $message->setDelayMs(1000 * $time);
$producer = $this->container->get(Producer::class); $producer = $this->container->get(Producer::class);
$res = $producer->produce($message); $res = $producer->produce($message);
if (!$res) { if (!$res) {
Db::rollBack();
Log::getInstance("queue-UserCouponExpired")->error("未到过期时间，重新添加队列失败"); Log::getInstance("queue-UserCouponExpired")->error("未到过期时间，重新添加队列失败");
return Result::REQUEUE; return Result::REQUEUE;
} }
@ -103,12 +101,10 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage
$data['user_coupon_status'] = 3; $data['user_coupon_status'] = 3;
UserCoupon::edit($params, $data); UserCoupon::edit($params, $data);
} catch (\Throwable $e) { } catch (\Throwable $e) {
Db::rollBack();
Log::getInstance("queue-UserCouponExpired")->error($e->getMessage()); Log::getInstance("queue-UserCouponExpired")->error($e->getMessage());
return Result::REQUEUE; // 重回队列 return Result::REQUEUE; // 重回队列
} }
Db::commit();
Log::getInstance("queue-UserCouponExpired")->info("成功"); Log::getInstance("queue-UserCouponExpired")->info("成功");
Db::beginTransaction(); Db::beginTransaction();