package cn.lili.modules.purchase.serviceimpl; import cn.lili.common.security.context.UserContext; import cn.lili.common.utils.BeanUtil; import cn.lili.modules.purchase.entity.dos.PurchaseOrder; import cn.lili.modules.purchase.entity.dos.PurchaseOrderItem; import cn.lili.modules.purchase.entity.params.PurchaseOrderSearchParams; import cn.lili.modules.purchase.entity.vos.PurchaseOrderVO; import cn.lili.modules.purchase.mapper.PurchaseOrderMapper; import cn.lili.modules.purchase.service.PurchaseOrderItemService; import cn.lili.modules.purchase.service.PurchaseOrderService; import cn.lili.mybatis.util.PageUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; /** * 采购单业务层实现 * * @author Bulbasaur * @since 2020/11/26 16:13 */ @Service public class PurchaseOrderServiceImpl extends ServiceImpl implements PurchaseOrderService { @Autowired private PurchaseOrderItemService purchaseOrderItemService; @Override @Transactional(rollbackFor = Exception.class) public PurchaseOrderVO addPurchaseOrder(PurchaseOrderVO purchaseOrderVO) { PurchaseOrder purchaseOrder = new PurchaseOrder(); BeanUtil.copyProperties(purchaseOrderVO, purchaseOrder); //添加采购单 purchaseOrder.setStatus("OPEN"); purchaseOrder.setMemberId(UserContext.getCurrentUser().getId()); this.save(purchaseOrder); //添加采购单子内容 purchaseOrderItemService.addPurchaseOrderItem(purchaseOrder.getId(), purchaseOrderVO.getPurchaseOrderItems()); return purchaseOrderVO; } @Override public PurchaseOrderVO getPurchaseOrder(String id) { PurchaseOrderVO purchaseOrderVO = new PurchaseOrderVO(); //获取采购单内容 PurchaseOrder purchaseOrder = this.getById(id); BeanUtil.copyProperties(purchaseOrder, purchaseOrderVO); //获取采购单子内容 purchaseOrderVO.setPurchaseOrderItems(purchaseOrderItemService.list( new LambdaQueryWrapper().eq(PurchaseOrderItem::getPurchaseOrderId,id))); return purchaseOrderVO; } @Override public IPage page(PurchaseOrderSearchParams purchaseOrderSearchParams) { LambdaQueryWrapper lambdaQueryWrapper = Wrappers.lambdaQuery(); lambdaQueryWrapper.eq(purchaseOrderSearchParams.getMemberId() != null, PurchaseOrder::getMemberId, purchaseOrderSearchParams.getMemberId()); lambdaQueryWrapper.eq(purchaseOrderSearchParams.getCategoryId() != null, PurchaseOrder::getCategoryId, purchaseOrderSearchParams.getCategoryId()); lambdaQueryWrapper.eq(purchaseOrderSearchParams.getStatus() != null, PurchaseOrder::getStatus, purchaseOrderSearchParams.getStatus()); lambdaQueryWrapper.orderByDesc(PurchaseOrder::getCreateTime); return this.page(PageUtil.initPage(purchaseOrderSearchParams), lambdaQueryWrapper); } @Override @Transactional(rollbackFor = Exception.class) public boolean close(String id) { PurchaseOrder purchaseOrder = this.getById(id); purchaseOrder.setStatus("CLOSE"); UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.eq("id", id); updateWrapper.set("status", "CLOSE"); return this.update(updateWrapper); } }