CN116012156A - Automatic transaction method, device and readable storage medium - Google Patents
Automatic transaction method, device and readable storage medium Download PDFInfo
- Publication number
- CN116012156A CN116012156A CN202310025757.5A CN202310025757A CN116012156A CN 116012156 A CN116012156 A CN 116012156A CN 202310025757 A CN202310025757 A CN 202310025757A CN 116012156 A CN116012156 A CN 116012156A
- Authority
- CN
- China
- Prior art keywords
- data
- local
- cloud
- local equipment
- information
- 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.)
- Pending
Links
Images
Landscapes
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
The application provides an automated transaction method and system, which are characterized by comprising the following steps: s1, acquiring and analyzing information data of local equipment in real time; s2, sending the analyzed local processing data and configuration information data to a cloud based on the standard Internet of things MQTT and storing the local processing data and the configuration information data; s3, the cloud end predefines a plurality of topics according to the analyzed local processing data and configuration information data; s4, the cloud returns control instruction data based on the theme; s5, receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control conditions of the business process, and executing actions based on the control instruction information if the local equipment meets the control conditions of the business process; s6, the cloud receives and stores operation data generated by the execution action of the local equipment, and updates business flow information of the local equipment stored in the cloud. The invention can solve the break point of the off-line market transaction, and the real-time interaction of all-service links of the market transaction improves the operation management efficiency of the market service and the transaction efficiency.
Description
Technical Field
The present invention relates to the field of internet of things, and in particular, to an automated transaction method, an apparatus, and a readable storage medium.
Background
At present, the informatization development of market trade is lagged, the overall informatization level is low, the market hardware system is disordered, the hardware is in an off-line management mode, the hardware operates independently, the management mode is excessively dependent on personnel, the market trade information management system still belongs to extensive operation management, is uncoordinated with the modern informatization management requirement, and can also face the problem of break points in market trade. The existing market transaction data transmission mainly adopts an HTTP protocol, and the offline hardware customized interface protocol is in butt joint, so that the defects are mainly that the real-time performance is relatively poor, the implementation of automatic transaction is difficult to support, when the real-time performance requirement is high, the real-time performance is often realized in a short-time polling mode, the pressure ratio of a platform is relatively high, the butt joint research and development cost is high, the development of a hardware interface is required to be re-adapted to different hardware, and the method is time-consuming and labor-consuming, and the cost is extremely high.
In order to solve the technical problems, the traditional offline breakpoint transaction mode of the agricultural batch market is solved, the commercial tenant association operation of the market full-volume service platform is realized, the real-time performance of the full-service link market transaction is realized, the operation management efficiency of the agricultural batch market service is comprehensively improved, the docking cost of various software and hardware is greatly reduced, and the working efficiency of the platform is improved. The invention provides an automatic transaction method, an automatic transaction device and a readable storage medium. MQTT is a message transport protocol for the publish-subscribe mode of a client-side architecture. The design concept is light, open, simple and standard, and is easy to realize. These features make it a good choice for many scenarios, including limited environments such as machine-to-machine communication (M2M) and internet of things (IoT), that can greatly reduce transaction costs and improve platform transaction efficiency.
It is worth noting that the data collection and migration actions related to the present application are already agreed by the user and are necessary for the applicant to perform normal operation activities. The collected data applicants are subjected to desensitization treatment such as anonymization and confidentiality, and the access rights of the data are correspondingly set so as to ensure that the privacy of users cannot be revealed. The data processing activities performed by the applicant accord with the rules of laws and regulations such as data security laws and personal information protection laws.
Disclosure of Invention
In order to solve the shortcomings of the prior art, the present invention provides an automated transaction method, an automated transaction device and a readable storage medium.
The first aspect of the present application proposes an automated transaction method, which is characterized by comprising:
s1, acquiring and analyzing information data of local equipment in real time, classifying the analyzed information data, and at least dividing the information data into local processing data and configuration information data, wherein the local processing data comprises control type data and alarm prompt type data, and the configuration information data comprises business logic information and business flow information;
S2, sending the analyzed local processing data and configuration information data to a cloud based on the standard Internet of things MQTT and storing the local processing data and the configuration information data;
s3, the cloud end predefines a plurality of topics according to the analyzed local processing data and configuration information data, wherein the topics are used for providing API interfaces based on a publishing and subscribing mode for the cloud end and the local equipment;
s4, the cloud returns control instruction data based on the theme, wherein the control instruction data comprises business process control data and action control data;
s5, receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control conditions of the business process, and executing actions based on the control instruction information if the local equipment meets the control conditions of the business process;
s6, the cloud receives and stores operation data generated by the execution action of the local equipment, and updates business flow information of the local equipment stored in the cloud.
Further, the method further includes S7:
s71, setting a business process mark for the local equipment, wherein the business process mark is used for recording the action sequences of different transaction processes of the local equipment;
s72, after the first local equipment executes the first action, judging whether the market subject enters a second local equipment area or not based on the business process mark;
S73, if the market main body enters the second local equipment area, the second local equipment executes the second action in real time.
Further, the method further includes S8:
s81, acquiring a unique identification code of the local equipment in real time, wherein the unique identification code comprises a manufacturer identification;
s82, judging whether the unique identification code stored in the cloud is recorded or not, and if not, determining that the local equipment is newly added local equipment;
s83, establishing communication connection between the newly added local equipment and the cloud based on the information transmission protocol information of the newly added local equipment;
and S84, based on the configuration information data of the newly added equipment, the cloud end distributes the newly added equipment to the existing theme and business process.
Further, the method further includes S9:
s91, summarizing transaction information of local equipment, and judging whether a market main body completes all transactions;
s92, if all transactions are not completed by the market subject, reminding the market subject of completing the market transactions;
and S93, after the market main body completes all transactions, the local equipment executes actions based on all completed transaction information.
Further, the method further includes S10:
s101, connecting first intelligent hardware with an Internet of things platform, and sending second control instruction data to local equipment by the first intelligent hardware through a cloud, wherein the first intelligent hardware comprises a mobile phone, a tablet, a computer and an intelligent bracelet;
S102, the local equipment obtains second control instruction information, judges whether the local equipment meets the business process control condition, and executes a second action based on the control instruction information if the local equipment meets the business process control condition.
Further, the step S1 further includes:
s11, collecting a data transmission protocol supported by local equipment, wherein the data transmission protocol comprises a data transmission protocol and a data receiving protocol;
and S12, connecting different data transmission interfaces with the local equipment based on the data transmission protocol, wherein the data transmission interfaces are used for transmitting information data of the local equipment to the cloud.
Further, the step S4 includes:
s41, the cloud terminal selects a second data receiving method based on the local equipment, wherein the second data receiving mode comprises Bluetooth and 4G;
s42, the control instruction data is sent to the local equipment based on the second data receiving method.
A second aspect of the present application proposes an automated transaction apparatus based on MQTT protocol, comprising:
the data acquisition analysis module is used for acquiring and analyzing information data of the local equipment in real time, classifying the analyzed information data, and at least dividing the information data into local processing data and configuration information data, wherein the local processing data comprises control class data and alarm prompt class data, and the configuration information data comprises business logic information and business flow information;
The data transmission module is used for sending the analyzed local processing data and the configuration information data to the cloud and storing the local processing data and the configuration information data based on the standard internet of things MQTT;
the topic definition module is used for predefining a plurality of topics according to the analyzed local processing data and configuration information data by the cloud, and the topics are used for providing API interfaces based on a release subscription mode for the cloud and local equipment;
the control instruction data return module is used for returning control instruction data based on the theme by the cloud, wherein the control instruction data comprise business flow control data and action control data;
the judging and executing module is used for receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control condition of the business process, and executing actions based on the control instruction information if the local equipment meets the control condition of the business process;
the flow updating module is used for receiving and storing operation data generated by the execution action of the local equipment by the cloud, and updating the business flow information of the local equipment stored by the cloud.
A third aspect of the present application proposes an electronic device, characterized by comprising: a processor, and a memory communicatively coupled to the processor;
The memory stores computer-executable instructions;
the processor executes the computer-executable instructions stored by the memory to implement the method of automated transaction based on the MQTT protocol described above.
A fourth aspect of the present application proposes a computer-readable storage medium, wherein computer-executable instructions are stored in the computer-readable storage medium, the computer-executable instructions, when executed by a processor, being configured to implement a method for an MQTT protocol-based automated transaction as described above.
A fifth aspect of the present application proposes a computer program product comprising a computer program which, when executed by a processor, implements a method of automated transaction based on the MQTT protocol as described above.
The beneficial effects of the invention are as follows: the invention can solve the defect of the traditional market offline transaction breakpoint, realize the commercial tenant association operation of the market full-volume service platform, newly increase local equipment, realize the real-time interaction of the transaction full-service link, control the whole market transaction through the service flow, reduce the labor cost, comprehensively improve the operation management efficiency of the agricultural batch market service, reduce the docking cost of various software and hardware and improve the working efficiency of the platform.
Drawings
FIG. 1 is a flow chart of a method of automating transactions according to the present invention.
Fig. 2 is a block diagram of an automated transaction apparatus according to the present invention.
Fig. 3 is a block diagram of an automated transaction system according to an embodiment of the present invention.
Fig. 4 is a schematic structural diagram of an electronic device according to an embodiment of the present invention.
Detailed Description
For a clearer understanding of the present invention, reference will be made to the following detailed description taken in conjunction with the accompanying drawings and examples.
It should be understood that the description is only illustrative and is not intended to limit the scope of the invention. In addition, in the following description, descriptions of well-known structures and techniques are omitted so as not to unnecessarily obscure the present invention. The terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the invention. The words "a", "an", and "the" as used herein are also intended to include the meaning of "a plurality", etc., unless the context clearly indicates otherwise. Furthermore, the terms "comprises," "comprising," and the like, as used herein, specify the presence of stated features, steps, operations, and/or components, but do not preclude the presence or addition of one or more other features, steps, operations, or components.
All terms (including technical and scientific terms) used herein have the same meaning as commonly understood by one of ordinary skill in the art unless otherwise defined. It should be noted that the terms used herein should be construed to have meanings consistent with the context of the present specification and should not be construed in an idealized or overly formal manner. The present invention is an improvement over the prior art and is therefore implemented in the prior art for the part not described in this application.
In the existing market transaction, such as wholesale agricultural product market, off-line hardware systems, such as loaders, banners and the like, can only support independent business operation, cannot realize merchant association and business linkage, and needs manual configuration for newly built equipment, so that the problem of business synchronization is solved in a personnel dependent manner. If a wagon balance manager weighs goods, the goods are manually calculated after weighing, and then corresponding transaction actions are performed according to manual calculation results, so that the wagon balance manager is over-heavy in dependence, easy to make mistakes and has a plurality of service break points, and the transaction data of the whole service link cannot be synchronized, so that the online and offline efficiency is low. The existing solution mainly adopts the HTTP protocol, and the offline hardware customized interface protocol is in butt joint, so that the defects are relatively poor in instantaneity, difficult to support and implement automatic transaction, and when the instantaneity requirement is high, the implementation is usually realized by adopting a short-time polling mode, the pressure ratio of a platform is relatively high, the butt joint research and development cost is high, the research and development of a hardware interface is required to be re-adapted to different hardware, and the method is time-consuming and labor-consuming, and the cost is extremely high.
The invention develops a local service system, integrates various local hardware wagon balance, road gate and other systems, and realizes the integrated management of market business by interfacing with a protocol of a hardware system or wirelessly connecting local equipment. The whole butt joint adopts a protocol configuration conversion mode, the butt joint is configured, real-time data is collected, an MQTT protocol is adopted to link a local service system with a cloud platform, the local data is synchronized to the cloud platform in real time by adopting a real-time communication mode, the cloud platform carries out real-time business transaction through the received local data and sends the real-time business transaction to the local system in real time, and further, a local control instruction is synchronized to the local service system, so that the real-time transaction behavior of the local equipment and the cloud platform which are not replaced is completed. The invention realizes the parameter conversion configuration of various software and hardware interface protocols, and the platform can conveniently configure the interface protocol of a third party into the system in a configuration mode without developing codes aiming at specific interface protocols, thereby realizing automatic docking and greatly improving the docking efficiency of software and hardware systems; the optimization of market business management is realized, the management of the distributed wagon balance weighing, the gateway access control and the water ammeter is realized, the unified business integration management integration of platform merchants is realized, all business behaviors of the merchants in the market are better collected and counted, and the market operation management energy efficiency is improved.
FIG. 1 is a flow chart of a method of automating transactions according to the present invention. The first aspect of the present application proposes an automated transaction method, which is characterized by comprising:
s1, acquiring and analyzing information data of local equipment in real time, classifying the analyzed information data, and at least dividing the information data into local processing data and configuration information data, wherein the local processing data comprises control type data and alarm prompt type data, and the configuration information data comprises business logic information and business flow information;
specifically, the local device information data is collected and analyzed to be a local service system, the local service system comprises a hardware server, a cloud server and the like, if the local device supports an internet of things protocol, the local service system can be directly connected with the local device to interact with the data, and if the local device does not support the internet of things protocol, the local service system can be connected with the local device through a hardware interface to collect the local data. The local equipment is not limited to a wagon balance, a barrier gate, a water meter and an intelligent screen, equipment related to market transaction can be included, the main function of the local equipment is to collect change information of the market transaction, the action is executed based on a cloud control instruction, the cloud instruction can be preset on a cloud platform, and the local equipment can be controlled through intelligent hardware such as a mobile phone. If the road gate can identify vehicle information, if the vehicle main body pays parking fee or is a person in the market, the vehicle can be directed, the water meter is used for counting water consumption information of merchants, the water meter information is updated based on payment of the merchants, and the local equipment can also accumulate transaction information of the market main body for a period of time, such as one day and one week, so that the market main body pays based on the transaction information.
Further, the step S1 includes:
s11, collecting a data transmission protocol supported by local equipment, wherein the data transmission protocol comprises a data transmission protocol and a data receiving protocol;
and S12, connecting different data transmission interfaces with the local equipment based on the data transmission protocol, wherein the data transmission interfaces are used for transmitting information data of the local equipment to the cloud.
Specifically, the local service system is directly connected with the local device based on the hardware interface, the local device transmits data to the local service system, monitors the local device in a protocol configuration mode, if the data format of the local device cannot be transmitted based on the MQTT protocol, the device can be added to convert the data of the local device, and similarly, if the local device supports a wireless mode, the device can also wirelessly transmit the data to the local service system. The local service system monitors and collects local data.
Optionally, one or more CoAP plug-ins, BACnet plug-ins, OPC plug-ins, modBus plug-ins, and JT808 plug-ins may be deployed in the data acquisition end module.
CoAP refers to constrained application protocol (Constrained Application Protocol, coAP). CoAP is a specialized network transport protocol for constrained nodes and constrained networks in the internet of things. The protocol design may be used for machine-to-machine (M2M) applications such as intelligent energy and building automation.
BACnet refers to a building automation network data communication protocol (A Data Communication Protocol for Building Automation and Control Networks, BACnet), a building automation and control network specific protocol implemented for embedded systems.
OPC refers to the OLE (Object Linking and Embedding ) protocol for process control, english, collectively Object Linking and Embedding (OLE) for Process Control, the advent of which has bridged Windows-based applications and field process control applications.
ModBus was invented by Modicon (now a brand of Schneider electric company) in 1979, and was the first bus protocol truly used in the industrial field worldwide. The ModBus network is an industrial communication system, which is formed by connecting a programmable controller with an intelligent terminal and a computer through a public line or a local private line. The system structure comprises hardware and software. It can be used for various data acquisition and process monitoring.
JT808 represents JT/T808 protocols issued by the traffic segment. The acquisition end module can acquire data for various different types of sensing equipment by using the various plug-ins deployed by the acquisition end module.
S2, sending the analyzed local processing data and configuration information data to a cloud based on the standard Internet of things MQTT and storing the local processing data and the configuration information data;
specifically, for different data transmission forms of the local equipment, since the data monitored by the hardware interface can be directly sent to the internet of things platform in the form of the MQTT protocol, if the local equipment is connected with the local service system in a wireless mode, if the data sent by the local equipment does not support the MQTT protocol, the local data can be converted into the data form supported by the MQTT protocol, and then the local service system sends the local data to the internet of things platform.
S3, the cloud end predefines a plurality of topics according to the analyzed local processing data and configuration information data, wherein the topics are used for providing API interfaces based on a publishing and subscribing mode for the cloud end and the local equipment;
specifically, the local device can execute different services, different local devices also need different data transmission protocols, the local device is divided into a plurality of topics to perform unified management, and the local device is divided into a plurality of topics because the local device adopts a mode based on an MQTT protocol to perform data transmission, for example, a weighing and charging flow, an interface can be set for transmitting data of the whole flow of weighing and charging, and an interface can be set for transmitting data supporting the MQTT independently.
S4, the cloud returns control instruction data based on the theme, wherein the control instruction data comprises business process control data and action control data;
further, the step S4 includes:
s41, the cloud terminal selects a second data receiving method based on the local equipment, wherein the second data receiving mode comprises Bluetooth and 4G;
s42, the control instruction data is sent to the local equipment based on the second data receiving method.
Specifically, the cloud comprises an internet of things platform and a cloud service platform, the cloud sends control instruction data to a local service system through an interface according to a predefined theme, and the local service system sends the control instruction data to local equipment to execute actions. Since it is not necessary to base the MQTT protocol during the transmission of the control instructions to the local device, the control instruction information may be transmitted in a manner different from the MQTT protocol at this time. The manner in which the local service system transmits the feedback data is not limited to one, and the manner in which the feedback data is transmitted may be selected for configuration when the local device information is collected. After receiving feedback information of the cloud service platform, the local equipment can execute different actions, such as calculating weight change on the wagon balance and the like.
In some embodiments of the present invention, based on the complex field situation, different requirements on transmission distance and transmission speed are selected, and communication modes of Wifi, 4G, bluetooth (bluetooth), zigBee, lora and the like can be mainly adopted for communication of different devices in the system by selecting different wireless internet of things access technologies.
Lora: in the environment temperature and humidity inspection process, as the cellular network is not covered, the nodes and the gateway are deployed based on the lora transmission mode, and the environment parameters of the sensing equipment can be uploaded to the cloud platform.
ZigBee: the ZigBee wireless transmission module can be added on the lamplight equipment to transmit data to the edge gateway and upload the data to the cloud platform through the cable and the switch. That is, a ZigBee module may be added to the light device as a sensing device to upload data of the light device.
Bluetooth: the Bluetooth of the mobile phone is connected with the ibeacon to locate the mobile phone, and then the locating information is sent to the background through the mobile phone to locate the mobile phone. That is, for the internet of things devices such as the mobile phone, the ibeacon module can be deployed to cooperate with the mobile phone as a sensing device to instruct the mobile phone to upload positioning information.
4G: for the scene that the field environment is complex and the gateway is difficult to lay, 4G is a good selection mode, and the connection with the base station of an operator is realized by adding the eSIM card.
S5, receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control conditions of the business process, and executing actions based on the control instruction information if the local equipment meets the control conditions of the business process;
according to the method, different transaction flows are designed aiming at different local equipment, such as a transaction flow for transporting agricultural products, the first step is to collect vehicle information, the vehicle firstly needs to enter and exit a barrier gate, the second step is to weigh and measure on a wagon balance, the third step is to calculate cost information according to weighing, then the vehicle can leave an agricultural market and can stop in a parking lot, the local equipment can upload the business flow information to a cloud end, the business flow information can be stored in the cloud end, the control instruction data of a cloud platform comprise business flow control data, if the local equipment meets the business flow conditions, if the wagon balance is to execute actions after the barrier gate, namely the business flow conditions are met, the wagon balance can execute actions such as weighing and charging, and the like, and correspondingly, other business flows can be met, but only different business flow sequences are required to be met.
Specifically, the cloud service platform can send an operation instruction to the local equipment, for example, the application can preset a transaction mode, pay a transaction amount through the local equipment, the local equipment releases a market transaction main body, and can uniformly settle payment information when the market transaction main body leaves an intelligent transaction market, and after waiting for the payment of the market main body, the barrier gate releases the market main body, can record credit information of the transaction main body and allow the market main body to conduct transaction in a credit line.
In addition, for market transaction without setting business flow, the business flow information can be left blank, so that the local equipment can be set by default to meet the control condition of the business flow, the local equipment can also directly execute actions, and the business flow can be added, deleted, checked and the like according to the new addition of the local equipment or the manual setting.
S6, the cloud receives and stores operation data generated by the execution action of the local equipment, and updates business flow information of the local equipment stored in the cloud.
Specifically, the market transaction can set an administrator authority for executing manual operation on the local device which does not meet the business process, the local device uploads the corresponding operand to the cloud end, the cloud end can record, in addition, a new business process is established or existing business process information is replaced, the new business process is directly called when waiting for the next business process operation, and the operation of the local device by a user is facilitated. Accordingly, the information such as authentication of the administrator is not limited here, and may be a mobile phone number, an entity card, and the like.
Further, the method further includes S7:
s71, setting a business process mark for the local equipment, wherein the business process mark is used for recording the action sequences of different transaction processes of the local equipment;
S72, after the first local equipment executes the first action, judging whether the market subject enters a second local equipment area or not based on the business process mark;
s73, if the market main body enters the second local equipment area, the second local equipment executes the second action in real time.
Specifically, through the design of a transaction flow, for example, after the road gate collects and uploads the vehicle information, whether the vehicle needs to enter a wagon balance area or not is monitored, then the wagon balance collects the vehicle weight change information to conduct transaction settlement, the unit price and article information of specific vehicle transportation can be preset in local equipment in advance, or the unit price information of articles can be manually input after local data are collected, wherein for different transaction flows, different local equipment can be in different stages, for example, in the second step, the transaction settlement can be conducted according to the vehicle parking time collected by the intelligent parking lot, then the wagon balance is conducted, and the specific sequence and flow can be set according to the description of the main body of the market transaction which is required to be filled in advance or the main body of the market. And different transaction flows can be named with different numbers, if the flow A represents that the aisle gate and the wagon balance need to be completed, the design of the flow can be optimized according to the change of the market, if the parking lot is stopped, the equipment of the intelligent parking lot can be deleted from the systems such as the local equipment and the cloud service platform, and correspondingly, the acquired image and the body temperature can be increased to the flow, so that the effect of uploading data by the local equipment in real time can be met.
Further, the method further includes S8:
s81, acquiring a unique identification code of the local equipment in real time, wherein the unique identification code comprises a manufacturer identification;
s82, judging whether the unique identification code stored in the cloud is recorded or not, and if not, determining that the local equipment is newly added local equipment;
s83, establishing communication connection between the newly added local equipment and the cloud based on the information transmission protocol information of the newly added local equipment;
and S84, based on the configuration information data of the newly added equipment, the cloud end distributes the newly added equipment to the existing theme and business process.
Specifically, the existing local equipment is troublesome to join, whether new equipment is added is judged by collecting information of local data in real time, and the technical problem that the adding of the new equipment depends on excessive labor cost in the prior art is solved by setting automatic connection and business flow of the new equipment. Specifically, the method and the device can also configure and connect the cloud internet of things and the cloud service platform to newly added local equipment so as to realize a new function of market transaction, can record a mode of label memorization on the local equipment, can judge whether the record exists or not according to the search of the record of the cached local equipment if the new equipment exists, can mark the new equipment if the record exists, and can sort and add the newly added equipment into the existing process based on the design of the process so as to realize automatic transaction.
Further, the method further includes S9:
s91, summarizing transaction information of local equipment, and judging whether a market main body completes all transactions;
s92, if all transactions are not completed by the market subject, reminding the market subject of completing the market transactions;
and S93, after the market main body completes all transactions, the local equipment executes actions based on all completed transaction information.
Specifically, different transaction modes such as credit transaction, field transaction, monthly settlement, annual settlement and the like can be set for different market subjects, and for different transaction modes, a single settlement or a summary settlement mode, preferably a summary settlement mode, can be adopted, and the market transaction subjects are reminded of completing the transaction under the condition that the market subjects leave the market each time or certain payment conditions are met, for example, the preset one-month settlement is adopted, and the market subjects are reminded of paying under the condition that the market transaction subjects leave the market in full one month. The market subject may be denied departure or blacklisted for outstanding transactions.
Further, the method further includes S10:
s101, connecting first intelligent hardware with an Internet of things platform, and sending second control instruction data to local equipment by the first intelligent hardware through a cloud, wherein the first intelligent hardware comprises a mobile phone, a tablet, a computer and an intelligent bracelet;
S102, the local equipment obtains second control instruction information, judges whether the local equipment meets the business process control condition, and executes a second action based on the control instruction information if the local equipment meets the business process control condition.
Specifically, the method and the device can also operate the local device based on the intelligent device, for example, the cloud service platform is connected by using a mobile phone, and the cloud service platform sends an action instruction to the local device through the operation of the mobile phone.
Optionally, the present application may also connect to the local device through the intelligent device, and directly provide the intelligent device to send an operation instruction to the local device, for example, through the mobile phone to operate the gateway to pass, pay the water fee, etc.
Fig. 2 is a block diagram of an automated transaction apparatus according to the present invention. A second aspect of the present application proposes an automated transaction apparatus based on MQTT protocol, comprising:
the data acquisition analysis module is used for acquiring and analyzing information data of the local equipment in real time, classifying the analyzed information data, and at least dividing the information data into local processing data and configuration information data, wherein the local processing data comprises control class data and alarm prompt class data, and the configuration information data comprises business logic information and business flow information;
The data transmission module is used for sending the analyzed local processing data and the configuration information data to the cloud and storing the local processing data and the configuration information data based on the standard internet of things MQTT;
the topic definition module is used for predefining a plurality of topics according to the analyzed local processing data and configuration information data by the cloud, and the topics are used for providing API interfaces based on a release subscription mode for the cloud and local equipment;
the control instruction data return module is used for returning control instruction data based on the theme by the cloud, wherein the control instruction data comprise business flow control data and action control data;
the judging and executing module is used for receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control condition of the business process, and executing actions based on the control instruction information if the local equipment meets the control condition of the business process;
the flow updating module is used for receiving and storing operation data generated by the execution action of the local equipment by the cloud, and updating the business flow information of the local equipment stored by the cloud.
Further, the device further comprises a business process execution module, configured to:
s71, setting a business process mark for the local equipment, wherein the business process mark is used for recording the action sequences of different transaction processes of the local equipment;
S72, after the first local equipment executes the first action, judging whether the market subject enters a second local equipment area or not based on the business process mark;
s73, if the market main body enters the second local equipment area, the second local equipment executes the second action in real time.
Further, the apparatus further includes a new device configuration module configured to:
s81, acquiring a unique identification code of the local equipment in real time, wherein the unique identification code comprises a manufacturer identification;
s82, judging whether the unique identification code stored in the cloud is recorded or not, and if not, determining that the local equipment is newly added local equipment;
s83, establishing communication connection between the newly added local equipment and the cloud based on the information transmission protocol information of the newly added local equipment;
and S84, based on the configuration information data of the newly added equipment, the cloud end distributes the newly added equipment to the existing theme and business process.
Further, the device also comprises a transaction reminding module for:
s91, summarizing transaction information of local equipment, and judging whether a market main body completes all transactions;
s92, if all transactions are not completed by the market subject, reminding the market subject of completing the market transactions;
And S93, after the market main body completes all transactions, the local equipment executes actions based on all completed transaction information.
Further, the device also comprises an intelligent operation feedback module for:
s101, connecting first intelligent hardware with an Internet of things platform, and sending second control instruction data to local equipment by the first intelligent hardware through a cloud, wherein the first intelligent hardware comprises a mobile phone, a tablet, a computer and an intelligent bracelet;
s102, the local equipment obtains second control instruction information, judges whether the local equipment meets the business process control condition, and executes a second action based on the control instruction information if the local equipment meets the business process control condition.
Further, the data acquisition and analysis module is further configured to:
s11, collecting a data transmission protocol supported by local equipment, wherein the data transmission protocol comprises a data transmission protocol and a data receiving protocol;
and S12, connecting different data transmission interfaces with the local equipment based on the data transmission protocol, wherein the data transmission interfaces are used for transmitting information data of the local equipment to the cloud.
Further, the control instruction data return module is further configured to:
s41, the cloud terminal selects a second data receiving method based on the local equipment, wherein the second data receiving mode comprises Bluetooth and 4G;
S42, the control instruction data is sent to the local equipment based on the second data receiving method.
Fig. 3 is a block diagram of an automated transaction system according to an embodiment of the present invention.
The local service system is responsible for butting market hardware equipment, adapting hardware protocol data of various factories in a collocation mode, collecting data according to the well-configured service parameter data, keeping long-link communication with the cloud platform, and transmitting the collected hardware data to the cloud platform of the Internet of things in real time. The system comprises an Internet of things management platform and an intelligent agricultural batch service platform, wherein the Internet of things cloud platform and a local service system keep long-link communication through an MQTT protocol, data collected by the local service system are received in real time, the collected data are transmitted to the service system in an MQTT mode, the service system carries out relevant service circulation, a result is returned to the Internet of things platform and is sent to the local service system, the Internet of things platform simultaneously realizes local hardware equipment management, equipment protocol configuration and other functions, and realizes automatic configuration butt joint of equipment. The cloud Internet of things system can realize HTTP and MQTT protocol interface service adaptation, and the cloud Internet of things system and the local service system keep long-link communication through the MQTT protocol. The cloud internet of things system realizes functions of equipment registration management, equipment configuration, equipment association and the like, and realizes authentication management of local hardware. And the device is connected with a long-chain heartbeat monitor of a local system to acquire the state of a local hardware terminal, the instantiation of a local hardware protocol is realized through device configuration, and the instantiation protocol is bound with a specific market and merchant through device association. The binding relation is used as the basis of market business, thereby realizing the Saas service mode of multiple markets and multiple merchants.
Optionally, after the authentication of the cloud internet of things system is passed and a link is established, the local service system sends the obtained hardware data to the cloud, and the cloud receives the data and then follows the configured equipment information and service protocol instantiation information to send the specific service data to the intelligent agricultural batch service platform in an MQ mode.
For example, if the cloud service platform is an intelligent agricultural batch service platform, the service management function of the agricultural batch market core, the market basic information configuration, the in-out function, the vehicle management function, the water meter function, the charging function, the booth leasing function, the food security tracing function and the like are realized. The field entering and exiting function of the system mainly depends on the cooperation of the hardware data of the road gate and the wagon balance; the vehicle management function mainly depends on the barrier gate and the vehicle management hardware equipment; the water meter function mainly depends on intelligent water meter and intelligent meter hardware linkage. The wireless connection of the configured receiving of hardware protocols such as the wagon balance, the barrier gate and the water ammeter is realized through the local service system, the data is transmitted to the cloud internet of things platform based on the MQTT protocol, the intelligent agricultural lot platform receives real-time data of the cloud internet of things platform through the MQ, the wagon balance and the barrier gate data are obtained, the charging and discharging cost is dynamically calculated in real time based on basic configuration charging rule information, and the business can obtain the entering field after online payment through the agricultural lot service platform, so that the whole business flow function of entering and discharging the field is integrally realized. And acquiring the gateway and vehicle management hardware data, calculating the payment required by the vehicle in real time based on the configuration information of the basic charging rule of the vehicle, and carrying out online payment by the vehicle through an agricultural batch service platform, so that the vehicle can be released. Dynamic data of the water meter is obtained, the water meter charging rule configuration information is based on the water meter charging rule configuration information, the water meter charging information and the required charging information are calculated and informed to the commercial tenant in real time, the commercial tenant pays the water and electricity fee through the agricultural batch service platform, and the overall water and electricity service flow function is achieved.
Fig. 4 is a schematic structural diagram of an electronic device according to an embodiment of the present application. As shown in fig. 4, the electronic device may include: a transceiver 121, a processor 122, a memory 123.
The transceiver 121 may be used to obtain the local data and the first feedback data.
The system bus may be a peripheral component interconnect standard (peripheral component interconnect, PCI) bus or an extended industry standard architecture (extended industry standard architecture, EISA) bus, among others. The system bus may be classified into an address bus, a data bus, a control bus, and the like. For ease of illustration, the figures are shown with only one bold line, but not with only one bus or one type of bus. The transceiver is used to enable communication between the database access device and other computers (e.g., clients, read-write libraries, and read-only libraries). The memory may include random access memory (random access memory, RAM) and may also include non-volatile memory (non-volatile memory).
The electronic device provided in the embodiment of the present application may be a terminal device in the above embodiment.
The embodiment of the application also provides a chip for running the instruction, which is used for executing the technical scheme of the automatic transaction method based on the MQTT protocol in the embodiment.
The embodiment of the application also provides a computer readable storage medium, wherein the computer readable storage medium stores computer instructions, and when the computer instructions run on a computer, the computer is caused to execute the technical scheme of the method for the automated transaction based on the MQTT protocol in the embodiment.
Embodiments of the present application also provide a computer program product, where the computer program product includes a computer program, where the computer program is stored in a computer readable storage medium, and at least one processor may read the computer program from the computer readable storage medium, and when the at least one processor executes the computer program, the technical solution of the method for automatic transaction based on the MQTT protocol in the foregoing embodiments may be implemented.
The beneficial effects of the invention are as follows: the invention can solve the defect of the traditional market offline transaction breakpoint, realize the commercial tenant association operation of the market full-volume service platform, realize the real-time interaction of the transaction full-service link, comprehensively improve the operation management efficiency of the agricultural batch market service, reduce the docking cost of various software and hardware and improve the working efficiency of the platform. The transition personnel dependence of the agricultural batch market is liberated, and the production capacity is greatly improved. By means of metadata management, configuration of service protocol parameters is achieved, dynamic instantiation configuration is supported, transaction butt-joint flow can be completed without research and development, software and hardware butt-joint efficiency is greatly improved, and butt-joint research and development cost is saved. The system realizes the data integration and association of the agricultural batch transaction service association party, the market party and the merchant party, and solves the problem that off-line breakpoint transactions cannot form merchant data accumulation.
It is worth noting that the data collection and migration actions related to the present application are already agreed by the user and are necessary for the applicant to perform normal operation activities. The collected data applicants are subjected to desensitization treatment such as anonymization and confidentiality, and the access rights of the data are correspondingly set so as to ensure that the privacy of users cannot be revealed. The data processing activities performed by the applicant accord with the rules of laws and regulations such as data security laws and personal information protection laws.
Other embodiments of the present application will be apparent to those skilled in the art from consideration of the specification and practice of the invention disclosed herein. This application is intended to cover any variations, uses, or adaptations of the application following, in general, the principles of the application and including such departures from the present disclosure as come within known or customary practice within the art to which the application pertains. It is intended that the specification and examples be considered as exemplary only, with a true scope and spirit of the application being indicated by the following claims.
It is to be understood that the present application is not limited to the precise arrangements and instrumentalities shown in the drawings, which have been described above, and that various modifications and changes may be effected without departing from the scope thereof. The scope of the application is limited only by the appended claims.
Those skilled in the art will further appreciate that the algorithm steps described in connection with the embodiments disclosed herein are capable of being carried out in electronic hardware, computer software, or a combination of both, and that the functions are carried out in either hardware or software, depending on the particular application and design constraints of the solution, those skilled in the art can utilize different methods for achieving the described functions for each particular application, but such implementation should not be considered to be beyond the scope of the present invention.
While preferred embodiments of the present invention have been described, additional variations and modifications in those embodiments may occur to those skilled in the art once they learn of the basic inventive concepts. It is therefore intended that the following claims be interpreted as including the preferred embodiments and all such alterations and modifications as fall within the scope of the invention.
The foregoing is only a preferred embodiment of the present invention, but the scope of the present invention is not limited thereto, and any changes or substitutions easily contemplated by those skilled in the art within the scope of the present invention should be included in the scope of the present invention. Therefore, the protection scope of the present invention should be subject to the protection scope of the claims.
Claims (11)
1. An automated transaction method, comprising:
s1, acquiring and analyzing information data of local equipment in real time, classifying the analyzed information data, and at least dividing the information data into local processing data and configuration information data, wherein the local processing data comprises control type data and alarm prompt type data, and the configuration information data comprises business logic information and business flow information;
s2, sending the analyzed local processing data and configuration information data to a cloud based on the standard Internet of things MQTT and storing the local processing data and the configuration information data;
s3, the cloud end predefines a plurality of topics according to the analyzed local processing data and configuration information data, wherein the topics are used for providing API interfaces based on a publishing and subscribing mode for the cloud end and the local equipment;
s4, the cloud returns control instruction data based on the theme, wherein the control instruction data comprises business process control data and action control data;
s5, receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control conditions of the business process, and executing actions based on the control instruction information if the local equipment meets the control conditions of the business process;
s6, the cloud receives and stores operation data generated by the execution action of the local equipment, and updates business flow information of the local equipment stored in the cloud.
2. The method according to claim 1, characterized in that the method further comprises S7:
s71, setting a business process mark for the local equipment, wherein the business process mark is used for recording the action sequences of different transaction processes of the local equipment;
s72, after the first local equipment executes the first action, judging whether the market subject enters a second local equipment area or not based on the business process mark;
s73, if the market main body enters the second local equipment area, the second local equipment executes the second action in real time.
3. The method according to claim 1, characterized in that the method further comprises S8:
s81, acquiring a unique identification code of the local equipment in real time, wherein the unique identification code comprises a manufacturer identification;
s82, judging whether the unique identification code stored in the cloud is recorded or not, and if not, determining that the local equipment is newly added local equipment;
s83, establishing communication connection between the newly added local equipment and the cloud based on the information transmission protocol information of the newly added local equipment;
and S84, based on the configuration information data of the newly added equipment, the cloud end distributes the newly added equipment to the existing theme and business process.
4. The method according to claim 1, characterized in that the method further comprises S9:
S91, summarizing transaction information of local equipment, and judging whether a market main body completes all transactions;
s92, if all transactions are not completed by the market subject, reminding the market subject of completing the market transactions;
and S93, after the market main body completes all transactions, the local equipment executes actions based on all completed transaction information.
5. The method according to claim 1, characterized in that the method further comprises S10:
s101, connecting first intelligent hardware with an Internet of things platform, and sending second control instruction data to local equipment by the first intelligent hardware through a cloud, wherein the first intelligent hardware comprises a mobile phone, a tablet, a computer and an intelligent bracelet;
s102, the local equipment obtains second control instruction information, judges whether the local equipment meets the business process control condition, and executes a second action based on the control instruction information if the local equipment meets the business process control condition.
6. The method according to claim 1, wherein the step S1 further comprises:
s11, collecting a data transmission protocol supported by local equipment, wherein the data transmission protocol comprises a data transmission protocol and a data receiving protocol;
and S12, connecting different data transmission interfaces with the local equipment based on the data transmission protocol, wherein the data transmission interfaces are used for transmitting information data of the local equipment to the cloud.
7. The method according to claim 6, wherein the step S4 includes:
s41, the cloud terminal selects a second data receiving method based on the local equipment, wherein the second data receiving mode comprises Bluetooth and 4G;
s42, the control instruction data is sent to the local equipment based on the second data receiving method.
8. An automated transaction device based on MQTT protocol, comprising:
the data acquisition analysis module is used for acquiring and analyzing information data of the local equipment in real time, classifying the analyzed information data, and at least dividing the information data into local processing data and configuration information data, wherein the local processing data comprises control class data and alarm prompt class data, and the configuration information data comprises business logic information and business flow information;
the data transmission module is used for sending the analyzed local processing data and the configuration information data to the cloud and storing the local processing data and the configuration information data based on the standard internet of things MQTT;
the topic definition module is used for predefining a plurality of topics according to the analyzed local processing data and configuration information data by the cloud, and the topics are used for providing API interfaces based on a release subscription mode for the cloud and local equipment;
The control instruction data return module is used for returning control instruction data based on the theme by the cloud, wherein the control instruction data comprise business flow control data and action control data;
the judging and executing module is used for receiving and analyzing control instruction data of the cloud to obtain control instruction information, judging whether the local equipment meets the control condition of the business process, and executing actions based on the control instruction information if the local equipment meets the control condition of the business process;
the flow updating module is used for receiving and storing operation data generated by the execution action of the local equipment by the cloud, and updating the business flow information of the local equipment stored by the cloud.
9. An electronic device, comprising: a processor, and a memory communicatively coupled to the processor;
the memory stores computer-executable instructions;
the processor executes computer-executable instructions stored in the memory to implement the method of any one of claims 1-7.
10. A computer readable storage medium having stored therein computer executable instructions which when executed by a processor are adapted to carry out the method of any one of claims 1-7.
11. A computer program product comprising a computer program which, when executed by a processor, implements the method of any of claims 1-7.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202310025757.5A CN116012156A (en) | 2023-01-09 | 2023-01-09 | Automatic transaction method, device and readable storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202310025757.5A CN116012156A (en) | 2023-01-09 | 2023-01-09 | Automatic transaction method, device and readable storage medium |
Publications (1)
Publication Number | Publication Date |
---|---|
CN116012156A true CN116012156A (en) | 2023-04-25 |
Family
ID=86028291
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202310025757.5A Pending CN116012156A (en) | 2023-01-09 | 2023-01-09 | Automatic transaction method, device and readable storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN116012156A (en) |
-
2023
- 2023-01-09 CN CN202310025757.5A patent/CN116012156A/en active Pending
Similar Documents
Publication | Publication Date | Title |
---|---|---|
JP6353117B2 (en) | Communication processes and systems related to monitoring and controlling resource consumption | |
CN109379430B (en) | 'Internet of things +' industry ecosphere sharing and sharing platform | |
US11616832B2 (en) | Data routing in peer-to-peer networks | |
JP2023540150A (en) | Systems and methods for automated application programming interface evaluation and migration | |
US11747889B2 (en) | Customized Internet-of-Things data packaging and brokering | |
US20160050279A1 (en) | METHOD FOR MANAGING IoT DEVICES AND ANALYZING SERVICE OF BIG DATA | |
DE112016001678T5 (en) | A method and apparatus for managing remote devices and accessing information from remote devices | |
US10437575B2 (en) | Aercloud application express and aercloud application express launcher | |
CN111177112A (en) | Database blocking method and device based on operation and maintenance management system and electronic equipment | |
CN111092767B (en) | Method and device for debugging equipment | |
CN109933508B (en) | Method and apparatus for transmitting information | |
WO2018101103A1 (en) | On-demand service provision system and on-demand service provision method | |
CN110011875A (en) | Dial testing method, device, equipment and computer readable storage medium | |
Gao et al. | Big data sensing and service: A tutorial | |
CN110913362B (en) | Method and device for realizing wireless signal test through client and test equipment | |
Luntovskyy et al. | Technologies and Solutions for Smart Home and Smart Office | |
CN116012156A (en) | Automatic transaction method, device and readable storage medium | |
CN115242422A (en) | Data intercommunication processing method and device and information management system | |
CN110135803B (en) | Item management method and block chain link point equipment | |
Peoples et al. | A Review of IoT Service Provision to Assess the Potential for System Interoperability in an Uncertain Ecosystem | |
CN113592575B (en) | Order determining method and device, storage medium and electronic device | |
KR20120097120A (en) | System and method for intermediating chauffeur service | |
KR20130007508A (en) | System and method for intermediating chauffeur service | |
CN113313605B (en) | Product acquisition method and device, storage medium and electronic device | |
US11102329B2 (en) | Miniaturized network nodes |
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 |