From fc979d26ffd9c13fccc17a5e8c17d570f959086e Mon Sep 17 00:00:00 2001 From: jingboyitiji Date: Thu, 29 May 2025 10:06:19 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=9F=E6=B2=B9=E5=85=AB=E5=A4=A7=E7=BB=B4?= =?UTF-8?q?=E5=BA=A6=E5=8F=91=E7=89=88=E5=89=8D=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config_jingbo.py | 6 +- config_jingbo_yuedu.py | 6 +- config_jingbo_zhoudu.py | 2 +- config_shiyoujiao_puhuo_zhoudu.py | 195 ++++++++++++++---------------- main_shiyoujiao_puhuo_zhoudu.py | 2 +- 原油八大维度预测任务.py | 20 +-- 原油预测定时任务，请勿关闭.py | 22 ---- 石油焦铝用八大维度预测任务.py | 52 ++++++++ 聚烯烃八大维度预测任务.py | 2 +- 聚烯烃预测定时任务，请勿关闭.py | 22 ---- 10 files changed, 165 insertions(+), 164 deletions(-) delete mode 100644 原油预测定时任务，请勿关闭.py create mode 100644 石油焦铝用八大维度预测任务.py delete mode 100644 聚烯烃预测定时任务，请勿关闭.py diff --git a/config_jingbo.py b/config_jingbo.py index 56940c2..8af6963 100644 --- a/config_jingbo.py +++ b/config_jingbo.py @@ -364,9 +364,9 @@ table_name = 'v_tbl_crude_oil_warning' # 开关 -is_train = False # 是否训练 -is_debug = True # 是否调试 -is_eta = False # 是否使用eta接口 +is_train = True # 是否训练 +is_debug = False # 是否调试 +is_eta = True # 是否使用eta接口 is_market = True # 是否通过市场信息平台获取特征 ,在is_eta 为true 的情况下生效 is_timefurture = True # 是否使用时间特征 is_fivemodels = False # 是否使用之前保存的最佳的5个模型 diff --git a/config_jingbo_yuedu.py b/config_jingbo_yuedu.py index b2a3196..7942a82 100644 --- a/config_jingbo_yuedu.py +++ b/config_jingbo_yuedu.py @@ -382,9 +382,9 @@ table_name = 'v_tbl_crude_oil_warning' # 开关 -is_train = False # 是否训练 -is_debug = True # 是否调试 -is_eta = False # 是否使用eta接口 +is_train = True # 是否训练 +is_debug = False # 是否调试 +is_eta = True # 是否使用eta接口 is_market = True # 是否通过市场信息平台获取特征 ,在is_eta 为true 的情况下生效 is_timefurture = True # 是否使用时间特征 is_fivemodels = False # 是否使用之前保存的最佳的5个模型 diff --git a/config_jingbo_zhoudu.py b/config_jingbo_zhoudu.py index 5db96dc..b1c3d3b 100644 --- a/config_jingbo_zhoudu.py +++ b/config_jingbo_zhoudu.py @@ -326,7 +326,7 @@ table_name = 'v_tbl_crude_oil_warning' # 开关 is_train = True # 是否训练 -is_debug = True # 是否调试 +is_debug = False # 是否调试 is_eta = True # 是否使用eta接口 is_market = True # 是否通过市场信息平台获取特征 ,在is_eta 为true 的情况下生效 is_timefurture = True # 是否使用时间特征 diff --git a/config_shiyoujiao_puhuo_zhoudu.py b/config_shiyoujiao_puhuo_zhoudu.py index fd16269..da846e0 100644 --- a/config_shiyoujiao_puhuo_zhoudu.py +++ b/config_shiyoujiao_puhuo_zhoudu.py @@ -20,13 +20,97 @@ edbdeleteurl = 'http://10.189.2.78:8108/v1/edb/business/edb/del' edbbusinessurl = 'http://10.189.2.78:8108/v1/edb/business/data/del' edbcodenamedict = { - 'C2403283369': '预赔阳极加工利润（高端）', - 'C2403285560': '预培阳极加工利润（低端）', - 'C2403288616': '低硫石油焦煅烧利润', - 'S6949656': '平均价：氧化铝：一级：全国', - 'S5807052': '氧化铝：一级：贵阳', - 'S5443355': '市场价：煤沥青：河北地区', - 'S5443357': '市场价：煤沥青：山西地区', + 'C2403287411': '华北高硫焦与等热值动力煤价格对比', + 'C2403282801': '华东高硫焦与等热值动力煤价格对比', + 'ID00150321': '石油焦：2 # A：市场低端价：山东（日）', + 'ID00150329': '石油焦：2 # A：市场主流价：山东（日）', + 'ID00150325': '石油焦：2 # A：市场高端价：山东（日）', + 'ID00150333': '石油焦：2 # B：市场低端价：山东（日）', + 'ID00150357': '石油焦：2 # B：市场主流价：山东（日）', + 'ID00150345': '石油焦：2 # B：市场高端价：山东（日）', + 'ID01101276': '高硫焦：4B：出厂价：山东：青岛炼化（日）', + 'ID00150417': '石油焦：高硫焦：市场低端价：华北地区（日）', + 'ID00150425': '石油焦：高硫焦：市场低端价：华南地区（日）', + 'ID00150437': '石油焦：高硫焦：市场高端价：华北地区（日）', + 'ID00150441': '石油焦：高硫焦：市场高端价：华东地区（日）', + 'ID00150445': '石油焦：高硫焦：市场高端价：华南地区（日）', + 'ID00150449': '石油焦：高硫焦：市场高端价：西北地区（日）', + 'ID00150453': '石油焦：高硫焦：市场高端价：西南地区（日）', + 'ID01300358': '石油焦：3 # C：市场低端价：山东（日）', + 'ID01300357': '石油焦：3 # C：市场高端价：山东（日）', + 'ID00150377': '石油焦：3 # ：市场主流价：华中地区（日）', + 'ID01387678': '煅烧焦：中硫：3 % S：市场价：华中地区（日）', + 'ID01387656': '煅烧焦：中硫：3 % S：市场价：山东（日）', + 'ID00150381': '石油焦：3 # A：市场低端价：山东（日）', + 'ID00150397': '石油焦：3 # B：市场低端价：山东（日）', + 'ID00150405': '石油焦：3 # B：市场高端价：山东（日）', + 'ID00150429': '石油焦：高硫焦：市场低端价：西北地区（日）', + 'ID00150433': '石油焦：高硫焦：市场低端价：西南地区（日）', + 'ID00150457': '石油焦：高硫焦：市场主流价：华北地区（日）', + 'ID00150461': '石油焦：高硫焦：市场主流价：华东地区（日）', + 'ID00150465': '石油焦：高硫焦：市场主流价：华南地区（日）', + 'ID00150469': '石油焦：高硫焦：市场主流价：西北地区（日）', + 'ID00150473': '石油焦：高硫焦：市场主流价：西南地区（日）', + 'ID00150421': '石油焦：高硫焦：市场低端价：华东地区（日）', + 'B3e90b34e4b9e7a6ea3': '石油焦市场均价(元/吨)', + 'B8a0ab5357569c385a9': '石油焦海绵焦市场均价(元/吨)', + 'B8a920b59fe7effd116': '石油焦4 # -5#市场均价(元/吨)', + 'B81e66c7dc542809035': '石油焦海绵焦华东高硫焦（低端）(元/吨)（百川）', + 'B6fc631d20e277ce496': '石油焦海绵焦华东高硫焦（高端）(元/吨)（百川）', + 'Be9ed3ebd44ad291a3c': '石油焦海绵焦华南高硫焦（低端）(元/吨)（百川）', + 'B347350473783e640dc': '石油焦海绵焦华南高硫焦（高端）(元/吨)（百川）', + 'B7acab268ac4a419f77': '煅烧焦华北中硫(低端S < 3.0，普货)(元/吨)', + 'Beecfb2678481997f68': '煅烧焦山东中硫(高端S < 3.0，普货)(元/吨)', + 'B4bc4d186dc0f7d6d96': '煅烧焦华中中硫(高端S < 3.0，普货)(元/吨)', + 'B46cc7d0a90155b5bfd': '煅烧焦山东高硫(高端S < 3.5，普货)(元/吨)', + 'B4501068048575cd6f1': '煅烧焦西北高硫(S < 4.0，普货)(元/吨)', + 'Bfccb234f4c4e047314': '煅烧焦中硫普货市场均价(硫 < 3.0 %)(元/吨)', + 'B1133e458cc493d7728': '煅烧焦高硫普货市场均价(元/吨)（百川）', + 'B185a597decfc71915a': '预焙阳极山东低端(元/吨)（百川）', + 'B16b98ff5f959dfdcad': '负极材料市场参考价(元/吨)（百川）', + 'B7ce1371e09479bee56': '人造石墨负极材料中端(元/吨)', + 'Bab0904b23e968a3068': '天然石墨负极材料中端(元/吨)', + 'B180e67aaa174414553': '中间相碳微球负极材料高端(元/吨)', + 'B41c03de42ea84d5c2f': '中间相碳微球负极材料中端(元/吨)', + 'B5c3b60680b7bbd92af': '负极材料石墨化国内低端价(元/吨)', + 'B1bcde6130de031bd42': '山西 改质沥青(元/吨)', + 'Bb9f4a1f6dd32b4ad8a': '山东 改质沥青(元/吨)', + 'C2411261557491549': '石油焦市场均价(元/吨)/4DMA', + 'C2411271143174617': '石油焦市场均价(元/吨)/9DMA', + 'RE00010074': '煅烧焦：中硫焦：生产毛利：山东（周）', + 'B9d1acaf80383683da3': '石油焦总产量（周）(吨)', + 'Bdaa719a38936c8dd76': '石油焦开工率（周）(% )', + 'B9459d549a332b200e7': '石油焦行业总库存（周）(吨)', + 'Bce6e098b9518370cff': '石油焦工厂库存（周）(吨)', + 'B577ce2809772779710': '石油焦市场库存（周）(吨)', + 'B5d8c564c62f3e6b77f': '石油焦成本（周）(吨)', + 'B43baa98bcaa06c11a5': '石油焦利润（周）(吨)', + 'Bdd0c1361d94081211c': '煅烧石油焦总产量（周）(吨)', + 'B65315111fa28951b1e': '煅烧石油焦开工率（周）(% )', + 'B2aff5f2632a20027d0': '煅烧石油焦行业总库存（周）(吨)', + 'B29fbd31128cd71b212': '煅烧石油焦工厂库存（周）(吨)', + 'B7a88313a89d1261c53': '煅烧石油焦成本（周）(吨)', + 'Bd4fa36b4decec0aafa': '煅烧石油焦利润（周）(吨)', + 'B9bd80eac7df81ffbd4': '预焙阳极总产量（周）(吨)', + 'B27074786605f4660d2': '预焙阳极开工率（周）(% )', + 'Bdc2a5985ecb56b6a0c': '预焙阳极行业总库存（周）(吨)', + 'Bce8511f899e487e5b6': '预焙阳极工厂库存（周）(吨)', + 'B13ec89105bd866a2bd': '预焙阳极成本（周）(吨)', + 'B66c3abcfa15a2e611c': '预焙阳极利润（周）(吨)', + 'Ba3bcf63e6e846cd3f8': '负极材料总产量（周）(吨)', + 'B10b8f4c702b72f4ee4': '负极材料开工率（周）(% )', + 'Bc25e82dd595c5f92fc': '负极材料行业总库存（周）(吨)', + 'B0a14d1936a5e072f25': '负极材料工厂库存（周）(吨)', + 'Ba9d192464b78194a48': '负极材料成本（周）(吨)', + 'B15d62d9f48ccfa5984': '负极材料利润（周）(吨)', + 'B7478e77ca116386afd': '针状焦总产量（周）(吨)', + 'Bbe316d65258a4d47f4': '针状焦行业总库存（周）(吨)', + 'Bf036a360a5eecb591d': '针状焦工厂库存（周）(吨)', + 'Bc43a790c62aa57fc9d': '针状焦成本（周）(吨)', + 'B23ebedbb88ff412952': '针状焦利润（周）(吨)', + 'C2403286685': '黄骅港动力煤等热值', + 'C2403285171': '黄骅等热值动力煤', + 'C2403287884': '中硫石油焦煅烧利润', 'W000294': '国内主要港口石油焦出货量（隆重）', 'W000293': '日照港库存（隆重）', 'W000292': '港口总库存（隆重）', @@ -35,104 +119,9 @@ edbcodenamedict = { 'W000281': '中国石油焦产量（隆重）', 'W000280': '主营石油焦开工负荷率（隆重）', 'W000279': '地炼石油焦开工负荷率（隆重）', - 'ID00150273': '石油焦：1 # ：市场低端价：东北地区（日）', - 'ID00150281': '石油焦：1 # ：市场主流价：东北地区（日）', - 'ID00150277': '石油焦：1 # ：市场高端价：东北地区（日）', - 'ID00150289': '石油焦：2 # ：市场低端价：华东地区（日）', - 'ID00150285': '石油焦：2 # ：市场低端价：西北地区（日）', - 'ID00150313': '石油焦：2 # ：市场主流价：华东地区（日）', - 'ID00150309': '石油焦：2 # ：市场主流价：西北地区（日）', - 'ID00150301': '石油焦：2 # ：市场高端价：华东地区（日）', - 'ID00150297': '石油焦：2 # ：市场高端价：西北地区（日）', - 'ID00150321': '石油焦：2 # A：市场低端价：山东（日）', - 'ID00150329': '石油焦：2 # A：市场主流价：山东（日）', - 'ID00150325': '石油焦：2 # A：市场高端价：山东（日）', - 'ID00150337': '石油焦：2 # B：市场低端价：华南地区（日）', - 'ID00150341': '石油焦：2 # B：市场低端价：华中地区（日）', - 'ID00150361': '石油焦：2 # B：市场主流价：华南地区（日）', - 'ID00150365': '石油焦：2 # B：市场主流价：华中地区（日）', - 'ID00150349': '石油焦：2 # B：市场高端价：华南地区（日）', - 'ID00150353': '石油焦：2 # B：市场高端价：华中地区（日）', - 'ID00150333': '石油焦：2 # B：市场低端价：山东（日）', - 'ID00150357': '石油焦：2 # B：市场主流价：山东（日）', - 'ID00150345': '石油焦：2 # B：市场高端价：山东（日）', - 'ID00150369': '石油焦：3 # ：市场低端价：华中地区（日）', - 'ID00150373': '石油焦：3 # ：市场高端价：华中地区（日）', - 'ID00150385': '石油焦：3 # A：市场高端价：山东（日）', - 'ID00150393': '石油焦：3 # B：市场低端价：华东地区（日）', - 'ID00150409': '石油焦：3 # B：市场主流价：华东地区（日）', - 'ID00150401': '石油焦：3 # B：市场高端价：华东地区（日）', - 'ID00146589': '海绵焦：4 # ：出厂价：华中地区：洛阳石化（日）', - 'ID01242846': '石油焦：4 # B：挂牌价：华北地区：中石化燕山（日）', - 'ID01300358': '石油焦：3 # C：市场低端价：山东（日）', - 'ID01300357': '石油焦：3 # C：市场高端价：山东（日）', - 'ID00150377': '石油焦：3 # ：市场主流价：华中地区（日）', - 'ID01387643': '煅烧焦：低硫：0.5 % S：市场价：东北地区（日）', - 'ID01387646': '煅烧焦：低硫：3.5 % S：市场价：东北地区（日）', - 'ID01387660': '煅烧焦：中硫：3 % S，400V：市场价：山东（日）', - 'ID00150381': '石油焦：3 # A：市场低端价：山东（日）', - 'ID00150397': '石油焦：3 # B：市场低端价：山东（日）', - 'ID00150405': '石油焦：3 # B：市场高端价：山东（日）', - 'ID00146545': '海绵焦：3B：出厂价：山东：山东东明（日）', - 'B3e90b34e4b9e7a6ea3': '石油焦市场均价(元/吨)', - 'B6b5c53b270a3af12ac': '石油焦1 # 市场均价(元/吨)', - 'B10721189a11c209a20': '石油焦2 # 市场均价(元/吨)', - 'B6accfa9d2bf4735a50': '石油焦3 # 市场均价(元/吨)', - 'B8a0ab5357569c385a9': '石油焦海绵焦市场均价(元/吨)', - 'B19dcf45e22fbfd3e43': '石油焦海绵焦东北1 # A焦（低端）(元/吨)（百川）', - 'B5832a62d1e0fba50b6': '石油焦海绵焦东北1 # A焦（高端）(元/吨)（百川）', - 'B1de4fba026d4609cc7': '石油焦海绵焦东北1 # B焦（低端）(元/吨)（百川）', - 'B38f89180736172490d': '石油焦海绵焦东北1 # B焦（高端）(元/吨)（百川）', - 'B4f847871674c3d77f2': '石油焦海绵焦山东地炼1 # -3#焦（低端）(元/吨)', - 'B1aefb8a64a5200adbd': '石油焦海绵焦山东地炼1 # -3#焦（高端）(元/吨)', - 'B1df7d0afbfedfb628a': '煅烧焦东北低硫(高端S < 0.5)(元/吨)', - 'B5f8f9859635876da28': '煅烧焦东北低硫(低端S < 0.5)(元/吨)', - 'B2342a8c5a39fa00348': '煅烧焦华北中硫(高端S < 3.0，钒 < 400)(元/吨)', - 'B051f27900397c6a35f': '煅烧焦山东中硫(高端S < 3.0，钒 < 400)(元/吨)', - 'Be2a8050a48e86cae1f': '煅烧焦华东中硫(高端S < 3.0，钒 < 400)(元/吨)', - 'B4a1811938f85065f6a': '煅烧焦华中中硫(高端S < 3.0，钒 < 400)(元/吨)', - 'Bc197d4834ef7fb98ec': '煅烧焦华东高硫(高端S < 3.5，钒 < 400)(元/吨)', - 'B62be5dbdb8c6454530': '煅烧焦低硫参考价格(元/吨)（百川）', - 'Bdd813140bffc4edfa6': '煅烧焦中硫微量市场均价(元/吨)（百川）', - 'B185a597decfc71915a': '预焙阳极山东低端(元/吨)（百川）', - 'B1bcde6130de031bd42': '山西 改质沥青(元/吨)', - 'Bb9f4a1f6dd32b4ad8a': '山东 改质沥青(元/吨)', - 'C2411261557491549': '石油焦市场均价(元/吨)/4DMA', - 'C2411271143174617': '石油焦市场均价(元/吨)/9DMA', - 'ID01387649': '煅烧焦：中硫：3 % S，350V：市场价：华东地区（日）', - 'ID01387655': '煅烧焦：中硫：3 % S，350V：市场价：山东（日）', - 'RE00010076': '煅烧焦：低硫：生产毛利：东北地区（周）', - 'B9d1acaf80383683da3': '石油焦总产量（周）(吨)', - 'Bdaa719a38936c8dd76': '石油焦开工率（周）( % )', - 'B9459d549a332b200e7': '石油焦行业总库存（周）(吨)', - 'Bce6e098b9518370cff': '石油焦工厂库存（周）(吨)', - 'B577ce2809772779710': '石油焦市场库存（周）(吨)', - 'B5d8c564c62f3e6b77f': '石油焦成本（周）(吨)', - 'B43baa98bcaa06c11a5': '石油焦利润（周）(吨)', - 'Bdd0c1361d94081211c': '煅烧石油焦总产量（周）(吨)', - 'B65315111fa28951b1e': '煅烧石油焦开工率（周）( % )', - 'B2aff5f2632a20027d0': '煅烧石油焦行业总库存（周）(吨)', - 'B29fbd31128cd71b212': '煅烧石油焦工厂库存（周）(吨)', - 'B7a88313a89d1261c53': '煅烧石油焦成本（周）(吨)', - 'Bd4fa36b4decec0aafa': '煅烧石油焦利润（周）(吨)', - 'B9bd80eac7df81ffbd4': '预焙阳极总产量（周）(吨)', - 'B27074786605f4660d2': '预焙阳极开工率（周）( % )', - 'Bdc2a5985ecb56b6a0c': '预焙阳极行业总库存（周）(吨)', - 'Bce8511f899e487e5b6': '预焙阳极工厂库存（周）(吨)', - 'B13ec89105bd866a2bd': '预焙阳极成本（周）(吨)', - 'B66c3abcfa15a2e611c': '预焙阳极利润（周）(吨)', - 'Bf7efe3200f9abc0453': '电解铝开工率（周）( % )', - 'Be193166f347267b1a7': '电解铝行业总库存（周）(吨)', - 'Baa744fc97769353175': '电解铝工厂库存（周）(吨)', - 'Bf9654603913cfc5282': '电解铝市场库存（周）(吨)', - 'Bef1535c96da0d70fbc': '电解铝利润（周）(吨)', - 'B7d1d0b24316d49cbdc': '煤沥青总产量（周）(吨)', - 'B4303fb002ea1c214da': '煤沥青开工率（周）( % )', - 'Be9a470c97e9efe660c': '煤沥青行业总库存（周）(吨)', - 'B50d4d87f6b78bca587': '煤沥青工厂库存（周）(吨)', - 'B46cc7d0a90155b5bfd': '煅烧焦山东高硫(高端S < 3.5，普货)(元/吨)' } + edbcodelist = edbcodenamedict.keys() # 临时写死用指定的列,与上面的edbcode对应，后面更改 edbnamelist = ['ds', 'y']+[edbcodenamedict[edbcodename] diff --git a/main_shiyoujiao_puhuo_zhoudu.py b/main_shiyoujiao_puhuo_zhoudu.py index f500bf4..0156822 100644 --- a/main_shiyoujiao_puhuo_zhoudu.py +++ b/main_shiyoujiao_puhuo_zhoudu.py @@ -1,7 +1,7 @@ # 读取配置 from lib.dataread import * -from config_shiyoujiao_lvyong_zhoudu import * +from config_shiyoujiao_puhuo_zhoudu import * from lib.tools import SendMail, exception_logger from models.nerulforcastmodels import ex_Model, model_losss, shiyoujiao_lvyong_export_pdf import datetime diff --git a/原油八大维度预测任务.py b/原油八大维度预测任务.py index b452cde..bf6e96b 100644 --- a/原油八大维度预测任务.py +++ b/原油八大维度预测任务.py @@ -16,8 +16,9 @@ def run_predictions(target_date): # 依次执行每个脚本 for script in scripts: - # command = [r"C:\Users\Hello\.conda\envs\predict\python", script] - command = [r"C:\Users\EDY\.conda\envs\predict\python", script] + # command = [r"C:\Users\EDY\.conda\envs\predict\python", script] + command = [r"C:/Users/Hello/.conda/envs/jaigeyuce/python.exe", script] #yitijipc + subprocess.run(command, check=True) @@ -27,9 +28,9 @@ def is_weekday(date): if __name__ == "__main__": - start_date = datetime.date(2025, 2, 1) + # start_date = datetime.date(2025, 2, 1) # 开始时间取当前时间 - # start_date = datetime.date.today() + start_date = datetime.date.today() end_date = datetime.date(2025, 3, 31) current_date = start_date @@ -47,7 +48,10 @@ if __name__ == "__main__": # current_date += datetime.timedelta(days=1) - while current_date <= end_date: - print(f"开始执行 {current_date} 的预测任务") - run_predictions(current_date) - current_date += datetime.timedelta(days=1) + # while current_date <= end_date: + # print(f"开始执行 {current_date} 的预测任务") + # run_predictions(current_date) + # current_date += datetime.timedelta(days=1) + + print(f"开始执行 {current_date} 的预测任务") + run_predictions(current_date) \ No newline at end of file diff --git a/原油预测定时任务，请勿关闭.py b/原油预测定时任务，请勿关闭.py deleted file mode 100644 index 41341c2..0000000 --- a/原油预测定时任务，请勿关闭.py +++ /dev/null @@ -1,22 +0,0 @@ -# 定时执行cmd命令 - -import time -import os -while True: - try: - print(time.strftime('%H:%M')) - # 判断是不是工作日且 是17：00 7：00 才执行 - if time.strftime('%A') not in ['Saturday', 'Sunday'] and time.strftime('%H:%M') in ['07:50']: - # 要执行的命令 - command = r"d:\yuanyouyuce\envs\predict\python main_yuanyou.py" - - # 调用系统命令 - os.system(command) - time.sleep(60) - except: - time.sleep(3600) - # 要执行的命令 - command = r"d:\yuanyouyuce\envs\predict\python main_yuanyou.py" - - # 调用系统命令 - os.system(command) \ No newline at end of file diff --git a/石油焦铝用八大维度预测任务.py b/石油焦铝用八大维度预测任务.py new file mode 100644 index 0000000..c8474e2 --- /dev/null +++ b/石油焦铝用八大维度预测任务.py @@ -0,0 +1,52 @@ +# 这是原油日度，周度，月度的预测，脚本 +# 遍历时间，跳过周六日，每日7点开始预测 + +import datetime +import subprocess +import time + + +def run_predictions(target_date): + """执行三个预测脚本""" + scripts = [ + "main_shiyoujiao_lvyong.py", + "main_shiyoujiao_lvyong_zhoudu.py", + "main_shiyoujiao_lvyong_yuedu.py" + ] + + # 依次执行每个脚本 + for script in scripts: + # command = [r"C:\Users\Hello\.conda\envs\predict\python", script] # liuruipc + # command = [r"C:/Users/EDY/.conda/envs/priceforecast/python.exe", script] #168pc + command = [r"C:/Users/Hello/.conda/envs/jaigeyuce/python.exe", script] #yitijipc + subprocess.run(command, check=True) + + +def is_weekday(date): + """判断是否为工作日（周一到周五）""" + return date.weekday() < 5 # 0-4 为周一到周五 + + +if __name__ == "__main__": + # start_date = datetime.date(2025, 3, 13) + # 开始时间取当前时间 + start_date = datetime.date.today() + # end_date = datetime.date(2100, 12, 31) + + current_date = start_date + # while current_date <= end_date: + # if is_weekday(current_date): + # # 等待到目标日期的7点 + # target_time = datetime.datetime.combine( + # current_date, datetime.time(13, 15)) + # while datetime.datetime.now() < target_time: + # time.sleep(60) # 每分钟检查一次 + # print(f"等待到 {target_time} 开始执行任务") + + # print(f"开始执行 {current_date} 的预测任务") + # run_predictions(current_date) + + # current_date += datetime.timedelta(days=1) + + print(f"开始执行 {current_date} 的预测任务") + run_predictions(current_date) diff --git a/聚烯烃八大维度预测任务.py b/聚烯烃八大维度预测任务.py index 9173be2..e570298 100644 --- a/聚烯烃八大维度预测任务.py +++ b/聚烯烃八大维度预测任务.py @@ -18,7 +18,7 @@ def run_predictions(target_date): for script in scripts: # command = [r"C:\Users\Hello\.conda\envs\predict\python", script] # liuruipc # command = [r"C:/Users/EDY/.conda/envs/priceforecast/python.exe", script] #168pc - command = [r"C:/Users/Hello/.conda/envs/predict/python.exe", script] #yitijipc + command = [r"C:/Users/Hello/.conda/envs/jaigeyuce/python.exe", script] #yitijipc subprocess.run(command, check=True) diff --git a/聚烯烃预测定时任务，请勿关闭.py b/聚烯烃预测定时任务，请勿关闭.py deleted file mode 100644 index a9113c6..0000000 --- a/聚烯烃预测定时任务，请勿关闭.py +++ /dev/null @@ -1,22 +0,0 @@ -# 定时执行cmd命令 - -import time -import os -while True: - try: - print(time.strftime('%H:%M')) - # 判断是不是工作日且 是17：00 7：00 才执行 - if time.strftime('%A') not in ['Saturday', 'Sunday'] and time.strftime('%H:%M') in ['16:10']: - # 要执行的命令 - command = r"d:\yuanyouyuce\envs\predict\python main_yuanyou.py" - - # 调用系统命令 - os.system(command) - time.sleep(60) - except: - time.sleep(3600) - # 要执行的命令 - command = r"d:\yuanyouyuce\envs\predict\python main_juxiting.py" - - # 调用系统命令 - os.system(command) \ No newline at end of file