更新

whycxzp

2023-12-05 85c1c9580b3d4a80d68042fc6a43a087dda2d6e7

更新

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

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

import com.whyc.pojo.db_ckpwrdev_inf.CKPwrDevInf;

public interface CKPwrDevInfMapper extends CustomMapper<CKPwrDevInf>{
}

 src/main/java/com/whyc/pojo/db_ckpwrdev_inf/CKPwrDevInf.java

@@ -1,6 +1,7 @@
package com.whyc.pojo.db_ckpwrdev_inf;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
@@ -38,5 +39,9 @@
    @ApiModelProperty(value = "测控电源ip地址")
    private String powerDeviceIp;

    @ApiModelProperty("电池单体数")
    @TableField("batt_moncount")
    private Integer battMonCount;


}

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

@@ -9,6 +9,7 @@
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

@Service
public class CKPowerDevBattRtDataService {
@@ -16,9 +17,9 @@
    @Resource
    private CKPowerDevBattRtDataMapper mapper;

    public CKPowerDevBattRtData get() {
    public List<CKPowerDevBattRtData> getList() {
        QueryWrapper<CKPowerDevBattRtData> query = Wrappers.query();
        query.last(" limit 1");
        return mapper.selectOne(query);
        query.eq("batt_index",0);
        return mapper.selectList(query);
    }
}

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

@@ -4,9 +4,12 @@
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.mapper.CKPowerDevBattRtStateMapper;
import com.whyc.pojo.db_ckpwrdev_data_rt.CKPowerDevBattRtState;
import com.whyc.pojo.db_ckpwrdev_inf.CKPwrDevInf;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.List;

@Service
public class CKPowerDevBattRtStateService {
@@ -14,9 +17,16 @@
    @Resource
    private CKPowerDevBattRtStateMapper mapper;

    public CKPowerDevBattRtState get() {
    @Autowired
    private CKPwrDevInfService ckPwrDevInfService;

    public List<CKPowerDevBattRtState> getList() {
        //查询有单体数量
        CKPwrDevInf ckPwrDevInf = ckPwrDevInfService.get();

        QueryWrapper<CKPowerDevBattRtState> query = Wrappers.query();
        query.last(" limit 1");
        return mapper.selectOne(query);
        query.eq("batt_index",0);
        query.le("mon_num",ckPwrDevInf.getBattMonCount());
        return mapper.selectList(query);
    }
}

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

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.whyc.mapper.CKPwrDevInfMapper;
import com.whyc.pojo.db_ckpwrdev_inf.CKPwrDevInf;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class CKPwrDevInfService {

    @Resource
    private CKPwrDevInfMapper mapper;

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

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

@@ -16,6 +16,7 @@
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.List;

/**
 * 测控电源遥测量和遥信量
@@ -68,8 +69,8 @@
                    while (!currentThread().isInterrupted()) {
                        CKPowerDevRt ckPowerDevRt = ckPowerDevRtService.get();
                        CKPowerDevSignal ckPowerDevSignal = ckPowerDevSignalService.get();
                        CKPowerDevBattRtState ckPowerDevBattRtState = ckPowerDevBattRtStateService.get();
                        CKPowerDevBattRtData ckPowerDevBattRtData = ckPowerDevBattRtDataService.get();
                        List<CKPowerDevBattRtState> ckPowerDevBattRtState = ckPowerDevBattRtStateService.getList();
                        List<CKPowerDevBattRtData> ckPowerDevBattRtData = ckPowerDevBattRtDataService.getList();
                        session.getBasicRemote().sendObject(new Response<>().setIV(1,ckPowerDevRt,ckPowerDevSignal,ckPowerDevBattRtState,ckPowerDevBattRtData,"查询完成"));
                        sleep(4000);
                    }