控制台应用,yzncms本身基于tp5.1框架,里面的队列用不了,bug,坑
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | Yzncms [ 御宅男工作室 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2018 http://yzncms.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
  8. // +----------------------------------------------------------------------
  9. // | Author: 御宅男 <530765310@qq.com>
  10. // +----------------------------------------------------------------------
  11. // +----------------------------------------------------------------------
  12. // | 队列插件
  13. // +----------------------------------------------------------------------
  14. namespace addons\queue;
  15. use think\Addons;
  16. use think\Loader;
  17. class Queue extends Addons
  18. {
  19. //安装
  20. public function install()
  21. {
  22. //复制配置文件
  23. $route_file = ADDON_PATH . str_replace("/", DS, "queue/install/queue.php");
  24. copy($route_file, ROOT_PATH . 'config' . DS . 'queue.php');
  25. return true;
  26. }
  27. //卸载
  28. public function uninstall()
  29. {
  30. //删除配置文件
  31. if (file_exists(ROOT_PATH . 'config' . DS . 'queue.php')) {
  32. unlink(ROOT_PATH . 'config' . DS . 'queue.php');
  33. }
  34. return true;
  35. }
  36. /**
  37. * 添加命名空间
  38. */
  39. public function appInit()
  40. {
  41. Loader::addNamespace('think', ADDON_PATH . 'queue' . DS . 'SDK' . DS . 'src' . DS);
  42. if (request()->isCli()) {
  43. \think\Console::addDefaultCommands([
  44. "think\\queue\\command\\Work",
  45. "think\\queue\\command\\Restart",
  46. "think\\queue\\command\\Listen",
  47. "think\\queue\\command\\Subscribe",
  48. ]);
  49. }
  50. }
  51. }