read_pdf_plt/parseCreditXmlAuto.py

#coding=utf-8
from xml.dom import minidom
import base64
import sys
import os
from customModel import CustomModel

from ini_op import Config;
base_dir = os.path.dirname(os.path.abspath(__file__))
config = Config(base_dir+"/config.ini");
productNumXy = config.get("baseconf", "productNumKcd")
productNumJz = config.get("baseconf","productNumJz")
productNumXxw = config.get("baseconf","productNumXxw")
productNumFb = config.get("baseconf", "productNumFb")
productNumKcd = config.get("baseconf", "productNumKcd")

productNumFd = config.get("baseconf", "productNumFd")
productNumKn = config.get("baseconf", "productNumKn")
productNumHst = config.get("baseconf", "productNumHst")
productNumQk = config.get("baseconf", "productNumQk")
productNumHc = config.get("baseconf", "productNumHc")
productNum500 = config.get("baseconf", "productNum500")
productNumHsz = config.get("baseconf", "productNumHsz")
#简营
productNumJy = config.get("baseconf", "productNumJy")

#新版桔子
productNumJzA = config.get("baseconf", "productNumJzA")
#仁东
productNumRd = config.get("baseconf", "productNumRd")
#恒昌新
productNumHcNew = config.get("baseconf", "productNumHcNew")
isPlt = config.get("baseconf", "isPlt");

import xyHttp
import hst_rule_set
import pboc_hc
import log
import shutil
logger = log.logger
import time
from dbController import DbController
dbController = DbController();
import json
import requests
import timeit
import traceback
import gzip
import io
from xmlParser import XmlParser;
from xmlParserHsz import XmlParserHsz;
from pboc.invokePboc import PBOC
from mailUtil import MailUtil
import datetime

today=datetime.date.today()
today = str(today)

def gzip_str(string_):
    out = io.BytesIO()

    with gzip.GzipFile(fileobj=out, mode='w') as fo:
        fo.write(string_.encode())

    bytes_obj = out.getvalue()
    return bytes_obj


def gunzip_bytes_obj(bytes_obj):
    in_ = io.BytesIO()
    in_.write(bytes_obj)
    in_.seek(0)
    with gzip.GzipFile(fileobj=in_, mode='rb') as fo:
        gunzipped_bytes_obj = fo.read()

    return gunzipped_bytes_obj.decode()


#解析xml数据
def getBusinessInfo(xmlFile):
    doc = minidom.parse(xmlFile)
    request = doc.documentElement.getElementsByTagName("request")[0]
    responseBody = doc.documentElement.getElementsByTagName("responseBody")[0]
    responseHeader = doc.documentElement.getElementsByTagName("responseHeader")[0]
    result = ""
    xmlData = ""
    isBaihu = "0";

    if len(responseBody.childNodes)==0:
        mailUtil = MailUtil();
        webhook = 'https://oapi.dingtalk.com/robot/send?access_token=64d8b2c7fed4949e9433b807c7c5559939f1517af8f77c1dacb4de19c6910b56'
        resultMsg =  getNodeData(responseHeader,"resultMsg")
        if resultMsg =="查询成功，无报告":
            isBaihu = "1"
        elif resultMsg == "输入的姓名与系统收录的姓名不一致":
            isBaihu = "3"
        else:
            isBaihu = "2"#查询失败
            mailUtil.dingtalk("号码:" + xmlFile.split("_")[0] + " 查询失败 ", webhook)
    else:
        responseBodyText = responseBody.childNodes[0].data
        decrpyt_bytes = base64.b64decode(responseBodyText)
        xmlData = gunzip_bytes_obj(decrpyt_bytes)
        # print(xmlData)
        #remove by chenqiwang 1105
        xmlPath = xmlFile+".txt"
        # 生成xml格式报告
        # with open(xmlPath, 'w', encoding='utf-8') as fp:
        #     fp.write(xmlData)
    # 非小赢需要解析
    productNum = getNodeData(request, "productNum")
    sqlMap = []
    if productNum != productNumXy:
        if xmlData !="":
            if productNum == productNumHsz:
                result,sqlMap = parseHsz(xmlData)
            else:
                #跑数据的时候改为parseHsz
                result,sqlMap = parse(xmlData)
    data = {
        "businessNum":getNodeData(request,"businessNum"),
        "coopBusinessNum": getNodeData(request, "coopBusinessNum"),
        "customerNum":getNodeData(request,"customerNum"),
        "certificateNum": getNodeData(request, "certificateNum"),
        "productNum": productNum,
        "creditXml":xmlData,
        "extend": getNodeData(request, "extend"),
        "result":result,
        "isBaihu":isBaihu,
        "sqlMap":sqlMap
    }
    return data
