提交任务后端

DAPlatform/dao/Relation.py

@@ -237,6 +237,28 @@ def delete_by_sliceid(user_id, slice_id):
         return True
 
 
+# 判断分片列表是否完成，若全部完成，置flag=True
+def finish_slicelist(user_id, slicelist):
+    try:
+        find = Relation.select().where(Relation.user_id == user_id, Relation.slice_id << slicelist)
+        complete_flag = True
+        index = 0
+        while index < len(find):
+            if find[index].complete_time is None:
+                complete_flag = False
+                break
+            index += 1
+        if complete_flag:
+            Relation.update({Relation.flag: True}).where(Relation.user_id == user_id, Relation.slice_id << slicelist).execute()
+        else:
+            return Result(0, "submit failed", {})
+
+    except:
+        return Result(0, "submit failed", {})
+    else:
+        return Result(1, "submit success", {})
+
+
 if __name__ == '__main__':
     Relation.drop_table()
     Relation.create_table()

DAPlatform/views/task.py

@@ -255,3 +255,21 @@ def give_up_task():
         'data': {}
     }
     return json.dumps(res)
+
+
+# 提交任务
+@task.route("/finsihTask", methods=["Post"])
+def finish_task():
+    userId = request.args['userId']
+    taskId = request.args['taskId']
+    slicelist = Slice.find_slicelist_by_taskId(taskId)
+    list = []
+    for sliceItem in slicelist:
+        list.append(sliceItem.slice_id)
+    ret = Relation.finish_slicelist(userId, list)
+    res = {
+        'code': ret.code,
+        'message': ret.message,
+        'data': ret.data
+    }
+    return json.dumps(res)