packagecom.zehong.system.controller;importcom.alibaba.fastjson.JSONObject;importcom.zehong.system.domain.TEventReceive;importcom.zehong.system.service.ITEventReceiveService;importcom.zehong.system.service.WebSocketServer;importorg.slf4j.Logger;importorg.slf4j.LoggerFactory;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;importjava.util.List;@RestController@RequestMapping("/websocket")publicclassWebSocketController{privatestaticfinalLoggerlog=LoggerFactory.getLogger(WebSocketController.class);@AutowiredprivateWebSocketServerwebSocketServer;@AutowiredprivateITEventReceiveServicetEventReceiveService;@GetMapping("/send")publicvoidsend(IntegerenterpriseId){try{//List<TEventReceive> list = tEventReceiveService.getReadReceiveList( enterpriseId);webSocketServer.batchSendMessage(JSONObject.toJSONString("success"));}catch(Exceptione){log.error("wesocket发送失败!");}}}