#創(chuàng)建一個(gè)項(xiàng)目，名稱為blogs
django-admin.exe startproject blogs 
#進(jìn)入項(xiàng)目目錄
cd blogs
#創(chuàng)建一個(gè)應(yīng)用，注應(yīng)用名稱不能與項(xiàng)目名稱相同
python manage.py startapp blog

from django.contrib import admin
from django.urls import path
from blog.views import *

urlpatterns = [
    path('admin/', admin.site.urls),
    path('', indexes),
    path('blog/', index),
    path('start/', start_scrapy),
]

import pymysql  #引用mysql驅(qū)動(dòng)
pymysql.install_as_MySQLdb()

ALLOWED_HOSTS = ["*"]#允許全部主機(jī)訪問


# Application definition

INSTALLED_APPS = [
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'blog',#添加創(chuàng)建的應(yīng)用模塊
    'bootstrap3',#如果需要使用bootstrap框架，需要安裝django-bootstrap3插件
]

DATABASES = {#配置數(shù)據(jù)庫鏈接屬性
    # 'default': {
    #     'ENGINE': 'django.db.backends.sqlite3',
    #     'NAME': os.path.join(BASE_DIR, 'db.sqlite3'),
    # }
    'default': {
        'ENGINE': 'django.db.backends.mysql',  # 或者使用 mysql.connector.django
        'NAME': 'blog',
        'USER': 'root',
        'PASSWORD': '@bjive321',
        'HOST': '59.110.138.8',
        'PORT': '3306',
    }
}

from django.db import models

# Create your models here.

class Blog(models.Model):
    title = models.CharField(u'標(biāo)題', max_length=64)
    content = models.TextField(u'內(nèi)容', default="")
    update_time = models.DateTimeField(u'更新時(shí)間', auto_now=True)
    pub_date = models.DateField(u'發(fā)布時(shí)間')
    author = models.CharField(u'作者', max_length=64, default=None)

    # update_time.editable = True
    # 列表中顯示的內(nèi)容
    def __str__(self):
        return "標(biāo)題:{},字?jǐn)?shù):{},概要:{}".format(self.title, len(self.content), self.content[:18])


class Spider(models.Model):
    #自定義主鍵
    # id = models.CharField(primary_key=True)
    date = models.DateField(u'日期')
    open = models.DecimalField(u'開盤價(jià)', max_digits=8, decimal_places=2)
    close = models.DecimalField(u'收盤價(jià)', max_digits=8, decimal_places=2)
    height = models.DecimalField(u'最高價(jià)', max_digits=8, decimal_places=2)
    low = models.DecimalField(u'最低價(jià)', max_digits=8, decimal_places=2)
    updownd = models.DecimalField(u'漲跌幅度', max_digits=8, decimal_places=2)
    turnrate = models.DecimalField(u'換手率', max_digits=8, decimal_places=2)
    count = models.DecimalField(u'總價(jià)', max_digits=8, decimal_places=2)

from django.contrib import admin
from blog.models import Blog, Spider


class ContactAdmin(admin.ModelAdmin):
    # 增加內(nèi)容時(shí)，將登陸人的賬號(hào)存入指定的字段中，models中要預(yù)留這個(gè)字段，這里是author
    def save_model(self, request, obj, form, change):
        if change:  # 更新操作返回true
            obj.save()
        else:  # 否則是新增
            obj.author = request.user
            obj.save()

    # 設(shè)置作者字段只讀
    readonly_fields = ("author",)

    # 過濾，只能查看操作登陸人自己創(chuàng)建的內(nèi)容
    def get_queryset(self, request):
        qs = super(ContactAdmin, self).get_queryset(request)
        if request.user.is_superuser:
            return qs
        return qs.filter(author=request.user)

    # listdisplay設(shè)置要顯示在列表中的字段（id字段是Django模型的默認(rèn)主鍵）
    list_display = ('title', 'update_time', 'pub_date', 'author')  # list
    search_fields = ('title', 'content',)  # 如果只有一個(gè)值，結(jié)尾必須有一個(gè)逗號(hào)，證明是list或元組
    # list_per_page設(shè)置每頁顯示多少條記錄，默認(rèn)是100條
    list_per_page = 5
    # ordering設(shè)置默認(rèn)排序字段，負(fù)號(hào)表示降序排序
    ordering = ('-update_time',)
    # list_editable 設(shè)置默認(rèn)可編輯字段,第一個(gè)字段不允許編輯
    list_editable = ['pub_date', ]
    # fk_fields 設(shè)置顯示外鍵字段
    # fk_fields = ('machine_room_id',)
    date_hierarchy = 'pub_date'


class SpiderAdmin(admin.ModelAdmin):
    list_display = ('date', 'open', 'close', 'height', 'low', 'updownd', 'turnrate', 'count')  # list
    date_hierarchy = 'date'
    # list_per_page設(shè)置每頁顯示多少條記錄，默認(rèn)是100條
    list_per_page = 20


# Register your models here.
admin.site.register(Blog, ContactAdmin)
admin.site.register(Spider, SpiderAdmin)
# 設(shè)置登陸窗口的標(biāo)題
admin.site.site_header = '屌炸天系統(tǒng)'
# 設(shè)置頁簽標(biāo)題
admin.site.site_title = '牛逼轟轟'

$ python manage.py migrate   # 創(chuàng)建表結(jié)構(gòu),默認(rèn)創(chuàng)建admin模塊表
$ python manage.py makemigrations blog  # 讓 Django 知道我們在我們的模型有一些變更
$ python manage.py migrate blog  # 創(chuàng)建自定義表結(jié)構(gòu)
$ python manage.py createsuperuser #創(chuàng)建后臺(tái)管理員賬號(hào)

import base64
from io import BytesIO

import requests
from django.http import JsonResponse
from django.shortcuts import render
import markdown
# Create your views here.

import blog.models as m
import pandas as pd
import matplotlib
from matplotlib import pyplot as plt


# 查詢
# models.UserInfo.objects.all()
# models.UserInfo.objects.all().values('user')    #只取user列
# models.UserInfo.objects.all().values_list('id','user')    #取出id和user列，并生成一個(gè)列表
# models.UserInfo.objects.get(id=1)
# models.UserInfo.objects.get(user='yangmv')

# 增
# models.UserInfo.objects.create(user='yangmv',pwd='123456')
# 或者
# obj = models.UserInfo(user='yangmv',pwd='123456')
# obj.save()
# 或者
# dic = {'user':'yangmv','pwd':'123456'}
# models.UserInfo.objects.create(**dic)

# 刪
# models.UserInfo.objects.filter(id=1).delete()

# 改
# models.UserInfo.objects.filter(user='yangmv').update(pwd='520')
# 或者
# obj = models.UserInfo.objects.get(user='yangmv')
# obj.pwd = '520'
# obj.save()
def index(request):
    i = request.GET.get('id')
    # postdata = request.POST['id']
    blog = m.Blog.objects.get(id=i)
    blog_content = markdown.markdown(blog.content)
    spider = m.Spider.objects.all().values()
    plot_data = showMatplot(pd.DataFrame(spider))
    imb = base64.b64encode(plot_data)  # 對plot_data進(jìn)行編碼
    ims = imb.decode()
    imd = "data:image/png;base64," + ims
    return render(request, "blog.html", {'blog': blog, 'blog_content': blog_content, 'img': imd})


def indexes(request):
    blogs = m.Blog.objects.all()
    return render(request, "blogs.html", {'blogs': blogs})

#圖標(biāo)嵌入django頁面
def showMatplot(df):
    plt.figure(figsize=(12, 10))  # 設(shè)置圖像大小
    plt.subplot(212)  # 布局兩行1列的第二個(gè)
    col = ['date', 'open', 'close', 'height', 'low', 'updownd', 'count']
    df = df.astype(
        {'open': 'float', 'close': 'float', 'height': 'float', 'low': 'float', 'updownd': 'float', 'count': 'float'})
    df = pd.DataFrame(df, columns=col)
    # print(df)
    # print("*" * 40)
    # # corr只能對數(shù)值型數(shù)據(jù)進(jìn)行相關(guān)度計(jì)算
    # print(df.corr())
    x = pd.to_datetime(df['date'])
    y1 = df["open"]
    y2 = df["close"]
    y3 = df["height"]
    y4 = df["low"]

    plt.plot(x, y1, label='open', linestyle='-', c='black', linewidth=1)
    plt.plot(x, y2, label='close', linestyle='--', c='r', linewidth=1)
    plt.plot(x, y3, label='height', linestyle=':', c='g', linewidth=1)
    plt.plot(x, y4, label='low', linestyle='-.', c='b', linewidth=1)
    plt.legend()
    plt.subplot(211)  # 布局兩行一列第一個(gè)
    df1 = df.sort_values(by='date', ascending=True)
    # df1 = df1.iloc[30:]
    col = ["date", "close"]
    close = pd.DataFrame(df1, columns=col)

    data = cal_macd_system(close, 12, 26, 9)
    x = pd.to_datetime(data['date'])
    # y = pd.to_numeric(data["close"])
    y1 = data["macd"]
    # plt.plot(x, y, label="k")
    plt.plot(x, y1, label="macd")
    plt.title("某公司股票", fontproperties=zhfont1, fontsize=15)
    plt.legend()
    buffer = BytesIO()
    plt.savefig(buffer)
    plot_data = buffer.getvalue()
    return plot_data

#下載字體放到項(xiàng)目目錄中，解決圖標(biāo)中文顯示
zhfont1 = matplotlib.font_manager.FontProperties(fname="FZSTK.TTF")

#macd指標(biāo)算法
def cal_macd_system(data, short_, long_, m):
    '''
    data是包含高開低收成交量的標(biāo)準(zhǔn)dataframe
    short_,long_,m分別是macd的三個(gè)參數(shù)
    返回值是包含原始數(shù)據(jù)和diff,dea,macd三個(gè)列的dataframe
    '''
    data['diff'] = data['close'].ewm(adjust=False, alpha=2 / (short_ + 1), ignore_na=True).mean() - \
                   data['close'].ewm(adjust=False, alpha=2 / (long_ + 1), ignore_na=True).mean()
    data['dea'] = data['diff'].ewm(adjust=False, alpha=2 / (m + 1), ignore_na=True).mean()
    data['macd'] = 2 * (data['diff'] - data['dea'])
    return data

#繪制macd指標(biāo)曲線
def macdview(df):
    df1 = df.sort_values(by='date', ascending=True)
    # df1 = df1.iloc[30:]
    col = ["date", "close"]
    close = pd.DataFrame(df1, columns=col)

    data = cal_macd_system(close, 12, 26, 9)
    x = pd.to_datetime(data['date'])
    # y = pd.to_numeric(data["close"])
    y1 = data["macd"]
    # plt.plot(x, y, label="k")
    plt.plot(x, y1, label="macd")
    plt.title("某公司股票", fontproperties=zhfont1, fontsize=15)
    # plt.legend()
    buffer = BytesIO()
    buffer.flush()
    plt.savefig(buffer)
    plot_data = buffer.getvalue()
    buffer.close()
    return plot_data

#在線啟動(dòng)爬蟲
def start_scrapy(request):
    # 獲取頁面?zhèn)鲄?，要區(qū)分請求類型是POST還是GET，不同請求用不同的方法接收參數(shù)
    year = request.POST.get('year')
    jd = request.POST.get('jd')
    url = 'http://127.0.0.1:6800/schedule.json'
    # spider是執(zhí)行scrapy list返回的名稱,參數(shù)問題：除了內(nèi)置key的參數(shù)外如project,spider等，其他參數(shù)均由爬蟲初始化函數(shù)的kwargs接收
    # 同時(shí)jobid也有kwargs接收，**kwargs是接收字典型的參數(shù)，帶有key值的
    data = {'project': 'pachong', 'spider': 'pachong_spider', 'year': year, 'jd': jd}
    print(requests.post(url=url, data=data))
    return JsonResponse({'result': 'ok'})

$python manage.py runserver 8080（不指定端口號(hào)的話默認(rèn)8000）