定时异常处理

application/task/controller/SquareTask.php

@@ -7,6 +7,7 @@ namespace app\task\controller;
 use app\api_broker\service\SquareSortService;
 use app\model\BSquare;
 use app\model\BSquareSort;
+use think\Log;
 
 class SquareTask
 {
@@ -18,6 +19,12 @@ class SquareTask
         $this->m_square = new BSquare();
     }
 
+    /**
+     * 备份redis开盘排序
+     *
+     * User HuJun
+     * Date 19-5-8 上午10:09
+     */
     public function squareBackUp() {
         $save_data = $square_id = [];
 
@@ -42,29 +49,35 @@ class SquareTask
 
         $square_id = array_unique($square_id);
         sort($square_id);
-        foreach ($square_id as $k=>$v) {
-            if (isset($look_num[$v])) {
-                $save_data['browse_number'] = $look_num[$v];
+        try {
+            foreach ($square_id as $k=>$v) {
+                if (isset($look_num[$v])) {
+                    $save_data['browse_number'] = $look_num[$v];
 
-                if ($look_num[$v] >= 500) {
-                    $square_data = $this->m_square->getSquare('id,is_cream',['id'=>$v]);
-                    //是否是精华帖 0普通 1精华
-                    if ($square_data[0]['is_cream'] == 0) {
-                        $this->m_square->updateStatus(['id'=>$v], ['is_cream'=>1]);
+                    if ($look_num[$v] >= 500) {
+                        $square_data = $this->m_square->getSquare('id,is_cream',['id'=>$v]);
+                        //是否是精华帖 0普通 1精华
+                        if ($square_data[0]['is_cream'] == 0) {
+                            $this->m_square->updateStatus(['id'=>$v], ['is_cream'=>1]);
+                        }
                     }
                 }
-            }
-            if (isset($comment[$v])) {
-                $save_data['last_reply_time'] = date('Y-m-d H:i:s', $comment[$v]);
-            }
+                if (isset($comment[$v])) {
+                    $save_data['last_reply_time'] = date('Y-m-d H:i:s', $comment[$v]);
+                }
 
-            $num = $this->m_sort->getList(1, 1, '', 'id',['square_id'=>$v, 'is_del'=>0]);
-            if ($num) {
-                $this->m_sort->updateData($save_data, $num[0]['id']);
-            } else {
-                $save_data['square_id'] = $v;
-                $this->m_sort->insertData($save_data);
+                $num = $this->m_sort->getList(1, 1, '', 'id',['square_id'=>$v, 'is_del'=>0]);
+                if ($num) {
+                    $this->m_sort->updateData($save_data, $num[0]['id']);
+                } else {
+                    $save_data['square_id'] = $v;
+                    $this->m_sort->insertData($save_data);
+                }
             }
+        } catch (\Exception $e) {
+            Log::write($e->getMessage(), 'redis_backUp_square_task'); //记录日志
         }
+
+        return ;
     }
 }
\ No newline at end of file