django example

Author: kkirsanov

django_example/models.py

@@ -0,0 +1,30 @@
+# coding=utf8
+import logging
+
+from django.db import models
+
+# Create your models here.
+
+SOURCE = ['tele2', 'beeline', 'mts', 'megafon']
+
+ops = zip(SOURCE, SOURCE)
+import json
+
+dirs = [[0, 'выход'], [1, 'вход']]
+import urllib.request
+from django.conf import settings
+
+
+class SMS(models.Model):
+    class Meta:
+        verbose_name = 'СМС'
+        verbose_name_plural = 'СМС'
+
+    sphone = models.CharField(max_length=64, verbose_name='откуда', db_index=True)
+    tphone = models.CharField(max_length=64, verbose_name='куда', db_index=True)
+    message = models.TextField(verbose_name='текст сообщения')
+    date = models.DateTimeField(auto_now_add=True, db_index=True)
+    sended = models.BooleanField(default=False)
+    op = models.CharField(choices=ops, max_length=16, verbose_name='оператор')
+    direction = models.IntegerField(choices=dirs, default=0, verbose_name='направление')
+    uuid = models.CharField(max_length=128, blank=True, null=True)

django_example/settings.py

@@ -0,0 +1,32 @@
+SMPP = {
+    'tele2': {
+        'ip': '123.123.123.123',
+        'port': 3331,
+        'system_id': '123123',
+        'password': '123123',
+        'source': ['1234', 'asdasd'] #sender name
+    },
+    'mts': {
+        'ip': 'smpp.mcommunicator.ru',
+        'port': 123,
+        'system_id': 'asdasd',
+        'password': 'asdasd',
+        'source': ['123123', 'ASDAS']
+    },
+    'beeline': {
+        'ip': '123.123.123.123',
+        'port': 3340,
+        'system_id': '12321321',
+        'password': 'asdasda',
+        'source': ['1234']
+    },
+    'megafon': {
+        'ip': '10.236.123.123',
+        'port': 12000,
+        'system_id': 'MSK_asdasd',
+        'password': 'asdsadas',
+        'source': ['1234']
+    },
+
+}
+

django_example/smpp-serve.py

@@ -0,0 +1,77 @@
+# coding=utf8
+from django.core.management.base import BaseCommand
+
+import datetime
+import logging
+import smpplib.gsm
+import smpplib.client
+import smpplib.consts
+
+h1 = datetime.timedelta(hours=1)
+
+from django.conf import settings
+
+def mkGetPdu(op: str):
+    def getPdu(pdu):
+        try:
+            source = pdu.parsed['saddress']
+            target = pdu.parsed['daddress']
+            message = pdu.parsed.get('sm', '') + pdu.parsed.get('payload', '')
+            from sms import models
+            if 'submit date:' not in message:
+                sms = models.SMS(direction=1, sphone=source, tphone=target, message=message, sended=True, op=op)
+                sms.message = "".join(filter(lambda x: x not in ['\u0000'], sms.message))
+                sms.save()
+
+        except Exception as e:
+           logging.error(e)
+
+    return getPdu
+
+
+def mkGenMessages(op, num):
+    def GenMessages():
+        from sms.models import SMS
+        newSMS = list(SMS.objects.filter(op=op, direction=0, sended=False)[:100])
+
+        if newSMS:
+            for sms in newSMS:
+                if not sms.sphone:
+                    sms.sphone = num
+                sms.sended = True
+                sms.save()
+                yield (sms.sphone, sms.tphone, sms.message)
+        yield None
+
+    return GenMessages
+
+
+class Command(BaseCommand):
+    help = 'serve SMPP requests'
+
+    def add_arguments(self, parser):
+        parser.add_argument('op', help='tele2/mts/beeline')
+
+    def handle(self, *args, **options):
+        logging.basicConfig(level='DEBUG')
+        try:
+            op = options['op']
+            s = settings.SMPP[op]
+        except:
+            logging.error("no such config")
+            exit()
+
+        timeout = 15
+        if options['op'] == 'megafon':
+            timeout = 60
+        client = smpplib.client.Client(s['ip'], s['port'], timeout)
+
+        client.set_message_received_handler(mkGetPdu(op))
+        client.set_message_source(mkGenMessages(op, s['source']))
+        client.connect()
+
+        client.bind_transceiver(system_id=s['system_id'], password=s['password'])
+        try:
+            client.listen([11])
+        except Exception as e:
+            logging.error(e)

pdu.py

@@ -192,7 +192,7 @@ def parse(self):
             self._parseCMD('s msgid')
         if self._pdu['cmdid'] in [b'00000004', b'00000005']:
             self._parseCMD("s servtype 2 saddrton 2 saddrnpi s saddress 2 daddrton 2 daddrnpi s daddress " +
-                           "2 esm 2 pid 2 priority s sdt s valt 2 rdel 2 rip 2 dcs 2 smid 2 smlen ls sm "+
+                           "2 esm 2 pid 2 priority s sdt s valt 2 rdel 2 rip 2 dcs 2 smid 2 smlen ls sm " +
                            "4 tag 4 paylen pl payload")
         if self._pdu['cmdid'] in [b'00000103']:
             self._parseCMD('s servtype 2 saddrton 2 saddrnpi s saddress 2 daddrton 2 daddrnpi s daddress ' +