|  |  | 
 |  |  | package com.doumee.service.business.impl; | 
 |  |  |  | 
 |  |  | import com.doumee.biz.system.SystemDictDataBiz; | 
 |  |  | 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.SmsConstants; | 
 |  |  | import com.doumee.core.utils.Utils; | 
 |  |  | import com.doumee.dao.business.HiddenDangerParamMapper; | 
 |  |  | import com.doumee.dao.business.MemberMapper; | 
 |  |  | import com.doumee.dao.business.SmsConfigMapper; | 
 |  |  | import com.doumee.dao.business.SmsEmailMapper; | 
 |  |  | import com.doumee.dao.business.model.*; | 
 |  |  | import com.doumee.service.business.HiddenDangerParamService; | 
 |  |  | 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.doumee.service.business.third.EmayService; | 
 |  |  | import com.github.yulichang.wrapper.MPJLambdaWrapper; | 
 |  |  | import io.swagger.models.auth.In; | 
 |  |  | import org.apache.commons.lang3.StringUtils; | 
 |  |  | import org.apache.shiro.SecurityUtils; | 
 |  |  | import org.checkerframework.checker.units.qual.C; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | import org.springframework.stereotype.Service; | 
 |  |  | import org.springframework.util.CollectionUtils; | 
 |  |  | 
 |  |  |         } | 
 |  |  |         if(Constants.equalsInteger(model.getType(),Constants.ZERO)){ | 
 |  |  |             //如果是区域配置 | 
 |  |  |             if(model.getCompanyId() == null){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,请选择责任部门!"); | 
 |  |  |             } | 
 |  |  |             List<Integer> ids = model.getMemberIdList(); | 
 |  |  |             if(ids==null || ids.size() ==0){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,安全员信息不正确,请按要求填写内容!"); | 
 |  |  |             } | 
 |  |  |            List<Member>  memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda() | 
 |  |  |                     .eq(Member::getType,Constants.TWO) | 
 |  |  | //                    .eq(Member::getType,Constants.TWO) | 
 |  |  |                     .eq(Member::getCompanyId,model.getCompanyId()) | 
 |  |  |                     .in(Member::getId,ids) | 
 |  |  |                     .eq(Member::getIsdeleted,Constants.ZERO)); | 
 |  |  |             if(memberList == null || memberList.size() == 0 || memberList.size() != ids.size() ){ | 
 |  |  | 
 |  |  |         } | 
 |  |  |         if(Constants.equalsInteger(hiddenDangerParam.getType(),Constants.ZERO)){ | 
 |  |  |             //如果是区域配置,校验安全员信息是否正确 | 
 |  |  |             if(model.getCompanyId() == null){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,请选择责任部门!"); | 
 |  |  |             } | 
 |  |  |             List<Integer> ids =model.getMemberIdList(); | 
 |  |  |             if(ids==null || ids.size() ==0){ | 
 |  |  |                 throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起,安全员信息不正确,请按要求填写内容!"); | 
 |  |  |             } | 
 |  |  |             List<Member>  memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda() | 
 |  |  |                     .eq(Member::getType,Constants.TWO) | 
 |  |  |                     .eq(Member::getCompanyId,model.getCompanyId()) | 
 |  |  |                     .in(Member::getId,ids) | 
 |  |  |                     .eq(Member::getIsdeleted,Constants.ZERO)); | 
 |  |  |             if(memberList == null || memberList.size() == 0 || memberList.size() != ids.size() ){ | 
 |  |  | 
 |  |  |     @Override | 
 |  |  |     public PageData<HiddenDangerParam> findPage(PageWrap<HiddenDangerParam> pageWrap) { | 
 |  |  |         IPage<HiddenDangerParam> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
 |  |  |         QueryWrapper<HiddenDangerParam> queryWrapper = new QueryWrapper<>(); | 
 |  |  |         MPJLambdaWrapper<HiddenDangerParam> queryWrapper = new MPJLambdaWrapper<>(); | 
 |  |  |         Utils.MP.blankToNull(pageWrap.getModel()); | 
 |  |  |         pageWrap.getModel().setIsdeleted(Constants.ZERO); | 
 |  |  |         queryWrapper.lambda() | 
 |  |  |         queryWrapper. selectAll(HiddenDangerParam.class) | 
 |  |  |                 .selectAs(Company::getCompanyNamePath,HiddenDangerParam::getCompanyName) | 
 |  |  |                 .leftJoin(Company.class,Company::getId,HiddenDangerParam::getCompanyId) | 
 |  |  |                 .eq(pageWrap.getModel().getId() != null, HiddenDangerParam::getId, pageWrap.getModel().getId()) | 
 |  |  |                 .eq(pageWrap.getModel().getCreator() != null, HiddenDangerParam::getCreator, pageWrap.getModel().getCreator()) | 
 |  |  |                 .eq(pageWrap.getModel().getEditor() != null, HiddenDangerParam::getEditor, pageWrap.getModel().getEditor()) | 
 |  |  |                 .eq(pageWrap.getModel().getIsdeleted() != null, HiddenDangerParam::getIsdeleted, pageWrap.getModel().getIsdeleted()) | 
 |  |  |                 .like(pageWrap.getModel().getName() != null, HiddenDangerParam::getName, pageWrap.getModel().getName()) | 
 |  |  |                 .like(pageWrap.getModel().getCompanyName() != null, Company::getName, pageWrap.getModel().getCompanyName()) | 
 |  |  |                 .eq(pageWrap.getModel().getRemark() != null, HiddenDangerParam::getRemark, pageWrap.getModel().getRemark()) | 
 |  |  |                 .eq(pageWrap.getModel().getStatus() != null, HiddenDangerParam::getStatus, pageWrap.getModel().getStatus()) | 
 |  |  |                 .eq(pageWrap.getModel().getSortnum() != null, HiddenDangerParam::getSortnum, pageWrap.getModel().getSortnum()) | 
 |  |  | 
 |  |  |                 queryWrapper.orderByAsc(sortData.getProperty()); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         PageData<HiddenDangerParam> result = PageData.from(hiddenDangerParamMapper.selectPage(page, queryWrapper)); | 
 |  |  |         PageData<HiddenDangerParam> result = PageData.from(hiddenDangerParamMapper.selectJoinPage(page,HiddenDangerParam.class, queryWrapper)); | 
 |  |  |  | 
 |  |  |         return result; | 
 |  |  |     } |