package com.java110.fee.bmo.meterWater.impl; import com.alibaba.fastjson.JSONArray; import com.java110.dto.RoomDto; import com.java110.dto.meterWater.MeterWaterDto; import com.java110.dto.parking.ParkingSpaceDto; import com.java110.fee.bmo.meterWater.IQueryPreMeterWater; import com.java110.intf.community.IParkingSpaceInnerServiceSMO; import com.java110.intf.community.IRoomInnerServiceSMO; import com.java110.intf.fee.IMeterWaterInnerServiceSMO; import com.java110.utils.util.StringUtil; import com.java110.vo.ResultVo; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; import org.springframework.stereotype.Service; import java.util.List; /** * 上期度数查询 */ @Service public class QueryPreMeterWaterImpl implements IQueryPreMeterWater { private static Logger logger = LoggerFactory.getLogger(QueryPreMeterWaterImpl.class); @Autowired private IMeterWaterInnerServiceSMO meterWaterInnerServiceSMOImpl; @Autowired private IRoomInnerServiceSMO roomInnerServiceSMOImpl; @Autowired private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMOImpl; @Override public ResponseEntity query(MeterWaterDto meterWaterDto, String roomNum) { if (!freshFeeDtoParam(meterWaterDto, roomNum)) { return ResultVo.createResponseEntity(1, 0, new JSONArray()); } List meterWaterDtos = meterWaterInnerServiceSMOImpl.queryMeterWaters(meterWaterDto); int total = meterWaterDtos == null ? 0 : meterWaterDtos.size(); return ResultVo.createResponseEntity(1, total, meterWaterDtos); } private boolean freshFeeDtoParam(MeterWaterDto meterWaterDto, String roomNum) { if (StringUtil.isEmpty(roomNum)) { return true; } if (!roomNum.contains("-")) { return false; } if (MeterWaterDto.METER_TYPE_ROOM.equals(meterWaterDto.getObjType())) { String[] nums = roomNum.split("-"); if (nums.length != 3) { return false; } RoomDto roomDto = new RoomDto(); roomDto.setFloorNum(nums[0]); roomDto.setUnitNum(nums[1]); roomDto.setRoomNum(nums[2]); roomDto.setCommunityId(meterWaterDto.getCommunityId()); List roomDtos = roomInnerServiceSMOImpl.queryRooms(roomDto); if (roomDtos == null || roomDtos.size() < 1) { return false; } meterWaterDto.setObjId(roomDtos.get(0).getRoomId()); } else { String[] nums = roomNum.split("-"); if (nums.length != 2) { return false; } ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto(); parkingSpaceDto.setAreaNum(nums[0]); parkingSpaceDto.setNum(nums[1]); parkingSpaceDto.setCommunityId(meterWaterDto.getCommunityId()); List parkingSpaceDtos = parkingSpaceInnerServiceSMOImpl.queryParkingSpaces(parkingSpaceDto); if (parkingSpaceDtos == null || parkingSpaceDtos.size() < 1) { return false; } meterWaterDto.setObjId(parkingSpaceDtos.get(0).getPsId()); } return true; } }