互联网医院系统开发如何实现在线问诊与图文视频会诊

CREATE TABLE consultation_order (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  patient_id BIGINT,
  doctor_id BIGINT,
  type VARCHAR(20),       -- TEXT/VIDEO
  price DECIMAL(10,2),
  status VARCHAR(20),     -- WAITING/ONGOING/FINISHED/CANCEL
  start_time DATETIME,
  end_time DATETIME,
  created_at DATETIME
);

CREATE TABLE consultation_message (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  order_id BIGINT,
  sender_id BIGINT,
  sender_role VARCHAR(20), -- DOCTOR/PATIENT
  msg_type VARCHAR(20),    -- TEXT/IMAGE/FILE
  content TEXT,
  created_at DATETIME
);

CREATE TABLE consultation_video (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  order_id BIGINT,
  room_id VARCHAR(50),
  duration INT,
  record_url VARCHAR(255),
  created_at DATETIME
);

@ServerEndpoint("/ws/{userId}")
@Component
public class ChatWebSocket {

    private static ConcurrentHashMap<Long, Session> sessions = new ConcurrentHashMap<>();

    @OnOpen
    public void onOpen(@PathParam("userId") Long userId, Session session) {
        sessions.put(userId, session);
    }

    @OnMessage
    public void onMessage(String message) {
        ChatDTO dto = JSON.parseObject(message, ChatDTO.class);

        // 1 存库
        messageService.save(dto);

        // 2 推送对方
        Session target = sessions.get(dto.getTargetId());
        if(target != null){
            target.getAsyncRemote().sendText(message);
        }
    }
}

public void save(ChatDTO dto){
    ConsultationMessage msg = new ConsultationMessage();
    msg.setOrderId(dto.getOrderId());
    msg.setContent(dto.getContent());
    msg.setMsgType(dto.getType());
    msg.setSenderId(dto.getSenderId());

    messageMapper.insert(msg);
}

@PostMapping("/video/room/create")
public VideoRoomDTO createRoom(Long orderId){

    String roomId = "room_" + orderId;

    String token = trtcService.genUserSig(roomId);

    return new VideoRoomDTO(roomId, token);
}

const client = TRTC.createClient({
  sdkAppId,
  userId,
  userSig,
  mode: "rtc"
});

await client.join({ roomId });
await client.publish(localStream);

WAITING → ONGOING → FINISHED
        → CANCEL

public void startConsult(Long orderId){

    ConsultationOrder order = mapper.selectById(orderId);

    if(!"WAITING".equals(order.getStatus())){
        throw new RuntimeException("状态异常");
    }

    order.setStatus("ONGOING");
    order.setStartTime(LocalDateTime.now());

    mapper.update(order);
}

redisTemplate.opsForSet().add("online_doctor", doctorId);

mqProducer.send(chatMsg);

String encrypt = AESUtil.encrypt(content);