#解析xml报文
def parse(xmlData):
    xmlParse = XmlParser()
    result = ""
    try:
        result,sqlMap = xmlParse.parse(xmlData)
    except:
        info = sys.exc_info()
        logger.error(info[0])
        logger.error(info[1])
        logger.error(traceback.extract_tb(info[2], 1))
    return result,sqlMap
#解析xml报文 汇算帐
def parseHsz(xmlData):
    xmlParseHsz = XmlParserHsz()
    result = ""
    try:
        result = xmlParseHsz.parse(xmlData)
    except:
        info = sys.exc_info()
        logger.error(info[0])
        logger.error(info[1])
        logger.error(traceback.extract_tb(info[2], 1))
    return result
def getNodeData(request,key):
    data = request.getElementsByTagName(key)[0].childNodes[0].data
    return data;
# if __name__ == '__main__':
    # businessInfo = getBusinessInfo('./test.xml')
    # print(businessInfo)
    # xml = ""
    # data = base64.b64encode(xml.encode("UTF-8"))
    # print(str(data))
#调用http
def process(startTime,businessInfo,basePath_init,basePath,xml_path):
    startTime = str(startTime)

    productNum = businessInfo["productNum"]
    if productNumXy.find(productNum) >= 0:
        try:
            result = xyHttp.call_credit(businessInfo)
            # result = json.loads(result);
            # logger.info(result)
            #上传审批结果
            jsonPath = basePath + businessInfo["certificateNum"] + ".txt"
            logger.info(jsonPath)
            with open(jsonPath, 'w', encoding='utf-8') as fp:
                fp.write(result)
            uploadJsonFile(businessInfo,jsonPath)
            #移动xml文件
            try:
                dayStrPath = basePath+productNum+"/"+time.strftime('%Y%m%d', time.localtime(time.time()))+"/";
                descXmlPath = dayStrPath +"xml/"+ os.path.basename(xml_path)
                descJsonPath = dayStrPath+"txt/" + os.path.basename(jsonPath)
                if not os.path.exists(basePath+productNum):
                    os.mkdir(basePath+productNum)
                if not os.path.exists(dayStrPath):
                    os.mkdir(dayStrPath)
                if not os.path.exists(dayStrPath+"xml/"):
                    os.mkdir(dayStrPath + "xml/")
                if not os.path.exists(dayStrPath+"txt/"):
                    os.mkdir(dayStrPath+"txt/")
                logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
                if isPlt == "1":
                    move(xml_path, descXmlPath)
                    shutil.move(jsonPath, descJsonPath)
            except:
                logger.error(businessInfo["certificateNum"]+"#创建文件夹或者移动文件失败，不影响业务")
                logger.error(traceback.print_exc())
                logger.error(traceback.format_exc())
        except:
            logger.error(traceback.print_exc())
            logger.error(traceback.format_exc())
            mailUtil = MailUtil();
            webhook = 'https://oapi.dingtalk.com/robot/send?access_token=64d8b2c7fed4949e9433b807c7c5559939f1517af8f77c1dacb4de19c6910b56'
            mailUtil.dingtalk("号码:" + businessInfo["certificateNum"] + " 调用xy服务失败 ", webhook)

        endTime = str(datetime.now())  # 结束时间
        # yuan原有商户模型入库
        dbController.getConn()
        parse_info = str(businessInfo["result"])
        parse_info = parse_info.replace("'", "\\'")
        filter_info = str(result)
        filter_info = filter_info.replace("'", "\\'")
        sql = "INSERT INTO filter_result(report_name,filter_info,parse_info,start_time,end_time) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "', '" + startTime + "', '" + endTime + "')"
        dbController.execSql(sql)
        dbController.commit()

    elif productNumQk.find(productNum) >= 0 or productNumHsz.find(productNum) >= 0 or productNumHc.find(productNum) >= 0 \
            or productNumJzA.find(productNum) >= 0 or productNumRd.find(productNum) >= 0 or productNumHcNew.find(productNum) >= 0:#洽客
        txtPath = xml_path.replace(".xml", ".txt")
        result = ""
        if businessInfo["isBaihu"] != "3":
            with open(txtPath, 'w', encoding='utf-8') as fp:
                fp.write(businessInfo["result"])
            if productNumQk.find(productNum) >= 0:
                result = xyHttp.callQk(businessInfo)
            if productNumHc.find(productNum) >= 0:
                result = xyHttp.callHc(businessInfo)
            elif productNumHsz.find(productNum) >= 0:
                result = xyHttp.callHsz(businessInfo)
            elif productNumJzA.find(productNum) >= 0:
                result = xyHttp.callJz(businessInfo)
            elif productNumRd.find(productNum) >= 0:
                result = xyHttp.callRd(businessInfo)
            elif productNumHcNew.find(productNum) >= 0:
                result = pboc_hc.renhang_rules(businessInfo)
        # result = json.loads(result);
        #上传审批结果
        jsonPath = basePath + businessInfo["certificateNum"] + ".txt"
        logger.info(jsonPath)
        if businessInfo["isBaihu"] == "3":
            result = "{'errCode':-1,errMsg:'输入的姓名与系统收录的姓名不一致'}"
        logger.info(result)
        with open(jsonPath, 'w', encoding='utf-8') as fp:
            fp.write(result)
        uploadJsonFile(businessInfo,jsonPath)

        endTime = str(datetime.now())  # 结束时间

        #yuan原有商户模型入库
        dbController.getConn()
        parse_info = str(businessInfo["result"])
        parse_info = parse_info.replace("'", "\\'")
        filter_info = str(result)
        filter_info = filter_info.replace("'", "\\'")
        sql = "INSERT INTO filter_result(report_name,product_num,filter_info,parse_info,start_time,end_time) VALUES ('" + file_name + "', '" +productNum + "', '" + filter_info + "', '" + parse_info + "', '" + startTime + "', '" + endTime + "')"
        dbController.execSql(sql)
        dbController.commit()

        #移动xml文件
        dayStrPath = basePath+productNum+"/"+time.strftime('%Y%m%d', time.localtime(time.time()))+"/";
        descXmlPath = dayStrPath +"xml/"+ os.path.basename(xml_path)
        descJsonPath = dayStrPath+"txt/" + os.path.basename(jsonPath)
        descTxtPath = dayStrPath + "txt/" + os.path.basename(txtPath)
        if not os.path.exists(basePath+productNum):
            os.mkdir(basePath+productNum)
        if not os.path.exists(dayStrPath):
            os.mkdir(dayStrPath)
        if not os.path.exists(dayStrPath+"xml/"):
            os.mkdir(dayStrPath + "xml/")
        if not os.path.exists(dayStrPath+"txt/"):
            os.mkdir(dayStrPath+"txt/")
        logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
        if isPlt == "1":
            move(xml_path, descXmlPath)
            shutil.move(jsonPath, descJsonPath)
            shutil.move(txtPath, descTxtPath)
    else:
        #走jar包逻辑
        # print(businessInfo["result"])
        txtPath = xml_path.replace(".xml",".txt")
        with open(txtPath, 'w', encoding='utf-8') as fp:
            fp.write(businessInfo["result"])


        if productNum == productNumJz:#桔子


            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            invokePboc(businessInfo, txtPath)
            #移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            if isPlt == "1":
                move(xml_path, descXmlPath)
        elif productNum == productNumXxw:#新希望

            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            invokeXxw(businessInfo, txtPath);
            jsonPath = basePath + businessInfo["certificateNum"] + ".txt"
            #移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
            if isPlt == "1":
                move(xml_path, descXmlPath)
        elif productNum == productNumFb or productNum== productNumKcd or productNum500.find(productNum)>=0:#没有java包 #快车道和风暴 上传500个字段
            logger.info(businessInfo["productNum"])

            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            uploadJsonFile(businessInfo,txtPath)
            # 移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
            if isPlt == "1":
                move(xml_path, descXmlPath)
        elif productNumJy.find(productNum)>=0:#简营
            logger.info(businessInfo["productNum"])

            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            jsonPath = txtPath.replace(".txt","_json.txt")
            #写入数据到文件
            xyHttp.buildJyData(businessInfo,jsonPath)
            uploadJsonFile(businessInfo, jsonPath)
            # 移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
            if isPlt == "1":
                descTxtPath = basePath_init + "execed_txt/" + os.path.basename(jsonPath)
                try:
                    shutil.move(jsonPath, descTxtPath)
                except Exception:
                    pass
                move(xml_path, descXmlPath)
        elif productNum == productNumFd:#分蛋 白户审批通过

            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            if businessInfo["result"]!="":
                result = xyHttp.callNewModel(businessInfo)
                uploadAudit(result,businessInfo["businessNum"],productNum)
            else:
                result = {"approveResult":"1","rule":"白户"}
                uploadAudit(result, businessInfo["businessNum"], productNum)
            # 移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
            if isPlt == "1":
                move(xml_path, descXmlPath)
        elif productNumKn.find(productNum)>=0 :#快牛本地jar包,本地jar改为逗号配置

            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            if businessInfo["result"]!="":
                result = xyHttp.callLocal(businessInfo)
                uploadAudit(result,businessInfo["businessNum"],productNum)
            else:
                result = {"approveResult":"0","rule":"白户"}
                uploadAudit(result, businessInfo["businessNum"], productNum)
            # 移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
            if isPlt == "1":
                move(xml_path, descXmlPath)
        elif productNum == productNumHst:#海盛通

            # yuan原有商户模型入库
            dbController.getConn()
            parse_info = str(businessInfo["result"])
            parse_info = parse_info.replace("'", "\\'")
            filter_info = "此模型不产生结果"
            sql = "INSERT INTO filter_result(report_name,filter_info,parse_info) VALUES ('" + file_name + "', '" + filter_info + "', '" + parse_info + "')"
            # print(sql)
            dbController.execSql(sql)
            # if i==1:
            #     break
            dbController.commit()

            if businessInfo["result"]!="":
                result = hst_rule_set.callLocal(businessInfo)
                uploadAudit(result,businessInfo["businessNum"],productNum)
            else:
                result = {"approveResult":"0","rule":"白户"}
                uploadAudit(result, businessInfo["businessNum"], productNum)
            # 移动xml文件
            descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
            if not os.path.exists(basePath_init + "execed_new/"):
                os.mkdir(basePath_init + "execed_new/")
            logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
            if isPlt == "1":
                move(xml_path, descXmlPath)
        else:
        #走新增的自定义模型

            customModel=CustomModel();
            res=customModel.doCustomModel(productNum,businessInfo,xml_path);
            if res==3:
                jsonPath = xml_path.replace(".xml", "_json.txt")
                dayStrPath = basePath + productNum + "/" + time.strftime('%Y%m%d', time.localtime(time.time())) + "/";
                descXmlPath = dayStrPath + "xml/" + os.path.basename(xml_path)
                descJsonPath = dayStrPath + "txt/" + os.path.basename(jsonPath)
                descTxtPath = dayStrPath + "txt/" + os.path.basename(txtPath)
                if not os.path.exists(basePath_init + productNum):
                    os.mkdir(basePath_init + productNum)
                if not os.path.exists(dayStrPath):
                    os.mkdir(dayStrPath)
                if not os.path.exists(dayStrPath + "xml/"):
                    os.mkdir(dayStrPath + "xml/")
                if not os.path.exists(dayStrPath + "txt/"):
                    os.mkdir(dayStrPath + "txt/")
                logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
                if isPlt == "1":
                    move(xml_path, descXmlPath)
                    shutil.move(jsonPath, descJsonPath)
                    shutil.move(txtPath, descTxtPath)
            else :
                descXmlPath = basePath_init + "execed_new/" + os.path.basename(xml_path)
                if not os.path.exists(basePath_init + "execed_new/"):
                    os.mkdir(basePath_init + "execed_new/")
                logger.info("移动文件 from " + xml_path + " to " + descXmlPath)
                if isPlt == "1":
                    move(xml_path, descXmlPath)
            # if(res):
            #     result["approveResult"]="1"
            #
            # print(result);
            # 结果返回
            # uploadAudit(res, businessInfo["businessNum"], productNum)
            # 这个地方嵌进去结果
            i=0
            #本地jar
        if isPlt == "1":
            if not os.path.exists(basePath_init + "execed_txt/"):
                os.mkdir(basePath_init + "execed_txt/")
            descTxtPath = basePath_init + "execed_txt/" + os.path.basename(txtPath)
            shutil.move(txtPath, descTxtPath)
