|
|
@ -194,8 +194,16 @@ public class SuperAdminService { |
|
|
|
Map<Integer, MatrixAdvRecord> map = new HashMap<>(); |
|
|
|
for (MatrixUser x : users) { |
|
|
|
MatrixAdvRecord record = advRecordMapper.queryByUidOld(x.getId()); |
|
|
|
if (record == null) { |
|
|
|
L.trace("error_inner_user", x + ""); |
|
|
|
continue; |
|
|
|
} |
|
|
|
map.put(x.getId(), record); |
|
|
|
} |
|
|
|
users = users.stream().filter(x -> map.containsKey(x.getId())).toList(); |
|
|
|
if (CollectionUtils.isEmpty(users)) { |
|
|
|
return; |
|
|
|
} |
|
|
|
while (current < total) { |
|
|
|
int ecpm = 3000_00 + ThreadLocalRandom.current().nextInt(3000_00); |
|
|
|
current += ecpm; |
|
|
|