iro/controller/cmtelecom.py
author hefee
Sat, 27 Jul 2019 13:36:18 +0200
changeset 308 a891fdd0c1a9
permissions -rw-r--r--
cmtelecom status inbound provider added.
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
308
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     1
# -*- coding: utf-8 -*-
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     2
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     3
from datetime import datetime
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     4
import json
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     5
from ..model import schema
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     6
from ..model.dbdefer import dbdefer
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     7
from twisted.python import log
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     8
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
     9
@dbdefer
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    10
def addStatus(session, recipient, exID, status, data):
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    11
    try:
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    12
        status = int(status)
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    13
    except ValueError:
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    14
        log.msg("Ungültiger Status", status)
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    15
        status = -1
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    16
    _s = schema.Status(recipient=recipient,
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    17
                           exID = exID,
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    18
                           status = status,
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    19
                           data = json.dumps(data),
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    20
                           date = datetime.now(),
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    21
                           sender = "cmtelecom"
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    22
                           )
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    23
    session.add(_s)
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    24
    session.commit()
a891fdd0c1a9 cmtelecom status inbound provider added.
hefee
parents:
diff changeset
    25
    return _s