#调用jar包
def move(xml_path, descXmlPath):
    try:

        shutil.move(xml_path, descXmlPath)
        # print(xml_path)
        if not os.path.exists(basePath_init + "execed_xml/"):
            os.mkdir(basePath_init + "execed_xml/")
        shutil.move(xml_path+".txt", descXmlPath.replace("execed_new","execed_xml")+".txt")
        # print("diaomeidiao")
        # os.remove(xml_path+".txt")#删除生成的xml.txt文件
    except:
        logger.info("移动文件 from " + xml_path + " to " + descXmlPath +" error")
def invokePboc(businessInfo,txtPath):
    # ===================================
    try:
        businessNum = businessInfo["businessNum"]
        coopBusinessNum = businessInfo["coopBusinessNum"]
        pboc = PBOC()
        jarTxt = pboc.calc(txtPath,coopBusinessNum);
        result = json.loads(jarTxt)
        logger.info(result)
        if result.get("errcode")== None:
            uploadAudit(result,businessNum,businessInfo["productNum"])
        else:
            if businessInfo["isBaihu"]=="1":
                result = {"approveResult":"1"}
                uploadAudit(result, businessNum, businessInfo["productNum"])
            logger.error(result["errmsg"])
    except:
        logger.error("certificateNum=" + businessInfo["coopBusinessNum"])
        info = sys.exc_info()
        logger.error(info[0])
        logger.error(info[1])
        # logging.log(logging.ERROR, info[2])
        logger.error(traceback.extract_tb(info[2], 1))
