from flask import Flask, request, redirect, abort, session
from utils import *
import os, _thread, urllib


app = Flask(__name__)
app.config['SECRET_KEY'] = os.urandom(24)



@app.route('/queryUserId', methods=['GET'])
def queryUserId():
    # 获取支付明细
    try:
        code = request.args.get('code')
        data = query_wx_userid(code)
        if len(data) <= 11:
            res = query_wx_fj_info(data)
            data = res
        print(f'http://web.jiyuankeshang.com/?user={data}')
        return  redirect(f'http://web.jiyuankeshang.com/?user={data}')
    except Exception as e:
        return {}


@app.route('/queryUser', methods=['GET'])
def queryUserApi():
    # 获取支付明细
    try:
        id = request.args.get('user')
        data = queryUser(id)
        return data
    except Exception as e:
        return {}


@app.route('/getPaymentDetails', methods=['GET'])
def getPaymentDetails():
    try:
        id = request.args.get('user','')
        
        id = id.replace(" ", "")
        
        if not id:
           return {}
        data = query_pay_details(id)
        return data
    except Exception as e:
        print(e)
        return {}



@app.route('/test', methods=['POST'])
def test():
    # 新增未收付明细 {"pay_amount": 20000, "id": "18515367096"}
    try:
        data = request.data.decode("utf-8")
        print(data)
        return {}
    except Exception as e:
        print(e)
        return {}




@app.route('/addUnPayment', methods=['POST'])
def addUnPayment():
    # 新增未收付明细 {"pay_amount": 20000, "id": "18515367096"}
    try:
        data = request.data.decode("utf-8")
        data = data.replace("null", "None")
        data = eval(data)
        data = data['data']
        print("开始========", data)
        if data['shifoudikou'] != "是":
            return {data}
        res = filter_jdy_ht(data['sijishenfenzhenghao'])
        data1 = {"pay_amount": 0, "id": data['sijishenfenzhenghao'],
         "fs": data['fs'], "jg": data['company_jc'], "name": data['sijixingming'],
         "fsfz": data['fs_p'],"shfid": data['shfid'],
         "hphm": data['license_plate']}
        print(data1)
        _thread.start_new_thread(add_payment, (data1, 1))

        return data
    except Exception as e:
        print("addUnPayment",e, res)
        return {}


@app.route('/addPayment', methods=['POST'])
def addPayment():
    # 新增充值明细 {"pay_amount": 20000, "id": "18515367096"}
    try:
        data = request.data.decode("utf-8")
        print(data)
        data = data.replace("null", "None")
        data = eval(data)
        data = data['data']
        # res = filter_jdy_ht(data['id_card'])
        if not data['price']:
            data['price'] = 0
        # if not res:
        #     # 合同表单未有数据
        fsfz = data['fsfz']['dept_no'] if data['fsfz'] else ""
        _thread.start_new_thread(add_payment, ({"pay_amount": data['price'], "id": data['id_card'],
                                                "fs": data['fs'], "jg": data['jg'], "name": data['name'],
                                                "fsfz": fsfz, "hphm": data['hphm']}, 1))
        # else:
        #     _thread.start_new_thread(add_payment, ({"pay_amount": data['price'], "id": data['id_card'],
        #      "fs": res[1], "jg": res[0], "name": res[4],
        #      "fsfz": res[6],"shfid": res[7],
        #      "hphm": res[5]}, 1))
        return {}
    except Exception as e:
        print("addPayment",e, data)
        return {}


if __name__ == '__main__':
    app.run(host="0.0.0.0", port=3007, processes=True)