[go: up one dir, main page]

CN114037155A - 一种订单统计的优化方法 - Google Patents

一种订单统计的优化方法 Download PDF

Info

Publication number
CN114037155A
CN114037155A CN202111320377.1A CN202111320377A CN114037155A CN 114037155 A CN114037155 A CN 114037155A CN 202111320377 A CN202111320377 A CN 202111320377A CN 114037155 A CN114037155 A CN 114037155A
Authority
CN
China
Prior art keywords
order
statistical
data
driver
passenger
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202111320377.1A
Other languages
English (en)
Inventor
牛京
郑晕
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Shouyue Technology Beijing Co Ltd
Original Assignee
Shouyue Technology Beijing Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Shouyue Technology Beijing Co Ltd filed Critical Shouyue Technology Beijing Co Ltd
Priority to CN202111320377.1A priority Critical patent/CN114037155A/zh
Publication of CN114037155A publication Critical patent/CN114037155A/zh
Pending legal-status Critical Current

Links

Images

Classifications

    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q10/00—Administration; Management
    • G06Q10/04—Forecasting or optimisation specially adapted for administrative or management purposes, e.g. linear programming or "cutting stock problem"
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24—Querying
    • G06F16/245—Query processing
    • G06F16/2455—Query execution
    • G06F16/24552—Database cache management
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00—Arrangements for program control, e.g. control units
    • G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/46—Multiprogramming arrangements
    • G06F9/54—Interprogram communication
    • G06F9/546—Message passing systems or structures, e.g. queues
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q30/00—Commerce
    • G06Q30/06—Buying, selling or leasing transactions
    • G06Q30/0601—Electronic shopping [e-shopping]
    • G06Q30/0633—Lists, e.g. purchase orders, compilation or processing
    • G06Q30/0635—Processing of requisition or of purchase orders
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q50/00—Information and communication technology [ICT] specially adapted for implementation of business processes of specific business sectors, e.g. utilities or tourism
    • G06Q50/40—Business processes related to the transportation industry
    • G—PHYSICS
    • G06—COMPUTING; CALCULATING OR COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F2209/00—Indexing scheme relating to G06F9/00
    • G06F2209/54—Indexing scheme relating to G06F9/54
    • G06F2209/548—Queue

Landscapes

  • Engineering & Computer Science (AREA)
  • Business, Economics & Management (AREA)
  • Theoretical Computer Science (AREA)
  • General Physics & Mathematics (AREA)
  • Physics & Mathematics (AREA)
  • Strategic Management (AREA)
  • Economics (AREA)
  • General Business, Economics & Management (AREA)
  • Human Resources & Organizations (AREA)
  • Marketing (AREA)
  • Databases & Information Systems (AREA)
  • General Engineering & Computer Science (AREA)
  • Finance (AREA)
  • Accounting & Taxation (AREA)
  • Software Systems (AREA)
  • Development Economics (AREA)
  • Tourism & Hospitality (AREA)
  • Computational Linguistics (AREA)
  • Data Mining & Analysis (AREA)
  • Entrepreneurship & Innovation (AREA)
  • Operations Research (AREA)
  • Quality & Reliability (AREA)
  • Game Theory and Decision Science (AREA)
  • Health & Medical Sciences (AREA)
  • General Health & Medical Sciences (AREA)
  • Primary Health Care (AREA)
  • Debugging And Monitoring (AREA)

Abstract

本发明提供的一种订单统计的优化方法，所述优化方法包括：采用数据变动监听组件获取订单数据变化，并发送订单数据消息队列消息；接收所述订单数据消息队列消息并存储，以供消费者消费信息存储器Redis；从所述消费信息存储器中获取现有乘客统计信息；从所述消费信息存储器中获取现有司机统计信息。缓存已有统计数据，减少统计过程耗时，且快速响应统计数据查询，实时监听完单数据，实时完成司乘完单统计。

Description

