一种用于煤炭贸易的数据处理方法、系统及存储介质

摘要

本发明公开了一种用于煤炭贸易的数据处理方法、系统及存储介质。方法包括：采集煤炭贸易基础数据建立基础数据库；获取各基础数据间的线路关联建立线路数据库；根据煤矿至用煤终端之间的运输形式，将运输环节对应的线路成本进行测算和排序，建立线路成本测算数据库；接收用户的查询请求，根据查询请求对应的查询类型查询相应的数据库，并将查询结果反馈至用户。本发明通过整合煤炭生产、运输、销售等环节的数据，进行成本、距离、利润等全方位测算，实现煤炭贸易业务的数据化，建立数字化采销业态，可以有效降低物流成本，促进煤炭资源的高效配置，同时本发明还支持多个维度查询。

说明书

技术领域

本发明涉及数据处理技术领域，尤其涉及一种用于煤炭贸易的数据处理方法、系统及存储介质。

背景技术

煤炭行业是历史悠久的工业形式，为其它行业的生产提供生产原料和能源基础。随着煤炭行业发展，运用计算机网络技术、信息技术、电子商务技术等方式提高企业的经营水平和市场竞争能力也成为了迫切需求。煤炭贸易是指在较长交易周期内通过市场买卖煤炭的大宗商品交易过程。如果贸易商需要购买并销售给下游客户，就需要完成从矿口到铁路到港口以及汽运船运等一系列操作。

由于煤炭贸易涉及煤炭生产、运输、销售等较多环节，涉及到的交易数据相当复杂。煤炭品种众多，销售流程复杂，信息量大，数据繁杂。煤炭行业长期存在的“从哪儿产、从哪儿装、走哪条路、到哪儿去、卖给谁”等问题。现有煤炭贸易交易处理较依赖人们的经验，信息化、数字化程度较低，信息获取不对等、滞后，导致交易处理效率较低，影响企业经济效益。

发明内容

本发明的目的在于，针对现有技术中存在的技术问题，提供一种用于煤炭贸易的数据处理方法、系统及存储介质，可以整合煤炭生产、运输、销售等环节的大量交易数据，进行成本、距离、利润等全方位测算，实现企业业务的数据化和物流数据的业务化，建立企业的数字化采销业态，为煤炭上中下游客户进行最佳供货方、最佳线路、最佳运输方式的智能匹配。

为实现上述目的，本发明提供了一种用于煤炭贸易的数据处理方法，所述方法包括如下步骤：采集煤炭贸易基础数据建立基础数据库；获取各基础数据间的线路关联建立线路数据库；根据煤矿至用煤终端之间的运输形式，将运输环节对应的线路成本进行测算和排序，建立线路成本测算数据库；接收用户的查询请求，根据查询请求对应的查询类型查询相应的数据库，并将查询结果反馈至用户。

优选地，所述方法进还包括对所述基础数据库、所述线路数据库中的数据进行动态监测，以实时更新相应数据库，进而实时更新对相应线路成本的测算和排序，从而更新所述线路成本测算数据库确。

为实现上述目的，本发明还提供了一种用于煤炭贸易的数据处理系统，所述系统包括：基础数据库建立模块，用于采集煤炭贸易基础数据建立基础数据库；线路数据库建立模块，用于获取各基础数据间的线路关联建立线路数据库；线路成本测算数据库建立模块，用于按线路关联的类型将供应链的每个环节对应的线路成本进行测算和排序，建立线路成本测算数据库；查询处理模块，用于接收用户的查询请求，根据查询请求对应的查询类型查询相应的数据库，并将查询结果反馈至用户。

优选地，所述系统还包括动态监测处理模块，用于对所述基础数据库、所述线路数据库中的数据进行动态监测，以实时更新相应数据库，进而实时更新对相应线路成本的测算和排序，从而更新所述线路成本测算数据库确。

为实现上述目的，本发明还提供了一种存储介质，所述存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现本发明所述的用于煤炭贸易的数据处理方法的步骤。

本发明的优点在于：本发明通过整合煤炭生产、运输、销售等环节的数据，进行成本、距离、利润等全方位测算，实现煤炭贸易业务的数据化，建立数字化采销业态，可以为煤炭上中下游客户进行最佳供货方、最佳线路、最佳运输方式的智能匹配，实现智能决策与精细化管理，可以有效降低物流成本、扩大已有业务的规模和收益，并可以为大型采购集团提供定价依据，促进煤炭资源的高效配置。同时本发明还支持煤矿与用煤终端之间的汽车运输直供、铁路运输直供、多式联运查询，站台发运线路查询，用煤终端可采购线路及煤矿查询等多个维度查询。

