from django.db import models
from utils.models import BaseModel
from tinymce.models import HTMLField

class GoodsCategory(BaseModel):
    """商品类别表"""
    name = models.CharField(max_length=20, verbose_name="名称")
    logo = models.CharField(max_length=100, verbose_name="标识")
    image = models.ImageField(upload_to="category", verbose_name="图片")

    class Meta:
        db_table = "df_goods_category"
        verbose_name = "商品类别"  # admin站点使用
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.name


class Goods(BaseModel):
    """商品SPU表"""
    name = models.CharField(max_length=100, verbose_name="名称")
    desc = HTMLField(verbose_name="详细介绍", default="", blank=True)

    class Meta:
        db_table = "df_goods"
        verbose_name = "商品"
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.name


class GoodsSKU(BaseModel):
    """商品SKU表"""
    category = models.ForeignKey(GoodsCategory, verbose_name="类别")
    goods = models.ForeignKey(Goods, verbose_name="商品")
    name = models.CharField(max_length=100, verbose_name="名称")
    title = models.CharField(max_length=200, verbose_name="简介")
    unit = models.CharField(max_length=10, verbose_name="销售单位")
    price = models.DecimalField(max_digits=10, decimal_places=2, verbose_name="价格")
    stock = models.IntegerField(default=0, verbose_name="库存")
    sales = models.IntegerField(default=0, verbose_name="销量")
    default_image = models.ImageField(upload_to="goods", verbose_name="图片")
    status = models.BooleanField(default=True, verbose_name="是否上线")

    class Meta:
        db_table = "df_goods_sku"
        verbose_name = "商品SKU"
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.name


class GoodsImage(BaseModel):
    """商品图片"""
    sku = models.ForeignKey(GoodsSKU, verbose_name="商品SKU")
    image = models.ImageField(upload_to="goods", verbose_name="图片")

    class Meta:
        db_table = "df_goods_image"
        verbose_name = "商品图片"
        verbose_name_plural = verbose_name

    def __str__(self):
        return str(self.sku)


class IndexGoodsBanner(BaseModel):
    """主页轮播商品展示"""
    sku = models.ForeignKey(GoodsSKU, verbose_name="商品SKU")
    image = models.ImageField(upload_to="banner", verbose_name="图片")
    index = models.SmallIntegerField(default=0, verbose_name="顺序")

    class Meta:
        db_table = "df_index_goods"
        verbose_name = "主页轮播商品"
        verbose_name_plural = verbose_name

    def __str__(self):
        return str(self.sku)


class IndexCategoryGoodsBanner(BaseModel):
    """主页分类商品展示"""
    DISPLAY_TYPE_CHOICES = (
        (0, "标题"),
        (1, "图片")
    )
    category = models.ForeignKey(GoodsCategory, verbose_name="商品类别")
    sku = models.ForeignKey(GoodsSKU, verbose_name="商品SKU")
    display_type = models.SmallIntegerField(choices=DISPLAY_TYPE_CHOICES, verbose_name="展示类型")
    index = models.SmallIntegerField(default=0, verbose_name="顺序")

    class Meta:
        db_table = "df_index_category_goods"
        verbose_name = "主页分类展示商品"
        verbose_name_plural = verbose_name

    def __str__(self):
        return str(self.sku)


class IndexPromotionBanner(BaseModel):
    """主页促销活动展示"""
    name = models.CharField(max_length=50, verbose_name="活动名称")
    url = models.URLField(verbose_name="活动连接")
    image = models.ImageField(upload_to="banner", verbose_name="图片")
    index = models.SmallIntegerField(default=0, verbose_name="顺序")

    class Meta:
        db_table = "df_index_promotion"
        verbose_name = "主页促销活动"
        verbose_name_plural = verbose_name

    def __str__(self):
        return self.name

from django.db import models
from utils.models import BaseModel
from users.models import User, Address
from goods.models import GoodsSKU

