From c897a68da55d63439826d37be3cb13c5c0f95a48 Mon Sep 17 00:00:00 2001 From: huliguo <2023611923@qq.com> Date: 星期五, 25 七月 2025 20:13:02 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/2.0' into 2.0 --- ruoyi-modules/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/order/OrderServiceImpl.java | 676 ++++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 533 insertions(+), 143 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..defa9b3 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; @@ -52,6 +58,8 @@ import com.ruoyi.order.util.HuiFuTianXiaUtil; import com.ruoyi.order.util.douyin.OrderUtil; import com.ruoyi.order.util.douyin.VerifyUtil; +import com.ruoyi.order.util.kuaishou.KSOrderUtil; +import com.ruoyi.order.util.kuaishou.KSVerifyUtil; import com.ruoyi.system.api.constant.AppErrorConstant; import com.ruoyi.system.api.constant.DelayTaskEnum; import com.ruoyi.system.api.constant.SecurityConstant; @@ -84,6 +92,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; @@ -1494,7 +1504,7 @@ appUserOrderGetVo.setCouponDiscount(order.getCouponMoney()); appUserOrderGetVo.setReceivableDeposit(order.getReceivableDeposit()); appUserOrderGetVo.setReceivableMoney(order.getReceivableMoney()); - appUserOrderGetVo.setUnpaidMoney(order.getReceivableMoney().subtract(order.getOnlinePayMoney())); + appUserOrderGetVo.setUnpaidMoney(order.getReceivableMoney().subtract(null == order.getOnlinePayMoney() ? BigDecimal.ZERO : order.getOnlinePayMoney())); appUserOrderGetVo.setPayType(order.getPayType()); appUserOrderGetVo.setPayMoney(order.getPayMoney()); appUserOrderGetVo.setOrderRemark(order.getOrderRemark()); @@ -1868,13 +1878,55 @@ // 设置返回对象的属性值 merVerifyOrderVo.setOrderId(orderId); merVerifyOrderVo.setOrderFrom(6); - merVerifyOrderVo.setOrderStatus(status.intValue() == 1 ? 2 : 3); + merVerifyOrderVo.setOrderStatus((null == status || status.intValue() == 1) ? 2 : 3); List<AppUserOrderGoodsPageVo> appUserOrderGoodsPageVoList = new ArrayList<>(); AppUserOrderGoodsPageVo orderGoodsPageVo = new AppUserOrderGoodsPageVo(); orderGoodsPageVo.setGoodsName(sku.getTitle()); appUserOrderGoodsPageVoList.add(orderGoodsPageVo); merVerifyOrderVo.setAppUserOrderGoodsPageVoList(appUserOrderGoodsPageVoList); - merVerifyOrderVo.setLaveTime(timeCard.getTimesCount() - timeCard.getTimesUsed()); + if(null != timeCard){ + merVerifyOrderVo.setLaveTime(timeCard.getTimesCount() - timeCard.getTimesUsed()); + }else{ + merVerifyOrderVo.setLaveTime(-1); + } + // 返回结果 + return merVerifyOrderVo; + } + + + @Override + public MerVerifyOrderVo verifyOrderKuaiShou(String orderId, Long shopId) { + VerifyPrepareDataNew data = KSVerifyUtil.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); + if(null != sku.getTimes_count()){ + merVerifyOrderVo.setLaveTime(sku.getTimes_count()); + }else{ + merVerifyOrderVo.setLaveTime(-1); + } // 返回结果 return merVerifyOrderVo; } @@ -2141,27 +2193,43 @@ throw new ServiceException("查询券信息失败"); } List<CertificatePrepareResponseDataCertificatesItem> itemList = data.getCertificates(); - if (null == itemList || itemList.isEmpty()) { + if (null == itemList && itemList.isEmpty()) { throw new ServiceException("查询券信息失败"); } CertificatePrepareResponseDataCertificatesItem certificatesItem = itemList.get(0); + //商品信息 + CertificatePrepareResponseDataCertificatesItemSku sku = certificatesItem.getSku(); + //次卡信息 + CertificatePrepareResponseDataCertificatesItemTimeCard timeCard = certificatesItem.getTimeCard(); Number status = certificatesItem.getStatus(); - if (status.intValue() == 2) { + if (null != status && status.intValue() == 2) { throw new ServiceException("该抖音券不能重复核销"); } - if (status.intValue() != 1) { + if (null != status && status.intValue() != 1) { throw new ServiceException("抖音券核销失败"); } + Member member = remoteMemberService.getMemberByMobile(phone).getData();//绑定用户判断核销商户 + if(null == member){ + throw new ServiceException("手机号还未注册账户,请先进行注册"); + } + if (member.getBindingFlag() == 1) { + if (!member.getRelationShopId().equals(shopId)) { + throw new ServiceException(AppErrorConstant.VERIFY_SHOP_ERROR); + } + } + //不是次卡才校验是否重复核销 + if(null == timeCard){ + Order one = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getTripartiteOrderId, data.getOrderId())); + if (null != one) { + throw new ServiceException("该抖音券不能重复核销"); + } + } String encryptedCode = certificatesItem.getEncryptedCode(); - List<CertificateVerifyResponseDataVerifyResultsItem> items = VerifyUtil.certificateVerify(data.getVerifyToken(), shop.getPoiId(), new ArrayList<String>() {{ + List<CertificateVerifyResponseDataVerifyResultsItem> items = VerifyUtil.certificateVerify(data.getVerifyToken(), shop.getDyPoiId(), new ArrayList<String>() {{ add(encryptedCode); }}); if (null == items || items.isEmpty()) { throw new ServiceException("抖音券核销失败"); - } - Order one = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getTripartiteOrderId, data.getOrderId())); - if (null != one) { - throw new ServiceException("该抖音券不能重复核销"); } TradeOrderQueryResponseData tradeOrderQueryResponseData = OrderUtil.queryOrderList(1, 10, data.getOrderId()); @@ -2171,161 +2239,483 @@ BigDecimal payAmount = BigDecimal.ZERO; //优惠金额 BigDecimal payDiscountAmount = BigDecimal.ZERO; + Long createOrderTime = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")); + Long payTime = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")); if (null != tradeOrderQueryResponseData) { TradeOrderQueryResponseDataOrdersItem ordersItem = tradeOrderQueryResponseData.getOrders().get(0); - TradeOrderQueryResponseDataOrdersItemAmountInfo amountInfo = ordersItem.getAmountInfo(); - originAmount = BigDecimal.valueOf(amountInfo.getOriginAmount()).divide(new BigDecimal(100)); - payAmount = BigDecimal.valueOf(amountInfo.getPayAmount()).divide(new BigDecimal(100)); - payDiscountAmount = BigDecimal.valueOf(amountInfo.getPayDiscountAmount()).divide(new BigDecimal(100)); + originAmount = BigDecimal.valueOf(ordersItem.getOriginalAmount()).divide(new BigDecimal(100)); + payAmount = BigDecimal.valueOf(ordersItem.getPayAmount()).divide(new BigDecimal(100)); + payDiscountAmount = BigDecimal.valueOf(ordersItem.getDiscountAmount()).divide(new BigDecimal(100)); + createOrderTime = ordersItem.getCreateOrderTime(); + payTime = ordersItem.getPayTime(); } 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(6); - 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.getOrderId()); - + Order order = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getTripartiteOrderId, data.getOrderId())); + if(null == order){ + order = new Order(); + order.setOrderId(IdUtils.fastSimpleUUID()); + order.setDelFlag(0); + order.setOrderStatus(3); + order.setOrderNo(CodeFactoryUtil.getShopOrderNo()); + order.setOrderFrom(6); + 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(new Date(createOrderTime * 1000)); + order.setPayTime(new Date(payTime * 1000)); + order.setTripartiteOrderId(data.getOrderId()); + order.setUseTime(nowTime); + order.setUseUserId(merVerifyOrderDto.getUserId()); + order.setCloseFlag(1); + order.setGoodsNum(1); + order.setCouponMoney(BigDecimal.ZERO); + this.save(order); + //创建服务商品 + //获取商品信息(商品简介,调理问题) + + OrderGoods orderGoods = new OrderGoods(); + orderGoods.setOrderGoodsId(IdUtils.simpleUUID()); + orderGoods.setDelFlag(0); + orderGoods.setOrderId(order.getOrderId()); + + ConsumerGoods consumerGoods = new ConsumerGoods(); + if(null != timeCard){ + orderGoods.setBuyNum(timeCard.getTimesCount()); + orderGoods.setServiceNum(timeCard.getTimesCount()); + consumerGoods.setServiceNum(timeCard.getTimesCount()); + consumerGoods.setUsedNum(1); + consumerGoods.setUseTime(new Date()); + } + orderGoods.setCycleNumFlag(1); + orderGoods.setGoodsType(2); + orderGoods.setGoodsName(sku.getTitle()); + orderGoodsService.save(orderGoods); + + consumerGoods.setConsumerGoodsId(IdUtils.simpleUUID()); + consumerGoods.setDelFlag(0); + consumerGoods.setServiceStatus(1); + consumerGoods.setShopId(order.getShopId()); + consumerGoods.setUserId(order.getUserId()); + consumerGoods.setOrderId(orderId); + consumerGoods.setOrderGoodsId(orderGoods.getOrderGoodsId()); + consumerGoods.setGoodsName(sku.getTitle()); + consumerGoods.setCycleNumFlag(1); + 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(BigDecimal.ZERO); + 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; + }else{ + //扣减剩余次数 + OrderGoods orderGoods = orderGoodsService.getOne(new LambdaQueryWrapper<OrderGoods>().eq(OrderGoods::getOrderId, order.getOrderId())); + ConsumerGoods consumerGoods = consumerGoodsService.getOne(new LambdaQueryWrapper<ConsumerGoods>().eq(ConsumerGoods::getOrderId, order.getOrderId()).eq(ConsumerGoods::getOrderGoodsId, orderGoods.getOrderGoodsId())); + consumerGoods.setUsedNum(consumerGoods.getUsedNum() + 1); + consumerGoods.setUseTime(new Date()); + if(consumerGoods.getUsedNum() == consumerGoods.getServiceNum()){ + consumerGoods.setCompleteTime(new Date()); + } + consumerGoodsService.updateById(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(BigDecimal.ZERO); + merVerifyOrderVo.setUserId(order.getUserId()); + merVerifyOrderVo.setUserName(member.getRealName()); + merVerifyOrderVo.setUserMobile(member.getMobile()); + merVerifyOrderVo.setCloseFlag(order.getCloseFlag()); + return merVerifyOrderVo; + } + } + + + /** + * 核销快手券 + * + * @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 = KSVerifyUtil.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(); + if(null == sku.getTimes_count()){ + Order one = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getTripartiteOrderId, data.getOrder_id())); + if (null != one) { + throw new ServiceException("该快手券不能重复核销"); + } + } + + Member member = remoteMemberService.getMemberByMobile(phone).getData(); //绑定用户判断核销商户 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); - //创建服务商品 - //获取商品信息(商品简介,调理问题) - //商品信息 - CertificatePrepareResponseDataCertificatesItemSku sku = certificatesItem.getSku(); - //次卡信息 - CertificatePrepareResponseDataCertificatesItemTimeCard timeCard = certificatesItem.getTimeCard(); - OrderGoods orderGoods = new OrderGoods(); - orderGoods.setOrderGoodsId(IdUtils.simpleUUID()); - orderGoods.setDelFlag(0); - orderGoods.setOrderId(order.getOrderId()); - orderGoods.setBuyNum(timeCard.getTimesCount()); - orderGoods.setCycleNumFlag(1); - orderGoods.setServiceNum(timeCard.getTimesCount()); - orderGoods.setGoodsType(2); - orderGoods.setGoodsName(sku.getTitle()); - orderGoodsService.save(orderGoods); + String encryptedCode = certificatesItem.getEncrypted_code(); + List<VerifyResult> items = KSVerifyUtil.certificateVerify(redisService, data.getVerify_token(), shop.getKsPoiId(), new ArrayList<String>() {{ + add(encryptedCode); + }}, data.getOrder_id()); + if (null == items || items.isEmpty()) { + throw new ServiceException("快手券核销失败"); + } + + OpenApiQueryOrderDetailInfoV1 orderDetailInfoV1 = KSOrderUtil.queryOrderInfo(redisService, data.getOrder_id()); + //原始金额 + BigDecimal originAmount = BigDecimal.ZERO; + //支付金额 + BigDecimal payAmount = BigDecimal.ZERO; + //优惠金额 + BigDecimal payDiscountAmount = BigDecimal.ZERO; + Long create_order_time = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")); + Long pay_time = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")); + if (null != orderDetailInfoV1) { + OpenApiOrderAmountV1 amountInfo = orderDetailInfoV1.getAmount(); + originAmount = BigDecimal.valueOf(amountInfo.getTotal_amount()); + payAmount = BigDecimal.valueOf(amountInfo.getPay_amount()); + payDiscountAmount = originAmount.subtract(payAmount); + create_order_time = orderDetailInfoV1.getCreate_order_time(); + pay_time = orderDetailInfoV1.getPay_time(); + } - 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.setOrderGoodsId(orderGoods.getOrderGoodsId()); - consumerGoods.setGoodsName(sku.getTitle()); - consumerGoods.setCycleNumFlag(1); - consumerGoods.setServiceNum(timeCard.getTimesCount()); - 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()); + Date nowTime = new Date(); + Order order = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getTripartiteOrderId, data.getOrder_id())); + if(null == 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(new Date(create_order_time * 1000)); + order.setPayTime(new Date(pay_time * 1000)); + order.setTripartiteOrderId(data.getOrder_id()); + order.setUseTime(nowTime); + order.setUseUserId(merVerifyOrderDto.getUserId()); + order.setCloseFlag(1); + order.setGoodsNum(1); + order.setCouponMoney(BigDecimal.ZERO); + this.save(order); + //创建服务商品 + //获取商品信息(商品简介,调理问题) + + 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.setUsedNum(1); + consumerGoods.setUseTime(new Date()); + 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()); + 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.setReceiveMoney(BigDecimal.ZERO); + 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); + merVerifyOrderVo.setUnReceiveMoney(BigDecimal.ZERO); + 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); } - 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()); + 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; + }else{ + //扣减剩余次数 + OrderGoods orderGoods = orderGoodsService.getOne(new LambdaQueryWrapper<OrderGoods>().eq(OrderGoods::getOrderId, order.getOrderId())); + ConsumerGoods consumerGoods = consumerGoodsService.getOne(new LambdaQueryWrapper<ConsumerGoods>().eq(ConsumerGoods::getOrderId, order.getOrderId()).eq(ConsumerGoods::getOrderGoodsId, orderGoods.getOrderGoodsId())); + consumerGoods.setUsedNum(consumerGoods.getUsedNum() + 1); + consumerGoods.setUseTime(new Date()); + if(consumerGoods.getUsedNum() == consumerGoods.getServiceNum()){ + consumerGoods.setCompleteTime(new Date()); + } + consumerGoodsService.updateById(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(BigDecimal.ZERO); + merVerifyOrderVo.setUserId(order.getUserId()); + merVerifyOrderVo.setUserName(member.getRealName()); + merVerifyOrderVo.setUserMobile(member.getMobile()); + merVerifyOrderVo.setCloseFlag(order.getCloseFlag()); + return merVerifyOrderVo; } - //更新消费时间 - memberTotalChangeDto.setConsumeTime(nowTime); - remoteMemberService.changeMemberTotal(memberTotalChangeDto); - return merVerifyOrderVo; + } + /** * @param orderId * @param orderNo -- Gitblit v1.7.1