dingdingDelete_flight.py 1.5 KB

123456789101112131415161718192021222324252627282930313233343536
  1. from .flightDB import flightDB
  2. import datetime
  3. from unitls.LogerinTxt import app_logger
  4. import requests
  5. import json
  6. import unitls.baseFunction as baseFunction
  7. from unitls.StaticDataclass import get_dic
  8. def dingdingDelete_flight(database:flightDB):
  9. try:
  10. dmac={}
  11. # 需要建立昨日初始化
  12. nowDay = datetime.datetime.now().strftime("%Y%m%d")
  13. nowDay_1 = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y%m%d")
  14. day = [nowDay_1,nowDay]
  15. for nowDayStr in day:
  16. tfac_ids=database.queryTabel('sortFlight{}'.format(nowDayStr),"航班编号","CAST(级别 AS integer)=1")
  17. datas=database.queryTabel('TaskFlightinfo{}'.format(nowDayStr),"*","航班编号!=''")
  18. if len(tfac_ids) != 0:
  19. for i in tfac_ids:
  20. acno=baseFunction.TuplefindInList3(datas,i[0],0,1)
  21. type=get_dic("taskType")[baseFunction.TuplefindInList3(datas,i[0],0,3)]
  22. if acno in dmac.keys() and type !="航前":
  23. dmac[acno]=i[0]
  24. elif acno not in dmac.keys():
  25. dmac[acno] = i[0]
  26. try:
  27. res = requests.post(url="http://124.223.185.200:888/delete_flight/", data=json.dumps(dmac),timeout=5) # 自己服务器
  28. #flightsts = res.json()
  29. #print(flightsts)
  30. except Exception as e:
  31. app_logger.log_error(e)
  32. pass
  33. #QT输出弹窗警告,服务器链接失效
  34. except Exception as e:
  35. app_logger.log_error(e)