华鑫适配

Administrator

2023-07-14 131b5d95b9163780f338b308174cf749ba952ba4

华鑫适配

 trade/huaxin/trade_api_server.py

@@ -333,6 +333,7 @@
                        # 设置可用资金
                elif type_ == "deal_list":
                    dataJSON = huaxin_trade_api.get_deal_list()
                    print("成交响应：",dataJSON)
                    if dataJSON["code"] == 0:
                        data = dataJSON["data"]
                        huaxin_trade_record_manager.DealRecordManager.add(data)

 trade/huaxin/trade_server.py

@@ -159,6 +159,7 @@
                        datas = data["data"]
                        hx_logger_l2_transaction.info(f"{code}#{datas}")
                        buyno_map = l2_data_util.local_today_buyno_map.get(code)
                        print(f"{code}的买入订单号数量", len(buyno_map.keys()) if buyno_map else 0 )
                        buy_progress_index = None
                        for d in datas:
                            buy_no = d[6]
@@ -171,6 +172,7 @@
                            code)
                        if True:
                            if buy_progress_index is not None:
                                logger_l2_trade_buy_queue.info("获取成交位置成功： code-{} index-{}", code, buy_progress_index)
                                buy_time = l2_data_util.local_today_datas.get(code)[buy_progress_index]["val"]["time"]
                                HourCancelBigNumComputer.set_trade_progress(code, buy_time, buy_exec_index,
                                                                            buy_progress_index,
@@ -182,7 +184,7 @@
                                                                         l2_data_util.local_today_datas.get(
                                                                             code))

                                logger_l2_trade_buy_queue.info("获取成交位置成功： code-{} index-{}", code, buy_progress_index)

                                # 计算大单成交额
                                deal_big_money_manager.set_trade_progress(code, buy_progress_index,
                                                                          l2_data_util.local_today_datas.get(