一种订单统计的优化方法
技术领域
本发明涉及网约车领域，尤其涉及一种订单统计的优化方法。
背景技术
司乘订单统计在网约车中有大量的应用场景，比如：司机完单奖励、新乘客发券儿、司机星级展示、高价值用户优惠。
乘客统计表中包含乘客基本信息、个人、机构单完单信息，统计状态，统计状态包括待统计、统计中、统计完成。
司机统计表中包含司机基本信息、个人、机构单完单信息，统计状态。
新用户注册，新用户包括乘客/司机，将乘客/司机信息插入对应统计表。
每30s扫描订单表将订单表中完单时间在上次统计时间之后的订单数据全部取出，从订单中取出下单乘客id，接单司机id，分别更新乘客和司机统计表，将对应乘客或司机的统计状态更新为待统计。
每1min扫描一次统计表中统计状态为：待统计的数据，再次扫描订单表，将对应用户或者乘客最新的完单信息统计出来,更新回统计表。
现有技术中的统计方法，方案设计复杂，代码和逻辑晦涩不易理解；30s扫描一次数据表，1min更新一次统计数据，统计数据不够实时；多次扫描订单表，获取待统计数据和统计司乘完单信息，对数据库造成很大压力。
发明内容
鉴于上述问题，提出了本发明以便提供克服上述问题或者至少部分地解决上述问题的一种订单统计的优化方法。
根据本发明的一个方面，提供了一种订单统计的优化方法，所述优化方法包括：
采用数据变动监听组件获取订单数据变化，并发送订单数据消息队列消息；
接收所述订单数据消息队列消息并存储，以供消费者消费信息存储器Redis；
从所述消费信息存储器中获取现有乘客统计信息；
从所述消费信息存储器中获取现有司机统计信息。
可选的，所述接收所述订单数据消息队列消息并存储，以供消费者消费信息存储器具体包括：缓存中间件，内存存储，查询响应在1ms以内，查询效率为磁盘存储的10倍，用来缓存司机、乘客统计数据，避免磁盘存储访问；
配置Canal监听订单数据变化，订单数据变化包括插入、更新和删除，将新增数据或变更数据发送到RocketMQ中；
配置消费者，监听订单变动数据，包括乘客信息，司机信息,订单是个人单还是机构单，变更实时获取；
新乘客注册：将用户信息，乘客ID、注册时间写入统计表，完单数据初始化为0，统计状态置更新为待统计状态；
新司机注册：将司机信息，司机ID、注册时间写入统计表，完单数初始化为0，统计状态更新为待统计；
监听订单数据变动,处理订单完单状态。
可选的，所述从所述消费信息存储器中获取现有乘客统计信息具体包括：
若所述消费信息存储器中为空，说明是首单，根据订单类型orderType更新对应统计字段；
若所述消费信息存储器为非空，Redis中已有乘客统计信息，说明已有统计信息，取出原有信息，将对应字段+1，orderType为1，则将个人单完单数的值增加1，机构单完单数的值不变，更新缓存，并且更新回磁盘存储乘客统计表。
可选的，所述从所述消费信息存储器中获取现有司机统计信息具体包括：
根据orderType和是否首单，更新Redis数据并更新司机统计表；
实时统计订单数据。
可选的，所述根据订单类型orderType更新对应统计字段具体包括：
若订单类型orderType为1，订单为个人单，将司乘统计表对应个人单完单数字段更新为1，机构单完单数不变；
若订单类型orderType为2，订单为机构单，将机构单完单数字段置为1，个人单完单数不变，保持为0，写回Redis，并写回所述磁盘存储中乘客统计表。
本发明提供了提供了一种订单统计的优化方法，所述优化方法包括：采用数据变动监听组件获取订单数据变化，并发送订单数据消息队列消息；接收所述订单数据消息队列消息并存储，以供消费者消费信息存储器Redis；从所述消费信息存储器中获取现有乘客统计信息；从所述消费信息存储器中获取现有司机统计信息。缓存已有统计数据，减少统计过程耗时，且快速响应统计数据查询，实时监听完单数据，实时完成司乘完单统计。
上述说明仅是本发明技术方案的概述，为了能够更清楚了解本发明的技术手段，而可依照说明书的内容予以实施，并且为了让本发明的上述和其它目的、特征和优点能够更明显易懂，以下特举本发明的具体实施方式。
附图说明
为了更清楚地说明本发明实施例的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其它的附图。
图1为本发明实施例提供的一种订单统计的优化方法流程图。
具体实施方式
下面将参照附图更详细地描述本公开的示例性实施例。虽然附图中显示了本公开的示例性实施例，然而应当理解，可以以各种形式实现本公开而不应被这里阐述的实施例所限制。相反，提供这些实施例是为了能够更透彻地理解本公开，并且能够将本公开的范围完整的传达给本领域的技术人员。
本发明的说明书实施例和权利要求书及附图中的术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元。
下面结合附图和实施例，对本发明的技术方案做进一步的详细描述。
如图1所示，一种订单统计的优化方法，所述优化方法包括：
采用数据变动监听组件获取订单数据变化，并发送订单数据消息队列消息。
接收订单数据消息队列消息并存储，以供消费者消费信息存储器Redis。
缓存中间件，内存存储，查询响应在1ms以内，查询效率为磁盘存储的10倍，用来缓存司机、乘客统计数据，避免磁盘存储访问。
配置Canal监听订单数据变化，订单数据变化包括插入、更新和删除，将新增数据或变更数据发送到RocketMQ中。
配置消费者，监听订单变动数据，包括乘客信息，司机信息,订单是个人单还是机构单，变更实时获取。
新乘客注册：将用户信息，乘客ID、注册时间写入统计表，完单数据初始化为0，统计状态置更新为待统计状态。
新司机注册：将司机信息，司机ID、注册时间写入统计表，完单数初始化为0，统计状态更新为待统计。监听订单数据变动,处理订单完单状态。从消费信息存储器中获取现有乘客统计信息。
若消费信息存储器中为空，说明是首单，根据订单类型orderType更新对应统计字段；若订单类型orderType为1，订单为个人单，将司乘统计表对应个人单完单数字段更新为1，机构单完单数不变。
若订单类型orderType为2，订单为机构单，将机构单完单数字段置为1，个人单完单数不变，保持为0，写回Redis，并写回磁盘存储中乘客统计表。
若消费信息存储器为非空，Redis中已有乘客统计信息，说明已有统计信息，取出原有信息，将对应字段+1，orderType为1，则将个人单完单数的值增加1，机构单完单数的值不变，更新缓存，并且更新回磁盘存储乘客统计表。
从消费信息存储器中获取现有司机统计信息；根据orderType和是否首单，更新Redis数据并更新司机统计表；实时统计订单数据。
有益效果：缓存已有统计数据，减少统计过程耗时，快速响应统计数据查询；实时监听完单数据，实时完成司乘完单统计；无需反复扫描订单表，极大降低磁盘存储的压力。
以上的具体实施方式，对本发明的目的、技术方案和有益效果进行了进一步详细说明，所应理解的是，以上仅为本发明的具体实施方式而已，并不用于限定本发明的保护范围，凡在本发明的精神和原则之内，所做的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。

