upgrade

src/event/socket.rs

@@ -38,8 +38,6 @@ pub struct SocketEvent {
     pub qos: Option<i32>,
 
     // 设备信息
-    pub seller_id: Option<i64>,
-    pub store_id: Option<i64>,
     pub device_id: Option<String>,
     pub client_type: Option<i32>,
     pub version: Option<i32>,

src/socket/event.rs

@@ -26,8 +26,6 @@ impl BusinessEvent for SocketEvent {
     ) -> SocketEvent {
         let Header(msg_id, msg_ty, qos) = header;
         SocketEvent {
-            seller_id: None,
-            store_id: None,
             device_id: None,
             client_type: None,
             version: None,
@@ -61,8 +59,6 @@ impl PublishEvent for SocketEvent {
     ) -> SocketEvent {
         let Header(msg_id, msg_ty, qos) = header;
         SocketEvent {
-            seller_id: Some(info.seller_id),
-            store_id: Some(info.store_id),
             device_id: Some(info.device_id.clone()),
             client_type: Some(info.client_type),
             version: Some(info.version),
@@ -81,8 +77,6 @@ impl PublishEvent for SocketEvent {
 
     fn ack(info: &TokenInfo, msg_id: i64, desc: impl AsRef<str>) -> SocketEvent {
         SocketEvent {
-            seller_id: Some(info.seller_id),
-            store_id: Some(info.store_id),
             device_id: Some(info.device_id.clone()),
             client_type: Some(info.client_type),
             version: Some(info.version),
@@ -114,8 +108,6 @@ impl ConnectEvent for SocketEvent {
             "设备断开连接"
         };
         SocketEvent {
-            seller_id: Some(info.seller_id),
-            store_id: Some(info.store_id),
             device_id: Some(info.device_id.clone()),
             client_type: Some(info.client_type),
             version: Some(info.version),
@@ -134,8 +126,6 @@ impl ConnectEvent for SocketEvent {
 
     fn clean_session(info: &TokenInfo, extra: impl AsRef<str>) -> SocketEvent {
         SocketEvent {
-            seller_id: Some(info.seller_id),
-            store_id: Some(info.store_id),
             device_id: Some(info.device_id.clone()),
             client_type: Some(info.client_type),
             version: Some(info.version),
@@ -176,8 +166,6 @@ impl ConsumeEvent for SocketEvent {
         };
         let Header(msg_id, msg_ty, qos) = header;
         SocketEvent {
-            seller_id: Some(info.seller_id),
-            store_id: Some(info.store_id),
             device_id: Some(info.device_id.clone()),
             client_type: Some(info.client_type),
             version: Some(info.version),