| | |
|---|
| | | |
|---|
| | | def OnRealTimeBuy1Info(self, code, buy1_info): |
|---|
| | | # buy1_info: [买1时间,买1价格, 原始买1量, 实时买1量] |
|---|
| | | async_log_util.info(logger_debug, f"OnRealTimeBuy1Info：{code}-{buy1_info}") |
|---|
| | | L1DataProcessor.excute_sell_rule(code, buy1_info[3], buy1_info[1], "l2") |
|---|
| | | rules = TradeRuleManager().list_can_excut_rules_cache(types=[TradeRuleManager.TYPE_SELL]) |
|---|
| | | if not rules: |
|---|
| | | rules = [] |
|---|
| | | codes = [rule.code for rule in rules] |
|---|
| | | if code in codes: |
|---|
| | | async_log_util.info(logger_debug, f"OnRealTimeBuy1Info：{code}-{buy1_info}") |
|---|
| | | # L1DataProcessor.excute_sell_rule(code, buy1_info[3], buy1_info[1], "l2-real") |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 做一些初始化的操作 |
|---|
