diff --git a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/game/party3rd/GameHkysRestController.java b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/game/party3rd/GameHkysRestController.java index 7e360201..7db33403 100644 --- a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/game/party3rd/GameHkysRestController.java +++ b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/game/party3rd/GameHkysRestController.java @@ -265,32 +265,27 @@ public class GameHkysRestController { log.info("Spins游戏消费任务, userId={}, spendAmount={}, totalSpend={}", userId, amount, totalSpend); - if (totalSpend >= 5000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_5000") - .setProgressValue(1) - ); - } + int progressValue = Integer.parseInt(String.valueOf(totalSpend)); + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_5000") + .setProgressValue(progressValue) + ); - if (totalSpend >= 10000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_10000") - .setProgressValue(1) - ); - } + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_10000") + .setProgressValue(progressValue) + ); - if (totalSpend >= 50000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_50000") - .setProgressValue(1) - ); - } + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_50000") + .setProgressValue(progressValue) + ); log.info("Spins游戏消费任务处理成功, userId={}, totalSpend={}", userId, totalSpend); } catch (Exception e) { diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java index 1ebf424e..f1343943 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java @@ -335,32 +335,27 @@ public class GameBaishunServiceImpl implements GameBaishunService { redisService.setString(redisKey, String.valueOf(totalSpend), expireSeconds, TimeUnit.SECONDS); } - if (totalSpend >= 5000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_5000") - .setProgressValue(1) - ); - } + int progressValue = Integer.parseInt(String.valueOf(totalSpend)); + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_5000") + .setProgressValue(progressValue) + ); - if (totalSpend >= 10000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_10000") - .setProgressValue(1) - ); - } + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_10000") + .setProgressValue(progressValue) + ); - if (totalSpend >= 50000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_50000") - .setProgressValue(1) - ); - } + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_50000") + .setProgressValue(progressValue) + ); log.info("Spins游戏消费任务处理成功, userId={}, totalSpend={}", userId, totalSpend); } catch (Exception e) { diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/HotGameServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/HotGameServiceImpl.java index a04359e4..02dcb926 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/HotGameServiceImpl.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/HotGameServiceImpl.java @@ -408,32 +408,27 @@ public class HotGameServiceImpl implements HotGameService { log.info("Spins游戏消费任务, userId={}, spendAmount={}, totalSpend={}", userId, amount, totalSpend); - if (totalSpend >= 5000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_5000") - .setProgressValue(1) - ); - } + int progressValue = Integer.parseInt(String.valueOf(totalSpend)); + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_5000") + .setProgressValue(progressValue) + ); - if (totalSpend >= 10000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_10000") - .setProgressValue(1) - ); - } + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_10000") + .setProgressValue(progressValue) + ); - if (totalSpend >= 50000) { - spinsUserTaskProgressService.updateTaskProgress( - new SpinsTaskProgressUpdateCmd() - .setUserId(userId) - .setTaskCode("SPINS_SPEND_50000") - .setProgressValue(1) - ); - } + spinsUserTaskProgressService.updateTaskProgress( + new SpinsTaskProgressUpdateCmd() + .setUserId(userId) + .setTaskCode("SPINS_SPEND_50000") + .setProgressValue(progressValue) + ); log.info("Spins游戏消费任务处理成功, userId={}, totalSpend={}", userId, totalSpend); } catch (Exception e) {