roomDailyTask 更新
This commit is contained in:
parent
4085716563
commit
345c9f2e06
@ -192,6 +192,11 @@ public enum GoldOrigin {
|
||||
*/
|
||||
DAILY_TASK("Daily task"),
|
||||
|
||||
/**
|
||||
* 房间每日奖励
|
||||
*/
|
||||
ROOM_DAILY_TASK("Daily Coin Bonanza"),
|
||||
|
||||
/**
|
||||
* cp奖励.
|
||||
*/
|
||||
|
||||
@ -10,6 +10,11 @@ import com.red.circle.other.infra.database.rds.entity.task.RoomDailyTaskTier;
|
||||
import com.red.circle.other.infra.database.rds.service.RoomDailyTaskDatabaseService;
|
||||
import com.red.circle.other.inner.asserts.user.UserErrorCode;
|
||||
import com.red.circle.tool.core.date.ZonedDateTimeAsiaRiyadhUtils;
|
||||
import com.red.circle.tool.core.sequence.IdWorkerUtils;
|
||||
import com.red.circle.tool.core.tuple.PennyAmount;
|
||||
import com.red.circle.wallet.inner.endpoint.wallet.WalletGoldClient;
|
||||
import com.red.circle.wallet.inner.model.cmd.GoldReceiptCmd;
|
||||
import com.red.circle.wallet.inner.model.enums.GoldOrigin;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Component;
|
||||
@ -27,6 +32,7 @@ import java.time.LocalDateTime;
|
||||
public class RoomDailyTaskClaimExe {
|
||||
|
||||
private final RoomDailyTaskDatabaseService taskDatabaseService;
|
||||
private final WalletGoldClient walletGoldClient;
|
||||
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public RoomDailyTaskClaimCO execute(RoomDailyTaskClaimCmd cmd) {
|
||||
@ -78,7 +84,14 @@ public class RoomDailyTaskClaimExe {
|
||||
record.setCreateTime(LocalDateTime.now());
|
||||
taskDatabaseService.saveClaimRecord(record);
|
||||
|
||||
// TODO: 调用钱包服务发放金币
|
||||
walletGoldClient.changeBalance(GoldReceiptCmd.builder()
|
||||
.appIncome()
|
||||
.userId(userId)
|
||||
.amount(PennyAmount.ofDollar(tier.getRewardValue().longValue()))
|
||||
.eventId(bizNo)
|
||||
.sysOrigin(cmd.requireReqSysOrigin())
|
||||
.origin(GoldOrigin.ROOM_DAILY_TASK)
|
||||
.build());
|
||||
|
||||
log.info("任务奖励领取成功, userId={}, taskCode={}, tierIndex={}, rewardValue={}", userId, taskCode, tierIndex, tier.getRewardValue());
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user