> 持续流程改进 > 线索到收款 > SAP Sales Cloud > 数据模板

您的Lead to Cash数据模板

SAP Sales Cloud

← 返回改进指南

线索到收款属性 (17) 线索到收款活动 (15) 提取指南 (2)

您的Lead to Cash数据模板

此模板为收集Lead to Cash流程分析所需数据提供结构化指南，列出构建完整事件日志所需的关键属性和活动，并提供从SAP Sales Cloud系统提取数据的实用指导，帮助您顺利开始流程挖掘。

建议收集的属性
需要跟踪的关键活动
SAP Sales Cloud数据提取指南

刚接触事件日志？了解如何创建流程挖掘事件日志.

下载模板

线索到收款属性

以下是建议纳入事件日志的数据字段，用于全面分析SAP Sales Cloud中的线索到收款流程。

3 必需 6 建议 8 可选

	名称	说明
	事件时间 EventTime	表示特定活动或事件发生时间的时间戳。
说明事件时间记录活动完成的准确日期和时间。这些时间数据对于了解流程步骤的时间点和持续时长至关重要，也为构建流程顺序提供所需的时间先后关系。在流程分析中，时间戳用于计算活动之间的周期时间、衡量销售流程的总体持续时长，并识别延迟或瓶颈。随时间分析时间戳，还可以发现流程绩效趋势。为什么重要时间戳对于按时间顺序排列事件，以及开展周期时间分析和瓶颈识别等所有基于时间的分析都至关重要。获取位置通常位于SAP Sales Cloud中Lead、Opportunity、Quote和Sales Order等业务对象的“Creation Date”或“Last Changed Date”字段。示例 2023-04-15T10:30:00Z2023-05-02T14:00:00Z2023-06-20T09:15:00Z
	活动名称 ActivityName	在流程特定节点发生的业务活动或事件名称。
说明活动名称用于描述订单到收款过程中的具体步骤或事件，例如“Lead Qualified”“Quote Created”或“Payment Received”。这些事件构成每个销售机会流程顺序中的一系列操作。分析这些活动是流程挖掘的核心。它可以将流程图可视化，识别步骤之间的瓶颈，并衡量不同流程路径的频次，从而揭示销售流程的实际执行方式。为什么重要此属性定义流程图中的步骤，是可视化和分析流程顺序的基础。获取位置来源包括业务对象状态变更、文档创建事件，或SAP Sales Cloud交易日志中记录的特定用户操作。示例线索已获取机会已创建报价已发送给客户已收到付款
	销售商机 SalesOpportunityId	销售商机的唯一标识符，是Lead to Cash流程的主要案例标识符。
说明 Sales Opportunity ID可唯一标识每笔潜在销售，从最初作为线索产生，到最终成交或流失。它是连接所有相关活动的主线，包括线索资格审查、报价创建、订单处理和付款。在流程挖掘分析中，该ID对于还原每个商机的端到端历程至关重要。它可以关联所有事件，从而按商机分析流程变体、周期时间和转化率。为什么重要这是连接流程中所有活动的核心Case ID，可用于追踪每个销售商机的完整生命周期。获取位置这是SAP Sales Cloud中Opportunity业务对象的主键。示例 OP-8000123456OP-8000123457OP-8000123458
	产品类别 ProductCategory	商机中所售产品或服务的类别。
说明 Product Category将商机中的具体产品或服务归入更宽泛的分类，例如“硬件”“软件”或“咨询服务”。当涉及大量具体产品时，这种分类可以简化分析。按Product Category分析对于了解不同类型产品的销售流程差异至关重要。它可用于“折扣分布”和“订单履约效率”等仪表板，判断某些类别是否涉及更高折扣或更长履约时间。为什么重要支持根据所售产品或服务类型分析流程差异，因为不同类型的销售周期可能存在显著不同。获取位置来源于SAP Sales Cloud中与Sales Quote或Sales Order行项目关联的产品主数据。示例软件许可证硬件专业服务支持订阅
	商机状态 OpportunityStatus	销售商机当前所处的状态或结果，例如“Open”“Won”或“Lost”。
说明此属性反映销售商机在特定时间点的整体状态，表示商机仍在推进中、已成功赢单，或因竞争对手等原因而流失。分析最终状态是计算“商机赢单率”等关键KPI的基础。您还可以据此筛选分析范围，仅关注成功路径，或调查最常导致交易流失的流程模式。为什么重要定义案例结果，对于计算赢单率和流失率，以及分析成功与未成功商机的流程路径至关重要。获取位置 SAP Sales Cloud中Opportunity业务对象的“Status”字段。示例开放处理中已赢单已丢单已停止
	折扣百分比 DiscountPercentage	应用于销售报价或订单的折扣百分比。
说明此属性记录商机适用的整体折扣率，通常在报价或订单阶段确定，以标价的百分比表示。这是分析财务绩效和销售纪律的重要指标。“折扣分布”仪表板使用此属性监控不同销售代表和产品的折扣行为；“折扣审批合规”KPI则使用该属性确保大额折扣遵循正确的审批工作流。为什么重要对于分析定价策略、销售团队的折扣行为及其对盈利能力的影响至关重要。获取位置根据SAP Sales Cloud中关联Sales Quote或Sales Order业务对象的定价要素计算。示例 0.050.100.25
	线索来源 LeadSource	初始线索的营销渠道或来源。
说明 Lead Source用于说明潜在客户最初通过何种方式被识别，例如网页表单、展会或合作伙伴推荐。该信息通常在线索创建时采集。此属性是“按来源统计线索转化率”仪表板的关键数据。分析这一维度可以帮助营销和销售团队了解哪些渠道带来的线索价值最高，从而更合理地分配资源并优化营销活动。为什么重要对于衡量不同营销渠道的效果和优化线索生成策略至关重要。获取位置位于SAP Sales Cloud的Lead和Opportunity业务对象中，字段通常命名为“Source”或“Origin”。示例网络研讨会合作伙伴推荐贸易展会网站咨询
	销售代表 SalesRepresentative	负责管理销售商机的员工。
说明此属性用于标识负责线索或商机的用户或员工。该人员通常是客户的主要联系人，并负责推动交易通过销售管道。在分析中，Sales Representative是比较绩效的重要维度。您可以按个人、团队或区域评估销售周期时间、赢单率和流程遵循情况，从而识别高绩效人员及需要辅导的领域。为什么重要支持按员工分析绩效，帮助识别销售人员的辅导机会和最佳实践。获取位置关联SAP Sales Cloud中Opportunity或Lead业务对象的“Owner”或“Employee Responsible”参与方角色。示例 John SmithMaria GarciaChen Wei
	销售订单金额 SalesOrderAmount	与商机关联的销售订单总金额。
说明此属性表示商机赢单并创建销售订单后，所售商品或服务的总价值，反映销售流程成功完成后产生的收入。 Sales Order Amount是分析中的关键财务维度。您可以按金额将商机划分为小型、中型和大型交易，观察不同规模交易的流程行为是否存在差异。它还为赢单率等KPI提供价值背景，展示赢单商机与流失商机的总金额。为什么重要为流程提供财务维度，支持按价值分析销售周期和结果。获取位置该值来源于SAP Sales Cloud中关联Sales Order业务对象的“Total Net Value”字段。示例 50000.00125000.507800.00
	付款条件 PaymentTerms	约定的付款条件，例如“Net 30”或“Net 60”。
说明 Payment Terms定义客户购买商品或服务时应遵守的付款条件。该条件在销售订单或签约阶段确定，并规定发票到期日。此属性是“付款回收周期时间”仪表板的重要维度。按付款条件细分后，企业可以评估客户是否遵守约定的付款计划，并识别哪些条件对应更长或更短的付款周期。为什么重要为付款回收分析提供上下文，帮助判断延迟是由客户行为还是宽松的付款条件造成。获取位置位于SAP Sales Cloud的Sales Order或Customer主数据中。示例账期30天账期60天收到即付
	最后数据更新时间 LastDataUpdate	数据最近一次从源系统提取或刷新的时间戳。
