# -*- coding: utf-8 -*- from web.controllers.api import route_api from flask import request,jsonify,g,send_file from application import app,db import requests,json from common.models.member.Member import Member from common.models.member.Mendianuserinfo import Mendianuserinfo from common.models.member.DeviceInfo import Deviceinfo from common.models.member.Membermiya import Membermiya from common.models.member.OauthMemberBind import OauthMemberBind from common.models.food.WxShareHistory import WxShareHistory from common.libs.Helper import getCurrentDate from common.libs.member.MemberService import MemberService # RJBrjb @route_api.route("/member/login",methods = [ "GET","POST" ]) def login(): resp = {'code': 200, 'msg': '操作成功~', 'data': {}} req = request.values code = req['code'] if 'code' in req else '' app.logger.info(code) if not code or len(code) < 1: resp['code'] = -1 resp['msg'] = "需要code" return jsonify(resp) openid = MemberService.getWeChatOpenId(code) app.logger.info(openid) if openid is None: resp['code'] = -1 resp['msg'] = "调用微信出错" return jsonify(resp) nickname = req['nickName'] if 'nickName' in req else '' sex = req['gender'] if 'gender' in req else 0 avatar = req['avatarUrl'] if 'avatarUrl' in req else '' ''' 判断是否已经测试过，注册了直接返回一些信息 ''' bind_info = OauthMemberBind.query.filter_by(openid=openid, type=1).first() if not bind_info: model_member = Member() model_member.nickname = nickname model_member.sex = sex model_member.avatar = avatar model_member.salt = MemberService.geneSalt() model_member.updated_time = model_member.created_time = getCurrentDate() db.session.add(model_member) db.session.commit() model_bind = OauthMemberBind() model_bind.member_id = model_member.id model_bind.type = 1 model_bind.openid = openid model_bind.extra = '' model_bind.updated_time = model_bind.created_time = getCurrentDate() db.session.add(model_bind) db.session.commit() bind_info = model_bind member_info = Member.query.filter_by(id=bind_info.member_id).first() token = "%s#%s" % (MemberService.geneAuthCode(member_info), member_info.id) resp['data'] = {'token': token} return jsonify(resp) @route_api.route("/member/logintwo",methods = [ "GET","POST" ]) def logintwo(): resp = {'code': 200, 'msg': '操作成功~', 'data': {}} req = request.values app.logger.info(req) name = req['name'] if 'name' in req else '' app.logger.info(name) phone = req['phone'] if 'phone' in req else 0 app.logger.info(phone) storename = req['storename'] if 'storename' in req else '' app.logger.info(storename) name_info = Mendianuserinfo.query.filter_by(nickname=name).first() if not name_info: model_mendianuserinfo = Mendianuserinfo() model_mendianuserinfo.nickname = name model_mendianuserinfo.mobile = phone model_mendianuserinfo.storename = storename db.session.add(model_mendianuserinfo) db.session.commit() return jsonify(resp) @route_api.route("/member/deviceinfo",methods = [ "GET","POST" ]) def deviceinfo(): resp = {'code': 200, 'msg': '操作成功~', 'data': {}} req = request.values app.logger.info(req) nickname = req['nickname'] if 'nickname' in req else '' app.logger.info(nickname) version = req['version'] if 'version' in req else '' app.logger.info(version) jiguang = req['jiguang'] if 'jiguang' in req else '' app.logger.info(jiguang) xiaoqu = req['xiaoqu'] if 'xiaoqu' in req else '' app.logger.info(xiaoqu) louhao = req['louhao'] if 'louhao' in req else '' app.logger.info(louhao) danyuan = req['danyuan'] if 'danyuan' in req else '' app.logger.info(danyuan) jingdu = req['jingdu'] if 'jingdu' in req else '' app.logger.info(jingdu) weidu = req['weidu'] if 'weidu' in req else '' app.logger.info(weidu) snnum = req['snnum'] if 'snnum' in req else '' app.logger.info(snnum) reg_ip = req['reg_ip'] if 'reg_ip' in req else '' app.logger.info(reg_ip) name_info = Deviceinfo.query.filter_by(nickname=nickname).first() if not name_info: model_deviceinfo = Deviceinfo() model_deviceinfo.nickname = nickname model_deviceinfo.version = version model_deviceinfo.jiguang = jiguang model_deviceinfo.xiaoqu = xiaoqu model_deviceinfo.louhao = louhao model_deviceinfo.danyuan = danyuan model_deviceinfo.jingdu = jingdu model_deviceinfo.weidu = weidu model_deviceinfo.snnum = snnum model_deviceinfo.reg_ip = reg_ip db.session.add(model_deviceinfo) db.session.commit() return jsonify(resp) @route_api.route("/member/loginmiya",methods = [ "GET","POST" ]) def loginmiya(): resp = {'code': 200, 'msg': 'r操作成功~', 'data': {}} req = request.values app.logger.info(req) name = req['nickname'] if 'nickname' in req else '' app.logger.info(name) mobile = req['mobile'] if 'mobile' in req else 0 app.logger.info(mobile) token = req['token'] if 'token' in req else '' app.logger.info(token) miya_info = Membermiya.query.filter_by(nickname=name).first() if not miya_info: model_membermiya = Membermiya() model_membermiya.nickname = name model_membermiya.mobile = mobile model_membermiya.token = token db.session.add(model_membermiya) db.session.commit() return jsonify(resp) @route_api.route("/member/ruilaizi",methods = [ "GET","POST" ]) def ruilaizi(): resp = {'code': 200, 'msg': 'r操作成功~', 'data': {}} req = request.values app.logger.info(req) # 文件路径 1.txt为测试文件 在项目的static/file目录下 # 获取文件的路径和文件名 filepath = os.path.join('static/app-release.apk') try: # 尝试打开文件并发送 return send_file(filepath, as_attachment=True) except PermissionError: return '文件权限错误，无法访问', 403 except Exception as e: return f'发生错误：{str(e)}', 500 return jsonify(resp) @route_api.route("/member/ruilaizitest",methods = [ "GET","POST" ]) def ruilaizitest(): resp = {'code': 200, 'msg': 'r操作成功~', 'data': {}} req = request.values app.logger.info(req) # name = req['nickname'] if 'nickname' in req else '' # app.logger.info(name) # mobile = req['mobile'] if 'mobile' in req else 0 # app.logger.info(mobile) # token = req['token'] if 'token' in req else '' # app.logger.info(token) # miya_info = Membermiya.query.filter_by(nickname=name).first() # if not miya_info: # model_membermiya = Membermiya() # model_membermiya.nickname = name # model_membermiya.mobile = mobile # model_membermiya.token = token # db.session.add(model_membermiya) # db.session.commit() return jsonify(resp) @route_api.route("/member/check-reg",methods = [ "GET","POST" ]) def checkReg(): resp = {'code': 200, 'msg': '操作成功~', 'data': {}} req = request.values code = req['code'] if 'code' in req else '' if not code or len(code) < 1: resp['code'] = -1 resp['msg'] = "需要code" return jsonify(resp) openid = MemberService.getWeChatOpenId(code) if openid is None: resp['code'] = -1 resp['msg'] = "调用微信出错" return jsonify(resp) bind_info = OauthMemberBind.query.filter_by(openid=openid, type=1).first() if not bind_info: resp['code'] = -1 resp['msg'] = "未绑定" return jsonify(resp) member_info = Member.query.filter_by( id = bind_info.member_id).first() if not member_info: resp['code'] = -1 resp['msg'] = "未查询到绑定信息" return jsonify(resp) token = "%s#%s"%( MemberService.geneAuthCode( member_info ),member_info.id ) resp['data'] = { 'token':token } return jsonify(resp) @route_api.route("/member/share",methods = [ "POST" ]) def memberShare(): resp = {'code': 200, 'msg': '操作成功~', 'data': {}} req = request.values url = req['url'] if 'url' in req else '' member_info = g.member_info model_share = WxShareHistory() if member_info: model_share.member_id = member_info.id model_share.share_url = url model_share.created_time = getCurrentDate() db.session.add(model_share) db.session.commit() return jsonify(resp) @route_api.route("/member/info") def memberInfo(): resp = {'code': 200, 'msg': '操作成功~', 'data': {}} member_info = g.member_info resp['data']['info'] = { "nickname":member_info.nickname, "avatar_url":member_info.avatar } return jsonify(resp)