后端加锁

backend/SqliteUtil.py

@@ -262,6 +262,7 @@ def deleteStaff(staff_id):
 
 def updateActivity(activity):
     try:
+        lock_threading.acquire()
         print(activity)  # {"UserID": 1, "ActivityName": "Meeting", "ActivityBeginDate": "2024-05-21", "ActivityBeginTime": "10:00:00", "ActivityEndDate": "2024-05-21", "ActivityEndTime": "11:00:00"}
         activity = json.loads(activity)
         activityID = activity.get('ActivityID', 0)
@@ -315,6 +316,8 @@ def updateActivity(activity):
     except Exception as e:
         print(repr(e))
         return '新增或修改失败'
+    finally:
+        lock_threading.release()
 
 def getActivities(UserID):
     try:
@@ -330,28 +333,39 @@ def getActivities(UserID):
         lock_threading.release()
 
 def getActivitiesFromData(dataList):
-    activities = []
-    for itemArray in dataList:   # dataList数据库返回的数据集，是一个二维数组
-        # itemArray: (1, 1, 'Meeting', '2024-05-21', '10:00:00', '2024-05-21', '11:00:00')
-        activity = {}
-        for columnIndex, columnName in enumerate(activityColumns):
-            columnValue = itemArray[columnIndex]
-            activity[columnName] = columnValue
-        activities.append(activity)
-    return activities
+    try:
+        lock_threading.acquire()
+        activities = []
+        for itemArray in dataList:   # dataList数据库返回的数据集，是一个二维数组
+            # itemArray: (1, 1, 'Meeting', '2024-05-21', '10:00:00', '2024-05-21', '11:00:00')
+            activity = {}
+            for columnIndex, columnName in enumerate(activityColumns):
+                columnValue = itemArray[columnIndex]
+                activity[columnName] = columnValue
+            activities.append(activity)
+        return activities
+    except Exception as e:
+        print(repr(e))
+        return []
+    finally:
+        lock_threading.release()
 
 def deleteActivity(activity_id):
     try:
+        lock_threading.acquire()
         sql = 'DELETE FROM TodoActivity WHERE ActivityID = ?'
         cursor.execute(sql, (activity_id,))
         conn.commit()
         return '删除成功'
     except Exception as e:
         print(repr(e))
         return '删除失败'
+    finally:
+        lock_threading.release()
 
 def insertOrUpdateTodoItem(item):
     try:
+        lock_threading.acquire()
         item = json.loads(item)
         print(item)
         item_id = item.get('ItemID', 0)
@@ -405,49 +419,67 @@ def insertOrUpdateTodoItem(item):
     except Error as e:
         print(e)
         return '新增或修改失败'
+    finally:
+        lock_threading.release()
 
 
 def deleteTodoItem(item_id):
     try:
+        lock_threading.acquire()
         sql = 'DELETE FROM TodoItem WHERE ItemID = ?'
         cursor.execute(sql, (item_id,))
         conn.commit()
         return '删除成功'
     except Error as e:
         print(e)
         return '删除失败'
+    finally:
+        lock_threading.release()
 
 
 def getTodoItems():
     try:
+        lock_threading.acquire()
         sql = 'SELECT * FROM TodoItem'
         cursor.execute(sql)
         return cursor.fetchall()
     except Error as e:
         print(e)
         return []
+    finally:
+        lock_threading.release()
 
 def getTodoItemsFromData(dataList):
-    items = []
-    for itemArray in dataList:
-        item = {
-            "ItemID": itemArray[0],
-            "ActivityID": itemArray[1],
-            "UserID": itemArray[2],
-            "ItemContent": itemArray[3],
-            "ItemLevel": itemArray[4]
-        }
-        items.append(item)
-    return items
+    try:
+        lock_threading.acquire()
+        items = []
+        for itemArray in dataList:
+            item = {
+                "ItemID": itemArray[0],
+                "ActivityID": itemArray[1],
+                "UserID": itemArray[2],
+                "ItemContent": itemArray[3],
+                "ItemLevel": itemArray[4]
+            }
+            items.append(item)
+        return items
+    except Error as e:
+        print(e)
+        return []
+    finally:
+        lock_threading.release()
 
 def getTodoItemsByActivity(activity_id):
     try:
+        lock_threading.acquire()
         sql = 'SELECT * FROM TodoItem WHERE ActivityID = ?'
         cursor.execute(sql, (activity_id,))
         return cursor.fetchall()
     except Error as e:
         print(e)
         return []
+    finally:
+        lock_threading.release()