From d3844ee25fbb06b656b5521978f083695d194b07 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 29 Apr 2025 09:56:11 +0800
Subject: [PATCH] feat(mall): 添加门票核销功能

---
 src/main/java/cc/mrbird/febs/mall/service/impl/HappyActivityServiceImpl.java |   39 +++++++++++++++++++++++++++++++++++----
 1 files changed, 35 insertions(+), 4 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/HappyActivityServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/HappyActivityServiceImpl.java
index b2d0db8..e3d7a6c 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/HappyActivityServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/HappyActivityServiceImpl.java
@@ -903,11 +903,10 @@
                 .last("limit 1")
         );
         if(happyActivityOrderItem != null){
-            happyActivityOrderItem.setState(StateUpDownEnum.UP.getCode());
-            happyActivityOrderItem.setTransferItemId(memberId);
-            happyActivityOrderItemMapper.updateById(happyActivityOrderItem);
 
-            agentProducer.sendCheckActivityItem(happyActivityOrderItem.getOrderId());
+            if(StateUpDownEnum.UP.getCode() == happyActivityOrderItem.getState()){
+                throw new FebsException("该票号已核销!");
+            }
 
             HappyActivity happyActivity = this.baseMapper.selectById(happyActivityOrderItem.getActivityId());
             ApiCheckOrderVo apiCheckOrderVo = new ApiCheckOrderVo();
@@ -926,6 +925,38 @@
         return new FebsResponse().fail().message("核销失败!");
     }
 
+    @Override
+    public FebsResponse insureOrder(ApiCheckOrderDto dto) {
+        // 获取当前登录用户的ID
+        Long memberId = LoginUserUtil.getLoginUser().getId();
+
+        MallMember mallMember = mallMemberMapper.selectById(memberId);
+
+        if(StateUpDownEnum.UP.getCode() != mallMember.getCheckOrder()){
+            throw new FebsException("您不是核销员!");
+        }
+
+        String orderItemCode = dto.getOrderItemCode();
+
+        HappyActivityOrderItem happyActivityOrderItem = happyActivityOrderItemMapper.selectOne(
+                new LambdaQueryWrapper<HappyActivityOrderItem>()
+                        .eq(HappyActivityOrderItem::getCode, orderItemCode)
+                        .eq(HappyActivityOrderItem::getState, StateUpDownEnum.DOWN.getCode())
+                        .last("limit 1")
+        );
+        if(happyActivityOrderItem != null){
+            if(StateUpDownEnum.UP.getCode() == happyActivityOrderItem.getState()){
+                throw new FebsException("该票号已核销!");
+            }
+
+            happyActivityOrderItem.setState(StateUpDownEnum.UP.getCode());
+            happyActivityOrderItem.setTransferItemId(memberId);
+            happyActivityOrderItemMapper.updateById(happyActivityOrderItem);
+            agentProducer.sendCheckActivityItem(happyActivityOrderItem.getOrderId());
+        }
+        return new FebsResponse().success().message("操作成功");
+    }
+
     /**
      * 检查活动订单项的状态
      * 当指定订单的所有活动订单项都不处于"未使用"状态时,将订单状态更新为"已使用"

--
Gitblit v1.9.1