-
Notifications
You must be signed in to change notification settings - Fork 556
/
_MoneyManager.cpp
237 lines (170 loc) · 9.88 KB
/
_MoneyManager.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
/*
* _MoneyManager.cpp
*
* Created on: 2013-3-13
* Author: fasiondog
*/
#include <hikyuu/trade_sys/moneymanager/build_in.h>
#include "../pybind_utils.h"
namespace py = pybind11;
using namespace hku;
class PyMoneyManagerBase : public MoneyManagerBase {
PY_CLONE(PyMoneyManagerBase, MoneyManagerBase)
public:
using MoneyManagerBase::MoneyManagerBase;
PyMoneyManagerBase(const MoneyManagerBase& base) : MoneyManagerBase(base) {}
void _reset() override {
PYBIND11_OVERLOAD(void, MoneyManagerBase, _reset, );
}
void buyNotify(const TradeRecord& tr) override {
PYBIND11_OVERLOAD_NAME(void, MoneyManagerBase, "buy_notify", buyNotify, tr);
}
void sellNotify(const TradeRecord& tr) override {
PYBIND11_OVERLOAD_NAME(void, MoneyManagerBase, "sell_notify", sellNotify, tr);
}
double _getBuyNumber(const Datetime& datetime, const Stock& stock, price_t price, price_t risk,
SystemPart from) override {
PYBIND11_OVERLOAD_PURE_NAME(double, MoneyManagerBase, "_get_buy_num", _getBuyNumber,
datetime, stock, price, risk, from);
}
double _getSellNumber(const Datetime& datetime, const Stock& stock, price_t price, price_t risk,
SystemPart from) override {
PYBIND11_OVERLOAD_NAME(double, MoneyManagerBase, "_get_sell_num", _getSellNumber, datetime,
stock, price, risk, from);
}
double _getSellShortNumber(const Datetime& datetime, const Stock& stock, price_t price,
price_t risk, SystemPart from) override {
PYBIND11_OVERLOAD_NAME(double, MoneyManagerBase, "_get_sell_short_num", _getSellShortNumber,
datetime, stock, price, risk, from);
}
double _getBuyShortNumber(const Datetime& datetime, const Stock& stock, price_t price,
price_t risk, SystemPart from) override {
PYBIND11_OVERLOAD_NAME(double, MoneyManagerBase, "_get_buy_short_num", _getBuyShortNumber,
datetime, stock, price, risk, from);
}
};
void export_MoneyManager(py::module& m) {
py::class_<MoneyManagerBase, MMPtr, PyMoneyManagerBase>(m, "MoneyManagerBase",
py::dynamic_attr(),
R"(资金管理策略基类
公共参数:
- auto-checkin=False (bool) : 当账户现金不足以买入资金管理策略指示的买入数量时,自动向账户中补充存入(checkin)足够的现金。
- max-stock=20000 (int) : 最大持有的证券种类数量(即持有几只股票,而非各个股票的持仓数)
- disable_ev_force_clean_position=False (bool) : 禁用市场环境失效时强制清仓
- disable_cn_force_clean_position=False (bool) : 禁用系统有效条件失效时强制清仓
自定义资金管理策略接口:
- buyNotify : 【可选】接收实际买入通知,预留用于多次增减仓处理
- sellNotify : 【可选】接收实际卖出通知,预留用于多次增减仓处理
- _getBuyNumber : 【必须】获取指定交易对象可买入的数量
- _getSellNumber : 【可选】获取指定交易对象可卖出的数量,如未重载,默认为卖出全部已持仓数量
- _reset : 【可选】重置私有属性
- _clone : 【必须】克隆接口)")
.def(py::init<>())
.def(py::init<const MoneyManagerBase&>())
.def(py::init<const string&>(), R"(初始化构造函数
:param str name: 名称)")
.def("__str__", to_py_str<MoneyManagerBase>)
.def("__repr__", to_py_str<MoneyManagerBase>)
.def_property("name", py::overload_cast<>(&MoneyManagerBase::name, py::const_),
py::overload_cast<const string&>(&MoneyManagerBase::name),
py::return_value_policy::copy, "名称")
.def_property("tm", &MoneyManagerBase::getTM, &MoneyManagerBase::setTM,
"设置或获取交易管理对象")
.def_property("query", &MoneyManagerBase::getQuery, &MoneyManagerBase::setQuery,
py::return_value_policy::copy, "设置或获取查询条件")
.def("get_param", &MoneyManagerBase::getParam<boost::any>, R"(get_param(self, name)
获取指定的参数
:param str name: 参数名称
:return: 参数值
:raises out_of_range: 无此参数)")
.def("set_param", &MoneyManagerBase::setParam<boost::any>, R"(set_param(self, name, value)
设置参数
:param str name: 参数名称
:param value: 参数值
:raises logic_error: Unsupported type! 不支持的参数类型)")
.def("have_param", &MoneyManagerBase::haveParam, "是否存在指定参数")
.def("reset", &MoneyManagerBase::reset, "复位操作")
.def("clone", &MoneyManagerBase::clone, "克隆操作")
.def("buy_notify", &MoneyManagerBase::buyNotify,
R"(buy_notify(self, trade_record)
【重载接口】交易系统发生实际买入操作时,通知交易变化情况,一般存在多次增减仓的情况才需要重载
:param TradeRecord trade_record: 发生实际买入时的实际买入交易记录)")
.def("sell_notify", &MoneyManagerBase::sellNotify,
R"(sell_notify(self, trade_record)
【重载接口】交易系统发生实际卖出操作时,通知实际交易变化情况,一般存在多次增减仓的情况才需要重载
:param TradeRecord trade_record: 发生实际卖出时的实际卖出交易记录)")
.def("get_buy_num", &MoneyManagerBase::getBuyNumber,
R"(get_buy_num(self, datetime, stock, price, risk, part_from)
获取指定交易对象可买入的数量
:param Datetime datetime: 交易时间
:param Stock stock: 交易对象
:param float price: 交易价格
:param float risk: 交易承担的风险,如果为0,表示全部损失,即市值跌至0元
:param System.Part part_from: 来源系统组件
:return: 可买入数量
:rtype: float)")
.def("get_sell_num", &MoneyManagerBase::getSellNumber,
R"(get_sell_num(self, datetime, stock, price, risk, part_from)
获取指定交易对象可卖出的数量
:param Datetime datetime: 交易时间
:param Stock stock: 交易对象
:param float price: 交易价格
:param float risk: 新的交易承担的风险,如果为0,表示全部损失,即市值跌至0元
:param System.Part part_from: 来源系统组件
:return: 可卖出数量
:rtype: float)")
.def("_get_buy_num", &MoneyManagerBase::_getBuyNumber,
R"(_get_buy_num(self, datetime, stock, price, risk, part_from)
【重载接口】获取指定交易对象可买入的数量
:param Datetime datetime: 交易时间
:param Stock stock: 交易对象
:param float price: 交易价格
:param float risk: 交易承担的风险,如果为0,表示全部损失,即市值跌至0元
:param System.Part part_from: 来源系统组件
:return: 可买入数量
:rtype: float)")
.def("_get_sell_num", &MoneyManagerBase::_getSellNumber,
R"(_get_sell_num(self, datetime, stock, price, risk, part_from)
【重载接口】获取指定交易对象可卖出的数量。如未重载,默认为卖出全部已持仓数量。
:param Datetime datetime: 交易时间
:param Stock stock: 交易对象
:param float price: 交易价格
:param float risk: 新的交易承担的风险,如果为0,表示全部损失,即市值跌至0元
:param System.Part part_from: 来源系统组件
:return: 可卖出数量
:rtype: float)")
.def("get_sell_short_num", &MoneyManagerBase::getSellShortNumber)
.def("get_buy_short_num", &MoneyManagerBase::getBuyShortNumber)
.def("_get_sell_short_num", &MoneyManagerBase::_getSellShortNumber)
.def("_get_buy_short_num", &MoneyManagerBase::_getBuyShortNumber)
.def("_reset", &MoneyManagerBase::_reset, R"(【重载接口】子类复位接口,复位内部私有变量)")
DEF_PICKLE(MMPtr);
m.def("MM_Nothing", MM_Nothing, R"(MM_Nothing()
特殊的资金管理策略,相当于不做资金管理,有多少钱买多少。)");
m.def("MM_FixedRisk", MM_FixedRisk, py::arg("risk") = 1000.00,
R"(MM_FixedRisk([risk = 1000.00])
固定风险资金管理策略对每笔交易限定一个预先确定的或者固定的资金风险,如每笔交易固定风险1000元。公式:交易数量 = 固定风险 / 交易风险。
:param float risk: 固定风险
:return: 资金管理策略实例)");
m.def("MM_FixedCapital", MM_FixedCapital, py::arg("capital") = 10000.00,
R"(MM_FixedCapital([capital = 10000.0])
固定资本资金管理策略
:param float capital: 固定资本单位
:return: 资金管理策略实例)");
m.def("MM_FixedCount", MM_FixedCount, py::arg("n") = 100, R"(MM_FixedCount([n = 100])
固定交易数量资金管理策略。每次买入固定的数量。
:param float n: 每次买入的数量(应该是交易对象最小交易数量的整数,此处程序没有此进行判断)
:return: 资金管理策略实例)");
m.def("MM_FixedPercent", MM_FixedPercent, py::arg("p") = 0.03, R"(MM_FixedPercent([p = 0.03])
固定百分比风险模型。公式:P(头寸规模)= 账户余额 * 百分比 / R(每股的交易风险)。[BOOK3]_, [BOOK4]_ .
:param float p: 百分比
:return: 资金管理策略实例)");
m.def("MM_FixedUnits", MM_FixedUnits, py::arg("n") = 33, R"(MM_FixedUnits([n = 33])
固定单位资金管理策略
:param int n: n个资金单位
:return: 资金管理策略实例)");
m.def("MM_WilliamsFixedRisk", MM_WilliamsFixedRisk, py::arg("p") = 0.1,
py::arg("max_loss") = 1000.0,
R"( MM_WilliamsFixedRisk([p=0.1, max_loss=1000.0])
威廉斯固定风险资金管理策略)");
}