From 878ac7cc8e1951bbc7b27619c4e7ece1e3d331ff Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期三, 16 七月 2025 16:41:12 +0800
Subject: [PATCH] 新增加快手团购券核销功能

---
 ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/order/OrderServiceImpl.java |  244 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 244 insertions(+), 0 deletions(-)

diff --git a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/order/OrderServiceImpl.java b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/order/OrderServiceImpl.java
index 2962360..7e10468 100644
--- a/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/order/OrderServiceImpl.java
+++ b/ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/order/OrderServiceImpl.java
@@ -17,6 +17,12 @@
 import com.github.binarywang.wxpay.service.WxPayService;
 import com.google.common.collect.Lists;
 import com.google.gson.Gson;
+import com.kuaishou.locallife.open.api.domain.locallife_order.OpenApiOrderAmountV1;
+import com.kuaishou.locallife.open.api.domain.locallife_order.OpenApiQueryOrderDetailInfoV1;
+import com.kuaishou.locallife.open.api.domain.locallife_trade.SimpleCertificateTimesCard;
+import com.kuaishou.locallife.open.api.domain.locallife_trade.SkuTImesCard;
+import com.kuaishou.locallife.open.api.domain.locallife_trade.VerifyPrepareDataNew;
+import com.kuaishou.locallife.open.api.domain.locallife_trade.VerifyResult;
 import com.ruoyi.common.core.constant.CacheConstants;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.enums.UserStatus;
@@ -84,6 +90,8 @@
 import java.math.RoundingMode;
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
@@ -1879,6 +1887,40 @@
         return merVerifyOrderVo;
     }
     
