flightinfoV3_sever/ServerWithJWT.py

import concurrent.futures
import datetime
import os
import random
import socket
import time
import traceback
from datetime import timedelta
import sqlite3
import requests
from flask import Flask , render_template
from flask import request , jsonify
from flask_jwt_extended import JWTManager , create_refresh_token
from flask_jwt_extended import jwt_required , get_jwt_identity , create_access_token
from waitress import serve
from Functions import utils , DataComputer as DataComputer , ipcall , flaskDBUtils4PG as flaskDBUtils
from Functions.DButilsFunction import flightDB , judge_bc as Judge_bc , initFlightDatabase as InitFlightDatabase , \
    insertTaskDataToTable , sortFlighttime , sortFlighttime2 , checkTFUairplane , \
    createWorkloadtablesFromPg as CreateWorkloadtablesFromPg , \
    checkFlightAlert , calledChecked as CalledChecked , \
    infoConfirm as InfoConfirm , infoConfirm3 as InfoConfirm3 , infoConfirm2 as InfoConfirm2 , \
    maintainAuthCheck as MaintainAuthCheck , \
    checkLoadSingal as CheckLoadSingal , changepassword as Changepassword , postgresql_local , \
    mapDispaly as MapDispaly , \
    checkPglist as CheckPglist , updateEidteItem as UpdateEidteItem , updateDragDropItem as UpdateDragDropItem , \
    qtPeopleLoad as QtPeopleLoad , tableWidgetDispaly as TableWidgetDispaly , \
    tableWidgetDispaly2 as TableWidgetDispaly2 , \
    tableWidgetDispalyRead2 as TableWidgetDispalyRead2 , tableWidgetDispalyRead as TableWidgetDispalyRead , \
    bakupdata as Bakupdata , getphonelist as Getphonelist , MM_GJJH_LIST as mM_GJJH_LIST , \
    checkCalllist as CheckCalllist , \
    tableWidgetLOGDispaly as TableWidgetLOGDispaly , tableWidgetDisplayChange as TableWidgetDisplayChange , \
    manAddFlight as ManAddFlight , get_dic as Get_dic , manChangests as ManChangests , insertLogs as InsertLogs , \
    insertLogs2 as InsertLogs2 , \
    selftaxiLogs as SelftaxiLogs , taskAtuoCheck as TaskAtuoCheck , deleteFlight as DeleteFlight , \
    get_empNos as Get_empNos , updateTaskAuto as UpdateTaskAuto , insertCalllist as InsertCalllist , \
    insertWorkjob as InsertWorkjob , \
    getRiskData as GetRiskData , saveRisktable as SaveRisktable , updateRiskdb as UpdateRiskdb , \
    updateStopFlight as UpdateStopFlight , \
    dealLogs as DealLogs , update_Pglist as Update_Pglist , getWorkjobInfo as GetWorkjobInfo , \
    mandealAllLogs as MandealAllLogs , \
    calltry as Calltry , callon as Callon , get_empNos_phoone as Get_empNos_phoone , FlightSearchInsert , \
    TaskListInsert , checkWorkerlaod_new , \
    GetPglistInDatabase , Getworkload , HandoverStsChange , ManCahangeWorkload , UpdateNoteItem , postgresql_bakup , \
    UpdatePeopleScheduleFromOnline , FlightPlanInsert , checkFlightplan
from unitls.LogerinTxt import app_logger
from unitls.StaticDataclass import initialize_file , write_status_to_file
from unitls.settings import DBServer, flightDB4 , DataTransferMode , Server_Class , Main_Sever , databasefileDB , \
    Oline_flight
import hmac
import hashlib
import json
#requests.packages.urllib3.disable_warnings(InsecureRequestWarning)

'''
200 OK：请求成功，常用于GET和POST请求。

201 Created：请求成功并创建了新资源。

301 Moved Permanently：资源已永久移动到新位置。

302 Found：资源临时移动。

400 Bad Request：请求语法错误，服务器无法理解。

401 Unauthorized：请求需要身份验证。

403 Forbidden：服务器拒绝执行请求。

404 Not Found：服务器无法找到请求的资源。

500 Internal Server Error：服务器内部错误，无法完成请求。

503 Service Unavailable：服务器因超载或维护暂时无法处理请求。
'''

#初始化Flask应用
app = Flask(__name__)
app.config['initialized'] = False
app.config['JWT_SECRET_KEY'] = 'your-secret-key'  # 设置JWT密钥
# 设置普通JWT过期时间
app.config["JWT_ACCESS_TOKEN_EXPIRES"] = timedelta(hours=1)
# 设置刷新JWT过期时间
app.config["JWT_REFRESH_TOKEN_EXPIRES"] = timedelta(days=30)
app.config["SECRET_KEY"] = "Can't not guess it ."
jwt = JWTManager(app)
dir = os.getcwd()

dbhost, dbport, dbuser, dbpassword,online_host, online_port, online_user, online_password = DBServer()
mainseverip, maindatabase=Main_Sever()
backupactive = False #备用服务器激活标注
database="flaskDatabase"
databaseDB4 = flightDB4()
databaseWorkLoad = 'workLoad'
databaseLoginDB = 'loginDB'
databasefileDB=databasefileDB()
SameDatabase,HighRefreh,Online_flight_sts=Oline_flight()
flightDataTransfer,displayDataTransfer=DataTransferMode()
ServerClas = Server_Class()
severVersion = "18.0.0"
displayVersion = "18.0.0"
print(f"当前客户端版本：{severVersion}/白板版本：{displayVersion}")
print(f"当前服务器为:【{ServerClas}】")
print(f"当前服务器航班数据传输模式为:【{flightDataTransfer}】")
print(f"当前服务器显示计算请求模式为:【{displayDataTransfer}】")
print(f"在线编辑模式:【{Online_flight_sts}】")
print(f"一期二期服务器是否统一:【{SameDatabase}】")
print(f"在线编辑高刷模式:【{HighRefreh}】")
VinA1="328"
VinA2="328"
VinA3="328"
VinB1="328"
VinB2="328"
VinB3="328"

SIGNATURE_KEY=b"secret-key-neverout"  # 用于请求签名的密钥
REQUEST_VALID_DURATION = 30  # 请求有效期（秒)
# 获取本地IP地址
def get_local_ip():
    try:
        s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        s.connect(("8.8.8.8", 80))  # 连接到Google DNS服务器
        ip = s.getsockname()[0]
        s.close()
        return ip
    except:
        return socket.gethostbyname(socket.gethostname())

def generate_signature() :
    """
    生成请求签名
    :param data: 请求的JSON数据
    :return: (时间戳, 签名)
    """

    # 1. 获取当前Unix时间戳（秒级）
    timestamp = str(int(time.time()))
    data = { "timestamp" : timestamp }
    # 2. 对数据进行JSON序列化，确保排序一致
    # sort_keys=True 保证键的顺序一致，否则签名会不匹配
    data_str = json.dumps(data , sort_keys = True).encode('utf-8')

    # 3. 组合数据：数据字符串 + | + 时间戳
    signature_base = f"{data_str.decode('utf-8')}|{timestamp}".encode('utf-8')

    # 4. 使用HMAC-SHA256算法生成签名
    signature = hmac.new(
        SIGNATURE_KEY ,
        signature_base ,
        hashlib.sha256
    ).hexdigest()

    return timestamp , signature
def verify_request(timestamp , signature , data) :
    """验证请求的合法性"""
    try :
        # 1. 验证时间戳是否在有效范围内
        request_time = datetime.datetime.fromtimestamp(int(timestamp))
        current_time = datetime.datetime.now()

        # 检查时间是否在有效期内
        if abs((current_time - request_time).total_seconds()) > REQUEST_VALID_DURATION :
            return False

        # 2. 验证签名
        # 将数据、时间戳和密钥组合生成签名
        data_str = json.dumps(data , sort_keys = True)  # 确保数据顺序一致
        signature_base = f"{data_str}|{timestamp}".encode('utf-8')

        # 计算HMAC SHA256签名
        computed_signature = hmac.new(
            SIGNATURE_KEY,
            signature_base,
            hashlib.sha256
        ).hexdigest()

        # 比较签名（使用hmac.compare_digest更安全）
        if not hmac.compare_digest(computed_signature, signature):
            return False
        return True
    except Exception as e :
        return False


def check_a_availability():
    """检查A服务器的可用性"""
    try:
        timestamp, signature = generate_signature()
        header = {'Content-Type' : 'application/json',
                   'X-Timestamp' : timestamp,
                   'X-Signature' : signature,
                   }
        response = requests.get("http://" + mainseverip +  ':5001/static/health' , headers = header)
        #ip = "http://" + mainseverip + ":5001/static/health"
        #response = requests.get(ip, timeout=5)
        return response.status_code != 200  #看是否连接成功
    except Exception as e:
        return True  #出问题了

def create_user_table():
    conn = sqlite3.connect('users.db')
    c = conn.cursor()
    cur_str = """
        CREATE TABLE IF NOT EXISTS users (ID INTEGER PRIMARY KEY AUTOINCREMENT, 
        username TEXT NOT NULL, 
        password TEXT NOT NULL, 
        roles TEXT NOT NULL )
    """
    c.execute(cur_str)
    conn.commit()
    conn.close()
    print("Table created successfully")
'''
def insert_user(username, password, roles):
    conn = sqlite3.connect('users.db')
    c = conn.cursor()
    result = query_user(username)
    if not result:
        cur_str="""
        INSERT INTO users (username, password, roles) VALUES ("{}", "{}", "{}")""".format(username, password, roles)
        c.execute(cur_str)
        conn.commit()
        print("User ({}) inserted successfully".format(username))
    else:
        print("User {} already exists".format(username))
    conn.close()

def query_user(username):
    conn = sqlite3.connect('users.db')
    c = conn.cursor()
    cur_str="""
    SELECT * FROM users WHERE username = "{}" """.format(username)
    result = c.execute(cur_str).fetchall()
    return result

def verify_user(username, password):
    result = query_user(username)
    if not result:
        print("User ({}) doesn't exist".format(username))
        return False
    else:
        if result[0][2] == password:
            return True
        else:
            return False
'''

