获取设备某次记录详细的单体放电过程

whyclxw

2024-09-09 264536ddf21ec750a6c9914daba8c17969b6c592

获取设备某次记录详细的单体放电过程

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

@@ -38,4 +38,10 @@
    public Response getTinfById(@RequestParam Integer devId){
        return service.getTinfById(devId);
    }

    @ApiOperation(value = "获取设备某次记录详细的单体放电过程")
    @GetMapping("getTdataById")
    public Response getTdataById(@RequestParam Integer devId,@RequestParam Integer testRecordCount,@RequestParam Integer record_num){
        return service.getTinfById(devId,testRecordCount,record_num);
    }
}

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

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

import com.whyc.pojo.db_batt_testdata.BatttestdataId;

public interface BatttestdataIdMapper extends CustomMapper<BatttestdataId>{
}

 src/main/java/com/whyc/pojo/db_batt_testdata/BatttestdataId.java

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

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
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-09-09
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="BatttestdataId对象", description="设备电池历史数据记录表")
public class BatttestdataId implements Serializable {

    private static final long serialVersionUID = 1L;

    @ApiModelProperty(value = "自增主键")
    @TableId(value = "num", type = IdType.AUTO)
    private int num;

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

    @ApiModelProperty(value = "电池组编号[0-组1 1-组2 ... 4-组4]")
    private Integer battIdx;

    @ApiModelProperty(value = "测试次数")
    private Integer testRecordCount;

    @ApiModelProperty(value = "测试类型")
    private Integer testType;

    @ApiModelProperty(value = "测试笔数")
    private Integer recordNum;

    @ApiModelProperty(value = "测试开始时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
    private Date testStarttime;

    @ApiModelProperty(value = "记录时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
    private Date recordTime;

    @ApiModelProperty(value = "测试时长(秒)")
    private int testTimelong;

    @ApiModelProperty(value = "组端电压")
    private Double groupVol;

    @ApiModelProperty(value = "测试电流")
    private Double testCurr;

    @ApiModelProperty(value = "测试容量")
    private Double testCap;

    @ApiModelProperty(value = "单体编号")
    private Integer monNum;

    @ApiModelProperty(value = "单体电压")
    private Double monVol;

    @ApiModelProperty(value = "单体温度")
    private Double monTmp;

    @ApiModelProperty(value = "单体电流")
    private Double monCurr;

    @ApiModelProperty(value = "单体容量")
    private Double monCap;

    @ApiModelProperty(value = "单体能量")
    private Double monWh;

    @ApiModelProperty(value = "单体状态")
    private Integer monState;

    @ApiModelProperty(value = "故障信息")
    private Integer monFault;


}

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

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

import org.springframework.stereotype.Service;

@Service
public class BatttestdataIdService {
}

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

@@ -1,11 +1,10 @@
package com.whyc.service;

import com.whyc.dto.Response;
import com.whyc.mapper.BatttestdataIdMapper;
import com.whyc.mapper.BatttestdataInfMapper;
import com.whyc.pojo.db_batt_testdata.BatttestdataId;
import com.whyc.pojo.db_batt_testdata.BatttestdataInf;
import com.whyc.pojo.db_lithium_ram_db.DevInf;
import com.whyc.pojo.db_user.UserInf;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -18,6 +17,12 @@

    @Autowired(required = false)
    private BatttestdataInfMapper mapper;

    @Autowired(required = false)
    private BatttestdataIdMapper dataMapper;

    @Autowired(required = false)
    private SubTablePageInfoService subService;

    //充放电一体机测试统计
    public Map<String, Object> getDevTinfByYearMonth(int userId) {
@@ -146,4 +151,9 @@
        map.put("chr",listChr);
        return new Response().setII(1,true,map,"获取设备的充放电记录");
    }
    //获取设备某次记录详细的单体放电过程
    public Response getTinfById(Integer devId, Integer testRecordCount, Integer record_num) {
        List<BatttestdataId> list=subService.getTinfById(devId,testRecordCount,record_num);
        return new Response().setII(1,list!=null,list,"获取设备某次记录详细的单体放电过程");
    }
}

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

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

import com.whyc.mapper.CallBack;
import com.whyc.pojo.db_batt_testdata.BatttestdataId;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -14,6 +15,47 @@
public class SubTablePageInfoService {
    @Autowired
    private MybatisSqlExecuteService sqlExecuteService;
    //获取设备某次记录详细的单体放电过程
    public List<BatttestdataId> getTinfById(Integer devId, Integer testRecordCount, Integer record_num) {
        String sql="select  * from db_batt_testdata.tb_batttestdata_" +devId
                +" where test_record_count="+testRecordCount+" and record_num="+record_num;
        sql+="  ORDER BY test_starttime asc ";
        System.out.println(sql);
        List list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List<BatttestdataId> list=new ArrayList<>();
                while (rs.next()){
                    BatttestdataId tdata=new BatttestdataId();
                    tdata.setNum(rs.getInt("num"));
                    tdata.setDevId(rs.getInt("dev_id"));
                    tdata.setBattIdx(rs.getInt("batt_idx"));
                    tdata.setTestRecordCount(rs.getInt("test_record_count"));
                    tdata.setTestType(rs.getInt("test_type"));
                    tdata.setRecordNum(rs.getInt("record_num"));
                    tdata.setTestStarttime(rs.getTimestamp("test_starttime"));
                    tdata.setRecordTime(rs.getTimestamp("record_time"));
                    tdata.setTestTimelong(rs.getInt("test_timelong"));
                    tdata.setGroupVol(rs.getDouble("group_vol"));
                    tdata.setTestCurr(rs.getDouble("test_curr"));
                    tdata.setTestCap(rs.getDouble("test_cap"));
                    tdata.setMonNum(rs.getInt("mon_num"));
                    tdata.setMonVol(rs.getDouble("mon_vol"));
                    tdata.setMonTmp(rs.getDouble("mon_tmp"));
                    tdata.setMonCurr(rs.getDouble("mon_curr"));
                    tdata.setMonCap(rs.getDouble("mon_cap"));
                    tdata.setMonWh(rs.getDouble("mon_wh"));
                    tdata.setMonState(rs.getInt("mon_state"));
                    tdata.setMonFault(rs.getInt("mon_fault"));
                    list.add(tdata);
                }
                return list;
            }
        });
        return list;
    }


    /*//查询DevAlm历史告警数量
    public int getCountForDevAlm(DevAlarmHisDto alm) {
        String sql="select  count(distinct num) as number from db_ckpwrdev_alarm." +alm.getRecordYear()

 src/main/resources/mapper/BatttestdataIdMapper.xml

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

</mapper>