Dragonboard410c服务器系列六之用户交互系统

admin 管理员组

文章数量: 1087131

Dragonboard410c服务器系列六之用户交互系统

一.前言

本系列文章的前几篇,博主已经给大家分享过如何在Django框架下构建web用户登陆注册系统和实时视频分享的功能，今天，我们将其整合一下，并添加页面构成一套web用户的交互系统。

二.代码分析

1.代码架构

图1 代码架构

2.主代码分享

online/view.py

#coding=utf-8
from django.shortcuts import render,render_to_response
from django.http import HttpResponse,HttpResponseRedirect
from django.template import RequestContext
from django import forms
from online.models import MyUser
from online.models import Message
from online.models import SystemStatus
from django.contrib.auth import authenticate, login
from django.utils import timezone
import os
import json
import encodings
#表单class UserForm(forms.Form):username = forms.CharField(label='用户名',max_length=100)password = forms.CharField(label='密码',widget=forms.PasswordInput())#def getuser(forms):#    return forms.username#   password1 = forms.CharField(label='重复密码',widget=forms.TextInput())#   loginaddr="http://127.0.0.1:8000/online/login/"#   registaddr="http://127.0.0.1:8000/online/regist/"#注册
def regist(req):if req.method == 'POST':uf = UserForm(req.POST)if uf.is_valid():#获得表单数据username = uf.cleaned_data['username']password = uf.cleaned_data['password']password1 = req.POST['password1']#比较数据库中是否已有用户#user = myUser.objects.all().filter(username = username)#print(user)if MyUser.objects.filter(username =username).exists():return render_to_response('registfaild.html',{'uf':uf}, context_instance=RequestContext(req))else:if password1==password:user=MyUser.objects.create(username= username,password=password)#添加用户进数据库# profile=UserProfile()#e************************# profile.user_id=user.id# profile.phone=phone# profile.save()# user = MyUser.objects.create_user(username=username,password=password)print(user.is_staff) #True#user.set_password(password)user.save()print(user.id)#user.userID=user.id#user.save()#print(user.userID)#user_sum=MyUser.objects.all().values('username').count()#user.userID=user_sum#print(user.userID)#user.save()response = HttpResponseRedirect('/online/registsuccee/')return responseelse:return render_to_response('registfaild1.html',{'uf':uf}, context_instance=RequestContext(req))else:uf = UserForm()return render_to_response('regist.html',{'uf':uf}, context_instance=RequestContext(req))def createSystemstatus():#创建系统状态信息#SystemStatus.objects.filter().delete()SystemRecord=SystemStatus.objects.filter().count()#返回所有状态信息对象print('SystemRecord = ',SystemRecord)if SystemRecord == 0:#系统状态信息只创建一个，如已创建，则不再创建print('create systemstatus')systemstatus=SystemStatus()systemstatus.statusName="peopleInfront"systemstatus.statusValue=-1systemstatus.statusParam=0systemstatus.statusDiscirption="no people in front"systemstatus.save()print('statusName = ',systemstatus.statusName)print('statusDiscirption = ',systemstatus.statusDiscirption)else:print(' systemstatus had credted')#登陆
def loginin(req):
#    getAllUser(req)createSystemstatus()#创建全服务器唯一的系统状态对象user_firstflag=True #初始化接收用户选择标志位print(timezone.localtime(timezone.now()).strftime("%Y-%m-%d %H:%M:%S"))#获取本机IP#myname = socket.getfqdn(socket.gethostname(  ))#获取本机ip#myaddr = socket.gethostbyname(myname)#print('myname is ',myname,'myaddr = ',myaddr)if req.method == 'POST':uf = UserForm(req.POST)if uf.is_valid():#获取表单用户密码username = uf.cleaned_data['username']password = uf.cleaned_data['password']#获取的表单数据与数据库进行比较user = MyUser.objects.filter(username__exact = username,password__exact = password)#user = authenticate(username=username, password=password)if user:#比较成功，跳转indexresponse = HttpResponseRedirect('/online/index/')#good="xiaoms"#将username写入浏览器cookie,失效时间为3600response.set_cookie('username',username,3600)response.set_cookie('user_firstflag',user_firstflag,3600)#成功登陆后，第一次的用户是未选择接收者return responseelse:#比较失败，跳转loginfaildreturn render_to_response('loginfaild.html',{'uf':uf},context_instance=RequestContext(req))else:uf = UserForm()return render_to_response('login.html',{'uf':uf},context_instance=RequestContext(req))#def loginfaild(req):
#    response = login(req)
#    return response
#
def registsuccee(req):if req.method == 'POST':uf = UserForm(req.POST)if uf.is_valid():#获取表单用户密码username = uf.cleaned_data['username']password = uf.cleaned_data['password']#获取的表单数据与数据库进行比较user = MyUser.objects.filter(username__exact = username,password__exact = password)if user:#比较成功，跳转indexresponse = HttpResponseRedirect('/online/index/')#将username写入浏览器cookie,失效时间为3600response.set_cookie('username',username,3600)return responseelse:#比较失败，跳转loginfaildreturn render_to_response('loginfaild.html',{'uf':uf},context_instance=RequestContext(req))else:uf = UserForm()#return render_to_response('registfaild.html',{'uf':uf},context_instance=RequestContext(req))return render_to_response('registsuccee.html',{'uf':uf},context_instance=RequestContext(req))
#
#def registfaild(req):
#    response = regist(req)
#    return response
#
#def registfaild1(req):
#    response = regist(req)
#    return responsedef jsonclient(req):#获取json对象try:print("start json POST")req = json.loads((req.body).decode())print("get json succee")return reqexcept:import sysinfo = "%s || %s" % (sys.exc_info()[0], sys.exc_info()[1])print(info)def datasave(request):#解板json对象并保存info = 'Data log save success'try:if request.method == 'POST':print("start json POST")req = json.loads((request.body).decode())user = req['user']infoType = req['infoType']name = req['name']print(name)print(infoType)print(user)except:import sysinfo = "%s || %s" % (sys.exc_info()[0], sys.exc_info()[1])print(info)dict['message']=inforeturn HttpResponse(json)def getOtherUser(req,name):userlogin=MyUser.objects.filter(username__exact=name)#检索当前登陆用户print(userlogin)print(userlogin.id)user_list=MyUser.objects.all().values('username','id').exclude(id__in=userlogin.id)# user_sum=MyUser.objects.all().values('username').count()print(user_list)# print(user_sum)return user_listdef getAllUser(req):#获取已注册过的所有用户user_list=MyUser.objects.all().values('username','id').order_by('id')user_sum=MyUser.objects.all().values('username').count()print(user_list)print(user_sum)return user_list#登陆成功
def index(req):username = req.COOKIES.get('username','')user_list=getAllUser(req)#检索所有拥有username和id的用户对象i=0for list in user_list:name=list.get('username').encode()user_list[i].update({'username':name})i=i+1print('user_list == ',user_list)#good=req.COOKIES.get('good','')#print('good = ',good)#user_list=getOtherUser(req,username)#检索当前登陆用户以外的所有用户#user_first=user_list[0].usernameuser_first=username #暂时以登录人自己为默认接收人#user_sum=MyUser.objects.all().values('username').count()#统计注册的用户数#print(user_sum)#datasave(req)key_input=0if req.method == 'POST':print('index.username first= ',username)json=jsonclient(req)#获取json对象if json is not None:#判断是选择用户还是选择输入方式user_ower = json['ownerID']#获取owerIDprint('json is not none user_ower = ',user_ower)#message=Message()#当选择消息接收者时创建消息对象response = render_to_response('login_user.html' ,{'user_list':user_list,'username':username,'user_first':user_first},context_instance=RequestContext(req))response.set_cookie('ownerID',user_ower,3600)return responseelse:ownerID = req.COOKIES.get('ownerID','')#获取接收者IDprint('the message ownerID is',ownerID)if ownerID:#如果有选择，则用选择者user_ower=ownerIDelse:#否则默认推送给发送者自己Uower=MyUser.objects.get(username__exact=username)user_ower=Uower.id# message=Message.objects.get(id=messid)#user_ower=message.ownerIDmessage=Message()#创建消息，注意就算第一次未选择消息接收者，也应该创建默认消息对象，默认接收ID为发送者自身infoType_c=req.POST['submit']#提交信息的方式获取infoType=int(infoType_c)print('index:infotType=',infoType)key_user=user_owerkey_input=infoTypeprint('key_user=',key_user)print('key_input=',key_input)user_push=MyUser.objects.get(username__exact=username)print('username=',username)print('user_push=',user_push)message.infoType=infoType#推送消息的类型message.pushID=user_push.id#推送者IDmessage.ownerID= key_user#接收者的IDmessage.pushTim=timezone.localtime(timezone.now()).strftime("%Y-%m-%d %H:%M:%S")message.isTop = 0 #置顶标志默认1message.viewWeight = 1#阅读等级默认1message.save()print('message.id=',message.id)messid=message.idprint('messid=',messid)#由于post 的bug这里用html5前端来保存我们的messidif key_input == 0:print('please input text')response = HttpResponseRedirect('/online/text/')#将username写入浏览器cookie,失效时间为3600response.set_cookie('username',username,3600)response.set_cookie('messid',messid,3600)print('index:messid=',messid)return responseelif key_input == 1:print('please input video')response = HttpResponseRedirect('/online/video/')#将username写入浏览器cookie,失效时间为3600response.set_cookie('username',username,3600)response.set_cookie('messid',messid,3600)return responseelse:response = render_to_response('login_user.html' ,{'user_list':user_list,'username':username,'user_first':user_first,'messid':messid},context_instance=RequestContext(req))print('error ~! just donot in this page')response.set_cookie('messid',messid,3600)return response#return render_to_response('loginsuccee.html' ,{'user_list':json.dumps(user_list),'username':username,'user_first':user_first,'messid':messid},context_instance=RequestContext(req))else:return render_to_response('login_user.html' ,{'user_list': user_list,'user_first':user_first,'username':username},context_instance=RequestContext(req))#退出
def logout(req):response = HttpResponse('logout !!')#清理cookie里保存usernameresponse.delete_cookie('username')response.delete_cookie('messid')return response#response = HttpResponse('logout !!')#清理cookie里保存username# response.delete_cookie('username')# return responsedef text(req):#输入文本处理username = req.COOKIES.get('username','')messid= req.COOKIES.get('messid','')print('text:username=',username)print('text:messid=',messid)if req.method == 'POST':#  json=jsonclient(req)#获取json对象#  messid1 = json['messid']#获取owerID#  print(messid1)text = req.POST['text_input']#if text is not None:user=MyUser.objects.get(username__exact=username)print('user.id=',user.id)print('messid=',messid)#userID=user.idmessage=Message.objects.get(id=messid)message.infoContent=textprint(username)print('message.ownerID = ',message.ownerID)print('message.pushID =',message.pushID)print(message.infoContent)#message.pushTim=timezone.localtime(timezone.now()).strftime("%Y-%m-%d %H:%M:%S")message.save()response = HttpResponseRedirect('/online/show/')#将username写入浏览器cookie,失效时间为3600response.set_cookie('username',username,3600)return response# else:#     return render_to_response('textfailed.html')# print(dir(MyUser))return render_to_response('text1.html',context_instance=RequestContext(req))def video(req):#输入视频处理username = req.COOKIES.get('username','')messid= req.COOKIES.get('messid','')print('video:username=',username)print('video:messid=',messid)if req.method == 'POST':f = req.FILES.get('video')if f is not None:baseDir = os.path.dirname(os.path.abspath(__name__))dir = os.path.join(baseDir,'static','save')filedir=os.path.join(dir,f.name)print('filedir = ',filedir)timename=timezone.localtime(timezone.now()).strftime("%Y%m%d%H%M%S")#filename = os.path.join(dir,f.name)fname=os.path.splitext(f.name)fsuffix=fname[1]print('fsuffix =',fsuffix)filename = os.path.join(dir,timename+fsuffix)#用当地时间编号代替手机发过来的任意文章名，以免重叠print('filename =',filename)fobj = open(filename,'wb')for chrunk in f.chunks():fobj.write(chrunk)fobj.close()message=Message.objects.get(id=messid)message.filePath=filenamemessage.save()response = HttpResponseRedirect('/online/show/')#将username写入浏览器cookie,失效时间为3600response.set_cookie('username',username,3600)return responseelse:return render_to_response('camera_reinput.html')else:return render_to_response('camera.html')def show(req):username = req.COOKIES.get('username','')messid = req.COOKIES.get('messid','')message=Message.objects.get(id=messid)print('message.infoContent',message.infoContent)return render_to_response('save.html',{'text':text,'username':username,'message.infoContent':message.infoContent})def delete():MyUser.objects.filter().delete()

