remote模块远程开关阀逻辑修改

liurunyu

2025-06-27 3878bfa207d6dd0a8a84177a437ec3b3a9a6825d

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/allRound/Ar4StatisticsSv.java

New file
@@ -0,0 +1,84 @@
package com.dy.pipIrrStatistics.allRound;

import com.dy.common.mw.protocol.p206V1.CommonV1;
import com.dy.pipIrrGlobal.voAllRound.*;
import com.dy.pipIrrGlobal.daoAllRound.Ar4StatisticsMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @Author: liurunyu
 * @Date: 2025/2/5 10:46
 * @Description
 */
@Slf4j
@Service
public class Ar4StatisticsSv {

    @Autowired
    private Ar4StatisticsMapper statisticsDao;

    //记录条数
    private static final int totalRecordsCount = 10 ;

    /**
     * 得到取水口开关阀记录（totalRecordsCount条）
     * @param intakeId
     */
    public List<VoArIntakeOpenCloseValve> openCloseValveRecords(Long intakeId){
        List<VoArIntakeOpenCloseValve> list = statisticsDao.openCloseRecords(intakeId, 0, totalRecordsCount);
        if(list != null && list.size() > 0){
            for (VoArIntakeOpenCloseValve vo : list) {
                if(vo != null){
                    if(vo.opType != null){
                        vo.openType = CommonV1.openCloseValveType(vo.opType);
                    }
                    if(vo.clType != null){
                        vo.closeType = CommonV1.openCloseValveType(vo.clType);
                    }
                }
            }
        }
        return list;
    }


    /**
     * 得到取水口日漏损记录（totalRecordsCount条）
     * @param intakeId
     */
    public List<VoArIntakeLossDay> lossDayRecords(Long intakeId){
        return statisticsDao.lossDayRecords(intakeId, 0, totalRecordsCount);
    }


    /**
     * 得到取水口月漏损记录（totalRecordsCount条）
     * @param intakeId
     */
    public List<VoArIntakeLossMonth> lossMonthRecords(Long intakeId){
        return statisticsDao.lossMonthRecords(intakeId, 0, totalRecordsCount);
    }


    /**
     * 得到取水口日用水记录（totalRecordsCount条）
     * @param intakeId
     */
    public List<VoArIntakeAmountDay> amountDayRecords(Long intakeId){
        return statisticsDao.amountDayRecords(intakeId, 0, totalRecordsCount);
    }


    /**
     * 得到取水口月用水记录（totalRecordsCount条）
     * @param intakeId
     */
    public List<VoArIntakeAmountMonth> amountMonthRecords(Long intakeId){
        return statisticsDao.amountMonthRecords(intakeId, 0, totalRecordsCount);
    }

}