| package doumeemes.service.business.impl; | 
|   | 
| import doumeemes.core.model.LoginUserInfo; | 
| import doumeemes.core.model.PageData; | 
| import doumeemes.core.model.PageWrap; | 
| import doumeemes.core.utils.Constants; | 
| import doumeemes.core.utils.Utils; | 
| import doumeemes.dao.business.UnitConversionMapper; | 
| import doumeemes.dao.business.model.UnitConversion; | 
| import doumeemes.service.business.UnitConversionService; | 
| 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 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 江蹄蹄 | 
|  * @date 2022/04/20 09:37 | 
|  */ | 
| @Service | 
| public class UnitConversionServiceImpl implements UnitConversionService { | 
|   | 
|     @Autowired | 
|     private UnitConversionMapper unitConversionMapper; | 
|   | 
|     @Override | 
|     public Integer create(UnitConversion unitConversion) { | 
|         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
|         unitConversion.setDeleted(Constants.ZERO); | 
|         unitConversion.setCreateUser(user.getId()); | 
|         unitConversion.setCreateTime(new Date()); | 
|         unitConversion.setRootDepartId(user.getRootDepartment().getId()); | 
|         unitConversion.setOrigin(Constants.ONE); | 
|         unitConversionMapper.insert(unitConversion); | 
|         return unitConversion.getId(); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteById(UnitConversion unitConversion) { | 
|         unitConversionMapper.updateById(unitConversion); | 
|     } | 
|   | 
|     @Override | 
|     public void delete(UnitConversion unitConversion) { | 
|         UpdateWrapper<UnitConversion> deleteWrapper = new UpdateWrapper<>(unitConversion); | 
|         unitConversionMapper.delete(deleteWrapper); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteByIdInBatch(List<Integer> ids) { | 
|         if (CollectionUtils.isEmpty(ids)) { | 
|             return; | 
|         } | 
|         for(Integer id:ids){ | 
|             UnitConversion unitConversion=this.findById(id); | 
|             unitConversion.setDeleted(Constants.ONE); | 
|             unitConversionMapper.updateById(unitConversion); | 
|         } | 
|     } | 
|   | 
|     @Override | 
|     public void updateById(UnitConversion unitConversion) { | 
|         LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); | 
|   | 
|   | 
|         UnitConversion find=this.findById(unitConversion.getId()); | 
|         find.setUpdateTime(new Date()); | 
|         find.setUpdateUser(user.getId()); | 
|         find.setMaterialId(unitConversion.getMaterialId()); | 
|         find.setConvertedType(unitConversion.getConvertedType()); | 
|         find.setConvertedNum(unitConversion.getConvertedNum()); | 
|         find.setConvertedId(unitConversion.getConvertedId()); | 
|         find.setUnitType(unitConversion.getUnitType()); | 
|         find.setUnitId(unitConversion.getUnitId()); | 
|         find.setUnitNum(unitConversion.getUnitNum()); | 
|         unitConversionMapper.updateById(find); | 
|     } | 
|   | 
|   | 
|     @Override | 
|     public void updateByIdInBatch(List<UnitConversion> unitConversions) { | 
|         if (CollectionUtils.isEmpty(unitConversions)) { | 
|             return; | 
|         } | 
|         for (UnitConversion unitConversion: unitConversions) { | 
|             this.updateById(unitConversion); | 
|         } | 
|     } | 
|   | 
|     @Override | 
|     public UnitConversion findById(Integer id) { | 
|         return unitConversionMapper.selectById(id); | 
|     } | 
|   | 
|     @Override | 
|     public UnitConversion findOne(UnitConversion unitConversion) { | 
|         QueryWrapper<UnitConversion> wrapper = new QueryWrapper<>(unitConversion); | 
|         return unitConversionMapper.selectOne(wrapper); | 
|     } | 
|   | 
|     @Override | 
|     public List<UnitConversion> findList(UnitConversion unitConversion) { | 
|         QueryWrapper<UnitConversion> wrapper = new QueryWrapper<>(unitConversion); | 
|         return unitConversionMapper.selectList(wrapper); | 
|     } | 
|    | 
|     @Override | 
|     public PageData<UnitConversion> findPage(PageWrap<UnitConversion> pageWrap) { | 
|         IPage<UnitConversion> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|         QueryWrapper<UnitConversion> queryWrapper = new QueryWrapper<>(); | 
|         Utils.MP.blankToNull(pageWrap.getModel()); | 
|         if (pageWrap.getModel().getId() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getId, pageWrap.getModel().getId()); | 
|         } | 
|         if (pageWrap.getModel().getDeleted() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getDeleted, pageWrap.getModel().getDeleted()); | 
|         } | 
|         if (pageWrap.getModel().getCreateUser() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getCreateUser, pageWrap.getModel().getCreateUser()); | 
|         } | 
|         if (pageWrap.getModel().getCreateTime() != null) { | 
|             queryWrapper.lambda().ge(UnitConversion::getCreateTime, Utils.Date.getStart(pageWrap.getModel().getCreateTime())); | 
|             queryWrapper.lambda().le(UnitConversion::getCreateTime, Utils.Date.getEnd(pageWrap.getModel().getCreateTime())); | 
|         } | 
|         if (pageWrap.getModel().getUpdateUser() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getUpdateUser, pageWrap.getModel().getUpdateUser()); | 
|         } | 
|         if (pageWrap.getModel().getUpdateTime() != null) { | 
|             queryWrapper.lambda().ge(UnitConversion::getUpdateTime, Utils.Date.getStart(pageWrap.getModel().getUpdateTime())); | 
|             queryWrapper.lambda().le(UnitConversion::getUpdateTime, Utils.Date.getEnd(pageWrap.getModel().getUpdateTime())); | 
|         } | 
|         if (pageWrap.getModel().getRemark() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getRemark, pageWrap.getModel().getRemark()); | 
|         } | 
|         if (pageWrap.getModel().getRootDepartId() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getRootDepartId, pageWrap.getModel().getRootDepartId()); | 
|         } | 
|         if (pageWrap.getModel().getMaterialId() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getMaterialId, pageWrap.getModel().getMaterialId()); | 
|         } | 
|         if (pageWrap.getModel().getOrigin() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getOrigin, pageWrap.getModel().getOrigin()); | 
|         } | 
|         if (pageWrap.getModel().getConvertedType() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getConvertedType, pageWrap.getModel().getConvertedType()); | 
|         } | 
|         if (pageWrap.getModel().getConvertedId() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getConvertedId, pageWrap.getModel().getConvertedId()); | 
|         } | 
|         if (pageWrap.getModel().getConvertedNum() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getConvertedNum, pageWrap.getModel().getConvertedNum()); | 
|         } | 
|         if (pageWrap.getModel().getConvertedRatio() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getConvertedRatio, pageWrap.getModel().getConvertedRatio()); | 
|         } | 
|         if (pageWrap.getModel().getUnitType() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getUnitType, pageWrap.getModel().getUnitType()); | 
|         } | 
|         if (pageWrap.getModel().getUnitId() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getUnitId, pageWrap.getModel().getUnitId()); | 
|         } | 
|         if (pageWrap.getModel().getUnitNum() != null) { | 
|             queryWrapper.lambda().eq(UnitConversion::getUnitNum, pageWrap.getModel().getUnitNum()); | 
|         } | 
|         for(PageWrap.SortData sortData: pageWrap.getSorts()) { | 
|             if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { | 
|                 queryWrapper.orderByDesc(sortData.getProperty()); | 
|             } else { | 
|                 queryWrapper.orderByAsc(sortData.getProperty()); | 
|             } | 
|         } | 
|         return PageData.from(unitConversionMapper.selectPage(page, queryWrapper)); | 
|     } | 
|   | 
|     @Override | 
|     public long count(UnitConversion unitConversion) { | 
|         QueryWrapper<UnitConversion> wrapper = new QueryWrapper<>(unitConversion); | 
|         return unitConversionMapper.selectCount(wrapper); | 
|     } | 
| } |