class OrderInfo(BaseModel):
    """订单信息"""
    PAY_METHODS = {
        1: "货到付款",
        2: "支付宝",
    }

    PAY_METHODS_ENUM = {
        "CASH": 1,
        "ALIPAY": 2
    }

    PAY_METHOD_CHOICES = (
        (1, "货到付款"),
        (2, "支付宝"),
    )

    ORDER_STATUS = {
        1: "待支付",
        2: "待发货",
        3: "待收货",
        4: "待评价",
        5: "已完成",
    }

    ORDER_STATUS_ENUM = {
        "UNPAID": 1,
        "UNSEND": 2,
        "UNRECEIVED": 3,
        "UNCOMMENT": 4,
        "FINISHED": 5
    }

    ORDER_STATUS_CHOICES = (
        (1, "待支付"),
        (2, "待发货"),
        (3, "待收货"),
        (4, "待评价"),
        (5, "已完成"),
    )

    order_id = models.CharField(max_length=64, primary_key=True, verbose_name="订单号")
    user = models.ForeignKey(User, verbose_name="下单用户")
    address = models.ForeignKey(Address, verbose_name="收获地址")
    total_count = models.IntegerField(default=1, verbose_name="商品总数")
    total_amount = models.DecimalField(max_digits=10, decimal_places=2, verbose_name="商品总金额")
    trans_cost = models.DecimalField(max_digits=10, decimal_places=2, verbose_name="运费")
    pay_method = models.SmallIntegerField(choices=PAY_METHOD_CHOICES, default=1, verbose_name="支付方式")
    status = models.SmallIntegerField(choices=ORDER_STATUS_CHOICES, default=1, verbose_name="订单状态")
    trade_id = models.CharField(max_length=100, unique=True, null=True, blank=True, verbose_name="支付编号")

    class Meta:
        db_table = "df_order_info"


class OrderGoods(BaseModel):
    """订单商品"""
    order = models.ForeignKey(OrderInfo, verbose_name="订单")
    sku = models.ForeignKey(GoodsSKU, verbose_name="订单商品")
    count = models.IntegerField(default=1, verbose_name="数量")
    price = models.DecimalField(max_digits=10, decimal_places=2, verbose_name="单价")
    comment = models.TextField(default="", verbose_name="评价信息")

    class Meta:
        db_table = "df_order_goods"

