Dragonboard 410c搭载web服务器之用户交互系统
处理器/DSP
891人已加入
描述
一.前言
本系列文章的前几篇，博主已经给大家分享过如何在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 response
else:
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=-1
systemstatus.statusParam=0
systemstatus.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:
#比较成功，跳转index
response = HttpResponseRedirect('/online/index/')
#good="xiaoms"
#将username写入浏览器cookie,失效时间为3600
response.set_cookie('username',username,3600)
response.set_cookie('user_firstflag',user_firstflag,3600)#成功登陆后，第一次的用户是未选择接收者
return response
else:
#比较失败，跳转loginfaild
return 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:
#比较成功，跳转index
response = HttpResponseRedirect('/online/index/')
#将username写入浏览器cookie,失效时间为3600
response.set_cookie('username',username,3600)
return response
else:
#比较失败，跳转loginfaild
return 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 response
def jsonclient(req):#获取json对象
try:
print("start json POST")
req = json.loads((req.body).decode())
print("get json succee")
return req
except:
import sys
info = "%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 sys
info = "%s || %s" % (sys.exc_info()[0], sys.exc_info()[1])
print(info)
dict['message']=info
return 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_list
def 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=0
for list in user_list:
name=list.get('username').encode()
user_list[i].update({'username':name})
i=i+1
print('user_list == ',user_list)
#good=req.COOKIES.get('good','')
#print('good = ',good)
#user_list=getOtherUser(req,username)#检索当前登陆用户以外的所有用户
#user_first=user_list[0].username
user_first=username #暂时以登录人自己为默认接收人
#user_sum=MyUser.objects.all().values('username').count()#统计注册的用户数
#print(user_sum)
#datasave(req)
key_input=0
if req.method == 'POST':
print('index.username first= ',username)
json=jsonclient(req)#获取json对象
if json is not None:#判断是选择用户还是选择输入方式
user_ower = json['ownerID']#获取owerID
print('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 response
else:
ownerID = req.COOKIES.get('ownerID','')#获取接收者ID
print('the message ownerID is',ownerID)
if ownerID:#如果有选择，则用选择者
user_ower=ownerID
else:#否则默认推送给发送者自己
Uower=MyUser.objects.get(username__exact=username)
user_ower=Uower.id
# message=Message.objects.get(id=messid)
#user_ower=message.ownerID
message=Message()#创建消息，注意就算第一次未选择消息接收者，也应该创建默认消息对象，默认接收ID为发送者自身
infoType_c=req.POST['submit']#提交信息的方式获取
infoType=int(infoType_c)
print('index:infotType=',infoType)
key_user=user_ower
key_input=infoType
print('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#推送者ID
message.ownerID= key_user#接收者的ID
message.pushTim=timezone.localtime(timezone.now()).strftime("%Y-%m-%d %H:%M:%S")
message.isTop = 0 #置顶标志默认1
message.viewWeight = 1#阅读等级默认1
message.save()
print('message.id=',message.id)
messid=message.id
print('messid=',messid)
#由于post 的bug这里用html5前端来保存我们的messid
if key_input == 0:
print('please input text')
response = HttpResponseRedirect('/online/text/')
#将username写入浏览器cookie,失效时间为3600
response.set_cookie('username',username,3600)
response.set_cookie('messid',messid,3600)
print('index:messid=',messid)
return response
elif key_input == 1:
print('please input video')
response = HttpResponseRedirect('/online/video/')
#将username写入浏览器cookie,失效时间为3600
response.set_cookie('username',username,3600)
response.set_cookie('messid',messid,3600)
return response
else:
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里保存username
response.delete_cookie('username')
response.delete_cookie('messid')
return response
#response = HttpResponse('logout !!')
#清理cookie里保存username
# response.delete_cookie('username')
# return response
def 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.id
message=Message.objects.get(id=messid)
message.infoContent=text
print(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,失效时间为3600
response.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=filename
message.save()
response = HttpResponseRedirect('/online/show/')
#将username写入浏览器cookie,失效时间为3600
response.set_cookie('username',username,3600)
return response
else:
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.name
class 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 上传成功页面
四.例程分享：
http://pan.baidu.com/share/link？shareid=3536829173&uk=1812979481
声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表电子发烧友网立场。文章及其配图仅供工程师学习之用，如有内容侵权或者其他违规问题，请联系本站处理。
举报投诉
-
利用DragonBoard 410c应对智慧城市的挑战2016-06-28 0
-
【资料】DragonBoard 410c开发套件相关资料2016-07-12 0
-
【DragonBoard 410c申请】基于DragonBoard 410C远程监控系统和OpenCV实验学习2016-08-19 0
-
【DragonBoard 410c】汇总帖（2016.10.25更新）2016-08-26 0
-
【DragonBoard 410c试用体验】DragonBoard 410c官方全套文档2016-08-27 0
-
【DragonBoard 410c试用体验】 DragonBoard 410c 基于VPN的高安全性基础物联网2016-09-01 0
-
DragonBoard 410c平台boa web服务器移植2018-09-21 0
-
基于dragonboard 410c的智能魔镜整体方案设计2018-09-21 0
-
Dragonboard 410c USB摄像头的图像采集及web发布2018-09-21 0
-
PC机如何利用total control控制DragonBoard 410c2018-09-28 0
-
Dragonboard 410c搭载web服务器之数据库的设计2017-02-09 909
-
Dragonboard 410c搭载web服务器之如何实现视频文件上传2017-02-09 986
-
基于Dragonboard 410c服务器系列之二局域网用户管理系统2017-02-15 880
-
如何为DragonBoard 410c定制Android系统2017-02-22 1585
全部0条评论
快来发表一下你的评论吧 !
