在线监测-实时监控-查询历史实时数据

whyclxw

2022-01-10 b78806ed6a30e43c244f1434a8f47a28432b93c9

在线监测-实时监控-查询历史实时数据

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

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

import com.whyc.dto.Response;
import com.whyc.pojo.BattRealdata;
import com.whyc.service.BattRealdataService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Api(tags = "在线监测-实时监控")
@RestController
@RequestMapping("Batt_realdataAction")
public class BattRealdataController {
    @Autowired
    private BattRealdataService service;

    @ApiOperation(value = "查询历史实时数据",notes = "Batt_realdataAction!serchByCondition:参数recrod_time，recrod_time1，battGroupId")
    @PostMapping("")
    public Response serchByCondition(@RequestBody BattRealdata realdata){
        return service.serchByCondition(realdata);
    }
}

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

@@ -17,7 +17,7 @@
    @Autowired
    private BattResDataService service;

    @ApiOperation("历史内阻数据查询")
    @ApiOperation(value = "历史内阻数据查询",notes = "Fbs9100s_nibian_stateAction_action_serchByCondition")
    @GetMapping("getResInfoByBattGroupId")
    public Response getResInfoByBattGroupId(@RequestParam int battGroupId){
        return service.getResInfoByBattGroupId(battGroupId);

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

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

import com.whyc.dto.Response;
import com.whyc.service.Fbs9100sBuscoupleStateService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
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;

@Api(tags = "在线监测-实时监控")
@RestController
@RequestMapping("FBS9100sBuscoupleStateAction")
public class Fbs9100sBuscoupleStateController {
    @Autowired
    private Fbs9100sBuscoupleStateService service;


    @ApiOperation(value = "获取逆变的其他信息",notes = "FBS9100sBuscoupleStateAction_action_searchDataByDevId")
    @GetMapping("serchByDevId")
    public Response serchByDevId(@RequestParam int devId){
        return service.serchByDevId(devId);
    }
}

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

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

import com.whyc.dto.Response;
import com.whyc.service.Fbs9100sNibianStateService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

@Api(tags = "在线监测-实时监控")
@RestController
@RequestMapping("Fbs9100s_nibian_stateAction")
public class Fbs9100sNibianStateController {
    @Autowired
    private Fbs9100sNibianStateService service;

    @ApiOperation(value = "获取设备的逆变信息",notes ="Fbs9100s_nibian_stateAction_action_serchByCondition")
    @GetMapping("serchByCondition")
    public Response serchByCondition(@RequestParam int devId){
        return service.serchByCondition(devId);
    }
}

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

@@ -6,6 +6,7 @@
import com.whyc.util.ActionUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
@@ -17,7 +18,7 @@
@RequestMapping("fbs9600State")
@Api(tags = "FBS9600设备状态")
public class Fbs9600StateController {
    @Resource
    @Autowired
    private Fbs9600StateService service;

    @ApiOperation("FBS9600设备通信状态查询")

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

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

import com.whyc.pojo.BattRealdata;

import java.util.List;

public interface BattRealdataMapper extends CustomMapper<BattRealdata>{
    //查询历史实时数据
    List<BattRealdata> serchByCondition(BattRealdata realdata);
}

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

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

import com.whyc.pojo.Fbs9100sBuscoupleState;

public interface Fbs9100sBuscoupleStateMapper extends CustomMapper<Fbs9100sBuscoupleState>{
}

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

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

import com.whyc.pojo.Fbs9100sNibianState;

public interface Fbs9100sNibianStateMapper extends CustomMapper<Fbs9100sNibianState>{
}

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

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

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 com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2022-01-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="BattRealdata_ID对象", description="")
public class BattRealdata implements Serializable {

    private static final long serialVersionUID = 1L;

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

    @TableField("BattGroupId")
    private Integer BattGroupId;

    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date recrodTime;
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @TableField(exist = false)
    private Date recrodTime1;

    private Float groupVol;

    private Float onlineVol;

    private Float groupCurr;

    private Float groupTmp;

    private Integer battState;

    private Integer battTestType;

    private Date battTestStarttime;

    private Integer battTestTlong;

    private Float battTestCap;

    private Integer monNum;

    private Float monVol;

    private Float monTmp;

    private Float monRes;

    private Float monSer;

    private Float monConnRes;

    private Float monCap;

    @TableField("mon_JH_curr")
    private Float monJhCurr;

    private String note;


}

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

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

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;
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 2022-01-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName(schema = "db_ram_db",value = "tb_fbs9100s_buscouple_state")
@ApiModel(value="Fbs9100sBuscoupleState对象", description="")
public class Fbs9100sBuscoupleState 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 = "防雷状态:0:未连接;1:正常工作;2需要更换防雷设备")
    private Integer fangleiState;

    @ApiModelProperty(value = "工作状态")
    private Integer workstate;

    @ApiModelProperty(value = "空开操作状态")
    private Integer rlayworkmode;

    @ApiModelProperty(value = "开关输入ON状态")
    @TableField("rlyAstate")
    private Integer rlyAstate;

    @ApiModelProperty(value = "开关输入OFF状态")
    @TableField("rlyBstate")
    private Integer rlyBstate;

    @ApiModelProperty(value = "停止原因")
    private Integer stopreson;

    @ApiModelProperty(value = "电压1")
    private Float voltM1;

    @ApiModelProperty(value = "电压2")
    private Float voltM2;

    @ApiModelProperty(value = "电流")
    private Float iout;

    @ApiModelProperty(value = "电流方向")
    private Integer curdir;

    @ApiModelProperty(value = "通信状态")
    private Integer commustate;


}

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

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

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;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

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

