import os
import json
import time
import requests
from flask import request
from flask import Flask, Response
from concurrent.futures import ThreadPoolExecutor
app = Flask(__name__)
executor = ThreadPoolExecutor(3)


def  analysing(request_data):
    patrol_host = '172.20.0.115'
    patrol_port = 8000
    request_data = json.loads(request_data)
    file_path = request_data['file_path']
    url = "http://" + patrol_host + ":" + patrol_port + "/notifyresult"
    #url = "http://172.20.0.115:8000/notifyresult"
    headers = {'Content--Type': 'application/json;charset=UTF-8'}

    '''
    print("--------------------------- url---------------------------", url)
    res = requests.post(url=url, json=result_data, headers=headers)
    print("---------------------------------res------------------------------------", res)
    '''




@app.route('/analysis', methods=['POST'])
def picAnalyse():
    print("---------------------------picAnalyse---start------------------------", request.args)
    request_data = request.get_data().decode('utf-8')
    print("---------------------------request_data---------------------------", request_data)
    executor.submit(analysing, request_data)
    #return Response()
    return json.dumps({'success':True})


if __name__ == '__main__':
    app.run(host='0.0.0.0', port=8000)