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

您的线索到收款数据模板

Oracle CX Sales

← 返回改进指南

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

您的线索到收款数据模板

此模板将指导您准备线索到收款流程挖掘所需的数据，说明需要收集的关键属性和跟踪的主要活动，并提供从Oracle CX Sales提取这些信息的实用指引。按照模板准备数据，有助于全面、准确地分析流程。

线索到收款分析建议属性
销售与收款周期中需要跟踪的关键活动
从Oracle CX Sales提取数据的详细指引

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

下载模板

线索到收款属性

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

5 必填 5 建议填写 10 选填

	名称	说明
	事件时间 EventTime	表示特定活动或事件发生时间的时间戳。
说明事件时间是记录活动的日期和时间。它对于按时间顺序排列事件，以及计算流程不同步骤之间的耗时至关重要。该时间戳是所有时间分析的基础，包括计算周期时间、通过测量等待时间发现瓶颈，以及监控服务级别协议的执行情况。准确的时间戳是可靠开展流程挖掘分析的关键。重要性它提供事件的时间顺序，是计算周期时间和耗时等各项绩效指标的基础。获取途径这通常对应特定活动相关记录的创建日期或最后更新日期，例如状态变更时间戳。示例 2023-04-15T10:00:00Z2023-05-01T14:30:00Z2023-05-20T09:15:00Z
	活动名称 ActivityName	销售商机在特定时间发生的业务活动或事件名称。
说明此属性描述线索到收款流程中的具体步骤或里程碑，例如“线索转为商机”“报价已创建”或“已收到付款”。这些活动构成流程图的基本要素。分析活动的顺序和频率，有助于呈现流程走向、识别常见路径和替代路径，并发现偏差或瓶颈。这也是衡量步骤间转换时间、了解实际工作方式的基础。重要性此属性是构建流程图、了解销售生命周期中事件顺序的基础。获取途径通常根据状态变更、事件日志，或与Opportunity、Quote或Order对象相关的任务完成记录生成。示例商机通过资格审核报价已发送给客户订单已履行已收到付款
	销售商机 SalesOpportunity	销售商机的唯一标识符，作为线索到收款流程中的案例标识。
说明销售商机是核心对象，用于跟踪潜在收入交易从线索初始阶段到最终赢单或流失的全过程。它关联资格审查、报价、下单和付款等所有相关活动。在流程挖掘分析中，这一标识符对于还原每笔交易的端到端历程至关重要。借助它，您可以分析完整生命周期，包括各阶段的周期时间、转化率，以及促成成功或导致交易流失的路径。重要性这是关联所有流程事件的关键案例ID，可帮助您完整、准确地了解每笔潜在交易的整个销售生命周期。获取途径这是Oracle CX Sales Opportunity对象中的主要标识符。示例 OPP-0012345OPP-0023456OPP-0034567
	数据最后更新时间 LastDataUpdate	数据最近一次从源系统刷新或提取的时间戳。
说明此属性表示待分析数据的新鲜度，显示最近一次从Oracle CX Sales提取数据的日期和时间。在仪表板和报告中，该时间戳对于告知用户数据的时效性至关重要。它有助于用户判断分析是否包含最新活动。重要性告知用户数据的时效性，这对于解读仪表板和做出有依据的决策至关重要。获取途径此时间戳在数据提取、转换和加载（ETL）过程中生成并添加。示例 2024-06-10T02:00:00Z
	源系统 SourceSystem	提取数据的系统。
说明此属性标识流程数据的来源，在此场景中为Oracle CX Sales。在包含多个系统的环境中，该字段有助于区分数据源。分析时，该属性可提供数据来源背景。在整合多个系统的数据或了解特定系统的行为时，这些信息可能很重要。它也是数据治理和追溯的标准字段。重要性提供数据来源等关键信息，确保数据可追溯，并帮助管理来自多个集成系统的数据。获取途径通常在数据提取过程中添加静态值，用于标记数据来源。示例 Oracle CX Sales
	区域 Region	与商机关联的地理区域或销售辖区。
说明区域属性根据地理位置对商机进行分类，例如“北美”“欧洲、中东和非洲”或“亚太地区”。这是细分业务绩效的常用维度。此属性对于“区域销售绩效基准”仪表板至关重要。它支持比较不同区域的销售周期时间、转化率和流程变体等关键指标，从而发现绩效较好的区域以及需要重点改进的区域。重要性支持比较不同地理区域的流程绩效，发现区域差异和最佳实践。获取途径 Oracle CX Sales的Account或Opportunity对象中通常提供标准字段或自定义字段。示例北美欧洲、中东和非洲亚太地区拉丁美洲
	商机负责人 OpportunityOwner	主要负责销售商机的销售代表。
说明商机负责人是负责管理并促成交易的用户。此属性可用于分析个人或团队的绩效。在流程挖掘中，按商机负责人筛选可以揭示不同的工作模式、绩效基准，以及对标准销售流程的遵循情况。这有助于销售经理发现辅导机会，并了解优秀销售人员如何推进销售周期。重要性支持按销售代表或团队分析绩效，帮助发现最佳实践和需要辅导的方面。获取途径 Oracle CX Sales的Opportunity对象中提供标准“Owner”或“AssignedTo”字段。示例 John SmithJane DoePeter Jones
	商机金额 OpportunityValue	销售商机的预估金额或实际金额。
说明此属性表示销售商机的潜在收入或最终收入，可用于在商机生命周期内进行细分和优先级排序。在流程挖掘中，分析商机金额有助于了解不同流程变体对高价值和低价值交易的影响。对于跟踪收入流失的仪表板，例如“商机流失与退出原因”分析，该属性至关重要，因为它可以将流程路径与财务结果关联起来。重要性量化流程低效带来的财务影响，并帮助确定商机和改进工作的优先级。获取途径 Oracle CX Sales的Opportunity对象中可能有“Revenue”或“Amount”等字段。示例 50000.00125000.0025000.00
	流失原因 LossReason	商机流失的原因。
说明商机未能成交并关闭时，流失原因会记录主要原因，例如“输给竞争对手”“价格”或“未做决定”。这些信息对于战略分析和流程改进至关重要。此属性是“商机流失与退出原因”仪表板的核心。结合商机流失时所处的阶段分析流失原因，有助于企业了解自身竞争劣势，并改进销售策略、产品方案或定价模式。重要性深入了解交易未能赢单的原因，为改进销售流程和产品方案提供依据。获取途径在Oracle CX Sales中将商机状态设为“已关闭-流失”时，通常会记录此标准字段。示例价格输给竞争对手产品匹配度未做决定
	销售阶段 SalesStage	销售商机在销售管道中的当前阶段。
说明销售阶段表示商机在既定销售流程中的进展情况，取值可能包括“资格审查”“已提出解决方案”或“谈判中”。这是了解商机当前状态的关键属性。此属性是构建销售漏斗可视化和“停滞商机阶段分析”仪表板的基础。通过分析商机在各阶段的停留时间，团队可以发现交易进展缓慢的环节，并集中精力疏通销售管道。重要性对于销售漏斗分析以及发现商机经常停滞或流失的瓶颈至关重要。获取途径这是Oracle CX Sales Opportunity对象中的标准字段，通常名为“SalesStage”或“StageName”。示例 01-资格审查03-方案05-谈判赢单关闭
	产品名称 ProductName	商机中销售的主要产品或服务。
说明此属性指定与销售商机关联的产品或产品系列。对于包含多种产品的商机，它可能表示主要意向产品，也可能针对每个产品明细重复记录。按产品分析流程走向，可以发现某些产品的销售周期是否更长或更复杂。这些信息有助于制定针对特定产品的销售策略、培训和流程优化方案。重要性支持分析不同产品或服务对应的销售流程差异，并发现特定产品的瓶颈。获取途径可在Product对象中找到，并通过Oracle CX Sales中的Opportunity Product Line Item关联。示例企业CRM许可证云存储一级专业服务套餐
	发票ID InvoiceId	为销售订单生成的发票唯一标识符。
说明发票ID是订单履约后发送给客户的账单文档参考编号，是流程最后财务阶段的关键单据。此标识符对于分析“发票生成周期时间”和“收款周期”至关重要。它支持跟踪每张发票从创建到最终付款的全过程，对于监控现金流和应收账款绩效十分重要。重要性跟踪最终财务交易，对于分析开票周期时间和收款效率至关重要。获取途径请查阅Oracle CX Sales文档或集成的ERP/财务系统，了解Invoice对象的标识符。示例 INV-2023-001INV-2023-002INV-2023-003
	客户名称 CustomerName	与销售商机关联的客户或客户账户名称。
说明此属性标识交易的潜在客户或现有客户，是细分和分析销售流程的基本维度。按客户筛选可以详细分析特定客户账户的销售历程，有助于重点客户管理。您还可以按客户规模、行业或其他特征细分流程绩效，以便调整销售方式。重要性支持按客户细分流程分析，这对于了解客户特有的行为和管理重点客户至关重要。获取途径 Oracle CX Sales中与Opportunity对象关联的Account Name。示例 Global Tech Inc.Innovate Solutions LLCPioneer Corp
	履约前开票 InvoiceBeforeFulfillment	用于标记订单履约前是否已生成发票。
说明对于特定案例，如果“发票已生成”事件早于“订单已履约”事件发生，此布尔属性将设为true。这表示流程路径不符合规范或存在风险。此属性直接支持“履约前开票率”KPI，并用于流程合规仪表板。跟踪此偏差有助于企业落实正确的开票流程、减少客户争议并降低收入确认风险。重要性标记关键的流程合规违规情况：订单尚未履约就向客户开票，可能导致客户不满和财务风险。获取途径通过比较同一案例中“发票已生成”和“订单已履约”活动的时间戳来计算。示例 truefalse
	折扣百分比 DiscountPercentage	应用于销售报价或商机的折扣百分比。
说明此属性记录特定交易的折扣百分比，直接影响最终价格和销售利润。分析折扣水平对于“平均折扣使用率”KPI至关重要。它有助于企业了解折扣对利润率的影响，并发现折扣是否使用不一致或未经适当批准，从而揭示报价审批工作流中的潜在问题。重要性有助于分析盈利能力和折扣策略的有效性，并发现可能存在的折扣失控问题。获取途径请查阅Oracle CX Sales文档，了解Quote或Opportunity Product Line Item对象中的折扣字段。示例 0.050.100.150.20
	报价ID QuoteId	与商机关联的销售报价唯一标识符。
说明报价ID是为商机生成的特定销售报价文档的参考编号。商机在其生命周期内可能有多个报价，尤其是在发生返工时。跟踪此标识符对于分析“报价到订单周期时间”和“报价返工率”至关重要。它可以准确衡量从发出报价到客户接受报价所需的时间，并区分初始报价与修订版本。重要性唯一标识销售报价，支持准确分析报价周期，包括返工和转化时间。获取途径这是Oracle CX Sales中Quote对象的主要标识符，与Opportunity对象相关联。示例 QUO-98765QUO-98766QUO-98767
	是否为报价返工 IsQuoteRework	用于标记同一商机的报价是否经过返工或创建多次。
说明如果单个销售商机发生“报价已返工”或第二次“报价已创建”等活动，此布尔属性将设为true。它有助于识别报价阶段的流程低效情况。此标记用于计算“报价返工率”KPI，并支持“流程偏差与返工分析”仪表板。突出显示返工情况，有助于定位初始需求收集、定价或产品配置方面的问题，这些问题会导致额外工作和延误。重要性直接标记报价流程中的低效和偏差，帮助查明延误和重复工作的根本原因。获取途径通过分析事件日志计算。对于给定的销售商机，如果“报价已创建”或“报价已返工”活动出现多次，则值为true。示例 truefalse
	是否停滞 IsStalled	用于标记商机是否在同一销售阶段停留过久。
说明当商机连续两项活动之间的间隔超过预设业务阈值（例如30天）时，此布尔属性将设为true。此属性用于计算“停滞商机率”KPI，也是“停滞商机阶段分析”仪表板的重要依据。发现停滞交易后，销售经理可以主动介入并提供支持，从而提升销售管道的整体推进速度。重要性帮助主动发现因缺乏进展而面临流失风险的交易，以便及时介入。获取途径通过测量同一案例中连续事件之间的时间，并与设定阈值进行比较来计算。示例 truefalse
	用户名 UserName	执行特定活动或事件的用户。
