fixed some bugs

app/Services/PriceChannelBroadcastService.php

@@ -76,9 +76,8 @@ TXT;
             }
 
             try {
-                // شرط ۱: از آخرین «ارسال واقعی» حداقل price_channel_min_seconds گذشته باشد.
-                // چون فقط روی ارسال واقعی markSent می‌کنیم، یک بررسیِ بی‌ارسال تایمر را ریست نمی‌کند.
-                if (! $this->cooldownElapsed()) {
+                // شرط ۱: حداقل price_channel_min_seconds از آخرین ارسال گذشته باشد (اتمی — جلوی race و چند worker)
+                if (! $this->acquireSendCooldown()) {
                     return;
                 }
 
@@ -111,8 +110,7 @@ TXT;
                     $results[$messenger] = $this->dispatchToMessenger($messenger, $target['token'], $target['chat_ids'], $message);
                 }
 
-                // فقط بعد از ارسال واقعی: تایمر cooldown و امضای قیمت به‌روزرسانی می‌شوند
-                $this->markSent();
+                // فقط بعد از ارسال واقعی: امضا به‌روزرسانی می‌شود (cooldown در acquireSendCooldown ست شد)
                 Cache::put(self::SIGNATURE_CACHE_KEY, $signature, now()->addDay());
 
                 Log::info('PriceChannel: قیمت به کانال ارسال شد', [
@@ -176,6 +174,11 @@ TXT;
                     return;
                 }
 
+                if (! $this->acquireSendCooldown()) {
+                    Log::debug('PriceChannel: قالب عوض شد ولی cooldown هنوز تمام نشده');
+                    return;
+                }
+
                 $message = $this->buildMessage($products, $boardProduct);
                 if ($message === '') {
                     return;
@@ -187,10 +190,9 @@ TXT;
                 }
 
                 $signature = $this->broadcastSignature();
-                $this->markSent();
                 Cache::put(self::SIGNATURE_CACHE_KEY, $signature, now()->addDay());
 
-                Log::info('PriceChannel: قالب پیام تغییر کرد — ارسال فوری به کانال', [
+                Log::info('PriceChannel: قالب پیام تغییر کرد — ارسال به کانال', [
                     'targets' => array_keys($targets),
                     'results' => $results,
                 ]);
@@ -221,10 +223,8 @@ TXT;
         }
 
         if ($message !== '' && $targets !== []) {
-            $this->markSent();
-            if ($this->resolveLiveTradePrices() !== null) {
-                Cache::put(self::SIGNATURE_CACHE_KEY, $this->broadcastSignature(), now()->addDay());
-            }
+            $this->acquireSendCooldown(true);
+            Cache::put(self::SIGNATURE_CACHE_KEY, $this->broadcastSignature(), now()->addDay());
         }
 
         return [
@@ -266,6 +266,7 @@ TXT;
             'selected_messengers' => $selected,
             'min_seconds' => $this->config->getInt('price_channel_min_seconds', 120),
             'cooldown_elapsed' => $this->cooldownElapsed(),
+            'cooldown_seconds_remaining' => $this->cooldownSecondsRemaining(),
             'eligible_products' => count($this->eligibleProducts()),
             'messengers' => $messengers,
             'active_targets' => array_keys($this->resolveActiveTargets()),
@@ -718,25 +719,39 @@ TXT;
             ]);
     }
 
-    /** حداقل فاصله‌ی مجاز بین دو ارسال — جلوگیری از سیل پیام در هر تیک ۱۰ثانیه‌ای */
-    private function cooldownElapsed(): bool
+    /** حداقل فاصلهٔ مجاز بین دو ارسال — Cache::add اتمی (TTL = min_seconds) */
+    private function acquireSendCooldown(bool $force = false): bool
     {
         $minSeconds = max(0, $this->config->getInt('price_channel_min_seconds', 120));
-        if ($minSeconds === 0) {
+        if ($minSeconds === 0 || $force) {
+            if ($minSeconds > 0) {
+                Cache::put(self::COOLDOWN_CACHE_KEY, now()->timestamp, $minSeconds);
+            }
+
             return true;
         }
 
-        $lastSent = Cache::get(self::COOLDOWN_CACHE_KEY);
-        if ($lastSent === null) {
-            return true;
-        }
-
-        return now()->timestamp - (int) $lastSent >= $minSeconds;
+        return Cache::add(self::COOLDOWN_CACHE_KEY, now()->timestamp, $minSeconds);
     }
 
-    private function markSent(): void
+    private function cooldownElapsed(): bool
     {
-        Cache::put(self::COOLDOWN_CACHE_KEY, now()->timestamp, now()->addDay());
+        return $this->cooldownSecondsRemaining() === 0;
+    }
+
+    private function cooldownSecondsRemaining(): int
+    {
+        $minSeconds = max(0, $this->config->getInt('price_channel_min_seconds', 120));
+        if ($minSeconds === 0 || ! Cache::has(self::COOLDOWN_CACHE_KEY)) {
+            return 0;
+        }
+
+        $lastSent = (int) Cache::get(self::COOLDOWN_CACHE_KEY, 0);
+        if ($lastSent <= 0) {
+            return 0;
+        }
+
+        return max(0, $minSeconds - (now()->timestamp - $lastSent));
     }
 
     /** @return array<int, string> */