.idea/.gitignore

@@ -0,0 +1,8 @@
+# 默认忽略的文件
+/shelf/
+/workspace.xml
+# 基于编辑器的 HTTP 客户端请求
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

.idea/DjangoBlog.iml

@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="FacetManager">
+    <facet type="django" name="Django">
+      <configuration>
+        <option name="rootFolder" value="$MODULE_DIR$/src" />
+        <option name="settingsModule" value="settings.py" />
+        <option name="manageScript" value="$MODULE_DIR$/src/manage.py" />
+        <option name="environment" value="&lt;map/&gt;" />
+        <option name="doNotUseTestRunner" value="false" />
+        <option name="trackFilePattern" value="migrations" />
+      </configuration>
+    </facet>
+  </component>
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+    </content>
+    <orderEntry type="jdk" jdkName="Python 3.10 (DjangoBlog)" jdkType="Python SDK" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+  <component name="PyDocumentationSettings">
+    <option name="format" value="PLAIN" />
+    <option name="myDocStringFormat" value="Plain" />
+  </component>
+  <component name="TemplatesService">
+    <option name="TEMPLATE_CONFIGURATION" value="Jinja2" />
+    <option name="TEMPLATE_FOLDERS">
+      <list>
+        <option value="$MODULE_DIR$/src/templates" />
+      </list>
+    </option>
+  </component>
+  <component name="TestRunnerService">
+    <option name="PROJECT_TEST_RUNNER" value="py.test" />
+  </component>
+</module>

.idea/inspectionProfiles/profiles_settings.xml

@@ -0,0 +1,6 @@
+<component name="InspectionProjectProfileManager">
+  <settings>
+    <option name="USE_PROJECT_PROFILE" value="false" />
+    <version value="1.0" />
+  </settings>
+</component>

.idea/misc.xml

@@ -0,0 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.10 (DjangoBlog)" project-jdk-type="Python SDK" />
+</project>

.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/DjangoBlog.iml" filepath="$PROJECT_DIR$/.idea/DjangoBlog.iml" />
+    </modules>
+  </component>
+</project>

.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="" vcs="Git" />
+  </component>
+</project>

README.md

@@ -1,2 +0,0 @@
-# software_DjangoBlog
-

src/.dockerignore

@@ -8,4 +8,5 @@ settings_production.py
 *.md
 docs/
 logs/
-static/
+static/
+.github/

src/.gitignore

@@ -62,7 +62,6 @@ target/
 # http://www.jetbrains.com/pycharm/webhelp/project.html
 .idea
 .iml
-static/
 # virtualenv
 venv/
 
@@ -78,3 +77,4 @@ uploads/
 settings_production.py
 werobot_session.db
 bin/datas/
+myenv/

src/DjangoBlog

@@ -0,0 +1 @@
+Subproject commit ef67f8db4fafce7e84c0e7bae23d5c5bf8869fac

src/DjangoBlog-master/.coveragerc

@@ -1,10 +0,0 @@
-[run]
-source = .
-include = *.py
-omit =
-    *migrations*
-    *tests*
-    *.html
-    *whoosh_cn_backend*
-    *settings.py*
-    *venv*

src/DjangoBlog-master/.github/ISSUE_TEMPLATE.md

