From e2d3955793746503681eafbe5dc47b9b04f41c01 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Tue, 13 Jan 2026 19:44:24 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Eaccount=20=E6=89=B9=E9=87=8F?= =?UTF-8?q?=E6=89=A3=E9=99=A4=20test?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/test/java/AnchorTargetTest.java | 42 +++++++++++++++++-- 1 file changed, 39 insertions(+), 3 deletions(-) diff --git a/rc-service/rc-service-other/other-start/src/test/java/AnchorTargetTest.java b/rc-service/rc-service-other/other-start/src/test/java/AnchorTargetTest.java index 8dd7ac04..3247051d 100644 --- a/rc-service/rc-service-other/other-start/src/test/java/AnchorTargetTest.java +++ b/rc-service/rc-service-other/other-start/src/test/java/AnchorTargetTest.java @@ -1,4 +1,6 @@ import com.red.circle.OtherServiceApplication; +import com.red.circle.other.domain.gateway.user.UserProfileGateway; +import com.red.circle.other.domain.model.user.UserProfile; import com.red.circle.other.infra.common.team.decay.ListMemberWorkDecay; import com.red.circle.other.infra.database.mongo.entity.team.team.TeamMemberTarget; import com.red.circle.other.infra.database.mongo.service.team.team.TeamMemberTargetService; @@ -29,6 +31,8 @@ public class AnchorTargetTest { private ListMemberWorkDecay listMemberWorkDecay; @Autowired private MongoTemplate mongoTemplate; + @Autowired + private UserProfileGateway userProfileGateway; /** @@ -111,10 +115,42 @@ public class AnchorTargetTest { */ @Test public void batchAnchorTargetDeduct() { - // 定义批量扣除的用户和金额列表 + Map map = Map.ofEntries( + Map.entry(8832761L, 150000L), + Map.entry(8834979L, 300000L), + Map.entry(8834654L, 300000L), + Map.entry(8839847L, 300000L), + Map.entry(8827498L, 150000L), + Map.entry(8839866L, 150000L), + Map.entry(8839902L, 300000L), + Map.entry(8839851L, 300000L), + Map.entry(8839894L, 300000L), + Map.entry(8840819L, 300000L), + Map.entry(8839949L, 300000L), + Map.entry(8839954L, 300000L), + Map.entry(8839957L, 300000L), + Map.entry(90090L, 1500000L), + Map.entry(8831059L, 150000L), + Map.entry(8829177L, 150000L), + Map.entry(8840323L, 300000L) + ); + + // 将account转换为userId并构建batchDeductMap Map batchDeductMap = new HashMap<>(); - batchDeductMap.put(1957345312961527809L, 1L); - batchDeductMap.put(1989287471839113218L, 1L); + map.forEach((account, amount) -> { + UserProfile userProfile = userProfileGateway.getByAccount("LIKEI", String.valueOf(account)); + if (Objects.nonNull(userProfile)) { + batchDeductMap.put(userProfile.getId(), amount); + } else { + throw new RuntimeException("账号不存在:" + account); + } + }); + + + // 定义批量扣除的用户和金额列表 +// Map batchDeductMap = new HashMap<>(); +// batchDeductMap.put(1957345312961527809L, 1L); +// batchDeductMap.put(1989287471839113218L, 1L); // 可以继续添加更多用户... System.out.println("========== 开始批量扣除 ==========");