| | |
|---|
| | | import constant |
|---|
| | | import inited_data |
|---|
| | | from api import low_suction_data_pusher |
|---|
| | | from code_attribute.code_l1_data_manager import L1DataManager |
|---|
| | | from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager, CodePrePriceManager |
|---|
| | | from l2.code_price_manager import CurrentPriceManager |
|---|
| | | from l2.huaxin import huaxin_target_codes_manager |
|---|
| | |
|---|
| | | data.append(limit_up_time) |
|---|
| | | pre_close_price = CodePrePriceManager().get_price_pre_cache(code) |
|---|
| | | latest_transaction_data = HuaXinTransactionDatasProcessor.get_latest_transaction_data(code) |
|---|
| | | # 获取L1数据 |
|---|
| | | price = L1DataManager.get_l1_current_price(code) |
|---|
| | | if price: |
|---|
| | | data.append(round((price - pre_close_price) * 100 / pre_close_price, 2)) |
|---|
| | | else: |
|---|
| | | data.append("--") |
|---|
| | | zylt_volume = global_util.zylt_volume_map.get(code) |
|---|
| | | zyltgb = zylt_volume * limit_up_price |
|---|
| | | if latest_transaction_data: |
|---|
| | | data.append(round((latest_transaction_data[1] - pre_close_price) * 100 / pre_close_price, 2)) |
|---|
| | | data.append((latest_transaction_data[2]//100, latest_transaction_data[6] - latest_transaction_data[7])) |
|---|
| | | data.append(output_util.money_desc(zyltgb) if zyltgb else '--') |
|---|
| | | data.append(latest_transaction_data[1]) |
|---|
| | | else: |
|---|
| | | data.append("--") |
|---|
| | | data.append(("--", 0)) |
|---|
| | | data.append(output_util.money_desc(zyltgb) if zyltgb else '--') |
|---|
| | | data.append(output_util.money_desc(zyltgb) if zyltgb else '--') |
|---|
| | | if price: |
|---|
| | | data.append(price) |
|---|
| | | else: |
|---|
| | | data.append("--") |
|---|
| | | fdatas.append(data) |
|---|
| | | fdatas.sort(key=lambda x: x[2] if x[2] else time.time()) |
|---|
