| | |
| | | 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.CompanyMapper; |
| | | import com.doumee.dao.business.join.CompanyJoinMapper; |
| | | import com.doumee.dao.business.model.Category; |
| | | import com.doumee.dao.business.model.Company; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.service.business.CompanyService; |
| | | 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.apache.commons.collections.CollectionUtils; |
| | | import org.apache.shiro.SecurityUtils; |
| | | 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; |
| | | |
| | | /** |
| | |
| | | @Autowired |
| | | private CompanyMapper companyMapper; |
| | | |
| | | @Autowired |
| | | private CompanyJoinMapper companyJoinMapper; |
| | | |
| | | @Override |
| | | public Integer create(Company company) { |
| | | companyMapper.insert(company); |
| | | return company.getId(); |
| | | } |
| | | |
| | | @Override |
| | | public Integer createLaborServices(Company company) { |
| | | LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); |
| | | |
| | | checkUnique(company); |
| | | |
| | | Company insert = new Company(); |
| | | insert.setCreator(loginUserInfo.getId()); |
| | | insert.setCreateDate(new Date()); |
| | | insert.setEditor(loginUserInfo.getId()); |
| | | insert.setEditDate(new Date()); |
| | | insert.setIsdeleted(Constants.ZERO); |
| | | insert.setName(company.getName()); |
| | | insert.setRemark(company.getRemark()); |
| | | insert.setStatus(Constants.ZERO); |
| | | insert.setSortnum(company.getSortnum()); |
| | | insert.setImgurl(company.getImgurl()); |
| | | insert.setType(Constants.ZERO); |
| | | insert.setCategoryId(company.getCategoryId()); |
| | | insert.setCode(company.getCode()); |
| | | insert.setParentId(company.getParentId()); |
| | | insert.setLinkName(company.getLinkName()); |
| | | insert.setLinkPhone(company.getLinkPhone()); |
| | | companyMapper.insert(insert); |
| | | return insert.getId(); |
| | | } |
| | | |
| | | @Override |
| | |
| | | @Override |
| | | public void updateById(Company company) { |
| | | companyMapper.updateById(company); |
| | | } |
| | | |
| | | @Override |
| | | public Integer updateLaborServicesById(Company company) { |
| | | checkUnique(company); |
| | | companyMapper.updateById(company); |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | |
| | | QueryWrapper<Company> wrapper = new QueryWrapper<>(company); |
| | | return companyMapper.selectList(wrapper); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public PageData<Company> findPage(PageWrap<Company> pageWrap) { |
| | | IPage<Company> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); |
| | | QueryWrapper<Company> queryWrapper = new QueryWrapper<>(); |
| | | MPJLambdaWrapper<Company> queryWrapper = new MPJLambdaWrapper<>(); |
| | | Utils.MP.blankToNull(pageWrap.getModel()); |
| | | if (pageWrap.getModel().getId() != null) { |
| | | queryWrapper.lambda().eq(Company::getId, pageWrap.getModel().getId()); |
| | | queryWrapper.eq(Company::getId, pageWrap.getModel().getId()); |
| | | } |
| | | if (pageWrap.getModel().getCreator() != null) { |
| | | queryWrapper.lambda().eq(Company::getCreator, pageWrap.getModel().getCreator()); |
| | | queryWrapper.eq(Company::getCreator, pageWrap.getModel().getCreator()); |
| | | } |
| | | if (pageWrap.getModel().getCreateDate() != null) { |
| | | queryWrapper.lambda().ge(Company::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); |
| | | queryWrapper.lambda().le(Company::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); |
| | | queryWrapper.ge(Company::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); |
| | | queryWrapper.le(Company::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); |
| | | } |
| | | if (pageWrap.getModel().getEditor() != null) { |
| | | queryWrapper.lambda().eq(Company::getEditor, pageWrap.getModel().getEditor()); |
| | | queryWrapper.eq(Company::getEditor, pageWrap.getModel().getEditor()); |
| | | } |
| | | if (pageWrap.getModel().getEditDate() != null) { |
| | | queryWrapper.lambda().ge(Company::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); |
| | | queryWrapper.lambda().le(Company::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); |
| | | queryWrapper.ge(Company::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); |
| | | queryWrapper.le(Company::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); |
| | | } |
| | | if (pageWrap.getModel().getIsdeleted() != null) { |
| | | queryWrapper.lambda().eq(Company::getIsdeleted, pageWrap.getModel().getIsdeleted()); |
| | | queryWrapper.eq(Company::getIsdeleted, pageWrap.getModel().getIsdeleted()); |
| | | } |
| | | if (pageWrap.getModel().getName() != null) { |
| | | queryWrapper.lambda().eq(Company::getName, pageWrap.getModel().getName()); |
| | | queryWrapper.eq(Company::getName, pageWrap.getModel().getName()); |
| | | } |
| | | if (pageWrap.getModel().getRemark() != null) { |
| | | queryWrapper.lambda().eq(Company::getRemark, pageWrap.getModel().getRemark()); |
| | | queryWrapper.eq(Company::getRemark, pageWrap.getModel().getRemark()); |
| | | } |
| | | if (pageWrap.getModel().getStatus() != null) { |
| | | queryWrapper.lambda().eq(Company::getStatus, pageWrap.getModel().getStatus()); |
| | | queryWrapper.eq(Company::getStatus, pageWrap.getModel().getStatus()); |
| | | } |
| | | if (pageWrap.getModel().getSortnum() != null) { |
| | | queryWrapper.lambda().eq(Company::getSortnum, pageWrap.getModel().getSortnum()); |
| | | queryWrapper.eq(Company::getSortnum, pageWrap.getModel().getSortnum()); |
| | | } |
| | | if (pageWrap.getModel().getImgurl() != null) { |
| | | queryWrapper.lambda().eq(Company::getImgurl, pageWrap.getModel().getImgurl()); |
| | | queryWrapper.eq(Company::getImgurl, pageWrap.getModel().getImgurl()); |
| | | } |
| | | if (pageWrap.getModel().getType() != null) { |
| | | queryWrapper.lambda().eq(Company::getType, pageWrap.getModel().getType()); |
| | | queryWrapper.eq(Company::getType, pageWrap.getModel().getType()); |
| | | } |
| | | if (pageWrap.getModel().getCategoryId() != null) { |
| | | queryWrapper.lambda().eq(Company::getCategoryId, pageWrap.getModel().getCategoryId()); |
| | | queryWrapper.eq(Company::getCategoryId, pageWrap.getModel().getCategoryId()); |
| | | } |
| | | if (pageWrap.getModel().getCode() != null) { |
| | | queryWrapper.lambda().eq(Company::getCode, pageWrap.getModel().getCode()); |
| | | queryWrapper.eq(Company::getCode, pageWrap.getModel().getCode()); |
| | | } |
| | | if (pageWrap.getModel().getParentId() != null) { |
| | | queryWrapper.lambda().eq(Company::getParentId, pageWrap.getModel().getParentId()); |
| | | queryWrapper.eq(Company::getParentId, pageWrap.getModel().getParentId()); |
| | | } |
| | | if (pageWrap.getModel().getLinkName() != null) { |
| | | queryWrapper.lambda().eq(Company::getLinkName, pageWrap.getModel().getLinkName()); |
| | | queryWrapper.eq(Company::getLinkName, pageWrap.getModel().getLinkName()); |
| | | } |
| | | if (pageWrap.getModel().getLinkPhone() != null) { |
| | | queryWrapper.lambda().eq(Company::getLinkPhone, pageWrap.getModel().getLinkPhone()); |
| | | queryWrapper.eq(Company::getLinkPhone, pageWrap.getModel().getLinkPhone()); |
| | | } |
| | | if (pageWrap.getModel().getHkId() != null) { |
| | | queryWrapper.lambda().eq(Company::getHkId, pageWrap.getModel().getHkId()); |
| | | queryWrapper.eq(Company::getHkId, pageWrap.getModel().getHkId()); |
| | | } |
| | | if (pageWrap.getModel().getHkStatus() != null) { |
| | | queryWrapper.lambda().eq(Company::getHkStatus, pageWrap.getModel().getHkStatus()); |
| | | queryWrapper.eq(Company::getHkStatus, pageWrap.getModel().getHkStatus()); |
| | | } |
| | | if (pageWrap.getModel().getHkDate() != null) { |
| | | queryWrapper.lambda().ge(Company::getHkDate, Utils.Date.getStart(pageWrap.getModel().getHkDate())); |
| | | queryWrapper.lambda().le(Company::getHkDate, Utils.Date.getEnd(pageWrap.getModel().getHkDate())); |
| | | queryWrapper.ge(Company::getHkDate, Utils.Date.getStart(pageWrap.getModel().getHkDate())); |
| | | queryWrapper.le(Company::getHkDate, Utils.Date.getEnd(pageWrap.getModel().getHkDate())); |
| | | } |
| | | if (pageWrap.getModel().getErpId() != null) { |
| | | queryWrapper.lambda().eq(Company::getErpId, pageWrap.getModel().getErpId()); |
| | | queryWrapper.eq(Company::getErpId, pageWrap.getModel().getErpId()); |
| | | } |
| | | if (pageWrap.getModel().getErpDate() != null) { |
| | | queryWrapper.lambda().ge(Company::getErpDate, Utils.Date.getStart(pageWrap.getModel().getErpDate())); |
| | | queryWrapper.lambda().le(Company::getErpDate, Utils.Date.getEnd(pageWrap.getModel().getErpDate())); |
| | | queryWrapper.ge(Company::getErpDate, Utils.Date.getStart(pageWrap.getModel().getErpDate())); |
| | | queryWrapper.le(Company::getErpDate, Utils.Date.getEnd(pageWrap.getModel().getErpDate())); |
| | | } |
| | | if (pageWrap.getModel().getErpStatus() != null) { |
| | | queryWrapper.lambda().eq(Company::getErpStatus, pageWrap.getModel().getErpStatus()); |
| | | queryWrapper.eq(Company::getErpStatus, pageWrap.getModel().getErpStatus()); |
| | | } |
| | | if (pageWrap.getModel().getDdId() != null) { |
| | | queryWrapper.lambda().eq(Company::getDdId, pageWrap.getModel().getDdId()); |
| | | queryWrapper.eq(Company::getDdId, pageWrap.getModel().getDdId()); |
| | | } |
| | | if (pageWrap.getModel().getDdDate() != null) { |
| | | queryWrapper.lambda().ge(Company::getDdDate, Utils.Date.getStart(pageWrap.getModel().getDdDate())); |
| | | queryWrapper.lambda().le(Company::getDdDate, Utils.Date.getEnd(pageWrap.getModel().getDdDate())); |
| | | queryWrapper.ge(Company::getDdDate, Utils.Date.getStart(pageWrap.getModel().getDdDate())); |
| | | queryWrapper.le(Company::getDdDate, Utils.Date.getEnd(pageWrap.getModel().getDdDate())); |
| | | } |
| | | if (pageWrap.getModel().getDdStatus() != null) { |
| | | queryWrapper.lambda().eq(Company::getDdStatus, pageWrap.getModel().getDdStatus()); |
| | | queryWrapper.eq(Company::getDdStatus, pageWrap.getModel().getDdStatus()); |
| | | } |
| | | if (pageWrap.getModel().getFsId() != null) { |
| | | queryWrapper.lambda().eq(Company::getFsId, pageWrap.getModel().getFsId()); |
| | | queryWrapper.eq(Company::getFsId, pageWrap.getModel().getFsId()); |
| | | } |
| | | if (pageWrap.getModel().getFsStatus() != null) { |
| | | queryWrapper.lambda().eq(Company::getFsStatus, pageWrap.getModel().getFsStatus()); |
| | | queryWrapper.eq(Company::getFsStatus, pageWrap.getModel().getFsStatus()); |
| | | } |
| | | if (pageWrap.getModel().getFsDate() != null) { |
| | | queryWrapper.lambda().ge(Company::getFsDate, Utils.Date.getStart(pageWrap.getModel().getFsDate())); |
| | | queryWrapper.lambda().le(Company::getFsDate, Utils.Date.getEnd(pageWrap.getModel().getFsDate())); |
| | | queryWrapper.ge(Company::getFsDate, Utils.Date.getStart(pageWrap.getModel().getFsDate())); |
| | | queryWrapper.le(Company::getFsDate, Utils.Date.getEnd(pageWrap.getModel().getFsDate())); |
| | | } |
| | | for(PageWrap.SortData sortData: pageWrap.getSorts()) { |
| | | if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { |
| | | queryWrapper.orderByDesc(sortData.getProperty()); |
| | | } else { |
| | | queryWrapper.orderByAsc(sortData.getProperty()); |
| | | } |
| | | } |
| | | return PageData.from(companyMapper.selectPage(page, queryWrapper)); |
| | | queryWrapper.orderByDesc(Company::getCreateDate); |
| | | queryWrapper.leftJoin(Category.class,Category::getId,Company::getCategoryId) |
| | | .leftJoin(SystemUser.class,SystemUser::getId,Company::getCreator); |
| | | queryWrapper.selectAll(Company.class) |
| | | .selectAs(Category::getName,Company::getCategoryName) |
| | | .selectAs(SystemUser::getRealname,Company::getCreatorName); |
| | | IPage<Company> companyIPage = companyJoinMapper.selectJoinPage(page, Company.class, queryWrapper); |
| | | return PageData.from(companyIPage); |
| | | } |
| | | |
| | | @Override |
| | |
| | | QueryWrapper<Company> wrapper = new QueryWrapper<>(company); |
| | | return companyMapper.selectCount(wrapper); |
| | | } |
| | | |
| | | /** |
| | | * å³å¡å
¬å¸å¯ä¸æ§æ ¡éª |
| | | * @param company |
| | | */ |
| | | private void checkUnique(Company company){ |
| | | QueryWrapper<Company> wrapper = new QueryWrapper<>(); |
| | | wrapper.lambda() |
| | | .eq(Company::getIsdeleted,Constants.ZERO) |
| | | .eq(Company::getType,Constants.ZERO) |
| | | .eq(Company::getName,company.getName()); |
| | | List<Company> companies = companyMapper.selectList(wrapper); |
| | | |
| | | if (CollectionUtils.isNotEmpty(companies)){ |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"ä¼ä¸ä¿¡æ¯å·²åå¨"); |
| | | } |
| | | } |
| | | } |