flightinfo_sever/Functions/DButilsFunction/insertTaskDataToTable.py

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


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 noteinsert(database,text,taskid,col):
    try:
        newDic = {"警告信息": '',"航班编号":taskid, "信息状态": "", "提示信息": text, "产生时间": "%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 checkTASKTYPE(row,en2zh,database,flightdate,LOGsdeactive,headerLabelKey,headerLabel,nowDayStr):
    try:
        newDic = {}
        for col in row:
            if col in headerLabelKey:
                if col != "FJ_TASKIDS":
                    newDic[en2zh[col]] = row[col]
                else:
                    newDic[en2zh[col]] = ",".join(row[col])
        if row["TASKTYPE"] == "" and LOGsdeactive != 0:
            waringinsert(database,"[%s]机号%s航班号%s,航班类型显示为空白,请查看派工模块并及时调整任务类型!!" %(flightdate, row["ACNO"], row["FNO"]),row["TASKID"], en2zh["TASKTYPE"])


        newDic['航班编号'] = str(row['TASKID'])
        newDic['取消标志'] = "0"
        newDic['航班来源'] = "AMRO"
        for key in headerLabel:
            if key not in newDic.keys():
                newDic[key] = ''

        database.lazyInsertData('TaskFlightinfo{}'.format(nowDayStr), newDic)
    except Exception as e:
        app_logger.log_error(f"航班类型监测并写入数据错误，详细错误信息见下条")
        app_logger.log_error(e)

def judgeWaringsts(bztime,oldbztime): #只抑制警告，不抑制note
    now = datetime.datetime.now()
    starttime = now-datetime.timedelta(hours=3)
    endtime = now+datetime.timedelta(hours=4)   #最多4+2小时的
    if (starttime < datetime.datetime.strptime(bztime, "%Y-%m-%d %H:%M:%S") < endtime) or (starttime < datetime.datetime.strptime(oldbztime, "%Y-%m-%d %H:%M:%S") < endtime ):  #当现在距离这个航班的预计保障时间相差5h或者过了一1h之内就不抑制
        return 0
    else:
        return 1



def insertTaskDataToTable(database: flightDB, datatime: str, jsonData,jsonData2):
    flightst_code = {"4": "接机已到位提示", "7": "已放行提示", "11": "二送已到位提示"}
    bglist = ["ACNO", "FNO", "ETA", "BAY_B", "TASKTYPE", "BL", "SJ_DEP"]  # 需要播报的变更列表,应该与显示的相结合
    AFbglist = ["ACNO", "FNO", "ETA", "BAY_B", "BL"]
    APbglist = ["ACNO", "FNO", "SJ_DEP"]
    TRbglist = ["ACNO", "FNO", "ETA", "BAY_B", "BL", "SJ_DEP"]



    nowDayStr = datatime
    now = datetime.datetime.now()
    insertdatestr = datatime + " 00:00:00"
    insertdate = datetime.datetime.strptime(insertdatestr, "%Y%m%d %H:%M:%S").strftime("%Y-%m-%d %H:%M:%S")
    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")
    nowDay_str2 = datetime.date.today().strftime("%Y-%m-%d")
    a_str = nowDay_str2 + " 20:30:00"
    b_str = nowDay_str2 + " 22:00:00"
    c_str = nowDay_str2 + " 09:00:00"
    time1 = datetime.datetime.strptime(a_str, "%Y-%m-%d %H:%M:%S")
    time2 = datetime.datetime.strptime(b_str, "%Y-%m-%d %H:%M:%S")
    time3 = datetime.datetime.strptime(c_str, "%Y-%m-%d %H:%M:%S")
    if now < time3:
        days = [nowDay, nowDay_1]
    elif time3 < now < time1:
        days = [nowDay]
    else:
        days = [nowDay, nowDay_2]
    try:
        if nowDayStr in days:
            #获取静态参数
            en2zh=get_dic("TaskflightinfoLabel2en")
            headerLabelKey = get_dic("headerLabelKey")
            headerLabel = get_dic("TaskflightinfoLabel")
            taskType=get_dic("taskType")
            header2num=get_dic("header2num")
            taskSTS=get_dic("taskSTS")
            ecsjtaskSTS=get_dic("ecsjtaskSTS")
            zydy_simple=get_dic("zydy_simple")
            ########################################
            flightinfo_flight_ids_arr = []
            flightinfo_flight_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '*', "航班来源='AMRO'")#确认一下要不要取整张表
            if len(flightinfo_flight_ids) != 0:
                for i in flightinfo_flight_ids:
                    flightinfo_flight_ids_arr.append(i[0])

            flight_id_now = []
            for i in [jsonData,jsonData2]:
                if jsonData != "" and jsonData2 !="" and jsonData2 !=None and jsonData !=None and jsonData != {} and  jsonData2 != {} and len(jsonData)!=0 and len(jsonData2)!=0:
                    for row in i:
                        bztime=row["STARTDATE_PL"] if 'STARTDATE_PL' in row and row["STARTDATE_PL"] != "" else datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
                        flightinfos=baseFunction.TuplefindInList1(flightinfo_flight_ids, row["TASKID"], 0)
                        oldbztime=flightinfos[0][36] if flightinfos else bztime
                        LOGsdeactive = judgeWaringsts(bztime,oldbztime)
                        flight_id_now.append(row["TASKID"])
                        now11=str(now).split(".")[0]
                        flightdate=str(row["FLIGHTDATE"]).split(" ")[0][5:10]
                        if str(row["TASKID"]) not in str(flightinfo_flight_ids_arr) and str(insertdate)==row["FLIGHTDATE"]:
                            checkTASKTYPE(row,en2zh,database,flightdate,LOGsdeactive,headerLabelKey,headerLabel,nowDayStr)
                            ####这里需要一个检查返航的，目前还没有确定返航字段
                            if len(flightinfo_flight_ids_arr) != 0 and LOGsdeactive == 0:
                                #app_logger.log_error("bztime")
                                #app_logger.log_error(bztime)
                                #app_logger.log_error(oldbztime)
                                #app_logger.log_error(f'{flightdate},{row["ACNO"]},{row["TASKID"]}')
                                a = taskType[row["TASKTYPE"]] if row["TASKTYPE"] != "" else "未显示"
                                waringinsert(database, "有新增航班,[%s]机号:%s航班号：%s航班类型:%s,请注意核对FOC!!!" % (flightdate, row["ACNO"], row["TASKID"], a),  row["TASKID"], "全部新增")
                        elif str(row["TASKID"]) in str(flightinfo_flight_ids_arr) and str(row["TASKID"]) != "":
                            #检测到航班信息，清零取消监测
                            newdic = {"取消标志": "'0'"}
                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic,"航班编号='%s'" % row["TASKID"])
                            acno=flightinfos[0][1]
                            if acno == row["ACNO"]:
                                old_tasktype = flightinfos[0][3]
                                sjry = flightinfos[0][15]
                                for col in headerLabelKey:
                                    b = flightinfos[0][header2num[col]]
                                    if col =='TASKTYPE' and 'TASKTYPE' in row and row[col] != b:
                                        if LOGsdeactive == 0:
                                            waringinsert(database, "[%s]机号:%s航班类型由%s变更为%s,请注意核对FOC!!!" % (flightdate,row["ACNO"],taskType[b],taskType[row["TASKTYPE"]] ),row["TASKID"], en2zh[col])
                                            if "BAY_A" in row and "BAY_B" in row and row["BAY_A"] != row["BAY_B"] and (row[col] == "TR" or row[col] == "TAF"):
                                                mesg="[%s]%s %s航班进港机位为%s，出港机位为%s,短停进出港机位不一致，请注意核对AMRO机位信息，按需修改，注意核对工作人员派送机位信息!!!" % (flightdate,row["ACNO"], row["FNO"],row["BAY_A"], row["BAY_B"])
                                                if mesg not in str(database.queryTabel('logs', "警告信息", "航班编号='%s'" % row["TASKID"])):
                                                   waringinsert(database, mesg, row["TASKID"], "机位不一致警告")
                                        else:
                                            noteinsert(database, "[%s]机号:%s航班类型由%s变更为%s,请注意核对FOC!!!" % (flightdate,row["ACNO"],taskType[b],taskType[row["TASKTYPE"]] ),row["TASKID"], en2zh[col])

                                        newdic = {"航班类型": "'%s'" % row["TASKTYPE"]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic,"航班编号='%s'" % row["TASKID"])
                                    elif 'TASKSTS' in row and col == 'TASKSTS' and row[col] != b:
                                        noteinsert(database, "[%s]机号:%s维修状态由%s变更为%s!%s" % (flightdate,row["ACNO"],taskSTS[b], taskSTS[row["TASKSTS"]],now11),row["TASKID"], en2zh[col])
                                        if row[col] in flightst_code.keys():
                                            newdic={"%s"%flightst_code[row[col]]:"1"}
                                            database.lazyUpdateItem('flightsts{}'.format(nowDayStr),newdic,"航班编号='%s'"%row["TASKID"])
                                        if row['TASKTYPE'] != "AP" and row['TASKSTS'] != "" and int(row['TASKSTS']) >= 7 and ("ATA" not in row or row["ATA"] == '' or datetime.datetime.strptime(row['ATA'],"%Y-%m-%d %H:%M:%S")+datetime.timedelta(minutes=15) >= datetime.datetime.now()):
                                            waringinsert(database, "[%s]机号:%s放行节点上报过早，请确认是否误上报并确认放行情况！！" % (flightdate,row["FNO"]), row["TASKID"], "放行节点早报")

                                        newdic = {"维修状态": "'%s'" % row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == 'TASKSTS_ECSJ' and 'TASKSTS_ECSJ' in row and row[col] != b:
                                        noteinsert(database, "[%s]机号:%s二送状态由%s变更为%s!%s" % (flightdate,row["ACNO"],ecsjtaskSTS[b], ecsjtaskSTS[row["TASKSTS_ECSJ"]],now11),row["TASKID"], en2zh[col])
                                        newdic = {"二送状态": "'%s'" % row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    ####需要判断返航备降的字段，暂缺
                                    elif col == 'ETA' and "ETA" in row and row[col] != b and row["TASKTYPE"] != "AP":
                                        if b == "" and LOGsdeactive == 0 and "FLYING" in row and row["FLYING"] != "" :  #新航班有预计到达，且上段已经实际起飞
                                            waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b, row[col][-8:-3]),row["TASKID"], en2zh[col])

                                        elif b != "" and LOGsdeactive == 0 and "ATD" in row and row["ATD"] != "" : #预计到达发生变更，且上段已经实际起飞
                                            ETA_P = datetime.datetime.strptime(b, "%Y-%m-%d %H:%M:%S") + datetime.timedelta(minutes=10)
                                            ETA_N = datetime.datetime.strptime(b, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=5)
                                            ETAnew = datetime.datetime.strptime(str(row[col]), "%Y-%m-%d %H:%M:%S")
                                            if (ETAnew < ETA_N or ETAnew > ETA_P ) and ETAnew > now:
                                                waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b[-8:-3], row[col][-8:-3]),row["TASKID"], en2zh[col])
                                        else:
                                            noteinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b, row[col][-8:-3]),row["TASKID"], en2zh[col])
                                        newdic = {"非航前预计到达": "'%s'" % row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == "FLYING" and "FLYING" in row and old_tasktype != "AP" and row[col] != b and "新航班播报" not in str(database.queryTabel('logs', "变更字段", "航班编号='%s'" %row["TASKID"])):
                                        FJtask = ",有工作包" if row["FJ_TASKIDS"] != [] else ""
                                        BLstr = "" if "BL" not in row else ",有保留"
                                        bay_str=row["BAY_B"] if "BAY_B" in row else ""
                                        waringinsert(database, "[%s]新航班:%s%s%s %s%s%s!" % (flightdate,row["ACNO"],taskType[old_tasktype],bay_str, row["ETA"][-8:-3],BLstr,FJtask),row["TASKID"], "新航班播报")

                                        newdic = {"上段起飞时间": "'%s'" % row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                        now_1= (datetime.datetime.now() - datetime.timedelta(minutes=0.5)).strftime("%Y-%m-%d %H:%M:%S")
                                        waringsts = database.queryTabel('logs', "编号","航班编号 ='%s' and 变更字段='非航前预计到达' and 产生时间>'%s'" %(row["TASKID"],now_1))
                                        if len(waringsts) != 0:
                                            newdic = {"处理人": "'系统抑制'", "处理时间": "'%s'" % now}
                                            database.lazyUpdateItem('logs', newdic, "编号='%s'" % waringsts[0][0])
                                    elif col == 'STD' and "ETD" not in row and "STD" in row and row[col] != b:
                                        if LOGsdeactive == 0 and "ATD" not in row:
                                            waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b, row[col]),row["TASKID"], en2zh[col])
                                        else:
                                            noteinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b, row[col]),row["TASKID"], en2zh[col])
                                        newdic = {"航前预计起飞": "'%s'" % row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == 'STD' and "STD" in row and "ETD" in row and "ATD" not in row and row["ETD"] != b :
                                        if LOGsdeactive == 0 and ("CSC" in flightinfos[0][21] or "3U" in flightinfos[0][21] or ("CSC" not in flightinfos[0][21] and "3U" not in flightinfos[0][21] and datetime.datetime.strptime(row["ETD"], "%Y-%m-%d %H:%M:%S") > datetime.datetime.now())):
                                            waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b, row["ETD"]),row["TASKID"], en2zh[col])
                                        else:
                                            noteinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col], b, row["ETD"]),row["TASKID"], en2zh[col])
                                        newdic = {"航前预计起飞": "'%s'" % row["ETD"]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == 'FJ_TASKIDS' and "FJ_TASKIDS" in row and ",".join(row[col]) != b:
                                        if row['TASKTYPE'] != "AF" and row['TASKTYPE'] != "AP" and LOGsdeactive == 0:
                                            mesg = "[%s]机号:%s航班号:%s有新增工作包!" % (flightdate,row["ACNO"],row['FNO'])
                                            if mesg not in str(database.queryTabel('logs', "警告信息", "航班编号='%s'" % row["TASKID"])):
                                                waringinsert(database,mesg,row["TASKID"], en2zh[col])
                                        newdic = {"工作包": "'%s'" % ",".join(row[col])}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == 'BAY_A' and "BAY_A" in row:
                                        if b != row[col]:
                                            if (row["TASKTYPE"] == "TR" or row["TASKTYPE"] == "AF" or row["TASKTYPE"] == "TAF") and LOGsdeactive == 0:
                                                waringinsert(database, "[%s]%s机位由%s变更为%s" % (flightdate, row["ACNO"], b, row[col]),row["TASKID"], "进港机位变更")
                                            else:
                                                noteinsert(database, "[%s]%s机位由%s变更为%s" % (flightdate, row["ACNO"], b, row[col]),row["TASKID"], "进港机位变更")
                                            newDic2={"%s"%en2zh[col]:"'%s'"%row[col]}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2, "航班编号='%s'" %row["TASKID"])
                                        if (row["TASKTYPE"] == "TR" or row["TASKTYPE"] == "TAF") and "BAY_B" not in row:
                                            newDic2 = {"航前离港机位": "'%s'" % row[col]}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2,"航班编号='%s'" % row["TASKID"])
                                    elif col == 'BAY_B' and "BAY_B" in row:
                                        if b != row[col]:
                                            if (row["TASKTYPE"] == "AP" or ((row["TASKTYPE"] == "TR" or row["TASKTYPE"] == "TAF") and("BAY_A" not in row or row["BAY_A"] != row["BAY_B"]))) and LOGsdeactive == 0:
                                                waringinsert(database,  "[%s]%s机位由%s变更为%s" % (flightdate, row["ACNO"], b, row[col]),row["TASKID"], "出港机位变更")
                                            else:
                                                noteinsert(database,  "[%s]%s机位由%s变更为%s" % (flightdate, row["ACNO"], b, row[col]),row["TASKID"], "出港机位变更")
                                            newDic2 = {"%s"%en2zh[col]: "'%s'" % row[col]}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2,"航班编号='%s'" % row["TASKID"])
                                            if (row["TASKTYPE"] == "TR" or row["TASKTYPE"] == "TAF") and "BAY_A" in row and (row["BAY_A"] != row["BAY_B"]):
                                                newDic2 = {"非航前进港机位": "'%s'" % row[col]}
                                                database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2,"航班编号='%s'" %row["TASKID"])
                                        if (row["TASKTYPE"] == "TR" or row["TASKTYPE"] == "TAF") and ("BAY_A" not in row.keys()):
                                            newDic2 = {"非航前进港机位": "'%s'" % row[col]}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2,"航班编号='%s'" % row["TASKID"])
                                    elif col == "SJ_DEP" and "SJ_DEP" in row and "SJ_ARR" not in row:
                                        if row["SJ_DEP"] != "":
                                            SJ = "随机"+row["SJ_DEP"].replace("已安排","").replace("已登机","")+";"
                                        else:
                                            SJ = ""
                                        new_a = row["TASKID"] + "-2" + "-A"
                                        fj = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息", "编号='%s'" % str(new_a))
                                        if sjry != SJ:
                                            newDic2={"%s"%en2zh[col]:"'%s'" % SJ}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2, "航班编号='%s'" % row["TASKID"])
                                            if fj and len(fj) != 0 and ((sjry != "" and sjry not in str(fj) and SJ not in str(fj) and SJ != "") or sjry == ""):
                                                new_fj=SJ + fj[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                                waringinsert(database, "[%s]%s随机由%s变更为%s" % (flightdate, row["ACNO"], sjry, SJ),row["TASKID"],"随机人员变更")
                                            elif fj and len(fj)!=0 and sjry in str(fj) and SJ != sjry:
                                                new_fj=fj[0][0].replace("%s"% sjry,"%s"% SJ)
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                                waringinsert(database, "[%s]%s随机由%s变更为%s" % (flightdate, row["ACNO"], sjry, SJ),row["TASKID"],"随机人员变更")
                                        else:
                                            if fj == None or len(fj) == 0:
                                                newDic2 = {"编号":new_a,"航班编号":row["TASKID"],"显示模式":"A","放行":"","勤务1":"","勤务2":"","工1":"","工2":"","工3":"","附加消息":"%s" % SJ}
                                                database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newDic2)
                                            elif SJ not in str(fj):
                                                new_fj = SJ + fj[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                    elif col == "SJ_ARR" and "SJ_ARR" in row and "SJ_DEP" not in row:
                                        if row["SJ_ARR"] != "":
                                            SJ="随机"+row["SJ_ARR"].replace("已安排","").replace("已登机","")+";"
                                        else:
                                            SJ = ""
                                        new_a = row["TASKID"] + "-1" + "-A"
                                        fj = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_a))
                                        if sjry != SJ:
                                            newDic2={"%s"%en2zh[col]:"'%s'" %SJ}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2, "航班编号='%s'" % row["TASKID"])
                                            if fj and len(fj)!=0 and ((sjry!="" and sjry not in str(fj) and SJ not in str(fj) and SJ !="") or sjry == ""):
                                                new_fj=SJ + fj[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                                waringinsert(database, "[%s]%s随机由%s变更为%s" % (flightdate, row["ACNO"], sjry, SJ),row["TASKID"],"随机人员变更")
                                            elif fj and   len(fj)!=0 and sjry in str(fj) and SJ != sjry:
                                                new_fj=fj[0][0].replace("%s"%sjry,"%s"%SJ)
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                                waringinsert(database, "[%s]%s随机由%s变更为%s" % (flightdate, row["ACNO"], sjry, SJ),row["TASKID"],"随机人员变更")
                                        else:
                                            if fj == None or len(fj)==0:
                                                newDic2 = {"编号":new_a,"航班编号":row["TASKID"],"显示模式":"A","放行":"","勤务1":"","勤务2":"","工1":"","工2":"","工3":"","附加消息":"%s" % SJ}
                                                database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newDic2)
                                            elif SJ not in str(fj):
                                                new_fj=SJ+ fj[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))

                                    elif (col == "SJ_DEP" and "SJ_ARR" in row and "SJ_DEP" in row) or (col == "SJ_ARR" and "SJ_DEP" in row and "SJ_ARR" in row):
                                        if row["SJ_DEP"] != "" and row["SJ_ARR"] == "":
                                            SJ_DEP="随机"+row["SJ_DEP"].replace("已安排","").replace("已登机","")+";"
                                            SJ_ARR=""
                                            SJ = str(SJ_DEP)
                                        elif row["SJ_DEP"] == "" and row["SJ_ARR"] != "":
                                            SJ_ARR = "随机" + row["SJ_ARR"].replace("已安排","").replace("已登机","")+";"
                                            SJ_DEP = ""
                                            SJ = str(SJ_ARR)
                                        elif row["SJ_DEP"] == "" and row["SJ_ARR"] == "":
                                            SJ_DEP = ""
                                            SJ_ARR = ""
                                            SJ = ""
                                        else:
                                            SJ_ARR = "随机" + row["SJ_ARR"].replace("已安排","").replace("已登机","")+";"
                                            SJ_DEP = "随机" + row["SJ_DEP"].replace("已安排","").replace("已登机","")+";"
                                            SJ=str(SJ_ARR)+"-"+str(SJ_DEP)
                                        new_a = row["TASKID"] + "-1" + "-A"
                                        new_b = row["TASKID"] + "-2" + "-A"
                                        fj = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_a))
                                        fj2 = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_b))


                                        if "离港" in sjry and "进港" not in sjry:
                                            sjry_ARR = ""
                                            sjry_DEP = sjry
                                        elif "进港" in sjry and "离港" not in sjry:
                                            sjry_ARR = sjry
                                            sjry_DEP = ""
                                        elif "进港" not in sjry and "离港" not in sjry:
                                            sjry_ARR = ""
                                            sjry_DEP = ""
                                        else:
                                            sjry_ARR=sjry.split("-")[0]
                                            sjry_DEP = sjry.split("-")[1]

                                        if sjry != SJ:
                                            newDic2={"随机":"'%s'" %SJ}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2, "航班编号='%s'" % row["TASKID"])
                                            waringinsert(database, "[%s]%s随机由%s变更为%s" % (flightdate, row["ACNO"], sjry, SJ),row["TASKID"],"随机人员变更")
                                            if fj and len(fj)!=0 and ((sjry_ARR !="" and str(sjry_ARR) not in str(fj) and str(SJ_ARR) not in str(fj) and sjry_ARR !=SJ_ARR)or(sjry_ARR =="" and str(SJ_ARR) not in str(fj) and sjry_ARR !=SJ_ARR)):
                                                new_fj=SJ_ARR+fj[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                            elif fj and  len(fj)!=0 and sjry_ARR !="" and str(sjry_ARR) in str(fj) and sjry_ARR != SJ_ARR:
                                                new_fj=fj[0][0].replace("%s"%(sjry_ARR),"%s"%(SJ_ARR))
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                            if fj2 and len(fj2)!=0 and ((sjry_DEP !="" and str(sjry_DEP) not in str(fj2) and str(SJ_DEP) not in str(fj2) and sjry_DEP !=SJ_DEP)or(sjry_DEP =="" and str(SJ_DEP) not in str(fj2) and sjry_DEP !=SJ_DEP)):

                                                new_fj2 = SJ_DEP+fj2[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj2}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_b))
                                            elif fj2 and  len(fj2)!=0 and sjry_DEP !="" and sjry_DEP in str(fj2) and sjry_DEP != SJ_DEP:
                                                new_fj2=fj2[0][0].replace("%s"%(sjry_DEP),"%s"%(SJ_DEP))
                                                newDic2 = {"附加消息": "'%s'" % new_fj2}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_b))
                                        else:
                                            if fj==None or len(fj)==0:
                                                newDic2 = {"编号":new_a,"航班编号":row["TASKID"],"显示模式":"A","放行":"","勤务1":"","勤务2":"","工1":"","工2":"","工3":"","附加消息":"%s" %SJ_ARR}
                                                database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newDic2)
                                            elif fj2==None or len(fj2)==0:
                                                newDic2 = {"编号":new_b,"航班编号":row["TASKID"],"显示模式":"A","放行":"","勤务1":"","勤务2":"","工1":"","工2":"","工3":"","附加消息":"%s" %SJ_DEP}
                                                database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newDic2)
                                            elif str(SJ_ARR) not in str(fj) or str(str(SJ_DEP)) not in str(fj2):
                                                new_fj=SJ_ARR+fj[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_a))
                                                new_fj2 = SJ_DEP + fj2[0][0]
                                                newDic2 = {"附加消息": "'%s'" % new_fj2}
                                    elif col == 'REMARK_BUSINESS' and "REMARK_BUSINESS" in row and row[col] != b:
                                        if "返航" in row["REMARK_BUSINESS"]:
                                            if row["TASKTYPE"] != "AP":
                                                new_a = row["TASKID"] + "-1" + "-A"
                                            else:
                                                new_a = row["TASKID"] + "-2" + "-A"
                                            fj = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_a))
                                            if fj == None or len(fj) == 0:
                                                newDic2 = {"编号": new_a, "航班编号": row["TASKID"], "显示模式": "A", "放行": "","勤务1": "", "勤务2": "", "工1": "", "工2": "", "工3": "","附加消息": "返航航班;"}
                                                database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newDic2)
                                            elif "返航航班;" not in str(fj):
                                                new_fj=fj[0][0]+"返航航班;"
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2, "编号='%s'" % str(new_a))
                                            waringinsert(database, "%s/%s判断为返航航班，请核对FOC" % (row["ACNO"],row["FNO"]),row["TASKID"],"返航警告")
                                        elif "备降天府" in row["REMARK_BUSINESS"]:
                                            new_a = row["TASKID"] + "-1" + "-A"
                                            fj = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_a))
                                            if fj == None or len(fj) == 0:
                                                newDic2 = {"编号": new_a, "航班编号": row["TASKID"], "显示模式": "A", "放行": "","勤务1": "", "勤务2": "", "工1": "", "工2": "", "工3": "","附加消息": "备降航班;"}
                                                database.lazyInsertData('peopleSchedule{}'.format(nowDayStr), newDic2)
                                            elif "备降航班;" not in str(fj):
                                                new_fj=fj[0][0]+"备降航班;"
                                                newDic2 = {"附加消息": "'%s'" % new_fj}
                                                database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2, "编号='%s'" % str(new_a))
                                            waringinsert(database, "%s/%s判断为备降航班，请核对FOC" % (row["ACNO"],row["FNO"]),row["TASKID"],"备降警告")
                                        newdic = {"%s"% en2zh[col]: "'%s'" %row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == "WX" and "WX" in row and row[col] != "" and row[col] != b:
                                        noteinsert(database, "[%s]机号:%s%s由%s变更为%s!%s" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col],now11),row["TASKID"], en2zh[col])
                                        newdic = {"%s"% en2zh[col]: "'%s'" %row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == "FX" and "FX" in row and row[col] != "" and row[col] != b:
                                        noteinsert(database, "[%s]机号:%s%s由%s变更为%s!%s" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col],now11),row["TASKID"], en2zh[col])
                                        newdic = {"%s"% en2zh[col]: "'%s'" %row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col == "ECSJ" and "ECSJ" in row and row[col] != "" and row[col] != b:
                                        noteinsert(database, "[%s]机号:%s%s由%s变更为%s!%s" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col],now11),row["TASKID"], en2zh[col])
                                        newdic = {"%s"% en2zh[col]: "'%s'" %row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col== 'HIGHALT' and 'HIGHALT' in row and row[col] != b:
                                        if LOGsdeactive == 0 and row[col] == 'Y' and "A319" in row["ACTYPE"]:
                                            waringinsert(database, "[%s]%s-%s航线变更为高高原航线，注意工作单签署" % (flightdate,row["ACNO"],row["FNO"]),row["TASKID"], en2zh[col])
                                        elif LOGsdeactive == 0 and row[col] != 'Y' and "A319" in row["ACTYPE"]:
                                            waringinsert(database, "[%s]%s-%s航线变更为非高高原航线，注意工作单签署" % (flightdate,row["ACNO"],row["FNO"]),row["TASKID"], en2zh[col])
                                        newdic = {"%s"% en2zh[col]: "'%s'" %row[col]}
                                        database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                    elif col not in ["TASKID","FJ_TASKIDS","SJ_DEP","SJ_ARR","STD","WX","FX","ECSJ","BAY_A","BAY_B"]:
                                        if col not in row:
                                            row[col] = ''
                                        if row[col] != b:
                                            if old_tasktype == "AP" and col in APbglist and LOGsdeactive == 0:
                                                waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col]),row["TASKID"], en2zh[col])
                                            elif old_tasktype == "AF" and col in AFbglist and LOGsdeactive == 0:
                                                waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col]),row["TASKID"], en2zh[col])
                                            elif (old_tasktype =="TR" or old_tasktype=="TAF" ) and col in TRbglist and LOGsdeactive == 0:
                                                waringinsert(database, "[%s]机号:%s%s由%s变更为%s!" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col]),row["TASKID"], en2zh[col])
                                            else:    #限制提示信息输出位置
                                                if col not in ["TASKSTS_TIME",'ISSHIFTEX',"FLIGHTID1","FLIGHTID2",'ACGGY']:
                                                    noteinsert(database, "[%s]机号:%s%s由%s变更为%s!%s" % (flightdate,row["ACNO"], zydy_simple[col],b, row[col],now11),row["TASKID"], en2zh[col])

                                            newdic = {"%s" % en2zh[col]: "'%s'" % row[col]}
                                            database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                                #database.FunctionCommit()
                                if "SJ_DEP" not in row and "SJ_ARR" not in row and sjry != "":
                                    #if sjry != "":
                                    newDic2 = {"随机": "''"}
                                    database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newDic2,"航班编号='%s'" % row["TASKID"])
                                    waringinsert(database, "[%s]%s %s取消,请核对FOC" % (flightdate, row["ACNO"], sjry),row["TASKID"], "随机人员")
                                    new_a = row["TASKID"] + "-1" + "-A"
                                    new_b = row["TASKID"] + "-2" + "-A"
                                    fj = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_a))
                                    fj2 = database.queryTabel('peopleSchedule{}'.format(nowDayStr), "附加消息","编号='%s'" % str(new_b))
                                    if fj and len(fj)!=0 and len(fj[0])!=0:
                                        new_fj=re.sub(r"随机.*港.*?[;]","",fj[0][0])
                                        newDic = {"附加消息": "'%s'" % new_fj}
                                        database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic,"编号='%s'" % str(new_a))
                                    if fj2 and len(fj2)!=0 and len(fj2[0])!=0:
                                        new_fj2=re.sub(r"随机.*港.*?[;]", "",fj2[0][0])
                                        newDic2 = {"附加消息": "'%s'" % new_fj2}
                                        database.lazyUpdateItem('peopleSchedule{}'.format(nowDayStr), newDic2,"编号='%s'" % str(new_b))
                            else:
                                if LOGsdeactive == 0:
                                    waringinsert(database, "[%s]%s航班机号由%s变更为%s,请注意核对FOC!!!" % (flightdate,row["TASKID"], acno, row["ACNO"]),row["TASKID"], "机号")

                                newdic = {"机号": "'%s'" % row["ACNO"]}
                                database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" % row["TASKID"])
                    database.FunctionCommit()
                else:
                    print(datetime.datetime.now(), "[数据库操作]TaskFlightinfo航班数据为空")
                    app_logger.log_error("[数据库操作]TaskFlightinfo航班数据为空")
                    pass
            if jsonData != "" and jsonData2 !="" and jsonData2 != None and jsonData != None and jsonData != {} and  jsonData2 != {} and len(flight_id_now) != 0 and len(jsonData)!=0 and len(jsonData2)!=0:
                flightinfo_flight_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr),'*',"航班来源='AMRO'")
                if len(flightinfo_flight_ids) != 0:
                    for iii in flightinfo_flight_ids:
                        datas=baseFunction.TuplefindInList1(flightinfo_flight_ids, iii[0], 0)[0]
                        now=datetime.datetime.now()
                        now_15=datetime.datetime.now()-datetime.timedelta(hours=15)
                        if str(iii[0]) not in flight_id_now and datetime.datetime.strptime(datas[36] if datas[36] else now, "%Y-%m-%d %H:%M:%S") >= now_15 :
                            cancelid=datas[35]
                            newcancelid=int(cancelid)+1
                            if int(newcancelid) < 4:
                                newdic={"取消标志":"'%s'"%newcancelid}
                                database.lazyUpdateItem('TaskFlightinfo{}'.format(nowDayStr), newdic, "航班编号='%s'" %iii[0])
                            else:
                                c = datas[2][5:10]
                                a = datas[1]
                                bb = datas[21]
                                database.deleteSingledata("TaskFlightinfo{}".format(nowDayStr), "航班编号='%s'" % str(iii[0]) )
                                if nowDayStr == nowDay:
                                    waringinsert(database, "[%s]%s,%s航班已取消,注意核对FOC!!!"% (c,a,bb),iii[0], "全部取消")
            database.FunctionCommit()

            selectdaystr = str(datatime)[0:4] + "-" + str(datatime)[4:6] + "-" + str(datatime)[6:] + " 00:00:00"
            nowDayStr_search = datetime.datetime.strptime(selectdaystr, "%Y-%m-%d %H:%M:%S")
            starttime=(nowDayStr_search - datetime.timedelta(days=7)).strftime("%Y-%m-%d %H:%M:%S")
            endtime = (nowDayStr_search + datetime.timedelta(days=7)).strftime("%Y-%m-%d %H:%M:%S")
            tasknuminworjoblist=database.getSingledata("任务编号",'workjob')
            tasknums=database.queryTabel('TaskFlightinfo{}'.format(nowDayStr),'*', "工作包 !=''")
            if len(tasknums) != 0:
                for i in tasknums:
                    if i[0] not in str(tasknuminworjoblist):
                        workjoblist=i[18]
                        #print(workjoblist)
                        newdic3={"任务编号":"%s"%i[0],"工作包编号":"%s"%workjoblist,"查询开始时间":"%s"%starttime,"查询结束时间":"%s"%endtime,"开始时间":"","基地":"","项目描述":"","工作步骤":"","机号":"%s"%i[1],"机型":"%s"%i[26],"航班类型":"%s"%taskType[i[3]]}
                        database.lazyInsertData('workjob', newdic3)
                        #返回一个数值去查询
                    if i[0] in str(tasknuminworjoblist):
                        if i[18] != database.queryTabel('workjob','工作包编号', "任务编号 ='%s'"%i[0])[0][0]:
                            newdic = {"工作包编号": "'%s'" % i[18],"开始时间":"''","基地":"''","项目描述":"''","工作步骤":"''"}
                            database.lazyUpdateItem('workjob', newdic, "任务编号='%s'" % i[0])
            database.FunctionCommit()
    except Exception as e:
        app_logger.log_error(e)