| | |
|---|
| | | class DelegateRecordManager: |
|---|
| | | key_list = ["id", "orderLocalID", "securityID", "securityName", "direction", "orderSysID", "insertTime", |
|---|
| | | "insertDate", "acceptTime", "cancelTime", "limitPrice", "turnover", "volume", "volumeTraded", |
|---|
| | | "orderStatus", "orderSubmitStatus", "statusMsg", "createTime", "updateTime", "accountID", "orderRef"] |
|---|
| | | "orderStatus", "orderSubmitStatus", "statusMsg", "createTime", "updateTime", "accountID", "orderRef", "sinfo"] |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def add(cls, datas): |
|---|
| | |
|---|
| | | nameDict = HistoryKDatasUtils.get_gp_codes_names([d['securityID']]) |
|---|
| | | name = nameDict.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','%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"], d["sinfo"])) |
|---|
| | | else: |
|---|
| | | # 修改数据 |
|---|
| | | updateDict = {} |
|---|
