Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Improved: Enhance products processing logic in atp rule execution to use virtual products tags for its variant (#46). #47

Merged
merged 1 commit into from
Jan 21, 2025
Merged

Improved: Enhance products processing logic in atp rule execution to use virtual products tags for its variant (#46). #47

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions service/co/hotwax/common/CommonServices.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
</in-parameters>
<out-parameters>
<parameter name="response" type="Map"/>
<parameter name="grouped" type="Map"/>
</out-parameters>
</service>
</services>
100 changes: 70 additions & 30 deletions service/co/hotwax/product/ProductFacilityServices.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@
import org.kie.api.io.ResourceType;
import org.kie.api.KieBase;
import org.kie.api.KieServices
import co.hotwax.common.CommerceUtil

kieServices = KieServices.Factory.get();
kieHelper = new KieHelper();
Expand All @@ -41,25 +42,37 @@
productFacilityDetail = [:]
</script>

<set field="viewSize" value="100" type="Integer"/>
<set field="viewIndex" value="0" type="Integer"/>
<set field="fieldsToSelect" value="productId,tags,productFeatures"/>
<set field="viewSize" value="20" type="Integer"/>
<set field="serviceCtx" from="[viewSize: viewSize, viewIndex: 0, fieldsToSelect: 'productId,isVirtual,isVariant,tags,productFeatures', resultGroupingField: 'groupId']"/>
<service-call name="co.hotwax.product.ProductFacilityServices.get#Products"
in-map="[viewIndex: viewIndex, viewSize: viewSize, fieldsToSelect: fieldsToSelect]"
in-map="serviceCtx + [viewIndex: 0]"
out-map="productResult"/>
<if condition="!productResult.productDetail">
<if condition="!productResult.productDetail || productResult.productDetail.totalCount == 0">
<return error="true" message="No products found."/>
</if>
<set field="products" from="productResult.productDetail.products"/>
<set field="totalProducts" from="productResult.productDetail.totalCount"/>
<log message="Rule group ${ruleGroupId}: Total ${totalProducts} products to process."/>

<iterate list="products" entry="product">
<script>
kieSession.setGlobal("productFacilityDetail", productFacilityDetail);
kieSession.insert(product);
int numberOfRulesFired = kieSession.fireAllRules();
</script>
<set field="productGroups" from="productResult.productDetail.productGroups"/>
<set field="totalGroups" from="productResult.productDetail.totalCount"/>
<log message="Rule group ${ruleGroupId}: Total ${totalGroups} product groups to process."/>

<iterate list="productGroups" entry="productGroup">
<set field="products" from="productGroup.doclist.docs"/>
<set field="virtualProduct" from="products.find { it.isVirtual == 'true' }"/>

<iterate list="products" entry="product">
<!--skip virtual product-->
<if condition="product.isVirtual == 'true'">
<continue/>
</if>
<!--considering tags are always managed on virtual product, hence copying virtual product tags to it's variant -->
<if condition="product.isVariant == 'true' &amp;&amp; virtualProduct">
<set field="product.tags" from="virtualProduct.tags"/>
</if>
<script>
kieSession.setGlobal("productFacilityDetail", productFacilityDetail);
kieSession.insert(product);
int numberOfRulesFired = kieSession.fireAllRules();
</script>
</iterate>
</iterate>
<set field="csvFilePath" value=""/>
<if condition="productFacilityDetail.values()">
Expand All @@ -70,24 +83,36 @@
<set field="csvFilePath" from="result.csvFilePath"/>
<set field="productFacilityDetail" from="[:]"/>
</if>
<if condition="totalGroups > viewSize">
<script>
import co.hotwax.common.CommerceUtil
paginationValues = CommerceUtil.getPaginationValues(viewSize, 0, totalProducts)
paginationValues = CommerceUtil.getPaginationValues(viewSize, 0, totalGroups)
viewIndexLast = paginationValues.viewIndexLast
viewIndexList = (1..viewIndexLast).toList()
</script>
<iterate list="viewIndexList" entry="viewIndex">
<service-call name="co.hotwax.product.ProductFacilityServices.get#Products"
in-map="[viewIndex: viewIndex*viewSize, viewSize: viewSize, fieldsToSelect: fieldsToSelect]"
in-map="serviceCtx + [viewIndex: viewIndex*viewSize]"
out-map="productResult"/>
<if condition="productResult.productDetail">
<set field="products" from="productResult.productDetail.products"/>
<iterate list="products" entry="product">
<script>
kieSession.setGlobal("productFacilityDetail", productFacilityDetail);
kieSession.insert(product);
int numberOfRulesFired = kieSession.fireAllRules();
</script>
<if condition="productResult.productDetail &amp;&amp; productResult.productDetail.totalCount > 0">
<set field="productGroups" from="productResult.productDetail.productGroups"/>
<iterate list="productGroups" entry="productGroup">
<set field="products" from="productGroup.doclist.docs"/>
<set field="virtualProduct" from="products.find { it.isVirtual == 'true' }"/>
<iterate list="products" entry="product">
<!--skip virtual product-->
<if condition="product.isVirtual == 'true'">
<continue/>
</if>
<!--considering tags are always managed on virtual product, hence copying virtual product tags to it's variant -->
<if condition="product.isVariant == 'true' &amp;&amp; virtualProduct">
<set field="product.tags" from="virtualProduct.tags"/>
</if>
<script>
kieSession.setGlobal("productFacilityDetail", productFacilityDetail);
kieSession.insert(product);
int numberOfRulesFired = kieSession.fireAllRules();
</script>
</iterate>
</iterate>
<if condition="productFacilityDetail.values()">
<service-call name="co.hotwax.product.ProductFacilityServices.prepare#ProductFacilityCsv"
Expand All @@ -98,6 +123,7 @@
</if>
</if>
</iterate>
</if>
<script>
kieSession.dispose();
</script>
Expand Down Expand Up @@ -169,6 +195,8 @@
<parameter name="query"/>
<parameter name="fieldsToSelect"/>
<parameter name="filter"/>
<parameter name="resultGroupingField"/>
<parameter name="groupLimit" default-value="10000"/>
<parameter name="viewIndex" type="Integer"/>
<parameter name="viewSize" type="Integer"/>
</in-parameters>
Expand All @@ -177,18 +205,30 @@
</out-parameters>
<actions>
<set field="productDetail" from="[:]"/>
<set field="filterConditions" value="docType:PRODUCT AND isVirtual:false"/>
<set field="filterConditions" value="docType:PRODUCT"/>
<if condition="filter">
<set field="filterConditions" value="${filterConditions} AND ${filter}"/>
</if>
<set field="queryObject" from="[query: query ?: '*:*', filter: filterConditions, params: [rows: viewSize ?: 10, start: viewIndex ?: 0]]" />
<set field="params" from="[rows: (viewSize ?: 10), start: (viewIndex ?: 0)]"/>
<if condition="resultGroupingField">
<set field="params" from="params + ['group': true, 'group.field': resultGroupingField, 'group.limit': (groupLimit ?: 10), 'group.ngroups': true]"/>
</if>
<set field="queryObject" from="[query: (query ?: '*:*'), filter: filterConditions ?: [], params: params]"/>
<if condition="fieldsToSelect">
<set field="queryObject.fields" from="fieldsToSelect"/>
</if>
<service-call name="co.hotwax.common.CommonServices.run#SolrQuery" in-map="[json:queryObject]" out-map="outResult"/>
<if condition="outResult">
<set field="productDetail.products" from="outResult.response.docs"/>
<set field="productDetail.totalCount" from="outResult.response.numFound"/>
<if condition="resultGroupingField &amp;&amp; outResult.grouped">
<then>
<set field="productDetail.productGroups" from="outResult.grouped[resultGroupingField].groups"/>
<set field="productDetail.totalCount" from="outResult.grouped[resultGroupingField].ngroups"/>
</then>
<else>
<set field="productDetail.products" from="outResult.response.docs"/>
<set field="productDetail.totalCount" from="outResult.response.numFound"/>
</else>
</if>
</if>
<log message="${viewSize} products are fetched successfully from index ${viewIndex}."/>
</actions>
Expand Down