package cc.mrbird.febs.server.hr.service.impl; import cc.mrbird.febs.common.core.constant.ModuleCode; import cc.mrbird.febs.server.hr.entity.EmpBadRecord; import cc.mrbird.febs.server.hr.entity.EmpRemarkInfo; import cc.mrbird.febs.server.hr.entity.EmpRemarkInfo; import cc.mrbird.febs.server.hr.mapper.EmpRemarkInfoMapper; import cc.mrbird.febs.server.hr.service.IEmpRemarkinfoService; import cn.hutool.core.date.DateUtil; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Propagation; import lombok.RequiredArgsConstructor; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import cc.mrbird.febs.common.core.entity.QueryRequest; import cc.mrbird.febs.common.core.entity.system.Dept; import cc.mrbird.febs.common.core.utils.CastUtil; import cc.mrbird.febs.common.core.utils.FebsUtil; import cc.mrbird.febs.common.core.utils.SequenceUtil; import cc.mrbird.febs.common.redis.service.RedisService; import java.util.*; /** * name:EmpRemarkinfo * package:cc.mrbird.febs.server.hr.controller * description:员工备注信息服务接口实现 * * @author luoyibo * @date 2021-01-31 11:26:48 * @since JDK1.8 */ @Service @RequiredArgsConstructor @Transactional(propagation = Propagation.SUPPORTS, readOnly = true) class EmpRemarkInfoServiceImpl extends ServiceImpl implements IEmpRemarkinfoService { private final RedisService redisService; private final EmpRemarkInfoMapper empRemarkinfoMapper; private final String operatorId = Optional.ofNullable(FebsUtil.getCurrentUser()) .map(u -> u.getUserId().toString()) .orElse("1"); @Override public IPage findEmpRemarkinfos(QueryRequest request, EmpRemarkInfo empRemarkinfo) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(EmpRemarkInfo::getDelFlag, empRemarkinfo.getDelFlag()); if (StringUtils.isNotBlank(empRemarkinfo.getEmpNumb())) { queryWrapper.like(EmpRemarkInfo::getEmpNumb, empRemarkinfo.getEmpNumb()); } if (StringUtils.isNotBlank(empRemarkinfo.getEmpName())) { queryWrapper.like(EmpRemarkInfo::getEmpName, empRemarkinfo.getEmpName()); } if (StringUtils.isNotBlank(empRemarkinfo.getCertificateNumb())) { queryWrapper.like(EmpRemarkInfo::getCertificateNumb, empRemarkinfo.getCertificateNumb()); } if (StringUtils.isNotBlank(empRemarkinfo.getDeptName())) { queryWrapper.like(EmpRemarkInfo::getDeptName, empRemarkinfo.getDeptName()); } if (StringUtils.isNotBlank(empRemarkinfo.getRemarkDateStr())) { queryWrapper.between(EmpRemarkInfo::getRemarkDate, empRemarkinfo.getRemarkDateStr().split(",")[0], empRemarkinfo.getRemarkDateStr().split(",")[1]); } if (StringUtils.isNotBlank(empRemarkinfo.getRemarkContent())) { queryWrapper.like(EmpRemarkInfo::getRemarkContent, empRemarkinfo.getRemarkContent()); } Page page = new Page<>(request.getPageNum(), request.getPageSize()); return this.page(page, queryWrapper); } @Override public List findEmpRemarkinfos(EmpRemarkInfo empRemarkinfo) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(EmpRemarkInfo::getDelFlag, empRemarkinfo.getDelFlag()); return this.baseMapper.selectList(queryWrapper); } @Override @Transactional(rollbackFor = Exception.class) public void createEmpRemarkinfo(EmpRemarkInfo empRemarkinfo) { empRemarkinfo.setRemarkId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); empRemarkinfo.setCreator(operatorId); empRemarkinfo.setModifier(operatorId); this.save(empRemarkinfo); } @Override @Transactional(rollbackFor = Exception.class) public void updateEmpRemarkinfo(EmpRemarkInfo empRemarkinfo) { EmpRemarkInfo dbData = this.getById(empRemarkinfo.getRemarkId()); empRemarkinfo.setCreateTime(dbData.getCreateTime()); empRemarkinfo.setCreator(dbData.getCreator()); empRemarkinfo.setDelFlag(dbData.getDelFlag()); empRemarkinfo.setModifyTime(new Date()); empRemarkinfo.setModifier(operatorId); this.saveOrUpdate(empRemarkinfo); } @Override @Transactional(rollbackFor = Exception.class) public void deleteEmpRemarkinfo(EmpRemarkInfo empRemarkinfo) { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); // TODO 设置删除条件 this.remove(wrapper); } /** * 根据Id批量逻辑删除记录 *

* date 2021-01-28 10:48 * * @param ids 待删除Id * @return void * @author: luoyibo */ @Override @Transactional(rollbackFor = Exception.class) public void logicDelEmpRemarkinfo(String ids) { String[] str = ids.split(","); List list = new ArrayList<>(Arrays.asList(str)); empRemarkinfoMapper.logicDeleteByIds(list, operatorId); } @Override public boolean momentToNormal(String ids) { String[] str = ids.split(","); List list = new ArrayList<>(Arrays.asList(str)); return empRemarkinfoMapper.momentToNormal(list, operatorId)>0; } @Override @Transactional(rollbackFor = Exception.class) public void importEmpRemarkInfo(List> listObject) { for (List list : listObject) { EmpRemarkInfo empRemarkinfo=new EmpRemarkInfo(); empRemarkinfo.setRemarkId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE)); empRemarkinfo.setEmpNumb(list.get(0).toString()); List depts = CastUtil.castList(redisService.get("depts"), Dept.class); Long deptId = depts.stream().filter(d -> d.getDeptName().equals(list.get(1).toString())).findFirst().get() .getDeptId(); empRemarkinfo.setDeptName(list.get(1).toString()); empRemarkinfo.setDeptId(deptId); empRemarkinfo.setJobName(list.get(2).toString()); empRemarkinfo.setEmpName(list.get(3).toString()); empRemarkinfo.setCertificateNumb(list.get(4).toString()); if (StringUtils.isNotBlank(list.get(5).toString())) { empRemarkinfo.setRemarkDate(DateUtil.parseDateTime(list.get(5).toString())); } empRemarkinfo.setRemarkContent(list.get(6).toString()); this.save(empRemarkinfo); } } }