get history price 1.1

hlfx.py

@@ -15,7 +15,7 @@ db = pymysql.connect(host='localhost',
                      password='r6kEwqWU9!v3',
                      database='qbh')
 
-fre = '1d'
+fre = '30m'
 
 cursor = db.cursor()
 # cursor.execute("select table_name from information_schema.tables where table_schema='qbh_hlfx_backup' and table_name like {}".format('\'%{}\''.format(fre)))

qbh.py

@@ -33,7 +33,7 @@ stocks = list(get_all_securities(['stock'], date='2022-02-01').index)
 
 thd = threading.local()
 
-# docker run --name mysql -p 3307:3306 -e MYSQL_ROOT_PASSWORD='r6kEwqWU9!v3' -v /Users/daniel/mysqldata:/var/lib/mysql -d mysql:8.0-oracle
+
 # def qbh(stocks, engine, engine_backup):
 
 fre = '30m'
@@ -51,68 +51,69 @@ print("#########################################################################
       "###############################################################################################################"
       "###############################################################################################################"
       "###############################################################################################################")
-engine = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qbh?charset=utf8')
+# engine = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qbh?charset=utf8')
 
-for stock in stocks:
-    thd.new_df = pd.DataFrame(columns=('date', 'open', 'close', 'high', 'low', 'volume', 'money', 'HL'))
-    # print(new_df.head())
-    thd.df_day = stk['stk' + stock]
-    for i in thd.df_day.index:
-        if i == 0 or i == 1:
-            thd.new_df = pd.concat([thd.new_df, thd.df_day.iloc[[i]]], ignore_index=True)
-        # 不包含
-        elif (thd.new_df.iloc[-1, 3] > thd.df_day.loc[i, 'high']
-              and thd.new_df.iloc[-1, 4] > thd.df_day.loc[i, 'low']) \
-                or (thd.new_df.iloc[-1, 3] < thd.df_day.loc[i, 'high']
-                    and thd.new_df.iloc[-1, 4] < thd.df_day.loc[i, 'low']):
-            thd.new_df = pd.concat([thd.new_df, thd.df_day.iloc[[i]]], ignore_index=True)
-        # 包含
-        else:
-            # (new_df.iloc[-1,3]>=df_day.loc[i,'high'] and new_df.iloc[-1,4]<= df_day.loc[i,'low']):
-            # 左高，下降
-            if thd.new_df.iloc[-2, 3] > thd.new_df.iloc[-1, 3]:
-                thd.new_df.iloc[-1, 3] = min(thd.new_df.iloc[-1, 3], thd.df_day.loc[i, 'high'])
-                thd.new_df.iloc[-1, 4] = min(thd.new_df.iloc[-1, 4], thd.df_day.loc[i, 'low'])
+def qbh(stocks, engine, engine_backup):
+    for stock in stocks:
+        thd.new_df = pd.DataFrame(columns=('date', 'open', 'close', 'high', 'low', 'volume', 'money', 'HL'))
+        # print(new_df.head())
+        thd.df_day = stk['stk' + stock]
+        for i in thd.df_day.index:
+            if i == 0 or i == 1:
+                thd.new_df = pd.concat([thd.new_df, thd.df_day.iloc[[i]]], ignore_index=True)
+            # 不包含
+            elif (thd.new_df.iloc[-1, 3] > thd.df_day.loc[i, 'high']
+                  and thd.new_df.iloc[-1, 4] > thd.df_day.loc[i, 'low']) \
+                    or (thd.new_df.iloc[-1, 3] < thd.df_day.loc[i, 'high']
+                        and thd.new_df.iloc[-1, 4] < thd.df_day.loc[i, 'low']):
+                thd.new_df = pd.concat([thd.new_df, thd.df_day.iloc[[i]]], ignore_index=True)
+            # 包含
             else:
