实时推送加获取615全功能逆变假负载开关以及逆变模块实时

whyclxw

2024-12-26 5fce70ad7604dba45b40f5a5b515e59dece92b22

实时推送加获取615全功能逆变假负载开关以及逆变模块实时

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

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

import com.whyc.pojo.Qgn618Nbstate;

public interface Qgn618NbstateMapper extends CustomMapper<Qgn618Nbstate>{
}

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

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

import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 全功能逆变假负载开关以及逆变模块实时状态表
 * </p>
 *
 * @author lxw
 * @since 2024-12-26
 */
@Data
@EqualsAndHashCode(callSuper = false)
@AllArgsConstructor
@NoArgsConstructor
@Accessors(chain = true)
@TableName(schema ="db_ram_db" ,value = "tb_qgn_618_nbstate")
@ApiModel(value="Qgn618Nbstate对象", description="全功能逆变假负载开关以及逆变模块实时状态表")
public class Qgn618Nbstate implements Serializable {

    private static final long serialVersionUID = 1L;

    private Long num;

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

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

    @ApiModelProperty(value = "模块编号[0-模块1  1-模块2 .. 5-模块6]")
    private Integer modelNum;

    @ApiModelProperty(value = "DK11状态【1-闭合  0-断开】")
    private Integer dk11St;

    @ApiModelProperty(value = "DK12状态【1-闭合  0-断开】")
    private Integer dk12St;

    @ApiModelProperty(value = "DK13状态【1-闭合  0-断开】")
    private Integer dk13St;

    @ApiModelProperty(value = "DK21状态【1-闭合  0-断开】")
    private Integer dk21St;

    @ApiModelProperty(value = "DK22状态【1-闭合  0-断开】")
    private Integer dk22St;

    @ApiModelProperty(value = "DK23状态【1-闭合  0-断开】")
    private Integer dk23St;

    @ApiModelProperty(value = "DK31状态【1-闭合  0-断开】")
    private Integer dk31St;

    @ApiModelProperty(value = "JK1状态【1-闭合  0-断开】")
    private Integer jk1St;

    @ApiModelProperty(value = "急停状态")
    private Integer emergenStop;

    @ApiModelProperty(value = "远程闭锁状态")
    private Integer remoteLock;

    @ApiModelProperty(value = "交流A相电压")
    private Float acVola;

    @ApiModelProperty(value = "交流B相电压")
    private Float acVolb;

    @ApiModelProperty(value = "交流C相电压")
    private Float acVolc;

    @ApiModelProperty(value = "交流A相电流")
    private Float acCurra;

    @ApiModelProperty(value = "交流B相电流")
    private Float acCurrb;

    @ApiModelProperty(value = "交流C相电流")
    private Float acCurrc;

    @ApiModelProperty(value = "直流侧电压")
    private Float dcVol;

    @ApiModelProperty(value = "直流侧电流")
    private Float dcCurr;

    @ApiModelProperty(value = "温度")
    private Float interverTemp;

    @ApiModelProperty(value = "告警1[bit0-输出大短路 bit4-模块休眠 bit5-模块放电异常 bit8-模块DC侧处于关机状态 bit9-模块故障告警 bit10-模块保护告警 bit11-风扇故障告警 bit12-过温告警 bit13-输出过压告警 bit14-WALK-IN使能 bit15-模块通信中断告警  bit16-模块处于限功率状态 bit17-模块ID重复 bit18-模块严重不均流 bit19-三相输入缺相告警 bit20-三相输入不平衡告警 bit21-输入欠压告警 bit22-输入过压告警 bit23-模块PFC侧处于关机状态] ")
    private Integer interverAlm1;

    @ApiModelProperty(value = "告警2[bit0-（1-逆变模式；0-整流模式） bit4-(1-AC故障)  bit5-(1-锁相错误)]")
    private Integer interverAlm2;


}

 src/main/java/com/whyc/service/Qgn618NbstateService.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.Qgn618NbstateMapper;
import com.whyc.pojo.Qgn618Nbstate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class Qgn618NbstateService {
    @Autowired(required = false)
    private Qgn618NbstateMapper mapper;

    //实时推送618数据
    public Response serchByDevId(int devId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        List<Qgn618Nbstate> list=mapper.selectList(wrapper);
        return new Response().setII(1, list!= null , list, "实时推送618数据");
    }
}

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

@@ -93,6 +93,8 @@

    private static PowerInfService pinfService;

    private static Qgn618NbstateService qgnService;

    private Session session;

    private HttpSession httpSession;
@@ -106,6 +108,12 @@
    public void setService(AcdcSecuityService acdcSecuityService) {
        RealTimeWebsocket.acdcSecuityService = acdcSecuityService;
    }

    @Autowired
    public void setQgn618NbstateService(Qgn618NbstateService qgnService) {
        RealTimeWebsocket.qgnService = qgnService;
    }


    @Autowired
    public void setService(BattRtstateService rtstateservice) {
@@ -664,7 +672,9 @@
        //最后一次核容放电数据
        Response tinfRes = batttestDataInfService.searchBattLastHrDataById(realTimePar.getBattGroupId(), realTimePar.getDevId(), lang);
        res.put("tinfdata", tinfRes);

        //获取615全功能逆变假负载开关以及逆变模块实时
        Response  qgnRes= qgnService.serchByDevId(realTimePar.getDevId());
        res.put("qgnRes", qgnRes);

        return new Response().set(1, res);
    }