说明此属性标识执行特定任务的人员，例如“报价已创建”或“订单已提交”。商机负责人对整个交易负责，而用户名则记录具体操作的执行者。这些信息有助于了解资源分配、工作量分布，以及角色和职责的履行情况。它还可以帮助发现某些用户是否成为流程瓶颈，或特定任务是否经常由未经授权的人员处理。重要性记录每项具体操作的执行者，便于详细分析工作量并审计活动。获取途径通常可在Oracle CX Sales中与活动相关对象的“CreatedBy”或“LastUpdatedBy”字段中找到。示例 Alice WilliamsBob BrownCharlie Davis
	订单ID OrderId	根据已赢单商机创建的销售订单唯一标识符。
说明订单ID是正式销售订单的参考编号。客户接受报价且商机赢单后，该订单会发送至履约部门。它标志着销售向运营的关键交接。从“订单已提交履约”这一活动开始，此标识符对于跟踪流程至关重要。它连接线索到收款周期中的销售和履约环节，支持端到端分析订单处理和履约时间。重要性将销售商机与履约流程关联起来，支持从线索到最终交付的端到端分析。获取途径请查阅Oracle CX Sales文档或集成的ERP系统，了解Sales Order对象的主要标识符。示例 SO-554433SO-554434SO-554435

必填建议填写选填

线索到收款活动

以下是建议记录在事件日志中的关键流程步骤和里程碑，有助于准确发现流程并识别瓶颈。

6 建议填写 8 选填

	活动	说明
	商机已赢单	表示交易成功结束，客户已承诺购买。通常可根据商机状态变更为最终的“已关闭 - 赢单”状态推断此事件。
重要性这是销售漏斗中的主要成功里程碑，也是后续履行和开票流程的触发点。获取途径当Opportunity对象的“StatusCode”更新为“WON”时，可推断此事件。“WinProb”（赢单概率）字段通常也会变为100%。采集检测Opportunity状态字段是否更新为系统定义的“已赢单”状态。事件类型 inferred
	商机流失	表示商机未能成交并已关闭。商机状态更新为“已关闭-流失”时，可据此推断该结果。
重要性这是一个关键的失败节点。分析商机流失的时间、原因和金额，有助于发现流程薄弱环节和市场挑战。获取途径当Opportunity对象的“StatusCode”更新为“LOST”时，可据此推断。 “ReasonWonLostCode”字段通常会提供相关背景信息。采集检测Opportunity状态字段是否更新为系统定义的“Lost”状态。事件类型 inferred
	客户已接受报价	表示客户已正式同意报价中的条款和价格。这是一个关键里程碑，通常通过Quote对象的状态变更为“已接受”来记录。
重要性这是重要的购买信号，也是创建销售订单的前提。它标志着谈判阶段成功结束，也是报价到订单周期中的一个里程碑。获取途径当Quote对象的状态变更为“已接受”或“客户已批准”时，可推断此事件。采集检测Quote对象的状态字段是否变更为指定的“已接受”值。事件类型 inferred
	已创建报价	表示已为该商机生成正式报价文件。创建与商机关联的新Quote记录时，会明确记录此事件。
重要性这是表明销售意向明确的重要里程碑。分析商机创建到报价创建之间的时间，有助于衡量销售推进速度。获取途径当创建与销售商机ID（OptyId）关联的Quote记录（Q_Quote对象）时，即可捕获此事件。采集使用与商机关联的Quote对象的创建时间戳。事件类型 explicit
	已收到付款	标记线索到收款周期成功完成。此时客户付款已收到并记录。该事件来自财务系统。
重要性这是流程成功完成的最终节点，表示收入已实现。它对于衡量整体销售周期时间和现金流效率至关重要。获取途径数据来自外部应收账款或财务系统。必须将数据关联回销售商机，才能完整分析整个流程。采集事件时间戳取自财务系统中的付款核销记录。事件类型 explicit
	线索转化为商机	标记符合条件的销售线索转为销售商机的时间。此事件是以商机为中心的流程分析起点，通常由用户在系统中执行线索转化操作时触发。
重要性这是流程的主要开始事件。分析已转化线索的数量和来源，对于了解线索生成和资格审核工作的成效至关重要。获取途径当创建销售商机记录（Opportunity对象）时，如果“LeadId”或类似来源字段已填充，即可捕获此事件，表明该商机来自已转化的线索。采集记录来源线索引用非空的Opportunity对象的创建时间戳。事件类型 explicit
	商机通过资格审核	表示商机已完成初步资格审核阶段。通常可根据商机销售阶段的更新推断此事件，表明初步评估已完成，且该商机具备可行性。
重要性跟踪这一里程碑有助于衡量销售早期流程的效率，并了解商机在资格审核阶段停留的时间。这是线索到商机转化率这一关键绩效指标的重要依据。获取途径当Opportunity对象的“销售阶段”字段（StgId）变更为代表资格审核的值时，可推断此事件，例如从“1 - 资格审核”变为“2 - 需求探索”。采集检测Opportunity的销售阶段字段是否变更为指定的“已通过资格审核”状态。事件类型 inferred
	已提出解决方案	表示已向客户正式提交解决方案或方案建议。商机进入“方案建议”或“方案演示”阶段时，可推断此活动。
重要性跟踪此活动有助于分析方案制定和提交所需的时间。它也是“商机停滞率”这一关键绩效指标的重要阶段，因为商机经常在此停留。获取途径当Opportunity对象的“销售阶段”字段变更为“4 - 方案建议”或“方案演示”等值时，可推断此事件。采集检测Opportunity的销售阶段字段是否变更为方案建议状态。事件类型 inferred
	已生成发票	表示已为履行的订单创建客户发票。此活动发生在开票或财务系统中，而非Oracle CX Sales，因此必须集成相关数据。
重要性此事件标志着收款周期开始。订单履行到开票之间的延误会对现金流和“开票到收款周期时间”这一关键绩效指标产生负面影响。获取途径数据来自外部ERP或应收账款系统。进行流程分析时，必须将事件数据与销售商机ID关联。采集事件时间戳取自财务系统的发票创建日志。事件类型 explicit
	报价已修改	记录报价修改后重新发送给客户的情况。可通过观察同一商机的多次“已创建报价”事件，或单个报价记录的版本变化来推断此事件。