def returnTrue(message, data):
    return jsonify(msg=message, data=data)

def tableWidgetDispalyN(selectedtime,date):
    #t1 = datetime.datetime.now()
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    #t2 = datetime.datetime.now()
    #print(f'航班刷新登录时间:{t2 - t1}')
    res=TableWidgetDispaly(fdb,selectedtime,date)
    fdb.close()
    #print(datetime.datetime.now(),res)
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]A模式航班信息刷新请求[%s]"%(remote_addr,date))
    #t3 = datetime.datetime.now()
    #print(f'航班刷新处理时间:{t3 - t2}')
    return res

def tableWidgetDispaly2N(selectedtime,date):
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDispaly2(fdb,selectedtime,date)
    fdb.close()
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]B模式航班信息刷新请求[%s]"%(remote_addr,date))
    return res

def updatetimer():

    db = flaskDBUtils.flaskDB(host = dbhost , port = dbport , user = dbuser , password = dbpassword ,database = database)
    try:
        today = datetime.datetime.now().strftime("%Y%m%d")
        tomorrow = (datetime.datetime.now() + datetime.timedelta(days=1)).strftime("%Y%m%d")
        yesterday = (datetime.datetime.now() - datetime.timedelta(days=1)).strftime("%Y%m%d")
        dict={"1":yesterday,"2":today, "3":tomorrow}
        for key,value in dict.items():
            tableWidgetDispalyN(value,key)
            tableWidgetDispaly2N(value,key)
        flaskDBUtils.updateALlVin(db)
        #print(VinA1 , VinA2 , VinA3 , VinB1 , VinB2 , VinB3)
    except Exception as e:
        print(traceback.format_exc())
        db.close()

def task_function(taskname, paramaDict):
    #ts = time.time()
    #print('开始请求：{}'.format(taskname))
    time.sleep(random.randint(10,100)/100)
    if taskname == "taskflightdata":
        result = fl.request_task_filght_list(paramaDict['nowDayStr'], paramaDict['token'])
    elif taskname == "Thirdtaskflightdata":
        result = fl.request_task_filght_third_list(paramaDict['nowDayStr'], paramaDict['token'])
    elif taskname == "flightsearch":
        result = fl.request_LM_FLIGHT_SEARCH_LIST(paramaDict['nowDayStr'], paramaDict['token'])
    elif taskname == "flightsearch_1":
        result = fl.request_LM_FLIGHT_SEARCH_LIST(paramaDict['nowDay_1'], paramaDict['token'])
    elif taskname == "TaskList":
        result = fl.request_LM_TASK_ARCHIVE_LIST(paramaDict['nowDayStr'], paramaDict['token'])
    elif taskname == "TaskList_1":
        result = fl.request_LM_TASK_ARCHIVE_LIST(paramaDict['nowDay_1'], paramaDict['token'])
    elif taskname == "FlightplanInfo":
        result = fl.request_flight_from_flightplan(paramaDict['nowDay_1'],paramaDict['nowDayStr'], paramaDict['token'])
    else:
        result = {'code': 404}
    #print("{} 请求耗时：{}".format(taskname, time.time()-ts))
    return result
'''
#用户注册与登录
@app.route('/register', methods=['POST'])
def register():
    data = request.get_json()
    print(data)
    username = data.get('username')
    password = data.get('password')
    insert_user(username, password, 'general')

    return jsonify({'msg': 'User created successfully'}), 201

@app.route('/getAccessToken', methods=['POST'])
def get_access_token():
    data = request.get_json()
    username = data.get('username')
    password = data.get('password')


    if verify_user(username, password):
        access_token = create_access_token(identity=username)
        refresh_token = create_refresh_token(identity=username)
        return jsonify(access_token=access_token, refresh_token=refresh_token, msg="Login {} success".format(username)), 200

    return jsonify({'msg': 'Invalid credentials'}), 401
'''

# 健康检查接口，暂时不做要求，后期做白名单或者删掉
@app.route('/static/health')  #签名检测
def health_check():
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp,signature, {"timestamp": timestamp}):
        try:
            # 检查数据库连接
            db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
            db.close()
            return jsonify({"status": "ok", "msg":{"timestamp": datetime.datetime.now().isoformat()}}), 200
        except Exception as e:
            return jsonify({"status": "error", "msg": str(e)}), 500
    else:
        return jsonify({"status": "error", "msg": "签名验证未通过"}), 401
@app.route("/map/<selectedtime>/<token>")
def index(selectedtime,token):
    return render_template("map.html", selectedtime=selectedtime,token=token)


@app.route('/loginTable', methods=['POST'])  #签名检测
def loginTable():
    data = request.get_json()
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp,signature,data):
        username = data.get('username')
        password = data.get('password')
        remote_addr = request.remote_addr
        res1={"返回值":""}
        #t1 = datetime.datetime.now()
        loginTabledb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseLoginDB)
        #t2 = datetime.datetime.now()
        #print(f'登录时间:{t2 - t1}')
        res=loginTabledb.queryTabel('logintable', '*', "登录名='{}' and 密码='{}'".format(username,password))
        loginTabledb.close()
        if res !=[]:
            access_token = create_access_token(identity=username)
            refresh_token = create_refresh_token(identity=username)
            res1["返回值"]=res[0]
            return jsonify(data=res1, access_token=access_token, refresh_token=refresh_token), 200
        print(datetime.datetime.now(),"[%s]%s尝试登录" %(remote_addr,username))
        #t3 = datetime.datetime.now()
        #print(f'处理时间:{t3-t2}')
        return jsonify(msg=(datetime.datetime.now(),"[%s]%s尝试登录失败" %(remote_addr,username)), data=res1), 401
    else:
        return jsonify(msg=(datetime.datetime.now(),"签名验证未通过" ), data={"返回值":"fail"}), 401

@app.route('/static/remoteCheck', methods=['POST']) #操作系统版本验证 #签名检测
def remoteCheck():
    data = request.get_json()
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp,signature,data):
        checknumber = data.get('checknumber')
        if checknumber ==severVersion:
            res={"返回值":"ok"}
        else:
            res={"返回值":severVersion}
        res['msg']="check server version"
        return jsonify(res)
    else:
        res = { "返回值" : "签名验证未通过" }
        return jsonify(res), 401

@app.route('/static/remoteCheck2', methods=['POST']) #电子白板系统版本验证#签名检测
def remoteCheck2():
    data = request.get_json()
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp,signature,data):
        checknumber = data.get('checknumber')
        if checknumber ==displayVersion:
            res={"返回值": "ok"}
        else:
            res={"返回值": displayVersion}
        res['msg']="check display version"
        return jsonify(res)
    else:
        res = { "返回值" : "签名验证未通过" }
        return jsonify(res), 401

@app.route('/bakupdata')#签名检测
def bakupdata():
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp , signature , {"timestamp": timestamp}) :
        remote_addr = request.remote_addr
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        Bakupdata(fdb)
        fdb.close()
        print(datetime.datetime.now(), "[%s]5分钟间隔自动备份"%remote_addr)
        return jsonify(status="ok")
    else:
        return jsonify(status="fail",msg= '签名验证失败'), 401

@app.route('/postgresql')#签名检测
def postgresql():
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp , signature , {"timestamp": timestamp}) :
        try:
            if flightDataTransfer == 1:
                local = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
                try:
                    postgresql_local(local,online_host,online_port,online_user,online_password,databaseDB4)
                except:
                    local.close()
                    print(datetime.datetime.now(), "[远端链接失败]云端数据库服务器")
                    return jsonify(status="fail")
                local.close()
            if displayDataTransfer == 1:
                res= DataComputer.mytask()
                if res == "ok":
                    url = "https://"+online_host+":7162/computerDispalydata"
                    #url = "https://192.168.2.87:5070/computerDispalydata"
                    try:
                        ress=requests.get(url, verify=False)
                        ress.raise_for_status()  # 检查HTTP状态码是否为成功
                        data = ress.json()
                        #ress=requests.post(url, cert=('D:\\flightinfo\\DATABASE\\sichuanair.com.pem','D:\\flightinfo\\DATABASE\\sichuanair.com.key')).json()
                        if data == "ok":
                        #if data.get("result") == "ok":
                            print(datetime.datetime.now(), "远端显示中心计算请求成功")
                        else:
                            print(datetime.datetime.now(), "[返回为fail]远端显示中心计算请求失败")
                    except Exception as e:
                        print(e)
                        print(datetime.datetime.now(), "[请求被拒绝]远端显示中心计算请求失败")
            return jsonify(status="ok", msg=("远端显示中心计算请求成功"))
        except:
            print(traceback.format_exc())
            return jsonify(status="fail", msg=("[返回为fail]远端显示中心计算请求失败"))
    else:
        return jsonify(status="fail",msg= '签名验证失败'), 401

