From 36d03339f1eb3ac030e5569abc133f9942af0ac8 Mon Sep 17 00:00:00 2001
From: peng <peng.com>
Date: 星期二, 30 九月 2025 17:08:20 +0800
Subject: [PATCH] 店铺扫码抽奖功能
---
framework/src/main/java/cn/lili/modules/lmk/service/impl/ScanPrizeServiceImpl.java | 106 ++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 104 insertions(+), 2 deletions(-)
diff --git a/framework/src/main/java/cn/lili/modules/lmk/service/impl/ScanPrizeServiceImpl.java b/framework/src/main/java/cn/lili/modules/lmk/service/impl/ScanPrizeServiceImpl.java
index 0193259..cc7d618 100644
--- a/framework/src/main/java/cn/lili/modules/lmk/service/impl/ScanPrizeServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/lmk/service/impl/ScanPrizeServiceImpl.java
@@ -1,13 +1,20 @@
package cn.lili.modules.lmk.service.impl;
import cn.lili.common.exception.ServiceException;
+import cn.lili.common.security.AuthUser;
+import cn.lili.common.security.context.UserContext;
import cn.lili.modules.lmk.domain.entity.PrizeClaimRecord;
import cn.lili.modules.lmk.domain.entity.StoreCoupon;
import cn.lili.modules.lmk.domain.entity.StoreCouponSingle;
+import cn.lili.modules.lmk.domain.form.AddPrizeNumForm;
+import cn.lili.modules.lmk.domain.vo.StorePrizeVO;
import cn.lili.modules.lmk.enums.general.*;
import cn.lili.modules.lmk.service.PrizeClaimRecordService;
+import cn.lili.modules.lmk.service.PrizeService;
import cn.lili.modules.order.order.entity.enums.ClaimStatusEnum;
+import cn.lili.utils.COSUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import cn.lili.modules.lmk.domain.entity.ScanPrize;
import cn.lili.modules.lmk.mapper.ScanPrizeMapper;
@@ -49,7 +56,9 @@
private final RedissonClient redissonClient;
private static final String STORE_PRIZE_GENERATE = "store_prize_generate:";
private final PrizeClaimRecordService prizeClaimRecordService;
-
+ private static final String STORE_PRIZE_CLAIM = "store_prize_claim:";
+ private final PrizeService prizeService;
+ private final COSUtil cosUtil;
/**
* 娣诲姞
* @param form
@@ -164,7 +173,7 @@
}
@Override
- @Transactional
+ @Transactional(rollbackFor = Exception.class)
public Result generateStorePrize(String id) {
RLock redissonLock = redissonClient.getLock(STORE_PRIZE_GENERATE + id);
@@ -224,4 +233,97 @@
prizeClaimRecord.setMaterial(MaterialStatusEnum.NOT_GENERATE.name());
return prizeClaimRecord;
}
+ @Override
+ public Result claimPrize(String id) {
+ AuthUser currentUser = UserContext.getCurrentUser();
+ if (currentUser == null) {
+ throw new ServiceException("褰撳墠鐢ㄦ埛娌℃湁鐧诲綍鏃犳硶棰嗗彇");
+ }
+ String userId = currentUser.getId();
+ String nickName = currentUser.getNickName();
+
+ //閿佷綇绀煎搧鐮乮d
+ RLock redissonLock = redissonClient.getLock(STORE_PRIZE_CLAIM + id);
+ try {
+ redissonLock.lock();
+ LambdaQueryWrapper<PrizeClaimRecord> forUpdate = Wrappers.<PrizeClaimRecord>lambdaQuery()
+ .eq(PrizeClaimRecord::getId, id).last("FOR UPDATE");
+ PrizeClaimRecord prizeClaimRecord = prizeClaimRecordService.getOne(forUpdate);
+ if (prizeClaimRecord == null) {
+ throw new ServiceException("褰撳墠棰嗗彇鎶藉鏈轰細浜岀淮鐮佷笉瀛樺湪");
+ }
+ if (!ClaimStatusEnum.NOT_CLAIM.name().equals(prizeClaimRecord.getClaimStatus())) {
+ throw new ServiceException("褰撳墠棰嗗彇鎶藉鏈轰細鐘舵�佸紓甯�");
+ }
+ //鏇存柊琚鍙栫殑璁板綍
+ prizeClaimRecord.setClaimStatus(ClaimStatusEnum.CLAIM.name());
+ prizeClaimRecord.setUserId(userId);
+ prizeClaimRecord.setNickName(nickName);
+ LambdaQueryWrapper<ScanPrize> storeCoupQuery = Wrappers.<ScanPrize>lambdaQuery()
+ .eq(ScanPrize::getId, prizeClaimRecord.getStorePrizeId()).last("FOR UPDATE");
+ ScanPrize scanPrize = this.getOne(storeCoupQuery);
+ AddPrizeNumForm addPrizeNumForm = new AddPrizeNumForm();
+ addPrizeNumForm.setUserId(userId);
+ addPrizeNumForm.setPrizeActivityId(prizeClaimRecord.getPrizeActivityId());
+ addPrizeNumForm.setAddType(PrizeUserActionEnum.USER_SCAN_STORE.name());
+ prizeService.addPrizeNum(addPrizeNumForm);
+ if (scanPrize == null) {
+ throw new ServiceException("褰撳墠搴楅摵鎶藉鍗蜂笉瀛樺湪");
+ }
+ if (!StoreScanPrizeStausEnum.ENABLE.name().equals(scanPrize.getStatus())) {
+ throw new ServiceException("褰撳墠搴楅摵鎶藉鍗风姸鎬佸紓甯�");
+ }
+ //棰嗗彇瀵瑰簲鐨勪紭鎯犲嵎鍐欏叆璁板綍
+ prizeClaimRecordService.updateById(prizeClaimRecord);
+ LambdaUpdateWrapper<ScanPrize> updateStoreCoupon = Wrappers.<ScanPrize>lambdaUpdate()
+ .eq(ScanPrize::getId, scanPrize.getId())
+ .set(ScanPrize::getClaimNum, scanPrize.getClaimNum() + 1)
+ .ge(ScanPrize::getGenerateNum, scanPrize.getClaimNum() + 1);
+ boolean update = this.update(updateStoreCoupon);
+ if (!update) {
+ throw new ServiceException("棰嗗彇澶辫触");
+ }
+ return Result.ok().data(0);
+
+ } finally {
+ TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
+ @Override
+ public void afterCommit() {
+ if (redissonLock.isHeldByCurrentThread()) {
+ redissonLock.unlock();
+ }
+ }
+
+ @Override
+ public void afterCompletion(int status) {
+ // 纭繚鍗充娇鍦ㄤ簨鍔″洖婊氱殑鎯呭喌涓嬩篃鑳介噴鏀鹃攣
+ if (redissonLock.isHeldByCurrentThread()) {
+ redissonLock.unlock();
+ }
+ }
+
+ });
+
+ }
+ }
+
+ @Override
+ public Result getStorePrize(String id) {
+ StorePrizeVO storePrize = baseMapper.getStorePrize(id);
+ if (storePrize == null) {
+ throw new ServiceException("褰撳墠娲诲姩涓嶅瓨鍦�");
+ }
+ Boolean popup = storePrize.getPopup();
+ if (!Boolean.TRUE.equals(popup)) {
+ throw new ServiceException("褰撳墠娲诲姩娌℃湁寮�鍚�");
+ }
+ if (!PrizeActivityStatusEnum.ON.name().equals(storePrize.getEnableStatus())) {
+ throw new ServiceException("褰撳墠娲诲姩娌℃湁寮�鍚�");
+ }
+ String activityCover = storePrize.getActivityCover();
+ if (StringUtils.isNotBlank(activityCover)&&!activityCover.contains("http")) {
+ storePrize.setActivityCover(cosUtil.getPreviewUrl(activityCover));
+ }
+ return Result.ok().data(storePrize);
+ }
}
--
Gitblit v1.8.0