devbox
IT小白
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

基于python的电影推荐系统源码_基于python电影推荐系统源码

作者：IT小白 | 2024-05-03 20:59:56

赞

踩

基于python电影推荐系统源码

目录

一、整体目录（示范）：

文档含项目技术介绍、E-R图、数据字典、项目功能介绍与截图等

二、运行截图

三、代码部分（示范）：

四、数据库表(示范)：

数据库表有注释，可以导出数据字典及更新数据库时间，欢迎交流学习

五、主要技术介绍：

六、项目调试学习（点击查看）

七、项目交流

一、整体目录（示范）：

文档含项目技术介绍、E-R图、数据字典、项目功能介绍与截图等

 

二、运行截图

三、代码部分（示范）：

注册较验代码：

  1. // 注册
  2. 			async register() {
  3. 				if((!this.ruleForm.yonghuzhanghao) && `yonghu` == this.tableName){
  4. 					this.$utils.msg(`用户账号不能为空`);
  5. 					return
  6. 				}
  7. 				if(`yonghu` == this.tableName && (this.ruleForm.yonghuzhanghao.length<8)){
  8. 					this.$utils.msg(`用户账号长度不能小于8`);
  9. 					return
  10. 				}
  11. 				if(`yonghu` == this.tableName && (this.ruleForm.yonghuzhanghao.length>12)){
  12. 					this.$utils.msg(`用户账号长度不能大于12`);
  13. 					return
  14. 				}
  15. 				if((!this.ruleForm.mima) && `yonghu` == this.tableName){
  16. 					this.$utils.msg(`密码不能为空`);
  17. 					return
  18. 				}
  19.                 if(`yonghu` == this.tableName && (this.ruleForm.mima!=this.ruleForm.mima2)){
  20.                     this.$utils.msg(`两次密码输入不一致`);
  21.                     return
  22.                 }
  23. 				if((!this.ruleForm.yonghuxingming) && `yonghu` == this.tableName){
  24. 					this.$utils.msg(`用户姓名不能为空`);
  25. 					return
  26. 				}
  27. 				if(`yonghu` == this.tableName && this.ruleForm.nianling&&(!this.$validate.isIntNumer(this.ruleForm.nianling))){
  28. 					this.$utils.msg(`年龄应输入整数`);
  29. 					return
  30. 				}
  31. 				if((!this.ruleForm.schoolname) && `yonghu` == this.tableName){
  32. 					this.$utils.msg(`学校名称不能为空`);
  33. 					return
  34. 				}
  35. 				if(`yonghu` == this.tableName && this.ruleForm.shouji&&(!this.$validate.isMobile(this.ruleForm.shouji))){
  36. 					this.$utils.msg(`手机应输入手机格式`);
  37. 					return
  38. 				}
  39. 				if(`yonghu` == this.tableName && this.ruleForm.youxiang&&(!this.$validate.isEmail(this.ruleForm.youxiang))){
  40. 					this.$utils.msg(`邮箱应输入邮件格式`);
  41. 					return
  42. 				}
  43. 				await this.$api.register(`${this.tableName}`, this.ruleForm, this.emailcode);
  44. 				this.$utils.msgBack('注册成功');;
  45. 			}
  46. 		}
  47. 	}
  48. </script>

推荐算法代码

  1. //智能推荐商品业务步骤
  2. 1.获取当前用户信息
  3. 2.判断当前是否有收藏信息
  4. 3.如有收藏信息按收藏推荐信息推荐，无推荐信息默认按点击次数
  5.  
  6. //================以下是相关类和方法==============
  7. //商品信息后端接口类
  8. com.controller.ShangpinxinxiController
  9.  
  10. /**
  11.  * 商品信息前端智能排序
  12.  */
  13. @IgnoreAuth
  14. @RequestMapping("/autoSort")
  15. public R autoSort(@RequestParam Map<String, Object> params,ShangpinxinxiEntity shangpinxinxi, HttpServletRequest request,String pre){
  16. 	EntityWrapper<ShangpinxinxiEntity> ew = new EntityWrapper<ShangpinxinxiEntity>();
  17. 	Map<String, Object> newMap = new HashMap<String, Object>();
  18. 	Map<String, Object> param = new HashMap<String, Object>();
  19. 	boolean flag = false;
  20. 	String isRecommend =(String) params.get("isRecommend");
  21. 	if("1".equals(isRecommend)){ //是否推荐
  22. 		String  userId =  (String) params.get("userId");
  23. 		YonghuEntity user = yonghuService.selectById(Long.valueOf(userId));
  24. 		params.remove("isRecommend");
  25. 		params.remove("userId");
  26. 		StringBuffer refIds = new  StringBuffer();
  27. 		List<StoreupView>  storeupList = storeupService.selectListView(new EntityWrapper<StoreupEntity>().eq("userid",userId));
  28. 		if(storeupList!=null && storeupList.size()>0){
  29. 			for(StoreupView storeupView: storeupList){
  30. 				refIds.append(storeupView.getRefid()+",");
  31. 			}
  32. 			flag =true;
  33. 			ew.in("id",refIds.toString());
  34. 		}
  35. 	}
  36. 	Iterator<Map.Entry<String, Object>> it = param.entrySet().iterator();
  37. 	while (it.hasNext()) {
  38. 		Map.Entry<String, Object> entry = it.next();
  39. 		String key = entry.getKey();
  40. 		String newKey = entry.getKey();
  41. 		if (pre.endsWith(".")) {
  42. 			newMap.put(pre + newKey, entry.getValue());
  43. 		} else if (StringUtils.isEmpty(pre)) {
  44. 			newMap.put(newKey, entry.getValue());
  45. 		} else {
  46. 			newMap.put(pre + "." + newKey, entry.getValue());
  47. 		}
  48. 	}
  49. 	params.put("sort", "clicknum");
  50. 	params.put("order", "desc");
  51. 	PageUtils page = shangpinxinxiService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, shangpinxinxi), params), params));
  52. 	return R.ok().put("data", page);
  53. }
  54.  
  55.  
  56.  
  57. //收藏表后端接口
  58. com.controller.StoreupController
  59. /**
  60.  * 收藏表后端保存方法 
  61.  */
  62. @RequestMapping("/save")
  63. public R save(@RequestBody StoreupEntity storeup, HttpServletRequest request){
  64. 	storeup.setId(new Date().getTime()+new Double(Math.floor(Math.random()*1000)).longValue());
  65. 	//ValidatorUtils.validateEntity(storeup);
  66. 	storeup.setUserid((Long)request.getSession().getAttribute("userId"));
  67. 	storeupService.insert(storeup);
  68. 	return R.ok();
  69. }
  70.  
  71. /**
  72.  * 收藏表删除方法
  73.  */
  74. @RequestMapping("/delete")
  75. public R delete(@RequestBody Long[] ids){
  76. 	storeupService.deleteBatchIds(Arrays.asList(ids));
  77. 	return R.ok();
  78. }
  79.  
  80.  
  81.  
  82.

