From e4e3f752792527c5c22df131c8dffa4733c98057 Mon Sep 17 00:00:00 2001 From: skyouc Date: 星期四, 05 六月 2025 15:05:11 +0800 Subject: [PATCH] 任务列表优化 DO单功能优化 出库单功能优化 --- rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeliveryServiceImpl.java | 33 +++++++++++++++++++++++++++++++++ 1 files changed, 33 insertions(+), 0 deletions(-) diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeliveryServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeliveryServiceImpl.java index 2147d90..b34fdcb 100644 --- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeliveryServiceImpl.java +++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/DeliveryServiceImpl.java @@ -1,12 +1,45 @@ package com.vincent.rsf.server.manager.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.vincent.rsf.framework.exception.CoolException; +import com.vincent.rsf.server.common.exception.BusinessException; +import com.vincent.rsf.server.manager.enums.AsnExceStatus; import com.vincent.rsf.server.manager.mapper.DeliveryMapper; import com.vincent.rsf.server.manager.entity.Delivery; +import com.vincent.rsf.server.manager.service.DeliveryItemService; import com.vincent.rsf.server.manager.service.DeliveryService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; + +import java.util.List; @Service("deliveryService") public class DeliveryServiceImpl extends ServiceImpl<DeliveryMapper, Delivery> implements DeliveryService { + @Autowired + private DeliveryItemService deliveryItemService; + + + @Override + public Delivery removeDo(List<Long> list) { + List<Delivery> deliveries = this.list(new LambdaQueryWrapper<Delivery>().eq(Delivery::getId, list)); + if (deliveries.isEmpty()) { + throw new BusinessException("鏁版嵁閿欒锛氬崟鎹俊鎭笉瀛樺湪锛侊紒"); + } + deliveries.forEach(delivery -> { + if (delivery.getExceStatus().equals(AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val)){ + if (!this.removeById(delivery.getId())) { + throw new CoolException("涓诲崟鍒犻櫎澶辫触锛侊紒"); + } + if (!deliveryItemService.removeById(delivery.getId())) { + throw new CoolException("鍗曟嵁鏄庣粏鍒犻櫎澶辫触锛�1"); + } + } else { + throw new CoolException("鍗曟嵁宸叉墽琛岋紝涓嶅彲鎵ц鍒犻櫎鎿嶄綔锛侊紒"); + } + }); + + return null; + } } -- Gitblit v1.9.1