From c0161c424fcfd724651fd1fd08a895816ef2b0d7 Mon Sep 17 00:00:00 2001
From: dzc <2388224167@qq.com>
Date: Thu, 24 Apr 2025 11:37:44 +0800
Subject: [PATCH] =?UTF-8?q?feat:=E6=9F=A5=E7=9C=8B=E5=BD=93=E5=89=8D?=
 =?UTF-8?q?=E7=94=A8=E6=88=B7=E6=98=AF=E5=90=A6=E6=9C=89=E6=AD=A3=E5=9C=A8?=
 =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E8=B4=AD=E4=B9=B0=E7=9A=84=E5=8A=A8=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../hard/service/impl/HardDoorFlowServiceImpl.java   | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardDoorFlowServiceImpl.java b/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardDoorFlowServiceImpl.java
index f511878f6..89f717fa3 100644
--- a/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardDoorFlowServiceImpl.java
+++ b/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardDoorFlowServiceImpl.java
@@ -29,7 +29,9 @@ import com.bsd.pjcloud.hard.api.utils.HardUtil;
 import com.bsd.pjcloud.hard.api.vo.HardDoorFlowVo;
 import com.bsd.pjcloud.hard.api.vo.manager.HardDoorManagerVo;
 import com.bsd.pjcloud.hard.api.vo.spu.HardSpuJoinVo;
-import com.bsd.pjcloud.hard.mapper.HardAuthMapper;
+
+import java.time.temporal.ChronoUnit;
+
 import com.bsd.pjcloud.hard.mapper.HardDoorFlowMapper;
 import com.bsd.pjcloud.hard.mapper.manager.HardManagerMapper;
 import com.bsd.pjcloud.hard.service.*;
@@ -200,6 +202,14 @@ public class HardDoorFlowServiceImpl extends ServiceImpl<HardDoorFlowMapper, Har
         if (!userCredit) {
             throw new RuntimeException("用户信誉不足,请联系管理员");
         }
+        // 查看当前用户是否有正在进行购买的动作
+        Long isHaveFlowCount = baseMapper.selectCount(new LambdaQueryWrapper<HardDoorFlowEntity>()
+                .eq(HardDoorFlowEntity::getUserId, dto.getUserId())
+                .eq(HardDoorFlowEntity::getIsOpen, YesNoEnum.NO.getCode())
+                .eq(HardDoorFlowEntity::getBizType, HardDoorFlowBizEnum.PAY_OPEN.getType())
+                .between(HardDoorFlowEntity::getCreateTime, LocalDateTime.now().minus(1, ChronoUnit.HOURS), LocalDateTime.now())
+        );
+        if (isHaveFlowCount > 0) throw new RuntimeException("正在购买中请勿重复操作,请稍后再试");
         // 查询货柜是否配置spu信息
         List<HardSpuJoinVo> spuList = hardSpuJoinService.getSpuList(hardDoorDetail.getId(), dto.getCabinetNo());
         if (ObjectUtil.isEmpty(spuList) || spuList.isEmpty()) throw new RuntimeException("货柜商品信息为空,请上架");