Search

CN-121998559-A - Replenishment configuration method, replenishment configuration device, electronic equipment, storage medium and computer program product

CN121998559ACN 121998559 ACN121998559 ACN 121998559ACN-121998559-A

Abstract

The application provides a replenishment configuration method, a replenishment configuration device, electronic equipment, a storage medium and a computer program product, and relates to the technical field of supply chains. The method comprises the steps of sequentially reading configuration data corresponding to each workflow definition based on a spark computing engine according to the execution sequence of a plurality of workflow definitions in a preset workflow arrangement, processing and determining replenishment information corresponding to the preset workflow arrangement, wherein the execution of each workflow definition needs a processing result corresponding to the workflow definition. The scheme in the embodiment of the application can improve the efficiency of replenishment calculation.

Inventors

  • YANG FAN

Assignees

  • 北京京东远升科技有限公司

Dates

Publication Date
20260508
Application Date
20241105

Claims (12)

  1. 1. A restocking configuration method, comprising: And reading configuration data corresponding to each workflow definition in sequence based on a spark computing engine according to the execution sequence of the workflow definitions in a preset workflow arrangement, and processing to determine replenishment information corresponding to the preset workflow arrangement, wherein the execution of each workflow definition requires a processing result corresponding to the workflow definition.
  2. 2. The restocking configuration method according to claim 1, wherein the step of sequentially reading configuration data corresponding to each workflow definition by the spark-based computing engine for processing, and determining restocking information corresponding to the preset workflow layout includes: Reading the configuration data corresponding to each workflow definition based on the spark computing engine, performing data association and grouping computation, and determining a data set of each item code corresponding to each workflow definition, wherein the data set of the item code is used for representing at least one of item logistics data, supply demand data and logistics time sequence data corresponding to the item code; And distributing the data sets corresponding to the object codes to corresponding executors for processing, and determining the processing result corresponding to each workflow definition until the replenishment information is determined for the last workflow definition processing, wherein the resource of the executors is dynamically determined by the spark computing engine based on the current load.
  3. 3. The restocking configuration method according to claim 2, wherein the step of reading the configuration data corresponding to each workflow definition based on the spark calculation engine and performing data association and grouping calculation to determine a data set of each item code corresponding to each workflow definition includes: Reading and defining at least one of corresponding commodity circulation data, supply demand data and logistics time sequence data by each workflow on the basis of the spark calculation engine in a preset configuration file, and performing data association calculation to form two-dimensional data corresponding to the commodity circulation data, the supply demand data and the logistics time sequence data respectively; Grouping the plurality of two-dimensional data by the included item codes, and determining the data set of each item code.
  4. 4. The restocking configuration method of claim 2, wherein the distributing the data sets corresponding to the respective item codes to corresponding actuators for processing, determining the processing results corresponding to each workflow definition, comprises: and when the number of the executors is smaller than that of the data sets, distributing the data sets to the executors one by one for calculation, and distributing the data sets which are not distributed to the executors with the calculated data sets for calculation so as to call a corresponding replenishment algorithm model to calculate the processing result corresponding to each workflow definition.
  5. 5. The restocking configuration method according to any one of claims 1 to 4, wherein the method further comprises, before determining restocking information corresponding to the preset workflow schedule, sequentially reading configuration data corresponding to each workflow definition based on a spark calculation engine for processing according to an execution order of a plurality of workflow definitions in the preset workflow schedule: and determining the configuration data in response to the configuration operation of the user on the replenishment configuration interface, and storing the configuration data in a preset configuration file.
  6. 6. The restocking configuration method of claim 5, wherein the configuration data is used to characterize at least one of a data source and time range of the read data, logistics time series data, item logistics data, data to be deleted, a result output form, a supply demand related rule and a policy configuration for each of the workflow definitions.
  7. 7. The restocking configuration method according to any one of claims 1 to 4, wherein the method further comprises, before determining restocking information corresponding to the preset workflow schedule, sequentially reading configuration data corresponding to each workflow definition based on a spark calculation engine for processing according to an execution order of a plurality of workflow definitions in the preset workflow schedule: Responding to the arrangement operation of the workflow definition corresponding control displayed in the flow arrangement interface by a user, and forming initial workflow arrangement corresponding to a plurality of workflow definitions with an execution order; after the initial workflow arrangement is activated, the preset workflow arrangement is formed in the workflow definitions corresponding to the arrangement data of the workflow definitions of the initial workflow arrangement.
  8. 8. The restocking configuration method of claim 7, wherein the method further comprises: The workflow definition meeting the modification condition is offline; And after responding to the modification operation of the user on the workflow definition which is offline, the modified workflow definition is online, and the preset workflow arrangement is determined.
  9. 9. A restocking configuration device, comprising: The data processing unit is used for sequentially reading configuration data corresponding to each workflow definition based on a spark computing engine to process according to the execution sequence of the workflow definitions in a preset workflow arrangement, and determining replenishment information corresponding to the preset workflow arrangement, wherein the execution of each workflow definition needs a processing result corresponding to the workflow definition.
  10. 10. An electronic device comprising a memory and a processor, the memory storing a computer program executable on the processor, the processor implementing the steps of the method of any one of claims 1 to 8 when the computer program is executed.
  11. 11. A computer readable storage medium, on which a computer program is stored, characterized in that the computer program, when being executed by a processor, implements the steps of the method of any of claims 1 to 8.
  12. 12. A computer program product comprising a computer program, characterized in that the computer program, when being executed by a processor, realizes the steps in the method of any one of claims 1 to 8.