-                # 右高，上升
-                thd.new_df.iloc[-1, 3] = max(thd.new_df.iloc[-1, 3], thd.df_day.loc[i, 'high'])
-                thd.new_df.iloc[-1, 4] = max(thd.new_df.iloc[-1, 4], thd.df_day.loc[i, 'low'])
-    thd.new_df.to_sql('stk%s_%s' % (stock, fre), con=engine, index=True, if_exists='append')
-    with engine.connect() as con:
-        con.execute('ALTER TABLE `stk%s_%s` ADD PRIMARY KEY (`date`);' % (stock, fre))
-    # thd.new_df.to_sql('stk%s_%s' % (stock[:6], u), con=engine_backup, index=True, if_exists='replace')
-    # with engine_backup.connect() as con_backup:
-    #     con_backup.execute('ALTER TABLE stk%s_%s ADD PRIMARY KEY (`date`);' % (stock[:6], u))
-    # thd.new_df.to_csv(
-    #     '/Users/daniel/Library/CloudStorage/OneDrive-个人/个人/python_stocks/20220211qbh/qbh%s.csv' % stock[:6])
-    print(stock)
-    print("**************")
+                # (new_df.iloc[-1,3]>=df_day.loc[i,'high'] and new_df.iloc[-1,4]<= df_day.loc[i,'low']):
+                # 左高，下降
+                if thd.new_df.iloc[-2, 3] > thd.new_df.iloc[-1, 3]:
+                    thd.new_df.iloc[-1, 3] = min(thd.new_df.iloc[-1, 3], thd.df_day.loc[i, 'high'])
+                    thd.new_df.iloc[-1, 4] = min(thd.new_df.iloc[-1, 4], thd.df_day.loc[i, 'low'])
+                else:
+                    # 右高，上升
+                    thd.new_df.iloc[-1, 3] = max(thd.new_df.iloc[-1, 3], thd.df_day.loc[i, 'high'])
+                    thd.new_df.iloc[-1, 4] = max(thd.new_df.iloc[-1, 4], thd.df_day.loc[i, 'low'])
+        thd.new_df.to_sql('stk%s_%s' % (stock, fre), con=engine, index=True, if_exists='append')
+        with engine.connect() as con:
+            con.execute('ALTER TABLE `stk%s_%s` ADD PRIMARY KEY (`date`);' % (stock, fre))
+        # thd.new_df.to_sql('stk%s_%s' % (stock[:6], u), con=engine_backup, index=True, if_exists='replace')
+        # with engine_backup.connect() as con_backup:
+        #     con_backup.execute('ALTER TABLE stk%s_%s ADD PRIMARY KEY (`date`);' % (stock[:6], u))
+        # thd.new_df.to_csv(
+        #     '/Users/daniel/Library/CloudStorage/OneDrive-个人/个人/python_stocks/20220211qbh/qbh%s.csv' % stock[:6])
+        print(stock)
+        print("**************")
         #
         # # new_df.to_csv('new_df.csv')
         #
         # #return new_df
 
 
-# engine = []
-# engine_backup = []
+engine = []
+engine_backup = []
 #
 #
 #
