From bb0b70fa447ef1dd1ce11cf5a8e48b7b5f5bfea7 Mon Sep 17 00:00:00 2001 From: jackyu66git Date: Fri, 25 Apr 2025 21:39:24 +0800 Subject: [PATCH] add more files --- .DS_Store | Bin 6148 -> 6148 bytes ChanKLU.py | 18 +- ChanLun.py | 52 ++- ChanLun_Classifier.py | 92 ++++- __pycache__/ChanKLU.cpython-312.pyc | Bin 2593 -> 2984 bytes __pycache__/ChanLun.cpython-312.pyc | Bin 112036 -> 113712 bytes .../ChanLun_Classifier.cpython-312.pyc | Bin 17001 -> 19498 bytes strategies/ChanLun_SOL_15.py | 356 ++++++++++++++++++ strategies/ChanLun_SOL_5.py | 56 +-- web/app.py | 19 +- web/requirements.txt | 18 +- web/templates/index.html | 284 +++++++++++--- 12 files changed, 787 insertions(+), 108 deletions(-) create mode 100644 strategies/ChanLun_SOL_15.py diff --git a/.DS_Store b/.DS_Store index 6cd3efbfbdcb01df3ab8c2d15aee50b6d5fa35ec..dafb576df815a2de5f4d50797d6396679e564498 100644 GIT binary patch delta 14 VcmZoMXffDuj){?R^LZvyQ2-}#1i1hJ delta 14 VcmZoMXffDuj){?B^LZvyQ2-}v1h@bI diff --git a/ChanKLU.py b/ChanKLU.py index 681672c..be68190 100644 --- a/ChanKLU.py +++ b/ChanKLU.py @@ -21,15 +21,15 @@ class ChanKLU: def set_idx(self, idx): self.idx = idx self.index = idx - def set_indicators(self, dict): - self.macd = dict['macd'] - self.signal = dict['macdsignal'] - self.macdhist = dict['macdhist'] - self.ma5 = dict['ma5'] - self.ma10 = dict['ma10'] - self.ma30 = dict['ma30'] - self.ma250 = dict['ma250'] - self.rsi = dict['rsi'] + def set_indicators(self, item): + self.macd = float(item['macd']) if item['macd'] else 0 + self.signal = float(item['macdsignal']) if item['macdsignal'] else 0 + self.macdhist = float(item['macdhist']) if item['macdhist'] else 0 + self.ma5 = float(item['ma5']) if item['ma5'] else 0 + self.ma10 = float(item['ma10']) if item['ma10'] else 0 + self.ma30 = float(item['ma30']) if item['ma30'] else 0 + self.ma250 = float(item['ma250']) if item['ma250'] else 0 + self.rsi = float(item['rsi']) if item['rsi'] else 0 def get_feature_data(self): features = dict() features['klu_close'] = self.close diff --git a/ChanLun.py b/ChanLun.py index d134eef..f9e9c39 100644 --- a/ChanLun.py +++ b/ChanLun.py @@ -142,14 +142,28 @@ class ChanLun(): bi_list = self.cal_bi_list(klc_list) klc_index = 0 state_list = [] + bi_dir_list = [] for index in range(0, len(dataframe)): klc = klc_list[klc_index] + if klc.bi and klc.bi.dir == Chan_BI_DIR.UP: + bi_dir_list.append(1) + else: + bi_dir_list.append(-1) if klc.end_klu and klc.end_klu.idx == index: + klc.set_state("00") + if klc.klc_fx_type == Chan_KLC_FX.BOTTOM1: + klc.set_state("10") + elif klc.klc_fx_type == Chan_KLC_FX.TOP1: + klc.set_state("-10") + elif klc.klc_fx_type == Chan_KLC_FX.BOTTOM2: + klc.set_state("20") + elif klc.klc_fx_type == Chan_KLC_FX.TOP2: + klc.set_state("-20") state_list.append(klc.state) klc_index += 1 else: state_list.append("00") - return state_list + return state_list, bi_dir_list def get_bi_list(self, dataframe): bi_list = self.cal_bi_list(self.get_klc_list(dataframe)) return bi_list @@ -180,12 +194,24 @@ class ChanLun(): klu = ChanKLU(time_str, o, h, l, c, v) klu.set_idx(i) klu_list.append(klu) - if True: + if 'macd' in item: klu.set_indicators(item) return klu_list + def cal_volume_ratio(self, dataframe, window=10): + df = dataframe.copy() + # 计算过去N根K线的平均成交量 + df['avg_volume'] = df['volume'].rolling(window=window).mean() + # 计算量比 + df['volume_ratio'] = df['volume'] / df['avg_volume'] + # 填充缺失值（前N根K线） + df['volume_ratio'] = df['volume_ratio'].fillna(1.0) + return df['volume_ratio'] def calculate_zs(self, bi_list, seg_list): return self.get_zs_list(bi_list, seg_list) - + def get_full_klc_list(self, dataframe): + klc_list = self.get_klc_list(dataframe) + bi_list = self.cal_bi_list(klc_list) + return klc_list def get_seg_list(self, bi_list): seg_list = [] up_bi_list = [] @@ -573,7 +599,7 @@ class ChanLun(): # Second top lower to be second sell point if last_top.high > klc.high: #klc.set_fx(Chan_FX_TYPE.TT) - klc.set_state("20") + #klc.set_state("20") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) #print(klc.start_time, klc.fx, "二类卖点Sell 1") @@ -585,7 +611,7 @@ class ChanLun(): klc.set_klc_fx_type(Chan_KLC_FX.TOP1) #print(klc.start_time, klc.fx, "一类卖点Sell 1") #klc.set_fx(fx) - klc.set_state("10") + #klc.set_state("10") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) else: @@ -634,7 +660,7 @@ class ChanLun(): last_top = klc #print(klc.start_time, klc.fx, bi_list[-1].dir, "Last Top Change 2") klc.set_klc_fx_type(Chan_KLC_FX.TOP2) - klc.set_state('30') + #klc.set_state('30') bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) #print(klc.start_time, last_bottom.start_time, "Normal TOP Found, Confirm down bi 4") @@ -652,7 +678,7 @@ class ChanLun(): #print(klc.start_time, klc.fx, "笔卖点Sell 3") else: klc.set_fx(Chan_FX_TYPE.TT) - klc.set_state('20') + #klc.set_state('20') #print(klc.start_time, klc.fx, "二类卖点Sell 2") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) @@ -691,7 +717,7 @@ class ChanLun(): # Second bottom uppper to be second buy point and confirm last bi if last_bottom.low < klc.low: #klc.set_fx(Chan_FX_TYPE.BB) - klc.set_state("-20") + #klc.set_state("-20") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) #print(klc.start_time, klc.fx, "二类买点Buy 1") @@ -702,7 +728,7 @@ class ChanLun(): #print(klc.start_time, klc.fx, bi_list[-1].dir, "Last Bottom Change 1") klc.set_klc_fx_type(Chan_KLC_FX.BOTTOM1) #print(klc.start_time, klc.fx, "一类买点Buy 1") - klc.set_state("-10") + #klc.set_state("-10") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) else: @@ -730,7 +756,7 @@ class ChanLun(): #print(klc.start_time, klc.fx, bi_list[-1].dir, "Last Top Bottom Change 2") klc.set_klc_fx_type(Chan_KLC_FX.BOTTOM2) #print(klc.start_time, last_bi.start_klc.start_time, "New BOTTOM Found reset last bi") - klc.set_state("-10") + #klc.set_state("-10") #print(klc.start_time, klc.fx, "笔买点Buy 1") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) @@ -753,7 +779,7 @@ class ChanLun(): last_bottom = klc #print(klc.start_time, klc.fx, bi_list[-1].dir, "Last Bottom Change 2") klc.set_klc_fx_type(Chan_KLC_FX.BOTTOM2) - klc.set_state('-30') + #klc.set_state('-30') bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) #print(klc.start_time, klc.fx, "笔买点Buy 2") @@ -771,7 +797,7 @@ class ChanLun(): #print(klc.start_time, klc.fx, "笔买点Buy 3") else: klc.set_fx(Chan_FX_TYPE.BB) - klc.set_state('-20') + #klc.set_state('-20') #print(klc.start_time, klc.fx, "二类买点Buy 2") bi_list[-1].add_klc(klc) klc.set_bi(bi_list[-1]) @@ -815,7 +841,7 @@ class ChanLun(): #for index in range(0, 10): #print(bi_list[index].start_time, bi_list[index].start_klc.start_time, bi_list[index].dir) return bi_list - + def get_zs_list(self, bi_list, seg_list): zs_list = [] bsp_list = [] diff --git a/ChanLun_Classifier.py b/ChanLun_Classifier.py index 6d0d76f..ab7fd23 100644 --- a/ChanLun_Classifier.py +++ b/ChanLun_Classifier.py @@ -49,17 +49,15 @@ class ChanLunClassifier: train_df = dataframe.iloc[:train_size].copy() # 获取训练集特征和标签 - X_train, y_train = self.get_feature_data(train_df) + save_csv = True if data_file_path else False + X_train, y_train = self.get_feature_data(train_df, save_csv=save_csv, csv_path=data_file_path if data_file_path else 'feature_data.csv') if len(X_train) == 0: print("没有提取到足够的特征数据进行训练") return None - # 保存特征数据（可选） - if data_file_path: - feature_df = pd.DataFrame(X_train) - feature_df['label'] = y_train - feature_df.to_csv(data_file_path, index=False) + # 保存特征数据的步骤已经移到get_feature_data方法中处理 + # 以下是原有代码 #{'eta': 0.03, 'max_depth': 4, 'subsample': 0.8, 'colsample_bytree': 0.8, 'gamma': 0.1, 'min_child_weight': 3, 'alpha': 1, 'lambda': 3}, # 默认XGBoost参数 default_params = { @@ -210,10 +208,12 @@ class ChanLunClassifier: else: self.model = xgb.Booster() self.model.load_model(model_file_path) - def find_best_params(self, dataframe=None): + def find_best_params(self, dataframe=None, save_csv=False, csv_path_prefix='param_'): """ 寻找最佳参数组合 :param dataframe: 输入的DataFrame，如果为None则使用初始化时的dataframe + :param save_csv: 是否保存特征数据到CSV文件 + :param csv_path_prefix: CSV文件保存路径前缀，会自动添加参数信息 :return: 最佳参数 """ # 不同参数组合 @@ -234,9 +234,13 @@ class ChanLunClassifier: best_params = None best_model = None - for params in param_combinations: + for i, params in enumerate(param_combinations): print(f"\n尝试参数组合: {params}") - model = self.train_model(dataframe=dataframe, custom_params=params) + # 生成CSV文件名，包含一些参数信息 + param_info = f"eta{params['eta']}_depth{params['max_depth']}" + train_csv_path = f"{csv_path_prefix}train_{param_info}.csv" if save_csv else None + + model = self.train_model(dataframe=dataframe, data_file_path=train_csv_path, custom_params=params) # 分割数据集，后20%用于测试 if dataframe is None: @@ -246,7 +250,8 @@ class ChanLunClassifier: test_df = dataframe.iloc[train_size:].copy() # 获取测试集特征和标签 - X_test, y_test = self.get_validate_feature_data(test_df) + test_csv_path = f"{csv_path_prefix}test_{param_info}.csv" if save_csv else None + X_test, y_test = self.get_validate_feature_data(test_df, save_csv=save_csv, csv_path=test_csv_path) if len(X_test) == 0: print("没有提取到足够的测试特征数据") @@ -272,10 +277,12 @@ class ChanLunClassifier: return best_params - def get_feature_data(self, dataframe): + def get_feature_data(self, dataframe, save_csv=False, csv_path='feature_data.csv'): """ 从dataframe提取特征数据 :param dataframe: 输入的DataFrame + :param save_csv: 是否保存特征数据到CSV文件 + :param csv_path: CSV文件保存路径 :return: 特征矩阵X和标签y """ # 使用ChanLun获取bi_list @@ -285,6 +292,7 @@ class ChanLunClassifier: # 筛选方向为UP的bi的起始klc feature_data = [] labels = [] + feature_keys = [] # 用于保存特征名称 bi_index = 1 sample_list = [] @@ -301,6 +309,10 @@ class ChanLunClassifier: # 提取特征 features = klc.get_feature_data() + # 保存第一个样本的特征名称，用于CSV列名 + if len(feature_keys) == 0: + feature_keys = list(features.keys()) + # 将特征转换为模型可用的格式 feature_vec = [] for key, value in features.items(): @@ -323,15 +335,38 @@ class ChanLunClassifier: feature_data.append(feature_vec) labels.append(label) + + # 如果需要保存到CSV + if save_csv: + # 创建DataFrame保存特征数据 + # 只保留数值型特征 + numeric_feature_keys = [key for i, key in enumerate(feature_keys) + if i < len(feature_data[0]) if isinstance(feature_data[0][i], (int, float))] + + # 创建特征数据的DataFrame + df_features = pd.DataFrame(feature_data, columns=numeric_feature_keys) + # 添加标签列 + df_features['label'] = labels + # 添加时间信息便于分析 + if len(sample_list) > 0: + times = [klc.start_time for klc in sample_list] + df_features['time'] = times + + # 保存到CSV + df_features.to_csv(csv_path, index=False) + print(f"特征数据已保存到 {csv_path}") + # 在return前添加 positive_count = np.sum(labels) print(f"正样本数量: {positive_count}, 负样本数量: {len(labels) - positive_count}") print("Trainning data: ", len(feature_data), klc_list[-1].start_time, klc_list[-1].klc_fx_type , "---------------------") return np.array(feature_data), np.array(labels) - def get_validate_feature_data(self, dataframe): + def get_validate_feature_data(self, dataframe, save_csv=False, csv_path='validate_feature_data.csv'): """ 从dataframe提取特征数据 :param dataframe: 输入的DataFrame + :param save_csv: 是否保存特征数据到CSV文件 + :param csv_path: CSV文件保存路径 :return: 特征矩阵X和标签y """ # 使用ChanLun获取bi_list @@ -341,6 +376,8 @@ class ChanLunClassifier: # 筛选方向为UP的bi的起始klc feature_data = [] labels = [] + feature_keys = [] # 用于保存特征名称 + bi_index = 1 sample_list = [] for klc in klc_list: @@ -353,6 +390,10 @@ class ChanLunClassifier: # 提取特征 features = klc.get_feature_data() + # 保存第一个样本的特征名称，用于CSV列名 + if len(feature_keys) == 0: + feature_keys = list(features.keys()) + # 将特征转换为模型可用的格式 feature_vec = [] # 与get_feature_data保持一致，只使用相同的特征集 @@ -373,12 +414,35 @@ class ChanLunClassifier: feature_data.append(feature_vec) labels.append(label) + + # 如果需要保存到CSV + if save_csv: + # 创建DataFrame保存特征数据 + # 只保留数值型特征 + numeric_feature_keys = [key for i, key in enumerate(feature_keys) + if i < len(feature_data[0]) if isinstance(feature_data[0][i], (int, float))] + + # 创建特征数据的DataFrame + df_features = pd.DataFrame(feature_data, columns=numeric_feature_keys) + # 添加标签列 + df_features['label'] = labels + # 添加时间信息便于分析 + if len(sample_list) > 0: + times = [klc.start_time for klc in sample_list] + df_features['time'] = times + + # 保存到CSV + df_features.to_csv(csv_path, index=False) + print(f"验证特征数据已保存到 {csv_path}") + print("Validating data: ", len(feature_data), klc_list[-1].start_time, klc_list[-1].klc_fx_type , "---------------------") return np.array(feature_data), np.array(labels) - def validate_model(self, dataframe=None): + def validate_model(self, dataframe=None, save_csv=False, csv_path='validate_feature_data.csv'): """ 使用dataframe后20%的数据验证模型 :param dataframe: 输入的DataFrame，如果为None则使用初始化时的dataframe + :param save_csv: 是否保存特征数据到CSV文件 + :param csv_path: CSV文件保存路径 :return: 验证结果 """ if self.model is None: @@ -393,7 +457,7 @@ class ChanLunClassifier: test_df = dataframe.iloc[train_size:].copy() # 获取测试集特征和标签 - X_test, y_test = self.get_validate_feature_data(test_df) + X_test, y_test = self.get_validate_feature_data(test_df, save_csv=save_csv, csv_path=csv_path) if len(X_test) == 0: print("没有提取到足够的测试特征数据") diff --git a/__pycache__/ChanKLU.cpython-312.pyc b/__pycache__/ChanKLU.cpython-312.pyc index c2110842936c6f61a3d6e42786d9bb7d7c33130a..d218f34fcfc1f9f4bc7e8416bdb913f06fd4e887 100644 GIT binary patch delta 777 zcmZ1|vO=8iG%qg~0}!lj=FYHV-^jO>Kt2S( z#8yK^@)%Q?Y8c{?<(aYQ0gIvOVL~#K1*E4Q%_6WMnkJC*zyRnFRxB2Q#nAMCyam(4 zhD8rp45+6btO)8OR;V6OD6nJE1QtWHhz&^(2NpeGF*H5w2t8gYoM25ND8UUDgJ}W= zH3v*XB?CCPCa+;JWXUW^&7J&^#j^esP(cI3 z4Q>4mY^!XhxXw_SQ8rWOiirA-zz&uk&Kt(&J9sV`yG}`+;j%#HqKw`ZG5r&UKpAe3 z4A&)N=Q*r1QWjWUl+(K+p?^XUD8qY0Q+Gw`D(NYvGel;j&Xm3)thz%HD9(Y^4sVbp zxGdK-+@QWHc1q|BlLhQEZLf%G9$*9-#D!+TWntA0mR^n>ikr(=tC-ksv7}@smu&vZ wzL1ek5#)R0$#Xc37;Pq>=ai5#2MI`l2nitZi^C>2KczG$)vm~5G9#A)0L3kz>i_@% delta 379 zcmZ1>zEFhkG%qg~0}#yp%bDTIwvlfq^JG0{&iW-lq3H}Yj46zgKvoSyJV*@~0L7S~ zVvI;)%uq2VBrz7K7&DR>D^!dHNsJ9D#tIkHV@zR(3bMfk8B;i*V(c)nN(N0%zasw0 zeXM$n9Fu2p8nCjYWG0tP{>f??69ZJ#z;HuEVusj6pAMED&KqJuYMg#Q5 zE=b}SV4rG>BqE%T=uUxOjw+N6+HDY`|9Zn9pM`glaFWO1?as;wf6cRuE8 zg=JEquuP4A8pdK%OpP#al^`tB)~afya8zlTu2#n$T5Xc#`@IA^=WAk_kv>Yma}Xv5 z)oNJzFjIh4br`TWen2P<^j5O6IA50gZHUwevKEOHL#=jEvLMK}P|}J#6WeJuf{vZL zI!uy-yj1~KbuT#$G$M;-C%+128JpBNn3pdu$|%nBwkhrkxV!N}l&@5p-pSc|EldpT z5J#*C>`2D+sgQ>P7dYrVxmyg10M z=6n`Cdq1wf$?cPG&#~I&oMOA9Qr=ACPGl9og);y66xCc{55%X}wFLy#_y5e_)R?tP zY?`ps&*k5*LkJe5>TPZMz(z}pKB|6jn?}EO!O8`V!Ai)M5G7(u#IC1aT)t!Z#lW;S z$-h+!X^}!2D=tgnSGr5`B`Jcq7Oh&;SfDK0vPdc0Qg*<6F(kcB(ypDdVoGD;B`LH` zYp7dWx1w%W|JI1KmWZ^A+O#&cZtc7k^BRX-R)@9eeK*IhkKHw?H7d0wD)pj1wX1dL zWp#M3)&VV111{Yu zhWf3Eee_##?TEN;d{}DYv{bnWr@*4?SrBf?UR+inucetW^2w#C$2A~tV0#nyY7S$a z<8wASDMIJ+>C-NRiP6lS^kSHAqqMRVJ=y8|%F9xeXCO63^$qtCk%|5~-Vu~d3n5Wm zD_S93*&PF+KDDY>x;7;{|4*~>&{WX%$98cfGVp%hZ;`fnjSsJrI@@ULvx-;Ebv^qL zIeNDWXsISsK7hOyaBG&>ORZ%~+=jfxg*l7MimOU&ZeQeei<7Z;c2StQwl{p1vaw}d*xbR-=TLL7eN0Z6z53i66O zhw+N92^(9KS30?>H2vO|4~V-Q0pqqdVD0i1%U#;g`h+Xy&?eoMCtJ;y7PIAO$OW^- zWggyY9@SzV=Fsfxy z^+b=mj9-e4@(j}cZrcM3aoH@WDlWz#Qowh6O?a2_|JLLp{(cB(y)m%W7}H{mX{vS^ zEo@4Buu31uvd%|4Z}t5lSS@eEUhMM`V_^e}f8asb?96>&Flbsyz!c|)+HJcgh<=E>XGuE%pU6!qi}7(6itj<6@6sM5TKnZmK2 zwLbBf-sKbDA=H2v;Y^qvs*#9dBXb^zcqv#A6akZx$|@`q@lUFSaYCbh-g)Pi95whi z*NTmz{AI0#XsMN0R=$ay%#9Q`){08~A~3U`8bj3Ma9j&JUp`IOaJ^Q&OvF&1n_^;Z z@5Ct6k}>hzXPd5uhJl^z=ib#a$sW$^`Ric|+arg9$nF$HvJ1HqODPD6mKKpbcdg2* z=6Mk_q*c|KA+^jCi5c=a%rrzeHq~mCJu;Y7l`%?71w`@eRe_aX?Lyr$%KccydXq9b z5%la%iJE;~63k+)!Af=&1WRZt*Hcv)!XEl6imR#tOiK&X80dpR!v@&qimHZfY(P;w zi?Wsas~W!Or3+Vqy=r?D_}I}bH$W>b)1zu%m6(;fK=5Is7L>5Ol;GYYpfhHQ$9s8? z+ucx@2r=wf;WESlMWfjW+cdq@P*^L;@?BmlRli0KMqg)%Qp2b0BYP5Z{A}N89LcBX zC{CA3{uR9%!d_b#soqp8EqsveDK@cX#f$Xnh8K{#m)V;a^GemAL zt`c#=T^fXtzR=3<QDb^rq*}O)UuwLLOZ<^mHS^N%3qYQM^+V>q^?CpuBjpZNo@%guk|7!S75&;%@zpA`U&K0Qi*GHnZoNMw-_XNf#ga8G;6ab?gW1d6UQ=32rg-j%3)( z9^8=<`z}`01ozGuH4dIereKD0b=qfHPFQ3 z2`GDC5$bnp->mRoNR8WAiz&+-dO;P$uUmd%B1_tzg}0vp?SfiLVAcC)iuB#GzmFOl zJu&Q+*ZMkR4-8dJ_r?5T36Qyu_!=`}h4)B|AzYCEU#)c1$|u3A6&3x6*Prb_lok?5 zWDr4cw?GrHb5$W*4-X61;ihq@umSZB3A>;Q=F84cOkxuc&+F0q&|$CMs#lUkY;>l) z@(zsuhDM^x#tr=AANgzilF1D>o-!SI^sAcHqb(ZQOyhDdl0V%(l<%#!0((hbG5T=e zkz`E(*No*H8K;RPg#y^YBk4Mqe^R^PE2c8{k-v!e?L73_S%{Coz9=;8E}?QX6?x8% zVb2_k(1dy=9y<1jCfzIX@5e}DUy_*4`n^sP)7d{>cf-r=s7Q{ zN3NOt5cNdEGtZ3)TS|JI#lCcE^T#MgPYQlwINN(}A1?NATIvPw^}w!tI+Yc>O`L0$dumrRiXL$}(&=$e2Vdlb zpQoz$fX*qOJ>w7KS=$e_u$9fc`53Of7jE_m=-wOhgJjNT)^amCfSdd{mARoGuz%eg zK5YVdY9hfTg2@PO-+X&vPQIhudxxGv_1sfg#7oiCt)tdb+tNyJ9JoXcmkFk`H9t<( z-XafeQ=^B5v7lS`>s|h-7)JqTF7wtNoy#<$L-14M#I;8;zn_kaM8Ee_hPNR=9gYpx z)t-2wzVXb&>hT>yKzDyV%l-L1k;<0#!Cj5S^Q{3nJdfioUkrCEjfwv&Nn*w0duPn|K?)Q1z+Nfpern{Kf^Qj~|0r#-*x&l!tK~d4=eOC~d^P%Y zAD~~8oL~Mn81!w%aC)Ab49aXH3jJq&VOu#)D zr`WJfm?u4{jbmJ`1z?ER2^_;%sQ%V}u9^gU#tcuuR}*lOEUgxQU-q zx_#9ZyGN0+(+DOL(2nce$4Yt-41~E#ZV*Ij4v`CPDJz1&q~n*;ATdB`3WCu(S7186 zy{aP=cM$wRBw}SSpaH$A_Xc|O*x)e;egP}*^CTf}^OGicOReJ>C>j?*Oaz48#}@%# z-+b09a0JRi*?Zcb_}mqNA#WpLQ%hy)x+y>h!HLDIO+8 zRiT+R=B|??J+zeM64inOFO8RU!>Mo2wo*PqV&mzey~cJlnsO7h*FmgVF_Hml%HR=)N2@7Y7zOc z@)@@>WPABfgWw-=V?6}utr zpyY;XFUK)rdr_G_9s29M?v~FeYo^148s2h5`EWWsj~lRP2Bg6@W%~@6m2!~$Bvn%0 z>Wie@vvhY*(U)L8!Iw(ROo-C1rZLV6%EL3kuF0pu1m);Vut1jLo(Ugmj!@rS%Hdg% zFa|eQDKimjOI65`yI{Ak3$RKGih|YU=V|q4YT1DBNCnn!H92ECehS9 zdJgOaBU1SDh#y}6Okz;;&H|hbMVbdEgRpozRS1e~8s-X2=n(pg>gEsU!TS)2)NNcE z0cQS2KGhYL>he!(7j$A7DEo3CDT=7uL7g2gM5VgI(p>%+b#&rVP_AGPiBq~qF9Qawek&hOU_8Ed-sMjLY{tH0G zO}EoY@!_t(M6S4kitpW?0|sTud`MGr7r;+ZcUf^ED$Ny^?()ZrlTNGv#a778sOW7* zx+`pe%Rhs9)PV9L_CPa`dcTmH5kh86;AV_c`V~Pv+A=}ae5eT25^PY87DF^dD}OD9 zkzi4LN+3Ei5Vv`ae^;!)U}m)!RBpsn;82vYB@mD2mqhxREJ7(PfkF5?S%k8y1h$Sy zqPg!&kc{A(%)<47C| z^Twks*n$aXLFHw~D+%Qf)PK5$2pennR6Ki0whDS@Ma%&BQ4LN|#g$wxS`e?ZsOBS_v z3l)@=$ySG3v$UFTuu~+5N1V5n5o;l}?q#Z2LCPN@ihfb6qASYPH($N}!b>tg=J69A zy~N5#30@~yMR0=P4T852eueqmWxr7F9(d!}sjDZC-dK4OU-301dGaEg>zI(91(-gmg5N$2>K8t5+o_}*Fn;# zqc}b{;@Z=1Ts^hjtuB}C1vWXBy6{LEM-*w$6@w$XD&&`xbL${v3`I+shvAh(og<+5 zE1xIoU4lOnyhrdp!3P8%5&W6pFG|>Yh%xZMuPR<5zoR^~9wsjErU>dl!&mvE$m_cf zT|3fneO;s1f1ZHy18UlXHbp!s^B!8+r_Y6+kHs#DS&_B!%`?)oFa$$+R)UC@aEiI$p zGUc_~H$ZsSXC!0<@$*Nm&#CwY!IuP-l;kT!>2apqB0grworwqQzM+Pz1lI{}5PYjF z+yIe7lBv6TT3%&Ak$es7-3EFqtmY}lOE2{%(eH@qdx9U7lN+EQ`zFyp65K*?tLa(N z!S}UW&*_{}JOoj8a~tx@tkpRMWyNK(_Yi&`sXLs2FSk1+MNlcF4RBxnJvmTQWV06* zRmwmsP(|7ry_*Gp>8&odIdJio*-IRsm4b|F~8+t8Y+6ymAB(zv68Pj8x_x zf{*Y97vC;u#aP917_8w)+%^fmfsKLBj&1UDnfkeW@E<;giH7Dqhaps@YYPZ%7euX} za_Ut`G9%G}SDD}|rttcjwx9@X()lZ%SK&U9h?FBRDH3^a;}yj#@Wheq$%fL z2RSK172iHgr3&=uqEtbKLI@MYRWkDy>}-RYC2#=1eCH1NcOF`Z&Zwi}Hu# wFa$nV+{Ym!)QAJR)fivOt7U&0oDZ`=i9Z2hP^pYK0dxJWNq{$MLaxsL0W#ZXcmMzZ delta 8060 zcmbtZ33yahvcA=~yOZuL-JNu2-^tdH9Yhw{w~-|Yh#(+@>Si49^D9iQWynE-Ja++Nk`kRUVjeee5Te;+p2fN(zQGn@esU||TWenS-vC5Kpfa|zskV;pJvYMpJ{=uxrr$Uwj%&x`0 zCqOsfOAfFwtA3U&1%~jNV2E@*tsg1tz81VI$h#JBjd(2666yLPFj}Q+>XT+P)sr-~ zKP}SrvZ=)nZn2@!S7A7_#H7d_##A;j=E_jXWbICq^ik(kkv$s86yhx08N7Yoj+l01 zYExaOI;2A#eL)?)z2rmnfNmKlcj+Q=Ds8744eU@-Br|-L&Q8VpviD*K1}$79Nh`ID zsz!A-{PaKN|hufoOIb~@7QyPPIA~l)u#R8`g2$)SR#H$^UFVT2OX`(oB5CZ7 zLPx39mmM82$e=iB>Qn@~F9Q2%z%ba%o(oTA4=3u%t{BYDnLFj}_wNX7H>5O`cIr${ z>jhm@)8J06Ze7)yDrYgTYOUfmtu?>1d=Qe+sSfN=TP~tuL|DgfJk;QX$L&brX^2>Ic!_?i zzX5El_1Q>$r`o4O9dbb(;&gndj_S^q{1dx#Bz;g*Cj068NEVv59FDV=v`qH?8J+8` z^sj@}9@T^S%r$NTD)-&E(cp9q9X}YfCrS25Rx@Foe8oT5b!@`leMGqKpXLgJb!_pX zFmSOIiwd-4edP$dx@bPU$c7ixX}1EdT*HnO{6_BZi+5=jhiYZXKY_)Sjf}ZumLx8f zODk0+(n=ZssT*OU%n73NzbP9w{Ge zl-cPSW)`co5O%0)g+XqXP^a6P2nE=T>M6Q7G`;wF707y0 zr_nX~F0r!suwWK$hxH zM&|R{cNXkpV`?Hn!xq%o;U+s*^PsG0j%6veNn%wriyPw0l-gy6CiI(H(V!1yWwh7A z%|#)!Z*=-JfBa8A zTv#`y-*k7m?r(K{uIrcS$F475D8Joz@G*CXz>Ht~SlRN~vaUHpxbWg~;lf@cBY8c` zt0x~;)!X4b`=oxZ=0`F+8&n&Aw=4`Nbf;sizImZq!jz@L9Ods#&|m$6KaVOW%cIK9 z`bv#4=uO#&Y4jvQgPfj|g^-=4Ji%fc?pY-g@;u~tbdo|5 zjVM+O$Q`b{P7_6?29k+Jv(nk_U%Cq`>`Ph&a%u$r$-OM zpta}wQUUMu4{S>53@|mNb{fr1gQz&~esp6%m(IT>dPB6+aY+}|$qFBfVbdF91GSPq z;8)}XS4-ms2jqmwY4Hg*6Gxxavxu(7H>yXcC&pf}6triJHLj zoBkTmz0Q_Vj^1vt7gSf;9fM``(JXds_YnCC9_8EJKg)7Q=tS3#FN{#BrLalBhQBmW z?y!t^RlW3_93+KIfbK_S$q?GzpqBKerVM5}8tEFgH(iw>LRRR_XnSfryrucqQ7HmQ zX=ZF+1uFOBzB%U0q{CluI>w15^t>vF+P$j%Gv#(;CVPATgVxrbu?8d?L5Dg8r1U`KN zeSrstK?s}HHq`t#()W9>z9C`Qx==Vj)3#9P`%9Zw-?@j9L~yJ+^hd}zN83=R_9gxk zKjnS=qg+Gy@=^1FDW5hxF~+J@bhO_(R^tl6=3=cYH9&n^0gqo%CG&SjvUXR37SyPK zAN$#rA-5Zn*pMTCk|krZOMUcB7#D~uP?EopM0*H7nCMY-9zn$SQLMz8OfZn(F#u@v_lG;^STF~VcExOA%(qgtS5rR{yMBmN{cI(7FK7t+Kw+% zL6$4!Ht|}z&lQX^KP5E zPivv8GK6NLDGvX~_~1pP*m0bT;ZKTPMxFf6yexEzA)Q?BpW#NMh#>>5GZI{5bsYtM z&yXt12-?^u9iy<(jP4B63X?k7$j;~paTV{O3F3wfqmjr;N0`#d@dD~UO2$4b`=fbU zh4dJ}oFBEw9fpC->Um7=2$|_>^Ef~!h0cQRWJzaad7fxC^~y-W+H_?Z$jD+oSJxup zew?cV_UtFcNSw+vU3o-gZJtP1eb)n^M&B-w27KWvy50y~?33%i z!N^LzF~Hc@%`2lxStna?BiblVG?$)5ojbzT-x!uZitI3&U<|=n1do4FWqCo7y;dYQ zWgO8(UYbd3DK~n2iEAsZcX+S(DPo)^n8J)V^L#Fm6|mQA{m9B%Zcav1q_L|vpO-t# zBbevgB(}e2pDbBMviaX+_0po)fp6Xuw3XjJh_p#K?=Nb}G8x!A-wp01M6sCf-_sMZ zdoEfa-PQB`5-|3=Z#ij@$85JEjCUW4ZNHU+9p>3v<6)R9@P~UeeqA(qIGrtbYc7N) z_KOjzwm-dzRzTdc{H+@xDnb+sQB_2giWnBruyN~~ka73UGq?T(^L&1zL4!OCXpkiL z8i2tdUk(W8Z>V4-=C=snPxdN98jV1(#wh(NJxaSAwBljxqj8XTJwfLNStw(!GzPt<3h@r{jnf6nndy@6HFna&;*9;K#(^Z5oC*Ly4C_*xT0^DYCJ zu#T?@1#9AON!fl&^;<<$f3IoyxloAk_5j}7!+Sy@dw3q6t|8=h`7f))uK|vVN~MIX z|6gDw!aq}S^ zT)bvJ%*lBcck!qll;)FhsPsjX$M5bJC}j~%ILrS&AEJEfX|EN)gBC!gb`Cv^;;R>c z6(;e03*fBwMVi~n8y|+OVOwY{t{I)qqgG0b9n{3*X$r*7A_Rkpr>AG^>q|=O6$}6T zVMvK>B;hLwDoD;_G+IUQ3O?F%*s9$YK6W9*@htdP3*iFb$E#>wSOEKd zCI6V72q_@g9kCd8fG>`E(xgBO|8XnCxVsABBn03i(t;wl5A84|xDOV?J7AH52J}1x zlF=eQ>*ZYxOKUfz^VU*GvPi~^o}gaN`KYvuVd?FL4E_PK@LFW@A4(w(^S_z<+h7zg zEQ3{;r|>{!kcV2u@{#3m7`2Kctt{?a<>(jG%F>f11%~!%r3U_W1(#XxJ5wNs_-Pz7C31v!UbQbk`52qFDXqUxdUKiNQ|j-_(wk?YHg zJU$a=6grg3dXLIh>(LY{O5qB{#IGxGA13__J48qN;B9O$+)k#LTS_X69d=C2_RYM^ z4)JokIgz*6AqRVcB>uJ?HjfA=zeW&5A=v3U$Hgg`!G}UxSag z6A5uP5^)nj3xO!K!$iHN1fwtl`ednWBM@n3JB_FSd0?WlmmZ4o0aa<`A2-9`bfMkv zh+c^Fh5)6e&Q_9ETUatGD`T*-3mN5Q;`iq<%6>j-BbKl>nk{mQix+K#wEU-uu$mNn zmPXGZ)KMe;`RlL#dG`xS7jY=TDK8SdMDPm1a)RFz>?1gca0?bG3H<6th#v0EXd=0} z#Y7bI4OQ0cFAtsgV&k?i*BldxNzihT_W7|kqV3>AHbFwxPFy2cgZrlAyO$X)tb`JT z5rh*&5Jd8|n;>b`%P3#y{>788eSTt_M^md*7MCg(nj%tU2#rXe+sV~&G0|OOGi;Bp%%V>0zfD*0p8jW5jI7VBD4NnrBA~;R(M?SU% zV)Viws_Ny6n^&~JRKFL9M+E^1CtDz5Tt7jS50QaMRj)IIbv)|a8e6GVbH|B5v-$>GcJdo-Y2lo8P^er z*W7bNJJ0{<#3JP4UpQe9;AiDl2wAnB=1?W@=qA+{m)1HeYix>mFShw;3YgMP9WTV*N#Ed_(ka zfp6Ok_r}~+fV35*mE{!<En9_V$;VXw!(*)=*>L|_$KYf^79@h@W7B8 zb3oDtd}bKkH2iZ+@l!g265ZE0c<`+;IEkNn8Wv*{oW@N%AdHWD29BDgko4jJ2?9Pz%!Te+jB=A3^z)Ze>2du;OVnP^yU?+?gv%(}<%MG;< z?>@d0;!FeS3xc>Hlkd18%gG|>jNY8GhDKdneE_CI6rXtj<_zicvPWH9Q@cVDaWaJF zO(H@Hbp-B3r$zGSBQPyQ^0)S2%JIrLA7;I19@ybG$bI7o#CwHA zy6+Sc64}&9LLPL(a3Q4C4b#FT|FrH}ko4i_Rbfgtn!zgP=H^-l^B>&s_^MX2%XR|s zDygQ?0Rr)+EIxT$rN=sgHUb?PR($vBf8`7%nu#Edz(Mou1ozS-zHLd$Y=Q*@1q4L| zd2k;hDkmwG1V0i`-B;+6C}i}#lF->(#KTD>0p%n606yUuD3Sgu^Nk3V%GB)}r3!j3 z{HBC|Zj1m``VFnya}0(8oaLqy5DRB`_6ZmQAMmmhkQFN9HXeW7^Wsc_zj6rDDl6Yaov6Z diff --git a/__pycache__/ChanLun_Classifier.cpython-312.pyc b/__pycache__/ChanLun_Classifier.cpython-312.pyc index 439a339e255af5fd63a7dc127c875a6ccad0f6e8..7dc51438aaaa5260f101764da4c3eba97a2f0f80 100644 GIT binary patch delta 7751 zcmcIpdvp}nd7s($?##Y-wOXzAA!&uQk`M^Vl6eXl448*8!LZ8oYH{yG0n?Y zL-ckNXX6ZTXE-}&ggeWb4pH0990O?CtByEM|4v;>)7ywwd)TVtRh&9Wa~jDgQe6yr ze4cZ_AR0yRiz@JI$8@7=?2MuwR#B8>k{CgoO;eO;8l|%~r{7ggQ9LV{l|0U%@??O^M#FDjb*9Br?i8(Mu+(T#KZVf?9QA$@A1P zRYBDf&W*Ex*|?YCy@Z=j{>Ts{e`&B8OL93ScukACsuHcoO-NjRF_>gk%|^&Es7ErC>Fe|b>s*2 zPSRqsFm;NTqR88ZQil{yK74!8P_weQya%h#R?1nV%;d(p3vRDV{?%l0-(G|2Y9c>v zbdoYAOv~%qB-+HV@`EWHxv1s?b9PE~waD+}DC02SKD*yAb9cK~p1YF`GfS0eh?QiE z-(?xirMcyYC{9f{ww10s{paiyU334M&uks>n9$G1qg+gg)wid1zo^O>QnB6fDA*YT zK(sF=>?BWEmXNnBKhbBj-Lc2w-Q=Kk#f~Oun7;#|8KDK?PJ|^0I1C=&Kz=#G3V;a9 z=j&w5-SHToOe8y_d`yVnR-5>3z7ST**!xrQsN8Ebo^0>s;yk|?8`JQM$TnLQ-9Yx+ zs^g8=$s&Zcn5pKG9{2`?jk4n!W?thE&Z9%09r`M;3p$rajpNU-$!I(!Bzj^(FQ2-G z^vbU#X8W;9xyBYuW5XG(z{e8Fj3&N2)}6Qt%*fvhZj!cNq#MbI<39R4`P5NE2T0g? z2kCOwm#)OBZCKTs+9fYSeNSBA6YVMfF7k@AWx)hZ~ zD?rmV&lauTd_zZ-);!ZR(m!apmTAo*-Nj-(jhSS|YYQthf8(6ZzbU7TyzYIr;jr%3VvcwH4lr_VMwK#1l(G z`I6aouD<&6^c#n!pM3hm*Y|()`jN}8fAi|sPfZ^lx$^33*6G71rjH(kJ}$p`^2&ji z$(CUCz0 z$*rxY=f#KaJ z;?GILy(15duQ{`HqG@fqab4Pb&*1uZH*7s&O$Qf_>&Ewucb^SU_}8Ytx?}L(_g%#o zUEv8=cx3PSK)SOh?Fvu2lH^zAt&4za*VA92hX>Mu1tb0A+s8Ma)l8J$oqq74!A+O^ zWf%QRC;Us#tUbRo9ZRPDODFxk#8)xkJu+~~9~?4W3WSH4OaAg_P1o1bR7uMx>&Xu* zS_0?lY-_B#b`8u;xsah`YQ3r@$Lki;8qyZ7W%5KSX(8<)-w3-%{X%28r0b+4J^UNs z-^kID3GR%jSxxN#AqDbdNo@X7nt^SFoBY;q3;_c*YABJB3E3hSG0pC+MQFX!>(nYg zV2<7gG77ZI5^KG`)?851m@lJ}j}2bItxQ2Q1B=<~OJ+&T2&1xq+ly|pxt?jTN;bil zuV52O6R);FT*K>##oWU$r!Zhk-pX-?+6RDkNwAw{2Od2*bz@m<>5c#OyV}`rZ z80b4)bJ8C;8?)liLZRWv8hm4eMb~!Ldeiih6mWPSi6h(STdAfdQv7PZ}ib zh#ktR_|rnA(yo|a2W07^)^@eb)39lh)xZU6;VM`)J*Ps7R@&SJ?=v4LScqJ{=)zL4 zDD!ju%(*HcK0y7=S?ZUpLKV4D04V>%8Cw{n?;D54>3(XjhNzibY+@Fd;=YG?{SkZ%~E+(vaU1b4C>JLfsK? zzlRrY+?&Mwfm13jsAUq1LF}1=3FOO(#bisBGd$Y^TTn``OjFcwW-lqz7wgf$-eU7z z#hhg{cMOIxD&xT804T6KU-#CWs(jxas+^puB{;9{QKXFpX|w*v3<*}p9{e(utw7Sq zo8}_2zdEw65#}Om)0+EVq%->V-tPXMWQuPEcSZwS;W&7;i6j?)q93PylbF8x!>lrb zs)oob)ouQ*P~tQ9{JE}(k2oS*t7Un3TyDHOkrFbRUGcpsK7|fbB9%y{gjljY&i9Z5 z5!dFQgPR}2JXIgZBgermScvgL6bA;n)r%(%O_!;8I>H7hR6TXC-D{KM((5B)Nl-tox9rs&jT z@u|-4bgXCUuH?sRsV zA)-4Ua&B0lnOoY1fB(`}Jh!y@ZDCikwvzIlIDIvdE!N7P(*7>wUW1SRI@i#7Yr7Gbn3T@Zb(p$z8Vzo(lxe znG-yxEO@T0;F+znT`IcgnstHh`Tkekb04+cqI+(L@wp2Y^8c!PavfYx6hwjZPR^k3DuR5SujG|bKqF8Q@okOuu zIbr9bJg>Z7p?_djQ47=xBC9v4m6`u3yfb`(nD9SChfJ&I(E4kD{vg1$Q%A18eBg6+ zWS{*3h^ati3Zg_IxLIRMLOkjU{|kUf2{AR43?NDHzeac)AulTY-(oV2fRe&bAjrp( z3usLu#njhj&bD zd}J!dO?B)_KiWOj){|G3UOJ~Nz4YfQi+&BO)9V@2T*2@Mn@ilHL`*fy) z4)@+9Ex(`^Z=iMOYn&VOAT8uZg^Q-hx9WW4cw@U(1F;+v?%mWHjwTEIL0U^T`#oMQ zL}}Dx8YL1U@5^-%rZSQ(%bZSa?xV+SbVNsxl3?rEY54;BQ1%Z(KcL9klh|_={KF}DI(Mje4#mMJjFaj>g zBKWfw?7H)rSr6?0XQz<=9#9yU;TVzSSYmJXLfFfkvn--Twn{Yc`9aR4ZKSq2sLwS| zwlq7-SkWw6L@Ra);W+yX`g|D21bbaae@DmDIvyv$2@(q4gaE znYKmhoBDQSkL8gfidS!Nz38)v7eF!fhWCI^) zeIEfCm@h#W2sc4BN6B8AxOt1+J)<<-&($sre}zz zwOnOVk?PjFmi;Hxi>U8ilhI`(ND2of0Mq}#RK@Q zARE^@j@Fw9@)F1o_68>9XF7w{PJ}81dAvci5bz17)&U%%uB%kqk`s{`3T_YuVx3Pd z-oJWAlYr#R{aT&2amKQW*7|1FtG3eGJ7+9ARU7cWP1US5ecVSHS5{hap)>l}V=4SH z!#_bfR}Rxt&$fLd8(-T){bL3Bu;I-_I9(Z3pq)($gWzVE)3fc>*4^M3by z-`T!%?)N+2cXR5f_~m}l`Dcei5uk*wDO)SnoOK>Fh>!APhLu(Fe&Hd7SO9IrNv!+D zhwMZF$w6#@&fSKX>qTQ&6p!7YRvvhfqG;kzD@1VOWEifY11u`uhDn644Swpu}; zcGZ!V1%Vi|ZKAMSWD>1YUD>uFH@~*PSDG8G*_gs?#MF*++J=1C+9VP4X?Y6P#3BmB zLaam~68zbSojAa7{JDy3@*()9&nCnwuF9 zi_}33#53#|acZ6sm*#~P48%L^9`R_t5wGSS@o52FCl33yBDI)5VTl@uuatjnUOz$1 z#CAF|Wlt}o6%Pm``n(8Orek>lR_OIg9jl%fN%e7AE0F}|WyP$7)IiP00@y39qP3ZoR(V&^HUa&Sju0w zRNS9?)1-b6cu#h1EzGPeY!iqW6toEVK(-!bRwAMV`ZA{E>gDR3HybKrjp~L;LmlWDe4EXy%rW`6O*cUr>g4Bbt&Xnj@~lQ@PtZ&{_6wwmSKB*r zYv*>_FNiWl5{@_Wl@%er-&x{GnTF$=6T_=xV#+i)N)kWd$DOa4=mO})H@WVZSOOK= zgwTwDCQv*giu@+tfFD6-Kp%~(iQA1%S!rURFFriBHJ(zi zIvgL_Oyc@fDbILmG65PeurD#%znvr~ZN)W=w2?Qt=Zg*eVRvnKF|OT+(2b1-eUG#O z6>Isk?&6?s|4Nke_UooE(x` z#CQ0{(8l7-?GI`}z{rALKl_TrFNXS-O2nucNI)~f&%~r|Vbee1?lG&Ghy)R+h?(cy zbOLW&Q{-gk)5X~ z94v72X5*hR6aVt7mt@;SVe%*Zo}Q>X-yK4h420`y3QuSb=I9olboNUFLcg@h277Qa zC-H9szoZf|jf%v0M4EIM17^Yf zS?1OZ%&ZxitUY3yykQgyhK88|hmy!MhWrNd?W`cIGZS1tnHUI%VZ0YMAi_^`?h<0r z@t+I)dh`$vlt(9e;jq5Mh(==w_*yA4FlJ6)5jxrOJj>q`Yp^FWbYP2KKJQF(RA=rw zY+Q>_hp-4BX1U#jo?C7nezE)xYfPf$IPfvPqGET2gKkIRID)Po!rC^3VT2L>Nkv(0 z600geN*<#LGT5)uFshKEF%PZAdN}~^s9an^52A=o^hW?GSxqEWpdf##vf1dtUiY*W zaZ6Q;;{yxK}4oyr)$_^{j(dxst=}6@fWu`+Y zj(xR~Z>(vJUR>(#DKhsL5)9vuPB5>LKh_@P-&;~9O1x_cq&`dhwp_xX8FbyIpnrbO zLp0-npqb!jCZZ<8)1ng+UNO+f%6H6L!QZP5)aLU=;6#&AU>0EQ=Xxhu#q-b$GjOe` zG?1H|h{Iw3H*Q3^CEhQ%Ad0HUmfU_q!x>$g>)ZH7_*)fV8DL_gY zOb(7F)%a+Cf)4Ssb^eBh*fxo6hUEB&&M*jAYMiQl>flHsWr|Z8-yQR2h{OH$t^C3I zrpB!}?#DPz9*L{{TN5NDZ64H9jFfY1dvZ`6grL{IeSB0+dZ8P?R#_}lv}8{uKeDE% zG#BsUYTO6BN`9Comy>rktmc1jYZhnun+=WJ*?7YCfxUdDQ}CC4wMyiVFWwub^I@Kw zs3C(wr^W@ow>|X#V#dtvnNfBtGYm||x34LAj@W=BcKDdWkD{88+a*LU@a-I%(j-7Hx95qHR!-dP?-u$htfYscjH~bQ zY>W>NlDG;9XgNIM%gZTxKK%_q%uip#`fm|lNBAAW8weN&>6-}W5pHG%eG7FEP?iex z0#+{~=;Y9Y&hJq~n$SN008l`T zUxK)2Argb{YYRBmBOzYT6QY;Tv^D93DCgbFOZX3$PdShjOOX^Ug4N0Ywc_r`t+dER zj2jX}3=N_MW>FG;&SkSGLpqC+Gd|1Tg$vopPeekZi9gw~kh|w8qFE0pA9eWgTAYxX z4Ed0yARn?Y3o&Q%A-NzQvTBxsi{Av%B@@oze-!92dVwUx3VD(xmnYfO(6_eP)yTYW zZFH!31?YuX`PrynA;1V?!#pc30^bTn2eTK7P6q#9$##~A3&-@TW!X9B8k%PX{&R%c znFD(;nYfS3xlGFfnU-h#Re@{v5PzX_AAf4)!vQ_L`YFsyUqH|=@}F_JYms=8H+NNw zzu*scwXA&^+s+`ogzzFj%$-hFbe}9oEx7DWIS`8IOf;7V(Nlc7D{_}JpZe&z4*eDO z`Za>S##yZ48uT23zT`C4{)&)7K!cJ_0DkwX9(fP?=#wJ%rECKUNXruagCp@_dJ5;0 z)7#PMb{nQq+)mPqVWB)-DBeDB7K?hL;+b>ndsm9$$9!^4rS!JQ&#YNx{sfyVdHve9 z3H=Ju)68d4`3iz=vwpB2qKG!oj}a0G7?08mptn#2OgfW20Q-d*NiqeWi_Hq~!0#{L zp|-uRBkBZGE<@zxHYHf|{Jj{}kz**{XSEaFZ@5BVbdEJQEbZ{wIX;}YgMK6Mr`8{In#G3e!gfI2 G DataFrame: + + # resample our dataframes + dataframe_5 = resample_to_interval(dataframe, self.get_ticker_indicator() * 5) + dataframe_15 = resample_to_interval(dataframe, self.get_ticker_indicator() * 15) + dataframe_30 = resample_to_interval(dataframe, self.get_ticker_indicator() * 30) + dataframe_60 = resample_to_interval(dataframe, self.get_ticker_indicator() * 60) + dataframe_4h = resample_to_interval(dataframe, self.get_ticker_indicator() * 240) + + #dataframe_1d = self.dp.get_pair_dataframe(pair=metadata['pair'], timeframe='1d') + #dataframe_1w = resample_to_interval(dataframe_1d, self.get_ticker_indicator() * 10080) + #dataframe_1m = resample_to_interval(dataframe_1d, self.get_ticker_indicator() * 43200) + + dataframe_1d = resample_to_interval(dataframe, self.get_ticker_indicator() * 1440) + #dataframe_1w = resample_to_interval(dataframe, self.get_ticker_indicator() * 10080) + #dataframe_1m = resample_to_interval(dataframe, self.get_ticker_indicator() * 43200) + dataframe = self.add_indicators(dataframe) + dataframe_5 = self.add_indicators(dataframe_5) + dataframe_30 = self.add_indicators(dataframe_30) + dataframe_60 = self.add_indicators(dataframe_60) + dataframe_4h = self.add_indicators(dataframe_4h) + dataframe_1d = self.add_indicators(dataframe_1d) + dataframe['state'], dataframe['bi_dir'] = self.chan.cal_klu_state(dataframe) + dataframe_5['state'], dataframe_5['bi_dir'] = self.chan.cal_klu_state(dataframe_5) + dataframe_30['state'], dataframe_30['bi_dir'] = self.chan.cal_klu_state(dataframe_30) + dataframe_60['state'], dataframe_60['bi_dir'] = self.chan.cal_klu_state(dataframe_60) + dataframe['volume_ratio'] = self.chan.cal_volume_ratio(dataframe) + dataframe['volume_ratio_5'] = self.chan.cal_volume_ratio(dataframe_5) + dataframe['volume_ratio_30'] = self.chan.cal_volume_ratio(dataframe_30) + dataframe['volume_ratio_60'] = self.chan.cal_volume_ratio(dataframe_60) + #self.print_klc(dataframe, "1m: ") + #self.chan.plot_dual(dataframe_5, dataframe_30) + #dataframe['rsi'] = ta.RSI(dataframe, timeperiod=14) + #self.print_macd_div_list(dataframe) + #self.print_resample_df(dataframe, 1, 50) + #self.chan.get_bi_list(dataframe_30) + #if self.last_time + timedelta(minutes=1) < datetime.now(): + #print(informative.iloc[-1]) + #self.print_klc(dataframe, "1m: ") + #self.print_klc(dataframe_5, "5m: ") + #self.print_klc(dataframe_30, "30m:") + #self.log_macd_div_list(dataframe) + #self.print_xgb(dataframe, "1m_model") + #self.print_xgb(dataframe_5, "5m_model") + #self.print_xgb(dataframe_30, "30m_model") + #self.print_xgb(dataframe_60, "1h_model") + #self.print_xgb(dataframe_4h, "4h_model") + #print("-------------------------------------------------------------------------------") + #self.last_time = datetime.now() + dataframe = resampled_merge(dataframe, dataframe_5) + #dataframe = resampled_merge(dataframe, dataframe_15) + dataframe = resampled_merge(dataframe, dataframe_30) + dataframe = resampled_merge(dataframe, dataframe_60) + #dataframe = resampled_merge(dataframe, dataframe_4h) + return dataframe + # This is called when placing the initial order (opening trade) + def print_xgb(self, dataframe, model_name): + self.classifier.load_model(model_name) + klc_list = self.chan.get_klc_list(dataframe) + klc1 = klc_list[-1] + klc2 = klc_list[-2] + klc3 = klc_list[-3] + if klc1.end_time == klc2.start_time: + print(model_name, klc1.end_time, klc1.fx, self.classifier.predict(klc1)) + else: + print(model_name, klc1.start_time, klc1.fx, self.classifier.predict(klc1)) + print(model_name, klc2.end_time, klc2.fx, self.classifier.predict(klc2)) + print(model_name, klc3.end_time, klc3.fx, self.classifier.predict(klc3)) + def custom_stake_amount(self, pair: str, current_time: datetime, current_rate: float, + proposed_stake: float, min_stake: float | None, max_stake: float, + leverage: float, entry_tag: str | None, side: str, + **kwargs) -> float: + + # We need to leave most of the funds for possible further DCA orders + # This also applies to fixed stakes + return proposed_stake / self.max_dca_multiplier + def adjust_trade_position1(self, trade: Trade, current_time: datetime, + current_rate: float, current_profit: float, + min_stake: float | None, max_stake: float, + current_entry_rate: float, current_exit_rate: float, + current_entry_profit: float, current_exit_profit: float, + **kwargs + ) -> float | None | tuple[float | None, str | None]: + """ + Custom trade adjustment logic, returning the stake amount that a trade should be + increased or decreased. + This means extra entry or exit orders with additional fees. + Only called when `position_adjustment_enable` is set to True. + + For full documentation please go to https://www.freqtrade.io/en/latest/strategy-advanced/ + + When not implemented by a strategy, returns None + + :param trade: trade object. + :param current_time: datetime object, containing the current datetime + :param current_rate: Current entry rate (same as current_entry_profit) + :param current_profit: Current profit (as ratio), calculated based on current_rate + (same as current_entry_profit). + :param min_stake: Minimal stake size allowed by exchange (for both entries and exits) + :param max_stake: Maximum stake allowed (either through balance, or by exchange limits). + :param current_entry_rate: Current rate using entry pricing. + :param current_exit_rate: Current rate using exit pricing. + :param current_entry_profit: Current profit using entry pricing. + :param current_exit_profit: Current profit using exit pricing. + :param **kwargs: Ensure to keep this here so updates to this won't break your strategy. + :return float: Stake amount to adjust your trade, + Positive values to increase position, Negative values to decrease position. + Return None for no action. + Optionally, return a tuple with a 2nd element with an order reason + """ + #if trade.has_open_orders: + # Only act if no orders are open + #return + + #if current_profit > 0.05 and trade.nr_of_successful_exits == 0: + # Take half of the profit at +5% + #return -(trade.stake_amount / 2), "half_profit_5%" + + #if current_profit > -0.05: + #return None + + # Obtain pair dataframe (just to show how to access it) + dataframe, _ = self.dp.get_analyzed_dataframe(trade.pair, self.timeframe) + # Only buy when not actively falling price. + #last_candle = dataframe.iloc[-1].squeeze() + #previous_candle = dataframe.iloc[-2].squeeze() + #if last_candle["close"] < previous_candle["close"]: + #return None + filled_entries = trade.select_filled_orders(trade.entry_side) + last_entry = filled_entries[-1] + count_of_entries = trade.nr_of_successful_entries + # Allow up to 3 additional increasingly larger buys (4 in total) + # Initial buy is 1x + # If that falls to -5% profit, we buy 1.25x more, average profit should increase to roughly -2.2% + # If that falls down to -5% again, we buy 1.5x more + # If that falls once again down to -5%, we buy 1.75x more + # Total stake for this trade would be 1 + 1.25 + 1.5 + 1.75 = 5.5x of the initial allowed stake. + # That is why max_dca_multiplier is 5.5 + # Hope you have a deep wallet! + # This returns first order stake size + #print(dataframe.iloc[-1]['resample_{}_state'.format(self.get_ticker_indicator()*self.time60)]) + + # This returns first order stake size + stake_amount = filled_entries[0].stake_amount + # This then calculates current safety order size + stake_amount = stake_amount * (1 + (count_of_entries * 0.5)) + dataframe_date = dataframe.iloc[-1]['date'] + #print(stake_amount, "---------------------------------------------------") + if last_entry.order_filled_utc + timedelta(minutes=self.time5) < dataframe_date: + if dataframe.iloc[-self.time5]['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)] == "-10" and last_entry.side == "buy": + #print(dataframe.iloc[-self.time5]) + #print(stake_amount) + return stake_amount, "1/3rd_increase" + if last_entry.order_filled_utc + timedelta(minutes=self.time5) < dataframe_date: + if dataframe.iloc[-self.time5]['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)] == "10" and last_entry.side == "sell": + #print(dataframe.iloc[-self.time5]) + #print(stake_amount) + return stake_amount, "1/3rd_increase" + return None + def log_macd_div_list(self, dataframe): + bi_macd_div_list, bi_list, seg_macd_div_list, seg_list = self.chan.get_macd_div_list(dataframe) + logger.info(f"BI MACD DIV LIST") + for index in range(len(bi_list)-5, len(bi_list)): + bi = bi_list[index] + logger.info(f'{bi.start_time}, {bi.high}, {bi.low}, {bi.dir}, {bi.macd_div}') + logger.info(f"SEG MACD DIV LIST") + for index in range(len(seg_list)-5, len(seg_list)): + seg = seg_list[index] + logger.info(f'{seg.start_bi.start_time}, {seg.high}, {seg.low}, {seg.dir}, {seg.macd_div}') + def print_klc(self, df, label): + klc_list = self.chan.get_full_klc_list(df) + log_str = f"" + for index in range(len(klc_list)-5, len(klc_list)): + klc = klc_list[index] + bi_dir = str(klc.bi.dir).replace("Chan_BI_DIR.", "") + klc_fx_type = str(klc.klc_fx_type).replace("Chan_KLC_FX.", "") + volume_ratio = df.iloc[index]['volume_ratio'] + if klc.end_time: + log_str += f"{klc.end_time}E, {bi_dir}, {klc_fx_type}, {volume_ratio}, " + else: + log_str += f"{klc.start_time}S, {bi_dir}, {klc_fx_type}, {volume_ratio}, " + logger.info(label+log_str) + def print_resample_df(self, dataframe, time, limit=10): + df = dataframe.tail(limit) + if limit > 0: + if time == 1: + for index in range(len(dataframe) - limit, len(dataframe)): + cn1 = 'date' + cn2 = 'rsi' + cn3 = 'state' + logger.info(f'{df[cn1][index]}, {df[cn2][index]}, {df[cn3][index]}') + else: + for index in range(0, limit): + cn1 = 'resample_{}_date'.format(self.get_ticker_indicator()*time) + cn2 = 'resample_{}_rsi'.format(self.get_ticker_indicator()*time) + cn3 = 'resample_{}_state'.format(self.get_ticker_indicator()*time) + logger.info(f'{df[cn1][index]}, {df[cn2][index]}, {df[cn3][index]}') + def add_indicators(self, df): + fast = 9 + slow = 24 + period = 14 + macd = ta.MACD(df, fastperiod=fast, slowperiod=slow, signalperiod=period) + df['macd'] = macd['macd'] + df['macdsignal'] = macd['macdsignal'] + df['macdhist'] = macd['macdhist'] + df['ma5'] = ta.MA(df, timeperiod=5) + df['ma10'] = ta.MA(df, timeperiod=10) + df['ma30'] = ta.EMA(df, timeperiod=30) + df['ma250'] = ta.MA(df, timeperiod=250) + df['rsi'] = ta.RSI(df, timeperiod=14) + df['macd'] = df['macd'].fillna(0) + df['macdsignal'] = df['macdsignal'].fillna(0) + df['macdhist'] = df['macdhist'].fillna(0) + df['ma5'] = df['ma5'].fillna(0) + df['ma10'] = df['ma10'].fillna(0) + df['ma30'] = df['ma30'].fillna(0) + df['ma250'] = df['ma250'].fillna(0) + df['rsi'] = df['rsi'].fillna(0) + return df + def populate_entry_trend(self, dataframe: DataFrame, metadata: dict) -> DataFrame: + + dataframe.loc[ + ( + #(dataframe['state'] == "-30") + ((dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "10")) | + ((dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "20")) + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "-10") & + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time30)] == "-10") & + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "-10") + #(qtpylib.crossed_above(dataframe['macd'], dataframe['macdsignal'])) + ), + ['enter_long', 'enter_tag']] = (1, 'long_signal_chan') + dataframe.loc[ + ( + #(dataframe['state'] == "30") + ((dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "99")) | + ((dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "99")) + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "10") & + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time30)] == "10") & + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "10") + #(qtpylib.crossed_above(dataframe['macd'], dataframe['macdsignal'])) + ), + ['enter_short', 'enter_tag']] = (1, 'short_signal_chan') + return dataframe + def populate_exit_trend(self, dataframe: DataFrame, metadata: dict) -> DataFrame: + dataframe.loc[ + ( + #(dataframe['state']== "-10").shift(1) | + #(dataframe['state']== "-20").shift(1) + ((dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "-10")) | + ((dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "-20")) + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "10") + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time30)] == "10") & + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time60)] == "10") + ), + ['exit_long', 'exit_tag']] = (1, 'long_close_signal_chan') + dataframe.loc[ + ( + (dataframe['state'] == "99").shift(1) | + (dataframe['state'] == "99").shift(1) + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time5)].shift(self.time5) == "-10") + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time30)] == "-10") & + #(dataframe['resample_{}_state'.format(self.get_ticker_indicator()*self.time60)] == "-10") + ), + ['exit_short', 'exit_tag']] = (1, 'short_close_signal_chan') + return dataframe + def leverage(self, pair: str, current_time: datetime, current_rate: float, + proposed_leverage: float, max_leverage: float, entry_tag: Optional[str], side: str, + **kwargs) -> float: + return 1.0 + + def get_ticker_indicator(self): + return int(self.timeframe[:-1]) \ No newline at end of file diff --git a/strategies/ChanLun_SOL_5.py b/strategies/ChanLun_SOL_5.py index d140dbc..eb569b7 100644 --- a/strategies/ChanLun_SOL_5.py +++ b/strategies/ChanLun_SOL_5.py @@ -2,10 +2,8 @@ from freqtrade.strategy import IStrategy import sys import os -#sys.setrecursionlimit(1000000) #例如这里设置为一百万 -#sys.path.append(os.path.abspath("/freqtrade/user_data/Chan")) -#sys.path.append(os.path.abspath("/Users/jack/Project/freqtrade/user_data/Chan")) -sys.path.append(os.path.abspath("/Users/jack/Documents/GitHub/freqtrade/user_data/Chan")) +# 添加父目录到系统路径 +sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) from ChanLun import ChanLun from ChanLun_Classifier import ChanLunClassifier from ChanEnum import Chan_FX_TYPE, Chan_KLC_FX @@ -26,9 +24,9 @@ logger = logging.getLogger(__name__) # freqtrade download-data -c ./user_data/Chan/config/ChanLun_SOL.json -t 1m --pairs SOL/USDT:USDT --timerange=20250405- # freqtrade hyperopt --hyperopt-loss SharpeHyperOptLossDaily --spaces roi stoploss --strategy ChanLun_SOL_5 --strategy-path ./user _data/Chan/strategies -c ./user_data/Chan/config/ChanLun_SOL.json -e 200 --timerange=20250201-20250401 -# sudo docker compose run --rm chan_btc backtesting -c ./user_data/ChanLun_SOL.json --strategy ChanLun_SOL --strategy-path ./user_data/strategies --timerange=20250101- -# sudo docker compose run --rm chan_btc download-data -c ./user_data/ChanLun_SOL.json --pairs SOL/USDT:USDT -t 1m --timerange 20240101- -# sudo docker compose run --rm chan_btc trade -c ./user_data/ChanLun_SOL.json --strategy ChanLun_SOL --strategy-path ./user_data/strategies +# sudo docker compose run --rm chan_btc backtesting -c ./user_data/Chan/config/ChanLun_SOL.json --strategy ChanLun_SOL --strategy-path ./user_data/Chan/strategies --timerange=20250101- +# sudo docker compose run --rm chan_btc download-data -c ./user_data/Chan/config/ChanLun_SOL.json --pairs SOL/USDT:USDT -t 1m --timerange 20240101- +# sudo docker compose run --rm chan_btc trade -c ./user_data/Chan/config/ChanLun_SOL.json --strategy ChanLun_SOL --strategy-path ./user_data/Chan/strategies class ChanLun_SOL_5(IStrategy): INTERFACE_VERSION: int = 3 @@ -72,7 +70,7 @@ class ChanLun_SOL_5(IStrategy): time30 = 30 time60 = 60 time4h = 240 - time5 = 30 + time5 = 5 last_time = datetime.now() big_size = 0 big_state = "00" @@ -117,11 +115,11 @@ class ChanLun_SOL_5(IStrategy): self.classifier.train_model(dataframe, model_name="1m_model") self.classifier.train_model(dataframe_1d, model_name="1d_model") """ - - model_name = "60m_model" - df = dataframe_60 + """ + model_name = "30m_model" + df = dataframe_30 if self.classifier.model is None: - #self.classifier.train_model(df, model_name=model_name) + #self.classifier.train_model(df, model_name=model_name, data_file_path=model_name + '_feature_data.csv') self.classifier.load_model(model_name=model_name) klc_list = self.chan.get_klc_list(df) bi_list = self.chan.cal_bi_list(klc_list) @@ -131,14 +129,14 @@ class ChanLun_SOL_5(IStrategy): bottom_count = 0 for index in range(int(len(klc_list) * 0.8), len(klc_list)): klc = klc_list[index] - if self.classifier.predict(klc) > 0.37 and (klc.klc_fx_type == Chan_KLC_FX.BOTTOM1 or klc.klc_fx_type == Chan_KLC_FX.BOTTOM2): + if self.classifier.predict(klc) > 0.4 and (klc.klc_fx_type == Chan_KLC_FX.BOTTOM1 or klc.klc_fx_type == Chan_KLC_FX.BOTTOM2): features = klc.get_feature_data() - print(klc.bi.start_time, klc.start_time, klc.fx, self.classifier.predict(klc), features['klc_macd'], features['klc_macd_hist'], features['klc_rsi'], features['klc_macd_signal']) + print(klc.end_time, klc.fx, self.classifier.predict(klc), features['klc_macd'], features['klc_macd_hist'], features['klc_rsi'], features['klc_macd_signal']) bottom_avg += self.classifier.predict(klc) bottom_count += 1 - if self.classifier.predict(klc) > 0.42 and (klc.klc_fx_type == Chan_KLC_FX.TOP1 or klc.klc_fx_type == Chan_KLC_FX.TOP2): + if self.classifier.predict(klc) > 0.35 and (klc.klc_fx_type == Chan_KLC_FX.TOP1 or klc.klc_fx_type == Chan_KLC_FX.TOP2): features = klc.get_feature_data() - print(klc.bi.start_time, klc.start_time, klc.fx, self.classifier.predict(klc), features['klc_macd'], features['klc_macd_hist'], features['klc_rsi'], features['klc_macd_signal']) + print(klc.end_time, klc.fx, self.classifier.predict(klc), features['klc_macd'], features['klc_macd_hist'], features['klc_rsi'], features['klc_macd_signal']) top_avg += self.classifier.predict(klc) top_count += 1 if bottom_count > 0: @@ -147,7 +145,7 @@ class ChanLun_SOL_5(IStrategy): top_avg /= top_count print(bottom_avg, top_avg) print("-------------------------------------------------------------------------------") - + """ """ self.print_xgb(dataframe, "1m_model") self.print_xgb(dataframe_5, "5m_model") @@ -167,13 +165,16 @@ class ChanLun_SOL_5(IStrategy): #dataframe_60['state'] = self.chan.cal_klu_state(dataframe_60) #dataframe_4h['state'] = self.chan.resample_klc_list(dataframe_4h) - self.chan.plot_dual(dataframe_30, dataframe_60) + #self.chan.plot_dual(dataframe_5, dataframe_30) dataframe['rsi'] = ta.RSI(dataframe, timeperiod=14) #self.print_macd_div_list(dataframe) #self.print_resample_df(dataframe, 1, 50) #self.chan.get_bi_list(dataframe_30) if self.last_time + timedelta(minutes=1) < datetime.now(): #print(informative.iloc[-1]) + #self.print_klc(dataframe, "1m: ") + #self.print_klc(dataframe_5, "5m: ") + #self.print_klc(dataframe_30, "30m:") #self.log_macd_div_list(dataframe) #self.print_xgb(dataframe, "1m_model") #self.print_xgb(dataframe_5, "5m_model") @@ -311,6 +312,19 @@ class ChanLun_SOL_5(IStrategy): fx5 = fx_list[-5] #print(fx1.end_time, fx1.fx, fx2.end_time, fx2.fx, fx3.end_time, fx3.fx) logger.info(f'\n{fx5.end_time} {fx5.state} {fx4.end_time} {fx4.state} {fx3.end_time} {fx3.state} {fx2.end_time} {fx2.state} {fx1.end_time} {fx1.state} TF: {label}') + def print_klc(self, df, label): + klc_list = self.chan.get_full_klc_list(df) + log_str = f"" + for index in range(len(klc_list)-5, len(klc_list)): + klc = klc_list[index] + fx = str(klc.fx).replace("Chan_FX_TYPE.", "") + bi_dir = str(klc.bi.dir).replace("Chan_BI_DIR.", "") + klc_fx_type = str(klc.klc_fx_type).replace("Chan_KLC_FX.", "") + if klc.end_time: + log_str += f"{klc.end_time}E, {bi_dir}, {klc_fx_type}, " + else: + log_str += f"{klc.start_time}S, {bi_dir}, {klc_fx_type}, " + logger.info(label+log_str) def print_fx_list(self, df): bsp_list = self.chan.get_bsp_list(self.chan.get_klc_list(df)) for bsp in bsp_list: @@ -336,9 +350,9 @@ class ChanLun_SOL_5(IStrategy): cn3 = 'resample_{}_state'.format(self.get_ticker_indicator()*time) logger.info(f'{df[cn1][index]}, {df[cn2][index]}, {df[cn3][index]}') def add_indicators(self, df): - fast = 8 - slow = 16 - period = 6 + fast = 9 + slow = 24 + period = 14 macd = ta.MACD(df, fastperiod=fast, slowperiod=slow, signalperiod=period) df['macd'] = macd['macd'] df['macdsignal'] = macd['macdsignal'] diff --git a/web/app.py b/web/app.py index 4299763..4379799 100644 --- a/web/app.py +++ b/web/app.py @@ -128,6 +128,7 @@ def get_kl_data(symbol, timeframe, limit=1000, start_time=None, end_time=None): # 按时间排序 df = df.sort_values('timestamp') + """ chan = ChanLun() klc_list = chan.get_klc_list(df) klc_index = 0 @@ -140,13 +141,14 @@ def get_kl_data(symbol, timeframe, limit=1000, start_time=None, end_time=None): if index == klc.start_klu.index: ret_df.loc[klc_index] = df_copy.loc[index] klc_index += 1 + """ # 如果过滤后没有数据，返回None - if len(ret_df) == 0: + if len(df) == 0: print("过滤后无数据") return None - print(f"获取到总共 {len(ret_df)} 条数据") - return ret_df + print(f"获取到总共 {len(df)} 条数据") + return df except Exception as e: print(f"获取数据错误: {e}") @@ -471,6 +473,9 @@ def analyze(): 'direction': convert_direction(bi.dir) } for bi in element_analysis['bi_list'] if bi.end_klc] + # 添加小周期K线数据 + result['element_kline_data'] = element_df.to_dict('records') + result['element_seg_list'] = [{ 'start_time': seg.start_bi.start_klc.end_time if isinstance(seg.start_bi.start_klc.end_time, str) else seg.start_bi.start_klc.end_time.astimezone(client_tz).isoformat(), 'end_time': (seg.end_bi.end_klc.end_time if isinstance(seg.end_bi.end_klc.end_time, str) else seg.end_bi.end_klc.end_time.astimezone(client_tz).isoformat()) if seg.end_bi else None, @@ -503,6 +508,14 @@ def analyze(): 'desc': point['desc'] } for point in element_analysis['trade_points']] + # 添加小周期分型信息 + result['element_klc_fx_info'] = [{ + 'time': format_time_safely(point['time'], client_tz), + 'price': point['price'], + 'fx_type': point['fx_type'], + 'is_bottom': point['is_bottom'] + } for point in element_analysis['klc_fx_info']] + print(f"小周期分析完成: {element_timeframe}, 笔数量: {len(result['element_bi_list'])}, {'仅元素数据' if elements_only else '包含主周期数据'}") else: print(f"无法获取小周期数据: {element_timeframe}") diff --git a/web/requirements.txt b/web/requirements.txt index 05b50c2..b73a9ba 100644 --- a/web/requirements.txt +++ b/web/requirements.txt @@ -1,5 +1,13 @@ -flask==2.0.1 -ccxt==4.4.70 -pandas==1.3.3 -numpy==1.21.2 -plotly==5.3.1 \ No newline at end of file +flask>=2.0.1 +ccxt>=4.4.70 +pandas>=1.3.3 +numpy>=1.21.2 +plotly>=5.3.1 +matplotlib>=3.4.3 +pytz>=2021.1 +python-dateutil>=2.8.2 +xgboost>=1.5.0 +scikit-learn>=1.0.1 +ta-lib>=0.4.19 +bootstrap-flask>=2.0.0 +gunicorn>=20.1.0 \ No newline at end of file diff --git a/web/templates/index.html b/web/templates/index.html index fe8af7f..c1c7ab8 100644 --- a/web/templates/index.html +++ b/web/templates/index.html @@ -5,10 +5,12 @@ + + @@ -271,6 +273,23 @@ + + +
+ + +
+
+ + + +
+ +
+ + +
+
@@ -279,8 +298,15 @@
- @@ -731,7 +757,7 @@ // 添加买卖点复选框变更事件 $('#showTradePoints').change(function() { - updateChartDisplay(); + refreshChart(currentData); }); // 添加分型类型复选框变更事件 @@ -924,8 +950,11 @@ console.log('- 显示中枢:', $('#showMainZs').is(':checked')); console.log('- 显示未完成中枢:', $('#showMainUncompletedZs').is(':checked')); console.log('- 显示MACD:', $('#showMacd').is(':checked')); - console.log('- 显示买卖点:', $('#showTradePoints').is(':checked')); + console.log('- 显示成交量:', $('#showVolume').is(':checked')); console.log('- 显示分型类型:', $('#showKlcFxType').is(':checked')); + console.log('- 显示小周期分型:', $('#showElementKlcFxType').is(':checked')); + console.log('- 显示买卖点:', $('#showTradePoints').is(':checked')); + console.log('- 显示原始K线:', $('#showOriginalKline').is(':checked')); // 重新初始化图表，这将清除旧图形并重新绘制 initTradingView($('#symbol').val(), $('#timeframe').val()); @@ -1212,18 +1241,42 @@ macdChart = LightweightCharts.createChart(macdChartContainer, createChartOptions(false)); } - // 转换K线数据 - 始终使用主时间周期数据 - const candles = currentData.kline_data.map((kline) => { - const date = new Date(kline.date); - const timestamp = date.getTime() / 1000; - return { - time: timestamp, - open: parseFloat(kline.open), - high: parseFloat(kline.high), - low: parseFloat(kline.low), - close: parseFloat(kline.close), - }; - }); + // 转换K线数据 - 根据选中的周期使用主周期或小周期数据 + let candles; + const useElementPeriod = $('#elementPeriodKline').is(':checked') && + currentData.element_timeframe && + currentData.element_kline_data; + + // 输出K线周期选择状态 + console.log('K线周期选择:', useElementPeriod ? '小周期' : '主周期'); + + if (useElementPeriod) { + // 使用小周期K线数据 + candles = currentData.element_kline_data.map((kline) => { + const date = new Date(kline.date); + const timestamp = date.getTime() / 1000; + return { + time: timestamp, + open: parseFloat(kline.open), + high: parseFloat(kline.high), + low: parseFloat(kline.low), + close: parseFloat(kline.close), + }; + }); + } else { + // 使用主周期K线数据 + candles = currentData.kline_data.map((kline) => { + const date = new Date(kline.date); + const timestamp = date.getTime() / 1000; + return { + time: timestamp, + open: parseFloat(kline.open), + high: parseFloat(kline.high), + low: parseFloat(kline.low), + close: parseFloat(kline.close), + }; + }); + } // 创建蜡烛图系列并设置数据 if (showOriginalKline) { @@ -1257,14 +1310,23 @@ } // 转换成交量数据 - 始终使用主K线周期数据 - const volumes = currentData.kline_data.map(kline => { - const timestamp = Math.floor(new Date(kline.date).getTime() / 1000); - return { - time: timestamp, - value: parseFloat(kline.volume), - color: parseFloat(kline.close) >= parseFloat(kline.open) ? 'rgba(220, 53, 69, 0.5)' : 'rgba(40, 167, 69, 0.5)', - }; - }); + const volumes = useElementPeriod ? + currentData.element_kline_data.map(kline => { + const timestamp = Math.floor(new Date(kline.date).getTime() / 1000); + return { + time: timestamp, + value: parseFloat(kline.volume), + color: parseFloat(kline.close) >= parseFloat(kline.open) ? 'rgba(220, 53, 69, 0.5)' : 'rgba(40, 167, 69, 0.5)', + }; + }) : + currentData.kline_data.map(kline => { + const timestamp = Math.floor(new Date(kline.date).getTime() / 1000); + return { + time: timestamp, + value: parseFloat(kline.volume), + color: parseFloat(kline.close) >= parseFloat(kline.open) ? 'rgba(220, 53, 69, 0.5)' : 'rgba(40, 167, 69, 0.5)', + }; + }); // 添加成交量图表 const volumeSeries = volumeChart.addHistogramSeries({ @@ -2440,6 +2502,66 @@ console.log('绘制分型类型标签 - 已禁用或无数据'); } + // 绘制小周期分型标记 + if ($('#showElementKlcFxType').is(':checked') && currentData.element_klc_fx_info && currentData.element_klc_fx_info.length > 0) { + console.log(`绘制小周期分型标记，共${currentData.element_klc_fx_info.length}条`); + + currentData.element_klc_fx_info.forEach(function(fx) { + try { + // 直接使用UTC时间戳（秒） + const timestamp = Math.floor(new Date(fx.time).getTime() / 1000); + const price = parseFloat(fx.price); + + if (isNaN(timestamp) || isNaN(price)) { + console.error('小周期分型时间或价格转换错误:', fx.time, fx.price); + return; + } + + // 小周期分型使用红色标记，不同于主周期分型 + const redColor = '#FF0000'; // 红色 + + // 创建标记系列 + const markerSeries = mainChart.addLineSeries({ + lastValueVisible: false, + priceLineVisible: false, + }); + + // 设置文本标记 + markerSeries.setMarkers([ + { + time: timestamp, + position: fx.is_bottom ? 'belowBar' : 'aboveBar', + color: redColor, + shape: 'arrowUp', // 使用箭头形状，与主周期分型区分 + text: fx.is_bottom ? '↓' : '↑', // 显示箭头 + size: 1 + } + ]); + + // 为小周期分型添加明显的箭头标记 + const arrowSeries = mainChart.addLineSeries({ + lastValueVisible: false, + priceLineVisible: false, + lineWidth: 1, + color: redColor + }); + + // 计算标记位置，底分型在价格下方，顶分型在价格上方 + const offset = fx.is_bottom ? -0.001 * price : 0.001 * price; + + arrowSeries.setData([{ + time: timestamp, + value: price + offset + }]); + + } catch (e) { + console.error('绘制小周期分型标记出错:', e); + } + }); + } else { + console.log('绘制小周期分型标记 - 已禁用或无数据'); + } + // 调整所有图表以适应数据 mainChart.timeScale().fitContent(); volumeChart.timeScale().fitContent(); @@ -2487,18 +2609,40 @@ // 检查是否显示原始K线 const showOriginalKline = $('#showOriginalKline').is(':checked'); + // 检查是否使用小周期数据 + const useElementPeriod = $('#elementPeriodKline').is(':checked') && + currentData.element_timeframe && + currentData.element_kline_data; + // 转换K线数据 - const candles = currentData.kline_data.map((kline) => { - const date = new Date(kline.date); - const timestamp = date.getTime() / 1000; - return { - time: timestamp, - open: parseFloat(kline.open), - high: parseFloat(kline.high), - low: parseFloat(kline.low), - close: parseFloat(kline.close), - }; - }); + let candles; + if (useElementPeriod) { + console.log('使用小周期K线数据'); + candles = currentData.element_kline_data.map((kline) => { + const date = new Date(kline.date); + const timestamp = date.getTime() / 1000; + return { + time: timestamp, + open: parseFloat(kline.open), + high: parseFloat(kline.high), + low: parseFloat(kline.low), + close: parseFloat(kline.close), + }; + }); + } else { + console.log('使用主周期K线数据'); + candles = currentData.kline_data.map((kline) => { + const date = new Date(kline.date); + const timestamp = date.getTime() / 1000; + return { + time: timestamp, + open: parseFloat(kline.open), + high: parseFloat(kline.high), + low: parseFloat(kline.low), + close: parseFloat(kline.close), + }; + }); + } // 更新K线数据 if (showOriginalKline && tvWidget.series.candleSeries) { @@ -2514,14 +2658,23 @@ } // 更新成交量数据 - const volumes = currentData.kline_data.map(kline => { - const timestamp = Math.floor(new Date(kline.date).getTime() / 1000); - return { - time: timestamp, - value: parseFloat(kline.volume), - color: parseFloat(kline.close) >= parseFloat(kline.open) ? 'rgba(220, 53, 69, 0.5)' : 'rgba(40, 167, 69, 0.5)', - }; - }); + const volumes = useElementPeriod ? + currentData.element_kline_data.map(kline => { + const timestamp = Math.floor(new Date(kline.date).getTime() / 1000); + return { + time: timestamp, + value: parseFloat(kline.volume), + color: parseFloat(kline.close) >= parseFloat(kline.open) ? 'rgba(220, 53, 69, 0.5)' : 'rgba(40, 167, 69, 0.5)', + }; + }) : + currentData.kline_data.map(kline => { + const timestamp = Math.floor(new Date(kline.date).getTime() / 1000); + return { + time: timestamp, + value: parseFloat(kline.volume), + color: parseFloat(kline.close) >= parseFloat(kline.open) ? 'rgba(220, 53, 69, 0.5)' : 'rgba(40, 167, 69, 0.5)', + }; + }); if (tvWidget.series.volumeSeries) { tvWidget.series.volumeSeries.setData(volumes); @@ -3572,6 +3725,51 @@ // 更新表格数据 updateTables(data); } + + // 绑定分型类型显示开关 + $('#showKlcFxType').change(function() { + refreshChart(currentData); + }); + + // 绑定小周期分型显示开关 + $('#showElementKlcFxType').change(function() { + refreshChart(currentData); + }); + + // 绑定买卖点显示开关 + $('#showTradePoints').change(function() { + refreshChart(currentData); + }); + + // 绑定K线周期切换 + $('input[name="klinePeriod"]').change(function() { + refreshChart(currentData); + }); + + // 在控制台输出当前显示状态 + console.log('当前显示状态:', { + 'showOriginalKline': $('#showOriginalKline').is(':checked'), + 'showMainBi': $('#showMainBi').is(':checked'), + 'showMainSeg': $('#showMainSeg').is(':checked'), + 'showMainZs': $('#showMainZs').is(':checked'), + 'showMainUncompletedZs': $('#showMainUncompletedZs').is(':checked'), + 'showVolume': $('#showVolume').is(':checked'), + 'showMacd': $('#showMacd').is(':checked'), + 'showKlcFxType': $('#showKlcFxType').is(':checked'), + 'showElementKlcFxType': $('#showElementKlcFxType').is(':checked'), + 'showTradePoints': $('#showTradePoints').is(':checked'), + 'timeframe': $('#timeframe').val(), + 'elementTimeframe': $('#elementTimeframe').val(), + 'timezone': $('#timezone').val(), + 'start_time': $('#start_time').val(), + 'end_time': $('#end_time').val() + }); + + // 初始化提示工具 + var tooltipTriggerList = [].slice.call(document.querySelectorAll('[data-bs-toggle="tooltip"]')) + var tooltipList = tooltipTriggerList.map(function (tooltipTriggerEl) { + return new bootstrap.Tooltip(tooltipTriggerEl) + }) \ No newline at end of file