| | |
|---|
| | | |
|---|
| | | # 保存最新价 |
|---|
| | | symbol = symbol.split(".")[1] |
|---|
| | | logger_juejin_tick.info("{} {} {}".format(symbol, price, tick["created_at"])) |
|---|
| | | |
|---|
| | | accpt_price(symbol, price) |
|---|
| | | __prices_now[symbol] = price |
|---|
| | | |
|---|
| | |
|---|
| | | if pricePre is not None: |
|---|
| | | rate = round((price - pricePre) * 100 / pricePre, 1) |
|---|
| | | if rate >= 7: |
|---|
| | | print(code, price, rate) |
|---|
| | | logger_juejin_tick.info("{}-{}-{}",code, price, rate) |
|---|
| | | if not gpcode_manager.is_listen(code) and not gpcode_manager.is_operate( |
|---|
| | | code) and not gpcode_manager.is_listen_full(): |
|---|
| | | L2CodeOperate.get_instance().add_operate(1, code) |
|---|
| | | L2CodeOperate.get_instance().add_operate(1, code,"现价变化") |
|---|
| | | # 进入监控 |
|---|
| | | elif rate < 5: |
|---|
| | | # 移除监控 |
|---|
| | | if gpcode_manager.is_listen(code) and not gpcode_manager.is_operate(code): |
|---|
| | | L2CodeOperate.get_instance().add_operate(0, code) |
|---|
| | | L2CodeOperate.get_instance().add_operate(0, code,"现价变化") |
|---|
| | | |
|---|
| | | |
|---|
| | | def on_bar(context, bars): |
|---|
