diff --git a/jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiService/impl/VipServiceImpl.java b/jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiService/impl/VipServiceImpl.java index 10ce8a4..4afb75f 100644 --- a/jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiService/impl/VipServiceImpl.java +++ b/jeecg-boot-module-system/src/main/java/org/jeecg/modules/apiService/impl/VipServiceImpl.java @@ -97,34 +97,42 @@ public class VipServiceImpl implements VipService { WxPayOrderNotifyResult notify = mpWxPayService.notify(requestBody); String outTradeNo = notify.getOutTradeNo(); log.info("支付回调订单号码:"+outTradeNo); - //查询订单信息 - EmployVipRecord vipRecord = employVipRecordService.getById(outTradeNo); - //如果订单存在则修改订单状态 - if (vipRecord!=null){ - if("0".equals(vipRecord.getStatus())){ - vipRecord.setStatus("1"); - } - employVipRecordService.updateById(vipRecord); - //会员信息 - EmployVipUser vipUser = employVipUserService - .lambdaQuery() - .eq(EmployVipUser::getUserId, vipRecord.getUserId()) - .one(); - - //如果已有会员信息,则修改,否则新增会员信息 - if(null != vipUser){ - vipUser.setTypeId(vipRecord.getVipTypeId()); - employVipUserService.updateById(vipUser); - }else { - EmployVipUser newVipUser = new EmployVipUser(); - vipUser.setUserId(vipRecord.getUserId()); - vipUser.setTypeId(vipRecord.getVipTypeId()); - employVipUserService.save(newVipUser); + try{ + //查询订单信息 + EmployVipRecord vipRecord = employVipRecordService.getById(outTradeNo); + //如果订单存在则修改订单状态 + if (vipRecord!=null){ + if("0".equals(vipRecord.getStatus())){ + vipRecord.setStatus("1"); + } + employVipRecordService.updateById(vipRecord); + + //会员信息 + EmployVipUser vipUser = employVipUserService + .lambdaQuery() + .eq(EmployVipUser::getUserId, vipRecord.getUserId()) + .one(); + + //如果已有会员信息,则修改,否则新增会员信息 + if(null != vipUser){ + vipUser.setTypeId(vipRecord.getVipTypeId()); + employVipUserService.updateById(vipUser); + }else { + EmployVipUser newVipUser = new EmployVipUser(); + newVipUser.setUserId(vipRecord.getUserId()); + newVipUser.setTypeId(vipRecord.getVipTypeId()); + employVipUserService.save(newVipUser); + } } + }catch (Exception e){ + log.info("支付回调失败,订单号码:"+outTradeNo); + e.printStackTrace(); } + + return null; }