@Override public void sendMsg(BusMessageList en) { en.setSendUser(UserUtil.getUserId()); en.setIsRead("N"); baseMapper.insert(en); try { if(StrUtil.isNotEmpty(en.getAcceptUser())){ //客服给用户发的消息 HashMap<String, Object> map = new HashMap<>(); map.put("type","CustomerService"); map.put("msg",en.getContent()); //发送消息 socketServer.sendInfo(map,en.getAcceptUser()); }else{ //用户给客服发的消息 HashMap<String, Object> map = new HashMap<>(); map.put("type","CustomerServiceAll"); map.put("msg",en.getContent()); socketServer.sendAll(map); } } catch (IOException e) { e.printStackTrace(); } }
时间: 2024-02-14 16:09:50 浏览: 63
这是一个Java方法,它接收一个BusMessageList类型的参数en,并将其插入到数据库中。然后,它根据en对象中的接收用户信息判断是客服给用户发的消息还是用户给客服发的消息,然后将消息内容和类型封装成一个HashMap对象map,调用socketServer对象的sendInfo或sendAll方法发送消息。如果发送消息的过程中发生IOException异常,它将打印异常堆栈信息。
阅读全文