api-datamanager/Modules/TycApi/TycRoutes.py

from flask import Blueprint, request

from Modules.TycApi.TycImpl import TycDataImpl
from Utils.ErrorUtil import APIReturnError
from Utils.RouteUtil import RouteParamsCheck

tyc_route = Blueprint('tyc', __name__)


@tyc_route.route('/basic_information', methods=['GET'])
def basic_information_route():
    """工商信息"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.basic_information(name=request.args['company'])
        return {"info": "工商信息", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/executive_information', methods=['GET'])
def executive_information_route():
    """高管信息"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.executive_information(name=request.args['company'])
        return {"info": "高管信息", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/shareholders_information', methods=['GET'])
def shareholders_information_route():
    """股东信息"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.shareholders_information(name=request.args['company'])
        return {"info": "股东信息", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/outbound_investment', methods=['GET'])
def outbound_investment_route():
    """对外投资"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.outbound_investment(name=request.args['company'])
        return {"info": "对外投资", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/branch_offices', methods=['GET'])
def branch_offices_route():
    """分支机构"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.branch_offices(name=request.args['company'])
        return {"info": "分支机构", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/change_record', methods=['GET'])
def change_record_route():
    """工商变更"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.change_record(name=request.args['company'])
        return {"info": "工商变更", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/business_information', methods=['GET'])
def business_information_route():
    """工商信息全量数据"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.basic_information(name=request.args['company'])
        if result == '保存成功':
            result = impl.executive_information(name=request.args['company'])
            if result == '保存成功':
                result = impl.shareholders_information(name=request.args['company'])
                if result == '保存成功':
                    result = impl.outbound_investment(name=request.args['company'])
                    if result == '保存成功':
                        result = impl.branch_offices(name=request.args['company'])
                        if result == '保存成功':
                            result = impl.change_record(name=request.args['company'])
        return {"info": "工商信息全量数据", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/trademark_information', methods=['GET'])
def trademark_information_route():
    """商标信息"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.trademark_information(name=request.args['company'])
        return {"info": "商标信息", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/patent_information', methods=['GET'])
def patent_information_route():
    """专利信息"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.patent_information(name=request.args['company'])
        return {"info": "专利信息", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/software_copyrights', methods=['GET'])
def software_copyrights_route():
    """软件著作权"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.software_copyrights(name=request.args['company'])
        return {"info": "软件著作权", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/website_record', methods=['GET'])
def website_record_route():
    """网站备案"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.website_record(name=request.args['company'])
        return {"info": "网站备案", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/intellectual_property', methods=['GET'])
def intellectual_property_route():
    """知识产权全量数据"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.trademark_information(name=request.args['company'])
        if result == '保存成功':
            result = impl.patent_information(name=request.args['company'])
            if result == '保存成功':
                result = impl.software_copyrights(name=request.args['company'])
                if result == '保存成功':
                    result = impl.website_record(name=request.args['company'])
        return {"info": "知识产权全量数据", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/hearing_announcement', methods=['GET'])
def hearing_announcement_route():
    """开庭公告"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.hearing_announcement(name=request.args['company'])
        return {"info": "开庭公告", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/executor', methods=['GET'])
def executor_route():
    """被执行人"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.executor(name=request.args['company'])
        return {"info": "被执行人", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/court_announcement', methods=['GET'])
def court_announcement_route():
    """法院公告"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.court_announcement(name=request.args['company'])
        return {"info": "法院公告", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/case_filing_information', methods=['GET'])
def case_filing_information_route():
    """立案信息"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.case_filing_information(name=request.args['company'])
        return {"info": "立案信息", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/untrustworthy', methods=['GET'])
def untrustworthy_route():
    """失信人"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.untrustworthy(name=request.args['company'])
        return {"info": "失信人", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/legal_proceedings', methods=['GET'])
def legal_proceedings_route():
    """法律诉讼"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.legal_proceedings(name=request.args['company'])
        return {"info": "法律诉讼", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/delivery_announcement', methods=['GET'])
def delivery_announcement_route():
    """送达公告"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.delivery_announcement(name=request.args['company'])
        return {"info": "送达公告", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/bankruptcy_reorganization', methods=['GET'])
def bankruptcy_reorganization_route():
    """破产重整"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.bankruptcy_reorganization(name=request.args['company'])
        return {"info": "破产重整", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/restricted_spending_order', methods=['GET'])
def restricted_spending_order_route():
    """限制消费令"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.restricted_spending_order(name=request.args['company'])
        return {"info": "限制消费令", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/final_case', methods=['GET'])
def final_case_route():
    """终本案件"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.final_case(name=request.args['company'])
        return {"info": "终本案件", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/judicial_risks', methods=['GET'])
def judicial_risks_route():
    """司法风险全量数据"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.hearing_announcement(name=request.args['company'])
        if result == '保存成功':
            result = impl.executor(name=request.args['company'])
            if result == '保存成功':
                result = impl.court_announcement(name=request.args['company'])
                if result == '保存成功':
                    result = impl.case_filing_information(name=request.args['company'])
                    if result == '保存成功':
                        result = impl.untrustworthy(name=request.args['company'])
                        if result == '保存成功':
                            result = impl.legal_proceedings(name=request.args['company'])
                            if result == '保存成功':
                                result = impl.delivery_announcement(name=request.args['company'])
                                if result == '保存成功':
                                    result = impl.bankruptcy_reorganization(name=request.args['company'])
                                    if result == '保存成功':
                                        result = impl.restricted_spending_order(name=request.args['company'])
                                        if result == '保存成功':
                                            result = impl.final_case(name=request.args['company'])
        return {"info": "司法风险全量数据", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/equity_pledge', methods=['GET'])
def equity_pledge_route():
    """股权出质"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.equity_pledge(name=request.args['company'])
        return {"info": "股权出质", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/mortgage_movable_property', methods=['GET'])
def mortgage_movable_property_route():
    """动产抵押"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.mortgage_movable_property(name=request.args['company'])
        return {"info": "动产抵押", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/land_mortgage', methods=['GET'])
def land_mortgage_route():
    """土地抵押"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.land_mortgage(name=request.args['company'])
        return {"info": "土地抵押", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/operational_risks', methods=['GET'])
def operational_risks_route():
    """经营风险全量数据"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.equity_pledge(name=request.args['company'])
        if result == '保存成功':
            result = impl.mortgage_movable_property(name=request.args['company'])
            if result == '保存成功':
                result = impl.land_mortgage(name=request.args['company'])
        return {"info": "经营风险全量数据", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/abnormal_operation', methods=['GET'])
def abnormal_operation_route():
    """经营异常"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.abnormal_operation(name=request.args['company'])
        return {"info": "经营异常", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/administrative_penalties', methods=['GET'])
def administrative_penalties_route():
    """行政处罚"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.administrative_penalties(name=request.args['company'])
        return {"info": "行政处罚", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/serious_violation', methods=['GET'])
def serious_violation_route():
    """严重违法"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.serious_violation(name=request.args['company'])
        return {"info": "严重违法", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/tax_violation', methods=['GET'])
def tax_violation_route():
    """税收违法"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.tax_violation(name=request.args['company'])
        return {"info": "税收违法", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/tax_arrears_announcement', methods=['GET'])
def tax_arrears_announcement_route():
    """欠税公告"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.tax_arrears_announcement(name=request.args['company'])
        return {"info": "欠税公告", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code


@tyc_route.route('/regulatory_risks', methods=['GET'])
def regulatory_risks_route():
    """监管风险全量数据"""
    try:
        RouteParamsCheck(req=request.args, params=["company"]).required()
        impl = TycDataImpl()
        result = impl.abnormal_operation(name=request.args['company'])
        if result == '保存成功':
            result = impl.administrative_penalties(name=request.args['company'])
            if result == '保存成功':
                result = impl.serious_violation(name=request.args['company'])
                if result == '保存成功':
                    result = impl.tax_violation(name=request.args['company'])
                    if result == '保存成功':
                        result = impl.tax_arrears_announcement(name=request.args['company'])
        return {"info": "监管风险全量数据", "result": result}
    except APIReturnError as e:
        return {"info": e.__str__()}, e.status_code