@app.route('/getFlightData2', methods=['POST'])#签名检测
async def getFlightData2():
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp , signature, {"timestamp": timestamp}):
        data = request.get_json()
        type = data.get('type')
        global singlePeopleNotice,loaclseverip
        db = flaskDBUtils.flaskDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=database)
        fdb = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseDB4)
        onlinefileDB=None
        workLoad = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseWorkLoad)
        if Online_flight_sts == "1":
            onlinefileDB = flightDB(host=online_host, port=dbport, user=dbuser, password=dbpassword, database=databasefileDB)
        if (mainseverip and mainseverip == loaclseverip) or mainseverip == "" or (mainseverip and mainseverip != loaclseverip and check_a_availability()):
            try:
                #print(type)
                ts = time.time()
                taskname_queue = ["taskflightdata","Thirdtaskflightdata","flightsearch","TaskList","FlightplanInfo","flightsearch_1","TaskList_1"] #FlightplanInfo 飞机排班系统的航班嘻嘻你
                taskparama_queue = []
                date_time = Judge_bc()["date"]
                nowDay = datetime.datetime.now()
                nowDayStr = nowDay.strftime("%Y%m%d")
                now_130 = (datetime.datetime.now() + datetime.timedelta(minutes=300)).strftime("%Y%m%d")
                nowStr = nowDay.strftime("%Y%m%d %H:%M:%S")
                print(datetime.datetime.now(), "[判断：%s,当前：%s,+130：%s]" % (date_time, nowDayStr, now_130))
                if date_time == nowDayStr and now_130 == nowDayStr:  # 当班次判断为09：00-1900时，只查当日   1900取决于300min不取决于班次判断
                    nowDay_1 =nowDayStr
                    nowday_11=nowDayStr
                    searchDay=f"{nowDayStr[:4]}-{nowDayStr[4:6]}-{nowDayStr[6:]}"
                    start=nowDay.strftime('%Y-%m-%d 00:00:00')
                    end= nowDay.strftime('%Y-%m-%d 00:00:00')

                elif date_time == nowDayStr and now_130 != nowDayStr:  # 当班次判断为1900-2400时，今日和明日
                    nowDay_1 = (datetime.date.today() + datetime.timedelta(days=1)).strftime("%Y%m%d")
                    nowday_11=nowDayStr
                    searchDay=f"{nowDayStr[:4]}-{nowDayStr[4:6]}-{nowDayStr[6:]}"
                    start=nowDay.strftime('%Y-%m-%d 00:00:00')
                    end= (datetime.date.today() + datetime.timedelta(days=1)).strftime('%Y-%m-%d 00:00:00')
                else:                                             #当班次判断为000-0900时，查昨日和今日
                    nowDay_1 = date_time
                    nowday_11= nowDayStr
                    searchDay=f"{date_time[:4]}-{date_time[4:6]}-{date_time[6:]}"
                    start=f"{date_time[:4]}-{date_time[4:6]}-{date_time[6:]} 00:00:00"
                    end=nowDay.strftime('%Y-%m-%d 00:00:00')
                print('nowDay_1:{},nowday_11:{},searchDay:{}'.format(nowDay_1,nowday_11,searchDay))
                if type == "A":
                    if str(flaskDBUtils.checkLogin(db)) == '1':
                        token,x_access_token = flaskDBUtils.getToken(db)
                        #print('db-token:{}'.format(token))
                        print(datetime.datetime.now(), "A动态获取获取[%s/%s]" % (nowDayStr, nowDay_1))
                        taskparama_queue.append({'nowDayStr':searchDay, 'token': token})
                        taskparama_queue.append({'nowDayStr':searchDay, 'token': token})
                        taskparama_queue.append({'nowDayStr':nowday_11, 'token': token})
                        taskparama_queue.append({'nowDayStr':nowday_11, 'token': token})
                        taskparama_queue.append({'nowDayStr':end,'nowDay_1': start, 'token': x_access_token})
                        taskparama_queue.append({'nowDay_1': nowDay_1, 'token': token})
                        taskparama_queue.append({'nowDay_1': nowDay_1, 'token': token})
                        flaskDBUtils.clearinfolog(db)
                        with concurrent.futures.ThreadPoolExecutor() as executor:
                            if nowday_11 == nowDay_1: #如果两个日期相同，只查一次避免相同
                                results = executor.map(task_function, taskname_queue[:5], taskparama_queue[:5])
                            else:
                                results = executor.map(task_function, taskname_queue, taskparama_queue)
                        resultsList = []
                        for result in results:
                            resultsList.append(result)
                        taskflightdata= resultsList[0]
                        Thirdtaskflightdata= resultsList[1]
                        flightsearchdata= resultsList[2]
                        tasklistdata= resultsList[3]
                        infoFromflightplan= resultsList[4] #飞机排班数据
                        #print(infoFromflightplan)
                        if nowday_11 != nowDay_1:  ##如果两个日期相同，就没有另外一天的数据
                            flightsearchdata_1= resultsList[5]
                            tasklistdata_1= resultsList[6]

                        if taskflightdata['code'] and taskflightdata['code'] != 200:
                            flaskDBUtils.logout(db)
                            flaskDBUtils.insertinfolog(db, nowStr, str(taskflightdata['code']))
                            InitFlightDatabase(fdb,workLoad, nowDayStr)
                            InitFlightDatabase(fdb,workLoad, nowDay_1)
                            sortFlighttime(fdb,workLoad)
                            sortFlighttime2(fdb,workLoad)
                            checkTFUairplane(fdb,onlinefileDB)
                            checkWorkerlaod_new(fdb,workLoad,nowDayStr,nowDay_1)
                            checkFlightAlert(fdb, singlePeopleNotice)
                            #dingdingDelete_flight(fdb)
                            #dingdingFlightsts(fdb)
                            #dingdinginfoget(fdb)
                            CalledChecked(fdb)
                            if Online_flight_sts == "1" and SameDatabase == "0":
                                res = UpdatePeopleScheduleFromOnline(fdb, onlinefileDB)
                                if res:
                                    updatetimer()
                            else:
                                updatetimer()
                            print(datetime.datetime.now(), "A静态刷新")
                            code=str(taskflightdata['code'])
                        else:
                            #ts2 = time.time()
                            InitFlightDatabase(fdb,workLoad, nowDayStr)
                            InitFlightDatabase(fdb,workLoad, nowDay_1)
                            insertTaskDataToTable(fdb, nowDayStr, taskflightdata['data'], Thirdtaskflightdata['data'])
                            FlightSearchInsert(fdb, nowDayStr, flightsearchdata['data'])
                            TaskListInsert(fdb, nowDayStr, tasklistdata['data'])
                            if infoFromflightplan['code'] and infoFromflightplan['code'] == 200:
                                FlightPlanInsert(fdb, nowDayStr, infoFromflightplan['result'])
                            if nowday_11 != nowDay_1:  ##如果两个日期相同，就没有另外一天的数据，无需写入
                                insertTaskDataToTable(fdb, nowDay_1, taskflightdata['data'], Thirdtaskflightdata['data'])
                                FlightSearchInsert(fdb, nowDay_1, flightsearchdata_1['data'])
                                TaskListInsert(fdb, nowDay_1, tasklistdata_1['data'])
                                if infoFromflightplan['code'] and infoFromflightplan['code'] == 200:
                                    FlightPlanInsert(fdb, nowDay_1, infoFromflightplan['result'])
                            checkFlightplan(fdb,workLoad)
                            sortFlighttime(fdb,workLoad)
                            sortFlighttime2(fdb,workLoad)
                            checkTFUairplane(fdb,onlinefileDB)
                            checkWorkerlaod_new(fdb,workLoad,nowDayStr,nowDay_1)
                            checkFlightAlert(fdb, singlePeopleNotice)
                            #dingdingDelete_flight(fdb)
                            #dingdingFlightsts(fdb)
                            #dingdinginfoget(fdb)
                            CalledChecked(fdb)
                            flaskDBUtils.insertinfolog(db,nowStr,str(taskflightdata['code']))
                            if Online_flight_sts == "1":
                                if SameDatabase == "0":
                                    UpdatePeopleScheduleFromOnline(fdb , onlinefileDB)
                            updatetimer()
                            print(datetime.datetime.now(), "A动态刷新")
                            #print('数据库耗时：{}'.format(time.time()-ts2))
                            code = str(taskflightdata['code'])+";刷新用时:"+str(time.time()-ts)
                    else:
                        code = '未登录'
                else: #type==B
                    InitFlightDatabase(fdb,workLoad, nowDayStr)
                    InitFlightDatabase(fdb,workLoad, nowDay_1)
                    sortFlighttime(fdb,workLoad)
                    sortFlighttime2(fdb,workLoad)
                    checkTFUairplane(fdb,onlinefileDB)
                    checkWorkerlaod_new(fdb,workLoad,nowDayStr,nowDay_1)
                    checkFlightAlert(fdb, singlePeopleNotice)
                    #dingdingDelete_flight(fdb)
                    #dingdingFlightsts(fdb)
                    #dingdinginfoget(fdb)
                    CalledChecked(fdb)
                    if Online_flight_sts == "1" and SameDatabase == "0":
                        res=UpdatePeopleScheduleFromOnline(fdb, onlinefileDB)
                        if res:
                            updatetimer()
                    else:
                        updatetimer()
                    print(datetime.datetime.now(),"B静态刷新")
                    code = "200"
                if mainseverip and mainseverip != loaclseverip and type == "B":
                    print(datetime.datetime.now(), '[系统警告]主服务器通讯失败，备份服务器工作中')
                    main_fdb=flightDB(host=maindatabase, port=dbport, user=dbuser, password=dbpassword, database=databaseDB4)
                    main_db = flaskDBUtils.flaskDB(host=maindatabase, port=dbport, user=dbuser, password=dbpassword, database=database)
                    main_loginTabledb = flightDB(host=maindatabase, port=dbport, user=dbuser, password=dbpassword, database=databaseLoginDB)
                    loginTabledb = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseLoginDB)
                    try:
                        postgresql_bakup(fdb, main_fdb,1)
                        postgresql_bakup(db, main_db,3)
                        postgresql_bakup(loginTabledb, main_loginTabledb,2)
                        main_fdb.close()
                        main_db.close()
                        main_loginTabledb.close()
                    except Exception as e:
                        main_fdb.close()
                        main_db.close()
                        main_loginTabledb.close()
                        print(datetime.datetime.now(), '[系统警告]向主数据传输失败')
                fdb.close()
                workLoad.close()
                db.close()
                if Online_flight_sts == "1":
                    onlinefileDB.close()
                return jsonify(code=code, msg='正常刷新')
            except Exception as e:
                fdb.close()
                workLoad.close()
                db.close()
                if Online_flight_sts == "1":
                    onlinefileDB.close()
                app_logger.log_error(e)
                return jsonify(code='未登录', msg=str(e))

        else:
            #需要加入数据库同步
            if type == "B":
                print(datetime.datetime.now(), '[主从备份]非主服务器,该服务器仅同步')
                main_fdb=flightDB(host=maindatabase, port=dbport, user=dbuser, password=dbpassword, database=databaseDB4)
                main_db = flaskDBUtils.flaskDB(host=maindatabase, port=dbport, user=dbuser, password=dbpassword, database=database)
                main_loginTabledb = flightDB(host=maindatabase, port=dbport, user=dbuser, password=dbpassword, database=databaseLoginDB)
                loginTabledb = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseLoginDB)
                try:
                    postgresql_bakup(main_fdb,fdb,1)
                    postgresql_bakup(main_db, db, 3)
                    postgresql_bakup(main_loginTabledb, loginTabledb, 2)
                    db.close()
                    fdb.close()
                    workLoad.close()
                    main_fdb.close()
                    main_db.close()
                    main_loginTabledb.close()
                    return '200'
                except Exception as e:
                    print(e)
                    db.close()
                    fdb.close()
                    workLoad.close()
                    main_fdb.close()
                    main_db.close()
                    main_loginTabledb.close()
                    print(datetime.datetime.now(), '[系统警告]从主数据备份失败')
                    return '200'
            else:
                return "200"
    else:
        return jsonify(code='未登录',msg= '签名验证失败'), 401
