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
|
import sys
import time
import quickfix as fix
class Application(fix.Application):
orderID = 0
execID = 0
def onCreate(self, sessionID): return
def onLogon(self, sessionID): return
def onLogout(self, sessionID): return
def toAdmin(self, sessionID, message): return
def fromAdmin(self, sessionID, message): return
def toApp(self, sessionID, message): return
def fromApp(self, message, sessionID):
beginString = fix.BeginString()
msgType = fix.MsgType()
message.getHeader().getField( beginString )
message.getHeader().getField( msgType )
symbol = fix.Symbol()
side = fix.Side()
ordType = fix.OrdType()
orderQty = fix.OrderQty()
price = fix.Price()
clOrdID = fix.ClOrdID()
message.getField( ordType )
if ordType.getValue() != fix.OrdType_LIMIT:
raise fix.IncorrectTagValue( ordType.getField() )
message.getField( symbol )
message.getField( side )
message.getField( orderQty )
message.getField( price )
message.getField( clOrdID )
executionReport = fix.Message()
executionReport.getHeader().setField( beginString )
executionReport.getHeader().setField( fix.MsgType(fix.MsgType_ExecutionReport) )
executionReport.setField( fix.OrderID(self.genOrderID()) )
executionReport.setField( fix.ExecID(self.genExecID()) )
executionReport.setField( fix.OrdStatus(fix.OrdStatus_FILLED) )
executionReport.setField( symbol )
executionReport.setField( side )
executionReport.setField( fix.CumQty(orderQty.getValue()) )
executionReport.setField( fix.AvgPx(price.getValue()) )
executionReport.setField( fix.LastShares(orderQty.getValue()) )
executionReport.setField( fix.LastPx(price.getValue()) )
executionReport.setField( clOrdID )
executionReport.setField( orderQty )
if beginString.getValue() == fix.BeginString_FIX40 or beginString.getValue() == fix.BeginString_FIX41 or beginString.getValue() == fix.BeginString_FIX42:
executionReport.setField( fix.ExecTransType(fix.ExecTransType_NEW) )
if beginString.getValue() >= fix.BeginString_FIX41:
executionReport.setField( fix.ExecType(fix.ExecType_FILL) )
executionReport.setField( fix.LeavesQty(0) )
try:
fix.Session.sendToTarget( executionReport, sessionID )
except fix.SessionNotFound as e:
return
def genOrderID(self):
self.orderID = self.orderID+1
return self.orderID
def genExecID(self):
self.execID = self.execID+1
return self.execID
try:
file = sys.argv[1]
settings = fix.SessionSettings( file )
application = Application()
storeFactory = fix.FileStoreFactory( settings )
logFactory = fix.ScreenLogFactory( settings )
acceptor = fix.SocketAcceptor( application, storeFactory, settings, logFactory )
acceptor.start()
while 1:
time.sleep(1)
except (fix.ConfigError, fix.RuntimeError) as e:
print(e)
|
