123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330 |
- <?php
- namespace app\admin\model\cms;
- use addons\cms\library\Service;
- use think\Exception;
- use think\Model;
- class Channel extends Model
- {
- // 表名
- protected $name = 'cms_channel';
- // 自动写入时间戳字段
- protected $autoWriteTimestamp = 'int';
- // 定义时间戳字段名
- protected $createTime = 'createtime';
- protected $updateTime = 'updatetime';
- // 追加属性
- protected $append = [
- 'type_text',
- 'status_text',
- 'url',
- 'fullurl',
- 'outlink',
- ];
- protected static $config = [];
- public function getOriginData()
- {
- return $this->origin;
- }
- public function getUrlAttr($value, $data)
- {
- return $this->buildUrl($value, $data);
- }
- public function getFullurlAttr($value, $data)
- {
- return $this->buildUrl($value, $data, true);
- }
- private function buildUrl($value, $data, $domain = false)
- {
- $diyname = isset($data['diyname']) && $data['diyname'] ? $data['diyname'] : $data['id'];
- $cateid = $data['id'] ?? 0;
- $catename = isset($data['diyname']) && $data['diyname'] ? $data['diyname'] : 'all';
- $time = $data['createtime'] ?? time();
- $vars = [
- ':id' => $data['id'],
- ':diyname' => $diyname,
- ':channel' => $cateid,
- ':catename' => $catename,
- ':cateid' => $cateid,
- ':year' => date("Y", $time),
- ':month' => date("m", $time),
- ':day' => date("d", $time)
- ];
- if (isset($data['type']) && isset($data['outlink']) && $data['type'] == 'link') {
- return $this->getAttr('outlink');
- }
- return addon_url('cms/channel/index', $vars, static::$config['urlsuffix'], $domain);
- }
- public function getOutlinkAttr($value, $data)
- {
- $indexUrl = $view_replace_str = config('view_replace_str.__PUBLIC__');
- $indexUrl = rtrim($indexUrl, '/');
- return str_replace('__INDEX__', $indexUrl, $value);
- }
- protected static function init()
- {
- $config = static::$config = get_addon_config('cms');
- self::beforeInsert(function ($row) {
- if ($row->getData('type') == 'link') {
- $row->model_id = 0;
- }
- $diyname = $row['diyname'] ?? '';
- if ($diyname) {
- $exists = Channel::getByDiyname($diyname);
- if ($exists) {
- throw new Exception("自定义URL名称已经存在");
- }
- }
- });
- self::beforeUpdate(function ($row) {
- if (isset($row['parent_id']) && $row['parent_id']) {
- $childrenIds = self::getChildrenIds($row['id'], true);
- if (in_array($row['parent_id'], $childrenIds)) {
- throw new Exception("上级栏目不能是其自身或子栏目");
- }
- }
- if (isset($row['diyname']) && $row['diyname']) {
- $exists = Channel::where('diyname', $row['diyname'])->where('id', '<>', $row['id'])->find();
- if ($exists) {
- throw new Exception("自定义URL名称已经存在");
- }
- }
- });
- self::beforeWrite(function ($row) {
- //在更新之前对数组进行处理
- foreach ($row->getData() as $k => $value) {
- if (is_array($value) && is_array(reset($value))) {
- $value = json_encode(self::getArrayData($value), JSON_UNESCAPED_UNICODE);
- } else {
- $value = is_array($value) ? implode(',', $value) : $value;
- }
- $row->setAttr($k, $value);
- }
- });
- self::afterInsert(function ($row) {
- //创建时自动添加权重值
- $pk = $row->getPk();
- $row->getQuery()->where($pk, $row[$pk])->update(['weigh' => $row[$pk]]);
- });
- self::afterDelete(function ($row) {
- //删除时,删除子节点,同时将所有相关文档移入回收站
- $childIds = self::getChildrenIds($row['id']);
- if ($childIds) {
- Channel::destroy(function ($query) use ($childIds) {
- $query->where('id', 'in', $childIds);
- });
- }
- $childIds[] = $row['id'];
- db('cms_archives')->where('channel_id', 'in', $childIds)->update(['deletetime' => time()]);
- });
- self::afterWrite(function ($row) use ($config) {
- $changed = $row->getChangedData();
- //隐藏时判断是否有子节点,有则隐藏
- if (isset($changed['status']) && $changed['status'] == 'hidden') {
- $childIds = self::getChildrenIds($row['id']);
- db('cms_channel')->where('id', 'in', $childIds)->update(['status' => 'hidden']);
- }
- //隐藏栏目显示时判断是否有子节点
- if (isset($changed['isnav']) && !$changed['isnav']) {
- $childIds = self::getChildrenIds($row['id']);
- db('cms_channel')->where('id', 'in', $childIds)->update(['isnav' => 0]);
- }
- //推送到熊掌号+百度站长
- if (isset($changed['status']) && $changed['status'] == 'normal') {
- if ($config['baidupush']) {
- $urls = [$row->fullurl];
- \think\Hook::listen("baidupush", $urls);
- }
- }
- //刷新栏目统计数据
- if (isset($changed['listtype']) || isset($changed['parent_id'])) {
- $origined = $row->getOriginData();
- $refreshIds = [$origined['parent_id'] ?? 0, $row['parent_id'] ?? 0, $row['id'] ?? 0];
- self::refreshItems($refreshIds);
- }
- //同步配置到子栏目
- if (isset($row['syncconfig'])) {
- $childIds = self::getChildrenIds($row['id']);
- $data = [
- 'channeltpl' => $row['channeltpl'],
- 'listtpl' => $row['listtpl'],
- 'showtpl' => $row['showtpl'],
- 'listtype' => $row['listtype'],
- 'pagesize' => $row['pagesize'],
- 'vip' => $row['vip'],
- ];
- db('cms_channel')->where('id', 'in', $childIds)->update($data);
- }
- });
- }
- public static function getTypeList()
- {
- return ['channel' => __('Channel'), 'list' => __('List'), 'link' => __('Link'), 'home_button' => __('Home Button'), 'footer_button' => __('Footer Button')];
- }
- public function getFlagList()
- {
- $config = get_addon_config('cms');
- return $config['flagtype'];
- }
- public static function getStatusList()
- {
- return ['normal' => __('Normal'), 'hidden' => __('Hidden')];
- }
- public static function getSecondaryList()
- {
- return ['normal' => __('Normal'), 'hidden' => __('Hidden')];
- }
- public static function getListtypeList()
- {
- return ['0' => __('自已和所有子级'), '1' => __('自己和一级子级'), '2' => __('仅自己'), '3' => __('仅包含一级子级(不含自己)'), '4' => __('仅包含所有子级(不含自己)')];
- }
- public function getTypeTextAttr($value, $data)
- {
- $value = $value ? $value : $data['type'];
- $list = $this->getTypeList();
- return isset($list[$value]) ? $list[$value] : '';
- }
- public function getStatusTextAttr($value, $data)
- {
- $value = $value ? $value : $data['status'];
- $list = $this->getStatusList();
- return isset($list[$value]) ? $list[$value] : '';
- }
- public function getLinkdataAttr($value, $data)
- {
- $result = [];
- if (isset($data['linktype']) && isset($data['linkid']) && $data['linktype'] && $data['linkid']) {
- $model = Service::getModelByType($data['linktype'], $data['linkid']);
- if ($model) {
- $result = [
- 'type' => $data['linktype'],
- 'source_id' => $data['linkid'],
- 'title' => $model['title'] ?? ($model['name'] ?? '未知'),
- 'url' => $model['url'] ?? '',
- ];
- }
- }
- return $result;
- }
- /**
- * 获取栏目的所有子节点ID,无缓存
- * @param int $id 栏目ID
- * @param bool $withself 是否包含自身
- * @return array
- */
- public static function getChildrenIds($id, $withself = false)
- {
- static $tree;
- if (!$tree) {
- $tree = \fast\Tree::instance();
- $tree->init(collection(Channel::order('weigh desc,id desc')->field('id,parent_id,name,type,diyname,status')->select())->toArray(), 'parent_id');
- }
- $childIds = $tree->getChildrenIds($id, $withself);
- return $childIds;
- }
- /**
- * 获取栏目的所有父节点ID,无缓存
- * @param int $id 栏目ID
- * @param bool $withself 是否包含自身
- * @return array
- */
- public static function getParentsIds($id, $withself = false)
- {
- static $tree;
- if (!$tree) {
- $tree = \fast\Tree::instance();
- $tree->init(collection(Channel::order('weigh desc,id desc')->field('id,parent_id,name,type,diyname,status')->select())->toArray(), 'parent_id');
- }
- $childIds = $tree->getParentsIds($id, $withself);
- return $childIds;
- }
- /**
- * 刷新栏目统计数据
- * @param mixed $ids 栏目ID集合
- * @return bool
- */
- public static function refreshItems($ids)
- {
- $ids = is_array($ids) ? $ids : explode(',', $ids);
- $ids = array_filter(array_unique($ids));
- try {
- $channelList = self::where('id', 'in', $ids)->select();
- foreach ($channelList as $index => $channel) {
- if ($channel['parent_id']) {
- $ids = array_merge($ids, self::getParentsIds($channel['id']));
- }
- }
- $ids = array_filter(array_unique($ids));
- $channelList = self::where('id', 'in', $ids)->select();
- foreach ($channelList as $index => $channel) {
- $count = Archives::where(function ($query) use ($channel) {
- //只统计当前栏目
- $query->where('channel_id', $channel['id']);
- //按栏目列表类型
- //$query->where(function ($query) use ($channel) {
- // if ($channel['listtype'] <= 2) {
- // $query->whereOr("channel_id", $channel['id']);
- // }
- // if ($channel['listtype'] == 1 || $channel['listtype'] == 3) {
- // $query->whereOr('channel_id', 'in', function ($query) use ($channel) {
- // $query->name("cms_channel")->where('parent_id', $channel['id'])->field("id");
- // });
- // }
- // if ($channel['listtype'] == 0 || $channel['listtype'] == 4) {
- // $childrenIds = self::getChildrenIds($channel['id'], false);
- // if ($childrenIds) {
- // $query->whereOr('channel_id', 'in', $childrenIds);
- // }
- // }
- //});
- //副栏目
- //$query->whereOr("(`channel_ids`!='' AND FIND_IN_SET('{$channel['id']}', `channel_ids`))");
- })
- ->where('status', 'normal')
- ->whereNull('deletetime')
- ->count();
- $channel->save(['items' => $count]);
- }
- } catch (\Exception $e) {
- \think\Log::record($e->getMessage());
- return false;
- }
- return true;
- }
- public function model()
- {
- return $this->belongsTo('Modelx', 'model_id')->setEagerlyType(0);
- }
- public function getSettingAttr($value, $data)
- {
- return is_array($value) ? $value : (array)json_decode($data['setting'], true);
- }
- }
|