@app.route('/static/linktest')#签名检测
def linktest():
    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp , signature , { "timestamp": timestamp}) :
        return jsonify(status="ok", msg="linktest")
    else:
        return jsonify(status="fail",msg= '签名验证失败'), 401

@app.route('/checkLogin')#签名检测
def checkLogin():

    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp , signature , { "timestamp": timestamp}) :
        sts= False
        db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
        cookie,x_access_token = flaskDBUtils.getToken(db)
        if str(flaskDBUtils.checkLogin(db)) == '1':
            logincode = fl.checkCookieSts(cookie)
            if logincode and logincode != 200:
                sts= False
                flaskDBUtils.logout(db)
                time.sleep(0.1)
            elif logincode and logincode == 200:
                sts= True
        if str(flaskDBUtils.checkLoginflightplan(db)) == '1':
            flightplanlogincode = fl.checkCookieStsFLIGHTplan(x_access_token)
            if flightplanlogincode and flightplanlogincode != 200:
                sts= False
                flaskDBUtils.logoutflightplan(db)
                time.sleep(0.1)
            elif flightplanlogincode and flightplanlogincode == 200:
                sts= True
        #db.close()
        if sts:
            return jsonify(code="1", msg="登录正常")
        else:
            return jsonify(code="0", msg="登录超时")
    else:
        return jsonify(code="0",msg= '签名验证失败'), 401
@app.route('/table')#签名检测
def table():

    signature = request.headers.get('X-Signature')
    timestamp = request.headers.get('X-Timestamp')
    if verify_request(timestamp , signature , { "timestamp": timestamp}) :
        flaskDB = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
        result = flaskDBUtils.getinfolog(flaskDB)
        flaskDB.close()
        dl = []
        if result !=None:
            for i in result:
                dl.append([i[0], i[1], i[2]])
            data = {
                "data":dl,
                'msg':"get table data"
            }
            #print(data)
            #print('get table data')
            return jsonify(data)
        else:
            return jsonify({"data":[],'msg':"无数据"})
    else:
        return jsonify({"data":[],'msg':"签名验证失败"}), 401

#------------------------------------------------------------------------------------------------
#受保护的路由

@app.route("/map/getSelectInf", methods=['POST'])
@jwt_required()
def getSelectInf():
    data = request.get_json()
    selectedtime=data["selectedtime"]
    bay = data["bay"]
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res = MapDispaly(fdb, selectedtime)
    try:
        data = res[bay]
        fdb.close()
        return render_template('notuse/table.html' , data=data)
    except Exception:
        fdb.close()
        return render_template('notuse/table.html' , data={})

@app.route('/changeSinglepoepleNotice', methods=['POST'])
@jwt_required()
def changeSinglepoepleNotice():
    global singlePeopleNotice
    data = request.get_json()
    boolsts = data.get('boolsts')
    singlePeopleNotice = str(boolsts) == "1"
    write_status_to_file(singlePeopleNotice,'D:\\flightinfo\\DATABASE\\singlepoeple_notice.txt')
    return jsonify({"status": "success", "new_value": singlePeopleNotice, "msg":"changeSinglepoepleNotice"})

@app.route('/getSinglepoepleNotice')
@jwt_required()
def getSinglepoepleNotice():
    global singlePeopleNotice
    return jsonify({"singlepoepleNotice": singlePeopleNotice, "msg":"getSinglepoepleNotice"})

@app.route('/protected', methods=['GET'])
@jwt_required()
def protected():
    current_user_id = get_jwt_identity()
    return jsonify({'msg': f'Hello user {current_user_id}'}), 200

@app.route('/findserver')
def findserver():
    return jsonify(msg=ServerClas)

@app.route('/static/remoteCookielogin',methods=["POST"])
@jwt_required()
def remoteCookielogin():
    remote_addr = request.remote_addr
    data = request.get_json()
    username = data.get('username')
    cookie = data.get('cookie')
    cookie2 = data.get('cookie2')
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    user = username
    token = "{}".format(cookie)
    token2 = "{}".format(cookie2)

    flaskDBUtils.login(db, user, token, token2)
    db.close()
    if token != None:
        print(datetime.datetime.now(),"[%s]远程登录已获取Token"%remote_addr)
        return jsonify(msg=(datetime.datetime.now(),"[%s]远程登录已获取Token"%remote_addr), status = "ok")
    else:
        return jsonify(status="fail", msg=(datetime.datetime.now(),"[%s]远程登录获取Token失败！"%remote_addr))

@app.route('/static/remotelogin',methods=["POST"])
@jwt_required()
def remotelogin():
    remote_addr = request.remote_addr
    data = request.get_json()
    username = data.get('username')
    password = data.get('password')
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    user = username
    pwd =password
    #print(user, pwd)
    token,x_access_token = fl.start(user, pwd)
    flaskDBUtils.login(db, user, token,x_access_token)
    if token != None:
        print(datetime.datetime.now(),"[%s]远程登录已获取Token"%remote_addr)
        return jsonify(msg=(datetime.datetime.now(),"[%s]远程登录已获取Token"%remote_addr), status = "ok")
    else:
        return jsonify(status="fail", msg=(datetime.datetime.now(),"[%s]远程登录获取Token失败！"%remote_addr))

@app.route('/static/remotelogout')
@jwt_required()
def remotelogout():
    remote_addr = request.remote_addr
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    flaskDBUtils.logout(db)
    db.close()
    print(datetime.datetime.now(), "[%s]远程注销服务器AMRO账号"%remote_addr)
    return jsonify(stauts="ok", msg=("[%s]远程注销服务器AMRO账号"%remote_addr))

@app.route('/static/checkjobcard', methods=['GET', 'POST'])
@jwt_required()
def checkjobcard():
    remote_addr = request.remote_addr
    if request.method == 'GET':
        file_path = request.args.get('path')
    else:
        file_path = request.form.get('path')
    try:
        res= fl.request_jobcard("_udid=80c6089a041646db9c1d9f1a2bc1381a", file_path)
        print(datetime.datetime.now(), "[%s]调取电签工卡查询" % remote_addr)
    except Exception as e:
        app_logger.log_error(e)
        res = ""
    return jsonify(msg=res)

@app.route('/static/VinCheck', methods=['POST'])
@jwt_required()
def VinCheck():
    data = request.get_json()
    vinLcoal = data.get('vinLcoal')
    mode = data.get('mode')
    num = data.get('num')
    if int(num) !=4:
        db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
        vinOnline = flaskDBUtils.getVin(db,mode,int(num))
        db.close()
        if vinLcoal == vinOnline:
            a = "检验一致"
            res = {"返回值":"ok"}
        else:
            a = "服务器有更新"
            res = {"返回值": "update"}
    else:
        a = "非昨天、今天、明天无需获取"
        res = {"返回值": "ok"}
    remote_addr = request.remote_addr
    res['msg'] = ("[%s]刷新识别码监测:%s" % (remote_addr,a))
    print(datetime.datetime.now(), "[%s]刷新识别码监测:%s" % (remote_addr,a))
    return jsonify(res)

@app.route('/static/setIpPhone', methods=['POST'])
@jwt_required()
def setIpPhone():
    data = request.get_json()
    ip = data.get('ip')
    remote_addr = request.remote_addr
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    token=si.start(ip)
    if token != "fail":
        res={"返回值":"ok"}
        flaskDBUtils.setIpPhone(db, ip, token)
        print(datetime.datetime.now(), "[%s]自动网页电话登录成功[%s,%s]" % (remote_addr,ip, token))
        res['msg'] = ("[%s]自动网页电话登录成功[%s,%s]" % (remote_addr,ip, token))
    else:
        res={"返回值":"fail"}
        flaskDBUtils.setIpPhone(db, ip, None)
        print(datetime.datetime.now(), "[%s]自动网页电话登录失败[%s]" % (remote_addr,ip))
        res['msg']=("[%s]自动网页电话登录失败[%s]" % (remote_addr,ip))
    db.close()
    return jsonify(res)

@app.route('/static/maintainAuthCheck', methods=['POST'])
@jwt_required()
def maintainAuthCheck():
    data = request.get_json()
    name = data.get('name')
    flighttype = data.get('flighttype')
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=MaintainAuthCheck(fdb,name,flighttype)
    fdb.close()
    print(datetime.datetime.now(), "[%s]维修权限验证"%remote_addr)
    res['msg'] = ("[%s]维修权限验证"%remote_addr)
    return jsonify(res)

