insertWorkjob.py 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. from .flightDB import flightDB
  2. from unitls.LogerinTxt import app_logger
  3. def insertWorkjob(database:flightDB,workjobdata,taskid):
  4. try:
  5. A=["MDTITLE_C","WORKSTEP","BASE_CODE","PLANSTD"]
  6. num=1
  7. MDTITLE_C=""
  8. WORKSTEP=""
  9. PLANSTD=""
  10. BASE_CODE_now=""
  11. if len(workjobdata) != 0:
  12. for row in workjobdata:
  13. MDTITLE_C_now=row["MDTITLE_C"] if "MDTITLE_C" in row.keys() else ""
  14. WORKSTEP_now = row["WORKSTEP"] if "WORKSTEP" in row.keys() else ""
  15. BASE_CODE_now = row["BASE_CODE"] if "BASE_CODE" in row.keys() else ""
  16. PLANSTD_now = row["PLANSTD"] if "PLANSTD" in row.keys() else ""
  17. if MDTITLE_C !="":
  18. MDTITLE_C=MDTITLE_C+"\n------------------------------------------------\n"+"工作包%s内容:"%num+"\n"+MDTITLE_C_now
  19. WORKSTEP=WORKSTEP+"\n------------------------------------------------\n"+"工作包%s步骤:"%num+"\n"+WORKSTEP_now
  20. PLANSTD=PLANSTD+"\n------------------------------------------------\n"+"工作包%s计划开始时间:"%num+"\n"+PLANSTD_now
  21. else:
  22. MDTITLE_C ="工作包%s内容:" % num + "\n" + MDTITLE_C_now
  23. WORKSTEP ="工作包%s步骤:" % num + "\n" + WORKSTEP_now
  24. PLANSTD ="工作包%s计划开始时间:" % num + "\n" + PLANSTD_now
  25. num+=1
  26. newdic={"基地":"'%s'"%BASE_CODE_now,"开始时间":"'%s'"%PLANSTD,"项目描述":"'%s'"%MDTITLE_C.replace("\"","*").replace("#","*").replace("\\",";").replace("\'","*").replace("/","、"),"工作步骤":"'%s'"%WORKSTEP.replace("\'","*").replace("\\",";").replace("/","、").replace("\"","*").replace("#","*")}
  27. database.lazyUpdateItem('workjob', newdic, "任务编号='%s'" %taskid)
  28. res={"返回值":"ok"}
  29. database.FunctionCommit()
  30. return res
  31. except Exception as e:
  32. app_logger.log_error(e)
  33. res = {"返回值": "fail"}
  34. database.FunctionCommit()
  35. return res