chen.lin
15 小时以前 0b2093ed5234b45c1c4d4c11052d9cda0caeaea8
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/MaterialAutoSchedules.java
@@ -11,6 +11,7 @@
import com.vincent.rsf.server.manager.enums.OrderType;
import com.vincent.rsf.server.manager.enums.OrderWorkType;
import com.vincent.rsf.server.manager.enums.TaskStsType;
import com.vincent.rsf.server.manager.enums.TaskType;
import com.vincent.rsf.server.manager.service.*;
import com.vincent.rsf.server.manager.utils.LocManageUtil;
import com.vincent.rsf.server.system.constant.GlobalConfigCode;
@@ -227,11 +228,41 @@
    }
    /**
     * 定时任务:配置物料出库任务在 RCS 回调为 199(待确认)后自动拣货完成,无需 PDA 快速拣货确认即可更新库存。
     * 配置:AUTO_FULL_OUT_MATNR_CODE(物料编码,配置了则对该物料生效)
     */
    @Scheduled(cron = "0 0/1 * * * ?")
    public void autoConfirmPickOut() {
        Config matnrConfig = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.AUTO_FULL_OUT_MATNR_CODE));
        if (matnrConfig == null || StringUtils.isBlank(matnrConfig.getVal())) {
            return;
        }
        String matnrCode = matnrConfig.getVal().trim();
        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()
                .eq(Task::getTaskType, TaskType.TASK_TYPE_OUT.type)
                .eq(Task::getTaskStatus, TaskStsType.WAVE_SEED.id));
        for (Task task : tasks) {
            long cnt = taskItemService.count(new LambdaQueryWrapper<TaskItem>()
                    .eq(TaskItem::getTaskId, task.getId())
                    .eq(TaskItem::getMatnrCode, matnrCode));
            if (cnt == 0) {
                continue;
            }
            try {
                taskService.completeFullOutStock(task.getId(), SYSTEM_USER_ID);
                log.info("[自动拣货完成] 任务: {}, 料箱: {}, 物料: {} 已自动确认出库并更新库存", task.getTaskCode(), task.getBarcode(), matnrCode);
            } catch (Exception e) {
                log.warn("[自动拣货完成] 任务: {} 处理失败: {}", task.getTaskCode(), e.getMessage());
            }
        }
    }
    /**
     * 定时任务3:无订单组托 + 自动生成入库单(仅针对配置物料,)
     * 先按配置物料与数量做无订单组托,再生成入库单并关联组托明细,便于 RCS 入库闭环。
     * 配置:AUTO_PAKIN_ON_ASN_ENABLED(true)、AUTO_FULL_OUT_MATNR_CODE、AUTO_PAKIN_QTY(数量)
     */
    @Scheduled(cron = "0/35 * * * * ?")
//    @Scheduled(cron = "0/35 * * * * ?")
    @Transactional(rollbackFor = Exception.class)
    public void autoPakinOnInbound() {
        Config enabledConfig = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.AUTO_PAKIN_ON_ASN_ENABLED));