devbox
2023面试高手
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

无人自助棋牌室系统使用Redis消息队列实现充值升级会员及开卡赠礼_无人棋牌室uniapp

作者：2023面试高手 | 2024-05-21 09:47:13

赞

踩

无人棋牌室uniapp

本文将介绍如何利用Spring Boot与Redis结合实现消息队列的在实际业务中实践。

   具体场景描述步骤如下：

            用户在自助棋牌室小程序上充值支付后

            调用后台服务端接口首先添加用户充值订单为待支付状态

            调用微信支付接口，支付成功后，微信回调方法设置（充值订单为已支付、添加用户余额、同时发送消息队列通知升级会员、开卡赠礼）

  先视频看下效果吧，有个感观了解

无人自助棋牌室系统实现充值升级会员及开卡赠礼

后台设置会员等级效果

后台设置升级会员开卡效果

  程序开发实现步骤如下：

  1、用户在小程序充值，小程序使用uniapp开发

  1. 			// 充值提交
  2. 			confirmRechargeMoney(){
  3. 				let that = this
  4. 				if(this.topUpList.length<=0){
  5. 					uni.showToast({
  6. 					  title: '商家未设置充值信息',
  7. 					  icon: 'none',
  8. 					  duration: 2000,
  9. 					})
  10. 				}else{
  11. 					
  12. 					 let doRechargeParam = {
  13. 						 storeId:this.storeId,
  14. 						 userId:this.userInfo.uid,
  15. 						 rechargeAmount:this.rechargeAmount
  16. 					 }
  17. 					 doRecharge(doRechargeParam).then(res => {
  18. 						var payment = res.data.payment;
  19. 						weappPay(payment)
  20. 						  .then(() => {
  21. 						    this.$yrouter.back();
  22. 						  })
  23. 					 })					 
  24. 				}
  25. 			},

  2、调用后台服务端接口

  1. export function doRecharge(data) {
  2. 	return request.post("/balance/doRecharge", data, {
  3. 		login: true
  4. 	});
  5. }

  3、后台服务端添加用户充值订单为待支付状态

  1.     /**
  2.      * 充值余额
  3.      */
  4.     @AppLog(value = "充值余额", type = 1)
  5.     //@AuthCheck
  6.     @PostMapping("/balance/doRecharge")
  7.     @ApiOperation(value = "充值余额", notes = "充值余额")
  8.     public ApiResult<Map<String, Object>> doRecharge(HttpServletRequest request, @RequestBody TBalanceParam param) {
  9.         //Integer storeId = request.getHeader("storeId") == null ? 0 : Integer.parseInt(request.getHeader("storeId"));
  10.         // Integer userId = Integer.parseInt(param.get("userId").toString());
  11.         Integer storeId = param.getStoreId();
  12.         Integer userId = param.getUserId();
  13.         Map<String, Object> data = new HashMap();
  14.         // String rechargeAmount = param.get("rechargeAmount") == null ? "" : param.get("rechargeAmount").toString();
  15.         //String customAmount = param.get("customAmount") == null ? "" : param.get("customAmount").toString();
  16.         String rechargeAmount = param.getRechargeAmount();
  17.         String customAmount = param.getCustomAmount();
  18.         if (StringUtil.isEmpty(rechargeAmount) && StringUtil.isEmpty(customAmount)) {
  19.             //return getFailureResult(2000, "请确认充值金额");
  20.             //throw new YshopException("请确认充值金额");
  21.             return ApiResult.fail(ErrorEnum.E_100028.getErrorMsg(), data);
  22.         }
  23.         // 充值赠送金额
  24.         String ruleParam = "";
  25.         MtSetting mtSetting = mtSettingService.querySettingByName(BalanceSettingEnum.RECHARGE_RULE.getKey(), storeId);
  26.         if (StringUtil.isNotEmpty(rechargeAmount) && mtSetting != null) {
  27.             if (mtSetting.getValue() != null && StringUtil.isNotEmpty(mtSetting.getValue())) {
  28.                 String rules[] = mtSetting.getValue().split(",");
  29.                 for (String rule : rules) {
  30.                     String amountArr[] = rule.split("_");
  31.                     if (amountArr.length == 2) {
  32.                         if (amountArr[0].equals(rechargeAmount)) {
  33.                             ruleParam = rule;
  34.                             break;
  35.                         }
  36.                     }
  37.                 }
  38.             }
  39.         }
  40.  
  41.         // 自定义充值没有赠送金额
  42.         if (StringUtil.isEmpty(rechargeAmount)) {
  43.             rechargeAmount = customAmount;
  44.             ruleParam = customAmount + "_0";
  45.         }
  46.  
  47.         if (StringUtil.isEmpty(ruleParam)) {
  48.             ruleParam = rechargeAmount + "_0";
  49.         }
  50.         MtStore mtStore = storeService.queryStoreById(storeId);
  51.         BigDecimal amount = new BigDecimal(rechargeAmount);
  52.         OrderDto orderDto = new OrderDto();
  53.         orderDto.setType(OrderTypeEnum.RECHARGE.getKey());
  54.         orderDto.setUserId(userId);
  55.         orderDto.setStoreId(storeId);
  56.         orderDto.setAmount(amount);
  57.         orderDto.setUsePoint(0);
  58.         if(mtStore!=null){
  59.             orderDto.setRemark(mtStore.getName()+"会员充值");
  60.         }else{
  61.             orderDto.setRemark("平台通用会员充值");
  62.         }
  63.         orderDto.setParam(ruleParam);
  64.         orderDto.setStatus(OrderStatusEnumV.CREATED.getKey());
  65.         orderDto.setPayStatus(PayStatusEnum.WAIT.getKey());
  66.         orderDto.setPointAmount(new BigDecimal("0"));
  67.         orderDto.setOrderMode("");
  68.         orderDto.setCouponId(0);
  69.         MtOrder orderInfo = mtOrderService.saveOrder(orderDto);
  70.         YxUser user = userService.getById(userId);
  71.         String ip = CommonUtilV.getIPFromHttpRequest(request);
  72.         BigDecimal pay = amount.multiply(new BigDecimal("100"));
  73.         orderInfo.setPayType(PayTypeEnumV.JSAPI.getKey());
  74.         ResponseObject paymentInfo = weixinService.createPrepayOrder(user, orderInfo, (pay.intValue()), "", 0, ip, PlatformTypeEnum.MP_WEIXIN.getCode());
  75.         //ResponseObject paymentInfo = weixinService.createPrepayOrder(user, orderInfo, pay, "", 0, ip,PlatformTypeEnum.MP_WEIXIN.getCode());
  76.         if (paymentInfo.getData() == null) {
  77.             //return getFailureResult(201, "抱歉，发起支付失败");
  78.             return ApiResult.fail(ErrorEnum.E_100029.getErrorMsg(), data);
  79.         }
  80.         Object payment = paymentInfo.getData();
  81.         data.put("payment", payment);
  82.         data.put("orderInfo", orderInfo);
  83.         return ApiResult.ok(data);
  84.     }

  注：weixinService.createPrepayOrder为微信支付方式

 4、微信回调方法-充值订单为已支付、添加用户余额

  1.     /**
  2.      * 支付回调
  3.      */
  4.     @RequestMapping(value = "/pay/weixinCallback", method = RequestMethod.POST)
  5.     @CrossOrigin
  6.     public void weixinCallback(HttpServletRequest request, HttpServletResponse response) throws Exception {
  7.         log.info("微信支付结果回调....");
  8.         Map<String, String> inParams = weixinService.processResXml(request);
  9.         log.info("微信返回Map:" + inParams);
  10.         if (!CollectionUtils.isEmpty(inParams)) {
  11.             String orderSn = inParams.get("out_trade_no");// 商户订单号
  12.             String orderId = inParams.get("transaction_id");// 微信订单号
  13.             String tranAmt = inParams.get("total_fee");// 交易金额
  14.             BigDecimal tranAmount = new BigDecimal(tranAmt).divide(new BigDecimal("100"), BigDecimal.ROUND_CEILING);
  15.             // 参数校验
  16.             if (StringUtil.isNotEmpty(orderSn) && StringUtil.isNotEmpty(tranAmt) && StringUtil.isNotEmpty(orderId)) {
  17.                 UserOrderDto orderInfo = mtOrderService.getOrderByOrderSn(orderSn);
  18.                 if (orderInfo != null) {
  19.                     //MtStore storeInfo = orderInfo.getStoreInfo();
  20.                     String callbackUrl = this.getApiUrl() + "/api/pay/weixinCallback";
  21.                     WXPayConfigImpl wxPayConfig = WXPayConfigImpl.getInstance(callbackUrl, orderInfo.getStoreId(), redisUtils, storeService);
  22.                     //WXPayConfigImpl wxPayConfig = WXPayConfigImpl.getInstance(env, storeInfo == null ? 0 : storeInfo.getId(), storeService);
  23.                     boolean valid = WXPayUtil.isSignatureValid(inParams, wxPayConfig.getKey());
  24. /*                    if (!valid) {
  25.                         log.error("微信支付回调接口验签失败");
  26.                         return;
  27.                     }*/
  28.                     // 订单金额
  29.                     BigDecimal payAmount = orderInfo.getPayAmount();
  30.                     int compareFlag = tranAmount.compareTo(payAmount);
  31.                     if (true) { // compareFlag == 0，测试暂时去掉
  32.                         if (orderInfo.getStatus().equals(OrderStatusEnumV.CREATED.getKey())) {
  33.                             boolean flag = weixinService.paymentCallback(orderInfo);
  34.                             log.info("回调结果：" + flag);
  35.                             if (flag) {
  36.                                 weixinService.processRespXml(response, true);
  37.                             } else {
  38.                                 weixinService.processRespXml(response, false);
  39.                             }
  40.                         } else {
  41.                             log.error("订单{}已经支付，orderInfo.getStatus() = {}, CREATED.getKey() = {}", orderSn, orderInfo.getStatus(), OrderStatusEnumV.CREATED.getKey());
  42.                         }
  43.                     } else {
  44.                         log.error("回调金额与支付金额不匹配 tranAmount = {}, payAmount = {}, compareFlag = {}", tranAmount, orderInfo.getPayAmount(), compareFlag);
  45.                     }
  46.                 } else {
  47.                     log.error("支付订单{}对应的信息不存在", orderSn);
  48.                 }
  49.             }
  50.         }
  51.     }

 5、微信回调方法-同时发送消息队列通知升级会员、开卡赠礼

   以下是关键代码步骤片段

  1. // redis发送消息队列，充值升级会员等级,享受预约下单折扣,并有开卡赠礼（赠券）
  2. PublishMessage publishMessage = new PublishMessage();
  3. publishMessage.setMsgType(2);
  4. publishMessage.setStoreId(orderInfo.getStoreId());
  5. publishMessage.setUserId(orderInfo.getUserId());
  6. redisSqueueService.doSomethingAndPublishMessage(publishMessage);

 doSomethingAndPublishMessage()方法时，消息将被发布到Redis的消息队列中，并由订阅者接收和处理

  1. @Service
  2. public class RedisSqueueService {
  3.  
  4.     private final MessagePublisher messagePublisher;
  5.  
  6.     public RedisSqueueService(MessagePublisher messagePublisher) {
  7.         this.messagePublisher = messagePublisher;
  8.     }
  9.  
  10.     public void doSomethingAndPublishMessage(PublishMessage publishMessage) {
  11.  
  12.         // 执行一些操作
  13.         // String message = uid.toString();
  14.         messagePublisher.publishMessage(publishMessage);
  15.  
  16.     }
  17.  
  18. }