重要性频繁返工可能表明初始方案不准确或谈判周期过长，从而延长销售周期。这有助于衡量“报价返工率”这一关键绩效指标，并支持返工分析仪表板。获取途径检测到新版本的Quote被创建，或现有报价在发送给客户后发生重大更新（例如状态重置为草稿），即可推断此事件。采集识别同一商机后续发生的“已创建报价”事件或版本递增情况。事件类型 inferred
	报价已发送给客户	标记报价正式交付客户审核的时间。通常可根据Quote对象本身的状态变更推断此事件，例如状态变为“已提交”或“已发送”。
重要性此活动标志着客户审核和谈判周期的开始，也是衡量“报价到订单创建时间”这一关键绩效指标的起点。获取途径根据与商机关联的Quote对象的状态变更推断此事件。状态字段可能名为“StatusCode”或类似名称。采集检测Quote对象的状态字段是否变更为“已发送”或“已提交”。事件类型 inferred
	订单已履行	表示产品已发货或服务已交付给客户。此事件数据并非Oracle CX Sales原生数据，必须从集成的订单管理或ERP系统获取。
重要性标记对客户的交付承诺已完成，也是开票的触发点。此事件对于衡量订单履行周期时间至关重要。获取途径需要与外部ERP或履行系统集成，并将数据关联回来源销售商机ID。采集通过集成从履行系统获取事件时间戳。事件类型 explicit
	订单已提交履行	标记从销售团队向订单履行团队的交接。在Oracle CX Sales中，可根据商机赢单来推断此事件，因为赢单可能会触发集成ERP系统创建销售订单。
重要性此活动衔接了销售与运营。分析这一交接环节对于了解和优化“订单履行时间”这一关键绩效指标至关重要。获取途径此事件通常是CX Sales中的概念性事件，表示在另一个系统中创建订单的触发点。它可以关联“商机已赢单”的时间戳，或后续的集成确认状态。采集通常使用“商机已赢单”的时间戳作为替代值，或需要从集成的订单管理系统获取数据。事件类型 inferred
	需求分析完成	表示销售团队已收集并记录客户需求。通常可根据商机销售阶段推进至需求探索或分析阶段之后来推断此事件。
重要性这是提出解决方案前的关键里程碑。此处出现延误，可能表明客户互动不足，或缺少开展深入技术分析所需的资源。获取途径当Opportunity对象的“销售阶段”字段变更时，可推断此事件，例如从“2 - 需求探索”变为“3 - 方案构建”。采集检测Opportunity的销售阶段字段是否变更为表示需求探索已完成的状态。事件类型 inferred

建议填写选填

数据提取指南

如何从Oracle CX Sales获取数据

步骤

前提条件与身份验证：确保您拥有Oracle CX Sales用户账号及必要权限，例如销售管理员或类似角色，以访问商机和报价REST API。请向Oracle Cloud管理员获取OAuth 2.0客户端凭据（Client ID和Client Secret），用于验证API请求并生成Bearer令牌。
设置环境：在本地计算机或服务器上配置Node.js环境。安装用于发送HTTP请求和处理CSV文件的必要库。打开终端并运行以下命令： npm install axios npm install json2csv
确定API端点：此次提取主要使用Opportunity和Quote对象的端点。基础URL因Oracle实例而异，例如https://[your-oracle-cx-cloud-host].fa.us2.oraclecloud.com。主要资源如下：

商机：/salesApi/resources/latest/opportunities
报价（作为商机的子对象）：/salesApi/resources/latest/opportunities/{OptyId}/child/Quote

配置提取脚本：将提供的JavaScript代码复制到文件中，例如extract.js。将脚本顶部的占位变量替换为您的Oracle CX Cloud主机URL、客户端ID、客户端密钥以及所需的数据提取日期范围。
运行脚本：在终端中使用命令node extract.js运行脚本。脚本会先获取身份验证令牌，然后开始通过API逐页获取商机数据。
获取数据并分页：脚本会自动处理API分页。每次请求指定数量的商机，并使用offset参数请求后续页面，直到获取指定日期范围内的所有商机。
获取相关报价数据：对于获取的每条商机，脚本都会另行调用API，获取所有关联报价。这些数据对于生成“已创建报价”和“客户已接受报价”等活动至关重要。
转换为事件日志：脚本的核心逻辑会处理每条商机及其关联报价，将层级JSON数据转换为扁平的表格型事件日志。脚本会根据状态代码、销售阶段和创建日期推断事件，并为每项业务活动生成单独的记录。
处理外部数据依赖：请注意，“订单已履行”“已生成发票”和“已收到付款”等活动发生在外部系统中。脚本会为销售到履行的交接生成占位活动。您必须从ERP或财务系统另行提取数据，并使用SalesOpportunity作为共同键将其与此事件日志合并。
导出为CSV：获取并转换所有数据后，脚本会使用json2csv库将最终事件日志记录数组转换为名为oracle_cx_sales_event_log.csv的CSV文件。文件将保存在运行脚本的同一目录中。
准备上传：检查生成的CSV文件，确认内容正确且完整。文件包含所需列（SalesOpportunity、ActivityName、EventTime等），可直接上传到ProcessMind进行分析。

配置

API主机URL：Oracle CX Sales环境的基础URL，例如https://[your-instance].fa.us2.oraclecloud.com。
身份验证：脚本使用OAuth 2.0和Client ID、Client Secret进行服务器间身份验证。您必须在Oracle Cloud身份管理设置中配置这些凭据。
日期范围：脚本根据LastUpdateDate字段筛选商机。建议从较近的时间范围开始，例如最近3至6个月，以控制数据量和API负载。日期格式应为YYYY-MM-DD。
字段选择：脚本使用fields查询参数，仅请求API所需字段。这可以显著提升性能并减少网络流量。如果使用自定义字段，必须将其添加到此参数中。
分页限制：limit参数用于控制每次API调用返回的记录数。脚本将其设为500，这是常见的最大值，可减少所需的API调用次数。
所需权限：使用的用户或OAuth应用凭据必须具有对“Opportunity”和“Quote”REST资源的读取权限，包括所有标准字段和相关自定义字段。

