修改接口(小程序用户一键设置项目的的抽佣比例),用户主要信息表中添加一个字段uniteRate(统一抽佣比例)

This commit is contained in:
2025-06-04 17:35:00 +08:00
parent 0632b32c08
commit de79efda9a
2 changed files with 12 additions and 21 deletions

View File

@ -1,6 +1,7 @@
package com.greenorange.promotion.controller.project;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.support.SFunction;
import com.greenorange.promotion.annotation.RequiresPermission;
import com.greenorange.promotion.annotation.SysLog;
@ -24,6 +25,7 @@ import com.greenorange.promotion.service.project.ProjectDetailService;
import com.greenorange.promotion.service.project.ProjectService;
import com.greenorange.promotion.service.project.SubUserProjectCommissionService;
import com.greenorange.promotion.service.userInfo.UserInfoService;
import com.greenorange.promotion.service.userInfo.UserMainInfoService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
@ -69,25 +71,10 @@ public class ProjectCommissionController {
private UserInfoService userInfoService;
@Resource
private RedisTemplate<String, String> redisTemplate;
private static final String SUB_USER_COMMISSION_RATE = "subUserCommissionRate";
private UserMainInfoService userMainInfoService;
/**
* 小程序用户查看下级用户统一的抽佣比例
* @return 是否添加成功
*/
@PostMapping("get/redis/Rate")
@Operation(summary = "小程序用户查看下级用户统一的抽佣比例", description = "参数用户id权限用户方法名querySubUserUnitCommissionRate")
@RequiresPermission(mustRole = UserConstant.DEFAULT_ROLE)
public BaseResponse<String> querySubUserUnitCommissionRate(HttpServletRequest request) {
Long userId = (Long) request.getAttribute("userId");
String rate = redisTemplate.opsForValue().get(SUB_USER_COMMISSION_RATE + ":" + userId);
return ResultUtils.success(rate);
}
/**
@ -298,7 +285,12 @@ public class ProjectCommissionController {
public BaseResponse<Boolean> uniteProjectCommissionRate(@Valid @RequestBody ProjectCommissionUniteUpdateRequest projectCommissionUniteUpdateRequest, HttpServletRequest request) {
Long userId = (Long) request.getAttribute("userId");
BigDecimal uniteCommissionRate = projectCommissionUniteUpdateRequest.getUniteCommissionRate();
redisTemplate.opsForValue().set(SUB_USER_COMMISSION_RATE + ":" + userId, uniteCommissionRate.setScale(2, RoundingMode.HALF_UP).toString()); // 保留两位小数
// 修改项目的统一抽佣比例
LambdaUpdateWrapper<UserMainInfo> userMainInfoLambdaUpdateWrapper = new LambdaUpdateWrapper<>();
userMainInfoLambdaUpdateWrapper.eq(UserMainInfo::getUserId, userId).set(UserMainInfo::getUniteRate, uniteCommissionRate);
userMainInfoService.update(userMainInfoLambdaUpdateWrapper);
LambdaQueryWrapper<ProjectCommission> projectCommissionLambdaQueryWrapper = new LambdaQueryWrapper<>();
projectCommissionLambdaQueryWrapper.eq(ProjectCommission::getUserId, userId);
List<ProjectCommission> projectCommissionList = projectCommissionService.list(projectCommissionLambdaQueryWrapper);

View File

@ -73,17 +73,19 @@ public class UserInfoServiceImpl extends ServiceImpl<UserInfoMapper, UserInfo>
@Resource
private WechatGetQrcodeService wechatGetQrcodeService;
@Resource
private ProjectCommissionService projectCommissionService;
@Resource
private SubUserProjectCommissionService subUserProjectCommissionService;
@Resource
private UserInfoMapper userInfoMapper;
private static final String SUB_USER_COMMISSION_RATE = "subUserCommissionRate";
/**
@ -173,9 +175,6 @@ public class UserInfoServiceImpl extends ServiceImpl<UserInfoMapper, UserInfo>
}
userMainInfoService.updateBatchById(userMainInfoList);
// 为当前用户添加一个下级统一抽佣比例
redisTemplate.opsForValue().set(SUB_USER_COMMISSION_RATE + ":" + myUserInfo.getId(), BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP).toString()); // 保留两位小数
// 生成邀请二维码
try {
String view = wechatGetQrcodeService.getWxQrCode(myUserInfo.getInvitationCode());