| | |
| | | threading.Thread(target=lambda: middle_api_protocol.request( |
| | | middle_api_protocol.load_l2_subscript_codes_rate(cls.__current_rate_dict)), daemon=True).start() |
| | | |
| | | @classmethod |
| | | def get_current_rate_dict(cls): |
| | | return cls.__current_rate_dict |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | print(Buy1PriceManager().get_limit_up_info("002777")) |
| | |
| | | import inited_data |
| | | from api import low_suction_data_pusher |
| | | from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager |
| | | from l2.code_price_manager import CurrentPriceManager |
| | | from l2.huaxin import huaxin_target_codes_manager |
| | | from l2.l2_transaction_data_manager import HuaXinBuyOrderManager |
| | | from log_module.log import logger_system, logger_debug, logger_kpl_limit_up, logger_request_api, \ |
| | |
| | | else: |
| | | codes = huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.get_subscript_codes() |
| | | if codes: |
| | | current_rate_dict = CurrentPriceManager.get_current_rate_dict() |
| | | for code in codes: |
| | | deal_big_order_detail_info = None |
| | | try: |
| | |
| | | except: |
| | | pass |
| | | fresults.append( |
| | | (code, code_name, deal_big_order_info, deal_big_order_detail_info, big_order_enough)) |
| | | (code, code_name, deal_big_order_info, deal_big_order_detail_info, big_order_enough, current_rate_dict.get(code, 0))) |
| | | response_data = json.dumps({"code": 0, "data": fresults}) |
| | | except Exception as e: |
| | | response_data = json.dumps({"code": 1, "data": str(1)}) |
| | |
| | | if not human_setting_money: |
| | | # 没有人为设置累计大单阈值就不能加白 |
| | | return |
| | | |
| | | gpcode_manager.MustBuyCodesManager().add_code(code) |
| | | trade_record_log_util.add_must_buy(code, "大单足够") |
| | | |