说明此属性表示事件日志数据最近一次更新的时间，可帮助了解所分析数据的新鲜度，从而判断分析结果的参考价值。在任何流程分析中，了解数据的时效性都至关重要。它可以帮助相关人员判断洞察反映的是当前运营情况还是过去某一时期，这会影响基于分析结果的决策。为什么重要提供有关数据新鲜度的重要上下文，确保分析和决策基于最新信息。获取位置这是在数据提取和转换（ETL）过程中添加的元数据时间戳。示例 2024-07-20T02:00:00Z2024-07-21T02:00:00Z
	区域 Region	客户或销售团队所在的地理区域。
说明 Region表示分配给销售商机的地理区域，通常依据客户所在地或销售组织架构确定，可以是国家、州或自定义销售区域。这是重要的细分属性，直接用于“商机赢单率绩效”仪表板，以比较不同区域的绩效，帮助识别各区域在流程效率、市场成功率和销售策略方面的差异。为什么重要支持按地理位置分析销售绩效，突出不同区域在赢单率、周期时间和流程执行方面的差异。获取位置通常根据客户地址或SAP Sales Cloud中分配给商机的销售组织得出。示例北美EMEAAPACLATAM
	客户名称 CustomerName	与销售商机关联的公司或个人名称。
说明此属性用于标识销售交易的潜在客户，并将销售流程关联到系统中的特定客户账户。按客户分析可以从客户视角了解销售流程，帮助识别销售周期最长或返工最多的客户，也可用于按客户细分“付款回收周期时间”等KPI。为什么重要支持以客户为中心的分析，识别特定账户在销售周期或付款行为方面的模式。获取位置关联SAP Sales Cloud中Opportunity业务对象的“Account”或“Prospect”参与方角色。示例 Global Tech Inc.Innovate Solutions Ltd.Dynamic Corp
	是否返工 IsReworked	用于标识活动或案例是否经历过返工的标志。
说明如果检测到流程返工循环，此布尔标志将设为true，例如销售订单创建后被修改，或报价被多次修订。该标志通过分析活动序列得出。此计算属性对于量化流程低效至关重要。它直接支持“销售订单返工频率”仪表板和“销售订单返工率”KPI，无需在分析工具中进行复杂的模式匹配，即可筛选和统计返工实例。为什么重要通过标记存在返工循环的案例，直接量化流程低效，简化返工频率及其原因分析。获取位置此属性不在源系统中，而是在数据转换过程中通过检测重复活动序列计算得出，例如“Sales Order Created”后紧接“Sales Order Reworked”。示例 truefalse
	源系统 SourceSystem	标识数据来源的系统。
说明此属性用于指定生成事件数据的源应用。对于此流程，通常为“SAP Sales Cloud”，也可能包括用于捕获线索的营销自动化平台等其他集成系统。在多系统环境中，此属性对于了解数据血缘和排查数据集成问题非常重要，可确保分析清楚掌握每条信息的来源。为什么重要有助于区分集成环境中的数据来源，确保分析时数据血缘和上下文清晰。获取位置通常是在数据提取过程中添加的静态值，用于标记记录来源。示例 SAP Sales CloudSAP C4CSSC_PROD_100
	运输方式 ShippingMethod	向客户交付实物产品所采用的方式。
说明此属性用于指定订单的物流或交付方式，例如“陆运”“空运”或“数字交付”。它适用于涉及实物商品的流程。在“订单履约效率”仪表板中，此属性有助于分析不同运输方式是否对应不同的履约时间，从而发现特定物流渠道的低效环节，或更准确地设定客户预期。为什么重要通过按物流渠道细分交付绩效，帮助诊断订单履约环节中的瓶颈。获取位置通常位于SAP Sales Cloud中Sales Order业务对象的行项目级或抬头级。示例陆运次日空运数字下载货运
	销售组织 SalesOrganization	负责销售的组织单位。
说明 Sales Organization表示公司内负责销售交易的特定单位、部门或团队，是SAP企业结构的重要组成部分。此属性支持按企业不同部门细分分析。您可以比较不同业务单元或销售部门的流程绩效、赢单率和周期时间，从组织层面了解效率。为什么重要支持在不同业务单元或公司部门之间进行绩效基准比较和流程分析。获取位置这是SAP Sales Cloud中Opportunity或Sales Order的关键组织分配字段。示例 US01DE01北区企业销售

必需建议可选

线索到收款活动

以下是需要记录在事件日志中的关键流程步骤和里程碑，用于准确发现并分析您的线索到收款流程。

7 建议 8 可选

	活动	说明
	已收到付款	此活动确认客户付款已收到并完成处理，标志着财务交易完成。该信息几乎总是来自外部财务或ERP系统，由其更新SAP Sales Cloud中的发票或订单状态。
为什么重要这是Lead to Cash流程中最终实现价值的步骤。衡量从发票到收款的“收款周期时间”，是管理现金流和评估应收账款绩效的关键指标。获取位置根据Invoice或Sales Order对象状态变更为“Paid”或“Cleared”来推断。该数据来自外部财务系统。采集确定Invoice状态变更为“Paid”或“Cleared”的时间戳。事件类型 inferred
	报价已发送给客户	此活动表示正式报价已提交给客户审核。通常根据Sales Quote对象的状态变更推断，例如从“In Preparation”变为“Sent”或“Proposed”。
为什么重要这是启动客户谈判和决策计时的关键里程碑。分析从此事件到报价接受之间的时长，对于了解交易推进速度和谈判瓶颈至关重要。获取位置根据Sales Quote业务对象的状态变更历史推断。查找状态更新为表示报价已发送的值时的时间戳。采集确定Sales Quote对象状态变更为“Sent”的时间戳。事件类型 inferred
	机会已创建	这是销售机会的正式起点，表示合格线索已转化为具体的销售推进事项。系统会在创建Opportunity业务对象时明确记录此事件，通常还会继承原始线索的数据。
为什么重要作为销售周期分析的主要起点，此活动至关重要。它支持衡量销售周期时长、机会赢单率以及交易正式形成后销售团队的绩效。获取位置此事件对应SAP Sales Cloud中Opportunity业务对象的创建时间戳。采集使用Opportunity记录的创建日期和时间。事件类型 explicit
	机会已赢单	此活动表示交易已成功结束，企业赢得了该业务。用户将Opportunity状态更改为“Won”时会记录此事件，这是系统中的标准明确操作。
为什么重要这是衡量赢单率和销售绩效的关键里程碑。它通常会触发订单创建和履约等后续流程，是Lead to Cash周期中的重要转折点。获取位置根据Opportunity业务对象的状态变更历史推断，即状态更新为“Won”时的时间戳。采集确定Opportunity对象状态变更为“Won”的时间戳。事件类型 inferred
	机会已赢单关闭	此活动表示成功机会在订单创建、履约等所有后续活动完成后的最终状态。用户将Opportunity状态更改为最终“Closed”状态，并将原因设为“Won”时记录此事件。
为什么重要此事件是流程挖掘分析中的成功终点，可用于计算所有赢单交易的端到端销售周期时长，并提供明确、完整的流程结论。获取位置根据Opportunity对象的状态变更历史推断，具体为状态更新为“Closed”且原因为“Won”时的时间戳。采集确定状态变更为“Closed”且原因代码为“Won”的时间戳。事件类型 inferred
	机会已输单关闭	此活动标志着未成功机会的最终结束，可能是交易输给竞争对手，也可能是客户决定不购买。用户将Opportunity状态更改为“Lost”或“Closed Lost”时记录此事件。