查询示例 javascript

const axios = require('axios');
const { Parser } = require('json2csv');
const fs = require('fs');

// --- Configuration --- //
const ORACLE_CX_HOST = 'https://[your-oracle-cx-cloud-host].fa.us2.oraclecloud.com';
const CLIENT_ID = '[Your Client ID]';
const CLIENT_SECRET = '[Your Client Secret]';
const START_DATE = '2023-01-01'; // YYYY-MM-DD
const END_DATE = '2023-06-30'; // YYYY-MM-DD
const PAGE_LIMIT = 500;
// --- End Configuration --- //

const tokenUrl = `${ORACLE_CX_HOST}/fscmRestApi/tokenrelay`;
const opportunitiesUrl = `${ORACLE_CX_HOST}/salesApi/resources/latest/opportunities`;

const getAuthToken = async () => {
    try {
        const response = await axios.post(tokenUrl, 'grant_type=client_credentials', {
            headers: {
                'Content-Type': 'application/x-www-form-urlencoded',
                'Authorization': `Basic ${Buffer.from(`${CLIENT_ID}:${CLIENT_SECRET}`).toString('base64')}`
            }
        });
        console.log('Successfully obtained authentication token.');
        return response.data.access_token;
    } catch (error) {
        console.error('Error fetching auth token:', error.response ? error.response.data : error.message);
        throw new Error('Authentication failed.');
    }
};

const fetchAllOpportunities = async (token) => {
    let allOpportunities = [];
    let hasMore = true;
    let offset = 0;

    console.log(`Fetching opportunities updated between ${START_DATE} and ${END_DATE}...`);

    while (hasMore) {
        const params = {
            q: `LastUpdateDate between '${START_DATE}' and '${END_DATE}'`,
            onlyData: true,
            limit: PAGE_LIMIT,
            offset: offset,
            fields: 'OptyId,CreationDate,LastUpdateDate,Name,SalesStage,StatusCode,RevnAmount,OwnerResourcePartyId,PrimaryContactPartyName,LossReasonCode,LeadId,OrganizationName,OptyNumber,OwnerName'
        };

        try {
            const response = await axios.get(opportunitiesUrl, { headers: { Authorization: `Bearer ${token}` }, params });
            const opportunities = response.data.items;
            if (opportunities && opportunities.length > 0) {
                allOpportunities.push(...opportunities);
                offset += opportunities.length;
                console.log(`Fetched ${opportunities.length} opportunities, total so far: ${allOpportunities.length}`);
            } else {
                 hasMore = false;
            }
            hasMore = response.data.hasMore;
        } catch (error) {
            console.error(`Error fetching opportunities at offset ${offset}:`, error.response ? error.response.data : error.message);
            hasMore = false; // Stop on error
        }
    }
    return allOpportunities;
};

const fetchQuotesForOpportunity = async (token, optyId) => {
    const quotesUrl = `${opportunitiesUrl}/${optyId}/child/Quote`;
    try {
        const response = await axios.get(quotesUrl, {
            headers: { Authorization: `Bearer ${token}` },
            params: { fields: 'QuoteId,CreationDate,LastUpdateDate,QuoteStatus,QuoteNumber', onlyData: true }
        });
        return response.data.items;
    } catch (error) {
        console.error(`Error fetching quotes for opportunity ${optyId}:`, error.response ? error.response.data : error.message);
        return [];
    }
};

const transformToEventLog = async (token, opportunities) => {
    const eventLog = [];
    const now = new Date().toISOString();

    for (const opp of opportunities) {
        const commonAttributes = {
            SalesOpportunity: opp.OptyNumber,
            SourceSystem: 'Oracle CX Sales',
            LastDataUpdate: now,
            OpportunityValue: opp.RevnAmount,
            SalesStage: opp.SalesStage,
            OpportunityOwner: opp.OwnerName,
            Region: opp.OrganizationName, // Example mapping, adjust as needed
            LossReason: opp.LossReasonCode
        };

        // Activity: Lead Converted To Opportunity
        if (opp.LeadId) {
            eventLog.push({ ...commonAttributes, ActivityName: 'Lead Converted To Opportunity', EventTime: opp.CreationDate });
        }
        
        // Inferred stage-based activities. Using LastUpdateDate as proxy.
        // A more accurate method requires audit trail data which is more complex to extract.
        const stageNumber = parseInt(opp.SalesStage?.split('-')[0], 10);
        if (stageNumber >= 2) {
             eventLog.push({ ...commonAttributes, ActivityName: 'Opportunity Qualified', EventTime: opp.LastUpdateDate });
        }
        if (stageNumber >= 3) {
             eventLog.push({ ...commonAttributes, ActivityName: 'Needs Analysis Completed', EventTime: opp.LastUpdateDate });
        }
        if (stageNumber >= 4) {
             eventLog.push({ ...commonAttributes, ActivityName: 'Solution Proposed', EventTime: opp.LastUpdateDate });
        }

        // Fetch and process quotes
        const quotes = await fetchQuotesForOpportunity(token, opp.OptyId);
        let quoteCreationCount = 0;
        for (const quote of quotes) {
            quoteCreationCount++;
            // Activity: Quote Created
            eventLog.push({ ...commonAttributes, ActivityName: 'Quote Created', EventTime: quote.CreationDate });
            // Activity: Quote Reworked (inferred from second or later quote creation)
            if (quoteCreationCount > 1) {
                 eventLog.push({ ...commonAttributes, ActivityName: 'Quote Reworked', EventTime: quote.CreationDate });
            }
            // Activity: Quote Sent To Customer
            if (['PRESENTED', 'SENT'].includes(quote.QuoteStatus)) {
                 eventLog.push({ ...commonAttributes, ActivityName: 'Quote Sent To Customer', EventTime: quote.LastUpdateDate });
            }
            // Activity: Quote Accepted By Customer
            if (quote.QuoteStatus === 'ACCEPTED') {
                 eventLog.push({ ...commonAttributes, ActivityName: 'Quote Accepted By Customer', EventTime: quote.LastUpdateDate });
            }
        }

        // Final Opportunity Status activities
        if (opp.StatusCode === 'WON') {
            eventLog.push({ ...commonAttributes, ActivityName: 'Opportunity Won', EventTime: opp.LastUpdateDate });
            // Activity: Order Submitted For Fulfillment (inferred from Opportunity Won)
            eventLog.push({ ...commonAttributes, ActivityName: 'Order Submitted For Fulfillment', EventTime: opp.LastUpdateDate });
            
            // Placeholder for events from external systems. Data should be merged from other sources.
            // eventLog.push({ ...commonAttributes, ActivityName: 'Order Fulfilled', EventTime: [Timestamp from ERP] });
            // eventLog.push({ ...commonAttributes, ActivityName: 'Invoice Generated', EventTime: [Timestamp from Financials] });
            // eventLog.push({ ...commonAttributes, ActivityName: 'Payment Received', EventTime: [Timestamp from Financials] });

        } else if (opp.StatusCode === 'LOST') {
            eventLog.push({ ...commonAttributes, ActivityName: 'Opportunity Lost', EventTime: opp.LastUpdateDate });
        }
    }
    return eventLog;
};

