|
|
|
@ -85,6 +85,25 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
@Override |
|
|
|
public Result<?> getSharePage(String token,Integer state,Integer status, PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//查询是否是代理 |
|
|
|
if(hanHaiMember.getIsPay() == 0){ |
|
|
|
return Result.error("您还不是代理,无法查看分享记录"); |
|
|
|
} |
|
|
|
// 检查代理是否过期(增加null检查) |
|
|
|
Date endTime = hanHaiMember.getEndTime(); |
|
|
|
if (endTime == null) { |
|
|
|
return Result.error("代理有效期未设置"); |
|
|
|
} |
|
|
|
|
|
|
|
if (endTime.before(new Date())) { |
|
|
|
return Result.error("您的代理已过期"); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if(state == 0){ |
|
|
|
Page<CommonMember> page = new Page<>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
QueryWrapper<CommonMember> queryWrapper = new QueryWrapper<>(); |
|
|
|
@ -165,11 +184,41 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
return Result.error("参数错误"); |
|
|
|
} |
|
|
|
|
|
|
|
//获取个人分享记录详情 |
|
|
|
|
|
|
|
//查询当前用户分享审核通过的记录条数 |
|
|
|
@Override |
|
|
|
public Result<?> getShareInfo(String token,String id){ |
|
|
|
public Result<?> queryShareCount(String token){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
return Result.OK("个人分享审核通过记录条数",commonMemberService.lambdaQuery() |
|
|
|
.eq(CommonMember::getUserId,hanHaiMember.getId()) |
|
|
|
.eq(CommonMember::getStatus,1) |
|
|
|
.count()); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//获取个人分享记录详情 |
|
|
|
@Override |
|
|
|
public Result<?> getShareInfo(String id){ |
|
|
|
CommonMember commonMember = commonMemberService.getById(id); |
|
|
|
//根据当前记录查询当前用户 |
|
|
|
HanHaiMember byId = hanHaiMemberService.getById(commonMember.getUserId()); |
|
|
|
//分享用户是否存在 |
|
|
|
if(null==byId){ |
|
|
|
return Result.error("分享用户不存在"); |
|
|
|
} |
|
|
|
//判断分享用户是否是代理 |
|
|
|
if(byId.getIsPay() == 0){ |
|
|
|
return Result.error("分享用户不是代理"); |
|
|
|
} |
|
|
|
//分享权限过期 |
|
|
|
if(byId.getEndTime().getTime() < new Date().getTime()){ |
|
|
|
return Result.error("分享权限已过期"); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return Result.OK("个人分享详情",commonMember); |
|
|
|
} |
|
|
|
|
|
|
|
@ -249,7 +298,7 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
|
|
|
|
//根据用户一级邀请人id查询用户信息 |
|
|
|
HanHaiMember hanHaiMemberOne = hanHaiMemberService.lambdaQuery() |
|
|
|
.eq(HanHaiMember::getId,commonCode.getPid()) |
|
|
|
.eq(HanHaiMember::getId,hanHaiMember.getShareId()) |
|
|
|
.one(); |
|
|
|
if(null!=hanHaiMemberOne){ |
|
|
|
//根据配置列表查询返佣比例 |
|
|
|
@ -274,15 +323,19 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
//增加用户佣金 |
|
|
|
BigDecimal oneMoney1 = hanHaiMemberOne.getPrice().add(oneMoney); |
|
|
|
hanHaiMemberOne.setPrice(oneMoney1); |
|
|
|
// hanHaiMemberOne.setShareId(hanHaiMemberOne.getId()); |
|
|
|
hanHaiMemberService.updateById(hanHaiMemberOne); |
|
|
|
|
|
|
|
|
|
|
|
hanHaiMember.setShareId(hanHaiMemberOne.getId()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//根据用户一级邀请人id查询用户信息 |
|
|
|
HanHaiMember hanHaiMemberTwo = hanHaiMemberService.lambdaQuery() |
|
|
|
.eq(HanHaiMember::getId,commonCode.getPidTwo()) |
|
|
|
.eq(HanHaiMember::getId,hanHaiMember.getVid()) |
|
|
|
.one(); |
|
|
|
if(null!=hanHaiMemberTwo){ |
|
|
|
//根据配置列表查询返佣比例 |
|
|
|
@ -304,8 +357,11 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
|
|
|
|
BigDecimal twoMoney1 = hanHaiMemberTwo.getPrice().add(twoMoney); |
|
|
|
hanHaiMemberTwo.setPrice(twoMoney1); |
|
|
|
// hanHaiMemberTwo.setShareId(hanHaiMemberTwo.getId()); |
|
|
|
hanHaiMemberService.updateById(hanHaiMemberTwo); |
|
|
|
|
|
|
|
hanHaiMember.setVid(hanHaiMemberTwo.getId()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -319,6 +375,8 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
//修改个人信息 |
|
|
|
hanHaiMember.setIsPay(1); |
|
|
|
hanHaiMember.setEndTime(commonCode.getEndTime()); |
|
|
|
|
|
|
|
|
|
|
|
hanHaiMemberService.updateById(hanHaiMember); |
|
|
|
|
|
|
|
|
|
|
|
@ -356,25 +414,64 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
|
|
|
|
//获取视频分享记录详情 |
|
|
|
@Override |
|
|
|
public Result<?> getVideoShareInfo(String token,String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
public Result<?> getVideoShareInfo(String id){ |
|
|
|
CommonVio commonVio = commonVioService.getById(id); |
|
|
|
//根据当前记录查询当前用户 |
|
|
|
HanHaiMember byId = hanHaiMemberService.getById(commonVio.getUserId()); |
|
|
|
//分享用户是否存在 |
|
|
|
if(null==byId){ |
|
|
|
return Result.error("分享用户不存在"); |
|
|
|
} |
|
|
|
//判断分享用户是否是代理 |
|
|
|
if(byId.getIsPay() == 0){ |
|
|
|
return Result.error("分享用户不是代理"); |
|
|
|
} |
|
|
|
//分享权限过期 |
|
|
|
if(byId.getEndTime().getTime() < new Date().getTime()){ |
|
|
|
return Result.error("分享权限已过期"); |
|
|
|
} |
|
|
|
return Result.OK("视频分享详情",commonVio); |
|
|
|
} |
|
|
|
|
|
|
|
//获取群分享记录详情 |
|
|
|
@Override |
|
|
|
public Result<?> getGroupShareInfo(String token,String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
public Result<?> getGroupShareInfo(String id){ |
|
|
|
CommonTeam commonTeam = commonTeamService.getById(id); |
|
|
|
//根据当前记录查询当前用户 |
|
|
|
HanHaiMember byId = hanHaiMemberService.getById(commonTeam.getUserId()); |
|
|
|
//分享用户是否存在 |
|
|
|
if(null==byId){ |
|
|
|
return Result.error("分享用户不存在"); |
|
|
|
} |
|
|
|
//判断分享用户是否是代理 |
|
|
|
if(byId.getIsPay() == 0){ |
|
|
|
return Result.error("分享用户不是代理"); |
|
|
|
} |
|
|
|
//分享权限过期 |
|
|
|
if(byId.getEndTime().getTime() < new Date().getTime()){ |
|
|
|
return Result.error("分享权限已过期"); |
|
|
|
} |
|
|
|
return Result.OK("群分享详情",commonTeam); |
|
|
|
} |
|
|
|
|
|
|
|
//获取文章分享记录详情 |
|
|
|
@Override |
|
|
|
public Result<?> getArticleShareInfo(String token,String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
public Result<?> getArticleShareInfo(String id){ |
|
|
|
CommonBook commonBook = commonBookService.getById(id); |
|
|
|
//根据当前记录查询当前用户 |
|
|
|
HanHaiMember byId = hanHaiMemberService.getById(commonBook.getUserId()); |
|
|
|
//分享用户是否存在 |
|
|
|
if(null==byId){ |
|
|
|
return Result.error("分享用户不存在"); |
|
|
|
} |
|
|
|
//判断分享用户是否是代理 |
|
|
|
if(byId.getIsPay() == 0){ |
|
|
|
return Result.error("分享用户不是代理"); |
|
|
|
} |
|
|
|
//分享权限过期 |
|
|
|
if(byId.getEndTime().getTime() < new Date().getTime()){ |
|
|
|
return Result.error("分享权限已过期"); |
|
|
|
} |
|
|
|
return Result.OK("文章分享详情",commonBook); |
|
|
|
} |
|
|
|
|
|
|
|
@ -551,7 +648,12 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonMember.setUserId(hanHaiMember.getId()); |
|
|
|
commonMember.setStatus(0); |
|
|
|
commonMemberService.saveOrUpdate(commonMember); |
|
|
|
// commonMemberService.saveOrUpdate(commonMember); |
|
|
|
if(StringUtils.isEmpty(commonMember.getId())){ |
|
|
|
commonMemberService.save(commonMember); |
|
|
|
}else{ |
|
|
|
commonMemberService.updateById(commonMember); |
|
|
|
} |
|
|
|
return Result.OK("保存成功"); |
|
|
|
} |
|
|
|
|
|
|
|
@ -562,7 +664,12 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonVio.setUserId(hanHaiMember.getId()); |
|
|
|
commonVio.setStatus(0); |
|
|
|
commonVioService.saveOrUpdate(commonVio); |
|
|
|
// commonVioService.saveOrUpdate(commonVio); |
|
|
|
if(StringUtils.isEmpty(commonVio.getId())){ |
|
|
|
commonVioService.save(commonVio); |
|
|
|
}else{ |
|
|
|
commonVioService.updateById(commonVio); |
|
|
|
} |
|
|
|
return Result.OK("保存成功"); |
|
|
|
} |
|
|
|
|
|
|
|
@ -573,7 +680,13 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonTeam.setUserId(hanHaiMember.getId()); |
|
|
|
commonTeam.setStatus(0); |
|
|
|
commonTeamService.saveOrUpdate(commonTeam); |
|
|
|
// commonTeamService.saveOrUpdate(commonTeam); |
|
|
|
|
|
|
|
if(StringUtils.isEmpty(commonTeam.getId())){ |
|
|
|
commonTeamService.save(commonTeam); |
|
|
|
}else{ |
|
|
|
commonTeamService.updateById(commonTeam); |
|
|
|
} |
|
|
|
return Result.OK("保存成功"); |
|
|
|
} |
|
|
|
|
|
|
|
@ -584,7 +697,20 @@ public class AppletFenServiceImpl implements AppletFenService { |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonBook.setUserId(hanHaiMember.getId()); |
|
|
|
commonBook.setStatus(0); |
|
|
|
commonBookService.saveOrUpdate(commonBook); |
|
|
|
|
|
|
|
if(StringUtils.isEmpty(commonBook.getId())){ |
|
|
|
|
|
|
|
commonBookService.save(commonBook); |
|
|
|
}else{ |
|
|
|
if(commonBook.getId().equals("null")){ |
|
|
|
commonBook.setId(null); |
|
|
|
commonBookService.save(commonBook); |
|
|
|
}else{ |
|
|
|
commonBookService.updateById(commonBook); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return Result.OK("保存成功"); |
|
|
|
} |
|
|
|
|
|
|
|
|