#调用xxwjar包
def invokeXxw(businessInfo,txtPath):
    try:
        businessNum = businessInfo["businessNum"]
        coopBusinessNum = businessInfo["coopBusinessNum"]
        customerNum = businessInfo["customerNum"]
        certificateNum =  businessInfo["certificateNum"]
        pboc = PBOC()
        jarTxt = pboc.calcXxw(coopBusinessNum,customerNum,txtPath);
        logger.info("jarTxt:"+jarTxt)
        result = json.loads(jarTxt)
        jsonPath = basePath+certificateNum+".txt"
        # logger.info(jsonPath)
        with open(jsonPath, 'w', encoding='utf-8') as fp:
            fp.write(jarTxt)
        uploadJsonFile(businessInfo,jsonPath)
        if not os.path.exists(basePath + "execed_txt/"):
            os.mkdir(basePath + "execed_txt/")
        descJsonPath = basePath + "execed_txt/" + os.path.basename(jsonPath)
        shutil.move(jsonPath, descJsonPath)
    except:
        logger.error("certificateNum=" + businessInfo["coopBusinessNum"])
        info = sys.exc_info()
        logger.error(info[0])
        logger.error(info[1])
        logger.error(traceback.extract_tb(info[2], 1))
#上传审批结果
def uploadAudit(result,businessNum,productNum):
    approvalType = result["approveResult"]
    if productNum == productNumJz:
        if approvalType=="1":
            approvalOpinion = "征信通过"
            approvalType = "4"
        else:
            approvalOpinion = "征信拒绝"
            approvalType = "3"
    elif productNumKn.find(productNum)>=0 or productNum == productNumHst or productNum == productNumFd:
        if approvalType=="1":
            approvalOpinion = "征信通过"
            approvalType = "4"
        else:#快牛 需要添加拒绝原因
            approvalOpinion = "征信拒绝" + "#" + result["rule"]
            approvalType = "3"
    taskKey = config.get("baseconf","taskKey")
    appoveApiUrl = config.get("baseconf","appoveApiUrl")
    key = config.get("baseconf", "AESKey")
    data = {"header":{
            "ticket": "2938123198320412343",
            "timestamp": int(int(round(time.time() * 1000+60*1000))),
            "nonce": config.get("baseconf", "nonce")
        },
       "body":{"approvalType": approvalType, "businessNum": businessNum,"taskKey":taskKey,"approvalOpinion":approvalOpinion}}
    access_token = dbController.getToken();
    if access_token == "":#获取token失败重新获取
        access_token = dbController.getToken();
    appoveApiUrl = appoveApiUrl+"?access_token="+access_token
    headers = {"Content-Type": "application/json"}
    jsonStr = json.dumps(data);
    jsonStr = jsonStr.replace('"',"\\\"")#必须替换才行
    logger.info(jsonStr)
    pboc = PBOC();
    encryData = pboc.encrypt(jsonStr,key)
    encryData = encryData[0:len(encryData)-2]
    logger.info(encryData)
    response = requests.post(appoveApiUrl, data=encryData,headers=headers)
    text = response.text
    pboc = PBOC();
    resultText = pboc.decrypt(text, config.get("baseconf", "AESKey"))
    logger.info(businessNum + "#" + "uploadAudit upload_result:" + resultText)
