Administrator
2023-10-23 9972c26c36c18a1ca5b636964a38ba1cf56a1208
output/code_info_output.py
@@ -155,9 +155,22 @@
        else:
            if trade_progress < len(total_datas):
                data = total_datas[trade_progress]
                params["trade_data"]["trade_progress"] = {"time": data['val']['time'],
                                                          "num": data['val']['num'], "money": round(
                        data['val']['num'] * float(data['val']['price']) * 100 / 10000, 1)}
                trade_progress_datas = []
                for min_money in [30000, 20000, 10000]:
                    for i in range(trade_progress - 1, -1, -1):
                        # 是否为涨停买
                        if L2DataUtil.is_limit_up_price_buy(total_datas[i]['val']):
                            if data['val']['num'] * float(data['val']['price']) > min_money:
                                trade_progress_datas.append({"time": data['val']['time'],
                                                             "num": data['val']['num'], "money": money_desc(round(
                                        data['val']['num'] * float(data['val']['price']) * 100))})
                                break
                    if trade_progress_datas:
                        break
                trade_progress_datas.append({"time": data['val']['time'],
                                             "num": data['val']['num'], "money": money_desc(round(
                        data['val']['num'] * float(data['val']['price']) * 100))})
        # 买入信号
        buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(
@@ -375,12 +388,23 @@
                                             extra_datas))
                elif type == trade_record_log_util.TYPE_REAL_PLACE_ORDER_POSITION:
                    _datas = []
                    MIN_MONEYS = [30000, 20000, 10000]
                    for min_money in MIN_MONEYS:
                        for i in range(data['index'], 0, -1):
                            if L2DataUtil.is_limit_up_price_buy(total_datas[i]['val']) and total_datas[i]['val'][
                                'num'] * float(total_datas[i]['val']['price']) >= min_money:
                                _datas.append(f"【{format_l2_data(total_datas[i])}】")
                                if len(_datas) >= 1:
                                    break
                        if len(_datas) >= 1:
                            break
                    for i in range(data['index'], 0, -1):
                        if L2DataUtil.is_limit_up_price_buy(total_datas[i]['val']) and total_datas[i]['val'][
                            'num'] * float(total_datas[i]['val']['price']) >= 3000:
                            if len(_datas) >= 2:
                            if _datas and _datas[-1]["index"] == i:
                                break
                            _datas.append(f"【{format_l2_data(total_datas[i])}】")
                            break
                    records_new_data.append(
                        (time_, "实际挂单位", "".join(_datas), []))