const main = async () => {
    try {
        const token = await getAuthToken();
        const opportunities = await fetchAllOpportunities(token);
        console.log(`Total opportunities to process: ${opportunities.length}`);

        if (opportunities.length > 0) {
            console.log('Transforming data into event log...');
            const eventLog = await transformToEventLog(token, opportunities);
            console.log(`Generated ${eventLog.length} event records.`);
            
            const parser = new Parser();
            const csv = parser.parse(eventLog);
            fs.writeFileSync('oracle_cx_sales_event_log.csv', csv);
            console.log('Event log saved to oracle_cx_sales_event_log.csv');
        }
    } catch (error) {
        console.error('An error occurred during the extraction process:', error.message);
    }
};

main();

步骤

准备Python环境：确保系统已安装Python。使用pip安装所需库：pip install requests pandas。
获取API凭据：使用管理员账号登录Oracle CX Sales实例。进入安全控制台（导航器>工具>安全控制台），创建具有“销售代表”角色或自定义集成角色的新用户。该用户需要访问salesLeads、opportunities、quotes及相关对象的API权限。请记下用户名和密码。
确定Oracle CX域名：找到您的Oracle CX Sales域名URL，通常格式为https://[your-pod-name].fa.em2.oraclecloud.com。
配置脚本：在编辑器中打开提供的Python脚本。将ORACLE_CX_DOMAIN、USERNAME、PASSWORD、START_DATE和END_DATE的占位值替换为实际凭据及所需的数据提取日期范围。
自定义API端点和字段：检查脚本中的API调用。请求的字段（例如OptyId、名称、SalesStage、StatusCode）均为标准字段。如果分析需要使用自定义字段（后缀为_c），请将其添加到相关API请求的fields参数中。
集成外部系统：脚本为Oracle CX Sales以外发生的活动提供了占位函数（get_order_data_from_erp、get_invoice_data_from_finance、get_payment_data_from_finance）。您必须将占位逻辑替换为实际的ERP和财务系统API调用，以获取Order Submitted、Order Fulfilled、Invoice Generated和Payment Received事件的数据。此集成对于完整呈现线索到收款流程至关重要。
运行脚本：在命令行中运行python your_script_name.py。脚本会调用Oracle CX Sales API、处理数据，并将数据汇总为一个事件日志。
检查输出：脚本会生成名为lead_to_cash_event_log.csv的文件。请在电子表格应用中打开文件，检查其结构和内容。确认包含预期列：SalesOpportunity、ActivityName、EventTime、SourceSystem等。
处理API分页：提供的脚本包含基本的分页循环。对于大型数据集，您可能需要增加更完善的错误处理，或在请求之间短暂暂停，以避免触及API速率限制。
准备上传：最终CSV文件已按格式整理，可直接上传到ProcessMind。请确保列标题与ProcessMind项目中的映射一致。无需进一步调整格式。

配置

API凭据：需要一个具有足够读取权限的专用API用户，可访问销售线索、销售商机和报价对象，包括状态和阶段变更的历史数据或审计记录。
Oracle CX域名：必须在脚本中正确指定Oracle CX Sales实例的基础URL。
日期范围：在脚本中设置START_DATE和END_DATE变量，以定义数据提取时间范围。初次分析建议选择3至6个月，以平衡数据量和性能。
商机筛选条件：您可以自定义脚本，按特定条件筛选商机。例如，可在API URL中添加查询参数，按Organization_Id或自定义字段筛选，将提取范围限制在特定业务单元或商机类型。
外部系统端点：您必须提供ERP和财务系统的实际API端点、凭据和处理逻辑，以提取订单、发票和付款数据。脚本假设这些系统可通过销售商机ID或相关订单ID进行关联。
分页限制：API调用中的limit参数设为100。您可以调整此值，但对于复杂查询，较高的值可能增加超时风险。

查询示例 python

import requests
import pandas as pd
from requests.auth import HTTPBasicAuth
import datetime

class=class="hl-string">"hl-comment"># --- Configuration Settings ---
class=class="hl-string">"hl-comment"># Replace with your Oracle CX Sales domain, username, and password
ORACLE_CX_DOMAIN = class="hl-string">"https://[your-pod-name].fa.em2.oraclecloud.com"
USERNAME = class="hl-string">"[Your_API_Username]"
PASSWORD = class="hl-string">"[Your_API_Password]"

class=class="hl-string">"hl-comment"># Define the date range for the extraction (YYYY-MM-DD format)
START_DATE = class="hl-string">"2023-01-01"
END_DATE = class="hl-string">"2023-12-31"

class=class="hl-string">"hl-comment"># --- Helper Function for API Calls ---
def fetch_all_pages(endpoint, q_filter):
    all_items = []
    url = fclass="hl-string">"{ORACLE_CX_DOMAIN}/salesApi/resources/latest/{endpoint}"
    params = {
        class="hl-string">'q': q_filter,
        class="hl-string">'onlyData': class="hl-string">'true',
        class="hl-string">'limit': 100, class=class="hl-string">"hl-comment"># Max records per page
        class="hl-string">'offset': 0
    }
    
    while True:
        try:
            response = requests.get(url, auth=HTTPBasicAuth(USERNAME, PASSWORD), params=params)
            response.raise_for_status()
            data = response.json()
            items = data.get(class="hl-string">'items', [])
            if not items:
                break
            all_items.extend(items)
            if data.get(class="hl-string">'hasMore', False):
                params[class="hl-string">'offset'] += params[class="hl-string">'limit']
            else:
                break
        except requests.exceptions.RequestException as e:
            print(fclass="hl-string">"Error fetching {url}: {e}")
            break
    return all_items

