功能完善

admin

2025-01-17 c2ded490628e6db67c97aabc6ca16f4b59083af1

 trade/huaxin_trade_record_manager.py

@@ -7,6 +7,7 @@
import json

from db.redis_manager_delegate import RedisUtils
from strategy import data_cache
from utils import tool
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager

@@ -18,7 +19,6 @@

    @classmethod
    def add(cls, datas):
        print("保存委托数据：",  datas)
        mysqldb = mysql_data.Mysqldb()
        try:
            if datas:
@@ -29,14 +29,14 @@
                        f"select * from hx_trade_delegate_record where id='{_id}'")
                    if not result:
                        # 新增数据
                        name = ''
                        name = data_cache.DataCache().code_name_dict.get(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')" % (
                            "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"],
                                d["orderSysID"], d["insertTime"], d["insertDate"], d["acceptTime"], d["cancelTime"],
                                d["limitPrice"], d["turnover"], d["volume"], d["volumeTraded"], d["orderStatus"],
                                d["orderSubmitStatus"], d["statusMsg"], tool.get_now_datetime_str(),
                                tool.get_now_datetime_str(), d["accountID"]))
                                tool.get_now_datetime_str(), d["accountID"], d["orderRef"]))
                    else:
                        # 修改数据
                        updateDict = {}
@@ -347,5 +347,6 @@


if __name__ == "__main__":
    results = DelegateRecordManager.list_latest_cancel_records(10)
    datas = [{'securityID': '600622', 'orderLocalID': '8100033928', 'direction': '0', 'orderSysID': '110018100033928', 'insertTime': '11:23:04', 'insertDate': '20250117', 'acceptTime': '11:22:45', 'cancelTime': '', 'limitPrice': 3.39, 'accountID': '00044396', 'turnover': 0.0, 'orderRef': 95567, 'volume': 200, 'volumeTraded': 0, 'orderStatus': '2', 'orderSubmitStatus': '1', 'statusMsg': ''}, {'securityID': '605199', 'orderLocalID': '8100034719', 'direction': '0', 'orderSysID': '110018100034719', 'insertTime': '11:31:56', 'insertDate': '20250117', 'acceptTime': '13:00:20', 'cancelTime': '', 'limitPrice': 18.11, 'accountID': '00044396', 'turnover': 3622.0, 'orderRef': 95600, 'volume': 200, 'volumeTraded': 200, 'orderStatus': '4', 'orderSubmitStatus': '1', 'statusMsg': ''}, {'securityID': '002184', 'orderLocalID': 'P900048961', 'direction': '0', 'orderSysID': '12002P900048961', 'insertTime': '11:19:36', 'insertDate': '20250117', 'acceptTime': '11:19:18', 'cancelTime': '', 'limitPrice': 15.1, 'accountID': '00044396', 'turnover': 15080.0, 'orderRef': 95538, 'volume': 1000, 'volumeTraded': 1000, 'orderStatus': '4', 'orderSubmitStatus': '1', 'statusMsg': ''}, {'securityID': '002184', 'orderLocalID': 'P900049345', 'direction': '0', 'orderSysID': '12002P900049345', 'insertTime': '11:22:14', 'insertDate': '20250117', 'acceptTime': '11:21:56', 'cancelTime': '', 'limitPrice': 15.09, 'accountID': '00044396', 'turnover': 1506.0, 'orderRef': 95550, 'volume': 100, 'volumeTraded': 100, 'orderStatus': '4', 'orderSubmitStatus': '1', 'statusMsg': ''}, {'securityID': '002184', 'orderLocalID': 'P900050555', 'direction': '1', 'orderSysID': '12002P900050555', 'insertTime': '11:28:48', 'insertDate': '20250117', 'acceptTime': '11:28:48', 'cancelTime': '', 'limitPrice': 15.02, 'accountID': '00044396', 'turnover': 1502.0, 'orderRef': 95584, 'volume': 100, 'volumeTraded': 100, 'orderStatus': '4', 'orderSubmitStatus': '1', 'statusMsg': ''}]
    results = DelegateRecordManager.add(datas)
    print(results)