流量到期预警增加系统通知

Controller/ComboCron/ComboCronPushController.py

@@ -13,7 +13,7 @@ import traceback
 from django.db.models import Q
 from django.views import View
 
-from Model.models import UnicomComboOrderInfo, UnicomDeviceInfo, GatewayPush
+from Model.models import UnicomComboOrderInfo, UnicomDeviceInfo, GatewayPush, SysMsgModel
 from Object.ResponseObject import ResponseObject
 from Service.GatewayService import GatewayPushService
 
@@ -41,6 +41,9 @@ class ComboCronPushView(View):
 
     @classmethod
     def combo_expire_push(cls, response):
+        """
+        套餐到期预警通知，分别7前3天前消息推送
+        """
         logger = logging.getLogger('info')
         logger.info('进入流量包过期消息推送')
         try:
@@ -67,7 +70,7 @@ class ComboCronPushView(View):
         """
         消息推送
         """
-        mow_time = int(time.time())
+        now_time = int(time.time())
         logger = logging.getLogger('info')
         for item in combo_order_qs:
             iccid = item['iccid']
@@ -87,7 +90,7 @@ class ComboCronPushView(View):
                 continue
             for push_vo in push_qs:
                 kwargs = {
-                    'n_time': mow_time,
+                    'n_time': now_time,
                     'event_type': 1,
                     'nickname': nickname,
                 }
@@ -109,7 +112,7 @@ class ComboCronPushView(View):
                 kwargs['token_val'] = token_val
                 kwargs['msg_title'] = msg_title
                 kwargs['msg_text'] = sys_msg_text
-
+                cls.sys_msg_save(user_id, nickname, now_time, sys_msg_text)
                 try:
                     # ios apns
                     if push_type == 0:
@@ -125,3 +128,16 @@ class ComboCronPushView(View):
                     logger.info('4G流量预警推送消息异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
                     continue
         return True
+
+    @classmethod
+    def sys_msg_save(cls, user_id, serial_no, n_time, text_msg):
+        """
+        系统消息存库
+        """
+        logger = logging.getLogger('info')
+        try:
+            data = {'addTime': n_time, 'updTime': n_time, 'userID_id': user_id, 'eventType': 0, 'msg': text_msg,
+                    'uid': serial_no}
+            SysMsgModel.objects.create(**data)
+        except Exception as e:
+            logger.info('---4G流量存库异常--- {}'.format(repr(e)))