附图说明

为了更清楚地说明本发明实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其它的附图。

图1为本发明用于煤炭贸易的数据处理方法的流程示意图；

图2为本发明线路成本测算数据库建立的流程示意图；

图3为本发明用于煤炭贸易的数据处理系统的架构示意图。

具体实施方式

下面将结合附图，对本发明实施例中的技术方案进行清楚、完整地描述。本发明的说明书和权利要求书以及附图中的术语“第一”、“第二”、“第三”等(如果存在)是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应当理解，这样描述的对象在适当情况下可以互换。此外，术语“包括”和“具有”以及它们的任何变形，意图在于覆盖不排它的包含。在本发明的描述中，“多个”的含义是两个或两个以上，除非另有明确具体的限定。在本发明的描述中，需要说明的是，除非另有明确的规定和限定，术语“安装”“相连”“连接”应做广义理解，例如，可以是固定连接，也可以是可拆卸连接，或一体地连接；可以是机械连接，也可以是电连接或可以相互通讯；可以是直接相连，也可以通过中间媒介间接相连，可以是两个元件内部的连通或两个元件的相互作用关系。对于本领域的普通技术人员而言，可以根据具体情况理解上述术语在本发明中的具体含义。

请参阅图1，其为本发明用于煤炭贸易的数据处理方法的流程示意图。如图1所示，所述方法包括如下步骤：S1、采集煤炭贸易基础数据建立基础数据库；S2、获取各基础数据间的线路关联建立线路数据库；S3、根据煤矿至用煤终端之间的运输形式，将运输环节对应的线路成本进行测算和排序，建立线路成本测算数据库；S4、接收用户的查询请求，根据查询请求对应的查询类型查询相应的数据库，并将查询结果反馈至用户。以下给出详细解释说明。

关于步骤S1、采集煤炭贸易基础数据建立基础数据库。

在此步骤中，可以通过大数据筛选的方式，采集预设范围内(例如，全国范围内或指定区域单位内)的所有煤矿、用煤终端、铁路站台、铁路专用线等的数据信息，以建立基础数据库。数据信息包含但不限于企业名称、联系方式、地理位置、经纬度、所属企业、产能、所产/所需指标、对应价格等信息。还可以采集预设范围内的洗煤厂、煤炭物流园等的数据信息，以完善、优化基础数据库。也即，基础数据库可以涵盖煤矿、站台、洗煤厂、用煤终端等煤炭贸易相关企业的底层基础数据。

具体地，所述基础数据库包括：预设范围内的煤矿信息库、用煤终端信息库、运输站点库、汽车运费库、铁路运输运费库、铁路站台费库。其中，所述煤矿信息库包括：企业名称、联系方式、地理位置、经纬度、生产指标、价格信息；所述用煤终端信息库包括：企业名称、联系方式、地理位置、经纬度、需求指标信息。需要说明的是，所述基础数据库也可以根据煤炭供应链上涉及的节点变动，增加相应的基础数据的采集和数据库建立。

关于步骤S2、获取各基础数据间的线路关联建立线路数据库。

在此步骤中，可以通过大数据筛选的方式，采集网络上的物流沉淀数据，获取各基础数据间的线路关联，进而建立线路数据库。例如，通过对有数据获取权限的交易平台、无车承运平台、第三方平台等的物流沉淀数据进行采集，获取各基础数据间的线路关联。其中，物流沉淀数据包括煤矿、洗煤厂、站台、港口、用煤终端、煤矿最新煤价、煤矿历史煤价、平台煤价(例如陕煤价格、神华价格、用煤终端长期协议价)、汽运线路、铁运线路、汽运线路运价、铁运线路运价、站台费等相关数据。物流沉淀数据还可以包括船运线路、船运运价、装卸费、服务费、信息费、公里数、路况、宏观经济等相关数据。

具体地，所述线路数据包括：煤矿至用煤终端之间不同运输形式时运输环节的各节点数据。例如，煤矿至用煤终端之间全程铁路运输形式的供应链上的各节点数据、煤矿至用煤终端之间全程汽车运输形式的供应链上的各节点数据、煤矿至用煤终端之间铁路运输与汽车运输结合的多式联运形式的供应链上的各节点数据。也即，线路数据库可以涵盖汽车运输、铁路运输、多式联运等供应链上的各节点数据。例如，全局铁路运费信息，预设范围内(例如全国范围内)铁路局发站-到站的大列、小列运费信息，汽车运费信息(包含煤矿上站短倒汽车运输费、煤矿长途汽车运输费、用煤终端短倒汽车运输费)等数据信息。

