sate24.py
1.13 KB
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
def parsePullMessage(message):
task = {
'status': 'NONE'
}
if message == 'NONE':
return task
values = message.split(';')
try:
task = {
'status': values[0],
'requestId': values[1],
'timestamp': values[3],
'destination': values[4],
'member': values[5],
'gateway_type': values[6],
'product': values[7],
'city': values[8]
}
except:
task
return task
def keyByRequestId(chipinfo, requestId):
return str(chipinfo) + '.trx.requestId:' + str(requestId)
def keyByNominalDestination(chipinfo, nominal, destination):
return str(chipinfo) + '.trx.nominal:' + str(nominal) + '.destination:' + str(destination)
def main():
return
def removeProduct(products, product):
try:
products = products.upper()
newProducts = products.split(',')
newProducts.remove(product.upper())
newProducts.sort()
return ','.join(newProducts)
except:
return products
if __name__ == '__main__':
main()