package com.zy.asrs.service.impl;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.core.common.*;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.entity.param.EmptyPlateOutParam;
|
import com.zy.asrs.entity.param.OpenOrderPakinParam;
|
import com.zy.asrs.entity.param.OpenOrderPakoutParam;
|
import com.zy.asrs.mapper.OrderDetlPakoutMapper;
|
import com.zy.asrs.mapper.OrderPakoutMapper;
|
import com.zy.asrs.service.*;
|
import com.zy.common.model.DetlDto;
|
import com.zy.common.model.LocDto;
|
import com.zy.common.model.TaskDto;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Slf4j
|
@Service("orderPakoutService")
|
public class OrderPakoutServiceImpl extends ServiceImpl<OrderPakoutMapper, OrderPakout> implements OrderPakoutService {
|
|
@Autowired
|
private OrderDetlPakoutMapper orderDetlMapper;
|
@Autowired
|
private OpenService openService;
|
@Autowired
|
private SnowflakeIdWorker snowflakeIdWorker;
|
@Autowired
|
private OrderDetlPakoutService orderDetlService;
|
@Autowired
|
private DocTypeService docTypeService;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
@Autowired
|
private OrderDetlPakoutServiceImpl orderDetlPakoutService;
|
@Autowired
|
private LocDetlService locDetlService;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired
|
private StaDescService staDescService;
|
@Autowired
|
private WorkService workService;
|
@Autowired
|
private BasDevpService basDevpService;
|
|
@Resource
|
private OrderPakoutService orderPakOutService;
|
|
@Override
|
public OrderPakout selectByNo(String orderNo) {
|
List<OrderPakout> orderList = this.selectList(new EntityWrapper<OrderPakout>().eq("order_no", orderNo));
|
if (Cools.isEmpty(orderList)) {
|
return null;
|
}
|
return orderList.get(0);
|
}
|
|
@Override
|
public List<OrderPakout> selectBySettle(Long settle) {
|
List<OrderPakout> orderList = this.selectList(new EntityWrapper<OrderPakout>().eq("settle", settle));
|
if (Cools.isEmpty(orderList)) {
|
return new ArrayList<>();
|
}
|
return orderList;
|
}
|
|
@Override
|
public List<OrderDetlPakout> selectWorkingDetls(Long orderId) {
|
return orderDetlMapper.selectWorkingDetls(orderId);
|
}
|
|
@Override
|
public boolean updateSettle(Long orderId, Long settle, Long userId) {
|
return this.baseMapper.updateSettle(orderId, settle, userId) > 0;
|
}
|
|
@Override
|
public void checkComplete(String orderNo) {
|
OrderPakout order = this.selectByNo(orderNo);
|
if (Cools.isEmpty(order) || order.getSettle() >= 4L) {
|
return;
|
}
|
List<OrderDetlPakout> orderDetls = orderDetlPakoutService.selectList(new EntityWrapper<OrderDetlPakout>().eq("order_id", order.getId()));
|
boolean complete = true;
|
for (OrderDetlPakout orderDetl : orderDetls) {
|
if (orderDetl.getAnfme() > orderDetl.getQty()) {
|
complete = false;
|
break;
|
}
|
}
|
if (complete) {
|
// 出库订单重新整理明细
|
DocType docType = docTypeService.selectById(order.getDocType());
|
if (null != docType && docType.getPakout() == 1) {
|
if (!orderDetlPakoutService.delete(new EntityWrapper<OrderDetlPakout>().eq("order_id", order.getId()))) {
|
throw new CoolException("重整出库订单【orderNo = " + order.getOrderNo() + "】明细失败");
|
}
|
List<WrkDetl> wrkDetls = wrkDetlService.selectAndLogByOrderNo(orderNo);
|
for (WrkDetl wrkDetl : wrkDetls) {
|
OrderDetlPakout orderDetl = new OrderDetlPakout();
|
orderDetl.sync(wrkDetl);
|
orderDetl.setQty(orderDetl.getAnfme());
|
orderDetl.setOrderId(order.getId());
|
orderDetl.setOrderNo(orderNo);
|
orderDetl.setStatus(1);
|
orderDetl.setCreateTime(order.getCreateTime());
|
orderDetl.setCreateBy(order.getCreateBy());
|
orderDetl.setUpdateTime(order.getUpdateTime());
|
orderDetl.setUpdateBy(order.getUpdateBy());
|
orderDetl.setBarcode(wrkDetl.getZpallet());
|
if (!orderDetlPakoutService.insert(orderDetl)) {
|
throw new CoolException("重整出库订单【orderNo = " + order.getOrderNo() + "】明细失败");
|
}
|
}
|
}
|
|
if (!this.updateSettle(order.getId(), 4L, null)) {
|
throw new CoolException("修改订单【orderNo = " + order.getOrderNo() + "】状态为已完成失败");
|
}
|
}
|
|
}
|
|
@Override
|
public boolean saveHandlerOrder(Boolean pakin, WrkMast wrkMast, List<WrkDetl> wrkDetls) {
|
try {
|
List<DetlDto> detlDtos = new ArrayList<>();
|
wrkDetls.forEach(wrkDetl -> {
|
detlDtos.add(new DetlDto(wrkDetl.getMatnr(), wrkDetl.getBatch(),wrkDetl.getBrand(),wrkDetl.getStandby1(),wrkDetl.getStandby2(),wrkDetl.getStandby3(),wrkDetl.getBoxType1(),wrkDetl.getBoxType2(),wrkDetl.getBoxType3(), wrkDetl.getAnfme()));
|
});
|
String orderNo = "HAND" + snowflakeIdWorker.nextId();
|
if (pakin) {
|
// 生成入库单据
|
OpenOrderPakinParam openParam = new OpenOrderPakinParam();
|
openParam.setOrderNo(orderNo);
|
openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime()));
|
openParam.setOrderType("手动入库单");
|
openParam.setOrderDetails(detlDtos);
|
openService.pakinOrderCreate(openParam);
|
} else {
|
// 生成出库单据
|
OpenOrderPakoutParam openParam = new OpenOrderPakoutParam();
|
openParam.setOrderNo(orderNo);
|
openParam.setOrderTime(DateUtils.convert(wrkMast.getModiTime()));
|
openParam.setOrderType("手动出库单");
|
openParam.setOrderDetails(detlDtos);
|
openService.pakoutOrderCreate(openParam);
|
}
|
|
OrderPakout order = this.selectByNo(orderNo);
|
if (null == order) {
|
throw new CoolException("生成单据失败");
|
}
|
if (!this.updateSettle(order.getId(), 4L, null)) {
|
throw new CoolException("修改单据状态失败");
|
}
|
for (DetlDto detlDto : detlDtos) {
|
// 修改订单明细数量
|
if (!orderDetlService.increase(order.getId(), detlDto.getMatnr(), detlDto.getBatch(),detlDto.getBrand(),detlDto.getStandby1(),detlDto.getStandby2(),detlDto.getStandby3()
|
,detlDto.getBoxType1(),detlDto.getBoxType2(),detlDto.getBoxType3(), detlDto.getAnfme())) {
|
throw new CoolException("修改单据明细数量失败");
|
}
|
// 修改订单作业数量
|
if (!orderDetlService.increaseWorkQty(order.getId(), detlDto.getMatnr(), detlDto.getBatch(),detlDto.getBrand(),detlDto.getStandby1(),detlDto.getStandby2(),detlDto.getStandby3()
|
,detlDto.getBoxType1(),detlDto.getBoxType2(),detlDto.getBoxType3(), detlDto.getAnfme())) {
|
throw new CoolException("修改单据作业数量失败");
|
}
|
}
|
} catch (Exception e) {
|
log.error("saveHandlerOrder===>>", e);
|
return false;
|
}
|
return true;
|
}
|
|
@Override
|
public void remove(Long orderId) {
|
if (!this.deleteById(orderId)) {
|
throw new CoolException("删除单据失败");
|
}
|
orderDetlPakoutService.delete(new EntityWrapper<OrderDetlPakout>().eq("order_id", orderId));
|
}
|
|
@Override
|
public List<OrderPakout> selectComplete() {
|
return this.baseMapper.selectComplete();
|
}
|
|
@Override
|
public List<OrderPakout> selectComplete8() {
|
return this.baseMapper.selectComplete8();
|
}
|
|
@Override
|
public boolean addToLogTable(OrderPakout order) {
|
return this.baseMapper.addToLogTable(order) > 0;
|
}
|
|
@Override
|
public List<OrderPakout> selectorderNoL(String orderNo) {
|
return this.baseMapper.selectorderNoL(orderNo);
|
}
|
|
@Override
|
public OrderPakout selectOrderMoveStatus() {
|
return this.baseMapper.selectOrderMoveStatus();
|
}
|
@Override
|
public OrderPakout selectOrderMoveStatusInitial() {
|
return this.baseMapper.selectOrderMoveStatusInitial();
|
}
|
|
@Override
|
public R pakout(List<LocDto> locDtos) {
|
if (Cools.isEmpty(locDtos)) {
|
return R.parse(BaseRes.PARAM);
|
}
|
List<LocDto> locDtoArrayList = new ArrayList<>();
|
for (LocDto locDto : locDtos) {
|
if (locDto.getFrozen() != 1 && locDto.getFrozenLoc() != 1) {
|
locDtoArrayList.add(locDto);
|
}
|
}
|
locDtos = locDtoArrayList;
|
if (Cools.isEmpty(locDtos)) {
|
return R.parse("库存/库位被冻结，请处理后出库！！！");
|
}
|
boolean lack = true;
|
for (LocDto locDto : locDtos) {
|
if (!locDto.isLack()) {
|
lack = false;
|
break;
|
}
|
}
|
if (lack) {
|
return R.error("库存不足");
|
}
|
|
List<TaskDto> taskDtos = new ArrayList<>();
|
// 根据 （库位 & 出库站） 分组； 理想状态：一组为一次出库任务
|
for (LocDto locDto : locDtos) {
|
if (locDto.isLack()) {
|
continue;
|
}
|
TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getStaNo(), locDto);
|
if (TaskDto.has(taskDtos, taskDto)) {
|
TaskDto dto = TaskDto.find(taskDtos, taskDto);
|
assert dto != null;
|
dto.getLocDtos().addAll(taskDto.getLocDtos());
|
} else {
|
taskDtos.add(taskDto);
|
}
|
}
|
OrderPakout orderPakout = orderPakOutService.selectByNo(locDtos.get(0).getOrderNo());
|
|
//配盘出库单用， i=5时或者出库到最后时下发空板出库任务
|
int i = 0;
|
//需要出库的托盘数量
|
int size = taskDtos.size();
|
//优先级
|
int ioPri = 50;
|
//已下空板出库任务数量
|
int j = 1;
|
// -----------------------------------------------------------------------------------------------
|
for (TaskDto taskDto : taskDtos) {
|
BasDevp staNo = basDevpService.checkSiteStatus(taskDto.getStaNo());
|
workService.stockOut(staNo, taskDto, 9995L, ioPri);
|
ioPri--;
|
i++;
|
//配盘出库单使用，下发需要出的空板任务
|
if (orderPakout.getDocType() == 11) {
|
if (i == size) {
|
for (; j <= orderPakout.getPayType(); j++) {
|
LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", taskDto.getLocNo()));
|
Integer locType = Integer.valueOf(locMast1.getLocType2());
|
//配盘 出库单出库区域时Q-L4时,出大托盘空板
|
if(!Cools.isEmpty(orderPakout.getCstmrName())&&orderPakout.getCstmrName().equals("Q-L4")){
|
locType = 2;
|
}
|
String bar = "";
|
//具体待定
|
// if(!Cools.isEmpty(orderPakout.getShipCode())&&orderPakout.getShipCode().equals("A01")){
|
// bar = "A01";
|
// }
|
LocMast locMast = new LocMast();
|
if (Cools.isEmpty(bar)) {
|
locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
|
.eq("loc_sts", "D").eq("loc_type2", locType).orderBy("row1",false));
|
} else {
|
locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
|
.eq("loc_sts", "D").eq("loc_type2", locType).like("barcode", bar).orderBy("row1",false));
|
}
|
|
if (Cools.isEmpty(locMast)) {
|
return R.error("库存没有空板");
|
}
|
String locNo = locMast.getLocNo();
|
EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
|
emptyPlateOutParam.setOutSite(303);
|
emptyPlateOutParam.setLocNos(new ArrayList<String>() {{
|
add(locNo);
|
}});
|
String agvSta = "";
|
if (locMast.getLocType3() == 2) {
|
agvSta = "Z-LZP26";
|
}else if(locType ==2){
|
|
} else {
|
agvSta = orderPakout.getCstmrName();//agv目标站点位置
|
}
|
WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam, ioPri, agvSta);
|
ioPri--;
|
|
}
|
} else if (i == 4) {
|
LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", taskDto.getLocNo()));
|
Integer locType = Integer.valueOf(locMast1.getLocType2());
|
//配盘 出库单出库区域时Q-L4时,出大托盘空板
|
if(orderPakout.getCstmrName().equals("Q-L4")){
|
locType = 2;
|
}
|
|
String bar = "";
|
if (!Cools.isEmpty(orderPakout.getShipCode()) && orderPakout.getShipCode().equals("A01")) {
|
bar = "A01";
|
}
|
LocMast locMast = null;
|
if (Cools.isEmpty(bar)) {
|
locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
|
.eq("loc_sts", "D").eq("loc_type2", locType).orderBy("row1",false));
|
} else {
|
locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
|
.eq("loc_sts", "D").eq("loc_type2", locType).like("barcode", bar).orderBy("row1",false));
|
}
|
|
if (Cools.isEmpty(locMast)) {
|
return R.error("库存没有空板");
|
}
|
String locNo = locMast.getLocNo();
|
EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
|
emptyPlateOutParam.setOutSite(303);
|
emptyPlateOutParam.setLocNos(new ArrayList<String>() {{
|
add(locNo);
|
}});
|
String agvSta = "";
|
if (locMast.getLocType3() == 2) {
|
agvSta = "Z-LZP26";
|
}else if(locType ==2){
|
|
} else {
|
agvSta = orderPakout.getCstmrName();//agv目标站点位置
|
}
|
WrkMast wrkMast = workService.emptyPlateOut(emptyPlateOutParam, ioPri, agvSta);
|
ioPri--;
|
j++;
|
}
|
}
|
}
|
return R.ok();
|
}
|
|
}
|
