init

ruoyi-xq/src/main/java/com/ruoyi/xq/service/UserExtendService.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.ruoyi.common.core.domain.PageQuery;
 import com.ruoyi.xq.domain.UserExtend;
 import com.ruoyi.xq.dto.admin.user.UserExtendAdminVo;
+import com.ruoyi.xq.dto.admin.user.req.UpdateIncomeCoinReq;
 
 import java.math.BigDecimal;
 
@@ -19,4 +20,6 @@ public interface UserExtendService extends IService<UserExtend> {
     boolean withdraw(Long userId, BigDecimal withdrawPrice);
 
     Page<UserExtendAdminVo> pageAdmin(PageQuery pageQuery, UserExtendAdminVo bo);
+
+    void updateIncomeCoin(UpdateIncomeCoinReq bo);
 }

ruoyi-xq/src/main/java/com/ruoyi/xq/service/UserInviteService.java

@@ -1,7 +1,10 @@
 package com.ruoyi.xq.service;
 
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.ruoyi.common.core.domain.PageQuery;
 import com.ruoyi.xq.domain.UserInvite;
+import com.ruoyi.xq.dto.admin.user.UserInviteAdminVo;
 
 /**
  * 用户邀请Service接口
@@ -14,4 +17,6 @@ public interface UserInviteService extends IService<UserInvite> {
     void bindInvite(Long userId, String inviteCode);
 
     void unBindInviteUser(Long userId);
+
+    Page<UserInviteAdminVo> pageAdmin(PageQuery pageQuery, UserInviteAdminVo bo);
 }

ruoyi-xq/src/main/java/com/ruoyi/xq/service/impl/UserExtendServiceImpl.java

@@ -3,12 +3,18 @@ package com.ruoyi.xq.service.impl;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.common.core.domain.PageQuery;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.xq.domain.User;
 import com.ruoyi.xq.domain.UserExtend;
 import com.ruoyi.xq.dto.admin.user.UserExtendAdminVo;
+import com.ruoyi.xq.dto.admin.user.req.UpdateIncomeCoinReq;
 import com.ruoyi.xq.mapper.UserExtendMapper;
 import com.ruoyi.xq.service.UserExtendService;
+import com.ruoyi.xq.service.UserService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 
@@ -21,7 +27,8 @@ import java.math.BigDecimal;
 @RequiredArgsConstructor
 @Service
 public class UserExtendServiceImpl extends ServiceImpl<UserExtendMapper,UserExtend> implements UserExtendService {
-
+    @Autowired
+    private UserService userService;
 
     @Override
     public boolean withdraw(Long userId, BigDecimal withdrawPrice){
@@ -34,4 +41,17 @@ public class UserExtendServiceImpl extends ServiceImpl<UserExtendMapper,UserExte
         return baseMapper.pageAdmin(pageQuery.build(), bo);
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void updateIncomeCoin(UpdateIncomeCoinReq bo) {
+        User user = userService.getByUsercode(bo.getUsercode());
+        if(user == null){
+            throw new ServiceException("用户不存在");
+        }
+        boolean income = baseMapper.incrIncome(user.getId(), bo.getRechargeCoin());
+        if(!income){
+            throw new ServiceException("调整失败，请保证调整后金额不为负数");
+        }
+    }
+
 }

ruoyi-xq/src/main/java/com/ruoyi/xq/service/impl/UserInviteServiceImpl.java

@@ -1,10 +1,13 @@
 package com.ruoyi.xq.service.impl;
 
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.core.domain.PageQuery;
 import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.xq.domain.User;
 import com.ruoyi.xq.domain.UserInvite;
+import com.ruoyi.xq.dto.admin.user.UserInviteAdminVo;
 import com.ruoyi.xq.mapper.UserInviteMapper;
 import com.ruoyi.xq.service.UserInviteService;
 import com.ruoyi.xq.service.UserService;
@@ -65,4 +68,9 @@ public class UserInviteServiceImpl extends ServiceImpl<UserInviteMapper, UserInv
                 .eq(User::getId, userId)
                 .set(User::getInviteId, null));
     }
+
+    @Override
+    public Page<UserInviteAdminVo> pageAdmin(PageQuery pageQuery, UserInviteAdminVo bo) {
+        return baseMapper.pageAdmin(pageQuery.build(), bo);
+    }
 }