Service - Sell Offer Manager: Difference between revisions

From Izara Wiki
Jump to navigation Jump to search
No edit summary
 
(29 intermediate revisions by the same user not shown)
Line 17: Line 17:
<syntaxhighlight lang="JavaScript">
<syntaxhighlight lang="JavaScript">
{
{
configKey: "ProductsGraphServiceName"
configKey: "ProductGraphServiceName"
configTag: "ProductsGraphServiceName"
configTag: "ProductGraphServiceName"
configValue: xxx // eg: "ProductsGraph"
configValue: xxx // eg: "ProductGraph"
}
}
</syntaxhighlight>
</syntaxhighlight>
Line 25: Line 25:
<syntaxhighlight lang="JavaScript">
<syntaxhighlight lang="JavaScript">
{
{
configKey: "SellOfferService"
configKey: "SellOfferHandlerService"
configTag: xxx // sellOfferServiceNameTag, eg: "SellOfferStandard", this is what is saved in each catalog record
configTag: xxx // sellOfferHandlerServiceNameTag, eg: "SellOfferStandard", this is what is saved in each catalog record
configValue: {
configValue: {
serviceName: xxx // eg: "SellOfferStandard", this is the actual deployed service name}
serviceName: xxx // eg: "SellOfferStandard", this is the actual deployed service name}
Line 33: Line 33:
</syntaxhighlight>
</syntaxhighlight>


== TranslateIdsRequest ==
<syntaxhighlight lang="JavaScript">
{
configKey: "TranslateIdsType"
configTag: xxx // eg SellOffer > Product would be sellOffer_product
configValue: {
ttl: 64000 // number of seconds TranslateIdsCache records live for
}
}
</syntaxhighlight>
 
== SellOfferRecord ==
 
Records which Handler manages each sell offer
 
<syntaxhighlight lang="JavaScript">
{
sellOfferId
sellOfferHandlerServiceNameTag
}
</syntaxhighlight>
 
* partition key: sellOfferId
* sort key: (none)
 
== TranslateIdsCache ==
 
Stores a record for one translateId data which can be queried as a cache rather than performing the translateIDs logic
 
<syntaxhighlight lang="JavaScript">
{
cacheId // fromType + "_" + fromDataId + "_" + toType
toDataId
expiryTime
}
</syntaxhighlight>
 
* partition key: cacheId
* sort key: toDataId
* expireTime is set as an automatic DynamoDB TTL attibute
 
== LogicalResultsMain ==
[[Standard LogicalResults Per Service|LogicalResultsMain]]
 
== LogicalResultsData ==
[[Standard LogicalResults Per Service|LogicalResultsData]]
 
== LogicalAwaitingStep ==
 
[[NPM module - izara-shared|AwaitingStep]]
 
== LogicalSortedRequest ==
[[Standard LogicalResults Per Service|LogicalSortedRequest]]
 
== AwaitingMultipleSteps ==
 
[[NPM module - izara-shared|AwaitingMultipleSteps]]
 
* stores pending sellOfferPriceSortResultId
 
== FindDataMain ==
[[Standard FindData Per Service|FindDataMain]]
 
== FindDataAwaitingStep ==
 
[[NPM module - izara-shared|AwaitingStep]]
 
== FindDataSortedRequest ==
[[Standard FindData Per Service|FindDataSortedRequest]]
 
== OrderPrice ==
 
Cache of one total calculation for list of sellOffer quantities, and one combination of deliverToLocationId, / sellOfferPlanUserPaymentMethodLinkId / sellOfferPlanDeliveryMethodLinkId. Price includes Payment and Delivery method costs.
 
<syntaxhighlight lang="JavaScript">
{
orderPriceId: "xx",
sellOfferQuantities: {},
deliverToLocationId: "xx",
//price: "xx", //removing and using findDataMain process
//expiryTime: "xx", //removing and using findDataMain process
// status: "xx", // "recalculating"|"complete"|"error", not really needed, added as a reference
// errorsFound: [], // stringSet, when recalculating, will reset to empty, once finished if any errorsFound then status will be "error"
// uniqueRequestId: "xx", (I think no longer used) used for idempotence when first process request called, in case that invocation fails and restarts, can be removed when set to complete/error
orderSubtotal: "xx",
orderQuantity: "xx",
sellOfferPrices: {}
deliveryPrice: "xx",
sellOfferPlanDeliveryMethodLinkId: "xx",
paymentPrice: "xx",
sellOfferPlanUserPaymentMethodLinkId: "xx",
}
</syntaxhighlight>
 
* partition key: orderPriceId
* sort key: (none)
* orderPriceId is {hash of sellOfferQuantities / orderQuantity / deliverToLocationId / sellOfferPlanDeliveryMethodLinkId / sellOfferPlanUserPaymentMethodLinkId
* sellOfferPlanQuantities works out the combined total for multiple sellOfferPlans, all sellOfferPlans must offer the given payment and delivery Ids, if not will be status error
* values found during re-calc are stored here, and can be used to present detailed cart pricing
* total price is stored in FindData table, and price is recalculated whenever FindData expires. This will mean should always request price via FindData, cannot request directly from orderPrice table
 
= Complex Filter requests =
 
<syntaxhighlight lang="JavaScript">
{
filterType: "sellOffer" //unique id is sellOfferId
type: "group",
elements:
[
{
type: "complexFilter",
complexFilter: {
filterType: "sellOfferPlan",
// see [[Service - Sell Offer Plan|Complex Filter requests]]
}
},
{
type: "complexFilter",
complexFilter: {
filterType: "sellOfferTermLink",
// see [[Service - Sell Offer Terms|Complex Filter requests]]
}
},
{
type: "complexFilter",
complexFilter: {
filterType: "planDeliveryPaymentCombination",
// see [[Service - Sell Offer Plan|Complex Filter requests]]
}
},
{
type: "complexFilter",
complexFilter: {
filterType: "orderPrice",
// see below
}
},
...
]
}
</syntaxhighlight>


Stores a record for any unique translateId request
* TranslateIds from planDeliveryPaymentCombination to sellOffer will find all unique sellOfferIds in the range of combinations
* TranslateIds from orderPrice to sellOffer will find all unique sellOfferIds in the range of orderPrices


<syntaxhighlight lang="JavaScript">
<syntaxhighlight lang="JavaScript">
{
{
translateIdsRequestId: xxx // fromType + '_' + fromResultId + '_' + toType
filterType: "orderPrice" //unique id is orderPriceId
fromType
type: "group",
fromResultId
elements:
fromResultTable
[
toType
{
status: // "processing"|"complete"
type: "logical",
requestHashes: [..] // string set of hashes of each request object, used for idempotence
logicalTag: "maxPrice"|"minPrice"|"averagePrice",
requests: [..] // array of request objects waiting a reply when this request is complete
comparison: "xx", // "equals"|"greaterThan"|"lessThan"|"greaterThanEquals"|"lessThanEquals"
value: "xx",
orderQuantity: 1,
deliverToLocationIds: [],
paymentMethodIds: [],
deliveryMethodIds: []
excludeEmpty: true
},
{
// finds all orderPrices for one sellOfferId according to all combinations of deliverToLocationIds / paymentMethodIds / deliveryMethodIds
type: "logical",
logicalTag: "sellOfferQuantityLocationIdCombinations",
sellOfferId: "xx",
orderQuantity: 1,
deliverToLocationIds: [],
paymentMethodIds: [],
deliveryMethodIds: [],
excludeEmpty: true
},
{
//will create a set of orderPrices, one per sellOffer according to aggregate function
type: "logical",
logicalTag: "aggregatedSellOfferPrices",
orderQuantity: 1,
deliverToLocationIds: [],
paymentMethodIds: [],
deliveryMethodIds: [],
aggregate: "xx", // "maxPrice"|"minPrice"|"averagePrice",
excludeEmpty: true
},
...
]
}
}
</syntaxhighlight>
</syntaxhighlight>


* partition key: translateIdsRequestId
* do not have open ended filters (like orderPrice status) because orderPrice does not have a defined set of underlying records, instead each element needs to contain filters that will create a list of orderPrices (that can be filtered in some way once created)
* sort key: {none}
* excludeEmpty: if true will not store values that are null/zero/empty string (eg orderPrices that are status "error")


= Working documents =
= Working documents =

Latest revision as of 12:38, 4 February 2022

Overview

Each sell offer is handled by a Service - Sell Offer (handlers) service.

The Sell Offer Manager service handles shared orchestration of the Sell Offer Handler services.

Repository

https://bitbucket.org/izara-market-products/izara-market-products-sell-offer-manager/src/master/

DynamoDB tables

Standard Config Table Per Service

Configuration tags

{
	configKey: "ProductGraphServiceName"
	configTag: "ProductGraphServiceName"
	configValue: xxx // eg: "ProductGraph"
}
{
	configKey: "SellOfferHandlerService"
	configTag: xxx // sellOfferHandlerServiceNameTag, eg: "SellOfferStandard", this is what is saved in each catalog record
	configValue: {
		serviceName: xxx // eg: "SellOfferStandard", this is the actual deployed service name}
	}
}
{
	configKey: "TranslateIdsType"
	configTag: xxx // eg SellOffer > Product would be sellOffer_product
	configValue: {
		ttl: 64000 // number of seconds TranslateIdsCache records live for
	}
}

SellOfferRecord

Records which Handler manages each sell offer

{
	sellOfferId
	sellOfferHandlerServiceNameTag
}
  • partition key: sellOfferId
  • sort key: (none)

TranslateIdsCache

Stores a record for one translateId data which can be queried as a cache rather than performing the translateIDs logic

{
	cacheId // fromType + "_" + fromDataId + "_" + toType
	toDataId
	expiryTime
}
  • partition key: cacheId
  • sort key: toDataId
  • expireTime is set as an automatic DynamoDB TTL attibute

LogicalResultsMain

LogicalResultsMain

LogicalResultsData

LogicalResultsData

LogicalAwaitingStep

AwaitingStep

LogicalSortedRequest

LogicalSortedRequest

AwaitingMultipleSteps

AwaitingMultipleSteps

  • stores pending sellOfferPriceSortResultId

FindDataMain

FindDataMain

FindDataAwaitingStep

AwaitingStep

FindDataSortedRequest

FindDataSortedRequest

OrderPrice

Cache of one total calculation for list of sellOffer quantities, and one combination of deliverToLocationId, / sellOfferPlanUserPaymentMethodLinkId / sellOfferPlanDeliveryMethodLinkId. Price includes Payment and Delivery method costs.

{
	orderPriceId: "xx",
	sellOfferQuantities: {},
	deliverToLocationId: "xx",
	//price: "xx", //removing and using findDataMain process
	//expiryTime: "xx", //removing and using findDataMain process
	// status: "xx", // "recalculating"|"complete"|"error", not really needed, added as a reference
	// errorsFound: [], // stringSet, when recalculating, will reset to empty, once finished if any errorsFound then status will be "error"
	// uniqueRequestId: "xx", (I think no longer used) used for idempotence when first process request called, in case that invocation fails and restarts, can be removed when set to complete/error
	orderSubtotal: "xx",
	orderQuantity: "xx",
	sellOfferPrices: {}
	deliveryPrice: "xx",
	sellOfferPlanDeliveryMethodLinkId: "xx",
	paymentPrice: "xx",
	sellOfferPlanUserPaymentMethodLinkId: "xx",
}
  • partition key: orderPriceId
  • sort key: (none)
  • orderPriceId is {hash of sellOfferQuantities / orderQuantity / deliverToLocationId / sellOfferPlanDeliveryMethodLinkId / sellOfferPlanUserPaymentMethodLinkId
  • sellOfferPlanQuantities works out the combined total for multiple sellOfferPlans, all sellOfferPlans must offer the given payment and delivery Ids, if not will be status error
  • values found during re-calc are stored here, and can be used to present detailed cart pricing
  • total price is stored in FindData table, and price is recalculated whenever FindData expires. This will mean should always request price via FindData, cannot request directly from orderPrice table

Complex Filter requests

{
	filterType: "sellOffer" //unique id is sellOfferId
	type: "group",
	elements:
	[
		{
			type: "complexFilter",
			complexFilter: {
				filterType: "sellOfferPlan",
				// see [[Service - Sell Offer Plan|Complex Filter requests]]
			}
		},		
		{
			type: "complexFilter",
			complexFilter: {
				filterType: "sellOfferTermLink",
				// see [[Service - Sell Offer Terms|Complex Filter requests]]
			}
		},	
		{
			type: "complexFilter",
			complexFilter: {
				filterType: "planDeliveryPaymentCombination",
				// see [[Service - Sell Offer Plan|Complex Filter requests]]
			}
		},
		{
			type: "complexFilter",
			complexFilter: {
				filterType: "orderPrice",
				// see below
			}
		},		
		...
	]
}
  • TranslateIds from planDeliveryPaymentCombination to sellOffer will find all unique sellOfferIds in the range of combinations
  • TranslateIds from orderPrice to sellOffer will find all unique sellOfferIds in the range of orderPrices
{
	filterType: "orderPrice" //unique id is orderPriceId
	type: "group",
	elements:
	[
		{
			type: "logical",
			logicalTag: "maxPrice"|"minPrice"|"averagePrice",
			comparison: "xx", // "equals"|"greaterThan"|"lessThan"|"greaterThanEquals"|"lessThanEquals"
			value: "xx",
			orderQuantity: 1,
			deliverToLocationIds: [],
			paymentMethodIds: [],
			deliveryMethodIds: []
			excludeEmpty: true
		},
		{
			// finds all orderPrices for one sellOfferId according to all combinations of deliverToLocationIds / paymentMethodIds / deliveryMethodIds
			type: "logical",
			logicalTag: "sellOfferQuantityLocationIdCombinations",
			sellOfferId: "xx",
			orderQuantity: 1,
			deliverToLocationIds: [],
			paymentMethodIds: [],
			deliveryMethodIds: [],
			excludeEmpty: true
		},
		{
			//will create a set of orderPrices, one per sellOffer according to aggregate function
			type: "logical",
			logicalTag: "aggregatedSellOfferPrices",
			orderQuantity: 1,
			deliverToLocationIds: [],
			paymentMethodIds: [],
			deliveryMethodIds: [],
			aggregate: "xx", // "maxPrice"|"minPrice"|"averagePrice",
			excludeEmpty: true
		},
		...
	]
}
  • do not have open ended filters (like orderPrice status) because orderPrice does not have a defined set of underlying records, instead each element needs to contain filters that will create a list of orderPrices (that can be filtered in some way once created)
  • excludeEmpty: if true will not store values that are null/zero/empty string (eg orderPrices that are status "error")

Working documents

Sell Offer Manager