package com.doumee.service.business.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.doumee.core.constants.Constants; 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.Utils; import com.doumee.dao.business.ManagersMapper; import com.doumee.dao.business.MemberMapper; import com.doumee.dao.business.model.Managers; import com.doumee.dao.business.model.Member; import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.ManagersService; 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 io.swagger.models.auth.In; 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; /** * 责任人信息表Service实现 * @author 江蹄蹄 * @since 2025/04/02 17:49 */ @Service public class ManagersServiceImpl implements ManagersService { @Autowired private ManagersMapper managersMapper; @Autowired private MemberMapper memberMapper; @Override public Integer create(Managers managers) { Member member =memberMapper.selectById(managers.getMemberId()); if(member == null || Constants.equalsInteger(member.getIsdeleted(),Constants.ONE)){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起,该负责人信息不存在,请刷新页面重试!"); } Managers model =managersMapper.selectOne(new LambdaQueryWrapper().eq(Managers::getMemberId,managers.getMemberId()) .eq(Managers::getType,managers.getType()) .eq(Managers::getIsdeleted,Constants.ZERO) ); if(model !=null){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"该人员信息已设置,无需重新添加"); } LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); managers.setCreator(user.getId()); managers.setCreateDate(new Date()); managers.setIsdeleted(Constants.ZERO); managers.setEditor(managers.getCreator()); managers.setEditDate(managers.getCreateDate()); managers.setStatus(Constants.ZERO); managersMapper.insert(managers); return managers.getId(); } @Override public void deleteById(Integer id) { Managers managers = new Managers(); managers.setId(id); LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); managers.setEditor(user.getId()); managers.setEditDate(new Date()); managers.setIsdeleted(Constants.ONE); managersMapper.updateById(managers); } @Override public void delete(Managers managers) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(managers); managersMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } for(Integer id :ids){ deleteById(id); } } @Override public void updateById(Managers managers) { LoginUserInfo user = new LoginUserInfo(); managers.setEditor(user.getId()); managers.setEditDate(new Date()); managersMapper.updateById(managers); } @Override public void updateByIdInBatch(List managerss) { if (CollectionUtils.isEmpty(managerss)) { return; } for (Managers managers: managerss) { this.updateById(managers); } } @Override public Managers findById(Integer id) { return managersMapper.selectById(id); } @Override public Managers findOne(Managers managers) { QueryWrapper wrapper = new QueryWrapper<>(managers); return managersMapper.selectOne(wrapper); } @Override public List findList(Managers pageWrap) { MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); pageWrap.setIsdeleted(Constants.ZERO); queryWrapper.selectAll(Managers.class ) .selectAs(Member::getPhone,Managers::getMemberPhone) .selectAs(Member::getName,Managers::getMemberName) .selectAs(Member::getEmail,Managers::getMemberEmail) .selectAs(Member::getCompanyName,Managers::getCompanyName) .selectAs(SystemUser::getUsername,Managers::getEditorName) .leftJoin(Member.class,Member::getId,Managers::getMemberId) .leftJoin(SystemUser.class,SystemUser::getId,Managers::getEditor) .eq(pageWrap.getId() != null, Managers::getId, pageWrap.getId()) .eq(pageWrap.getCreator() != null, Managers::getCreator, pageWrap.getCreator()) .ge(pageWrap.getCreateDate() != null, Managers::getCreateDate, Utils.Date.getStart(pageWrap.getCreateDate())) .le(pageWrap.getCreateDate() != null, Managers::getCreateDate, Utils.Date.getEnd(pageWrap.getCreateDate())) .eq(pageWrap.getEditor() != null, Managers::getEditor, pageWrap.getEditor()) .ge(pageWrap.getEditDate() != null, Managers::getEditDate, Utils.Date.getStart(pageWrap.getEditDate())) .le(pageWrap.getEditDate() != null, Managers::getEditDate, Utils.Date.getEnd(pageWrap.getEditDate())) .eq(pageWrap.getIsdeleted() != null, Managers::getIsdeleted, pageWrap.getIsdeleted()) .eq(pageWrap.getCategoryId() != null, Managers::getCategoryId, pageWrap.getCategoryId()) .eq(pageWrap.getRemark() != null, Managers::getRemark, pageWrap.getRemark()) .eq(pageWrap.getStatus() != null, Managers::getStatus, pageWrap.getStatus()) .eq(pageWrap.getSortnum() != null, Managers::getSortnum, pageWrap.getSortnum()) .eq(pageWrap.getType() != null, Managers::getType, pageWrap.getType()) .eq(pageWrap.getMemberId() != null, Managers::getMemberId, pageWrap.getMemberId()) .like(pageWrap.getMemberName() != null, Member::getName, pageWrap.getMemberName()); if (pageWrap.getKeyword() != null) { queryWrapper.and( ms->ms.like(Member::getName,pageWrap.getKeyword()) .or().like(Member::getPhone,pageWrap.getKeyword()) .or().like(Member::getCompanyName,pageWrap .getKeyword())); } queryWrapper.orderByDesc(Managers::getEditDate); return managersMapper.selectJoinList( Managers.class, queryWrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); pageWrap.getModel().setIsdeleted(Constants.ZERO); queryWrapper.selectAll(Managers.class ) .selectAs(Member::getPhone,Managers::getMemberPhone) .selectAs(Member::getName,Managers::getMemberName) .selectAs(Member::getEmail,Managers::getMemberEmail) .selectAs(Member::getCompanyName,Managers::getCompanyName) .selectAs(SystemUser::getUsername,Managers::getEditorName) .leftJoin(Member.class,Member::getId,Managers::getMemberId) .leftJoin(SystemUser.class,SystemUser::getId,Managers::getEditor) .eq(pageWrap.getModel().getId() != null, Managers::getId, pageWrap.getModel().getId()) .eq(pageWrap.getModel().getCreator() != null, Managers::getCreator, pageWrap.getModel().getCreator()) .ge(pageWrap.getModel().getCreateDate() != null, Managers::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())) .le(pageWrap.getModel().getCreateDate() != null, Managers::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())) .eq(pageWrap.getModel().getEditor() != null, Managers::getEditor, pageWrap.getModel().getEditor()) .ge(pageWrap.getModel().getEditDate() != null, Managers::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())) .le(pageWrap.getModel().getEditDate() != null, Managers::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())) .eq(pageWrap.getModel().getIsdeleted() != null, Managers::getIsdeleted, pageWrap.getModel().getIsdeleted()) .eq(pageWrap.getModel().getCategoryId() != null, Managers::getCategoryId, pageWrap.getModel().getCategoryId()) .eq(pageWrap.getModel().getRemark() != null, Managers::getRemark, pageWrap.getModel().getRemark()) .eq(pageWrap.getModel().getStatus() != null, Managers::getStatus, pageWrap.getModel().getStatus()) .eq(pageWrap.getModel().getSortnum() != null, Managers::getSortnum, pageWrap.getModel().getSortnum()) .eq(pageWrap.getModel().getType() != null, Managers::getType, pageWrap.getModel().getType()) .eq(pageWrap.getModel().getMemberId() != null, Managers::getMemberId, pageWrap.getModel().getMemberId()) .like(pageWrap.getModel().getMemberName() != null, Member::getName, pageWrap.getModel().getMemberName()); if (pageWrap.getModel().getKeyword() != null) { queryWrapper.and( ms->ms.like(Member::getName,pageWrap.getModel().getKeyword()) .or().like(Member::getPhone,pageWrap.getModel().getKeyword()) .or().like(Member::getCompanyName,pageWrap.getModel().getKeyword())); } queryWrapper.orderByDesc(Managers::getEditDate); return PageData.from(managersMapper.selectJoinPage(page,Managers.class, queryWrapper)); } @Override public long count(Managers managers) { QueryWrapper wrapper = new QueryWrapper<>(managers); return managersMapper.selectCount(wrapper); } }