核容单体信息

whycxzp

2023-12-05 15c7bf201ca77efe0e130c6a6c89db90196d93a0

核容单体信息

 src/main/java/com/whyc/mapper/CKPowerDevBattRtDataMapper.java

New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;

import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtData;

public interface CKPowerDevBattRtDataMapper extends CustomMapper<CKPowerDevBattRtData> {
}

 src/main/java/com/whyc/service/CKPowerDevBattRtDataService.java

New file
@@ -0,0 +1,24 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.mapper.CKPowerDevBattRtDataMapper;
import com.whyc.mapper.CKPowerDevBattRtStateMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtData;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtState;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class CKPowerDevBattRtDataService {

    @Resource
    private CKPowerDevBattRtDataMapper mapper;

    public CKPowerDevBattRtData get() {
        QueryWrapper<CKPowerDevBattRtData> query = Wrappers.query();
        query.last(" limit 1");
        return mapper.selectOne(query);
    }
}

 src/main/java/com/whyc/websocket/CKRtAndSignalAndHrSocket.java

@@ -2,9 +2,11 @@

import com.whyc.config.WebSocketConfig;
import com.whyc.dto.Response;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtData;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtState;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevRt;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevSignal;
import com.whyc.service.CKPowerDevBattRtDataService;
import com.whyc.service.CKPowerDevBattRtStateService;
import com.whyc.service.CKPowerDevRtService;
import com.whyc.service.CKPowerDevSignalService;
@@ -33,6 +35,8 @@

    private static CKPowerDevBattRtStateService ckPowerDevBattRtStateService;

    private static CKPowerDevBattRtDataService ckPowerDevBattRtDataService;

    @Autowired
    public void setCkPowerDevRtService(CKPowerDevRtService ckPowerDevRtService) {
        CKRtAndSignalAndHrSocket.ckPowerDevRtService = ckPowerDevRtService;
@@ -48,6 +52,11 @@
        CKRtAndSignalAndHrSocket.ckPowerDevBattRtStateService = ckPowerDevBattRtStateService;
    }

    @Autowired
    public void setCkPowerDevBattRtDataService(CKPowerDevBattRtDataService ckPowerDevBattRtDataService) {
        CKRtAndSignalAndHrSocket.ckPowerDevBattRtDataService = ckPowerDevBattRtDataService;
    }

    @OnOpen
    public void onOpen(Session session, EndpointConfig config){
        this.session = session;
@@ -60,7 +69,8 @@
                        CKPowerDevRt ckPowerDevRt = ckPowerDevRtService.get();
                        CKPowerDevSignal ckPowerDevSignal = ckPowerDevSignalService.get();
                        CKPowerDevBattRtState ckPowerDevBattRtState = ckPowerDevBattRtStateService.get();
                        session.getBasicRemote().sendObject(new Response<>().setIII(1,ckPowerDevRt,ckPowerDevSignal,ckPowerDevBattRtState,"查询完成"));
                        CKPowerDevBattRtData ckPowerDevBattRtData = ckPowerDevBattRtDataService.get();
                        session.getBasicRemote().sendObject(new Response<>().setIV(1,ckPowerDevRt,ckPowerDevSignal,ckPowerDevBattRtState,ckPowerDevBattRtData,"查询完成"));
                        sleep(4000);
                    }
                } catch (Exception e) {