package com.zy.asrs.task.handler;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.core.common.Cools;
|
import com.zy.asrs.entity.WrkMast;
|
import com.zy.asrs.entity.mes.MesInApply;
|
import com.zy.asrs.entity.mes.MesOutApply;
|
import com.zy.asrs.entity.mes.TransTask;
|
import com.zy.asrs.service.MesService;
|
import com.zy.asrs.service.WrkMastService;
|
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.ArrayList;
|
|
/**
|
* @author pang.jiabao
|
* @description 济南二机床加工相关定时任务
|
* @createDate 2025/12/10 14:25
|
*/
|
@Slf4j
|
@Service
|
public class JlerHandler {
|
|
@Resource
|
private MesService mesService;
|
|
@Value("${wms.wmsTransStartStation3}")
|
public String WMS_TRANS_START_STATION_3;
|
|
@Value("${wms.zpalletId}")
|
public String WMS_ZPALLET_ID;
|
|
@Resource
|
private WrkMastService wrkMastService;
|
|
@Transactional
|
public void createAgvOutTasks(WrkMast wrkMast) {
|
|
String memo = wrkMast.getMemo();
|
MesOutApply mesOutApply = null;
|
if(!Cools.isEmpty(memo)) {
|
mesOutApply = JSONObject.parseObject(memo, MesOutApply.class);
|
}
|
|
// 空托出库
|
if(wrkMast.getIoType() == 110) {
|
if(mesOutApply == null) { // 不是mes下发的空托出库
|
TransTask transTask = new TransTask();
|
// transTask.setTaskno(mesOutApply.getTaskno());
|
// transTask.setTaskname(mesOutApply.getTaskname());
|
// transTask.setOrderNo(mesOutApply.getOrderNo());
|
transTask.setTransType("01");
|
transTask.setCurStationId(WMS_TRANS_START_STATION_3);
|
// transTask.setNextProcess(mesOutApply.getProductLineId());
|
transTask.setNextStationId(wrkMast.getAgvSta());
|
transTask.setItemno(WMS_ZPALLET_ID); // 固定为空托的编码
|
transTask.setQty(1); // 空托只出1个
|
// transTask.setProductLineId(mesOutApply.getProductLineId());
|
transTask.setOperateType(1);
|
transTask.setAgvFactory(1);
|
JSONObject sendAgvTask = mesService.submitTask(transTask);
|
if ("1".equals(sendAgvTask.getString("Success"))) {
|
String taskno = sendAgvTask.getString("taskno");
|
if(Cools.isEmpty(wrkMast.getTaskNo())) {
|
wrkMast.setTaskNo(taskno);
|
}
|
wrkMast.setCallAgv(1);
|
wrkMastService.updateById(wrkMast);
|
}else {
|
log.error("出库下发agv运输任务失败：{}", JSONObject.toJSONString(transTask));
|
}
|
} else {
|
TransTask transTask = new TransTask();
|
transTask.setTaskno(mesOutApply.getTaskno());
|
transTask.setTaskname(mesOutApply.getTaskname());
|
transTask.setOrderNo(mesOutApply.getOrderNo());
|
transTask.setTransType(mesOutApply.getTransType());
|
transTask.setCurStationId(WMS_TRANS_START_STATION_3);
|
transTask.setNextProcess(mesOutApply.getProductLineId());
|
transTask.setNextStationId(mesOutApply.getStationId());
|
transTask.setItemno(WMS_ZPALLET_ID); // 固定为空托的编码
|
transTask.setItemBarcode(new ArrayList<>()); // 没有零件二维码
|
transTask.setQty(1); // 空托只出1个
|
transTask.setProductLineId(mesOutApply.getProductLineId());
|
transTask.setOperateType(1);
|
transTask.setAgvFactory(1);
|
JSONObject sendAgvTask = mesService.submitTask(transTask);
|
if ("1".equals(sendAgvTask.getString("Success"))) {
|
// String taskno = sendAgvTask.getString("taskno");
|
// if(Cools.isEmpty(wrkMast.getTaskNo())) {
|
// wrkMast.setTaskNo(taskno);
|
// }
|
wrkMast.setCallAgv(1);
|
wrkMastService.updateById(wrkMast);
|
}else {
|
log.error("出库下发agv运输任务失败：{}", JSONObject.toJSONString(transTask));
|
}
|
}
|
} else if(wrkMast.getIoType() == 101) { // 满托出库
|
if(mesOutApply == null) {
|
log.error("满托出库呼叫agv无transTask，任务号：{}",wrkMast.getWrkNo());
|
} else {
|
TransTask transTask = new TransTask();
|
transTask.setTaskno(mesOutApply.getTaskno());
|
transTask.setTaskname(mesOutApply.getTaskname());
|
transTask.setOrderNo(mesOutApply.getOrderNo());
|
transTask.setTransType(mesOutApply.getTransType());
|
transTask.setCurStationId(WMS_TRANS_START_STATION_3);
|
transTask.setNextProcess(mesOutApply.getProductLineId());
|
transTask.setNextStationId(mesOutApply.getStationId());
|
transTask.setItemno(mesOutApply.getItemno());
|
transTask.setQty(mesOutApply.getQty());
|
transTask.setProductLineId(mesOutApply.getProductLineId());
|
transTask.setItemBarcode(mesOutApply.getItemBarcode());
|
transTask.setTuoPanId(wrkMast.getBarcode());
|
transTask.setOperateType(1);
|
transTask.setAgvFactory(1);
|
|
JSONObject sendAgvTask = mesService.submitTask(transTask);
|
if ("1".equals(sendAgvTask.getString("Success"))) {
|
// String taskno = sendAgvTask.getString("taskno");
|
// if(Cools.isEmpty(wrkMast.getTaskNo())) {
|
// wrkMast.setTaskNo(taskno);
|
// }
|
wrkMast.setCallAgv(1);
|
wrkMastService.updateById(wrkMast);
|
}else {
|
log.error("出库下发agv运输任务失败：{}", JSONObject.toJSONString(transTask));
|
}
|
}
|
} else {
|
log.error("出库呼叫agv任务类型错误，任务号：{}",wrkMast.getWrkNo());
|
}
|
}
|
|
}
|
