whyclxw
2024-07-27 4037203a1c69a26154f2e4efb89495abb8a3c470
电源核容一体机
6个文件已添加
1个文件已修改
692 ■■■■■ 已修改文件
src/main/java/com/whyc/mapper/Dev6159PowerYcMapper.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/mapper/Dev6159PowerYxMapper.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/pojo/Dev6159PowerYc.java 288 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/pojo/Dev6159PowerYx.java 301 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/Dev6159PowerYcService.java 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/service/Dev6159PowerYxService.java 26 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/webSocket/RealTimeWebsocket.java 41 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/whyc/mapper/Dev6159PowerYcMapper.java
New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;
import com.whyc.pojo.Dev6159PowerYc;
public interface Dev6159PowerYcMapper extends CustomMapper<Dev6159PowerYc>{
}
src/main/java/com/whyc/mapper/Dev6159PowerYxMapper.java
New file
@@ -0,0 +1,6 @@
package com.whyc.mapper;
import com.whyc.pojo.Dev6159PowerYx;
public interface Dev6159PowerYxMapper extends CustomMapper<Dev6159PowerYx>{
}
src/main/java/com/whyc/pojo/Dev6159PowerYc.java
New file
@@ -0,0 +1,288 @@
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.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.util.Date;
/**
 * <p>
 * 通信电源核容一体机遥测实时状态表
 * </p>
 *
 * @author lxw
 * @since 2024-07-27
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName(schema = "db_ram_db",value = "tb_dev6159_power_yc")
@ApiModel(value="Dev6159PowerYc对象", description="通信电源核容一体机遥测实时状态表")
public class Dev6159PowerYc implements Serializable {
    private static final long serialVersionUID = 1L;
    @ApiModelProperty(value = "自增主键")
    @TableId(value = "num", type = IdType.AUTO)
    private Long num;
    private Integer devId;
    @ApiModelProperty(value = "更新时间")
    private Date recordTime;
    @ApiModelProperty(value = "第1路交流A相输入电压-ACSWIB")
    private Float acin1VolaAc;
    @ApiModelProperty(value = "第1路交流B相输入电压-ACSWIB")
    private Float acin1VolbAc;
    @ApiModelProperty(value = "第1路交流C相输入电压-ACSWIB")
    private Float acin1VolcAc;
    @ApiModelProperty(value = "第1路交流A相输入电流-ACSWIB")
    private Float acin1CurraAc;
    @ApiModelProperty(value = "第1路交流B相输入电流-ACSWIB")
    private Float acin1CurrbAc;
    @ApiModelProperty(value = "第1路交流C相输入电流-ACSWIB")
    private Float acin1CurrcAc;
    @ApiModelProperty(value = "第2路交流A相输入电压-ACSWIB")
    private Float acin2VolaAc;
    @ApiModelProperty(value = "第2路交流B相输入电压-ACSWIB")
    private Float acin2VolbAc;
    @ApiModelProperty(value = "第2路交流C相输入电压-ACSWIB")
    private Float acin2VolcAc;
    @ApiModelProperty(value = "第2路交流A相输入电流-ACSWIB")
    private Float acin2CurraAc;
    @ApiModelProperty(value = "第2路交流B相输入电流-ACSWIB")
    private Float acin2CurrbAc;
    @ApiModelProperty(value = "第2路交流C相输入电流-ACSWIB")
    private Float acin2CurrcAc;
    @ApiModelProperty(value = "交流电压告警阈值上限-ACSWIB")
    private Float acVolHighlimitAc;
    @ApiModelProperty(value = "交流电压告警阈值下限-ACSWIB")
    private Float acVolLowlimitAc;
    @ApiModelProperty(value = "交流配电柜温度值-ACSWIB")
    private Float acDevTempAc;
    @ApiModelProperty(value = "第1路交流A相输入电压-CPSS")
    private Float acin1VolaCpss;
    @ApiModelProperty(value = "第1路交流B相输入电压-CPSS")
    private Float acin1VolbCpss;
    @ApiModelProperty(value = "第1路交流C相输入电压-CPSS")
    private Float acin1VolcCpss;
    @ApiModelProperty(value = "交流电压告警阈值上限-CPSS")
    private Float acVolHiglimitCpss;
    @ApiModelProperty(value = "交流电压告警阈值下限-CPSS")
    private Float acVolLowlimitCpss;
    @ApiModelProperty(value = "第2路交流A相输入电压-CPSS")
    private Float acin2VolaCpss;
    @ApiModelProperty(value = "第2路交流B相输入电压-CPSS")
    private Float acin2VolbCpss;
    @ApiModelProperty(value = "第2路交流C相输入电压-CPSS")
    private Float acin2VolcCpss;
    @ApiModelProperty(value = "交流A相输出电压-CPSS")
    private Float acVolaCpss;
    @ApiModelProperty(value = "交流B相输出电压-CPSS")
    private Float acVolbCpss;
    @ApiModelProperty(value = "交流C相输出电压-CPSS")
    private Float acVolcCpss;
    @ApiModelProperty(value = "交流A相输出电流-CPSS")
    private Float acOutcurraCpss;
    @ApiModelProperty(value = "交流B相输出电流-CPSS")
    private Float acOutcurrbCpss;
    @ApiModelProperty(value = "交流C相输出电流-CPSS")
    private Float acOutcurrcCpss;
    @ApiModelProperty(value = "直流输出电压-CPSS")
    private Float dcOutvolCpss;
    @ApiModelProperty(value = "负载电流-CPSS")
    private Float loadCurrCpss;
    @ApiModelProperty(value = "直流输出电压告警阈值上限-CPSS")
    private Float dcOutvolHighlimitCpss;
    @ApiModelProperty(value = "直流输出电压告警阈值下限-CPSS")
    private Float dcOutvolLowlimitCpss;
    @ApiModelProperty(value = "电池端1电压-CPSS")
    private Float batt1VolCpss;
    @ApiModelProperty(value = "蓄电池组充电电流-CPSS")
    private Float battChargecurrCpss;
    @ApiModelProperty(value = "均充电压-CPSS")
    private Float junChargeVolCpss;
    @ApiModelProperty(value = "浮充电压-CPSS")
    private Float floatChargeVolCpss;
    @ApiModelProperty(value = "电池充电限流值-CPSS")
    private Float battCharcurrLimitCpss;
    @ApiModelProperty(value = "电池端2电压-CPSS")
    private Float batt2VolCpss;
    @ApiModelProperty(value = "高频开关电源柜温度-CPSS")
    private Float devTempCpss;
    @ApiModelProperty(value = "模块1输出电流-CPSS")
    private Float m1OutcurrCpss;
    @ApiModelProperty(value = "模块2输出电流-CPSS")
    private Float m2OutcurrCpss;
    @ApiModelProperty(value = "模块3输出电流-CPSS")
    private Float m3OutcurrCpss;
    @ApiModelProperty(value = "模块4输出电流-CPSS")
    private Float m4OutcurrCpss;
    @ApiModelProperty(value = "模块5输出电流-CPSS")
    private Float m5OutcurrCpss;
    @ApiModelProperty(value = "模块6输出电流-CPSS")
    private Float m6OutcurrCpss;
    @ApiModelProperty(value = "模块7输出电流-CPSS")
    private Float m7OutcurrCpss;
    @ApiModelProperty(value = "模块8输出电流-CPSS")
    private Float m8OutcurrCpss;
    @ApiModelProperty(value = "模块9输出电流-CPSS")
    private Float m9OutcurrCpss;
    @ApiModelProperty(value = "模块10输出电流-CPSS")
    private Float m10OutcurrCpss;
    @ApiModelProperty(value = "模块11输出电流-CPSS")
    private Float m11OutcurrCpss;
    @ApiModelProperty(value = "模块12输出电流-CPSS")
    private Float m12OutcurrCpss;
    @ApiModelProperty(value = "模块13输出电流-CPSS")
    private Float m13OutcurrCpss;
    @ApiModelProperty(value = "模块14输出电流-CPSS")
    private Float m14OutcurrCpss;
    @ApiModelProperty(value = "模块15输出电流-CPSS")
    private Float m15OutcurrCpss;
    @ApiModelProperty(value = "模块16输出电流-CPSS")
    private Float m16OutcurrCpss;
    @ApiModelProperty(value = "模块17输出电流-CPSS")
    private Float m17OutcurrCpss;
    @ApiModelProperty(value = "模块18输出电流-CPSS")
    private Float m18OutcurrCpss;
    @ApiModelProperty(value = "模块19输出电流-CPSS")
    private Float m19OutcurrCpss;
    @ApiModelProperty(value = "模块20输出电流-CPSS")
    private Float m20OutcurrCpss;
    @ApiModelProperty(value = "模块21输出电流-CPSS")
    private Float m21OutcurrCpss;
    @ApiModelProperty(value = "模块22输出电流-CPSS")
    private Float m22OutcurrCpss;
    @ApiModelProperty(value = "模块23输出电流-CPSS")
    private Float m23OutcurrCpss;
    @ApiModelProperty(value = "模块24输出电流-CPSS")
    private Float m24OutcurrCpss;
    @ApiModelProperty(value = "模块25输出电流-CPSS")
    private Float m25OutcurrCpss;
    @ApiModelProperty(value = "模块26输出电流-CPSS")
    private Float m26OutcurrCpss;
    @ApiModelProperty(value = "模块27输出电流-CPSS")
    private Float m27OutcurrCpss;
    @ApiModelProperty(value = "模块28输出电流-CPSS")
    private Float m28OutcurrCpss;
    @ApiModelProperty(value = "模块29输出电流-CPSS")
    private Float m29OutcurrCpss;
    @ApiModelProperty(value = "模块30输出电流-CPSS")
    private Float m30OutcurrCpss;
    @ApiModelProperty(value = "模块31输出电流-CPSS")
    private Float m31OutcurrCpss;
    @ApiModelProperty(value = "模块32输出电流-CPSS")
    private Float m32OutcurrCpss;
    @ApiModelProperty(value = "在用交流路数-CPSS")
    private Integer acinUsecountCpss;
    @ApiModelProperty(value = "第1路直流输入电压-DCSWIB")
    private Float dcin1VolDc;
    @ApiModelProperty(value = "第1路直流输入电压-DCSWIB")
    private Float dcin2VolDc;
    @ApiModelProperty(value = "1段直流母线输出电压-DCSWIB")
    private Float dcout1VolDc;
    @ApiModelProperty(value = "1段直流母线输出电流-DCSWIB")
    private Float dcout1CurrDc;
    @ApiModelProperty(value = "直流电压告警阈值上限-DCSWIB")
    private Float dcvolHighlimitDc;
    @ApiModelProperty(value = "直流电压告警阈值下限-DCSWIB")
    private Float dcvolLowlimitDc;
    @ApiModelProperty(value = "2段直流母线输出电压-DCSWIB")
    private Float dcout2VolDc;
    @ApiModelProperty(value = "2段直流母线输出电流-DCSWIB")
    private Float dcout2CurrDc;
    @ApiModelProperty(value = "直流配电柜温度-DCSWIB")
    private Float devTempDc;
}
src/main/java/com/whyc/pojo/Dev6159PowerYx.java
New file
@@ -0,0 +1,301 @@
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.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.util.Date;
/**
 * <p>
 * 通信电源核容一体机遥信实时状态表
 * </p>
 *
 * @author lxw
 * @since 2024-07-27
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName(schema = "db_ram_db",value = "tb_dev6159_power_yx")
@ApiModel(value="Dev6159PowerYx对象", description="通信电源核容一体机遥信实时状态表")
public class Dev6159PowerYx implements Serializable {
    private static final long serialVersionUID = 1L;
    @ApiModelProperty(value = "自增主键")
    @TableId(value = "num", type = IdType.AUTO)
    private Long num;
    @ApiModelProperty(value = "设备ID")
    private Integer devId;
    @ApiModelProperty(value = "更新时间")
    private Date recordTime;
    @ApiModelProperty(value = "第1路交流A相过压-ACSWIB")
    private Integer ac1OvervolaAc;
    @ApiModelProperty(value = "第1路交流A相欠压-ACSWIB")
    private Integer ac1UndervolaAc;
    @ApiModelProperty(value = "第1路交流A相缺相-ACSWIB")
    private Integer ac1LessvolaAc;
    @ApiModelProperty(value = "第1路交流B相过压-ACSWIB")
    private Integer ac1OvervolbAc;
    @ApiModelProperty(value = "第1路交流B相欠压-ACSWIB")
    private Integer ac1UndervolbAc;
    @ApiModelProperty(value = "第1路交流B相缺相-ACSWIB")
    private Integer ac1LessvolbAc;
    @ApiModelProperty(value = "第1路交流C相过压-ACSWIB")
    private Integer ac1OvervolcAc;
    @ApiModelProperty(value = "第1路交流C相欠压-ACSWIB")
    private Integer ac1UndervolcAc;
    @ApiModelProperty(value = "第1路交流C相缺相-ACSWIB")
    private Integer ac1LessvolcAc;
    @ApiModelProperty(value = "交流输入1防雷器故障-ACSWIB")
    private Integer acin1ThunderFaultAc;
    @ApiModelProperty(value = "第2路交流A相过压-ACSWIB")
    private Integer ac2OvervolaAc;
    @ApiModelProperty(value = "第2路交流A相欠压-ACSWIB")
    private Integer ac2UndervolaAc;
    @ApiModelProperty(value = "第2路交流A相缺相-ACSWIB")
    private Integer ac2LessvolaAc;
    @ApiModelProperty(value = "第2路交流B相过压-ACSWIB")
    private Integer ac2OvervolbAc;
    @ApiModelProperty(value = "第2路交流B相欠压-ACSWIB")
    private Integer ac2UndervolbAc;
    @ApiModelProperty(value = "第2路交流B相缺相-ACSWIB")
    private Integer ac2LessvolbAc;
    @ApiModelProperty(value = "第2路交流C相过压-ACSWIB")
    private Integer ac2OvervolcAc;
    @ApiModelProperty(value = "第2路交流C相欠压-ACSWIB")
    private Integer ac2UndervolcAc;
    @ApiModelProperty(value = "第2路交流C相缺相-ACSWIB")
    private Integer ac2LessvolcAc;
    @ApiModelProperty(value = "交流输入2防雷器故障-ACSWIB")
    private Integer acin2ThunderFaultAc;
    @ApiModelProperty(value = "交流配电柜温度告警-ACSWIB")
    private Integer acDevTempAlmAc;
    @ApiModelProperty(value = "交流输入1停电-ACSWIB")
    private Integer acin1PowerdownAc;
    @ApiModelProperty(value = "交流输入2停电-ACSWIB")
    private Integer acin2PowerdownAc;
    @ApiModelProperty(value = "交流监控单元故障-ACSWIB")
    private Integer acMonitorerrFaultAc;
    @ApiModelProperty(value = "第1路交流输入开关跳闸-ACSWIB")
    private Integer acin1TripAc;
    @ApiModelProperty(value = "第2路交流输入开关跳闸-ACSWIB")
    private Integer acin2TripAc;
    @ApiModelProperty(value = "1段交流母线输出开关0-25跳闸[bit0-开关1 ... bit24 - 开关25]-ACSWIB")
    private Integer fsw1Sw1tripAc;
    @ApiModelProperty(value = "1段交流母线输出开关26-50跳闸[bit0-开关26 ... bit24 - 开关50]-ACSWIB")
    private Integer fsw1Sw2tripAc;
    @ApiModelProperty(value = "1段交流母线输出开关51-64跳闸[bit0-开关51 ... bit13 - 开关64]-ACSWIB")
    private Integer fsw1Sw3tripAc;
    @ApiModelProperty(value = "2段交流母线输出开关0-25跳闸[bit0-开关1 ... bit24 - 开关25]-ACSWIB")
    private Integer fsw2Sw1tripAc;
    @ApiModelProperty(value = "2段交流母线输出开关26-50跳闸[bit0-开关26 ... bit24 - 开关50]-ACSWIB")
    private Integer fsw2Sw2tripAc;
    @ApiModelProperty(value = "2段交流母线输出开关51-64跳闸[bit0-开关51 ... bit13 - 开关64]-ACSWIB")
    private Integer fsw2Sw3tripAc;
    @ApiModelProperty(value = "交流配电柜总告警-ACSWIB")
    private Integer acTotalAlmAc;
    @ApiModelProperty(value = "第1路交流A相过压-CPSS")
    private Integer ac1OvervolaCpss;
    @ApiModelProperty(value = "第1路交流A相欠压-CPSS")
    private Integer ac1UndervolaCpss;
    @ApiModelProperty(value = "第1路交流A相缺相-CPSS")
    private Integer ac1LessvolaCpss;
    @ApiModelProperty(value = "第1路交流B相过压-CPSS")
    private Integer ac1OvervolbCpss;
    @ApiModelProperty(value = "第1路交流B相欠压-CPSS")
    private Integer ac1UndervolbCpss;
    @ApiModelProperty(value = "第1路交流B相缺相-CPSS")
    private Integer ac1LessvolbCpss;
    @ApiModelProperty(value = "第1路交流C相过压-CPSS")
    private Integer ac1OvervolcCpss;
    @ApiModelProperty(value = "第1路交流C相欠压-CPSS")
    private Integer ac1UndervolcCpss;
    @ApiModelProperty(value = "第1路交流C相缺相-CPSS")
    private Integer ac1LessvolcCpss;
    @ApiModelProperty(value = "交流输入1停电-CPSS")
    private Integer acin1PowerdownCpss;
    @ApiModelProperty(value = "交流输入1防雷器故障-CPSS")
    private Integer acin1ThunderFaultCpss;
    @ApiModelProperty(value = "第2路交流A相过压-CPSS")
    private Integer ac2OvervolaCpss;
    @ApiModelProperty(value = "第2路交流A相欠压-CPSS")
    private Integer ac2UndervolaCpss;
    @ApiModelProperty(value = "第2路交流A相缺相-CPSS")
    private Integer ac2LessvolaCpss;
    @ApiModelProperty(value = "第2路交流B相过压-CPSS")
    private Integer ac2OvervolbCpss;
    @ApiModelProperty(value = "第2路交流B相欠压-CPSS")
    private Integer ac2UndervolbCpss;
    @ApiModelProperty(value = "第2路交流B相缺相-CPSS")
    private Integer ac2LessvolbCpss;
    @ApiModelProperty(value = "第2路交流C相过压-CPSS")
    private Integer ac2OvervolcCpss;
    @ApiModelProperty(value = "第2路交流C相欠压-CPSS")
    private Integer ac2UndervolcCpss;
    @ApiModelProperty(value = "第2路交流C相缺相-CPSS")
    private Integer ac2LessvolcCpss;
    @ApiModelProperty(value = "交流输入2停电-CPSS")
    private Integer acin2PowerdownCpss;
    @ApiModelProperty(value = "交流输入2防雷器故障-CPSS")
    private Integer acin2ThunderFaultCpss;
    @ApiModelProperty(value = "监控单元故障-CPSS")
    private Integer monitorerrFaultCpss;
    @ApiModelProperty(value = "直流输出过压-CPSS")
    private Integer dcOutvolOverCpss;
    @ApiModelProperty(value = "直流输出欠压-CPSS")
    private Integer dcOutvolUnderCpss;
    @ApiModelProperty(value = "电池组下电保护告警-CPSS")
    private Integer battPowerdownCpss;
    @ApiModelProperty(value = "模块1-25故障[bit0-模块1... bit24-模块25]-CPSS")
    private Integer modFault1Cpss;
    @ApiModelProperty(value = "模块25-32故障[bit0-模块26... bit6-模块32]-CPSS")
    private Integer modFault2Cpss;
    @ApiModelProperty(value = "模块1-25关机[bit0-模块1... bit24-模块25]-CPSS")
    private Integer modClose1Cpss;
    @ApiModelProperty(value = "模块25-32关机[bit0-模块26... bit6-模块32]-CPSS")
    private Integer modClose2Cpss;
    @ApiModelProperty(value = "第1路交流输入开关跳闸-CPSS")
    private Integer acin1TripCpss;
    @ApiModelProperty(value = "第2路交流输入开关跳闸-CPSS")
    private Integer acin2TripCpss;
    @ApiModelProperty(value = "高频开关电源柜总告警-CPSS")
    private Integer devTotalAlmCpss;
    @ApiModelProperty(value = "负载熔丝状态-CPSS")
    private Integer loaderFuseCpss;
    @ApiModelProperty(value = "电池组1熔丝告警-CPSS")
    private Integer batt1FuseCpss;
    @ApiModelProperty(value = "电池组2熔丝告警-CPSS")
    private Integer batt2FuseCpss;
    @ApiModelProperty(value = "第1路直流过压-DCSWIB")
    private Integer dcvol1OverDc;
    @ApiModelProperty(value = "第1路直流欠压-DCSWIB")
    private Integer dcvol1UnderDc;
    @ApiModelProperty(value = "第2路直流过压-DCSWIB")
    private Integer dcvol2OverDc;
    @ApiModelProperty(value = "第2路直流欠压-DCSWIB")
    private Integer dcvol2UnderDc;
    @ApiModelProperty(value = "监控单元故障-DCSWIB")
    private Integer monitorFaultDc;
    @ApiModelProperty(value = "直流配电柜温度告警-DCSWIB")
    private Integer devTempAlmDc;
    @ApiModelProperty(value = "第1路输入开关跳闸-DCSWIB")
    private Integer dcin1SwtripDc;
    @ApiModelProperty(value = "第2路输入开关跳闸-DCSWIB")
    private Integer dcin2SwtripDc;
    @ApiModelProperty(value = "1段直流第1-25路开关跳闸[bit0-第1路  ... bit24-第25路]-DCSWIB")
    private Integer fsw1Sw1Trip;
    @ApiModelProperty(value = "1段直流第26-50路开关跳闸[bit0-第26路  ... bit24-第50路]-DCSWIB")
    private Integer fsw1Sw2Trip;
    @ApiModelProperty(value = "1段直流第51-75路开关跳闸[bit0-第51路  ... bit24-第75路]-DCSWIB")
    private Integer fsw1Sw3Trip;
    @ApiModelProperty(value = "1段直流第76-100路开关跳闸[bit0-第76路  ... bit24-第100路]-DCSWIB")
    private Integer fsw1Sw4Trip;
    @ApiModelProperty(value = "2段直流第1-25路开关跳闸[bit0-第1路  ... bit24-第25路]-DCSWIB")
    private Integer fsw2Sw1Trip;
    @ApiModelProperty(value = "2段直流第26-50路开关跳闸[bit0-第26路  ... bit24-第50路]-DCSWIB")
    private Integer fsw2Sw2Trip;
    @ApiModelProperty(value = "2段直流第51-75路开关跳闸[bit0-第51路  ... bit24-第75路]-DCSWIB")
    private Integer fsw2Sw3Trip;
    @ApiModelProperty(value = "2段直流第76-100路开关跳闸[bit0-第76路  ... bit24-第100路]-DCSWIB")
    private Integer fsw2Sw4Trip;
    @ApiModelProperty(value = "直流配电柜总告警-DCSWIB")
    private Integer devTotalAlmDc;
}
src/main/java/com/whyc/service/Dev6159PowerYcService.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.Dev6159PowerYcMapper;
import com.whyc.pojo.Dev6159PowerYc;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class Dev6159PowerYcService {
    @Autowired(required = false)
    private Dev6159PowerYcMapper mapper;
    //通信电源核容一体机遥测实时状态
    public Response serchByCondition(int devId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        wrapper.last("limit 1");
        Dev6159PowerYc yc=mapper.selectOne(wrapper);
        return new Response().setII(1, yc == null ? false : true, yc, "");
    }
}
src/main/java/com/whyc/service/Dev6159PowerYxService.java
New file
@@ -0,0 +1,26 @@
package com.whyc.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.whyc.dto.Response;
import com.whyc.mapper.Dev6159PowerYxMapper;
import com.whyc.pojo.Dev6159PowerYc;
import com.whyc.pojo.Dev6159PowerYx;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class Dev6159PowerYxService {
    @Autowired(required = false)
    private Dev6159PowerYxMapper mapper;
    //通信电源核容一体机遥信实时状态
    public Response serchByCondition(int devId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        wrapper.last("limit 1");
        Dev6159PowerYx yx=mapper.selectOne(wrapper);
        return new Response().setII(1, yx == null ? false : true, yx, "");
    }
}
src/main/java/com/whyc/webSocket/RealTimeWebsocket.java
@@ -83,6 +83,10 @@
    private static Fbs9100sStemnodeStateService  fbs9100sStemnodeStateService;
    private static Dev6159PowerYxService dev6159PowerYxService;
    private static Dev6159PowerYcService  dev6159PowerYcService;
    private Session session;
    private HttpSession httpSession;
@@ -130,10 +134,6 @@
    @Autowired
    public void setService(Fbs9100SetparamService f9100setservice) {
        RealTimeWebsocket.f9100setservice = f9100setservice;
    }
    @Autowired
    public void setService(Ess3100SysstateService ess3100Sysservice) {
        RealTimeWebsocket.ess3100Sysservice = ess3100Sysservice;
    }
    @Autowired
    public void setService(Ess3100PcsStateService ess3100Pcsservice) {
@@ -209,6 +209,15 @@
        RealTimeWebsocket.fbs9100sStemnodeStateService = fbs9100sStemnodeStateService;
    }
    @Autowired
    public void setService(Dev6159PowerYxService dev6159PowerYxService) {
        RealTimeWebsocket.dev6159PowerYxService = dev6159PowerYxService;
    }
    @Autowired
    public void setService(Dev6159PowerYcService dev6159PowerYcService) {
        RealTimeWebsocket.dev6159PowerYcService = dev6159PowerYcService;
    }
    @OnOpen
    public void onOpen(Session session, EndpointConfig config) {
        this.session = session;
@@ -279,6 +288,9 @@
                                break;
                            case "inverter5100":
                                res = getInverter5100(realTimePar);
                                break;
                            case "powerHr6159":
                                res = getPowerHr6159(realTimePar);
                                break;
                        }
                        //实时显示调整,增加电池数量,标称单体电压,铅酸还是锂电,放置于返回结果的data2
@@ -424,6 +436,27 @@
        return new Response().set(1, res);
    }
    //电源与蓄电池核容一体机6159
    public Response getPowerHr6159(RealTimePar realTimePar) {
        Map<String, Response> res = new HashMap<>();
        //查询fbs9100信息
        Response f9100stateRes = f9100service.serchContactorState(realTimePar.getDevId());
        res.put("f9100state", f9100stateRes);
        //查询电池组端信息
        Response rtstateRes = rtstateservice.serchByCondition(realTimePar.getBattGroupId());
        res.put("rtstate", rtstateRes);
        //查询电池组单体信息
        Response rtdataRes = rtdataservice.serchByCondition(realTimePar.getBattGroupId());
        res.put("rtdata", rtdataRes);
        //通信电源核容一体机遥测实时状态
        Response ycRes = dev6159PowerYcService.serchByCondition(realTimePar.getDevId());
        res.put("ycdata", ycRes);
        //通信电源核容一体机遥信实时状态
        Response yxRes = dev6159PowerYxService.serchByCondition(realTimePar.getDevId());
        res.put("yxdata", yxRes);
        return new Response().set(1, res);
    }
    //并联电源的实时页面信息
    public Response getParalle(RealTimePar realTimePar, String lang) {
        Map<String, Response> res = new HashMap<>();