From 2afce3afa1b9a111b20d2d372fb9867751a50ad2 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 01 Mar 2024 14:18:35 +0800
Subject: [PATCH] 抽奖
---
src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java | 251 +++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 219 insertions(+), 32 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java
index e2adb67..77eeabd 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java
@@ -17,9 +17,11 @@
import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.crypto.SecureUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -30,6 +32,8 @@
import java.math.BigDecimal;
import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
import java.util.List;
@Slf4j
@@ -65,15 +69,16 @@
List<ApiMallProductNftVo> list = this.baseMapper.selectByState(ProductEnum.PRODUCT_NFT_OPEN.getValue());
if(CollUtil.isNotEmpty(list)){
for(ApiMallProductNftVo apiMallProductNftVo : list){
- if(nowTime.compareTo(startTime) < 0){
- apiMallProductNftVo.setYuYueState(1);
- }
- if(nowTime.compareTo(startTime) >= 0 && nowTime.compareTo(endTime) <= 0){
- apiMallProductNftVo.setYuYueState(2);
- }
- if(nowTime.compareTo(endTime) > 0){
- apiMallProductNftVo.setYuYueState(3);
- }
+ apiMallProductNftVo.setYuYueState(2);
+// if(nowTime.compareTo(startTime) < 0){
+// apiMallProductNftVo.setYuYueState(1);
+// }
+// if(nowTime.compareTo(startTime) >= 0 && nowTime.compareTo(endTime) <= 0){
+// apiMallProductNftVo.setYuYueState(2);
+// }
+// if(nowTime.compareTo(endTime) > 0){
+// apiMallProductNftVo.setYuYueState(3);
+// }
}
}
return list;
@@ -95,20 +100,20 @@
throw new FebsException("用户已冻结");
}
- DateTime nowTime = DateUtil.parseTime(DateUtil.formatTime(DateUtil.date()));
- DataDictionaryCustom startTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
- DataDictionaryEnum.YU_YUE_START_TIME.getType(),
- DataDictionaryEnum.YU_YUE_START_TIME.getCode()
- );
- DateTime startTime = DateUtil.parseTime(startTimeDic.getValue());
- DataDictionaryCustom endTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
- DataDictionaryEnum.YU_YUE_END_TIME.getType(),
- DataDictionaryEnum.YU_YUE_END_TIME.getCode()
- );
- DateTime endTime = DateUtil.parseTime(endTimeDic.getValue());
- if(!(nowTime.compareTo(startTime) >= 0 && nowTime.compareTo(endTime) <= 0)){
- throw new FebsException("预约未开始");
- }
+// DateTime nowTime = DateUtil.parseTime(DateUtil.formatTime(DateUtil.date()));
+// DataDictionaryCustom startTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// DataDictionaryEnum.YU_YUE_START_TIME.getType(),
+// DataDictionaryEnum.YU_YUE_START_TIME.getCode()
+// );
+// DateTime startTime = DateUtil.parseTime(startTimeDic.getValue());
+// DataDictionaryCustom endTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// DataDictionaryEnum.YU_YUE_END_TIME.getType(),
+// DataDictionaryEnum.YU_YUE_END_TIME.getCode()
+// );
+// DateTime endTime = DateUtil.parseTime(endTimeDic.getValue());
+// if(!(nowTime.compareTo(startTime) >= 0 && nowTime.compareTo(endTime) <= 0)){
+// throw new FebsException("预约未开始");
+// }
if(!tradePassword.equals(mallMember.getTradePassword())){
throw new FebsException("请输入正确的交易密码");
}
@@ -122,7 +127,14 @@
MallProductBuy mallProductBuy = mallProductBuyMapper.selectMemberIdAndNFTIdAndStateAndMateState(
memberId,productNFTId,ProductEnum.PRODUCT_BUY_ON_GOING.getValue(),ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
if(ObjectUtil.isNotEmpty(mallProductBuy)){
- throw new FebsException("不可重复预约");
+ throw new FebsException("不可重复开启");
+ }
+ QueryWrapper<MallProductBuy> mallProductBuyDone = new QueryWrapper<>();
+ mallProductBuyDone.like("CREATED_TIME", DateUtil.today());
+ mallProductBuyDone.eq("member_id",memberId);
+ Integer selectCount = mallProductBuyMapper.selectCount(mallProductBuyDone);
+ if(0 < selectCount){
+ throw new FebsException("每日开启一次");
}
BigDecimal priceToken = mallProductNft.getPriceToken();
@@ -155,7 +167,10 @@
null,
FlowTypeNewEnum.TOKEN.getValue(),
MoneyFlowTypeNewEnum.TOKEN_BUY_FROZEN.getDescrition());
- return new FebsResponse().success();
+ HashMap<String, Long> objectObjectHashMap = new HashMap<>();
+ objectObjectHashMap.put("id",productNFTId);
+ objectObjectHashMap.put("time",5L);
+ return new FebsResponse().success().data(objectObjectHashMap);
}
@Override
@@ -497,6 +512,15 @@
mallMember.getId(),
FlowTypeNewEnum.NFT.getValue(),
MoneyFlowTypeNewEnum.PAY.getDescrition());
+
+ DataDictionaryCustom insureMinuteDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.INSURE_END_MINUTE.getType(),
+ DataDictionaryEnum.INSURE_END_MINUTE.getCode()
+ );
+ Integer insureMinute = Integer.parseInt(ObjectUtil.isEmpty(insureMinuteDic) ? "60" : insureMinuteDic.getValue());
+ Date endTime = DateUtil.offsetMinute(payTime, insureMinute);
+ long remainTime = DateUtil.between(payTime, endTime, DateUnit.SECOND, false);
+ agentProducer.sendFcmPayBuyTimeTTLMsg(mallProductSellRecord.getId(), remainTime * 1000L);
return new FebsResponse().success();
}
@@ -644,16 +668,179 @@
objects.add(apiOrderListVo);
}
}
-
- IPage<ApiOrderRecordListVo> pageSell = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize());
- IPage<ApiOrderRecordListVo> apiOrderListVoIPageSell = mallProductSellRecordMapper.selectListInPage(pageSell, apiOrderListDto);
- if(CollUtil.isNotEmpty(apiOrderListVoIPageSell.getRecords())){
- for(ApiOrderRecordListVo apiOrderListVo : apiOrderListVoIPageSell.getRecords()){
- objects.add(apiOrderListVo);
- }
+ }
+ IPage<ApiOrderRecordListVo> pageSell = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize());
+ IPage<ApiOrderRecordListVo> apiOrderListVoIPageSell = mallProductSellRecordMapper.selectListInPage(pageSell, apiOrderListDto);
+ if(CollUtil.isNotEmpty(apiOrderListVoIPageSell.getRecords())){
+ for(ApiOrderRecordListVo apiOrderListVo : apiOrderListVoIPageSell.getRecords()){
+ objects.add(apiOrderListVo);
}
}
return new FebsResponse().success().data(objects);
}
+
+ @Override
+ public FebsResponse orderSellRecord(ApiOrderSellInfoDto apiOrderSellInfoDto) {
+ Long productSellRecordId = apiOrderSellInfoDto.getId();
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+ MallProductSellRecord mallProductSellRecord = mallProductSellRecordMapper.selectById(productSellRecordId);
+ if(ObjectUtil.isEmpty(mallProductSellRecord)){
+ throw new FebsException("记录不存在");
+ }
+ ApiOrderSellRecordInfoVo apiOrderSellRecordInfoVo = mallProductSellRecordMapper.selectBySellRecordId(productSellRecordId);
+ return new FebsResponse().success().data(apiOrderSellRecordInfoVo);
+ }
+
+ @Override
+ public FebsResponse orderBuyRecord(ApiOrderBuyInfoDto apiOrderBuyInfoDto) {
+ Long productBuyRecordId = apiOrderBuyInfoDto.getId();
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+ MallProductBuyRecord mallProductBuyRecord = mallProductBuyRecordMapper.selectById(productBuyRecordId);
+ if(ObjectUtil.isEmpty(mallProductBuyRecord)){
+ throw new FebsException("记录不存在");
+ }
+ ApiOrderBuyRecordInfoVo apiOrderBuyRecordInfoVo = mallProductBuyRecordMapper.selectByBuyRecordId(productBuyRecordId);
+ return new FebsResponse().success().data(apiOrderBuyRecordInfoVo);
+ }
+
+ @Override
+ @Transactional
+ public FebsResponse transGfd(ApiTransGfdDto transGfdDto) {
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+ BigDecimal cnt = transGfdDto.getCnt();//兑换数量
+
+ MallMember mallMember = memberMapper.selectById(memberId);
+ String tradePassword = SecureUtil.md5(transGfdDto.getTradePassword());
+ Boolean aBoolean = operationPermissionMemberFrozen(memberId);
+ if(aBoolean){
+ throw new FebsException("用户已冻结");
+ }
+ if(!tradePassword.equals(mallMember.getTradePassword())){
+ throw new FebsException("请输入正确的交易密码");
+ }
+ MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
+ Integer type = transGfdDto.getType();
+ String orderNo = MallUtils.getOrderNum("GSD");
+ if(1 == type){//NFT兑换GFD
+ BigDecimal trendsNft = mallMemberAmount.getTrendsNft();
+ if(BigDecimal.ZERO.compareTo(trendsNft) >= 0){
+ throw new FebsException("NFT不足");
+ }
+ if(cnt.compareTo(trendsNft) > 0){
+ throw new FebsException("NFT不足");
+ }
+ mallMemberAmount.setTrendsNft(trendsNft.subtract(cnt));
+ mallMemberAmount.setGsd(mallMemberAmount.getGsd().add(cnt));
+ mallMemberAmountMapper.updateTrendsNftAndGsdById(mallMemberAmount);
+ iMallMoneyFlowService.addMoneyFlow(
+ memberId,
+ cnt,
+ MoneyFlowTypeNewEnum.NFT_GSD.getValue(),
+ orderNo,
+ mallMember.getId(),
+ FlowTypeNewEnum.GSD.getValue(),
+ MoneyFlowTypeNewEnum.NFT_GSD.getDescrition());
+
+ }
+ if(2 == type){//GFA兑换GFD
+ BigDecimal fcmCntAva = mallMemberAmount.getFcmCntAva();
+ if(BigDecimal.ZERO.compareTo(fcmCntAva) >= 0){
+ throw new FebsException("代币不足");
+ }
+ if(cnt.compareTo(fcmCntAva) > 0){
+ throw new FebsException("代币不足");
+ }
+ DataDictionaryCustom fcmPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.FCM_PRICE.getType(),
+ DataDictionaryEnum.FCM_PRICE.getCode());
+ BigDecimal fcmPrice = ObjectUtil.isEmpty(fcmPriceDic) ? new BigDecimal(2) : new BigDecimal(fcmPriceDic.getValue());
+ BigDecimal gsdCnt = fcmPrice.multiply(cnt);
+ mallMemberAmount.setFcmCntAva(fcmCntAva.subtract(cnt));
+ mallMemberAmount.setGsd(mallMemberAmount.getGsd().add(gsdCnt));
+ mallMemberAmountMapper.updateFcmCntAvaAndGsdById(mallMemberAmount);
+ iMallMoneyFlowService.addMoneyFlow(
+ memberId,
+ cnt,
+ MoneyFlowTypeNewEnum.GFA_GSD.getValue(),
+ orderNo,
+ mallMember.getId(),
+ FlowTypeNewEnum.GSD.getValue(),
+ MoneyFlowTypeNewEnum.GFA_GSD.getDescrition());
+
+ }
+ return new FebsResponse().success();
+ }
+
+ @Override
+ @Transactional
+ public FebsResponse gfdTrans(ApiGfdTransDto transGfdDto) {
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+ BigDecimal cnt = transGfdDto.getCnt();//兑换数量
+
+ MallMember mallMember = memberMapper.selectById(memberId);
+ String tradePassword = SecureUtil.md5(transGfdDto.getTradePassword());
+ Boolean aBoolean = operationPermissionMemberFrozen(memberId);
+ if(aBoolean){
+ throw new FebsException("用户已冻结");
+ }
+ if(!tradePassword.equals(mallMember.getTradePassword())){
+ throw new FebsException("请输入正确的交易密码");
+ }
+ MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
+ BigDecimal gsd = mallMemberAmount.getGsd();
+ if(BigDecimal.ZERO.compareTo(gsd) >= 0){
+ throw new FebsException("积分不足");
+ }
+ if(cnt.compareTo(gsd) > 0){
+ throw new FebsException("积分不足");
+ }
+ Integer type = transGfdDto.getType();
+ String orderNo = MallUtils.getOrderNum("GSD");
+ if(1 == type){//GFD兑换NFT
+ BigDecimal trendsNft = mallMemberAmount.getTrendsNft();
+ mallMemberAmount.setTrendsNft(trendsNft.add(cnt));
+ mallMemberAmount.setGsd(mallMemberAmount.getGsd().subtract(cnt));
+ mallMemberAmountMapper.updateTrendsNftAndGsdById(mallMemberAmount);
+ iMallMoneyFlowService.addMoneyFlow(
+ memberId,
+ cnt,
+ MoneyFlowTypeNewEnum.GSD_NFT.getValue(),
+ orderNo,
+ mallMember.getId(),
+ FlowTypeNewEnum.GSD.getValue(),
+ MoneyFlowTypeNewEnum.GSD_NFT.getDescrition());
+
+ }
+ if(2 == type){//GFD兑换GFA
+ BigDecimal fcmCntAva = mallMemberAmount.getFcmCntAva();
+ DataDictionaryCustom fcmPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.FCM_PRICE.getType(),
+ DataDictionaryEnum.FCM_PRICE.getCode());
+ BigDecimal fcmPrice = ObjectUtil.isEmpty(fcmPriceDic) ? new BigDecimal(2) : new BigDecimal(fcmPriceDic.getValue());
+ BigDecimal gsdCnt = cnt.divide(fcmPrice,2,BigDecimal.ROUND_DOWN);
+ mallMemberAmount.setFcmCntAva(fcmCntAva.add(gsdCnt));
+ mallMemberAmount.setGsd(mallMemberAmount.getGsd().subtract(cnt));
+ mallMemberAmountMapper.updateFcmCntAvaAndGsdById(mallMemberAmount);
+ iMallMoneyFlowService.addMoneyFlow(
+ memberId,
+ cnt,
+ MoneyFlowTypeNewEnum.GSD_GFA.getValue(),
+ orderNo,
+ mallMember.getId(),
+ FlowTypeNewEnum.GSD.getValue(),
+ MoneyFlowTypeNewEnum.GSD_GFA.getDescrition());
+
+ }
+ return new FebsResponse().success();
+ }
+
+ @Override
+ public FebsResponse orderSellList(ApiOrderSellDto apiOrderBuyDto) {
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+ IPage<ApiOrderSellVo> page = new Page<>(apiOrderBuyDto.getPageNum(), apiOrderBuyDto.getPageSize());
+ apiOrderBuyDto.setMemberId(memberId);
+ IPage<ApiOrderSellVo> apiOrderBuyVoIPage = mallProductBuyMapper.selectSellListInPage(page, apiOrderBuyDto);
+ return new FebsResponse().success().data(apiOrderBuyVoIPage);
+ }
}
--
Gitblit v1.9.1