本发明涉及数据监控，尤其涉及一种环保袋破损监控方法、装置、设备及存储介质。
背景技术：
1、在快件运输过程中，可能会出现破损环保袋在快递网络中流通使用的问题，若破损环保袋无法及时返修或淘汰，容易导致异常集包或快递丢失，给快递企业或客户造成损失；现有的物流企业，对于环保袋的破损情况了解途径单一，一般通过网点分拨中心或站点进行人工上报，然而，人工上报破损环保袋数据存在不积极、不及时的问题，导致破损环保袋在流通时不易被拦截，进一步导致大量破损环保袋在快递网络中流通；此外，现有的物流气液，无法线上对环保袋破损数据进行多维度分析，导致无法针对环保袋使用寿命、破损原因、供应商等进一步做出优化措施。
2、可见，现有技术还有待改进和提高。
技术实现思路
1、为了克服现有技术的不足，本发明的目的在于提供一种环保袋破损监控方法、装置、设备及存储介质，可对来自不同分拨中心的大批量环保袋数据进行统筹管理，提高数据流转效率，以对破损环保袋进行及时拦截。
2、本发明第一方面提供了一种环保袋破损监控方法，包括：基于多个分拨中心的数据传输端口，构建环保袋数据监控系统；当环保袋数据监控系统接收到实时检举信息时，对实时检举信息进行审核，若实时检举信息通过审核，则基于通过审核的实时检举信息生成拦截指令和奖惩信息；根据预设的分类关键词对通过审核的实时检举信息进行提取处理，得到提取信息，将提取信息存储至环保袋数据监控系统中；获取环保袋数据监控系统所存储的多条历史提取信息，基于历史提取信息训练破损预测模型；获取环保袋数据监控系统所存储的多条近期提取信息，将多条近期提取信息分别输入至破损预测模型中，得到预测结果；当环保袋数据监控系统接收到查询指令时，对查询指令进行提取处理，得到查询信息，基于查询信息生成查询报表。
3、可选的，在本发明第一方面的第一种实施方式中，所述基于多个分拨中心的数据传输端口，构建环保袋数据监控系统，具体包括：构建多个分拨中心的数据传输端口与kafka集群的连接关系，将多个分拨中的数据传输端口反馈的数据分别发送至kafka集群中的特定主题；引入flink流处理引擎，从kafka集群的特定主题中消费数据流，进行实时的数据处理和转换；引入doris和mysql数据库，用于存储flink流处理引擎处理后的数据；采用bi工具连接doris和mysql数据库，完成环保袋数据监控系统的构建。
4、可选的，在本发明第一方面的第二种实施方式中，所述当环保袋数据监控系统接收到实时检举信息时，对实时检举信息进行审核，若实时检举信息通过审核，则基于通过审核的实时检举信息生成拦截指令和奖惩信息，具体包括：当环保袋数据监控系统接收到实时检举信息时，采用表单库配合正则表达式对实时检举信息进行审核，以确认实时检举信息是否包括所有必填信息；当实时检举信息通过审核时，获取实时检举信息所包括的检举人信息和检举地址；根据检举地址，采用编辑距离算法匹配预设的分拨中心地址库，以确认与检举地址对应的分拨中心地址；获取所确认的分拨中心地址的联系人信息，基于所获取的联系人信息、预设的提醒间隔次数和间隔时间生成拦截指令，并基于联系人信息、检举人信息和预设的检举奖惩表生成奖惩信息。
5、可选的，在本发明第一方面的第三种实施方式中，所述根据预设的分类关键词对通过审核的实时检举信息进行提取处理，得到提取信息，将提取信息存储至环保袋数据监控系统中，具体包括：采用kmp算法，根据预设的分类关键词对通过审核的实时检举信息进行提取处理，以提取与分类关键词对应的信息关键词；将信息关键词分配至预设的类别中，得到分类信息；对分类信息依次进行清洗过滤和归纳总结，得到提取信息，并将提取信息存储至环保袋数据监控系统中。
6、可选的，在本发明第一方面的第四种实施方式中，所述获取环保袋数据监控系统所存储的多条历史提取信息，基于历史提取信息训练破损预测模型，具体包括：获取环保袋数据监控系统所存储的多条历史提取信息，所述历史提取信息为存储于环保袋数据监控系统中的、三个月前的提取信息；分别对多条历史提取信息进行清洗和预处理，并从历史提取信息中提取与使用寿命相关的特征，得到处理后信息；对处理后信息依次进行特征缩放处理和划分处理，得到训练集和测试集；将训练集输入至线性回归模型中进行训练，并使用测试集对线性回归模型进行评估，得到破损预测模型。
7、可选的，在本发明第一方面的第五种实施方式中，所述获取环保袋数据监控系统所存储的多条近期提取信息，将多条近期提取信息分别输入至破损预测模型中，得到预测结果，具体包括：获取环保袋数据监控系统所存储的多条近期提取信息，所述近期提取信息为存储于环保袋数据监控系统中的、近一个月的提取信息；将多条近期提取信息分别输入至破损预测模型中，得到预测结果，所述预测结果为环保袋的使用寿命预测结果；采用随机森林算法对预测结果进行分析，得到分析结果；基于预测结果和分析结果生成采购调整信息。
8、可选的，在本发明第一方面的第六种实施方式中，所述当环保袋数据监控系统接收到查询指令时，对查询指令进行提取处理，得到查询信息，基于查询信息生成查询报表，具体包括：当环保袋数据监控系统接收到查询指令时，使用命名实体识别方法对查询指令进行提取处理，得到查询信息；根据查询信息构建sql查询语句，通过sql查询语句从环保袋数据监控系统中提取查询数据；对查询数据进行聚合和过滤处理，得到过滤数据；基于过滤数据和查询信息中所包括的报表需求，使用报表生成工具生成查询报表。
9、本发明第二方面提供了一种环保袋破损监控装置，包括：构建模块，用于基于多个分拨中心的数据传输端口，构建环保袋数据监控系统；审核模块，用于当环保袋数据监控系统接收到实时检举信息时，对实时检举信息进行审核，若实时检举信息通过审核，则基于通过审核的实时检举信息生成拦截指令和奖惩信息；提取模块，用于根据预设的分类关键词对通过审核的实时检举信息进行提取处理，得到提取信息，将提取信息存储至环保袋数据监控系统中；训练模块，用于获取环保袋数据监控系统所存储的多条历史提取信息，基于历史提取信息训练破损预测模型；预测模块，用于获取环保袋数据监控系统所存储的多条近期提取信息，将多条近期提取信息分别输入至破损预测模型中，得到预测结果；查询模块，用于当环保袋数据监控系统接收到查询指令时，对查询指令进行提取处理，得到查询信息，基于查询信息生成查询报表。
10、可选的，在本发明第二方面的第一种实现方式中，所述构建模块包括：构建单元，用于构建多个分拨中心的数据传输端口与kafka集群的连接关系，将多个分拨中的数据传输端口反馈的数据分别发送至kafka集群中的特定主题；第一引入单元，用于引入flink流处理引擎，从kafka集群的特定主题中消费数据流，进行实时的数据处理和转换；第二引入单元，用于引入doris和mysql数据库，用于存储flink流处理引擎处理后的数据；连接单元，用于采用bi工具连接doris和mysql数据库，完成环保袋数据监控系统的构建。
11、可选的，在本发明第二方面的第二种实现方式中，所述审核模块包括：审核单元，用于当环保袋数据监控系统接收到实时检举信息时，采用表单库配合正则表达式对实时检举信息进行审核，以确认实时检举信息是否包括所有必填信息；第一获取单元，用于当实时检举信息通过审核时，获取实时检举信息所包括的检举人信息和检举地址；匹配单元，用于根据检举地址，采用编辑距离算法匹配预设的分拨中心地址库，以确认与检举地址对应的分拨中心地址；第二获取单元，用于获取所确认的分拨中心地址的联系人信息，基于所获取的联系人信息、预设的提醒间隔次数和间隔时间生成拦截指令，并基于联系人信息、检举人信息和预设的检举奖惩表生成奖惩信息。
12、可选的，在本发明第二方面的第三种实现方式中，所述提取模块包括：第一提取单元，用于采用kmp算法，根据预设的分类关键词对通过审核的实时检举信息进行提取处理，以提取与分类关键词对应的信息关键词；分配单元，用于将信息关键词分配至预设的类别中，得到分类信息；存储单元，用于对分类信息依次进行清洗过滤和归纳总结，得到提取信息，并将提取信息存储至环保袋数据监控系统中。
13、可选的，在本发明第二方面的第四种实现方式中，所述训练模块包括：第三获取单元，用于获取环保袋数据监控系统所存储的多条历史提取信息，所述历史提取信息为存储于环保袋数据监控系统中的、三个月前的提取信息；处理单元，用于分别对多条历史提取信息进行清洗和预处理，并从历史提取信息中提取与使用寿命相关的特征，得到处理后信息；划分单元，用于对处理后信息依次进行特征缩放处理和划分处理，得到训练集和测试集；训练单元，用于将训练集输入至线性回归模型中进行训练，并使用测试集对线性回归模型进行评估，得到破损预测模型。
14、可选的，在本发明第二方面的第五种实现方式中，所述预测模块包括：第四获取单元，用于获取环保袋数据监控系统所存储的多条近期提取信息，所述近期提取信息为存储于环保袋数据监控系统中的、近一个月的提取信息；预测单元，用于将多条近期提取信息分别输入至破损预测模型中，得到预测结果，所述预测结果为环保袋的使用寿命预测结果；分析单元，用于采用随机森林算法对预测结果进行分析，得到分析结果；第一生成单元，用于基于预测结果和分析结果生成采购调整信息。
15、可选的，在本发明第二方面的第六种实现方式中，所述查询模块包括：第二提取单元，用于当环保袋数据监控系统接收到查询指令时，使用命名实体识别方法对查询指令进行提取处理，得到查询信息；查询单元，用于根据查询信息构建sql查询语句，通过sql查询语句从环保袋数据监控系统中提取查询数据；过滤单元，用于对查询数据进行聚合和过滤处理，得到过滤数据；第二生成单元，用于基于过滤数据和查询信息中所包括的报表需求，使用报表生成工具生成查询报表。
16、本发明第三方面提供了一种环保袋破损监控设备，所述环保袋破损监控设备包括：存储器和至少一个处理器，所述存储器中存储有指令；至少一个所述处理器调用所述存储器中的所述指令，以使得所述环保袋破损监控设备执行上述任一项所述的环保袋破损监控方法的各个步骤。
17、本发明的第四方面提供了一种计算机可读存储介质，所述计算机可读存储介质上存储有指令，所述指令被处理器执行时实现上述任一项所述环保袋破损监控方法的各个步骤。
18、本发明的技术方案中，通过基于多个分拨中心的数据传输端口构建环保袋数据监控系统；对所收到的实时检举信息进行审核，并基于通过审核的实时检举信息生成拦截指令和奖惩信息；根据预设的分类关键词对通过审核的实时检举信息进行提取处理，得到提取信息并存储；基于所获取的多条历史提取信息训练破损预测模型；将所获取多条近期提取信息分别输入至破损预测模型中，得到预测结果；对所收到的查询指令进行提取处理，以得到用于生成查询报表的查询信息；本技术公开的方法，可对来自不同分拨中心的大批量环保袋数据进行统筹管理，提高数据流转效率，以对破损环保袋进行及时拦截，且可根据查询指令生成对应的查询报表，结合破损预测模型对环保袋的使用寿命进行预测，可为物流公司优化环保袋采购流程提供数据支撑。
1.一种环保袋破损监控方法，其特征在于，包括：
2.根据权利要求1所述的一种环保袋破损监控方法，其特征在于，所述基于多个分拨中心的数据传输端口，构建环保袋数据监控系统，具体包括：
3.根据权利要求1所述的一种环保袋破损监控方法，其特征在于，所述当环保袋数据监控系统接收到实时检举信息时，对实时检举信息进行审核，若实时检举信息通过审核，则基于通过审核的实时检举信息生成拦截指令和奖惩信息，具体包括：
4.根据权利要求1所述的一种环保袋破损监控方法，其特征在于，所述根据预设的分类关键词对通过审核的实时检举信息进行提取处理，得到提取信息，将提取信息存储至环保袋数据监控系统中，具体包括：
5.根据权利要求1所述的一种环保袋破损监控方法，其特征在于，所述获取环保袋数据监控系统所存储的多条历史提取信息，基于历史提取信息训练破损预测模型，具体包括：
6.根据权利要求5所述的一种环保袋破损监控方法，其特征在于，所述获取环保袋数据监控系统所存储的多条近期提取信息，将多条近期提取信息分别输入至破损预测模型中，得到预测结果，具体包括：
7.根据权利要求1所述的一种环保袋破损监控方法，其特征在于，所述当环保袋数据监控系统接收到查询指令时，对查询指令进行提取处理，得到查询信息，基于查询信息生成查询报表，具体包括：
8.一种环保袋破损监控装置，其特征在于，包括：
9.一种环保袋破损监控设备，其特征在于，所述环保袋破损监控设备包括：存储器和至少一个处理器，所述存储器中存储有指令；
10.一种计算机可读存储介质，所述计算机可读存储介质上存储有指令，其特征在于，所述指令被处理器执行时实现如权利要求1-7中任一项所述环保袋破损监控方法的各个步骤。
