| | |
|---|
| | | import com.vincent.rsf.server.manager.service.TaskService; |
|---|
| | | import com.vincent.rsf.server.system.constant.SerialRuleCode; |
|---|
| | | import com.vincent.rsf.server.system.utils.SerialRuleUtils; |
|---|
| | | import lombok.Synchronized; |
|---|
| | | 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; |
|---|
| | |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | @Synchronized |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public R generateTask(Map<String, Object> map) { |
|---|
| | | if (Objects.isNull(map.get("siteNo"))) { |
|---|
| | | throw new CoolException("站点不能为空！"); |
|---|
| | |
|---|
| | | if (Objects.isNull(loc)) { |
|---|
| | | throw new CoolException("数据错误：所选库存信息不存在！！"); |
|---|
| | | } |
|---|
| | | loc.setUseStatus(LocStsType.LOC_STS_TYPE_R.type); |
|---|
| | | |
|---|
| | | if (!locService.updateById(loc)) { |
|---|
| | | throw new CoolException("库位状态更新失败！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_TASK_CODE, null); |
|---|
| | | task.setOrgLoc(loc.getCode()) |
|---|
| | | .setTaskCode(ruleCode) |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | Double orgQty = locItems.stream().mapToDouble(LocItem::getAnfme).sum(); |
|---|
| | | Double workQty = locItems.stream().mapToDouble(LocItem::getWorkQty).sum(); |
|---|
| | | List<LocItem> locItemList = listMap.get(key); |
|---|
| | | Double outQty = locItemList.stream().mapToDouble(LocItem::getOutQty).sum(); |
|---|
| | | |
|---|
| | | if (orgQty.compareTo(outQty) > 0) { |
|---|
| | | |
|---|
| | | Task serviceOne = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getBarcode, loc.getBarcode())); |
|---|
| | | if (!Objects.isNull(serviceOne)) { |
|---|
| | | throw new CoolException("托盘任务执行中，不能重复创建！"); |
|---|
| | | } |
|---|
| | | Double useQty = Math.round((outQty + workQty) * 10000) / 10000.0; |
|---|
| | | if (orgQty.compareTo(useQty) > 0) { |
|---|
| | | //拣料出库 |
|---|
| | | task.setTaskType(TaskType.TASK_TYPE_PICK_AGAIN_IN.type); |
|---|
| | | } else { |
|---|
