flightinfoV3_sever/Functions/DButilsFunction/checkflightplan.py

import datetime
import unitls.baseFunction as baseFunction
from unitls.LogerinTxt import app_logger
from unitls.StaticDataclass import get_dic
from .flightDB import flightDB
from .initFlightDatabase import initFlightDatabase


def waringinsert(database,text,taskid,col):
    try:
        newDic = {"警告信息": text,"航班编号":taskid, "信息状态": "", "提示信息": "", "产生时间": "%s" % datetime.datetime.now(),
               "处理人": "", "处理时间": "","变更字段": col, "显示对象": "", "提示内容": ""}
        database.lazyInsertData('logs', newDic)
    except Exception as e:
        app_logger.log_error(f"警告信息插入错误，插入信息{text}，{taskid}，{col}，错误信息见下一条")
        app_logger.log_error(e)
def checkFlightplan(database:flightDB,wokload:flightDB):
    updatedic = {2: 11, 4: 13,5:14,6: 16,7: 17, 8: 9,10: 7, 11: 8, 15: 18, 16: 18,21: 12, 25: 3, 26: 2, 33 : 20} #taskinfo :flightplan
    try:
        print(datetime.datetime.now(),'[数据库操作]开始校验航班')
        nowDay = datetime.datetime.now().strftime("%Y%m%d")
        nowDay_1 = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y%m%d")
        nowDay_2 = (datetime.date.today() + datetime.timedelta(days=1)).strftime("%Y%m%d")
        now_20 = (datetime.datetime.now() + datetime.timedelta(hours=5)).strftime("%Y%m%d")
        initFlightDatabase(database, wokload, now_20)
        initFlightDatabase(database, wokload, nowDay_1)
        initFlightDatabase(database, wokload, nowDay_2)
        initFlightDatabase(database, wokload, nowDay)

        if now_20 == nowDay:
            day = [nowDay, nowDay_1]
        else:
            day = [nowDay, nowDay_1, nowDay_2]
        for nowDayStr in day:
            flightplan_flight_ids = database.queryTabel('flightplaninfo{}'.format(nowDayStr),"*","备1 ='1' and flgCs =''")
            TaskFlightinfo_flight_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '备4,备5', "航班编号!=''")
            TaskFlightinfo_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '航班编号', "航班编号!=''")

            flight_id_now = []
            if flightplan_flight_ids and len(flightplan_flight_ids) != 0:
                for sortkey in flightplan_flight_ids:
                    if str(sortkey[0]) not in str(TaskFlightinfo_flight_ids):
                        flight_id_now.append(f"System{sortkey[0]}")
                        TaskflightinfoLabel=get_dic("TaskflightinfoLabel")
                        if f"System{sortkey[0]}" not in str(TaskFlightinfo_ids):
                            peopleSchedule_ids = database.queryTabel('peopleSchedule{}'.format(nowDayStr) , '编号,附加消息', "航班编号 ='%s'"%f"System{sortkey[0]}")
                            newdic={"航班编号":f"System{sortkey[0]}","进出港城市":sortkey[5]+"-"+sortkey[6],"航班来源":"飞机排班","机号":sortkey[1].replace("B",""),"取消标志":0}
                            if sortkey[6] == "天府":
                                newdic["航班类型"] = "AF"
                            else:
                                newdic["航班类型"] = "AP"

                            for key,value in updatedic.items():
                                newdic[TaskflightinfoLabel[key]]= sortkey[value]
                            for key in TaskflightinfoLabel:
                                if key not in newdic.keys():
                                    newdic[key]=""
                            database.lazyInsertData('TaskFlightinfo{}'.format(nowDayStr), newdic)
                            if sortkey[6] == "天府":
                                if  f"System{sortkey[0]}-1-A" not in str(peopleSchedule_ids):
                                    newdic={"编号":f"System{sortkey[0]}-1-A","航班编号":f"System{sortkey[0]}","显示模式":"A","放行":"","勤务1":"","勤务2":"","工1":"","工2":"","工3":"","附加消息":"AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间"}
                                    database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newdic)
                                else:
                                    fj = peopleSchedule_ids[0][1]
                                    if "AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间" not in fj:
                                        newdic={"附加消息":"'%s'"%(fj+";AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间")}
                                    else:
                                        newdic={"附加消息":"'AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间'"}
                                    database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newdic,"编号='%s'"%f"System{sortkey[0]}-1-A")
                            elif sortkey[5] == "天府":
                                if  f"System{sortkey[0]}-2-A" not in str(peopleSchedule_ids):
                                    newdic={"编号":f"System{sortkey[0]}-2-A","航班编号":f"System{sortkey[0]}","显示模式":"A","放行":"","勤务1":"","勤务2":"","工1":"","工2":"","工3":"","附加消息":"AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间"}
                                    database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newdic)
                                else:
                                    fj = peopleSchedule_ids[0][1]
                                    if "AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间" not in fj:
                                        newdic={"附加消息":"'%s'"%(fj+";AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间")}
                                    else:
                                        newdic={"附加消息":"'AMRO航班缺失,无法派工，航班信息来源于飞机排班，请核实航班类型和保障时间'"}
                                    database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newdic,"编号='%s'"%f"System{sortkey[0]}-2-A")

                            waringinsert(database,f"{sortkey[1]}/{sortkey[12]}在Amro任务派工模块无显示，已读取飞机排班系统信息显示，航班将无法派工，请核对航班、随机等信息并加强监控！",f"System{sortkey[0]}","航班缺失警告")
                        else:
                            TaskFlightinfos = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '*' ,"航班编号='%s'"%f"System{sortkey[0]}")[0]
                            for key,value in updatedic.items():
                                if TaskFlightinfos[key] != sortkey[value]:
                                    newdic={TaskflightinfoLabel[key]:"'%s'"%sortkey[value]}
                                    database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr),newdic,"航班编号='%s'"%f"System{sortkey[0]}")
                                if (sortkey[5]+sortkey[6]) !=TaskFlightinfos[23]:
                                    newdic={TaskflightinfoLabel[23]:"'%s'"%(sortkey[5]+"-"+sortkey[6])}
                                    database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr),newdic,"航班编号='%s'"%f"System{sortkey[0]}")
                                if sortkey[1].replace("B","") != TaskFlightinfos[1]:
                                    newdic={"机号":"'%s'"%sortkey[1].replace("B","")}
                                    database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr),newdic,"航班编号='%s'"%f"System{sortkey[0]}")
                                if sortkey[6] == "天府" and TaskFlightinfos[3] != "AF":
                                    newdic={"航班类型":"'AF'"}
                                    database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic,"航班编号='%s'" % f"System{sortkey[ 0 ]}")
                                elif sortkey[5] == "天府" and TaskFlightinfos[3] != "AP":
                                    newdic={"航班类型":"'AP'"}
                                    database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic,"航班编号='%s'" % f"System{sortkey[ 0 ]}")
                    elif str(sortkey[0]) in str(TaskFlightinfo_flight_ids) and f"System{sortkey[0]}" in str(TaskFlightinfo_ids):
                        database.deleteSingledata('TaskFlightinfo{}'.format(nowDayStr),"航班编号='%s'"%f"System{sortkey[0]}")
                        waringinsert(database,f"{sortkey[1]}/{sortkey[12]}在Amro任务派工模块中恢复显示，如未派工请前往派工！飞机排班显示航班将在5min中后自动删除，做好人员安排信息备份！",f"System{sortkey[0]}","航班缺失恢复警告")
            database.FunctionCommit()
            flightinfo_flight_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '*',"航班来源 ='飞机排班'")
            if len(flightinfo_flight_ids) != 0 :
                for iii in flightinfo_flight_ids:
                    datas = baseFunction.TuplefindInList1(flightinfo_flight_ids , iii[0], 0)[0]
                    if str(iii[0]) not in flight_id_now:
                        cancelid = datas[35] if datas[35] else 0
                        newcancelid = int(cancelid) + 1
                        if int(newcancelid) < 3:
                            newdic = {"取消标志" : "'%s'" % newcancelid}
                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr) , newdic ,"航班编号='%s'" % iii[0])
                        else:
                            database.deleteSingledata("TaskFlightinfo{}".format(nowDayStr),"航班编号='%s'" %f"{iii[0]}")
                            #waringinsert(database,f"{datas[1]}/{datas[12]}Sytem航班删除！",f"System{datas[0]}","Sytem航班自动删除")
                        database.FunctionCommit()
    except Exception as e:
        #print(e)
        database.FunctionCommit()
        app_logger.log_error(e)
        app_logger.log_error("飞机排班系统校验航班失败")

    print(datetime.datetime.now(),'[数据库操作]结束校验航班')