Detailed Description
The present invention will be described in further detail with reference to the accompanying drawings and examples. It is to be understood that the specific embodiments described herein are merely illustrative of the invention and are not limiting of the invention. It should be further noted that, for the convenience of description, only some of the structures related to the present invention are shown in the drawings, not all of the structures.
Example one
Fig. 1 is a flowchart of a method for processing logistics distribution information according to an embodiment of the present invention, and this embodiment is applicable to a case of processing and merging distribution of logistics distribution information in real time, and particularly applicable to a scenario where an e-commerce platform server processes and merges distribution of logistics distribution information, and also applicable to other application scenarios where logistics distribution information needs to be processed. The method can be executed by a processing device for logistics distribution information, which can be implemented by software and/or hardware, and is integrated in an e-commerce platform server. It should be noted that the e-commerce service platform may be understood as a platform for supplying goods and displaying logistics information of the goods. The E-commerce platform server can be a server of a Jingdong shopping platform, a server of a guild shopping platform and the like. The method specifically comprises the following steps:
and S110, receiving logistics distribution information sent by the cloud platform in real time.
The logistics distribution information is acquired by the cloud platform from a server or terminal equipment of a logistics party in real time. The logistics party may include one or more logistics distribution platforms, and the logistics party may be a third-party logistics party, such as a roundabout express logistics party, a midabout express logistics party, and the like. Optionally, the receiving logistics distribution information sent by the cloud platform in real time includes: receiving logistics distribution information issued in real time by a middleware module which is deployed on a cloud platform in advance; the system comprises a logistics side server, a logistics side terminal device and a middleware module, wherein the logistics side server and the logistics side terminal device are both provided with the middleware module; after the middleware module in the terminal equipment collects the entered logistics distribution information, the logistics distribution information is sent to the middleware module in the server of the logistics party, the middleware module in the server of the logistics party receives the logistics distribution information sent to the middleware module on the cloud platform, or the middleware module is deployed in the terminal equipment of the logistics party, and after the middleware module in the terminal equipment collects the entered logistics distribution information, the middleware module on the cloud platform is sent to the middleware module.
The middleware module can be understood as an independent system software service program deployed on the cloud platform, the server of the logistics party and the terminal device, and is used for resource sharing and function sharing. As shown in fig. 2, which is a schematic diagram of an overall module of the method for processing logistics distribution information, the middleware module is communicatively connected to a logistics party and is configured to receive the logistics distribution information sent by the logistics party. Specifically, two ways of receiving logistics distribution information by the cloud platform are explained: (1) the terminal equipment sends the recorded logistics distribution information to a middleware module in a server of a third logistics party in real time through the middleware module, and the middleware module in the server of the logistics party sends the received logistics distribution information to the middleware module on the cloud platform; (2) and the terminal equipment of the logistics party sends the input logistics distribution information to the middleware module on the cloud platform in real time through the middleware module.
It can be understood that this implementation can make E-commerce platform server receive logistics distribution information in real time through setting up middleware module, handles or demonstrates logistics distribution information in real time, compares in prior art through the mode transmission logistics distribution information of off-line, can guarantee the timeliness of logistics distribution information, in time provides up-to-date logistics distribution information for the user, is favorable to improving user experience.
And S120, carrying out backtracking error correction verification processing and normalization processing on the logistics distribution information.
It can be understood that after the cloud platform sends the logistics distribution information to the e-commerce platform server, some data may have errors. For example, a node information error, an address information error, etc. The e-commerce platform server needs to detect error information existing in the logistics distribution information in real time and perform backtracking error correction verification processing and normalization processing on the error information, so that the error information is prevented from being displayed to users.
The backtracking error correction checking processing is a search trying process similar to enumeration, a solution of a problem is searched in the search trying process, and when the solution condition is found not to be met, backtracking is returned to try another path. That is to say, after receiving the logistics distribution information, the e-commerce platform server compares the logistics distribution information with the original logistics distribution information, and if the logistics distribution information is wrong, returns the logistics distribution information to the cloud platform, so that the cloud platform performs error correction and verification processing on the logistics distribution information, and the backtracking processing process is completed. The original logistics distribution information can be a plurality of logistics distribution information which are extracted by the cloud platform in real time and meet the logistics information standard format of the e-commerce platform server, and the logistics distribution information is stored in the database in real time.
Wherein the normalization process comprises: address normalization processing and/or operation node normalization processing. The address normalization processing can be understood as converting the address information of the logistics distribution information which does not conform to the e-commerce platform specification into an address which conforms to the e-commerce platform specification; the operation node normalization processing may be understood as converting operation node information of the logistics distribution information that does not conform to the e-commerce platform specification into an operation node that conforms to the e-commerce platform specification. Illustratively, the order, name, code and the like of the multi-level addresses in the logistics distribution information are processed to finish address normalization processing on the logistics distribution information; the name, description and code of each operation node in the logistics distribution information are processed, so that the operation node standardization processing of the logistics distribution information is completed.
Optionally, before performing the traceback error correction checking process and the normalization process on the logistics distribution information, the method further includes: according to the indication information sent by the middleware module on the cloud platform, processing resources are respectively reserved for each logistics party, so that the processing resources are used for carrying out backtracking error correction check processing and normalization processing on the received logistics distribution information; the middleware module on the cloud platform determines processing resources which need to be reserved for each logistics party according to the data volume of the logistics distribution information corresponding to each logistics party received in the current time window, and sends the indication information to the e-commerce platform server according to the determination result.
The processing resource may be a machine resource, such as a memory and a network bandwidth resource, reserved by the e-commerce platform server for each logistics party. The current time window may be a time period for the cloud platform to receive each logistics distribution information, and may be 1s or any minimum time period. In this embodiment, the middleware module of the cloud platform receives logistics distribution information sent by multiple logistics parties at the same time in the current time window, determines respective channels corresponding to the logistics parties, determines processing resources that need to be reserved by the logistics parties according to data volume of the logistics distribution information in the respective channels corresponding to the logistics parties, and generates the indication information.
Exemplarily, if a middleware module of the cloud platform receives logistics distribution information sent by a roundabout express party, a midlet express party, a rhyme express party and a downwind express party at the same time in a current time window, determining channels corresponding to the plurality of logistics parties respectively, and determining the data volume of the logistics distribution information received by each channel in the current time window, if the data volume of the logistics distribution information sent by a certain channel in the current time window is large, preferentially determining the processing resources required to be reserved by the logistics party. Namely, the middleware module of the cloud platform can determine the channels of different logistics parties, the priorities of reserved resources and the reserved resources according to the data volume of the logistics distribution information received by the current time window, determine the indication information according to the channels of different logistics parties, the priorities of the reserved resources and the reserved resources, and send the indication information corresponding to different logistics parties to the e-commerce platform server, so that the e-commerce platform server reserves processing resources for each logistics party according to the indication information, and performs backtracking error correction verification processing and normalization processing on the received logistics distribution information.
It can be understood that, in this embodiment, before performing the backtracking error correction verification processing and the normalization processing on the logistics distribution information, if the middleware module of the cloud platform receives a large amount of logistics distribution information at the same time, the middleware module of the cloud platform determines the channels corresponding to the logistics parties respectively, and determines the processing resources that need to be reserved by the logistics parties under different channels, the e-commerce platform server receives the logistics distribution information by channels, reserves the processing resources for the logistics parties corresponding to the channels, and determines the priority of the reserved processing resources, and the processing resources of the e-commerce platform server performs the backtracking error correction verification processing and the normalization processing on the logistics distribution information of different channels according to the priority of the reserved processing resources, so that the ordered processing of the logistics distribution information can be guaranteed, and the processing normalization of the logistics distribution information is improved; through carrying out backtracking error correction verification processing and standardization processing on the logistics distribution information, the logistics distribution information sent by different logistics parties can be corrected, so that the logistics distribution information accords with the standard of the e-commerce platform server, the terminal equipment of the e-commerce platform is guaranteed to display the standard logistics information in real time, and further the user experience is improved.
And S130, performing fusion distribution on the logistics distribution information subjected to the normalization processing so as to store the logistics distribution information into a database or load the logistics distribution information into a cache.
It can be understood that after the e-commerce platform server performs the backtracking error correction verification processing and the normalization processing on the logistics distribution information, the sequence of each node of each logistics distribution information may be disordered, and the sequence of each node needs to be converted into the sequence specified by the e-commerce platform. In order to solve the above problem, the embodiment may sequentially perform data combing, extraction verification, and data fusion processing on the normalized logistics distribution information.
Optionally, the data combing is to reorder the sequence of each node and divide each third stream distribution information into respective corresponding channels; the extraction verification is to extract a plurality of combed logistics distribution information in real time, verify the data format, the operation code of each node, the address after conversion and the like of the combed logistics distribution information extracted in real time so that the combed logistics distribution information extracted in real time conforms to the specification of an e-commerce platform, and determine the priority of each logistics distribution information according to the data quantity of the logistics distribution information and the request quantity of the logistics distribution information; and the data fusion processing is to distribute the logistics distribution information to the corresponding channels according to the priority of the logistics distribution information, and fuse the logistics distribution information of each channel with the data of the e-commerce platform side. Optionally, the data combing process may be executed by a data combing sub-module of the fusion distribution module in fig. 2; the extraction verification process can be executed by the extraction verification sub-module of the fusion distribution module in fig. 2; the data fusion processing procedure can be executed by the data fusion sub-module of the fusion distribution module in fig. 2.
Further, after the data fusion processing is performed on each logistics distribution information, each logistics distribution information can be stored in a database or loaded into a cache. For example, if the data volume or the requested viewing volume of the logistics distribution information is large, the logistics distribution information can be loaded to the cache; if the data volume of the logistics distribution information or the requested viewing volume is small, the logistics distribution information can be stored in the database.
The embodiment can further process the logistics distribution information into a format meeting the specification of the e-commerce platform by fusing and distributing the logistics distribution information subjected to the standardized processing, and stores the logistics distribution information into a database or loads the logistics distribution information into a cache according to actual conditions, so that a user can timely inquire the logistics information, and the normalization and the real-time performance of the logistics information are ensured.
The technical solution provided by this embodiment is to receive logistics distribution information sent by a cloud platform in real time, perform traceback error correction check processing and normalization processing on the logistics distribution information, so as to correct the logistics distribution information sent by different logistics parties, make the logistics distribution information conform to the specification of an e-commerce platform server, ensure that the terminal device of the e-commerce platform displays the standardized logistics information, perform fusion distribution on the logistics distribution information after the normalization processing, process the logistics distribution information into a format conforming to the specification of the e-commerce platform, store the logistics distribution information in a database or load the logistics distribution information into a cache, so that a user can query the logistics information in time, compared with the prior art in which the logistics distribution information is transmitted in an off-line manner, can ensure the standardization and real-time of the logistics information, and provide the latest distribution logistics information for the user, the method is beneficial to improving the user experience.
Example two
Fig. 3 is a flowchart of a method for processing logistics distribution information according to a second embodiment of the present invention. The technical solution of this embodiment is refined on the basis of the above embodiment, and optionally, the backtracking error correction verification processing is performed on the logistics distribution information, including: comparing the logistics distribution information with original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform; if the logistics distribution information is determined to be wrong according to the comparison result, the logistics distribution information is sent to the cloud platform; and receiving the corrected logistics distribution information returned by the cloud platform, or rejecting the logistics distribution information according to the instruction of the cloud platform. In the method, reference is made to the above-described embodiments for those parts which are not described in detail. Referring specifically to fig. 3, the method may include the steps of:
s210, receiving logistics distribution information sent by the cloud platform in real time.
S220, comparing the logistics distribution information with original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform, and if the logistics distribution information is determined to be wrong according to a comparison result, sending the logistics distribution information to the cloud platform.
And S230, receiving the corrected logistics distribution information returned by the cloud platform, or eliminating the logistics distribution information according to the indication of the cloud platform.
S220-S230 are explained in conjunction with fig. 2 and 4. The backtracking error correction check processing on the logistics distribution information can be performed through the backtracking error correction check module in fig. 2, and the backtracking error correction check module can be stored on the e-commerce platform server. The backtracking error correction checking module may compare the logistics distribution information with original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform to determine whether the logistics distribution information has an error. Specifically, as shown in fig. 4, the e-commerce platform server receives logistics distribution information, performs a backtracking check on the logistics distribution information through a backtracking error correction check module, determines whether the logistics distribution information has error data or duplicate data, if the logistics distribution information has error data or duplicate data, the backtracking error correction check module compares the logistics distribution information with the original logistics distribution information that has been put in storage, determines whether the logistics distribution information has data that is consistent with the original logistics distribution information that has been put in storage, and if the logistics distribution information has error data, transmits the logistics distribution information to the cloud platform to enable the cloud platform to correct the logistics distribution information and return the corrected logistics distribution information, or rejects the logistics distribution information according to an instruction of the cloud platform, and if the logistics distribution information does not exist, and the E-commerce platform server receives subsequent logistics distribution information. The original logistics distribution information is a plurality of logistics distribution information which are extracted in real time by the cloud platform and conform to the logistics information standard format of the e-commerce platform server, and the original logistics distribution information is data which are stored in the database in real time.
Optionally, the comparing item for comparing the logistics distribution information with the original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform includes: at least one of a order number, a multi-level address, and an order in which the nodes are operated. Specifically, comparing the logistics distribution information with original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform includes at least one of the following: comparing the order number in the logistics distribution information with the order number in the original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform; comparing the multi-level address in the logistics distribution information with the multi-level address in the original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform; and comparing the sequence of the operation nodes in the logistics distribution information with the sequence of the operation nodes in the original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform.
The order number can be an order number distributed by the e-commerce platform for each commodity; the multi-level addresses in the logistics distribution information can comprise provincial addresses, city addresses, county addresses and ballast addresses, and the address of each level corresponds to a unique code; the order of the operation nodes in the logistics distribution information refers to the logistics links that the logistics distribution information goes through in the whole logistics circulation process of the e-commerce platform, such as an initialization node (including order receiving, piece receiving, incomplete information, downloading and the like), an originating node (including generating a dispatching plan, dispatching and the like), a destination node (including all arrival, all warehousing and the like), a distribution stage (including carrier initialization, receipt of point-of-sale information management system equipment and the like) and a delivery node (including delivery and rejection).
Specifically, when comparing the logistics distribution information with the original logistics distribution information through the backtracking error correction check module, acquiring an order number, a multi-level address and an order of operation nodes corresponding to the logistics distribution information, analyzing the order number, the multi-level address and the order of the operation nodes respectively, determining the original logistics distribution information corresponding to the logistics distribution information, analyzing the order number, the multi-level address and the order of the operation nodes of the original logistics distribution information, comparing the order number of the analyzed logistics distribution information with the order number of the analyzed original logistics distribution information, or comparing the multi-level address of the analyzed logistics distribution information with the multi-level address of the analyzed original logistics distribution information, or comparing the order of the operation nodes of the analyzed logistics distribution information with the order of the operation nodes of the analyzed original logistics distribution information, and determining whether the logistics distribution information has errors according to the at least one comparison result.
In the embodiment, the order number, the multi-level address and the operation node of the logistics distribution information are respectively compared with the order number, the multi-level address and the operation node of the original logistics distribution information, whether errors exist in the logistics distribution information is determined according to at least one comparison result, so that the logistics distribution information is accurately judged according to information of multiple dimensions, the whole process of processing the logistics distribution information is more standardized, and the logistics distribution information is convenient to popularize and apply.
And S240, carrying out standardized processing on the logistics distribution information subjected to the backtracking error correction check processing.
Wherein the normalization processing comprises address normalization processing and/or operation node normalization processing.
Optionally, address normalization processing is performed on the logistics distribution information, and includes at least one of the following: converting the names of the road network nodes in the logistics distribution information into names meeting the E-commerce platform specification; replacing the name and the code of the address in the logistics distribution information with a standard name and a standard code in the E-commerce platform specification; and converting the format of the routing information in the logistics distribution information to meet the e-commerce platform specification.
Optionally, the logistics distribution information is subjected to operation node normalization processing, which includes at least one of the following: converting the name and/or code of the operation node in the logistics distribution information into a name and/or code which conforms to the specification of an e-commerce platform; and converting the description terms in the logistics distribution information into description terms conforming to the e-commerce platform specification.
The process of address normalization processing for the logistics distribution information is specifically explained with reference to fig. 2 and 4. As shown in fig. 2, the e-commerce platform server in this embodiment further includes an address information normalization module and an address normalization processing module, where the address normalization processing module includes a conversion sub-module, a permutation sub-module, and a formatting sub-module. The backtracking error correction checking module, the address information standardization module and the address standardization processing module can be stored on the E-commerce platform server in a distributed mode. The address information specification module stores address specification information of the e-commerce platform for each logistics distribution information, which may include multi-level road network node information, multi-level address location information, multi-level routing information and the like, and also stores a mapping relation of address specification processing between the e-commerce platform side and each logistics merchant. The multi-level road network node information is logistics network information distributed nationwide by logistics merchants (for example, a sorting center, a warehouse, a distribution station or a transfer center of an express company in a certain district of a certain city, and the like); the multi-level address information can comprise provincial level address information, city level address information, county level address information and the like, and each level of address specification code corresponds to a unique name and code; the multi-level routing information is a logistics state carried by one operation node to the next operation node, and may include a key value (e.g., a timestamp), a distribution start region (including a multi-level address), a distribution destination region (including a multi-level address), and a routing state (e.g., a transit state and a distribution state); the conversion sub-module can convert the logistics distribution information which does not conform to the e-commerce platform specification into information which conforms to the e-commerce platform specification; the replacement module can replace the logistics distribution information which does not conform to the e-commerce platform specification into information which conforms to the e-commerce platform specification; the formatting sub-module can format the logistics distribution information which does not meet the e-commerce platform specification.
As shown in fig. 4, after the e-commerce platform server receives the corrected logistics distribution information or the logistics distribution information from which the repeated data is removed, the logistics distribution information is converted and replaced, and the data is formatted. Fig. 5 is a schematic diagram of a mapping relationship between the e-commerce platform side and address specification processing of each logistics merchant, where the conversion sub-module and the replacement sub-module both receive the mapping relationship between the e-commerce platform side and address specification processing of each logistics merchant, which is sent by the address information specification module, and the conversion sub-module converts the name of a road network node in logistics distribution information into a name conforming to the e-commerce platform specification according to the mapping relationship; the replacement submodule replaces the name and the code of the address in the logistics distribution information into a standard name and a standard code in the e-commerce platform specification according to the mapping relation; and the conversion submodule converts the format of the routing information in the logistics distribution information according to the mapping relation so as to meet the e-commerce platform specification, and further formats the logistics distribution information which does not meet the e-commerce platform specification through the formatting submodule. It should be noted that the traceback error correction checking module, the address information normalization module and the address normalization processing module in this embodiment are pluggable, and can be set individually for different logistics parties, so as to meet the requirement of performing address normalization processing on logistics distribution information sent by different logistics parties.
The process of performing the operation node normalization processing on the logistics distribution information is specifically explained with reference to fig. 2 and 4. As shown in fig. 2, the e-commerce platform server in this embodiment further includes: the system comprises a node information normalization module and an operation node normalization processing module, wherein the operation node normalization processing module comprises a node conversion sub-module, a uniform coding sub-module and a term assimilation sub-module. The node information specification module stores node operation specification information of the e-commerce platform on each logistics distribution information, wherein the node operation specification information comprises names, codes, descriptions and the like of operation nodes. The node conversion sub-module, the uniform coding sub-module and the term assimilation sub-module can be stored on an e-commerce platform server in a distributed mode. The node conversion sub-module can convert the operation node information of the logistics distribution information which does not conform to the e-commerce platform specification into the operation node information which conforms to the e-commerce platform specification; the node conversion submodule and the unified coding submodule respectively convert and uniformly code the operation nodes of the logistics distribution information which do not accord with the e-commerce platform standard; the term assimilation sub-module can perform term unified description on the operation nodes of the logistics distribution information which do not conform to the e-commerce platform specification.
As shown in fig. 4, after the e-commerce platform server performs conversion, replacement, and formatting on the logistics distribution information, the name and/or code of the operation node of the logistics distribution information and the description terminology are unified. Specifically, the node conversion submodule and the uniform coding submodule both receive a mapping relation between the e-commerce platform side and address specification processing of each logistics merchant, which is sent by the address information specification module, and convert the name and/or code of the operation node of the logistics distribution information which does not meet the e-commerce platform specification into the name and/or code which meets the e-commerce platform specification according to the mapping relation; and the term assimilation sub-module converts the description terms in the logistics distribution information which does not conform to the e-commerce platform specification into the description terms which conform to the e-commerce platform specification according to the mapping relation. Optionally, the node conversion sub-module, the uniform coding sub-module, and the term assimilation sub-module may further perform uniform conversion, coding, and term unification processing on names and/or codes of all the sub-nodes of the operation node and description data. It should be noted that the node information normalization module and the operation node normalization processing module in this embodiment are pluggable, and can be set individually for different logistics parties, so as to meet the requirement of performing operation node normalization processing on logistics distribution information sent by different logistics parties.
In the embodiment, the address standardization processing is performed on the logistics distribution information, so that the logistics distribution information can be converted into the address information meeting the specification of the e-commerce platform, and the specification data is provided for the subsequent processing process; carry out operation node standardization through logistics distribution information and handle, can unify each logistics party to each operation node's name, code and description to show unified logistics information at the E-commerce platform side, avoid logistics distribution information to take place the confusion, make the user accurately master the logistics state of the commodity of ordering according to the logistics information of E-commerce platform side show, be favorable to promoting user experience.
And S250, performing fusion distribution on the logistics distribution information subjected to the normalization processing so as to store the logistics distribution information into a database or load the logistics distribution information into a cache.
Referring to the description of the foregoing embodiment, after performing backtracking error correction verification processing and normalization processing on the logistics distribution information, the e-commerce platform server sequentially performs data combing, extraction verification, and data fusion processing on the logistics distribution information after the normalization processing, so as to avoid possible confusion of the order of the nodes of the logistics distribution information; after data fusion processing is carried out on the logistics distribution information, the logistics distribution information is stored in a database or loaded into a cache, so that a user can inquire the logistics information in time, and the normalization and the real-time performance of the logistics information are guaranteed.
According to the technical scheme provided by the embodiment, the order number, the multi-level address and the sequence of the operation node of the logistics distribution information are respectively compared with the order number, the multi-level address and the sequence of the operation node in the original logistics distribution information, whether the logistics distribution information has errors or not is determined according to at least one comparison result, so that the logistics distribution information is accurately judged according to information of multiple dimensions, the whole process of processing the logistics distribution information is more standardized, and the logistics distribution information is convenient to popularize and apply; the logistics distribution information can be converted into address information conforming to the specification of the e-commerce platform by performing address standardization processing on the logistics distribution information, and specification data is provided for the subsequent processing process; carry out operation node standardization through logistics distribution information and handle, can unify each logistics party to each operation node's name, code and description to show unified logistics information at the E-commerce platform side, avoid logistics distribution information to take place the confusion, make the user accurately master the logistics state of the commodity of ordering according to the logistics information of E-commerce platform side show, be favorable to promoting user experience.
EXAMPLE III
Fig. 6 is a flowchart of a method for processing logistics distribution information according to a third embodiment of the present invention. The technical solution of this embodiment is refined on the basis of the above embodiment, and optionally, the fusion distribution is performed on the logistics distribution information after the normalization processing, so as to store the logistics distribution information in a database or load the logistics distribution information into a cache, where the method includes: determining the received data volume of the logistics distribution information of each logistics party and the request volume of the logistics distribution information of each logistics party by a client; determining logistics distribution information needing to be loaded to a cache and logistics distribution information needing to be stored to a database according to the data volume and the request volume; and storing the received logistics distribution information into a database or loading the logistics distribution information into a cache according to the determination result. In the method, reference is made to the above-described embodiments for those parts which are not described in detail. Referring specifically to fig. 6, the method may include the steps of:
and S310, receiving logistics distribution information sent by the cloud platform in real time.
S320, comparing the logistics distribution information with original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform, and if the logistics distribution information is determined to be wrong according to a comparison result, sending the logistics distribution information to the cloud platform.
S330, receiving the corrected logistics distribution information returned by the cloud platform, or eliminating the logistics distribution information according to the indication of the cloud platform.
And S340, carrying out standardized processing on the logistics distribution information subjected to backtracking error correction check processing.
Wherein the normalization process comprises: address normalization processing and/or operation node normalization processing.
Optionally, after the address normalization processing is performed on the logistics distribution information and before the operation node normalization processing is performed, the method further includes: sending the logistics distribution information to a first middleware module deployed on the E-commerce platform server; the received logistics distribution information is sent to a first processing module used for executing operation node standardization processing by a first middleware module, resources required to be reserved for each logistics party are determined according to the data volume of the logistics distribution information of each logistics party received in the current time window, indication information is sent to the first processing module according to the determination result, the first processing module is enabled to reserve the resources for each logistics party according to the indication information, and node operation standardization processing is carried out on the received logistics distribution information by using the reserved resources.
The first middleware module is an independent system software service program deployed on the e-commerce platform server and used for resource sharing and function sharing, and the first processing module can be an operation node normalized processing module and can be deployed on the e-commerce platform server. As shown in fig. 2, what is communicatively connected to the address normalization processing module and the operation node normalization processing module respectively in fig. 2 is a first middleware module, where the first middleware module may collect, sort, and sort the logistics distribution information after the address normalization processing according to a channel corresponding to the logistics distribution information, generate a logistics distribution information in an ordered sequence format, and send the logistics distribution information in the ordered sequence format to a first processing module (i.e., the operation node normalization processing module), and the first middleware module may also determine resources that need to be reserved for each logistics party according to the logistics distribution information of each channel received in a current time window, and if a data volume of the logistics distribution information sent by a corresponding logistics party in the current time window is larger, determine that more resources need to be reserved for the logistics party, resources are preferentially reserved for the logistics party. That is, the first middleware module may determine the channels of different logistics parties, the priorities of reserved resources, and the reserved resources according to the data volume of the logistics distribution information received by the current time window, determine the indication information according to the channels of different logistics parties, the priorities of the reserved resources, and send the indication information corresponding to different logistics parties to the first processing module, so that the first processing module reserves the processing resources for each logistics party according to the indication information, and performs the operation node normalization processing on the received logistics distribution information.
Optionally, after performing the operation node normalization processing on the logistics distribution information, the method further includes: sending the logistics distribution information to a second middleware module deployed on a server where the first processing module is located; the second middleware module sends the received logistics distribution information to a second processing module for executing the fusion distribution operation; and determining resources which need to be reserved for each logistics party according to the data volume of the logistics distribution information of each logistics party received in the current time window, and sending indication information to the second processing module according to the determination result, so that the second processing module reserves the resources for each logistics party according to the indication information respectively, and performs fusion distribution operation on the received logistics distribution information by using the reserved resources.
In fig. 2, communicatively connected to the operation node normalization processing module and the convergence distribution module, respectively, is a second middleware module, which may be deployed on the e-commerce platform server. Similar to the first middleware module, the second middleware module may collect, sort, and sort the logistics distribution information corresponding to the logistics distribution information after the address normalization processing according to the channel corresponding to the logistics distribution information, generate the logistics distribution information in the ordered sequence format, and send the logistics distribution information in the ordered sequence format to the second processing module (i.e., the fusion distribution module), and the second middleware module may also determine the resources that need to be reserved for each logistics party according to the logistics distribution information of each channel received in the current time window, and if the data volume of the logistics distribution information sent by the corresponding logistics party in the current time window of a certain channel is larger, it is determined that the more resources that need to be reserved for the logistics party is, the resources are preferentially reserved for the logistics party. That is, the second middleware module may determine the channels of different logistics parties, the priorities of reserved resources, and the reserved resources according to the data volume of the logistics distribution information received by the current time window, determine the indication information according to the channels of different logistics parties, the priorities of the reserved resources, and send the indication information corresponding to different logistics parties to the second processing module, so that the second processing module reserves the processing resources for each logistics party according to the indication information, and performs the fusion distribution operation on the received logistics distribution information.
It can be understood that the e-commerce platform server receives and sends logistics distribution information through the first middleware module and the second middleware module, and can transmit data among different modules in real time, so that the timeliness of data transmission is ensured; and the first middleware module and the second middleware module can also respectively determine resources reserved for each logistics party by the first processing module and the second processing module, so that the first processing module and the second processing module can process logistics distribution information according to the reserved resources in order, the timeliness and the orderliness of the whole process of processing the logistics distribution information are guaranteed, the terminal equipment of the e-commerce platform can be further facilitated to display the logistics information in real time, and the user experience is further improved.
S350, determining the received data volume of the logistics distribution information of each logistics party and the request volume of the logistics distribution information of each logistics party by the client, determining the logistics distribution information to be loaded to the cache and the logistics distribution information to be stored in the database according to the data volume and the request volume, and storing the received logistics distribution information to the database or loading the logistics distribution information to the cache according to the determination result.
The data volume is logistics traffic volume sent by a logistics party received by the e-commerce platform server, and the request volume is the number of logistics information viewing requests sent by a user through a client. Specifically, if the data volume and the request volume of the logistics distribution information are large, it can be determined that the logistics distribution information needs to be stored in a cache; if the data volume and the request volume of the logistics distribution information are small, the logistics distribution information can be determined to be stored in the non-relational database. By storing the data in the mode, the logistics distribution information can be quickly inquired and displayed in real time when the logistics information checking request sent by the user is received, and the user experience is favorably improved.
Optionally, before the received logistics allocation information is stored in the database or loaded into the cache, the method further includes: comparing and verifying the logistics distribution information with landing data; if the verification is passed, triggering to execute the operation of storing the logistics distribution information into a database or loading the logistics distribution information into a cache; the ground data is backup data stored in a database after backtracking error correction verification processing is carried out on the logistics distribution information.
This is explained in detail in conjunction with fig. 2 and 4. As shown in fig. 4, after the e-commerce platform server performs address normalization processing and/or operation node normalization processing on the logistics distribution information, the e-commerce platform server queries the operation specifications of each operation node and determines whether the code of each operation node exists; if the operation node does not exist, carrying out unified conversion, coding and term unification processing on the newly generated operation node, updating the node information standardization module, if the operation node exists, carrying out data carding and extraction verification on logistics distribution information, comparing the extracted logistics distribution information with landing data, verifying, and determining whether the verification is passed; if the verification is passed, the logistics distribution data of each channel is fused with the data of the e-commerce platform side; and after the data fusion is finished, triggering and executing the operation of storing the logistics distribution information into the database or loading the logistics distribution information into the cache so as to store the logistics distribution information into the database or loading the logistics distribution information into the cache. Optionally, the data combing and the extraction verification of the logistics distribution information may be processed by a data combing sub-module and an extraction verification sub-module in the fusion distribution module shown in fig. 2, respectively, and the data fusion of the logistics distribution data of each channel and the data at the e-commerce platform side may be processed by a data fusion sub-module in fig. 2.
According to the technical scheme provided by the embodiment, the logistics distribution information needing to be loaded to the cache and the logistics distribution information needing to be stored to the database are determined according to the data volume and the request volume, and the received logistics distribution information is stored to the database or loaded to the cache according to the determination result, so that the logistics distribution information can be quickly inquired and displayed in real time when a logistics information viewing request sent by a user is received, and the user experience is improved; moreover, the E-commerce platform server receives and sends logistics distribution information through the first middleware module and the second middleware module, can transmit data among different modules in real time, ensures timeliness of data transmission, determines reserved resources, processes the logistics distribution information according to the reserved resources in order, and ensures timeliness and orderliness of the whole process of processing the logistics distribution information; before the received logistics distribution information is stored in a database or loaded into a cache, the logistics distribution information is compared and verified again, the standardization and the accuracy of the logistics distribution information can be determined again, wrong information storage is avoided, accurate logistics information can be displayed by terminal equipment of an e-commerce platform, and user experience is improved.
Example four
Fig. 7 is a schematic structural diagram of a device for processing logistics distribution information according to a fourth embodiment of the present invention. Referring to fig. 7, the apparatus includes: a logistics distributioninformation receiving module 410, a logistics distributioninformation processing module 420 and a logistics distribution information fusion anddistribution module 430.
The logistics distributioninformation receiving module 410 is configured to receive logistics distribution information sent by a cloud platform in real time; the logistics distribution information is acquired by the cloud platform from a server or terminal equipment of a logistics party in real time;
the logistics distributioninformation processing module 420 is configured to perform backtracking error correction verification processing and normalization processing on the logistics distribution information; wherein the normalization process comprises: address normalization processing and/or operation node normalization processing;
the logistics distribution information fusion anddistribution module 430 is configured to perform fusion and distribution on the logistics distribution information after the normalization processing, so as to store the logistics distribution information in a database or load the logistics distribution information into a cache. The logistics distribution information fusion anddistribution module 430 can be the fusion and distribution module described in the foregoing embodiments.
On the basis of the above technical solutions, the logistics distributioninformation receiving module 410 is further configured to receive logistics distribution information issued in real time by a middleware module pre-deployed on the cloud platform;
the system comprises a logistics side server, a logistics side terminal device and a middleware module, wherein the logistics side server and the logistics side terminal device are both provided with the middleware module; after the middleware module in the terminal equipment collects the entered logistics distribution information, the logistics distribution information is sent to the middleware module in the server of the logistics party, the middleware module in the server of the logistics party receives the logistics distribution information sent to the middleware module on the cloud platform, or the middleware module is deployed in the terminal equipment of the logistics party, and after the middleware module in the terminal equipment collects the entered logistics distribution information, the middleware module on the cloud platform is sent to the middleware module.
On the basis of the above technical solutions, the apparatus further includes: a processing resource reservation module; the processing resource reservation module is used for respectively reserving processing resources for each logistics party according to the indication information sent by the middleware module on the cloud platform so as to use the processing resources to perform backtracking error correction verification processing and normalization processing on the received logistics distribution information;
the middleware module on the cloud platform determines processing resources which need to be reserved for each logistics party according to the data volume of the logistics distribution information corresponding to each logistics party received in the current time window, and sends the indication information to the e-commerce platform server according to the determination result.
On the basis of the foregoing technical solutions, the logistics distributioninformation processing module 420 is further configured to compare the logistics distribution information with original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform, and if it is determined that the logistics distribution information is wrong according to a comparison result, send the logistics distribution information to the cloud platform; and receiving the corrected logistics distribution information returned by the cloud platform, or rejecting the logistics distribution information according to the instruction of the cloud platform.
On the basis of the above technical solutions, the comparing item for comparing the logistics distribution information with the original logistics distribution information corresponding to the logistics distribution information stored by the cloud platform includes: at least one of a order number, a multi-level address, and an order in which the nodes are operated.
On the basis of the foregoing technical solutions, the logistics distributioninformation processing module 420 is further configured to perform address normalization processing on the logistics distribution information, where the address normalization processing includes at least one of the following:
converting the names of the road network nodes in the logistics distribution information into names meeting the E-commerce platform specification;
replacing the name and the code of the address in the logistics distribution information with a standard name and a standard code in the E-commerce platform specification;
and converting the format of the routing information in the logistics distribution information to meet the e-commerce platform specification.
On the basis of the foregoing technical solutions, the logistics distributioninformation processing module 420 is further configured to perform operation node normalization processing on the logistics distribution information, where the operation node normalization processing includes at least one of the following:
converting the name and/or code of the operation node in the logistics distribution information into a name and/or code which conforms to the specification of an e-commerce platform;
and converting the description terms in the logistics distribution information into description terms conforming to the e-commerce platform specification.
On the basis of the above technical solutions, the logistics distribution information fusion anddistribution module 430 is further configured to determine the data volume of the received logistics distribution information of each logistics party and the request volume of the client for the logistics distribution information of each logistics party;
determining logistics distribution information needing to be loaded to a cache and logistics distribution information needing to be stored to a database according to the data volume and the request volume;
and storing the received logistics distribution information into a database or loading the logistics distribution information into a cache according to the determination result.
On the basis of the above technical solutions, the apparatus further includes: a comparison verification module; the comparison verification module is used for comparing and verifying the logistics distribution information with landing data; if the verification is passed, triggering to execute the operation of storing the logistics distribution information into a database or loading the logistics distribution information into a cache;
the ground data is backup data stored in a database after backtracking error correction verification processing is carried out on the logistics distribution information.
On the basis of the above technical solutions, the logistics distributioninformation processing module 420 is further configured to send the logistics distribution information to a first middleware module deployed on the e-commerce platform server;
the received logistics distribution information is sent to a first processing module used for executing operation node standardization processing by a first middleware module, resources required to be reserved for each logistics party are determined according to the data volume of the logistics distribution information of each logistics party received in the current time window, indication information is sent to the first processing module according to the determination result, the first processing module is enabled to reserve the resources for each logistics party according to the indication information, and node operation standardization processing is carried out on the received logistics distribution information by using the reserved resources.
On the basis of the foregoing technical solutions, the logistics distributioninformation processing module 420 is further configured to send the logistics distribution information to a second middleware module deployed on a server where the first processing module is located;
and the second middleware module sends the received logistics distribution information to a second processing module for executing the fusion distribution operation, determines resources required to be reserved for each logistics party according to the data volume of the logistics distribution information of each logistics party received in the current time window, and sends indication information to the second processing module according to the determination result, so that the second processing module reserves the resources for each logistics party according to the indication information respectively, and executes the fusion distribution operation on the received logistics distribution information by using the reserved resources.
The technical solution provided by this embodiment is to receive logistics distribution information sent by a cloud platform in real time, perform traceback error correction check processing and normalization processing on the logistics distribution information, so as to correct the logistics distribution information sent by different logistics parties, make the logistics distribution information conform to the specification of an e-commerce platform server, ensure that the terminal device of the e-commerce platform displays the standardized logistics information, perform fusion distribution on the logistics distribution information after the normalization processing, process the logistics distribution information into a format conforming to the specification of the e-commerce platform, store the logistics distribution information in a database or load the logistics distribution information into a cache, so that a user can query the logistics information in time, compared with the prior art in which the logistics distribution information is transmitted in an off-line manner, can ensure the standardization and real-time of the logistics information, and provide the latest distribution logistics information for the user, the method is beneficial to improving the user experience.
EXAMPLE five
Fig. 8 is a schematic structural diagram of an e-commerce platform server according to a fifth embodiment of the present invention. Fig. 8 illustrates a block diagram of an exemplarye-commerce platform server 12 suitable for use in implementing embodiments of the present invention. Thee-commerce platform server 12 shown in fig. 8 is only an example and should not bring any limitations to the functionality and scope of use of the embodiments of the present invention.
As shown in fig. 6, thee-commerce platform server 12 is in the form of a general purpose computing device. The components of thee-commerce platform server 12 may include, but are not limited to: one or more processors orprocessing units 16, asystem memory 28, and abus 18 that couples various system components including thesystem memory 28 and theprocessing unit 16.
Bus 18 represents one or more of any of several types of bus structures, including a memory bus or memory controller, a peripheral bus, an accelerated graphics port, and a processor or local bus using any of a variety of bus architectures. By way of example, such architectures include, but are not limited to, Industry Standard Architecture (ISA) bus, micro-channel architecture (MAC) bus, enhanced ISA bus, Video Electronics Standards Association (VESA) local bus, and Peripheral Component Interconnect (PCI) bus.
Thee-commerce platform server 12 typically includes a variety of computer system readable media. Such media may be any available media that is accessible by thee-commerce platform server 12 and includes both volatile and non-volatile media, removable and non-removable media.
Thesystem memory 28 may include computer system readable media in the form of volatile memory, such as Random Access Memory (RAM)30 and/or cache memory. Thee-commerce platform server 12 may further include other removable/non-removable, volatile/nonvolatile computer system storage media. By way of example only,storage system 34 may be used to read from and write to non-removable, nonvolatile magnetic media (not shown in FIG. 8, and commonly referred to as a "hard drive"). Although not shown in FIG. 8, a magnetic disk drive for reading from and writing to a removable, nonvolatile magnetic disk (e.g., a "floppy disk") and an optical disk drive for reading from or writing to a removable, nonvolatile optical disk (e.g., a CD-ROM, DVD-ROM, or other optical media) may be provided. In these cases, each drive may be connected tobus 18 by one or more data media interfaces. Thememory 28 may include at least one program product having a set of program modules (e.g., the logistics distributioninformation reception module 410, the logistics distributioninformation processing module 420, and the logistics distribution informationfusion distribution module 430 of the logistics distribution information processing apparatus) configured to perform the functions of the embodiments of the present invention.
A program/utility 44 having a set of program modules 46 (e.g., a logistics distributioninformation reception module 410, a logistics distributioninformation processing module 420, and a logistics distribution informationfusion distribution module 430 of a logistics distribution information processing apparatus) may be stored, for example, inmemory 28, such program modules 46 including, but not limited to, an operating system, one or more application programs, other program modules, and program data, each of which examples or some combination thereof may include an implementation of a network environment. Program modules 46 generally carry out the functions and/or methodologies of the described embodiments of the invention.
Thee-commerce platform server 12 may also communicate with one or more external devices 14 (e.g., keyboard, pointing device,display 24, etc.), with one or more devices that enable a user to interact with thee-commerce platform server 12, and/or with any devices (e.g., network card, modem, etc.) that enable thee-commerce platform server 12 to communicate with one or more other computing devices. Such communication may be through an input/output (I/O)interface 22. Also, thee-commerce platform server 12 may communicate with one or more networks (e.g., a Local Area Network (LAN), a Wide Area Network (WAN), and/or a public network, such as the internet) via thenetwork adapter 20. As shown, thenetwork adapter 20 communicates with the other modules of thee-commerce platform server 12 over thebus 18. It should be understood that although not shown in the figures, other hardware and/or software modules may be used in conjunction with thee-commerce platform server 12, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAID systems, tape drives, and data backup storage systems, among others.
Theprocessing unit 16 executes various functional applications and data processing by executing programs stored in thesystem memory 28, for example, implementing a method for processing logistics distribution information provided by an embodiment of the present invention, the method including:
receiving logistics distribution information sent by a cloud platform in real time; the logistics distribution information is acquired by the cloud platform from a server or terminal equipment of a logistics party in real time;
backtracking error correction verification processing and normalization processing are carried out on the logistics distribution information; wherein the normalization process comprises: address normalization processing and/or operation node normalization processing;
and performing fusion distribution on the logistics distribution information subjected to the normalization processing so as to store the logistics distribution information in a database or load the logistics distribution information into a cache.
Theprocessing unit 16 executes various functional applications and data processing by executing programs stored in thesystem memory 28, for example, implementing a method for processing logistics distribution information provided by an embodiment of the present invention.
Of course, those skilled in the art can understand that the processor may also implement the technical solution of the method for processing logistics distribution information provided in any embodiment of the present invention.
EXAMPLE six
The sixth embodiment of the present invention further provides a computer-readable storage medium, on which a computer program is stored, where the computer program, when executed by a processor, implements a method for processing logistics distribution information, where the method includes:
receiving logistics distribution information sent by a cloud platform in real time; the logistics distribution information is acquired by the cloud platform from a server or terminal equipment of a logistics party in real time;
backtracking error correction verification processing and normalization processing are carried out on the logistics distribution information; wherein the normalization process comprises: address normalization processing and/or operation node normalization processing;
and performing fusion distribution on the logistics distribution information subjected to the normalization processing so as to store the logistics distribution information in a database or load the logistics distribution information into a cache.
Of course, the computer program stored on the computer-readable storage medium provided by the embodiment of the present invention is not limited to the above method operations, and may also perform related operations in a method for processing logistics distribution information provided by any embodiment of the present invention.
Computer storage media for embodiments of the invention may employ any combination of one or more computer-readable media. The computer readable medium may be a computer readable signal medium or a computer readable storage medium. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, or device, or any combination of the foregoing. More specific examples (a non-exhaustive list) of the computer readable storage medium would include the following: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this document, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, or device.
The computer-readable signal medium may include data after logistics information, address normalization processing, and/or operation node normalization processing, etc., in which computer-readable program code is carried. The transmitted logistics distribution information, address normalization processing and/or data after operation node normalization processing and the like. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, or device.
Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to wireless, wireline, optical fiber cable, RF, etc., or any suitable combination of the foregoing.
Computer program code for carrying out operations for aspects of the present invention may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, Smalltalk, C + +, or the like, as well as conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any type of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or the connection may be made to an external computer (for example, through the Internet using an Internet service provider).
It should be noted that, in the embodiment of the processing apparatus for logistics distribution information, the modules included in the embodiment are only divided according to functional logic, but are not limited to the above division as long as the corresponding functions can be realized; in addition, specific names of the functional units are only for convenience of distinguishing from each other, and are not used for limiting the protection scope of the present invention.
It is to be noted that the foregoing is only illustrative of the preferred embodiments of the present invention and the technical principles employed. It will be understood by those skilled in the art that the present invention is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the invention. Therefore, although the present invention has been described in greater detail by the above embodiments, the present invention is not limited to the above embodiments, and may include other equivalent embodiments without departing from the spirit of the present invention, and the scope of the present invention is determined by the scope of the appended claims.