class=class="hl-string">"hl-comment"># --- Placeholder Functions for External Systems ---
def get_order_data_from_erp(opportunity_ids):
    class=class="hl-string">"hl-comment"># CRITICAL: Replace this with actual API calls to your ERP system.
    class=class="hl-string">"hl-comment"># This function should return a list of dictionaries.
    class=class="hl-string">"hl-comment"># Each dictionary should have class="hl-string">'OptyId', class="hl-string">'EventTime', class="hl-string">'ActivityName'.
    print(class="hl-string">"Fetching placeholder Order data from ERP...")
    placeholder_data = []
    class=class="hl-string">"hl-comment"># Example: placeholder_data.append({class="hl-string">'OptyId': 12345, class="hl-string">'EventTime': class="hl-string">'2023-10-25T10:00:00Z', class="hl-string">'ActivityName': class="hl-string">'Order Submitted For Fulfillment'})
    class=class="hl-string">"hl-comment"># Example: placeholder_data.append({class="hl-string">'OptyId': 12345, class="hl-string">'EventTime': class="hl-string">'2023-10-28T14:00:00Z', class="hl-string">'ActivityName': class="hl-string">'Order Fulfilled'})
    return placeholder_data

def get_invoice_data_from_finance(opportunity_ids):
    class=class="hl-string">"hl-comment"># CRITICAL: Replace this with actual API calls to your financial system.
    print(class="hl-string">"Fetching placeholder Invoice data...")
    return [] class=class="hl-string">"hl-comment"># Example: [{class="hl-string">'OptyId': 12345, class="hl-string">'EventTime': class="hl-string">'2023-10-29T11:00:00Z', class="hl-string">'ActivityName': class="hl-string">'Invoice Generated'}]

def get_payment_data_from_finance(opportunity_ids):
    class=class="hl-string">"hl-comment"># CRITICAL: Replace this with actual API calls to your financial system.
    print(class="hl-string">"Fetching placeholder Payment data...")
    return [] class=class="hl-string">"hl-comment"># Example: [{class="hl-string">'OptyId': 12345, class="hl-string">'EventTime': class="hl-string">'2023-11-15T09:30:00Z', class="hl-string">'ActivityName': class="hl-string">'Payment Received'}]


class=class="hl-string">"hl-comment"># --- Main Extraction Logic ---
print(class="hl-string">"Starting Lead to Cash extraction...")

class=class="hl-string">"hl-comment"># 1. Fetch all relevant opportunities within the date range
date_filter = fclass="hl-string">"LastUpdateDate between '{START_DATE}' and '{END_DATE}'"
opportunities = fetch_all_pages(class="hl-string">'opportunities', date_filter)

if not opportunities:
    print(class="hl-string">"No opportunities found for the given date range. Exiting.")
    exit()

print(fclass="hl-string">"Found {len(opportunities)} opportunities to process.")
opp_ids = [opp[class="hl-string">'OptyId'] for opp in opportunities]

class=class="hl-string">"hl-comment"># DataFrame to hold all events
event_log_df = pd.DataFrame()

class=class="hl-string">"hl-comment"># 2. Extract activities from Opportunity and related objects
all_events = []

for opp in opportunities:
    opp_id = opp[class="hl-string">'OptyId']
    last_update = datetime.datetime.now().isoformat()

    base_attributes = {
        class="hl-string">'SalesOpportunity': opp_id,
        class="hl-string">'OpportunityValue': opp.get(class="hl-string">'Revenue'),
        class="hl-string">'SalesStage': opp.get(class="hl-string">'SalesStage'),
        class="hl-string">'OpportunityOwner': opp.get(class="hl-string">'OwnerResourcePartyName'),
        class="hl-string">'Region': opp.get(class="hl-string">'TerritoryName_c'), class=class="hl-string">"hl-comment"># Example custom field
        class="hl-string">'LossReason': opp.get(class="hl-string">'ReasonWonLostCode'),
        class="hl-string">'SourceSystem': class="hl-string">'Oracle CX Sales',
        class="hl-string">'LastDataUpdate': last_update
    }
    
    class=class="hl-string">"hl-comment"># Activity: Lead Converted To Opportunity (inference)
    if opp.get(class="hl-string">'PrimaryContactEmailAddress') and opp.get(class="hl-string">'SalesMethod') != class="hl-string">'Renewal': class=class="hl-string">"hl-comment"># Heuristic for lead-based opportunities
        all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Lead Converted To Opportunity', class="hl-string">'EventTime': opp.get(class="hl-string">'CreationDate')})
        
    class=class="hl-string">"hl-comment"># Activities from Sales Stage history
    stage_history = opp.get(class="hl-string">'ChildSalesStage', [])
    for stage in stage_history:
        stage_name = stage.get(class="hl-string">'SalesStageCode')
        event_time = stage.get(class="hl-string">'LastUpdateDate')
        activity = None
        if stage_name in [class="hl-string">'01-QUALIFICATION', class="hl-string">'QUALIFIED']: activity = class="hl-string">'Opportunity Qualified'
        elif stage_name in [class="hl-string">'02-DISCOVERY', class="hl-string">'ANALYSIS']: activity = class="hl-string">'Needs Analysis Completed'
        elif stage_name in [class="hl-string">'03-PROPOSAL', class="hl-string">'SOLUTION_PROPOSED']: activity = class="hl-string">'Solution Proposed'
        
        if activity:
            all_events.append({**base_attributes, class="hl-string">'ActivityName': activity, class="hl-string">'EventTime': event_time})

    class=class="hl-string">"hl-comment"># Activities: Opportunity Won / Lost
    if opp.get(class="hl-string">'StatusCode') == class="hl-string">'WON':
        all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Opportunity Won', class="hl-string">'EventTime': opp.get(class="hl-string">'LastUpdateDate')})
    elif opp.get(class="hl-string">'StatusCode') == class="hl-string">'LOST':
        all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Opportunity Lost', class="hl-string">'EventTime': opp.get(class="hl-string">'LastUpdateDate')})

    class=class="hl-string">"hl-comment"># Activities from Quotes
    quotes = opp.get(class="hl-string">'ChildQuote', [])
    quote_creation_dates = []
    for quote in quotes:
        quote_creation_dates.append(quote.get(class="hl-string">'CreationDate'))
        all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Quote Created', class="hl-string">'EventTime': quote.get(class="hl-string">'CreationDate')})
        
        class=class="hl-string">"hl-comment"># Infer other quote events from status or custom date fields
        if quote.get(class="hl-string">'QuoteStatus_c') == class="hl-string">'SENT' and quote.get(class="hl-string">'DateSent_c'):
            all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Quote Sent To Customer', class="hl-string">'EventTime': quote.get(class="hl-string">'DateSent_c')})
        if quote.get(class="hl-string">'QuoteStatus_c') == class="hl-string">'ACCEPTED' and quote.get(class="hl-string">'DateAccepted_c'):
            all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Quote Accepted By Customer', class="hl-string">'EventTime': quote.get(class="hl-string">'DateAccepted_c')})
    
    class=class="hl-string">"hl-comment"># Activity: Quote Reworked (inference)
    if len(quote_creation_dates) > 1:
        class=class="hl-string">"hl-comment"># Mark all but the first creation as a rework event
        sorted_dates = sorted(quote_creation_dates)
        for rework_date in sorted_dates[1:]:
            all_events.append({**base_attributes, class="hl-string">'ActivityName': class="hl-string">'Quote Reworked', class="hl-string">'EventTime': rework_date})