消息订阅者接收消息，进行升级会员、开卡赠礼

  1.     @Override
  2.     public void onMessage(Message message, byte[] pattern) {
  3.         
  4.         // 获取消息
  5.         byte[] messageBody = message.getBody();
  6.         // 使用值序列化器转换
  7.         Object msg = redisTemplate.getValueSerializer().deserialize(messageBody);
  8.         PublishMessage publishMessage = (PublishMessage)msg;
  9.         // 添加新注册用户赠送卡券
  10.         if(publishMessage.getMsgType()==1){
  11.  
  12.             Integer userId = publishMessage.getUserId();
  13.             MtCoupon coupon = new MtCoupon();
  14.             // 是否新注册赠送，A：是；D：否
  15.             coupon.setIsNewGive("A");
  16.             List<MtCoupon> list = couponService.queryCouponListByCondi(coupon);
  17.             if(list!=null && list.size()>0){
  18.                 for(MtCoupon mtCoupon:list){
  19.                     if(mtCoupon.getStoreIds()!=null||!"".equals(mtCoupon.getStoreIds())){
  20.                         String[] storeIds = mtCoupon.getStoreIds().split(",");
  21.                         for(String storeId : storeIds){
  22.                             couponService.sendCoupon(mtCoupon.getId(), 1 , userId, Integer.parseInt(storeId));
  23.                         }
  24.                     }
  25.                 }
  26.             }
  27.         // 充值升级会员等级,享受预约下单折扣,并有开卡赠礼（赠券）
  28.         }else if (publishMessage.getMsgType()==2){
  29.  
  30.             LambdaQueryWrapper<MtUserGrade> lambdaQueryWrapper = Wrappers.lambdaQuery();
  31.             lambdaQueryWrapper.eq(MtUserGrade::getStatus, StatusEnum.ENABLED.getKey());
  32.             lambdaQueryWrapper.orderByDesc(MtUserGrade::getId);
  33.             List<MtUserGrade> dataList = mtUserGradeMapper.selectList(lambdaQueryWrapper);
  34.             log.info("dataList.size():"+dataList.size());
  35.             if(dataList!=null){
  36.                 for (MtUserGrade item : dataList) {
  37.                     // 升级方式是充值获取的
  38.                     if(item.getCatchType().equals(UserGradeCatchTypeEnum.RECHARGE.getKey())){
  39.                         log.info(" openGiftService.openGift");
  40.                         openGiftService.openGift(
  41.                                 publishMessage.getUserId(),
  42.                                 item.getId(),
  43.                                 false,
  44.                                 publishMessage.getStoreId());
  45.                     }
  46.                 }
  47.             }
  48.         }
  49.     }

具体Redis消息队列基础实现说明，在无人自助系统使用Redis消息队列实现新用户注册送券 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/601931
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号