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

您的线索到收款数据模板

SAP Sales Cloud

← 返回改进指南

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

您的线索到收款数据模板

此模板为收集分析线索到收款流程所需的数据提供了结构化指引，列出了构建完整事件日志所需的属性和活动。您还可以参考从SAP Sales Cloud系统提取这些数据的实用说明，顺利开启流程挖掘。

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

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

下载模板

线索到收款属性

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

3 必填 6 建议填写 8 选填

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

必填建议填写选填

线索到收款活动

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

7 建议填写 8 选填

	活动	说明
	商机已关闭并丢单	此活动标志着未成功商机的最终结束，交易可能输给竞争对手，也可能是客户决定不购买。用户将商机状态更改为“已丢单”或“已关闭并丢单”时会记录此事件。
重要性分析商机何时以及为何丢失，对于改进销售策略至关重要。此失败终点有助于分析丢单情况，例如商机通常在哪个阶段流失，以及常见的丢单原因。获取途径根据商机业务对象的状态变更历史推断，即状态更新为“已丢单”或“已关闭并丢单”时的时间戳。采集确定商机对象状态变更为“已丢单”时的时间戳。事件类型 inferred
	商机已关闭并赢单	此活动表示成功商机的最终状态，且创建订单、履行订单等后续活动均已完成。用户将商机状态更改为最终的“已关闭”状态，并将原因设为“已赢单”时会记录此事件。
重要性此事件是流程挖掘分析中成功商机的终点，可用于计算所有赢单的端到端销售周期时长，并明确标记流程结束。获取途径根据商机对象的状态变更历史推断，具体为状态更新为“已关闭”且原因是“已赢单”时的时间戳。采集确定状态变更为“已关闭”且原因代码为“已赢单”时的时间戳。事件类型 inferred
	商机已创建	这是销售商机的正式起点，标志着已通过资格审核的线索转化为具体的销售机会。系统会在创建商机业务对象时明确记录此事件，通常还会沿用原始线索的数据。
重要性此活动是销售周期分析的主要起点，至关重要。它有助于衡量销售周期时长、商机赢单率，以及商机从具体化开始的销售团队表现。获取途径此事件对应于SAP Sales Cloud中商机业务对象的创建时间戳。采集使用商机记录的创建日期和时间。事件类型 explicit
	商机已赢单	此活动表示交易已成功完成，组织已赢得业务。用户将商机状态更改为“已赢单”时会记录此事件，这是系统中的标准明确操作。
重要性这是衡量赢单率和销售业绩的关键节点。它通常会触发后续流程，例如创建订单和履行订单，因此也是从线索到收款周期中的重要转折点。获取途径根据商机业务对象的状态变更历史推断，即状态更新为“已赢单”时的时间戳。采集确定商机对象状态变更为“已赢单”时的时间戳。事件类型 inferred
	已收到付款	此活动确认客户付款已收到并处理，标志着财务交易完成。此信息几乎总是来自外部财务系统或ERP，由其更新SAP Sales Cloud中的发票或订单状态。
重要性这是从线索到收款流程中最终实现价值的步骤。衡量从开票到收款的“收款周期时间”，是管理现金流和评估应收账款表现的重要KPI。获取途径根据发票或销售订单对象的状态变更为“已付款”或“已结清”推断。此数据来自外部财务系统。采集确定发票状态变更为“已付款”或“已结清”时的时间戳。事件类型 inferred
	报价单已发送给客户	此活动表示正式报价单已提交给客户审核。通常根据销售报价单对象的状态变更推断，例如从“准备中”变为“已发送”或“已提议”。
重要性这是客户开始协商和决策的关键节点。分析此事件到报价单获批之间的时长，对于了解交易推进速度和协商瓶颈至关重要。获取途径根据销售报价单业务对象的状态变更历史推断。查找状态更新为表示报价单已发送的值时的时间戳。采集确定销售报价单对象状态变更为“已发送”时的时间戳。事件类型 inferred
	销售订单已创建	此活动表示已创建正式销售订单，这是启动履约和开票的内部正式文件。用户创建销售订单对象并将其关联到上级商机时，系统会明确记录此事件。
重要性这是从销售到运营的关键交接点。分析“商机已赢单”到“销售订单已创建”之间的时间，可以发现内部延迟；跟踪此后的返工情况，则有助于发现数据质量问题。获取途径此事件对应于与商机关联的销售订单业务对象的创建时间戳。采集使用关联销售订单记录的创建日期和时间。事件类型 explicit
	发票已生成	表示已创建客户发票，流程由此进入最后的财务阶段。此事件可能取自SAP Sales Cloud中的发票对象创建记录，也更常见于集成的开票系统。
