diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java index f9fc045..41962c2 100644 --- a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java +++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java @@ -6,25 +6,19 @@ import com.muyu.common.core.domain.Result; import com.muyu.common.core.utils.StringUtils; import com.muyu.domain.*; import com.muyu.domain.req.TaskInfoReq; -import com.muyu.domain.taskenum.Weight; import com.muyu.mapper.TaskMapper; import com.muyu.service.TaskInputService; import com.muyu.service.TaskJoinService; import com.muyu.service.TaskOutputService; import com.muyu.service.TaskService; import com.muyu.task.feign.DataValueClient; -import jakarta.annotation.Resource; import lombok.extern.log4j.Log4j2; -import org.jetbrains.annotations.NotNull; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.HashSet; import java.util.List; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.PriorityBlockingQueue; import static com.muyu.task.PriorityThreadPool.executeUrgently; @@ -250,6 +244,7 @@ public class TaskServiceImpl extends ServiceImpl implement } String limitSelect = sql + limit; log.info("执行查询语句为{}", limitSelect); + log.info(databaseId); Result tableValue = dataValueClient.findTableValue(databaseId, limitSelect); log.info("远程调用完毕,idaoyong 调用返回的是{}", tableValue); List> data = (List>) tableValue.getData();