diff --git a/src/main/java/com/ai/da/service/impl/AccountServiceImpl.java b/src/main/java/com/ai/da/service/impl/AccountServiceImpl.java
index 0ad0b784..987efa74 100644
--- a/src/main/java/com/ai/da/service/impl/AccountServiceImpl.java
+++ b/src/main/java/com/ai/da/service/impl/AccountServiceImpl.java
@@ -337,6 +337,7 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
         accountMapper.updateById(accountNew);
 
         TrialOrder trialOrder = CopyUtil.copyObject(accountNew, TrialOrder.class);
+        trialOrder.setEmail(accountNew.getUserEmail());
         trialOrder.setCreateTime(LocalDateTime.now());
         trialOrder.setStatus(1);
         // 获取用户申请试用IP
@@ -1116,27 +1117,22 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
     @Override
     public void upgradeNotification() {
         QueryWrapper<Account> queryWrapper = new QueryWrapper<>();
-//        queryWrapper.lambda().eq(Account::getId, 6L);
-        queryWrapper.and(wrapper ->
-                        wrapper.gt("valid_end_time", 1729479104000L)
-                                .or().isNull("valid_end_time")
-                                .isNull("valid_start_time"))
-                .isNotNull("user_email");
-
-
-//        QueryWrapper<Account> queryWrapper = new QueryWrapper<>();
-//        queryWrapper.lt("valid_end_time", 1729237154000L);
+        queryWrapper.lambda().ne(Account::getSystemUser, 0);
 
         List<Account> accountList = accountMapper.selectList(queryWrapper);
         System.out.println(accountList);
         int i = 0;
         for (Account account : accountList) {
-            if (account.getLanguage().equals(Language.CHINESE_SIMPLIFIED.name())) {
+            try {
+                if (account.getLanguage().equals(Language.CHINESE_SIMPLIFIED.name())) {
                     SendEmailUtil.sendUpgradeNotification(account, null, 0);
                 } else {
                     // 英文
                     SendEmailUtil.sendUpgradeNotification(account, null, 1);
                 }
+            }catch (Exception e) {
+                log.info(e.getMessage());
+            }
             i ++;
         }
     }