@app.route('/static/getPglist', methods=['POST'])
@jwt_required()
def getPglist():
    data = request.get_json()
    bcstr = data.get('bcstr')
    try:
        remote_addr = request.remote_addr
        #print('获取派工数据')
        bc=bcstr
        #bc = "B"  #需要获取
        db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
        token,x_access_token  = flaskDBUtils.getToken(db)
        db.close()
        #token = utils.flight_list.get_cookie()
        nowDay = datetime.datetime.now()
        nowDayStr = nowDay.strftime("%Y%m%d")
        nowDayStr2 = nowDay.strftime("%Y-%m-%d")
        # (self, taskid:str, shiftDate:str, shift:str, cookie):
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        taskids=fdb.queryTabel("TaskFlightinfo{}".format(nowDayStr),"航班编号","进出港航班号 like '%3U%'")
        if taskids[0][0] != "":
            Pglistdata=fl.request_LM_TSK_EMP_PGLIST(taskids[0][0],nowDayStr2,bc,token)
            Update_Pglist(fdb,nowDayStr,bc,Pglistdata['data'])
            fdb.close()
            print(datetime.datetime.now(),"[%s]获取派工人员清单请求"%remote_addr)
            return jsonify(code=Pglistdata['code'], msg=(datetime.datetime.now(),"[%s]获取派工人员清单请求"%remote_addr))
        else:
            return jsonify(code='404', msg="获取派工失败"), 404
    except Exception as e:
        app_logger.log_error("获取派工失败")
        app_logger.log_error(e)
        return jsonify(code='404', msg="获取派工失败"), 500

@app.route('/static/getPglistInDatabase')
@jwt_required()
def getPglistInDatabase():
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    try:
        res = Judge_bc()
        ress = GetPglistInDatabase(fdb,res)
        fdb.close()
        return jsonify({"返回值":ress, "msg":"get PglistInDatabase success"})
    except Exception as e:
        fdb.close()
        app_logger.log_error(e)
        return jsonify({"返回值":[], "msg":"get PglistInDatabase fail"})

@app.route('/static/getworkload',methods=["POST"])
@jwt_required()
def getworkload():
    data = request.get_json()
    names = data.get('names')
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    workLoad = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseWorkLoad)
    try:
        res=Getworkload(fdb,workLoad,names)
        return jsonify(data=res, msg="get workload success")
    except Exception as e:
        fdb.close()
        workLoad.close()
        app_logger.log_error(e)
        return jsonify(data={}, msg="get workload fail")

@app.route('/static/manchangecosttime',methods=["POST"])
@jwt_required()
def manchangecosttime():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    workLoad = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseWorkLoad)
    res=ManCahangeWorkload(workLoad,data)
    workLoad.close()
    return jsonify({"返回值":res, "msg":"manchangecosttime workload success"})

@app.route('/static/handoverflight',methods=["POST"])
@jwt_required()
def handoverflight():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    workLoad = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseWorkLoad)
    res=HandoverStsChange(workLoad,data)
    workLoad.close()
    return jsonify({"返回值":res, "msg":"handoverflight workload success"})

@app.route('/static/handoverflightAMRO',methods=["POST"])
@jwt_required()
def handoverflightAMRO():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    token,x_access_token = flaskDBUtils.getToken(db)
    #token = utils.flight_list.get_cookie()

    Pglistdata=fl.request_LM_TSK_HANDOVER(data,token)
    if Pglistdata['code'] == 200:
        res = {"返回值": "ok"}
    else:
        res = {"返回值": "fail"}
    print(datetime.datetime.now(),"[%s]使用AMRO工作交接功能"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]使用AMRO工作交接功能"%remote_addr)
    return jsonify(res)

@app.route('/static/MM_GJJH_LIST', methods=["POST"])
@jwt_required()
def MM_GJJH_LIST():
    remote_addr = request.remote_addr
    data = request.get_json()
    team = data.get('team')
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    token,x_access_token  = flaskDBUtils.getToken(db)
    db.close()
    Pglistdata=fl.request_MM_GJJH_LIST(token)
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    mM_GJJH_LIST(fdb,team,Pglistdata['data'])
    fdb.close()
    print(datetime.datetime.now(),"[%s]%s工具接还查询"%(remote_addr,team))
    return jsonify(code=str(Pglistdata['code']), msg=(datetime.datetime.now(),"[%s]%s工具接还查询"%(remote_addr,team)))

@app.route('/static/checkWorkjob', methods=["POST"])
@jwt_required()
def checkWorkjob():
    remote_addr = request.remote_addr
    data = request.get_json()
    taskid = data.get('taskid')
    res = {"返回值": "fail"}
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    token,x_access_token  = flaskDBUtils.getToken(db)
    db.close()
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    getinfos=GetWorkjobInfo(fdb,taskid)
    if getinfos !={}:
        getworkjob = fl.checkWorkjob(getinfos["taskids"], getinfos["acno"], getinfos["taskType"], getinfos["actype"], getinfos["startDate"], getinfos["endDate"], token)
        res=InsertWorkjob(fdb,getworkjob["data"],taskid)
        print(datetime.datetime.now(), "[%s]获取%s工作包请求"%(remote_addr,getinfos["acno"]))
    fdb.close()
    res['msg'] = ("[%s]获取%s工作包请求"%(remote_addr,getinfos["acno"]))
    return jsonify(res)

@app.route('/static/mandealAllLogs', methods=["POST"])
@jwt_required()
def mandealAllLogs():
    remote_addr = request.remote_addr
    data = request.get_json()
    mode = data.get('mode')
    user = data.get('user')
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    MandealAllLogs(fdb, user,mode)
    fdb.close()
    print(datetime.datetime.now(),"[%s]%s人工处理所有待办"%(remote_addr,user))
    return jsonify(status="ok", msg=(datetime.datetime.now(),"[%s]%s人工处理所有待办"%(remote_addr,user)))

@app.route('/static/calltry')
@jwt_required()
def calltry():
    remote_addr = request.remote_addr
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    phoneip=flaskDBUtils.getIpPhoneip(db)
    db.close()
    ip=phoneip["ip"]
    token = phoneip["token"]
    db.close()
    #print("客户端点击尝试拨打请求获取的IP：%s"%phoneip)
    if ip !="" and token!="":
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        A=Calltry(fdb, ip,token)
        fdb.close()
        if A != "fail":
            res = {"返回值": "ok"}
            print(datetime.datetime.now(),"[%s]尝试自动拨打请求%s"%(remote_addr,A))
            res['msg'] = (datetime.datetime.now(),"[%s]尝试自动拨打请求%s"%(remote_addr,A))
        else:
            res = { "返回值" : "fail" , "msg":"auto call fail"}
    else:
        res = {"返回值": "fail", "msg":"auto call fail"}
    return jsonify(res)

@app.route('/static/manAddFlight', methods=["POST"])
@jwt_required()
def manAddFlight():
    data = request.get_json()
    flighttype = data.get('flighttype')
    acno = data.get('acno')
    eng = data.get('eng')
    actype = data.get('actype')
    flightno = data.get('flightno')
    flightdate = data.get('flightdate')
    bay = data.get('bay')
    eta = data.get('eta')
    etd = data.get('etd')
    user = data.get('user')
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=ManAddFlight(fdb,flighttype,acno,eng,actype,flightno,flightdate,bay,eta,etd,user)
    print(datetime.datetime.now(),"%s人工添加航班%s"%(user,flightno))
    fdb.close()
    res['msg'] = (datetime.datetime.now(),"%s人工添加航班%s"%(user,flightno))
    return jsonify(res)

@app.route('/static/getphonelist')
@jwt_required()
def getphonelist():
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=Getphonelist(fdb)
    remote_addr = request.remote_addr
    fdb.close()
    print(datetime.datetime.now(),"[%s]客户端获取通讯录名单"%remote_addr)
    return jsonify(data=res, msg=(datetime.datetime.now(),"[%s]客户端获取通讯录名单"%remote_addr))

@app.route('/static/deleteFlight', methods=['POST'])
@jwt_required()
def deleteFlight():
    remote_addr = request.remote_addr
    data = request.get_json()
    flightid = data.get('flightid')
    user = data.get('user')
    time = data.get('time')
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=DeleteFlight(fdb,flightid,time)
    fdb.close()
    print(datetime.datetime.now(),"[%s]%s删除航班操作(%s)"%(remote_addr,user,flightid))
    res['msg'] = (datetime.datetime.now(),"[%s]%s删除航班操作(%s)"%(remote_addr,user,flightid))
    return jsonify(res)

@app.route('/static/called/')
@jwt_required()
def calledChecked():
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    CalledChecked(fdb)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]通话建立情况检查请求"%remote_addr)
    res['msg']=(datetime.datetime.now(),"[%s]通话建立情况检查请求"%remote_addr)
    return res

@app.route('/static/dingdong',methods=["POST"])
@jwt_required()
def dingdong():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    token,x_access_token =flaskDBUtils.getToken(db)
    db.close()
    LM_TSK_DINGDONG=fl.request_LM_TSK_DINGDONG(data,token)
    #print(data)
    if LM_TSK_DINGDONG['code'] and LM_TSK_DINGDONG['code'] == 200:
        res = {"返回值": "ok", "msg": (datetime.datetime.now(),"[%s]使用叮咚消息success"%remote_addr)}
    else:
        res = {"返回值": "fail", "msg": (datetime.datetime.now(),"[%s]使用叮咚消息fail"%remote_addr)}
    print(datetime.datetime.now(),"[%s]使用叮咚消息"%remote_addr)
    return jsonify(res)