最新电影

  1. #coding:utf-8
  2. __author__ = "ila"
  3. import base64, copy, logging, os, time, xlrd
  4. from django.http import JsonResponse
  5. from django.apps import apps
  6. from django.db.models.aggregates import Count,Sum
  7. from .models import zuixindianying
  8. from util.codes import *
  9. from util.auth import Auth
  10. from util.common import Common
  11. import util.message as mes
  12. from django.db import connection
  13. import random
  14. from django.core.mail import send_mail
  15. from alipay import AliPayConfig, AliPay
  16. from django.conf import settings
  17. from django.shortcuts import redirect
  18.  
  19. def zuixindianying_register(request):
  20.     if request.method in ["POST", "GET"]:
  21.         msg = {'code': normal_code, "msg": mes.normal_code}
  22.         req_dict = request.session.get("req_dict")
  23.  
  24.  
  25.         error = zuixindianying.createbyreq(zuixindianying, zuixindianying, req_dict)
  26.         if error != None:
  27.             msg['code'] = crud_error_code
  28.             msg['msg'] = "用户已存在,请勿重复注册!"
  29.         return JsonResponse(msg)
  30.  
  31. def zuixindianying_login(request):
  32.     if request.method in ["POST", "GET"]:
  33.         msg = {'code': normal_code, "msg": mes.normal_code}
  34.         req_dict = request.session.get("req_dict")
  35.  
  36.         datas = zuixindianying.getbyparams(zuixindianying, zuixindianying, req_dict)
  37.         if not datas:
  38.             msg['code'] = password_error_code
  39.             msg['msg'] = mes.password_error_code
  40.             return JsonResponse(msg)
  41.         try:
  42.             __sfsh__= zuixindianying.__sfsh__
  43.         except:
  44.             __sfsh__=None
  45.  
  46.         if  __sfsh__=='是':
  47.             if datas[0].get('sfsh')=='否':
  48.                 msg['code']=other_code
  49.                 msg['msg'] = "账号已锁定，请联系管理员审核!"
  50.                 return JsonResponse(msg)
  51.                 
  52.         req_dict['id'] = datas[0].get('id')
  53.         return Auth.authenticate(Auth, zuixindianying, req_dict)
  54.  
  55.  
  56. def zuixindianying_logout(request):
  57.     if request.method in ["POST", "GET"]:
  58.         msg = {
  59.             "msg": "登出成功",
  60.             "code": 0
  61.         }
  62.  
  63.         return JsonResponse(msg)
  64.  
  65.  
  66. def zuixindianying_resetPass(request):
  67.     '''
  68.     '''
  69.     if request.method in ["POST", "GET"]:
  70.         msg = {"code": normal_code, "msg": mes.normal_code}
  71.  
  72.         req_dict = request.session.get("req_dict")
  73.  
  74.         columns=  zuixindianying.getallcolumn( zuixindianying, zuixindianying)
  75.  
  76.         try:
  77.             __loginUserColumn__= zuixindianying.__loginUserColumn__
  78.         except:
  79.             __loginUserColumn__=None
  80.         username=req_dict.get(list(req_dict.keys())[0])
  81.         if __loginUserColumn__:
  82.             username_str=__loginUserColumn__
  83.         else:
  84.             username_str=username
  85.         if 'mima' in columns:
  86.             password_str='mima'
  87.         else:
  88.             password_str='password'
  89.  
  90.         init_pwd = '123456'
  91.  
  92.         eval('''zuixindianying.objects.filter({}='{}').update({}='{}')'''.format(username_str,username,password_str,init_pwd))
  93.         
  94.         return JsonResponse(msg)
  95.  
  96.  
  97.  
  98. def zuixindianying_session(request):
  99.     '''
  100.     '''
  101.     if request.method in ["POST", "GET"]:
  102.         msg = {"code": normal_code,"msg": mes.normal_code, "data": {}}
  103.  
  104.         req_dict={"id":request.session.get('params').get("id")}
  105.         msg['data']  = zuixindianying.getbyparams(zuixindianying, zuixindianying, req_dict)[0]
  106.  
  107.         return JsonResponse(msg)
  108.  
  109.  
  110. def zuixindianying_default(request):
  111.  
  112.     if request.method in ["POST", "GET"]:
  113.         msg = {"code": normal_code,"msg": mes.normal_code, "data": {}}
  114.         req_dict = request.session.get("req_dict")
  115.         req_dict.update({"isdefault":"是"})
  116.         data=zuixindianying.getbyparams(zuixindianying, zuixindianying, req_dict)
  117.         if len(data)>0:
  118.             msg['data']  = data[0]
  119.         else:
  120.             msg['data']  = {}
  121.         return JsonResponse(msg)
  122.  
  123. def zuixindianying_page(request):
  124.     '''
  125.     '''
  126.     if request.method in ["POST", "GET"]:
  127.         msg = {"code": normal_code, "msg": mes.normal_code,  "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
  128.         req_dict = request.session.get("req_dict")
  129.  
  130.         #获取全部列名
  131.         columns=  zuixindianying.getallcolumn( zuixindianying, zuixindianying)
  132.  
  133.         #当前登录用户所在表
  134.         tablename = request.session.get("tablename")
  135.  
  136.  
  137.             #authColumn=list(__authTables__.keys())[0]
  138.             #authTable=__authTables__.get(authColumn)
  139.  
  140.             # if authTable==tablename:
  141.                 #params = request.session.get("params")
  142.                 #req_dict[authColumn]=params.get(authColumn)
  143.  
  144.         '''__authSeparate__此属性为真，params添加userid，后台只查询个人数据'''
  145.         try:
  146.             __authSeparate__=zuixindianying.__authSeparate__
  147.         except:
  148.             __authSeparate__=None
  149.  
  150.         if __authSeparate__=="是":
  151.             tablename=request.session.get("tablename")
  152.             if tablename!="users" and 'userid' in columns:
  153.                 try:
  154.                     req_dict['userid']=request.session.get("params").get("id")
  155.                 except:
  156.                     pass
  157.  
  158.         #当项目属性hasMessage为”是”，生成系统自动生成留言板的表messages，同时该表的表属性hasMessage也被设置为”是”,字段包括userid（用户id），username(用户名)，content（留言内容），reply（回复）
  159.         #接口page需要区分权限，普通用户查看自己的留言和回复记录，管理员查看所有的留言和回复记录
  160.         try:
  161.             __hasMessage__=zuixindianying.__hasMessage__
  162.         except:
  163.             __hasMessage__=None
  164.         if  __hasMessage__=="是":
  165.             tablename=request.session.get("tablename")
  166.             if tablename!="users":
  167.                 req_dict["userid"]=request.session.get("params").get("id")
  168.  
  169.  
  170.  
  171.         # 判断当前表的表属性isAdmin,为真则是管理员表
  172.         # 当表属性isAdmin=”是”,刷出来的用户表也是管理员，即page和list可以查看所有人的考试记录(同时应用于其他表)
  173.         __isAdmin__ = None
  174.  
  175.         allModels = apps.get_app_config('main').get_models()
  176.         for m in allModels:
  177.             if m.__tablename__==tablename:
  178.  
  179.                 try:
  180.                     __isAdmin__ = m.__isAdmin__
  181.                 except:
  182.                     __isAdmin__ = None
  183.                 break
  184.  
  185.         # 当前表也是有管理员权限的表
  186.         if  __isAdmin__ == "是":
  187.             if req_dict.get("userid"):
  188.                 del req_dict["userid"]
  189.  
  190.         else:
  191.             #非管理员权限的表,判断当前表字段名是否有userid
  192.             if tablename!="users" and 'zuixindianying'[:7]!='discuss'and "userid" in zuixindianying.getallcolumn(zuixindianying,zuixindianying):
  193.                 req_dict["userid"] = request.session.get("params").get("id")
  194.  
  195.         #当列属性authTable有值(某个用户表)[该列的列名必须和该用户表的登陆字段名一致]，则对应的表有个隐藏属性authTable为”是”，那么该用户查看该表信息时，只能查看自己的
  196.         try:
  197.             __authTables__=zuixindianying.__authTables__
  198.         except:
  199.             __authTables__=None
  200.  
  201.         if __authTables__!=None and  __authTables__!={}:
  202.             try:
  203.                 del req_dict['userid']
  204.             except:
  205.                 pass
  206.             for authColumn,authTable in __authTables__.items():
  207.                 if authTable==tablename:
  208.                     params = request.session.get("params")
  209.                     req_dict[authColumn]=params.get(authColumn)
  210.                     break
  211.         msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
  212.         msg['data']['pageSize']  =zuixindianying.page(zuixindianying, zuixindianying, req_dict, request)
  213.  
  214.         return JsonResponse(msg)
  215.  
  216. def zuixindianying_autoSort(request):
  217.     '''
  218.     ．智能推荐功能(表属性：[intelRecom（是/否）],新增clicktime[前端不显示该字段]字段（调用info/detail接口的时候更新），按clicktime排序查询)
  219. 主要信息列表（如商品列表，新闻列表）中使用，显示最近点击的或最新添加的5条记录就行
  220.     '''
  221.     if request.method in ["POST", "GET"]:
  222.         msg = {"code": normal_code, "msg": mes.normal_code,  "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
  223.         req_dict = request.session.get("req_dict")
  224.         if "clicknum"  in zuixindianying.getallcolumn(zuixindianying,zuixindianying):
  225.             req_dict['sort']='clicknum'
  226.         else:
  227.             req_dict['sort']='clicktime'
  228.         req_dict['order']='desc'
  229.         msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
  230.         msg['data']['pageSize']  = zuixindianying.page(zuixindianying,zuixindianying, req_dict)
  231.  
  232.         return JsonResponse(msg)
  233.  
  234.  
  235. def zuixindianying_list(request):
  236.     '''
  237.     前台分页
  238.     '''
  239.     if request.method in ["POST", "GET"]:
  240.         msg = {"code": normal_code, "msg": mes.normal_code,  "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":10,"list":[]}}
  241.         req_dict = request.session.get("req_dict")
  242.  
  243.         #获取全部列名
  244.         columns=  zuixindianying.getallcolumn( zuixindianying, zuixindianying)
  245.         #表属性[foreEndList]前台list:和后台默认的list列表页相似,只是摆在前台,否:指没有此页,是:表示有此页(不需要登陆即可查看),前要登:表示有此页且需要登陆后才能查看
  246.         try:
  247.             __foreEndList__=zuixindianying.__foreEndList__
  248.         except:
  249.             __foreEndList__=None
  250.  
  251.         if __foreEndList__=="前要登":
  252.             tablename=request.session.get("tablename")
  253.             if tablename!="users" and 'userid' in columns:
  254.                 try:
  255.                     req_dict['userid']=request.session.get("params").get("id")
  256.                 except:
  257.                     pass
  258.         #forrEndListAuth
  259.         try:
  260.             __foreEndListAuth__=zuixindianying.__foreEndListAuth__
  261.         except:
  262.             __foreEndListAuth__=None
  263.  
  264.  
  265.         #authSeparate
  266.         try:
  267.             __authSeparate__=zuixindianying.__authSeparate__
  268.         except:
  269.             __authSeparate__=None
  270.  
  271.         if __foreEndListAuth__ =="是" and __authSeparate__=="是":
  272.             tablename=request.session.get("tablename")
  273.             if tablename!="users":
  274.                 req_dict['userid']=request.session.get("params",{"id":0}).get("id")
  275.  
  276.         tablename = request.session.get("tablename")
  277.         if tablename == "users" and req_dict.get("userid") != None:#判断是否存在userid列名
  278.             del req_dict["userid"]
  279.         else:
  280.             __isAdmin__ = None
  281.  
  282.             allModels = apps.get_app_config('main').get_models()
  283.             for m in allModels:
  284.                 if m.__tablename__==tablename:
  285.  
  286.                     try:
  287.                         __isAdmin__ = m.__isAdmin__
  288.                     except:
  289.                         __isAdmin__ = None
  290.                     break
  291.  
  292.             if __isAdmin__ == "是":
  293.                 if req_dict.get("userid"):
  294.                     del req_dict["userid"]
  295.             else:
  296.                 #非管理员权限的表,判断当前表字段名是否有userid
  297.                 if "userid" in columns:
  298.                     try:
  299.                         # 本接口可以匿名访问,所以try判断是否为匿名
  300.                         req_dict['userid']=request.session.get("params").get("id")
  301.                     except:
  302.                             pass
  303.         #当列属性authTable有值(某个用户表)[该列的列名必须和该用户表的登陆字段名一致]，则对应的表有个隐藏属性authTable为”是”，那么该用户查看该表信息时，只能查看自己的
  304.         try:
  305.             __authTables__=zuixindianying.__authTables__
  306.         except:
  307.             __authTables__=None
  308.  
  309.         if __authTables__!=None and  __authTables__!={} and __foreEndListAuth__=="是":
  310.             try:
  311.                 del req_dict['userid']
  312.             except:
  313.                 pass
  314.             for authColumn,authTable in __authTables__.items():
  315.                 if authTable==tablename:
  316.                     params = request.session.get("params")
  317.                     req_dict[authColumn]=params.get(authColumn)
  318.                     break
  319.         
  320.         if zuixindianying.__tablename__[:7]=="discuss":
  321.             try:
  322.                 del req_dict['userid']
  323.             except:
  324.                 pass
  325.  
  326.  
  327.         msg['data']['list'], msg['data']['currPage'], msg['data']['totalPage'], msg['data']['total'], \
  328.         msg['data']['pageSize']  = zuixindianying.page(zuixindianying, zuixindianying, req_dict)
  329.  
  330.         return JsonResponse(msg)
  331.  
  332. def zuixindianying_save(request):
  333.     '''
  334.     后台新增
  335.     '''
  336.     if request.method in ["POST", "GET"]:
  337.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  338.         req_dict = request.session.get("req_dict")
  339.         if 'clicktime' in req_dict.keys():
  340.             del req_dict['clicktime']
  341.         tablename=request.session.get("tablename")
  342.         __isAdmin__ = None
  343.         allModels = apps.get_app_config('main').get_models()
  344.         for m in allModels:
  345.             if m.__tablename__==tablename:
  346.  
  347.                 try:
  348.                     __isAdmin__ = m.__isAdmin__
  349.                 except:
  350.                     __isAdmin__ = None
  351.                 break
  352.  
  353.  
  354.         #获取全部列名
  355.         columns=  zuixindianying.getallcolumn( zuixindianying, zuixindianying)
  356.         if tablename!='users' and req_dict.get("userid")!=None and 'userid' in columns  and __isAdmin__!='是':
  357.             params=request.session.get("params")
  358.             req_dict['userid']=params.get('id')
  359.  
  360.  
  361.         error= zuixindianying.createbyreq(zuixindianying,zuixindianying, req_dict)
  362.         if error!=None:
  363.             msg['code'] = crud_error_code
  364.             msg['msg'] = error
  365.  
  366.         return JsonResponse(msg)
  367.  
  368.  
  369. def zuixindianying_add(request):
  370.     '''
  371.     前台新增
  372.     '''
  373.     if request.method in ["POST", "GET"]:
  374.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  375.         req_dict = request.session.get("req_dict")
  376.  
  377.         #获取全部列名
  378.         columns=  zuixindianying.getallcolumn( zuixindianying, zuixindianying)
  379.         try:
  380.             __authSeparate__=zuixindianying.__authSeparate__
  381.         except:
  382.             __authSeparate__=None
  383.  
  384.         if __authSeparate__=="是":
  385.             tablename=request.session.get("tablename")
  386.             if tablename!="users" and 'userid' in columns:
  387.                 try:
  388.                     req_dict['userid']=request.session.get("params").get("id")
  389.                 except:
  390.                     pass
  391.  
  392.         try:
  393.             __foreEndListAuth__=zuixindianying.__foreEndListAuth__
  394.         except:
  395.             __foreEndListAuth__=None
  396.  
  397.         if __foreEndListAuth__ and __foreEndListAuth__!="否":
  398.             tablename=request.session.get("tablename")
  399.             if tablename!="users":
  400.                 req_dict['userid']=request.session.get("params").get("id")
  401.  
  402.         error= zuixindianying.createbyreq(zuixindianying,zuixindianying, req_dict)
  403.         if error!=None:
  404.             msg['code'] = crud_error_code
  405.             msg['msg'] = error
  406.         return JsonResponse(msg)
  407.  
  408. def zuixindianying_thumbsup(request,id_):
  409.     '''
  410.      点赞：表属性thumbsUp[是/否]，刷表新增thumbsupnum赞和crazilynum踩字段，
  411.     '''
  412.     if request.method in ["POST", "GET"]:
  413.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  414.         req_dict = request.session.get("req_dict")
  415.         id_=int(id_)
  416.         type_=int(req_dict.get("type",0))
  417.         rets=zuixindianying.getbyid(zuixindianying,zuixindianying,id_)
  418.  
  419.         update_dict={
  420.         "id":id_,
  421.         }
  422.         if type_==1:#赞
  423.             update_dict["thumbsupnum"]=int(rets[0].get('thumbsupnum'))+1
  424.         elif type_==2:#踩
  425.             update_dict["crazilynum"]=int(rets[0].get('crazilynum'))+1
  426.         error = zuixindianying.updatebyparams(zuixindianying,zuixindianying, update_dict)
  427.         if error!=None:
  428.             msg['code'] = crud_error_code
  429.             msg['msg'] = error
  430.         return JsonResponse(msg)
  431.  
  432.  
  433. def zuixindianying_info(request,id_):
  434.     '''
  435.     '''
  436.     if request.method in ["POST", "GET"]:
  437.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  438.  
  439.         data = zuixindianying.getbyid(zuixindianying,zuixindianying, int(id_))
  440.         if len(data)>0:
  441.             msg['data']=data[0]
  442.         #浏览点击次数
  443.         try:
  444.             __browseClick__= zuixindianying.__browseClick__
  445.         except:
  446.             __browseClick__=None
  447.  
  448.         if __browseClick__=="是"  and  "clicknum"  in zuixindianying.getallcolumn(zuixindianying,zuixindianying):
  449.             try:
  450.                 clicknum=int(data[0].get("clicknum",0))+1
  451.             except:
  452.                 clicknum=0+1
  453.             click_dict={"id":int(id_),"clicknum":clicknum}
  454.             ret=zuixindianying.updatebyparams(zuixindianying,zuixindianying,click_dict)
  455.             if ret!=None:
  456.                 msg['code'] = crud_error_code
  457.                 msg['msg'] = ret
  458.         return JsonResponse(msg)
  459.  
  460. def zuixindianying_detail(request,id_):
  461.     '''
  462.     '''
  463.     if request.method in ["POST", "GET"]:
  464.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  465.  
  466.         data =zuixindianying.getbyid(zuixindianying,zuixindianying, int(id_))
  467.         if len(data)>0:
  468.             msg['data']=data[0]
  469.  
  470.         #浏览点击次数
  471.         try:
  472.             __browseClick__= zuixindianying.__browseClick__
  473.         except:
  474.             __browseClick__=None
  475.  
  476.         if __browseClick__=="是"   and  "clicknum"  in zuixindianying.getallcolumn(zuixindianying,zuixindianying):
  477.             try:
  478.                 clicknum=int(data[0].get("clicknum",0))+1
  479.             except:
  480.                 clicknum=0+1
  481.             click_dict={"id":int(id_),"clicknum":clicknum}
  482.  
  483.             ret=zuixindianying.updatebyparams(zuixindianying,zuixindianying,click_dict)
  484.             if ret!=None:
  485.                 msg['code'] = crud_error_code
  486.                 msg['msg'] = retfo
  487.         return JsonResponse(msg)
  488.  
  489.  
  490. def zuixindianying_update(request):
  491.     '''
  492.     '''
  493.     if request.method in ["POST", "GET"]:
  494.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  495.         req_dict = request.session.get("req_dict")
  496.         if req_dict.get("mima") and req_dict.get("password"):
  497.             if "mima" not  in zuixindianying.getallcolumn(zuixindianying,zuixindianying) :
  498.                 del req_dict["mima"]
  499.             if  "password" not  in zuixindianying.getallcolumn(zuixindianying,zuixindianying) :
  500.                 del req_dict["password"]
  501.         try:
  502.             del req_dict["clicknum"]
  503.         except:
  504.             pass
  505.  
  506.  
  507.         error = zuixindianying.updatebyparams(zuixindianying, zuixindianying, req_dict)
  508.         if error!=None:
  509.             msg['code'] = crud_error_code
  510.             msg['msg'] = error
  511.         return JsonResponse(msg)
  512.  
  513.  
  514. def zuixindianying_delete(request):
  515.     '''
  516.     批量删除
  517.     '''
  518.     if request.method in ["POST", "GET"]:
  519.         msg = {"code": normal_code, "msg": mes.normal_code, "data": {}}
  520.         req_dict = request.session.get("req_dict")
  521.  
  522.         error=zuixindianying.deletes(zuixindianying,
  523.             zuixindianying,
  524.              req_dict.get("ids")
  525.         )
  526.         if error!=None:
  527.             msg['code'] = crud_error_code
  528.             msg['msg'] = error
  529.         return JsonResponse(msg)
  530.  
  531.  
  532. def zuixindianying_vote(request,id_):
  533.     '''
  534.     浏览点击次数（表属性[browseClick:是/否]，点击字段（clicknum），调用info/detail接口的时候后端自动+1）、投票功能（表属性[vote:是/否]，投票字段（votenum）,调用vote接口后端votenum+1）
  535. 统计商品或新闻的点击次数；提供新闻的投票功能
  536.     '''
  537.     if request.method in ["POST", "GET"]:
  538.         msg = {"code": normal_code, "msg": mes.normal_code}
  539.  
  540.  
  541.         data= zuixindianying.getbyid(zuixindianying, zuixindianying, int(id_))
  542.         for i in data:
  543.             votenum=i.get('votenum')
  544.             if votenum!=None:
  545.                 params={"id":int(id_),"votenum":votenum+1}
  546.                 error=zuixindianying.updatebyparams(zuixindianying,zuixindianying,params)
  547.                 if error!=None:
  548.                     msg['code'] = crud_error_code
  549.                     msg['msg'] = error
  550.         return JsonResponse(msg)
  551.  
  552. def zuixindianying_importExcel(request):
  553.     if request.method in ["POST", "GET"]:
  554.         msg = {"code": normal_code, "msg": "成功", "data": {}}
  555.  
  556.         excel_file = request.FILES.get("file", "")
  557.         file_type = excel_file.name.split('.')[1]
  558.         
  559.         if file_type in ['xlsx', 'xls']:
  560.             data = xlrd.open_workbook(filename=None, file_contents=excel_file.read())
  561.             table = data.sheets()[0]
  562.             rows = table.nrows
  563.             
  564.             try:
  565.                 for row in range(1, rows):
  566.                     row_values = table.row_values(row)
  567.                     req_dict = {}
  568.                     zuixindianying.createbyreq(zuixindianying, zuixindianying, req_dict)
  569.                     
  570.             except:
  571.                 pass
  572.                 
  573.         else:
  574.             msg.code = 500
  575.             msg.msg = "文件类型错误"
  576.                 
  577.         return JsonResponse(msg)
  578.  
  579. def zuixindianying_sendemail(request):
  580.     if request.method in ["POST", "GET"]:
  581.         req_dict = request.session.get("req_dict")
  582.  
  583.         code = random.sample(['0', '1', '2', '3', '4', '5', '6', '7', '8', '9'], 4)
  584.         to = []
  585.         to.append(req_dict['email'])
  586.  
  587.         send_mail('用户注册', '您的注册验证码是【'+''.join(code)+'】，请不要把验证码泄漏给其他人，如非本人请勿操作。', 'yclw9@qq.com', to, fail_silently = False)
  588.  
  589.         cursor = connection.cursor()
  590.         cursor.execute("insert into emailregistercode(email,role,code) values('"+req_dict['email']+"','用户','"+''.join(code)+"')")
  591.  
  592.         msg = {
  593.             "msg": "发送成功",
  594.             "code": 0
  595.         }
  596.  
  597.         return JsonResponse(msg)
  598.  
  599. def zuixindianying_autoSort2(request):
  600.     
  601.     if request.method in ["POST", "GET"]:
  602.         req_dict = request.session.get("req_dict")
  603.         cursor = connection.cursor()
  604.         leixing = set()
  605.         try:
  606.             cursor.execute("select inteltype from storeup where userid = %d"%(request.session.get("params").get("id"))+" and tablename = 'zuixindianying' order by addtime desc")
  607.             rows = cursor.fetchall()
  608.             for row in rows:
  609.                 for item in row:
  610.                     leixing.add(item)
  611.         except:
  612.             leixing = set()
  613.         
  614.         L = []
  615.         cursor.execute("select * from zuixindianying where $intelRecomColumn in ('%s"%("','").join(leixing)+"') union all select * from zuixindianying where $intelRecomColumn not in('%s"%("','").join(leixing)+"')")
  616.         desc = cursor.description
  617.         data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()] 
  618.         for online_dict in data_dict:
  619.             for key in online_dict:
  620.                 if 'datetime.datetime' in str(type(online_dict[key])):
  621.                     online_dict[key] = online_dict[key].strftime(
  622.                         "%Y-%m-%d %H:%M:%S")
  623.                 else:
  624.                     pass
  625.             L.append(online_dict)
  626.  
  627.  
  628.         return JsonResponse({"code": 0, "msg": '',  "data":{"currPage":1,"totalPage":1,"total":1,"pageSize":5,"list": L[0:6]}})
  629.  
  630. def zuixindianying_value(request, xColumnName, yColumnName, timeStatType):
  631.     if request.method in ["POST", "GET"]:
  632.         msg = {"code": normal_code, "msg": "成功", "data": {}}
  633.         
  634.         where = ' where 1 = 1 '
  635.         sql = ''
  636.         if timeStatType == '日':
  637.             sql = "SELECT DATE_FORMAT({0}, '%Y-%m-%d') {0}, sum({1}) total FROM zuixindianying {2} GROUP BY DATE_FORMAT({0}, '%Y-%m-%d')".format(xColumnName, yColumnName, where, '%Y-%m-%d')
  638.  
  639.         if timeStatType == '月':
  640.             sql = "SELECT DATE_FORMAT({0}, '%Y-%m') {0}, sum({1}) total FROM zuixindianying {2} GROUP BY DATE_FORMAT({0}, '%Y-%m')".format(xColumnName, yColumnName, where, '%Y-%m')
  641.  
  642.         if timeStatType == '年':
  643.             sql = "SELECT DATE_FORMAT({0}, '%Y') {0}, sum({1}) total FROM zuixindianying {2} GROUP BY DATE_FORMAT({0}, '%Y')".format(xColumnName, yColumnName, where, '%Y')
  644.         L = []
  645.         cursor = connection.cursor()
  646.         cursor.execute(sql)
  647.         desc = cursor.description
  648.         data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()] 
  649.         for online_dict in data_dict:
  650.             for key in online_dict:
  651.                 if 'datetime.datetime' in str(type(online_dict[key])):
  652.                     online_dict[key] = online_dict[key].strftime(
  653.                         "%Y-%m-%d %H:%M:%S")
  654.                 else:
  655.                     pass
  656.             L.append(online_dict)
  657.         msg['data'] = L
  658.  
  659.         return JsonResponse(msg)
  660.  
  661. def zuixindianying_o_value(request, xColumnName, yColumnName):
  662.     if request.method in ["POST", "GET"]:
  663.         msg = {"code": normal_code, "msg": "成功", "data": {}}
  664.         
  665.         where = ' where 1 = 1 '
  666.         
  667.         sql = "SELECT {0}, sum({1}) AS total FROM zuixindianying {2} GROUP BY {0}".format(xColumnName, yColumnName, where)
  668.         L = []
  669.         cursor = connection.cursor()
  670.         cursor.execute(sql)
  671.         desc = cursor.description
  672.         data_dict = [dict(zip([col[0] for col in desc], row)) for row in cursor.fetchall()] 
  673.         for online_dict in data_dict:
  674.             for key in online_dict:
  675.                 if 'datetime.datetime' in str(type(online_dict[key])):
  676.                     online_dict[key] = online_dict[key].strftime(
  677.                         "%Y-%m-%d %H:%M:%S")
  678.                 else:
  679.                     pass
  680.             L.append(online_dict)
  681.         msg['data'] = L
  682.  
  683.         return JsonResponse(msg)
  684.  
  685. def zuixindianying_alipay(request):
  686.     if request.method in ["POST", "GET"]:
  687.         alipay = AliPay(
  688.             appid=settings.ALIPAY_APP_ID,
  689.             app_notify_url=None,
  690.             app_private_key_string=settings.APP_PRIVATE_KEY_STRING,
  691.             alipay_public_key_string=settings.ALIPAY_PUBLIC_KEY_STRING,
  692.             sign_type=settings.ALIPAY_SIGN_TYPE,
  693.             debug=True,
  694.             config=AliPayConfig(timeout=15)
  695.         )
  696.         
  697.         req_dict = request.session.get("req_dict")
  698.  
  699.         order_string = alipay.api_alipay_trade_page_pay(
  700.             out_trade_no=req_dict['tradeno'],
  701.             total_amount=req_dict['totalamount'],
  702.             subject=req_dict['subject'],
  703.             return_url='http://localhost:8080/django3yz6u/zuixindianying/notify',
  704.             #notify_url=''
  705.         )
  706.         pay_url = 'https://openapi.alipaydev.com/gateway.do?' + order_string
  707.         pay_url = '<form name="punchout_form" method="post" action="{0}"><input type="hidden" name="biz_content" ><input type="submit" value="立即支付" style="display: none"></form>'.format(pay_url)
  708.         
  709.         return JsonResponse({'code': 0, "data": pay_url})
  710.  
  711. def zuixindianying_notify(request):
  712.     if request.method in ["POST", "GET"]:
  713.         req_dict = request.session.get("req_dict")
  714.         out_trade_no = req_dict['out_trade_no']
  715.         cursor = connection.cursor()
  716.         
  717.         return redirect('http://localhost:8080/django3yz6u/admin/dist/index.html#/zuixindianying')
  718.  
  719.