为什么重要分析机会何时以及为何流失，对于改进销售策略至关重要。这个失败终点支持分析输单交易，例如客户通常在哪个阶段流失，以及最常见的流失原因。获取位置根据Opportunity业务对象的状态变更历史推断，即状态更新为“Lost”或“Closed Lost”时的时间戳。采集确定Opportunity对象状态变更为“Lost”的时间戳。事件类型 inferred
	销售订单已创建	此活动表示创建了正式销售订单，这是启动履约和开票的内部正式文件。用户创建Sales Order对象并将其关联到上级机会时，系统会明确记录此事件。
为什么重要这是从销售向运营交接的关键节点。分析从“Opportunity Won”到“Sales Order Created”的时间，可以发现内部延迟；跟踪此后的返工，则有助于识别数据质量问题。获取位置此事件对应与Opportunity关联的Sales Order业务对象的创建时间戳。采集使用关联Sales Order记录的创建日期和时间。事件类型 explicit
	发票已生成	表示创建客户发票，启动流程的最终财务阶段。此事件可能来自SAP Sales Cloud中Invoice对象的创建，更常见的是来自集成的计费系统。
为什么重要此活动会触发收款周期。发票生成延迟会直接影响现金流，因此监控从履约到开票的时间对于财务健康度至关重要。获取位置可以使用与Sales Order关联的Invoice业务对象创建时间戳，也可以使用外部ERP的更新记录。具体来源取决于系统环境。采集使用Invoice记录的创建日期，或集成ERP中的活动日志记录。事件类型 explicit
	客户已接受报价	表示客户已正式或非正式同意报价条款。通常由销售代表在Sales Quote或Opportunity对象上手动更新状态来记录。
为什么重要这是明确的购买信号，也是合同最终确定或创建订单前的关键里程碑。它有助于衡量方案效果和客户决策周期的长度。获取位置根据Sales Quote对象状态变更为“Accepted”，或关联Opportunity对象发生类似状态变更来推断。采集确定Sales Quote状态变更为“Accepted”的时间戳。事件类型 inferred
	已提出解决方案	此活动表示已向客户展示潜在解决方案或产品配置。通常根据Opportunity对象上的销售阶段或状态变更推断，例如进入“Proposal”或“Solution Design”阶段。
为什么重要分析在此阶段停留的时间以及进入报价阶段的过渡，有助于识别解决方案设计流程中的瓶颈，并了解从首次接触到形成具体方案所需的时间。获取位置根据Opportunity对象的变更日志或状态历史推断，具体查找销售阶段更新为“Solution Proposed”或“Value Proposition”等值的记录。采集确定Opportunity的销售阶段字段变更为表示已提出方案的时间戳。事件类型 inferred
	报价已创建	表示创建了与销售机会关联的正式销售报价单。这是报价发送给客户前的内部步骤，在用户生成新的Quote记录时明确记录。
为什么重要此活动将内部准备时间与客户收到报价后的时间区分开来，有助于分析报价生成流程的效率，以及销售人员准备定价所需的时间。获取位置此事件对应与Opportunity关联的Sales Quote业务对象的创建时间戳。采集使用关联Sales Quote记录的创建日期和时间。事件类型 explicit
	线索已合格	表示线索经过审核并符合成为有效销售潜客的标准。通常在用户将Lead状态手动更改为“Qualified”或类似状态时记录，表明该线索已准备好转化。
为什么重要此活动将原始线索与高意向潜客区分开来，有助于分析资格审查流程的效率。它可以帮助您判断不同来源线索的质量，并识别从线索获取到主动销售之间的瓶颈。获取位置根据Lead业务对象的状态变更历史推断。查找状态字段更新为“Qualified”的时间戳。采集确定Lead对象状态变更为“Qualified”的时间戳。事件类型 inferred
	线索已获取	此活动表示在SAP Sales Cloud中首次创建线索记录。它代表潜在客户的首次接触或兴趣，通常由网页表单、列表导入或用户手动录入自动记录。
为什么重要跟踪此事件对于分析不同线索来源的效果和衡量整体线索生成量至关重要。它是计算线索转化率和了解销售漏斗顶部情况的起点。获取位置此事件取自Lead业务对象的创建时间戳。线索来源通常作为同一对象的属性提供。采集使用Lead记录的创建日期和时间。事件类型 explicit
	订单已履约	此活动表示产品已发货或服务已交付给客户。通常通过与ERP或物流系统的集成记录，由外部系统更新SAP Sales Cloud中的Sales Order状态。
为什么重要这标志着交付环节完成。衡量从“Sales Order Created”到“Order Fulfilled”的时间，对于监控订单履约效率及其对客户满意度的影响至关重要。获取位置通常根据Sales Order对象的状态变更推断，例如变为“Fulfilled”或“Shipped”。该状态通常通过外部系统集成更新。采集确定Sales Order状态变更为“Fulfilled”或“Delivered”的时间戳。事件类型 inferred
	销售订单已返工	表示销售订单提交后发生了修改或更正。通常通过检测销售订单状态循环来推断，例如状态从“Submitted”退回“In Process”或“Pending Revision”。
为什么重要识别返工对于发现流程低效、数据录入错误以及销售与运营之间的沟通缺口至关重要。返工频率高通常表明存在质量问题，会造成延迟并增加成本。获取位置根据Sales Order对象的状态变更历史推断，需要分析状态变更序列，以识别回退或循环。采集检测表示循环的状态转换，例如从“Submitted”转为“In Process”。事件类型 inferred

建议可选

提取指南

如何从SAP Sales Cloud获取数据

步骤

前提条件：确保您在SAP Sales Cloud中拥有可访问Analytics工作中心的用户，并具备创建和编辑数据源及报表的权限。
创建组合数据源：在Business Analytics工作中心中进入Design Data Sources视图。创建新的Combined Data Source。使用左外连接依次连接以下标准数据源，确保捕获所有商机：Lead Information -> Opportunity Header and Item -> Sales Quote Header and Item -> Sales Order Header and Item。连接条件通常应基于Opportunity ID或后续文档ID。
构建自定义报表：进入Design Reports视图。基于上一步创建的组合数据源新建报表。在报表视图中添加所有必要的特征和关键指标，包括标识符（Lead ID、Opportunity ID）、所有相关状态字段，以及所有时间戳字段（Creation Date、Status Change Dates等）。同时加入Sales Representative、Lead Source和Order Amount等所需属性。
将报表公开为OData服务：在Design Reports视图中选择新建的报表。在报表配置或设置中找到将报表公开为OData查询的选项，通常是名为Enable for OData的复选框。保存更改后，系统将为该报表生成唯一的OData URL。
获取OData URL：进入Administrator工作中心的OData Services视图。在列表中找到自定义报表并复制其服务URL，Python脚本将使用该URL。
设置Python环境：确保已安装Python以及requests和pandas库。您可以使用pip安装：pip install requests pandas。
配置Python脚本：复制提供的Python脚本，将C4C_TENANT_URL、OData_SERVICE_PATH、USERNAME和PASSWORD的占位值替换为您的SAP Sales Cloud凭据，以及上一步获取的OData URL。
执行提取脚本：运行Python脚本。脚本将通过OData API进行身份验证，分批获取数据以处理大数据量，并将数据加载到pandas DataFrame中。
数据转换：脚本会自动将宽格式数据（每个商机一行）转换为长格式事件日志。脚本会遍历每个潜在活动并检查时间戳是否有效。若存在时间戳，则创建对应的事件记录，并填入正确的ActivityName。
导出事件日志：脚本运行完成后，会将最终事件日志保存为同一目录下的lead_to_cash_event_log.csv文件。该文件可直接上传到流程挖掘工具。

配置

数据源配置：此方法的核心是SAP Sales Cloud Analytics中的Combined Data Source。必须从Opportunity对象开始使用Left Outer Joins，以确保捕获未生成报价或订单的商机。
报表特征：自定义报表必须包含与目标活动对应的所有日期和时间字段，包括线索、商机、报价和订单的创建时间戳，以及状态变更时间戳。
OData API筛选：为控制性能和数据量，请在Python脚本的OData URL中使用$filter参数。强烈建议按日期范围筛选，例如OpportunityCreationDate。初次分析通常选择6至12个月的日期范围。
分页：提供的脚本使用$top和$skip参数处理OData分页。这对于提取大型数据集、避免API连接超时至关重要。
前提条件：此方法要求使用专用分析用户，并具备访问OData API以及线索、商机、报价和订单底层数据源的权限。