@app.route('/static/LM_TSK_SURE_PG',methods=["POST"])
@jwt_required()
def LM_TSK_SURE_PG():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    token,x_access_token = flaskDBUtils.getToken(db)
    db.close()
    LM_TSK_SURE_PG=fl.request_LM_TSK_SURE_PG(data,token)
    #print(data)
    if LM_TSK_SURE_PG['code'] and LM_TSK_SURE_PG['code'] == 200:
        res = {"返回值": "ok", "msg":(datetime.datetime.now(),"[%s]使用派工success"%remote_addr)}
    else:
        res = {"返回值": "fail", "msg":(datetime.datetime.now(),"[%s]使用派工fail"%remote_addr)}
    print(datetime.datetime.now(),"[%s]使用派工"%remote_addr)
    return jsonify(res)

@app.route('/static/insertCalllist',methods=["POST"])
@jwt_required()
def insertCalllist():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=InsertCalllist(fdb, data)
    fdb.close()
    print(datetime.datetime.now(),"[%s]录入拨号数据库"%remote_addr)
    #print(datetime.datetime.now(),data)
    res['msg']=(datetime.datetime.now(),"[%s]录入拨号数据库"%remote_addr)
    return jsonify(res)

@app.route('/static/get_empNos_phoone', methods=['POST'])
@jwt_required()
def get_empNos_phoone():
    remote_addr = request.remote_addr
    data = request.get_json()
    name = data.get("name")
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=Get_empNos_phoone(fdb, name)
    fdb.close()
    print(datetime.datetime.now(),"[%s]获取员工号和电话号码"%remote_addr)
    #print(datetime.datetime.now(),data)
    return res

@app.route('/static/get_empNos',methods=["POST"])
@jwt_required()
def get_empNos():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=Get_empNos(fdb, data)
    fdb.close()
    print(datetime.datetime.now(),"[%s]获取员工号"%remote_addr)
    #print(datetime.datetime.now(),data)
    res['msg'] = (datetime.datetime.now(),"[%s]获取员工号"%remote_addr)
    return res

@app.route('/static/updatecheck')
@jwt_required()
def updatecheck():
    try:
        remote_addr = request.remote_addr
        flaskDB =flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
        updatests=flaskDBUtils.updatecheck(flaskDB)
        res = {"返回值":updatests}
        flaskDB.close()
        #print(res)
        print(datetime.datetime.now(),"[%s]客户端自动检查更新请求"%remote_addr)
        res['msg'] = (datetime.datetime.now(),"[%s]客户端自动检查更新请求"%remote_addr)
        return jsonify(res)
    except:
        return jsonify({"返回值": "0", 'msg':(datetime.datetime.now(),"[%s]客户端自动检查更新请求fail"%remote_addr)})

@app.route('/static/calling', methods=['POST'])  #呼出通话建立
@jwt_required()
def calling():
    remote_addr = request.remote_addr
    data = request.get_json()
    phonenum0 = data.get("phonenum0")
    #print(phonenum0)
    flaskDB = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    now=datetime.datetime.now()
    a=flaskDBUtils.callingphoneUpdate(flaskDB,phonenum0,now)
    res = {"返回值":"ok"}
    flaskDB.close()
    #print(res)
    print(datetime.datetime.now(),"[%s]%s自动电话通话正在呼出"%(remote_addr,phonenum0))
    res['msg'] = (datetime.datetime.now(),"[%s]%s自动电话通话正在呼出"%(remote_addr,phonenum0))
    return jsonify(res)

@app.route('/static/calldown')  #通话结束
@jwt_required()
def calldown():
    remote_addr = request.remote_addr
    flaskDB = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    now=datetime.datetime.now()
    a=flaskDBUtils.callingphoneUpdate(flaskDB,None,now)
    res = {"返回值":"ok"}
    flaskDB.close()
    #print(res)
    print(datetime.datetime.now(),"[%s]自动电话缓存恢复初始值"%remote_addr)
    res['msg'] =(datetime.datetime.now(),"[%s]自动电话缓存恢复初始值"%remote_addr)
    return jsonify(res)

@app.route('/static/callon')  #呼出通话建立
@jwt_required()
def callon():
    remote_addr = request.remote_addr
    flaskDB = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    phonenum=flaskDBUtils.getPhoneNum(flaskDB)
    flaskDB.close()
    if phonenum != None:
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        Callon(fdb,phonenum)
        fdb.close()
        #print(res)
        print(datetime.datetime.now(),"[%s]%s自动电话通话建立写入"%(remote_addr,phonenum))
        return jsonify({"返回值": "ok", "msg":(datetime.datetime.now(),"[%s]%s自动电话通话建立写入"%(remote_addr,phonenum))})
    res = {"返回值": "ok", "msg":"phonenum=None"}
    return jsonify(res)

@app.route('/static/initFlightDatabase', methods=["POST"])
@jwt_required()
def initFlightDatabase():
    data = request.get_json()
    selectedtime = data.get("selectedtime")
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    workLoad = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseWorkLoad)
    InitFlightDatabase(fdb,workLoad,selectedtime)
    fdb.close()
    workLoad.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]初始化航班信息数据库"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]初始化航班信息数据库"%remote_addr)
    return jsonify(res)

@app.route('/static/selftaxiLogs', methods=["POST"])
@jwt_required()
def selftaxiLogs():
    data = request.get_json()
    text = data.get("text")
    flightid = data.get("flightid")
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    SelftaxiLogs(fdb,text,flightid)
    fdb.close()
    res = {"返回值": "ok"}
    res['msg'] = "selftaxiLogs"
    return jsonify(res)

@app.route('/static/checkCalllist', methods=["POST"])
@jwt_required()
def checkCalllist():
    data = request.get_json()
    time = data.get("time")
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=CheckCalllist(fdb,time)
    fdb.close()

    return jsonify(data=res, msg="checkCalllist")

@app.route('/static/insertLogs', methods=["POST"])
@jwt_required()
def insertLogs():
    data = request.get_json()
    time = data.get("time")
    text = data.get("text")
    name = data.get("name")
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    InsertLogs(fdb,text,name,time)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]%s插入日志信息"%(remote_addr,name))
    res['msg'] = (datetime.datetime.now(),"[%s]%s插入日志信息"%(remote_addr,name))
    return jsonify(res)

@app.route('/static/insertLogs2', methods=["POST"])
@jwt_required()
def insertLogs2():
    data = request.get_json()
    time = data.get("time")
    name = data.get("name")
    text = data.get("text")
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    InsertLogs2(fdb,text,name,time)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]%s插入日志信息"%(remote_addr,name))
    res['msg'] = (datetime.datetime.now(),"[%s]%s插入日志信息"%(remote_addr,name))
    return jsonify(res)

@app.route('/static/checkLoadSingal', methods=["POST"])
@jwt_required()
def checkLoadSingal():
    data = request.get_json()
    time1 = data.get("time1")
    time2 = data.get("time2")
    worknum = data.get("worknum")
    remote_addr = request.remote_addr
    wdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseWorkLoad)
    res=CheckLoadSingal(wdb,worknum,time1,time2)
    wdb.close()
    print(datetime.datetime.now(),"[%s]查询个人工作量请求"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]查询个人工作量请求"%remote_addr)
    return jsonify(res)

@app.route('/static/authorityCheck', methods=["POST"])
@jwt_required()
def authorityCheck():
    remote_addr = request.remote_addr
    data = request.get_json()
    username = data.get("username")
    res1={"返回值":""}
    loginTabledb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseLoginDB)
    res=loginTabledb.queryTabel('logintable', '*', "登录名='{}'".format(username))
    loginTabledb.close()
    if res !=[]:
        res1["返回值"]=res[0]
    print(datetime.datetime.now(),"[%s]%s验证权限请求" %(remote_addr,username))
    res1['msg']=(datetime.datetime.now(),"[%s]%s验证权限请求" %(remote_addr,username))
    return jsonify(res1)

@app.route('/static/loginDbget', methods=["POST"])
@jwt_required()
def loginDbget():
    data = request.get_json()
    username = data.get("username")
    remote_addr = request.remote_addr
    res1= {}
    loginTabledb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseLoginDB)
    res=loginTabledb.getAlldata('logintable')
    loginTabledb.close()
    if res !=[] and username in str(res):
        for i in res:
            res2={}
            res2["登录名"] = i[1]
            res2["权限"] = i[3]
            res2["使用人"] = i[4]
            res1[i[1]] = res2
    print(datetime.datetime.now(),"[%s]%s权限修改信息获取" % (remote_addr,username))

    return jsonify(data=res1, msg=(datetime.datetime.now(),"[%s]%s权限修改信息获取" % (remote_addr,username)))

@app.route('/static/changePassword',methods=["POST"])
@jwt_required()
def changePassword():
    remote_addr = request.remote_addr
    data = request.get_json()["data"]
    loginTabledb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseLoginDB)
    Changepassword(loginTabledb,data["登录名"], data["旧密码"], data["新密码"])
    loginTabledb.close()
    res1 = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]%s更改密码请求" % (remote_addr,data["登录名"]))
    res1['msg'] = (datetime.datetime.now(),"[%s]%s更改密码请求" % (remote_addr,data["登录名"]))
    return jsonify(res1)

@app.route('/static/addUserWidget',methods=["POST"])
@jwt_required()
def addUserWidget():
    remote_addr = request.remote_addr
    res1={"返回值":""}
    data = request.get_json()["data"]
    loginTabledb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseLoginDB)
    res=loginTabledb.queryTabel('logintable', '*', "登录名='%s'"%data["登录名"])
    if res:
        res=loginTabledb.insertData('logintable', data)
        if res == "ok":
            res1["返回值"] = "1"
        else:
            res1["返回值"] = "0"
    else:
        res1["返回值"] = "2"
    loginTabledb.close()
    print(datetime.datetime.now(),"[%s]创建新用户：%s请求" % (remote_addr,data["登录名"]))
    res1['msg'] = (datetime.datetime.now(),"[%s]创建新用户：%s请求" % (remote_addr,data["登录名"]))
    return jsonify(res1)