重要性此活动会启动收款周期。开票延迟会直接影响现金流，因此监控从履约到开票所需的时间对财务健康至关重要。获取途径可使用与销售订单关联的发票业务对象创建时间戳，或外部ERP的更新记录。具体来源取决于系统环境。采集使用发票记录的创建日期，或集成ERP中的活动日志条目。事件类型 explicit
	客户已接受报价单	表示客户已正式或非正式同意报价单条款。销售代表通常会手动更新销售报价单或商机对象的状态，以记录此信息。
重要性这是客户有意购买的明确信号，也是合同最终确定或创建订单前的关键节点。它有助于衡量方案的效果和客户决策周期的时长。获取途径根据销售报价单对象状态变更为“已接受”，或关联商机对象发生类似状态变更推断。采集确定销售报价单状态变更为“已接受”时的时间戳。事件类型 inferred
	已提出解决方案	此活动表示已向客户展示潜在解决方案或产品配置。通常根据商机对象的销售阶段或状态变更推断，例如进入“方案”或“解决方案设计”阶段。
重要性分析在此阶段花费的时间以及转入报价阶段的情况，有助于发现解决方案制定流程中的瓶颈，并了解从初次接触到形成具体方案需要多长时间。获取途径根据商机对象的变更日志或状态历史推断，具体查看销售阶段是否更新为“已提出解决方案”或“价值主张”等值。采集确定商机的销售阶段字段变更为表示已提出方案时的时间戳。事件类型 inferred
	报价单已创建	表示已创建与商机关联的正式销售报价单。这是报价单发送给客户前的内部步骤，用户生成新的报价单记录时会明确记录此事件。
重要性此活动将内部准备时间与客户收到报价单后的时间区分开来，有助于分析报价生成效率，以及销售人员准备价格方案所需的时间。获取途径此事件是与商机关联的销售报价单业务对象的创建时间戳。采集使用关联销售报价单记录的创建日期和时间。事件类型 explicit
	线索已捕获	此活动表示在SAP Sales Cloud中首次创建线索记录。它代表潜在客户首次表达联系意向或兴趣，通常通过网页表单、名单导入或用户手动录入自动捕获。
重要性跟踪此事件对于分析不同线索来源的效果和衡量整体线索生成量至关重要。它是计算线索转化率、了解销售漏斗顶部情况的起点。获取途径此事件取自线索业务对象的创建时间戳。线索来源通常作为同一对象的属性提供。采集使用线索记录的创建日期和时间。事件类型 explicit
	线索已通过资格审核	表示线索经过审核并符合条件，可视为有效销售潜客。通常在用户手动将线索状态更改为“已通过资格审核”或类似状态时捕获，表明该线索已具备转化条件。
重要性此活动将原始线索与有意向的潜客区分开来，便于分析资格审核流程的效率。它有助于评估不同来源的线索质量，并发现线索捕获到主动销售之间的瓶颈。获取途径根据线索业务对象的状态变更历史推断。查找状态字段更新为“已通过资格审核”时的时间戳。采集确定线索对象状态变更为“已通过资格审核”时的时间戳。事件类型 inferred
	订单已履行	此活动表示产品已发货或服务已交付给客户。通常通过与ERP或物流系统的集成捕获，由这些系统更新SAP Sales Cloud中的销售订单状态。
重要性这标志着交付环节已完成。衡量“销售订单已创建”到“订单已履行”之间的时间，对于监控订单履行效率及其对客户满意度的影响至关重要。获取途径通常根据销售订单对象的状态变更推断，例如变为“已履行”或“已发货”。此状态通常由外部系统集成更新。采集确定销售订单状态变更为“已履行”或“已交付”时的时间戳。事件类型 inferred
	销售订单已返工	表示销售订单提交后发生了修改或更正。可通过检测销售订单状态的循环变化推断此事件，例如状态从“已提交”退回“处理中”或“待修订”。
重要性识别返工有助于发现流程低效、数据录入错误以及销售与运营之间的沟通缺口。返工频繁通常意味着存在质量问题，进而造成延迟并增加成本。获取途径根据销售订单对象的状态变更历史推断。需要分析状态变更顺序，以识别回退或循环。采集检测表示循环的状态转换，例如从“已提交”变为“处理中”。事件类型 inferred

建议填写选填

数据提取指南

如何从SAP Sales Cloud获取数据

步骤

