parent
02aa730631
commit
178d2b7d1a
@ -1,2 +1,3 @@
|
||||
|
||||
.DS_Store
|
||||
.DS_Store
|
||||
|
@ -0,0 +1,16 @@
|
||||
FROM hubdocker.aminer.cn/library/python-base:1.0.0
|
||||
|
||||
WORKDIR /app
|
||||
|
||||
# 创建目录
|
||||
|
||||
COPY devlop_home/ /app/devlop_home/
|
||||
COPY main.py /app/devlop_home
|
||||
|
||||
RUN pip install --upgrade pip --progress-bar off -i https://mirrors.aliyun.com/pypi/simple/
|
||||
RUN pip install --no-cache-dir jsonlines
|
||||
RUN pip install --no-cache-dir --progress-bar off -r /app/devlop_home/requirements.txt -i https://mirrors.aliyun.com/pypi/simple/
|
||||
|
||||
ENV OPENBLAS_NUM_THREADS=1
|
||||
|
||||
CMD ["/app/py_devlop.sh", "/app/devlop_data/input_param.json", "/app/devlop_result/answer.json" ]
|
@ -0,0 +1,2 @@
|
||||
# agent/__init__.py
|
||||
from .brain import main_answer
|
@ -0,0 +1,2 @@
|
||||
# agent/embeddings/__init__.py
|
||||
from .embedding_utils import calculate_similarity, save_embeddings
|
@ -0,0 +1,2 @@
|
||||
# agent/question/__init__.py
|
||||
from .question_utils import process_question, rewrite_question, preprocess
|
@ -0,0 +1,2 @@
|
||||
# agent/schema/__init__.py
|
||||
from .schema_utils import get_table_schema, parse_table_structures, map_chinese_to_english_tables, find_value_in_list_of_dicts, filter_table_comments
|
@ -0,0 +1,4 @@
|
||||
# agent/sql/__init__.py
|
||||
from .exec import exec_sql_s
|
||||
from .process_sql import to_select, extract_table_names, all_tables_in_prompt
|
||||
from .knowledge import way_string_2
|
@ -0,0 +1,35 @@
|
||||
# agent/sql/exec.py
|
||||
from config import *
|
||||
import requests
|
||||
|
||||
def exec_sql_s(sql):
|
||||
"""
|
||||
Execute a given SQL query on a remote endpoint and return the result.
|
||||
Uses 'Access_Token' for authorization and limits the result to 10 rows.
|
||||
|
||||
Parameters:
|
||||
sql (str): The SQL query to be executed.
|
||||
|
||||
Returns:
|
||||
list: The query result as a list of rows (dictionaries), or None if not found.
|
||||
"""
|
||||
headers = {
|
||||
"Authorization": f'Bearer {Access_Token}',
|
||||
"Accept": "application/json"
|
||||
}
|
||||
url = "https://comm.chatglm.cn/finglm2/api/query"
|
||||
|
||||
response = requests.post(url, headers=headers, json={
|
||||
"sql": sql,
|
||||
"limit": 50
|
||||
})
|
||||
response_json = response.json()
|
||||
|
||||
# If there's no 'data' field, print the full response for debugging
|
||||
if 'data' not in response_json:
|
||||
if DEBUG_VER == 3:
|
||||
print(response_json)
|
||||
pass
|
||||
|
||||
# Return 'data' if present
|
||||
return response_json.get('data', None)
|
@ -0,0 +1,3 @@
|
||||
# agent/utils/__init__.py
|
||||
from .async_util import async_llm_chain_call,get_best
|
||||
from .json_utils import find_json,fix_json,dict_to_sentence
|
@ -0,0 +1,24 @@
|
||||
import json
|
||||
import jsonlines
|
||||
|
||||
|
||||
def load_external_answers(file_path):
|
||||
with open(file_path, 'r', encoding='utf-8') as f:
|
||||
ext_data = json.load(f)
|
||||
return ext_data
|
||||
|
||||
def dump_2_report_answer(info, path):
|
||||
with open(path, 'w') as output_json_file:
|
||||
json.dump(info, output_json_file, ensure_ascii=False, indent=4)
|
||||
|
||||
def dump_jsonl(info, path):
|
||||
with jsonlines.open(path, "w") as json_file:
|
||||
for obj in info:
|
||||
json_file.write(obj)
|
||||
|
||||
def read_jsonl(path):
|
||||
content = []
|
||||
with jsonlines.open(path, "r") as json_file:
|
||||
for obj in json_file.iter(type=dict, skip_invalid=True):
|
||||
content.append(obj)
|
||||
return content
|
Binary file not shown.
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@ -0,0 +1,262 @@
|
||||
AStockBasicInfoDB.LC_StockArchives.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockBasicInfoDB.LC_StockArchives.State=ConstantDB.LC_AreaCode.AreaInnerCode
|
||||
AStockBasicInfoDB.LC_StockArchives.CityCode=ConstantDB.LC_AreaCode.AreaInnerCode
|
||||
AStockBasicInfoDB.LC_StockArchives.RegArea=ConstantDB.LC_AreaCode.AreaInnerCode
|
||||
AStockBasicInfoDB.LC_Business.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockIndustryDB.LC_ExgIndustry.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockIndustryDB.LC_COConcept.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockIndustryDB.LC_COConcept.ConceptCode=AStockIndustryDB.LC_ConceptList.ConceptCode
|
||||
AStockOperationsDB.LC_SuppCustDetail.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockOperationsDB.LC_SuppCustDetail.InfoSourceCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockOperationsDB.LC_SuppCustDetail.RelationType=ConstantDB.CT_SystemConst.DM
|
||||
AStockOperationsDB.LC_SuppCustDetail.RelatedPartyCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockOperationsDB.LC_SuppCustDetail.RelatedPartyAttribute=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SHTypeClassifi.SHAttribute=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SHTypeClassifi.FirstLvCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SHTypeClassifi.SecondLvCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SHTypeClassifi.ThirdLvCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SHTypeClassifi.FourthLvCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_MainSHListNew.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_MainSHListNew.InfoTypeCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SHNumber.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_Mshareholder.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_Mshareholder.BulletinType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Mshareholder.SHAttribute=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Mshareholder.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Mshareholder.GDID=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockShareholderDB.LC_ActualController.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_ActualController.ControllerCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockShareholderDB.LC_ActualController.EconomicNature=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ActualController.ControllerNature=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareStru.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_ShareStru.ChangeType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_StockHoldingSt.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockShareholderDB.LC_StockHoldingSt.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_ShareTransfer.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_ShareTransfer.TranShareType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareTransfer.TranMode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareTransfer.ReceiverAttribute=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareFP.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_ShareFP.TypeSelect=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareFP.SHAttribute=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareFP.ReceiverAttribute=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ShareFPSta.Category=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Buyback.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_Buyback.ShareType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Buyback.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Buyback.BuybackModeCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_Buyback.BuybackPurpose=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_BuybackAttach.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_LegalDistribution.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockShareholderDB.LC_LegalDistribution.DistributionReason=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_LegalDistribution.SecuCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockShareholderDB.LC_LegalDistribution.DistributeNature=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_LegalDistribution.InvestorType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_LegalDistribution.AquirerType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_NationalStockHoldSt.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockShareholderDB.LC_NationalStockHoldSt.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_NationalStockHoldSt.SHID=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockShareholderDB.CS_ForeignHoldingSt.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockFinanceDB.LC_AShareSeasonedNewIssue.UnderwritingMode=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_AShareSeasonedNewIssue.ChangeType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_AShareSeasonedNewIssue.EventProcedureCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_AShareSeasonedNewIssue.IssueType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_AShareSeasonedNewIssue.SubscribeMethod=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_AShareSeasonedNewIssue.LargeSHSubMethod=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_ASharePlacement.SchemeChange=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_ASharePlacement.IssueMethod=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_ASharePlacement.EventProcedureCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_Dividend.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockFinanceDB.LC_Dividend.DiviObject=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_Dividend.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_Dividend.SchemeType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CapitalInvest.RaisingMethod=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CapitalInvest.IfSwitched=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CapitalInvest.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockFinanceDB.LC_CapitalInvest.PurchaseType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CapitalInvest.Relationship=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CapitalInvest.TransferorNature=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CapitalInvest.TargetNature=ConstantDB.CT_SystemConst.DM
|
||||
AStockMarketQuotesDB.CS_StockCapFlowIndex.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockMarketQuotesDB.CS_TurnoverVolTecIndex.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockMarketQuotesDB.CS_TurnoverVolTecIndex.SecuMarket=ConstantDB.CT_SystemConst.DM
|
||||
AStockMarketQuotesDB.CS_StockPatterns.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockMarketQuotesDB.QT_DailyQuote.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockMarketQuotesDB.QT_StockPerformance.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockMarketQuotesDB.LC_SuspendResumption.InfoSource=ConstantDB.CT_SystemConst.DM
|
||||
AStockMarketQuotesDB.LC_SuspendResumption.SuspendStatement=ConstantDB.CT_SystemConst.DM
|
||||
AStockMarketQuotesDB.LC_SuspendResumption.SuspendType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_BalanceSheetAll.InfoSource=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_BalanceSheetAll.BulletinType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_BalanceSheetAll.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockFinanceDB.LC_BalanceSheetAll.IfAdjusted=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_BalanceSheetAll.IfMerged=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_IncomeStatementAll.BulletinType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_IncomeStatementAll.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockFinanceDB.LC_IncomeStatementAll.IfAdjusted=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_IncomeStatementAll.IfComplete=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CashFlowStatementAll.BulletinType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CashFlowStatementAll.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockFinanceDB.LC_CashFlowStatementAll.IfAdjusted=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CashFlowStatementAll.IfMerged=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_CashFlowStatementAll.EnterpriseType=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockFinanceDB.LC_IntAssetsDetail.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockFinanceDB.LC_IntAssetsDetail.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockFinanceDB.LC_IntAssetsDetail.InfoSourceCode=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_MainOperIncome.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockFinanceDB.LC_MainOperIncome.Classification=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_OperatingStatus.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockFinanceDB.LC_AuditOpinion.InstiBelongedCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockFinanceDB.LC_AuditOpinion.OpinionType=ConstantDB.CT_SystemConst.DM
|
||||
AStockFinanceDB.LC_AuditOpinion.AuditReportsType=ConstantDB.CT_SystemConst.DM
|
||||
AStockOperationsDB.LC_Staff.MergeMark=ConstantDB.CT_SystemConst.DM
|
||||
AStockOperationsDB.LC_Staff.ClassfiedMethod=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockEventsDB.LC_Warrant.EventSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.ActionWays=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.SubjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_Warrant.SubjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.ObjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_Warrant.ObjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.GuarantorAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.SecuredPartyAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.CGuarantorAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Warrant.DischargeGuaranteeWays=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.EventSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.ActionWays=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.SubjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_Credit.SubjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.ObjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_Credit.ObjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.LoanCondition=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.BorrowerAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.LenderAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Credit.GuarantorAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockEventsDB.LC_SuitArbitration.AnnouncementType=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.EventSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.ActionWays=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.SubjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.ObjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.PlaintiffAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.DefendantAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.JSRPartyAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.OtherPartyAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.SubjectMatter=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.EventSubjectRole=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.CaseStatus=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.FirstInstanceStatus=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.SecondInstanceStatus=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.SPPStatus=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_SuitArbitration.PropertyEnforcement=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_EntrustInv.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockEventsDB.LC_EntrustInv.AnnouncementType=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_EntrustInv.EventSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_EntrustInv.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_EntrustInv.SubjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_EntrustInv.SubjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_EntrustInv.ObjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockEventsDB.LC_Regroup.AnnouncementType=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.EventSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.ActionWays=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.SubjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_Regroup.SubjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.ObjectCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockEventsDB.LC_Regroup.ObjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_Regroup.EventType=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockEventsDB.LC_MajorContract.BulletinType=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.EventSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.ActionWays=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.CurrencyUnit=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.SubjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.ObjectAssociation=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_MajorContract.ContractWay=ConstantDB.CT_SystemConst.DM
|
||||
AStockEventsDB.LC_InvestorRa.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockEventsDB.LC_InvestorRa.FileType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ESOP.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
AStockShareholderDB.LC_ESOP.Process=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ESOP.IfPeriod=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ESOPSummary.Process=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_ESOPSummary.IfPeriod=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_TransferPlan.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_TransferPlan.PromiseSubject=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_TransferPlan.IfEffected=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_TransferPlan.EventProcedure=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_TransferPlan.TransferPlanType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_TransferPlan.TradeType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SMAttendInfo.CompanyCode=ConstantDB.SecuMain.CompanyCode
|
||||
AStockShareholderDB.LC_SMAttendInfo.IfEffected=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SMAttendInfo.MeetingType=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SMAttendInfo.VotingMeans=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SMAttendInfo.NetVotingPlatform=ConstantDB.CT_SystemConst.DM
|
||||
AStockShareholderDB.LC_SMAttendInfo.LawOfficeCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
AStockShareholderDB.LC_SMAttendInfo.AttendanceType=ConstantDB.CT_SystemConst.DM
|
||||
HKStockDB.HK_EmployeeChange.InnerCode=ConstantDB.HK_SecuMain.InnerCode
|
||||
HKStockDB.HK_EmployeeChange.InfoSource=ConstantDB.CT_SystemConst.DM
|
||||
HKStockDB.HK_StockArchives.RegAbbr=ConstantDB.CT_SystemConst.DM
|
||||
HKStockDB.HK_StockArchives.CompanyType=ConstantDB.CT_SystemConst.DM
|
||||
HKStockDB.HK_StockArchives.RegCapitalCurrency=ConstantDB.CT_SystemConst.DM
|
||||
USStockDB.US_CompanyInfo.CompanyType=ConstantDB.CT_SystemConst.DM
|
||||
USStockDB.US_CompanyInfo.RegCountry=ConstantDB.LC_AreaCode.AreaInnerCode
|
||||
USStockDB.US_CompanyInfo.IfHeadOffice=ConstantDB.CT_SystemConst.DM
|
||||
USStockDB.US_CompanyInfo.CountryCode=ConstantDB.LC_AreaCode.AreaInnerCode
|
||||
USStockDB.US_CompanyInfo.EstablishmentDatePreci=ConstantDB.CT_SystemConst.DM
|
||||
USStockDB.US_DailyQuote.InnerCode=ConstantDB.US_SecuMain.InnerCode
|
||||
PublicFundDB.MF_FundArchives.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
PublicFundDB.MF_FundArchives.ExApplyingMarket=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.Type=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.FundNature=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.InvestmentType=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.InvestStyle=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.FundTypeCode=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.ExProfitDistri=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.OTCProfitDistri=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.FloatType=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.CarryOverDate=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.CarryOverType=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.InvestAdvisorCode=PublicFundDB.MF_InvestAdvisorOutline.InvestAdvisorCode
|
||||
PublicFundDB.MF_FundArchives.RegInstCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
PublicFundDB.MF_FundArchives.DeliveryDays=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.CustodyMarket=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.IfPensionTarget=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundArchives.IfFOF=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundProdName.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
PublicFundDB.MF_FundProdName.InfoType=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_FundProdName.IfEffected=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_InvestAdvisorOutline.InvestAdvisorCode=InstitutionDB.LC_InstiArchive.CompanyCode
|
||||
PublicFundDB.MF_InvestAdvisorOutline.OrganizationForm=ConstantDB.CT_SystemConst.DM
|
||||
PublicFundDB.MF_Dividend.InnerCode=ConstantDB.SecuMain.InnerCode
|
||||
PublicFundDB.MF_Dividend.EndDate=PublicFundDB.MF_Dividend.ProfitDistDate
|
||||
IndexDB.LC_IndexBasicInfo.IndexCode=ConstantDB.SecuMain.InnerCode
|
||||
IndexDB.LC_IndexBasicInfo.IndustryStandard=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexBasicInfo.WAMethod=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexBasicInfo.IndexType=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexBasicInfo.PubIndexType=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexBasicInfo.IndexSeries=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexBasicInfo.SecuMarket=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexBasicInfo.ComponentAdPeriod=ConstantDB.CT_SystemConst.DM
|
||||
IndexDB.LC_IndexComponent.IndexInnerCode=ConstantDB.SecuMain.InnerCode
|
||||
IndexDB.LC_IndexComponent.SecuInnerCode=ConstantDB.SecuMain.InnerCode
|
||||
IndexDB.LC_IndexComponent.SecuMarket=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.SecuMain.CompanyCode=PublicFundDB.MF_FundArchives.InvestAdvisorCode
|
||||
ConstantDB.SecuMain.SecuMarket=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.SecuMain.SecuCategory=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.SecuMain.ListedSector=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.HK_SecuMain.SecuCategory=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.LC_AreaCode.SecondLevelCode=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.US_SecuMain.SecuCategory=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.US_SecuMain.SecuMarket=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.US_SecuMain.ListedSector=ConstantDB.CT_SystemConst.DM
|
||||
ConstantDB.US_SecuMain.ListedState=ConstantDB.CT_SystemConst.DM
|
||||
InstitutionDB.PS_NewsSecurity.EventType=InstitutionDB.PS_EventStru.EventCode
|
File diff suppressed because it is too large
Load Diff
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,5 @@
|
||||
{
|
||||
"fileData": {
|
||||
"questionFilePath": "/app/devlop_data/question.json"
|
||||
}
|
||||
}
|
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,6 @@
|
||||
jieba
|
||||
zhipuai
|
||||
pandas
|
||||
openpyxl
|
||||
requests
|
||||
jsonlines
|
@ -0,0 +1,30 @@
|
||||
# coding=utf-8
|
||||
from config import *
|
||||
from agent.brain import main_answer
|
||||
import time
|
||||
import json
|
||||
import sys
|
||||
|
||||
if __name__ == "__main__":
|
||||
'''
|
||||
online devlop
|
||||
'''
|
||||
in_param_path = sys.argv[1]
|
||||
out_path = sys.argv[2]
|
||||
|
||||
try:
|
||||
main_start_time = time.time()
|
||||
with open(in_param_path, 'r') as load_f:
|
||||
input_params = json.load(load_f)
|
||||
questionFile = input_params["fileData"]["questionFilePath"]
|
||||
# 读取问题文件
|
||||
with open(questionFile, 'r') as load_f:
|
||||
q_json_list = json.load(load_f)
|
||||
|
||||
idx_ranges = [(0,100)]
|
||||
results = main_answer(q_json_list, out_path, idx_ranges)
|
||||
main_elapsed_time = time.time() - main_start_time
|
||||
print(f"Completed main in {main_elapsed_time:.2f} seconds")
|
||||
except Exception as e:
|
||||
print("Error: %s" % e)
|
||||
sys.exit(1)
|
File diff suppressed because it is too large
Load Diff
Loading…
Reference in new issue