* Fix SQLite queue.

2023-06-26 09:03:08 +08:00
parent 40f7650208
commit ebef781f5a
1 changed files with 9 additions and 2 deletions
@@ -531,10 +531,17 @@ class admin extends control
        $querys = $this->dao->select('*')->from(TABLE_SQLITE_QUEUE)->where('status')->eq('wait')->fetchAll();

        $sqlite->begin();
-        foreach($querys as $query) $sqlite->rawExec($query->sql);
+        foreach($querys as $query)
+        {
+            $sqlite->rawExec($query->sql);
+            $this->dao->update(TABLE_SQLITE_QUEUE)
+                ->set('status')->eq('done')
+                ->set('execDate')->eq($now)
+                ->where('id')->eq($query->id)
+                ->exec();
+        }
        $sqlite->commit();

-        $this->dao->update(TABLE_SQLITE_QUEUE)->set('status')->eq('done')->set('execDate')->eq($now)->where('id')->eq($query->id)->exec();
        echo 'success';
    }
 }