czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

异步注解 无返回值

Browse Source
This commit is contained in:
wangw
2025-12-03 14:16:07 +08:00
parent fd8d2cf57c
commit 5aded8c6c1
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cash-common/cash-common-service/src/main/java/com/czg/market/service/ShopCouponService.java
View File

@@ -44,7 +44,7 @@ public interface ShopCouponService extends IService<ShopCoupon> {
List<UserCouponVo> findCoupon(Long shopId, Long shopUserId, Integer type, Integer isFood); List<UserCouponVo> findCoupon(Long shopId, Long shopUserId, Integer type, Integer isFood);
Boolean use(List<Long> ids, Long shopUserId, Long orderId); void use(List<Long> ids, Long shopUserId, Long orderId);
Boolean refund(Long orderId, Long shopUserId); Boolean refund(Long orderId, Long shopUserId);

5
cash-service/market-service/src/main/java/com/czg/service/market/service/impl/ShopCouponServiceImpl.java
View File

@@ -339,11 +339,10 @@ public class ShopCouponServiceImpl extends ServiceImpl<ShopCouponMapper, ShopCou
@Override @Override
@Async @Async
public Boolean use(List<Long> ids, Long shopUserId, Long orderId) { public void use(List<Long> ids, Long shopUserId, Long orderId) {
List<MkShopCouponRecord> records = recordService.listByIds(ids); List<MkShopCouponRecord> records = recordService.listByIds(ids);
if (records.isEmpty()) { if (records.isEmpty()) {
log.error("优惠券使用失败，订单Id:{}", orderId); log.error("优惠券使用失败，订单Id:{}", orderId);
return false;
} }
Map<Long, Long> chatCouponIdCountMap = records.stream() Map<Long, Long> chatCouponIdCountMap = records.stream()
.filter(record -> "群聊发放".equals(record.getSource())) .filter(record -> "群聊发放".equals(record.getSource()))
@@ -389,7 +388,7 @@ public class ShopCouponServiceImpl extends ServiceImpl<ShopCouponMapper, ShopCou
} }
update(coupon1, recordQueryWrapper); update(coupon1, recordQueryWrapper);
}); });
return recordService.updateChain() recordService.updateChain()
.set(MkShopCouponRecord::getStatus, 1) .set(MkShopCouponRecord::getStatus, 1)
.set(MkShopCouponRecord::getTargetId, orderId) .set(MkShopCouponRecord::getTargetId, orderId)
.set(MkShopCouponRecord::getUseTime, LocalDateTime.now()) .set(MkShopCouponRecord::getUseTime, LocalDateTime.now())