问诊大厅代码提交

dev_2.0.0
liu 1 year ago
parent 20ae059e00
commit ca97cffad8

@ -1,5 +1,6 @@
package com.supervision.controller; package com.supervision.controller;
import com.supervision.service.DiagnoseHallService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
@ -15,8 +16,10 @@ import org.springframework.web.bind.annotation.RestController;
@RequiredArgsConstructor @RequiredArgsConstructor
public class DiagnoseHallController { public class DiagnoseHallController {
@ApiOperation("获取问诊资源") private final DiagnoseHallService diagnoseHallService;
public void achieveDiagnoseResource(){
@ApiOperation("获取问诊资源")
public boolean achieveDiagnoseResource(){
return diagnoseHallService.achieveDiagnoseResource();
} }
} }

@ -4,6 +4,7 @@ import cn.hutool.core.util.ObjectUtil;
import com.supervision.constant.UserTokenConstant; import com.supervision.constant.UserTokenConstant;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -16,10 +17,10 @@ import java.util.concurrent.ConcurrentHashMap;
@Component @Component
@Slf4j @Slf4j
@ServerEndpoint("/webSocket/{uid}") @ServerEndpoint("/webSocket/{uid}")
@RequiredArgsConstructor
public class WebSocketServer { public class WebSocketServer {
private final RedisTemplate<String, String> redisTemplate; @Autowired
private RedisTemplate<String, String> redisTemplate;
//concurrent包的线程安全Set用来存放每个客户端对应的WebSocketServer对象。 //concurrent包的线程安全Set用来存放每个客户端对应的WebSocketServer对象。
private static final ConcurrentHashMap<String, Session> SESSION_POOL = new ConcurrentHashMap<>(); private static final ConcurrentHashMap<String, Session> SESSION_POOL = new ConcurrentHashMap<>();

@ -0,0 +1,6 @@
package com.supervision.service;
public interface DiagnoseHallService {
boolean achieveDiagnoseResource();
}

@ -0,0 +1,21 @@
package com.supervision.service.impl;
import com.supervision.service.DiagnoseHallService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
@Service
@RequiredArgsConstructor
@Slf4j
public class DiagnoseHallServiceImpl implements DiagnoseHallService {
private final RedisTemplate<String,String> redisTemplate;
@Override
public boolean achieveDiagnoseResource() {
return false;
}
}
Loading…
Cancel
Save