a 示例查询 python

import requests
import pandas as pd
import numpy as np

class=class="hl-string">"hl-comment"># --- Configuration Placeholders ---
C4C_TENANT_URL = class="hl-string">"[Your SAP Sales Cloud Tenant URL, e.g., my123456.crm.ondemand.com]"
class=class="hl-string">"hl-comment"># The service path comes from the OData Services view for your custom report
ODATA_SERVICE_PATH = class="hl-string">"/sap/c4c/odata/analytics/ds/CUST_REPORT_ID.svc"
USERNAME = class="hl-string">"[Your_Username]"
PASSWORD = class="hl-string">"[Your_Password]"

class=class="hl-string">"hl-comment"># --- OData Service Details ---
class=class="hl-string">"hl-comment"># The entity set is usually the report ID followed by class="hl-string">'ResultSet'
ENTITY_SET = class="hl-string">"CUST_REPORT_IDResultSet"
BASE_API_URL = fclass="hl-string">"https://{C4C_TENANT_URL}{ODATA_SERVICE_PATH}/{ENTITY_SET}"

class=class="hl-string">"hl-comment"># --- Data Extraction ---
def get_odata_data(api_url, username, password):
    records = []
    page_size = 1000
    skip = 0
    
    class=class="hl-string">"hl-comment"># It is highly recommended to add a date filter for performance
    class=class="hl-string">"hl-comment"># e.g., class="hl-string">"$filter=OpportunityCreationDate ge datetime'2023-01-01T00:00:00'"
    odata_params = {
        class="hl-string">"$format": class="hl-string">"json",
        class="hl-string">"$top": page_size,
        class="hl-string">"$skip": skip,
        class="hl-string">"$inlinecount": class="hl-string">"allpages"
        class=class="hl-string">"hl-comment"># class="hl-string">"$filter": class="hl-string">"[Your OData Filter String]"
    }

    print(class="hl-string">"Starting data extraction from SAP Sales Cloud...")
    while True:
        odata_params[class="hl-string">'$skip'] = skip
        response = requests.get(api_url, auth=(username, password), params=odata_params)
        
        if response.status_code != 200:
            print(fclass="hl-string">"Error: Failed to fetch data. Status code: {response.status_code}")
            print(response.text)
            break

        data = response.json()[class="hl-string">'d']
        if class="hl-string">'results' in data and data[class="hl-string">'results']:
            records.extend(data[class="hl-string">'results'])
            count = len(data[class="hl-string">'results'])
            print(fclass="hl-string">"Fetched {len(records)} records...")
            if count < page_size:
                break
            skip += page_size
        else:
            break
            
    print(class="hl-string">"Extraction complete.")
    return pd.DataFrame(records)

source_df = get_odata_data(BASE_API_URL, USERNAME, PASSWORD)

class=class="hl-string">"hl-comment"># --- Data Transformation ---
if not source_df.empty:
    print(class="hl-string">"Starting data transformation into event log format...")
    
    class=class="hl-string">"hl-comment"># Rename columns for clarity (adjust these based on your report's field names)
    class=class="hl-string">"hl-comment"># These are example API field names from the OData service.
    class=class="hl-string">"hl-comment"># You MUST inspect your OData metadata to get the correct field names.
    column_mapping = {
        class="hl-string">'C_OpportunityId': class="hl-string">'SalesOpportunityId',
        class="hl-string">'LeadCreationDateTime': class="hl-string">'LeadCaptured_Time',
        class="hl-string">'LeadConversionDateTime': class="hl-string">'LeadQualified_Time',
        class="hl-string">'OpportunityCreationDateTime': class="hl-string">'OpportunityCreated_Time',
        class="hl-string">'OpportunityProposalStageDateTime': class="hl-string">'SolutionProposed_Time',
        class="hl-string">'QuoteCreationDateTime': class="hl-string">'QuoteCreated_Time',
        class="hl-string">'QuoteSentToCustomerDateTime': class="hl-string">'QuoteSentToCustomer_Time',
        class="hl-string">'QuoteAcceptedDateTime': class="hl-string">'QuoteAccepted_Time',
        class="hl-string">'OpportunityWonDateTime': class="hl-string">'OpportunityWon_Time',
        class="hl-string">'SalesOrderCreationDateTime': class="hl-string">'SalesOrderCreated_Time',
        class="hl-string">'SalesOrderReworkedDateTime': class="hl-string">'SalesOrderReworked_Time',
        class="hl-string">'SalesOrderFulfilledDateTime': class="hl-string">'OrderFulfilled_Time',
        class="hl-string">'InvoiceGeneratedDateTime': class="hl-string">'InvoiceGenerated_Time',
        class="hl-string">'PaymentReceivedDateTime': class="hl-string">'PaymentReceived_Time',
        class="hl-string">'OpportunityClosedWonDateTime': class="hl-string">'OpportunityClosedWon_Time',
        class="hl-string">'OpportunityClosedLostDateTime': class="hl-string">'OpportunityClosedLost_Time',
        class="hl-string">'SalesRepresentativeName': class="hl-string">'SalesRepresentative',
        class="hl-string">'LeadSourceName': class="hl-string">'LeadSource',
        class="hl-string">'OpportunityStatusName': class="hl-string">'OpportunityStatus',
        class="hl-string">'SalesOrderAmountValue': class="hl-string">'SalesOrderAmount',
        class="hl-string">'ProductCategoryName': class="hl-string">'ProductCategory',
        class="hl-string">'QuoteDiscountPercentage': class="hl-string">'DiscountPercentage'
    }
    source_df.rename(columns=column_mapping, inplace=True)

    class=class="hl-string">"hl-comment"># Convert date strings to datetime objects, coercing errors to NaT (Not a Time)
    date_cols = [col for col in source_df.columns if class="hl-string">'_Time' in col]
    for col in date_cols:
        class=class="hl-string">"hl-comment"># OData date format is /Date(timestamp)/. We need to extract the timestamp.
        source_df[col] = source_df[col].str.extract(rclass="hl-string">'\/Date\((\d+)\)\/').astype(float)
        source_df[col] = pd.to_datetime(source_df[col], unit=class="hl-string">'ms', errors=class="hl-string">'coerce')

    class=class="hl-string">"hl-comment"># Define the activities and their corresponding timestamp columns
    activity_mapping = {
        class="hl-string">'Lead Captured': class="hl-string">'LeadCaptured_Time',
        class="hl-string">'Lead Qualified': class="hl-string">'LeadQualified_Time',
        class="hl-string">'Opportunity Created': class="hl-string">'OpportunityCreated_Time',
        class="hl-string">'Solution Proposed': class="hl-string">'SolutionProposed_Time',
        class="hl-string">'Quote Created': class="hl-string">'QuoteCreated_Time',
        class="hl-string">'Quote Sent to Customer': class="hl-string">'QuoteSentToCustomer_Time',
        class="hl-string">'Quote Accepted by Customer': class="hl-string">'QuoteAccepted_Time',
        class="hl-string">'Opportunity Won': class="hl-string">'OpportunityWon_Time',
        class="hl-string">'Sales Order Created': class="hl-string">'SalesOrderCreated_Time',
        class="hl-string">'Sales Order Reworked': class="hl-string">'SalesOrderReworked_Time',
        class="hl-string">'Order Fulfilled': class="hl-string">'OrderFulfilled_Time',
        class="hl-string">'Invoice Generated': class="hl-string">'InvoiceGenerated_Time',
        class="hl-string">'Payment Received': class="hl-string">'PaymentReceived_Time',
        class="hl-string">'Opportunity Closed Won': class="hl-string">'OpportunityClosedWon_Time',
        class="hl-string">'Opportunity Closed Lost': class="hl-string">'OpportunityClosedLost_Time'
    }

    class=class="hl-string">"hl-comment"># Unpivot the DataFrame into an event log format
    event_log_df = pd.DataFrame()
    for activity, time_col in activity_mapping.items():
        if time_col in source_df.columns:
            temp_df = source_df[[class="hl-string">'SalesOpportunityId'] + [col for col in column_mapping.values() if col in source_df.columns]].copy()
            temp_df = temp_df.dropna(subset=[time_col])
            if not temp_df.empty:
                temp_df[class="hl-string">'ActivityName'] = activity
                temp_df.rename(columns={time_col: class="hl-string">'EventTime'}, inplace=True)
                event_log_df = pd.concat([event_log_df, temp_df])

    class=class="hl-string">"hl-comment"># Select and order final columns
    required_cols = [class="hl-string">'SalesOpportunityId', class="hl-string">'ActivityName', class="hl-string">'EventTime']
    recommended_cols = [class="hl-string">'SalesRepresentative', class="hl-string">'LeadSource', class="hl-string">'OpportunityStatus', class="hl-string">'SalesOrderAmount', class="hl-string">'ProductCategory', class="hl-string">'DiscountPercentage']
    final_cols = required_cols + [col for col in recommended_cols if col in event_log_df.columns]
    
    event_log_df = event_log_df[final_cols]
    event_log_df.sort_values(by=[class="hl-string">'SalesOpportunityId', class="hl-string">'EventTime'], inplace=True)

    class=class="hl-string">"hl-comment"># --- Export to CSV ---
    event_log_df.to_csv(class="hl-string">'lead_to_cash_event_log.csv', index=False)
    print(class="hl-string">"Event log saved to 'lead_to_cash_event_log.csv'.")
