提交一键通话推送日志代码

Model/models.py

@@ -3496,4 +3496,17 @@ class UserAudioVideoPush(models.Model):
 
     class Meta:
         db_table = 'user_audio_video_push'
-        verbose_name = '用户音视频推送表'
+        verbose_name = '用户音视频推送表'
+
+
+class PushLog(models.Model):
+    id = models.AutoField(primary_key=True, verbose_name='自增标记ID')
+    event_type = models.CharField(default='', max_length=100, verbose_name='事件类型')
+    push_result = models.BooleanField(default=False, verbose_name='推送结果')
+    content = models.TextField(default='', verbose_name='推送字段值')
+    created_time = models.IntegerField(default=0, verbose_name='触发时间')
+
+    class Meta:
+        db_table = 'push_log'
+        verbose_name = '推送日志'
+        app_label = 'db2'

Service/DevicePushService.py

@@ -25,7 +25,7 @@ from AnsjerPush.config import CONFIG_INFO, CONFIG_CN, MULTI_CHANNEL_TYPE_LIST, S
     HUAWEICLOUD_OBS_SERVER, HUAWEICLOUD_PUSH_BUKET, OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET
 from AnsjerPush.config import XMPUSH_CONFIG, OPPOPUSH_CONFIG, XM_PUSH_CHANNEL_ID
 from Model.models import UidPushModel, SysMsgModel, DeviceSharePermission, DeviceChannelUserSet, \
-    DeviceChannelUserPermission, UidSetModel, Device_Info, UserAudioVideoPush
+    DeviceChannelUserPermission, UidSetModel, Device_Info, UserAudioVideoPush, PushLog
 from Object.ETkObject import ETkObject
 from Object.OCIObjectStorage import OCIObjectStorage
 from Object.RedisObject import RedisObject
@@ -439,6 +439,11 @@ class DevicePushService:
                     push_result = PushObject.android_meizupush(**push_kwargs)
                 elif push_type == 8:  # android honorpush
                     push_result = PushObject.android_honorpush(**push_kwargs)
+
+                if kwargs['event_type'] in [606, 607]:
+                    # 写入日志表
+                    PushLog.objects.create(event_type=kwargs['event_type'], created_time=int(time.time()),
+                                           content=push_kwargs, push_result=push_result)
             return push_result
         except Exception as e:
             LOGGING.error('发送推送异常,error_line:{},error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))