package com.vincent.rsf.server.api.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.vincent.rsf.framework.common.Cools;
|
import com.vincent.rsf.framework.common.R;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.server.api.entity.params.PdaGeneralParam;
|
import com.vincent.rsf.server.api.service.PdaOtherService;
|
import com.vincent.rsf.server.manager.entity.Loc;
|
import com.vincent.rsf.server.manager.entity.LocItem;
|
import com.vincent.rsf.server.manager.entity.Transfer;
|
import com.vincent.rsf.server.manager.enums.LocStatusType;
|
import com.vincent.rsf.server.manager.enums.LocStsType;
|
import com.vincent.rsf.server.manager.service.LocItemService;
|
import com.vincent.rsf.server.manager.service.LocService;
|
import com.vincent.rsf.server.manager.service.TransferService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
@Service
|
public class PdaOtherServiceImpl implements PdaOtherService {
|
|
@Autowired
|
private TransferService transferService;
|
|
@Autowired
|
private LocService locService;
|
@Autowired
|
private LocItemService locItemService;
|
|
@Override
|
public R transferPage(String orderNo, Integer curr, Integer limit) {
|
Page<Transfer> page = new Page<>(curr, limit);
|
LambdaQueryWrapper<Transfer> transferLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
transferLambdaQueryWrapper.eq(!Cools.isEmpty(orderNo), Transfer::getCode, orderNo);
|
Page<Transfer> page1 = transferService.page(page, transferLambdaQueryWrapper);
|
return R.ok(page1);
|
}
|
|
@Override
|
public R inspectList(PdaGeneralParam generalParam) {
|
if (Cools.isEmpty(generalParam.getContainerNo())) {
|
throw new CoolException("容器码为空");
|
}
|
Loc loc = null;
|
try {
|
loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getBarcode, generalParam.getContainerNo()));
|
}catch (Exception e){
|
throw new CoolException("数据错误,查询到多条库位");
|
}
|
if (Cools.isEmpty(loc)) {
|
throw new CoolException("未找到对应的库位");
|
}
|
if (!loc.getUseStatus().equals(LocStsType.LOC_STS_TYPE_F.type)){
|
throw new CoolException("库位不为在库状态");
|
}
|
List<LocItem> list = locItemService.list(new LambdaQueryWrapper<LocItem>()
|
.eq(LocItem::getLocId, loc.getId())
|
.eq(!Cools.isEmpty(generalParam.getMatnrCode()),LocItem::getMatnrCode, generalParam.getMatnrCode())
|
);
|
if (Cools.isEmpty(list)) {
|
throw new CoolException("库位为在库状态,但库位为空");
|
}
|
return R.ok(list);
|
|
}
|
|
@Override
|
public R inspectConfirm(PdaGeneralParam generalParam) {
|
if (Cools.isEmpty(generalParam.getMatnrList())){
|
throw new CoolException("参数为空");
|
}
|
for (LocItem locItem : generalParam.getMatnrList()) {
|
LocItem locItem1 = locItemService.getById(locItem.getId());
|
if (Cools.isEmpty(locItem1)) {
|
throw new CoolException("数据错误");
|
}
|
if (locItem1.getStatus().equals(LocStatusType.FREEZE.type)){
|
continue;
|
}
|
if (locItem.getStatus().equals(LocStatusType.FREEZE.type)){
|
locItem1.setStatus(LocStatusType.FREEZE.type);
|
locItemService.updateById(locItem1);
|
}
|
|
|
}
|
return R.ok();
|
}
|
|
@Override
|
public R inspectConfirm2(PdaGeneralParam generalParam) {
|
if (Cools.isEmpty(generalParam.getMatnrList())){
|
throw new CoolException("参数为空");
|
}
|
for (LocItem locItem : generalParam.getMatnrList()) {
|
LocItem locItem1 = locItemService.getById(locItem.getId());
|
if (Cools.isEmpty(locItem1)) {
|
throw new CoolException("数据错误");
|
}
|
if (locItem1.getStatus().equals(LocStatusType.NORMAL.type)){
|
continue;
|
}
|
if (locItem.getStatus().equals(LocStatusType.NORMAL.type)){
|
locItem1.setStatus(LocStatusType.NORMAL.type);
|
locItemService.updateById(locItem1);
|
}
|
|
|
}
|
return R.ok();
|
}
|
}
|