class=class="hl-string">"hl-comment"># 3. Add data from external systems
print(class="hl-string">"Fetching data from external systems...")
order_events = get_order_data_from_erp(opp_ids)
invoice_events = get_invoice_data_from_finance(opp_ids)
payment_events = get_payment_data_from_finance(opp_ids)

external_system_events = []
last_update = datetime.datetime.now().isoformat()

for event in order_events + invoice_events + payment_events:
    opp_id = event[class="hl-string">'OptyId']
    class=class="hl-string">"hl-comment"># Find the corresponding opportunity to get base attributes
    opp_data = next((item for item in opportunities if item[class="hl-string">"OptyId"] == opp_id), None)
    if opp_data:
         base_attributes = {
            class="hl-string">'SalesOpportunity': opp_id,
            class="hl-string">'OpportunityValue': opp_data.get(class="hl-string">'Revenue'),
            class="hl-string">'SalesStage': opp_data.get(class="hl-string">'SalesStage'),
            class="hl-string">'OpportunityOwner': opp_data.get(class="hl-string">'OwnerResourcePartyName'),
            class="hl-string">'Region': opp_data.get(class="hl-string">'TerritoryName_c'),
            class="hl-string">'LossReason': opp_data.get(class="hl-string">'ReasonWonLostCode'),
            class="hl-string">'SourceSystem': class="hl-string">'ERP/Finance',
            class="hl-string">'LastDataUpdate': last_update
        }
    else:
        base_attributes = {class="hl-string">'SalesOpportunity': opp_id, class="hl-string">'SourceSystem': class="hl-string">'ERP/Finance', class="hl-string">'LastDataUpdate': last_update}
    
    external_system_events.append({**base_attributes, class="hl-string">'ActivityName': event[class="hl-string">'ActivityName'], class="hl-string">'EventTime': event[class="hl-string">'EventTime']})

all_events.extend(external_system_events)

class=class="hl-string">"hl-comment"># 4. Finalize the DataFrame
if all_events:
    event_log_df = pd.DataFrame(all_events)
    class=class="hl-string">"hl-comment"># Standardize column names
    event_log_df = event_log_df.rename(columns={class="hl-string">'ActivityName': class="hl-string">'ActivityName', class="hl-string">'EventTime': class="hl-string">'EventTime'})
    
    class=class="hl-string">"hl-comment"># Ensure required columns exist
    required_cols = [class="hl-string">'SalesOpportunity', class="hl-string">'ActivityName', class="hl-string">'EventTime', class="hl-string">'SourceSystem', class="hl-string">'LastDataUpdate', class="hl-string">'OpportunityValue', class="hl-string">'SalesStage', class="hl-string">'OpportunityOwner', class="hl-string">'Region', class="hl-string">'LossReason']
    for col in required_cols:
        if col not in event_log_df.columns:
            event_log_df[col] = None
            
    class=class="hl-string">"hl-comment"># Select and order columns
    event_log_df = event_log_df[required_cols]
    
    class=class="hl-string">"hl-comment"># Clean up and sort
    event_log_df = event_log_df.dropna(subset=[class="hl-string">'SalesOpportunity', class="hl-string">'ActivityName', class="hl-string">'EventTime'])
    event_log_df[class="hl-string">'EventTime'] = pd.to_datetime(event_log_df[class="hl-string">'EventTime'])
    event_log_df = event_log_df.sort_values(by=[class="hl-string">'SalesOpportunity', class="hl-string">'EventTime'])
    
    class=class="hl-string">"hl-comment"># Save to CSV
    output_filename = class="hl-string">'lead_to_cash_event_log.csv'
    event_log_df.to_csv(output_filename, index=False, date_format=class="hl-string">'%Y-%m-%dT%H:%M:%S.%fZ')
    print(fclass="hl-string">"Extraction complete. Event log saved to {output_filename}")
else:
    print(class="hl-string">"No events were generated.")

准备好开始了吗？

使用此模板准备数据，有把握地开始发现线索到收款流程中的重要洞察。立即着手优化运营，提升效率。

返回改进指南

下载模板

立即将线索到收款的赢单率提高20%

找出瓶颈，减少丢单，将赢单率提高20%。

开始免费试用

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

您的线索到收款数据模板

您的线索到收款数据模板

线索到收款属性

线索到收款活动

数据提取指南

通过Oracle CX Sales REST API直接查询提取数据

步骤

配置

查询示例 javascript

使用Oracle CX Sales REST API的Python脚本

步骤

配置

查询示例 python

准备好开始了吗？

立即将线索到收款的赢单率提高20%