else:
    print(class="hl-string">"No data extracted. Skipping transformation and export.")

步骤

确认已为相关业务对象启用SAP Sales Cloud标准OData访问，并确认集成用户拥有Opportunity、Lead、Sales Quote、Sales Order、Invoice以及租户中可用的付款或履约数据的读取授权。使用系统中提供的SAP Sales Cloud管理和集成工具。具体菜单路径和对象服务名称因租户而异，请根据您的系统进行配置。
确认所需业务对象已发布的标准OData服务名称、实体集、键字段、导航属性、状态字段、变更时间戳、负责人字段、来源字段、金额字段、产品字段和关系字段。不要假设某个对象或属性一定已公开。请从已配置OData服务URL提供的服务元数据文档中记录已确认的元数据。
在Python脚本中配置连接URL、凭据或OAuth设置、日期范围、分页大小和公司专属筛选条件。初始使用三到六个月的日期范围，验证性能和完整性后再扩大范围。
通过已确认的标准OData实体集提取Opportunity和Lead记录，通过相应实体集提取Sales Quote和Sales Order记录。仅当SAP Sales Cloud公开了对应的标准OData对象和关系时，才提取发票、履约和付款记录。如果这些记录维护在集成的ERP或财务系统中，请从该系统获取经批准的等效OData数据源，并将其标识符映射到Opportunity。
通过遵循服务提供的下一页链接或使用受支持的分页机制，获取每个OData请求的所有页面。在支持的情况下应用服务器端日期和公司筛选条件。转换前保存原始响应，以便审计数量和映射关系。
将时间戳统一为一个时区，最好使用UTC，并将SAP日期或日期时间值转换为一致的ISO 8601格式。通过去除空格并进行不区分大小写的比较，统一状态值。在可能的情况下，将原始状态值保留在审计数据集中。
为每项必需活动创建一条事件记录。使用Lead创建时间作为Lead Captured，使用Lead达到Qualified的时间戳作为Lead Qualified，使用Opportunity创建时间作为Opportunity Created，使用Opportunity达到配置的方案或解决方案阶段的时间戳作为Solution Proposed，使用Sales Quote创建时间作为Quote Created，使用报价达到Sent或Proposed状态的时间戳作为Quote Sent to Customer，使用报价或Opportunity记录客户接受的时间戳作为Quote Accepted by Customer，使用Opportunity达到Won状态的时间戳作为Opportunity Won，使用Sales Order创建时间作为Sales Order Created，使用检测到的Submitted to In Process或Pending Revision转换作为Sales Order Reworked，使用履约或发货完成时间作为Order Fulfilled，使用发票创建时间作为Invoice Generated，使用收到付款或结算的时间作为Payment Received，使用最终Closed且原因为Won的状态作为Opportunity Closed Won，使用最终Lost或Closed Lost状态作为Opportunity Closed Lost。
使用SalesOpportunityId在外部关联事件。使用Lead、Opportunity、Sales Quote、Sales Order、Invoice、履约和付款记录之间已确认的关系字段。如果无法建立直接关系，请使用集成或业务流程维护的经批准交叉引用。不要仅根据描述或金额匹配来推断关系。
在源关系允许的情况下，为每条事件填充建议属性。从相关源记录中带出SalesRepresentative、LeadSource、OpportunityStatus、SalesOrderAmount、ProductCategory和DiscountPercentage；如果源数据未提供可靠值，则保留null值。
按SalesOpportunityId和EventTime对最终事件日志排序。仅删除由重复API页面或重试产生的完全重复记录。除非业务规则明确允许，否则不要合并不同的状态转换或具有相同时间戳的事件。
验证全部15个活动名称均已存在，必填字段不为空，时间戳位于请求范围内，或已明确记录为相关历史事件，并确认关系连接不会造成异常案例重复。导出UTF-8 CSV或其他ProcessMind支持的事件日志格式，列名必须准确为SalesOpportunityId、ActivityName和EventTime，并在可用时附带建议属性。将生成的文件上传到ProcessMind，不要假设平台会自动补齐缺失事件。

配置

**OData服务配置：**仅使用已在您租户服务元数据中确认的SAP Sales Cloud标准OData服务和实体集。服务名称、实体名称、属性名称和导航路径必须根据您的系统进行配置。
**连接与授权：**配置经批准的SAP Sales Cloud URL、身份验证方式、客户端凭据、作用域和读取权限。如果SAP Sales Cloud未公开相关事件，访问外部ERP、物流、计费或付款数据需要单独授权。
**日期范围：**从三至六个月开始。如果创建时间和状态时间戳可能早于所选流程窗口，请加入较短的回溯期。记录筛选条件使用的是创建时间、最后变更时间、状态转换时间，还是其他已确认的时间戳。
**必需案例键：**将每条事件映射到SalesOpportunityId。除非记录可通过经批准的交叉引用解析，否则不要输出缺少可靠Opportunity关系的事件。
**状态映射：**为Qualified、提案或解决方案阶段、Sent、Proposed、accepted、Won、Closed、Lost、Closed Lost、Submitted、In Process、Pending Revision、履约完成、发票创建和收到付款配置精确且适用于租户的映射。状态标签可能因配置和语言而异。
**筛选条件：**仅当公司、组织单位、单据类型、销售范围、状态和日期字段已公开且其业务含义明确时，才应用已确认的筛选条件。不能假定每个SAP Sales Cloud对象都存在Company Code和Document Type。
**分页与限流：**使用OData服务支持的分页大小和下一页机制。为临时性HTTP错误增加重试处理，遵守租户速率限制，避免过多并行请求。
**变更历史要求：**基于状态的活动需要带时间戳的状态历史或变更日志。仅凭当前状态字段无法可靠还原之前状态的到达时间。
**外部事件源：**订单履约、发票生成和收到付款可能由集成ERP、物流、计费或财务系统维护。请配置经批准的跨系统标识符和针对数据源的提取规则。
**数据质量：**值不可用时保留null。除非业务规则明确接受这一限制，否则不要用当前状态或当前负责人替代历史值。
**前提条件：**在安排提取任务前，确认所需SAP Sales Cloud版本、API可用性、集成配置、业务对象公开情况、租户授权以及任何外部系统许可证。