Claims (5)

1.一种订单统计的优化方法，其特征在于，所述优化方法包括：
采用数据变动监听组件获取订单数据变化，并发送订单数据消息队列消息；
接收所述订单数据消息队列消息并存储，以供消费者消费信息存储器Redis；
从所述消费信息存储器中获取现有乘客统计信息；
从所述消费信息存储器中获取现有司机统计信息。
2.根据权利要求1所述的一种订单统计的优化方法，其特征在于，所述接收所述订单数据消息队列消息并存储，以供消费者消费信息存储器具体包括：缓存中间件，内存存储，查询响应在1ms以内，查询效率为磁盘存储的10倍，用来缓存司机、乘客统计数据，避免磁盘存储访问；
配置Canal监听订单数据变化，订单数据变化包括插入、更新和删除，将新增数据或变更数据发送到RocketMQ中；
配置消费者，监听订单变动数据，包括乘客信息，司机信息,订单是个人单还是机构单，变更实时获取；
新乘客注册：将用户信息，乘客ID、注册时间写入统计表，完单数据初始化为0，统计状态置更新为待统计状态；
新司机注册：将司机信息，司机ID、注册时间写入统计表，完单数初始化为0，统计状态更新为待统计；
监听订单数据变动,处理订单完单状态。
3.根据权利要求1所述的一种订单统计的优化方法，其特征在于，所述从所述消费信息存储器中获取现有乘客统计信息具体包括：
若所述消费信息存储器中为空，说明是首单，根据订单类型orderType更新对应统计字段；
若所述消费信息存储器为非空，Redis中已有乘客统计信息，说明已有统计信息，取出原有信息，将对应字段+1，orderType为1，则将个人单完单数的值增加1，机构单完单数的值不变，更新缓存，并且更新回磁盘存储乘客统计表。
4.根据权利要求1所述的一种订单统计的优化方法，其特征在于，所述从所述消费信息存储器中获取现有司机统计信息具体包括：
根据orderType和是否首单，更新Redis数据并更新司机统计表；
实时统计订单数据。
5.根据权利要求3所述的一种订单统计的优化方法，其特征在于，所述根据订单类型orderType更新对应统计字段具体包括：
若订单类型orderType为1，订单为个人单，将司乘统计表对应个人单完单数字段更新为1，机构单完单数不变；
若订单类型orderType为2，订单为机构单，将机构单完单数字段置为1，个人单完单数不变，保持为0，写回Redis，并写回所述磁盘存储中乘客统计表。
CN202111320377.1A 2021-11-09 2021-11-09 一种订单统计的优化方法 Pending CN114037155A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202111320377.1A CN114037155A (zh) 2021-11-09 2021-11-09 一种订单统计的优化方法

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202111320377.1A CN114037155A (zh) 2021-11-09 2021-11-09 一种订单统计的优化方法

Publications (1)

Publication Number Publication Date
CN114037155A true CN114037155A (zh) 2022-02-11

Family

ID=80143662

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202111320377.1A Pending CN114037155A (zh) 2021-11-09 2021-11-09 一种订单统计的优化方法

