opt:优化装箱数为1的触发补空任务

This commit is contained in:
2024-07-17 15:50:12 +08:00
parent 660ef38039
commit e58368070b

View File

@@ -9,7 +9,6 @@ import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.nl.b_lms.pdm.bi.slittingproductionplan.service.IPdmBiSlittingproductionplanService; import org.nl.b_lms.pdm.bi.slittingproductionplan.service.IPdmBiSlittingproductionplanService;
import org.nl.b_lms.pdm.bi.slittingproductionplan.service.dao.PdmBiSlittingproductionplan; import org.nl.b_lms.pdm.bi.slittingproductionplan.service.dao.PdmBiSlittingproductionplan;
@@ -33,7 +32,6 @@ import org.nl.wms.sch.manage.AbstractAcsTask;
import org.nl.wms.sch.manage.TaskStatusEnum; import org.nl.wms.sch.manage.TaskStatusEnum;
import org.nl.wms.util.TaskUtil; import org.nl.wms.util.TaskUtil;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -183,11 +181,14 @@ public class ZxDjwTask extends AbstractAcsTask {
* 装箱任务完成,异步调用装箱区->待检区补空任务 * 装箱任务完成,异步调用装箱区->待检区补空任务
*/ */
private void callingVehicleToDjqOrGzq(Integer callingNum) { private void callingVehicleToDjqOrGzq(Integer callingNum) {
if (callingNum == 1) {
autoSendVehicleToDjq.sendVehicleToDjqOrGzq1(IOSEnum.IS_NOTANDYES.code(""));
} else if (callingNum > 1) {
for (int i = 0; i < callingNum; i++) { for (int i = 0; i < callingNum; i++) {
final int index = i;
pool.execute(() -> { pool.execute(() -> {
try { try {
TimeUnit.SECONDS.sleep(4L * index); // 使用固定的延迟时间 4 秒
TimeUnit.SECONDS.sleep(5L);
autoSendVehicleToDjq.sendVehicleToDjqOrGzq1(IOSEnum.IS_NOTANDYES.code("")); autoSendVehicleToDjq.sendVehicleToDjqOrGzq1(IOSEnum.IS_NOTANDYES.code(""));
} catch (InterruptedException e) { } catch (InterruptedException e) {
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();
@@ -196,9 +197,7 @@ public class ZxDjwTask extends AbstractAcsTask {
}); });
} }
} }
}
@Override @Override