功能完善

admin

2025-01-17 2028239faa3d4f1a7afefb069b2b0ac6d7d64a71

功能完善

 trade/huaxin_trade_record_manager.py

@@ -29,7 +29,7 @@
                        f"select * from hx_trade_delegate_record where id='{_id}'")
                    if not result:
                        # 新增数据
                        name = data_cache.DataCache().code_name_dict.get(d["securityID"])
                        name = data_cache.DataCache().code_name_dict.get( tool.get_symbol(d["securityID"]))
                        mysqldb.execute(
                            "insert into hx_trade_delegate_record values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s', '%s')" % (
                                _id, d["orderLocalID"], d["securityID"], name, d["direction"],
@@ -98,7 +98,7 @@
                        else:
                            temp[cls.key_list[i]] = r[i]
                    fresults.append(temp)
            return fresults, max_update_time.strftime("%Y-%m-%d %H:%M:%S") if max_update_time else None
            return fresults, max_update_time if max_update_time else None
        finally:
            pass


 utils/tool.py

@@ -428,5 +428,12 @@
    return code.find("00") == 0 or code.find("30") == 0 or code.find("60") == 0 or code.find("68") == 0


def get_symbol(code):
    if is_sh_code(code):
        return f"SHSE.{code}"
    elif is_sz_code(code):
        return f"SZSE.{code}"
    return code

if __name__ == "__main__":
    print(get_buy_max_price(100.123, is_cb=True))