|  |  |  | 
|---|
|  |  |  | import com.doumee.dao.openapi.request.GasByMonthRequest; | 
|---|
|  |  |  | import com.doumee.dao.openapi.request.WaterByMonthRequest; | 
|---|
|  |  |  | import com.doumee.dao.openapi.response.GasByMonthResponse; | 
|---|
|  |  |  | import com.doumee.dao.openapi.response.PlatformLastMonthListResponse; | 
|---|
|  |  |  | import com.doumee.dao.openapi.response.WaterByMonthResponse; | 
|---|
|  |  |  | import com.doumee.service.business.PlatformWaterGasService; | 
|---|
|  |  |  | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; | 
|---|
|  |  |  | 
|---|
|  |  |  | import org.springframework.web.bind.annotation.RequestBody; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.math.BigDecimal; | 
|---|
|  |  |  | import java.util.Calendar; | 
|---|
|  |  |  | import java.util.Date; | 
|---|
|  |  |  | import java.util.List; | 
|---|
|  |  |  | import java.util.Objects; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 月台_用水用气信息记录表Service实现 | 
|---|
|  |  |  | 
|---|
|  |  |  | list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda() | 
|---|
|  |  |  | .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(PlatformWaterGas::getType,Constants.ZERO) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,beforMonth) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,DateUtil.getDate(beforMonth,"yyyy-MM")) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ | 
|---|
|  |  |  | waterByMonthResponse.setLastMonth(list.stream().map(m->m.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | 
|---|
|  |  |  | list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda() | 
|---|
|  |  |  | .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(PlatformWaterGas::getType,Constants.ZERO) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,beforYearMonth) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,DateUtil.getDate(beforYearMonth,"yyyy-MM")) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ | 
|---|
|  |  |  | waterByMonthResponse.setLastYearMonth(list.stream().map(m->m.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | 
|---|
|  |  |  | list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda() | 
|---|
|  |  |  | .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(PlatformWaterGas::getType,Constants.ONE) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,beforMonth) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,DateUtil.getDate(beforMonth,"yyyy-MM")) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ | 
|---|
|  |  |  | response.setLastMonth(list.stream().map(m->m.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | 
|---|
|  |  |  | list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda() | 
|---|
|  |  |  | .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(PlatformWaterGas::getType,Constants.ONE) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,beforYearMonth) | 
|---|
|  |  |  | .like(PlatformWaterGas::getTimeInfo,DateUtil.getDate(beforYearMonth,"yyyy-MM")) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ | 
|---|
|  |  |  | response.setLastYearMonth(list.stream().map(m->m.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | 
|---|
|  |  |  | return response; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * | 
|---|
|  |  |  | * @param type 0用水 1用气 | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public List<PlatformLastMonthListResponse> getPlatformLastMonthListResponse(Integer type){ | 
|---|
|  |  |  | List<PlatformLastMonthListResponse> lastMonthListResponses = new ArrayList<>(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | List<PlatformWaterGas> platformWaterGasList = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda() | 
|---|
|  |  |  | .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) | 
|---|
|  |  |  | .eq(PlatformWaterGas::getType,type) | 
|---|
|  |  |  | ); | 
|---|
|  |  |  | List<String> monthList = DateUtil.getBeforMonth(new Date(),12); | 
|---|
|  |  |  | for (String str:monthList) { | 
|---|
|  |  |  | PlatformLastMonthListResponse platformLastMonthListResponse = new PlatformLastMonthListResponse(); | 
|---|
|  |  |  | platformLastMonthListResponse.setNum(platformWaterGasList.stream().filter(i->DateUtil.dateToString(i.getTimeInfo(),"yyyy-MM").equals(str)).map(i->i.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); | 
|---|
|  |  |  | platformLastMonthListResponse.setTimeInfo(str); | 
|---|
|  |  |  | lastMonthListResponses.add(platformLastMonthListResponse); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return lastMonthListResponses; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|