online/models.py

#coding:utf8
from django.db import models
from django.contrib.auth.models import (BaseUserManager, AbstractBaseUser, PermissionsMixin)class MyUserManager(BaseUserManager):
#    def _create_user(self, username, email, password, **extra_fields):def _create_user(self, username, password, **extra_fields):"""Creates and saves a User with the given username, email and password."""if not username:raise ValueError('The given username must be set')
#        email = self.normalize_email(email)
#        user = self.model(username=username, email=email, **extra_fields)user = self.model(username=username, **extra_fields)user.set_password(password)user.save(using=self._db)return user#    def create_user(self, username, email, password, **extra_fields):def create_user(self, username, password, **extra_fields):extra_fields.setdefault('is_staff', False)extra_fields.setdefault('email',"")extra_fields.setdefault('phone',"")extra_fields.setdefault('haarValue',"")extra_fields.setdefault('avatarImg',"")
#        extra_fields.setdefault('text',"")
#        extra_fields.setdefault('video',"")
#        extra_fields.setdefault('time',"")return self._create_user(username, password, **extra_fields)
#        return self._create_user(username, email, password, **extra_fields)#  def create_superuser(self, username, email, password, **extra_fields):def create_superuser(self, username, password, **extra_fields):extra_fields.setdefault('is_staff', True)if extra_fields.get('is_staff') is not True:raise ValueError('Superuser must have is_staff=True')
#拓展user数据 by xiao
#get
#to
#message_flag
#text
#video
#time
#        extra_fields.setdefault('got',username)
#        extra_fields.setdefault('to',username)
#        extra_fields.setdefault('message_flag',"1")
#        extra_fields.setdefault('text',"")
#        extra_fields.setdefault('video',"")
#        extra_fields.setdefault('time',"")return self._create_user(username, password, **extra_fields)
#        return self._create_user(username, email, password, **extra_fields)class MyUser(AbstractBaseUser, PermissionsMixin):username = models.CharField(max_length=254, unique=True, db_index=True)email = models.CharField(max_length=254)phone = models.CharField(max_length=254)haarValue = models.CharField(max_length=254)avatarImg = models.CharField(max_length=254)#email = models.EmailField('email address', max_length=254)#text=models.CharField(max_length=254, unique=True, db_index=True)is_staff = models.BooleanField('staff status', default=False)#    userID = models.IntegerField(default=1) #用户独有的ID#    is_active = models.BooleanField('active', default=True)
#    got = models.CharField(max_length=254,default=username)
#    to = models.CharField(max_length=254,default=username)
#    message_flag = models.CharField(max_length=254, default=1)
#    text = models.CharField(max_length=254, default="")
#    video = models.CharField(max_length=254,default="")
#    time = models.CharField(max_length=254,default="")USERNAME_FIELD = 'username'
#    REQUIRED_FIELDS = ['email']objects = MyUserManager()class Meta:db_table = 'myuser'#   def get_full_name(self):#       return self.username#   def get_short_name(self):#      return self.username
#建立推送消息的模型class Message(models.Model):
#    username = models.CharField(max_length=254) #消息推送者的名字ownerID = models.IntegerField(default=1)pushID = models.IntegerField(default=1)infoType = models.IntegerField(default=0)infoSubject = models.CharField(max_length=254)infoContent = models.CharField(max_length=254)filePath = models.CharField(max_length=1000)pushTim = models.CharField(max_length=254)infoValidityTime = models.CharField(max_length=254)isTop = models.IntegerField(default=0)viewWeight = models.IntegerField(default=1)def __unicode__(self):# 在Python3中使用 def __str__(self)return self.nameclass SystemStatus(models.Model): #实例化对象：online_message MMDB.updateSystemStatus('peopleInfront',-1,0,'no people in front')statusName = models.CharField(max_length=30,default="peopleInfront")statusValue = models.IntegerField(default=-1)statusParam = models.IntegerField(default=0)statusDiscirption = models.CharField(max_length=50,default="no people in front")def __unicode__(self):# 在Python3中使用 def __str__(self)return self.name

三.演示效果图

图2 注册页面

图3 视频上传页面

图4 消息选择页面

图5 上传成功页面

四.例程分享:=3536829173&uk=1812979481

本文标签： Dragonboard410c服务器系列六之用户交互系统