|
|
@@ -365,6 +365,9 @@ public class WebSocketServer {
|
|
|
case "goods":
|
|
|
sendGoodsMessage(msg);
|
|
|
break;
|
|
|
+ case "deleteMsg":
|
|
|
+ deleteMsg(liveId,msg);
|
|
|
+ break;
|
|
|
case "red":
|
|
|
processRed(liveId, msg);
|
|
|
break;
|
|
|
@@ -385,6 +388,15 @@ public class WebSocketServer {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ private void deleteMsg(long liveId,SendMsgVo msg) {
|
|
|
+ SendMsgVo sendMsgVo = new SendMsgVo();
|
|
|
+ sendMsgVo.setLiveId(liveId);
|
|
|
+ sendMsgVo.setUserType(0L);
|
|
|
+ sendMsgVo.setCmd("deleteMsg");
|
|
|
+ sendMsgVo.setMsg(msg.getMsg());
|
|
|
+ broadcastMessage(liveId, JSONObject.toJSONString(R.ok().put("data", sendMsgVo)));
|
|
|
+ }
|
|
|
+
|
|
|
private void processCoupon(long liveId, SendMsgVo msg) {
|
|
|
JSONObject jsonObject = JSON.parseObject(msg.getData());
|
|
|
Integer status = jsonObject.getInteger("status");
|