#上传解析json
def uploadJsonFile(businessInfo,json_path):
    # ===================================
    try:
        fileName = os.path.basename(json_path)
        #上传文件逻辑
        logger.info(json_path+"#"+"准备上传文件")
        uploadApiUrl = config.get("baseconf", "uploadApiUrl");
        token = dbController.getToken();
        if token == "":#如果获取失败，重新获取
            token = dbController.getToken();
        uploadApiUrl = uploadApiUrl + "?access_token=" + token
        files = {'file': open(json_path, 'rb')}
        logger.info(fileName+"#"+"businessNum:"+businessInfo["businessNum"])
        data = {'docType': "23", 'businessNum': businessInfo["businessNum"]}
        response = requests.post(uploadApiUrl, files=files, data=data,timeout=15)
        text = response.text
        logger.info("上传结果:"+text)
        pboc = PBOC();
        resultText = pboc.decrypt(text,config.get("baseconf", "AESKey"))
        logger.info(fileName+"#"+"uploadJsonFile:" + resultText)
    except:
        logger.error("certificateNum="+businessInfo["coopBusinessNum"])
        info = sys.exc_info()
        logger.error(info[0])
        logger.error(info[1])
        # logging.log(logging.ERROR, info[2])
        logger.error(traceback.extract_tb(info[2], 1))
        mailUtil = MailUtil();
        webhook = 'https://oapi.dingtalk.com/robot/send?access_token=64d8b2c7fed4949e9433b807c7c5559939f1517af8f77c1dacb4de19c6910b56'
        # mailUtil.dingtalk("号码:" + businessInfo["certificateNum"]+"-"+businessInfo["businessNum"] + " 上传文件失败 ", webhook)

