admin1/jiangchengfeiyi-houduan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新了写真预约特殊产品处理

Browse Source
This commit is contained in:
chen-xin-zhi 2025-03-05 19:08:48 +08:00
parent 1a9e565cd7
commit 3c656d8a4d
1 changed files with 32 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
src/main/java/com/cultural/heritage/listener/OrderStatusListener.java
View File

@ -1,8 +1,14 @@
package com.cultural.heritage.listener;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.cultural.heritage.common.ErrorCode;
import com.cultural.heritage.constant.MqConstant;
import com.cultural.heritage.constant.OrderStatusConstant;
import com.cultural.heritage.exception.ThrowUtils;
import com.cultural.heritage.model.dto.snapshot.CouponSnapshot;
import com.cultural.heritage.model.entity.Order;
import com.cultural.heritage.model.entity.PendingServiceOrder;
import com.cultural.heritage.model.entity.UserCoupon;
import com.cultural.heritage.service.common.CommonService;
import com.cultural.heritage.service.good.UserCouponService;
import com.cultural.heritage.service.order.OrderService;
@ -69,32 +75,32 @@ public class OrderStatusListener {
});
return ;
}
// // 没有剩余延时时间，说明订单超时未支付，需取消订单
// UpdateWrapper<Order> updateWrapper = new UpdateWrapper<>();
// updateWrapper.eq("id", orderId).set("orderStatus", OrderStatusConstant.TRANSACTION_CLOSED);
// boolean update = orderService.update(updateWrapper);
// ThrowUtils.throwIf(!update, ErrorCode.OPERATION_ERROR, "订单状态更新失败");
//
// // 如果使用了优惠券，则退还优惠券
// CouponSnapshot couponSnapshot = order.getCouponSnapshot();
// if (couponSnapshot != null) {
// Long userCouponId = couponSnapshot.getId();
// UserCoupon userCoupon = userCouponService.getById(userCouponId);
// ThrowUtils.throwIf(userCoupon == null, ErrorCode.OPERATION_ERROR, "优惠券不存在");
// // 更新优惠券状态
// userCoupon.setIsUsed(0);
// boolean result = userCouponService.updateById(userCoupon);
// ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "优惠券状态更新失败");
// }
//
// boolean isGeneral = orderService.isGeneralGood(order.getOrderType());
// if (!isGeneral) {
// System.out.println("=========================================>" + order.getOrderNumber());
// UpdateWrapper<PendingServiceOrder> pendingServiceOrderUpdateWrapper = new UpdateWrapper<>();
// pendingServiceOrderUpdateWrapper.eq("orderNumber", order.getOrderNumber()).set("orderItemStatus", OrderStatusConstant.TRANSACTION_CLOSED);
// boolean updateBatch = pendingServiceOrderService.update(pendingServiceOrderUpdateWrapper);
// ThrowUtils.throwIf(!updateBatch, ErrorCode.OPERATION_ERROR, "订单状态批量更新失败");
// }
// 没有剩余延时时间，说明订单超时未支付，需取消订单
UpdateWrapper<Order> updateWrapper = new UpdateWrapper<>();
updateWrapper.eq("id", orderId).set("orderStatus", OrderStatusConstant.TRANSACTION_CLOSED);
boolean update = orderService.update(updateWrapper);
ThrowUtils.throwIf(!update, ErrorCode.OPERATION_ERROR, "订单状态更新失败");
// 如果使用了优惠券，则退还优惠券
CouponSnapshot couponSnapshot = order.getCouponSnapshot();
if (couponSnapshot != null) {
Long userCouponId = couponSnapshot.getId();
UserCoupon userCoupon = userCouponService.getById(userCouponId);
ThrowUtils.throwIf(userCoupon == null, ErrorCode.OPERATION_ERROR, "优惠券不存在");
// 更新优惠券状态
userCoupon.setIsUsed(0);
boolean result = userCouponService.updateById(userCoupon);
ThrowUtils.throwIf(!result, ErrorCode.OPERATION_ERROR, "优惠券状态更新失败");
}
boolean isGeneral = orderService.isGeneralGood(order.getOrderType());
if (!isGeneral) {
System.out.println("=========================================>" + order.getOrderNumber());
UpdateWrapper<PendingServiceOrder> pendingServiceOrderUpdateWrapper = new UpdateWrapper<>();
pendingServiceOrderUpdateWrapper.eq("orderNumber", order.getOrderNumber()).set("orderItemStatus", OrderStatusConstant.TRANSACTION_CLOSED);
boolean updateBatch = pendingServiceOrderService.update(pendingServiceOrderUpdateWrapper);
ThrowUtils.throwIf(!updateBatch, ErrorCode.OPERATION_ERROR, "订单状态批量更新失败");
}
}