| | |
|---|
| | | fdata["delegates"]["sell"] = delegates[3] |
|---|
| | | deals = trade_data_manager.AccountMoneyManager().get_deal_count_info() |
|---|
| | | fdata["deals"] = {} |
|---|
| | | fdata["deals"]["stock"]={"count": deals[0][1], "price": 5, "money": round(5 * deals[0][1], 2)} |
|---|
| | | fdata["deals"]["sh_cb"]={"count": deals[1][1], "price": 1, "money": round(1 * deals[1][1], 2)} |
|---|
| | | fdata["deals"]["sz_cb"]={"count": deals[2][1], "price": 0, "money": round(0 * deals[2][1], 2)} |
|---|
| | | fdata["deals"]["stock"] = {"count": deals[0][1], "price": 5, "money": round(5 * deals[0][1], 2)} |
|---|
| | | fdata["deals"]["sh_cb"] = {"count": deals[1][1], "price": 1, "money": round(1 * deals[1][1], 2)} |
|---|
| | | fdata["deals"]["sz_cb"] = {"count": deals[2][1], "price": 0, "money": round(0 * deals[2][1], 2)} |
|---|
| | | fdata["commission"] = trade_data_manager.AccountMoneyManager().get_commission_cache() |
|---|
| | | response_data = json.dumps({"code": 0, "data": fdata}) |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | |
|---|
| | | self.__kplDataManager.save_data(type_, result_list) |
|---|
| | | elif type_ == KPLDataType.LIMIT_UP.value: |
|---|
| | | result_list = kpl_util.parseLimitUpData(data["data"]) |
|---|
| | | self.__data_process_thread_pool.submit(lambda: do_limit_up(result_list)) |
|---|
| | | # 记录涨停日志 |
|---|
| | | logger_kpl_limit_up.info(result_list) |
|---|
| | | result_list, day = kpl_util.parseLimitUpData(data["data"]) |
|---|
| | | if day and day != tool.get_now_date_str(): |
|---|
| | | pass |
|---|
| | | else: |
|---|
| | | self.__data_process_thread_pool.submit(lambda: do_limit_up(result_list)) |
|---|
| | | # 记录涨停日志 |
|---|
| | | logger_kpl_limit_up.info(result_list) |
|---|
| | | elif type_ == KPLDataType.OPEN_LIMIT_UP.value: |
|---|
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP) |
|---|
| | | if result_list: |
|---|
