czg_team
/
video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

领取奖励时判断用户是否绑定支付宝

This commit is contained in:
GYJ 2024-12-16 15:17:41 +08:00
parent 12ca117e82
commit 249f857c9e
2 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/sqx/modules/discSpinning/controller/DiscSpinningController.java
View File

@ -6,6 +6,8 @@ import com.sqx.common.annotation.Debounce;
import com.sqx.common.utils.DateUtils; import com.sqx.common.utils.DateUtils;
import com.sqx.common.utils.Result; import com.sqx.common.utils.Result;
import com.sqx.modules.app.annotation.Login; import com.sqx.modules.app.annotation.Login;
import com.sqx.modules.app.entity.UserEntity;
import com.sqx.modules.app.service.UserService;
import com.sqx.modules.common.service.CommonInfoService; import com.sqx.modules.common.service.CommonInfoService;
import com.sqx.modules.discSpinning.entity.DiscSpinning; import com.sqx.modules.discSpinning.entity.DiscSpinning;
import com.sqx.modules.discSpinning.entity.DiscSpinningRecord; import com.sqx.modules.discSpinning.entity.DiscSpinningRecord;
@ -16,6 +18,7 @@ import com.sqx.modules.orders.service.OrdersService;
import com.sqx.modules.taskCenter.service.TaskCenterService; import com.sqx.modules.taskCenter.service.TaskCenterService;
import io.swagger.annotations.*; import io.swagger.annotations.*;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import reactor.util.annotation.Nullable; import reactor.util.annotation.Nullable;
@ -36,17 +39,18 @@ public class DiscSpinningController {
private final CommonInfoService commonRepository; private final CommonInfoService commonRepository;
private final OrdersService ordersService; private final OrdersService ordersService;
private final TaskCenterService taskCenterService; private final TaskCenterService taskCenterService;
private final UserService userService;
@Autowired @Autowired
public DiscSpinningController(CommonInfoService commonRepository, DiscSpinningService discSpinningService, public DiscSpinningController(CommonInfoService commonRepository, DiscSpinningService discSpinningService,
OrdersService ordersService, DiscSpinningRecordService recordService, OrdersService ordersService, DiscSpinningRecordService recordService,
TaskCenterService taskCenterService TaskCenterService taskCenterService, UserService userService) {
) {
this.commonRepository = commonRepository; this.commonRepository = commonRepository;
this.discSpinningService = discSpinningService; this.discSpinningService = discSpinningService;
this.ordersService = ordersService; this.ordersService = ordersService;
this.recordService = recordService; this.recordService = recordService;
this.taskCenterService = taskCenterService; this.taskCenterService = taskCenterService;
this.userService = userService;
} }
@PostMapping("/discSpinning/insertDiscSpinning") @PostMapping("/discSpinning/insertDiscSpinning")
@ -173,7 +177,12 @@ public class DiscSpinningController {
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
discSpinningService.receiveAsync(record); discSpinningService.receiveAsync(record);
}); });
return Result.success(); UserEntity userInfo = userService.queryByUserId(record.getUserId());
int res = 0;
if (StringUtils.isNotBlank(userInfo.getZhiFuBao()) && StringUtils.isNotBlank(userInfo.getZhiFuBaoName())) {
res = 1;
}
return Result.success().put("data", res);
} }
} }

8
src/main/java/com/sqx/modules/discSpinning/service/impl/DiscSpinningServiceImpl.java
View File

@ -42,9 +42,7 @@ import java.util.Random;
public class DiscSpinningServiceImpl extends ServiceImpl<DiscSpinningDao, DiscSpinning> implements DiscSpinningService { public class DiscSpinningServiceImpl extends ServiceImpl<DiscSpinningDao, DiscSpinning> implements DiscSpinningService {
private final DiscSpinningRecordService recordService; private final DiscSpinningRecordService recordService;
private final DiscSpinningAmountService amountService;
private final CommonInfoService commonRepository; private final CommonInfoService commonRepository;
private final OrdersService ordersService;
private final UserMoneyService userMoneyService; private final UserMoneyService userMoneyService;
private final UserMoneyDetailsService userMoneyDetailsService; private final UserMoneyDetailsService userMoneyDetailsService;
private final UserService userService; private final UserService userService;
@ -55,13 +53,11 @@ public class DiscSpinningServiceImpl extends ServiceImpl<DiscSpinningDao, DiscSp
@Autowired @Autowired
public DiscSpinningServiceImpl(CommonInfoService commonRepository, public DiscSpinningServiceImpl(CommonInfoService commonRepository,
UserMoneyDetailsService userMoneyDetailsService, CashOutService cashOutService, UserMoneyDetailsService userMoneyDetailsService, CashOutService cashOutService,
OrdersService ordersService, DiscSpinningRecordService recordService, DiscSpinningRecordService recordService,
UserMoneyService userMoneyService, UserService userService, UserMoneyService userMoneyService, UserService userService,
DiscSpinningAmountService amountService, RedisUtils redisUtils RedisUtils redisUtils
) { ) {
this.commonRepository = commonRepository; this.commonRepository = commonRepository;
this.amountService = amountService;
this.ordersService = ordersService;
this.recordService = recordService; this.recordService = recordService;
this.userMoneyService = userMoneyService; this.userMoneyService = userMoneyService;
this.userMoneyDetailsService = userMoneyDetailsService; this.userMoneyDetailsService = userMoneyDetailsService;