国网电源获取当前天负载电流的平均值

whyclxw

2024-11-05 e6cd256f189c1cd43fec2c45b2c35b16861e22f8

国网电源获取当前天负载电流的平均值

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

@@ -6,10 +6,7 @@
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;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.text.ParseException;
@@ -28,4 +25,10 @@
        return service.getListByParam(param);
    }

    @GetMapping("getAvgLoadCurr")
    @ApiOperation("获取当前天平均负载电流")
    public Response getAvgLoadCurr(@RequestParam Integer powerId) {
        return service.getAvgLoadCurr(powerId);
    }

}

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

@@ -148,6 +148,10 @@
    @TableField("useracin2_currc")
    private Float            useracin2_currc;

    @TableField("load_curr")
    private Float            load_curr;


    @TableField(exist = false)
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date startTime;
@@ -722,4 +726,12 @@
    public void setUseracin2_currc(Float useracin2_currc) {
        this.useracin2_currc = useracin2_currc;
    }

    public Float getLoad_curr() {
        return load_curr;
    }

    public void setLoad_curr(Float load_curr) {
        this.load_curr = load_curr;
    }
}

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

@@ -53,4 +53,11 @@
        }
        return new Response().set(1,list);
    }
    //获取当前天平均负载电流
    public Response getAvgLoadCurr(Integer powerId) {
        String tableName="db_pwrdev_data_history_gw"+"."+"tb_pwrdev_historydata_gw_"+powerId;
        tableName=tableName+"_"+ActionUtil.sdfwithOutday.format(new Date());
        Float avgCurr=subService.getAvgLoadCurr(powerId,tableName);
        return new Response().setII(1,true,avgCurr,"");
    }
}

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

@@ -4208,5 +4208,27 @@
        }
        sqlExecuteService.makeManualCommit(sql_str);
    }

    //获取当前天平均负载电流
    public Float getAvgLoadCurr(Integer powerId, String tableName) {
        String sql="  select avg(load_curr) as avgCurr from "+tableName +" where DATE(record_time) = CURDATE() ";
        List<Float> list = sqlExecuteService.executeQuery_call(sql, new CallBack() {
            @Override
            public List getResults(ResultSet rs) throws SQLException {
                List list=new ArrayList<>();
                try {
                    while (rs.next()){
                        list.add(rs.getFloat("avgCurr"));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                return list;
            }
        });
        float avgCurr=0f;
        if (list!=null){
            avgCurr=list.get(0);
        }
        return avgCurr;
    }
}