前提条件：确保您拥有SAP Sales Cloud用户账号，并可访问“分析”工作中心；该账号还需具备创建和编辑数据源及报表的权限。
创建组合数据源：进入“业务分析”工作中心中的“设计数据源”视图，创建新的组合数据源。使用左外连接关联以下标准数据源，确保纳入所有商机：“线索信息” -> “商机抬头和行项目” -> “销售报价抬头和行项目” -> “销售订单抬头和行项目”。连接条件通常基于商机ID或后续单据ID。
创建自定义报表：进入“设计报表”视图，基于上一步创建的组合数据源新建报表。在报表视图中添加所需的所有特征和关键指标，包括标识符（线索ID、商机ID）、相关状态字段和所有时间戳字段（创建日期、状态变更日期等）。同时添加所需属性，例如销售代表、线索来源和订单金额。
将报表设为OData服务：在“设计报表”视图中选择新建的报表。在报表配置或设置中，找到将报表公开为OData查询的选项，通常是名为“启用OData”的复选框。保存更改后，系统会为该报表生成唯一的OData URL。
查找OData URL：进入“管理员”工作中心中的“OData服务”视图，在列表中找到自定义报表并复制其服务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中创建组合数据源。必须从商机对象开始使用Left Outer Joins，以纳入未生成报价或订单的商机。
报表特征：自定义报表必须包含与目标活动对应的所有日期和时间字段，包括线索、商机、报价和订单的创建时间戳，以及状态变更时间戳。
OData API筛选：为控制性能和数据量，请在Python脚本的OData URL中使用$filter参数。强烈建议按日期范围筛选，例如使用OpportunityCreationDate。初次分析通常可选择6到12个月的日期范围。
分页：提供的脚本使用$top和$skip参数处理OData分页。这对于提取大型数据集、避免API连接超时至关重要。
前提条件：此方法需要专用分析用户，并授予其访问OData API以及线索、商机、报价和订单底层数据源的权限。

查询示例 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设置、日期范围、每页大小和公司专属筛选条件。初始日期范围设为3到6个月，验证性能和数据完整性后再延长。
通过已确认的标准OData实体集提取Opportunity和Lead记录，并通过各自已确认的实体集提取Sales Quote和Sales Order记录。仅当SAP Sales Cloud公开了相应的标准OData对象和关系时，才提取发票、履行和付款记录。如果这些记录由集成的ERP或财务系统维护，请从该系统获取经批准的等效OData数据源，并将其中的标识符映射到商机。
按照服务提供的下一页链接或支持的分页机制，获取每个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；使用报价或商机记录客户接受的时间表示Quote Accepted by Customer；使用Opportunity达到Won状态的时间表示Opportunity Won；使用Sales Order创建时间表示Sales Order Created；检测到Submitted转为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；如果源系统无法提供可靠值，则保留为空值。
按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、物流、开票或付款数据需要单独授权。
**日期范围：**从3到6个月开始。如果创建时间戳和状态时间戳可能早于所选流程时间范围，请加入较短的回溯期。记录筛选依据是创建时间、最后更改时间、状态转换时间，还是其他已确认的时间戳。
**必需案例键：**将每条事件映射到SalesOpportunityId。除非记录可通过经批准的交叉引用解析，否则不要输出无法可靠关联到商机的事件。
**状态映射：**针对Qualified、提案或解决方案阶段、Sent、Proposed、accepted、Won、Closed、Lost、Closed Lost、Submitted、In Process、Pending Revision、履行完成、发票创建和收到付款等状态，配置与环境相符的精确映射。状态标签可能因配置和语言而异。
**筛选条件：**仅在相关字段已公开且业务含义明确时，应用已确认的公司、组织单元、单据类型、销售区域、状态和日期筛选条件。不要假设每个SAP Sales Cloud对象都包含Company Code和Document Type。
**分页和限流：**使用OData服务支持的每页大小和下一页机制。针对临时HTTP错误设置重试处理，遵守环境的速率限制，避免过多并行请求。
**变更历史要求：**基于状态的活动需要带时间戳的状态历史或变更日志。仅凭当前状态字段无法可靠还原之前状态的到达时间。
**外部事件来源：**订单履行、发票生成和收到付款等记录可能由集成的ERP、物流、开票或财务系统维护。请配置经批准的跨系统标识符和针对各数据源的提取规则。
**数据质量：**值不可用时保留空值。除非业务规则明确接受此限制，否则不要用当前状态或当前所有者替代历史值。
**前提条件：**安排提取任务前，请确认所需的SAP Sales Cloud版本、API可用性、集成配置、业务对象公开情况、环境授权以及任何外部系统许可证。

查询示例 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}")

准备好开始了吗？

借助此数据模板，您可以着手优化线索到收款流程。立即开始改进收入周期。

返回改进指南

下载模板

立即优化线索到收款流程，提高赢单率！

免费试用，减少交易流失，将赢单率提高20%。

立即开始免费试用

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

您的线索到收款数据模板

您的线索到收款数据模板

线索到收款属性

线索到收款活动

数据提取指南

SAP Sales Cloud分析OData API数据提取

步骤

配置

查询示例 python

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

步骤

配置

查询示例 python

准备好开始了吗？

立即优化线索到收款流程，提高赢单率！