|
308
|
1 |
# -*- coding: utf-8 -*- |
|
|
2 |
|
|
|
3 |
from datetime import datetime |
|
|
4 |
import json |
|
|
5 |
from ..model import schema |
|
|
6 |
from ..model.dbdefer import dbdefer |
|
|
7 |
from twisted.python import log |
|
|
8 |
|
|
|
9 |
@dbdefer |
|
|
10 |
def addStatus(session, recipient, exID, status, data): |
|
|
11 |
try: |
|
|
12 |
status = int(status) |
|
|
13 |
except ValueError: |
|
|
14 |
log.msg("Ungültiger Status", status) |
|
|
15 |
status = -1 |
|
|
16 |
_s = schema.Status(recipient=recipient, |
|
|
17 |
exID = exID, |
|
|
18 |
status = status, |
|
|
19 |
data = json.dumps(data), |
|
|
20 |
date = datetime.now(), |
|
|
21 |
sender = "cmtelecom" |
|
|
22 |
) |
|
|
23 |
session.add(_s) |
|
|
24 |
session.commit() |
|
|
25 |
return _s |