Compare commits
18 Commits
master
...
zqx_branch
| Author | SHA1 | Date |
|---|---|---|
 pmluby46i
|
6b40a3433c | 5 months ago |
|
pmluby46i
|
8d505362a8 | 5 months ago |
|
pmluby46i
|
39620f728c | 5 months ago |
|
pmluby46i
|
b179b7d3fe | 5 months ago |
|
pmluby46i
|
83b2c1f8ff | 5 months ago |
|
pmluby46i
|
ef51e9cc82 | 5 months ago |
|
pmluby46i
|
2a0aa60997 | 5 months ago |
|
pmluby46i
|
a83b437725 | 5 months ago |
|
pmluby46i
|
a9bebf9570 | 5 months ago |
|
pmluby46i
|
db9227d788 | 5 months ago |
|
pmluby46i
|
d4871324e7 | 5 months ago |
|
pmluby46i
|
2f0cb7613d | 5 months ago |
|
pmluby46i
|
491a0fbb1d | 5 months ago |
|
pmluby46i
|
da297ae8f3 | 5 months ago |
|
pmluby46i
|
52c68d5444 | 5 months ago |
|
pmluby46i
|
d359a69da2 | 5 months ago |
|
pmluby46i
|
4daf23fee7 | 5 months ago |
|
pmluby46i
|
4709d3cfe1 | 6 months ago |
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -1 +0,0 @@
|
||||
default_app_config = 'djangoblog.apps.DjangoblogAppConfig'
|
||||
@ -1,64 +0,0 @@
|
||||
from django.contrib.admin import AdminSite
|
||||
from django.contrib.admin.models import LogEntry
|
||||
from django.contrib.sites.admin import SiteAdmin
|
||||
from django.contrib.sites.models import Site
|
||||
|
||||
from accounts.admin import *
|
||||
from blog.admin import *
|
||||
from blog.models import *
|
||||
from comments.admin import *
|
||||
from comments.models import *
|
||||
from djangoblog.logentryadmin import LogEntryAdmin
|
||||
from oauth.admin import *
|
||||
from oauth.models import *
|
||||
from owntracks.admin import *
|
||||
from owntracks.models import *
|
||||
from servermanager.admin import *
|
||||
from servermanager.models import *
|
||||
|
||||
|
||||
class DjangoBlogAdminSite(AdminSite):
|
||||
site_header = 'djangoblog administration'
|
||||
site_title = 'djangoblog site admin'
|
||||
|
||||
def __init__(self, name='admin'):
|
||||
super().__init__(name)
|
||||
|
||||
def has_permission(self, request):
|
||||
return request.user.is_superuser
|
||||
|
||||
# def get_urls(self):
|
||||
# urls = super().get_urls()
|
||||
# from django.urls import path
|
||||
# from blog.views import refresh_memcache
|
||||
#
|
||||
# my_urls = [
|
||||
# path('refresh/', self.admin_view(refresh_memcache), name="refresh"),
|
||||
# ]
|
||||
# return urls + my_urls
|
||||
|
||||
|
||||
admin_site = DjangoBlogAdminSite(name='admin')
|
||||
|
||||
admin_site.register(Article, ArticlelAdmin)
|
||||
admin_site.register(Category, CategoryAdmin)
|
||||
admin_site.register(Tag, TagAdmin)
|
||||
admin_site.register(Links, LinksAdmin)
|
||||
admin_site.register(SideBar, SideBarAdmin)
|
||||
admin_site.register(BlogSettings, BlogSettingsAdmin)
|
||||
|
||||
admin_site.register(commands, CommandsAdmin)
|
||||
admin_site.register(EmailSendLog, EmailSendLogAdmin)
|
||||
|
||||
admin_site.register(BlogUser, BlogUserAdmin)
|
||||
|
||||
admin_site.register(Comment, CommentAdmin)
|
||||
|
||||
admin_site.register(OAuthUser, OAuthUserAdmin)
|
||||
admin_site.register(OAuthConfig, OAuthConfigAdmin)
|
||||
|
||||
admin_site.register(OwnTrackLog, OwnTrackLogsAdmin)
|
||||
|
||||
admin_site.register(Site, SiteAdmin)
|
||||
|
||||
admin_site.register(LogEntry, LogEntryAdmin)
|
||||
@ -1,11 +0,0 @@
|
||||
from django.apps import AppConfig
|
||||
|
||||
class DjangoblogAppConfig(AppConfig):
|
||||
default_auto_field = 'django.db.models.BigAutoField'
|
||||
name = 'djangoblog'
|
||||
|
||||
def ready(self):
|
||||
super().ready()
|
||||
# Import and load plugins here
|
||||
from .plugin_manage.loader import load_plugins
|
||||
load_plugins()
|
||||
@ -1,6 +1,5 @@
|
||||
from django.apps import AppConfig
|
||||
|
||||
#zr 评论应用配置类
|
||||
|
||||
class CommentsConfig(AppConfig):
|
||||
#zr 定义应用名称
|
||||
name = 'comments'
|
||||
name = 'comments'
|
||||
|
||||
@ -1,183 +0,0 @@
|
||||
from django.utils.encoding import force_str
|
||||
from elasticsearch_dsl import Q
|
||||
from haystack.backends import BaseEngine, BaseSearchBackend, BaseSearchQuery, log_query
|
||||
from haystack.forms import ModelSearchForm
|
||||
from haystack.models import SearchResult
|
||||
from haystack.utils import log as logging
|
||||
|
||||
from blog.documents import ArticleDocument, ArticleDocumentManager
|
||||
from blog.models import Article
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class ElasticSearchBackend(BaseSearchBackend):
|
||||
def __init__(self, connection_alias, **connection_options):
|
||||
super(
|
||||
ElasticSearchBackend,
|
||||
self).__init__(
|
||||
connection_alias,
|
||||
**connection_options)
|
||||
self.manager = ArticleDocumentManager()
|
||||
self.include_spelling = True
|
||||
|
||||
def _get_models(self, iterable):
|
||||
models = iterable if iterable and iterable[0] else Article.objects.all()
|
||||
docs = self.manager.convert_to_doc(models)
|
||||
return docs
|
||||
|
||||
def _create(self, models):
|
||||
self.manager.create_index()
|
||||
docs = self._get_models(models)
|
||||
self.manager.rebuild(docs)
|
||||
|
||||
def _delete(self, models):
|
||||
for m in models:
|
||||
m.delete()
|
||||
return True
|
||||
|
||||
def _rebuild(self, models):
|
||||
models = models if models else Article.objects.all()
|
||||
docs = self.manager.convert_to_doc(models)
|
||||
self.manager.update_docs(docs)
|
||||
|
||||
def update(self, index, iterable, commit=True):
|
||||
|
||||
models = self._get_models(iterable)
|
||||
self.manager.update_docs(models)
|
||||
|
||||
def remove(self, obj_or_string):
|
||||
models = self._get_models([obj_or_string])
|
||||
self._delete(models)
|
||||
|
||||
def clear(self, models=None, commit=True):
|
||||
self.remove(None)
|
||||
|
||||
@staticmethod
|
||||
def get_suggestion(query: str) -> str:
|
||||
"""获取推荐词, 如果没有找到添加原搜索词"""
|
||||
|
||||
search = ArticleDocument.search() \
|
||||
.query("match", body=query) \
|
||||
.suggest('suggest_search', query, term={'field': 'body'}) \
|
||||
.execute()
|
||||
|
||||
keywords = []
|
||||
for suggest in search.suggest.suggest_search:
|
||||
if suggest["options"]:
|
||||
keywords.append(suggest["options"][0]["text"])
|
||||
else:
|
||||
keywords.append(suggest["text"])
|
||||
|
||||
return ' '.join(keywords)
|
||||
|
||||
@log_query
|
||||
def search(self, query_string, **kwargs):
|
||||
logger.info('search query_string:' + query_string)
|
||||
|
||||
start_offset = kwargs.get('start_offset')
|
||||
end_offset = kwargs.get('end_offset')
|
||||
|
||||
# 推荐词搜索
|
||||
if getattr(self, "is_suggest", None):
|
||||
suggestion = self.get_suggestion(query_string)
|
||||
else:
|
||||
suggestion = query_string
|
||||
|
||||
q = Q('bool',
|
||||
should=[Q('match', body=suggestion), Q('match', title=suggestion)],
|
||||
minimum_should_match="70%")
|
||||
|
||||
search = ArticleDocument.search() \
|
||||
.query('bool', filter=[q]) \
|
||||
.filter('term', status='p') \
|
||||
.filter('term', type='a') \
|
||||
.source(False)[start_offset: end_offset]
|
||||
|
||||
results = search.execute()
|
||||
hits = results['hits'].total
|
||||
raw_results = []
|
||||
for raw_result in results['hits']['hits']:
|
||||
app_label = 'blog'
|
||||
model_name = 'Article'
|
||||
additional_fields = {}
|
||||
|
||||
result_class = SearchResult
|
||||
|
||||
result = result_class(
|
||||
app_label,
|
||||
model_name,
|
||||
raw_result['_id'],
|
||||
raw_result['_score'],
|
||||
**additional_fields)
|
||||
raw_results.append(result)
|
||||
facets = {}
|
||||
spelling_suggestion = None if query_string == suggestion else suggestion
|
||||
|
||||
return {
|
||||
'results': raw_results,
|
||||
'hits': hits,
|
||||
'facets': facets,
|
||||
'spelling_suggestion': spelling_suggestion,
|
||||
}
|
||||
|
||||
|
||||
class ElasticSearchQuery(BaseSearchQuery):
|
||||
def _convert_datetime(self, date):
|
||||
if hasattr(date, 'hour'):
|
||||
return force_str(date.strftime('%Y%m%d%H%M%S'))
|
||||
else:
|
||||
return force_str(date.strftime('%Y%m%d000000'))
|
||||
|
||||
def clean(self, query_fragment):
|
||||
"""
|
||||
Provides a mechanism for sanitizing user input before presenting the
|
||||
value to the backend.
|
||||
|
||||
Whoosh 1.X differs here in that you can no longer use a backslash
|
||||
to escape reserved characters. Instead, the whole word should be
|
||||
quoted.
|
||||
"""
|
||||
words = query_fragment.split()
|
||||
cleaned_words = []
|
||||
|
||||
for word in words:
|
||||
if word in self.backend.RESERVED_WORDS:
|
||||
word = word.replace(word, word.lower())
|
||||
|
||||
for char in self.backend.RESERVED_CHARACTERS:
|
||||
if char in word:
|
||||
word = "'%s'" % word
|
||||
break
|
||||
|
||||
cleaned_words.append(word)
|
||||
|
||||
return ' '.join(cleaned_words)
|
||||
|
||||
def build_query_fragment(self, field, filter_type, value):
|
||||
return value.query_string
|
||||
|
||||
def get_count(self):
|
||||
results = self.get_results()
|
||||
return len(results) if results else 0
|
||||
|
||||
def get_spelling_suggestion(self, preferred_query=None):
|
||||
return self._spelling_suggestion
|
||||
|
||||
def build_params(self, spelling_query=None):
|
||||
kwargs = super(ElasticSearchQuery, self).build_params(spelling_query=spelling_query)
|
||||
return kwargs
|
||||
|
||||
|
||||
class ElasticSearchModelSearchForm(ModelSearchForm):
|
||||
|
||||
def search(self):
|
||||
# 是否建议搜索
|
||||
self.searchqueryset.query.backend.is_suggest = self.data.get("is_suggest") != "no"
|
||||
sqs = super().search()
|
||||
return sqs
|
||||
|
||||
|
||||
class ElasticSearchEngine(BaseEngine):
|
||||
backend = ElasticSearchBackend
|
||||
query = ElasticSearchQuery
|
||||
@ -1,40 +0,0 @@
|
||||
from django.contrib.auth import get_user_model
|
||||
from django.contrib.syndication.views import Feed
|
||||
from django.utils import timezone
|
||||
from django.utils.feedgenerator import Rss201rev2Feed
|
||||
|
||||
from blog.models import Article
|
||||
from djangoblog.utils import CommonMarkdown
|
||||
|
||||
|
||||
class DjangoBlogFeed(Feed):
|
||||
feed_type = Rss201rev2Feed
|
||||
|
||||
description = '大巧无工,重剑无锋.'
|
||||
title = "且听风吟 大巧无工,重剑无锋. "
|
||||
link = "/feed/"
|
||||
|
||||
def author_name(self):
|
||||
return get_user_model().objects.first().nickname
|
||||
|
||||
def author_link(self):
|
||||
return get_user_model().objects.first().get_absolute_url()
|
||||
|
||||
def items(self):
|
||||
return Article.objects.filter(type='a', status='p').order_by('-pub_time')[:5]
|
||||
|
||||
def item_title(self, item):
|
||||
return item.title
|
||||
|
||||
def item_description(self, item):
|
||||
return CommonMarkdown.get_markdown(item.body)
|
||||
|
||||
def feed_copyright(self):
|
||||
now = timezone.now()
|
||||
return "Copyright© {year} 且听风吟".format(year=now.year)
|
||||
|
||||
def item_link(self, item):
|
||||
return item.get_absolute_url()
|
||||
|
||||
def item_guid(self, item):
|
||||
return
|
||||
@ -1,91 +0,0 @@
|
||||
from django.contrib import admin
|
||||
from django.contrib.admin.models import DELETION
|
||||
from django.contrib.contenttypes.models import ContentType
|
||||
from django.urls import reverse, NoReverseMatch
|
||||
from django.utils.encoding import force_str
|
||||
from django.utils.html import escape
|
||||
from django.utils.safestring import mark_safe
|
||||
from django.utils.translation import gettext_lazy as _
|
||||
|
||||
|
||||
class LogEntryAdmin(admin.ModelAdmin):
|
||||
list_filter = [
|
||||
'content_type'
|
||||
]
|
||||
|
||||
search_fields = [
|
||||
'object_repr',
|
||||
'change_message'
|
||||
]
|
||||
|
||||
list_display_links = [
|
||||
'action_time',
|
||||
'get_change_message',
|
||||
]
|
||||
list_display = [
|
||||
'action_time',
|
||||
'user_link',
|
||||
'content_type',
|
||||
'object_link',
|
||||
'get_change_message',
|
||||
]
|
||||
|
||||
def has_add_permission(self, request):
|
||||
return False
|
||||
|
||||
def has_change_permission(self, request, obj=None):
|
||||
return (
|
||||
request.user.is_superuser or
|
||||
request.user.has_perm('admin.change_logentry')
|
||||
) and request.method != 'POST'
|
||||
|
||||
def has_delete_permission(self, request, obj=None):
|
||||
return False
|
||||
|
||||
def object_link(self, obj):
|
||||
object_link = escape(obj.object_repr)
|
||||
content_type = obj.content_type
|
||||
|
||||
if obj.action_flag != DELETION and content_type is not None:
|
||||
# try returning an actual link instead of object repr string
|
||||
try:
|
||||
url = reverse(
|
||||
'admin:{}_{}_change'.format(content_type.app_label,
|
||||
content_type.model),
|
||||
args=[obj.object_id]
|
||||
)
|
||||
object_link = '<a href="{}">{}</a>'.format(url, object_link)
|
||||
except NoReverseMatch:
|
||||
pass
|
||||
return mark_safe(object_link)
|
||||
|
||||
object_link.admin_order_field = 'object_repr'
|
||||
object_link.short_description = _('object')
|
||||
|
||||
def user_link(self, obj):
|
||||
content_type = ContentType.objects.get_for_model(type(obj.user))
|
||||
user_link = escape(force_str(obj.user))
|
||||
try:
|
||||
# try returning an actual link instead of object repr string
|
||||
url = reverse(
|
||||
'admin:{}_{}_change'.format(content_type.app_label,
|
||||
content_type.model),
|
||||
args=[obj.user.pk]
|
||||
)
|
||||
user_link = '<a href="{}">{}</a>'.format(url, user_link)
|
||||
except NoReverseMatch:
|
||||
pass
|
||||
return mark_safe(user_link)
|
||||
|
||||
user_link.admin_order_field = 'user'
|
||||
user_link.short_description = _('user')
|
||||
|
||||
def get_queryset(self, request):
|
||||
queryset = super(LogEntryAdmin, self).get_queryset(request)
|
||||
return queryset.prefetch_related('content_type')
|
||||
|
||||
def get_actions(self, request):
|
||||
actions = super(LogEntryAdmin, self).get_actions(request)
|
||||
if 'delete_selected' in actions:
|
||||
del actions['delete_selected']
|
||||
return actions
|
||||
@ -1,26 +1,7 @@
|
||||
from django.contrib import admin
|
||||
from .models import OwnTrackLog
|
||||
|
||||
# Register your models here.
|
||||
|
||||
@admin.register(OwnTrackLog)
|
||||
class OwnTrackLogAdmin(admin.ModelAdmin):
|
||||
"""
|
||||
OwnTrackLog模型管理配置
|
||||
"""
|
||||
list_display = ('tid', 'lat', 'lon', 'creation_time', 'accuracy')
|
||||
list_filter = ('tid', 'creation_time')
|
||||
search_fields = ('tid',)
|
||||
date_hierarchy = 'creation_time'
|
||||
readonly_fields = ('creation_time',)
|
||||
fieldsets = (
|
||||
('基本信息', {
|
||||
'fields': ('tid', 'creation_time')
|
||||
}),
|
||||
('位置信息', {
|
||||
'fields': ('lat', 'lon', 'accuracy', 'battery')
|
||||
}),
|
||||
)
|
||||
|
||||
def get_queryset(self, request):
|
||||
"""优化查询，减少数据库访问"""
|
||||
return super().get_queryset(request).select_related()
|
||||
class OwnTrackLogsAdmin(admin.ModelAdmin):
|
||||
pass
|
||||
|
||||
@ -1,36 +0,0 @@
|
||||
# 高德地图API配置
|
||||
AMAP_API_KEY = os.getenv('AMAP_API_KEY', 'your-default-key-here')
|
||||
|
||||
# 缓存配置
|
||||
CACHES = {
|
||||
'default': {
|
||||
'BACKEND': 'django.core.cache.backends.redis.RedisCache',
|
||||
'LOCATION': 'redis://127.0.0.1:6379/1',
|
||||
}
|
||||
}
|
||||
#management / commands / cleanup_old_locations.py
|
||||
from django.core.management.base import BaseCommand
|
||||
from django.utils import timezone
|
||||
from owntracks.models import OwnTrackLog
|
||||
|
||||
|
||||
class Command(BaseCommand):
|
||||
help = '清理过期的位置记录'
|
||||
|
||||
def add_arguments(self, parser):
|
||||
parser.add_argument(
|
||||
'--days',
|
||||
type=int,
|
||||
default=365,
|
||||
help='保留多少天内的数据'
|
||||
)
|
||||
|
||||
def handle(self, *args, **options):
|
||||
cutoff_date = timezone.now() - timezone.timedelta(days=options['days'])
|
||||
deleted_count, _ = OwnTrackLog.objects.filter(
|
||||
creation_time__lt=cutoff_date
|
||||
).delete()
|
||||
|
||||
self.stdout.write(
|
||||
self.style.SUCCESS(f'成功删除 {deleted_count} 条过期记录')
|
||||
)
|
||||
@ -1,194 +0,0 @@
|
||||
import logging
|
||||
from pathlib import Path
|
||||
|
||||
from django.template import TemplateDoesNotExist
|
||||
from django.template.loader import render_to_string
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class BasePlugin:
|
||||
# 插件元数据
|
||||
PLUGIN_NAME = None
|
||||
PLUGIN_DESCRIPTION = None
|
||||
PLUGIN_VERSION = None
|
||||
PLUGIN_AUTHOR = None
|
||||
|
||||
# 插件配置
|
||||
SUPPORTED_POSITIONS = [] # 支持的显示位置
|
||||
DEFAULT_PRIORITY = 100 # 默认优先级（数字越小优先级越高）
|
||||
POSITION_PRIORITIES = {} # 各位置的优先级 {'sidebar': 50, 'article_bottom': 80}
|
||||
|
||||
def __init__(self):
|
||||
if not all([self.PLUGIN_NAME, self.PLUGIN_DESCRIPTION, self.PLUGIN_VERSION]):
|
||||
raise ValueError("Plugin metadata (PLUGIN_NAME, PLUGIN_DESCRIPTION, PLUGIN_VERSION) must be defined.")
|
||||
|
||||
# 设置插件路径
|
||||
self.plugin_dir = self._get_plugin_directory()
|
||||
self.plugin_slug = self._get_plugin_slug()
|
||||
|
||||
self.init_plugin()
|
||||
self.register_hooks()
|
||||
|
||||
def _get_plugin_directory(self):
|
||||
"""获取插件目录路径"""
|
||||
import inspect
|
||||
plugin_file = inspect.getfile(self.__class__)
|
||||
return Path(plugin_file).parent
|
||||
|
||||
def _get_plugin_slug(self):
|
||||
"""获取插件标识符（目录名）"""
|
||||
return self.plugin_dir.name
|
||||
|
||||
def init_plugin(self):
|
||||
"""
|
||||
插件初始化逻辑
|
||||
子类可以重写此方法来实现特定的初始化操作
|
||||
"""
|
||||
logger.info(f'{self.PLUGIN_NAME} initialized.')
|
||||
|
||||
def register_hooks(self):
|
||||
"""
|
||||
注册插件钩子
|
||||
子类可以重写此方法来注册特定的钩子
|
||||
"""
|
||||
pass
|
||||
|
||||
# === 位置渲染系统 ===
|
||||
def render_position_widget(self, position, context, **kwargs):
|
||||
"""
|
||||
根据位置渲染插件组件
|
||||
|
||||
Args:
|
||||
position: 位置标识
|
||||
context: 模板上下文
|
||||
**kwargs: 额外参数
|
||||
|
||||
Returns:
|
||||
dict: {'html': 'HTML内容', 'priority': 优先级} 或 None
|
||||
"""
|
||||
if position not in self.SUPPORTED_POSITIONS:
|
||||
return None
|
||||
|
||||
# 检查条件显示
|
||||
if not self.should_display(position, context, **kwargs):
|
||||
return None
|
||||
|
||||
# 调用具体的位置渲染方法
|
||||
method_name = f'render_{position}_widget'
|
||||
if hasattr(self, method_name):
|
||||
html = getattr(self, method_name)(context, **kwargs)
|
||||
if html:
|
||||
priority = self.POSITION_PRIORITIES.get(position, self.DEFAULT_PRIORITY)
|
||||
return {
|
||||
'html': html,
|
||||
'priority': priority,
|
||||
'plugin_name': self.PLUGIN_NAME
|
||||
}
|
||||
|
||||
return None
|
||||
|
||||
def should_display(self, position, context, **kwargs):
|
||||
"""
|
||||
判断插件是否应该在指定位置显示
|
||||
子类可重写此方法实现条件显示逻辑
|
||||
|
||||
Args:
|
||||
position: 位置标识
|
||||
context: 模板上下文
|
||||
**kwargs: 额外参数
|
||||
|
||||
Returns:
|
||||
bool: 是否显示
|
||||
"""
|
||||
return True
|
||||
|
||||
# === 各位置渲染方法 - 子类重写 ===
|
||||
def render_sidebar_widget(self, context, **kwargs):
|
||||
"""渲染侧边栏组件"""
|
||||
return None
|
||||
|
||||
def render_article_bottom_widget(self, context, **kwargs):
|
||||
"""渲染文章底部组件"""
|
||||
return None
|
||||
|
||||
def render_article_top_widget(self, context, **kwargs):
|
||||
"""渲染文章顶部组件"""
|
||||
return None
|
||||
|
||||
def render_header_widget(self, context, **kwargs):
|
||||
"""渲染页头组件"""
|
||||
return None
|
||||
|
||||
def render_footer_widget(self, context, **kwargs):
|
||||
"""渲染页脚组件"""
|
||||
return None
|
||||
|
||||
def render_comment_before_widget(self, context, **kwargs):
|
||||
"""渲染评论前组件"""
|
||||
return None
|
||||
|
||||
def render_comment_after_widget(self, context, **kwargs):
|
||||
"""渲染评论后组件"""
|
||||
return None
|
||||
|
||||
# === 模板系统 ===
|
||||
def render_template(self, template_name, context=None):
|
||||
"""
|
||||
渲染插件模板
|
||||
|
||||
Args:
|
||||
template_name: 模板文件名
|
||||
context: 模板上下文
|
||||
|
||||
Returns:
|
||||
HTML字符串
|
||||
"""
|
||||
if context is None:
|
||||
context = {}
|
||||
|
||||
template_path = f"plugins/{self.plugin_slug}/{template_name}"
|
||||
|
||||
try:
|
||||
return render_to_string(template_path, context)
|
||||
except TemplateDoesNotExist:
|
||||
logger.warning(f"Plugin template not found: {template_path}")
|
||||
return ""
|
||||
|
||||
# === 静态资源系统 ===
|
||||
def get_static_url(self, static_file):
|
||||
"""获取插件静态文件URL"""
|
||||
from django.templatetags.static import static
|
||||
return static(f"{self.plugin_slug}/static/{self.plugin_slug}/{static_file}")
|
||||
|
||||
def get_css_files(self):
|
||||
"""获取插件CSS文件列表"""
|
||||
return []
|
||||
|
||||
def get_js_files(self):
|
||||
"""获取插件JavaScript文件列表"""
|
||||
return []
|
||||
|
||||
def get_head_html(self, context=None):
|
||||
"""获取需要插入到<head>中的HTML内容"""
|
||||
return ""
|
||||
|
||||
def get_body_html(self, context=None):
|
||||
"""获取需要插入到<body>底部的HTML内容"""
|
||||
return ""
|
||||
|
||||
def get_plugin_info(self):
|
||||
"""
|
||||
获取插件信息
|
||||
:return: 包含插件元数据的字典
|
||||
"""
|
||||
return {
|
||||
'name': self.PLUGIN_NAME,
|
||||
'description': self.PLUGIN_DESCRIPTION,
|
||||
'version': self.PLUGIN_VERSION,
|
||||
'author': self.PLUGIN_AUTHOR,
|
||||
'slug': self.plugin_slug,
|
||||
'directory': str(self.plugin_dir),
|
||||
'supported_positions': self.SUPPORTED_POSITIONS,
|
||||
'priorities': self.POSITION_PRIORITIES
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
ARTICLE_DETAIL_LOAD = 'article_detail_load'
|
||||
ARTICLE_CREATE = 'article_create'
|
||||
ARTICLE_UPDATE = 'article_update'
|
||||
ARTICLE_DELETE = 'article_delete'
|
||||
|
||||
ARTICLE_CONTENT_HOOK_NAME = "the_content"
|
||||
|
||||
# 位置钩子常量
|
||||
POSITION_HOOKS = {
|
||||
'article_top': 'article_top_widgets',
|
||||
'article_bottom': 'article_bottom_widgets',
|
||||
'sidebar': 'sidebar_widgets',
|
||||
'header': 'header_widgets',
|
||||
'footer': 'footer_widgets',
|
||||
'comment_before': 'comment_before_widgets',
|
||||
'comment_after': 'comment_after_widgets',
|
||||
}
|
||||
|
||||
# 资源注入钩子
|
||||
HEAD_RESOURCES_HOOK = 'head_resources'
|
||||
BODY_RESOURCES_HOOK = 'body_resources'
|
||||
|
||||
@ -1,44 +0,0 @@
|
||||
import logging
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
_hooks = {}
|
||||
|
||||
|
||||
def register(hook_name: str, callback: callable):
|
||||
"""
|
||||
注册一个钩子回调。
|
||||
"""
|
||||
if hook_name not in _hooks:
|
||||
_hooks[hook_name] = []
|
||||
_hooks[hook_name].append(callback)
|
||||
logger.debug(f"Registered hook '{hook_name}' with callback '{callback.__name__}'")
|
||||
|
||||
|
||||
def run_action(hook_name: str, *args, **kwargs):
|
||||
"""
|
||||
执行一个 Action Hook。
|
||||
它会按顺序执行所有注册到该钩子上的回调函数。
|
||||
"""
|
||||
if hook_name in _hooks:
|
||||
logger.debug(f"Running action hook '{hook_name}'")
|
||||
for callback in _hooks[hook_name]:
|
||||
try:
|
||||
callback(*args, **kwargs)
|
||||
except Exception as e:
|
||||
logger.error(f"Error running action hook '{hook_name}' callback '{callback.__name__}': {e}", exc_info=True)
|
||||
|
||||
|
||||
def apply_filters(hook_name: str, value, *args, **kwargs):
|
||||
"""
|
||||
执行一个 Filter Hook。
|
||||
它会把 value 依次传递给所有注册的回调函数进行处理。
|
||||
"""
|
||||
if hook_name in _hooks:
|
||||
logger.debug(f"Applying filter hook '{hook_name}'")
|
||||
for callback in _hooks[hook_name]:
|
||||
try:
|
||||
value = callback(value, *args, **kwargs)
|
||||
except Exception as e:
|
||||
logger.error(f"Error applying filter hook '{hook_name}' callback '{callback.__name__}': {e}", exc_info=True)
|
||||
return value
|
||||
@ -1,64 +0,0 @@
|
||||
import os
|
||||
import logging
|
||||
from django.conf import settings
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
# 全局插件注册表
|
||||
_loaded_plugins = []
|
||||
|
||||
def load_plugins():
|
||||
"""
|
||||
Dynamically loads and initializes plugins from the 'plugins' directory.
|
||||
This function is intended to be called when the Django app registry is ready.
|
||||
"""
|
||||
global _loaded_plugins
|
||||
_loaded_plugins = []
|
||||
|
||||
for plugin_name in settings.ACTIVE_PLUGINS:
|
||||
plugin_path = os.path.join(settings.PLUGINS_DIR, plugin_name)
|
||||
if os.path.isdir(plugin_path) and os.path.exists(os.path.join(plugin_path, 'plugin.py')):
|
||||
try:
|
||||
# 导入插件模块
|
||||
plugin_module = __import__(f'plugins.{plugin_name}.plugin', fromlist=['plugin'])
|
||||
|
||||
# 获取插件实例
|
||||
if hasattr(plugin_module, 'plugin'):
|
||||
plugin_instance = plugin_module.plugin
|
||||
_loaded_plugins.append(plugin_instance)
|
||||
logger.info(f"Successfully loaded plugin: {plugin_name} - {plugin_instance.PLUGIN_NAME}")
|
||||
else:
|
||||
logger.warning(f"Plugin {plugin_name} does not have 'plugin' instance")
|
||||
|
||||
except ImportError as e:
|
||||
logger.error(f"Failed to import plugin: {plugin_name}", exc_info=e)
|
||||
except AttributeError as e:
|
||||
logger.error(f"Failed to get plugin instance: {plugin_name}", exc_info=e)
|
||||
except Exception as e:
|
||||
logger.error(f"Unexpected error loading plugin: {plugin_name}", exc_info=e)
|
||||
|
||||
def get_loaded_plugins():
|
||||
"""获取所有已加载的插件"""
|
||||
return _loaded_plugins
|
||||
|
||||
def get_plugin_by_name(plugin_name):
|
||||
"""根据名称获取插件"""
|
||||
for plugin in _loaded_plugins:
|
||||
if plugin.plugin_slug == plugin_name:
|
||||
return plugin
|
||||
return None
|
||||
|
||||
def get_plugin_by_slug(plugin_slug):
|
||||
"""根据slug获取插件"""
|
||||
for plugin in _loaded_plugins:
|
||||
if plugin.plugin_slug == plugin_slug:
|
||||
return plugin
|
||||
return None
|
||||
|
||||
def get_plugins_info():
|
||||
"""获取所有插件的信息"""
|
||||
return [plugin.get_plugin_info() for plugin in _loaded_plugins]
|
||||
|
||||
def get_plugins_by_position(position):
|
||||
"""获取支持指定位置的插件"""
|
||||
return [plugin for plugin in _loaded_plugins if position in plugin.SUPPORTED_POSITIONS]
|
||||
@ -1,59 +0,0 @@
|
||||
from django.contrib.sitemaps import Sitemap
|
||||
from django.urls import reverse
|
||||
|
||||
from blog.models import Article, Category, Tag
|
||||
|
||||
|
||||
class StaticViewSitemap(Sitemap):
|
||||
priority = 0.5
|
||||
changefreq = 'daily'
|
||||
|
||||
def items(self):
|
||||
return ['blog:index', ]
|
||||
|
||||
def location(self, item):
|
||||
return reverse(item)
|
||||
|
||||
|
||||
class ArticleSiteMap(Sitemap):
|
||||
changefreq = "monthly"
|
||||
priority = "0.6"
|
||||
|
||||
def items(self):
|
||||
return Article.objects.filter(status='p')
|
||||
|
||||
def lastmod(self, obj):
|
||||
return obj.last_modify_time
|
||||
|
||||
|
||||
class CategorySiteMap(Sitemap):
|
||||
changefreq = "Weekly"
|
||||
priority = "0.6"
|
||||
|
||||
def items(self):
|
||||
return Category.objects.all()
|
||||
|
||||
def lastmod(self, obj):
|
||||
return obj.last_modify_time
|
||||
|
||||
|
||||
class TagSiteMap(Sitemap):
|
||||
changefreq = "Weekly"
|
||||
priority = "0.3"
|
||||
|
||||
def items(self):
|
||||
return Tag.objects.all()
|
||||
|
||||
def lastmod(self, obj):
|
||||
return obj.last_modify_time
|
||||
|
||||
|
||||
class UserSiteMap(Sitemap):
|
||||
changefreq = "Weekly"
|
||||
priority = "0.3"
|
||||
|
||||
def items(self):
|
||||
return list(set(map(lambda x: x.author, Article.objects.all())))
|
||||
|
||||
def lastmod(self, obj):
|
||||
return obj.date_joined
|
||||
@ -1,21 +0,0 @@
|
||||
import logging
|
||||
|
||||
import requests
|
||||
from django.conf import settings
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class SpiderNotify():
|
||||
@staticmethod
|
||||
def baidu_notify(urls):
|
||||
try:
|
||||
data = '\n'.join(urls)
|
||||
result = requests.post(settings.BAIDU_NOTIFY_URL, data=data)
|
||||
logger.info(result.text)
|
||||
except Exception as e:
|
||||
logger.error(e)
|
||||
|
||||
@staticmethod
|
||||
def notify(url):
|
||||
SpiderNotify.baidu_notify(url)
|
||||
@ -1,32 +0,0 @@
|
||||
from django.test import TestCase
|
||||
|
||||
from djangoblog.utils import *
|
||||
|
||||
|
||||
class DjangoBlogTest(TestCase):
|
||||
def setUp(self):
|
||||
pass
|
||||
|
||||
def test_utils(self):
|
||||
md5 = get_sha256('test')
|
||||
self.assertIsNotNone(md5)
|
||||
c = CommonMarkdown.get_markdown('''
|
||||
# Title1
|
||||
|
||||
```python
|
||||
import os
|
||||
```
|
||||
|
||||
[url](https://www.lylinux.net/)
|
||||
|
||||
[ddd](http://www.baidu.com)
|
||||
|
||||
|
||||
''')
|
||||
self.assertIsNotNone(c)
|
||||
d = {
|
||||
'd': 'key1',
|
||||
'd2': 'key2'
|
||||
}
|
||||
data = parse_dict_to_url(d)
|
||||
self.assertIsNotNone(data)
|
||||
File diff suppressed because it is too large
Load Diff
@ -1,16 +0,0 @@
|
||||
"""
|
||||
WSGI config for djangoblog project.
|
||||
|
||||
It exposes the WSGI callable as a module-level variable named ``application``.
|
||||
|
||||
For more information on this file, see
|
||||
https://docs.djangoproject.com/en/1.10/howto/deployment/wsgi/
|
||||
"""
|
||||
|
||||
import os
|
||||
|
||||
from django.core.wsgi import get_wsgi_application
|
||||
|
||||
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "djangoblog.settings")
|
||||
|
||||
application = get_wsgi_application()
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue