fdfd

application/api/controller/Cms.php

 // +----------------------------------------------------------------------
 namespace app\api\controller;
 
-use app\common\controller\Api;
-use app\common\library\Ems as Emslib;
 use app\member\controller\MemberApi;
-use app\member\model\Member;
-use think\facade\Hook;
-use think\facade\Validate;
 use think\Db;
 
 /**
 class Cms extends MemberApi
 {
 
-    protected $noNeedLogin = ['login', 'register','getProduct','getProductSmall','createTask','tagHandle','taskHandle','getAreaJson'];
+    protected $noNeedLogin = ['login', 'register','getProduct','getProductSmall','createTask','tagHandle','taskHandle','getAreaJson','getTagListHandle'];
     protected $noNeedRight = [];
 
     //初始化
             ->order('add_time asc')->paginate(1);
         $list = $list->toArray();
         $data = $list['data'];
+
+        if(empty($data)){
+            $this->error('fail',['ko'=>'不存在数据']);
+        }
+
         foreach ($data as $index => $row) {
 
             //获取标签
                        'run_time' => time(),
                        'status' => 1,
                    ]);
-                   $this->error('fail');
+                   $this->error('fail',['is_run'=>4]);
                }
 
                //是否只有一个页面 (远程)
                        'run_time' => time(),
                        'status' => 1,
                    ]);
-                   $this->error('fail');
+                   $this->error('fail',['is_run'=>3]);
                }
 
                //创建标签
         $data = $list['data'];
         //dump($data);die;
 
+        if(empty($data)){
+            $this->error('fail',['ko'=>'不存在数据']);
+        }
         /*
          * 跨库 无法保证远程和本地的事务一致性
          * 这种机制 类似 支付
             $one = Db::connect('db1')->table('ey_seo_number')->where([
                     'type' => 1,
                     'aid' => $row['aid'],
-                ])->where('parentid','!=',38)->find();
+                ])->where('parentid','<>',38)->find();
             $number = Db::connect('db1')->table('ey_seo_number')->where([
                     'type' => 1,
                     'aid' => $one['parentid'],
 
     }
 
+    /*
+     * 批量执行标签处理
+     * 加入队列 http://console.zx2049.com/api/cms/getTagListHandle
+     * 启动队列 php think queue:listen --queue tagHandle
+     * 监听队列 进程守护管理器 (附加参数参考: https://www.kancloud.cn/ken678/yzncms/2383907)
+     * redis查看数据器 默认重置次数1
+     * workman实时推送消息
+     * 添加自定义命令的方式来执行队列
+     */
+    public function getTagListHandle()
+    {
+
+
+/*        $a = new \app\api\queue\jobs\TagHandle();
+        var_dump($a);
+        return json([]);*/
+
+
+
+        $area = Db::connect('db1')
+            ->table('ey_citysite')
+            ->where(['level'=>1,'is_open'=>1,'status'=>1])
+            ->select();
+        //dump($area);
+        $area[] = [
+            'id' => 10000,
+            'name' => '主站',
+        ];
+
+        foreach ($area as $k=>$v){
+            //http://console.zx2049.com/api/cms/tagHandle?taskid=10&diqu=1
+            $jobData  = ['ts' => time(),'url'=>'http://console.zx2049.com/api/cms/tagHandle','taskid'=>10, 'area_id' => $v['id'], 'area_name' => $v['name']];//当前任务所需的业务数据
+            $isPushed = \think\Queue::push('app\common\jobs\TagHandle', $jobData,'tagHandle');//没有@使用默认方法fire，此方法为立即执行
+            if ($isPushed !== false) {
+                echo "ok";
+            } else {
+                echo 'warn';
+            }
+            echo "<br/>";
+        }
+
+    }
+
 
 }

application/common/jobs/TagHandle.php