关于步骤S3、根据煤矿至用煤终端之间的运输形式，将运输环节对应的线路成本进行测算和排序，建立线路成本测算数据库。

在此步骤中，可以根据前述建立的基础数据库、线路数据库中的数据，测算不同运输形式对应的成本，进而建立线路成本测算数据库。

进一步的实施例中，所述步骤S3进一步包括：S31、对煤矿的煤炭性能指标进行标准化换算获取煤炭实际成本；S32、根据煤矿至用煤终端之间的运输形式获取运输环节对应的线路成本；S33、对所述煤炭实际成本与线路成本进行求和获取测算结果；S34、对测算结果进行排序建立线路成本测算数据库；流程图如图2所示。

进一步的实施例中，所述的对煤矿的煤炭性能指标进行标准化换算获取煤炭实际成本的步骤进一步包括：根据煤炭的实际热值换算为相应的标准品以计算煤炭实际成本，根据煤炭的实际硫份与相应的标准品的标准硫份差值优化计算出的煤炭实际成本。由于煤炭指标规范性较低，在比较成本之前需要统一为同一标准。例如，可以将煤炭指标对应换算为3个标准品的其中之一；3个标准品包括第一标准热值、第一标准硫份，第二标准热值、第二标准硫份，第三标准热值、第三标准硫份。

所述的根据煤炭的实际热值换算为相应的标准品以计算煤炭实际成本进一步包括：1)确定煤炭实际热值，并与第一热值阈值以及第二热值阈值进行比较；2)当煤炭实际热值小于或等于第一热值阈值时，将煤炭销售价格除以煤炭实际热值后的比值再与预设的第一标准热值相乘，获取煤炭实际成本；3)当煤炭实际热值大于第一热值阈值、且小于或等于第二热值阈值时，将煤炭销售价格除以煤炭实际热值后的比值再与预设的第二标准热值相乘，获取煤炭实际成本；4)当煤炭实际热值大于第二热值阈值时，将煤炭销售价格除以煤炭实际热值后的比值再与预设的第三标准热值相乘，获取煤炭实际成本；其中，所述第二热值阈值大于所述第一热值阈值，所述第三标准热值大于所述第二标准热值，所述第二标准热值大于所述第一标准热值。可选地，所述第一热值阈值大于所述第一标准热值、且所述第一热值阈值小于所述第二标准热值；所述第二热值阈值大于所述第二标准热值、且所述第二热值阈值小于所述第三标准热值。

考虑到硫份指标也会影响成本计算，因此根据煤炭的实际硫份与相应的标准品的标准硫份差值优化计算出的煤炭实际成本。具体换算方式如下：当以第一标准热值、第一标准硫份计算成本时，若实际硫份大于第一标准硫份，按超出的数值换算为标准品成本时增加相应的成本；若实际硫份小于第一标准硫份，按低于的数值换算为标准品成本时降低相应的成本。当以第二标准热值、第二标准硫份计算成本时，若实际硫份大于第二标准硫份，按超出的数值换算为标准品成本时增加相应的成本；若实际硫份小于第二标准硫份，按低于的数值换算为标准品成本时降低相应的成本。当以第三标准热值、第三标准硫份计算成本时，若实际硫份大于第三标准硫份，按超出的数值换算为标准品成本时增加相应的成本；若实际硫份小于第三标准硫份，按低于的数值换算为标准品成本时降低相应的成本。

例如，3个标准品包括4500大卡、1.0％硫份，5000大卡、0.6％硫份，5500大卡、0.6％硫份。当实际热值≤4700大卡时，计算成本时按4500大卡标准计算，计算方法为“价格÷实际热值×4500”；以4500大卡、硫份1.0％为标准品时，实际硫份指标超出范围的，每超出0.01％(相比于1.0％)换算为标准品成本时增加相应成本，每降低0.01％(相比于1.0％)换算为标准品成本时减少相应成本。当4700大卡<实际热值≤5350大卡时，计算成本时按5000大卡标准计算，计算方法为“价格÷实际热值×5000”；以5000大卡、硫份0.6％为标准品时，实际硫份指标超出范围的，每超出0.01％(相比于0.6％)换算为标准品成本时增加相应成本，每降低0.01％(相比于0.6％)换算为标准品成本时减少相应成本。当实际热值>5350大卡时，计算成本时按5500大卡标准计算，计算方法为“价格÷实际热值×5500”；以5500大卡、硫份0.6％为标准品时，实际硫份指标超出范围的，每超出0.01％(相比于0.6％)换算为标准品成本时增加相应成本，每降低0.01％(相比于0.6％)换算为标准品成本时减少相应成本。

