package com.zy.asrs.task.handler;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.LocDetl;
|
import com.zy.asrs.entity.LocMast;
|
import com.zy.asrs.entity.WrkDetl;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.service.LocDetlService;
|
import com.zy.asrs.service.LocMastService;
|
import com.zy.asrs.service.WrkDetlService;
|
import com.zy.asrs.service.WrkMastService;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.asrs.utils.VersionUtils;
|
import com.zy.common.service.CommonService;
|
import lombok.extern.slf4j.Slf4j;
|
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;
|
|
@Slf4j
|
@Service
|
@Transactional
|
public class AutomaticLibraryTransferHandler extends AbstractHandler<String> {
|
@Autowired
|
private WrkMastService wrkMastService;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired
|
private LocDetlService locDetlService;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
@Autowired
|
private CommonService commonService;
|
|
|
public ReturnT<String> startOne() {
|
List<LocMast> locMastsF=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","F").eq("lev1",1).orderBy("bay1",false));
|
List<LocMast> locMastsO=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","O").eq("lev1",1).orderBy("bay1",false));
|
if(Cools.isEmpty(locMastsO)){
|
return FAIL;
|
}
|
LocMast locMast1 = locMastsO.get(0);
|
|
LocMast locMast2 = locMastsF.get(locMastsF.size()-1);
|
if(locMast2.getBay1()>locMast1.getBay1()){
|
return FAIL;
|
}
|
|
String locNo=null;
|
for(LocMast locMast:locMastsF){
|
if(locMast.getBay1()<locMast1.getBay1()){
|
locNo=locMast1.getLocNo();
|
}
|
//生成移库任务
|
if(locNo!=null){
|
// 获取工作号
|
int workNo = commonService.getWorkNo(0);
|
// 保存工作档
|
WrkMast wrkMast = new WrkMast();
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(new Date());
|
wrkMast.setWrkSts(0L); // 工作状态：11.生成出库ID
|
wrkMast.setIoType(11); // 入出库状态： 11.库格移载
|
wrkMast.setIoPri(10D);
|
wrkMast.setCrnNo(1);
|
wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位
|
wrkMast.setLocNo(locNo); // 目标库位
|
wrkMast.setFullPlt("Y"); // 满板
|
wrkMast.setPicking("N"); // 拣料
|
wrkMast.setExitMk("N"); // 退出
|
wrkMast.setEmptyMk("N"); // 空板
|
wrkMast.setBarcode(locMast.getBarcode()); // 托盘码
|
wrkMast.setLinkMis("N");
|
wrkMast.setAppeTime(new Date());
|
wrkMast.setModiTime(new Date());
|
|
if (!wrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败");
|
}
|
// 工作档明细保存
|
if (locMast.getLocSts().equals("F")) {
|
List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
|
for (LocDetl locDetl : locDetls) {
|
WrkDetl wrkDetl = new WrkDetl();
|
wrkDetl.sync(locDetl);
|
wrkDetl.setWrkNo(workNo);
|
wrkDetl.setIoTime(new Date());
|
wrkDetl.setAnfme(locDetl.getAnfme());
|
wrkDetl.setAppeTime(new Date());
|
wrkDetl.setModiTime(new Date());
|
if (!wrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作档明细失败");
|
}
|
}
|
}
|
// 修改源库位状态
|
if (locMast.getLocSts().equals("D") || locMast.getLocSts().equals("F")) {
|
locMast.setLocSts("R"); // R.出库预约
|
locMast.setModiTime(new Date());
|
if (!locMastService.updateById(locMast)) {
|
throw new CoolException("更新源库位状态失败");
|
}
|
} else {
|
throw new CoolException("源库位出库失败");
|
}
|
// 修改目标库位状态
|
if (locMast1.getLocSts().equals("O")) {
|
locMast1.setLocSts("S"); // S.入库预约
|
locMast1.setModiTime(new Date());
|
if (!locMastService.updateById(locMast1)) {
|
throw new CoolException("更新目标库位状态失败");
|
}
|
} else {
|
throw new CoolException("移转失败");
|
}
|
|
break;
|
}
|
}
|
|
|
return SUCCESS;
|
}
|
public ReturnT<String> startTwo() {
|
List<LocMast> locMastsF=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","F").eq("lev1",2).orderBy("bay1",false));
|
List<LocMast> locMastsO=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","O").eq("lev1",2).orderBy("bay1",false));
|
if(Cools.isEmpty(locMastsO)){
|
return FAIL;
|
}
|
LocMast locMast1 = locMastsO.get(0);
|
|
LocMast locMast2 = locMastsF.get(locMastsF.size()-1);
|
if(locMast2.getBay1()>locMast1.getBay1()){
|
return FAIL;
|
}
|
|
String locNo=null;
|
for(LocMast locMast:locMastsF){
|
if(locMast.getBay1()<locMast1.getBay1()){
|
locNo=locMast1.getLocNo();
|
}
|
//生成移库任务
|
if(locNo!=null){
|
// 获取工作号
|
int workNo = commonService.getWorkNo(0);
|
// 保存工作档
|
WrkMast wrkMast = new WrkMast();
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(new Date());
|
wrkMast.setWrkSts(0L); // 工作状态：11.生成出库ID
|
wrkMast.setIoType(11); // 入出库状态： 11.库格移载
|
wrkMast.setIoPri(10D);
|
wrkMast.setCrnNo(1);
|
wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位
|
wrkMast.setLocNo(locNo); // 目标库位
|
wrkMast.setFullPlt("Y"); // 满板
|
wrkMast.setPicking("N"); // 拣料
|
wrkMast.setExitMk("N"); // 退出
|
wrkMast.setEmptyMk("N"); // 空板
|
wrkMast.setBarcode(locMast.getBarcode()); // 托盘码
|
wrkMast.setLinkMis("N");
|
wrkMast.setAppeTime(new Date());
|
wrkMast.setModiTime(new Date());
|
|
if (!wrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败");
|
}
|
// 工作档明细保存
|
if (locMast.getLocSts().equals("F")) {
|
List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
|
for (LocDetl locDetl : locDetls) {
|
WrkDetl wrkDetl = new WrkDetl();
|
wrkDetl.setWrkNo(workNo);
|
wrkDetl.setIoTime(new Date());
|
wrkDetl.setAnfme(locDetl.getAnfme());
|
wrkDetl.setAppeTime(new Date());
|
wrkDetl.setModiTime(new Date());
|
if (!wrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作档明细失败");
|
}
|
}
|
}
|
// 修改源库位状态
|
if (locMast.getLocSts().equals("D") || locMast.getLocSts().equals("F")) {
|
locMast.setLocSts("R"); // R.出库预约
|
locMast.setModiTime(new Date());
|
if (!locMastService.updateById(locMast)) {
|
throw new CoolException("更新源库位状态失败");
|
}
|
} else {
|
throw new CoolException("源库位出库失败");
|
}
|
// 修改目标库位状态
|
if (locMast1.getLocSts().equals("O")) {
|
locMast1.setLocSts("S"); // S.入库预约
|
locMast1.setModiTime(new Date());
|
if (!locMastService.updateById(locMast1)) {
|
throw new CoolException("更新目标库位状态失败");
|
}
|
} else {
|
throw new CoolException("移转失败");
|
}
|
|
break;
|
}
|
}
|
return SUCCESS;
|
}
|
|
public ReturnT<String> startThree() {
|
List<LocMast> locMastsF=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","D").eq("lev1",3).orderBy("bay1",true));
|
List<LocMast> locMastsO=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","O").eq("lev1",3).orderBy("bay1",true));
|
if(Cools.isEmpty(locMastsO)){
|
return FAIL;
|
}
|
LocMast locMast1 = locMastsO.get(0);
|
|
LocMast locMast2 = locMastsF.get(locMastsF.size()-1);
|
if(locMast2.getBay1()>locMast1.getBay1()){
|
return FAIL;
|
}
|
|
String locNo=null;
|
for(LocMast locMast:locMastsF){
|
if(locMast.getBay1()<locMast1.getBay1()){
|
locNo=locMast1.getLocNo();
|
}
|
//生成移库任务
|
if(locNo!=null){
|
// 获取工作号
|
int workNo = commonService.getWorkNo(0);
|
// 保存工作档
|
WrkMast wrkMast = new WrkMast();
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(new Date());
|
wrkMast.setWrkSts(0L); // 工作状态：11.生成出库ID
|
wrkMast.setIoType(11); // 入出库状态： 11.库格移载
|
wrkMast.setIoPri(10D);
|
wrkMast.setCrnNo(1);
|
wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位
|
wrkMast.setLocNo(locNo); // 目标库位
|
wrkMast.setFullPlt("Y"); // 满板
|
wrkMast.setPicking("N"); // 拣料
|
wrkMast.setExitMk("N"); // 退出
|
wrkMast.setEmptyMk("N"); // 空板
|
wrkMast.setBarcode(locMast.getBarcode()); // 托盘码
|
wrkMast.setLinkMis("N");
|
wrkMast.setAppeTime(new Date());
|
wrkMast.setModiTime(new Date());
|
|
if (!wrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败");
|
}
|
// 工作档明细保存
|
if (locMast.getLocSts().equals("F")) {
|
List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
|
for (LocDetl locDetl : locDetls) {
|
WrkDetl wrkDetl = new WrkDetl();
|
wrkDetl.setWrkNo(workNo);
|
wrkDetl.setIoTime(new Date());
|
wrkDetl.setAnfme(locDetl.getAnfme());
|
wrkDetl.setAppeTime(new Date());
|
wrkDetl.setModiTime(new Date());
|
if (!wrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作档明细失败");
|
}
|
}
|
}
|
// 修改源库位状态
|
if (locMast.getLocSts().equals("D") || locMast.getLocSts().equals("F")) {
|
locMast.setLocSts("R"); // R.出库预约
|
locMast.setModiTime(new Date());
|
if (!locMastService.updateById(locMast)) {
|
throw new CoolException("更新源库位状态失败");
|
}
|
} else {
|
throw new CoolException("源库位出库失败");
|
}
|
// 修改目标库位状态
|
if (locMast1.getLocSts().equals("O")) {
|
locMast1.setLocSts("S"); // S.入库预约
|
locMast1.setModiTime(new Date());
|
if (!locMastService.updateById(locMast1)) {
|
throw new CoolException("更新目标库位状态失败");
|
}
|
} else {
|
throw new CoolException("移转失败");
|
}
|
|
break;
|
}
|
}
|
return SUCCESS;
|
}
|
public ReturnT<String> startAll() {
|
for(int i=1;i<=3;i++){
|
boolean boo=false;
|
String sts="F";
|
if(i==3){
|
boo=true;
|
sts="D";
|
}
|
List<LocMast> locMastsF=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts",sts).eq("lev1",i).orderBy("bay1",boo));
|
List<LocMast> locMastsO=locMastService.selectList(new EntityWrapper<LocMast>()
|
.eq("loc_sts","O").eq("lev1",i).orderBy("bay1",boo));
|
if(Cools.isEmpty(locMastsO)){
|
continue;
|
}
|
LocMast locMast1 = locMastsO.get(0);
|
|
LocMast locMast2 = locMastsF.get(locMastsF.size()-1);
|
if(i!=3&&locMast2.getBay1()>locMast1.getBay1()){
|
continue;
|
}else if(i==3&&locMast2.getBay1()<locMast1.getBay1()){
|
continue;
|
}
|
|
String locNo=null;
|
for(LocMast locMast:locMastsF){
|
if(i!=3&&locMast.getBay1()<locMast1.getBay1()){
|
locNo=locMast1.getLocNo();
|
}else if(i==3&&locMast.getBay1()>locMast1.getBay1()){
|
locNo=locMast1.getLocNo();
|
}
|
//生成移库任务
|
if(locNo!=null){
|
// 获取工作号
|
int workNo = commonService.getWorkNo(0);
|
// 保存工作档
|
WrkMast wrkMast = new WrkMast();
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(new Date());
|
wrkMast.setWrkSts(0L); // 工作状态：11.生成出库ID
|
wrkMast.setIoType(11); // 入出库状态： 11.库格移载
|
wrkMast.setIoPri(10D);
|
wrkMast.setCrnNo(1);
|
wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位
|
wrkMast.setLocNo(locNo); // 目标库位
|
if(i!=3){
|
wrkMast.setFullPlt("Y"); // 满板
|
wrkMast.setEmptyMk("N"); // 空板
|
}else{
|
wrkMast.setFullPlt("N"); // 满板
|
wrkMast.setEmptyMk("Y"); // 空板
|
}
|
wrkMast.setPicking("N"); // 拣料
|
wrkMast.setExitMk("N"); // 退出
|
|
wrkMast.setBarcode(locMast.getBarcode()); // 托盘码
|
wrkMast.setLinkMis("N");
|
wrkMast.setAppeTime(new Date());
|
wrkMast.setModiTime(new Date());
|
|
if (!wrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败");
|
}
|
// 工作档明细保存
|
if (locMast.getLocSts().equals("F")) {
|
List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
|
for (LocDetl locDetl : locDetls) {
|
WrkDetl wrkDetl = new WrkDetl();
|
wrkDetl.sync(locDetl);
|
wrkDetl.setWrkNo(workNo);
|
wrkDetl.setIoTime(new Date());
|
wrkDetl.setAnfme(locDetl.getAnfme());
|
wrkDetl.setAppeTime(new Date());
|
wrkDetl.setModiTime(new Date());
|
if (!wrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作档明细失败");
|
}
|
}
|
}
|
// 修改源库位状态
|
if (locMast.getLocSts().equals("D") || locMast.getLocSts().equals("F")) {
|
locMast.setLocSts("R"); // R.出库预约
|
locMast.setModiTime(new Date());
|
if (!locMastService.updateById(locMast)) {
|
throw new CoolException("更新源库位状态失败");
|
}
|
} else {
|
throw new CoolException("源库位出库失败");
|
}
|
// 修改目标库位状态
|
if (locMast1.getLocSts().equals("O")) {
|
locMast1.setLocSts("S"); // S.入库预约
|
locMast1.setModiTime(new Date());
|
if (!locMastService.updateById(locMast1)) {
|
throw new CoolException("更新目标库位状态失败");
|
}
|
} else {
|
throw new CoolException("移转失败");
|
}
|
break;
|
}
|
}
|
if (locNo !=null){
|
break;
|
}
|
}
|
return SUCCESS;
|
}
|
}
|
