| package com.doumee.service.business.impl; | 
|   | 
| import com.doumee.core.constants.ResponseStatus; | 
| import com.doumee.core.exception.BusinessException; | 
| import com.doumee.core.model.LoginUserInfo; | 
| import com.doumee.core.model.PageData; | 
| import com.doumee.core.model.PageWrap; | 
| import com.doumee.core.utils.Constants; | 
| import com.doumee.core.utils.Utils; | 
| import com.doumee.dao.business.YwBuildingMapper; | 
| import com.doumee.dao.business.YwRoomMapper; | 
| import com.doumee.dao.business.model.YwBuilding; | 
| import com.doumee.dao.business.model.YwProject; | 
| import com.doumee.dao.business.model.YwRoom; | 
| import com.doumee.service.business.YwRoomService; | 
| 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 com.github.yulichang.wrapper.MPJLambdaWrapper; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.stereotype.Service; | 
| import org.springframework.util.CollectionUtils; | 
|   | 
| import java.util.Date; | 
| import java.util.List; | 
|   | 
| /** | 
|  * 运维房源信息表Service实现 | 
|  * @author 江蹄蹄 | 
|  * @date 2024/11/19 16:07 | 
|  */ | 
| @Service | 
| public class YwRoomServiceImpl implements YwRoomService { | 
|   | 
|     @Autowired | 
|     private YwRoomMapper ywRoomMapper; | 
|     @Autowired | 
|     private YwBuildingMapper ywBuildingMapper; | 
|   | 
|     @Override | 
|     public Integer create(YwRoom model) { | 
|         if(model.getBuildingId()==null){ | 
|             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,请选择正确的楼宇信息!"); | 
|         } | 
|         YwBuilding ywBuilding = ywBuildingMapper.selectById(model.getBuildingId()); | 
|         if(ywBuilding ==null ||Constants.equalsInteger(ywBuilding.getIsdeleted(),Constants.ONE)){ | 
|             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,请选择正确的楼宇信息!"); | 
|         } | 
|         model.setProjectId(ywBuilding.getProjectId()); | 
|         model.setCreator(model.getLoginUserInfo().getId()); | 
|         model.setIsdeleted(Constants.ZERO); | 
|         model.setCreateDate(new Date()); | 
|         model.setStatus(Constants.ZERO); | 
|         model.setEditDate(model.getCreateDate()); | 
|         model.setEditor(model.getCreator()); | 
|         ywRoomMapper.insert(model); | 
|         return model.getId(); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteById(Integer id, LoginUserInfo user) { | 
|         YwRoom model = new YwRoom(); | 
|         model.setId(id); | 
|         model.setEditDate(new Date()); | 
|         model.setEditor(user.getId()); | 
|         model.setIsdeleted(Constants.ONE); | 
|         ywRoomMapper.updateById(model); | 
|     } | 
|   | 
|     @Override | 
|     public void delete(YwRoom ywRoom) { | 
|         UpdateWrapper<YwRoom> deleteWrapper = new UpdateWrapper<>(ywRoom); | 
|         ywRoomMapper.delete(deleteWrapper); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteByIdInBatch(List<Integer> ids, LoginUserInfo user) { | 
|         if (CollectionUtils.isEmpty(ids)) { | 
|             return; | 
|         } | 
|         for (Integer ywProject: ids) { | 
|             this.deleteById(ywProject,user); | 
|         } | 
|     } | 
|   | 
|     @Override | 
|     public void updateById(YwRoom model) { | 
|         if(model.getBuildingId()==null){ | 
|             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,请选择正确的楼宇信息!"); | 
|         } | 
|         YwBuilding ywBuilding = ywBuildingMapper.selectById(model.getBuildingId()); | 
|         if(ywBuilding ==null ||Constants.equalsInteger(ywBuilding.getIsdeleted(),Constants.ONE)){ | 
|             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,请选择正确的楼宇信息!"); | 
|         } | 
|         model.setProjectId(ywBuilding.getProjectId()); | 
|         model.setEditDate(new Date()); | 
|         model.setEditor(model.getLoginUserInfo().getId()); | 
|         ywRoomMapper.updateById(model); | 
|     } | 
|   | 
|     @Override | 
|     public void updateByIdInBatch(List<YwRoom> ywRooms) { | 
|         if (CollectionUtils.isEmpty(ywRooms)) { | 
|             return; | 
|         } | 
|         for (YwRoom ywRoom: ywRooms) { | 
|             this.updateById(ywRoom); | 
|         } | 
|     } | 
|   | 
|     @Override | 
|     public YwRoom findById(Integer id) { | 
|         return ywRoomMapper.selectById(id); | 
|     } | 
|   | 
|     @Override | 
|     public YwRoom findOne(YwRoom ywRoom) { | 
|         QueryWrapper<YwRoom> wrapper = new QueryWrapper<>(ywRoom); | 
|         return ywRoomMapper.selectOne(wrapper); | 
|     } | 
|   | 
|     @Override | 
|     public List<YwRoom> findList(YwRoom ywRoom) { | 
|         ywRoom.setIsdeleted(Constants.ZERO); | 
|         QueryWrapper<YwRoom> wrapper = new QueryWrapper< >(ywRoom); | 
|         return ywRoomMapper.selectList(wrapper); | 
|     } | 
|    | 
|     @Override | 
|     public PageData<YwRoom> findPage(PageWrap<YwRoom> pageWrap) { | 
|         IPage<YwRoom> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|          MPJLambdaWrapper<YwRoom> queryWrapper = new MPJLambdaWrapper<>(); | 
|         queryWrapper.selectAll(YwBuilding.class ) | 
|                 .selectAs(YwProject::getName,YwRoom::getProjectName) | 
|                 .selectAs(YwBuilding::getName,YwRoom::getBuildingName) | 
|                 .leftJoin(YwProject.class,YwProject::getId,YwRoom::getProjectId) | 
|                 .leftJoin(YwBuilding.class,YwBuilding::getId,YwRoom::getBuildingId); | 
|         pageWrap.getModel().setIsdeleted(Constants.ZERO); | 
|         Utils.MP.blankToNull(pageWrap.getModel()); | 
|         if (pageWrap.getModel().getId() != null) { | 
|             queryWrapper.eq(YwRoom::getId, pageWrap.getModel().getId()); | 
|         } | 
|         if (pageWrap.getModel().getCreator() != null) { | 
|             queryWrapper.eq(YwRoom::getCreator, pageWrap.getModel().getCreator()); | 
|         } | 
|         if (pageWrap.getModel().getCreateDate() != null) { | 
|             queryWrapper.ge(YwRoom::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); | 
|             queryWrapper.le(YwRoom::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); | 
|         } | 
|         if (pageWrap.getModel().getEditor() != null) { | 
|             queryWrapper.eq(YwRoom::getEditor, pageWrap.getModel().getEditor()); | 
|         } | 
|         if (pageWrap.getModel().getEditDate() != null) { | 
|             queryWrapper.ge(YwRoom::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); | 
|             queryWrapper.le(YwRoom::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); | 
|         } | 
|         if (pageWrap.getModel().getIsdeleted() != null) { | 
|             queryWrapper.eq(YwRoom::getIsdeleted, pageWrap.getModel().getIsdeleted()); | 
|         } | 
|         if (pageWrap.getModel().getName() != null) { | 
|             queryWrapper.eq(YwRoom::getName, pageWrap.getModel().getName()); | 
|         } | 
|         if (pageWrap.getModel().getRemark() != null) { | 
|             queryWrapper.eq(YwRoom::getRemark, pageWrap.getModel().getRemark()); | 
|         } | 
|         if (pageWrap.getModel().getStatus() != null) { | 
|             queryWrapper.eq(YwRoom::getStatus, pageWrap.getModel().getStatus()); | 
|         } | 
|         if (pageWrap.getModel().getSortnum() != null) { | 
|             queryWrapper.eq(YwRoom::getSortnum, pageWrap.getModel().getSortnum()); | 
|         } | 
|         if (pageWrap.getModel().getImgurl() != null) { | 
|             queryWrapper.eq(YwRoom::getImgurl, pageWrap.getModel().getImgurl()); | 
|         } | 
|         if (pageWrap.getModel().getCode() != null) { | 
|             queryWrapper.eq(YwRoom::getCode, pageWrap.getModel().getCode()); | 
|         } | 
|         if (pageWrap.getModel().getRoomNum() != null) { | 
|             queryWrapper.eq(YwRoom::getRoomNum, pageWrap.getModel().getRoomNum()); | 
|         } | 
|         if (pageWrap.getModel().getIsInvestment() != null) { | 
|             queryWrapper.eq(YwRoom::getIsInvestment, pageWrap.getModel().getIsInvestment()); | 
|         } | 
|         if (pageWrap.getModel().getArea() != null) { | 
|             queryWrapper.eq(YwRoom::getArea, pageWrap.getModel().getArea()); | 
|         } | 
|         if (pageWrap.getModel().getFeeArea() != null) { | 
|             queryWrapper.eq(YwRoom::getFeeArea, pageWrap.getModel().getFeeArea()); | 
|         } | 
|         if (pageWrap.getModel().getRentArea() != null) { | 
|             queryWrapper.eq(YwRoom::getRentArea, pageWrap.getModel().getRentArea()); | 
|         } | 
|         if (pageWrap.getModel().getFloor() != null) { | 
|             queryWrapper.eq(YwRoom::getFloor, pageWrap.getModel().getFloor()); | 
|         } | 
|         if (pageWrap.getModel().getProjectId() != null) { | 
|             queryWrapper.eq(YwRoom::getProjectId, pageWrap.getModel().getProjectId()); | 
|         } | 
|         if (pageWrap.getModel().getBuildingId() != null) { | 
|             queryWrapper.eq(YwRoom::getBuildingId, pageWrap.getModel().getBuildingId()); | 
|         } | 
|         queryWrapper.orderByAsc(YwRoom::getRoomNum); | 
|         return PageData.from(ywRoomMapper.selectJoinPage(page,YwRoom.class, queryWrapper)); | 
|     } | 
|   | 
|     @Override | 
|     public long count(YwRoom ywRoom) { | 
|         QueryWrapper<YwRoom> wrapper = new QueryWrapper<>(ywRoom); | 
|         return ywRoomMapper.selectCount(wrapper); | 
|     } | 
| } |