Description

Replenishment configuration method, replenishment configuration device, electronic equipment, storage medium and computer program product Technical Field The present application relates to the field of supply chain technologies, and in particular, to a method, an apparatus, an electronic device, a storage medium, and a computer program product for replenishment configuration. Background The use of ElasticJob in the restocking calculation of the supply chain distributes the master data associated with each stock keeping unit (Stock Keeping Unit, SKU) in a sliced manner to different docker containers for distributed calculation. However, the performance of replenishment calculation for large data amounts is slow when ElasticJob is used, and the proposed replenishment amount of tens of millions of levels needs to run for 12 hours, resulting in low efficiency of replenishment calculation. In addition, the upstream data on which the replenishment calculation depends needs to be manually controlled, a predicted task is manually executed, whether the task is completed or not is judged by manpower, predicted data is generated, the next task is executed by manpower to generate safety stock after the predicted data is generated, and if a certain replenishment task chain is longer, a large amount of manpower is needed to complete the replenishment plan, so that time and labor are wasted, and the efficiency of the whole replenishment calculation is lower. Disclosure of Invention The replenishment configuration method, the device, the electronic equipment, the storage medium and the computer program product provided by the embodiment of the application can improve the efficiency of replenishment calculation. The technical scheme of the application is realized as follows: the embodiment of the application provides a replenishment configuration method, which comprises the following steps: And reading configuration data corresponding to each workflow definition in sequence based on a spark computing engine according to the execution sequence of the workflow definitions in a preset workflow arrangement, and processing to determine replenishment information corresponding to the preset workflow arrangement, wherein the execution of each workflow definition requires a processing result corresponding to the workflow definition. In the above solution, the spark-based computing engine reads the configuration data corresponding to each workflow definition in turn for processing, and determines the replenishment information corresponding to the preset workflow layout, including: Reading the configuration data corresponding to each workflow definition based on the spark computing engine, and carrying out data association and grouping computation to determine a data set of each item code corresponding to each workflow definition, wherein the configuration data is used for representing at least one of item logistics data, supply demand data and logistics time sequence data corresponding to each item code; and distributing the data sets corresponding to the object codes to corresponding executors for processing, and determining the processing result corresponding to each workflow definition until the replenishment information is determined for the last workflow definition processing, wherein the number of the executors is dynamically determined by the spark calculation engine based on the current load. In the above solution, the step of reading the configuration data corresponding to each workflow definition based on the spark computing engine, performing data association and grouping computation, and determining a data set of each item code corresponding to each workflow definition includes: Reading and defining at least one of corresponding commodity circulation data, supply demand data and logistics time sequence data by each workflow on the basis of the spark calculation engine in a preset configuration file, and performing data association calculation to form two-dimensional array data corresponding to the commodity circulation data, the supply demand data and the logistics time sequence data respectively; Grouping the two-dimensional array data according to the contained item codes, and determining the data set of each item code. In the above solution, the distributing the data set corresponding to each item code to a corresponding executor for processing, and determining the processing result corresponding to each workflow definition includes: And when the number of the executors is smaller than that of the data sets, distributing the data sets according to the idle executors one by one so as to call a corresponding replenishment algorithm model to calculate the processing result corresponding to each workflow definition. In the above solution, according to the execution order of the workflow definitions in the preset workflow arrangement, the method further includes, before determining the replenishment information correspondin