消息接口新增字段，传入用户动态ID

alien-entity/src/main/java/shop/alien/entity/store/LifeMessage.java

@@ -68,4 +68,8 @@ public class LifeMessage {
     @ApiModelProperty(value = "修改人ID")
     @TableField("updated_user_id")
     private Integer updatedUserId;
+
+    @ApiModelProperty(value = "业务ID")
+    @TableField("business_id")
+    private Integer businessId;
 }

alien-entity/src/main/java/shop/alien/entity/store/vo/WebSocketVo.java

@@ -38,4 +38,7 @@ public class WebSocketVo {
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
     @ApiModelProperty(value = "创建时间")
     private Date createdTime;
+
+    @ApiModelProperty(value = "业务ID（用户动态ID）")
+    private Integer businessId;
 }

alien-store/src/main/java/shop/alien/store/config/WebSocketProcess.java

@@ -97,6 +97,7 @@ public class WebSocketProcess implements ApplicationContextAware {
             lifeMessage.setReceiverId(webSocketVo.getReceiverId());
             lifeMessage.setContent(webSocketVo.getText());
             lifeMessage.setType(webSocketVo.getType());
+            lifeMessage.setBusinessId(webSocketVo.getBusinessId());
             // 查询自己是否在对方的黑名单中
             if (baseRedisService.hasKey("blackList_" + webSocketVo.getSenderId())) {
                 List<String> blackList = baseRedisService.getList("blackList_" + webSocketVo.getSenderId());