flightinfo_sever/Functions/DButilsFunction/Getworkload.py

from .flightDB import flightDB
import datetime
from unitls.LogerinTxt import app_logger
from unitls import baseFunction


def sort_and_renumber_dict(nested_dict, sort_key, secondary_key=None, reverse=False,secondary_reverse=False):
    # 1. 将原始字典的值转换为列表
    items_list = list(nested_dict.values())

    # 2. 按双条件排序
    if secondary_key:
        sorted_list = sorted(
            items_list,
            key=lambda x: (x[sort_key], x[secondary_key]),
            reverse=secondary_reverse
        )
    else:
        sorted_list = sorted(items_list, key=lambda x: x[sort_key], reverse=reverse)

    # 3. 创建新字典，使用连续整数作为键
    new_dict = {}
    for new_key, item in enumerate(sorted_list):
        new_dict[new_key] = item
    return new_dict



def Getworkload(fdb:flightDB,workload: flightDB,names):
    res={}
    flighttypedic={"TR":"短停","AF":"航后","AP":"航前","TAF":"特后前","":"未显示"}
    dic={"FX":"放行","WX":"维修员","":"未分配"}
    nowDay = datetime.date.today().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")
    a_str = nowDay + " 09:00:00"
    b_str = nowDay + " 20:30:00"
    a = datetime.datetime.strptime(a_str, "%Y%m%d %H:%M:%S")
    b = datetime.datetime.strptime(b_str, "%Y%m%d %H:%M:%S")
    nowtime = datetime.datetime.now()
    if a < nowtime < b:
        date = [nowDay]
        bcdate = nowDay
        bc="A"
    elif b <= nowtime:
        date = [nowDay, nowDay_2]
        bcdate = nowDay
        bc = "B"
    else:
        date = [nowDay_1, nowDay]
        bcdate = nowDay_1
        bc = "B"
    allworkloaddatas=[]
    allpeopleschedule=[]
    allflightinfo=[]
    try:
        if names:
            lastBchandoverinfos=[]
            if len(date) == 1:
                daytime=(datetime.datetime.strptime(date[0],'%Y%m%d')-datetime.timedelta(days=4)).strftime('%Y%m%d')
                lastBchandoverinfos = workload.queryTabel("workload%s"%daytime,"*","(备3 ='交班' and 备4 !='N') or 备4 ='Y'") #上个班的交接情况
            for day in date:
                daily_data = workload.sort_queryTable("*","workload%s"%day,  "备2 != '1'",'结束时间','ASC')
                if daily_data:  # 确保有数据返回
                    allworkloaddatas.extend(daily_data)
                peopleschedule= fdb.queryTabel("peopleschedule%s"%day,"*","显示模式='A' and ('放行' !='' or '勤务1' !='' or '勤务2' !='' or '工1' !='' or '工2' !='' or '工3' !='')")
                if peopleschedule:  # 确保有数据返回
                    allpeopleschedule.extend(peopleschedule)
                flightinfo=  fdb.queryTabel("taskflightinfo%s"%day,"*","航班编号 !=''")
                if flightinfo:  # 确保有数据返回
                    allflightinfo.extend(flightinfo)
            if allworkloaddatas !=[]:
                allpeopleionfos=fdb.queryTabel("pglist%s"%bcdate,"*","班次='%s'"%bc)
                sqinfos=fdb.queryTabel('workerinfo',"*","姓名!=''")
                num = 0
                for name in names:
                    signalpeopleinfo=baseFunction.TuplefindInList1(allpeopleionfos,name,0)
                    singlepeopledata=baseFunction.TuplefindInList11(allworkloaddatas,name,11)#所有工时内容
                    hbsinglepeopledata=baseFunction .TuplefindInList8(singlepeopledata,'Y',17)#非人工的工作内容
                    rgsinglepeopledata=baseFunction.TuplefindInList11(singlepeopledata,'Y',17)#人工修正工作内容
                    notfinshsinglepeopledata= baseFunction.TuplefindInList8(hbsinglepeopledata,'完工',12) #未完工的内容
                    singlesqinfo=baseFunction.TuplefindInList1(sqinfos,name,1)
                    preinfos=baseFunction.TuplefindInList111(allpeopleschedule,name)
                    workrole=dic[signalpeopleinfo[0][2]]
                    noteinfo=signalpeopleinfo[0][4]
                    handoverSts=""
                    handoverids=""
                    if len(date) == 1:
                        handoverinfos=baseFunction.TuplefindInList33(lastBchandoverinfos,name,11,0)
                        if handoverinfos:
                            handoverSts="Y"
                            handoverids=",".join(handoverinfos)
                    sq = singlesqinfo[0][8].replace("*","") if singlesqinfo else ""
                    zgzl=len(hbsinglepeopledata)#总工作量
                    wwcgz=len(notfinshsinglepeopledata) #当前未完成工作量
                    zys = baseFunction.TuplefindInList9(singlepeopledata,9) #总用时
                    zgs = baseFunction.TuplefindInList9(singlepeopledata,10) #总的标准工时
                    rggs = baseFunction.TuplefindInList9(rgsinglepeopledata,10) #人工标准工时
                    xzgs = baseFunction.TuplefindInList9(rgsinglepeopledata,10) #修正工作时间的总长
                    dqgz = "无"
                    if notfinshsinglepeopledata:
                        for i in notfinshsinglepeopledata:
                          dqgz = i[4][-8:-3]+"-"+i[5][-8:-3]+"/"+i[6]+i[8][:2] if dqgz == "无" else dqgz+"\n"+ i[4][-8:-3]+"-"+i[5][-8:-3]+"/"+i[6]+i[8][:2]

                    xzxq = "无"
                    if rgsinglepeopledata:
                        for i in rgsinglepeopledata:
                            xzxq ="修正详情:"+"\n"+ i[18]+"/"+i[10] if xzxq == "无" else xzxq+"\n"+i[18]+"/"+i[10]
                    res[num]={
                        '0':num+1,
                        '1':handoverSts,
                        '2':name,
                        '3':handoverids,
                        '4':workrole,
                        '5':'',
                        '6':sq,
                        '7':'',
                        '8':f'{zgzl}({wwcgz})',
                        '9':'',
                        '10':wwcgz,
                        '11':'',
                        '12':zgzl,
                        '13':'',
                        '14':f'{zgs}({rggs})',
                        '15':'',
                        '16':dqgz,
                        '17':'',
                        '18':xzgs,
                        '19':'',
                        '20':xzxq,
                        '21':noteinfo,
                        '22':'',
                        '23':'',
                        '24':'',
                        '25':'',
                        '26':'',
                        '27':'',
                        '28':'',
                        '29':'',
                        '30':'',
                        '31':'',
                        '32':'',
                        '33':'',
                        '34':'',
                        '35':'',
                        '36':'',
                        '37':'',
                        '38':'',
                        '39':'',
                        '40':'',
                        '41':'',
                        '42':'',
                        '43':'',
                        '44':'',
                        '45':'',
                        '46':'',
                        '47':'',
                    }
                    num1 = 28
                    if hbsinglepeopledata:
                        for i in singlepeopledata:
                            res[num][str(num1)] = i[5][-8:-3]+"\n"+i[8][:2]+"/"+i[6]
                            num1 += 1
                    if preinfos:
                        for i in preinfos:
                            isok=False
                            preflightinfos= baseFunction.TuplefindInList1(allflightinfo,i[1],0)[0]
                            if i[0][-3] == "1" and preflightinfos[3] == "TR" and preflightinfos[8] != "":
                                endtime=(datetime.datetime.strptime(preflightinfos[8], "%Y-%m-%d %H:%M:%S")+ datetime.timedelta(minutes=10)).strftime("%H:%M")
                                flighttyep="短停接"
                                bay=preflightinfos[10]
                                isok = True
                            elif i[0][-3] == "1" and preflightinfos[3] == "AF" and preflightinfos[8] != "":
                                endtime=(datetime.datetime.strptime(preflightinfos[8], "%Y-%m-%d %H:%M:%S")+ datetime.timedelta(minutes=120)).strftime("%H:%M")
                                flighttyep="航后"
                                bay=preflightinfos[10]
                                isok = True
                            elif i[0][-3] == "1" and preflightinfos[3] == "TAF" and preflightinfos[8] != "":
                                endtime=(datetime.datetime.strptime(preflightinfos[8], "%Y-%m-%d %H:%M:%S")+ datetime.timedelta(minutes=60)).strftime("%H:%M")
                                flighttyep="特后前"
                                bay=preflightinfos[10]
                                isok = True
                            elif i[0][-3] == "2" and preflightinfos[3] != "AF" and preflightinfos[5] != "":
                                endtime=(datetime.datetime.strptime(preflightinfos[5], "%Y-%m-%d %H:%M:%S")+ datetime.timedelta(minutes=60)).strftime("%H:%M")
                                flighttyep="%s送"%flighttypedic[preflightinfos[3]]
                                if preflightinfos[3] !="AP":
                                    bay=preflightinfos[10]
                                else:
                                    bay=preflightinfos[11]
                                isok = True
                            if isok:
                                res[num][str(num1)] = endtime+"\n"+"预排"+flighttyep+"/"+bay
                                num1 += 1
                    num += 1
        res = sort_and_renumber_dict(
            res,
            sort_key="4",  # 第一排序条件：
            secondary_key="1",  # 第二排序条件：
            reverse=False,  # 第一升序
            secondary_reverse=True  # 第二降序
        )
        return res
    except Exception as e:
        app_logger.log_error(e)
        return res