新增第三方接口，以及更新

whyczh

2022-06-15 55442e87c1122e7a9e3fa88c704102660a767c64

新增第三方接口，以及更新

 src/main/java/com/whyc/controller/BattalarmDataController.java

@@ -25,9 +25,9 @@
    @Autowired
    private BattalarmDataService service;

    /*@GetMapping("/getAll")
    @ApiOperation(value = "查询所有的实时告警")*/
    public Response<List<BattalarmData>> getAll(){
    @GetMapping("/getAll")
    @ApiOperation(value = "查询所有的实时告警")
    public Response getAll(){
        return service.getAll();
    }


 src/main/java/com/whyc/controller/InterFaceController.java

New file
@@ -0,0 +1,44 @@
package com.whyc.controller;

import com.whyc.dto.Response;
import com.whyc.service.InterfaceService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@RequestMapping("interface")
@RestController
@Api(tags = "第三方接口")
public class InterFaceController {
    @Resource
    private InterfaceService service;
    @GetMapping("/getBattInf")
    @ApiOperation("获取所有电池信息")
    public Response getBattinf(@RequestParam int pageNum,@RequestParam int pageSize){
        return service.getBattinf(pageNum,pageSize);
    }

    @GetMapping("/getPowerInf")
    @ApiOperation("获取所有电源信息")
    public Response getPowerInf(@RequestParam int pageNum,@RequestParam int pageSize){
        return service.getPowerInf(pageNum,pageSize);
    }

    @GetMapping("/getBattAlarm")
    @ApiOperation("获取电池告警数据")
    public Response getBattAlarm(@RequestParam int pageNum,@RequestParam int pageSize){
        return service.getBattAlarm(pageNum,pageSize);
    }

    @GetMapping("/getPowerAlarm")
    @ApiOperation("获取电源告警数据")
    public Response getPowerAlarm(@RequestParam int pageNum,@RequestParam int pageSize){
        return service.getPwrdevAlarm(pageNum,pageSize);
    }

}

 src/main/java/com/whyc/dto/BattInfDTO.java

New file
@@ -0,0 +1,242 @@
package com.whyc.dto;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModelProperty;

import java.util.Date;

public class BattInfDTO {
    @TableId(value = "num", type = IdType.AUTO)
    private Integer num;

    @TableField("StationId")
    private String stationId;

    @TableField("StationId_ex")
    private String stationidEx;

    @TableField("stationName")
    private String stationName;

    @TableField("stationName1")
    private String stationName1;

    @TableField("stationName2")
    private String stationName2;

    @TableField("stationName3")
    private String stationName3;

    @TableField("stationName4")
    private String stationName4;

    @TableField("stationName5")
    private String stationName5;

    @TableField("StationIP")
    private String stationIP;

    @TableField("FBSDeviceId")
    private Long fBSDeviceId;

    @TableField("FBSDeviceIp")
    private String fBSDeviceIp;

    @TableField("FBSDeviceIp_WG")
    private String fbsdeviceipWg;

    @TableField("FBSDeviceIp_YM")
    private String fbsdeviceipYm;

    @TableField("FBSDeviceName")
    private String fBSDeviceName;

    @TableField("GroupIndexInFBSDevice")
    private Integer groupIndexInFBSDevice;

    @TableField("battModel")
    private String battModel;

    @TableField(" battGroupId")
    private Integer  battGroupId;

    @TableField(" battGroupNum")
    private Integer  battGroupNum;

    @TableField(" battGroupName")
    private String  battGroupName;

    @TableField(" battGroupName1")
    private String  battGroupName1;

    @TableField(" battGroupName2")
    private String  battGroupName2;

    @TableField(" battGroupName3")
    private String  battGroupName3;

    @TableField(" battGroupName4")
    private String  battGroupName4;

    @TableField(" battGroupName5")
    private String  battGroupName5;

    @TableField(" battGroupName6")
    private String  battGroupName6;

    @TableField("FloatVolLevel")
    private Float floatVolLevel;

    @TableField("OfflineVolLevel")
    private Float offlineVolLevel;

    @TableField("battFloatCurrent")
    private Float battFloatCurrent;

    @TableField("DeviceId")
    private String deviceId;

    @TableField("DeviceName")
    private String deviceName;

    @TableField("monCount")
    private Integer monCount;

    @TableField("monCapStd")
    private Float monCapStd;

    @TableField("monVolStd")
    private Float monVolStd;

    @TableField("monResStd")
    private Float monResStd;

    @TableField("monSerStd")
    private Float monSerStd;

    @TableField("monTmpStd")
    private Float monTmpStd;

    @TableField("monVolLowToAvg")
    private Float monVolLowToAvg;

    @TableField("monNum")
    private Integer monNum;

    @TableField("battProducer")
    private String battProducer;

    @TableField("battProductDate")
    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
    private Date battProductDate;
    @TableField(value = "battProductDate1",exist = false)
    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
    private Date battProductDate1;

    @TableField("battInUseDate")
    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
    private Date battInUseDate;

    @TableField("battGuarantDayCount")
    private Integer battGuarantDayCount;

    @TableField("SignalId")
    private String signalId;

    @TableField("CInterFaceId")
    private Integer cInterFaceId;

    @TableField("SignalName")
    private String signalName;

    @TableField("Load_curr")
    private Float loadCurr;

    @TableField("DisCurrMax")
    private Float disCurrMax;

    private String stationPhone;

    private int stationInstall;

    private String installUser;

    private Float chargeCurrMax;

    @TableField("Vol_grade")
    private Float volGrade;

    @TableField("Manufacturers")
    private String manufacturers;

    @TableField("Assetequipment")
    private String assetequipment;

    @TableField("Deviceclasspath")
    private String deviceclasspath;

    @TableField("DeviceOperationDepartment")
    private String deviceOperationDepartment;

    @TableField("PropertyRightUnit")
    private String propertyRightUnit;

    @TableField("PropertyAttribute")
    private String propertyAttribute;

    @TableField("FactoryNumber")
    private String factoryNumber;

    @TableField("OperationTeam")
    private String operationTeam;

    @TableField("DeviceIdentityCode")
    private String deviceIdentityCode;

    @TableField("ProjectType")
    private String projectType;

    @TableField("batteryApplicationType")
    private String batteryApplicationType;

    @TableField("SingleRatedVoltage")
    private Float singleRatedVoltage;

    @TableField("Remotemonitor")
    private String remotemonitor;

    @TableField("batttIndependentPlaced")
    private String batttIndependentPlaced;

    @TableField("JunChargeVoltageValue")
    private Float junChargeVoltageValue;

    @TableField("PublicKeyX")
    private String publicKeyX;

    @TableField("PublicKeyY")
    private String publicKeyY;

    @TableField("KeyID")
    private String keyID;

    @TableField("SerialNumber")
    private String serialNumber;

    private Integer sortId;

    private String videoUrl;

    @ApiModelProperty(value = "充放电状态：1:限流充电；2；逆变充电")
    private Integer chargeType;

    @ApiModelProperty(value = "母联状态：0：无母联；1:有母联")
    private Integer buscoupleState;

    private Integer tmpId;


}

 src/main/java/com/whyc/filter/AccessFilter.java

@@ -67,6 +67,10 @@
                        || requestURI.contains("battMapInformation/del")
                        || requestURI.contains("station3D/byDeviceId")
                        || requestURI.contains("battMapInformation/multAmout")
                        || requestURI.contains("interface/getBattInf")
                        || requestURI.contains("interface/getBattAlarm")
                        || requestURI.contains("interface/getPowerInf")
                        || requestURI.contains("interface/getPowerAlarm")
                        || requestURI.contains("."))) {
                    response.setStatus(403);
                    response.getWriter().write("非法请求,参数异常");

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

@@ -1,9 +1,9 @@
package com.whyc.mapper;

import com.whyc.dto.BattInfAndEnduranceDTO;
import com.whyc.dto.BattInfDTO;
import com.whyc.dto.ReportBattDTO;
import com.whyc.pojo.Battinf;
import com.whyc.pojo.BatttestdataInf;
import org.apache.ibatis.annotations.Param;

import java.util.List;
@@ -77,4 +77,8 @@
    Battinf serchExcelName(int battGroupId);

    List<Battinf> getA059StationOfBattinf(@Param("stationName1")String stationName1,@Param("stationName2")String stationName2,@Param("stationName5")String stationName5,@Param("stationName3")String stationName3);

    //第三方接口提供
    List<BattInfDTO> getBattInf();

}

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