+<?php
+// +----------------------------------------------------------------------
+// | Yzncms [ 御宅男工作室 ]
+// +----------------------------------------------------------------------
+// | Copyright (c) 2018 http://yzncms.com All rights reserved.
+// +----------------------------------------------------------------------
+// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
+// +----------------------------------------------------------------------
+// | Author: 御宅男 <530765310@qq.com>
+// +----------------------------------------------------------------------
+
+// +----------------------------------------------------------------------
+// | 测试队列,仅供参考
+// +----------------------------------------------------------------------
+namespace app\common\jobs;
+
+use think\facade\Log;
+use think\queue\Job;
+
+class TagHandle
+{
+
+    /**
+     * fire方法是消息队列默认调用的方法
+     * @param Job            $job      当前的任务对象
+     * @param array|mixed    $data     发布任务时自定义的数据
+     */
+    public function fire(Job $job, $data)
+    {
+        $isJobDone = $this->doHelloJob($data);
+        if ($isJobDone) {
+            // 如果任务执行成功， 记得删除任务
+            $job->delete();
+            print("<info>Hello Job has been done and deleted" . "</info>\n");
+        } else {
+            //超过3次删除任务 如果不删除 并且命令行附带--tries参数，则会执行failed方法
+            if ($job->attempts() > 3) {
+                $job->delete();
+                print("<warn>Hello Job has been retried more than 3 times!" . "</warn>\n");
+            } else {
+                //5秒后从新放入队列
+                $job->release(5);
+            }
+        }
+    }
+
+    //多任务A 在发布任务时，需要用 push('任务的类名@方法名')
+    public function taskA(Job $job, $data)
+    {
+        $isJobDone = $this->_doTaskA($data);
+        if ($isJobDone) {
+            $job->delete();
+            print("Info: TaskA of Job MultiTask has been done and deleted" . "\n");
+        } else {
+            if ($job->attempts() > 3) {
+                $job->delete();
+            }
+        }
+    }
+
+    //多任务B 在发布任务时，需要用 push('任务的类名@方法名')
+    public function taskB(Job $job, $data)
+    {
+        $isJobDone = $this->_doTaskA($data);
+        if ($isJobDone) {
+            $job->delete();
+            print("Info: TaskB of Job MultiTask has been done and deleted" . "\n");
+        } else {
+            if ($job->attempts() > 2) {
+                $job->release();
+            }
+        }
+    }
+
+    /**
+     * 根据消息中的数据进行实际的业务处理...
+     */
+    private function doHelloJob($data)
+    {
+/*        print("<info>Hello Job Started. job Data is: " . var_export($data, true) . "</info> \n");
+        print("<info>Hello Job is Fired at " . date('Y-m-d H:i:s') . "</info> \n");
+        print("<info>Hello Job is Done!" . "</info> \n");*/
+
+        /*
+         * "data": {
+            "ts": 1713866309,
+            "url": "http:\/\/console.zx2049.com\/api\/cms\/tagHandle",
+            "taskid": 10,
+            "area_id": 1,
+            "area_name": "\u5e7f\u4e1c"
+          },
+         */
+
+        //测试
+        print("<info>执行标签处理: " . $data['area_id'] . "</info> \n");
+
+        /*//拼装url
+        $url = $data['url'].'?taskid='.$data['taskid'].'&diqu='.$data['area_id'];
+        //发送执行
+        $content = file_get_contents($url);
+        echo $content;*/
+
+        return true;
+    }
+
+    private function _doTaskA($data)
+    {
+        print("Info: doing TaskA of Job MultiTask " . "\n");
+        return true;
+    }
+
+    private function _doTaskB($data)
+    {
+        print("Info: doing TaskB of Job MultiTask " . "\n");
+        return true;
+    }
+
+    //此函数可以省略 通常用于定义通知管理员队列失败
+    //任务最终失败回调 命令行的 --tries 参数的值大于0生效
+    public function failed($jobData)
+    {
+        Log::error("Warning: Job failed after max retries. job data is :" . var_export($jobData, true));
+    }
+}

config/queue.php

     'default'    => 'default', // 默认的队列名称
     'host'       => '127.0.0.1', // redis 主机ip
     'port'       => 6379, // redis 端口
-    'password'   => '', // redis 密码
+    'password'   => 'Zhengwei178..', // redis 密码
     'select'     => 0, // 使用哪一个 db，默认为 db0
     'timeout'    => 0, // redis连接的超时时间
     'persistent' => false, // 是否是长连接