预订单任务表 方法编写

This commit is contained in:
Jack 2025-10-23 16:51:05 +08:00
parent bc1c308043
commit a62b4b837d
3 changed files with 9 additions and 2 deletions

View File

@ -41,4 +41,7 @@ public class RedisConstant {
// 您有新的订单来了
public static final String New_Order_Push_Flag_Key = ConstantRedis.Cache_NameSpace + "new:order:comimg:";
// 预约订单任务新增键
public static final String Order_Booking_Task_Key = ConstantRedis.Cache_NameSpace + "new:order:booking:task:";
}

View File

@ -6642,7 +6642,10 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl<ShopOrderBaseMappe
info_row.setBooking_end_time(bookingEndTime);
// 重要预约订单任务创建处理
shopOrderBookingService.setupRedisBookingTask(info_row.getOrder_id(), info_row.getBooking_at());
Boolean isSuccess = shopOrderBookingService.setupRedisBookingTask(info_row.getOrder_id(), info_row.getBooking_at());
if (!isSuccess) {
throw new ApiException(I18nUtil._("保存预约订单任务失败!"));
}
}
info_row.setActivity_json(JSONUtil.toJsonStr(store_item.get("discount_detail_rows")));

View File

@ -13,6 +13,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.suisung.mall.common.constant.CommonConstant;
import com.suisung.mall.common.constant.RedisConstant;
import com.suisung.mall.common.modules.order.ShopOrderBooking;
import com.suisung.mall.common.utils.CheckUtil;
import com.suisung.mall.core.web.service.RedisService;
@ -66,7 +67,7 @@ public class ShopOrderBookingServiceImpl extends BaseServiceImpl<ShopOrderBookin
// 如果保存成功设置Redis过期键
if (shopOrderBooking != null) {
String redisKey = "booking::" + orderId;
String redisKey = RedisConstant.Order_Booking_Task_Key + orderId;
// 设置过期时间为runAt时间点相对于当前时间的秒数
if (runAt > 0) {
redisService.set(redisKey, String.valueOf(runAt), runAt);