diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/AbstractLoadSPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/AbstractLoadSPI.java index d1466622fe43dedcfe3db1c308c92ecc4bf5a0a0..6a48a557fab2ddb013cfa7d4f8a7bdf9c51c8fcb 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/AbstractLoadSPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/AbstractLoadSPI.java @@ -49,8 +49,10 @@ public abstract class AbstractLoadSPI { /** http实例 */ protected static final Client CLIENT = OkHttpClientImpl.getInstance(); + /** DEFAULT_APPLICATION_JSON_VALUE */ public static final String DEFAULT_APPLICATION_JSON_VALUE = "application/json"; + /** DEFAULT_TIMEOUT */ private static final int DEFAULT_TIMEOUT = 3; diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpBaseDataSPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpBaseDataSPI.java index 07650750bf38f03547e750ba4e7032c85e5b1232..72c0f109e2db5a6b2b00de96114913c13d8c952a 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpBaseDataSPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpBaseDataSPI.java @@ -1,11 +1,15 @@ package cn.icanci.rec.engine.sdk.http.spi; +import cn.icanci.rec.common.aggregation.WebApiRequest; import cn.icanci.rec.common.aggregation.model.BaseDataDTO; +import cn.icanci.rec.engine.script.client.http.HttpMethod; import cn.icanci.rec.engine.sdk.spi.BaseDataSPI; import java.util.List; import java.util.Set; +import com.google.common.collect.Sets; + /** * @author icanci * @since 1.0 Created in 2022/11/15 21:26 @@ -14,11 +18,12 @@ public class HttpBaseDataSPI extends AbstractLoadSPI implements BaseDataSPI { @Override public List load(Set domains) { - return null; + WebApiRequest request = new WebApiRequest(domains); + return call(BaseDataDTO.class, LOAD_BASE_DATA_PATH, HttpMethod.POST, request).getRet(); } @Override public List load(String domain) { - return null; + return load(Sets.newHashSet(domain)); } } diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDataSourceSPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDataSourceSPI.java index b53a6c83cd1751191b2e05a7322183b532abde02..f61bf95a78e931526e84311f4a5461074658ab0d 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDataSourceSPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDataSourceSPI.java @@ -1,10 +1,14 @@ package cn.icanci.rec.engine.sdk.http.spi; +import cn.icanci.rec.common.aggregation.WebApiRequest; +import cn.icanci.rec.common.aggregation.model.DataSourceDTO; +import cn.icanci.rec.engine.script.client.http.HttpMethod; +import cn.icanci.rec.engine.sdk.spi.DataSourceSPI; + import java.util.List; import java.util.Set; -import cn.icanci.rec.common.aggregation.model.DataSourceDTO; -import cn.icanci.rec.engine.sdk.spi.DataSourceSPI; +import com.google.common.collect.Sets; /** * @author icanci @@ -13,11 +17,12 @@ import cn.icanci.rec.engine.sdk.spi.DataSourceSPI; public class HttpDataSourceSPI extends AbstractLoadSPI implements DataSourceSPI { @Override public List load(Set domains) { - return null; + WebApiRequest request = new WebApiRequest(domains); + return call(DataSourceDTO.class, LOAD_DATA_SOURCE_PATH, HttpMethod.POST, request).getRet(); } @Override public List load(String domain) { - return null; + return load(Sets.newHashSet(domain)); } } diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDomainSPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDomainSPI.java index c386bb22f85086fe202d140684dd16af27628f69..c822cee6998fa478a970db8fc5c8f612cfa3ef8d 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDomainSPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpDomainSPI.java @@ -18,8 +18,7 @@ public class HttpDomainSPI extends AbstractLoadSPI implements DomainSPI { @Override public DomainDTO loadOne(String domain) { - WebApiRequest request = new WebApiRequest(Sets.newHashSet(domain)); - return call(DomainDTO.class, LOAD_DOMAIN_PATH, HttpMethod.POST, request).getRet().iterator().next(); + return load(domain).iterator().next(); } @Override @@ -31,8 +30,6 @@ public class HttpDomainSPI extends AbstractLoadSPI implements DomainSPI { @Override public List load(String domain) { - WebApiRequest request = new WebApiRequest(Sets.newHashSet(domain)); - return call(DomainDTO.class, LOAD_DOMAIN_PATH, HttpMethod.POST, request).getRet(); - + return load(Sets.newHashSet(domain)); } } diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpMetadataSPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpMetadataSPI.java index 8426dd143757c445325d4da62ece2784565dc84f..a26ac4e24c22da8428f6d39a6077c812606f06d5 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpMetadataSPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpMetadataSPI.java @@ -1,11 +1,15 @@ package cn.icanci.rec.engine.sdk.http.spi; +import cn.icanci.rec.common.aggregation.WebApiRequest; import cn.icanci.rec.common.aggregation.model.MetadataDTO; +import cn.icanci.rec.engine.script.client.http.HttpMethod; import cn.icanci.rec.engine.sdk.spi.MetadataSPI; import java.util.List; import java.util.Set; +import com.google.common.collect.Sets; + /** * @author icanci * @since 1.0 Created in 2022/11/15 21:27 @@ -13,11 +17,12 @@ import java.util.Set; public class HttpMetadataSPI extends AbstractLoadSPI implements MetadataSPI { @Override public List load(Set domains) { - return null; + WebApiRequest request = new WebApiRequest(domains); + return call(MetadataDTO.class, LOAD_METADATA_PATH, HttpMethod.POST, request).getRet(); } @Override public List load(String domain) { - return null; + return load(Sets.newHashSet(domain)); } } diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpSceneSPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpSceneSPI.java index 9a62b82991015e3378c8eac4aaa71b586fd97be9..87ea5bcf03410061dcff554a57d4c79def8970b5 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpSceneSPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpSceneSPI.java @@ -1,11 +1,15 @@ package cn.icanci.rec.engine.sdk.http.spi; +import cn.icanci.rec.common.aggregation.WebApiRequest; import cn.icanci.rec.common.aggregation.model.SceneDTO; +import cn.icanci.rec.engine.script.client.http.HttpMethod; import cn.icanci.rec.engine.sdk.spi.SceneSPI; import java.util.List; import java.util.Set; +import com.google.common.collect.Sets; + /** * @author icanci * @since 1.0 Created in 2022/11/15 21:28 @@ -13,16 +17,17 @@ import java.util.Set; public class HttpSceneSPI extends AbstractLoadSPI implements SceneSPI { @Override public List load(Set domains) { - return null; + WebApiRequest request = new WebApiRequest(domains); + return call(SceneDTO.class, LOAD_SCENE_PATH, HttpMethod.POST, request).getRet(); } @Override public List load(String domain) { - return null; + return load(Sets.newHashSet(domain)); } @Override public SceneDTO loadOne(String domainCode) { - return null; + return load(domainCode).iterator().next(); } } diff --git a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpStrategySPI.java b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpStrategySPI.java index 734c12187d366bda8d92f48abd08e1e45111b506..190e6579a17543d31ff5610d8078a837b120b24f 100644 --- a/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpStrategySPI.java +++ b/rec-engine/rec-engine-sdk-http/src/main/java/cn/icanci/rec/engine/sdk/http/spi/HttpStrategySPI.java @@ -1,10 +1,14 @@ package cn.icanci.rec.engine.sdk.http.spi; +import cn.icanci.rec.common.aggregation.WebApiRequest; +import cn.icanci.rec.common.aggregation.model.StrategyDTO; +import cn.icanci.rec.engine.script.client.http.HttpMethod; +import cn.icanci.rec.engine.sdk.spi.StrategySPI; + import java.util.List; import java.util.Set; -import cn.icanci.rec.common.aggregation.model.StrategyDTO; -import cn.icanci.rec.engine.sdk.spi.StrategySPI; +import com.google.common.collect.Sets; /** * @author icanci @@ -13,12 +17,13 @@ import cn.icanci.rec.engine.sdk.spi.StrategySPI; public class HttpStrategySPI extends AbstractLoadSPI implements StrategySPI { @Override public List load(Set domains) { - return null; + WebApiRequest request = new WebApiRequest(domains); + return call(StrategyDTO.class, LOAD_STRATEGY_PATH, HttpMethod.POST, request).getRet(); } @Override public List load(String domain) { - return null; + return load(Sets.newHashSet(domain)); } } diff --git a/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/condition/ContainCondition.java b/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/condition/ContainCondition.java index e8d4ab380edf38be70689a464e4cb3356addc756..c0e5dcd3eefc24089089c95e6f610052ccb755d2 100644 --- a/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/condition/ContainCondition.java +++ b/rec-engine/rec-engine-sdk/src/main/java/cn/icanci/rec/engine/sdk/condition/ContainCondition.java @@ -14,6 +14,7 @@ import org.springframework.stereotype.Component; @Component @ConditionBean(OperatorEnum.CONTAIN) public class ContainCondition extends AbstractCondition { + @Override public boolean match(Bindings bindings, StrategyDTO.SingleCondition singleCondition, String domainCode) { return false;