package doumeemes.service.business.impl; 
 | 
  
 | 
import doumeemes.core.model.PageData; 
 | 
import doumeemes.core.model.PageWrap; 
 | 
import doumeemes.core.utils.Utils; 
 | 
import doumeemes.dao.business.PlanImportMapper; 
 | 
import doumeemes.dao.business.model.PlanImport; 
 | 
import doumeemes.service.business.PlanImportService; 
 | 
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 2022/04/20 09:34 
 | 
 */ 
 | 
@Service 
 | 
public class PlanImportServiceImpl implements PlanImportService { 
 | 
  
 | 
    @Autowired 
 | 
    private PlanImportMapper planImportMapper; 
 | 
  
 | 
    @Override 
 | 
    public Integer create(PlanImport planImport) { 
 | 
        planImportMapper.insert(planImport); 
 | 
        return planImport.getId(); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void deleteById(Integer id) { 
 | 
        planImportMapper.deleteById(id); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void delete(PlanImport planImport) { 
 | 
        UpdateWrapper<PlanImport> deleteWrapper = new UpdateWrapper<>(planImport); 
 | 
        planImportMapper.delete(deleteWrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void deleteByIdInBatch(List<Integer> ids) { 
 | 
        if (CollectionUtils.isEmpty(ids)) { 
 | 
            return; 
 | 
        } 
 | 
        planImportMapper.deleteBatchIds(ids); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updateById(PlanImport planImport) { 
 | 
        planImportMapper.updateById(planImport); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updateByIdInBatch(List<PlanImport> planImports) { 
 | 
        if (CollectionUtils.isEmpty(planImports)) { 
 | 
            return; 
 | 
        } 
 | 
        for (PlanImport planImport: planImports) { 
 | 
            this.updateById(planImport); 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public PlanImport findById(Integer id) { 
 | 
        return planImportMapper.selectById(id); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public PlanImport findOne(PlanImport planImport) { 
 | 
        QueryWrapper<PlanImport> wrapper = new QueryWrapper<>(planImport); 
 | 
        return planImportMapper.selectOne(wrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public List<PlanImport> findList(PlanImport planImport) { 
 | 
        QueryWrapper<PlanImport> wrapper = new QueryWrapper<>(planImport); 
 | 
        return planImportMapper.selectList(wrapper); 
 | 
    } 
 | 
   
 | 
    @Override 
 | 
    public PageData<PlanImport> findPage(PageWrap<PlanImport> pageWrap) { 
 | 
        IPage<PlanImport> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); 
 | 
        QueryWrapper<PlanImport> queryWrapper = new QueryWrapper<>(); 
 | 
        Utils.MP.blankToNull(pageWrap.getModel()); 
 | 
        if (pageWrap.getModel().getId() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getId, pageWrap.getModel().getId()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getDeleted() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getDeleted, pageWrap.getModel().getDeleted()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getCreateUser() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getCreateUser, pageWrap.getModel().getCreateUser()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getCreateTime() != null) { 
 | 
            queryWrapper.lambda().ge(PlanImport::getCreateTime, Utils.Date.getStart(pageWrap.getModel().getCreateTime())); 
 | 
            queryWrapper.lambda().le(PlanImport::getCreateTime, Utils.Date.getEnd(pageWrap.getModel().getCreateTime())); 
 | 
        } 
 | 
        if (pageWrap.getModel().getUpdateUser() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getUpdateUser, pageWrap.getModel().getUpdateUser()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getUpdateTime() != null) { 
 | 
            queryWrapper.lambda().ge(PlanImport::getUpdateTime, Utils.Date.getStart(pageWrap.getModel().getUpdateTime())); 
 | 
            queryWrapper.lambda().le(PlanImport::getUpdateTime, Utils.Date.getEnd(pageWrap.getModel().getUpdateTime())); 
 | 
        } 
 | 
        if (pageWrap.getModel().getRemark() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getRemark, pageWrap.getModel().getRemark()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getRootDepartId() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getRootDepartId, pageWrap.getModel().getRootDepartId()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getDepartId() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getDepartId, pageWrap.getModel().getDepartId()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getFileUrl() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getFileUrl, pageWrap.getModel().getFileUrl()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getStatus() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getStatus, pageWrap.getModel().getStatus()); 
 | 
        } 
 | 
        if (pageWrap.getModel().getFileName() != null) { 
 | 
            queryWrapper.lambda().eq(PlanImport::getFileName, pageWrap.getModel().getFileName()); 
 | 
        } 
 | 
        for(PageWrap.SortData sortData: pageWrap.getSorts()) { 
 | 
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { 
 | 
                queryWrapper.orderByDesc(sortData.getProperty()); 
 | 
            } else { 
 | 
                queryWrapper.orderByAsc(sortData.getProperty()); 
 | 
            } 
 | 
        } 
 | 
        return PageData.from(planImportMapper.selectPage(page, queryWrapper)); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public long count(PlanImport planImport) { 
 | 
        QueryWrapper<PlanImport> wrapper = new QueryWrapper<>(planImport); 
 | 
        return planImportMapper.selectCount(wrapper); 
 | 
    } 
 | 
} 
 |