This commit is contained in:
yumoqing 2025-08-05 11:51:01 +08:00
parent 95af343674
commit a947a57eca

View File

@ -5,6 +5,8 @@ from ahserver.auth_api import get_session_userinfo
from sqlor.dbpools import DBPools from sqlor.dbpools import DBPools
from appPublic.uniqueID import getID from appPublic.uniqueID import getID
from appPublic.log import debug, error, exception from appPublic.log import debug, error, exception
from appPublic.registerfunction import RegisterFunction
from appPublic.worker import awaitify
from ahserver.filestorage import FileStorage from ahserver.filestorage import FileStorage
import hashlib import hashlib
@ -52,6 +54,9 @@ class FileMgr:
"hashvalue": hashvalue "hashvalue": hashvalue
} }
await sor.C('file', ns) await sor.C('file', ns)
if len(recs) == 0:
rf = RegisterFunction()
await rf.exe('fileuploaded', ns)
return True return True
return False return False
@ -67,6 +72,8 @@ class FileMgr:
remain = sor.R('file', {'hashvalue':delrec.hashvalue}) remain = sor.R('file', {'hashvalue':delrec.hashvalue})
if not remain: if not remain:
os.unlink(delrec.realpath) os.unlink(delrec.realpath)
rf = RegisterFunction()
await rf.exe('filedeleted', delrec)
async def has_sub(self, request, sor, folderid): async def has_sub(self, request, sor, folderid):
sql = """select unique a.* from folder a sql = """select unique a.* from folder a