a 示例查询 python

import os
import time
from datetime import datetime, timezone
from typing import Any, Dict, Iterable, List, Optional

import pandas as pd
import requests

class=class="hl-string">"hl-comment"># Configure these values for your tenant and approved OData services.
BASE_URL = os.environ.get(class="hl-string">"SAP_SALES_CLOUD_ODATA_BASE_URL", class="hl-string">"[Your SAP Sales Cloud OData base URL]")
USERNAME = os.environ.get(class="hl-string">"SAP_SALES_CLOUD_USERNAME", class="hl-string">"[Your username]")
PASSWORD = os.environ.get(class="hl-string">"SAP_SALES_CLOUD_PASSWORD", class="hl-string">"[Your password]")
START_DATE = os.environ.get(class="hl-string">"EXTRACTION_START_DATE", class="hl-string">"[YYYY-MM-DD]")
END_DATE = os.environ.get(class="hl-string">"EXTRACTION_END_DATE", class="hl-string">"[YYYY-MM-DD]")
OUTPUT_FILE = os.environ.get(class="hl-string">"OUTPUT_FILE", class="hl-string">"lead_to_cash_event_log.csv")
PAGE_SIZE = int(os.environ.get(class="hl-string">"ODATA_PAGE_SIZE", class="hl-string">"500"))

class=class="hl-string">"hl-comment"># Replace each value below with the confirmed standard OData service URL and entity set
class=class="hl-string">"hl-comment"># from the metadata document in your tenant. Do not use an unconfirmed object name.
SERVICES = {
    class="hl-string">"lead": class="hl-string">"[Confirmed Lead OData service URL]",
    class="hl-string">"opportunity": class="hl-string">"[Confirmed Opportunity OData service URL]",
    class="hl-string">"sales_quote": class="hl-string">"[Confirmed Sales Quote OData service URL]",
    class="hl-string">"sales_order": class="hl-string">"[Confirmed Sales Order OData service URL]",
    class="hl-string">"invoice": class="hl-string">"[Confirmed Invoice OData service URL or approved integrated billing service URL]",
    class="hl-string">"fulfillment": class="hl-string">"[Confirmed fulfillment OData service URL or approved integrated logistics service URL]",
    class="hl-string">"payment": class="hl-string">"[Confirmed payment OData service URL or approved integrated financial service URL]",
}

class=class="hl-string">"hl-comment"># Replace property names and relationship paths with names confirmed from service metadata.
FIELDS = {
    class="hl-string">"lead": {
        class="hl-string">"id": class="hl-string">"[Confirmed Lead identifier property]",
        class="hl-string">"opportunity_id": class="hl-string">"[Confirmed Lead to Opportunity relationship property]",
        class="hl-string">"created_at": class="hl-string">"[Confirmed Lead creation timestamp property]",
        class="hl-string">"status": class="hl-string">"[Confirmed Lead status property]",
        class="hl-string">"status_changed_at": class="hl-string">"[Confirmed Lead status change timestamp property]",
        class="hl-string">"sales_representative": class="hl-string">"[Confirmed Lead representative property]",
        class="hl-string">"lead_source": class="hl-string">"[Confirmed Lead source property]",
        class="hl-string">"opportunity_status": class="hl-string">"[Confirmed related Opportunity status property or blank]",
        class="hl-string">"sales_order_amount": class="hl-string">"[Confirmed related Sales Order amount property or blank]",
        class="hl-string">"product_category": class="hl-string">"[Confirmed Lead product category property or blank]",
        class="hl-string">"discount_percentage": class="hl-string">"[Confirmed related discount property or blank]",
    },
    class="hl-string">"opportunity": {
        class="hl-string">"id": class="hl-string">"[Confirmed Opportunity identifier property]",
        class="hl-string">"created_at": class="hl-string">"[Confirmed Opportunity creation timestamp property]",
        class="hl-string">"stage": class="hl-string">"[Confirmed Opportunity stage property]",
        class="hl-string">"status": class="hl-string">"[Confirmed Opportunity status property]",
        class="hl-string">"status_changed_at": class="hl-string">"[Confirmed Opportunity status change timestamp property]",
        class="hl-string">"status_reason": class="hl-string">"[Confirmed Opportunity status reason property]",
        class="hl-string">"sales_representative": class="hl-string">"[Confirmed Opportunity representative property]",
        class="hl-string">"lead_source": class="hl-string">"[Confirmed Opportunity lead source property]",
        class="hl-string">"sales_order_amount": class="hl-string">"[Confirmed Opportunity or related Sales Order amount property]",
        class="hl-string">"product_category": class="hl-string">"[Confirmed Opportunity product category property]",
        class="hl-string">"discount_percentage": class="hl-string">"[Confirmed Opportunity or related discount property]",
    },
    class="hl-string">"sales_quote": {
        class="hl-string">"id": class="hl-string">"[Confirmed Sales Quote identifier property]",
        class="hl-string">"opportunity_id": class="hl-string">"[Confirmed Sales Quote to Opportunity relationship property]",
        class="hl-string">"created_at": class="hl-string">"[Confirmed Sales Quote creation timestamp property]",
        class="hl-string">"status": class="hl-string">"[Confirmed Sales Quote status property]",
        class="hl-string">"status_changed_at": class="hl-string">"[Confirmed Sales Quote status change timestamp property]",
        class="hl-string">"accepted_at": class="hl-string">"[Confirmed Sales Quote acceptance timestamp property or blank]",
        class="hl-string">"sales_representative": class="hl-string">"[Confirmed Sales Quote representative property]",
        class="hl-string">"sales_order_amount": class="hl-string">"[Confirmed Sales Quote amount property]",
        class="hl-string">"product_category": class="hl-string">"[Confirmed Sales Quote product category property]",
        class="hl-string">"discount_percentage": class="hl-string">"[Confirmed Sales Quote discount property]",
    },
    class="hl-string">"sales_order": {
        class="hl-string">"id": class="hl-string">"[Confirmed Sales Order identifier property]",
        class="hl-string">"opportunity_id": class="hl-string">"[Confirmed Sales Order to Opportunity relationship property]",
        class="hl-string">"created_at": class="hl-string">"[Confirmed Sales Order creation timestamp property]",
        class="hl-string">"status": class="hl-string">"[Confirmed Sales Order status property]",
        class="hl-string">"status_changed_at": class="hl-string">"[Confirmed Sales Order status change timestamp property]",
        class="hl-string">"previous_status": class="hl-string">"[Confirmed Sales Order previous status property or status history field]",
        class="hl-string">"sales_order_amount": class="hl-string">"[Confirmed Sales Order amount property]",
        class="hl-string">"product_category": class="hl-string">"[Confirmed Sales Order product category property]",
        class="hl-string">"discount_percentage": class="hl-string">"[Confirmed Sales Order discount property]",
    },
    class="hl-string">"invoice": {
        class="hl-string">"id": class="hl-string">"[Confirmed Invoice identifier property]",
        class="hl-string">"opportunity_id": class="hl-string">"[Confirmed Invoice to Opportunity relationship property]",
        class="hl-string">"created_at": class="hl-string">"[Confirmed Invoice creation timestamp property]",
        class="hl-string">"invoice_date": class="hl-string">"[Confirmed Invoice date property]",
    },
    class="hl-string">"fulfillment": {
        class="hl-string">"id": class="hl-string">"[Confirmed fulfillment identifier property]",
        class="hl-string">"opportunity_id": class="hl-string">"[Confirmed fulfillment to Opportunity relationship property]",
        class="hl-string">"completed_at": class="hl-string">"[Confirmed fulfillment completion timestamp property]",
        class="hl-string">"status": class="hl-string">"[Confirmed fulfillment status property]",
    },
    class="hl-string">"payment": {
        class="hl-string">"id": class="hl-string">"[Confirmed payment identifier property]",
        class="hl-string">"opportunity_id": class="hl-string">"[Confirmed payment to Opportunity relationship property]",
        class="hl-string">"received_at": class="hl-string">"[Confirmed payment receipt or clearing timestamp property]",
        class="hl-string">"status": class="hl-string">"[Confirmed payment status property]",
    },
}

