package com.zy.asrs.task.handler;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.service.AgvLocDetlService;
|
import com.zy.asrs.service.AgvLocMastService;
|
import com.zy.asrs.service.OrderService;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.asrs.utils.Utils;
|
import com.zy.common.model.LocDto;
|
import com.zy.common.model.OrderDto;
|
import com.zy.common.model.TaskDto;
|
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;
|
import java.util.Optional;
|
import java.util.stream.Collectors;
|
|
/**
|
* Created by vincent on 2020/7/7
|
*/
|
@Service
|
public class AutoOrderHandler extends AbstractHandler<String> {
|
|
@Autowired
|
private OrderService orderService;
|
|
@Autowired
|
private AgvLocMastService agvLocMastService;
|
|
@Autowired
|
private AgvLocDetlService agvLocDetlService;
|
|
@Transactional
|
public ReturnT<String> start(Order order) {
|
// double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getQty()).orElse(0.0D);
|
// if (issued <= 0.0D) {
|
// continue;
|
// }
|
//
|
//
|
// Double issued = orderDetl.getAnfme() - orderDetl.getQty();
|
// //根据物料号和批次找到对应的库存，并且按照修改时间排序
|
// Wrapper<AgvLocDetl> wrapper = new EntityWrapper<AgvLocDetl>().eq("matnr", orderDetl.getMatnr()).orderBy("modi_time");
|
//
|
// wapperSetCondition(wrapper, "three_code", orderDetl.getThreeCode());
|
// List<AgvLocDetl> agvLocDetls = agvLocDetlService.selectList(wrapper);
|
//
|
// for (AgvLocDetl agvLocDetl : agvLocDetls) {
|
// //判断当前库位货物是否F在库
|
// AgvLocMast agvLocMast = agvLocMastService.selectById(agvLocDetl.getLocNo());
|
// if (!"F".equals(agvLocMast.getLocSts())) {
|
// continue;
|
// }
|
// //当前库位的库存量
|
// double anfme = agvLocDetl.getAnfme();
|
// //int ioType = anfme > issued ? 101 : 103;
|
// anfme = anfme > issued ? issued : anfme;
|
// //用于显示工作明细档的订单号
|
// String orderNoWrkDtel = Utils.getOrderNo(orderNo, anfme);
|
// //更新订单数量
|
// orderNo = Utils.orderMergeUpdate(orderNo, anfme);
|
// LocDto locDto = new LocDto(agvLocDetl.getLocNo(), agvLocDetl.getMatnr(), agvLocDetl.getMaktx(), agvLocDetl.getBatch(), orderNoWrkDtel, anfme, agvLocDetl.getProcessSts());
|
// locDto.setCsocode(csocode);
|
// locDto.setIsoseq(isoseq);
|
// locDto.setContainerCode(agvLocDetl.getSuppCode());
|
// locDto.setProcessSts(agvLocDetl.getProcessSts());
|
// //当前库位所处楼层
|
// int floor = Integer.parseInt(agvLocDetl.getLocNo().split("F")[1]);
|
// //locDto.setAgvStaNos(queryAgvStaNosByFloor(floor));
|
// locDto.setAgvStaNos(agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1(), floor));
|
// locDtoList.add(locDto);
|
//
|
// issued -= anfme;
|
// }
|
//
|
//
|
// // 订单预校验 ===>> 1.订单状态； 2.订单带出数量
|
// List<OrderDto> orderDtos = orderPreVerification(locDtos);
|
//
|
// List<TaskDto> taskDtos = new ArrayList<>();
|
// List<TaskDto> agvTaskDtos = new ArrayList<>();
|
// generateTaskDto(locDtos, taskDtos, agvTaskDtos);
|
//
|
// //生成AGV出库任务
|
// agvWorkService.stockOutWrkMast(agvTaskDtos, getUserId());
|
//
|
// // 生成出库任务
|
// taskDtos.stream().map(TaskDto::getLocNo).distinct().collect(Collectors.toList());
|
// for (TaskDto taskDto : taskDtos) {
|
// BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
|
// workService.stockOut(staNo, taskDto, getUserId());
|
// }
|
return SUCCESS;
|
}
|
|
|
private void wapperSetCondition(Wrapper wrapper, String column, String condition) {
|
if (Cools.isEmpty(condition)) {
|
wrapper.andNew().eq(column, "").or().isNull(column);
|
} else {
|
wrapper.andNew().eq(column, condition);
|
}
|
}
|
}
|