DATABASES = {
    ‘default‘: {
        ‘ENGINE‘: ‘django.db.backends.mysql‘,
        ‘NAME‘: ‘dailyfresh‘,
        ‘HOST‘: ‘192.168.24.136‘, # MySQL数据库地址
        ‘PORT‘: ‘3306‘,
        ‘USER‘: ‘root‘,
        ‘PASSWORD‘: ‘mysql‘,
    }
}

  urlpatterns = [
      url(r‘^admin/‘, include(admin.site.urls)),
      # 访问用户模块的路由配置
      url(r‘^users/‘, include(‘apps.users.urls‘,namespace=‘users‘)),
  ]

  urlpatterns = [from django.conf.urls import url
  from apps.users import views

  urlpatterns = [
      # 注册
      url(r‘^register$‘, views.register, name=‘register‘),
  ]

 def register(request):
    """处理注册"""

    # 获取请求方法，判断是GET/POST请求
    if request.method == ‘GET‘:
        # 处理GET请求，返回注册页面
        return render(request, ‘register.html‘)
    else:
        # 处理POST请求，实现注册逻辑
        return HttpResponse(‘这里实现注册逻辑‘)

class RegisterView(View):
    """类视图：处理注册"""

    def get(self, request):
        """处理GET请求，返回注册页面"""
        return render(request, ‘register.html‘)

    def post(self, request):
        """处理POST请求，实现注册逻辑"""
        return HttpResponse(‘这里实现注册逻辑‘)

urlpatterns = [
    # 视图函数：注册
    # url(r‘^register$‘, views.register, name=‘register‘),
    # 类视图：注册
    url(r‘^register$‘, views.RegisterView.as_view(), name=‘register‘),
]

class RegisterView(View):
    """类视图：处理注册"""

    def get(self, request):
        """处理GET请求，返回注册页面"""
        return render(request, ‘register.html‘)

    def post(self, request):
        """处理POST请求，实现注册逻辑"""

        # 获取注册请求参数
        user_name = request.POST.get(‘user_name‘)
        password = request.POST.get(‘pwd‘)
        email = request.POST.get(‘email‘)
        allow = request.POST.get(‘allow‘)

        return HttpResponse(‘这里实现注册逻辑‘)

class RegisterView(View):
    """类视图：处理注册"""

    def get(self, request):
        """处理GET请求，返回注册页面"""
        return render(request, ‘register.html‘)

    def post(self, request):
        """处理POST请求，实现注册逻辑"""

        # 获取注册请求参数
        user_name = request.POST.get(‘user_name‘)
        password = request.POST.get(‘pwd‘)
        email = request.POST.get(‘email‘)
        allow = request.POST.get(‘allow‘)

        # 参数校验：缺少任意一个参数，就不要在继续执行
        if not all([user_name, password, email]):
            return redirect(reverse(‘users:register‘))
        # 判断邮箱
        if not re.match(r"^[a-z0-9][\w\.\-]*@[a-z0-9\-]+(\.[a-z]{2,5}){1,2}$", email):
            return render(request, ‘register.html‘, {‘errmsg‘:‘邮箱格式不正确‘})
        # 判断是否勾选协
        if allow != ‘on‘:
            return render(request, ‘register.html‘, {‘errmsg‘: ‘没有勾选用户协议‘})

        return HttpResponse(‘这里实现注册逻辑‘)

class RegisterView(View):
    """类视图：处理注册"""

    def get(self, request):
        """处理GET请求，返回注册页面"""
        return render(request, ‘register.html‘)

    def post(self, request):
        """处理POST请求，实现注册逻辑"""

        # 获取注册请求参数
        user_name = request.POST.get(‘user_name‘)
        password = request.POST.get(‘pwd‘)
        email = request.POST.get(‘email‘)
        allow = request.POST.get(‘allow‘)

        # 参数校验：缺少任意一个参数，就不要在继续执行
        if not all([user_name, password, email]):
            return redirect(reverse(‘users:register‘))
        # 判断邮箱
        if not re.match(r"^[a-z0-9][\w\.\-]*@[a-z0-9\-]+(\.[a-z]{2,5}){1,2}$", email):
            return render(request, ‘register.html‘, {‘errmsg‘:‘邮箱格式不正确‘})
        # 判断是否勾选协
        if allow != ‘on‘:
            return render(request, ‘register.html‘, {‘errmsg‘: ‘没有勾选用户协议‘})

        # 保存数据到数据库
        try:
            # 隐私信息需要加密，可以直接使用django提供的用户认证系统完成
            user = User.objects.create_user(user_name, email, password)
        except db.IntegrityError:
            return render(request, ‘register.html‘, {‘errmsg‘: ‘用户已注册‘})

        # 手动的将用户认证系统默认的激活状态is_active设置成False,默认是True
        user.is_active = False
        # 保存数据到数据库
        user.save()

        return HttpResponse(‘这里实现注册逻辑‘)

# 查询出数据，并以列表形式展示
select * from df_users \G

class ActiveView(View):
    """邮件激活"""

    def get(self, request, token):
        """处理激活请求"""
        pass

# 邮件激活
url(r‘^active/(?P<token>.+)$‘, views.ActiveView.as_view(), name=‘active‘),

pip install itsdangerous

from itsdangerous import TimedJSONWebSignatureSerializer as Serializer
from django.conf import settings

class User(AbstractUser, BaseModel):
  """用户"""
  class Meta:
      db_table = "df_users"

  def generate_active_token(self):
      """生成激活令牌"""
      serializer = Serializer(settings.SECRET_KEY, 3600)
      token = serializer.dumps({"confirm": self.id})  # 返回bytes类型
      return token.decode()

EMAIL_BACKEND = ‘django.core.mail.backends.smtp.EmailBackend‘ # 导入邮件模块
EMAIL_HOST = ‘smtp.yeah.net‘ # 发邮件主机
EMAIL_PORT = 25 # 发邮件端口
EMAIL_HOST_USER = ‘dailyfreshzxc@yeah.net‘ # 授权的邮箱
EMAIL_HOST_PASSWORD = ‘dailyfresh123‘ # 邮箱授权时获得的密码，非注册登录密码
EMAIL_FROM = ‘天天生鲜<dailyfreshzxc@yeah.net>‘ # 发件人抬头

from django.core.mail import send_mail
from django.conf import settings

def send_active_email(to_email, user_name, token):
    """封装发送邮件方法"""
    subject = "天天生鲜用户激活"  # 标题
    body = ""  # 文本邮件体
    sender = settings.EMAIL_FROM  # 发件人
    receiver = [to_email]  # 接收人
    html_body = ‘<h1>尊敬的用户 %s, 感谢您注册天天生鲜！</h1>‘                 ‘<br/><p>请点击此链接激活您的帐号<a href="http://127.0.0.1:8000/users/active/%s">‘                 ‘http://127.0.0.1:8000/users/active/%s</a></p>‘ % (user_name, token, token)
    send_mail(subject, body, sender, receiver, html_message=html_body)

  from celery import Celery
  from django.core.mail import send_mail
  from django.conf import settings

  # 创建celery应用对象
  app = Celery(‘celery_tasks.tasks‘, broker=‘redis://192.168.243.191:6379/4‘)

  @app.task
  def send_active_email(to_email, user_name, token):
      """发送激活邮件"""

      subject = "天天生鲜用户激活"  # 标题
      body = ""  # 文本邮件体
      sender = settings.EMAIL_FROM  # 发件人
      receiver = [to_email]  # 接收人
      html_body = ‘<h1>尊敬的用户 %s, 感谢您注册天天生鲜！</h1>‘                   ‘<br/><p>请点击此链接激活您的帐号<a href="http://127.0.0.1:8000/users/active/%s">‘                   ‘http://127.0.0.1:8000/users/active/%s</a></p>‘ %(user_name, token, token)
      send_mail(subject, body, sender, receiver, html_message=html_body)

import os 
os.environ["DJANGO_SETTINGS_MODULE"] = "dailyfresh.settings"
# 放到Celery服务器上时添加的代码
import django
django.setup()

class ActiveView(View):
    """用户激活"""

    def get(self, request, token):
        # 创建序列化器
        serializer = Serializer(settings.SECRET_KEY, 3600)

        try:
            # 使用序列化器，获取token明文信息,需要判断签名是否过期
            result = serializer.loads(token)
        except SignatureExpired:
            # 提示激活链接已过期
            return HttpResponse(‘激活链接已过期‘)

        # 获取用户id
        user_id = result.get(‘confirm‘)

        try:
            # 查询需要激活的用户,需要判断查询的用户是否存在
            user = User.objects.get(id=user_id)
        except User.DoesNotExist:
            # 提示用户不存在
            return HttpResponse(‘用户不存在‘)

        # 设置激活用户的is_active为Ture
        user.is_active = True
        # 保存数据到数据库
        user.save()

        # 响应信息给客户端
        return redirect(reverse(‘users:login‘))

class LoginView(View):
    """登陆"""

    def get(self, request):
        """响应登陆页面"""
        return render(request, ‘login.html‘)

    def post(self, request):
        """处理登陆逻辑"""

        # 获取用户名和密码
        user_name = request.POST.get(‘username‘)
        password = request.POST.get(‘pwd‘)

        # 参数校验
        if not all([user_name, password]):
            return redirect(reverse(‘users:login‘))

        # django用户认证系统判断是否登陆成功
        user = authenticate(username=user_name, password=password)

        # 验证登陆失败
        if user is None:
            # 响应登录页面，提示用户名或密码错误
            return render(request, ‘login.html‘, {‘errmsg‘:‘用户名或密码错误‘})

        # 验证登陆成功，并判断是否是激活用户
        if user.is_active is False:
            # 如果不是激活用户
            return render(request, ‘login.html‘, {‘errmsg‘:‘用户未激活‘})

        # 使用django的用户认证系统，在session中保存用户的登陆状态
        login(request, user)

        # 登陆成功，重定向到主页
        return redirect(reverse(‘goods:index‘))

# 获取是否勾选‘记住用户名‘
remembered = request.POST.get(‘remembered‘)

# 登入用户
login(request, user)

# 判断是否是否勾选‘记住用户名‘
if remembered != ‘on‘:
    # 没有勾选，不需要记住cookie信息，浏览会话结束后过期
    request.session.set_expiry(0)
else:
    # 已勾选，需要记住cookie信息，两周后过期
    request.session.set_expiry(None)

# 响应结果: 重定向到主页
return redirect(reverse(‘goods:index‘))

  class LogoutView(View):
      """退出登录"""

      def get(self, request):
          """处理退出登录逻辑"""

          # 由Django用户认证系统完成：需要清理cookie和session,request参数中有user对象
          logout(request)
          # 退出后跳转：由产品经理设计
          return redirect(reverse(‘goods:index‘))