@app.route('/static/changeAuth',methods=["POST"])
@jwt_required()
def changeAuth():
    remote_addr = request.remote_addr
    res1={"返回值":""}
    data = request.get_json()["data"]
    loginTabledb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseLoginDB)
    res=loginTabledb.queryTabel('logintable', '*', "登录名='%s'"%str(data["登录名"]).replace("'",""))
    if res != []:
        loginTabledb.upDateItem('logintable',data,"登录名='%s'"%str(data["登录名"]).replace("'",""))
        res1["返回值"]="1"
    else:
        res1["返回值"] = "2"
    loginTabledb.close()
    print(datetime.datetime.now(),"[%s]权限变更写入：%s请求" % (remote_addr,data["登录名"]))
    res1['msg'] = (datetime.datetime.now(),"[%s]权限变更写入：%s请求" % (remote_addr,data["登录名"]))
    return jsonify(res1)

@app.route('/static/infoConfirm',methods=["POST"])
@jwt_required()
def infoConfirm():
    remote_addr = request.remote_addr
    data = request.get_json()
    type, flightid, displaymode, selectedtime = data['type'], data['flightid'], data['displaymode'], data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    InfoConfirm(fdb,type,flightid,displaymode,selectedtime)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(), "[%s]确认通知操作"%remote_addr)
    res['msg'] = ("[%s]确认通知操作"%remote_addr)
    return jsonify(res)

@app.route('/static/infoConfirm3',methods=["POST"])
@jwt_required()
def infoConfirm3():
    remote_addr = request.remote_addr
    data = request.get_json()
    type,flightid,displaymode,selectedtime = data['type'], data['flightid'], data['displaymode'], data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    InfoConfirm3(fdb,type,flightid,displaymode,selectedtime)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]确认自滑推送操作"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]确认自滑推送操作"%remote_addr)
    return jsonify(res)

@app.route('/static/infoConfirm2',methods=["POST"])
@jwt_required()
def infoConfirm2():
    remote_addr = request.remote_addr
    data = request.get_json()
    type, flightid, displaymode, selectedtime = data['type'], data['flightid'], data['displaymode'], data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    InfoConfirm2(fdb,type,flightid,displaymode,selectedtime)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]确认推送操作"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]确认推送操作"%remote_addr)
    return jsonify(res)

@app.route('/static/manChangests',methods=["POST"])
@jwt_required()
def manChangests():
    remote_addr = request.remote_addr
    data = request.get_json()
    text, type, selectedtime, username = data['text'], data['type'], data['selectedtime'], data['username']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    ManChangests(fdb,text,type,selectedtime,username)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s][%s]%s人工改变航班状态"%(remote_addr,username,text))
    res['msg'] = (datetime.datetime.now(),"[%s][%s]%s人工改变航班状态"%(remote_addr,username,text))
    return jsonify(res)

@app.route('/static/updateDragDropItem',methods=["POST"])
@jwt_required()
def updateDragDropItem():
    #t1 = datetime.datetime.now()
    remote_addr = request.remote_addr
    data = request.get_json()
    column, text, flightid, displayMode, flighttype, selectedtime = data['column'], data['text'], data['flightid'], data['displaymode'], data['flighttype'], data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    #print(fdb,column,text,flightid,displayMode,flighttype,selectedtime)
    #t2 = datetime.datetime.now()
    #print(f'编辑登录时间:{t2 - t1}')
    res = UpdateDragDropItem(fdb,column,text,flightid,displayMode,flighttype,selectedtime)
    fdb.close()
    res1={"返回值":res}
    print(datetime.datetime.now(),"[%s]拖拽更新请求"%remote_addr)
    #t3 = datetime.datetime.now()
    #print(f'编辑处理时间:{t3 - t2}')
    res1['msg'] = (datetime.datetime.now(),"[%s]拖拽更新请求"%remote_addr)
    return jsonify(res1)

@app.route('/static/updateEidteItem',methods=["POST"])
@jwt_required()
def updateEidteItem():
    remote_addr = request.remote_addr
    data = request.get_json()
    text, flightid, displayMode, flighttype, selectedtime = data['text'], data['flightid'], data['displaymode'], data['flighttype'], data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    #print(fdb,column,text,flightid,displayMode,flighttype,selectedtime)
    UpdateEidteItem(fdb,text,flightid,displayMode,flighttype,selectedtime)
    fdb.close()
    res1={"返回值":"OK"}
    print(datetime.datetime.now(),"[%s]附加消息请求"%remote_addr)
    res1['msg'] = (datetime.datetime.now(),"[%s]附加消息请求"%remote_addr)
    return jsonify(res1)

@app.route('/static/updateNoteItem',methods=["POST"])
@jwt_required()
def updateNoteItem():
    try:
        remote_addr = request.remote_addr
        data = request.get_json()
        text, name = data['text'], data['name']
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        UpdateNoteItem(fdb,text,name)
        fdb.close()
        res1={"返回值":"OK"}
        print(datetime.datetime.now(),"[%s]排班辅助备注修改"%remote_addr)
        return jsonify(res1)
    except Exception as e:
        res1={"返回值":"fail"}
        res1['msg'] = "error:"+str(e)
        print("有bug,请联系管理员")
        app_logger.log_error(e)
        return jsonify(res1)

@app.route('/static/checkPglist',methods=["POST"])
@jwt_required()
def checkPglist():
    remote_addr = request.remote_addr
    data = request.get_json()
    name, selectedtime, bc = data['name'], data['selectedtime'], data['bc']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    #print(fdb,column,text,flightid,displayMode,flighttype,selectedtime)
    res = CheckPglist(fdb,name,selectedtime,bc)
    fdb.close()
    #print(res)
    if res == "YES":
        res1 = {"返回值": "OK"}
        print(datetime.datetime.now(), "[%s]人工录入派工核查成功"%remote_addr)
    else:
        res1 = {"返回值": "fail"}
        print(datetime.datetime.now(), "[%s]人工录入派工核查失败"%remote_addr)
    return jsonify(res1)

@app.route('/static/tableWidgetLOGDispaly', methods=["POST"])
@jwt_required()
def tableWidgetLOGDispaly():
    data = request.get_json()
    selectedtime = data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetLOGDispaly(fdb,selectedtime)
    fdb.close()
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]日志刷新请求"%remote_addr)
    return jsonify(data=res)

@app.route('/static/qtPeopleLoad',methods=["POST"])
@jwt_required()
def qtPeopleLoad():
    data = request.get_json()
    selectedtime, bc = data['selectedtime'], data['bc']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    workLoad = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseWorkLoad)
    res=QtPeopleLoad(fdb,workLoad,bc,selectedtime)
    workLoad.close()
    fdb.close()
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]人员工作状态刷新请求"%remote_addr)
    return jsonify(data=res)

@app.route('/static/getVin',methods=["POST"])
@jwt_required()
def getVin():
    data = request.get_json()
    mode, num = data['mode'], data['num']
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    vin=flaskDBUtils.getVin(db,mode,int(num)) # 刷新航班
    db.close()
    res = {"返回值": "%s"%vin}
    remote_addr = request.remote_addr
    print(datetime.datetime.now(), "[%s]获取在线Vin码"%remote_addr)
    return jsonify(res)

@app.route('/static/updateVin',methods=["POST"])
@jwt_required()
def updateVin():
    data = request.get_json()
    mode, num = data['mode'], data['num']
    db = flaskDBUtils.flaskDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=database)
    vin=flaskDBUtils.updateVin(db,mode,int(num))  # 刷新航班
    db.close()
    res = {"返回值": "%s"%vin}
    remote_addr = request.remote_addr
    print(datetime.datetime.now(), "[%s]更新在线Vin码"%remote_addr)
    return jsonify(res)

@app.route('/static/tableWidgetDispalyRead',methods=["POST"])
@jwt_required()
def tableWidgetDispalyRead():
    data = request.get_json()
    date = data['date']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDispalyRead(fdb,date)
    fdb.close()
    #print(datetime.datetime.now(),res)
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]A模式只读航班信息刷新请求"%remote_addr)
    # res['msg'] = (datetime.datetime.now(),"[%s]A模式只读航班信息刷新请求"%remote_addr)
    return jsonify(data=res)

@app.route('/static/tableWidgetDispalyRead2',methods=["POST"])
@jwt_required()
def tableWidgetDispalyRead2():
    data = request.get_json()
    date = data['date']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDispalyRead2(fdb,date)
    fdb.close()
    #print(datetime.datetime.now(),res)
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]B模式只读航班信息刷新请求"%remote_addr)
    return jsonify(data=res)

@app.route('/static/tableWidgetDispaly',methods=["POST"])
@jwt_required()
def tableWidgetDispaly():
    #t1 = datetime.datetime.now()
    data = request.get_json()
    selectedtime, date = data['selectedtime'], data['date']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    #t2 = datetime.datetime.now()
    #print(f'航班刷新登录时间:{t2 - t1}')
    res=TableWidgetDispaly(fdb,selectedtime,date)
    fdb.close()
    #print(datetime.datetime.now(),res)
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]A模式航班信息刷新请求[%s]"%(remote_addr,date))
    #t3 = datetime.datetime.now()
    #print(f'航班刷新处理时间:{t3 - t2}')
    return jsonify(data=res)

@app.route('/static/tableWidgetDispaly11',methods=["POST"])
@jwt_required()
def tableWidgetDispaly11():
    data = request.get_json()
    selectedtime = data['selectedtime']
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDispaly(fdb,selectedtime,"4")
    fdb.close()
    #print(datetime.datetime.now(),res)
    print(datetime.datetime.now(),"[%s]文件存储1航班信息刷新请求"%remote_addr)
    return jsonify(data=res)

