package com.vincent.rsf.server.manager.schedules;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.server.api.entity.enums.TaskStsType;
|
import com.vincent.rsf.server.manager.entity.*;
|
import com.vincent.rsf.server.manager.service.*;
|
import com.vincent.rsf.server.system.constant.SerialRuleCode;
|
import com.vincent.rsf.server.system.enums.LocStsType;
|
import com.vincent.rsf.server.system.utils.SerialRuleUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.sql.Array;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Author Ryan
|
* 任务工作档
|
*/
|
@Component
|
public class TaskSchedules {
|
|
@Autowired
|
private TaskService taskService;
|
@Autowired
|
private TaskItemService taskItemService;
|
@Autowired
|
private StockItemService stockItemService;
|
@Autowired
|
private PurchaseService purchaseService;
|
@Autowired
|
private AsnOrderService asnOrderService;
|
@Autowired
|
private AsnOrderItemService asnOrderItemService;
|
@Autowired
|
private StockService stockService;
|
@Autowired
|
private LocService locService;
|
/**
|
* @author Ryan
|
* @description 完成入库，更新库存
|
* @param
|
* @return
|
* @time 2025/4/2 12:37
|
*/
|
@Scheduled(cron = "0 0/05 * * * ? ")
|
// @Scheduled(cron = "0/5 * * * * ?")
|
@Transactional(rollbackFor = Exception.class)
|
public void completeInStock() throws Exception {
|
List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_IN.id));
|
if (tasks.isEmpty()) {
|
return;
|
}
|
taskService.completeTask(tasks);
|
}
|
}
|
