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.BasStation;
|
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.BasStationService;
|
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 com.vincent.rsf.server.system.entity.User;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
public class PdaOtherServiceImpl implements PdaOtherService {
|
|
@Autowired
|
private TransferService transferService;
|
|
@Autowired
|
private LocService locService;
|
@Autowired
|
private LocItemService locItemService;
|
|
@Autowired
|
private BasStationService basStationService;
|
|
@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();
|
}
|
|
@Override
|
public R stationPage(String staNo, Integer curr, Integer limit) {
|
Page<BasStation> page = new Page<>(curr, limit);
|
LambdaQueryWrapper<BasStation> basStationLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
basStationLambdaQueryWrapper.eq(!Cools.isEmpty(staNo), BasStation::getStationName, staNo);
|
Page<BasStation> page1 = basStationService.page(page, basStationLambdaQueryWrapper);
|
return R.ok(page1);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R staOperate(PdaGeneralParam generalParam, User user) {
|
switch (generalParam.getStaOperateType()){
|
case 1:
|
stationDisabled(generalParam.getTransferStationNo(),user);
|
break;
|
case 2:
|
stationLiftTheBan(generalParam.getTransferStationNo(),user);
|
break;
|
case 3:
|
stationRelease(generalParam.getTransferStationNo(),user);
|
break;
|
default:
|
break;
|
}
|
|
return R.ok();
|
}
|
|
|
@Transactional(rollbackFor = Exception.class)
|
public void stationDisabled(String transferStationNo,User user){
|
BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, transferStationNo));
|
if (Cools.isEmpty(basStation)) {
|
throw new CoolException("未找到正确的站点");
|
}
|
if (basStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type) || basStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
|
throw new CoolException("当前站点正在工作");
|
}
|
basStation.setUseStatus(LocStsType.LOC_STS_TYPE_X.type);
|
basStation.setUpdateBy(user.getId());
|
basStation.setUpdateTime(new Date());
|
basStationService.updateById(basStation);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void stationLiftTheBan(String transferStationNo,User user){
|
BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, transferStationNo));
|
if (Cools.isEmpty(basStation)) {
|
throw new CoolException("未找到正确的站点");
|
}
|
if (basStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type) || basStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
|
throw new CoolException("当前站点正在工作");
|
}
|
|
basStation.setUseStatus(Cools.isEmpty(basStation.getBarcode())?LocStsType.LOC_STS_TYPE_O.type:LocStsType.LOC_STS_TYPE_F.type);
|
basStation.setUpdateBy(user.getId());
|
basStation.setUpdateTime(new Date());
|
basStationService.updateById(basStation);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void stationRelease(String transferStationNo,User user){
|
BasStation basStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, transferStationNo));
|
if (Cools.isEmpty(basStation)) {
|
throw new CoolException("未找到正确的站点");
|
}
|
if (basStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type) || basStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
|
throw new CoolException("当前站点正在工作");
|
}
|
|
basStation.setUseStatus(LocStsType.LOC_STS_TYPE_O.type);
|
basStation.setBarcode(null);
|
basStation.setUpdateBy(user.getId());
|
basStation.setUpdateTime(new Date());
|
basStationService.updateById(basStation);
|
}
|
|
|
@Override
|
public R locPage(String locNo, Integer curr, Integer limit) {
|
Page<Loc> page = new Page<>(curr, limit);
|
LambdaQueryWrapper<Loc> basStationLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
basStationLambdaQueryWrapper.eq(!Cools.isEmpty(locNo), Loc::getCode, locNo);
|
Page<Loc> page1 = locService.page(page, basStationLambdaQueryWrapper);
|
return R.ok(page1);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R locOperate(PdaGeneralParam generalParam, User user) {
|
switch (generalParam.getStaOperateType()){
|
case 1:
|
locDisabled(generalParam.getLocNo(),user);
|
break;
|
case 2:
|
locLiftTheBan(generalParam.getLocNo(),user);
|
break;
|
case 3:
|
locRelease(generalParam.getLocNo(),user);
|
break;
|
default:
|
break;
|
}
|
|
return R.ok();
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void locDisabled(String transferStationNo,User user){
|
Loc lco = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, transferStationNo));
|
if (Cools.isEmpty(lco)) {
|
throw new CoolException("未找到正确的库位");
|
}
|
if (lco.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type) || lco.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
|
throw new CoolException("当前站点正在工作");
|
}
|
lco.setUseStatus(LocStsType.LOC_STS_TYPE_X.type);
|
lco.setUpdateBy(user.getId());
|
lco.setUpdateTime(new Date());
|
locService.updateById(lco);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void locLiftTheBan(String transferStationNo,User user){
|
Loc lco = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, transferStationNo));
|
if (Cools.isEmpty(lco)) {
|
throw new CoolException("未找到正确的库位");
|
}
|
if (lco.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type) || lco.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
|
throw new CoolException("当前库位正在工作");
|
}
|
|
lco.setUseStatus(Cools.isEmpty(lco.getBarcode())?LocStsType.LOC_STS_TYPE_O.type:LocStsType.LOC_STS_TYPE_F.type);
|
lco.setUpdateBy(user.getId());
|
lco.setUpdateTime(new Date());
|
locService.updateById(lco);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
public void locRelease(String transferStationNo,User user){
|
Loc lco = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, transferStationNo));
|
if (Cools.isEmpty(lco)) {
|
throw new CoolException("未找到正确的库位");
|
}
|
if (lco.getUseStatus().equals(LocStsType.LOC_STS_TYPE_S.type) || lco.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
|
throw new CoolException("当前库位正在工作");
|
}
|
|
lco.setUseStatus(LocStsType.LOC_STS_TYPE_O.type);
|
lco.setBarcode(null);
|
lco.setUpdateBy(user.getId());
|
lco.setUpdateTime(new Date());
|
locService.updateById(lco);
|
}
|
|
}
|
