| | |
| | | import com.ruoyi.system.api.domain.GoodsGroupPurchase; |
| | | import com.ruoyi.system.api.domain.GoodsGroupPurchaseInfo; |
| | | import com.ruoyi.system.api.domain.GoodsSku; |
| | | import com.ruoyi.system.api.domain.Member; |
| | | import com.ruoyi.system.api.domain.Order; |
| | | import com.ruoyi.system.api.domain.OrderAuctionBond; |
| | | import com.ruoyi.system.api.domain.dto.MemberPointsDTO; |
| | |
| | | private PaylogMapper paylogMapper; |
| | | |
| | | @Override |
| | | public R<Map<String, Object>> getPayInfo(Integer uid, Integer type, String orderNO,String openId, HttpServletRequest request) { |
| | | public R<Map<String, Object>> getPayInfo(Long uid, Integer type, String orderNO, String openId, |
| | | HttpServletRequest request) { |
| | | Member member = memberClient.getMembeOne(uid, SecurityConstants.INNER).getData(); |
| | | openId = member.getMiniOpenid(); |
| | | Double price = 0.0; |
| | | String subject; |
| | | String body; |
| | |
| | | one1.setPaymentMethod(PaymentMethodEnum.WECHAT); |
| | | orderAuctionBondMapper.updateById(one1); |
| | | |
| | | if (one1.getBond().compareTo(new BigDecimal(0))==0){ |
| | | |
| | | if (one1.getBond()==null||one1.getBond().compareTo(new BigDecimal(0))==0){ |
| | | one1.setBoundStatus(BondStatusEnum.PAID); |
| | | Map<String, Object> returnMap = new HashMap<>(); |
| | | returnMap.put("Type",1); |
| | |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPaymentMethod(PaymentMethodEnum.WECHAT); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | |
| | | |
| | | if(page1.getOrderNo().contains("SP")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoods(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | |
| | | if(page1.getOrderNo().contains("MS")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsSeckill1(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | |
| | | |
| | | if(page1.getOrderNo().contains("TG")){ |
| | | GoodsGroupPurchase goodsSeckiGoodsGroupPurchaseOne = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | page1.setGroupNo(goodsSeckiGoodsGroupPurchaseInfo.getMubre()); |
| | | }else{ |
| | | UUID uuid = UUID.randomUUID(); |
| | | GoodsGroupPurchaseInfo goodsGroupPurchaseInfo=new GoodsGroupPurchaseInfo(); |
| | | goodsGroupPurchaseInfo.setGroupSize(goodsSeckiGoodsGroupPurchaseOne.getGroupSize()); |
| | | goodsGroupPurchaseInfo.setCurrentNumber(1); |
| | | goodsGroupPurchaseInfo.setMubre(uuid.toString()); |
| | | goodsGroupPurchaseInfo.setGroupPurchaseId(page1.getGoodsSkuId()); |
| | | goodsGroupPurchaseInfo.setGroupStatus(0); |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | page1.setGroupNo(uuid.toString()); |
| | | } |
| | | OrderMapper.updateById(page1); |
| | | if (page1.getTotalAmount().compareTo(new BigDecimal(0))==0){ |
| | | Map<String, Object> returnMap = new HashMap<>(); |
| | | returnMap.put("Type",1); |
| | | return R.ok(returnMap); |
| | | } |
| | | OrderMapper.updateById(page1); |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | /*if (orderNO.contains("BO")) { |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(OrderAuctionBond::getOrderNo,orderNO); |
| | | wrapper1.eq(OrderAuctionBond::getDelFlag,0); |
| | | OrderAuctionBond one1 = orderAuctionBondMapper.selectOne(wrapper1); |
| | | if (one1.getBond().compareTo(new BigDecimal(0))==0){ |
| | | one1.setBoundStatus(BondStatusEnum.PAID); |
| | | Map<String, Object> returnMap = new HashMap<>(); |
| | | returnMap.put("Type",1); |
| | | return R.ok(returnMap); |
| | | } |
| | | |
| | | |
| | | }else{ |
| | | LambdaQueryWrapper<Order> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(Order::getOrderNo,orderNO); |
| | | wrapper1.eq(Order::getDelFlag,0); |
| | | Order page1 = OrderMapper.selectOne(wrapper1); |
| | | if (page1.getTotalAmount().compareTo(new BigDecimal(0))==0){ |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | OrderMapper.updateById(page1); |
| | | Map<String, Object> returnMap = new HashMap<>(); |
| | | returnMap.put("Type",1); |
| | | |
| | | |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | OrderMapper.updateById(page1); |
| | | |
| | | if(page1.getOrderNo().contains("SP")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoods(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | |
| | | if(page1.getOrderNo().contains("MS")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsSeckill1(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | |
| | | |
| | | MemberPointsDTO memberPointsDTO=new MemberPointsDTO(); |
| | | memberPointsDTO.setMemberId(page1.getMemberId()); |
| | | memberPointsDTO.setPointsType(1); |
| | | memberPointsDTO.setPointsStatus(PointStatusEnum.INCREASE); |
| | | memberPointsDTO.setPoints(page1.getPoints()); |
| | | memberClient.addMemberPoints(memberPointsDTO); |
| | | |
| | | updMembeOneDTO MembeOneDTO=new updMembeOneDTO(); |
| | | MembeOneDTO.setType(1); |
| | | MembeOneDTO.setMemberId(page1.getMemberId()); |
| | | MembeOneDTO.setMoney(page1.getTotalAmount()); |
| | | MembeOneDTO.setTotalPoints(page1.getPoints()); |
| | | memberClient.updMembeOne(MembeOneDTO, SecurityConstants.INNER); |
| | | |
| | | |
| | | return R.ok(returnMap); |
| | | } |
| | | |
| | | |
| | | |
| | | }*/ |
| | | |
| | | if (orderNO.contains("BO")) { |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper1= Wrappers.lambdaQuery(); |
| | |
| | | wrapper1.eq(Order::getOrderNo,paylog1.getOutTradeNo()); |
| | | wrapper1.eq(Order::getDelFlag,0); |
| | | Order page1 = OrderMapper.selectOne(wrapper1); |
| | | |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | if(page1.getOrderNo().contains("SP")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | |
| | | GoodsGroupPurchase goodsSeckiGoodsGroupPurchaseOne = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | page1.setGroupNo(goodsSeckiGoodsGroupPurchaseInfo.getMubre()); |
| | | OrderMapper.updateById(page1); |
| | | Integer i= goodsSeckiGoodsGroupPurchaseInfo.getPurchaseNum()+page1.getGoodsQuantity(); |
| | | goodsSeckiGoodsGroupPurchaseInfo.setPurchaseNum(i); |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | |
| | | }else{ |
| | | UUID uuid = UUID.randomUUID(); |
| | | page1.setGroupNo(uuid.toString()); |
| | | OrderMapper.updateById(page1); |
| | | GoodsGroupPurchaseInfo goodsGroupPurchaseInfo=new GoodsGroupPurchaseInfo(); |
| | | goodsGroupPurchaseInfo.setGroupSize(goodsSeckiGoodsGroupPurchaseOne.getGroupSize()); |
| | | goodsGroupPurchaseInfo.setCurrentNumber(1); |
| | | goodsGroupPurchaseInfo.setPurchaseNum(page1.getGoodsQuantity()); |
| | | goodsGroupPurchaseInfo.setMubre(uuid.toString()); |
| | | goodsGroupPurchaseInfo.setGroupPurchaseId(page1.getGoodsSkuId()); |
| | | goodsGroupPurchaseInfo.setGroupPurchaseId(goodsSeckiGoodsGroupPurchaseOne.getId()); |
| | | goodsGroupPurchaseInfo.setGroupStatus(0); |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | page1.setGroupNo(uuid.toString()); |
| | | |
| | | } |
| | | } |
| | | |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | OrderMapper.updateById(page1); |
| | | if (page1.getPoints()!=0){ |
| | | MemberPointsDTO memberPointsDTO=new MemberPointsDTO(); |
| | | memberPointsDTO.setMemberId(page1.getMemberId()); |
| | | memberPointsDTO.setPointsType(1); |
| | | memberPointsDTO.setPointsStatus(PointStatusEnum.INCREASE); |
| | | memberPointsDTO.setPoints(page1.getPoints()); |
| | | memberClient.addMemberPoints(memberPointsDTO); |
| | | } |
| | | updMembeOneDTO MembeOneDTO=new updMembeOneDTO(); |
| | | MembeOneDTO.setType(1); |
| | | MembeOneDTO.setMemberId(page1.getMemberId()); |
| | | MembeOneDTO.setMoney(page1.getTotalAmount()); |
| | | MembeOneDTO.setTotalPoints(page1.getPoints()); |
| | | memberClient.updMembeOne(MembeOneDTO, SecurityConstants.INNER); |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | |
| | | // ——请根据您的业务逻辑来编写程序(以上代码仅作参考)—— |
| | | log.debug("AlipayController.notifyUrl__回调处理:success"); |
| | |
| | | System.out.println("WxpayController.notify__notityXml:\n" + notityXml); |
| | | |
| | | // 验证签名 |
| | | Map<String, Object> map = XMLParser.getMapFromXML(notityXml.toString()); |
| | | // log.debug("WxpayController.notify__map:\n" + map); |
| | | // 接口返回状态 |
| | | String result_code = (String) map.get("result_code"); |
| | | if ("SUCCESS".equals(result_code)) { |
| | | // // 商户订单号 |
| | | String out_trade_no = (String) map.get("out_trade_no"); |
| | | // // 微信支付交易号 |
| | | String trade_no = (String) map.get("transaction_id"); |
| | | // // 金额,以分为单位 |
| | | String total_fee = (String) map.get("total_fee"); |
| | | // // 优惠金额 |
| | | // String discount = (String) map.get("discount"); |
| | | // // 支付完成时间 |
| | | String time_end = (String) map.get("time_end"); |
| | | // // 支付者唯一Id(对应买家账号的一个加密串 ) |
| | | String buyer_id = (String) map.get("buyer_id"); |
| | | Map<String, Object> map = XMLParser.getMapFromXML(notityXml.toString()); |
| | | // log.debug("WxpayController.notify__map:\n" + map); |
| | | // 接口返回状态 |
| | | String result_code = (String) map.get("result_code"); |
| | | if ("SUCCESS".equals(result_code)) { |
| | | // // 商户订单号 |
| | | String out_trade_no = (String) map.get("out_trade_no"); |
| | | // // 微信支付交易号 |
| | | String trade_no = (String) map.get("transaction_id"); |
| | | // // 金额,以分为单位 |
| | | String total_fee = (String) map.get("total_fee"); |
| | | // // 优惠金额 |
| | | // String discount = (String) map.get("discount"); |
| | | // // 支付完成时间 |
| | | String time_end = (String) map.get("time_end"); |
| | | // // 支付者唯一Id(对应买家账号的一个加密串 ) |
| | | String buyer_id = (String) map.get("buyer_id"); |
| | | |
| | | ///////////////////////////// 这里程序处理支付回调逻辑 |
| | | ///////////////////////////// //////////////////// |
| | | ///////////////////////////// 这里程序处理支付回调逻辑 |
| | | ///////////////////////////// //////////////////// |
| | | |
| | | LambdaQueryWrapper<Paylog> wrapper = Wrappers.lambdaQuery(); |
| | | wrapper.eq(Paylog::getOutTradeNo,out_trade_no); |
| | | Paylog one = this.getOne(wrapper); |
| | | if(SinataUtil.isEmpty(one)) { |
| | | Paylog paylog = new Paylog(); |
| | | paylog.setOutTradeNo(out_trade_no); |
| | | paylog.setPayType(2); |
| | | paylog.setBuyerId(buyer_id); |
| | | paylog.setTradeNo(trade_no); |
| | | paylog.setPayMoney(Double.parseDouble(total_fee) / 100); |
| | | paylog.setState(1); |
| | | System.out.println("支付完成时间" + time_end); |
| | | paylog.setAddTime(LocalDateTime.now()); |
| | | this.save(paylog); |
| | | if (paylog.getOutTradeNo().contains("BO")) { |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(OrderAuctionBond::getOrderNo,paylog.getOutTradeNo()); |
| | | wrapper1.eq(OrderAuctionBond::getDelFlag,0); |
| | | OrderAuctionBond one1 = orderAuctionBondMapper.selectOne(wrapper1); |
| | | if (one1.getOrderTimeSx().isAfter(LocalDateTime.now())){ |
| | | String refundMoney = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer refundFee = Integer.parseInt(refundMoney.substring(0, refundMoney.length() - 3)); |
| | | String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer totalFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | refundFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | LambdaQueryWrapper<Paylog> wrapper = Wrappers.lambdaQuery(); |
| | | wrapper.eq(Paylog::getOutTradeNo,out_trade_no); |
| | | Paylog one = this.getOne(wrapper); |
| | | if(SinataUtil.isEmpty(one)) { |
| | | Paylog paylog = new Paylog(); |
| | | paylog.setOutTradeNo(out_trade_no); |
| | | paylog.setPayType(2); |
| | | paylog.setBuyerId(buyer_id); |
| | | paylog.setTradeNo(trade_no); |
| | | paylog.setPayMoney(Double.parseDouble(total_fee) / 100); |
| | | paylog.setState(1); |
| | | System.out.println("支付完成时间" + time_end); |
| | | paylog.setAddTime(LocalDateTime.now()); |
| | | this.save(paylog); |
| | | if (paylog.getOutTradeNo().contains("BO")) { |
| | | LambdaQueryWrapper<OrderAuctionBond> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(OrderAuctionBond::getOrderNo,paylog.getOutTradeNo()); |
| | | wrapper1.eq(OrderAuctionBond::getDelFlag,0); |
| | | OrderAuctionBond one1 = orderAuctionBondMapper.selectOne(wrapper1); |
| | | if (one1.getOrderTimeSx().isAfter(LocalDateTime.now())){ |
| | | String refundMoney = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer refundFee = Integer.parseInt(refundMoney.substring(0, refundMoney.length() - 3)); |
| | | String money = SinataUtil.doubleRetainTwo(paylog.getPayMoney() * 100d); |
| | | Integer totalFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | refundFee = Integer.parseInt(money.substring(0, money.length() - 3)); |
| | | |
| | | String regEx = "[^0-9]"; |
| | | Pattern p = Pattern.compile(regEx); |
| | | Matcher m = p.matcher(paylog.getOutTradeNo()); |
| | | String ma = m.replaceAll("").trim(); |
| | | refundForWxpay(4, paylog.getTradeNo(), paylog.getOutTradeNo(), "R" + ma, totalFee, refundFee, "2"); |
| | | } |
| | | |
| | | one1.setBoundStatus(BondStatusEnum.PAID); |
| | | one1.setPaymentMethod(PaymentMethodEnum.WECHAT); |
| | | orderAuctionBondMapper.updateById(one1); |
| | | |
| | | }else{ |
| | | LambdaQueryWrapper<Order> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(Order::getOrderNo,paylog.getOutTradeNo()); |
| | | wrapper1.eq(Order::getDelFlag,0); |
| | | Order page1 = OrderMapper.selectOne(wrapper1); |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPaymentMethod(PaymentMethodEnum.WECHAT); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | OrderMapper.updateById(page1); |
| | | |
| | | if(page1.getOrderNo().contains("SP")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoods(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | |
| | | if(page1.getOrderNo().contains("MS")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsSeckill1(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | if(page1.getOrderNo().contains("TG")){ |
| | | GoodsGroupPurchase goodsSeckiGoodsGroupPurchaseOne = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | page1.setGroupNo(goodsSeckiGoodsGroupPurchaseInfo.getMubre()); |
| | | }else{ |
| | | UUID uuid = UUID.randomUUID(); |
| | | GoodsGroupPurchaseInfo goodsGroupPurchaseInfo=new GoodsGroupPurchaseInfo(); |
| | | goodsGroupPurchaseInfo.setGroupSize(goodsSeckiGoodsGroupPurchaseOne.getGroupSize()); |
| | | goodsGroupPurchaseInfo.setCurrentNumber(1); |
| | | goodsGroupPurchaseInfo.setMubre(uuid.toString()); |
| | | goodsGroupPurchaseInfo.setGroupStatus(0); |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | page1.setGroupNo(uuid.toString()); |
| | | } |
| | | } |
| | | if (page1.getPoints()!=0){ |
| | | MemberPointsDTO memberPointsDTO=new MemberPointsDTO(); |
| | | memberPointsDTO.setMemberId(page1.getMemberId()); |
| | | memberPointsDTO.setPointsType(1); |
| | | memberPointsDTO.setPointsStatus(PointStatusEnum.INCREASE); |
| | | memberPointsDTO.setPoints(page1.getPoints()); |
| | | memberClient.addMemberPoints(memberPointsDTO); |
| | | } |
| | | updMembeOneDTO MembeOneDTO=new updMembeOneDTO(); |
| | | MembeOneDTO.setType(1); |
| | | MembeOneDTO.setMemberId(page1.getMemberId()); |
| | | MembeOneDTO.setMoney(page1.getTotalAmount()); |
| | | MembeOneDTO.setTotalPoints(page1.getPoints()); |
| | | memberClient.updMembeOne(MembeOneDTO, SecurityConstants.INNER); |
| | | String regEx = "[^0-9]"; |
| | | Pattern p = Pattern.compile(regEx); |
| | | Matcher m = p.matcher(paylog.getOutTradeNo()); |
| | | String ma = m.replaceAll("").trim(); |
| | | refundForWxpay(4, paylog.getTradeNo(), paylog.getOutTradeNo(), "R" + ma, totalFee, refundFee, "2"); |
| | | } |
| | | |
| | | log.debug("WxpayController.notify__回调处理成功:SUCCESS"); |
| | | response.getOutputStream().print("success"); |
| | | one1.setBoundStatus(BondStatusEnum.PAID); |
| | | one1.setPaymentMethod(PaymentMethodEnum.WECHAT); |
| | | orderAuctionBondMapper.updateById(one1); |
| | | |
| | | }else{ |
| | | LambdaQueryWrapper<Order> wrapper1= Wrappers.lambdaQuery(); |
| | | wrapper1.eq(Order::getOrderNo,paylog.getOutTradeNo()); |
| | | wrapper1.eq(Order::getDelFlag,0); |
| | | Order page1 = OrderMapper.selectOne(wrapper1); |
| | | page1.setOrderStatus(OrderStatusEnum.TO_BE_SHIPPED); |
| | | page1.setPaymentMethod(PaymentMethodEnum.WECHAT); |
| | | page1.setPayTime(LocalDateTime.now()); |
| | | |
| | | |
| | | if(page1.getOrderNo().contains("SP")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoods(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | |
| | | if(page1.getOrderNo().contains("MS")){ |
| | | GoodsSku goodsSku =new GoodsSku(); |
| | | goodsSku.setId(page1.getGoodsSkuId()); |
| | | goodsSku.setSoldQuantity(page1.getGoodsQuantity()); |
| | | goodsSkuClient.updGoodsSeckill1(goodsSku, SecurityConstants.INNER); |
| | | } |
| | | if(page1.getOrderNo().contains("TG")){ |
| | | GoodsGroupPurchase goodsSeckiGoodsGroupPurchaseOne = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseOne(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | GoodsGroupPurchaseInfo goodsSeckiGoodsGroupPurchaseInfo = goodsSkuClient.getGoodsSeckiGoodsGroupPurchaseInfo(page1.getGoodsSkuId(), SecurityConstants.INNER).getData(); |
| | | if (goodsSeckiGoodsGroupPurchaseInfo!=null){ |
| | | page1.setGroupNo(goodsSeckiGoodsGroupPurchaseInfo.getMubre()); |
| | | OrderMapper.updateById(page1); |
| | | Integer i= goodsSeckiGoodsGroupPurchaseInfo.getPurchaseNum()+page1.getGoodsQuantity(); |
| | | goodsSeckiGoodsGroupPurchaseInfo.setPurchaseNum(i); |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsSeckiGoodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | |
| | | }else{ |
| | | UUID uuid = UUID.randomUUID(); |
| | | page1.setGroupNo(uuid.toString()); |
| | | OrderMapper.updateById(page1); |
| | | GoodsGroupPurchaseInfo goodsGroupPurchaseInfo=new GoodsGroupPurchaseInfo(); |
| | | goodsGroupPurchaseInfo.setGroupSize(goodsSeckiGoodsGroupPurchaseOne.getGroupSize()); |
| | | goodsGroupPurchaseInfo.setCurrentNumber(1); |
| | | goodsGroupPurchaseInfo.setPurchaseNum(page1.getGoodsQuantity()); |
| | | goodsGroupPurchaseInfo.setMubre(uuid.toString()); |
| | | goodsGroupPurchaseInfo.setGroupPurchaseId(goodsSeckiGoodsGroupPurchaseOne.getId()); |
| | | goodsGroupPurchaseInfo.setGroupStatus(0); |
| | | goodsSkuClient.updgoodsGroupPurchaseInfo(goodsGroupPurchaseInfo, SecurityConstants.INNER); |
| | | |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | log.debug("WxpayController.notify__回调处理成功:SUCCESS"); |
| | | response.getOutputStream().print("success"); |
| | | } else { |
| | | log.debug("WxpayController.notify__回调处理:验证状态错误!" + result_code); |
| | | System.out.println("验证状态错误!" + result_code); |
| | | } |
| | | log.debug("WxpayController.notify__回调处理成功:SUCCESS"); |
| | | response.getOutputStream().print("success"); |
| | | } else { |
| | | log.debug("WxpayController.notify__回调处理:验证状态错误!" + result_code); |
| | | System.out.println("验证状态错误!" + result_code); |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | |
| | | //设置请求参数(总金额) |
| | | |
| | | String money=SinataUtil.doubleRetainTwo(price*100d); |
| | | Integer price1 = Integer.parseInt(money.substring(0,money.length()-3)); |
| | | Integer price1 = Integer.parseInt(money.substring(0,money.length()-3)); |
| | | paraMap.put("total_fee", price1.toString()); |
| | | //设置请求参数(通知地址) |
| | | paraMap.put("notify_url", Configure.wx_notify_url); |
| | |
| | | Map<String, String> map = PaymentKit.xmlToMap(xmlResult); |
| | | //返回状态码 |
| | | String returnCode = map.get("return_code"); |
| | | /* Assert.isTrue("SUCCESS".equals(returnCode), getMsgByCode(returnCode));*/ |
| | | /* Assert.isTrue("SUCCESS".equals(returnCode), getMsgByCode(returnCode));*/ |
| | | |
| | | //返回给小程序端需要的参数 |
| | | Map<String, Object> returnMap = new HashMap<>(20); |
| | |
| | | System.out.println("证书: " + Configure.getCertLocalPath_2()); |
| | | |
| | | String xmlResult = WxPayApi.orderRefund(false, paraMap,Configure.getCertLocalPath_2(), Configure.getMchid()); |
| | | |
| | | System.out.println("微信退款结果: " + xmlResult); |
| | | return true; |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | refundForWxpay(4, "4200002335202408022336923702", |
| | | "BO24080216090001", "R123456789", 1, 1, "2"); |
| | | } |
| | | /** |
| | | * 获取支付宝 |
| | | * |
| | |
| | | return paylog; |
| | | } |
| | | |
| | | public boolean judgeContainsStr(String cardNum) { |
| | | String regex=".*[a-zA-Z]+.*"; |
| | | Matcher m= Pattern.compile(regex).matcher(cardNum); |
| | | return m.matches(); |
| | | } |
| | | public boolean judgeContainsStr(String cardNum) { |
| | | String regex=".*[a-zA-Z]+.*"; |
| | | Matcher m= Pattern.compile(regex).matcher(cardNum); |
| | | return m.matches(); |
| | | } |
| | | |
| | | /** |
| | | * @param refundDTOS 退款数据传输对象 |
| | | * @return Map<String, Object> key :orderNo value 退款结果 |
| | | */ |
| | | @Override |
| | | public Map<String, Object> refund(List<RefundDTO> refundDTOS) { |
| | | Map<String, Object> map = new HashMap<>(); |
| | |
| | | } |
| | | |
| | | private Boolean handleRefund(Paylog paylog, BigDecimal amount, |
| | | String orderNo) { |
| | | String orderNo) { |
| | | boolean res = false; |
| | | if (StringUtils.isNotNull(paylog)) { |
| | | if (paylog.getPayType() == 1) { |