liurui/PriceForecast
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更改配置

Browse Source
This commit is contained in:
workpc 2024-12-30 16:11:58 +08:00
parent 8b8ff714e6
commit d07669e0ee
4 changed files with 9 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
config_jingbo.py
View File

@ -290,10 +290,6 @@ upload_warning_url = "http://192.168.100.115:9090/dom-api/api/basicBuiness/crude
query_data_list_item_nos_url = "http://192.168.100.115:9090/dom-api/api/warehouse/dwDataItem/queryDataListItemNos"
login_data = {
"data": {
"account": "api-dev",
@ -462,8 +458,3 @@ logger.addHandler(console_handler)
# logger.info('当前配置：'+settings)
if __name__ == '__main__':
import pandas as pd
df1 = pd.read_excel(os.path.join(dataset,'数据项下载.xls'),header=5, names=['numid','date', 'Brentzdj', 'Brentzgj'])
print(df1)

6
config_yongan.py
View File

@ -136,7 +136,6 @@ upload_data = {
"smartBusinessClassCode":'1', #分析报告分类编码
"reportEmployeeCode":"U270018", # 报告人
"reportDeptCode" :"D270001" ,# 报告部门
# "reportDeptCode" :"000001" ,# 报告部门
"productGroupCode":"RAW_MATERIAL" # 商品分类
}
}
@ -280,8 +279,3 @@ logger.addHandler(console_handler)
# logger.info('当前配置：'+settings)
if __name__ == '__main__':
import pandas as pd
df1 = pd.read_excel(os.path.join(dataset,'数据项下载.xls'),header=5, names=['numid','date', 'Brentzdj', 'Brentzgj'])
print(df1)

3
lib/dataread.py
View File

@ -41,8 +41,7 @@ plt.rcParams['font.sans-serif'] = ['SimHei'] # 用来正常显示中文标签
plt.rcParams['axes.unicode_minus'] = False # 用来正常显示负号
# from config_jingbo_pro import *
# from config_jingbo import *
from config_yongan import *
from config_jingbo import *
# from config_juxiting import *

13
main_yuanyou.py
View File

@ -144,11 +144,14 @@ def predict_main():
logger.info(f'要更新y的信息：{update_y}')
# try:
for row in update_y.itertuples(index=False):
row_dict = row._asdict()
yy = df[df['ds']==row_dict['ds']]['y'].values[0]
LOW = df[df['ds']==row_dict['ds']]['Brentzdj'].values[0]
HIGH = df[df['ds']==row_dict['ds']]['Brentzgj'].values[0]
sqlitedb.update_data('accuracy', f"y = {yy},LOW_PRICE = {LOW},HIGH_PRICE = {HIGH}", where_condition=f"ds = '{row_dict['ds']}'")
try:
row_dict = row._asdict()
yy = df[df['ds']==row_dict['ds']]['y'].values[0]
LOW = df[df['ds']==row_dict['ds']]['Brentzdj'].values[0]
HIGH = df[df['ds']==row_dict['ds']]['Brentzgj'].values[0]
sqlitedb.update_data('accuracy', f"y = {yy},LOW_PRICE = {LOW},HIGH_PRICE = {HIGH}", where_condition=f"ds = '{row_dict['ds']}'")
except:
logger.info(f'更新accuracy表的y值失败：{row_dict}')
# except Exception as e:
# logger.info(f'更新accuracy表的y值失败：{e}')