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 | 170 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 169 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 6fed40e..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,17 @@
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;
+import cn.lili.modules.lmk.domain.vo.PrizeRecordTimeVO;
+import cn.lili.modules.lmk.enums.general.PrizeDistributeStatusEnum;
+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;
@@ -9,17 +21,30 @@
import cn.lili.modules.lmk.domain.form.PrizeRecordForm;
import cn.lili.modules.lmk.domain.vo.PrizeRecordVO;
import cn.lili.modules.lmk.domain.query.PrizeRecordQuery;
+import org.apache.poi.ss.usermodel.Cell;
+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;
+import javax.servlet.http.HttpServletResponse;
+import java.net.URLEncoder;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
/**
- * 鐢ㄦ埛鎶藉璁板綍琛� 鏈嶅姟瀹炵幇绫�
+ * 鐢ㄦ埛鎶藉璁板綍 鏈嶅姟瀹炵幇绫�
*
* @author peng
* @since 2025-08-14
@@ -30,6 +55,84 @@
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);
+ XSSFWorkbook workbook = initExportData(list);
+ try {
+ // 璁剧疆鍝嶅簲澶�
+ String fileName = URLEncoder.encode("鐢ㄦ埛鎶藉璁板綍", "UTF-8");
+ response.setContentType("application/vnd.ms-excel;charset=UTF-8");
+ response.setHeader("Content-Disposition", "attachment;filename=" + fileName + ".xlsx");
+
+ ServletOutputStream out = response.getOutputStream();
+ workbook.write(out);
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ workbook.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ public XSSFWorkbook initExportData(List<PrizeRecordVO> list){
+ List<PrizeRecordExportDetailDTO> exportDetailDTOS = new ArrayList<>();
+ for (PrizeRecordVO vo : list){
+ PrizeRecordExportDetailDTO detailDtO = new PrizeRecordExportDetailDTO();
+ BeanUtils.copyProperties(vo,detailDtO);
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ // 灏咲ate绫诲瀷杞崲涓烘寚瀹氭牸寮忕殑瀛楃涓�
+ String createTimeStr = sdf.format(vo.getCreateTime());
+ // 璁剧疆鍒癉TO涓�
+ detailDtO.setCreateTime(createTimeStr);
+ exportDetailDTOS.add(detailDtO);
+ }
+ XSSFWorkbook workbook = new XSSFWorkbook();
+
+ Sheet sheet = workbook.createSheet("鐢ㄦ埛鎶藉璁板綍");
+ // 鍒涘缓琛ㄥご
+ Row header = sheet.createRow(0);
+ String[] headers = {
+ "鐢ㄦ埛鏄电О", "娲诲姩鍚�","涓鐘舵��",
+ "涓鍐呭","濂栧搧鍙戞斁鐘舵��","鎶藉鏃堕棿"
+ };
+ for(int i= 0 ;i< headers.length;i++){
+ Cell cell = header.createCell(i);
+ cell.setCellValue(headers[i]);
+ }
+ for (int i=0;i< exportDetailDTOS.size();i++){
+ PrizeRecordExportDetailDTO dto = exportDetailDTOS.get(i);
+ Row row = sheet.createRow(i+1);
+ row.createCell(0).setCellValue(dto.getNickName());
+ row.createCell(1).setCellValue(dto.getPrizeActivityName());
+ if (PrizeStatusEnum.WIN.name().equals(dto.getPrizeStatus())){
+ row.createCell(2).setCellValue(PrizeStatusEnum.WIN.getDescription());
+ }else{
+ row.createCell(2).setCellValue(PrizeStatusEnum.NOT_WIN.getDescription());
+ }
+
+ row.createCell(3).setCellValue(dto.getPrizeContent());
+ if (PrizeDistributeStatusEnum.SUCCESS.name().equals(dto.getDistributeStatus())){
+ row.createCell(4).setCellValue(PrizeGrantStatusEnums.SUCCESS.getDescription());
+ }else if(PrizeDistributeStatusEnum.FAILED.name().equals(dto.getDistributeStatus())){
+ row.createCell(4).setCellValue(PrizeDistributeStatusEnum.FAILED.getDescription());
+ }else if(PrizeDistributeStatusEnum.NOT_WAIT.name().equals(dto.getDistributeStatus())){
+ row.createCell(4).setCellValue(PrizeDistributeStatusEnum.NOT_WAIT.getDescription());
+
+ }else {
+ row.createCell(4).setCellValue(PrizeDistributeStatusEnum.WAIT.getDescription());
+ }
+ row.createCell(5).setCellValue(dto.getCreateTime());
+ }
+
+ return workbook;
+
+ }
/**
* 娣诲姞
* @param form
@@ -89,7 +192,34 @@
public Result page(PrizeRecordQuery query) {
IPage<PrizeRecordVO> page = PageUtil.getPage(query, PrizeRecordVO.class);
baseMapper.getPage(page, query);
+ for (PrizeRecordVO vo :page.getRecords()){
+ if (StringUtils.isNotBlank(vo.getPrizeActivityCover())){
+ vo.setPrizeActivityCoverUrl(cosUtil.getPreviewUrl(vo.getPrizeActivityCover()));
+ }
+ if (StringUtils.isNotBlank(vo.getPrizeImg())){
+ vo.setPrizeImgUrl(cosUtil.getPreviewUrl(vo.getPrizeImg()));
+ }
+ }
return Result.ok().data(page.getRecords()).total(page.getTotal());
+ }
+ @Override
+ public Result pageByUserId(PrizeRecordQuery query) {
+ String userId = UserContext.getCurrentUser().getId();
+ IPage<PrizeRecordVO> page = PageUtil.getPage(query, PrizeRecordVO.class);
+ if (StringUtils.isNotBlank(userId)){
+ baseMapper.getByUserIdPage(page, query, userId);
+ for (PrizeRecordVO vo :page.getRecords()){
+ if (StringUtils.isNotBlank(vo.getPrizeActivityCover())){
+ vo.setPrizeActivityCoverUrl(cosUtil.getPreviewUrl(vo.getPrizeActivityCover()));
+ }
+ if (StringUtils.isNotBlank(vo.getPrizeImg())){
+ vo.setPrizeImgUrl(cosUtil.getPreviewUrl(vo.getPrizeImg()));
+ }
+ }
+
+ }
+ return Result.ok().data(page.getRecords()).total(page.getTotal());
+
}
/**
@@ -116,4 +246,42 @@
.collect(Collectors.toList());
return Result.ok().data(vos);
}
+
+ @Override
+ 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