فهرست منبع

内部服务调用新增超时时间配置

mac 2 سال پیش
والد
کامیت
960de036de

+ 9 - 0
kxs-common/kxs-common-core/src/main/java/com/kxs/common/core/constant/ServiceNameConstants.java

@@ -3,6 +3,8 @@
 package com.kxs.common.core.constant;
 
 
+import java.time.Duration;
+
 /**
  * 服务名称
  *
@@ -13,6 +15,12 @@ public interface ServiceNameConstants {
 
 	String CLIENT_NAME = "http://";
 
+	/**
+	 * 请求超时时间
+	 * 单位:秒
+	 */
+	Duration REQ_TIMEOUT = Duration.ofSeconds(30);
+
 	/**
 	 * 系统模块
 	 */
@@ -32,6 +40,7 @@ public interface ServiceNameConstants {
 	 * 仓库模块
 	 */
 	String STORE_SERVICE = "kxs-store-biz";
+
 	/**
 	 * 统计模块
 	 */

+ 0 - 1
kxs-common/kxs-common-core/src/main/java/com/kxs/common/core/valid/Sn.java

@@ -1,6 +1,5 @@
 package com.kxs.common.core.valid;
 
-import com.kxs.common.core.valid.impl.PhoneValidator;
 import com.kxs.common.core.valid.impl.SnValidator;
 import jakarta.validation.Constraint;
 import jakarta.validation.Payload;

+ 1 - 1
kxs-common/kxs-common-core/src/main/java/com/kxs/common/core/valid/impl/NormMonthValidator.java

@@ -27,7 +27,7 @@ public class NormMonthValidator implements ConstraintValidator<NormMonth, String
 
     @Override
     public boolean isValid(String value, ConstraintValidatorContext context) {
-        if (value == null || value.equals("")){
+        if (value == null || value.isEmpty()){
             return false;
         }
         // 获取【Phone】对象的手机格式验证表达式

+ 1 - 1
kxs-common/kxs-common-core/src/main/java/com/kxs/common/core/valid/impl/PhoneValidator.java

@@ -26,7 +26,7 @@ public class PhoneValidator implements ConstraintValidator<Phone, String> {
 
     @Override
     public boolean isValid(String value, ConstraintValidatorContext context) {
-        if (value == null || value.equals("")){
+        if (value == null || value.isEmpty()){
             return false;
         }
         // 获取【Phone】对象的手机格式验证表达式

+ 1 - 1
kxs-common/kxs-common-core/src/main/java/com/kxs/common/core/valid/impl/SnValidator.java

@@ -26,7 +26,7 @@ public class SnValidator implements ConstraintValidator<Sn, String> {
 
     @Override
     public boolean isValid(String value, ConstraintValidatorContext context) {
-        if (value == null || value.equals("")){
+        if (value == null || value.isEmpty()){
             return false;
         }
         // 获取【sn】对象的手机格式验证表达式

+ 3 - 3
kxs-stat/kxs-stat-api/src/main/java/com/kxs/stat/api/feign/config/KxsStatFeignClientConfiguration.java

@@ -72,13 +72,13 @@ public class KxsStatFeignClientConfiguration {
 	}
 
 	/**
-	 * 远程仓库模块服务
+	 * 远程统计模块服务
 	 * @param client 客户端
-	 * @return 远程仓库模块服务
+	 * @return 远程统计模块服务
 	 */
 	@Bean
 	RemoteKxsStatService remoteKxsStatService(@Qualifier("kxsStatFeignClient") WebClient client) {
-		HttpServiceProxyFactory factory = HttpServiceProxyFactory.builder(WebClientAdapter.forClient(client)).build();
+		HttpServiceProxyFactory factory = HttpServiceProxyFactory.builder(WebClientAdapter.forClient(client)).blockTimeout(ServiceNameConstants.REQ_TIMEOUT).build();
 		return factory.createClient(RemoteKxsStatService.class);
 	}
 

+ 2 - 0
kxs-system/kxs-system-api/src/main/java/com/kxs/system/api/feign/config/KxsSystemFeignClientConfiguration.java

@@ -18,6 +18,8 @@ import org.springframework.web.reactive.function.client.WebClient;
 import org.springframework.web.reactive.function.client.support.WebClientAdapter;
 import org.springframework.web.service.invoker.HttpServiceProxyFactory;
 
+import java.time.Duration;
+
 /**
  * <p>
  * 当前服务的webClient配置

+ 0 - 3
kxs-user/kxs-user-api/src/main/java/com/kxs/user/api/dto/kxsapp/userAccount/UserAmountVariationListDTO.java

@@ -1,10 +1,7 @@
 package com.kxs.user.api.dto.kxsapp.userAccount;
 
 import com.kxs.common.core.valid.NormMonth;
-import com.kxs.common.core.valid.Phone;
 import io.swagger.v3.oas.annotations.media.Schema;
-import jakarta.validation.constraints.NotBlank;
-import jakarta.validation.constraints.NotEmpty;
 import lombok.Data;
 
 import java.util.List;