更新流量提醒邮件规则

重置周期内只发送一次邮件提醒长期有效的一个月只提醒一次
Neko-X2-Kyarameru · Jun 14, 2024 · 99cb8ac · 99cb8ac
1 parent 86e5cbc
commit 99cb8ac
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 4 deletions.
diff --git a/app/Console/Commands/ResetTraffic.php b/app/Console/Commands/ResetTraffic.php
@@ -119,6 +119,9 @@ private function resetByExpireYear($builder):void
             'u' => 0,
             'd' => 0
         ]);
+        foreach ($users as $user_id) {
+            Cache::forget(CacheKey::get('LAST_SEND_EMAIL_REMIND_TRAFFIC', $user_id));    //重置流量时清除 最后发送流量邮件提醒 标记
+        }
     }
 
     private function resetByYearFirstDay($builder):void
@@ -128,6 +131,9 @@ private function resetByYearFirstDay($builder):void
                 'u' => 0,
                 'd' => 0
             ]);
+            foreach ($builder->get() as $item) {
+                Cache::forget(CacheKey::get('LAST_SEND_EMAIL_REMIND_TRAFFIC', $item->id));    //重置流量时清除 最后发送流量邮件提醒 标记
+            }
         }
     }
 
@@ -138,6 +144,9 @@ private function resetByMonthFirstDay($builder):void
                 'u' => 0,
                 'd' => 0
             ]);
+            foreach ($builder->get() as $item) {
+                Cache::forget(CacheKey::get('LAST_SEND_EMAIL_REMIND_TRAFFIC', $item->id));    //重置流量时清除 最后发送流量邮件提醒 标记
+            }
         }
     }
 
@@ -160,5 +169,8 @@ private function resetByExpireDay($builder):void
             'u' => 0,
             'd' => 0
         ]);
+        foreach ($users as $user_id) {
+            Cache::forget(CacheKey::get('LAST_SEND_EMAIL_REMIND_TRAFFIC', $user_id));    //重置流量时清除 最后发送流量邮件提醒 标记
+        }
     }
 }
diff --git a/app/Services/MailService.php b/app/Services/MailService.php
@@ -12,10 +12,22 @@ class MailService
     public function remindTraffic (User $user)
     {
         if (!$user->remind_traffic) return;
-        if (!$this->remindTrafficIsWarnValue($user->u, $user->d, $user->transfer_enable)) return;
+        if (!$this->remindTrafficIsWarnValue($user->u, $user->d, $user->transfer_enable, 80)) return;
         $flag = CacheKey::get('LAST_SEND_EMAIL_REMIND_TRAFFIC', $user->id);
         if (Cache::get($flag)) return;
-        if (!Cache::put($flag, 1, 24 * 3600)) return;
+        $permanently_flag = 9999999999;  //长期有效
+        $expired_at = $user->expired_at;
+        if ($expired_at == NULL) $expired_at = $permanently_flag;    //长期有效
+        $nowTime = time();
+        if ($nowTime >= $expired_at ) return;
+        if ($expired_at == $permanently_flag) {  //判断是否长期有效
+            $expired_at = 30 * 24 *3600;  //一个月提醒一次
+        }
+        else{
+            $expired_at = $expired_at - $nowTime;  //过期时间内提醒一次
+        }
+
+        if (!Cache::put($flag, 1, $expired_at)) return;
         SendEmailJob::dispatch([
             'email' => $user->email,
             'subject' => __('The traffic usage in :app_name has reached 80%', [
@@ -45,13 +57,14 @@ public function remindExpire(User $user)
         ]);
     }
 
-    private function remindTrafficIsWarnValue($u, $d, $transfer_enable)
+    //warnValue 流量阈值 80，90，95
+    private function remindTrafficIsWarnValue($u, $d, $transfer_enable, $warnValue)
     {
         $ud = $u + $d;
         if (!$ud) return false;
         if (!$transfer_enable) return false;
         $percentage = ($ud / $transfer_enable) * 100;
-        if ($percentage < 80) return false;
+        if ($percentage < $warnValue) return false;
         if ($percentage >= 100) return false;
         return true;
     }

diff --git a/app/Services/OrderService.php b/app/Services/OrderService.php
@@ -260,6 +260,7 @@ private function buyByResetTraffic()
     {
         $this->user->u = 0;
         $this->user->d = 0;
+        Cache::forget(CacheKey::get('LAST_SEND_EMAIL_REMIND_TRAFFIC', $this->user->id));    //重置流量时清除 最后发送流量邮件提醒 标记
     }
 
     private function buyByPeriod(Order $order, Plan $plan)