def init_file_list(basePath):
    if not os.path.exists(basePath + "execed_txt/"):
        os.mkdir(basePath + "execed_txt/")
    if not os.path.exists(basePath + "execed_xml/"):
        os.mkdir(basePath + "execed_xml/")
    if not os.path.exists(basePath + "execed_new/"):
        os.mkdir(basePath + "execed_new/")
    # if not os.path.exists(basePath + "CPA0100657/"):
    #     os.mkdir(basePath + "CPA0100657/")
    # if not os.path.exists(basePath + "CPA0100759/"):
    #     os.mkdir(basePath + "CPA0100759/")
    # if not os.path.exists(basePath + "CPA0100775/"):
    #     os.mkdir(basePath + "CPA0100775/")
    # if not os.path.exists(basePath + "CPA0100657/"):
    #     os.mkdir(basePath + "CPA0100657/")
    # if not os.path.exists(basePath + "CPA0100841/"):
    #     os.mkdir(basePath + "CPA0100841/")
if __name__ == '__main__':
    basePath_init = "D:/jin_rong/todo/"
    init_file_list(basePath_init)
    file_name = sys.argv[1]
    # file_name = "樊术生_432924196512260092_525976302319050756-20221116100213782.xml"
    basePath = "D:/jin_rong/execed_xml/"
    xml_path = basePath + file_name
    start = timeit.default_timer();
    # if len(sys.argv) > 1:
    #     basePath = sys.argv[1]
    #     xml_path = basePath + sys.argv[2]
    #     file_name = sys.argv[2]
    # print("parseStarting")
    logger.info(xml_path+" 解析开始")
    startTime = datetime.now() #开始时间
    businessInfo = getBusinessInfo(xml_path)
    # with open('D:/jin_rong/test_data/朱传光_371425199305027971_256979050910728199.txt', 'r', encoding='utf-8')as fp:
    #     businessInfo['result'] = fp.read();
    # logger.info(businessInfo)
    if businessInfo["isBaihu"]!="2":#白户不上传1211
        try:
            process(startTime,businessInfo,basePath_init,basePath,xml_path)
        except:
            logger.error(traceback.print_exc())
            logger.error(traceback.format_exc())
    s = timeit.default_timer() - start;
    logger.info(str(s) + " 秒")
    logger.info(xml_path+" 解析完成")
    # 执行sql开始
    logger.info(xml_path + " 执行sql解析开始")
    sqlMap = businessInfo["sqlMap"]
    # 执行sql完成
    # logger.info(sqlMap)
    try:
        start = timeit.default_timer();
        dbController.getConn()
        for sql in sqlMap:
            dbController.execSql(sql)
        dbController.commit()
        s = timeit.default_timer() - start;
        logger.info(xml_path+str(s) + " 秒")
    except:
        logger.error(traceback.print_exc())
        logger.error(traceback.format_exc())
        logger.info(xml_path + " 执行sql解析失败")
    logger.info(xml_path + " 执行sql解析完成")