| | |
|---|
| | | package com.vincent.rsf.server.manager.service.impl; |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.vincent.rsf.framework.common.SpringUtils; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
|---|
| | | import com.vincent.rsf.server.api.entity.enums.OrderType; |
|---|
| | | import com.vincent.rsf.server.api.entity.enums.TaskStsType; |
|---|
| | | import com.vincent.rsf.framework.common.R; |
|---|
| | |
|---|
| | | import org.springframework.beans.BeanUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private WaitPakinService waitPakinService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private TaskItemService taskItemService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private WaitPakinItemService waitPakinItemService; |
|---|
| | | @Autowired |
|---|
| | | private LocService locService; |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @param |
|---|
| | | * @param loginUserId |
|---|
| | | * @return |
|---|
| | | * @author Ryan |
|---|
| | | * @description 生成任务列表 |
|---|
| | | * @param |
|---|
| | | * @return |
|---|
| | | * @time 2025/3/29 15:59 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public R generateTasks(List<WaitPakin> waitPakin) { |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public synchronized R generateTasks(List<WaitPakin> waitPakin, Long loginUserId) { |
|---|
| | | if (Objects.isNull(waitPakin) || waitPakin.isEmpty()) { |
|---|
| | | throw new CoolException("参数不能为空！！"); |
|---|
| | | } |
|---|
| | |
|---|
| | | .setTaskType(TaskType.TASK_TYPE_IN.type.shortValue()) |
|---|
| | | .setTargLoc(LocManageUtil.getTargetLoc()) |
|---|
| | | .setBarcode(pakin.getBarcode()) |
|---|
| | | .setCreateBy(loginUserId) |
|---|
| | | .setUpdateBy(loginUserId) |
|---|
| | | .setTargSite(LocManageUtil.getTargetSite()); |
|---|
| | | |
|---|
| | | if (!this.save(task)) { |
|---|
| | | throw new CoolException("任务保存失败！！"); |
|---|
| | | } |
|---|
| | | if (!locService.update(new LambdaUpdateWrapper<Loc>().eq(Loc::getCode, pakin.getCode()) |
|---|
| | | .set(Loc::getUseStatus, LocStsType.LOC_STS_TYPE_S.type).set(Loc::getBarcode, pakin.getBarcode()))) { |
|---|
| | | throw new CoolException("库位预约失败！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /**获取组拖明细**/ |
|---|
| | | List<WaitPakinItem> waitPakinItems = waitPakinItemService.list(new LambdaQueryWrapper<WaitPakinItem>().eq(WaitPakinItem::getPakinId, pakin.getId())); |
|---|
| | | if (waitPakinItems.isEmpty()) { |
|---|
| | |
|---|
| | | BeanUtils.copyProperties(item, taskItem); |
|---|
| | | taskItem.setTaskId(task.getId()) |
|---|
| | | .setOrderType(OrderType.ORDER_RECEIPT.type) |
|---|
| | | .setSourceCode(item.getAsnCode()) |
|---|
| | | .setSource(item.getId()) |
|---|
| | | .setCreateBy(loginUserId) |
|---|
| | | .setUpdateBy(loginUserId) |
|---|
| | | .setOrderId(item.getAsnId()) |
|---|
| | | .setOrderItemId(item.getAsnItemId()); |
|---|
| | | taskItems.add(taskItem); |
|---|
| | |
|---|
| | | throw new CoolException("任务明细保存失败！！"); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | //TODO 任务生成完成需修改任务ASN订单状态为执行中，组拖删除需判断是否有子任务在执行 |
|---|
| | | |
|---|
| | | return R.ok("任务生成完毕！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @author Ryan |
|---|
| | | * @description 完成任务 |
|---|
| | | * @param |
|---|
| | | * @return |
|---|
| | | * @time 2025/4/2 11:15 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public R completeTask(String id) { |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