+    
+    @Override
+    public MerVerifyOrderVo verifyOrderKuaiShou(String orderId, Long shopId) {
+        VerifyPrepareDataNew data = com.ruoyi.order.util.kuaishou.VerifyUtil.certificatePrepare(redisService, orderId);
+        if (null == data) {
+            throw new ServiceException("查询券信息失败");
+        }
+        List<SimpleCertificateTimesCard> itemList = data.getCertificates();
+        if (null == itemList || itemList.isEmpty()) {
+            throw new ServiceException("查询券信息失败");
+        }
+        SimpleCertificateTimesCard certificatesItem = itemList.get(0);
+        Long expire_time = certificatesItem.getExpire_time();
+        if(LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")) > expire_time){
+            throw new ServiceException("优惠券已过期");
+        }
+        //商品信息
+        SkuTImesCard sku = certificatesItem.getSku();
+        // 创建返回对象
+        MerVerifyOrderVo merVerifyOrderVo = new MerVerifyOrderVo();
+        // 设置返回对象的属性值
+        merVerifyOrderVo.setOrderId(orderId);
+        merVerifyOrderVo.setOrderFrom(7);
+        merVerifyOrderVo.setOrderStatus(2);
+        List<AppUserOrderGoodsPageVo> appUserOrderGoodsPageVoList = new ArrayList<>();
+        AppUserOrderGoodsPageVo orderGoodsPageVo = new AppUserOrderGoodsPageVo();
+        orderGoodsPageVo.setGoodsName(sku.getTitle());
+        appUserOrderGoodsPageVoList.add(orderGoodsPageVo);
+        merVerifyOrderVo.setAppUserOrderGoodsPageVoList(appUserOrderGoodsPageVoList);
+        merVerifyOrderVo.setLaveTime(sku.getTimes_count());
+        // 返回结果
+        return merVerifyOrderVo;
+    }
+    
     /**
      * 确认核销订单
      *
@@ -2327,6 +2369,208 @@
     
     
     /**
+     * 核销快手券
+     *
+     * @return
+     */
+    @Override
+    @Transactional
+//    @GlobalTransactional(rollbackFor = Exception.class) todo 放开分布式事务注解
+    public MerVerifyOrderVo sureVerifyOrderKuaiShou(MerVerifyOrderDto merVerifyOrderDto) {
+        String phone = merVerifyOrderDto.getPhone();
+        String orderId = merVerifyOrderDto.getOrderId();
+        Long shopId = merVerifyOrderDto.getShopId();
+        //获取核销商户
+        Shop shop = remoteShopService.getShop(shopId).getData();
+        VerifyPrepareDataNew data = com.ruoyi.order.util.kuaishou.VerifyUtil.certificatePrepare(redisService, orderId);
+        if (null == data) {
+            throw new ServiceException("查询券信息失败");
+        }
+        List<SimpleCertificateTimesCard> itemList = data.getCertificates();
+        if (null == itemList || itemList.isEmpty()) {
+            throw new ServiceException("查询券信息失败");
+        }
+        SimpleCertificateTimesCard certificatesItem = itemList.get(0);
+        Long expire_time = certificatesItem.getExpire_time();
+        if(LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")) > expire_time){
+            throw new ServiceException("优惠券已过期");
+        }
+        
+        String encryptedCode = certificatesItem.getEncrypted_code();
+        List<VerifyResult> items = com.ruoyi.order.util.kuaishou.VerifyUtil.certificateVerify(redisService, data.getVerify_token(), shop.getPoiId(), new ArrayList<String>() {{
+            add(encryptedCode);
+        }}, data.getOrder_id());
+        if (null == items || items.isEmpty()) {
+            throw new ServiceException("快手券核销失败");
+        }
+        Order one = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getTripartiteOrderId, data.getOrder_id()));
+        if (null != one) {
+            throw new ServiceException("该快手券不能重复核销");
+        }
+    
+        OpenApiQueryOrderDetailInfoV1 orderDetailInfoV1 = com.ruoyi.order.util.kuaishou.OrderUtil.queryOrderInfo(redisService, data.getOrder_id());
+        //原始金额
+        BigDecimal originAmount = BigDecimal.ZERO;
+        //支付金额
+        BigDecimal payAmount = BigDecimal.ZERO;
+        //优惠金额
+        BigDecimal payDiscountAmount = BigDecimal.ZERO;
+        if (null != orderDetailInfoV1) {
+            OpenApiOrderAmountV1 amountInfo = orderDetailInfoV1.getAmount();
+            originAmount = BigDecimal.valueOf(amountInfo.getTotal_amount());
+            payAmount = BigDecimal.valueOf(amountInfo.getPay_amount());
+            payDiscountAmount = originAmount.subtract(payAmount);
+        }
+        
+        Date nowTime = new Date();
+        Member member = remoteMemberService.getMemberByMobile(phone).getData();
+        //开始添加订单数据
+        Order order = new Order();
+        order.setOrderId(IdUtils.fastSimpleUUID());
+        order.setDelFlag(0);
+        order.setOrderStatus(3);
+        order.setOrderNo(CodeFactoryUtil.getShopOrderNo());
+        order.setOrderFrom(7);
+        order.setShopId(shopId);
+        order.setUserId(member.getUserId());
+        order.setOrderMoney(originAmount);
+        order.setDiscountMoney(payDiscountAmount);
+        order.setReceivableMoney(payAmount);
+        order.setPayType(1);
+        order.setPayMoney(payAmount);
+        order.setOnlinePayMoney(payAmount);
+        order.setOrderRemark("快手订单");
+        order.setCreateTime(nowTime);
+        order.setPayTime(nowTime);
+        order.setTripartiteOrderId(data.getOrder_id());
+        
+        //绑定用户判断核销商户
+        if (member.getBindingFlag() == 1) {
+            if (!member.getRelationShopId().equals(shopId)) {
+                throw new ServiceException(AppErrorConstant.VERIFY_SHOP_ERROR);
+            }
+        }
+        order.setUseTime(nowTime);
+        order.setUseUserId(merVerifyOrderDto.getUserId());
+        order.setCloseFlag(1);
+        this.save(order);
+        //创建服务商品
+        //获取商品信息(商品简介,调理问题)
+        //商品信息
+        SkuTImesCard sku = certificatesItem.getSku();
+        
+        OrderGoods orderGoods = new OrderGoods();
+        orderGoods.setOrderGoodsId(IdUtils.simpleUUID());
+        orderGoods.setDelFlag(0);
+        orderGoods.setOrderId(order.getOrderId());
+        orderGoods.setGoodsId(sku.getSku_id());
+        orderGoods.setBuyNum(sku.getTimes_count());
+        orderGoods.setCycleNumFlag(1);
+        orderGoods.setServiceNum(sku.getTimes_count());
+        orderGoods.setGoodsType(2);
+        orderGoods.setGoodsName(sku.getTitle());
+        orderGoodsService.save(orderGoods);
+        
+        ConsumerGoods consumerGoods = new ConsumerGoods();
+        consumerGoods.setConsumerGoodsId(IdUtils.simpleUUID());
+        consumerGoods.setDelFlag(0);
+        consumerGoods.setServiceStatus(1);
+        consumerGoods.setShopId(order.getShopId());
+        consumerGoods.setUserId(order.getUserId());
+        consumerGoods.setOrderId(orderId);
+        consumerGoods.setGoodsId(sku.getSku_id());
+        consumerGoods.setOrderGoodsId(orderGoods.getOrderGoodsId());
+        consumerGoods.setGoodsName(sku.getTitle());
+        consumerGoods.setCycleNumFlag(1);
+        consumerGoods.setServiceNum(sku.getTimes_count());
+        consumerGoods.setCreateTime(nowTime);
+        consumerGoods.setGoodsType(2);
+        consumerGoods.setSourceFrom(1);
+        consumerGoodsService.save(consumerGoods);
+        //生成返回
+        MerVerifyOrderVo merVerifyOrderVo = new MerVerifyOrderVo();
+        merVerifyOrderVo.setOrderId(orderId);
+        merVerifyOrderVo.setOrderNo(order.getOrderNo());
+        merVerifyOrderVo.setOrderStatus(order.getOrderStatus());
+        merVerifyOrderVo.setOrderFrom(order.getOrderFrom());
+        merVerifyOrderVo.setOrderGoodsMoney(order.getOrderMoney());
+        merVerifyOrderVo.setCouponDiscount(order.getCouponMoney());
+        merVerifyOrderVo.setReceivableDeposit(order.getReceivableDeposit());
+        merVerifyOrderVo.setPayMoney(order.getPayMoney());
+        merVerifyOrderVo.setOrderRemark(order.getOrderRemark());
+        merVerifyOrderVo.setAppUserOrderGoodsPageVoList(new ArrayList<AppUserOrderGoodsPageVo>() {{
+            add(new AppUserOrderGoodsPageVo() {{
+                setOrderGoodsId(orderGoods.getOrderGoodsId());
+                setGoodsName(orderGoods.getGoodsName());
+                setGoodsType(orderGoods.getGoodsType());
+                setBuyNum(orderGoods.getBuyNum());
+            }});
+        }});
+        merVerifyOrderVo.setCreateTime(order.getCreateTime());
+        merVerifyOrderVo.setPayTime(order.getPayTime());
+        merVerifyOrderVo.setUseTime(order.getUseTime());
+        merVerifyOrderVo.setPayType(order.getPayType());
+        merVerifyOrderVo.setRealReceiveMoney(order.getChangeReceivableMoney());
+        //根据支付方式返回应收金额和已收金额
+        if (order.getPayType() == 1) {
+            merVerifyOrderVo.setReceivableMoney(order.getOrderMoney().subtract(order.getPayMoney()));
+            merVerifyOrderVo.setReceiveMoney(order.getPayMoney());
+        } else {
+            merVerifyOrderVo.setReceivableMoney(order.getOrderMoney().subtract(order.getCouponMoney()).subtract(order.getReceivableDeposit()));
+            if (order.getOfflinePayMoney() != null) {
+                merVerifyOrderVo.setReceiveMoney(order.getOfflinePayMoney());
+            } else {
+                merVerifyOrderVo.setReceiveMoney(BigDecimal.ZERO);
+            }
+        }
+        merVerifyOrderVo.setUnReceiveMoney(merVerifyOrderVo.getRealReceiveMoney().subtract(merVerifyOrderVo.getReceiveMoney()));
+        merVerifyOrderVo.setUserId(order.getUserId());
+        merVerifyOrderVo.setUserName(member.getRealName());
+        merVerifyOrderVo.setUserMobile(member.getMobile());
+        merVerifyOrderVo.setCloseFlag(order.getCloseFlag());
+        //判断用户是否绑定  2023-09-05需求改变核销时绑定用户
+        if (member.getBindingFlag() != 1) {
+            //绑定商户
+            AppMemberBindingDto appMemberBindingDto = new AppMemberBindingDto();
+            appMemberBindingDto.setShopId(order.getShopId());
+            appMemberBindingDto.setUserId(order.getUserId());
+            appMemberBindingDto.setBindingFlag(1);
+            if (order.getOrderFrom() == 1) {
+                appMemberBindingDto.setBindingType(1);
+            } else if (order.getOrderFrom() == 2) {
+                appMemberBindingDto.setBindingType(2);
+            }
+            remoteMemberService.updateMemberBinding(appMemberBindingDto);
+            order.setNewMemberFlag(1);
+        } else {
+            order.setNewMemberFlag(0);
+        }
+        this.saveOrUpdate(order);
+        //更新用户积分和消费统计
+        MemberTotalChangeDto memberTotalChangeDto = new MemberTotalChangeDto();
+        memberTotalChangeDto.setUserId(order.getUserId());
+        // 如果存在积分兑换比例,则计算积分
+        if (redisService.hasKey(SecurityConstant.PAY_MONEY_INTEGRAL)) {
+            Integer moneyValue = redisService.getCacheObject(SecurityConstant.PAY_MONEY_INTEGRAL);
+            BigDecimal moneyValueBig = BigDecimal.valueOf(moneyValue);
+            BigDecimal integralBig = moneyValueBig.multiply(order.getOnlinePayMoney()).setScale(0, BigDecimal.ROUND_HALF_UP);
+            Integer integral = Integer.valueOf(integralBig.toString());
+            if (integral > 0) {
+                memberTotalChangeDto.setChangeIntegral(integral);
+                memberTotalChangeDto.setTypeIntegral(1);
+                memberTotalChangeDto.setOrderId(orderId);
+                memberTotalChangeDto.setOrderNo(order.getOrderNo());
+            }
+        }
+        //更新消费时间
+        memberTotalChangeDto.setConsumeTime(nowTime);
+        remoteMemberService.changeMemberTotal(memberTotalChangeDto);
+        return merVerifyOrderVo;
+    }
+    
+    
+    
+    /**
      * @param orderId
      * @param orderNo
      * @param shopId

--
Gitblit v1.7.1