| | |
|---|
| | | list_ = [level1_data_dict[k] for k in level1_data_dict] |
|---|
| | | flist = [] |
|---|
| | | now_time_int = int(tool.get_now_time_str().replace(":", "")) |
|---|
| | | threshold_rate = constant.L1_MIN_RATE_PRE if now_time_int < int( |
|---|
| | | "094000") else constant.L1_MIN_RATE |
|---|
| | | threshold_rate = constant.L1_MIN_RATE |
|---|
| | | for d in list_: |
|---|
| | | if d[2] >= threshold_rate or d[0] in fixed_codes: |
|---|
| | | # 涨幅小于5%的需要删除 |
|---|
| | | # 涨幅小于3%的需要删除 |
|---|
| | | flist.append(d) |
|---|
| | | flist.sort(key=lambda x: x[2], reverse=True) |
|---|
| | | # 将固定代码的排在最前 |
|---|
| | |
|---|
| | | if len(datas) > 0: |
|---|
| | | logger_l2_codes_subscript.info("开始#华鑫L1上传代码：数量-{}", len(datas)) |
|---|
| | | __upload_codes_info(queue_l1_w_strategy_r, datas) |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | logger_debug.exception(e) |
|---|
