package com.doumee.service.business.impl; import com.doumee.core.annotation.excel.ExcelImporter; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.service.business.third.model.LoginUserInfo; import com.doumee.service.business.third.model.PageData; import com.doumee.service.business.third.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; import com.doumee.dao.admin.request.PlatformGasImport; import com.doumee.dao.business.PlatformWaterGasMapper; import com.doumee.dao.business.model.PlatformWaterGas; 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 com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.web.multipart.MultipartFile; import java.math.BigDecimal; import java.util.*; /** * 月台_用水用气信息记录表Service实现 * @author 江蹄蹄 * @date 2024/08/26 16:22 */ @Service public class PlatformWaterGasServiceImpl implements PlatformWaterGasService { @Autowired private PlatformWaterGasMapper platformWaterGasMapper; @Override public Integer create(PlatformWaterGas platformWaterGas) { if(platformWaterGas.getTimeInfo() ==null || platformWaterGas.getNum()==null ||(Constants.equalsInteger(platformWaterGas.getType(),Constants.TWO) && StringUtils.isBlank(platformWaterGas.getCarCode()))){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,参数错误!"); } if( platformWaterGasMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted, Constants.ZERO) .apply("to_days(time_info) = to_days('"+ DateUtil.getPlusTime2(platformWaterGas.getTimeInfo()) +"')") .eq(PlatformWaterGas::getType,platformWaterGas.getType()) .eq(Constants.equalsInteger(platformWaterGas.getType(),Constants.TWO),PlatformWaterGas::getCarCode,platformWaterGas.getCarCode()))>0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,该年月数据已存在,请勿重新录入,可以尝试搜索后进行数据修改!"); } platformWaterGas.setIsdeleted(Constants.ZERO); platformWaterGas.setType(Constants.formatIntegerNum(platformWaterGas.getType())); platformWaterGas.setCreator(platformWaterGas.getLoginUserInfo().getId()); platformWaterGas.setCreateDate(new Date()); platformWaterGas.setEditDate(platformWaterGas.getCreateDate()); platformWaterGas.setEditor(platformWaterGas.getCreator()); platformWaterGasMapper.insert(platformWaterGas); return platformWaterGas.getId(); } @Override public void deleteById(Integer id) { platformWaterGasMapper.deleteById(id); } @Override public void deleteById(Integer id, LoginUserInfo model) { PlatformWaterGas param = new PlatformWaterGas(); param.setId(id); param.setIsdeleted(Constants.ONE); param.setEditor(model.getId()); param.setEditDate(new Date()); platformWaterGasMapper.updateById(param); } @Override public void delete(PlatformWaterGas platformWaterGas) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(platformWaterGas); platformWaterGasMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } platformWaterGasMapper.deleteBatchIds(ids); } @Override public void deleteByIdInBatch(List ids, LoginUserInfo model) { if (CollectionUtils.isEmpty(ids)) { return; } for(Integer id : ids){ deleteById(id,model); } } @Override public void updateById(PlatformWaterGas platformWaterGas) { if(platformWaterGas.getTimeInfo() ==null || platformWaterGas.getId()==null || platformWaterGas.getNum()==null ||(Constants.equalsInteger(platformWaterGas.getType(),Constants.TWO) && StringUtils.isBlank(platformWaterGas.getCarCode()))){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,该年月数据已存在,请勿重新录入,可以尝试搜索后进行数据修改!"); } if( platformWaterGasMapper.selectCount(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted, Constants.ZERO) .ne(PlatformWaterGas::getId,platformWaterGas.getId()) .apply("to_days(time_info) = to_days('"+ DateUtil.getPlusTime2(platformWaterGas.getTimeInfo()) +"')") .eq(PlatformWaterGas::getType, platformWaterGas.getType()) .eq(Constants.equalsInteger(platformWaterGas.getType(),Constants.TWO),PlatformWaterGas::getCarCode,platformWaterGas.getCarCode()))>0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,该年月数据已存在,请勿重新录入,可以尝试搜索后进行数据修改!"); } platformWaterGas.setEditDate(new Date()); platformWaterGas.setEditor(platformWaterGas.getLoginUserInfo().getId()); platformWaterGasMapper.updateById(platformWaterGas); } @Override public void updateByIdInBatch(List platformWaterGass) { if (CollectionUtils.isEmpty(platformWaterGass)) { return; } for (PlatformWaterGas platformWaterGas: platformWaterGass) { this.updateById(platformWaterGas); } } @Override public PlatformWaterGas findById(Integer id) { return platformWaterGasMapper.selectById(id); } @Override public PlatformWaterGas findOne(PlatformWaterGas platformWaterGas) { QueryWrapper wrapper = new QueryWrapper<>(platformWaterGas); return platformWaterGasMapper.selectOne(wrapper); } @Override public List findList(PlatformWaterGas platformWaterGas) { QueryWrapper wrapper = new QueryWrapper<>(platformWaterGas); return platformWaterGasMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); QueryWrapper queryWrapper = new QueryWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper.lambda().eq(PlatformWaterGas::getIsdeleted, Constants.ZERO); if (pageWrap.getModel().getId() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getId, pageWrap.getModel().getId()); } if (pageWrap.getModel().getCreator() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getCreator, pageWrap.getModel().getCreator()); } if (pageWrap.getModel().getCreateDate() != null) { queryWrapper.lambda().ge(PlatformWaterGas::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); queryWrapper.lambda().le(PlatformWaterGas::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); } if (pageWrap.getModel().getEditor() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getEditor, pageWrap.getModel().getEditor()); } if (pageWrap.getModel().getEditDate() != null) { queryWrapper.lambda().ge(PlatformWaterGas::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); queryWrapper.lambda().le(PlatformWaterGas::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); } if (pageWrap.getModel().getIsdeleted() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getIsdeleted, pageWrap.getModel().getIsdeleted()); } if (pageWrap.getModel().getRemark() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getRemark, pageWrap.getModel().getRemark()); } if (pageWrap.getModel().getTimeInfo() != null) { queryWrapper.lambda().ge(PlatformWaterGas::getTimeInfo, Utils.Date.getStart(pageWrap.getModel().getTimeInfo())); queryWrapper.lambda().le(PlatformWaterGas::getTimeInfo, Utils.Date.getEnd(pageWrap.getModel().getTimeInfo())); } if (pageWrap.getModel().getSortnum() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getSortnum, pageWrap.getModel().getSortnum()); } if (pageWrap.getModel().getType() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getType, pageWrap.getModel().getType()); } if (pageWrap.getModel().getNum() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getNum, pageWrap.getModel().getNum()); } if (pageWrap.getModel().getContent() != null) { queryWrapper.lambda().eq(PlatformWaterGas::getContent, pageWrap.getModel().getContent()); } if (pageWrap.getModel().getCarCode() != null) { queryWrapper.lambda().like(PlatformWaterGas::getCarCode, pageWrap.getModel().getCarCode()); } if (pageWrap.getModel().getStartTime() != null) { queryWrapper.lambda().ge(PlatformWaterGas::getTimeInfo, pageWrap.getModel().getStartTime()); } if (pageWrap.getModel().getEndTime() != null) { queryWrapper.lambda().le(PlatformWaterGas::getTimeInfo, pageWrap.getModel().getEndTime()); } queryWrapper.lambda().orderByDesc(PlatformWaterGas::getTimeInfo ,PlatformWaterGas::getCarCode); return PageData.from(platformWaterGasMapper.selectPage(page, queryWrapper)); } @Override public long count(PlatformWaterGas platformWaterGas) { QueryWrapper wrapper = new QueryWrapper<>(platformWaterGas); return platformWaterGasMapper.selectCount(wrapper); } @Override public WaterByMonthResponse waterDataByMonth(WaterByMonthRequest param){ Date queryDate = (Objects.nonNull(param)&&Objects.nonNull(param.getTimeInfo()))?param.getTimeInfo():new Date(); //获取上个月日期 Calendar calendar = Calendar.getInstance(); calendar.setTime(queryDate); calendar.add(Calendar.MONTH, -1); Date beforMonth = calendar.getTime(); calendar.add(Calendar.MONTH, -11); Date beforYearMonth = calendar.getTime(); WaterByMonthResponse waterByMonthResponse = new WaterByMonthResponse(); List list = platformWaterGasMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.ZERO) .like(PlatformWaterGas::getTimeInfo,DateUtil.getDate(queryDate,"yyyy-MM")) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ waterByMonthResponse.setCurrentMonth(list.stream().map(m->m.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); } list = platformWaterGasMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.ZERO) .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().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.ZERO) .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)); } return waterByMonthResponse; } @Override public GasByMonthResponse gasDataByMonth(GasByMonthRequest param){ Date queryDate = (Objects.nonNull(param)&&Objects.nonNull(param.getTimeInfo()))?param.getTimeInfo():new Date(); //获取上个月日期 Calendar calendar = Calendar.getInstance(); calendar.setTime(queryDate); calendar.add(Calendar.MONTH, -1); Date beforMonth = calendar.getTime(); calendar.add(Calendar.MONTH, -11); Date beforYearMonth = calendar.getTime(); GasByMonthResponse response = new GasByMonthResponse(); List list = platformWaterGasMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.ONE) .like(PlatformWaterGas::getTimeInfo,DateUtil.getDate(queryDate,"yyyy-MM")) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ response.setCurrentMonth(list.stream().map(m->m.getNum()).reduce(BigDecimal.ZERO,BigDecimal::add)); } list = platformWaterGasMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.ONE) .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().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.ONE) .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 getPlatformLastMonthListResponse(Integer type){ List lastMonthListResponses = new ArrayList<>(); List platformWaterGasList = platformWaterGasMapper.selectList(new QueryWrapper().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,type) ); List 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; } @Autowired private RedisTemplate redisTemplate; @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public String importBatch(MultipartFile file, LoginUserInfo loginUserInfo){ try { ExcelImporter ie = null; List dataList =null; try { ie = new ExcelImporter(file,1,0); dataList = ie.getDataList(PlatformGasImport.class,null); } catch (Exception e) { e.printStackTrace(); } if(dataList == null || dataList.size() ==0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,录入数据为空!"); } List newList = new ArrayList<>(); for(int i=0;i().lambda() .eq(PlatformWaterGas::getIsdeleted, Constants.ZERO) .apply("to_days(time_info) = to_days('"+ model.getTimeInfo()+"-01" +"')") .eq(PlatformWaterGas::getType,Constants.TWO) .eq(PlatformWaterGas::getCarCode,model.getCarCode()))>0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,该["+model.getTimeInfo()+"]数据已存在,请勿重新录入,可以尝试搜索后进行数据修改!"); } platformWaterGas.setTimeInfo(DateUtil.StringToDate(model.getTimeInfo()+"-01","yyyy-MM-dd")); platformWaterGas.setCarCode(model.getCarCode()); platformWaterGas.setIsdeleted(Constants.ZERO); platformWaterGas.setType(Constants.TWO); platformWaterGas.setCreator(loginUserInfo.getId()); platformWaterGas.setCreateDate(new Date()); platformWaterGas.setEditDate(platformWaterGas.getCreateDate()); platformWaterGas.setEditor(platformWaterGas.getCreator()); newList.add(platformWaterGas); } if(newList == null || newList.size() ==0){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,录入有效数据为空!"); } platformWaterGasMapper.insert(newList); return "导入成功"; }catch (BusinessException e){ throw e; }catch (Exception e){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"信息导入失败,请稍后重试"); }finally { redisTemplate.delete(Constants.RedisKeys.IMPORTING_MEMBER); } } }