| | |
|---|
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
|---|
| | | import com.google.common.collect.Lists; |
|---|
| | | import com.ruoyi.common.core.constant.SecurityConstants; |
|---|
| | | import com.ruoyi.common.core.enums.ClientTypeEnum; |
|---|
| | | import com.ruoyi.common.core.enums.GroupStatusEnum; |
|---|
| | | import com.ruoyi.common.core.enums.ListingStatusEnum; |
|---|
| | | import com.ruoyi.common.core.enums.OrderStatusEnum; |
|---|
| | |
|---|
| | | map.put("target_id", groupPurchaseId); |
|---|
| | | map.put("message_type", "start"); |
|---|
| | | String msg = objectMapper.writeValueAsString(map); |
|---|
| | | WebSocketUsers.sendMessageToUsersByText(msg); |
|---|
| | | WebSocketUsers.sendMessageToUsersByType(ClientTypeEnum.MEMBER.getCode(), msg); |
|---|
| | | log.info("===================>发送websocket通知，消息体{}", msg); |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | map.put("target_id", groupPurchaseId); |
|---|
| | | map.put("message_type", "end"); |
|---|
| | | String msg = objectMapper.writeValueAsString(map); |
|---|
| | | WebSocketUsers.sendMessageToUsersByText(msg); |
|---|
| | | WebSocketUsers.sendMessageToUsersByType(ClientTypeEnum.MEMBER.getCode(), msg); |
|---|
| | | log.info("===================>发送websocket通知，消息体{}", msg); |
|---|
| | | } |
|---|
| | | } |
|---|