@@ -47,4 +47,7 @@
    List<BattalarmData> getRealAlarm(Date yesterday,int uId,int[] alarmParams);

    List<BattMapInformation> findAllStation(@Param("alarmParams") int[] alarmParams);


    List<AlarmRes> getBattAlarm();
}

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

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

import com.whyc.pojo.PowerInf;
import com.whyc.service.PowerInfService;
import org.apache.ibatis.annotations.Param;

import java.util.List;

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

@@ -5,6 +5,8 @@
import java.util.List;

public interface PwrdevAlarmMapper extends CustomMapper<PwrdevAlarm>{
    //电源实时告警第三方接口
    List getPwrdevAlarm();
    //电源实时告警
    List getAllPage(PwrdevAlarm pwrdevAlarm);
    //电源告警个数

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

@@ -90,7 +90,7 @@
    @ApiModelProperty(value = "用户id")
    @TableField("usr_Id")
    private Integer usrId;

    @TableField(exist = false)
    private int msgSended;

    private Integer workFlag;

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

@@ -38,12 +38,12 @@


    //查询所有的告警
    public Response<List<BattalarmData>> getAll() {
    public Response getAll() {
        QueryWrapper<BattalarmData> wrapper = new QueryWrapper<>();
        // 通过id进行排序
        wrapper.orderByAsc("BattGroupId");
        List<BattalarmData> list=mapper.selectList(wrapper);
        return new Response<List<BattalarmData>>().set(1,list);
        return new Response().set(1,list);
    }
    //分页查询所有的实时告警
    public Response<List<BattalarmData>> getAllByPage(com.whyc.dto.Page p) {

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

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

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.AlarmDaoFactory;
import com.whyc.dto.Response;
import com.whyc.dto.result.AlarmRes;
import com.whyc.mapper.BattInfMapper;
import com.whyc.mapper.BattalarmDataMapper;
import com.whyc.mapper.PowerInfMapper;
import com.whyc.mapper.PwrdevAlarmMapper;
import com.whyc.pojo.BattalarmData;
import com.whyc.pojo.PwrdevAlarm;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

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

@Slf4j
@Service
public class InterfaceService {
    @Resource
    private BattInfMapper battInfMapper;
    @Resource
    private PowerInfMapper powerInfMapper;
    @Resource
    private BattalarmDataMapper battalarmDataMapper;
    @Resource
    private PwrdevAlarmMapper pwrdevAlarmMapper;

    public Response getBattinf(int pageNum,int pageSize){
        //分页信息
        PageHelper.startPage(pageNum,pageSize);
        List list = battInfMapper.getBattInf();
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }

    public Response getPowerInf(int pageNum,int pageSize){
        //分页信息
        PageHelper.startPage(pageNum,pageSize);
        List list = powerInfMapper.selectList(null);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }

    public Response getBattAlarm(int pageNum,int pageSize){
        //分页信息
        PageHelper.startPage(pageNum,pageSize);
        List<AlarmRes> list = battalarmDataMapper.getBattAlarm();
        for (AlarmRes a:list) {
            List<BattalarmData> l=a.getAdatas();
            for (BattalarmData adata:l) {
                adata.setAlmSignalIdName(AlarmDaoFactory.getAlarmName(adata.getAlmSignalId()));
                adata.setAlmLevelName(AlarmDaoFactory.getAlarmType(adata.getAlmLevel()));
            }
        }
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
    //电源实时告警查询--第三方接口
    public Response getPwrdevAlarm(int pageNum,int pageSize){
        //分页信息
        PageHelper.startPage(pageNum,pageSize);
        List<PwrdevAlarm> list=pwrdevAlarmMapper.getPwrdevAlarm();
        for (PwrdevAlarm p:list) {
            p.setAlarmName(AlarmDaoFactory.getAllAlarmName(p.getAlmType()));
            if(p.getAlmIndex()!=0){
                p.setAlarmName(p.getAlarmName().replace("N","第"+p.getAlmIndex()+"路"));
            }
        }
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }

}

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

@@ -64,7 +64,14 @@
    }

    @OnClose
    public void onOpen(Session session){
    public void onClose(CloseReason closeReason){
        System.err.println("closeReason = " + closeReason);
        thread.isInterrupted();
    }

    @OnError
    public void onError(Throwable error){
        error.printStackTrace();
        thread.isInterrupted();
    }


 src/main/resources/mapper/BattInfMapper.xml

@@ -463,5 +463,13 @@
    <select id="getA059StationOfBattinf" resultType="com.whyc.pojo.Battinf">
        SELECT * FROM db_battinf.tb_battinf where stationName1=#{stationName1} and StationName2=#{stationName2} and StationName5=#{stationName5} and StationName3=#{stationName3}
    </select>
    <select id="getBattInf" resultType="com.whyc.dto.BattInfDTO">
        select stationId,stationName1,stationName2,stationName5,stationName3,stationName4,
        fbsDeviceId,fbsDeviceIp,fbsDeviceIp_YM,fbsDeviceIp_WG,FBSDeviceName,battGroupId,battGroupName,
        FloatVolLevel,OfflineVolLevel,BattFloatCurrent,MonCount,MonCapStd,MonVolStd,MonResStd,MonSerStd,
        MonVolLowToAvg,Load_curr,DisCurrMax,BattProducer,BattModel,BattProductDate,BattInUseDate,video_url
        from db_battinf.tb_battinf

    </select>

</mapper>

 src/main/resources/mapper/BattalarmDataMapper.xml

@@ -226,5 +226,16 @@
            #{alarm}
        </foreach>
    </select>

    <select id="getBattAlarm" resultMap="alarmRes">
        select  distinct(db_alarm.tb_battalarm_data.BattGroupId),db_alarm.tb_battalarm_data.num,alm_signal_id,db_alarm.tb_battalarm_data.monnum,alm_value,alm_level,alm_is_confirmed,alm_confirmed_time,alm_start_time,alm_end_time,stationname,battgroupname
        from db_alarm.tb_battalarm_data,db_battinf.tb_battinf
        <where>
            db_alarm.tb_battalarm_data.battgroupid=db_battinf.tb_battinf.battgroupid
            and alm_id in(119001,119002,119012,119003,119004,119005,119007,119006)
            and alm_signal_id%2 in(1,0)
            and alm_level in(1,2,3,4)
            and alm_cleared_type=0
        </where>
        order by db_alarm.tb_battalarm_data.alm_start_time desc,db_alarm.tb_battalarm_data.monnum asc
    </select>
</mapper>

 src/main/resources/mapper/PwrdevAlarmMapper.xml

@@ -1,8 +1,12 @@
<?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.PwrdevAlarmMapper" >

    <select id="getAllPage" resultType="PwrdevAlarm">
    <!--第三方接口获取所有实时告警数据-->
    <select id="getPwrdevAlarm">
        select  alarm.*,inf.StationName from db_pwrdev_alarm.tb_pwrdev_alarm alarm,db_pwrdev_inf.tb_pwrdev_inf inf
        where alarm.PowerDeviceId = inf.PowerDeviceId
    </select>
    <select id="getAllPage" resultType="com.whyc.pojo.PwrdevAlarm">
        select  alarm.*,inf.StationName from db_pwrdev_alarm.tb_pwrdev_alarm alarm,db_pwrdev_inf.tb_pwrdev_inf inf
        <where>
            alarm.PowerDeviceId = inf.PowerDeviceId
@@ -60,7 +64,7 @@
        and db_user.tb_user_inf.uid=#{uid} ) ;
    </select>

    <select id="getAllPage2" resultType="PwrdevAlarm">
    <select id="getAllPage2" resultType="com.whyc.pojo.PwrdevAlarm">
        select  alarm.*,inf.StationName from db_pwrdev_alarm.tb_pwrdev_alarm alarm,db_pwrdev_inf.tb_pwrdev_inf inf
        <where>
            alarm.PowerDeviceId = inf.PowerDeviceId