From bc26bbd27b75ab2f8ffc79a5a5fe25206f15abc7 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 28 Nov 2023 17:39:07 +0800
Subject: [PATCH] 匹配
---
src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java | 71 ++++++++++++++++++++++++++++++++---
1 files changed, 65 insertions(+), 6 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 15fb84f..842f7b9 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
@@ -49,7 +49,32 @@
@Override
public List<ApiMallProductNftVo> productNFTList() {
+
+ 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());
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);
+ }
+ }
+ }
return list;
}
@@ -64,6 +89,25 @@
* 预约，验证交易密码、预约产品是否开启状态、该产品是否已经预约、token是否足够
* 冻结对应的令牌数量、生成预约记录、生成流水记录
*/
+ Integer isFrozen = mallMember.getIsFrozen();
+ if(ProductEnum.MEMBER_UNFROZEN.getValue() != isFrozen){
+ 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("请输入正确的交易密码");
}
@@ -75,7 +119,7 @@
throw new FebsException("预约超时");
}
MallProductBuy mallProductBuy = mallProductBuyMapper.selectMemberIdAndNFTIdAndStateAndMateState(
- memberId,productNFTId,ProductEnum.PRODUCT_BUY_ON_GOING.getValue(),null);
+ memberId,productNFTId,ProductEnum.PRODUCT_BUY_ON_GOING.getValue(),ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
if(ObjectUtil.isNotEmpty(mallProductBuy)){
throw new FebsException("不可重复预约");
}
@@ -95,7 +139,8 @@
mallProductBuy.setState(ProductEnum.PRODUCT_BUY_ON_GOING.getValue());
mallProductBuy.setMateState(ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
mallProductBuy.setNftTotal(mallProductNft.getPriceNft());
- mallProductBuy.setNftAva(BigDecimal.ZERO);
+ mallProductBuy.setNftAva(mallProductNft.getPriceNft());
+// mallProductBuy.setNftAva(BigDecimal.ZERO);
mallProductBuyMapper.insert(mallProductBuy);
//令牌 可用减少，冻结增加
mallMemberAmount.setTokenAva(mallMemberAmount.getTokenAva().subtract(priceToken));
@@ -176,8 +221,9 @@
FlowTypeNewEnum.FCM_COIN.getValue(),
MoneyFlowTypeNewEnum.FCM_OUT_FEE.getDescrition());
- mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(nftCnt));
- mallMemberAmountMapper.updateTrendsNftById(mallMemberAmount);
+ MallMemberAmount mallMemberAmountNft = mallMemberAmountMapper.selectByMemberId(memberId);
+ mallMemberAmountNft.setTrendsNft(mallMemberAmountNft.getTrendsNft().add(nftCnt));
+ mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountNft);
String orderNoNFT = MallUtils.getOrderNum("NFT");
iMallMoneyFlowService.addMoneyFlow(
memberId,
@@ -248,8 +294,13 @@
mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().subtract(nftCnt));
mallMemberAmountMapper.updateTrendsNftById(mallMemberAmount);
- mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().add(nftCntAva));
- mallMemberAmountMapper.updateFrozenNftById(mallMemberAmount);
+ MallMemberAmount mallMemberAmountFcm = mallMemberAmountMapper.selectByMemberId(memberId);
+ mallMemberAmountFcm.setFcmCntAva(mallMemberAmountFcm.getFcmCntAva().subtract(fcmFeeCnt));
+ mallMemberAmountMapper.updateFcmCntAvaById(mallMemberAmountFcm);
+
+ MallMemberAmount mallMemberAmountFrozenNFT = mallMemberAmountMapper.selectByMemberId(memberId);
+ mallMemberAmountFrozenNFT.setFrozenNft(mallMemberAmountFrozenNFT.getFrozenNft().add(nftCntAva));
+ mallMemberAmountMapper.updateFrozenNftById(mallMemberAmountFrozenNFT);
iMallMoneyFlowService.addMoneyFlow(
memberId,
nftCnt.negate(),
@@ -260,6 +311,14 @@
MoneyFlowTypeNewEnum.NFT_OUT.getDescrition());
iMallMoneyFlowService.addMoneyFlow(
memberId,
+ fcmFeeCnt.negate(),
+ MoneyFlowTypeNewEnum.NFT_OUT_FEE_FCM.getValue(),
+ orderNo,
+ mallMember.getId(),
+ FlowTypeNewEnum.FCM_COIN.getValue(),
+ MoneyFlowTypeNewEnum.NFT_OUT_FEE_FCM.getDescrition());
+ iMallMoneyFlowService.addMoneyFlow(
+ memberId,
nftFee.negate(),
MoneyFlowTypeNewEnum.NFT_OUT_FEE.getValue(),
orderNo,
--
Gitblit v1.9.1