liurunyu
7 天以前 4f99f59668c9160ca60958b7347944def26f2228
pipIrr-platform/pipIrr-web/pipIrr-web-project/src/main/java/com/dy/pipIrrProject/flowMonitoring/MoniFlowSv.java
New file
@@ -0,0 +1,53 @@
package com.dy.pipIrrProject.flowMonitoring;
import com.dy.pipIrrGlobal.daoPr.PrMonitoringFlowmeterMapper;
import com.dy.pipIrrGlobal.pojoPr.PrMonitoringFlowmeter;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
/**
 * @author ZhuBaoMin
 * @date 2024-01-05 10:25
 * @LastEditTime 2024-01-05 10:25
 * @Description 管网流量监测站、流量计关联管理服务类
 */
@Slf4j
@Service
public class MoniFlowSv {
    @Autowired
    private PrMonitoringFlowmeterMapper prMonitoringFlowmeterMapper;
    /**
     * 添加流量监测站、流量计关联关系
     * @param po
     * @return
     */
    public Integer addRecord(PrMonitoringFlowmeter po) {
        return prMonitoringFlowmeterMapper.insert(po);
    }
    /**
     * 根据流量监测站、流量计、操作类型获取记录数量
     * @param monitoringId 监测站编号
     * @param flowmeterId 流量计编号
     * @param operateType 操作类型 1-捆绑,2-解绑
     * @return
     */
    Integer getBindRecordCount(Long monitoringId, Long flowmeterId, Byte operateType) {
        return prMonitoringFlowmeterMapper.getBindRecordCount(monitoringId, flowmeterId, operateType);
    }
    /**
     * 根据 流量监测站编号 获取 绑定记录 按操作时间降序
     * @param monitoringId
     * @return  PrMonitoringFlowmeter
     * */
    public List<Map<String, Object>> getBingRecordsByMonitoringId(String monitoringId){
        return prMonitoringFlowmeterMapper.getBingRecordsByMonitoringId(monitoringId);
    }
}