| | |
|---|
| | | package com.vincent.rsf.server.manager.service.impl; |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.vincent.rsf.framework.common.R; |
|---|
| | | import com.vincent.rsf.framework.exception.CoolException; |
|---|
| | | import com.vincent.rsf.server.api.controller.params.TaskInParam; |
|---|
| | | import com.vincent.rsf.server.api.entity.dto.InTaskMsgDto; |
|---|
| | |
|---|
| | | * 库存出库生成出库任务 |
|---|
| | | * type: check 盘点, stock: 库存出库 |
|---|
| | | * |
|---|
| | | * @param resouce |
|---|
| | | * @param map |
|---|
| | | * @param loginUserId |
|---|
| | | * @return |
|---|
| | |
|---|
| | | @Override |
|---|
| | | @Synchronized |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void generateTask(LocToTaskParams map, Long loginUserId) throws Exception { |
|---|
| | | public void generateTask(Short resouce, LocToTaskParams map, Long loginUserId) throws Exception { |
|---|
| | | if (Objects.isNull(map.getSiteNo())) { |
|---|
| | | throw new CoolException("站点不能为空！"); |
|---|
| | | } |
|---|
| | |
|---|
| | | String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_TASK_CODE, null); |
|---|
| | | task.setOrgLoc(loc.getCode()) |
|---|
| | | .setTaskCode(ruleCode) |
|---|
| | | .setResource(resouce) |
|---|
| | | .setTargSite(siteNo) |
|---|
| | | .setSort(Constants.TASK_SORT_DEFAULT_VALUE) |
|---|
| | | .setUpdateBy(loginUserId) |
|---|
