diff --git a/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java b/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java index 71187db..caf66be 100644 --- a/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java +++ b/cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java @@ -2,6 +2,7 @@ package com.muyu.task.feign; import com.muyu.common.core.domain.Result; import com.muyu.domain.DataValue; +import com.muyu.task.feign.factory.DataValueClientFactory; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; @@ -17,7 +18,7 @@ import java.util.List; * @date: 2024/9/4 15:13 */ //,fallback = TaskFeignFallback.class -@FeignClient(name = "cloud-source" ) +@FeignClient(name = "cloud-source",fallbackFactory = DataValueClientFactory.class) public interface DataValueClient { /** diff --git a/cloud-task-remote/src/main/java/com/muyu/task/feign/factory/DataValueClientFactory.java b/cloud-task-remote/src/main/java/com/muyu/task/feign/factory/DataValueClientFactory.java new file mode 100644 index 0000000..00e7346 --- /dev/null +++ b/cloud-task-remote/src/main/java/com/muyu/task/feign/factory/DataValueClientFactory.java @@ -0,0 +1,51 @@ +package com.muyu.task.feign.factory; + +import com.muyu.common.core.domain.Result; +import com.muyu.domain.DataValue; +import com.muyu.task.feign.DataValueClient; +import lombok.extern.log4j.Log4j2; +import org.springframework.cloud.openfeign.FallbackFactory; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @PackageName:com.muyu.task.feign.factory + * @ClassName:DataValueClientFactory + * @Description: + * @author: ¥陈思豪¥ + * @date: 2024/9/9 10:48 + */ +@Log4j2 +@Component +public class DataValueClientFactory implements FallbackFactory { + @Override + public DataValueClient create(Throwable cause) { + return new DataValueClient() { + @Override + public Result>> findTableValue(Long basicId, String sql) { + return Result.error("网络开小差"); + } + + @Override + public Integer findCount(Long basicId, String sql) { + return 111111111; + } + + @Override + public Result addTableDataValue(Long basicId, Long tableId, List> dataValue) { + return Result.error("网络开小差"); + } + + @Override + public DataValue[][] findTableValueToArray(Long basicId, String sql, Long one, Integer two) { + return null; + } + + @Override + public Result addProduct(Long basicId, Long tableId, DataValue[][] listList) { + return Result.error("网络开小差"); + } + }; + } +} diff --git a/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java b/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java index e7cfad4..66771c6 100644 --- a/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java +++ b/cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java @@ -300,7 +300,7 @@ public class PriorityThreadPool { task.run(); log.info("执行任务完毕??"); } finally { -// lowPrioritySemaphore.release(); + lowPrioritySemaphore.release(); } }); } catch (InterruptedException e) {