1、通信中间件中，取水口日取水量统计重新实现，统计数据来源只采用关阀报，不再采用工作报和开阀报了； 2、临时任务中，增加统计取水口是取水量统计。

liurunyu

2025-01-11 f7c748120263ee6fbed1b137cbd7dad64e249c02

 pipIrr-platform/pipIrr-web/pipIrr-web-temp/src/main/java/com/dy/pipIrrTemp/changeSome/ChSomeCtrl.java

@@ -22,11 +22,27 @@

    private ChSomeIntakeAmountSv intakeAmountSv;

    private ChSomeIntakeLossSv intakeLossSv;

    @Autowired
    private void setSv(ChSomeIntakeAmountSv sv) {
        this.intakeAmountSv = sv;
    }

    @Autowired
    private void setSv(ChSomeIntakeLossSv sv) {
        this.intakeLossSv = sv;
    }





    ///////////////////////////////////////////
    //
    // 取水口相关取水量
    //
    ///////////////////////////////////////////
    /**
     * 修改一些取水口取水量日统计
     * @return
@@ -35,6 +51,18 @@
    @SsoAop()
    public BaseResponse<Boolean> changeSomeIntakeDayAmount() throws Exception{
        this.intakeAmountSv.chIntakeAmountDay();
        return BaseResponseUtils.buildSuccess(true);
    }

    /**
     * 重新统计取水口月取水量
     * @return
     */
    @GetMapping(path = "reStatisticsAllIntakeDayAmount")
    @SsoAop()
    public BaseResponse<Boolean> reStatisticsAllIntakeDayAmount() throws Exception{
        this.intakeAmountSv.deleteAllIntakeAmountDay();
        this.intakeAmountSv.statisticsIntakeAmountDay();
        return BaseResponseUtils.buildSuccess(true);
    }

@@ -62,4 +90,48 @@
        this.intakeAmountSv.statisticsIntakeAmountYear();
        return BaseResponseUtils.buildSuccess(true);
    }




    ///////////////////////////////////////////
    //
    // 取水口相关漏损
    //
    ///////////////////////////////////////////
    /**
     * 修改一些取水口漏损量日统计
     * @return
     */
    @GetMapping(path = "changeSomeIntakeDayLoss")
    @SsoAop()
    public BaseResponse<Boolean> changeSomeIntakeDayLoss() throws Exception{
        this.intakeLossSv.chIntakeLossDay();
        return BaseResponseUtils.buildSuccess(true);
    }


    /**
     * 重新统计取水口月漏损量
     * @return
     */
    @GetMapping(path = "reStatisticsAllIntakeMonthLoss")
    @SsoAop()
    public BaseResponse<Boolean> reStatisticsAllIntakeMonthLoss() throws Exception{
        this.intakeLossSv.deleteAllIntakeLossMonth();
        this.intakeLossSv.statisticsIntakeLossMonth();
        return BaseResponseUtils.buildSuccess(true);
    }

    /**
     * 重新统计取水口所漏损量
     * @return
     */
    @GetMapping(path = "reStatisticsAllIntakeYearLoss")
    @SsoAop()
    public BaseResponse<Boolean> reStatisticsAllIntakeYearLoss() throws Exception{
        this.intakeLossSv.deleteAllIntakeLossYear();
        this.intakeLossSv.statisticsIntakeLossYear();
        return BaseResponseUtils.buildSuccess(true);
    }
}