From 21a2b9eafcfa7fd676df93d0d7b199c54cdaedd0 Mon Sep 17 00:00:00 2001 From: liweidong-hj Date: Wed, 4 Mar 2026 14:34:00 +0800 Subject: [PATCH] =?UTF-8?q?=E7=89=A9=E6=B5=81=E7=8A=B6=E6=80=81=E6=8F=90?= =?UTF-8?q?=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../desk/logistics/pojo/entity/Task.java | 44 ++++++++---- .../controller/OrderBoxController.java | 6 +- .../controller/PipelineController.java | 2 + .../desk/logistics/mapper/TaskMapper.java | 3 + .../desk/logistics/mapper/TaskMapper.xml | 7 ++ ...tionService.java => ILocationService.java} | 2 +- ...indService.java => IOrderBindService.java} | 2 +- ...rBoxService.java => IOrderBoxService.java} | 2 +- .../logistics/service/IPipelineService.java | 7 ++ ...ationService.java => IStationService.java} | 2 +- .../{TaskService.java => ITaskService.java} | 19 ++++- .../service/impl/LocationServiceImpl.java | 4 +- .../service/impl/OrderBindServiceImpl.java | 7 +- .../service/impl/OrderBoxServiceImpl.java | 5 +- .../service/impl/PipelineServiceImpl.java | 72 ++++++++++++------- .../service/impl/StationServiceImpl.java | 7 +- .../service/impl/TaskServiceImpl.java | 24 +++++-- 17 files changed, 150 insertions(+), 65 deletions(-) rename blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/{LocationService.java => ILocationService.java} (95%) rename blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/{OrderBindService.java => IOrderBindService.java} (94%) rename blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/{OrderBoxService.java => IOrderBoxService.java} (84%) rename blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/{StationService.java => IStationService.java} (95%) rename blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/{TaskService.java => ITaskService.java} (71%) diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java index 40fbc770..66a13cec 100644 --- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java +++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/Task.java @@ -24,34 +24,54 @@ public class Task extends BaseEntity { private static final long serialVersionUID = 1L; /** - * 状态常量:退回(超重) + * 起点位置 */ - public static final Integer STATUS_RETURNED = 0; + public static final Integer STATUS_START = 0; /** - * 状态常量:站点 + * 输送线起点 */ - public static final Integer STATUS_STATION = 1; + public static final Integer STATUS_CONVEYOR_START = 1; /** - * 状态常量:库位 + * 退回(超重) */ - public static final Integer STATUS_LOCATION = 2; + public static final Integer STATUS_RETURNED = 2; /** - * 状态常量:等待 + * 输送线末尾 */ - public static final Integer STATUS_WAITING = 3; + public static final Integer STATUS_CONVEYOR_END = 3; /** - * 状态常量:回库 + * 站点 */ - public static final Integer STATUS_BACK_TO_STORAGE = 4; + public static final Integer STATUS_STATION = 4; /** - * 状态常量:结束 + * 库位 */ - public static final Integer STATUS_FINISHED = 5; + public static final Integer STATUS_LOCATION = 5; + + /** + * 等待 + */ + public static final Integer STATUS_WAITING = 6; + + /** + * 站点接收 + */ + public static final Integer STATUS_STATION_RECEIVE = 7; + + /** + * 回库 + */ + public static final Integer STATUS_BACK_TO_STORAGE = 8; + + /** + * 结束 + */ + public static final Integer STATUS_FINISHED = 9; /** * ID主键 diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/OrderBoxController.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/OrderBoxController.java index 4e2b546c..587bd336 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/OrderBoxController.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/OrderBoxController.java @@ -6,7 +6,7 @@ import io.swagger.v3.oas.annotations.tags.Tag; import lombok.AllArgsConstructor; import org.springblade.core.boot.ctrl.BladeController; import org.springblade.core.tool.api.R; -import org.springblade.desk.logistics.service.OrderBoxService; +import org.springblade.desk.logistics.service.IOrderBoxService; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; @@ -22,7 +22,7 @@ import java.math.BigDecimal; @RequestMapping("/order") @Tag(name = "订单箱子", description = "订单箱子称重接口") public class OrderBoxController extends BladeController { - private final OrderBoxService orderBoxService; + private final IOrderBoxService IOrderBoxService; @PostMapping("/getWeighing") @@ -44,7 +44,7 @@ public class OrderBoxController extends BladeController { if (actualWeight == null || new BigDecimal(actualWeight).compareTo(BigDecimal.ZERO) < 0) { return R.fail("实际重量必须为非负数"); } - return orderBoxService.upholdOrderPartWeight(cardNo,new BigDecimal(actualWeight)); + return IOrderBoxService.upholdOrderPartWeight(cardNo,new BigDecimal(actualWeight)); } } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/PipelineController.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/PipelineController.java index edb32e1b..5c44575c 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/PipelineController.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/controller/PipelineController.java @@ -140,6 +140,8 @@ public class PipelineController extends BladeController { throw new ServiceException("箱条码不能为空"); } + boolean isPassed = pipelineService.receiveBoxArriveConveyorEnd(boxBarcode); + return R.data(true); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.java index 2d9f11a4..16122207 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.java @@ -1,7 +1,10 @@ package org.springblade.desk.logistics.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Param; import org.springblade.desk.logistics.pojo.entity.Task; import org.springblade.desk.logistics.pojo.entity.WeighData; public interface TaskMapper extends BaseMapper { + + Task selectByBoxBarcode(@Param("boxBarcode") String boxBarcode); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.xml b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.xml index 46ebb6c4..2daf3f83 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.xml +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/mapper/TaskMapper.xml @@ -5,4 +5,11 @@ + diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/LocationService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ILocationService.java similarity index 95% rename from blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/LocationService.java rename to blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ILocationService.java index fcec962e..22b9d32a 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/LocationService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ILocationService.java @@ -37,6 +37,6 @@ import java.math.BigDecimal; * @author BladeX * @since 2025-11-12 */ -public interface LocationService extends BaseService { +public interface ILocationService extends BaseService { } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/OrderBindService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IOrderBindService.java similarity index 94% rename from blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/OrderBindService.java rename to blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IOrderBindService.java index 8baa2b2f..c3ac6cfd 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/OrderBindService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IOrderBindService.java @@ -35,6 +35,6 @@ import org.springblade.desk.logistics.pojo.entity.OrderBind; * @author BladeX * @since 2025-11-12 */ -public interface OrderBindService extends BaseService { +public interface IOrderBindService extends BaseService { } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/OrderBoxService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IOrderBoxService.java similarity index 84% rename from blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/OrderBoxService.java rename to blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IOrderBoxService.java index 9937257f..8fd0a0b2 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/OrderBoxService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IOrderBoxService.java @@ -4,6 +4,6 @@ import org.springblade.core.tool.api.R; import java.math.BigDecimal; -public interface OrderBoxService { +public interface IOrderBoxService { R upholdOrderPartWeight(String cardNo, BigDecimal actualWeight); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IPipelineService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IPipelineService.java index 0a069a07..dfa02cad 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IPipelineService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IPipelineService.java @@ -53,4 +53,11 @@ public interface IPipelineService { * @return */ BigDecimal getMaterialBoxWeight(String boxBarcode); + + /** + * 输送线到达末尾通知 + * @param boxBarcode + * @return + */ + boolean receiveBoxArriveConveyorEnd(String boxBarcode); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/StationService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IStationService.java similarity index 95% rename from blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/StationService.java rename to blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IStationService.java index 52b2dcd8..562c72bc 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/StationService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/IStationService.java @@ -35,6 +35,6 @@ import org.springblade.desk.logistics.pojo.entity.Station; * @author BladeX * @since 2025-11-12 */ -public interface StationService extends BaseService { +public interface IStationService extends BaseService { } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/TaskService.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskService.java similarity index 71% rename from blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/TaskService.java rename to blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskService.java index 76971c28..9c590e1b 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/TaskService.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/ITaskService.java @@ -26,15 +26,30 @@ package org.springblade.desk.logistics.service; import org.springblade.core.mp.base.BaseService; -import org.springblade.desk.logistics.pojo.entity.Station; import org.springblade.desk.logistics.pojo.entity.Task; +import java.math.BigDecimal; + /** * 物流任务 服务类 * * @author BladeX * @since 2025-11-12 */ -public interface TaskService extends BaseService { +public interface ITaskService extends BaseService { + + /** + * 保存输送线称重数据 + * @param boxBarcode 箱条码 + * @param actualWeight 输送线重量 + * @param statusReturned 任务状态 + */ + void savePipelineWeigh(String boxBarcode, BigDecimal actualWeight, Integer statusReturned); + /** + * 获取输送箱信息 + * @param boxBarcode + * @return + */ + Task getBoxBarcode(String boxBarcode); } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/LocationServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/LocationServiceImpl.java index 1f79ceca..e3f08b2e 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/LocationServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/LocationServiceImpl.java @@ -29,7 +29,7 @@ import lombok.extern.slf4j.Slf4j; import org.springblade.core.mp.base.BaseServiceImpl; import org.springblade.desk.logistics.mapper.LocationMapper; import org.springblade.desk.logistics.pojo.entity.Location; -import org.springblade.desk.logistics.service.LocationService; +import org.springblade.desk.logistics.service.ILocationService; import org.springframework.stereotype.Service; @@ -41,7 +41,7 @@ import org.springframework.stereotype.Service; */ @Service @Slf4j -public class LocationServiceImpl extends BaseServiceImpl implements LocationService { +public class LocationServiceImpl extends BaseServiceImpl implements ILocationService { } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBindServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBindServiceImpl.java index c0ddd6ad..df82a4cb 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBindServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBindServiceImpl.java @@ -27,12 +27,9 @@ package org.springblade.desk.logistics.service.impl; import lombok.extern.slf4j.Slf4j; import org.springblade.core.mp.base.BaseServiceImpl; -import org.springblade.desk.logistics.mapper.LocationMapper; import org.springblade.desk.logistics.mapper.OrderBindMapper; -import org.springblade.desk.logistics.pojo.entity.Location; import org.springblade.desk.logistics.pojo.entity.OrderBind; -import org.springblade.desk.logistics.service.LocationService; -import org.springblade.desk.logistics.service.OrderBindService; +import org.springblade.desk.logistics.service.IOrderBindService; import org.springframework.stereotype.Service; /** @@ -43,7 +40,7 @@ import org.springframework.stereotype.Service; */ @Service @Slf4j -public class OrderBindServiceImpl extends BaseServiceImpl implements OrderBindService { +public class OrderBindServiceImpl extends BaseServiceImpl implements IOrderBindService { } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBoxServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBoxServiceImpl.java index 31268578..5340fb01 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBoxServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/OrderBoxServiceImpl.java @@ -3,8 +3,7 @@ package org.springblade.desk.logistics.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import lombok.extern.slf4j.Slf4j; import org.springblade.core.tool.api.R; -import org.springblade.desk.jobtransfer.service.ICertificateMaintenanceService; -import org.springblade.desk.logistics.service.OrderBoxService; +import org.springblade.desk.logistics.service.IOrderBoxService; import org.springblade.desk.order.pojo.entity.YieldOrder; import org.springblade.desk.order.service.IYieldOrderService; @@ -21,7 +20,7 @@ import java.util.List; */ @Service @Slf4j -public class OrderBoxServiceImpl implements OrderBoxService { +public class OrderBoxServiceImpl implements IOrderBoxService { private final IYieldOrderService yieldOrderService; public OrderBoxServiceImpl(IYieldOrderService yieldOrderService) { diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/PipelineServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/PipelineServiceImpl.java index 0776601e..52704d15 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/PipelineServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/PipelineServiceImpl.java @@ -24,15 +24,16 @@ * Author: Chill Zhuang (bladejava@qq.com) */ package org.springblade.desk.logistics.service.impl; - import lombok.extern.slf4j.Slf4j; -import org.springblade.core.tool.api.R; +import org.springblade.desk.logistics.pojo.entity.Station; +import org.springblade.desk.logistics.pojo.entity.Task; import org.springblade.desk.logistics.pojo.entity .WeighData; import org.springblade.desk.logistics.service.IPipelineService; -import org.springblade.desk.logistics.service.IWeighDataService; +import org.springblade.desk.logistics.service.IStationService; +import org.springblade.desk.logistics.service.ITaskService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; - +import org.springblade.core.log.exception.ServiceException; import java.math.BigDecimal; /** @@ -46,21 +47,25 @@ import java.math.BigDecimal; public class PipelineServiceImpl implements IPipelineService { @Autowired - IWeighDataService weighDataService; + ITaskService taskService; + + @Autowired + IStationService stationService; @Override public boolean verifyConveyorBoxWeighing(String boxBarcode, BigDecimal actualWeight, BigDecimal ratedWeight, Integer returnStatus) { - // 1. 保存称重数据 - weighDataService.saveWeighingData(boxBarcode,actualWeight,ratedWeight,returnStatus); - - // 2. 判断是否超重 + // 1. 判断是否超重 if (WeighData.RETURN_STATUS_RETURNED.equals(returnStatus)) { - // todo 超重处理 + // 2. 保存称重数据 + taskService.savePipelineWeigh(boxBarcode,actualWeight, Task.STATUS_RETURNED); + + // todo 3.超重处理,解绑 return false; } else { - // 正常重量 + // 2. 保存称重数据 + taskService.savePipelineWeigh(boxBarcode,actualWeight, Task.STATUS_CONVEYOR_START); log.info("物料箱[{}]重量校验通过", boxBarcode); return true; } @@ -69,18 +74,37 @@ public class PipelineServiceImpl implements IPipelineService { @Override public BigDecimal getMaterialBoxWeight(String boxBarcode) { - // todo 2.查询箱信息 根据箱条码查询物料箱信息 -// //Box box = boxMapper.selectByBarcode(boxBarcode); -// if (box == null) { -// throw new ServiceException("箱号不存在: " + boxBarcode); -// } -// -// // 3.检查是否已绑定 -// if (!box.getBound()) { -// throw new ServiceException("该箱号未绑定预估重量"); -// } - BigDecimal estimatedWeight = new BigDecimal(50); - - return estimatedWeight; + // 2.查询箱信息 根据箱条码查询物料箱信息 + Task task = taskService.getBoxBarcode(boxBarcode); + if (null == task ) { + throw new ServiceException("查询不到该物料箱: "+boxBarcode); + } + + // 3.检查是否已绑定 + if (null == task.getWeight()) { + throw new ServiceException("该箱号未绑定预估重量"); + } + + return task.getWeight(); + } + + @Override + public boolean receiveBoxArriveConveyorEnd(String boxBarcode) { + Task task = taskService.getBoxBarcode(boxBarcode); + if (null == task ) { + throw new ServiceException("查询不到该物料箱: "+boxBarcode); + } + if(null == task.getStationId()){ + throw new ServiceException("查询不到站点信息: "+boxBarcode); + } + + //查询站点 判断站点是否为空 + Station station = stationService.getById(task.getStationId()); + if(Station.STATUS_FREE.equals(station.getStationStatus())){ + + } + + + return false; } } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java index cf4f0160..47b63634 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/StationServiceImpl.java @@ -27,12 +27,9 @@ package org.springblade.desk.logistics.service.impl; import lombok.extern.slf4j.Slf4j; import org.springblade.core.mp.base.BaseServiceImpl; -import org.springblade.desk.logistics.mapper.OrderBindMapper; import org.springblade.desk.logistics.mapper.StationMapper; -import org.springblade.desk.logistics.pojo.entity.OrderBind; import org.springblade.desk.logistics.pojo.entity.Station; -import org.springblade.desk.logistics.service.OrderBindService; -import org.springblade.desk.logistics.service.StationService; +import org.springblade.desk.logistics.service.IStationService; import org.springframework.stereotype.Service; /** @@ -43,7 +40,7 @@ import org.springframework.stereotype.Service; */ @Service @Slf4j -public class StationServiceImpl extends BaseServiceImpl implements StationService { +public class StationServiceImpl extends BaseServiceImpl implements IStationService { } diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskServiceImpl.java index 2952a1f7..c6d0626a 100644 --- a/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskServiceImpl.java +++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/logistics/service/impl/TaskServiceImpl.java @@ -26,15 +26,16 @@ package org.springblade.desk.logistics.service.impl; import lombok.extern.slf4j.Slf4j; +import org.checkerframework.checker.units.qual.A; import org.springblade.core.mp.base.BaseServiceImpl; -import org.springblade.desk.logistics.mapper.StationMapper; import org.springblade.desk.logistics.mapper.TaskMapper; -import org.springblade.desk.logistics.pojo.entity.Station; import org.springblade.desk.logistics.pojo.entity.Task; -import org.springblade.desk.logistics.service.StationService; -import org.springblade.desk.logistics.service.TaskService; +import org.springblade.desk.logistics.service.ITaskService; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.math.BigDecimal; + /** * 物流任务 服务类 * @@ -43,7 +44,20 @@ import org.springframework.stereotype.Service; */ @Service @Slf4j -public class TaskServiceImpl extends BaseServiceImpl implements TaskService { +public class TaskServiceImpl extends BaseServiceImpl implements ITaskService { + + @Autowired + TaskMapper taskMapper; + + @Override + public void savePipelineWeigh(String boxBarcode, BigDecimal actualWeight, Integer statusReturned) { + // 1.查询物料箱 筛选状态 + // 2.更新重量以及任务状态 + } + @Override + public Task getBoxBarcode(String boxBarcode) { + return taskMapper.selectByBoxBarcode(boxBarcode); + } }