@app.route('/static/tableWidgetDispaly22',methods=["POST"])
@jwt_required()
def tableWidgetDispaly22():
    data = request.get_json()
    selectedtime = data['selectedtime']
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDispaly2(fdb,selectedtime,"4")
    fdb.close()
    print(datetime.datetime.now(),"[%s]文件存储2航班信息刷新请求"%remote_addr)
    return jsonify(data=res)

@app.route('/static/tableWidgetDispaly2',methods=["POST"])
@jwt_required()
def tableWidgetDispaly2():
    data = request.get_json()
    selectedtime, date = data['selectedtime'], data['date']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDispaly2(fdb,selectedtime,date)
    fdb.close()
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]B模式航班信息刷新请求[%s]"%(remote_addr,date))
    return jsonify(data=res)

@app.route('/static/mapDispaly',methods=["POST"])
@jwt_required()
def mapDispaly():
    data = request.get_json()
    selectedtime = data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res = MapDispaly(fdb, selectedtime)
    fdb.close()
    #print(datetime.datetime.now(),'获取的机位数据：{}'.format(res))
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]地图显示刷新请求"%remote_addr)
    return jsonify(res)

@app.route('/static/judge_bc')
@jwt_required()
def judge_bc():
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    aa=Judge_bc()
    fdb.close()
    print(datetime.datetime.now(),"[%s]判断班次请求"%remote_addr)
    return jsonify(data=aa)

@app.route('/static/dealLogs',methods=["POST"])
@jwt_required()
def dealLogs():
    data = request.get_json()
    user, id = data['user'], data['id']
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    DealLogs(fdb,user,id)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]%s处理待办信息" % (remote_addr,user))
    return jsonify(res)

@app.route('/static/checkLogs',methods=["POST"])
@jwt_required()
def checkLogs():
    try:
        remote_addr = request.remote_addr
        data = request.get_json()
        start, end = data['start'], data['end']
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        res=fdb.sort_queryTable("*",'logs',"产生时间<'%s' and 产生时间>'%s'"%(end,start),"产生时间","desc")
        fdb.close()
        print(datetime.datetime.now(),"[%s]查询全部日志请求"%remote_addr)
        return jsonify(data=res)
    except:
        return jsonify(data={})

@app.route('/static/tableWidgetDisplayChange',methods=["POST"])
@jwt_required()
def tableWidgetDisplayChange():
    data = request.get_json()
    selectedtime = data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=TableWidgetDisplayChange(fdb,selectedtime)
    fdb.close()
    remote_addr = request.remote_addr
    print(datetime.datetime.now(),"[%s]待办信息刷新请求"%remote_addr)
    return jsonify(data=res, msg=(datetime.datetime.now(),"[%s]待办信息刷新请求"%remote_addr))

@app.route('/static/get_dic',methods=["POST"])
@jwt_required()
def get_dic():
    try:
        remote_addr = request.remote_addr
        data = request.get_json()['data']

        fdb = flightDB(host = dbhost , port = dbport , user = dbuser , password = dbpassword , database = databaseDB4)
        ress = Get_dic(fdb , data)
        fdb.close()
        res = {"返回值": ress}
        print(datetime.datetime.now(),"[%s]获取人员信息EXCEL表格"%remote_addr)
        res['msg'] = (datetime.datetime.now(),"[%s]获取人员信息EXCEL表格"%remote_addr)
        return jsonify(res)
    except:
        fdb.close()
        print(datetime.datetime.now(), "[%s]获取人员信息EXCEL表格失败" % remote_addr)
        res={ "返回值" : "fail" }
        return jsonify(res)

@app.route('/static/updateStopFlight',methods=["POST"])
@jwt_required()
def updateStopFlight():
    try:
        remote_addr = request.remote_addr
        data = request.get_json()['data']
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        workLoad = flightDB(host=dbhost, port=dbport, user=dbuser, password=dbpassword, database=databaseWorkLoad)
        ress=UpdateStopFlight(fdb,workLoad,data)
        fdb.close()
        workLoad.close()
        res = { "返回值" : ress}
        print(datetime.datetime.now(),"[%s]上传停场航班EXCEL数据"%remote_addr)
        return jsonify(res)
    except:
        fdb.close()
        workLoad.close()
        print(datetime.datetime.now(), "[%s]上传停场航班EXCEL数据失败" % remote_addr)
        return jsonify({"返回值": "fail", "msg":(datetime.datetime.now(), "[%s]上传停场航班EXCEL数据失败" % remote_addr)})

@app.route('/static/updateTaskAuto',methods=["POST"])
@jwt_required()
def updateTaskAuto():
    try:
        remote_addr = request.remote_addr
        data = request.get_json()['data']
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        ress=UpdateTaskAuto(fdb,data)
        fdb.close()
        res = {"返回值":ress}
        print(datetime.datetime.now(),"[%s]获取准备组任务EXCEL表格"%remote_addr)
        res['msg'] = (datetime.datetime.now(),"[%s]获取准备组任务EXCEL表格"%remote_addr)
        return jsonify(res)
    except:
        print(datetime.datetime.now(), "[%s]获取准备组任务EXCEL表格失败" % remote_addr)
        return jsonify({"返回值":"fail","msg":("[%s]获取准备组任务EXCEL表格失败" % remote_addr)})

@app.route('/static/saveRisktable')
@jwt_required()
def saveRisktable():
    remote_addr = request.remote_addr
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=SaveRisktable(fdb)
    fdb.close()
    print(datetime.datetime.now(),"[%s]导出风险数据库"%remote_addr)
    return {"返回值":res, "msg":(datetime.datetime.now(),"[%s]导出风险数据库"%remote_addr)}

@app.route('/static/getRiskData',methods=["POST"])
@jwt_required()
def getRiskData():
    remote_addr = request.remote_addr
    data = request.get_json()
    bay, time, acno, actype = data['bay'], data['time'], data['acno'], data['actype']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    res=GetRiskData(fdb,bay,time,acno,actype)
    fdb.close()
    print(datetime.datetime.now(),"[%s]导出风险数据库"%remote_addr)
    return {"返回值":res, "msg":(datetime.datetime.now(),"[%s]导出风险数据库"%remote_addr)}

@app.route('/static/updateRiskdb',methods=["POST"])
@jwt_required()
def updateRiskdb():
    try:
        remote_addr = request.remote_addr
        data = request.get_json()["data"]
        fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
        ress=UpdateRiskdb(fdb,data)
        fdb.close()
        res = {"返回值": ress}
        print(datetime.datetime.now(),"[%s]获取风险数据库EXCEL表格"%remote_addr)
        res['msg'] = (datetime.datetime.now(),"[%s]获取风险数据库EXCEL表格"%remote_addr)
        return jsonify(res)
    except:
        fdb.close()
        print(datetime.datetime.now(), "[%s]获取风险数据库EXCEL表格失败" % remote_addr)
        return jsonify({"返回值": "fail", "msg":("[%s]获取风险数据库EXCEL表格失败" % remote_addr)})

@app.route('/static/taskAtuoCheck',methods=["POST"])
@jwt_required()
def taskAtuoCheck():
    remote_addr = request.remote_addr
    data = request.get_json()
    time = data['time']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    TaskAtuoCheck(fdb,time)
    fdb.close()
    res = {"返回值": "ok"}
    print(datetime.datetime.now(),"[%s]确认准备组任务待办信息情况"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]确认准备组任务待办信息情况"%remote_addr)
    return jsonify(res)

@app.route('/static/createWorkloadtablesFromPg',methods=["POST"])
@jwt_required()
def createWorkloadtablesFromPg():
    remote_addr = request.remote_addr
    data = request.get_json()
    selectedtime = data['selectedtime']
    fdb = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseDB4)
    workLoad = flightDB(host=dbhost,port=dbport,user=dbuser,password=dbpassword,database=databaseWorkLoad)
    CreateWorkloadtablesFromPg(fdb,workLoad,selectedtime)
    fdb.close()
    workLoad.close()
    res={"返回值":"ok"}
    print(datetime.datetime.now(),"[%s]通过派工信息创建人员工作统计表"%remote_addr)
    res['msg'] = (datetime.datetime.now(),"[%s]通过派工信息创建人员工作统计表"%remote_addr)
    return jsonify(res)

#--------------------------------------------------------------------------------------------------------

@app.route('/getdict', methods=['GET'])
@jwt_required()
def getdict():
    data = {
        'data':['1','2','3','4','5','6','7','8','9'],
        'data2':'data2_data2'
    }
    return returnTrue('this is message', data), 200

#令牌刷新机制
@app.route('/refresh', methods=['POST'])
@jwt_required(refresh=True)
def refresh():
    current_user_id = get_jwt_identity()
    new_access_token = create_access_token(identity=current_user_id)
    return jsonify(access_token=new_access_token, msg='Refresh access_token success'), 200
'''
#用户角色与权限管理
@app.route('/admin', methods=['GET'])
@jwt_required()
def admin():
    current_user_id = get_jwt_identity()
    user = query_user(current_user_id)
    if user[0][3] != 'admin':
        return jsonify({'message': 'Access denied'}), 403
    return jsonify({'message': 'Hello admin'}), 200
'''
#'''
@app.before_first_request
def init():
    if not app.config['initialized']:
        print('####  Flask Start... ####')
        global fl,si,singlePeopleNotice,loaclseverip
        fl = utils.flight_list()
        si = ipcall.searchinfo()
        loaclseverip = get_local_ip()
        print(f"当前服务器IP:{loaclseverip}")
        singlePeopleNotice = initialize_file('D:\\flightinfo\\DATABASE\\singlepoeple_notice.txt',False)
        app.config['initialized'] = True

#if __name__ == '__main__':
#    app.run(debug=True, host='0.0.0.0', port=5001)
if __name__ == '__main__':
    serve(app, host='0.0.0.0',port=5001, threads=32)
    #serve(app, host='0.0.0.0',port=5001, threads=64)