whycxzp
2023-12-07 5679b14b9ece9cc448e0684c0c597e17b52117d3
命名规范
3 文件已重命名
32 ■■■■■ 已修改文件
src/main/java/com/whyc/service/CKPowerDevBattRsAlarmService.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/CKPowerDevBattRtAlarmService.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/websocket/CKDevRsAndRtAlmSocket.java 28 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/CKPowerDevBattRsAlarmService.java
File was renamed from src/main/java/com/whyc/service/CkpowerdevBattRsalarmService.java
@@ -9,7 +9,7 @@
import java.util.List;
@Service
public class CkpowerdevBattRsalarmService {
public class CKPowerDevBattRsAlarmService {
    @Autowired(required = false)
    private CkpowerdevBattRsalarmMapper mapper;
src/main/java/com/whyc/service/CKPowerDevBattRtAlarmService.java
File was renamed from src/main/java/com/whyc/service/CkpowerdevBattRtalarmService.java
@@ -10,7 +10,7 @@
import java.util.List;
@Service
public class CkpowerdevBattRtalarmService {
public class CKPowerDevBattRtAlarmService {
    @Autowired(required = false)
    private CkpowerdevBattRtalarmMapper mapper;
src/main/java/com/whyc/websocket/CKDevRsAndRtAlmSocket.java
File was renamed from src/main/java/com/whyc/websocket/CkDevRsAndRtAlmSocket.java
@@ -2,12 +2,8 @@
import com.whyc.config.WebSocketConfig;
import com.whyc.dto.Response;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevHrTestParam;
import com.whyc.pojo.db_ckpwrdev_data_rt.CkpowerdevBattRsalarm;
import com.whyc.service.CKPowerDevHrTestParamService;
import com.whyc.service.CkpowerdevBattRsalarmService;
import com.whyc.service.CkpowerdevBattRsalarmSetService;
import com.whyc.service.CkpowerdevBattRtalarmService;
import com.whyc.service.CKPowerDevBattRsAlarmService;
import com.whyc.service.CKPowerDevBattRtAlarmService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -15,7 +11,6 @@
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
@@ -23,23 +18,24 @@
 */
@Component
@ServerEndpoint(value = "/ckDevRsAndRtAlm",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
public class CkDevRsAndRtAlmSocket {
public class CKDevRsAndRtAlmSocket {
    private Session session;
    private Thread thread;
    private static CkpowerdevBattRsalarmService rsalarmService;
    private static CKPowerDevBattRsAlarmService rsAlarmService;
    private static CkpowerdevBattRtalarmService rtalarmService;
    private static CKPowerDevBattRtAlarmService rtAlarmService;
    @Autowired
    public void setCkpowerdevBattRsalarmService(CkpowerdevBattRsalarmService rsalarmService) {
        CkDevRsAndRtAlmSocket.rsalarmService = rsalarmService;
    public void setRsAlarmService(CKPowerDevBattRsAlarmService rsAlarmService) {
        CKDevRsAndRtAlmSocket.rsAlarmService = rsAlarmService;
    }
    @Autowired
    public void setCkpowerdevBattRtalarmService(CkpowerdevBattRtalarmService rtalarmService) {
        CkDevRsAndRtAlmSocket.rtalarmService = rtalarmService;
    public void setRtAlarmService(CKPowerDevBattRtAlarmService rtAlarmService) {
        CKDevRsAndRtAlmSocket.rtAlarmService = rtAlarmService;
    }
@@ -52,9 +48,9 @@
                try{
                    while (!currentThread().isInterrupted()) {
                        Map<String,Object>map=new HashMap<>();
                        Response rsAlmRes = rsalarmService.getRsAlm();
                        Response rsAlmRes = rsAlarmService.getRsAlm();
                        map.put("rsAlmRes",rsAlmRes);
                        Response rtAlmRes = rtalarmService.getRtAlm();
                        Response rtAlmRes = rtAlarmService.getRtAlm();
                        map.put("rtAlmRes",rtAlmRes);
                        session.getBasicRemote().sendObject(new Response<>().set(1,map,"查询完成"));
                        sleep(4000);