@@ -1,18 +0,0 @@
-<!--
-如果你不认真勾选下面的内容，我可能会直接关闭你的 Issue。
-提问之前，建议先阅读 https://github.com/ruby-china/How-To-Ask-Questions-The-Smart-Way
--->
-
-**我确定我已经查看了** (标注`[ ]`为`[x]`)
-
-- [ ] [DjangoBlog的readme](https://github.com/liangliangyy/DjangoBlog/blob/master/README.md)
-- [ ] [配置说明](https://github.com/liangliangyy/DjangoBlog/blob/master/bin/config.md)
-- [ ] [其他 Issues](https://github.com/liangliangyy/DjangoBlog/issues)
-
-----
-
-**我要申请**  (标注`[ ]`为`[x]`)
-
-- [ ] BUG 反馈
-- [ ] 添加新的特性或者功能
-- [ ] 请求技术支持

src/DjangoBlog-master/.github/workflows/codeql-analysis.yml

@@ -1,47 +0,0 @@
-name: "CodeQL"
-
-on:
-  push:
-    branches:
-      - master
-      - dev
-    paths-ignore:
-      - '**/*.md'
-      - '**/*.css'
-      - '**/*.js'
-      - '**/*.yml'
-      - '**/*.txt'
-  pull_request:
-    branches:
-      - master
-      - dev
-    paths-ignore:
-      - '**/*.md'
-      - '**/*.css'
-      - '**/*.js'
-      - '**/*.yml'
-      - '**/*.txt'
-  schedule:
-    - cron: '30 1 * * 0'
-
-
-jobs:
-  CodeQL-Build:
-    runs-on: ubuntu-latest
-    permissions:
-      security-events: write
-      actions: read
-      contents: read
-
-    steps:
-      - name: Checkout repository
-        uses: actions/checkout@v3
-
-      - name: Initialize CodeQL
-        uses: github/codeql-action/init@v2
-
-      - name: Autobuild
-        uses: github/codeql-action/autobuild@v2
-
-      - name: Perform CodeQL Analysis
-        uses: github/codeql-action/analyze@v2

src/DjangoBlog-master/.github/workflows/django.yml

@@ -1,136 +0,0 @@
-name: Django CI
-
-on:
-  push:
-    branches:
-      - master
-      - dev
-    paths-ignore:
-      - '**/*.md'
-      - '**/*.css'
-      - '**/*.js'
-  pull_request:
-    branches:
-      - master
-      - dev
-    paths-ignore:
-      - '**/*.md'
-      - '**/*.css'
-      - '**/*.js'
-
-jobs:
-  build-normal:
-    runs-on: ubuntu-latest
-    strategy:
-      max-parallel: 4
-      matrix:
-        python-version: ["3.10","3.11" ]
-
-    steps:
-      - name: Start MySQL
-        uses: samin/mysql-action@v1.3
-        with:
-          host port: 3306
-          container port: 3306
-          character set server: utf8mb4
-          collation server: utf8mb4_general_ci
-          mysql version: latest
-          mysql root password: root
-          mysql database: djangoblog
-          mysql user: root
-          mysql password: root
-
-      - uses: actions/checkout@v3
-      - name: Set up Python ${{ matrix.python-version }}
-        uses: actions/setup-python@v4
-        with:
-          python-version: ${{ matrix.python-version }}
-          cache: 'pip'
-      - name: Install Dependencies
-        run: |
-          python -m pip install --upgrade pip
-          pip install -r requirements.txt
-      - name: Run Tests
-        env:
-          DJANGO_MYSQL_PASSWORD: root
-          DJANGO_MYSQL_HOST: 127.0.0.1
-        run: |
-          python manage.py makemigrations
-          python manage.py migrate
-          python manage.py test
-
-  build-with-es:
-    runs-on: ubuntu-latest
-    strategy:
-      max-parallel: 4
-      matrix:
-        python-version: ["3.10","3.11" ]
-
-    steps:
-      - name: Start MySQL
-        uses: samin/mysql-action@v1.3
-        with:
-          host port: 3306
-          container port: 3306
-          character set server: utf8mb4
-          collation server: utf8mb4_general_ci
-          mysql version: latest
-          mysql root password: root
-          mysql database: djangoblog
-          mysql user: root
-          mysql password: root
-
-      - name: Configure sysctl limits
-        run: |
-          sudo swapoff -a
-          sudo sysctl -w vm.swappiness=1
-          sudo sysctl -w fs.file-max=262144
-          sudo sysctl -w vm.max_map_count=262144
-
-      - uses: miyataka/elasticsearch-github-actions@1
-
-        with:
-          stack-version: '7.12.1'
-          plugins: 'https://release.infinilabs.com/analysis-ik/stable/elasticsearch-analysis-ik-7.12.1.zip'
-
-
-      - uses: actions/checkout@v3
-      - name: Set up Python ${{ matrix.python-version }}
-        uses: actions/setup-python@v4
-        with:
-          python-version: ${{ matrix.python-version }}
-          cache: 'pip'
-      - name: Install Dependencies
-        run: |
-          python -m pip install --upgrade pip
-          pip install -r requirements.txt
-      - name: Run Tests
-        env:
-          DJANGO_MYSQL_PASSWORD: root
-          DJANGO_MYSQL_HOST: 127.0.0.1
-          DJANGO_ELASTICSEARCH_HOST: 127.0.0.1:9200
-        run: |
-          python manage.py makemigrations
-          python manage.py migrate
-          coverage run manage.py test
-          coverage xml
-
-      - name: Upload coverage to Codecov
-        uses: codecov/codecov-action@v1
-
-  docker:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v2
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-
-      - name: Build and push
-        uses: docker/build-push-action@v3
-        with:
-          context: .
-          push: false
-          tags: djangoblog/djangoblog:dev

src/DjangoBlog-master/.github/workflows/docker.yml

@@ -1,43 +0,0 @@
-name: docker
-
-on:
-  push:
-    paths-ignore:
-      - '**/*.md'
-      - '**/*.yml'
-    branches:
-      - 'master'
-      - 'dev'
-
-jobs:
-  docker:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Set env to docker dev tag
-        if: endsWith(github.ref, '/dev')
-        run: |
-          echo "DOCKER_TAG=test" >> $GITHUB_ENV
-      - name: Set env to docker latest tag
-        if: endsWith(github.ref, '/master')
-        run: |
-         echo "DOCKER_TAG=latest" >> $GITHUB_ENV
-      - name: Checkout
-        uses: actions/checkout@v3
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-    
-      - name: Login to DockerHub
-        uses: docker/login-action@v2
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Build and push
-        uses: docker/build-push-action@v3
-        with:
-          context: .
-          push: true
-          tags: ${{ secrets.DOCKERHUB_USERNAME }}/djangoblog:${{env.DOCKER_TAG}}
-          
-    

src/DjangoBlog-master/.github/workflows/publish-release.yml

@@ -1,39 +0,0 @@
-name: publish release
-
-on:
-  release:
-    types: [ published ]
-
-jobs:
-  docker:
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-
-      - name: Docker meta
-        id: meta
-        uses: docker/metadata-action@v3
-        with:
-          images: name/app
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-      - name: Login to DockerHub
-        uses: docker/login-action@v2
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Build and push
-        uses: docker/build-push-action@v3
-        with:
-          context: .
-          push: true
-          platforms: |
-            linux/amd64
-            linux/arm64
-            linux/arm/v7
-            linux/arm/v6
-            linux/386
-          tags: ${{ secrets.DOCKERHUB_USERNAME }}/djangoblog:${{ github.event.release.tag_name }}

src/DjangoBlog-master/accounts/admin.py

@@ -1,59 +0,0 @@
-from django import forms
-from django.contrib.auth.admin import UserAdmin
-from django.contrib.auth.forms import UserChangeForm
-from django.contrib.auth.forms import UsernameField
-from django.utils.translation import gettext_lazy as _
-
-# Register your models here.
-from .models import BlogUser
-
-
-class BlogUserCreationForm(forms.ModelForm):
-    password1 = forms.CharField(label=_('password'), widget=forms.PasswordInput)
-    password2 = forms.CharField(label=_('Enter password again'), widget=forms.PasswordInput)
-
-    class Meta:
-        model = BlogUser
-        fields = ('email',)
-
-    def clean_password2(self):
-        # Check that the two password entries match
-        password1 = self.cleaned_data.get("password1")
-        password2 = self.cleaned_data.get("password2")
-        if password1 and password2 and password1 != password2:
-            raise forms.ValidationError(_("passwords do not match"))
-        return password2
-
-    def save(self, commit=True):
-        # Save the provided password in hashed format
-        user = super().save(commit=False)
-        user.set_password(self.cleaned_data["password1"])
-        if commit:
-            user.source = 'adminsite'
-            user.save()
-        return user
-
-
-class BlogUserChangeForm(UserChangeForm):
-    class Meta:
-        model = BlogUser
-        fields = '__all__'
-        field_classes = {'username': UsernameField}
-
-    def __init__(self, *args, **kwargs):
-        super().__init__(*args, **kwargs)
-
-
-class BlogUserAdmin(UserAdmin):
-    form = BlogUserChangeForm
-    add_form = BlogUserCreationForm
-    list_display = (
-        'id',
-        'nickname',
-        'username',
-        'email',
-        'last_login',
-        'date_joined',
-        'source')
-    list_display_links = ('id', 'username')
-    ordering = ('-id',)

src/DjangoBlog-master/accounts/models.py

@@ -1,35 +0,0 @@
-from django.contrib.auth.models import AbstractUser
-from django.db import models
-from django.urls import reverse
-from django.utils.timezone import now
-from django.utils.translation import gettext_lazy as _
-from djangoblog.utils import get_current_site
-
-
-# Create your models here.
-
-class BlogUser(AbstractUser):
-    nickname = models.CharField(_('nick name'), max_length=100, blank=True)
-    creation_time = models.DateTimeField(_('creation time'), default=now)
-    last_modify_time = models.DateTimeField(_('last modify time'), default=now)
-    source = models.CharField(_('create source'), max_length=100, blank=True)
-
-    def get_absolute_url(self):
-        return reverse(
-            'blog:author_detail', kwargs={
-                'author_name': self.username})
-
-    def __str__(self):
-        return self.email
-
-    def get_full_url(self):
-        site = get_current_site().domain
-        url = "https://{site}{path}".format(site=site,
-                                            path=self.get_absolute_url())
-        return url
-
-    class Meta:
-        ordering = ['-id']
-        verbose_name = _('user')
-        verbose_name_plural = verbose_name
-        get_latest_by = 'id'

src/DjangoBlog-master/accounts/user_login_backend.py

@@ -1,26 +0,0 @@
-from django.contrib.auth import get_user_model
-from django.contrib.auth.backends import ModelBackend
-
-
-class EmailOrUsernameModelBackend(ModelBackend):
-    """
-    允许使用用户名或邮箱登录
-    """
-
-    def authenticate(self, request, username=None, password=None, **kwargs):
-        if '@' in username:
-            kwargs = {'email': username}
-        else:
-            kwargs = {'username': username}
-        try:
-            user = get_user_model().objects.get(**kwargs)
-            if user.check_password(password):
-                return user
-        except get_user_model().DoesNotExist:
-            return None
-
-    def get_user(self, username):
-        try:
-            return get_user_model().objects.get(pk=username)
-        except get_user_model().DoesNotExist:
-            return None

src/DjangoBlog-master/blog/middleware.py

@@ -1,42 +0,0 @@
-import logging
-import time
-
-from ipware import get_client_ip
-from user_agents import parse
-
-from blog.documents import ELASTICSEARCH_ENABLED, ElaspedTimeDocumentManager
-
-logger = logging.getLogger(__name__)
-
-
-class OnlineMiddleware(object):
-    def __init__(self, get_response=None):
-        self.get_response = get_response
-        super().__init__()
-
-    def __call__(self, request):
-        ''' page render time '''
-        start_time = time.time()
-        response = self.get_response(request)
-        http_user_agent = request.META.get('HTTP_USER_AGENT', '')
-        ip, _ = get_client_ip(request)
-        user_agent = parse(http_user_agent)
-        if not response.streaming:
-            try:
-                cast_time = time.time() - start_time
-                if ELASTICSEARCH_ENABLED:
-                    time_taken = round((cast_time) * 1000, 2)
-                    url = request.path
-                    from django.utils import timezone
-                    ElaspedTimeDocumentManager.create(
-                        url=url,
-                        time_taken=time_taken,
-                        log_datetime=timezone.now(),
-                        useragent=user_agent,
-                        ip=ip)
-                response.content = response.content.replace(
-                    b'<!!LOAD_TIMES!!>', str.encode(str(cast_time)[:5]))
-            except Exception as e:
-                logger.error("Error OnlineMiddleware: %s" % e)
-
-        return response

src/DjangoBlog-master/comments/admin.py

@@ -1,47 +0,0 @@
-from django.contrib import admin
-from django.urls import reverse
-from django.utils.html import format_html
-from django.utils.translation import gettext_lazy as _
-
-
-def disable_commentstatus(modeladmin, request, queryset):
-    queryset.update(is_enable=False)
-
-
-def enable_commentstatus(modeladmin, request, queryset):
-    queryset.update(is_enable=True)
-
-
-disable_commentstatus.short_description = _('Disable comments')
-enable_commentstatus.short_description = _('Enable comments')
-
-
-class CommentAdmin(admin.ModelAdmin):
-    list_per_page = 20
-    list_display = (
-        'id',
-        'body',
-        'link_to_userinfo',
-        'link_to_article',
-        'is_enable',
-        'creation_time')
-    list_display_links = ('id', 'body', 'is_enable')
-    list_filter = ('is_enable',)
-    exclude = ('creation_time', 'last_modify_time')
-    actions = [disable_commentstatus, enable_commentstatus]
-
-    def link_to_userinfo(self, obj):
-        info = (obj.author._meta.app_label, obj.author._meta.model_name)
-        link = reverse('admin:%s_%s_change' % info, args=(obj.author.id,))
-        return format_html(
-            u'<a href="%s">%s</a>' %
-            (link, obj.author.nickname if obj.author.nickname else obj.author.email))
-
-    def link_to_article(self, obj):
-        info = (obj.article._meta.app_label, obj.article._meta.model_name)
-        link = reverse('admin:%s_%s_change' % info, args=(obj.article.id,))
-        return format_html(
-            u'<a href="%s">%s</a>' % (link, obj.article.title))
-
-    link_to_userinfo.short_description = _('User')
-    link_to_article.short_description = _('Article')

src/DjangoBlog-master/comments/views.py

@@ -1,63 +0,0 @@
-# Create your views here.
-from django.core.exceptions import ValidationError
-from django.http import HttpResponseRedirect
-from django.shortcuts import get_object_or_404
-from django.utils.decorators import method_decorator
-from django.views.decorators.csrf import csrf_protect
-from django.views.generic.edit import FormView
-
-from accounts.models import BlogUser
-from blog.models import Article
-from .forms import CommentForm
-from .models import Comment
-
-
-class CommentPostView(FormView):
-    form_class = CommentForm
-    template_name = 'blog/article_detail.html'
-
-    @method_decorator(csrf_protect)
-    def dispatch(self, *args, **kwargs):
-        return super(CommentPostView, self).dispatch(*args, **kwargs)
-
-    def get(self, request, *args, **kwargs):
-        article_id = self.kwargs['article_id']
-        article = get_object_or_404(Article, pk=article_id)
-        url = article.get_absolute_url()
-        return HttpResponseRedirect(url + "#comments")
-
-    def form_invalid(self, form):
-        article_id = self.kwargs['article_id']
-        article = get_object_or_404(Article, pk=article_id)
-
-        return self.render_to_response({
-            'form': form,
-            'article': article
-        })
-
-    def form_valid(self, form):
-        """提交的数据验证合法后的逻辑"""
-        user = self.request.user
-        author = BlogUser.objects.get(pk=user.pk)
-        article_id = self.kwargs['article_id']
-        article = get_object_or_404(Article, pk=article_id)
-
-        if article.comment_status == 'c' or article.status == 'c':
-            raise ValidationError("该文章评论已关闭.")
-        comment = form.save(False)
-        comment.article = article
-        from djangoblog.utils import get_blog_setting
-        settings = get_blog_setting()
-        if not settings.comment_need_review:
-            comment.is_enable = True
-        comment.author = author
-
-        if form.cleaned_data['parent_comment_id']:
-            parent_comment = Comment.objects.get(
-                pk=form.cleaned_data['parent_comment_id'])
-            comment.parent_comment = parent_comment
-
-        comment.save(True)
-        return HttpResponseRedirect(
-            "%s#div-comment-%d" %
-            (article.get_absolute_url(), comment.pk))

src/DjangoBlog-master/djangoblog/__init__.py

@@ -1 +0,0 @@
-default_app_config = 'djangoblog.apps.DjangoblogAppConfig'

src/DjangoBlog-master/djangoblog/admin_site.py

@@ -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)

src/DjangoBlog-master/djangoblog/apps.py

@@ -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() 

src/DjangoBlog-master/djangoblog/blog_signals.py

@@ -1,122 +0,0 @@
-import _thread
-import logging
-
-import django.dispatch
-from django.conf import settings
-from django.contrib.admin.models import LogEntry
-from django.contrib.auth.signals import user_logged_in, user_logged_out
-from django.core.mail import EmailMultiAlternatives
-from django.db.models.signals import post_save
-from django.dispatch import receiver
-
-from comments.models import Comment
-from comments.utils import send_comment_email
-from djangoblog.spider_notify import SpiderNotify
-from djangoblog.utils import cache, expire_view_cache, delete_sidebar_cache, delete_view_cache
-from djangoblog.utils import get_current_site
-from oauth.models import OAuthUser
-
-logger = logging.getLogger(__name__)
-
-oauth_user_login_signal = django.dispatch.Signal(['id'])
-send_email_signal = django.dispatch.Signal(
-    ['emailto', 'title', 'content'])
-
-
-@receiver(send_email_signal)
-def send_email_signal_handler(sender, **kwargs):
-    emailto = kwargs['emailto']
-    title = kwargs['title']
-    content = kwargs['content']
-
-    msg = EmailMultiAlternatives(
-        title,
-        content,
-        from_email=settings.DEFAULT_FROM_EMAIL,
-        to=emailto)
-    msg.content_subtype = "html"
-
-    from servermanager.models import EmailSendLog
-    log = EmailSendLog()
-    log.title = title
-    log.content = content
-    log.emailto = ','.join(emailto)
-
-    try:
-        result = msg.send()
-        log.send_result = result > 0
-    except Exception as e:
-        logger.error(f"失败邮箱号: {emailto}, {e}")
-        log.send_result = False
-    log.save()
-
-
-@receiver(oauth_user_login_signal)
-def oauth_user_login_signal_handler(sender, **kwargs):
-    id = kwargs['id']
-    oauthuser = OAuthUser.objects.get(id=id)
-    site = get_current_site().domain
-    if oauthuser.picture and not oauthuser.picture.find(site) >= 0:
-        from djangoblog.utils import save_user_avatar
-        oauthuser.picture = save_user_avatar(oauthuser.picture)
-        oauthuser.save()
-
-    delete_sidebar_cache()
-
-
-@receiver(post_save)
-def model_post_save_callback(
-        sender,
-        instance,
-        created,
-        raw,
-        using,
-        update_fields,
-        **kwargs):
-    clearcache = False
-    if isinstance(instance, LogEntry):
-        return
-    if 'get_full_url' in dir(instance):
-        is_update_views = update_fields == {'views'}
-        if not settings.TESTING and not is_update_views:
-            try:
-                notify_url = instance.get_full_url()
-                SpiderNotify.baidu_notify([notify_url])
-            except Exception as ex:
-                logger.error("notify sipder", ex)
-        if not is_update_views:
-            clearcache = True
-
-    if isinstance(instance, Comment):
-        if instance.is_enable:
-            path = instance.article.get_absolute_url()
-            site = get_current_site().domain
-            if site.find(':') > 0:
-                site = site[0:site.find(':')]
-
-            expire_view_cache(
-                path,
-                servername=site,
-                serverport=80,
-                key_prefix='blogdetail')
-            if cache.get('seo_processor'):
-                cache.delete('seo_processor')
-            comment_cache_key = 'article_comments_{id}'.format(
-                id=instance.article.id)
-            cache.delete(comment_cache_key)
-            delete_sidebar_cache()
-            delete_view_cache('article_comments', [str(instance.article.pk)])
-
-            _thread.start_new_thread(send_comment_email, (instance,))
-
-    if clearcache:
-        cache.clear()
-
-
-@receiver(user_logged_in)
-@receiver(user_logged_out)
-def user_auth_callback(sender, request, user, **kwargs):
-    if user and user.username:
-        logger.info(user)
-        delete_sidebar_cache()
-        # cache.clear()

src/DjangoBlog-master/djangoblog/elasticsearch_backend.py

@@ -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

src/DjangoBlog-master/djangoblog/feeds.py

@@ -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

src/DjangoBlog-master/djangoblog/logentryadmin.py

@@ -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

src/DjangoBlog-master/djangoblog/plugin_manage/base_plugin.py

@@ -1,41 +0,0 @@
-import logging
-
-logger = logging.getLogger(__name__)
-
-
-class BasePlugin:
-    # 插件元数据
-    PLUGIN_NAME = None
-    PLUGIN_DESCRIPTION = None
-    PLUGIN_VERSION = None
-
-    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.init_plugin()
-        self.register_hooks()
-
-    def init_plugin(self):
-        """
-        插件初始化逻辑
-        子类可以重写此方法来实现特定的初始化操作
-        """
-        logger.info(f'{self.PLUGIN_NAME} initialized.')
-
-    def register_hooks(self):
-        """
-        注册插件钩子
-        子类可以重写此方法来注册特定的钩子
-        """
-        pass
-
-    def get_plugin_info(self):
-        """
-        获取插件信息
-        :return: 包含插件元数据的字典
-        """
-        return {
-            'name': self.PLUGIN_NAME,
-            'description': self.PLUGIN_DESCRIPTION,
-            'version': self.PLUGIN_VERSION
-        }

src/DjangoBlog-master/djangoblog/plugin_manage/hook_constants.py

@@ -1,7 +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"
-

src/DjangoBlog-master/djangoblog/plugin_manage/hooks.py

@@ -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

src/DjangoBlog-master/djangoblog/plugin_manage/loader.py

@@ -1,19 +0,0 @@
-import os
-import logging
-from django.conf import settings
-
-logger = logging.getLogger(__name__)
-
-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.
-    """
-    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:
-                __import__(f'plugins.{plugin_name}.plugin')
-                logger.info(f"Successfully loaded plugin: {plugin_name}")
-            except ImportError as e:
-                logger.error(f"Failed to import plugin: {plugin_name}", exc_info=e) 

src/DjangoBlog-master/djangoblog/settings.py

@@ -1,343 +0,0 @@
-"""
-Django settings for djangoblog project.
-
-Generated by 'django-admin startproject' using Django 1.10.2.
-
-For more information on this file, see
-https://docs.djangoproject.com/en/1.10/topics/settings/
-
-For the full list of settings and their values, see
-https://docs.djangoproject.com/en/1.10/ref/settings/
-"""
-import os
-import sys
-from pathlib import Path
-
-from django.utils.translation import gettext_lazy as _
-
-
-def env_to_bool(env, default):
-    str_val = os.environ.get(env)
-    return default if str_val is None else str_val == 'True'
-
-
-# Build paths inside the project like this: BASE_DIR / 'subdir'.
-BASE_DIR = Path(__file__).resolve().parent.parent
-
-# Quick-start development settings - unsuitable for production
-# See https://docs.djangoproject.com/en/1.10/howto/deployment/checklist/
-
-# SECURITY WARNING: keep the secret key used in production secret!
-SECRET_KEY = os.environ.get(
-    'DJANGO_SECRET_KEY') or 'n9ceqv38)#&mwuat@(mjb_p%em$e8$qyr#fw9ot!=ba6lijx-6'
-# SECURITY WARNING: don't run with debug turned on in production!
-DEBUG = env_to_bool('DJANGO_DEBUG', True)
-# DEBUG = False
-TESTING = len(sys.argv) > 1 and sys.argv[1] == 'test'
-
-# ALLOWED_HOSTS = []
-ALLOWED_HOSTS = ['*', '127.0.0.1', 'example.com']
-# django 4.0新增配置
-CSRF_TRUSTED_ORIGINS = ['http://example.com']
-# Application definition
-
-
-INSTALLED_APPS = [
-    # 'django.contrib.admin',
-    'django.contrib.admin.apps.SimpleAdminConfig',
-    'django.contrib.auth',
-    'django.contrib.contenttypes',
-    'django.contrib.sessions',
-    'django.contrib.messages',
-    'django.contrib.staticfiles',
-    'django.contrib.sites',
-    'django.contrib.sitemaps',
-    'mdeditor',
-    'haystack',
-    'blog',
-    'accounts',
-    'comments',
-    'oauth',
-    'servermanager',
-    'owntracks',
-    'compressor',
-    'djangoblog'
-]
-
-MIDDLEWARE = [
-
-    'django.middleware.security.SecurityMiddleware',
-    'django.contrib.sessions.middleware.SessionMiddleware',
-    'django.middleware.locale.LocaleMiddleware',
-    'django.middleware.gzip.GZipMiddleware',
-    # 'django.middleware.cache.UpdateCacheMiddleware',
-    'django.middleware.common.CommonMiddleware',
-    # 'django.middleware.cache.FetchFromCacheMiddleware',
-    'django.middleware.csrf.CsrfViewMiddleware',
-    'django.contrib.auth.middleware.AuthenticationMiddleware',
-    'django.contrib.messages.middleware.MessageMiddleware',
-    'django.middleware.clickjacking.XFrameOptionsMiddleware',
-    'django.middleware.http.ConditionalGetMiddleware',
-    'blog.middleware.OnlineMiddleware'
-]
-
-ROOT_URLCONF = 'djangoblog.urls'
-
-TEMPLATES = [
-    {
-        'BACKEND': 'django.template.backends.django.DjangoTemplates',
-        'DIRS': [os.path.join(BASE_DIR, 'templates')],
-        'APP_DIRS': True,
-        'OPTIONS': {
-            'context_processors': [
-                'django.template.context_processors.debug',
-                'django.template.context_processors.request',
-                'django.contrib.auth.context_processors.auth',
-                'django.contrib.messages.context_processors.messages',
-                'blog.context_processors.seo_processor'
-            ],
-        },
-    },
-]
-
-WSGI_APPLICATION = 'djangoblog.wsgi.application'
-
-# Database
-# https://docs.djangoproject.com/en/1.10/ref/settings/#databases
-
-
-DATABASES = {
-    'default': {
-        'ENGINE': 'django.db.backends.mysql',
-        'NAME': os.environ.get('DJANGO_MYSQL_DATABASE') or 'djangoblog',
-        'USER': os.environ.get('DJANGO_MYSQL_USER') or 'root',
-        'PASSWORD': os.environ.get('DJANGO_MYSQL_PASSWORD') or '123456',
-        'HOST': os.environ.get('DJANGO_MYSQL_HOST') or '127.0.0.1',
-        'PORT': int(
-            os.environ.get('DJANGO_MYSQL_PORT') or 3306),
-        'OPTIONS': {
-            'charset': 'utf8mb4'},
-    }}
-
-# Password validation
-# https://docs.djangoproject.com/en/1.10/ref/settings/#auth-password-validators
-
-AUTH_PASSWORD_VALIDATORS = [
-    {
-        'NAME': 'django.contrib.auth.password_validation.UserAttributeSimilarityValidator',
-    },
-    {
-        'NAME': 'django.contrib.auth.password_validation.MinimumLengthValidator',
-    },
-    {
-        'NAME': 'django.contrib.auth.password_validation.CommonPasswordValidator',
-    },
-    {
-        'NAME': 'django.contrib.auth.password_validation.NumericPasswordValidator',
-    },
-]
-
-LANGUAGES = (
-    ('en', _('English')),
-    ('zh-hans', _('Simplified Chinese')),
-    ('zh-hant', _('Traditional Chinese')),
-)
-LOCALE_PATHS = (
-    os.path.join(BASE_DIR, 'locale'),
-)
-
-LANGUAGE_CODE = 'zh-hans'
-
-TIME_ZONE = 'Asia/Shanghai'
-
-USE_I18N = True
-
-USE_L10N = True
-
-USE_TZ = False
-
-# Static files (CSS, JavaScript, Images)
-# https://docs.djangoproject.com/en/1.10/howto/static-files/
-
-
-HAYSTACK_CONNECTIONS = {
-    'default': {
-        'ENGINE': 'djangoblog.whoosh_cn_backend.WhooshEngine',
-        'PATH': os.path.join(os.path.dirname(__file__), 'whoosh_index'),
-    },
-}
-# Automatically update searching index
-HAYSTACK_SIGNAL_PROCESSOR = 'haystack.signals.RealtimeSignalProcessor'
-# Allow user login with username and password
-AUTHENTICATION_BACKENDS = [
-    'accounts.user_login_backend.EmailOrUsernameModelBackend']
-
-STATIC_ROOT = os.path.join(BASE_DIR, 'collectedstatic')
-
-STATIC_URL = '/static/'
-STATICFILES = os.path.join(BASE_DIR, 'static')
-
-AUTH_USER_MODEL = 'accounts.BlogUser'
-LOGIN_URL = '/login/'
-
-TIME_FORMAT = '%Y-%m-%d %H:%M:%S'
-DATE_TIME_FORMAT = '%Y-%m-%d'
-
-# bootstrap color styles
-BOOTSTRAP_COLOR_TYPES = [
-    'default', 'primary', 'success', 'info', 'warning', 'danger'
-]
-
-# paginate
-PAGINATE_BY = 10
-# http cache timeout
-CACHE_CONTROL_MAX_AGE = 2592000
-# cache setting
-CACHES = {
-    'default': {
-        'BACKEND': 'django.core.cache.backends.locmem.LocMemCache',
-        'TIMEOUT': 10800,
-        'LOCATION': 'unique-snowflake',
-    }
-}
-# 使用redis作为缓存
-if os.environ.get("DJANGO_REDIS_URL"):
-    CACHES = {
-        'default': {
-            'BACKEND': 'django.core.cache.backends.redis.RedisCache',
-            'LOCATION': f'redis://{os.environ.get("DJANGO_REDIS_URL")}',
-        }
-    }
-
-SITE_ID = 1
-BAIDU_NOTIFY_URL = os.environ.get('DJANGO_BAIDU_NOTIFY_URL') \
-                   or 'http://data.zz.baidu.com/urls?site=https://www.lylinux.net&token=1uAOGrMsUm5syDGn'
-
-# Email:
-EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
-EMAIL_USE_TLS = env_to_bool('DJANGO_EMAIL_TLS', False)
-EMAIL_USE_SSL = env_to_bool('DJANGO_EMAIL_SSL', True)
-EMAIL_HOST = os.environ.get('DJANGO_EMAIL_HOST') or 'smtp.mxhichina.com'
-EMAIL_PORT = int(os.environ.get('DJANGO_EMAIL_PORT') or 465)
-EMAIL_HOST_USER = os.environ.get('DJANGO_EMAIL_USER')
-EMAIL_HOST_PASSWORD = os.environ.get('DJANGO_EMAIL_PASSWORD')
-DEFAULT_FROM_EMAIL = EMAIL_HOST_USER
-SERVER_EMAIL = EMAIL_HOST_USER
-# Setting debug=false did NOT handle except email notifications
-ADMINS = [('admin', os.environ.get('DJANGO_ADMIN_EMAIL') or 'admin@admin.com')]
-# WX ADMIN password(Two times md5)
-WXADMIN = os.environ.get(
-    'DJANGO_WXADMIN_PASSWORD') or '995F03AC401D6CABABAEF756FC4D43C7'
-
-LOG_PATH = os.path.join(BASE_DIR, 'logs')
-if not os.path.exists(LOG_PATH):
-    os.makedirs(LOG_PATH, exist_ok=True)
-
-LOGGING = {
-    'version': 1,
-    'disable_existing_loggers': False,
-    'root': {
-        'level': 'INFO',
-        'handlers': ['console', 'log_file'],
-    },
-    'formatters': {
-        'verbose': {
-            'format': '[%(asctime)s] %(levelname)s [%(name)s.%(funcName)s:%(lineno)d %(module)s] %(message)s',
-        }
-    },
-    'filters': {
-        'require_debug_false': {
-            '()': 'django.utils.log.RequireDebugFalse',
-        },
-        'require_debug_true': {
-            '()': 'django.utils.log.RequireDebugTrue',
-        },
-    },
-    'handlers': {
-        'log_file': {
-            'level': 'INFO',
-            'class': 'logging.handlers.TimedRotatingFileHandler',
-            'filename': os.path.join(LOG_PATH, 'djangoblog.log'),
-            'when': 'D',
-            'formatter': 'verbose',
-            'interval': 1,
-            'delay': True,
-            'backupCount': 5,
-            'encoding': 'utf-8'
-        },
-        'console': {
-            'level': 'DEBUG',
-            'filters': ['require_debug_true'],
-            'class': 'logging.StreamHandler',
-            'formatter': 'verbose'
-        },
-        'null': {
-            'class': 'logging.NullHandler',
-        },
-        'mail_admins': {
-            'level': 'ERROR',
-            'filters': ['require_debug_false'],
-            'class': 'django.utils.log.AdminEmailHandler'
-        }
-    },
-    'loggers': {
-        'djangoblog': {
-            'handlers': ['log_file', 'console'],
-            'level': 'INFO',
-            'propagate': True,
-        },
-        'django.request': {
-            'handlers': ['mail_admins'],
-            'level': 'ERROR',
-            'propagate': False,
-        }
-    }
-}
-
-STATICFILES_FINDERS = (
-    'django.contrib.staticfiles.finders.FileSystemFinder',
-    'django.contrib.staticfiles.finders.AppDirectoriesFinder',
-    # other
-    'compressor.finders.CompressorFinder',
-)
-COMPRESS_ENABLED = True
-# COMPRESS_OFFLINE = True
-
-
-COMPRESS_CSS_FILTERS = [
-    # creates absolute urls from relative ones
-    'compressor.filters.css_default.CssAbsoluteFilter',
-    # css minimizer
-    'compressor.filters.cssmin.CSSMinFilter'
-]
-COMPRESS_JS_FILTERS = [
-    'compressor.filters.jsmin.JSMinFilter'
-]
-
-MEDIA_ROOT = os.path.join(BASE_DIR, 'uploads')
-MEDIA_URL = '/media/'
-X_FRAME_OPTIONS = 'SAMEORIGIN'
-
-DEFAULT_AUTO_FIELD = 'django.db.models.BigAutoField'
-
-if os.environ.get('DJANGO_ELASTICSEARCH_HOST'):
-    ELASTICSEARCH_DSL = {
-        'default': {
-            'hosts': os.environ.get('DJANGO_ELASTICSEARCH_HOST')
-        },
-    }
-    HAYSTACK_CONNECTIONS = {
-        'default': {
-            'ENGINE': 'djangoblog.elasticsearch_backend.ElasticSearchEngine',
-        },
-    }
-
-# Plugin System
-PLUGINS_DIR = BASE_DIR / 'plugins'
-ACTIVE_PLUGINS = [
-    'article_copyright',
-    'reading_time',
-    'external_links',
-    'view_count',
-    'seo_optimizer'
-]

src/DjangoBlog-master/djangoblog/sitemap.py

@@ -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

src/DjangoBlog-master/djangoblog/spider_notify.py

@@ -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)

src/DjangoBlog-master/djangoblog/tests.py

@@ -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)

src/DjangoBlog-master/djangoblog/urls.py

@@ -1,64 +0,0 @@
-"""djangoblog URL Configuration
-
-The `urlpatterns` list routes URLs to views. For more information please see:
-    https://docs.djangoproject.com/en/1.10/topics/http/urls/
-Examples:
-Function views
-    1. Add an import:  from my_app import views
-    2. Add a URL to urlpatterns:  url(r'^$', views.home, name='home')
-Class-based views
-    1. Add an import:  from other_app.views import Home
-    2. Add a URL to urlpatterns:  url(r'^$', Home.as_view(), name='home')
-Including another URLconf
-    1. Import the include() function: from django.conf.urls import url, include
-    2. Add a URL to urlpatterns:  url(r'^blog/', include('blog.urls'))
-"""
-from django.conf import settings
-from django.conf.urls.i18n import i18n_patterns
-from django.conf.urls.static import static
-from django.contrib.sitemaps.views import sitemap
-from django.urls import path, include
-from django.urls import re_path
-from haystack.views import search_view_factory
-
-from blog.views import EsSearchView
-from djangoblog.admin_site import admin_site
-from djangoblog.elasticsearch_backend import ElasticSearchModelSearchForm
-from djangoblog.feeds import DjangoBlogFeed
-from djangoblog.sitemap import ArticleSiteMap, CategorySiteMap, StaticViewSitemap, TagSiteMap, UserSiteMap
-
-sitemaps = {
-
-    'blog': ArticleSiteMap,
-    'Category': CategorySiteMap,
-    'Tag': TagSiteMap,
-    'User': UserSiteMap,
-    'static': StaticViewSitemap
-}
-
-handler404 = 'blog.views.page_not_found_view'
-handler500 = 'blog.views.server_error_view'
-handle403 = 'blog.views.permission_denied_view'
-
-urlpatterns = [
-    path('i18n/', include('django.conf.urls.i18n')),
-]
-urlpatterns += i18n_patterns(
-    re_path(r'^admin/', admin_site.urls),
-    re_path(r'', include('blog.urls', namespace='blog')),
-    re_path(r'mdeditor/', include('mdeditor.urls')),
-    re_path(r'', include('comments.urls', namespace='comment')),
-    re_path(r'', include('accounts.urls', namespace='account')),
-    re_path(r'', include('oauth.urls', namespace='oauth')),
-    re_path(r'^sitemap\.xml$', sitemap, {'sitemaps': sitemaps},
-            name='django.contrib.sitemaps.views.sitemap'),
-    re_path(r'^feed/$', DjangoBlogFeed()),
-    re_path(r'^rss/$', DjangoBlogFeed()),
-    re_path('^search', search_view_factory(view_class=EsSearchView, form_class=ElasticSearchModelSearchForm),
-            name='search'),
-    re_path(r'', include('servermanager.urls', namespace='servermanager')),
-    re_path(r'', include('owntracks.urls', namespace='owntracks'))
-    , prefix_default_language=False) + static(settings.STATIC_URL, document_root=settings.STATIC_ROOT)
-if settings.DEBUG:
-    urlpatterns += static(settings.MEDIA_URL,
-                          document_root=settings.MEDIA_ROOT)

src/DjangoBlog-master/djangoblog/utils.py

@@ -1,232 +0,0 @@
-#!/usr/bin/env python
-# encoding: utf-8
-
-
-import logging
-import os
-import random
-import string
-import uuid
-from hashlib import sha256
-
-import bleach
-import markdown
-import requests
-from django.conf import settings
-from django.contrib.sites.models import Site
-from django.core.cache import cache
-from django.templatetags.static import static
-
-logger = logging.getLogger(__name__)
-
-
-def get_max_articleid_commentid():
-    from blog.models import Article
-    from comments.models import Comment
-    return (Article.objects.latest().pk, Comment.objects.latest().pk)
-
-
-def get_sha256(str):
-    m = sha256(str.encode('utf-8'))
-    return m.hexdigest()
-
-
-def cache_decorator(expiration=3 * 60):
-    def wrapper(func):
-        def news(*args, **kwargs):
-            try:
-                view = args[0]
-                key = view.get_cache_key()
-            except:
-                key = None
-            if not key:
-                unique_str = repr((func, args, kwargs))
-
-                m = sha256(unique_str.encode('utf-8'))
-                key = m.hexdigest()
-            value = cache.get(key)
-            if value is not None:
-                # logger.info('cache_decorator get cache:%s key:%s' % (func.__name__, key))
-                if str(value) == '__default_cache_value__':
-                    return None
-                else:
-                    return value
-            else:
-                logger.debug(
-                    'cache_decorator set cache:%s key:%s' %
-                    (func.__name__, key))
-                value = func(*args, **kwargs)
-                if value is None:
-                    cache.set(key, '__default_cache_value__', expiration)
-                else:
-                    cache.set(key, value, expiration)
-                return value
-
-        return news
-
-    return wrapper
-
-
-def expire_view_cache(path, servername, serverport, key_prefix=None):
-    '''
-    刷新视图缓存
-    :param path:url路径
-    :param servername:host
-    :param serverport:端口
-    :param key_prefix:前缀
-    :return:是否成功
-    '''
-    from django.http import HttpRequest
-    from django.utils.cache import get_cache_key
-
-    request = HttpRequest()
-    request.META = {'SERVER_NAME': servername, 'SERVER_PORT': serverport}
-    request.path = path
-
-    key = get_cache_key(request, key_prefix=key_prefix, cache=cache)
-    if key:
-        logger.info('expire_view_cache:get key:{path}'.format(path=path))
-        if cache.get(key):
-            cache.delete(key)
-        return True
-    return False
-
-
-@cache_decorator()
-def get_current_site():
-    site = Site.objects.get_current()
-    return site
-
-
-class CommonMarkdown:
-    @staticmethod
-    def _convert_markdown(value):
-        md = markdown.Markdown(
-            extensions=[
-                'extra',
-                'codehilite',
-                'toc',
-                'tables',
-            ]
-        )
-        body = md.convert(value)
-        toc = md.toc
-        return body, toc
-
-    @staticmethod
-    def get_markdown_with_toc(value):
-        body, toc = CommonMarkdown._convert_markdown(value)
-        return body, toc
-
-    @staticmethod
-    def get_markdown(value):
-        body, toc = CommonMarkdown._convert_markdown(value)
-        return body
-
-
-def send_email(emailto, title, content):
-    from djangoblog.blog_signals import send_email_signal
-    send_email_signal.send(
-        send_email.__class__,
-        emailto=emailto,
-        title=title,
-        content=content)
-
-
-def generate_code() -> str:
-    """生成随机数验证码"""
-    return ''.join(random.sample(string.digits, 6))
-
-
-def parse_dict_to_url(dict):
-    from urllib.parse import quote
-    url = '&'.join(['{}={}'.format(quote(k, safe='/'), quote(v, safe='/'))
-                    for k, v in dict.items()])
-    return url
-
-
-def get_blog_setting():
-    value = cache.get('get_blog_setting')
-    if value:
-        return value
-    else:
-        from blog.models import BlogSettings
-        if not BlogSettings.objects.count():
-            setting = BlogSettings()
-            setting.site_name = 'djangoblog'
-            setting.site_description = '基于Django的博客系统'
-            setting.site_seo_description = '基于Django的博客系统'
-            setting.site_keywords = 'Django,Python'
-            setting.article_sub_length = 300
-            setting.sidebar_article_count = 10
-            setting.sidebar_comment_count = 5
-            setting.show_google_adsense = False
-            setting.open_site_comment = True
-            setting.analytics_code = ''
-            setting.beian_code = ''
-            setting.show_gongan_code = False
-            setting.comment_need_review = False
-            setting.save()
-        value = BlogSettings.objects.first()
-        logger.info('set cache get_blog_setting')
-        cache.set('get_blog_setting', value)
-        return value
-
-
-def save_user_avatar(url):
-    '''
-    保存用户头像
-    :param url:头像url
-    :return: 本地路径
-    '''
-    logger.info(url)
-
-    try:
-        basedir = os.path.join(settings.STATICFILES, 'avatar')
-        rsp = requests.get(url, timeout=2)
-        if rsp.status_code == 200:
-            if not os.path.exists(basedir):
-                os.makedirs(basedir)
-
-            image_extensions = ['.jpg', '.png', 'jpeg', '.gif']
-            isimage = len([i for i in image_extensions if url.endswith(i)]) > 0
-            ext = os.path.splitext(url)[1] if isimage else '.jpg'
-            save_filename = str(uuid.uuid4().hex) + ext
-            logger.info('保存用户头像:' + basedir + save_filename)
-            with open(os.path.join(basedir, save_filename), 'wb+') as file:
-                file.write(rsp.content)
-            return static('avatar/' + save_filename)
-    except Exception as e:
-        logger.error(e)
-        return static('blog/img/avatar.png')
-
-
-def delete_sidebar_cache():
-    from blog.models import LinkShowType
-    keys = ["sidebar" + x for x in LinkShowType.values]
-    for k in keys:
-        logger.info('delete sidebar key:' + k)
-        cache.delete(k)
-
-
-def delete_view_cache(prefix, keys):
-    from django.core.cache.utils import make_template_fragment_key
-    key = make_template_fragment_key(prefix, keys)
-    cache.delete(key)
-
-
-def get_resource_url():
-    if settings.STATIC_URL:
-        return settings.STATIC_URL
-    else:
-        site = get_current_site()
-        return 'http://' + site.domain + '/static/'
-
-
-ALLOWED_TAGS = ['a', 'abbr', 'acronym', 'b', 'blockquote', 'code', 'em', 'i', 'li', 'ol', 'pre', 'strong', 'ul', 'h1',
-                'h2', 'p']
-ALLOWED_ATTRIBUTES = {'a': ['href', 'title'], 'abbr': ['title'], 'acronym': ['title']}
-
-
-def sanitize_html(html):
-    return bleach.clean(html, tags=ALLOWED_TAGS, attributes=ALLOWED_ATTRIBUTES)

src/DjangoBlog-master/djangoblog/wsgi.py

@@ -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()

src/DjangoBlog-master/oauth/admin.py

@@ -1,54 +0,0 @@
-import logging
-
-from django.contrib import admin
-# Register your models here.
-from django.urls import reverse
-from django.utils.html import format_html
-
-logger = logging.getLogger(__name__)
-
-
-class OAuthUserAdmin(admin.ModelAdmin):
-    search_fields = ('nickname', 'email')
-    list_per_page = 20
-    list_display = (
-        'id',
-        'nickname',
-        'link_to_usermodel',
-        'show_user_image',
-        'type',
-        'email',
-    )
-    list_display_links = ('id', 'nickname')
-    list_filter = ('author', 'type',)
-    readonly_fields = []
-
-    def get_readonly_fields(self, request, obj=None):
-        return list(self.readonly_fields) + \
-               [field.name for field in obj._meta.fields] + \
-               [field.name for field in obj._meta.many_to_many]
-
-    def has_add_permission(self, request):
-        return False
-
-    def link_to_usermodel(self, obj):
-        if obj.author:
-            info = (obj.author._meta.app_label, obj.author._meta.model_name)
-            link = reverse('admin:%s_%s_change' % info, args=(obj.author.id,))
-            return format_html(
-                u'<a href="%s">%s</a>' %
-                (link, obj.author.nickname if obj.author.nickname else obj.author.email))
-
-    def show_user_image(self, obj):
-        img = obj.picture
-        return format_html(
-            u'<img src="%s" style="width:50px;height:50px"></img>' %
-            (img))
-
-    link_to_usermodel.short_description = '用户'
-    show_user_image.short_description = '用户头像'
-
-
-class OAuthConfigAdmin(admin.ModelAdmin):
-    list_display = ('type', 'appkey', 'appsecret', 'is_enable')
-    list_filter = ('type',)

src/DjangoBlog-master/servermanager/MemcacheStorage.py

@@ -1,32 +0,0 @@
-from werobot.session import SessionStorage
-from werobot.utils import json_loads, json_dumps
-
-from djangoblog.utils import cache
-
-
-class MemcacheStorage(SessionStorage):
-    def __init__(self, prefix='ws_'):
-        self.prefix = prefix
-        self.cache = cache
-
-    @property
-    def is_available(self):
-        value = "1"
-        self.set('checkavaliable', value=value)
-        return value == self.get('checkavaliable')
-
-    def key_name(self, s):
-        return '{prefix}{s}'.format(prefix=self.prefix, s=s)
-
-    def get(self, id):
-        id = self.key_name(id)
-        session_json = self.cache.get(id) or '{}'
-        return json_loads(session_json)
-
-    def set(self, id, value):
-        id = self.key_name(id)
-        self.cache.set(id, json_dumps(value))
-
-    def delete(self, id):
-        id = self.key_name(id)
-        self.cache.delete(id)

src/DjangoBlog-master/servermanager/admin.py

@@ -1,19 +0,0 @@
-from django.contrib import admin
-# Register your models here.
-
-
-class CommandsAdmin(admin.ModelAdmin):
-    list_display = ('title', 'command', 'describe')
-
-
-class EmailSendLogAdmin(admin.ModelAdmin):
-    list_display = ('title', 'emailto', 'send_result', 'creation_time')
-    readonly_fields = (
-        'title',
-        'emailto',
-        'send_result',
-        'creation_time',
-        'content')
-
-    def has_add_permission(self, request):
-        return False

src/accounts/admin.py

@@ -0,0 +1,85 @@
+from django import forms
+from django.contrib.auth.admin import UserAdmin
+from django.contrib.auth.forms import UserChangeForm
+from django.contrib.auth.forms import UsernameField
+from django.utils.translation import gettext_lazy as _
+
+# 注册模型到Django管理后台
+from .models import BlogUser
+
+
+# 自定义用户创建表单，用于在Django管理后台创建新用户
+class BlogUserCreationForm(forms.ModelForm):
+    # 定义两个密码字段，分别用于输入密码和确认密码
+    password1 = forms.CharField(label=_('password'), widget=forms.PasswordInput)  # 密码输入框
+    password2 = forms.CharField(label=_('Enter password again'), widget=forms.PasswordInput)  # 确认密码输入框
+
+    class Meta:
+        # 指定表单对应的模型
+        model = BlogUser
+        # 表单中包含的字段
+        fields = ('email',)
+
+    def clean_password2(self):
+        """
+        验证两个密码输入是否一致
+        """
+        password1 = self.cleaned_data.get("password1")  # 获取第一个密码
+        password2 = self.cleaned_data.get("password2")  # 获取第二个密码
+        if password1 and password2 and password1 != password2:
+            # 如果两个密码不一致，抛出验证错误
+            raise forms.ValidationError(_("passwords do not match"))
+        return password2
+
+    def save(self, commit=True):
+        """
+        保存用户实例，并将密码以哈希格式存储
+        """
+        user = super().save(commit=False)  # 获取未保存的用户实例
+        user.set_password(self.cleaned_data["password1"])  # 设置哈希密码
+        if commit:
+            user.source = 'adminsite'  # 设置用户来源为管理后台
+            user.save()  # 保存用户实例到数据库
+        return user
+
+
+# 自定义用户修改表单，用于在Django管理后台修改用户信息
+class BlogUserChangeForm(UserChangeForm):
+    class Meta:
+        # 指定表单对应的模型
+        model = BlogUser
+        # 表单中包含的所有字段
+        fields = '__all__'
+        # 自定义字段类型
+        field_classes = {'username': UsernameField}
+
+    def __init__(self, *args, **kwargs):
+        """
+        初始化表单
+        """
+        super().__init__(*args, **kwargs)
+
+
+# 自定义用户管理类，用于在Django管理后台管理用户
+class BlogUserAdmin(UserAdmin):
+    form = BlogUserChangeForm
+    add_form = BlogUserCreationForm
+    list_display = (
+        'id',
+        'nickname',
+        'username',
+        'email',
+        'last_login',
+        'date_joined',
+        'source'
+    )
+    list_display_links = ('id', 'username')
+    ordering = ('-id',)
+    search_fields = ('username', 'nickname', 'email')
+
+    fieldsets = (
+        (None, {'fields': ('username', 'password')}),
+        (_('Personal info'), {'fields': ('email', 'nickname')}),
+        (_('Permissions'), {'fields': ('is_active', 'is_staff', 'is_superuser', 'groups', 'user_permissions')}),
+        (_('Important dates'), {'fields': ('last_login', 'date_joined')}),
+    )

src/accounts/models.py

@@ -0,0 +1,48 @@
+from django.contrib.auth.models import AbstractUser
+from django.db import models
+from django.urls import reverse
+from django.utils.timezone import now
+from django.utils.translation import gettext_lazy as _
+from djangoblog.utils import get_current_site
+
+
+# 创建自定义用户模型
+class BlogUser(AbstractUser):
+    # 用户昵称字段，允许为空，最大长度为100
+    nickname = models.CharField(_('nick name'), max_length=100, blank=True)
+    # 用户创建时间字段，默认为当前时间
+    creation_time = models.DateTimeField(_('creation time'), default=now)
+    # 用户最后修改时间字段，默认为当前时间
+    last_modify_time = models.DateTimeField(_('last modify time'), default=now)
+    # 用户来源字段，用于记录用户的创建来源，允许为空，最大长度为100
+    source = models.CharField(_('create source'), max_length=100, blank=True)
+
+    def get_absolute_url(self):
+        """
+        获取用户的绝对URL，用于跳转到用户的详情页面
+        """
+        return reverse(
+            'blog:author_detail', kwargs={
+                'author_name': self.username})  # 根据用户名生成URL
+
+    def __str__(self):
+        """
+        定义对象的字符串表示，返回用户的邮箱
+        """
+        return self.email
+
+    def get_full_url(self):
+        """
+        获取用户的完整URL，包括域名和路径
+        """
+        site = get_current_site().domain  # 获取当前站点的域名
+        url = "https://{site}{path}".format(site=site,
+                                            path=self.get_absolute_url())  # 拼接完整URL
+        return url
+
+    class Meta:
+        # 定义模型的元数据
+        ordering = ['-id']  # 默认按ID降序排列
+        verbose_name = _('user')  # 模型的单数名称
+        verbose_name_plural = verbose_name  # 模型的复数名称
+        get_latest_by = 'id'  # 获取最新记录时使用的字段

src/accounts/user_login_backend.py

@@ -0,0 +1,18 @@
+# filepath: f:\DjangoBlog\src\accounts\user_login_backend.py
+from django.contrib.auth.backends import ModelBackend
+from django.contrib.auth import get_user_model
+from django.db import models
+User = get_user_model()
+
+class EmailOrUsernameModelBackend(ModelBackend):
+    """
+    自定义认证后端，支持通过用户名或邮箱登录
+    """
+    def authenticate(self, request, username=None, password=None, **kwargs):
+        try:
+            # 尝试通过用户名或邮箱获取用户
+            user = User.objects.get(models.Q(username=username) | models.Q(email=username))
+            if user.check_password(password):
+                return user
+        except User.DoesNotExist:
+            return None

src/accounts/views.py

@@ -1,3 +1,7 @@
+# 模块说明：
+# 该模块定义了与用户账户相关的视图，包括注册、登录、注销、忘记密码等功能。
+# 使用 Django 的类视图和表单视图来处理用户请求。
+
 import logging
 from django.utils.translation import gettext_lazy as _
 from django.conf import settings
@@ -28,23 +32,24 @@ from .models import BlogUser
 
 logger = logging.getLogger(__name__)
 
-
+# 注册视图
-# Create your views here.
-
 class RegisterView(FormView):
+    # 使用注册表单和模板
     form_class = RegisterForm
     template_name = 'account/registration_form.html'
 
     @method_decorator(csrf_protect)
     def dispatch(self, *args, **kwargs):
+        # 确保请求受 CSRF 保护
         return super(RegisterView, self).dispatch(*args, **kwargs)
 
     def form_valid(self, form):
+        # 表单验证通过后处理注册逻辑
         if form.is_valid():
-            user = form.save(False)
+            user = form.save(False)  # 创建用户但不保存到数据库
-            user.is_active = False
+            user.is_active = False  # 设置用户为未激活状态
-            user.source = 'Register'
+            user.source = 'Register'  # 标记用户来源
-            user.save(True)
+            user.save(True)  # 保存用户到数据库
             site = get_current_site().domain
             sign = get_sha256(get_sha256(settings.SECRET_KEY + str(user.id)))
 
@@ -70,82 +75,74 @@ class RegisterView(FormView):
                 ],
                 title='验证您的电子邮箱',
                 content=content)
-
+            # 重定向到结果页面
-            url = reverse('accounts:result') + \
+            url = reverse('accounts:result') + '?type=register&id=' + str(user.id)
-                  '?type=register&id=' + str(user.id)
             return HttpResponseRedirect(url)
         else:
-            return self.render_to_response({
+            # 如果表单无效，重新渲染表单
-                'form': form
+            return self.render_to_response({'form': form})
-            })
-
 
+# 注销视图
 class LogoutView(RedirectView):
-    url = '/login/'
+    url = '/login/'  # 注销后重定向到登录页面
 
     @method_decorator(never_cache)
     def dispatch(self, request, *args, **kwargs):
+        # 确保注销后页面不被缓存
         return super(LogoutView, self).dispatch(request, *args, **kwargs)
 
     def get(self, request, *args, **kwargs):
-        logout(request)
+        logout(request)  # 执行注销操作
-        delete_sidebar_cache()
+        delete_sidebar_cache()  # 清除侧边栏缓存
         return super(LogoutView, self).get(request, *args, **kwargs)
 
-
+# 登录视图
 class LoginView(FormView):
+    # 使用登录表单和模板
     form_class = LoginForm
     template_name = 'account/login.html'
-    success_url = '/'
+    success_url = '/'  # 登录成功后重定向的默认地址
     redirect_field_name = REDIRECT_FIELD_NAME
-    login_ttl = 2626560  # 一个月的时间
+    login_ttl = 2626560  # 设置会话过期时间为一个月
 
     @method_decorator(sensitive_post_parameters('password'))
     @method_decorator(csrf_protect)
     @method_decorator(never_cache)
     def dispatch(self, request, *args, **kwargs):
-
+        # 确保密码字段敏感、请求受 CSRF 保护且页面不被缓存
         return super(LoginView, self).dispatch(request, *args, **kwargs)
 
     def get_context_data(self, **kwargs):
-        redirect_to = self.request.GET.get(self.redirect_field_name)
+        # 获取上下文数据，添加重定向地址
-        if redirect_to is None:
+        redirect_to = self.request.GET.get(self.redirect_field_name, '/')
-            redirect_to = '/'
         kwargs['redirect_to'] = redirect_to
-
         return super(LoginView, self).get_context_data(**kwargs)
 
     def form_valid(self, form):
+        # 表单验证通过后处理登录逻辑
         form = AuthenticationForm(data=self.request.POST, request=self.request)
-
         if form.is_valid():
-            delete_sidebar_cache()
+            delete_sidebar_cache()  # 清除侧边栏缓存
-            logger.info(self.redirect_field_name)
+            auth.login(self.request, form.get_user())  # 执行登录操作
-
-            auth.login(self.request, form.get_user())
             if self.request.POST.get("remember"):
-                self.request.session.set_expiry(self.login_ttl)
+                self.request.session.set_expiry(self.login_ttl)  # 设置会话过期时间
             return super(LoginView, self).form_valid(form)
-            # return HttpResponseRedirect('/')
         else:
-            return self.render_to_response({
+            # 如果表单无效，重新渲染表单
-                'form': form
+            return self.render_to_response({'form': form})
-            })
 
     def get_success_url(self):
-
+        # 获取登录成功后的重定向地址
-        redirect_to = self.request.POST.get(self.redirect_field_name)
+        redirect_to = self.request.POST.get(self.redirect_field_name, self.success_url)
-        if not url_has_allowed_host_and_scheme(
+        if not url_has_allowed_host_and_scheme(url=redirect_to, allowed_hosts=[self.request.get_host()]):
-                url=redirect_to, allowed_hosts=[
-                    self.request.get_host()]):
             redirect_to = self.success_url
         return redirect_to
 
-
+# 账户结果视图
 def account_result(request):
+    # 处理注册或验证结果
     type = request.GET.get('type')
     id = request.GET.get('id')
-
     user = get_object_or_404(get_user_model(), id=id)
     logger.info(type)
     if user.is_active:
@@ -160,8 +157,8 @@ def account_result(request):
             c_sign = get_sha256(get_sha256(settings.SECRET_KEY + str(user.id)))
             sign = request.GET.get('sign')
             if sign != c_sign:
-                return HttpResponseForbidden()
+                return HttpResponseForbidden()  # 验证失败返回 403
-            user.is_active = True
+            user.is_active = True  # 激活用户
             user.save()
             content = '''
             恭喜您已经成功的完成邮箱验证，您现在可以使用您的账号来登录本站。
@@ -174,31 +171,30 @@ def account_result(request):
     else:
         return HttpResponseRedirect('/')
 
-
+# 忘记密码视图
 class ForgetPasswordView(FormView):
     form_class = ForgetPasswordForm
     template_name = 'account/forget_password.html'
 
     def form_valid(self, form):
+        # 表单验证通过后处理密码重置逻辑
         if form.is_valid():
             blog_user = BlogUser.objects.filter(email=form.cleaned_data.get("email")).get()
-            blog_user.password = make_password(form.cleaned_data["new_password2"])
+            blog_user.password = make_password(form.cleaned_data["new_password2"])  # 设置新密码
             blog_user.save()
-            return HttpResponseRedirect('/login/')
+            return HttpResponseRedirect('/login/')  # 重定向到登录页面
         else:
             return self.render_to_response({'form': form})
 
-
+# 忘记密码验证码视图
 class ForgetPasswordEmailCode(View):
-
     def post(self, request: HttpRequest):
+        # 处理验证码发送请求
         form = ForgetPasswordCodeForm(request.POST)
         if not form.is_valid():
             return HttpResponse("错误的邮箱")
         to_email = form.cleaned_data["email"]
-
+        code = generate_code()  # 生成验证码
-        code = generate_code()
+        utils.send_verify_email(to_email, code)  # 发送验证码邮件
-        utils.send_verify_email(to_email, code)
+        utils.set_code(to_email, code)  # 缓存验证码
-        utils.set_code(to_email, code)
-
         return HttpResponse("ok")

src/blog/admin.py

@@ -5,44 +5,55 @@ from django.urls import reverse
 from django.utils.html import format_html
 from django.utils.translation import gettext_lazy as _
 
-# Register your models here.
+# 导入相关模型
-from .models import Article
+from .models import Article, Category, Tag, Links, SideBar, BlogSettings
 
 
+# 自定义表单，用于文章模型的管理界面
 class ArticleForm(forms.ModelForm):
-    # body = forms.CharField(widget=AdminPagedownWidget())
+    # 可以在此处自定义字段的表单小部件
-
     class Meta:
         model = Article
         fields = '__all__'
 
 
+# 定义批量操作函数
 def makr_article_publish(modeladmin, request, queryset):
+    # 将选中的文章状态更新为“已发布”
     queryset.update(status='p')
 
 
 def draft_article(modeladmin, request, queryset):
+    # 将选中的文章状态更新为“草稿”
     queryset.update(status='d')
 
 
 def close_article_commentstatus(modeladmin, request, queryset):
+    # 将选中的文章评论状态更新为“关闭”
     queryset.update(comment_status='c')
 
 
 def open_article_commentstatus(modeladmin, request, queryset):
+    # 将选中的文章评论状态更新为“开启”
     queryset.update(comment_status='o')
 
 
+# 为批量操作函数添加描述
 makr_article_publish.short_description = _('Publish selected articles')
 draft_article.short_description = _('Draft selected articles')
 close_article_commentstatus.short_description = _('Close article comments')
 open_article_commentstatus.short_description = _('Open article comments')
 
 
+# 自定义文章管理界面
 class ArticlelAdmin(admin.ModelAdmin):
+    # 每页显示的记录数
     list_per_page = 20
+    # 可搜索的字段
     search_fields = ('body', 'title')
+    # 使用自定义表单
     form = ArticleForm
+    # 列表显示的字段
     list_display = (
         'id',
         'title',
@@ -53,17 +64,28 @@ class ArticlelAdmin(admin.ModelAdmin):
         'status',
         'type',
         'article_order')
+    # 可点击进入详情的字段
     list_display_links = ('id', 'title')
+    # 列表过滤器
     list_filter = ('status', 'type', 'category')
+    # 按日期层级显示
+    date_hierarchy = 'creation_time'
+    # 多对多字段的水平过滤器
     filter_horizontal = ('tags',)
+    # 排除的字段
     exclude = ('creation_time', 'last_modify_time')
+    # 是否允许在站点上查看
     view_on_site = True
+    # 批量操作
     actions = [
         makr_article_publish,
         draft_article,
         close_article_commentstatus,
         open_article_commentstatus]
+    # 使用原始 ID 字段显示外键
+    raw_id_fields = ('author', 'category',)
 
+    # 自定义显示分类链接
     def link_to_category(self, obj):
         info = (obj.category._meta.app_label, obj.category._meta.model_name)
         link = reverse('admin:%s_%s_change' % info, args=(obj.category.id,))
@@ -71,42 +93,59 @@ class ArticlelAdmin(admin.ModelAdmin):
 
     link_to_category.short_description = _('category')
 
+    # 自定义表单的查询集
     def get_form(self, request, obj=None, **kwargs):
         form = super(ArticlelAdmin, self).get_form(request, obj, **kwargs)
+        # 限制作者字段仅显示超级用户
         form.base_fields['author'].queryset = get_user_model(
         ).objects.filter(is_superuser=True)
         return form
 
+    # 保存模型时的自定义逻辑
     def save_model(self, request, obj, form, change):
         super(ArticlelAdmin, self).save_model(request, obj, form, change)
 
+    # 自定义站点查看 URL
     def get_view_on_site_url(self, obj=None):
         if obj:
+            # 如果对象存在，返回其完整 URL
             url = obj.get_full_url()
             return url
         else:
+            # 否则返回当前站点的域名
             from djangoblog.utils import get_current_site
             site = get_current_site().domain
             return site
 
 
+# 自定义标签管理界面
 class TagAdmin(admin.ModelAdmin):
+    # 排除的字段
     exclude = ('slug', 'last_mod_time', 'creation_time')
 
 
+# 自定义分类管理界面
 class CategoryAdmin(admin.ModelAdmin):
+    # 列表显示的字段
     list_display = ('name', 'parent_category', 'index')
+    # 排除的字段
     exclude = ('slug', 'last_mod_time', 'creation_time')
 
 
+# 自定义链接管理界面
 class LinksAdmin(admin.ModelAdmin):
+    # 排除的字段
     exclude = ('last_mod_time', 'creation_time')
 
 
+# 自定义侧边栏管理界面
 class SideBarAdmin(admin.ModelAdmin):
+    # 列表显示的字段
     list_display = ('name', 'content', 'is_enable', 'sequence')
+    # 排除的字段
     exclude = ('last_mod_time', 'creation_time')
 
 
+# 自定义博客设置管理界面
 class BlogSettingsAdmin(admin.ModelAdmin):
     pass

src/blog/documents.py

@@ -7,9 +7,11 @@ from elasticsearch_dsl.connections import connections
 
 from blog.models import Article
 
+# 检查是否启用了 Elasticsearch
 ELASTICSEARCH_ENABLED = hasattr(settings, 'ELASTICSEARCH_DSL')
 
 if ELASTICSEARCH_ENABLED:
+    # 创建 Elasticsearch 连接
     connections.create_connection(
         hosts=[settings.ELASTICSEARCH_DSL['default']['hosts']])
     from elasticsearch import Elasticsearch
@@ -19,8 +21,10 @@ if ELASTICSEARCH_ENABLED:
 
     c = IngestClient(es)
     try:
+        # 检查是否存在名为 'geoip' 的 pipeline
         c.get_pipeline('geoip')
     except elasticsearch.exceptions.NotFoundError:
+        # 如果不存在，则创建 'geoip' pipeline
         c.put_pipeline('geoip', body='''{
               "description" : "Add geoip info",
               "processors" : [
@@ -33,6 +37,7 @@ if ELASTICSEARCH_ENABLED:
             }''')
 
 
+# 定义 GeoIP 信息的内部文档
 class GeoIp(InnerDoc):
     continent_name = Keyword()
     country_iso_code = Keyword()
@@ -40,21 +45,25 @@ class GeoIp(InnerDoc):
     location = GeoPoint()
 
 
+# 定义用户代理浏览器信息的内部文档
 class UserAgentBrowser(InnerDoc):
     Family = Keyword()
     Version = Keyword()
 
 
+# 定义用户代理操作系统信息的内部文档
 class UserAgentOS(UserAgentBrowser):
     pass
 
 
+# 定义用户代理设备信息的内部文档
 class UserAgentDevice(InnerDoc):
     Family = Keyword()
     Brand = Keyword()
     Model = Keyword()
 
 
+# 定义用户代理信息的内部文档
 class UserAgent(InnerDoc):
     browser = Object(UserAgentBrowser, required=False)
     os = Object(UserAgentOS, required=False)
@@ -63,6 +72,7 @@ class UserAgent(InnerDoc):
     is_bot = Boolean()
 
 
+# 定义性能日志的 Elasticsearch 文档
 class ElapsedTimeDocument(Document):
     url = Keyword()
     time_taken = Long()
@@ -72,6 +82,7 @@ class ElapsedTimeDocument(Document):
     useragent = Object(UserAgent, required=False)
 
     class Index:
+        # 定义索引名称和设置
         name = 'performance'
         settings = {
             "number_of_shards": 1,
@@ -82,9 +93,11 @@ class ElapsedTimeDocument(Document):
         doc_type = 'ElapsedTime'
 
 
+# 定义性能日志文档的管理器
 class ElaspedTimeDocumentManager:
     @staticmethod
     def build_index():
+        # 创建 Elasticsearch 索引
         from elasticsearch import Elasticsearch
         client = Elasticsearch(settings.ELASTICSEARCH_DSL['default']['hosts'])
         res = client.indices.exists(index="performance")
@@ -93,12 +106,14 @@ class ElaspedTimeDocumentManager:
 
     @staticmethod
     def delete_index():
+        # 删除 Elasticsearch 索引
         from elasticsearch import Elasticsearch
         es = Elasticsearch(settings.ELASTICSEARCH_DSL['default']['hosts'])
         es.indices.delete(index='performance', ignore=[400, 404])
 
     @staticmethod
     def create(url, time_taken, log_datetime, useragent, ip):
+        # 创建性能日志文档
         ElaspedTimeDocumentManager.build_index()
         ua = UserAgent()
         ua.browser = UserAgentBrowser()
@@ -130,6 +145,7 @@ class ElaspedTimeDocumentManager:
         doc.save(pipeline="geoip")
 
 
+# 定义文章的 Elasticsearch 文档
 class ArticleDocument(Document):
     body = Text(analyzer='ik_max_word', search_analyzer='ik_smart')
     title = Text(analyzer='ik_max_word', search_analyzer='ik_smart')
@@ -154,6 +170,7 @@ class ArticleDocument(Document):
     article_order = Integer()
 
     class Index:
+        # 定义索引名称和设置
         name = 'blog'
         settings = {
             "number_of_shards": 1,
@@ -164,20 +181,25 @@ class ArticleDocument(Document):
         doc_type = 'Article'
 
 
+# 定义文章文档的管理器
 class ArticleDocumentManager():
 
     def __init__(self):
+        # 初始化时创建索引
         self.create_index()
 
     def create_index(self):
+        # 创建 Elasticsearch 索引
         ArticleDocument.init()
 
     def delete_index(self):
+        # 删除 Elasticsearch 索引
         from elasticsearch import Elasticsearch
         es = Elasticsearch(settings.ELASTICSEARCH_DSL['default']['hosts'])
         es.indices.delete(index='blog', ignore=[400, 404])
 
     def convert_to_doc(self, articles):
+        # 将文章对象转换为 Elasticsearch 文档
         return [
             ArticleDocument(
                 meta={
@@ -202,6 +224,7 @@ class ArticleDocumentManager():
                 article_order=article.article_order) for article in articles]
 
     def rebuild(self, articles=None):
+        # 重建索引并重新保存文档
         ArticleDocument.init()
         articles = articles if articles else Article.objects.all()
         docs = self.convert_to_doc(articles)
@@ -209,5 +232,6 @@ class ArticleDocumentManager():
             doc.save()
 
     def update_docs(self, docs):
+        # 更新文档
         for doc in docs:
-            doc.save()
+            doc.save()

src/blog/middleware.py

@@ -0,0 +1,71 @@
+import logging
+import time
+
+from ipware import get_client_ip  # 用于获取客户端的 IP 地址
+from user_agents import parse  # 用于解析用户代理字符串
+
+from blog.documents import ELASTICSEARCH_ENABLED, ElaspedTimeDocumentManager  # 导入 Elasticsearch 配置和文档管理器
+
+logger = logging.getLogger(__name__)  # 设置日志记录器
+
+
+class OnlineMiddleware(object):
+    def __init__(self, get_response=None):
+        """
+        初始化中间件，接收 Django 的 get_response 方法。
+        """
+        self.get_response = get_response
+        super().__init__()
+
+    def __call__(self, request):
+        """
+        中间件的主要逻辑，用于记录页面渲染时间并将其存储到 Elasticsearch。
+        """
+        # 记录请求开始时间
+        start_time = time.time()
+        
+        # 调用下一个中间件或视图
+        response = self.get_response(request)
+        
+        # 获取 HTTP 用户代理字符串
+        http_user_agent = request.META.get('HTTP_USER_AGENT', '')
+        
+        # 获取客户端 IP 地址
+        ip, _ = get_client_ip(request)
+        
+        # 解析用户代理字符串
+        user_agent = parse(http_user_agent)
+        
+        # 如果响应不是流式的，处理渲染时间
+        if not response.streaming:
+            try:
+                # 计算页面渲染时间
+                cast_time = time.time() - start_time
+                
+                # 如果启用了 Elasticsearch，将数据存储到 Elasticsearch
+                if ELASTICSEARCH_ENABLED:
+                    time_taken = round((cast_time) * 1000, 2)  # 将时间转换为毫秒并保留两位小数
+                    url = request.path  # 获取请求的 URL
+                    
+                    # 获取当前时间
+                    from django.utils import timezone
+                    
+                    # 创建 Elasticsearch 文档
+                    ElaspedTimeDocumentManager.create(
+                        url=url,
+                        time_taken=time_taken,
+                        log_datetime=timezone.now(),
+                        useragent=user_agent,
+                        ip=ip
+                    )
+                
+                # 替换响应内容中的占位符 <!!LOAD_TIMES!!> 为渲染时间
+                response.content = response.content.replace(
+                    b'<!!LOAD_TIMES!!>', str.encode(str(cast_time)[:5])
+                )
+            except Exception as e:
+                # 如果发生异常，记录错误日志
+                logger.error("Error OnlineMiddleware: %s" % e)
+
+        # 返回响应
+        return response

src/blog/static/account/css/account.css

@@ -0,0 +1,9 @@
+.button {
+    border: none;
+    padding: 4px 80px;
+    text-align: center;
+    text-decoration: none;
+    display: inline-block;
+    font-size: 16px;
+    margin: 4px 2px;
+}

src/blog/static/account/js/account.js

@@ -0,0 +1,47 @@
+let wait = 60;
+
+function time(o) {
+    if (wait == 0) {
+        o.removeAttribute("disabled");
+        o.value = "获取验证码";
+        wait = 60
+        return false
+    } else {
+        o.setAttribute("disabled", true);
+        o.value = "重新发送(" + wait + ")";
+        wait--;
+        setTimeout(function () {
+                time(o)
+            },
+            1000)
+    }
+}
+
+document.getElementById("btn").onclick = function () {
+    let id_email = $("#id_email")
+    let token = $("*[name='csrfmiddlewaretoken']").val()
+    let ts = this
+    let myErr = $("#myErr")
+    $.ajax(
+        {
+            url: "/forget_password_code/",
+            type: "POST",
+            data: {
+                "email": id_email.val(),
+                "csrfmiddlewaretoken": token
+            },
+            success: function (result) {
+                if (result != "ok") {
+                    myErr.remove()
+                    id_email.after("<ul className='errorlist' id='myErr'><li>" + result + "</li></ul>")
+                    return
+                }
+                myErr.remove()
+                time(ts)
+            },
+            error: function (e) {
+                alert("发送失败,请重试")
+            }
+        }
+    );
+}

src/blog/static/assets/css/ie10-viewport-bug-workaround.css

@@ -0,0 +1,13 @@
+/*!
+ * IE10 viewport hack for Surface/desktop Windows 8 bug
+ * Copyright 2014-2015 Twitter, Inc.
+ * Licensed under MIT (https://github.com/twbs/bootstrap/blob/master/LICENSE)
+ */
+
+/*
+ * See the Getting Started docs for more information:
+ * http://getbootstrap.com/getting-started/#support-ie10-width
+ */
+@-ms-viewport     { width: device-width; }
+@-o-viewport      { width: device-width; }
+@viewport         { width: device-width; }