package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.utils.Utils;
|
import com.zy.common.model.StartupDto;
|
import com.zy.common.service.CommonService;
|
import com.zy.common.utils.HttpHandler;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.concurrent.ThreadLocalRandom;
|
|
@Component
|
@Slf4j
|
public class CreateOutTask {
|
@Value("${wcs.address.URL}")
|
private String addrs;
|
@Value("${wcs.address.createOutTask}")
|
private String outTask;
|
@Value("${wcs.address.createLocMoveTask}")
|
private String locMoveTask;
|
@Value("${wcs.address.devicesStatus}")
|
private String devicesStatus;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired
|
private LocDetlService locDetlService;
|
@Autowired
|
private WrkMastService wrkMastService;
|
@Autowired
|
private CommonService commonService;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
|
@Scheduled(cron = "0/10 * * * * ? ")
|
@Transactional
|
public void outTask(){
|
//调用wcs接口获取设备状态
|
String statusResponse = "";
|
try {
|
statusResponse = new HttpHandler.Builder()
|
.setUri(addrs)
|
.setPath(devicesStatus)
|
.build()
|
.doPost();
|
JSONObject jsonObject = JSON.parseObject(statusResponse);
|
if (jsonObject.get("code").equals(200)){
|
log.info("设备正常");
|
}
|
}catch (Exception e){
|
log.error("设备异常");
|
}
|
log.info("开始调用WCS接口,派发出库/移库任务");
|
Date now = new Date();
|
boolean flag= false;
|
List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "F"));
|
List<Integer> outSitelist = new ArrayList<>();
|
outSitelist.add(1152);
|
outSitelist.add(1169);
|
outSitelist.add(1177);
|
LocMast shallowLocMast = new LocMast();
|
for (LocMast locMast : locMasts) {
|
//判断库位是否有出库任务
|
if (!Cools.isEmpty(wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("source_loc_no",locMast.getLocNo())))){
|
continue;
|
}
|
//判断是否是深库位 触发移库任务
|
if (Utils.isDeepLoc(locMast.getLocNo())) {
|
String deepLoc = locMast.getLocNo();
|
String shallowLocNo = Utils.getShallowLocNo(deepLoc);
|
shallowLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", shallowLocNo));
|
if (shallowLocMast.getLocSts().equals("F") || shallowLocMast.getLocSts().equals("D")) {
|
flag = true;
|
}
|
}
|
int outSite = ThreadLocalRandom.current().nextInt(0, outSitelist.size());
|
List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
|
// 目标站点状态检测
|
int workNo = commonService.getWorkNo(2);
|
//生成工作档
|
WrkMast wrkMast = new WrkMast();
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(now);
|
wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID
|
wrkMast.setIoType(flag ? 11 : 101); // 入出库状态
|
wrkMast.setIoPri(flag ? 20D : 15D); // 优先级
|
wrkMast.setCrnNo(locMast.getCrnNo());
|
wrkMast.setStaNo(outSitelist.get(outSite)); // 目标站
|
wrkMast.setSourceLocNo(flag ? shallowLocMast.getLocNo() : locMast.getLocNo()); // 源库位
|
wrkMast.setLocNo(flag ? getMoveLocNo(locMast.getLocNo()) : ""); //目标库位
|
wrkMast.setFullPlt("Y"); // 满板：Y
|
wrkMast.setPicking("N"); // 拣料
|
wrkMast.setExitMk("N"); // 退出
|
wrkMast.setEmptyMk("N"); // 空板
|
wrkMast.setLinkMis("N");
|
wrkMast.setBarcode(locMast.getBarcode());
|
wrkMast.setAppeUser(9527L); // 操作人员数据
|
wrkMast.setAppeTime(now);
|
wrkMast.setModiUser(9527l);
|
wrkMast.setModiTime(now);
|
if (!wrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败，出库库位号：" + locMast.getLocNo());
|
}
|
// 生成工作档明细
|
for (LocDetl locDetl : locDetlList) {
|
if (locDetl.getAnfme() == null || locDetl.getAnfme() <= 0.0D) {
|
continue;
|
}
|
WrkDetl wrkDetl = new WrkDetl();
|
wrkDetl.sync(locDetl);
|
wrkDetl.setOrderNo(""); // 手动出库不需要带出库存中的单据编号
|
wrkDetl.setWrkNo(workNo);
|
wrkDetl.setIoTime(now);
|
Double anfme = locDetl.getAnfme();
|
wrkDetl.setAnfme(anfme); // 数量
|
wrkDetl.setAppeTime(now);
|
wrkDetl.setAppeUser(9527L);
|
wrkDetl.setModiTime(now);
|
wrkDetl.setModiUser(9527L);
|
if (!wrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作档明细失败");
|
}
|
}
|
String response = "";
|
StartupDto startupDto = new StartupDto();
|
startupDto.setTaskNo(wrkMast.getWrkNo());
|
startupDto.setStaNo(wrkMast.getStaNo());
|
startupDto.setLocNo(Utils.locToLocNo(wrkMast.getSourceLocNo()));
|
startupDto.setTaskPri(wrkMast.getIoPri());
|
flag = false;
|
try {
|
response = new HttpHandler.Builder()
|
.setUri(addrs)
|
.setPath(flag ? locMoveTask : outTask)
|
.setJson(JSON.toJSONString(startupDto))
|
.build()
|
.doPost();
|
JSONObject jsonObject = JSON.parseObject(response);
|
if (jsonObject.get("code").equals(200)) {
|
wrkMast.setWrkSts(12L);
|
if (!wrkMastService.updateById(wrkMast)) {
|
throw new CoolException("工作档状态修改失败,工作号:{}" + wrkMast.getWrkNo());
|
}
|
// 修改库位状态: F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中
|
locMast = locMastService.selectById(flag?shallowLocMast.getLocNo():locMast.getLocNo());
|
if (locMast.getLocSts().equals("F")) {
|
locMast.setLocSts("R");
|
locMast.setModiUser(9527L);
|
locMast.setModiTime(now);
|
if (!locMastService.updateById(locMast)) {
|
throw new CoolException("预约库位状态失败，库位号：" + locMast.getLocNo());
|
}
|
} else {
|
throw new CoolException(locMast.getLocNo() + "库位不是在库状态");
|
}
|
log.info("出库/移库任务派发成功");
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
}
|
}
|
}
|
|
//移库任务找空库位 深库位
|
public String getMoveLocNo(String locNo){
|
LocMast targetLocMast = new LocMast();
|
int deepRow = Utils.getRow(locNo);
|
//先找深库位这一排还有没有空位库
|
targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow));
|
if (targetLocMast == null){
|
targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow + 3));
|
|
}
|
if (targetLocMast == null){
|
targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow + 1));
|
|
}
|
if (targetLocMast == null){
|
targetLocMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").eq("row1", deepRow + 2));
|
|
}
|
return targetLocMast.getLocNo();
|
}
|
}
|