Country Status (1)

Country Link
CN (1) CN114037155A (zh)

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN115688951A (zh) * 2022-11-15 2023-02-03 首约科技(北京)有限公司 一种运力订单指标的统计方法、装置和设备
WO2024143671A1 (ko) * 2022-12-27 2024-07-04 쿠팡 주식회사 주문 데이터를 처리하는 방법 및 장치

Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20090234529A1 (en) * 2008-03-15 2009-09-17 Volkswagen Of America, Inc. Method for Processing Data Based on an Evaluation of Real-Time Measurements of Movements of a User in a Vehicle and Based on Statistical Data on User Interactions With Input Devices in the Vehicle
US20180025407A1 (en) * 2015-02-02 2018-01-25 Beijing Didi Infinity Technology And Development Co., Ltd. Methods and systems for order processing
CN108804237A (zh) * 2017-05-05 2018-11-13 北京京东尚科信息技术有限公司 数据实时统计方法、装置、存储介质和电子设备
CN110019255A (zh) * 2017-07-31 2019-07-16 北京嘀嘀无限科技发展有限公司 数据查询方法、装置、服务器及存储介质
CN110727708A (zh) * 2019-09-29 2020-01-24 佘万卫 数据统计方法、展示方法及系统
CN113052543A (zh) * 2021-05-31 2021-06-29 广州宸祺出行科技有限公司 一种区域订单和司机热力的统计储存方法、装置及应用

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20090234529A1 (en) * 2008-03-15 2009-09-17 Volkswagen Of America, Inc. Method for Processing Data Based on an Evaluation of Real-Time Measurements of Movements of a User in a Vehicle and Based on Statistical Data on User Interactions With Input Devices in the Vehicle
US20180025407A1 (en) * 2015-02-02 2018-01-25 Beijing Didi Infinity Technology And Development Co., Ltd. Methods and systems for order processing
CN108804237A (zh) * 2017-05-05 2018-11-13 北京京东尚科信息技术有限公司 数据实时统计方法、装置、存储介质和电子设备
CN110019255A (zh) * 2017-07-31 2019-07-16 北京嘀嘀无限科技发展有限公司 数据查询方法、装置、服务器及存储介质
CN110727708A (zh) * 2019-09-29 2020-01-24 佘万卫 数据统计方法、展示方法及系统
CN113052543A (zh) * 2021-05-31 2021-06-29 广州宸祺出行科技有限公司 一种区域订单和司机热力的统计储存方法、装置及应用

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN115688951A (zh) * 2022-11-15 2023-02-03 首约科技(北京)有限公司 一种运力订单指标的统计方法、装置和设备
WO2024143671A1 (ko) * 2022-12-27 2024-07-04 쿠팡 주식회사 주문 데이터를 처리하는 방법 및 장치

Similar Documents

Publication Publication Date Title
CN114037155A (zh) 一种订单统计的优化方法
US8015152B2 (en) Web based client/server notification engine
CN111949568B (zh) 一种报文处理方法、装置及网络芯片
CN101046807B (zh) 存储数据已读信息的方法及装置
CN110830581B (zh) 提升区块链响应速度的方法、区块链应用系统及相关设备
CN106503020B (zh) 日志数据处理方法及装置
CN107888512B (zh) 动态共享缓冲存储器及交换机
CN111427859B (zh) 一种消息处理方法、装置、电子设备及存储介质
CN106326499B (zh) 一种数据处理方法及装置
CN107786623B (zh) 消息异步处理方法和装置
CN110737536A (zh) 一种基于共享内存的消息存储方法和消息读取方法
CN112860750A (zh) 数据处理方法、装置、电子设备及存储介质
JP2015505411A (ja) ローカルに記憶された電子メッセージとリモートに記憶された電子メッセージを混合提示するためのシステムおよび方法
CN101957849A (zh) 静态报表生成方法和装置
CN115617255A (zh) 缓存文件的管理方法和管理装置
CN111026755A (zh) 基于全量序号发生器的交易序号获取方法及装置
CN114077554B (zh) 一种数据解码方法、系统、设备及介质
CN100410945C (zh) 一种实现论坛的方法及系统
CN114328981B (zh) 基于模式映射的知识图谱建立和数据获取方法、装置
CN108629653A (zh) 一种低延时库存扣减服务系统及方法
CN111026758A (zh) 电子券发放方法和装置
CN115840654B (zh) 消息的处理方法、系统、计算设备及可读存储介质
CN115658337B (zh) 一种消息全生命周期处理方法及分布式消息系统
CN111309746A (zh) 异步并行数据同步方法及装置
CN117290395A (zh) 优惠券库存管理方法、装置、存储介质及处理器

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination