from django.db import models

# Create your models here.
class User(models.Model):
 name = models.CharField(max_length=100, verbose_name="博主名字")
 gender = models.CharField(max_length=6, choices=(('male', u'男'), ('female', '女')), default='female',
        verbose_name='性別')
 create_at = models.DateTimeField(auto_now_add=True, verbose_name='創(chuàng)建時(shí)間')

class Blog(models.Model):
 title = models.CharField(max_length=100, verbose_name='標(biāo)題')
 user = models.ForeignKey(User, null=True, blank=True, on_delete=models.SET_NULL, verbose_name='博主名字')
 content = models.TextField(verbose_name='博客內(nèi)容')
 create_at = models.DateTimeField(auto_now_add=True, verbose_name='創(chuàng)建時(shí)間')
 update_at = models.DateTimeField(auto_now=True, verbose_name='更新時(shí)間')

#!/usr/bin/env python
# encoding: utf-8

import graphene
from graphene_django.types import DjangoObjectType
from .models import User, Blog

class UserType(DjangoObjectType):
 class Meta:
  model = User

class BlogType(DjangoObjectType):
 class Meta:
  model = Blog

# 定義動(dòng)作約素輸入類型
class UserInput(graphene.InputObjectType):
 name = graphene.String(required=True)
 gender = graphene.String(required=True)

class BlogInput(graphene.InputObjectType):
 title = graphene.String(required=True)
 user = graphene.Int(required=True)
 content = graphene.String(required=True)

# 定義一個(gè)創(chuàng)建user的mutation
class CreateUser(graphene.Mutation):
 # api的輸入?yún)?shù)
 class Arguments:
  user_data = UserInput(required=True)

 # api的響應(yīng)參數(shù)
 ok = graphene.Boolean()
 user = graphene.Field(UserType)

 # api的相應(yīng)操作，這里是create
 def mutate(self, info, user_data):
  user = User.objects.create(name=user_data['name'], gender=user_data['gender'])
  ok = True
  return CreateUser(user=user, ok=ok)


# 定義一個(gè)創(chuàng)建博客的mutation
class CreateBlog(graphene.Mutation):
 class Arguments:
  blog_data = BlogInput(required=True)

 blog = graphene.Field(BlogType)

 def mutate(self, info, blog_data):
  # 插入到數(shù)據(jù)庫(kù)中
  blog = Blog.objects.create(title=blog_data['title'], user_id=blog_data['user'], content=blog_data['content'])
  return CreateBlog(blog=blog)

# 定義一個(gè)查詢語(yǔ)句
class Query(object):
 all_user = graphene.List(UserType)
 all_blog = graphene.List(BlogType)

 def resolve_all_user(self, info, **kwargs):
  # 查詢所有book的邏輯
  return User.objects.all()

 def resolve_all_blog(self, info, **kwargs):
  # 查詢所有title的邏輯
  return Blog.objects.all()

import graphene
import book.schema, blog.schema

class Query(blog.schema.Query, graphene.ObjectType):
 # 總的Schema的query入口
 pass

class Mutations(graphene.ObjectType):
 # 總的Schema的mutations入口
 create_user = blog.schema.CreateUser.Field()
 create_blog = blog.schema.CreateBlog.Field()

schema = graphene.Schema(query=Query, mutation=Mutations)

from django.contrib import admin
from django.urls import path
from graphene_django.views import GraphQLView
from .schema import schema
urlpatterns = [
 path('admin/', admin.site.urls),
 path('graphql/', GraphQLView.as_view(graphiql=True, schema=schema)),
]

# 定義一個(gè)總的mutation出口
class Mutation(graphene.AbstractType):
 create_user = CreateUser.Field()
 create_blog = CreateBlog.Field()

class Mutations(blog.schema.Mutation, graphene.ObjectType):
 # 總的Schema的mutations入口
 pass

class CreateUser(graphene.Mutation):
 # api的輸入?yún)?shù)(類名可以隨便定義)
 class Arguments:
  name = graphene.String(required=True)
  gender = graphene.String(required=True)

 # api的響應(yīng)參數(shù)
 ok = graphene.Boolean()
 user = graphene.Field(UserType)

 # api的相應(yīng)操作，這里是create
 def mutate(self, info, name, gender):
  user = User.objects.create(name=name, gender=gender)
  ok = True
  return CreateUser(user=user, ok=ok)

import graphene
from graphene_django.types import DjangoObjectType
from .models import Category, Ingredient

class CategoryType(DjangoObjectType):
 class Meta:
  model = Category

class IngredientType(DjangoObjectType):
 class Meta:
  model = Ingredient

# 定義一個(gè)查詢
class Query(object):
 # 定義一個(gè)根據(jù)id或者name查詢的
 category = graphene.Field(CategoryType,
        id=graphene.Int(),
        name=graphene.String())
 # 查詢?nèi)康?
 all_categories = graphene.List(CategoryType)
 # 根據(jù)條件查詢
 ingredient = graphene.Field(IngredientType,
        id=graphene.Int(),
        name=graphene.String())
 # 查詢?nèi)康?
 all_ingredients = graphene.List(IngredientType)

 def resolve_all_categories(self, info, **kwargs):
  return Category.objects.all()

 def resolve_all_ingredients(self, info, **kwargs):
  # We can easily optimize query count in the resolve method
  return Ingredient.objects.select_related('category').all()

 # 定義查詢語(yǔ)句
 def resolve_category(self, info, **kwargs):
  id = kwargs.get('id')
  name = kwargs.get('name')

  if id is not None:
   return Category.objects.get(pk=id)

  if name is not None:
   return Category.objects.get(name=name)

  return None

 def resolve_ingredient(self, info, **kwargs):
  id = kwargs.get('id')
  name = kwargs.get('name')

  if id is not None:
   return Ingredient.objects.get(pk=id)

  if name is not None:
   return Ingredient.objects.get(name=name)

  return None

from datetime import datetime
import time

# 每n秒執(zhí)行一次
def timer(n):
  while True:
    print(datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
    time.sleep(n)

timer(5)

from datetime import datetime
from threading import Timer

# 打印時(shí)間函數(shù)
def print_time(inc):
  print(datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
  """
  Timer的參數(shù)說(shuō)明
  inc:表示時(shí)間間隔
  print_time:執(zhí)行的函數(shù)
  (inc,):傳遞給執(zhí)行函數(shù)的參數(shù)
  """
  t = Timer(inc, print_time, (inc,))
  t.start()

print_time(2)

import time
import sched
from datetime import datetime

# 初始化 sched 模塊的 scheduler 類
# 第一個(gè)參數(shù)是一個(gè)可以返回時(shí)間戳的函數(shù)，第二個(gè)參數(shù)可以在定時(shí)未到達(dá)之前阻塞。
schedule = sched.scheduler(time.time, time.sleep)

# 被周期性調(diào)度觸發(fā)的函數(shù)
def print_time(inc):
  print(datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
  schedule.enter(inc, 0, print_time, (inc,))

# 默認(rèn)參數(shù) 60 s
def start(inc=60):
  # enter四個(gè)參數(shù)分別為：間隔事件、優(yōu)先級(jí)（用于同時(shí)間到達(dá)的兩個(gè)事件同時(shí)執(zhí)行時(shí)定序）、被調(diào)用觸發(fā)的函數(shù)、給觸發(fā)函數(shù)的參數(shù)（tuple形式）
  schedule.enter(0, 0, print_time, (inc,))
  schedule.run()

if __name__ == "__main__":
  start(10)

from apscheduler.schedulers.blocking import BlockingScheduler
from datetime import datetime


def job():
  print(datetime.now().strftime('%Y-%m-%d %H:%M:%S'))


if __name__ == "__main__":
  scheduler = BlockingScheduler()
  scheduler.add_job(job, 'interval', seconds=5)
  scheduler.start()