diff --git a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/activity/room/WeekStarRestController.java b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/activity/room/WeekStarRestController.java index cf241847..f8dd75d4 100644 --- a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/activity/room/WeekStarRestController.java +++ b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/activity/room/WeekStarRestController.java @@ -9,12 +9,14 @@ import com.red.circle.other.app.dto.clientobject.activity.WeekStarHistoryVO; import com.red.circle.other.app.dto.clientobject.gift.GiftConfigCO; import com.red.circle.other.app.dto.cmd.activity.WeekStarGiftQueryCmd; import com.red.circle.other.app.dto.cmd.activity.WeekStarRankingQueryCmd; +import com.red.circle.other.app.dto.cmd.activity.WeekStarExchangeCmd; import com.red.circle.other.app.service.activity.WeekStarService; import com.red.circle.other.inner.model.dto.activity.props.ActivityResource; import java.util.List; import lombok.RequiredArgsConstructor; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @@ -137,4 +139,17 @@ public class WeekStarRestController extends BaseController { return weekStarService.getHistoryTop1(cmd); } + /** + * 碎片兑换. + * + * @eo.name 碎片兑换 + * @eo.url /exchange + * @eo.method post + * @eo.request-type formdata + */ + @PostMapping("/exchange") + public Long exchange(@Validated WeekStarExchangeCmd cmd) { + return weekStarService.exchange(cmd); + } + } diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/activity/WeekStarExchangeExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/activity/WeekStarExchangeExe.java new file mode 100644 index 00000000..913ca293 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/activity/WeekStarExchangeExe.java @@ -0,0 +1,114 @@ +package com.red.circle.other.app.command.activity; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.nacos.shaded.com.google.common.collect.Lists; +import com.red.circle.common.business.core.enums.SysOriginPlatformEnum; +import com.red.circle.common.business.enums.SendPropsOrigin; +import com.red.circle.framework.core.asserts.ResponseAssert; +import com.red.circle.framework.core.response.CommonErrorCode; +import com.red.circle.framework.dto.ResultResponse; +import com.red.circle.other.app.dto.cmd.activity.WeekStarExchangeCmd; +import com.red.circle.other.infra.common.activity.PropsActivitySendCommon; +import com.red.circle.other.infra.common.activity.send.SendRewardParam; +import com.red.circle.other.infra.database.mongo.entity.game.egg.GameEggStockConfig; +import com.red.circle.other.infra.database.rds.entity.game.GameUserShardsBackpack; +import com.red.circle.other.inner.endpoint.activity.PropsActivityClient; +import com.red.circle.other.inner.endpoint.material.props.api.FragmentsBackpackClientApi; +import com.red.circle.other.inner.model.cmd.material.PrizeDescribe; +import com.red.circle.other.inner.model.dto.activity.props.ActivityPropsGroup; +import com.red.circle.other.inner.model.dto.activity.props.ActivityPropsRule; +import com.red.circle.other.inner.model.dto.activity.props.ActivityRewardProps; +import com.red.circle.other.inner.model.dto.material.FragmentsBackpackDTO; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Component; + +import java.util.List; +import java.util.Objects; +import java.util.Set; + +/** + * 周星碎片兑换执行器. + * + * @author pengshigang on 2025/9/19 + */ +@Component +@RequiredArgsConstructor +public class WeekStarExchangeExe { + + private final FragmentsBackpackClientApi fragmentsBackpackClientApi; + private final PropsActivitySendCommon sendPropsManager; + private final PropsActivityClient propsActivityClient; + + + public Long execute(WeekStarExchangeCmd cmd) { + + // 1. 校验碎片背包 + List backpackList = fragmentsBackpackClientApi + .listByUserIdByFragmentsIds(cmd.getReqUserId(), Set.of(cmd.getFragmentsId())) + .getBody(); + + ResponseAssert.notEmpty(CommonErrorCode.DATA_ERROR, backpackList); + + FragmentsBackpackDTO backpack = backpackList.get(0); + if (backpack.getQuantity() == null || backpack.getQuantity() <= 0) { + throw new RuntimeException("Insufficient amount of debris."); + } + + ActivityPropsRule activityPropsRule = propsActivityClient.getByRuleId(cmd.getPropsGroupId()).getBody(); + if (activityPropsRule == null) { + throw new RuntimeException("activityPropsRule is null."); + } + + JSONObject obj = JSON.parseObject(activityPropsRule.getJsonData()); + Integer needFragments = obj.getInteger("need_fragments"); + if (needFragments == null || needFragments <= 0) { + throw new RuntimeException("needFragments is null or needFragments <= 0."); + } + if (backpack.getQuantity() < needFragments) { + throw new RuntimeException("Insufficient amount of debris."); + } + + // 校验配置 + ActivityPropsGroup body = propsActivityClient.getActivityPropsGroup(cmd.getReqSysOrigin().getOrigin(), activityPropsRule.getResourceGroupId()).getBody(); + if (body == null || body.getActivityRewardProps().isEmpty()) { + throw new RuntimeException("ActivityPropsGroup is null."); + } + + List activityRewardProps = body.getActivityRewardProps(); + ActivityRewardProps rewardProps = activityRewardProps.get(0); + + // 2. 扣除碎片 + fragmentsBackpackClientApi.decrFragments( + cmd.getReqUserId(), + Set.of(cmd.getFragmentsId()), + needFragments + ); + + // 发送奖品 + sendPropsManager.sendGroup(SendRewardParam.builder() + .acceptUserId(cmd.getReqUserId()) + .origin(SendPropsOrigin.EGG) + .sysOrigin(SysOriginPlatformEnum.valueOf(cmd.getReqSysOrigin().getOrigin())) + .trackId(cmd.getPropsGroupId()) + .build(), + getPrizeDescribes(rewardProps)); + + // 4. 添加兑换记录 - 暂时不写 + // TODO: 添加兑换记录 + + return 1L; // 返回兑换数量 + } + + private List getPrizeDescribes(ActivityRewardProps rewardProps) { + + PrizeDescribe prize = new PrizeDescribe() + .setTrackId(rewardProps.getId()) + .setType(rewardProps.getType()) + .setDetailType(rewardProps.getDetailType()) + .setContent(rewardProps.getContent()) + .setQuantity(rewardProps.getQuantity()); + return List.of(prize); + } + +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/activity/WeekStarServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/activity/WeekStarServiceImpl.java index 0e4ab9a9..38eee108 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/activity/WeekStarServiceImpl.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/activity/WeekStarServiceImpl.java @@ -9,6 +9,7 @@ import com.red.circle.other.app.command.activity.query.WeekStarHistoryTop1QueryE import com.red.circle.other.app.command.activity.query.WeekStarRewardQueryExe; import com.red.circle.other.app.command.activity.query.WeekStarStartEndTimeQueryExe; import com.red.circle.other.app.command.activity.query.WeekStarThisWeeksGiftQueryExe; +import com.red.circle.other.app.command.activity.WeekStarExchangeExe; import com.red.circle.other.app.dto.clientobject.activity.LastWeekStarGiftUserRankCO; import com.red.circle.other.app.dto.clientobject.activity.UserRankCO; import com.red.circle.other.app.dto.clientobject.activity.WeekStarGiftUserRankCO; @@ -16,6 +17,7 @@ import com.red.circle.other.app.dto.clientobject.activity.WeekStarHistoryVO; import com.red.circle.other.app.dto.clientobject.gift.GiftConfigCO; import com.red.circle.other.app.dto.cmd.activity.WeekStarGiftQueryCmd; import com.red.circle.other.app.dto.cmd.activity.WeekStarRankingQueryCmd; +import com.red.circle.other.app.dto.cmd.activity.WeekStarExchangeCmd; import com.red.circle.other.inner.enums.activity.WeekStarGiftTypeEnum; import com.red.circle.other.inner.model.dto.activity.props.ActivityResource; import com.red.circle.tool.core.collection.CollectionUtils; @@ -40,6 +42,7 @@ public class WeekStarServiceImpl implements WeekStarService { private final WeekStarHistoryTop1QueryExe weekStarHistoryTop1QueryExe; private final WeekStarStartEndTimeQueryExe weekStarStartEndTimeQueryExe; private final WeekStarThisWeeksGiftQueryExe weekStarThisWeeksGiftQueryExe; + private final WeekStarExchangeExe weekStarExchangeExe; @Override public WeekStarGiftUserRankCO getGiftRanking(WeekStarRankingQueryCmd cmd) { @@ -92,4 +95,9 @@ public class WeekStarServiceImpl implements WeekStarService { public List getHistoryTop1(AppExtCommand cmd) { return weekStarHistoryTop1QueryExe.execute(cmd); } + + @Override + public Long exchange(WeekStarExchangeCmd cmd) { + return weekStarExchangeExe.execute(cmd); + } } diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/activity/WeekStarExchangeCmd.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/activity/WeekStarExchangeCmd.java new file mode 100644 index 00000000..ce635f28 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/activity/WeekStarExchangeCmd.java @@ -0,0 +1,29 @@ +package com.red.circle.other.app.dto.cmd.activity; + +import com.red.circle.common.business.dto.cmd.AppExtCommand; +import jakarta.validation.constraints.NotNull; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * 周星碎片兑换命令. + * + * @author pengshigang on 2025/9/19 + */ +@Data +@EqualsAndHashCode(callSuper = false) +public class WeekStarExchangeCmd extends AppExtCommand { + + /** + * 道具组ID. + */ + @NotNull(message = "propsGroupId {not.null}") + private Long propsGroupId; + + /** + * 碎片ID. + */ + @NotNull(message = "fragmentsId {not.null}") + private Long fragmentsId; + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/activity/WeekStarService.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/activity/WeekStarService.java index fdf8da7d..4ed9dc2d 100644 --- a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/activity/WeekStarService.java +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/activity/WeekStarService.java @@ -9,6 +9,7 @@ import com.red.circle.other.app.dto.clientobject.activity.WeekStarHistoryVO; import com.red.circle.other.app.dto.clientobject.gift.GiftConfigCO; import com.red.circle.other.app.dto.cmd.activity.WeekStarGiftQueryCmd; import com.red.circle.other.app.dto.cmd.activity.WeekStarRankingQueryCmd; +import com.red.circle.other.app.dto.cmd.activity.WeekStarExchangeCmd; import com.red.circle.other.inner.model.dto.activity.props.ActivityResource; import java.util.List; @@ -41,4 +42,9 @@ public interface WeekStarService { */ List getHistoryTop1(AppExtCommand cmd); + /** + * 碎片兑换. + */ + Long exchange(WeekStarExchangeCmd cmd); + } diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/FragmentsBackpackService.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/FragmentsBackpackService.java index dd797865..525e6bdc 100644 --- a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/FragmentsBackpackService.java +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/FragmentsBackpackService.java @@ -35,7 +35,7 @@ public interface FragmentsBackpackService extends BaseService * @param fragmentsIds 碎片ids * @param quantity 数量 */ - void decrFragments(Long userId, Set fragmentsIds, Integer quantity); + boolean decrFragments(Long userId, Set fragmentsIds, Integer quantity); /** * 根据用户id与碎片集合查询用户碎片背包，并且数量大于0 diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/impl/FragmentsBackpackServiceImpl.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/impl/FragmentsBackpackServiceImpl.java index c2d61b4b..718090a1 100644 --- a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/impl/FragmentsBackpackServiceImpl.java +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/props/impl/FragmentsBackpackServiceImpl.java @@ -54,12 +54,12 @@ public class FragmentsBackpackServiceImpl extends } @Override - public void decrFragments(Long userId, Set fragmentsIds, Integer quantity) { + public boolean decrFragments(Long userId, Set fragmentsIds, Integer quantity) { if (Objects.isNull(userId) || CollectionUtils.isEmpty(fragmentsIds) || quantity <= 0) { - return; + return false; } - update().set(FragmentsBackpack::getUpdateTime, TimestampUtils.now()) + return update().set(FragmentsBackpack::getUpdateTime, TimestampUtils.now()) .setSql("quantity=quantity-" + quantity) .in(FragmentsBackpack::getFragmentsId, fragmentsIds) .eq(FragmentsBackpack::getUserId, userId) diff --git a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/endpoint/material/props/FragmentsBackpackClientEndpoint.java b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/endpoint/material/props/FragmentsBackpackClientEndpoint.java index 0e96710c..f2e5526b 100644 --- a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/endpoint/material/props/FragmentsBackpackClientEndpoint.java +++ b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/endpoint/material/props/FragmentsBackpackClientEndpoint.java @@ -12,6 +12,8 @@ import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import static com.red.circle.framework.core.response.CommonErrorCode.OPERATING_FAILURE; + /** * 碎片服务. * @@ -35,8 +37,9 @@ public class FragmentsBackpackClientEndpoint implements FragmentsBackpackClientA @Override public ResultResponse decrFragments(Long userId, Set fragmentsIds, Integer quantity) { - fragmentsBackpackClientService.decrFragments(userId, fragmentsIds, quantity); - return ResultResponse.success(); + return fragmentsBackpackClientService.decrFragments(userId, fragmentsIds, quantity) ? + ResultResponse.success() : + ResultResponse.failure(OPERATING_FAILURE); } @Override diff --git a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/FragmentsBackpackClientService.java b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/FragmentsBackpackClientService.java index aee67356..fef34b74 100644 --- a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/FragmentsBackpackClientService.java +++ b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/FragmentsBackpackClientService.java @@ -29,7 +29,7 @@ public interface FragmentsBackpackClientService { * @param fragmentsIds 碎片ids * @param quantity 数量 */ - void decrFragments(Long userId, Set fragmentsIds, Integer quantity); + boolean decrFragments(Long userId, Set fragmentsIds, Integer quantity); /** * 根据用户id与碎片集合查询用户碎片背包，并且数量大于0 diff --git a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/impl/FragmentsBackpackClientServiceImpl.java b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/impl/FragmentsBackpackClientServiceImpl.java index a38656ac..0e7e9d71 100644 --- a/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/impl/FragmentsBackpackClientServiceImpl.java +++ b/rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/material/props/impl/FragmentsBackpackClientServiceImpl.java @@ -29,8 +29,8 @@ public class FragmentsBackpackClientServiceImpl implements FragmentsBackpackClie } @Override - public void decrFragments(Long userId, Set fragmentsIds, Integer quantity) { - fragmentsBackpackService.decrFragments(userId, fragmentsIds, quantity); + public boolean decrFragments(Long userId, Set fragmentsIds, Integer quantity) { + return fragmentsBackpackService.decrFragments(userId, fragmentsIds, quantity); } @Override