| package com.doumee.service.business.impl; | 
|   | 
| import com.doumee.core.model.PageData; | 
| import com.doumee.core.model.PageWrap; | 
| import com.doumee.core.utils.Utils; | 
| import com.doumee.dao.business.ReceiveWeightMapper; | 
| import com.doumee.dao.business.model.ReceiveWeight; | 
| import com.doumee.service.business.ReceiveWeightService; | 
| 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.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.stereotype.Service; | 
| import org.springframework.util.CollectionUtils; | 
|   | 
| import java.util.List; | 
|   | 
| /** | 
|  * 接单权重配置表Service实现 | 
|  * @author 江蹄蹄 | 
|  * @date 2025/07/09 12:00 | 
|  */ | 
| @Service | 
| public class ReceiveWeightServiceImpl implements ReceiveWeightService { | 
|   | 
|     @Autowired | 
|     private ReceiveWeightMapper receiveWeightMapper; | 
|   | 
|     @Override | 
|     public Integer create(ReceiveWeight receiveWeight) { | 
|         receiveWeightMapper.insert(receiveWeight); | 
|         return receiveWeight.getId(); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteById(Integer id) { | 
|         receiveWeightMapper.deleteById(id); | 
|     } | 
|   | 
|     @Override | 
|     public void delete(ReceiveWeight receiveWeight) { | 
|         UpdateWrapper<ReceiveWeight> deleteWrapper = new UpdateWrapper<>(receiveWeight); | 
|         receiveWeightMapper.delete(deleteWrapper); | 
|     } | 
|   | 
|     @Override | 
|     public void deleteByIdInBatch(List<Integer> ids) { | 
|         if (CollectionUtils.isEmpty(ids)) { | 
|             return; | 
|         } | 
|         receiveWeightMapper.deleteBatchIds(ids); | 
|     } | 
|   | 
|     @Override | 
|     public void updateById(ReceiveWeight receiveWeight) { | 
|         receiveWeightMapper.updateById(receiveWeight); | 
|     } | 
|   | 
|     @Override | 
|     public void updateByIdInBatch(List<ReceiveWeight> receiveWeights) { | 
|         if (CollectionUtils.isEmpty(receiveWeights)) { | 
|             return; | 
|         } | 
|         for (ReceiveWeight receiveWeight: receiveWeights) { | 
|             this.updateById(receiveWeight); | 
|         } | 
|     } | 
|   | 
|     @Override | 
|     public ReceiveWeight findById(Integer id) { | 
|         return receiveWeightMapper.selectById(id); | 
|     } | 
|   | 
|     @Override | 
|     public ReceiveWeight findOne(ReceiveWeight receiveWeight) { | 
|         QueryWrapper<ReceiveWeight> wrapper = new QueryWrapper<>(receiveWeight); | 
|         return receiveWeightMapper.selectOne(wrapper); | 
|     } | 
|   | 
|     @Override | 
|     public List<ReceiveWeight> findList(ReceiveWeight receiveWeight) { | 
|         QueryWrapper<ReceiveWeight> wrapper = new QueryWrapper<>(receiveWeight); | 
|         return receiveWeightMapper.selectList(wrapper); | 
|     } | 
|    | 
|     @Override | 
|     public PageData<ReceiveWeight> findPage(PageWrap<ReceiveWeight> pageWrap) { | 
|         IPage<ReceiveWeight> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); | 
|         QueryWrapper<ReceiveWeight> queryWrapper = new QueryWrapper<>(); | 
|         Utils.MP.blankToNull(pageWrap.getModel()); | 
|         if (pageWrap.getModel().getId() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getId, pageWrap.getModel().getId()); | 
|         } | 
|         if (pageWrap.getModel().getDeleted() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getDeleted, pageWrap.getModel().getDeleted()); | 
|         } | 
|         if (pageWrap.getModel().getStatus() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getStatus, pageWrap.getModel().getStatus()); | 
|         } | 
|         if (pageWrap.getModel().getCreateUser() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getCreateUser, pageWrap.getModel().getCreateUser()); | 
|         } | 
|         if (pageWrap.getModel().getCreateTime() != null) { | 
|             queryWrapper.lambda().ge(ReceiveWeight::getCreateTime, Utils.Date.getStart(pageWrap.getModel().getCreateTime())); | 
|             queryWrapper.lambda().le(ReceiveWeight::getCreateTime, Utils.Date.getEnd(pageWrap.getModel().getCreateTime())); | 
|         } | 
|         if (pageWrap.getModel().getUpdateUser() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getUpdateUser, pageWrap.getModel().getUpdateUser()); | 
|         } | 
|         if (pageWrap.getModel().getUpdateTime() != null) { | 
|             queryWrapper.lambda().ge(ReceiveWeight::getUpdateTime, Utils.Date.getStart(pageWrap.getModel().getUpdateTime())); | 
|             queryWrapper.lambda().le(ReceiveWeight::getUpdateTime, Utils.Date.getEnd(pageWrap.getModel().getUpdateTime())); | 
|         } | 
|         if (pageWrap.getModel().getRemark() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getRemark, pageWrap.getModel().getRemark()); | 
|         } | 
|         if (pageWrap.getModel().getReceiveMax() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getReceiveMax, pageWrap.getModel().getReceiveMax()); | 
|         } | 
|         if (pageWrap.getModel().getReceiveMin() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getReceiveMin, pageWrap.getModel().getReceiveMin()); | 
|         } | 
|         if (pageWrap.getModel().getLevel() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getLevel, pageWrap.getModel().getLevel()); | 
|         } | 
|         if (pageWrap.getModel().getDelayTime() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getDelayTime, pageWrap.getModel().getDelayTime()); | 
|         } | 
|         if (pageWrap.getModel().getSortnum() != null) { | 
|             queryWrapper.lambda().eq(ReceiveWeight::getSortnum, pageWrap.getModel().getSortnum()); | 
|         } | 
|         for(PageWrap.SortData sortData: pageWrap.getSorts()) { | 
|             if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { | 
|                 queryWrapper.orderByDesc(sortData.getProperty()); | 
|             } else { | 
|                 queryWrapper.orderByAsc(sortData.getProperty()); | 
|             } | 
|         } | 
|         return PageData.from(receiveWeightMapper.selectPage(page, queryWrapper)); | 
|     } | 
|   | 
|     @Override | 
|     public long count(ReceiveWeight receiveWeight) { | 
|         QueryWrapper<ReceiveWeight> wrapper = new QueryWrapper<>(receiveWeight); | 
|         return receiveWeightMapper.selectCount(wrapper); | 
|     } | 
| } |