实时页面websocket加kgdy

lxw

2022-12-21 7671ffbebf533f3a0865f247c4ac95b756dbc798

实时页面websocket加kgdy

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

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

import com.whyc.pojo.KgdyState;

public interface KgdyStateMapper extends CustomMapper<KgdyState> {
}

 src/main/java/com/whyc/pojo/KgdyState.java

New file
@@ -0,0 +1,113 @@
package com.whyc.pojo;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

import java.io.Serializable;
import java.util.Date;

/**
 * <p>
 *
 * </p>
 *
 * @author lxw
 * @since 2022-12-21
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@ToString
@TableName(schema = "db_ram_db", value = "tb_kgdy_state")
@ApiModel(value = "KgdyState对象", description = "")
public class KgdyState implements Serializable {

    private static final long serialVersionUID = 1L;

    @TableId(value = "num", type = IdType.AUTO)
    private Long num;

    @ApiModelProperty(value = "设备id")
    private Integer devId;

    @ApiModelProperty(value = "记录时间")
    private Date recordtime;

    @ApiModelProperty(value = "开关量输出状态信息")
    private Integer outputState;

    @ApiModelProperty(value = "开关量输入状态信息")
    private Integer inputState;

    @ApiModelProperty(value = "Ua电压有效值")
    private Float uaVol;

    @ApiModelProperty(value = "Ub电压有效值")
    private Float ubVol;

    @ApiModelProperty(value = "Uc电压有效值")
    private Float ucVol;

    @ApiModelProperty(value = "Uab线电压有效值")
    private Float uabVol;

    @ApiModelProperty(value = "Ubc线电压有效值")
    private Float ubcVol;

    @ApiModelProperty(value = "Uca线电压有效值")
    private Float ucaVol;

    @ApiModelProperty(value = "Ia电流有效值")
    private Float iaCurr;

    @ApiModelProperty(value = "Ib电流有效值")
    private Float ibCurr;

    @ApiModelProperty(value = "Ic电流有效值")
    private Float icCurr;

    @ApiModelProperty(value = "p总有功功率")
    private Float pSumactpower;

    @ApiModelProperty(value = "p总无功功率")
    private Float pSumreactpower;

    @ApiModelProperty(value = "pf总功率因素")
    private Float pfTotalpowerfactor;

    @ApiModelProperty(value = "pa有功功率")
    private Float paActpower;

    @ApiModelProperty(value = "pb有功功率")
    private Float pbActpower;

    @ApiModelProperty(value = "pc有功功率")
    private Float pcActpower;

    @ApiModelProperty(value = "qa无功功率")
    private Float qaReactpower;

    @ApiModelProperty(value = "qb无功功率")
    private Float qbReactpower;

    @ApiModelProperty(value = "qc无功功率")
    private Float qcReactpower;

    @ApiModelProperty(value = "pfa功率因素")
    private Float pfaPowerfactor;

    @ApiModelProperty(value = "pfb功率因素")
    private Float pfbPowerfactor;

    @ApiModelProperty(value = "pfc功率因素")
    private Float pfcPowerfactor;


}

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

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.whyc.dto.Response;
import com.whyc.mapper.KgdyStateMapper;
import com.whyc.pojo.KgdyState;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class KgdyStateService {

    @Autowired(required = false)
    private KgdyStateMapper mapper;

    ////kgdy状态数据
    public Response serchByCondition(int devId) {
        QueryWrapper wrapper = new QueryWrapper();
        wrapper.eq("dev_id", devId);
        wrapper.last("limit 1");
        KgdyState state = mapper.selectOne(wrapper);
        return new Response().setII(1, state != null, state, "开关电源数据");
    }
}

 src/main/java/com/whyc/webSocket/RealTimeWebsocket.java

@@ -69,6 +69,8 @@

    private static PeakStatisticsService peakStatisticsService;

    private static KgdyStateService kgdyStateService;

    private Session session;

    @Autowired
@@ -162,6 +164,11 @@
    @Autowired
    public void setPeakStatisticsService(PeakStatisticsService peakStatisticsService) {
        RealTimeWebsocket.peakStatisticsService = peakStatisticsService;
    }

    @Autowired
    public void setKgdyStateService(KgdyStateService kgdyStateService) {
        RealTimeWebsocket.kgdyStateService = kgdyStateService;
    }

    @OnOpen
@@ -296,7 +303,9 @@
        //查询电池组单体信息
        Response rtdataRes = rtdataservice.serchByCondition(realTimePar.getBattGroupId());
        res.put("rtdata", rtdataRes);
        
        //kgdy状态数据
        Response kgdystateRes = kgdyStateService.serchByCondition(realTimePar.getDevId());
        res.put("kgdystate", kgdystateRes);
        return new Response().set(1, res);
    }


 src/main/resources/mapper/KgdyStateMapper.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.whyc.mapper.KgdyStateMapper">


</mapper>