+ * 收货入库任务类 + *
+ * + * @author Liuxy + * @since 2025-08-15 */ @Component(value = "DetainInTask") @TaskType("DetainInTask") diff --git a/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/StOutTask.java b/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/ReceiveOutTask.java similarity index 73% rename from wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/StOutTask.java rename to wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/ReceiveOutTask.java index dc61268..a02811b 100644 --- a/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/StOutTask.java +++ b/wms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/sch_manage/service/util/tasks/ReceiveOutTask.java @@ -4,12 +4,16 @@ import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import org.nl.common.exception.BadRequestException; import org.nl.common.utils.SecurityUtils; import org.nl.config.IdUtil; import org.nl.wms.basedata_manage.enums.BaseDataEnum; +import org.nl.wms.sch_manage.enums.TaskEnum; import org.nl.wms.sch_manage.enums.TaskStatus; +import org.nl.wms.sch_manage.service.ISchBasePointService; import org.nl.wms.sch_manage.service.ISchBaseTaskService; +import org.nl.wms.sch_manage.service.dao.SchBasePoint; import org.nl.wms.sch_manage.service.dao.SchBaseTask; import org.nl.wms.sch_manage.service.util.AbstractTask; import org.nl.wms.sch_manage.service.util.AcsTaskDto; @@ -25,35 +29,57 @@ import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; /** - * @Author: Liuxy - * @Description: 入库任务类 - * @Date: 2025/5/25 + *+ * 领料出库任务类 + *
+ * + * @author Liuxy + * @since 2025-08-15 */ -@Component(value = "STOutTask") -@TaskType("STOutTask") -public class StOutTask extends AbstractTask { +@Component(value = "ReceiveOutTask") +@TaskType("ReceiveOutTask") +public class ReceiveOutTask extends AbstractTask { + + /** + * 任务服务 + */ @Autowired private ISchBaseTaskService taskService; + /** + * 出库服务 + */ @Resource private IOutBillService outBillService; + /** + * 分配明细mapper + */ @Resource private IOStorInvDisMapper ioStorInvDisMapper; + /** + * 点位服务 + */ + @Resource + private ISchBasePointService iSchBasePointService; + @Override public String create(JSONObject json) { SchBaseTask task = new SchBaseTask(); task.setTask_id(IdUtil.getStringId()); task.setTask_code(json.getString("TaskCode")); task.setTask_status(TaskStatus.CREATE.getCode()); - task.setConfig_code(json.getString("task_type")); - task.setPoint_code1(json.getString("PickingLocation")); - task.setPoint_code2(json.getString("PlacedLocation")); + task.setConfig_code(ReceiveOutTask.class.getSimpleName()); + task.setPoint_code1(json.getString("point_code1")); + task.setPoint_code2(json.getString("point_code2")); task.setVehicle_code(json.getString("vehicle_code")); + task.setMaterial_id(json.getString("material_id")); + task.setMaterial_qty(json.getBigDecimal("material_qty")); task.setGroup_id(json.getString("group_id")); task.setRequest_param(json.toString()); task.setPriority(json.getString("Priority")); + task.setTask_type(TaskEnum.TASK_TYPE.code("料箱")); task.setCreate_id(SecurityUtils.getCurrentUserId()); task.setCreate_name(SecurityUtils.getCurrentNickName()); task.setCreate_time(DateUtil.now()); @@ -98,10 +124,10 @@ public class StOutTask extends AbstractTask { taskService.updateById(taskObj); } if (status.equals(TaskStatus.FINISHED)) { - this.finishTask(taskObj); + this.finishTask(taskObj); } if (status.equals(TaskStatus.CANCELED)) { - this.cancelTask(taskObj); + this.cancelTask(taskObj); } } @@ -111,7 +137,7 @@ public class StOutTask extends AbstractTask { if (ObjectUtil.isEmpty(taskObj)) { throw new BadRequestException("该任务不存在"); } - this.finishTask(taskObj); + this.finishTask(taskObj); } @Override @@ -132,6 +158,13 @@ public class StOutTask extends AbstractTask { @Transactional(rollbackFor = Exception.class) public void finishTask(SchBaseTask taskObj) { + // 更新终点 + iSchBasePointService.update( + new UpdateWrapper