updateRiskdb.py 978 B

12345678910111213141516171819202122232425
  1. from .flightDB import flightDB
  2. from unitls.LogerinTxt import app_logger
  3. import openpyxl
  4. import datetime
  5. def updateRiskdb(database:flightDB, fileName): #创建准备组提示数据库
  6. fdb = database
  7. fdb.deleteTable("RiskTable")
  8. try:
  9. workbook = openpyxl.load_workbook(filename=fileName)
  10. mysheet = workbook.active
  11. myrows = list(mysheet.values)[1:]
  12. mytitle = list(mysheet.values)[0]
  13. for myrow in myrows:
  14. mydics0 = {}
  15. for i in range(0, (len(mytitle))):
  16. mydics0[mytitle[i]] = "%s"%(myrow[i] if myrow[i] != None and myrow[i] else '')
  17. #print(mydics0)
  18. fdb.lazyInsertData('RiskTable',mydics0)
  19. fdb.FunctionCommit()
  20. return 1
  21. except Exception as e:
  22. app_logger.log_error(e)
  23. print(datetime.datetime.now(),'[数据库操作]数据库获取错误!!检查模板文件!风险提示功能失效!!')
  24. fdb.FunctionCommit()
  25. return 0