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.DateUtil;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.YwBuildingMapper;
|
import com.doumee.dao.business.YwFloorMapper;
|
import com.doumee.dao.business.YwProjectMapper;
|
import com.doumee.dao.business.YwRoomMapper;
|
import com.doumee.dao.business.dto.DataDTO;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.business.vo.CompanyTree;
|
import com.doumee.dao.business.vo.ProjectDataVO;
|
import com.doumee.dao.business.vo.ProjectTree;
|
import com.doumee.service.business.AreasService;
|
import com.doumee.service.business.YwProjectService;
|
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.checkerframework.checker.units.qual.A;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 运维项目信息表Service实现
|
* @author 江蹄蹄
|
* @date 2024/11/19 16:07
|
*/
|
@Service
|
public class YwProjectServiceImpl implements YwProjectService {
|
|
@Autowired
|
private YwProjectMapper ywProjectMapper;
|
@Autowired
|
private AreasService areasService;
|
|
@Autowired
|
private YwFloorMapper ywFloorMapper;
|
|
@Autowired
|
private YwRoomMapper ywRoomMapper;
|
|
@Autowired
|
private YwBuildingMapper ywBuildingMapper;
|
|
@Override
|
public Integer create(YwProject model) {
|
if(Objects.isNull(model)
|
|| StringUtils.isBlank(model.getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
if(ywProjectMapper.selectCount(new QueryWrapper<YwProject>().lambda()
|
.eq(YwProject::getName,model.getName())
|
.eq(YwProject::getIsdeleted,Constants.ZERO))>Constants.ZERO){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+model.getName()+"】已存在!");
|
}
|
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());
|
ywProjectMapper.insert(model);
|
return model.getId();
|
}
|
|
@Override
|
public void deleteById(Integer id, LoginUserInfo user) {
|
//查询项目下的数据
|
if(ywBuildingMapper.selectCount(new QueryWrapper<YwBuilding>().lambda().eq(YwBuilding::getIsdeleted,Constants.ZERO)
|
.eq(YwBuilding::getProjectId,id))>Constants.ZERO){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"项目下存在楼宇数据!");
|
};
|
YwProject model = new YwProject();
|
model.setId(id);
|
model.setEditDate(new Date());
|
model.setEditor(user.getId());
|
model.setIsdeleted(Constants.ONE);
|
ywProjectMapper.updateById(model);
|
}
|
|
@Override
|
public void delete(YwProject ywProject) {
|
UpdateWrapper<YwProject> deleteWrapper = new UpdateWrapper<>(ywProject);
|
ywProjectMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids, LoginUserInfo user) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
for(Integer id : ids){
|
this.deleteById(id,user);
|
}
|
}
|
|
@Override
|
public void updateById(YwProject model) {
|
if(Objects.isNull(model)
|
|| Objects.isNull(model.getId())
|
|| StringUtils.isBlank(model.getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
if(ywProjectMapper.selectCount(new QueryWrapper<YwProject>().lambda()
|
.eq(YwProject::getName,model.getName())
|
.ne(YwProject::getId,model.getId())
|
.eq(YwProject::getIsdeleted,Constants.ZERO))>Constants.ZERO){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"【"+model.getName()+"】已存在!");
|
}
|
model.setEditDate(new Date());
|
model.setEditor(model.getLoginUserInfo().getId());
|
ywProjectMapper.updateById(model);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<YwProject> ywProjects) {
|
if (CollectionUtils.isEmpty(ywProjects)) {
|
return;
|
}
|
for (YwProject ywProject: ywProjects) {
|
this.updateById(ywProject);
|
}
|
}
|
|
@Override
|
public YwProject findById(Integer id) {
|
return ywProjectMapper.selectById(id);
|
}
|
|
@Override
|
public YwProject findOne(YwProject ywProject) {
|
QueryWrapper<YwProject> wrapper = new QueryWrapper<>(ywProject);
|
return ywProjectMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<YwProject> findList(YwProject ywProject) {
|
ywProject.setIsdeleted(Constants.ZERO);
|
QueryWrapper<YwProject> wrapper = new QueryWrapper<>(ywProject);
|
return ywProjectMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<YwProject> findPage(PageWrap<YwProject> pageWrap) {
|
IPage<YwProject> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
QueryWrapper<YwProject> queryWrapper = new QueryWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
pageWrap.getModel().setIsdeleted(Constants.ZERO);
|
queryWrapper.select("*,(select count(1) from yw_room a where a.isdeleted=0 and a.PROJECT_ID=yw_project.id) as roomNum"+
|
",(select count(1) from yw_room a where a.isdeleted=0 and a.PROJECT_ID=yw_project.id and a.IS_INVESTMENT=1) as roomRentNum," +
|
"( select ifnull(sum(a.RENT_AREA),0) from yw_room a where a.isdeleted=0 and a.PROJECT_ID=yw_project.id ) as area");
|
if (pageWrap.getModel().getId() != null) {
|
queryWrapper.lambda().eq(YwProject::getId, pageWrap.getModel().getId());
|
}
|
if (pageWrap.getModel().getCreator() != null) {
|
queryWrapper.lambda().eq(YwProject::getCreator, pageWrap.getModel().getCreator());
|
}
|
if (pageWrap.getModel().getCreateDate() != null) {
|
queryWrapper.lambda().ge(YwProject::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
|
queryWrapper.lambda().le(YwProject::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
|
}
|
if (pageWrap.getModel().getEditor() != null) {
|
queryWrapper.lambda().eq(YwProject::getEditor, pageWrap.getModel().getEditor());
|
}
|
if (pageWrap.getModel().getEditDate() != null) {
|
queryWrapper.lambda().ge(YwProject::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
|
queryWrapper.lambda().le(YwProject::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
|
}
|
if (pageWrap.getModel().getIsdeleted() != null) {
|
queryWrapper.lambda().eq(YwProject::getIsdeleted, pageWrap.getModel().getIsdeleted());
|
}
|
if (pageWrap.getModel().getName() != null) {
|
queryWrapper.lambda().eq(YwProject::getName, pageWrap.getModel().getName());
|
}
|
if (pageWrap.getModel().getRemark() != null) {
|
queryWrapper.lambda().eq(YwProject::getRemark, pageWrap.getModel().getRemark());
|
}
|
if (pageWrap.getModel().getStatus() != null) {
|
queryWrapper.lambda().eq(YwProject::getStatus, pageWrap.getModel().getStatus());
|
}
|
if (pageWrap.getModel().getSortnum() != null) {
|
queryWrapper.lambda().eq(YwProject::getSortnum, pageWrap.getModel().getSortnum());
|
}
|
if (pageWrap.getModel().getImgurl() != null) {
|
queryWrapper.lambda().eq(YwProject::getImgurl, pageWrap.getModel().getImgurl());
|
}
|
if (pageWrap.getModel().getAreaId() != null) {
|
queryWrapper.lambda().eq(YwProject::getAreaId, pageWrap.getModel().getAreaId());
|
}
|
if (pageWrap.getModel().getAddr() != null) {
|
queryWrapper.lambda().eq(YwProject::getAddr, pageWrap.getModel().getAddr());
|
}
|
queryWrapper.lambda().orderByDesc(YwProject::getCreateDate);
|
PageData<YwProject> data = PageData.from(ywProjectMapper.selectPage(page, queryWrapper));
|
if(data!=null && data.getRecords()!=null){
|
for(YwProject model :data.getRecords()){
|
if(model.getAreaId()!=null){
|
Areas a = areasService.findById(model.getAreaId(),Constants.TWO);
|
if(a != null){
|
model.setAreaName(a.getName());
|
model.setCityId(a.getCityId());
|
model.setCityName(a.getCityName());
|
model.setProvinceId(a.getProvinceId());
|
model.setProvinceName(a.getProvinceName());
|
}
|
}
|
}
|
}
|
return data;
|
}
|
|
@Override
|
public long count(YwProject ywProject) {
|
QueryWrapper<YwProject> wrapper = new QueryWrapper<>(ywProject);
|
return ywProjectMapper.selectCount(wrapper);
|
}
|
|
|
@Override
|
public List<ProjectDataVO> projectTree(DataDTO dataDTO){
|
List<ProjectDataVO> projectDataVOList = new ArrayList<>();
|
List<YwProject> ywProjectList = ywProjectMapper.selectList(new QueryWrapper<YwProject>().lambda()
|
.eq(YwProject::getIsdeleted,Constants.ZERO)
|
.eq(YwProject::getStatus,Constants.ZERO)
|
.eq(Objects.nonNull(dataDTO.getProjectId()),YwProject::getId,dataDTO.getProjectId())
|
.orderByAsc(YwProject::getSortnum)
|
);
|
for (YwProject ywProject:ywProjectList) {
|
ProjectDataVO projectDataVO = new ProjectDataVO();
|
BeanUtils.copyProperties(ywProject,projectDataVO);
|
projectDataVO.setLv(Constants.ZERO);
|
projectDataVOList.add(projectDataVO);
|
}
|
|
List<YwBuilding> ywBuildingList = ywBuildingMapper.selectList(new QueryWrapper<YwBuilding>().lambda()
|
.eq(YwBuilding::getIsdeleted,Constants.ZERO)
|
.eq(YwBuilding::getStatus,Constants.ZERO)
|
.eq(Objects.nonNull(dataDTO.getProjectId()),YwBuilding::getProjectId,dataDTO.getProjectId())
|
.orderByAsc(YwBuilding::getSortnum)
|
);
|
|
for (YwBuilding data:ywBuildingList) {
|
ProjectDataVO projectDataVO = new ProjectDataVO();
|
BeanUtils.copyProperties(data,projectDataVO);
|
projectDataVO.setPId(data.getProjectId());
|
projectDataVO.setLv(Constants.ONE);
|
projectDataVOList.add(projectDataVO);
|
}
|
|
|
List<YwFloor> ywFloorList = ywFloorMapper.selectList(new QueryWrapper<YwFloor>().lambda()
|
.eq(YwFloor::getIsdeleted,Constants.ZERO)
|
.eq(YwFloor::getStatus,Constants.ZERO)
|
.eq(Objects.nonNull(dataDTO.getProjectId()),YwFloor::getProjectId,dataDTO.getProjectId())
|
.orderByAsc(YwFloor::getSortnum)
|
);
|
|
for (YwFloor data:ywFloorList) {
|
ProjectDataVO projectDataVO = new ProjectDataVO();
|
BeanUtils.copyProperties(data,projectDataVO);
|
projectDataVO.setPId(data.getBuildingId());
|
projectDataVO.setLv(Constants.TWO);
|
projectDataVOList.add(projectDataVO);
|
}
|
|
List<YwRoom> ywRoomList = ywRoomMapper.selectList(new QueryWrapper<YwRoom>().lambda()
|
.eq(YwRoom::getIsdeleted,Constants.ZERO)
|
.eq(YwRoom::getStatus,Constants.ZERO)
|
.eq(Objects.nonNull(dataDTO.getProjectId()),YwRoom::getProjectId,dataDTO.getProjectId())
|
.apply(Objects.nonNull(dataDTO)&&Objects.nonNull(dataDTO.getStartDate())&&Objects.nonNull(dataDTO.getEndDate())," id not in (" +
|
" SELECT y2.room_id FROM yw_contract y1 left join yw_contract_room y2 on y1.id = y2.contract_id where 1 = 1 and y1.`STATUS` in( 0,1,2) " +
|
" and y1.START_DATE < '"+dataDTO.getEndDate()+" 00:00:00' and y1.END_DATE > '"+ dataDTO.getStartDate() +" 00:00:00' " +
|
" ) ")
|
.apply(Objects.nonNull(dataDTO)&&Objects.nonNull(dataDTO.getStartDate())&&Objects.nonNull(dataDTO.getEndDate())," id not in (" +
|
" SELECT y2.room_id FROM yw_contract y1 left join yw_contract_room y2 on y1.id = y2.contract_id where 1 = 1 and y1.`STATUS` = 3 " +
|
" and y1.START_DATE < '"+dataDTO.getEndDate()+" 00:00:00' and y1.BT_DATE > '"+ dataDTO.getStartDate() +" 00:00:00' " +
|
" ) ")
|
.orderByAsc(YwRoom::getSortnum)
|
);
|
|
for (YwRoom data:ywRoomList) {
|
ProjectDataVO projectDataVO = new ProjectDataVO();
|
BeanUtils.copyProperties(data,projectDataVO);
|
projectDataVO.setName(data.getCode() + " " + data.getArea() +"㎡");
|
projectDataVO.setPId(data.getFloor());
|
projectDataVO.setLv(Constants.THREE);
|
projectDataVOList.add(projectDataVO);
|
}
|
|
ProjectTree treeBuild = new ProjectTree(projectDataVOList);
|
projectDataVOList = treeBuild.buildTree();
|
return projectDataVOList;
|
|
}
|
|
|
|
|
|
}
|