session = requests.Session()
session.auth = (USERNAME, PASSWORD)
session.headers.update({class="hl-string">"Accept": class="hl-string">"application/json"})


def is_placeholder(value: Any) -> bool:
    return not value or (isinstance(value, str) and value.startswith(class="hl-string">"["))


def parse_time(value: Any) -> Optional[pd.Timestamp]:
    if value is None or value == class="hl-string">"":
        return None
    parsed = pd.to_datetime(value, utc=True, errors=class="hl-string">"coerce")
    if pd.isna(parsed):
        return None
    return parsed


def text(value: Any) -> Optional[str]:
    if value is None:
        return None
    value = str(value).strip()
    return value or None


def get_value(record: Dict[str, Any], property_name: str) -> Any:
    if is_placeholder(property_name):
        return None
    if class="hl-string">"/" in property_name:
        current: Any = record
        for part in property_name.split(class="hl-string">"/"):
            if not isinstance(current, dict):
                return None
            current = current.get(part)
        return current
    return record.get(property_name)


def fetch_all(service_url: str, select_fields: Iterable[str], filter_expression: Optional[str] = None) -> List[Dict[str, Any]]:
    if is_placeholder(service_url):
        return []
    fields = [field for field in select_fields if not is_placeholder(field) and field]
    params: Dict[str, Any] = {class="hl-string">"$top": PAGE_SIZE}
    if fields:
        params[class="hl-string">"$select"] = class="hl-string">",".join(dict.fromkeys(fields))
    if filter_expression:
        params[class="hl-string">"$filter"] = filter_expression
    records: List[Dict[str, Any]] = []
    next_url: Optional[str] = service_url
    first_request = True
    while next_url:
        response = session.get(next_url, params=params if first_request else None, timeout=120)
        response.raise_for_status()
        payload = response.json()
        page = payload.get(class="hl-string">"value", [])
        if not isinstance(page, list):
            raise ValueError(class="hl-string">"The OData response value property is not an array")
        records.extend(page)
        next_url = payload.get(class="hl-string">"@odata.nextLink") or payload.get(class="hl-string">"odata.nextLink")
        first_request = False
        if next_url:
            time.sleep(0.1)
    return records


def common_attributes(record: Dict[str, Any], field_map: Dict[str, str]) -> Dict[str, Any]:
    return {
        class="hl-string">"SalesRepresentative": text(get_value(record, field_map.get(class="hl-string">"sales_representative", class="hl-string">""))),
        class="hl-string">"LeadSource": text(get_value(record, field_map.get(class="hl-string">"lead_source", class="hl-string">""))),
        class="hl-string">"OpportunityStatus": text(get_value(record, field_map.get(class="hl-string">"opportunity_status", class="hl-string">""))) or text(get_value(record, field_map.get(class="hl-string">"status", class="hl-string">""))),
        class="hl-string">"SalesOrderAmount": get_value(record, field_map.get(class="hl-string">"sales_order_amount", class="hl-string">"")),
        class="hl-string">"ProductCategory": text(get_value(record, field_map.get(class="hl-string">"product_category", class="hl-string">""))),
        class="hl-string">"DiscountPercentage": get_value(record, field_map.get(class="hl-string">"discount_percentage", class="hl-string">"")),
    }


def add_event(events: List[Dict[str, Any]], opportunity_id: Any, activity: str, event_time: Any, attributes: Dict[str, Any]) -> None:
    case_id = text(opportunity_id)
    timestamp = parse_time(event_time)
    if not case_id or timestamp is None:
        return
    row = {
        class="hl-string">"SalesOpportunityId": case_id,
        class="hl-string">"ActivityName": activity,
        class="hl-string">"EventTime": timestamp.isoformat(),
    }
    row.update(attributes)
    events.append(row)


start_filter = None if is_placeholder(START_DATE) else START_DATE
end_filter = None if is_placeholder(END_DATE) else END_DATE

def date_filter(field_name: str) -> Optional[str]:
    if is_placeholder(field_name) or not start_filter or not end_filter:
        return None
    return fclass="hl-string">"{field_name} ge '{start_filter}T00:00:00Z' and {field_name} lt '{end_filter}T00:00:00Z'"


lead_fields = list(FIELDS[class="hl-string">"lead"].values())
opportunity_fields = list(FIELDS[class="hl-string">"opportunity"].values())
quote_fields = list(FIELDS[class="hl-string">"sales_quote"].values())
order_fields = list(FIELDS[class="hl-string">"sales_order"].values())
invoice_fields = list(FIELDS[class="hl-string">"invoice"].values())
fulfillment_fields = list(FIELDS[class="hl-string">"fulfillment"].values())
payment_fields = list(FIELDS[class="hl-string">"payment"].values())

leads = fetch_all(SERVICES[class="hl-string">"lead"], lead_fields, date_filter(FIELDS[class="hl-string">"lead"][class="hl-string">"created_at"]))
opportunities = fetch_all(SERVICES[class="hl-string">"opportunity"], opportunity_fields, date_filter(FIELDS[class="hl-string">"opportunity"][class="hl-string">"created_at"]))
quotes = fetch_all(SERVICES[class="hl-string">"sales_quote"], quote_fields, date_filter(FIELDS[class="hl-string">"sales_quote"][class="hl-string">"created_at"]))
orders = fetch_all(SERVICES[class="hl-string">"sales_order"], order_fields, date_filter(FIELDS[class="hl-string">"sales_order"][class="hl-string">"created_at"]))
invoices = fetch_all(SERVICES[class="hl-string">"invoice"], invoice_fields, date_filter(FIELDS[class="hl-string">"invoice"][class="hl-string">"created_at"]))
fulfillments = fetch_all(SERVICES[class="hl-string">"fulfillment"], fulfillment_fields, date_filter(FIELDS[class="hl-string">"fulfillment"][class="hl-string">"completed_at"]))
payments = fetch_all(SERVICES[class="hl-string">"payment"], payment_fields, date_filter(FIELDS[class="hl-string">"payment"][class="hl-string">"received_at"]))

events: List[Dict[str, Any]] = []

for record in leads:
    field_map = FIELDS[class="hl-string">"lead"]
    opportunity_id = get_value(record, field_map[class="hl-string">"opportunity_id"]) or get_value(record, field_map[class="hl-string">"id"])
    attributes = common_attributes(record, field_map)
    add_event(events, opportunity_id, class="hl-string">"Lead Captured", get_value(record, field_map[class="hl-string">"created_at"]), attributes)
    if text(get_value(record, field_map[class="hl-string">"status"])).lower() == class="hl-string">"qualified":
        add_event(events, opportunity_id, class="hl-string">"Lead Qualified", get_value(record, field_map[class="hl-string">"status_changed_at"]) or get_value(record, field_map[class="hl-string">"created_at"]), attributes)

