| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162 |
- from .flightDB import flightDB
- import datetime
- from unitls.LogerinTxt import app_logger
- def manChangests(database:flightDB,flight_id:str,changests_id:str,selectedtime,username):
- try:
- nowDayStr = selectedtime
- now = datetime.datetime.now()
- now11=str(now).split(".")[0]
- code = {"接机到位": "人工已到位", "放行": "人工已放行", "随机到位": "人工已到位", "销子夹板": "人工已取下", "二送到位": "人工已到位"}
- code2 = {"接机到位": "接机已到位提示", "放行": "已放行提示", "随机到位": "随机已到位提示", "销子夹板": "销子夹板已提示", "二送到位": "二送已到位提示"}
- flightsts_search=database.queryTabel("flightsts{}".format(nowDayStr),"%s"%changests_id,"航班编号 = '%s'"%flight_id)
- waringsts=database.queryTabel("logs","*","航班编号='%s' and 处理时间 =''"%flight_id)
- if len(flightsts_search) != 0:
- if flightsts_search[0][0] != "":
- newdic={"%s"%changests_id:"''","%s"%code2[changests_id]:"''"}
- database.upDateItem("flightsts{}".format(nowDayStr),newdic,"航班编号='%s'"%flight_id)
- a =database.queryTabel('flightsts{}'.format(nowDayStr), "机号", "航班编号='%s'" % flight_id)[0][0] if len(database.queryTabel('flightsts{}'.format(nowDayStr), "机号", "航班编号='%s'" % flight_id)) != 0 else "未显示机号"
- newdic = {"航班编号": "%s" % flight_id, "警告信息": "", "信息状态": "",
- "提示信息": "人工处理:%s取消%s状态!%s" % (a,changests_id,now11),
- "产生时间": "%s" % now, "处理人": "%s"%username, "处理时间": "%s" % now, "变更字段": "","显示对象":"","提示内容":""}
- database.insertData('logs', newdic)
- else:
- newdic={"%s"%changests_id:"'%s'"%code[changests_id],"%s"%code2[changests_id]:"'1'"}
- database.upDateItem("flightsts{}".format(nowDayStr),newdic,"航班编号 = '%s'"%flight_id)
- a = database.queryTabel('flightsts{}'.format(nowDayStr), "机号", "航班编号='%s'" % flight_id)[0][0] if len(
- database.queryTabel('flightsts{}'.format(nowDayStr), "机号", "航班编号='%s'" % flight_id)) != 0 else "未显示机号"
- newdic = {"航班编号": "%s" % flight_id, "警告信息": "", "信息状态": "",
- "提示信息": "人工处理:%s确认%s已完成!%s" % (a, changests_id,now11),
- "产生时间": "%s" % now, "处理人": "%s"%username, "处理时间": "%s" % now, "变更字段": "","显示对象":"","提示内容":""}
- database.insertData('logs', newdic)
- else:
- newdic = {"航班编号": "%s" % flight_id, "%s"%changests_id:"%s"%code[changests_id],"%s"%code2[changests_id]:"1"}
- for i in ["航班编号","接机到位","放行","销子夹板","随机到位","二送到位","接机已到位提示","已放行提示","销子夹板已提示","随机已到位提示","二送已到位提示","天府飞机","机号","机位"]:
- if i not in newdic.keys():
- newdic[i]=''
- database.insertData('flightsts{}'.format(nowDayStr), newdic)
- newdic = {"航班编号": "%s" % flight_id, "警告信息": "", "信息状态": "","提示信息": "人工处理[首次新建]:%s确认%s已完成!%s" % (flight_id, changests_id, now11),
- "产生时间": "%s" % now, "处理人": "%s" % username, "处理时间": "%s" % now, "变更字段": "", "显示对象": "","提示内容": ""}
- database.insertData('logs', newdic)
- if len(waringsts) != 0:
- for i in waringsts:
- if changests_id == "接机到位" and i[8]=="到位警告":
- newdic = {"处理人": "'%s'" % username, "处理时间": "'%s'" % now}
- database.upDateItem('logs', newdic, "编号='%s'" % i[0])
- elif changests_id == "放行" and i[8]=="放行警告":
- newdic = {"处理人": "'%s'" % username, "处理时间": "'%s'" % now}
- database.upDateItem('logs', newdic, "编号='%s'" % i[0])
- elif changests_id == "二送到位" and i[8]=="二送警告":
- newdic = {"处理人": "'%s'" % username, "处理时间": "'%s'" % now}
- database.upDateItem('logs', newdic, "编号='%s'" % i[0])
- elif changests_id == "销子夹板" and i[8]=="销夹警告":
- newdic = {"处理人": "'%s'" % username, "处理时间": "'%s'" % now}
- database.upDateItem('logs', newdic, "编号='%s'" % i[0])
- elif changests_id == "随机到位" and i[8] == "随机到位警告":
- newdic = {"处理人": "'%s'" % username, "处理时间": "'%s'" % now}
- database.upDateItem('logs', newdic, "编号='%s'" % i[0])
- except Exception as e:
- app_logger.log_error(e)
|