-# # 开始去包含
-# # qbh(stocks)
-# thread_list = []
-# step = 5
-# times_engine = 0
-# for m in range(0, len(stocks), step):
-#     engine.append(create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qbh?charset=utf8'))
-#     engine_backup.append(create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qbh_hlfx_backup?charset=utf8'))
-#     thread = threading.Thread(target=qbh, args=(stocks[m:m + step], engine[times_engine], engine_backup[times_engine]))
-#     times_engine =times_engine + 1
-#     thread.start()
-#     thread_list.append(thread)
-#
-# for thread in thread_list:
-#     thread.join()
+# 开始去包含
+# qbh(stocks)
+thread_list = []
+step = 100
+times_engine = 0
+for m in range(0, len(stocks), step):
+    engine.append(create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qbh?charset=utf8'))
+    engine_backup.append(create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qbh_hlfx_backup?charset=utf8'))
+    thread = threading.Thread(target=qbh, args=(stocks[m:m + step], engine[times_engine], engine_backup[times_engine]))
+    times_engine =times_engine + 1
+    thread.start()
+    thread_list.append(thread)
+
+for thread in thread_list:
+    thread.join()
 #
 
 endtime = dt.now()

real_time_signal.py

@@ -24,6 +24,7 @@ cursor = db.cursor()
 cursor.execute('show tables like {}'.format('\'%{}\''.format(fre)))
 # stocks = [tuple[0] for tuple in cursor.fetchall()]
 stocks = list(get_all_securities(['stock'], date='2021-12-31').index)
+stocks = ['301058.XSHE']
 # stocks = stocks[0:500]
 print(dt.now(), 'stocks范围已获取！')
 
@@ -36,6 +37,8 @@ for stock in stocks:
     except BaseException:
         continue
 
+
+
 print(dt.now(), '数据库数据已赋值！')
 
 thd = threading.local()
@@ -68,76 +71,73 @@ def qbh_hlfx(stocks, df):
                         thd.df_day.iloc[-1, 3] = max(thd.df_day.iloc[-1, 3], thd.get_bars.loc[i, 'high'])
                         thd.df_day.iloc[-1, 4] = max(thd.df_day.iloc[-1, 4], thd.get_bars.loc[i, 'low'])
         # return thd.df_day
-
-            # 寻找顶底分型
-            for x in range(stk_len, len(thd.df_day.index)):
-                m = x - 1
-                # 底
-                if ((thd.df_day.loc[x,'high']>thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']>thd.df_day.loc[x-1,'high'])):
-                    # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
-                        # stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
-                    thd.df_day.loc[x, 'HL'] = 'L*'
-                    if x == len(thd.df_day.index) -1:
-                        pass
-                        # print(stock, '$$$$$$$', '\n', thd.df_day.loc[x, 'date'], '考虑————买入！！')
-                    while m:
-                        if thd.df_day.loc[m, 'HL'] == 'H':
-                            if(i-m) > 3:
-                                thd.df_day.loc[x, 'HL'] = 'L'
-                                if x == len(thd.df_day.index) - 1:
-                                    print(stock, '$$$$$$$', '\n', '买买买买买！！')
-                            break
-                        elif (thd.df_day.loc[m, 'HL'] == 'L' ):
-                            if thd.df_day.loc[x-1, 'low'] < thd.df_day.loc[m-1, 'low']:
-                                # 前一个为底，且中间存在不包含 or 更低的底
-                                thd.df_day.loc[x, 'HL'] = 'L'
-                                if x == len(thd.df_day.index) - 1:
-                                    print(stock, '$$$$$$$', '\n', '中继后的底————买吗？！')
+            if len(thd.df_day.index) > 2:
+                # 寻找顶底分型
+                for x in range(stk_len, len(thd.df_day.index)):
+                    m = x - 1
+                    # 底
+                    if ((thd.df_day.loc[x,'high']>thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']>thd.df_day.loc[x-1,'high'])):
+                        # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
+                            # stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
+                        thd.df_day.loc[x, 'HL'] = 'L*'
+                        while m:
+                            if thd.df_day.loc[m, 'HL'] == 'H':
+                                if(x-m) > 3:
+                                    thd.df_day.loc[x, 'HL'] = 'L'
+                                    if x == len(thd.df_day.index) - 1:
+                                        print(stock, '$$$$$$$', '\n', thd.df_day.loc[x, 'date'], '买买买买买！！')
                                 break
-                            else:
+                            elif (thd.df_day.loc[m, 'HL'] == 'L' ):
+                                if thd.df_day.loc[x-1, 'low'] < thd.df_day.loc[m-1, 'low']:
+                                    # 前一个为底，且中间存在不包含 or 更低的底
+                                    thd.df_day.loc[x, 'HL'] = 'L'
+                                    if x == len(thd.df_day.index) - 1:
+                                        # pass
+                                        print(stock, '$$$$$$$', '\n', thd.df_day.loc[x, 'date'],'中继后的底————买吗？！')
+                                    break
+                                else:
+                                    break
+                            m = m-1
+                    # 顶
+                    elif ((thd.df_day.loc[x,'high']<thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']<thd.df_day.loc[x-1,'high'])):
+                        # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
+                        #     stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
+                        thd.df_day.loc[x, 'HL'] = 'H*'
+                        while m:
+                            if thd.df_day.loc[m, 'HL'] == 'L':
+                                if x-m > 3:
+                                    thd.df_day.loc[x, 'HL'] = 'H'
+                                    if x == len(thd.df_day.index) - 1:
+                                        # print(stock, '!!!!!!!', '\n', '卖卖卖卖卖卖卖!')
+                                        pass
+                                    thd.df_day.loc[x, 9] = thd.df_day.loc[x, 'close'] - thd.df_day.loc[m, 'close']
                                 break
-                        m = m-1
-
-                # 顶
-                elif ((thd.df_day.loc[x,'high']<thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']<thd.df_day.loc[x-1,'high'])):
-                    # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
-                    #     stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
-                    thd.df_day.loc[x, 'HL'] = 'H*'
-                    if x == len(thd.df_day.index) - 1:
-                        # print(stock, '!!!!!!!', '\n', thd.df_day.loc[x, 'date'], '考虑————卖出！！')
-                        pass
-                    while m:
-                        if thd.df_day.loc[m, 'HL'] == 'L':
-                            if i-m > 3:
-                                thd.df_day.loc[x, 'HL'] = 'H'
-                                if x == len(thd.df_day.index) - 1:
-                                    # print(stock, '!!!!!!!', '\n', '卖卖卖卖卖卖卖!')
-                                    pass
-                                thd.df_day.loc[x, 9] = thd.df_day.loc[x, 'close'] - thd.df_day.loc[m, 'close']
-                            break
-                        elif (thd.df_day.loc[m, 'HL'] == 'H'):
-                            if thd.df_day.loc[x-1, 'high'] > thd.df_day.loc[m-1, 'high']:
-                                # 前一个为顶，且中间存在不包含 or 更高的顶
-                                thd.df_day.loc[x, 'HL'] = 'H'
-                                if x == len(thd.df_day.index) - 1:
-                                    pass
-                                    # print(stock, '/\/\/\/\/\/\/', '一顶更有一顶高！')
+                            elif (thd.df_day.loc[m, 'HL'] == 'H'):
+                                if thd.df_day.loc[x-1, 'high'] > thd.df_day.loc[m-1, 'high']:
+                                    # 前一个为顶，且中间存在不包含 or 更高的顶
+                                    thd.df_day.loc[x, 'HL'] = 'H'
+                                    if x == len(thd.df_day.index) - 1:
+                                        pass
+                                        # print(stock, '/\/\/\/\/\/\/', '一顶更有一顶高！')
+                                    break
                                 break
-                            break
-                        m = m-1
-                else:
-                    thd.df_day.loc[x, 'HL'] = '-'
+                            m = m-1
+                    else:
+                        thd.df_day.loc[x, 'HL'] = '-'
+                    print(thd.df_day)
+            else:
+                pass
         except BaseException:
             continue
 
 
-while True:
-    df = get_bars(stocks, count=20, unit=fre,
-                  fields=['date', 'open', 'close', 'high', 'low', 'volume', 'money'], include_now=True, df=True)
-    print(dt.now(), 'get_bars 成功')
-    # strattime = dt.now()
-    qbh_hlfx(stocks, df)
-    # endtime = dt.now()
+# while True:
+df = get_bars(stocks, count=2, unit=fre,
+              fields=['date', 'open', 'close', 'high', 'low', 'volume', 'money'], include_now=True, df=True)
+print(dt.now(), 'get_bars 成功')
+# strattime = dt.now()
+qbh_hlfx(stocks, df)
+# endtime = dt.now()
 
 
 # end = dt.now()

real_time_signal_30m.py

@@ -69,64 +69,59 @@ def qbh_hlfx(stocks, df):
                         thd.df_day.iloc[-1, 4] = max(thd.df_day.iloc[-1, 4], thd.get_bars.loc[x, 'low'])
         # return thd.df_day
 
-            # 寻找顶底分型
-            for x in range(stk_len, len(thd.df_day.index)):
-                m = x - 1
-                # 底
-                if ((thd.df_day.loc[x,'high']>thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']>thd.df_day.loc[x-1,'high'])):
-                    # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
-                        # stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
-                    thd.df_day.loc[x, 'HL'] = 'L*'
-                    if x == len(thd.df_day.index) -1:
-                        pass
-                        # print(stock, '$$$$$$$', '\n', thd.df_day.loc[x, 'date'], '考虑————买入！！')
-                    while m:
-                        if thd.df_day.loc[m, 'HL'] == 'H':
-                            if(x-m) > 3:
-                                thd.df_day.loc[x, 'HL'] = 'L'
-                                if x == len(thd.df_day.index) - 1:
-                                    print(stock, '$$$$$$$', '\n', '买买买买买！！')
-                            break
-                        elif (thd.df_day.loc[m, 'HL'] == 'L' ):
-                            if thd.df_day.loc[x-1, 'low'] < thd.df_day.loc[m-1, 'low']:
-                                # 前一个为底，且中间存在不包含 or 更低的底
-                                thd.df_day.loc[x, 'HL'] = 'L'
-                                if x == len(thd.df_day.index) - 1:
-                                    print(stock, '$$$$$$$', '\n', '中继后的底————买吗？！')
+            if len(thd.df_day.index) > 2:
+                # 寻找顶底分型
+                for x in range(stk_len, len(thd.df_day.index)):
+                    m = x - 1
+                    # 底
+                    if ((thd.df_day.loc[x,'high']>thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']>thd.df_day.loc[x-1,'high'])):
+                        # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
+                            # stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
+                        thd.df_day.loc[x, 'HL'] = 'L*'
+                        while m:
+                            if thd.df_day.loc[m, 'HL'] == 'H':
+                                if(x-m) > 3:
+                                    thd.df_day.loc[x, 'HL'] = 'L'
+                                    if x == len(thd.df_day.index) - 1:
+                                        print(stock, '$$$$$$$', '\n', thd.df_day.loc[x, 'date'], '买买买买买！！')
                                 break
-                            else:
+                            elif (thd.df_day.loc[m, 'HL'] == 'L' ):
+                                if thd.df_day.loc[x-1, 'low'] < thd.df_day.loc[m-1, 'low']:
+                                    # 前一个为底，且中间存在不包含 or 更低的底
+                                    thd.df_day.loc[x, 'HL'] = 'L'
+                                    if x == len(thd.df_day.index) - 1:
+                                        # pass
+                                        print(stock, '$$$$$$$', '\n', thd.df_day.loc[x, 'date'],'中继后的底————买吗？！')
+                                    break
+                                else:
+                                    break
+                            m = m-1
+                    # 顶
+                    elif ((thd.df_day.loc[x,'high']<thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']<thd.df_day.loc[x-1,'high'])):
+                        # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
+                        #     stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
+                        thd.df_day.loc[x, 'HL'] = 'H*'
+                        while m:
+                            if thd.df_day.loc[m, 'HL'] == 'L':
+                                if x-m > 3:
+                                    thd.df_day.loc[x, 'HL'] = 'H'
+                                    if x == len(thd.df_day.index) - 1:
+                                        # print(stock, '!!!!!!!', '\n', '卖卖卖卖卖卖卖!')
+                                        pass
+                                    thd.df_day.loc[x, 9] = thd.df_day.loc[x, 'close'] - thd.df_day.loc[m, 'close']
                                 break
-                        m = m-1
-
-                # 顶
-                elif ((thd.df_day.loc[x,'high']<thd.df_day.loc[x-1,'high']) and (thd.df_day.loc[x-2,'high']<thd.df_day.loc[x-1,'high'])):
-                    # if ((stk.df_day.loc[i-2, 'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-3,'date'] != stk.fxdf.iloc[-1,0]) and (stk.df_day.loc[i-1,'date'] != stk.fxdf.iloc[-1,0])):
-                    #     stk.fxdf = pd.concat([stk.fxdf, stk.df_day.iloc[[i]]], ignore_index=True)
-                    thd.df_day.loc[x, 'HL'] = 'H*'
-                    if x == len(thd.df_day.index) - 1:
-                        # print(stock, '!!!!!!!', '\n', thd.df_day.loc[x, 'date'], '考虑————卖出！！')
-                        pass
-                    while m:
-                        if thd.df_day.loc[m, 'HL'] == 'L':
-                            if x-m > 3:
-                                thd.df_day.loc[x, 'HL'] = 'H'
-                                if x == len(thd.df_day.index) - 1:
-                                    # print(stock, '!!!!!!!', '\n', '卖卖卖卖卖卖卖!')
-                                    pass
-                                thd.df_day.loc[x, 9] = thd.df_day.loc[x, 'close'] - thd.df_day.loc[m, 'close']
-                            break
-                        elif (thd.df_day.loc[m, 'HL'] == 'H'):
-                            if thd.df_day.loc[x-1, 'high'] > thd.df_day.loc[m-1, 'high']:
-                                # 前一个为顶，且中间存在不包含 or 更高的顶
-                                thd.df_day.loc[x, 'HL'] = 'H'
-                                if x == len(thd.df_day.index) - 1:
-                                    pass
-                                    # print(stock, '/\/\/\/\/\/\/', '一顶更有一顶高！')
+                            elif (thd.df_day.loc[m, 'HL'] == 'H'):
+                                if thd.df_day.loc[x-1, 'high'] > thd.df_day.loc[m-1, 'high']:
+                                    # 前一个为顶，且中间存在不包含 or 更高的顶
+                                    thd.df_day.loc[x, 'HL'] = 'H'
+                                    if x == len(thd.df_day.index) - 1:
+                                        pass
+                                        # print(stock, '/\/\/\/\/\/\/', '一顶更有一顶高！')
+                                    break
                                 break
-                            break
-                        m = m-1
-                else:
-                    thd.df_day.loc[x, 'HL'] = '-'
+                            m = m-1
+                    else:
+                        thd.df_day.loc[x, 'HL'] = '-'
         except BaseException:
             continue