mt-ck/mt-qj-wms-hd
7
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: mt-ck:f2de6a3a04c91348dc9e35596230bea4f994128d
Branches Tags
mt-ck:master
mt-ck:mt-qj-wms
mt-ck:mt-qj-wcs
..
compare: mt-ck:5aa655b2b048f07788febbc1fa967f914c8bc2c1
Branches Tags
mt-ck:master
mt-ck:mt-qj-wms
mt-ck:mt-qj-wcs

No commits in common. "f2de6a3a04c91348dc9e35596230bea4f994128d" and "5aa655b2b048f07788febbc1fa967f914c8bc2c1" have entirely different histories.
f2de6a3a04 ... 5aa655b2b0

3 changed files with 3 additions and 9 deletions
Show Stats Expand all files Collapse all files

8
6.program/wms-empty/src/main/java/com/mt/wms/empty/task/AsynRunTaskService.java
View File

@ -86,7 +86,7 @@ public class AsynRunTaskService extends BaseService {
//工业炉可用未满的情况下，调用车辆起点为提升台终点为工业炉
@Async("asyncServiceExecutor")
public void asynRunTask(Long currTaskId, Long vehicleId) throws IOException, InterruptedException {
public void asynRunTask(Long currTaskId, Long vehicleId) throws IOException {
CurrTask currTask = currTaskServiceBiz.getById(currTaskId);
VehicleInfo vehicle = vehicleInfoServiceBiz.getById(vehicleId);
List<CurrTaskDet> currTaskDetList = currTaskDetServiceBiz.list(new QueryWrapper<CurrTaskDet>().eq(CurrTaskDet.CURR_TASK_ID, currTask));
@ -103,9 +103,7 @@ public class AsynRunTaskService extends BaseService {
runTaskServiceBiz.save(runTask);
//调用车辆填入起终点,得到车辆执行结果
Long startPoint = pointInfoServiceBiz.getOne(new QueryWrapper<PointInfo>().eq(PointInfo.NOTE, runTask.getStartPosition())).getCode();
PointInfo pointInfo = pointInfoServiceBiz.getOne(new QueryWrapper<PointInfo>().eq(PointInfo.NOTE, runTask.getEndPosition()));
Long endPoint = pointInfo.getCode();
logger.info("加工炉: "+pointInfo.getName()+"可用未满,调用车辆: "+vehicleId+" 起点为提升台终点为工业炉");
Long endPoint = pointInfoServiceBiz.getOne(new QueryWrapper<PointInfo>().eq(PointInfo.NOTE, runTask.getEndPosition())).getCode();
Integer status = sendTaskToRgv(vehicleId, currTaskId, startPoint, endPoint, currTask.getPlcValue());
logger.info(String.valueOf(status));
//执行成功,托盘进炉
@ -123,8 +121,6 @@ public class AsynRunTaskService extends BaseService {
currTask.setUpdateTime(LocalDateTime.now());
currTask.setBeginTime(LocalDateTime.now());
currTaskServiceBiz.updateById(currTask);
//程序休眠10秒.防止进炉后允许入炉信号还没消失,就又发了下一个入炉任务.
Thread.sleep(10000);
//更新小车状态
vehicle.setStatus(0);
vehicleInfoServiceBiz.updateById(vehicle);

1
6.program/wms-empty/src/main/java/com/mt/wms/empty/task/ScheduledTask.java
View File

@ -559,7 +559,6 @@ public class ScheduledTask extends BaseService {
vehicleInfoServiceBiz.updateById(vehicleInfo);
asynRunTaskService.asynRunTaskForStockToKiln(inStockInfo.getId(), vehicleId);
}
logger.info("当前两辆车都不在线.无法发起任务!");
}
}
}

3
6.program/wms-gateway/src/main/java/com/mt/wms/gateway/filter/GatewayFilter.java
View File

@ -107,8 +107,7 @@ public class GatewayFilter implements Filter {
if (r != null && r.ok()) {
if (r.getData() != null) {
//不打印
//log.info("loginUser={}", JSON.toJSONString(r.getData()));
log.info("loginUser={}", JSON.toJSONString(r.getData()));
}
chain.doFilter(request, response);
} else {