lsy/FT568-WCS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

简化修改调度逻辑

Browse Source
This commit is contained in:
lsymicc
2026-04-09 14:55:03 +08:00
parent 1a93c78909
commit 9bc0cbf620
1 changed files with 37 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
ruoyi-admin/src/main/java/com/ruoyi/schedule/scheduleTask/ssj/PortConvThread.java
View File

@@ -100,14 +100,14 @@ public class PortConvThread implements Runnable {
public void inDispatch(DeviceSsj inSsjDevice) { public void inDispatch(DeviceSsj inSsjDevice) {
// 测试数据 // 测试数据
inSsjDevice.setInOrOut(1); // inSsjDevice.setInOrOut(1);
inSsjDevice.setTrayCode("T888888"); // inSsjDevice.setTrayCode("T888888");
inSsjDevice.setTaskNo(85012); // inSsjDevice.setTaskNo(85012);
inSsjDevice.setKx(0); // inSsjDevice.setKx(0);
inSsjDevice.setDw(1); // inSsjDevice.setDw(1);
// inSsjDevice.setHeight("1"); // inSsjDevice.setHeight("1");
// inSsjDevice.setWeight("100"); // inSsjDevice.setWeight("100");
inSsjDevice.setException(0); // inSsjDevice.setException(0);
// inSsjDevice.setRkqq(1); // inSsjDevice.setRkqq(1);
switch (inSsjDevice.getInOrOut()) { switch (inSsjDevice.getInOrOut()) {
@@ -124,31 +124,10 @@ public class PortConvThread implements Runnable {
requestMydoJob(inSsjDevice); requestMydoJob(inSsjDevice);
} }
break; break;
//---------------------------出库模式--------------------------- //---------------------------出库模式---------------------------
case 2: case 2:
//出库到位 finishStockoutMydoJob(inSsjDevice);
if (inSsjDevice.getDw() == 1 && inSsjDevice.getTaskNo() > 0) {
//查询该出库任务
MydoJob mydoJob = mydoJobService.selectMydoJobByTaskNo(Convert.toLong(inSsjDevice.getTaskNo()));
if (mydoJob != null && Integer.parseInt(mydoJob.getInOrOut()) > 20) {
log.info("【出库到位】设备:{}，位置:{}，任务号:{}，出库到位", "输送线:", inSsjDevice.getDeviceCode(), mydoJob.getTaskNo());
mydoJobService.insertHistory(mydoJob.getJobId());
mydoJobService.deleteMydoJobByJobId(mydoJob.getJobId());
JobCallBack jobCallBack = new JobCallBack();
jobCallBack.setType("2");
jobCallBack.setMydojobId(mydoJob.getJobId());
jobCallBack.setStatus("0");
jobCallBack.setTaskNo(Convert.toLong(mydoJob.getTaskNo()));
jobCallBack.setCreateTime(new Date());
jobCallBack.setTaskTypeCode("");//todo ???
jobCallBack.setReqCode(UUID.randomUUID().toString().replace("-", ""));
jobCallBack.setTaskCode(mydoJob.getWmsTaskNo());
// jobCallBack.setSpare1("0");
jobCallBackService.insertJobCallBack(jobCallBack);
}
}
break; break;
} }
@@ -251,6 +230,8 @@ public class PortConvThread implements Runnable {
return m.find() ? m.group(1) : null; return m.find() ? m.group(1) : null;
} }
/** /**
* 请求wms获取wcs任务参数 * 请求wms获取wcs任务参数
* @param inSsjDevice * @param inSsjDevice
@@ -400,4 +381,32 @@ public class PortConvThread implements Runnable {
} }
} }
/**
* 输送机出库到位 - 任务出库完成
* @param inSsjDevice
*/
private void finishStockoutMydoJob(DeviceSsj inSsjDevice){
//出库到位
if (inSsjDevice.getDw() == 1 && inSsjDevice.getTaskNo() > 0) {
//查询该出库任务
MydoJob mydoJob = mydoJobService.selectMydoJobByTaskNo(Convert.toLong(inSsjDevice.getTaskNo()));
if (mydoJob != null && Integer.parseInt(mydoJob.getInOrOut()) > 20) {
log.info("【出库到位】设备:{}，位置:{}，任务号:{}，出库到位", "输送线:", inSsjDevice.getDeviceCode(), mydoJob.getTaskNo());
mydoJobService.insertHistory(mydoJob.getJobId());
mydoJobService.deleteMydoJobByJobId(mydoJob.getJobId());
JobCallBack jobCallBack = new JobCallBack();
jobCallBack.setType("2");
jobCallBack.setMydojobId(mydoJob.getJobId());
jobCallBack.setStatus("0");
jobCallBack.setTaskNo(Convert.toLong(mydoJob.getTaskNo()));
jobCallBack.setCreateTime(new Date());
jobCallBack.setTaskTypeCode("");//todo ???
jobCallBack.setReqCode(UUID.randomUUID().toString().replace("-", ""));
jobCallBack.setTaskCode(mydoJob.getWmsTaskNo());
// jobCallBack.setSpare1("0");
jobCallBackService.insertJobCallBack(jobCallBack);
}
}
}
} }