shayu/cai-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

123

Browse Source
This commit is contained in:
张良(004796)
2024-04-01 17:51:13 +08:00
parent 97f3f122c5
commit 102cf30c8d
3 changed files with 29 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
ruoyi-cai/src/main/java/com/ruoyi/cai/manager/AwardManager.java
View File

@@ -11,10 +11,7 @@ import com.ruoyi.cai.enums.account.AccountChangeCodeEnum;
import com.ruoyi.cai.executor.ExecutorConstant; import com.ruoyi.cai.executor.ExecutorConstant;
import com.ruoyi.cai.mapper.AccountMapper; import com.ruoyi.cai.mapper.AccountMapper;
import com.ruoyi.cai.notice.YunxinHttpService; import com.ruoyi.cai.notice.YunxinHttpService;
import com.ruoyi.cai.service.AccountChangeLogService; import com.ruoyi.cai.service.*;
import com.ruoyi.cai.service.RankService;
import com.ruoyi.cai.service.UserInfoService;
import com.ruoyi.cai.service.UserService;
import com.ruoyi.cai.util.CaiDateUtil; import com.ruoyi.cai.util.CaiDateUtil;
import com.ruoyi.common.exception.ServiceException; import com.ruoyi.common.exception.ServiceException;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -44,6 +41,8 @@ public class AwardManager {
private RankService rankService; private RankService rankService;
@Autowired @Autowired
private YunxinHttpService yunxinHttpService; private YunxinHttpService yunxinHttpService;
@Autowired
private UserInviteService userInviteService;
public void giveJoinAnchorAsync(Long anchorUserId){ public void giveJoinAnchorAsync(Long anchorUserId){
AwardManager bean = SpringUtil.getBean(AwardManager.class); AwardManager bean = SpringUtil.getBean(AwardManager.class);
@@ -74,6 +73,7 @@ public class AwardManager {
return; return;
} }
accountMapper.incsIncomeCoin(inviteUser.getId(),price); accountMapper.incsIncomeCoin(inviteUser.getId(),price);
userInviteService.incsCoin(inviteUser.getId(),anchorUserId,price);
accountChangeLogService.saveLogNoAdmin(inviteUser.getId(),inviteUser.getUsercode(), AccountChangeCodeEnum.JOIN_ANCHOR_INVITE,price,null,anchorUserId); accountChangeLogService.saveLogNoAdmin(inviteUser.getId(),inviteUser.getUsercode(), AccountChangeCodeEnum.JOIN_ANCHOR_INVITE,price,null,anchorUserId);
} }

8
ruoyi-cai/src/main/java/com/ruoyi/cai/service/UserInviteService.java
View File

@@ -24,5 +24,13 @@ public interface UserInviteService extends IService<UserInvite> {
Page<UserInviteAdminVo> pageAdmin(PageQuery pageQuery, UserInviteAdminVo bo); Page<UserInviteAdminVo> pageAdmin(PageQuery pageQuery, UserInviteAdminVo bo);
/**
*
* @param geUserId 邀请人 收到奖励的人
* @param seUserId 来源人 获取奖励的人
* @param amount 创造的收益
*/
void incsCoinAsync(Long geUserId, Long seUserId, Long amount); void incsCoinAsync(Long geUserId, Long seUserId, Long amount);
void incsCoin(Long geUserId, Long seUserId, Long amount);
} }

7
ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/UserInviteServiceImpl.java
View File

@@ -92,7 +92,11 @@ public class UserInviteServiceImpl extends ServiceImpl<UserInviteMapper, UserInv
*/ */
@Override @Override
public void incsCoinAsync(Long geUserId, Long seUserId, Long amount) { public void incsCoinAsync(Long geUserId, Long seUserId, Long amount) {
ExecutorConstant.COMMON_EXECUTOR.execute(() -> { ExecutorConstant.COMMON_EXECUTOR.execute(() -> incsCoin(geUserId,seUserId,amount));
}
@Override
public void incsCoin(Long geUserId, Long seUserId, Long amount){
if(geUserId == null || seUserId == null || amount == null || amount <= 0){ if(geUserId == null || seUserId == null || amount == null || amount <= 0){
log.error("执行收益的递增失败【参数异常】"); log.error("执行收益的递增失败【参数异常】");
return; return;
@@ -105,7 +109,6 @@ public class UserInviteServiceImpl extends ServiceImpl<UserInviteMapper, UserInv
return; return;
} }
baseMapper.incsCoinTotal(one.getId(),amount); baseMapper.incsCoinTotal(one.getId(),amount);
});
} }
} }