From 362e79ed14f77f850f3397d225f3b1b897ca44d7 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期一, 24 十一月 2025 15:26:44 +0800
Subject: [PATCH] 补偿领劵
---
framework/src/main/java/cn/lili/modules/lmk/service/impl/PrizeRecordServiceImpl.java | 43 ++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 42 insertions(+), 1 deletions(-)
diff --git a/framework/src/main/java/cn/lili/modules/lmk/service/impl/PrizeRecordServiceImpl.java b/framework/src/main/java/cn/lili/modules/lmk/service/impl/PrizeRecordServiceImpl.java
index d2bb6af..0c495d6 100644
--- a/framework/src/main/java/cn/lili/modules/lmk/service/impl/PrizeRecordServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/lmk/service/impl/PrizeRecordServiceImpl.java
@@ -1,5 +1,6 @@
package cn.lili.modules.lmk.service.impl;
+import cn.lili.common.properties.RocketmqCustomProperties;
import cn.lili.common.security.context.UserContext;
import cn.lili.common.utils.StringUtils;
import cn.lili.modules.lmk.domain.query.PrizeRecordTimeQuery;
@@ -8,7 +9,9 @@
import cn.lili.modules.lmk.enums.general.PrizeGrantStatusEnums;
import cn.lili.modules.lmk.enums.general.PrizeStatusEnum;
import cn.lili.modules.order.order.entity.dto.PrizeRecordExportDetailDTO;
+import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
import cn.lili.utils.COSUtil;
+import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import cn.lili.modules.lmk.domain.entity.PrizeRecord;
import cn.lili.modules.lmk.mapper.PrizeRecordMapper;
@@ -22,10 +25,14 @@
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Service;
import lombok.RequiredArgsConstructor;
import cn.lili.utils.PageUtil;
import org.springframework.beans.BeanUtils;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.support.TransactionSynchronization;
+import org.springframework.transaction.support.TransactionSynchronizationManager;
import org.springframework.util.Assert;
import javax.servlet.ServletOutputStream;
@@ -49,7 +56,8 @@
private final PrizeRecordMapper prizeRecordMapper;
private final COSUtil cosUtil;
-
+ private final RocketmqCustomProperties rocketmqCustomProperties;
+ private final RocketMQTemplate rocketMQTemplate;
@Override
public void queryExportStock(HttpServletResponse response, PrizeRecordQuery query){
List<PrizeRecordVO> list = baseMapper.getExportData(query);
@@ -243,4 +251,37 @@
public List<PrizeRecordTimeVO> getPrizeRecordListByTime(PrizeRecordTimeQuery query) {
return baseMapper.getPrizeRecordListByTime(query);
}
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public Result push(String id) {
+ PrizeRecord prizeRecord = baseMapper.selectById(id);
+ if (prizeRecord != null){
+ String distributeStatus = prizeRecord.getDistributeStatus();
+ String prizeStatus = prizeRecord.getPrizeStatus();
+
+ if (StringUtils.isNotBlank(distributeStatus) &&
+ StringUtils.isNotBlank(prizeStatus) &&
+ PrizeStatusEnum.WIN.name().equals(prizeStatus) &&
+ PrizeDistributeStatusEnum.WAIT.name().equals(distributeStatus)){
+
+ TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
+ @Override
+ public void afterCommit() {
+ String destination = rocketmqCustomProperties.getPrizeTopic() + ":" + PrizeStatusEnum.WIN.name();
+ rocketMQTemplate.asyncSend(destination, JSON.toJSONString(prizeRecord), RocketmqSendCallbackBuilder.commonCallback());
+ }
+ });
+ return Result.ok().data("宸插彂鏀捐ˉ鍋�");
+ }else {
+ throw new RuntimeException("鐢ㄦ埛棰嗗彇璁板綍涓簄ull鎴栭敊璇姸鎬�,琛ュ伩鍙戞斁澶辫触:" +prizeRecord);
+ }
+
+ }else{
+ return Result.error().data("琛ュ伩鍙戞斁澶辫触");
+
+ }
+
+
+ }
}
--
Gitblit v1.8.0