修改管理员界面 推荐码下线查询功能

src/main/java/com/edgec/browserbackend/account/repository/AccountRepository.java

@@ -31,6 +31,8 @@ public interface AccountRepository extends MongoRepository<Account, String>, Acc
 
     List<Account> findAllBySignupDateBetweenAndPromotionCodeAndParentIsNull(Date startDate, Date endDate, String promotionCode);
 
+    List<Account> findAllByPromotionCodeAndParentIsNull(String code);
+
     Page<Account> findAllBySignupDateBetweenAndPromotionCodeAndParentIsNull(Pageable pageable, Date startDate, Date endDate, String promotionCode);
 
     Page<Account> findAllBySignupDateBetweenAndParentIsNull(Pageable pageable, Date startDate, Date endDate);
@@ -45,4 +47,5 @@ public interface AccountRepository extends MongoRepository<Account, String>, Acc
     List<Account> findByPromotionCodeAndParentIsNull(String code);
 
     int countByPromotionCodeAndParentIsNull(String promotionCode);
+
 }

src/main/java/com/edgec/browserbackend/account/service/impl/AdministratorServiceImpl.java

@@ -407,16 +407,24 @@ public class AdministratorServiceImpl implements AdministratorService {
 
     @Override
     public PromotionQueryResultDto queryPromotion(Pageable pageable, String username, String promotionCode, String strDate1, String strDate2) {
-        if (StringUtils.isBlank(username) && StringUtils.isBlank(promotionCode))
+        if (StringUtils.isBlank(username) && StringUtils.isBlank(promotionCode)) {
             throw new ClientRequestException(BrowserErrorCode.INFORMATIONNOTCOMPELETE);
+        }
+
         Account account = null;
-        if (!StringUtils.isBlank(username))
+        if (!StringUtils.isBlank(username)) {
             account = accountRepository.findByName(username).orElseThrow(() -> new ClientRequestException(AccountErrorCode.NAMENOTEXIST));
-        else account = accountRepository.findByPromotion(promotionCode);
-        if (account == null)
+        } else {
+            account = accountRepository.findByPromotion(promotionCode);
+        }
+        if (account == null) {
             throw new ClientRequestException(AccountErrorCode.NAMENOTEXIST);
-        if (account.getParent() != null)
+        }
+
+        if (account.getParent() != null) {
             throw new ClientRequestException(AccountErrorCode.NOPERMISSION);
+        }
+
         SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
         PromotionQueryResultDto promotionQueryResultDto = new PromotionQueryResultDto(account);
         promotionQueryResultDto.setUsername(username);
@@ -434,25 +442,34 @@ public class AdministratorServiceImpl implements AdministratorService {
             Page<AccountPromotionDto> accountPromotionDtoPage = new PageImpl<AccountPromotionDto>(accountPromotionDtos);
             promotionQueryResultDto.setUsers(accountPromotionDtoPage);
 
-            List<Account> accounts = accountRepository.findAllBySignupDateBetweenAndPromotionCodeAndParentIsNull(dateTime1, dateTime2, account.getPromotion().getCode());
+            // 查询在指定的日期通过邀请码注册的账户
+            // List<Account> accounts = accountRepository.findAllBySignupDateBetweenAndPromotionCodeAndParentIsNull(dateTime1, dateTime2, account.getPromotion().getCode());
+            // 从上面的  改为查询 某用户邀请的所有账户
+            List<Account> accounts = accountRepository.findAllByPromotionCodeAndParentIsNull(account.getPromotion().getCode());
+
             Promotion promotion = new Promotion();
             Account finalAccount = account;
             AtomicLong ipCount = new AtomicLong();
             if (accounts != null && accounts.size() > 0) {
                 accounts.forEach(x -> {
                     promotion.setInvitedUsers(promotion.getInvitedUsers() + 1);
+                    // 查询账户在指定日期充值记录
                     List<UserPrePaidBilling> userPrePaidBillings = userPrePaidBillingRepository.findByAdministratorAndPayMethodInAndTimestampBetween(x.getName(), Arrays.asList(1, 2, 3), dateTime1.getTime(), dateTime2.getTime());
                     double totalCommission = 0;
-                    if (userPrePaidBillings != null && userPrePaidBillings.size() > 0)
+                    if (userPrePaidBillings != null && userPrePaidBillings.size() > 0) {
                         totalCommission = userPrePaidBillings.stream().mapToDouble(UserPrePaidBilling::getTotal).sum();
+                    }
+
                     promotion.setTotalCommission(promotion.getTotalCommission() + (int) totalCommission);
                     promotion.setCommission(promotion.getCommission() + x.getPromotion().getCommission());
-                    double secondCommission = 0;
+
                     ipCount.addAndGet(ipResourceRepository.countAllByOwnerAndIsDeletedAndValidTimeGreaterThan(x.getName(), false, Instant.now().toEpochMilli()));
                     List<Account> children = accountRepository.findByParent(x.getName());
                     if (children != null && children.size() > 0) {
                         ipCount.addAndGet(ipResourceRepository.countAllByOwnerInAndIsDeletedAndValidTimeGreaterThan(children.stream().map(Account::getName).collect(Collectors.toList()), false, Instant.now().toEpochMilli()));
                     }
+
+                    double secondCommission = 0;
                     if (finalAccount.getPromotion().isSale() && x.getParent() == null) {
                         List<Account> secondPromotes = accountRepository.findByPromotionCodeAndParentIsNull(x.getPromotion().getCode());
                         if (secondPromotes != null && secondPromotes.size() > 0) {
@@ -470,10 +487,11 @@ public class AdministratorServiceImpl implements AdministratorService {
                             }
                         }
                     }
-                    if (finalAccount.getPromotion().isSale())
+                    if (finalAccount.getPromotion().isSale()) {
                         promotion.setAllGift(promotion.getAllGift() + totalCommission * 0.1 + secondCommission * 0.02);
-                    else
+                    } else {
                         promotion.setAllGift(promotion.getAllGift() + totalCommission * 0.08);
+                    }
                     promotion.setWithdrawn(promotion.getWithdrawn() + secondCommission);
                     promotion.setGift(promotion.getGift() + x.getPromotion().getGift());
                     promotion.setCommissionLastMonth(promotion.getCommissionLastMonth() + x.getPromotion().getCommissionLastMonth());