煤矿至用煤终端之间一个完整的供应链按运输方式可包括多个环节。进一步的实施例中，煤矿至用煤终端之间的运输形式包括全程铁路运输形式、全程汽车运输形式以及多式联运形式；所述全程铁路运输形式运输环节对应的线路成本为煤矿至用煤终端之间的煤矿铁路专用线费、发站站台费、铁路运费、到站站台费、用煤终端铁路专用线费的总和；所述全程汽车运输形式运输环节对应的线路成本为煤矿至用煤终端之间的汽车运输运费的总和；所述多式联运形式运输环节对应的线路成本为煤矿至用煤终端之间的汽车运费、铁路运费、铁路站台费的总和。其中，根据选择的多式联运形式，多式联运形式运输环节对应的线路成本具体可以为：短倒汽车运费、发站站台费、铁路运费、到站站台费、短倒汽车运费的总和；或者为：短倒汽车运费、发站站台费、铁路运费、到站站台费、终端铁路专用线费的总和；或者为：煤矿铁路专用线费、发站站台费、铁路运费、到站站台费、短倒汽车运费的总和。

通过对煤炭实际成本与线路成本进行求和获取测算结果，进一步对测算结果进行排序，即可建立线路成本测算数据库。其中，可以根据指标匹配度、历史交货量、成本高低等指标，对测算结果进行排序；根据排序结构还可以进一步输出重点推荐线路和可开发终端。

关于步骤S4、接收用户的查询请求，根据查询请求对应的查询类型查询相应的数据库，并将查询结果反馈至用户。

具体地，当查询请求对应的查询类型为查询基础信息时，查找所述基础数据库；当查询请求对应的查询类型为查询线路信息时，查找所述线路数据库；当查询请求对应的查询类型为查询线路成本信息时，查找所述线路成本测算数据库。

基于建立的基础数据库、线路数据库、线路成本测算数据库，用户可以进行信息查询。例如，用户可以查询基础信息：煤矿指标、煤矿位置、煤矿产能、煤矿/用煤终端联系方式、用煤终端需求指标、用煤终端位置、站台位置、站台费、铁路运费、汽车运费等等；当接收到用户的此类查询请求时，可以通过查询基础数据库获取查询结果并反馈给用户。用户也可以查询线路信息：某煤矿上哪些站台、某煤矿可通过汽车运输方式供货给哪些用煤终端、某站台往哪些站台发运供货给哪些用煤终端、某用煤终端在哪些站台集运以及采购的煤炭从哪里来等等；当接收到用户的此类查询请求时，可以通过查询线路数据库获取查询结果并反馈给用户。用户也可以查询线路成本信息：某煤矿通过某种运输方式供货给某用煤终端的相应线路详细的成本是多少等等；当接收到用户的此类查询请求时，可以通过线路成本测算数据库获取查询结果并反馈给用户。本发明还可以结合导航功能实现位置查询并导航：可查找某站台周边指定范围内的煤矿、用煤终端、其他站台并导航，某煤矿周边指定范围内的站台、用煤终端、其他煤矿并导航，某用煤终端周边指定范围内的站台、煤矿、其他用煤终端并导航等。

综上，采用本发明提供的用于煤炭贸易的数据处理方法，可以应用于煤炭供应链领域，实现煤炭销售、煤炭采购、煤炭发运等相关的定价、线路规划、成本测算等。

进一步的实施例中，所述方法进一步包括步骤S5、对所述基础数据库、所述线路数据库中的数据进行动态监测，以实时更新相应数据库，进而实时更新对相应线路成本的测算和排序，从而更新所述线路成本测算数据库确。例如，可以对于煤矿生产指标、用煤终端需求指标、汽车运输运费、铁路运输运费等环节数据进行动态监测，及时更新相应数据库、实时对线路成本进行测算和排序，确保本发明采销解决方案的时效性。