四、数据库表(示范)：

数据库表有注释，可以导出数据字典及更新数据库时间，欢迎交流学习

 

五、主要技术介绍：

 Django框架介绍：

Django是高水准的Python编程语言驱动的一个开源模型．视图，控制器风格的Web应用程序框架，它起源于开源社区。使用这种架构，程序员可以方便、快捷地创建高品质、易维护、数据库驱动的应用程序。这也正是OpenStack的Horizon组件采用这种架构进行设计的主要原因。另外，在Dj ango框架中，还包含许多功能强大的第三方插件，使得Django具有较强的可扩展性。Django 项目源自一个在线新闻 Web 站点，于 2005 年以开源的形式被释放出来。Django 框架的核心组件有：

用于创建模型的对象关系映射；

为最终用户设计较好的管理界面；

URL 设计；

设计者友好的模板语言；

缓存系统。

Django(发音：[`dʒæŋɡəʊ]) 是用python语言写的开源web开发框架(open source web framework)，它鼓励快速开发,并遵循MVC设计。Django遵守BSD版权，初次发布于2005年7月, 并于2008年9月发布了第一个正式版本1.0 。

Django 根据比利时的爵士音乐家Django Reinhardt命名，他是一个吉普赛人，主要以演奏吉它为主，还演奏过小提琴等。

由于Django在近年来的迅速发展，应用越来越广泛，被著名IT开发杂志SD Times评选为2013 SD Times 100，位列“API、库和框架”分类第6位，被认为是该领域的佼佼者。

1.9 Django架构设计：

Django已经成为web开发者的首选框架，是一个遵循 MVC 设计模式的框架。MVC是Model、View、Controller三个单词的简写，分别代表模型、视图、控制器。Django其实也是一个MTV 的设计模式。MTV是Model、Template、View三个单词的简写，分别代表模型、模版、视图。但是在Django中，控制器接受用户输入的部分由框架自行处理，所以 Django 里更关注的是模型（Model）、模板(Template)和视图（Views），称为 MTV模式。它们各自的职责如下：

层次

职责

模型（Model），即数据存取层

处理与数据相关的所有事务： 如何存取、如何验证有效性、包含哪些行为以及数据之间的关系等。

模板(Template)，即表现层

处理与表现相关的决定： 如何在页面或其他类型文档中进行显示。

视图（View），即业务逻辑层

存取模型及调取恰当模板的相关逻辑。模型与模板的桥梁。

从以上表述可以看出Django 视图不处理用户输入，而仅仅决定要展现哪些数据给用户，而Django 模板 仅仅决定如何展现Django视图指定的数据。或者说, Django将MVC中的视图进一步分解为 Django视图 和 Django模板两个部分，分别决定 “展现哪些数据” 和 “如何展现”，使得Django的模板可以根据需要随时替换，而不仅仅限制于内置的模板。

至于MVC控制器部分，由Django框架的URLconf来实现。URLconf机制是使用正则表达式匹配URL，然后调用合适的Python函数。URLconf对于URL的规则没有任何限制，你完全可以设计成任意的URL风格，不管是传统的，RESTful的，或者是另类的。框架把控制层给封装了，无非与数据交互这层都是数据库表的读,写,删除,更新的操作。在写程序的时候，只要调用相应的方法就行了，感觉很方便。程序员把控制层东西交给Django自动完成了。 只需要编写非常少的代码完成很多的事情。所以，它比MVC框架考虑的问题要深一步，因为我们程序员大都在写控制层的程序。这个工作交给了框架，仅需写很少的调用代码，大大提高了工作效率。

1.10 Django工作机制：

1.用manage .py runserver 启动Django服务器时就载入了在同一目录下的settings .py。该文件包含了项目中的配置信息，如前面讲的URLConf等，其中最重要的配置就是ROOT_URLCONF，它告诉Django哪个Python模块应该用作本站的URLConf，默认的是urls .py

2.当访问url的时候，Django会根据ROOT_URLCONF的设置来装载URLConf。

3.然后按顺序逐个匹配URLConf里的URLpatterns。如果找到则会调用相关联的视图函数，并把HttpRequest对象作为第一个参数(通常是request)

4.最后该view函数负责返回一个HttpResponse对象。

六、项目调试学习（点击查看）

七、项目交流

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/IT小白/article/detail/531488
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号