From 89ddff9a271d752aa2de91c25b82d8d7b8eee281 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Wed, 13 Dec 2023 17:21:23 +0800
Subject: [PATCH] 微信小程序配置

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java |   24 +++++++++++++++++-------
 1 files changed, 17 insertions(+), 7 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 82b4dfb..a70f9fe 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,6 +17,7 @@
 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;
@@ -30,6 +31,7 @@
 
 import java.math.BigDecimal;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 @Slf4j
@@ -497,6 +499,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,13 +655,12 @@
                     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);
             }
         }
 

--
Gitblit v1.9.1