具体地，所述动态监测的方式包括一下至少其中之一：根据获取权限通过程序调取相应的煤矿、用煤终端的供需和价格信息；根据监测权限监测相应的煤矿、用煤终端的供需和价格信息；根据获取权限通过人工获取相应的煤矿、用煤终端的供需和价格信息，获取相应的汽车运费、铁路运输运费、铁路站台费；或根据获取权限通过程序调取相应的承运车辆的汽车运费。例如，对于某些具有智能调运系统的煤矿、站台、物流园、用煤终端等，因系统里有详细的企业名称、指标信息、日期等，可根据获取权限通过程序调取从系统里直接调取。对于在某些平台挂牌交易的煤矿、用煤终端等，可根据监测权限直接监测到其供需的详细指标和价格；对于煤炭贸易上下游企业网站及对所在区域的煤矿指标、价格有详细跟进的第三方平台等，可以作为获取数据的渠道，根据监测权限获取其指标和价格。对于公司自有驻矿、驻站团队，以及分布于产区、港口、下游区域的业务人员，可根据获取权限通过人工及时获取所在区域煤矿和终端的指标和价格、站台费用、发运铁路费用等。对于有获取权限的无车承运平台、车队等，可以即时调取或咨询短途、中途、长途汽运价格等相应的承运车辆的汽车运费。

基于建立的基础数据库、线路数据库、线路成本测算数据库以及动态监测功能的基础上，本发明可以接收用户的定制化需求，进行定制化操作；例如进行指定区域煤矿价格的动态监测、指定区域用煤终端查询、指定线路的成本测算分析、指定站台发运信息分析等等。

本发明用于煤炭贸易的数据处理方法，通过整合煤炭生产、运输、销售等环节的数据，进行成本、距离、利润等全方位测算，实现煤炭贸易业务的数据化，建立数字化采销业态，可以为煤炭上中下游客户进行最佳供货方、最佳线路、最佳运输方式的智能匹配，实现智能决策与精细化管理，可以有效降低物流成本、扩大已有业务的规模和收益，并可以为大型采购集团提供定价依据，促进煤炭资源的高效配置。同时本发明还支持煤矿与用煤终端之间的汽车运输直供、铁路运输直供、多式联运查询，站台发运线路查询，用煤终端可采购线路及煤矿查询等多个维度查询。

基于同一发明构思，本发明还提供了一种用于煤炭贸易的数据处理系统。

请参阅图3，其为本发明用于煤炭贸易的数据处理系统的架构示意图。如图3所示，所述系统包括：基础数据库建立模块31、线路数据库建立模块32、线路成本测算数据库建立模块33以及查询处理模块34。

具体地，基础数据库建立模块31用于采集煤炭贸易基础数据建立基础数据库。线路数据库建立模块32用于获取各基础数据间的线路关联建立线路数据库。线路成本测算数据库建立模块33用于按线路关联的类型将供应链的每个环节对应的线路成本进行测算和排序，建立线路成本测算数据库。查询处理模块34用于接收用户的查询请求，根据查询请求对应的查询类型查询相应的数据库，并将查询结果反馈至用户。

进一步的实施例中，所述系统进一步包括动态监测处理模块35；动态监测处理模块35用于对所述基础数据库、所述线路数据库中的数据进行动态监测，以实时更新相应数据库，进而实时更新对相应线路成本的测算和排序，从而更新所述线路成本测算数据库确。

关于所述系统的额外细节及实现效果可参考上述用于煤炭贸易的数据处理方法的描述，此处不再赘述。

基于同一发明构思，本发明还还提供了一种存储介质。所述存储介质上存储有计算机程序，所述计算机程序被处理器执行时实现本发明用于煤炭贸易的数据处理方法的步骤。本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成。所述的计算机程序可存储于一非易失性计算机可读取存储介质中，所述计算机程序在执行时，可实现包括如上述用于煤炭贸易的数据处理方法的实施例的流程。

本发明所提供的各实施例中所使用的对存储、数据库或其它介质的任何引用，均可包括非易失性和/或易失性存储器。非易失性存储器可包括只读存储器(ROM)、可编程ROM(PROM)、电可编程ROM(EPROM)、电可擦除可编程ROM(EEPROM)或闪存。易失性存储器可包括随机存取存储器(RAM)或者外部高速缓冲存储器。作为说明而非局限，RAM以多种形式可得，诸如静态RAM(SRAM)、动态RAM(DRAM)、同步DRAM(SDRAM)、双数据率SDRAM(DDRSDRAM)、增强型SDRAM(ESDRAM)、同步链路(Synchlink)DRAM(SLDRAM)等。

在上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述的部分，可以参见其它实施例的相关描述。

以上实施例的说明只是用于帮助理解本发明的技术方案及其核心思想；本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例的技术方案的范围。