fix

mec-biz/src/main/java/com/ym/mec/biz/dal/dto/TencentData.java

@@ -3,11 +3,16 @@ package com.ym.mec.biz.dal.dto;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.annotation.JSONField;
 import com.ym.mec.biz.dal.enums.ETencentGroupType;
 import com.ym.mec.biz.dal.enums.ETencentImCallbackCommand;
+import io.swagger.annotations.ApiModel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.io.Serializable;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
@@ -184,4 +189,139 @@ public class TencentData {
         }
     }
 
+    @Data
+    @Builder
+    @NoArgsConstructor
+    @AllArgsConstructor
+    @ApiModel("推断流事件回调通知")
+    public static class CallbackStreamStateEvent implements Serializable {
+
+        @JSONField(name = "app")
+        private String app;
+        @JSONField(name = "appid")
+        private Integer appid;
+        @JSONField(name = "appname")
+        private String appname;
+        @JSONField(name = "channel_id")
+        private String channelId;
+        @JSONField(name = "errcode")
+        private Integer errcode;
+        @JSONField(name = "errmsg")
+        private String errmsg;
+        @JSONField(name = "event_time")
+        private Integer eventTime;
+        @JSONField(name = "event_type")
+        private Integer eventType;
+        @JSONField(name = "set_id")
+        private Integer setId;
+        @JSONField(name = "node")
+        private String node;
+        @JSONField(name = "sequence")
+        private String sequence;
+        @JSONField(name = "stream_id")
+        private String streamId;
+        @JSONField(name = "stream_param")
+        private String streamParam;
+        @JSONField(name = "user_ip")
+        private String userIp;
+        @JSONField(name = "width")
+        private Integer width;
+        @JSONField(name = "height")
+        private Integer height;
+        @JSONField(name = "sign")
+        private String sign;
+        @JSONField(name = "t")
+        private Integer t;
+    }
+
+    @Data
+    @Builder
+    @NoArgsConstructor
+    @AllArgsConstructor
+    @ApiModel("流录制事件回调通知")
+    public static class CallbackSteamRecordEvent implements Serializable {
+
+        @JSONField(name = "event_type")
+        private Integer eventType;
+        @JSONField(name = "appid")
+        private Integer appid;
+        @JSONField(name = "app")
+        private String app;
+        @JSONField(name = "callback_ext")
+        private String callbackExt;
+        @JSONField(name = "appname")
+        private String appname;
+        @JSONField(name = "stream_id")
+        private String streamId;
+        @JSONField(name = "channel_id")
+        private String channelId;
+        @JSONField(name = "file_id")
+        private String fileId;
+        @JSONField(name = "record_file_id")
+        private String recordFileId;
+        @JSONField(name = "file_format")
+        private String fileFormat;
+        @JSONField(name = "task_id")
+        private String taskId;
+        @JSONField(name = "start_time")
+        private Integer startTime;
+        @JSONField(name = "end_time")
+        private Integer endTime;
+        @JSONField(name = "start_time_usec")
+        private Integer startTimeUsec;
+        @JSONField(name = "end_time_usec")
+        private Integer endTimeUsec;
+        @JSONField(name = "duration")
+        private Integer duration;
+        @JSONField(name = "file_size")
+        private Integer fileSize;
+        @JSONField(name = "stream_param")
+        private String streamParam;
+        @JSONField(name = "video_url")
+        private String videoUrl;
+        @JSONField(name = "media_start_time")
+        private Integer mediaStartTime;
+        @JSONField(name = "record_bps")
+        private Integer recordBps;
+        @JSONField(name = "sign")
+        private String sign;
+        @JSONField(name = "t")
+        private Integer t;
+
+    }
+
+    @Data
+    @NoArgsConstructor
+    @AllArgsConstructor
+    @ApiModel("流异常事件回调通知")
+    public static class CallbackStreamExceptionEvent implements Serializable {
+
+
+        @JSONField(name = "appid")
+        private Integer appid;
+        @JSONField(name = "data_time")
+        private Long dataTime;
+        @JSONField(name = "domain")
+        private String domain;
+        @JSONField(name = "event_type")
+        private Integer eventType;
+        @JSONField(name = "interface")
+        private String interfaceX;
+        @JSONField(name = "path")
+        private String path;
+        @JSONField(name = "report_interval")
+        private Integer reportInterval;
+        @JSONField(name = "sequence")
+        private String sequence;
+        @JSONField(name = "stream_id")
+        private String streamId;
+        @JSONField(name = "stream_param")
+        private String streamParam;
+        @JSONField(name = "timeout")
+        private Integer timeout;
+        @JSONField(name = "abnormal_event")
+        private String abnormalEvent;
+    }
+
+
 }