CN107769934B - Rate processing method and processing device - Google Patents
Rate processing method and processing device Download PDFInfo
- Publication number
- CN107769934B CN107769934B CN201710995125.6A CN201710995125A CN107769934B CN 107769934 B CN107769934 B CN 107769934B CN 201710995125 A CN201710995125 A CN 201710995125A CN 107769934 B CN107769934 B CN 107769934B
- Authority
- CN
- China
- Prior art keywords
- message
- tariff
- verification
- verifying
- module
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/02—Details
- H04L12/14—Charging, metering or billing arrangements for data wireline or wireless communications
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Computer And Data Communications (AREA)
Abstract
Description
技术领域technical field
本发明实施例涉及通信技术领域,尤其涉及一种资费处理方法及装置。The embodiments of the present invention relate to the technical field of communications, and in particular, to a method and device for processing tariffs.
背景技术Background technique
随着中国联通4G cBSS集中计费系统用户数和业务的发展,市场多样化资费套餐的需求爆发式增长,大量新增资费和套餐被推出。With the development of the number of users and services of China Unicom's 4G cBSS centralized billing system, the demand for diversified tariff packages in the market has exploded, and a large number of new tariffs and packages have been launched.
资费配置内容为几百条ORACLE数据库表的DML操作语句,资费验证内容为几百个覆盖不同场景的测试话单,现有技术中,资费的配置和测试主要是人工使用VB、EXCEL、ORACLE简单技术进行手工配置验证,从而降低了资费的配置和验证效率。The content of tariff configuration is hundreds of DML operation statements of ORACLE database tables, and the content of tariff verification is hundreds of test bills covering different scenarios. In the existing technology, the configuration and testing of tariffs are mainly done manually using VB, EXCEL, and ORACLE. The technology performs manual configuration verification, thereby reducing the efficiency of tariff configuration and verification.
发明内容Contents of the invention
本发明实施例提供一种资费处理方法及装置,以提高资费的配置和验证效率。Embodiments of the present invention provide a tariff processing method and device, so as to improve the configuration and verification efficiency of tariffs.
本发明实施例的一个方面是提供一种资费处理方法,包括:An aspect of the embodiments of the present invention is to provide a tariff processing method, including:
接收前台设备发送的消息;Receive messages sent by the foreground device;
将所述消息分解为消息头、消息执行方式、消息执行内容;Decomposing the message into message header, message execution mode, and message execution content;
通过对所述消息头进行解析,将所述消息分发给后台服务器;Distributing the message to the background server by parsing the message header;
根据所述消息执行方式和所述消息执行内容调用所述后台服务器中的应用。The application in the background server is invoked according to the message execution mode and the message execution content.
本发明实施例的另一个方面是提供一种资费处理装置,包括:Another aspect of the embodiments of the present invention is to provide a tariff processing device, including:
接收模块,用于接收前台设备发送的消息;The receiving module is used to receive the message sent by the foreground device;
分解模块,用于将所述消息分解为消息头、消息执行方式、消息执行内容;A decomposing module, configured to decompose the message into a message header, a message execution method, and a message execution content;
发送模块,用于通过对所述消息头进行解析,将所述消息分发给后台服务器;A sending module, configured to distribute the message to a background server by parsing the message header;
调用模块,用于根据所述消息执行方式和所述消息执行内容调用所述后台服务器中的应用。The calling module is used to call the application in the background server according to the message execution mode and the message execution content.
本发明实施例提供的资费处理方法及装置,通过中间件前后台数据交互和前后调用后台应用,使得该中间件能够灵活扩展前后台应用,资费的配置和测试主要通过前后台和该中间件实现,无需人工参与,提高了资费的配置和验证效率。The tariff processing method and device provided by the embodiments of the present invention enable the middleware to flexibly expand the front-end and background applications through the front-end and back-end data interaction of the middleware and the back-end and back-end calls. , without manual participation, which improves the efficiency of tariff configuration and verification.
附图说明Description of drawings
图1为本发明实施例提供的资费处理方法流程图;FIG. 1 is a flow chart of a tariff processing method provided by an embodiment of the present invention;
图2为本发明实施例提供的资费配置流程图;FIG. 2 is a flow chart of tariff configuration provided by an embodiment of the present invention;
图3为本发明实施例提供的资费验证流程图;Fig. 3 is the tariff verification flow chart that the embodiment of the present invention provides;
图4为本发明实施例提供的系统的技术流程验证流程图;Fig. 4 is a flow chart of technical process verification of the system provided by the embodiment of the present invention;
图5为本发明实施例提供的资费验证平台的示意图;FIG. 5 is a schematic diagram of a tariff verification platform provided by an embodiment of the present invention;
图6为本发明实施例提供的中间件的示意图;FIG. 6 is a schematic diagram of middleware provided by an embodiment of the present invention;
图7为本发明实施例提供的资费处理装置的结构图;FIG. 7 is a structural diagram of a tariff processing device provided by an embodiment of the present invention;
图8为本发明另一实施例提供的资费处理装置的结构图;Fig. 8 is a structural diagram of a tariff processing device provided by another embodiment of the present invention;
图9为本发明实施例提供的通信系统的结构图。FIG. 9 is a structural diagram of a communication system provided by an embodiment of the present invention.
具体实施方式Detailed ways
终端设备例如移动终端已经成为人们日常生活中不可或缺的通信工具,用户可以通过移动终端进行语音通话、短信收发。通常情况下,移动终端需要与通信运营商的网络侧设备通讯连接,也就是说,移动终端需要连接到通信运营商网络才能够实现其通讯的功能。在移动终端入网之前,用户通常需要选定一款通信业务套餐,该通信业务套餐规定了该移动终端的消费标准。每个套餐有一定的套餐费用,每个套餐限定了移动终端可使用的资源,在不超出移动终端可使用的资源范围时,不会产生额外的费用。Terminal devices such as mobile terminals have become an indispensable communication tool in people's daily life, and users can make voice calls and send and receive short messages through the mobile terminals. Usually, the mobile terminal needs to communicate with the network side equipment of the communication operator, that is, the mobile terminal needs to be connected to the network of the communication operator to realize its communication function. Before the mobile terminal accesses the network, the user usually needs to select a communication service package, which specifies the consumption standard of the mobile terminal. Each package has a certain package fee, and each package limits the resources that the mobile terminal can use, and no additional fees will be generated when it does not exceed the range of resources that the mobile terminal can use.
用户可以通过移动终端、营业厅的设备查询资费信息,或者,用户还可以通过登录通信运营商服务器的方式查询资费信息。对于通信运营商的网络侧设备而言,可能要处理大量的资费请求,随着市场多样化资费套餐的需求爆发式增长,大量新增资费和套餐被推出。伴随而来的可能是大量的资费配置和验证需求,以及如何满足快速而又准确的完成资费配置和验证的需求,或对资费的查询需求,现有技术中,资费配置内容为几百条ORACLE数据库表的DML操作语句,资费验证内容为几百个覆盖不同场景的测试话单,现有技术中,资费的配置和测试主要是人工使用VB、EXCEL、ORACLE简单技术进行手工配置验证,从而降低了资费的配置和验证效率。为了解决该问题,本实施例提供了一种资费处理方法,下面结合具体的实施例对该资费处理方法进行详细介绍。The user can inquire about the tariff information through the mobile terminal or the equipment in the business hall, or the user can also inquire about the tariff information by logging into the communication operator's server. For the network-side equipment of communication operators, it may be necessary to process a large number of tariff requests. With the explosive growth of demand for diversified tariff packages in the market, a large number of new tariffs and packages have been launched. It may be accompanied by a large number of tariff configuration and verification requirements, and how to meet the needs of quickly and accurately completing tariff configuration and verification, or the query requirements for tariffs. In the prior art, the tariff configuration content is hundreds of ORACLE The DML operation statement of the database table, the tariff verification content is hundreds of test bills covering different scenarios. In the prior art, the configuration and testing of tariffs are mainly manually performed using VB, EXCEL, and ORACLE simple techniques for manual configuration verification, thereby reducing It improves the efficiency of tariff configuration and verification. In order to solve this problem, this embodiment provides a tariff processing method, which will be described in detail below in conjunction with specific embodiments.
图1为本发明实施例提供的资费处理方法流程图。本发明实施例针对资费配置内容为几百条ORACLE数据库表的DML操作语句,资费验证内容为几百个覆盖不同场景的测试话单,现有技术中,资费的配置和测试主要是人工使用VB、EXCEL、ORACLE简单技术进行手工配置验证,从而降低了资费的配置和验证效率,提供了资费处理方法,该方法具体步骤如下:Fig. 1 is a flowchart of a tariff processing method provided by an embodiment of the present invention. In the embodiment of the present invention, the tariff configuration content is hundreds of DML operation statements of the ORACLE database table, and the tariff verification content is hundreds of test bills covering different scenarios. In the prior art, the configuration and testing of tariffs are mainly manual use of VB , EXCEL, ORACLE simple technology for manual configuration verification, thereby reducing the efficiency of tariff configuration and verification, and providing a tariff processing method. The specific steps of this method are as follows:
步骤S101、接收前台设备发送的消息。Step S101, receiving a message sent by the foreground device.
在本实施例中,前台设备可以是用户终端,也可以是用于处理资费业务的设备,用户可以在用户终端或资费业务处理设备上进行资费验证操作。可选的,用户终端或资费业务处理设备上安装有应用软件,该应用软件提供有交互界面,用户可以在该交互界面上进行相应的操作,用户终端或资费业务处理设备根据用户的操作识别用户的资费验证操作。In this embodiment, the foreground device may be a user terminal, or a device for processing tariff services, and the user may perform a tariff verification operation on the user terminal or the tariff service processing device. Optionally, application software is installed on the user terminal or the tariff service processing device, and the application software provides an interactive interface, and the user can perform corresponding operations on the interactive interface, and the user terminal or the tariff service processing device identifies the user according to the user's operation tariff verification operation.
当用户终端或资费业务处理设备检测到用户的资费验证操作时,生成相应的消息,具体的,根据用户的资费验证操作从配置表中获取应用程序的名称、应用程序所在的主机信息、以及该应用程序需要执行的方法,通过对消息进行封装得到封装后的内容,可选的,封装后的内容包括消息头(消息内容的md5加密结果)、应用执行方法、消息分发目标主机、消息通信端口。When the user terminal or tariff service processing device detects the user's tariff verification operation, it generates a corresponding message. Specifically, according to the user's tariff verification operation, the name of the application program, the host information where the application program is located, and the The method that the application needs to execute is to obtain the encapsulated content by encapsulating the message. Optionally, the encapsulated content includes the message header (the md5 encryption result of the message content), the application execution method, the message distribution target host, and the message communication port .
步骤S102、将所述消息分解为消息头、消息执行方式、消息执行内容。Step S102, decomposing the message into message header, message execution mode, and message execution content.
消息监听master程序收到有消息发送任务,将调用消息解析程序从任务列表中去读取消息内容,然后获取消息分发目标主机和消息通信端口,然后消息分发模块将消息通过socket通信形式发送应用给所在主机,并从任务列表中监控此任务执行情况,以便是否需要重发(状态失败后,将重发3 次,半小时状态未发生变化,判为未超时任务),master程序同时定时对各agent进行心跳通信(发送的消息仅有消息头,消息内容为空),尝试三次通信不成功,将此agent置为无效。When the message monitoring master program receives a message sending task, it will call the message analysis program to read the message content from the task list, and then obtain the message distribution target host and message communication port, and then the message distribution module will send the message to the application through socket communication The host where the task is located and monitors the execution status of the task from the task list to see if it needs to be resent (after the status fails, it will be resent 3 times, and if the status does not change for half an hour, it will be judged as a non-overtime task). The agent performs heartbeat communication (the message sent is only the message header, and the message content is empty), and the communication is unsuccessful after three attempts, and the agent is set to invalid.
步骤S103、通过对所述消息头进行解析,将所述消息分发给后台服务器。Step S103, distributing the message to the background server by parsing the message header.
应用主机上的消息监听agent应用接收到消息,按照消息格式进行解析,首先根据消息头对消息内容进行md5校验,如果异常则反馈更新消息状态为失败,如果md5校验通过,如果接收到消息头标识为心跳消息,直接回复master消息即可,否则将解析消息从中获取需要调用应用程序名称以及应用执行方法。The message monitoring agent application on the application host receives the message and parses it according to the message format. First, the md5 verification is performed on the message content according to the message header. If it is abnormal, the update message status will be reported as failure. The header is identified as a heartbeat message, and you can directly reply to the master message, otherwise, you need to call the application name and application execution method to obtain the parsed message.
步骤S104、根据所述消息执行方式和所述消息执行内容调用所述后台服务器中的应用。Step S104, calling the application in the background server according to the message execution mode and the message execution content.
消息解析完成后,获取需要调用的应用程序和应用执行方法,然后应用调用模块按照消息中制定的方法调用应用,并更新消息正在执行中,调用模块监控应用执行情况,执行完成后,更新消息状态为处理完成。After the message parsing is completed, obtain the application program and application execution method that needs to be called, and then the application calling module calls the application according to the method specified in the message, and updates that the message is being executed, and the calling module monitors the execution status of the application, and updates the message status after the execution is completed Completed for processing.
本实施例所述的资费处理方法包括资费配置和资费验证两个部分,资费配置由原来的需要配置一系列的DML语句,改变为仅需选择几个参数即可完成配置与发布,资费验证通过模拟用户套餐订购和用户实际使用情况,在短短几分钟之内即可完成资费的验证,确保资费配置的准确性。资费配置用户通过选择资费模板和填充资费类型和包含套餐量即可,应用程序通过模板解析和关键字段映射和编码规则管理,最终形成一套符合资费模型的资费,其次,程序解析资费场景组,用户、样本生成器根据用户样本、话单样本生成测试话单,后台批价、入库程序对话单进行批价入库,然后生成测试结果,前台页面进行展示,最后通过发布流程进行发布,图2所示为资费配置流程图、图3所示为资费验证流程图。The tariff processing method described in this embodiment includes two parts: tariff configuration and tariff verification. The tariff configuration is changed from the original need to configure a series of DML statements to only need to select a few parameters to complete the configuration and release, and the tariff verification is passed. Simulate user package ordering and user actual usage, and complete tariff verification in just a few minutes to ensure the accuracy of tariff configuration. Tariff configuration The user can select a tariff template and fill in the tariff type and included package amount. The application program will finally form a set of tariffs that conform to the tariff model through template analysis, key field mapping and coding rules management. Secondly, the program analyzes the tariff scenario group , the user and the sample generator generate test bills based on user samples and bill samples, background price approval, and warehousing program dialogue sheets are priced and stored, and then test results are generated, displayed on the front page, and finally released through the publishing process. Figure 2 shows the flow chart of tariff configuration, and Figure 3 shows the flow chart of tariff verification.
本实施例所述的方法采用B/S架构,利用Java语言开发,开发工具为Myeclipse6.5,采用Struts和Spring的MVC框架,利用oracle数据库做为数据存储,后台服务器采用tomcat中间件,如图4所示为技术流程实现过程。如图4所示,系统集成实现了用户的统一登陆以及数据同步的功能,在此系统集成操作中还实现了对用户的权限管理,明确不同用户的使用权限; JSF页面设计层,在此使用Struts框架,按需求对JSP页面进行设计,使用的技术有CSS、JavaScript、jQueryEasyUI、Json等技术,利用Form表单,将信息传送到后台,最后将后台返回的数据按规定显示,实现了不同页面之间的跳转;BackingBean处理层,根据前台传送过来的信息,调用相关方法,然后将结果返回到页面进行显示;Service层实现本系统所需要的逻辑功能,调用后台数据库操作的相关方法;数据库操作层设计了数据库连接池,根据不同数据库类型(其中涉及Oracle数据库,Dmdb内存库、快立方内存库)建立不同连接池,实现数据库连接资源共享。The method described in this embodiment adopts B/S framework, utilizes Java language to develop, development tool is Myeclipse6.5, adopts the MVC framework of Struts and Spring, utilizes oracle database as data storage, and background server adopts tomcat middleware, as shown in the figure 4 shows the process of technical process realization. As shown in Figure 4, the system integration realizes the unified login of users and the functions of data synchronization. In this system integration operation, it also realizes the authority management of users and clarifies the use authority of different users; JSF page design layer is used here The Struts framework designs the JSP pages according to the requirements. The technologies used include CSS, JavaScript, jQueryEasyUI, Json and other technologies. The Form is used to transmit the information to the background, and finally the data returned by the background is displayed according to the regulations, realizing the connection between different pages. The jump between; the BackingBean processing layer, according to the information sent by the front desk, calls the relevant methods, and then returns the results to the page for display; the Service layer implements the logical functions required by the system, and calls the relevant methods of the background database operation; database operation Layer design database connection pool, according to different database types (involving Oracle database, Dmdb memory library, fast cube memory library) to establish different connection pools, to achieve database connection resource sharing.
图5为本发明实施例提供的资费验证平台的示意图。资费验证平台分为两大模块,前台功能与后台功能,前后台通信采用了socket技术、前台调用后台脚本的技术、存储过程的调用以及快立方内存数据库接口,后台使用 C++,借助shell脚本实现了话单自动生成功能。Fig. 5 is a schematic diagram of a tariff verification platform provided by an embodiment of the present invention. The tariff verification platform is divided into two modules, the front-end function and the back-end function. The front-end and back-end communication adopts socket technology, the technology of the front-end calling the background script, the calling of the stored procedure, and the Kuaicube memory database interface. The back-end uses C++ and uses shell scripts to realize Bill automatic generation function.
当前台设备接收到用户的资费验证操作时,前台WEB程序调用后台程序例如通过Shell脚本调用后台程序中的话单生成程序,前台WEB程序通过调用后台程序中的话单生成程序之后,生成资费验证生成话单和资费验证下载话单。另外,后台程序还可预先存储有资费验证规则,当前台设备接收到用户的资费验证操作时,后台程序根据资费验证规则自动模拟实际用户订购资费生成用户信息,该用户信息可以包括用户的身份信息、通信业务信息、套餐业务信息、资费信息等。进一步的,后台程序还可将用户信息存储在内存库中。When the foreground device receives the user's tariff verification operation, the foreground WEB program calls the background program, such as calling the bill generation program in the background program through a Shell script, and the foreground WEB program generates a tariff verification after calling the bill generation program in the background program. Bill and tariff verification to download the bill. In addition, the background program can also store tariff verification rules in advance. When the front-end equipment receives the user’s tariff verification operation, the background program automatically simulates the actual user’s order tariff according to the tariff verification rules to generate user information. The user information can include the user’s identity information , communication service information, package service information, tariff information, etc. Further, the background program can also store user information in the memory bank.
另外,资费验证所需元素包括如下至少一种:业务类型、业务属性,业务类型例如漫游类型、长途类型等,业务属性例如各类业务的属性值。根据资费验证规则可以对资费验证所需元素进行任意组合,本实施例不限定具体的组合方式。通过资费验证规则对资费验证所需元素进行任意组合后生成相应场景的用户话单,进一步的,根据生成的相应场景的用户话单模拟用户的实际使用需求,调用批价程序对用户话单进行批价处理得到批价后的处理结果。In addition, the elements required for tariff verification include at least one of the following: service type, service attribute, service type such as roaming type, toll type, etc., and service attribute such as attribute values of various services. The elements required for tariff verification can be combined arbitrarily according to the tariff verification rules, and this embodiment does not limit the specific combination manner. According to the tariff verification rules, the elements required for tariff verification are arbitrarily combined to generate the user bills of the corresponding scenarios, and further, according to the generated user bills of the corresponding scenarios to simulate the actual use needs of the users, call the approval program to process the user bills The batch price process obtains the processing result after the batch price is processed.
进一步的,调用结果验证程序对批价后的处理结果进行解析汇总,以展示按此资费配置处理话单结果,并对资费结果的正确性进行验证。Further, call the result verification program to analyze and summarize the processing results after the price approval, so as to display the results of processing the bills according to this tariff configuration, and verify the correctness of the tariff results.
在本实施例中,前台WEB和后台应用之间设置有消息中间件,如图6所示,后台通信中间件:通过对消息内容和格式进行格式化,分为消息头、消息执行方式、消息执行内容共同组合而成,通过对消息头解析,将消息分发至需要执行任务的主机,并记录消息状态,然后再对消息执行方式进行解析,解析执行方式之后,获取消息执行内容,再根据消息执行方式和消息执行内容调用后台相关应用,因此来实现前后台的数据交互,实现分布式调度;依此实现1个前台和多台后台应用主机进行并发通信。In this embodiment, a message middleware is provided between the foreground WEB and the background application. As shown in FIG. The execution content is combined together. By analyzing the message header, the message is distributed to the host that needs to perform the task, and the message status is recorded, and then the message execution method is analyzed. After the execution method is analyzed, the message execution content is obtained, and then according to the message The execution method and message execution content call the background related applications, so as to realize the data interaction between the front and back, and realize the distributed scheduling; in this way, one foreground and multiple background application hosts can communicate concurrently.
验证话单生成技术:根据验证规则,绩效验证场景,根据验证场景选择验证用户,根据用户和验证场景信息,从相关业务话单样本库中选择样本模板,可以支撑国内、国际话单,语音、流量、短信、彩信、宽带等业务,然后根据验证话单,然后根据前台调用分发规则,进行话单分发至各个验证主机进行验证。Verification bill generation technology: According to the verification rules and performance verification scenarios, the verification user is selected according to the verification scenario, and the sample template is selected from the relevant business bill sample database according to the user and verification scene information, which can support domestic and international bills, voice, Traffic, SMS, MMS, broadband and other services, and then according to the verification bill, and then according to the foreground call distribution rules, the bill is distributed to each verification host for verification.
本发明实施例通过中间件前后台数据交互和前后调用后台应用,使得该中间件能够灵活扩展前后台应用,资费的配置和测试主要通过前后台和该中间件实现,无需人工参与,提高了资费的配置和验证效率。The embodiment of the present invention enables the middleware to flexibly expand the front-end and back-end applications through the data interaction between the front-end and back-end of the middleware and the front-end and back-end calls. configuration and verification efficiency.
图7为本发明实施例提供的资费处理装置的结构图。本发明实施例提供的资费处理装置可以执行资费处理方法实施例提供的处理流程,如图7所示,资费处理装置70包括:接收模块71、分解模块72、发送模块73、调用模块74;接收模块71用于接收前台设备发送的消息;分解模块72用于将所述消息分解为消息头、消息执行方式、消息执行内容;发送模块73用于通过对所述消息头进行解析,将所述消息分发给后台服务器;调用模块74用于根据所述消息执行方式和所述消息执行内容调用所述后台服务器中的应用。Fig. 7 is a structural diagram of a tariff processing device provided by an embodiment of the present invention. The tariff processing device provided by the embodiment of the present invention can execute the processing flow provided by the embodiment of the tariff processing method. As shown in FIG. Module 71 is used to receive the message sent by the foreground device; Decomposition module 72 is used to decompose the message into message header, message execution mode, message execution content; Sending module 73 is used to parse the message header, the The message is distributed to the background server; the calling module 74 is used to call the application in the background server according to the message execution mode and the message execution content.
在本实施例中,前台设备可以是用户终端,也可以是用于处理资费业务的设备,用户可以在用户终端或资费业务处理设备上进行资费验证操作。可选的,用户终端或资费业务处理设备上安装有应用软件,该应用软件提供有交互界面,用户可以在该交互界面上进行相应的操作,用户终端或资费业务处理设备根据用户的操作识别用户的资费验证操作。当用户终端或资费业务处理设备检测到用户的资费验证操作时,生成相应的消息,具体的,根据用户的资费验证操作从配置表中获取应用程序的名称、应用程序所在的主机信息、以及该应用程序需要执行的方法,通过对消息进行封装得到封装后的内容,可选的,封装后的内容包括消息头(消息内容的md5加密结果)、应用执行方法、消息分发目标主机、消息通信端口。In this embodiment, the foreground device may be a user terminal, or a device for processing tariff services, and the user may perform a tariff verification operation on the user terminal or the tariff service processing device. Optionally, application software is installed on the user terminal or the tariff service processing device, and the application software provides an interactive interface, and the user can perform corresponding operations on the interactive interface, and the user terminal or the tariff service processing device identifies the user according to the user's operation tariff verification operation. When the user terminal or tariff service processing device detects the user's tariff verification operation, it generates a corresponding message. Specifically, according to the user's tariff verification operation, the name of the application program, the host information where the application program is located, and the The method that the application needs to execute is to obtain the encapsulated content by encapsulating the message. Optionally, the encapsulated content includes the message header (the md5 encryption result of the message content), the application execution method, the message distribution target host, and the message communication port .
消息监听master程序收到有消息发送任务,将调用消息解析程序从任务列表中去读取消息内容,然后获取消息分发目标主机和消息通信端口,然后消息分发模块将消息通过socket通信形式发送应用给所在主机,并从任务列表中监控此任务执行情况,以便是否需要重发(状态失败后,将重发3 次,半小时状态未发生变化,判为未超时任务),master程序同时定时对各 agent进行心跳通信(发送的消息仅有消息头,消息内容为空),尝试三次通信不成功,将此agent置为无效。When the message monitoring master program receives a message sending task, it will call the message analysis program to read the message content from the task list, and then obtain the message distribution target host and message communication port, and then the message distribution module will send the message to the application through socket communication The host where the task is located and monitors the execution status of the task from the task list to see if it needs to be resent (after the status fails, it will be resent 3 times, and if the status does not change for half an hour, it will be judged as a non-overtime task). The agent performs heartbeat communication (the message sent is only the message header, and the message content is empty), and the communication is unsuccessful after three attempts, and the agent is set to invalid.
应用主机上的消息监听agent应用接收到消息,按照消息格式进行解析,首先根据消息头对消息内容进行md5校验,如果异常则反馈更新消息状态为失败,如果md5校验通过,如果接收到消息头标识为心跳消息,直接回复master消息即可,否则将解析消息从中获取需要调用应用程序名称以及应用执行方法。The message monitoring agent application on the application host receives the message and parses it according to the message format. First, the md5 verification is performed on the message content according to the message header. If it is abnormal, the update message status will be reported as failure. The header is identified as a heartbeat message, and you can directly reply to the master message, otherwise, you need to call the application name and application execution method to obtain the parsed message.
消息解析完成后,获取需要调用的应用程序和应用执行方法,然后应用调用模块按照消息中制定的方法调用应用,并更新消息正在执行中,调用模块监控应用执行情况,执行完成后,更新消息状态为处理完成。After the message parsing is completed, obtain the application program and application execution method that needs to be called, and then the application calling module calls the application according to the method specified in the message, and updates that the message is being executed, and the calling module monitors the execution status of the application, and updates the message status after the execution is completed Completed for processing.
本实施例所述的资费处理方法包括资费配置和资费验证两个部分,资费配置由原来的需要配置一系列的DML语句,改变为仅需选择几个参数即可完成配置与发布,资费验证通过模拟用户套餐订购和用户实际使用情况,在短短几分钟之内即可完成资费的验证,确保资费配置的准确性。资费配置用户通过选择资费模板和填充资费类型和包含套餐量即可,应用程序通过模板解析和关键字段映射和编码规则管理,最终形成一套符合资费模型的资费,其次,程序解析资费场景组,用户、样本生成器根据用户样本、话单样本生成测试话单,后台批价、入库程序对话单进行批价入库,然后生成测试结果,前台页面进行展示,最后通过发布流程进行发布,图2所示为资费配置流程图、图3所示为资费验证流程图。The tariff processing method described in this embodiment includes two parts: tariff configuration and tariff verification. The tariff configuration is changed from the original need to configure a series of DML statements to only need to select a few parameters to complete the configuration and release, and the tariff verification is passed. Simulate user package ordering and user actual usage, and complete tariff verification in just a few minutes to ensure the accuracy of tariff configuration. Tariff configuration The user can select a tariff template and fill in the tariff type and included package amount. The application program will finally form a set of tariffs that conform to the tariff model through template analysis, key field mapping and coding rules management. Secondly, the program analyzes the tariff scenario group , the user and the sample generator generate test bills based on user samples and bill samples, background price approval, and warehousing program dialogue sheets are priced and stored, and then test results are generated, displayed on the front page, and finally released through the publishing process. Figure 2 shows the flow chart of tariff configuration, and Figure 3 shows the flow chart of tariff verification.
本实施例所述的方法采用B/S架构,利用Java语言开发,开发工具为Myeclipse6.5,采用Struts和Spring的MVC框架,利用oracle数据库做为数据存储,后台服务器采用tomcat中间件,如图4所示为技术流程实现过程。如图4所示,系统集成实现了用户的统一登陆以及数据同步的功能,在此系统集成操作中还实现了对用户的权限管理,明确不同用户的使用权限; JSF页面设计层,在此使用Struts框架,按需求对JSP页面进行设计,使用的技术有CSS、JavaScript、jQueryEasyUI、Json等技术,利用Form表单,将信息传送到后台,最后将后台返回的数据按规定显示,实现了不同页面之间的跳转;BackingBean处理层,根据前台传送过来的信息,调用相关方法,然后将结果返回到页面进行显示;Service层实现本系统所需要的逻辑功能,调用后台数据库操作的相关方法;数据库操作层设计了数据库连接池,根据不同数据库类型(其中涉及Oracle数据库,Dmdb内存库、快立方内存库)建立不同连接池,实现数据库连接资源共享。The method described in this embodiment adopts B/S framework, utilizes Java language to develop, development tool is Myeclipse6.5, adopts the MVC framework of Struts and Spring, utilizes oracle database as data storage, and background server adopts tomcat middleware, as shown in the figure 4 shows the process of technical process realization. As shown in Figure 4, the system integration realizes the unified login of users and the functions of data synchronization. In this system integration operation, it also realizes the authority management of users and clarifies the use authority of different users; JSF page design layer is used here The Struts framework designs the JSP pages according to the requirements. The technologies used include CSS, JavaScript, jQueryEasyUI, Json and other technologies. The Form is used to transmit the information to the background, and finally the data returned by the background is displayed according to the regulations, realizing the connection between different pages. The jump between; the BackingBean processing layer, according to the information sent by the front desk, calls the relevant methods, and then returns the results to the page for display; the Service layer implements the logical functions required by the system, and calls the relevant methods of the background database operation; database operation Layer design database connection pool, according to different database types (involving Oracle database, Dmdb memory library, fast cube memory library) to establish different connection pools, to achieve database connection resource sharing.
本发明实施例提供的资费处理装置可以具体用于执行上述图1所提供的方法实施例,具体功能此处不再赘述。The tariff processing device provided in the embodiment of the present invention can be specifically used to execute the method embodiment provided in FIG. 1 above, and the specific functions will not be repeated here.
本发明实施例通过中间件前后台数据交互和前后调用后台应用,使得该中间件能够灵活扩展前后台应用,资费的配置和测试主要通过前后台和该中间件实现,无需人工参与,提高了资费的配置和验证效率。The embodiment of the present invention enables the middleware to flexibly expand the front-end and back-end applications through the data interaction between the front-end and back-end of the middleware and the front-end and back-end calls. configuration and verification efficiency.
图8为本发明另一实施例提供的资费处理装置的结构图。在上述实施例的基础上,资费处理装置70还包括:记录模块75,用于记录所述消息的状态信息。Fig. 8 is a structural diagram of a tariff processing device provided by another embodiment of the present invention. On the basis of the above embodiments, the tariff processing device 70 further includes: a recording module 75, configured to record the state information of the message.
另外,资费处理装置70还包括:解析模块76,用于对所述消息执行方式进行解析。In addition, the tariff processing device 70 further includes: an analysis module 76, configured to analyze the message execution mode.
此外,资费处理装置70还包括:获取模块77,获取模块77用于根据验证场景信息,从业务话单样本库中获取样本模板。In addition, the tariff processing device 70 also includes: an acquisition module 77, which is used to acquire a sample template from the service bill sample database according to the verification scenario information.
在一些实施例中,资费处理装置70还包括:生成模块78,生成模块78 用于根据所述样本模板生成验证话单;发送模块73还用于:将所述验证话单发送给多个验证主机进行验证。In some embodiments, the tariff processing device 70 also includes: a generation module 78, which is used to generate a verification bill according to the sample template; the sending module 73 is also used to: send the verification bill to multiple verification The host is authenticated.
本发明实施例提供的资费处理装置可以具体用于执行上述图2-6所提供的方法实施例,具体功能此处不再赘述。The tariff processing device provided by the embodiment of the present invention can be specifically used to execute the method embodiments provided in the above-mentioned FIGS. 2-6 , and the specific functions will not be repeated here.
本发明实施例通过中间件前后台数据交互和前后调用后台应用,使得该中间件能够灵活扩展前后台应用,资费的配置和测试主要通过前后台和该中间件实现,无需人工参与,提高了资费的配置和验证效率。The embodiment of the present invention enables the middleware to flexibly expand the front-end and back-end applications through the data interaction between the front-end and back-end of the middleware and the front-end and back-end calls. configuration and verification efficiency.
综上所述,本发明实施例通过中间件前后台数据交互和前后调用后台应用,使得该中间件能够灵活扩展前后台应用,资费的配置和测试主要通过前后台和该中间件实现,无需人工参与,提高了资费的配置和验证效率。In summary, the embodiment of the present invention enables the middleware to flexibly expand the front-end and back-end applications through the data interaction between the front-end and back-end of the middleware and the back-end and back-end calls. Participation improves the efficiency of tariff configuration and verification.
另外,本发明提供的资费处理方法,可以适用于图9所示的通信系统。如图9所示,该通信系统包括:接入网设备91以及终端设备92。需要说明的是,图9所示的通信系统可以适用于不同的网络制式,例如,可以适用于全球移动通讯(Global System of Mobilecommunication,简称GSM)、码分多址(Code Division Multiple Access,简称CDMA)、宽带码分多址 (Wideband Code Division Multiple Access,简称WCDMA)、时分同步码分多址(Time Division-Synchronous Code Division Multiple Access,简称TD-SCDMA)、长期演进(Long Term Evolution,简称LTE)系统及未来的 5G等网络制式。可选的,上述通信系统可以为5G通信系统中高可靠低时延通信(Ultra-Reliable and Low LatencyCommunications,简称URLLC) 传输的场景中的系统。In addition, the tariff processing method provided by the present invention can be applied to the communication system shown in FIG. 9 . As shown in FIG. 9 , the communication system includes: an access network device 91 and a terminal device 92 . It should be noted that the communication system shown in FIG. 9 can be applied to different network standards, for example, can be applied to Global System of Mobile Communication (GSM for short), Code Division Multiple Access (Code Division Multiple Access, CDMA for short). ), Wideband Code Division Multiple Access (WCDMA for short), Time Division-Synchronous Code Division Multiple Access (TD-SCDMA for short), Long Term Evolution (LTE for short) system and future network standards such as 5G. Optionally, the foregoing communication system may be a system in a scenario of Ultra-Reliable and Low Latency Communications (URLLC for short) transmission in a 5G communication system.
故而,可选的,上述接入网设备91可以是GSM或CDMA中的基站(Base TransceiverStation,简称BTS)和/或基站控制器,也可以是WCDMA中的基站(NodeB,简称NB)和/或无线网络控制器(Radio Network Controller,简称RNC),还可以是LTE中的演进型基站(Evolutional Node B,简称eNB 或eNodeB),或者中继站或接入点,或者未来5G网络中的基站(gNB)等,本发明在此并不限定。Therefore, optionally, the above-mentioned access network device 91 may be a base station (Base TransceiverStation, referred to as BTS) and/or a base station controller in GSM or CDMA, or may be a base station (NodeB, referred to as NB) in WCDMA and/or The radio network controller (Radio Network Controller, referred to as RNC), can also be an evolved base station (Evolutional Node B, referred to as eNB or eNodeB) in LTE, or a relay station or access point, or a base station (gNB) in the future 5G network etc., the present invention is not limited here.
上述终端设备92可以是无线终端也可以是有线终端。无线终端可以是指向用户提供语音和/或其他业务数据连通性的设备,具有无线连接功能的手持式设备、或连接到无线调制解调器的其他处理设备。无线终端可以经无线接入网(Radio Access Network,简称RAN)与一个或多个核心网设备进行通信,无线终端可以是移动终端,如移动电话(或称为“蜂窝”电话)和具有移动终端的计算机,例如,可以是便携式、袖珍式、手持式、计算机内置的或者车载的移动装置,它们与无线接入网交换语言和/或数据。再例如,无线终端还可以是个人通信业务(Personal Communication Service,简称PCS)电话、无绳电话、会话发起协议(Session Initiation Protocol,简称SIP)话机、无线本地环路(Wireless LocalLoop,简称WLL)站、个人数字助理(Personal Digital Assistant,简称PDA)等设备。无线终端也可以称为系统、订户单元(Subscriber Unit)、订户站(Subscriber Station),移动站(Mobile Station)、移动台(Mobile)、远程站(Remote Station)、远程终端(RemoteTerminal)、接入终端(Access Terminal)、用户终端(User Terminal)、用户代理(UserAgent)、用户设备(User Device or User Equipment),在此不作限定。可选的,上述终端设备92还可以是智能手表、平板电脑等设备。The above-mentioned terminal device 92 may be a wireless terminal or a wired terminal. A wireless terminal may be a device that provides voice and/or other business data connectivity to a user, a handheld device with a wireless connection function, or other processing device connected to a wireless modem. The wireless terminal can communicate with one or more core network devices via the radio access network (Radio Access Network, referred to as RAN), and the wireless terminal can be a mobile terminal, such as a mobile phone (or called a "cellular" phone) and a The computers, which may be, for example, portable, pocket, handheld, built-in or vehicle-mounted mobile devices, exchange speech and/or data with the radio access network. For another example, the wireless terminal may also be a Personal Communication Service (PCS for short) phone, a cordless phone, a Session Initiation Protocol (SIP for short) phone, a Wireless Local Loop (WLL for short) station, Personal digital assistant (Personal Digital Assistant, referred to as PDA) and other devices. Wireless terminal can also be called system, subscriber unit (Subscriber Unit), subscriber station (Subscriber Station), mobile station (Mobile Station), mobile station (Mobile), remote station (Remote Station), remote terminal (RemoteTerminal), access A terminal (Access Terminal), a user terminal (User Terminal), a user agent (UserAgent), and a user device (User Device or User Equipment) are not limited herein. Optionally, the above-mentioned terminal device 92 may also be a device such as a smart watch or a tablet computer.
在本发明所提供的几个实施例中,应该理解到,所揭露的装置和方法,可以通过其它的方式实现。例如,以上所描述的装置实施例仅仅是示意性的,例如,所述单元的划分,仅仅为一种逻辑功能划分,实际实现时可以有另外的划分方式,例如多个单元或组件可以结合或者可以集成到另一个系统,或一些特征可以忽略,或不执行。另一点,所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口,装置或单元的间接耦合或通信连接,可以是电性,机械或其它的形式。In the several embodiments provided by the present invention, it should be understood that the disclosed devices and methods can be implemented in other ways. For example, the device embodiments described above are only illustrative. For example, the division of the units is only a logical function division. In actual implementation, there may be other division methods. For example, multiple units or components can be combined or May be integrated into another system, or some features may be ignored, or not implemented. In another point, the mutual coupling or direct coupling or communication connection shown or discussed may be through some interfaces, and the indirect coupling or communication connection of devices or units may be in electrical, mechanical or other forms.
所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。The units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in one place, or may be distributed to multiple network units. Part or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.
另外,在本发明各个实施例中的各功能单元可以集成在一个处理单元中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现,也可以采用硬件加软件功能单元的形式实现。In addition, each functional unit in each embodiment of the present invention may be integrated into one processing unit, each unit may exist separately physically, or two or more units may be integrated into one unit. The above-mentioned integrated units can be implemented in the form of hardware, or in the form of hardware plus software functional units.
上述以软件功能单元的形式实现的集成的单元,可以存储在一个计算机可读取存储介质中。上述软件功能单元存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等) 或处理器(processor)执行本发明各个实施例所述方法的部分步骤。而前述的存储介质包括:U盘、移动硬盘、只读存储器(Read-Only Memory,ROM)、随机存取存储器(Random Access Memory,RAM)、磁碟或者光盘等各种可以存储程序代码的介质。The above-mentioned integrated units implemented in the form of software functional units may be stored in a computer-readable storage medium. The above-mentioned software functional units are stored in a storage medium, and include several instructions to enable a computer device (which may be a personal computer, server, or network device, etc.) or a processor (processor) to execute the methods described in various embodiments of the present invention. partial steps. The aforementioned storage medium includes: U disk, mobile hard disk, read-only memory (Read-Only Memory, ROM), random access memory (Random Access Memory, RAM), magnetic disk or optical disk and other various media that can store program codes. .
本领域技术人员可以清楚地了解到,为描述的方便和简洁,仅以上述各功能模块的划分进行举例说明,实际应用中,可以根据需要而将上述功能分配由不同的功能模块完成,即将装置的内部结构划分成不同的功能模块,以完成以上描述的全部或者部分功能。上述描述的装置的具体工作过程,可以参考前述方法实施例中的对应过程,在此不再赘述。Those skilled in the art can clearly understand that for the convenience and brevity of description, only the division of the above-mentioned functional modules is used as an example for illustration. The internal structure of the system is divided into different functional modules to complete all or part of the functions described above. For the specific working process of the device described above, reference may be made to the corresponding process in the foregoing method embodiments, and details are not repeated here.
最后应说明的是:以上各实施例仅用以说明本发明的技术方案,而非对其限制;尽管参照前述各实施例对本发明进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分或者全部技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本发明各实施例技术方案的范围。Finally, it should be noted that: the above embodiments are only used to illustrate the technical solutions of the present invention, rather than limiting them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: It is still possible to modify the technical solutions described in the foregoing embodiments, or perform equivalent replacements for some or all of the technical features; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the technical solutions of the various embodiments of the present invention. scope.
Claims (6)
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201710995125.6A CN107769934B (en) | 2017-10-23 | 2017-10-23 | Rate processing method and processing device |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201710995125.6A CN107769934B (en) | 2017-10-23 | 2017-10-23 | Rate processing method and processing device |
Publications (2)
Publication Number | Publication Date |
---|---|
CN107769934A CN107769934A (en) | 2018-03-06 |
CN107769934B true CN107769934B (en) | 2019-09-10 |
Family
ID=61269253
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201710995125.6A Active CN107769934B (en) | 2017-10-23 | 2017-10-23 | Rate processing method and processing device |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN107769934B (en) |
Families Citing this family (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN111476016A (en) * | 2020-04-15 | 2020-07-31 | 北京思特奇信息技术股份有限公司 | Template configuration method for package tariff in telecommunication industry |
CN112132645B (en) * | 2020-08-26 | 2022-05-17 | 北京思特奇信息技术股份有限公司 | Method and system for verifying similar elements of tariff configuration template |
CN113378037B (en) * | 2020-09-10 | 2023-05-30 | 中国联合网络通信集团有限公司 | Tariff configuration acquisition method and tariff configuration acquisition device |
Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1744646A (en) * | 2004-08-30 | 2006-03-08 | 华为技术有限公司 | System and method for providing recharge payment service in telecommunication network |
CN101466109A (en) * | 2009-01-14 | 2009-06-24 | 北京邮电大学 | Communication system and method for WiMAX network management |
CN105930460A (en) * | 2016-04-21 | 2016-09-07 | 重庆邮电大学 | Multi-algorithm-integrated big data analysis middleware platform |
Family Cites Families (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US6999449B2 (en) * | 2000-08-18 | 2006-02-14 | Telefonaktiebolaget Lm Ericsson (Publ) | System and method of monitoring and reporting accounting data based on volume |
-
2017
- 2017-10-23 CN CN201710995125.6A patent/CN107769934B/en active Active
Patent Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN1744646A (en) * | 2004-08-30 | 2006-03-08 | 华为技术有限公司 | System and method for providing recharge payment service in telecommunication network |
CN101466109A (en) * | 2009-01-14 | 2009-06-24 | 北京邮电大学 | Communication system and method for WiMAX network management |
CN105930460A (en) * | 2016-04-21 | 2016-09-07 | 重庆邮电大学 | Multi-algorithm-integrated big data analysis middleware platform |
Also Published As
Publication number | Publication date |
---|---|
CN107769934A (en) | 2018-03-06 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN107769934B (en) | Rate processing method and processing device | |
CN108173915A (en) | Call chain processing method and device | |
CN101384086A (en) | Method, device and system for configuring network equipment | |
CN104935744A (en) | Verification code display method, verification code display device and mobile terminal | |
CN101695164A (en) | Verification method, device and system for controlling resource access | |
EP2955947B1 (en) | Processing of preferred roaming lists | |
CA2824705A1 (en) | Communications network, computer architecture, computer-implemented method and computer program product for development and management of femtocell-based applications | |
CN109783357A (en) | The method and device of test application program, computer equipment, storage medium | |
CN101384061A (en) | Systems and methods for mobile phone validation | |
CN111294798A (en) | A method, apparatus, terminal device and medium for data interaction | |
CN101984717B (en) | A kind of method of data synchronization, mobile terminal and data synchronous system | |
WO2023134312A1 (en) | Content charging test method, management device, terminal device and storage medium | |
CN102446308A (en) | Telecom product releasing method and service management subsystem | |
CN116112943B (en) | A simulation communication system and its deployment method, and a simulation communication test method | |
CN104125622B (en) | A kind of collocation method, equipment and system for accessing standard | |
CN104581744B (en) | A kind of method and device for realizing the network planning | |
CN102256241B (en) | Method, server and intelligent card for acquiring bearer independent protocol (BIP) information of terminal | |
EP2982185B1 (en) | Soft activation of cellular modems in tablets | |
CN105988814A (en) | Interface generation method and apparatus | |
CN115988438A (en) | Call service data processing method, device, equipment and storage medium | |
AU2014411891B2 (en) | Charging control apparatus, method, and system | |
CN108632088A (en) | Method for processing business, device and server | |
WO2023169097A1 (en) | 5g message terminal identification method, service platform and storage medium | |
CN111225389B (en) | Method and device for mobile data traffic processing | |
CN106211128B (en) | Method and device for generating WLAN access state event |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination | ||
GR01 | Patent grant | ||
GR01 | Patent grant |