更新标准输送线程序代码；generateBusAndTask补充校验任务是否存校验逻辑

zhang

2 天以前 6eb6558c6e3f092a4585c39eae2b4a295400c5f6

 zy-acs-manager/src/main/java/com/zy/acs/manager/core/service/ValidService.java

@@ -15,6 +15,7 @@
import com.zy.acs.manager.manager.service.CodeService;
import com.zy.acs.manager.manager.service.LocService;
import com.zy.acs.manager.manager.service.StaService;
import com.zy.acs.manager.manager.service.TaskService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -41,14 +42,19 @@
    private SnowflakeIdWorker snowflakeIdWorker;
    @Autowired
    private UplinkProperties uplinkProperties;
    @Autowired
    private TaskService taskService;

    public List<Task> validTaskDtoList(List<TaskDto> taskDtoList) {
    public List<Task> validTaskDtoList(Long batchNo, List<TaskDto> taskDtoList) {
        List<Task> taskList = new ArrayList<>();
        String uplinkSts = uplinkProperties.getEnabled() ? TaskUplinkStateType.PENDING.toString() : TaskUplinkStateType.SKIPPED.toString();
        for (TaskDto taskDto : taskDtoList) {
            if (Cools.isEmpty(taskDto.getTaskNo())) {
                throw new BusinessException("Task seqNum can't be empty!");
            }
            if (taskService.selectBySeqNum(batchNo, taskDto.getTaskNo()) != null){
                throw new BusinessException("Task seqNum is exist!");
            }
            taskDto.setPriority(Optional.ofNullable(taskDto.getPriority()).orElse(1));
            Task task = new Task();
            taskList.add(task);