PipeInterfaceServiceImpl.java 5.26 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197
package com.zehong.system.service.impl;
import com.zehong.system.domain.*;
import com.zehong.system.mapper.PipeInterfaceMapper;
import com.zehong.system.service.IPipeInterfaceService;
import org.apache.ibatis.annotations.Param;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;

/**
 * 管道信息数据实现层
 */
@Service
public class PipeInterfaceServiceImpl implements IPipeInterfaceService {

    @Autowired
    PipeInterfaceMapper pipeInterfaceMapper;

    /**
     * 查询管道数据列表
     * @return
     */
    @Override
    public List<PipeDate> selectPipeData(String enterId) {
        List<PipeDate> pipeDates = pipeInterfaceMapper.selectPipeData(enterId);
        return pipeDates;
    }

    /**
     * 获取分组数据
     * @return
     */
    @Override
    public List<PipeDate> selectGroupPipeData() {
        List<PipeDate> pipeDates = pipeInterfaceMapper.selectGroupPipeData();
        return pipeDates;
    }

    /**
     * 调压箱数据查询方法
     * @return
     */
    @Override
    public List<DeviceData> selectDeviceData(String enterId) {
        List<DeviceData> deviceData = pipeInterfaceMapper.selectDeviceData(enterId);
        return deviceData;
    }

    /**
     * 查询下级设备数据
     * @param deviceId
     * @return
     */
    @Override
    public List<PressureFlow> selectPressureFlow(String deviceId) {
        List<PressureFlow> pressureFlows = pipeInterfaceMapper.selectPressureFlow(deviceId);
        return pressureFlows;
    }

    /**
     * 场站信息查询方法
     * @return
     */
    @Override
    public List<TSiteStationInfoData> selectTSiteStationInfoData(String enterId) {
        List<TSiteStationInfoData> tSiteStationInfoData = pipeInterfaceMapper.selectTSiteStationInfoData(enterId);
        return tSiteStationInfoData;
    }

    /**
     * 查询场站下级数据
     * @param siteStationId
     * @return
     */
    @Override
    public List<PressureFlow> selecttSiteStationInfoDataList(String siteStationId) {
        List<PressureFlow> pressureFlows = pipeInterfaceMapper.selecttSiteStationInfoDataList(siteStationId);
        return pressureFlows;
    }

    /**
     * 监控信息查询
     * @return
     */
    @Override
    public List<TvideoManagerData> selectTvideoManagerData() {
        List<TvideoManagerData> tvideoManagerData = pipeInterfaceMapper.selectTvideoManagerData();
        return tvideoManagerData;
    }

    /**
     * 燃气用户信息查询接口
     * @return
     */
    @Override
    public List<TdetectorUserData> selectTdetectorUser() {
        List<TdetectorUserData> tdetectorUserData = pipeInterfaceMapper.selectTdetectorUser();
        return tdetectorUserData;
    }

    /**
     * 查询企业名称id方法
     * @return
     */
    @Override
    public List<TenterpriseInfoData> selectTenterpriseInfoData() {
        List<TenterpriseInfoData> tenterpriseInfoData = pipeInterfaceMapper.selectTenterpriseInfoData();
        return tenterpriseInfoData;
    }

    /**
     * 查询阀门井数据
     * @return
     */
    @Override
    public List<DeviceData> selectvalveData(String enterId) {
        List<DeviceData> pipeDates = pipeInterfaceMapper.selectvalveData(enterId);
        return pipeDates;
    }

    /**
     * 查询下级在线设备数量
     * @param pressureList
     * @return
     */
    @Override
    public int  selectOnlineQuantity(List<PressureFlow> pressureList, int isOnLine) {
        int i = pipeInterfaceMapper.selectOnlineQuantity(pressureList,isOnLine);
        return i;
    }

    /**
     * 查询历史报警数量
     * @param pressureList
     * @return
     */
    @Override
    public int selectHistoricalAlarm(List<PressureFlow> pressureList) {
        int i = pipeInterfaceMapper.selectHistoricalAlarm(pressureList);
        return i;
    }

    /**
     * 查询已处理报警
     * @param pressureList
     * @return
     */
    @Override
    public int selectProcessAlarm(List<PressureFlow> pressureList) {
        int i = pipeInterfaceMapper.selectProcessAlarm(pressureList);
        return i;
    }

    /**
     * 查询报警中
     * @param pressureList
     * @return
     */
    @Override
    public int selectInAlarm(List<PressureFlow> pressureList) {
        int i = pipeInterfaceMapper.selectInAlarm(pressureList);
        return i;
    }

    /**
     * 查询 场站/设备 列表信息方法
     * @param devId
     * @param relationDeviceType
     * @return
     */
    @Override
    public List<TAssociatedEquipment> selectSensingDevice(String devId, String relationDeviceType) {
        List<TAssociatedEquipment> tAssociatedEquipments = pipeInterfaceMapper.selectSensingDevice(devId, relationDeviceType);
        return tAssociatedEquipments;
    }

    /**
     * 查询上级设备是否有下级设备
     * @param deviceId
     * @return
     */
    @Override
    public int selectValveWellIsNUll(String deviceId,int type) {
        return pipeInterfaceMapper.selectValveWellIsNUll(deviceId,type);
    }

    /**
     * 查询下级全部数据方法
     * @param type
     * @return
     */
    @Override
    public List<PressureFlow> selectPressureFlows(String type) {
        List<PressureFlow> flows = pipeInterfaceMapper.selectPressureFlows(type);
        return flows;
    }
}