From 22316f91223df0535d67bdc34deeb9d4cb4fbf71 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 05 Jan 2024 15:14:57 +0800 Subject: [PATCH] 团队列表 --- src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java | 361 ++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 322 insertions(+), 39 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 1f2f630..7b39e38 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,7 @@ import java.math.BigDecimal; import java.util.ArrayList; +import java.util.Date; import java.util.List; @Slf4j @@ -46,6 +49,7 @@ private final MallProductSellMapper mallProductSellMapper; private final MallProductSellRecordMapper mallProductSellRecordMapper; private final MallProductBuyRecordMapper mallProductBuyRecordMapper; + private final MallMemberSpeakMapper mallMemberSpeakMapper; @Override public List<ApiMallProductNftVo> productNFTList() { @@ -64,15 +68,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; @@ -94,20 +99,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,6 +127,13 @@ memberId,productNFTId,ProductEnum.PRODUCT_BUY_ON_GOING.getValue(),ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue()); if(ObjectUtil.isNotEmpty(mallProductBuy)){ 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(); @@ -362,24 +374,41 @@ ); DateTime endTime = DateUtil.parseTime(endTimeDic.getValue()); if(nowTime.compareTo(startTime) >= 0 && nowTime.compareTo(endTime) <= 0){ - //买单 - if(2 == orderType){ - IPage<ApiOrderListVo> page = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); - IPage<ApiOrderListVo> apiOrderListVoIPageBuy = mallProductBuyMapper.selectListInPage(page, apiOrderListDto); - if(CollUtil.isNotEmpty(apiOrderListVoIPageBuy.getRecords())){ - for(ApiOrderListVo apiOrderListVo : apiOrderListVoIPageBuy.getRecords()){ - objects.add(apiOrderListVo); - } +// //买单 +// if(2 == orderType){ +// IPage<ApiOrderListVo> page = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); +// IPage<ApiOrderListVo> apiOrderListVoIPageBuy = mallProductBuyMapper.selectListInPage(page, apiOrderListDto); +// if(CollUtil.isNotEmpty(apiOrderListVoIPageBuy.getRecords())){ +// for(ApiOrderListVo apiOrderListVo : apiOrderListVoIPageBuy.getRecords()){ +// objects.add(apiOrderListVo); +// } +// } +// } +// //卖单 +// if(1 == orderType){ +// IPage<ApiOrderListVo> page = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); +// IPage<ApiOrderListVo> apiOrderListVoIPageSell = mallProductSellMapper.selectListInPage(page, apiOrderListDto); +// if(CollUtil.isNotEmpty(apiOrderListVoIPageSell.getRecords())){ +// for(ApiOrderListVo apiOrderListVo : apiOrderListVoIPageSell.getRecords()){ +// objects.add(apiOrderListVo); +// } +// } +// } + + IPage<ApiOrderListVo> pageBuy = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); + IPage<ApiOrderListVo> apiOrderListVoIPageBuy = mallProductBuyMapper.selectListInPage(pageBuy, apiOrderListDto); + if(CollUtil.isNotEmpty(apiOrderListVoIPageBuy.getRecords())){ + for(ApiOrderListVo apiOrderListVo : apiOrderListVoIPageBuy.getRecords()){ + objects.add(apiOrderListVo); } } - //卖单 - if(1 == orderType){ - IPage<ApiOrderListVo> page = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); - IPage<ApiOrderListVo> apiOrderListVoIPageSell = mallProductSellMapper.selectListInPage(page, apiOrderListDto); - if(CollUtil.isNotEmpty(apiOrderListVoIPageSell.getRecords())){ - for(ApiOrderListVo apiOrderListVo : apiOrderListVoIPageSell.getRecords()){ - objects.add(apiOrderListVo); - } + + + IPage<ApiOrderListVo> pageSell = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); + IPage<ApiOrderListVo> apiOrderListVoIPageSell = mallProductSellMapper.selectListInPage(pageSell, apiOrderListDto); + if(CollUtil.isNotEmpty(apiOrderListVoIPageSell.getRecords())){ + for(ApiOrderListVo apiOrderListVo : apiOrderListVoIPageSell.getRecords()){ + objects.add(apiOrderListVo); } } } @@ -479,6 +508,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(); } @@ -547,4 +585,249 @@ } return false; } + + @Override + public FebsResponse orderSellComplain(ApiOrderSellComplainDto apiOrderSellComplainDto) { + Long memberId = LoginUserUtil.getLoginUser().getId(); + Long sellRecordId = apiOrderSellComplainDto.getSellRecordId(); + Integer orderType = apiOrderSellComplainDto.getOrderType(); + String buyOrderNo = null; + if(orderType == 1){ + + MallProductSellRecord mallProductSellRecord = mallProductSellRecordMapper.selectById(sellRecordId); + if(ObjectUtil.isEmpty(mallProductSellRecord)){ + throw new FebsException("记录不存在"); + } + MallProductBuyRecord mallProductBuyRecord = mallProductBuyRecordMapper.selectById(mallProductSellRecord.getBuyRecordId()); + if(ObjectUtil.isEmpty(mallProductBuyRecord)){ + throw new FebsException("记录不存在"); + } + + mallProductBuyRecord.setState(ProductEnum.PRODUCT_MATE_STATE_COMPLAIN.getValue()); + mallProductBuyRecordMapper.updateById(mallProductBuyRecord); + + mallProductSellRecord.setState(ProductEnum.PRODUCT_MATE_STATE_COMPLAIN.getValue()); + mallProductSellRecordMapper.updateById(mallProductSellRecord); + buyOrderNo = mallProductBuyRecord.getBuyOrderNo(); + } + if(orderType == 2){ + MallProductBuyRecord mallProductBuyRecord = mallProductBuyRecordMapper.selectById(sellRecordId); + if(ObjectUtil.isEmpty(mallProductBuyRecord)){ + throw new FebsException("记录不存在"); + } + + MallProductSellRecord mallProductSellRecord = mallProductSellRecordMapper.selectById(mallProductBuyRecord.getSellRecordId()); + if(ObjectUtil.isEmpty(mallProductSellRecord)){ + throw new FebsException("记录不存在"); + } + + + mallProductBuyRecord.setState(ProductEnum.PRODUCT_MATE_STATE_COMPLAIN.getValue()); + mallProductBuyRecordMapper.updateById(mallProductBuyRecord); + + mallProductSellRecord.setState(ProductEnum.PRODUCT_MATE_STATE_COMPLAIN.getValue()); + mallProductSellRecordMapper.updateById(mallProductSellRecord); + buyOrderNo = mallProductBuyRecord.getBuyOrderNo(); + + } + + MallMemberSpeak mallMemberSpeak = new MallMemberSpeak(); + mallMemberSpeak.setMemberId(memberId); + mallMemberSpeak.setState(ProductEnum.SPEAK_NO_DEAL.getValue()); + String description = apiOrderSellComplainDto.getDescription(); + mallMemberSpeak.setDescription("编号:"+buyOrderNo+","+description); + mallMemberSpeakMapper.insert(mallMemberSpeak); + return new FebsResponse().success(); + } + + @Override + public FebsResponse orderRecordList(ApiOrderRecordListDto apiOrderListDto) { + Long memberId = LoginUserUtil.getLoginUser().getId(); + List<ApiOrderRecordListVo> objects = new ArrayList<>(); + apiOrderListDto.setMemberId(memberId); + 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){ + IPage<ApiOrderRecordListVo> pageBuy = new Page<>(apiOrderListDto.getPageNum(), apiOrderListDto.getPageSize()); + IPage<ApiOrderRecordListVo> apiOrderListVoIPageBuy = mallProductBuyRecordMapper.selectListInPage(pageBuy, apiOrderListDto); + if(CollUtil.isNotEmpty(apiOrderListVoIPageBuy.getRecords())){ + for(ApiOrderRecordListVo apiOrderListVo : apiOrderListVoIPageBuy.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(); + } } -- Gitblit v1.9.1