for record in opportunities:
    field_map = FIELDS[class="hl-string">"opportunity"]
    opportunity_id = get_value(record, field_map[class="hl-string">"id"])
    attributes = common_attributes(record, field_map)
    add_event(events, opportunity_id, class="hl-string">"Opportunity Created", get_value(record, field_map[class="hl-string">"created_at"]), attributes)
    stage = text(get_value(record, field_map[class="hl-string">"stage"])).lower()
    if stage in {class="hl-string">"proposal", class="hl-string">"solution design", class="hl-string">"solution proposed"}:
        add_event(events, opportunity_id, class="hl-string">"Solution Proposed", get_value(record, field_map[class="hl-string">"status_changed_at"]) or get_value(record, field_map[class="hl-string">"created_at"]), attributes)
    status = text(get_value(record, field_map[class="hl-string">"status"])).lower()
    reason = text(get_value(record, field_map[class="hl-string">"status_reason"])).lower()
    if status == class="hl-string">"won":
        add_event(events, opportunity_id, class="hl-string">"Opportunity Won", get_value(record, field_map[class="hl-string">"status_changed_at"]), attributes)
    if status in {class="hl-string">"closed", class="hl-string">"closed won"} and reason == class="hl-string">"won":
        add_event(events, opportunity_id, class="hl-string">"Opportunity Closed Won", get_value(record, field_map[class="hl-string">"status_changed_at"]), attributes)
    if status in {class="hl-string">"lost", class="hl-string">"closed lost"}:
        add_event(events, opportunity_id, class="hl-string">"Opportunity Closed Lost", get_value(record, field_map[class="hl-string">"status_changed_at"]), attributes)

for record in quotes:
    field_map = FIELDS[class="hl-string">"sales_quote"]
    opportunity_id = get_value(record, field_map[class="hl-string">"opportunity_id"])
    attributes = common_attributes(record, field_map)
    add_event(events, opportunity_id, class="hl-string">"Quote Created", get_value(record, field_map[class="hl-string">"created_at"]), attributes)
    status = text(get_value(record, field_map[class="hl-string">"status"])).lower()
    status_time = get_value(record, field_map[class="hl-string">"status_changed_at"]) or get_value(record, field_map[class="hl-string">"created_at"])
    if status in {class="hl-string">"sent", class="hl-string">"proposed"}:
        add_event(events, opportunity_id, class="hl-string">"Quote Sent to Customer", status_time, attributes)
    if status in {class="hl-string">"accepted", class="hl-string">"customer accepted"} or get_value(record, field_map[class="hl-string">"accepted_at"]):
        add_event(events, opportunity_id, class="hl-string">"Quote Accepted by Customer", get_value(record, field_map[class="hl-string">"accepted_at"]) or status_time, attributes)

for record in orders:
    field_map = FIELDS[class="hl-string">"sales_order"]
    opportunity_id = get_value(record, field_map[class="hl-string">"opportunity_id"])
    attributes = common_attributes(record, field_map)
    add_event(events, opportunity_id, class="hl-string">"Sales Order Created", get_value(record, field_map[class="hl-string">"created_at"]), attributes)
    status = text(get_value(record, field_map[class="hl-string">"status"])).lower()
    previous_status = text(get_value(record, field_map[class="hl-string">"previous_status"])).lower()
    if previous_status == class="hl-string">"submitted" and status in {class="hl-string">"in process", class="hl-string">"pending revision"}:
        add_event(events, opportunity_id, class="hl-string">"Sales Order Reworked", get_value(record, field_map[class="hl-string">"status_changed_at"]), attributes)

for record in fulfillments:
    field_map = FIELDS[class="hl-string">"fulfillment"]
    opportunity_id = get_value(record, field_map[class="hl-string">"opportunity_id"])
    status = text(get_value(record, field_map[class="hl-string">"status"])).lower()
    if status in {class="hl-string">"fulfilled", class="hl-string">"completed", class="hl-string">"delivered", class="hl-string">"shipped"} or get_value(record, field_map[class="hl-string">"completed_at"]):
        add_event(events, opportunity_id, class="hl-string">"Order Fulfilled", get_value(record, field_map[class="hl-string">"completed_at"]), {})

for record in invoices:
    field_map = FIELDS[class="hl-string">"invoice"]
    opportunity_id = get_value(record, field_map[class="hl-string">"opportunity_id"])
    add_event(events, opportunity_id, class="hl-string">"Invoice Generated", get_value(record, field_map[class="hl-string">"created_at"]) or get_value(record, field_map[class="hl-string">"invoice_date"]), {})

for record in payments:
    field_map = FIELDS[class="hl-string">"payment"]
    opportunity_id = get_value(record, field_map[class="hl-string">"opportunity_id"])
    status = text(get_value(record, field_map[class="hl-string">"status"])).lower()
    if status in {class="hl-string">"received", class="hl-string">"cleared", class="hl-string">"processed", class="hl-string">"paid"} or get_value(record, field_map[class="hl-string">"received_at"]):
        add_event(events, opportunity_id, class="hl-string">"Payment Received", get_value(record, field_map[class="hl-string">"received_at"]), {})

columns = [
    class="hl-string">"SalesOpportunityId",
    class="hl-string">"ActivityName",
    class="hl-string">"EventTime",
    class="hl-string">"SalesRepresentative",
    class="hl-string">"LeadSource",
    class="hl-string">"OpportunityStatus",
    class="hl-string">"SalesOrderAmount",
    class="hl-string">"ProductCategory",
    class="hl-string">"DiscountPercentage",
]

result = pd.DataFrame(events)
for column in columns:
    if column not in result.columns:
        result[column] = None
result = result[columns]
result = result.drop_duplicates()
result[class="hl-string">"EventTime"] = pd.to_datetime(result[class="hl-string">"EventTime"], utc=True, errors=class="hl-string">"coerce")
result = result.dropna(subset=[class="hl-string">"SalesOpportunityId", class="hl-string">"ActivityName", class="hl-string">"EventTime"])
result = result.sort_values([class="hl-string">"SalesOpportunityId", class="hl-string">"EventTime", class="hl-string">"ActivityName"], kind=class="hl-string">"stable")
result[class="hl-string">"EventTime"] = result[class="hl-string">"EventTime"].dt.strftime(class="hl-string">"%Y-%m-%dT%H:%M:%SZ")
result.to_csv(OUTPUT_FILE, index=False, encoding=class="hl-string">"utf-8")

required_activities = {
    class="hl-string">"Lead Captured",
    class="hl-string">"Lead Qualified",
    class="hl-string">"Opportunity Created",
    class="hl-string">"Solution Proposed",
    class="hl-string">"Quote Created",
    class="hl-string">"Quote Sent to Customer",
    class="hl-string">"Quote Accepted by Customer",
    class="hl-string">"Opportunity Won",
    class="hl-string">"Sales Order Created",
    class="hl-string">"Sales Order Reworked",
    class="hl-string">"Order Fulfilled",
    class="hl-string">"Invoice Generated",
    class="hl-string">"Payment Received",
    class="hl-string">"Opportunity Closed Won",
    class="hl-string">"Opportunity Closed Lost",
}
missing_activities = sorted(required_activities.difference(set(result[class="hl-string">"ActivityName"].dropna().unique())))
print(fclass="hl-string">"Wrote {len(result)} event rows to {OUTPUT_FILE}")
if missing_activities:
    print(class="hl-string">"Activities with no extracted rows in this data range or configuration:")
    for activity in missing_activities:
        print(fclass="hl-string">"- {activity}")

准备好开始了吗？

借助此数据模板，您已具备开始优化Lead to Cash流程所需的一切。立即开始改造您的收入周期。

返回改进指南下载模板

立即优化您的Lead to Cash流程，提高赢单率！

通过免费试用，减少交易流失，让赢单率提升20%。

开始免费试用

无需信用卡，几分钟即可完成设置。

您的Lead to Cash数据模板

您的Lead to Cash数据模板

线索到收款属性

线索到收款活动

提取指南

SAP Sales Cloud Analytics OData API提取

步骤

配置

a 示例查询 python

SAP Sales Cloud标准OData业务对象查询

步骤

配置

a 示例查询 python

准备好开始了吗？

立即优化您的Lead to Cash流程，提高赢单率！

您的Lead to Cash数据模板

您的Lead to Cash数据模板

线索到收款属性

线索到收款活动

提取指南

SAP Sales Cloud Analytics OData API提取

步骤

配置

a 示例查询 python

SAP Sales Cloud标准OData业务对象查询

步骤

配置

a 示例查询 python

准备好开始了吗？

立即优化您的Lead to Cash流程，提高赢单率！

我们重视您的隐私