/**
 * <p>
 * 
 * </p>
 *
 * @author lxw
 * @since 2022-01-10
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName(schema = "db_ram_db",value = "tb_fbs9100s_nibian_state")
@ApiModel(value="Fbs9100sNibianState对象", description="")
public class Fbs9100sNibianState implements Serializable {

    private static final long serialVersionUID = 1L;

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

    private Long devId;

    private Long nbNum;

    private Date recordTime;

    @TableField("AC_ASimVol")
    private Float acAsimvol;

    @TableField("AC_ASimCur")
    private Float acAsimcur;

    @TableField("AC_BSimVol")
    private Float acBsimvol;

    @TableField("AC_BSimCur")
    private Float acBsimcur;

    @TableField("AC_CSimVol")
    private Float acCsimvol;

    @TableField("AC_CSimCur")
    private Float acCsimcur;

    @TableField("A_HZ")
    private Float aHz;

    @TableField("B_HZ")
    private Float bHz;

    @TableField("C_HZ")
    private Float cHz;

    @TableField("Power_Pa")
    private Float powerPa;

    @TableField("Power_Pb")
    private Float powerPb;

    @TableField("Power_Pc")
    private Float powerPc;

    @TableField("Power_Sa")
    private Float powerSa;

    @TableField("Power_Sb")
    private Float powerSb;

    @TableField("Power_Sc")
    private Float powerSc;

    @TableField("Temp1")
    private Float Temp1;

    @TableField("Temp2")
    private Float Temp2;

    @TableField("RunState")
    private Float RunState;

    @TableField("DcACState")
    private Integer DcACState;

    @TableField("InsulaTionRes1")
    private Integer InsulaTionRes1;

    @TableField("InsulaTionRes2")
    private Integer InsulaTionRes2;

    @TableField("DCInputVol")
    private Float DCInputVol;

    @TableField("DCInputCur")
    private Float DCInputCur;

    @TableField("SetRun_Stop")
    private Integer setrunStop;

    @TableField("SetDischargeCur")
    private Float SetDischargeCur;

    @TableField("CommTxCnt")
    private Integer CommTxCnt;

    @TableField("CommRxCnt")
    private Integer CommRxCnt;


}

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

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

import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.BattRealdataMapper;
import com.whyc.pojo.BattRealdata;
import com.whyc.util.ActionUtil;
import org.springframework.stereotype.Service;

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

@Service
public class BattRealdataService {
    @Resource
    private BattRealdataMapper mapper;
    //查询历史实时数据
    public Response serchByCondition(BattRealdata realdata) {
        realdata.setNote(ActionUtil.sdfwithOutday.format(realdata.getRecrodTime()));//表名时间格式部分
        List<BattRealdata> list=mapper.serchByCondition(realdata);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
}

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

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageHelper;
import com.whyc.dto.Response;
import com.whyc.mapper.Fbs9100sBuscoupleStateMapper;
import com.whyc.pojo.Fbs9100sBuscoupleState;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class Fbs9100sBuscoupleStateService {
    @Resource
    private Fbs9100sBuscoupleStateMapper mapper;

    //获取逆变的其他信息
    public Response serchByDevId(int devId) {
        PageHelper.startPage(1,1);
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        Fbs9100sBuscoupleState sBuscoupleState=mapper.selectOne(wrapper);
        return new Response().set(1,sBuscoupleState);
    }
}

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

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

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.Fbs9100sNibianStateMapper;
import com.whyc.pojo.Fbs9100sNibianState;
import org.springframework.stereotype.Service;

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

@Service
public class Fbs9100sNibianStateService {
    @Resource
    private Fbs9100sNibianStateMapper mapper;

    //获取设备的逆变信息
    public Response serchByCondition(int devId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("dev_id",devId);
        List<Fbs9100sNibianState> list=mapper.selectList(wrapper);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
}

 src/main/java/com/whyc/util/ActionUtil.java

@@ -25,6 +25,7 @@
public class ActionUtil{

    public static String time_yyyyMMddHHmmss = "yyyy-MM-dd HH:mm:ss";
    public static SimpleDateFormat sdfwithOutday=new SimpleDateFormat("yyyy_MM");

    /*
     * 获取HttpServletRequest

 src/main/resources/mapper/BattRealdataMapper.xml

New file
@@ -0,0 +1,11 @@
<?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.BattRealdataMapper">


    <select id="serchByCondition" resultType="com.whyc.pojo.BattRealdata">
        select * from db_batt_history.tb_batt_realdata_${BattGroupId}_${note}
                where  recrod_time>=#{recrodTime} and recrod_time&lt;=#{recrodTime1}
                 order by recrod_time asc
    </select>
</mapper>

 src/main/resources/mapper/Fbs9100sBuscoupleStateMapper.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.Fbs9100sBuscoupleStateMapper">


</mapper>

 src/main/resources/mapper/Fbs9100sNibianStateMapper.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.Fbs9100sNibianStateMapper">


</mapper>