From 361404ea32a6806cdd2951f99fba347325de3736 Mon Sep 17 00:00:00 2001
From: pengda <10266652509@qq.com>
Date: Tue, 3 Jun 2025 09:29:41 +0800
Subject: [PATCH] =?UTF-8?q?cookie=E5=A4=B1=E6=95=88=E9=82=AE=E4=BB=B6?=
 =?UTF-8?q?=E5=8F=91=E9=80=81=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 control/weibo.php                 |  2 +-
 queue/deal/get_weibo_behavior.php | 11 ++++++-----
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/control/weibo.php b/control/weibo.php
index b862a91..fb5b704 100644
--- a/control/weibo.php
+++ b/control/weibo.php
@@ -94,7 +94,7 @@ class weibo extends publicBase {
 
         $obj = new mWeiboBehavior();
         $list = $obj->getSpiderBehavior($date, $uid, $wid, $cur_page, $page_size);
-        $total = $obj->getSpiderBehaviorTotal($date, $wid, $uid);
+        $total = $obj->getSpiderBehaviorTotal($date, $uid, $wid);
 
         $rdata = array(
             'total' => $total,
diff --git a/queue/deal/get_weibo_behavior.php b/queue/deal/get_weibo_behavior.php
index a986985..6086c0d 100644
--- a/queue/deal/get_weibo_behavior.php
+++ b/queue/deal/get_weibo_behavior.php
@@ -33,10 +33,7 @@ class getWeiboBehavior extends dealBase {
         $obj->proxy_port = $ipdata['port'];
 
         $rq_data = $rdobj->rpop($this->task_key);
-        if (empty($rq_data)) {
-            sleep(60);
-            return false;
-        }
+        if (empty($rq_data)) exit;
 
         $baselog = $rq_data . "|" . $ipdata['ip'] . "|" . $ipdata['port'] . "|" . PROC_CODE . "|";
 
@@ -61,7 +58,11 @@ class getWeiboBehavior extends dealBase {
 
         if (!$res) {
             $error = $obj->getError();
-            if($error == 'cookie失效') $obj->sendMail(array('1026652509@qq.com'), date('Y年m月d日', time()) . '-微博数据抓取', $data['info']);
+            if($error == 'cookie失效') {
+                $obj->sendMail(array('1026652509@qq.com'), date('Y年m月d日', time()) . '-微博数据抓取', $error);
+                $rdobj->del($this->task_key);
+                exit;
+            }
             if ($obj->is_change_ip) {
                 // 0进程监控更换ip
                 if (PROC_CODE == 0) $rdobj->del(_RC_SPIDER_USE_IP);