package com.zy.acs.manager.core.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.zy.acs.framework.common.Cools;
|
import com.zy.acs.manager.common.utils.LocUtils;
|
import com.zy.acs.manager.core.domain.Lane;
|
import com.zy.acs.manager.manager.entity.Agv;
|
import com.zy.acs.manager.manager.entity.AgvModel;
|
import com.zy.acs.manager.manager.entity.Task;
|
import com.zy.acs.manager.manager.enums.TaskStsType;
|
import com.zy.acs.manager.manager.service.AgvModelService;
|
import com.zy.acs.manager.manager.service.AgvService;
|
import com.zy.acs.manager.manager.service.TaskService;
|
import com.zy.acs.manager.system.service.ConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* Created by vincent on 8/12/2024
|
*/
|
@Slf4j
|
@Service
|
public class AllocateService {
|
|
@Autowired
|
private AgvService agvService;
|
@Autowired
|
private AgvModelService agvModelService;
|
@Autowired
|
private ConfigService configService;
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private LaneService laneService;
|
|
/**
|
* get available agv list which is idle
|
*/
|
private List<Agv> getAvailableAgv() {
|
List<Agv> result = new ArrayList<>();
|
List<Agv> agvList = agvService.list(new LambdaQueryWrapper<Agv>().eq(Agv::getStatus, 1));
|
Collections.shuffle(agvList);
|
for (Agv agv : agvList) {
|
|
// 1. without running tasks
|
if (0 < taskService.count(new LambdaQueryWrapper<Task>()
|
.eq(Task::getAgvId, agv.getId())
|
.and(i ->
|
i.eq(Task::getTaskSts, TaskStsType.ASSIGN.val())
|
.or().eq(Task::getTaskSts, TaskStsType.PROGRESS.val())
|
)
|
)) {
|
continue;
|
}
|
|
// 2. in idle status
|
if (!agvService.judgeEnable(agv.getId(), true)) {
|
continue;
|
}
|
|
result.add(agv);
|
}
|
|
return result;
|
}
|
|
/**
|
* 1. 判断task的起始点和目的点所在的巷道承载任务数量，
|
* 如果数量已经达到负载，则判断负载任务的AGV是否还有空背篓，如果有则优先派发给它，
|
* 如果没有了，那么则阻塞任务，直到该巷道释放
|
* 2. 轮询空闲小车，目标是让每台小车都动起来
|
* 判断逻辑：背篓数量最少的小车轮询的时候，优先级最高
|
*
|
* it can break the limit of the number of agv backpack
|
*/
|
public synchronized Agv execute(Task task) {
|
List<Agv> availableAgvList = getAvailableAgv();
|
if (Cools.isEmpty(availableAgvList)) {
|
log.warn("No available agv to assign the task[{}]", task.getSeqNum());
|
return null;
|
}
|
List<String> availableAgvNos = availableAgvList.stream().map(Agv::getUuid).distinct().collect(Collectors.toList());
|
|
Integer maxAgvCountInLane = configService.getVal("maxAgvCountInLane", Integer.class);
|
|
// checkout lane
|
Lane originLane = taskService.checkoutOriginLane(task);
|
Lane destinationLane = taskService.checkoutDestinationLane(task);
|
|
|
// allocate about origin
|
List<String> availableAgvNosByOriLane = new ArrayList<>(availableAgvNos);
|
if (null != originLane) {
|
List<String> agvNosByOriLane = findAgvNosByLane(originLane); // the agv list that had tasks in this lane
|
if (!Cools.isEmpty(agvNosByOriLane) && agvNosByOriLane.size() >= maxAgvCountInLane) {
|
|
availableAgvNosByOriLane = Cools.getIntersection(agvNosByOriLane, availableAgvNos);
|
}
|
}
|
// valid backpack limit
|
availableAgvNosByOriLane = this.validBackpackLimit(availableAgvNosByOriLane);
|
|
|
// allocate about destination
|
List<String> availableAgvNosByDestLane = new ArrayList<>(availableAgvNos);
|
if (null != destinationLane) {
|
List<String> agvNosByDestLane = findAgvNosByLane(destinationLane);
|
if (!Cools.isEmpty(agvNosByDestLane) && agvNosByDestLane.size() >= maxAgvCountInLane) {
|
|
availableAgvNosByDestLane = Cools.getIntersection(agvNosByDestLane, availableAgvNos);
|
}
|
}
|
availableAgvNosByDestLane = this.validBackpackLimit(availableAgvNosByDestLane);
|
|
// valid
|
if (Cools.isEmpty(availableAgvNosByOriLane)) {
|
log.warn("No available agv to assign the task origin[{}]", task.getSeqNum());
|
return null;
|
}
|
if (Cools.isEmpty(availableAgvNosByDestLane)) {
|
log.warn("No available agv to assign the task destination[{}]", task.getSeqNum());
|
return null;
|
}
|
|
List<String> actualAvailableAgvNos = Cools.getIntersection(availableAgvNosByOriLane, availableAgvNosByDestLane);
|
if (Cools.isEmpty(actualAvailableAgvNos)) {
|
log.warn("No available agv to assign the task[{}]", task.getSeqNum());
|
return null;
|
}
|
|
// choose min number of running task
|
actualAvailableAgvNos.sort(new Comparator<String>() {
|
@Override
|
public int compare(String agvNo1, String agvNo2) {
|
return calcAllocateWeight(agvNo2, task) - calcAllocateWeight(agvNo1, task);
|
}
|
});
|
|
|
if (null != originLane) {
|
task.setOriLaneHash(originLane.getHashCode());
|
}
|
if (null != destinationLane) {
|
task.setDestLaneHash(destinationLane.getHashCode());
|
}
|
|
return agvService.selectByUuid(actualAvailableAgvNos.stream().findFirst().orElse(null));
|
}
|
|
private List<String> findAgvNosByLane(Lane lane) {
|
if (null == lane) {
|
return null;
|
}
|
List<Task> taskList = taskService.findRunningTasksByLaneHash(lane.getHashCode());
|
if (Cools.isEmpty(taskList)) {
|
return null;
|
}
|
return taskList.stream().map(task -> {
|
return agvService.getById(task.getAgvId()).getUuid();
|
}).distinct().collect(Collectors.toList());
|
}
|
|
// calculate wight
|
private int calcAllocateWeight(String agvNo, Task task) {
|
int weight = 0;
|
Agv agv = agvService.selectByUuid(agvNo);
|
List<Task> runningTasks = taskService.findRunningTasksByAgv(agv.getId());
|
if (!Cools.isEmpty(runningTasks)) {
|
weight = weight + runningTasks.size() * 10;
|
}
|
|
return weight;
|
}
|
|
private List<String> validBackpackLimit(List<String> agvNoList) {
|
if (Cools.isEmpty(agvNoList)) {
|
return new ArrayList<>();
|
}
|
return agvNoList.stream().filter(agvNo -> {
|
Agv agv = agvService.selectByUuid(agvNo);
|
AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
|
List<Task> runningTasks = taskService.findRunningTasksByAgv(agv.getId());
|
return runningTasks.size() < agvModel.getBackpack();
|
}).collect(Collectors.toList());
|
}
|
|
public synchronized Agv execute(Task task, Map<String, List<Long>> taskAllot, List<Long> taskIds) {
|
String oriLocNo = task.getOriLoc$();
|
int oriLocRow = LocUtils.getRow(oriLocNo);
|
String destLocNo = task.getDestLoc$();
|
int destLocRow = LocUtils.getRow(destLocNo);
|
|
Agv hit = null;
|
|
List<Agv> agvList = agvService.list(new LambdaQueryWrapper<Agv>().eq(Agv::getStatus, 1));
|
Collections.shuffle(agvList);
|
for (Agv agv : agvList) {
|
AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
|
int allotTaskCount = 0;
|
List<Long> allotTaskIds = taskAllot.get(agv.getUuid());
|
if (!Cools.isEmpty(allotTaskIds)) {
|
allotTaskCount = allotTaskIds.size();
|
}
|
if (allotTaskCount >= agvModel.getBackpack()) {
|
continue;
|
}
|
if (taskService.count(new LambdaQueryWrapper<Task>()
|
.eq(Task::getAgvId, agv.getId())
|
.notIn(Task::getId, taskIds)
|
.and(i -> {
|
i.eq(Task::getTaskSts, TaskStsType.WAITING.val()) // 已经有waiting任务的车不能再分配
|
.or().eq(Task::getTaskSts, TaskStsType.ASSIGN.val())
|
.or().eq(Task::getTaskSts, TaskStsType.PROGRESS.val());
|
})) > 0) {
|
log.info(agv.getUuid() + "号AGV不可用，已经存在进行中的任务...");
|
continue;
|
}
|
if (!agvService.judgeEnable(agv.getId(), true)) {
|
log.info(agv.getUuid() + "号AGV不可用，" + task.getSeqNum() + "任务无法计算...");
|
continue;
|
}
|
|
hit = agv;
|
break;
|
}
|
|
return hit;
|
}
|
|
public synchronized Agv execute1(Task task, Map<String, List<Long>> taskAllot, List<Long> taskIds) {
|
String oriLocNo = task.getOriLoc$();
|
int oriLocRow = LocUtils.getRow(oriLocNo);
|
String destLocNo = task.getDestLoc$();
|
int destLocRow = LocUtils.getRow(destLocNo);
|
|
Agv agv = null;
|
if (oriLocRow <= 2 && destLocRow <= 2) {
|
agv = agvService.selectByUuid(String.valueOf(1));
|
}
|
if (oriLocRow > 2 && destLocRow > 2) {
|
agv = agvService.selectByUuid(String.valueOf(2));
|
}
|
assert agv != null;
|
AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
|
int allotTaskCount = 0;
|
List<Long> allotTaskIds = taskAllot.get(agv.getUuid());
|
if (!Cools.isEmpty(allotTaskIds)) {
|
allotTaskCount = allotTaskIds.size();
|
}
|
if (allotTaskCount >= agvModel.getBackpack()) {
|
return null;
|
}
|
if (taskService.count(new LambdaQueryWrapper<Task>()
|
.eq(Task::getAgvId, agv.getId())
|
.notIn(Task::getId, taskIds)
|
.and(i -> {
|
i.eq(Task::getTaskSts, TaskStsType.WAITING.val()) // 已经有waiting任务的车不能再分配
|
.or().eq(Task::getTaskSts, TaskStsType.ASSIGN.val())
|
.or().eq(Task::getTaskSts, TaskStsType.PROGRESS.val());
|
})) > 0) {
|
log.info(agv.getUuid() + "号AGV不可用，已经存在进行中的任务...");
|
return null;
|
}
|
if (!agvService.judgeEnable(agv.getId(), true)) {
|
log.info(agv.getUuid() + "号AGV不可用，" + task.getSeqNum() + "任务无法计算...");
|
return null;
|
}
|
|
return agv;
|
}
|
|
}
|
