HookModel.class.php 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155
  1. <?php
  2. namespace Admin\Model;
  3. use Common\Model\ModelModel;
  4. /**
  5. * 插件钩子模型
  6. * 该类参考了OneThink的部分实现
  7. *
  8. */
  9. class HookModel extends ModelModel
  10. {
  11. /**
  12. * 数据库表名
  13. *
  14. */
  15. protected $tableName = 'admin_hook';
  16. /**
  17. * 自动验证规则
  18. *
  19. */
  20. protected $_validate = array(
  21. array('name', 'require', '钩子名称必须!', self::MUST_VALIDATE, 'regex', self::MODEL_BOTH),
  22. array('name', '1,32', '钩子名称长度为1-32个字符', self::EXISTS_VALIDATE, 'length', self::MODEL_BOTH),
  23. array('name', '', '钩子名称已经存在', self::VALUE_VALIDATE, 'unique', self::MODEL_BOTH),
  24. array('description', 'require', '钩子描述必须!', self::MUST_VALIDATE, 'regex', self::MODEL_BOTH),
  25. );
  26. /**
  27. * 自动完成规则
  28. *
  29. */
  30. protected $_auto = array(
  31. array('create_time', 'time', self::MODEL_INSERT, 'function'),
  32. array('update_time', 'time', self::MODEL_BOTH, 'function'),
  33. array('sort', '0', self::MODEL_INSERT),
  34. array('status', '1', self::MODEL_INSERT),
  35. );
  36. /**
  37. * 获取件所需的钩子是否存在,没有则新增
  38. * @param string $str 钩子名称
  39. * @param string $addons 插件名称
  40. * @param string $addons 件简介
  41. *
  42. */
  43. public function existHook($name, $data)
  44. {
  45. $where['name'] = $name;
  46. $gethook = $this->where($where)->find();
  47. if (!$gethook || empty($gethook) || !is_array($gethook)) {
  48. $data['name'] = $name;
  49. $data['description'] = $data['description'];
  50. $data['type'] = 1;
  51. if (false !== $this->create($data)) {
  52. $this->add();
  53. }
  54. }
  55. }
  56. /**
  57. * 更新插件里的所有钩子对应的插件
  58. */
  59. public function updateHooks($addons_name)
  60. {
  61. $addons_class = get_addon_class($addons_name); //获取插件名
  62. if (!class_exists($addons_class)) {
  63. $this->error = "未实现{$addons_name}插件的入口文件";
  64. return false;
  65. }
  66. $methods = get_class_methods($addons_class);
  67. $hooks = $this->getField('name', true);
  68. $common = array_intersect($hooks, $methods);
  69. if (!empty($common)) {
  70. foreach ($common as $hook) {
  71. $flag = $this->updateAddons($hook, array($addons_name));
  72. if (false === $flag) {
  73. $this->removeHooks($addons_name);
  74. return false;
  75. }
  76. }
  77. }
  78. return true;
  79. }
  80. /**
  81. * 更新单个钩子处的插件
  82. */
  83. public function updateAddons($hook_name, $addons_name)
  84. {
  85. $o_addons = $this->where("name='{$hook_name}'")->getField('addons');
  86. if ($o_addons) {
  87. $o_addons = explode(',', $o_addons);
  88. }
  89. if ($o_addons) {
  90. $addons = array_merge($o_addons, $addons_name);
  91. $addons = array_unique($addons);
  92. } else {
  93. $addons = $addons_name;
  94. }
  95. $flag = $this->where("name='{$hook_name}'")
  96. ->setField('addons', implode(',', $addons));
  97. if (false === $flag) {
  98. $this->where("name='{$hook_name}'")
  99. ->setField('addons', implode(',', $o_addons));
  100. }
  101. return $flag;
  102. }
  103. /**
  104. * 去除插件所有钩子里对应的插件数据
  105. */
  106. public function removeHooks($addons_name)
  107. {
  108. $addons_class = get_addon_class($addons_name);
  109. if (!class_exists($addons_class)) {
  110. return false;
  111. }
  112. $methods = get_class_methods($addons_class);
  113. $hooks = $this->getField('name', true);
  114. $common = array_intersect($hooks, $methods);
  115. if ($common) {
  116. foreach ($common as $hook) {
  117. $flag = $this->removeAddons($hook, array($addons_name));
  118. if (false === $flag) {
  119. return false;
  120. }
  121. }
  122. }
  123. return true;
  124. }
  125. /**
  126. * 去除单个钩子里对应的插件数据
  127. */
  128. public function removeAddons($hook_name, $addons_name)
  129. {
  130. $o_addons = $this->where("name='{$hook_name}'")->getField('addons');
  131. $o_addons = explode(',', $o_addons);
  132. if ($o_addons) {
  133. $addons = array_diff($o_addons, $addons_name);
  134. } else {
  135. return true;
  136. }
  137. $flag = $this->where("name='{$hook_name}'")
  138. ->setField('addons', implode(',', $addons));
  139. if (false === $flag) {
  140. $this->where("name='{$hook_name}'")
  141. ->setField('addons', implode(',', $o_addons));
  142. }
  143. return $flag;
  144. }
  145. }