| | |
|---|
| | | package org.springblade.modules.system.service.impl; |
|---|
| | | |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|---|
| | | import com.google.zxing.WriterException; |
|---|
| | | import lombok.AllArgsConstructor; |
|---|
| | | import org.springblade.common.cache.DictCache; |
|---|
| | | import org.springblade.common.cache.ParamCache; |
|---|
| | | import org.apache.commons.lang3.StringUtils; |
|---|
| | | import org.springblade.common.cache.SysCache; |
|---|
| | | import org.springblade.common.cache.UserCache; |
|---|
| | | import org.springblade.common.constant.AgeUtil; |
|---|
| | | import org.springblade.common.constant.CommonConstant; |
|---|
| | | import org.springblade.common.constant.TenantConstant; |
|---|
| | | import org.springblade.common.enums.DictEnum; |
|---|
| | | import org.springblade.common.utils.QRCodeUtil; |
|---|
| | | import org.springblade.core.log.exception.ServiceException; |
|---|
| | | import org.springblade.core.mp.base.BaseServiceImpl; |
|---|
| | |
|---|
| | | import org.springblade.core.tool.utils.*; |
|---|
| | | import org.springblade.modules.FTP.FtpUtil; |
|---|
| | | import org.springblade.modules.auth.enums.UserEnum; |
|---|
| | | import org.springblade.modules.dispatcher.service.IDispatcherService; |
|---|
| | | import org.springblade.modules.dispatcher.vo.DispatcherUnitVO; |
|---|
| | | import org.springblade.modules.dispatcher.vo.DispatcherVO; |
|---|
| | | import org.springblade.modules.information.entity.Information; |
|---|
| | | import org.springblade.modules.information.service.IInformationService; |
|---|
| | | import org.springblade.modules.jurisdiction.entity.Jurisdiction; |
|---|
| | | import org.springblade.modules.system.entity.*; |
|---|
| | | import org.springblade.modules.system.excel.QrCodeExcel; |
|---|
| | | import org.springblade.modules.system.excel.UserExcel; |
|---|
| | |
|---|
| | | import java.net.URLEncoder; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.*; |
|---|
| | | |
|---|
| | | import static org.springblade.common.constant.CommonConstant.DEFAULT_PARAM_PASSWORD; |
|---|
| | | import java.util.concurrent.atomic.AtomicBoolean; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 服务实现类 |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | // @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void importUser(List<UserExcel> data, Boolean isCovered,String deptId) { |
|---|
| | | //将不能导入的保安员账号存起来 |
|---|
| | | List<String> errorList = new ArrayList<>(); |
|---|
| | | //导入状态，默认为true ,如果有一个出现问题则为 false |
|---|
| | | AtomicBoolean status = new AtomicBoolean(true); |
|---|
| | | data.forEach(userExcel -> { |
|---|
| | | User user = Objects.requireNonNull(BeanUtil.copy(userExcel, User.class)); |
|---|
| | | //设置部门id |
|---|
| | |
|---|
| | | if (null!=deptIds && !deptIds.equals("")) { |
|---|
| | | if (null != deptId && !deptId.equals("")) { |
|---|
| | | if (!deptId.equals(deptIds)) { |
|---|
| | | throw new ServiceException("不能导入不是本公司的保安员数据!"); |
|---|
| | | throw new ServiceException("导入失败!不能导入不是本公司的保安员数据!"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | user.setDeptId(deptIds); |
|---|
| | | }else { |
|---|
| | | //如果deptIds 为空，则说明还没有改公司 |
|---|
| | | throw new ServiceException("公司名:"+user.getDeptId()+"不存在!"); |
|---|
| | | throw new ServiceException("导入失败!公司名:["+user.getDeptId()+"]不存在!"); |
|---|
| | | } |
|---|
| | | //判断当前用户是否已在本单位，如果是的更新数据 |
|---|
| | | User user1 = new User(); |
|---|
| | | user1.setAccount(user.getCardid()); |
|---|
| | | System.out.println("user.getCardid() = " + user.getCardid()); |
|---|
| | | // System.out.println("user.getCardid() = " + user.getCardid()); |
|---|
| | | user1.setIsDeleted(0); |
|---|
| | | user1.setStatus(1); |
|---|
| | | User user2 = this.getOne(Condition.getQueryWrapper(user1)); |
|---|
| | |
|---|
| | | //匹配组织机构是否一致,如果不一致 |
|---|
| | | if(!user2.getDeptId().equals(user.getDeptId())){ |
|---|
| | | Dept dept = deptService.getById(user2.getDeptId()); |
|---|
| | | throw new ServiceException("用户:"+"["+user.getCardid()+"]"+"已在["+dept.getDeptName()+"]存在!"); |
|---|
| | | // throw new ServiceException("用户:"+"["+user.getCardid()+"]"+"已在其他单位存在!"); |
|---|
| | | status.set(false); |
|---|
| | | //加入集合 |
|---|
| | | errorList.add(user.getCardid()); |
|---|
| | | //forEach 只能使用 return 跳出本次循环 |
|---|
| | | return; |
|---|
| | | }else { |
|---|
| | | //如果是一致，则更新用户数据 |
|---|
| | | //判断是否持证 |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | //如果所有数据导入有一个异常 |
|---|
| | | if (!status.get()){ |
|---|
| | | String errorAccount = StringUtils.join(errorList, "\\\n"); |
|---|
| | | throw new ServiceException("用户:["+errorAccount+"]导入失败!已在其他单位存在!"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // @Override |
|---|
