|
@ -97,34 +97,42 @@ public class VipServiceImpl implements VipService { |
|
|
WxPayOrderNotifyResult notify = mpWxPayService.notify(requestBody); |
|
|
WxPayOrderNotifyResult notify = mpWxPayService.notify(requestBody); |
|
|
String outTradeNo = notify.getOutTradeNo(); |
|
|
String outTradeNo = notify.getOutTradeNo(); |
|
|
log.info("支付回调订单号码:"+outTradeNo); |
|
|
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; |
|
|
return null; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|