add 后端用户表、数据表

DAPlatform/.idea/DAPlatform.iml

@@ -7,7 +7,7 @@
     <content url="file://$MODULE_DIR$">
       <excludeFolder url="file://$MODULE_DIR$/venv" />
     </content>
-    <orderEntry type="inheritedJdk" />
+    <orderEntry type="jdk" jdkName="Python 3.7" jdkType="Python SDK" />
     <orderEntry type="sourceFolder" forTests="false" />
   </component>
   <component name="TemplatesService">
@@ -18,7 +18,4 @@
       </list>
     </option>
   </component>
-  <component name="TestRunnerService">
-    <option name="PROJECT_TEST_RUNNER" value="Unittests" />
-  </component>
 </module>
\ No newline at end of file

DAPlatform/.idea/misc.xml

@@ -3,5 +3,8 @@
   <component name="JavaScriptSettings">
     <option name="languageLevel" value="ES6" />
   </component>
-  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.7 (DAPlatform)" project-jdk-type="Python SDK" />
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.7" project-jdk-type="Python SDK" />
+  <component name="PyCharmProfessionalAdvertiser">
+    <option name="shown" value="true" />
+  </component>
 </project>
\ No newline at end of file

DAPlatform/DA.py

-from flask import Flask, render_template
+from flask import Flask, render_template, request
+from flask import jsonify
+from peewee import *
 import  os
 app = Flask(__name__)
+mysql = MySQLDatabase(
+    'sys',
+    host='127.0.0.1',
+    user='root',
+    passwd='root',
+)
 
-# @app.route('/')
-# def hello_world():
-#     return "<h1 style='color:red'>Hello World</h1>"
-
-
-@app.route('/')
-def hello(name=None):
-    return render_template('index.html', name=name)
-
-
-from service.common.testss import *
 
 if __name__ == '__main__':
+    mysql.connect()
     app.run()
 
+

DAPlatform/dao/Data.py

+from peewee import *
+from DA import mysql
+
+mysql.connect()
+
+class Data(Model):
+    name = CharField(null=False)
+    url = CharField(null=False,unique=True)
+    class Meta:
+        database = mysql
+
+#向数据库中添加原始数据
+def create_data(name,url):
+    if not Data.table_exists():
+        Data.create_table()
+    try:
+        data = Data(name=name,url=url)
+        data.save()
+    except Exception:
+        print(0)
+    else:
+        print(1)
+
+#根据数据id寻找数据url
+def find_data(id):
+    if not Data.table_exists():
+        Data.create_table()
+    try:
+        data = Data.get(Data.id == id)
+    except Exception:
+        print(0)
+    else:
+        print(data.url)
+
+if __name__ == '__main__':
+    create_data('ha','123')
+    find_data(1)
\ No newline at end of file

DAPlatform/dao/User.py

+from peewee import *
+from DA import mysql
+
+mysql.connect()
+
+class User(Model):
+    username = CharField(unique=True,null=False);
+    password = CharField(null=False);
+    email = CharField(unique=True,null=False);
+    type = BooleanField(default=0);
+    picscore = IntegerField(default=0);
+    picAccuracy =  DoubleField(default=0);
+    textscore = IntegerField(default=0);
+    textAccuracy = DoubleField(default=0);
+    publishscore = IntegerField(default=0);
+    class Meta:
+        database = mysql;
+
+#注册功能
+def create_user(username,password,email):
+    if not User.table_exists():
+        User.create_table()
+    user = User(username=username,password=password,email=email)
+    try:
+        user.save()
+    except BaseException:
+        print(0);
+    else:
+        print(1)
+
+#登录
+def find_user(username,password):
+    if not User.table_exists():
+        User.create_table()
+    try:
+        p = User.get(User.username == username and User.password == password)
+    except Exception:
+        print(0)
+    else:
+        print(1)
+
+#个人信息界面根据用户名返回用户信息
+def find_information(username):
+    if not User.table_exists():
+        User.create_table()
+    try:
+        p = User.get(User.username == username)
+    except Exception:
+        print(0)
+    else:
+        print(p.email)
+
+if __name__ == '__main__':
+    create_user('333','0','7')
+    find_information('333')
+    find_user('123','200')
\ No newline at end of file

DAPlatform/dao/model.py

-from peewee import *
-from pymongo import MongoClient
-import datetime
-
-mysql = MySQLDatabase(
-    'test',
-    host='127.0.0.1',
-    user='root',
-    passwd='root',
-    charset='utf8'
-)
-# 连接mysql数据库
-# mysql.connect();
-
-# 连接mongodb数据库, root:mongodb为角色：登录密码
-client = MongoClient('mongodb://root:mongodb@localhost:27017')
-
-# mysql数据库基类
-class MysqlBaseModel(Model):
-    # 内部类
-    class Meta:
-        database = mysql;  # 每一个继承BaseModel类的子类都是连接db表
-
-# mysql示例类
-class User(MysqlBaseModel):
-    username = CharField(unique=True);  # 每个属性都是一个表字段
-
-
-class Tweet(MysqlBaseModel):
-    user = ForeignKeyField(User, related_name='tests');
-    message = TextField();
-    created_date = DateTimeField(default=datetime.datetime.now);
-    is_published = BooleanField(default=True);
-
-
-if __name__ == '__main__':
-    # mysql操作示例
-    # User.create_table();   创建User表
-    # Tweet.create_table();   创建Tweet表
-    # 添加
-    # user = User.create(username="tom")
-    # Tweet.create(user=user, message="this is test msg")
-    # # 查询
-    # t = Tweet.get(message="this is test msg")
-    # print(t.user_id)
-    # print(t.created_date)
-    # print(t.is_published)
-
-    # mongodb操作示例
-    mongodb = client['test']
-    collection = mongodb['testcollection'].find()
-    for t in collection:
-        print(t)
-    col = mongodb['test1']
-    image = {'onepic': '1.jpg', 'twopic': '2.jpg', 'threepic': '3.jpg'}
-    aim = {'name': 'test_1', 'document': 'this is test msg!', 'image': image}
-    col.insert_one(aim)
-
-

DAPlatform/handler/hd_user.py

+from flask import jsonify
+from flask import request
+from dao import User
+from DA import app
+
+@app.route('/register')
+def login():
+    username = request.form.get('username')
+    password = request.form.get('password')
+    email = request.form.get('email')
+    User.create_user(username,password,email)
+    return jsonify(username)
\ No newline at end of file