123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361 |
- from .flightDB import flightDB
- import datetime
- from unitls.LogerinTxt import app_logger
- import unitls.baseFunction as baseFunction
- from unitls.StaticDataclass import get_dic
- def checkWorkerlaod(database:flightDB, workload:flightDB,nowDayStr1,nowDay_11):
- try:
- #需要初始化表格
- nowDay = datetime.datetime.now().strftime("%Y%m%d")
- nowDay_1 = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y%m%d")
- day=[nowDay_1,nowDay]
- nowDayStr_search = datetime.date.today().strftime("%Y-%m-%d %H:%M:%S")
- #nowDayStr_search=datetime.datetime.strptime(str("2023-06-11 00:00:00"),"%Y-%m-%d %H:%M:%S")
- yesterday_search = (datetime.date.today() - datetime.timedelta(days=1)).strftime("%Y-%m-%d %H:%M:%S")
- workernames_arr=[]
- workernames1=database.queryTabel('pglist%s'%nowDayStr1,"*","姓名!=''")
- workernames2=database.queryTabel('pglist%s' % nowDay_11, "*", "姓名!=''")
- if workernames1 and len(workernames1) != 0:
- for i in workernames1:
- workernames_arr.append(i[0])
- if workernames2 and len(workernames2) != 0:
- for i in workernames2:
- workernames_arr.append(i[0])
- for worker in workernames_arr:
- if workernames1 and len(workernames1)!= 0:
- worker_number = baseFunction.TuplefindInList3(workernames1, worker, 0,1)
- else:
- worker_number = baseFunction.TuplefindInList3(workernames2, worker, 0,1)
- # worker_number = a if len(a) !=0 else ""
- single_worker_load_ids = workload.queryTabel('workload%s' % worker_number, "*", "编号!=''")
- single_worker_load_ids_arr = []
- if single_worker_load_ids and len(single_worker_load_ids) != 0:
- for l in single_worker_load_ids:
- single_worker_load_ids_arr.append(l[0])
- for nowDayStr in day:
- worker_laod_ids=database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '*', "维修人员 like '%{}%'".format(worker))
- worker_laod_ids_arr = []
- if worker_laod_ids and len(worker_laod_ids)!= 0:
- for j in worker_laod_ids:
- worker_laod_ids_arr.append(j[0])
- if worker_laod_ids_arr and len(worker_laod_ids_arr) != 0:
- for k in worker_laod_ids_arr:
- TYPE = get_dic('taskType')[baseFunction.TuplefindInList3(worker_laod_ids, k, 0,3)]
- acno = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 1)
- bay = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 10)
- bay1= baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 11)
- flight_id = k
- flight_id_1=str(str(flight_id))+str("-1") #接机保障标志
- flight_id_2 = str(str(flight_id)) + str("-2") # 接机保障标志
- flight_date = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 2)
- if TYPE == "短停" and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8) != "":
- eta_str=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8)
- starttime = datetime.datetime.strptime(eta_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=15)
- endtime=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 6)
- if flight_id_1 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'"%acno, "机位": "'%s'"%bay, "开始时间": "'%s'"%starttime, "结束时间": "'%s'"%endtime,"航班类型": "'%s'"%TYPE}
- workload.lazyUpdateItem('workload%s'%worker_number,newdic,"编号='{}'".format(flight_id_1))
- else:
- newdic = {"编号":"%s"%flight_id_1,"机号": "%s" % acno, "机位": "%s" % bay, "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s" % endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,"人员状态":""}
- workload.lazyInsertData('workload%s'%worker_number, newdic)
- elif TYPE == '航前' and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5) != "":
- endtime_ap = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7)
- STD_ap=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5)
- starttime_ap = datetime.datetime.strptime(STD_ap, "%Y-%m-%d %H:%M:%S")-datetime.timedelta(minutes=90)
- if flight_id_1 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'"%acno, "机位": "'%s'"%bay1, "开始时间": "'%s'"%starttime_ap, "结束时间": "'%s'"%endtime_ap, "航班类型": "'%s'"%TYPE}
- workload.lazyUpdateItem('workload%s'%worker_number,newdic,"编号='%s'"%flight_id_1)
- else:
- newdic = {"编号":"%s"%flight_id_1,"机号": "%s" % acno, "机位": "%s"%bay1, "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime_ap,
- "结束时间": "%s" % endtime_ap, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,"人员状态":""}
- workload.lazyInsertData('workload%s'%worker_number, newdic)
- elif TYPE == '航后' and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8) != "":
- eta_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8)
- starttime = datetime.datetime.strptime(eta_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=15)
- if str(baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 14)) == "8":
- endtime =baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 17)
- else:
- endtime=""
- if flight_id_1 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay, "开始时间": "'%s'" % starttime,
- "结束时间": "'%s'" % endtime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_1))
- else:
- newdic = {"编号": "%s" % flight_id_1, "机号": "%s" % acno, "机位": "%s" % bay,
- "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s" % endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE, "人员状态": ""}
- workload.lazyInsertData('workload%s' % worker_number, newdic)
- elif TYPE == "特后前" and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8) != "":
- eta_str=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8)
- starttime = datetime.datetime.strptime(eta_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=15)
- if baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7) != "" :
- endtime_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7)
- endtime = datetime.datetime.strptime(endtime_str, "%Y-%m-%d %H:%M:%S")
- else:
- endtime = ""
- if flight_id_1 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'"%acno, "机位": "'%s'"%bay, "开始时间": "'%s'"%starttime, "结束时间": "'%s'"%endtime,"航班类型": "'%s'"%TYPE}
- workload.lazyUpdateItem('workload%s'%worker_number,newdic,"编号='{}'".format(flight_id_1))
- else:
- newdic = {"编号":"%s"%flight_id_1,"机号": "%s" % acno, "机位": "%s" % bay, "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s" % endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,"人员状态":""}
- workload.lazyInsertData('workload%s'%worker_number, newdic)
- #if len(database.queryTabel('pglist%s' % nowDayStr1, '工号', "姓名 ='%s'" % worker)) != 0:
- # worker_number = database.queryTabel('pglist%s' % nowDayStr1, '工号', "姓名 ='%s'" % worker)[0]
- #else:
- # worker_number = database.queryTabel('pglist%s' % nowDay_11, '工号', "姓名 ='%s'" % worker)[0]
- single_worker_load_ids = workload.getSingledata('编号', 'workload%s' % worker_number)
- single_worker_load_ids_arr = []
- if single_worker_load_ids and len(single_worker_load_ids) != 0:
- for l in single_worker_load_ids:
- single_worker_load_ids_arr.append(l[0])
- FX_laod_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '航班编号', "放行人员 like '%{}%'".format(worker))
- FX_laod_ids_arr = []
- if FX_laod_ids and len(FX_laod_ids) != 0:
- for j in FX_laod_ids:
- FX_laod_ids_arr.append(j[0])
- if FX_laod_ids_arr and len(FX_laod_ids_arr) != 0:
- for k in FX_laod_ids_arr:
- TYPE = get_dic('taskType')[baseFunction.TuplefindInList3(worker_laod_ids, k, 0,3)]
- acno = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 1)
- bay = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 10)
- bay1= baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 11)
- flight_id = k
- flight_id_1=str(str(flight_id))+str("-1") #接机保障标志
- flight_id_2 = str(str(flight_id)) + str("-2") # 接机保障标志
- flight_date = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 2)
- if TYPE == "短停" and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8) != "":
- eta_str=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8)
- starttime = datetime.datetime.strptime(eta_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=15)
- if int(baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 14)) >= 7:
- endtime = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 15)
- else:
- endtime = ""
- if flight_id_1 in single_worker_load_ids_arr:
- if workload.queryTabel('workload%s' % worker_number, '结束时间', "编号 ='%s'"%flight_id_1)[0][0] =="":
- newdic = {"机号": "'%s'"%acno, "机位": "'%s'"%bay, "开始时间": "'%s'"%starttime, "结束时间": "'%s'"%endtime,"航班类型": "'%s'"%TYPE}
- workload.lazyUpdateItem('workload%s'%worker_number,newdic,"编号='{}'".format(flight_id_1))
- else:
- newdic = {"编号":"%s"%flight_id_1,"机号": "%s" % acno, "机位": "%s" % bay, "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s" % endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,"人员状态":""}
- workload.lazyInsertData('workload%s'%worker_number, newdic)
- elif TYPE == '航前' and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5) != "":
- if int(baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 14)) >= 7:
- endtime_ap = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 15)
- else:
- endtime_ap = ""
- STD_ap=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5)
- starttime_ap = datetime.datetime.strptime(STD_ap, "%Y-%m-%d %H:%M:%S")-datetime.timedelta(minutes=90)
- if flight_id_1 in single_worker_load_ids_arr:
- if workload.queryTabel('workload%s' % worker_number, '结束时间', "编号 ='%s'" % flight_id_1)[0][0] == "":
- newdic = {"机号": "'%s'"%acno, "机位": "'%s'"%bay1, "开始时间": "'%s'"%starttime_ap, "结束时间": "'%s'"%endtime_ap, "航班类型": "'%s'"%TYPE}
- workload.lazyUpdateItem('workload%s'%worker_number,newdic,"编号='%s'"%flight_id_1)
- else:
- newdic = {"编号":"%s"%flight_id_1,"机号": "%s" % acno, "机位": "%s"%bay1, "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime_ap,
- "结束时间": "%s" % endtime_ap, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,"人员状态":""}
- workload.lazyInsertData('workload%s'%worker_number, newdic)
- elif TYPE == '航后' and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8) != "":
- eta_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8)
- starttime = datetime.datetime.strptime(eta_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=15)
- if int(baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 14)) >= 8:
- endtime = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 15)
- else:
- endtime=""
- if flight_id_1 in single_worker_load_ids_arr:
- if workload.queryTabel('workload%s' % worker_number, '结束时间', "编号 ='%s'" % flight_id_1)[0][0] == "":
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay, "开始时间": "'%s'" % starttime,
- "结束时间": "'%s'" % endtime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_1))
- else:
- newdic = {"编号": "%s" % flight_id_1, "机号": "%s" % acno, "机位": "%s" % bay,
- "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s" % endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE, "人员状态": ""}
- workload.lazyInsertData('workload%s' % worker_number, newdic)
- elif TYPE == "特后前" and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8) != "":
- eta_str=baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 8)
- starttime = datetime.datetime.strptime(eta_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=15)
- if baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7) !="":
- #print(flight_date)
- #print(endtime_str)
- endtime_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7)
- endtime = datetime.datetime.strptime(endtime_str, "%Y-%m-%d %H:%M:%S")
- else:
- endtime = ""
- if flight_id_1 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'"%acno, "机位": "'%s'"%bay, "开始时间": "'%s'"%starttime, "结束时间": "'%s'"%endtime,"航班类型": "'%s'"%TYPE}
- workload.lazyUpdateItem('workload%s'%worker_number,newdic,"编号='{}'".format(flight_id_1))
- else:
- newdic = {"编号":"%s"%flight_id_1,"机号": "%s" % acno, "机位": "%s" % bay, "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s" % endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,"人员状态":""}
- workload.lazyInsertData('workload%s'%worker_number, newdic)
- #if len(database.queryTabel('pglist%s' % nowDayStr1, '工号', "姓名 ='%s'" % worker)) != 0:
- # worker_number = database.queryTabel('pglist%s' % nowDayStr1, '工号', "姓名 ='%s'" % worker)[0]
- #else:
- # worker_number = database.queryTabel('pglist%s' % nowDay_11, '工号', "姓名 ='%s'" % worker)[0]
- single_worker_load_ids = workload.getSingledata('编号', 'workload%s' % worker_number)
- single_worker_load_ids_arr = []
- if single_worker_load_ids and len(single_worker_load_ids) != 0:
- for l in single_worker_load_ids:
- single_worker_load_ids_arr.append(l[0])
- ECCJ_laod_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDayStr), '航班编号', "二次送机 like '%{}%'".format(worker))
- ECSJ_laod_ids_arr = []
- if ECCJ_laod_ids and len(ECCJ_laod_ids) != 0:
- for j in ECCJ_laod_ids:
- ECSJ_laod_ids_arr.append(j[0])
- if ECSJ_laod_ids_arr and len(ECSJ_laod_ids_arr) != 0:
- for k in ECSJ_laod_ids_arr:
- TYPE = get_dic('taskType')[baseFunction.TuplefindInList3(worker_laod_ids, k, 0,3)]
- acno = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 1)
- bay = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 10)
- bay1= baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 11)
- flight_id = k
- flight_id_1=str(str(flight_id))+str("-1") #接机保障标志
- flight_id_2 = str(str(flight_id)) + str("-2") # 接机保障标志
- flight_date = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 2)
- if TYPE == "短停" and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5) != "":
- if baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7) =="" :
- starttime_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5)
- starttime = datetime.datetime.strptime(starttime_str, "%Y-%m-%d %H:%M:%S")-datetime.timedelta(minutes=25)
- if flight_id_2 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay, "开始时间": "'%s'" % starttime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_2))
- else:
- newdic = {"编号": "%s" % flight_id_2, "机号": "%s" % acno, "机位": "%s" % bay,
- "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "" , "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,
- "人员状态": ""}
- workload.lazyInsertData('workload%s' % worker_number, newdic)
- if baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7) !="" :
- endtime_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7)
- endtime = datetime.datetime.strptime(endtime_str, "%Y-%m-%d %H:%M:%S")
- starttime = datetime.datetime.strptime(endtime_str, "%Y-%m-%d %H:%M:%S")- datetime.timedelta(minutes=25)
- if flight_id_2 in single_worker_load_ids_arr:
- if workload.queryTabel('workload%s' % worker_number, "开始时间", "编号='{}'".format(flight_id_2))[0][0] != "":
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay, "结束时间": "'%s'" % endtime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_2))
- else:
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay,"开始时间": "'%s'" % starttime, "结束时间": "'%s'" % endtime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_2))
- else:
- newdic = {"编号": "%s" % flight_id_2, "机号": "%s" % acno, "机位": "%s" % bay,
- "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s"%endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,
- "人员状态": ""}
- workload.lazyInsertData('workload%s' % worker_number, newdic)
- if TYPE == "特后前" and baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5) != "":
- if baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7) =="":
- starttime_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 5)
- starttime = datetime.datetime.strptime(starttime_str, "%Y-%m-%d %H:%M:%S")-datetime.timedelta(minutes=25)
- if flight_id_2 in single_worker_load_ids_arr:
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay, "开始时间": "'%s'" % starttime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_2))
- else:
- newdic = {"编号": "%s" % flight_id_2, "机号": "%s" % acno, "机位": "%s" % bay,
- "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "" , "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,
- "人员状态": ""}
- workload.lazyInsertData('workload%s' % worker_number, newdic)
- if baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7) !="":
- endtime_str = baseFunction.TuplefindInList3(worker_laod_ids, k, 0, 7)
- endtime = datetime.datetime.strptime(endtime_str, "%Y-%m-%d %H:%M:%S")
- starttime = datetime.datetime.strptime(endtime_str, "%Y-%m-%d %H:%M:%S") - datetime.timedelta(minutes=25)
- if flight_id_2 in single_worker_load_ids_arr:
- if workload.queryTabel('workload%s' % worker_number, "开始时间", "编号='{}'".format(flight_id_2))[0][0] != "":
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay, "结束时间": "'%s'" % endtime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_2))
- else:
- newdic = {"机号": "'%s'" % acno, "机位": "'%s'" % bay,"开始时间": "'%s'" % starttime, "结束时间": "'%s'" % endtime, "航班类型": "'%s'" % TYPE}
- workload.lazyUpdateItem('workload%s' % worker_number, newdic, "编号='{}'".format(flight_id_2))
- else:
- newdic = {"编号": "%s" % flight_id_2, "机号": "%s" % acno, "机位": "%s" % bay,
- "航班编号": "%s" % flight_id, "开始时间": "%s" % starttime,
- "结束时间": "%s"%endtime, "保障日期": "%s" % flight_date, "航班类型": "%s" % TYPE,
- "人员状态": ""}
- workload.lazyInsertData('workload%s' % worker_number, newdic)
- single_worker_load_twoday_ids = workload.queryTabel('workload%s' % worker_number, '编号',"保障日期='{}'or 保障日期='{}'".format(nowDayStr_search,yesterday_search))
- single_worker_load_twoday_ids_arr = []
- if single_worker_load_twoday_ids and len(single_worker_load_twoday_ids) != 0:
- for ll in single_worker_load_twoday_ids:
- single_worker_load_twoday_ids_arr.append(ll[0])
- worker_laod_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDay), '航班编号',"维修人员 like '%{}%'".format(worker))
- worker_laod_ids_twoday_arr = [] # 两天的量
- if worker_laod_ids and len(worker_laod_ids) != 0:
- for j in worker_laod_ids:
- worker_laod_ids_twoday_arr.append(j[0])
- worker_laod_ids_yesterday = database.queryTabel('TaskFlightinfo{}'.format(nowDay_1), '航班编号',"维修人员 like '%{}%'".format(worker))
- if worker_laod_ids_yesterday and len(worker_laod_ids_yesterday) != 0:
- for m in worker_laod_ids_yesterday:
- worker_laod_ids_twoday_arr.append(m[0])
- FX_laod_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDay), '航班编号', "放行人员 like '%{}%'".format(worker))
- if FX_laod_ids and len(FX_laod_ids) != 0:
- for j in FX_laod_ids:
- worker_laod_ids_twoday_arr.append(j[0])
- FX_laod_ids_yesterday = database.queryTabel('TaskFlightinfo{}'.format(nowDay_1), '航班编号',"放行人员 like '%{}%'".format(worker))
- if FX_laod_ids_yesterday and len(FX_laod_ids_yesterday) != 0:
- for m in FX_laod_ids_yesterday:
- worker_laod_ids_twoday_arr.append(m[0])
- ECSJ_laod_ids = database.queryTabel('TaskFlightinfo{}'.format(nowDay), '航班编号', "二次送机 like '%{}%'".format(worker))
- if ECSJ_laod_ids and len(ECSJ_laod_ids) != 0:
- for j in ECSJ_laod_ids:
- worker_laod_ids_twoday_arr.append(j[0])
- #暂无昨日table,待完善后启用两日查询
- ECCJ_laod_ids_yesterday = database.queryTabel('TaskFlightinfo{}'.format(nowDay_1), '航班编号',"二次送机 like '%{}%'".format(worker))
- if ECCJ_laod_ids_yesterday and len(ECCJ_laod_ids_yesterday) != 0:
- for m in ECCJ_laod_ids_yesterday:
- worker_laod_ids_twoday_arr.append(m[0])
- for kk in single_worker_load_twoday_ids_arr:
- if str(str(kk)[:-2]) not in str(worker_laod_ids_twoday_arr):
- workload.deleteSingledata('workload%s' % worker_number, "编号='{}'".format(kk))
- workload.FunctionCommit()
- except Exception as e:
- app_logger.log_error(e)
|