Explorar o código

优化流量推送系统消息存库

zhangdongming %!s(int64=3) %!d(string=hai) anos
pai
achega
6d0f2ddaa2
Modificáronse 1 ficheiros con 2 adicións e 2 borrados
  1. 2 2
      Controller/ComboCron/ComboCronPushController.py

+ 2 - 2
Controller/ComboCron/ComboCronPushController.py

@@ -162,7 +162,7 @@ class ComboCronPushView(View):
                     params = u'{"devname":"' + item.serial_no + '","usage":"流量' + usage + '","usable":"流量' + \
                              usable + '","total":"流量共' + total + '"}'
                     cls.send_aliyun_sms(user_qs.first()['phone'], params, 'SMS_246100414')
-
+                sys_msg = cls.get_msg_text(item.serial_no, push_qs[0]['lang'], total, usage, usable)
                 for push_vo in push_qs:
                     kwargs = {
                         'n_time': now_time,
@@ -181,9 +181,9 @@ 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, item.serial_no, now_time, sys_msg_text)
                     if not cls.msg_push(push_type, **kwargs):
                         continue
+                cls.sys_msg_save(user_id, item.serial_no, now_time, sys_msg)
                 # 修改推送状态
                 UnicomFlowPush.objects.filter(id=item.id).update(status=1)
             except Exception as e: