diff --git a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java index 319e0f5e..7866edde 100644 --- a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java +++ b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java @@ -361,18 +361,22 @@ public class WuyouController { } ordersService.updateById(order); ordersService.insertOrders(order); - InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId()); - if (inviteAchievement == null) { - inviteAchievement = new InviteAchievement(); - inviteAchievement.setState(0); - inviteAchievement.setCount(1); - inviteAchievement.setCreateTime(DateUtil.date()); - inviteAchievement.setUserId(user.getUserId()); - inviteAchievement.setSourceUserId(byUser.getUserId()); - inviteAchievementService.insertNotExists(inviteAchievement); - } else { - inviteAchievementService.incrCount(inviteAchievement.getId(), 1); + + if (byUser != null) { + InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId()); + if (inviteAchievement == null) { + inviteAchievement = new InviteAchievement(); + inviteAchievement.setState(0); + inviteAchievement.setCount(1); + inviteAchievement.setCreateTime(DateUtil.date()); + inviteAchievement.setUserId(user.getUserId()); + inviteAchievement.setSourceUserId(byUser.getUserId()); + inviteAchievementService.insertNotExists(inviteAchievement); + } else { + inviteAchievementService.incrCount(inviteAchievement.getId(), 1); + } } + ThreadUtil.execAsync(() -> { activities(user, byUser); });