package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.entity.rcs.RcsReturn;
|
import com.zy.asrs.entity.rcs.RcsTaskSubmit;
|
import com.zy.asrs.entity.rcs.RcsTaskTargetRoute;
|
import com.zy.asrs.service.*;
|
import com.zy.asrs.utils.OrderInAndOutUtil;
|
import com.zy.common.model.LocDto;
|
import com.zy.common.model.TaskDto;
|
import com.zy.common.model.enums.WorkNoType;
|
import com.zy.common.service.CommonService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
|
/**
|
* @author pang.jiabao
|
* @description 济南二机床刀具库相关定时任务
|
* @createDate 2025/12/10 14:25
|
*/
|
@Slf4j
|
@Service
|
public class JlerHandler {
|
|
@Resource
|
private WrkMastService wrkMastService;
|
|
@Resource
|
private RcsService rcsService;
|
|
@Resource
|
private OrderPakoutService orderPakoutService;
|
|
@Resource
|
private OrderDetlPakoutService orderDetlPakoutService;
|
|
@Resource
|
private LocDetlService locDetlService;
|
|
@Resource
|
private LocMastService locMastService;
|
|
@Resource
|
private StaDescService staDescService;
|
|
@Value("${mes.defaultUserId}")
|
public long defaultUserId;
|
|
@Resource
|
private CommonService commonService;
|
|
@Resource
|
private WrkDetlService wrkDetlService;
|
|
@Transactional
|
public void callAgvToWarehouse(WrkMast wrkMast) {
|
|
// 下发给RCS
|
RcsTaskSubmit rcsTaskSubmit = new RcsTaskSubmit();
|
// 模板名
|
rcsTaskSubmit.setTaskType("CTU1");
|
rcsTaskSubmit.setRobotTaskCode(String.valueOf(new Date().getTime()));
|
rcsTaskSubmit.setInitPriority(10); //默认10
|
List<RcsTaskTargetRoute> targetRouteList = new ArrayList<>();
|
RcsTaskTargetRoute startRoute = new RcsTaskTargetRoute();
|
startRoute.setSeq(0);
|
startRoute.setCode(wrkMast.getStaNo());
|
startRoute.setOperation("COLLECT");
|
startRoute.setType("SITE");
|
targetRouteList.add(startRoute);
|
RcsTaskTargetRoute endRoute = new RcsTaskTargetRoute();
|
endRoute.setSeq(1);
|
endRoute.setCode(wrkMast.getLocNo());
|
endRoute.setOperation("DELIVERY");
|
endRoute.setType("STORAGE");
|
targetRouteList.add(endRoute);
|
rcsTaskSubmit.setTargetRoute(targetRouteList);
|
|
// 转发给海康或华晓RCS
|
RcsReturn rcsReturn = rcsService.submitTask(rcsTaskSubmit, 1);
|
if (rcsReturn.getCode().equals("SUCCESS")) {
|
Date now = new Date();
|
wrkMast.setWrkSts(3L);
|
wrkMast.setModiTime(now);
|
wrkMast.setCrnStrTime(now);
|
wrkMast.setTaskNo(rcsTaskSubmit.getRobotTaskCode());
|
wrkMastService.updateById(wrkMast);
|
log.info("出库给料箱机器人发送命令成功，工作号：{}，任务号：{}",wrkMast.getWrkNo(),rcsTaskSubmit.getRobotTaskCode());
|
} else {
|
log.error("出库给料箱机器人发送命令失败，工作号：{}，任务号：{}",wrkMast.getWrkNo(),rcsTaskSubmit.getRobotTaskCode());
|
}
|
}
|
|
/**
|
* 根据出库订单自动生成出库任务
|
*/
|
@Transactional
|
public void autoGenerateOutTask(OrderPakout orderPakout) {
|
List<OrderDetlPakout> orderDetlPakouts = orderDetlPakoutService.selectByOrderId(orderPakout.getId());
|
|
List<LocDto> locDtos = new ArrayList<>();
|
|
Set<String> exist = new HashSet<>();
|
|
for (OrderDetlPakout orderDetl : orderDetlPakouts) {
|
double issued = Optional.of(orderDetl.getAnfme() - orderDetl.getWorkQty()).orElse(0.0D);
|
if (issued <= 0.0D) {
|
continue;
|
}
|
List<LocDetl> locDetls = locDetlService.queryStockAll(null, exist,orderDetl.getMatnr(), orderDetl.getBatch(),
|
orderDetl.getBrand(),orderDetl.getStandby1(),orderDetl.getStandby2(),orderDetl.getStandby3(),orderDetl.getBoxType1(),orderDetl.getBoxType2(),orderDetl.getBoxType3());
|
for (LocDetl locDetl : locDetls) {
|
if (issued > 0) {
|
LocDto locDto = new LocDto(locDetl.getLocNo(), locDetl.getMatnr(), locDetl.getMaktx(), locDetl.getBatch(), orderDetl.getOrderNo(),
|
issued >= locDetl.getAnfme() ? locDetl.getAnfme() : issued);
|
LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetl.getLocNo()));
|
locDto.setFrozen(locDetl.getFrozen());
|
locDto.setFrozenLoc(locMast.getFrozen());
|
// List<Integer> staNos = staDescService.queryOutStaNosByLocNo(locDetl.getLocNo(), issued >= locDetl.getAnfme() ? 101 : 103);
|
// locDto.setStaNos(staNos);
|
locDto.setStaNo(103);
|
locDto.setBrand(orderDetl.getBrand());
|
|
locDto.setStandby1(orderDetl.getStandby1());
|
locDto.setStandby2(orderDetl.getStandby2());
|
locDto.setStandby3(orderDetl.getStandby3());
|
locDto.setBoxType1(orderDetl.getBoxType1());
|
locDto.setBoxType2(orderDetl.getBoxType2());
|
locDto.setBoxType3(orderDetl.getBoxType3());
|
locDtos.add(locDto);
|
exist.add(locDetl.getLocNo());
|
// 剩余待出数量递减
|
issued = issued - locDetl.getAnfme();
|
} else {
|
break;
|
}
|
}
|
if (issued > 0) {
|
LocDto locDto = new LocDto(null, orderDetl.getMatnr(), orderDetl.getMaktx(), orderDetl.getBatch(), orderDetl.getOrderNo(), issued);
|
locDto.setBrand(orderDetl.getBrand());
|
locDto.setStandby1(orderDetl.getStandby1());
|
locDto.setStandby2(orderDetl.getStandby2());
|
locDto.setStandby3(orderDetl.getStandby3());
|
locDto.setBoxType1(orderDetl.getBoxType1());
|
locDto.setBoxType2(orderDetl.getBoxType2());
|
locDto.setBoxType3(orderDetl.getBoxType3());
|
locDto.setLack(Boolean.TRUE);
|
locDtos.add(locDto);
|
}
|
}
|
|
List<LocDto> locDtoArrayList = new ArrayList<>();
|
//
|
for (LocDto locDto : locDtos){
|
if (locDto.getFrozen()!=1 && locDto.getFrozenLoc()!=1 && !locDto.isLack()){
|
locDtoArrayList.add(locDto);
|
} else {
|
log.warn("库位/库存被冻结或库存不足:{}", JSONObject.toJSONString(locDto));
|
}
|
}
|
locDtos = locDtoArrayList;
|
|
List<TaskDto> taskDtos = new ArrayList<>();
|
// 根据 （库位 & 出库站） 分组； 理想状态：一组为一次出库任务
|
for (LocDto locDto : locDtos) {
|
if (locDto.isLack()) { continue; }
|
TaskDto taskDto = new TaskDto(locDto.getLocNo(), locDto.getStaNo(), locDto);
|
if (TaskDto.has(taskDtos, taskDto)) {
|
TaskDto dto = TaskDto.find(taskDtos, taskDto);
|
assert dto != null;
|
dto.getLocDtos().addAll(taskDto.getLocDtos());
|
} else {
|
taskDtos.add(taskDto);
|
}
|
}
|
// -----------------------------------------------------------------------------------------------
|
long userId = defaultUserId;
|
for (TaskDto taskDto : taskDtos) {
|
Date now = new Date();
|
// 获取库位
|
LocMast locMast = locMastService.selectById(taskDto.getLocNo());
|
int ioType = taskDto.isAll() ? 101 : 103;
|
// 生成工作号
|
int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));
|
// 生成工作档
|
WrkMast wrkMast = new WrkMast();
|
wrkMast.setWrkNo(workNo);
|
wrkMast.setIoTime(now);
|
wrkMast.setWrkSts(11L); // 工作状态：11.生成出库ID
|
wrkMast.setIoType(ioType); // 入出库状态
|
wrkMast.setIoPri(13D); // 优先级：13
|
wrkMast.setCrnNo(locMast.getCrnNo());
|
wrkMast.setSourceStaNo("101"); // 源站
|
wrkMast.setStaNo("103"); // 目标站
|
wrkMast.setSourceLocNo(taskDto.getLocNo()); // 源库位
|
wrkMast.setFullPlt("Y"); // 满板：Y
|
wrkMast.setPicking("N"); // 拣料
|
wrkMast.setExitMk("N"); // 退出
|
wrkMast.setEmptyMk("N"); // 空板
|
wrkMast.setLinkMis("N");
|
wrkMast.setBarcode(locMast.getBarcode());
|
wrkMast.setAppeUser(userId); // 操作人员数据
|
wrkMast.setAppeTime(now);
|
wrkMast.setModiUser(userId);
|
wrkMast.setModiTime(now);
|
if (!wrkMastService.insert(wrkMast)) {
|
throw new CoolException("保存工作档失败，出库库位号：" + taskDto.getLocNo());
|
}
|
// 生成工作档明细
|
for (LocDto locDto : taskDto.getLocDtos()) {
|
if (locDto.getAnfme() == null || locDto.getAnfme() <= 0.0D) {
|
continue;
|
}
|
OrderDetl orderDetl = OrderInAndOutUtil.selectItem(Boolean.FALSE, locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch(), locDto.getBrand()
|
, locDto.getStandby1(), locDto.getStandby2(), locDto.getStandby3(), locDto.getBoxType1(), locDto.getBoxType2(), locDto.getBoxType3());
|
|
WrkDetl wrkDetl = new WrkDetl();
|
wrkDetl.sync(orderDetl);
|
wrkDetl.setZpallet(wrkMast.getBarcode());
|
wrkDetl.setIoTime(now);
|
wrkDetl.setWrkNo(workNo);
|
wrkDetl.setBatch(locDto.getBatch());
|
wrkDetl.setOrderNo(locDto.getOrderNo());
|
wrkDetl.setAnfme(locDto.getAnfme()); // 数量
|
wrkDetl.setAppeTime(now);
|
wrkDetl.setAppeUser(userId);
|
wrkDetl.setModiTime(now);
|
wrkDetl.setModiUser(userId);
|
wrkDetl.setMatnr(orderDetl.getMatnr());
|
wrkDetl.setMaktx(orderDetl.getMaktx());
|
wrkDetl.setSpecs(orderDetl.getSpecs());
|
wrkDetl.setModel(orderDetl.getModel());
|
wrkDetl.setUnit(orderDetl.getUnit());
|
wrkDetl.setThreeCode(String.valueOf(orderPakout.getDocType())); // 单据类型,rcs反馈end到wcs时给tms上报用
|
if (!wrkDetlService.insert(wrkDetl)) {
|
throw new CoolException("保存工作档明细失败");
|
}
|
OrderInAndOutUtil.increaseWorkQty(Boolean.FALSE, orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(),
|
orderDetl.getBrand(), orderDetl.getStandby1(), orderDetl.getStandby2(), orderDetl.getStandby3(),
|
orderDetl.getBoxType1(), orderDetl.getBoxType2(), orderDetl.getBoxType3()
|
, locDto.getAnfme());
|
log.info("根据订单自动生成出库任务成功【工作号：{}，订单号：{}，物料：{}，数量：{}】",workNo,locDto.getOrderNo(),locDto.getMatnr(),locDto.getAnfme());
|
}
|
// 修改库位状态: F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中
|
locMast = locMastService.selectById(taskDto.getLocNo());
|
if (locMast.getLocSts().equals("F")) {
|
locMast.setLocSts(ioType == 101 ? "R" : "P");
|
locMast.setModiUser(userId);
|
locMast.setModiTime(now);
|
if (!locMastService.updateById(locMast)) {
|
throw new CoolException("预约库位状态失败，库位号：" + taskDto.getLocNo());
|
}
|
} else {
|
throw new CoolException(taskDto.getLocNo() + "库位不是在库状态");
|
}
|
}
|
OrderInAndOutUtil.updateOrder(Boolean.FALSE, orderPakout.getId(), 2L, userId);
|
}
|
|
public void outboundCallBinRobot(WrkMast wrkMast) {
|
// 下发给RCS
|
RcsTaskSubmit rcsTaskSubmit = new RcsTaskSubmit();
|
// 模板名
|
rcsTaskSubmit.setTaskType("F11");
|
rcsTaskSubmit.setRobotTaskCode(String.valueOf(new Date().getTime()));
|
rcsTaskSubmit.setInitPriority(10); //默认10
|
List<RcsTaskTargetRoute> targetRouteList = new ArrayList<>();
|
RcsTaskTargetRoute startRoute = new RcsTaskTargetRoute();
|
startRoute.setSeq(0);
|
startRoute.setCode(wrkMast.getSourceLocNo());
|
startRoute.setOperation("COLLECT");
|
startRoute.setType("STORAGE");
|
targetRouteList.add(startRoute);
|
RcsTaskTargetRoute endRoute = new RcsTaskTargetRoute();
|
endRoute.setSeq(1);
|
endRoute.setCode(wrkMast.getSourceStaNo());
|
endRoute.setOperation("DELIVERY");
|
endRoute.setType("SITE");
|
targetRouteList.add(endRoute);
|
rcsTaskSubmit.setTargetRoute(targetRouteList);
|
|
// 转发给海康或华晓RCS
|
RcsReturn rcsReturn = rcsService.submitTask(rcsTaskSubmit, 1);
|
if (rcsReturn.getCode().equals("SUCCESS")) {
|
Date now = new Date();
|
wrkMast.setWrkSts(12L);
|
wrkMast.setModiTime(now);
|
wrkMast.setCrnStrTime(now);
|
wrkMast.setTaskNo(rcsTaskSubmit.getRobotTaskCode());
|
wrkMastService.updateById(wrkMast);
|
log.info("出库给料箱机器人发送命令成功，工作号：{}，任务号：{}",wrkMast.getWrkNo(),rcsTaskSubmit.getRobotTaskCode());
|
} else {
|
log.error("出库给料箱机器人发送命令失败，工作号：{}，任务号：{}",wrkMast.getWrkNo(),rcsTaskSubmit.getRobotTaskCode());
|
}
|
}
|
}
|
