package com.zy.asrs.task.handler;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.mapper.Wrapper;
|
import com.baomidou.mybatisplus.plugins.Page;
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.LocMast;
|
import com.zy.asrs.entity.StaDesc;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.entity.param.EmptyPlateOutParam;
|
import com.zy.asrs.service.BasDevpService;
|
import com.zy.asrs.service.LocMastService;
|
import com.zy.asrs.service.StaDescService;
|
import com.zy.asrs.service.WorkService;
|
import com.zy.asrs.service.WrkMastService;
|
import com.zy.asrs.task.AbstractHandler;
|
import com.zy.asrs.task.core.ReturnT;
|
import com.zy.system.entity.Config;
|
import com.zy.system.service.ConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
public class AutoEmptyOutHandler extends AbstractHandler<String> {
|
@Autowired
|
private ConfigService configService;
|
@Autowired
|
private WrkMastService wrkMastService;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired
|
private WorkService workService;
|
@Autowired
|
private BasDevpService basDevpService;
|
@Autowired
|
private StaDescService staDescService;
|
@Transactional
|
public ReturnT<String> start() {
|
try {
|
Config config = configService.selectConfigByCode("EmptyMax");
|
Integer max;
|
if (Cools.isEmpty(config)) {
|
max = 10;
|
}else{
|
max = Integer.valueOf(config.getValue());
|
}
|
for(Integer crnNo = 1; crnNo < 5; crnNo++){
|
List<WrkMast> wrkMastList = wrkMastService.selectList(new EntityWrapper<WrkMast>()
|
.eq("crn_no", crnNo)
|
.eq("io_type", 110)
|
);
|
if(!wrkMastList.isEmpty()){continue;}
|
Integer emptyLocCount = locMastService.selectCount(new EntityWrapper<LocMast>()
|
.eq("crn_no", crnNo)
|
.eq("loc_sts", "O")
|
.eq("frozen", 0)
|
.eq("deleted", 0)
|
.eq("whs_type", 1));
|
if (emptyLocCount == null || emptyLocCount >= max) {
|
continue;
|
}
|
|
List<LocMast> locMastDList = locMastService.selectPage(
|
new Page<>(1, 3), //选三个空轴库位
|
new EntityWrapper<LocMast>()
|
.eq("crn_no", crnNo)
|
.eq("loc_sts", "D")
|
.eq("frozen", 0)
|
.eq("deleted", 0)
|
.eq("whs_type", 1)
|
.orderBy("lev1,bay1")
|
).getRecords();
|
if (Cools.isEmpty(locMastDList)) {
|
continue;
|
}
|
|
List<String> locNos = new ArrayList<>();
|
for (LocMast locMast : locMastDList) {
|
locNos.add(locMast.getLocNo());
|
}
|
EmptyPlateOutParam emptyPlateOutParam = new EmptyPlateOutParam();
|
emptyPlateOutParam.setOutSite(1076);
|
emptyPlateOutParam.setLocNos(locNos);
|
workService.emptyPlateOut(emptyPlateOutParam, 1L);
|
|
}
|
|
} catch (Exception e) {
|
log.error("fail", e);
|
e.printStackTrace();
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
return FAIL.setMsg(e.getMessage());
|
}
|
return SUCCESS;
|
}
|
|
|
}
|
