updated "MyJoined"

Author: ldqLDQ

app.py

@@ -101,7 +101,7 @@ def post(self):
 api.add_resource(Search, '/search', endpoint='Search')
 api.add_resource(Join, '/join', endpoint='Join')
 api.add_resource(MyPublished, '/my/published', endpoint='MyPublished')
-#api.add_resource(MyJoined, '/my/joined', endpoint='MyJoined')
+api.add_resource(MyJoined, '/my/joined', endpoint='MyJoined')
 api.add_resource(TestSearch, '/test/search', endpoint='testsearch')
 
 

users.py

@@ -150,4 +150,45 @@ def post(self):
             "sql": sql,
             "data": dat
             # "result": float(args["rate"]*100)
+        }
+
+
+class MyJoined(Resource):
+    def get(self):
+        return 1
+
+    def post(self):
+        parser = reqparse.RequestParser()  # 新建parser实例
+        # 向parser实例中添加rate参数，并加以配置
+        # parser.add_argument('rate', type=float, help='Rate cannot be converted')
+        parser.add_argument('username')
+
+        # 将请求中传过来的参数存到args中
+        args = parser.parse_args()
+        # 将请求参数中的rate的值加以计算，并返回
+        username = pymysql.escape_string(args["username"])
+        db = pymysql.connect(host=Q_HOST, port=Q_PORT, user=Q_USER, passwd=Q_PASSWORD, db=Q_DB)
+        cursor = db.cursor()
+        sql = "SELECT * FROM participants where pname = \'%s\'" % username
+        cursor.execute(sql)
+        lis = cursor.fetchall()
+        print(lis)
+        tidlist = []
+        for i in lis:
+            tidlist.append(i[3])
+        dat = {}
+        num = 0
+        for j in tidlist:
+            sql = "SELECT * FROM records where tid = %d" % j
+            cursor.execute(sql)
+            res = cursor.fetchall()
+            for i in res:
+                dat0 = {"tid": i[0], "username": i[1], "stime": i[2], "etime": i[3], "location": i[4], "remarks": i[5], "joined": i[6], "finished": "已完成"}
+                dat[num] = dat0
+                num += 1
+        return {
+            "result": "ok",
+            "sql": sql,
+            "data": dat
+            # "result": float(args["rate"]*100)
         }