CN112506485B - 业务处理系统 - Google Patents
业务处理系统 Download PDFInfo
- Publication number
- CN112506485B CN112506485B CN202011474832.9A CN202011474832A CN112506485B CN 112506485 B CN112506485 B CN 112506485B CN 202011474832 A CN202011474832 A CN 202011474832A CN 112506485 B CN112506485 B CN 112506485B
- Authority
- CN
- China
- Prior art keywords
- service
- data
- processed
- external system
- service data
- 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
- 238000012545 processing Methods 0.000 title claims abstract description 70
- 230000006870 function Effects 0.000 claims abstract description 54
- 210000001503 joint Anatomy 0.000 claims abstract description 14
- 238000004891 communication Methods 0.000 claims description 51
- 230000007246 mechanism Effects 0.000 claims description 17
- 230000001960 triggered effect Effects 0.000 claims description 9
- 230000005540 biological transmission Effects 0.000 claims description 6
- 230000001419 dependent effect Effects 0.000 claims description 4
- 238000000034 method Methods 0.000 abstract description 24
- 238000011161 development Methods 0.000 abstract description 16
- 230000008569 process Effects 0.000 abstract description 11
- 238000004519 manufacturing process Methods 0.000 description 22
- 238000010586 diagram Methods 0.000 description 8
- 230000003993 interaction Effects 0.000 description 6
- 229920006395 saturated elastomer Polymers 0.000 description 5
- 230000008859 change Effects 0.000 description 3
- 238000013480 data collection Methods 0.000 description 3
- 238000007689 inspection Methods 0.000 description 3
- 238000003672 processing method Methods 0.000 description 3
- 230000002159 abnormal effect Effects 0.000 description 2
- 238000000262 chemical ionisation mass spectrometry Methods 0.000 description 2
- 238000006243 chemical reaction Methods 0.000 description 2
- 238000001514 detection method Methods 0.000 description 2
- 238000005538 encapsulation Methods 0.000 description 2
- 238000004806 packaging method and process Methods 0.000 description 2
- 230000002265 prevention Effects 0.000 description 2
- 239000004065 semiconductor Substances 0.000 description 2
- 238000004458 analytical method Methods 0.000 description 1
- 230000006835 compression Effects 0.000 description 1
- 238000007906 compression Methods 0.000 description 1
- 230000006837 decompression Effects 0.000 description 1
- 239000012634 fragment Substances 0.000 description 1
- 230000005484 gravity Effects 0.000 description 1
- 230000010354 integration Effects 0.000 description 1
- 230000002452 interceptive effect Effects 0.000 description 1
- 238000012423 maintenance Methods 0.000 description 1
- 238000005259 measurement Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000003032 molecular docking Methods 0.000 description 1
- 238000010606 normalization Methods 0.000 description 1
- 230000006798 recombination Effects 0.000 description 1
- 238000005215 recombination Methods 0.000 description 1
- 238000011084 recovery Methods 0.000 description 1
- 238000012546 transfer Methods 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/20—Software design
- G06F8/24—Object-oriented
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F8/00—Arrangements for software engineering
- G06F8/30—Creation or generation of source code
- G06F8/36—Software reuse
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computer And Data Communications (AREA)
Abstract
本申请涉及一种业务处理系统,该系统包括:至少一个用于控制业务设备运行的第一装置、与第一装置通过局域网连接的第二装置以及预先封装的含有多种业务功能的类库,第一装置和第二装置共享该类库,第一装置通过第二装置与外部系统进行对接;当第一装置存在第一待处理业务时,第一装置从类库中调用与第一待处理业务对应的第一业务功能,通过第一业务功能对第一待处理业务的第一初始业务数据进行标准化处理,并将标准化处理后的第一目标业务数据传输给第二装置;第二装置基于外部系统的需求信息,对第一目标业务数据进行处理后传输给外部系统。该系统能够整合多个第一装置的业务,具有高并发、易扩展以及易移植的特点,大大缩短了项目开发周期。
Description
技术领域
本申请涉及计算机集成制造领域,特别是涉及一种业务处理系统。
背景技术
目前,可以通过全自动化生产线的方式对客户的待检测产品进行生产检测。这样,集成在全自动化生产线上的业务设备均需要与客户的生产系统进行对接,以便业务设备能够接收生产系统下发的与生产检测相关的指令信息以及上报生产过程中产生的业务数据。
在实际应用中,各业务设备对接的生产系统会经常随着项目、客户的不同而发生变化,此时,为了能够与不同客户的生产系统进行对接,需要基于客户的生产系统重新对控制业务设备运行的客户端软件进行定制化开发,导致项目开发周期较长。
发明内容
本申请实施例针对传统方式需要基于客户的生产系统重新对控制业务设备运行的客户端软件进行定制化开发,导致项目开发周期较长的技术问题,提供一种业务处理系统。
第一方面,本申请实施例提供一种业务处理系统,包括:至少一个用于控制业务设备运行的第一装置、与所述第一装置通过局域网连接的第二装置以及预先封装的含有多种业务功能的类库,其中,所述第一装置和所述第二装置共享所述类库,所述第一装置通过所述第二装置与外部系统进行对接,所述业务功能用于将所述业务的业务数据进行标准化处理,或将接收到的标准化处理后的数据还原成业务实例;
当所述第一装置存在第一待处理业务时,所述第一装置从所述类库中调用与所述第一待处理业务对应的第一业务功能,通过所述第一业务功能对所述第一待处理业务的第一初始业务数据进行标准化处理,并将标准化处理后的第一目标业务数据传输给所述第二装置;所述第二装置基于所述外部系统的需求信息,对所述第一目标业务数据进行处理后传输给所述外部系统;
当所述外部系统存在第二待处理业务时,所述第二装置接收所述外部系统发送的所述第二待处理业务的第二初始业务数据,并从所述类库中调用与所述第二待处理业务对应的第二业务功能,通过所述第二业务功能对所述第二初始业务数据进行标准化处理,并将标准化处理后的第二目标业务数据传输给所述第一装置,以使所述第一装置基于所述第二目标业务数据对所述业务设备进行控制。
在其中一个实施例中,可选的,所述系统还包括:预先封装的通信模块;
其中,所述第一装置和所述第二装置共享所述通信模块,所述通信模块用于所述第一装置和所述第二装置之间的数据传输。
在其中一个实施例中,可选的,所述系统还包括:预先封装的序列化反序列化功能集;
其中,所述第一装置和所述第二装置共享所述序列化反序列化功能集;所述序列化反序列化功能集用于对待传输的业务数据进行序列化处理或者反序列化处理。
在其中一个实施例中,可选的,所述通信模块包括解码子模块;其中,所述解码子模块采用防止数据粘包机制进行数据的解码。
在其中一个实施例中,可选的,所述通信模块通过异步套接字操作类对象来实现,且所述异步套接字操作类对象可回收。
在其中一个实施例中,可选的,所述通信模块还包括用于所述第一装置和第二装置之间进行通信的缓冲区;
所述通信模块还集成有断线重连机制以及心跳机制。
在其中一个实施例中,可选的,所述第二装置包括多个接口;其中,不同的接口对应不同的外部系统。
在其中一个实施例中,可选的,所述第二装置还包括接口切换模块;
所述接口切换模块用于根据接口配置文件确定所述第二装置与所述外部系统进行通信的目标接口,并与所述目标接口建立连接。
在其中一个实施例中,可选的,所述第二装置还用于向所述第一装置下发业务数据的采集模式。
可选的,所述采集模式包括以下至少一种:
无条件的按频率上报数据、特定事件触发的一个时间周期内按频率上报数据以及特定事件触发的单次上报数据。
本申请实施例提供的技术方案,包括至少一个用于控制业务设备运行的第一装置、与第一装置通过局域网连接第二装置以及预先封装的含有多种业务功能的类库。各第一装置通过第二装置与客户的外部系统进行对接,使得各第一装置不需要与外部系统直接对接,即由第二装置来整合各第一装置的业务;并且第一装置和第二装置均可以共享该用于将待传输的业务数据进行标准化处理的类库,使得第一装置和第二装置之间的交互流程是标准的,且所交互的业务数据也是标准化的以及饱和的。这样,当外部系统发生改变时,第二装置仅需要基于外部系统的需求信息对标准化的业务数据进行相应处理即可,不需要基于外部系统重复对各第一装置进行定制化开发,大大缩短了项目开发周期。
附图说明
图1为本申请实施例提供的业务处理系统的一种结构示意图;
图2为本申请实施例提供的业务处理系统的另一种结构示意图;
图3为本申请实施例提供的业务处理系统的又一种结构示意图;
图4为本申请实施例提供的通信模块的一种结构示意图;
图5为本申请实施例提供的业务处理系统的一种工作原理示意图;
图6为本申请实施例提供的业务处理方法的一种流程示意图。
具体实施方式
为了使本申请的目的、技术方案及优点更加清楚明白,通过下述实施例并结合附图,对本申请实施例中的技术方案进行进一步详细说明。应当理解,此处所描述的具体实施例仅用以解释本申请,并不用于限定本申请。
图1为本申请实施例提供的业务处理系统的一种结构示意图。如图1所示,该业务处理系统可以包括:至少一个用于控制业务设备运行的第一装置101、与所述第一装置101通过局域网连接的第二装置102以及预先封装的含有多种业务功能的类库103,其中,所述第一装置101和所述第二装置102共享所述类库103,所述第一装置101通过所述第二装置102与外部系统进行对接,所述业务功能用于将所述业务的业务数据进行标准化处理,或将接收到的标准化处理后的数据还原成业务实例。当所述第一装置101存在第一待处理业务时,所述第一装置101从所述类库103中调用与所述第一待处理业务对应的第一业务功能,通过所述第一业务功能对所述第一待处理业务的第一初始业务数据进行标准化处理,并将标准化处理后的第一目标业务数据传输给所述第二装置102;所述第二装置102基于所述外部系统的需求信息,对所述第一目标业务数据进行处理后传输给所述外部系统;当所述外部系统存在第二待处理业务时,所述第二装置102接收所述外部系统发送的所述第二待处理业务的第二初始业务数据,并从所述类库103中调用与所述第二待处理业务对应的第二业务功能,通过所述第二业务功能对所述第二初始业务数据进行标准化处理,并将标准化处理后的第二目标业务数据传输给所述第一装置101,以使所述第一装置101基于所述第二目标业务数据对所述业务设备进行控制。
具体的,业务设备用于实现不同的业务功能,第一装置101用于控制业务设备的运行。例如,在半导体/面板检测领域,各业务设备均集成在全自动化生产线中,该生产线由客户的生产系统(即上述的外部系统)进行整合,在生产系统的统一整合下,各业务设备在所对应的第一装置101的控制下实现对待检测产品的检测。同时,第一装置101还用于在业务设备产生业务数据时,将该业务数据通过第二装置102上报给外部系统。例如,业务设备对待检测产品检测过程中,产生了报警数据,此时,第一装置101会将报警数据通过第二装置102上报给外部系统。
在实际应用中,上述外部系统经常会随着项目、客户的不同而发生变化,为了避免在外部系统发生变化后,需要反复对第一装置101进行重复开发,该业务处理系统中还设置有第二装置102,第二装置102用于对各第一装置101的业务进行整合。这样,第一装置101便不需要关注外部系统的变化,统一由第二装置102与客户的外部系统进行对接。同时,无论外部系统如何变化,各业务设备自身的内部处理逻辑可能变化不大,即各业务设备所提供的业务服务基本变化不大(其中,业务服务如实时状况消息上报、报警消息上报、生产配方管理以及测量数据上报等),因此,可以将各业务设备所能提供的业务服务进行业务抽象并归纳,封装成相应的业务功能并存入类库103中,让各第一装置101从纷繁复杂的计算机集成制造(Computer Integrated Manufacturing System,CIMS)需求中解放出来。在第一装置101和第二装置102之间,只需考虑最大化完善业务因子并抽象出来,以及进行规范化封装。在进行封装时,不同的业务对应不同的业务功能,封装的业务功能用于将对应业务的业务数据进行标准化处理。
示例性的,对于业务设备的报警业务,在业务设备产生报警数据后,报警数据中可能仅携带了报警标识,为了能够对接不同的外部系统,需要尽可能饱和地采集报警数据。为此,可以预先对报警业务进行抽象并归纳,基于饱和式的报警需求,形成报警业务模板,并根据该报警业务模板生成对应的报警报告方法。再将该报警报告方法进行封装,存入用于第一装置101和第二装置102共享的类库103中。该报警报告方法能够基于报警业务模板,通过上述报警标识产生其它相关的报警信息(如报警级别等),从而生成报警实体。
通过上述过程,将各业务设备所支持的业务进行整合,从内部将业务数据抽象归纳,封装成第一装置101和第二装置102能够共享的各种业务功能。这样,当第一装置101从业务设备处获取到需要上报给外部系统的业务数据时,即在第一装置101存在第一待处理业务时,第一装置101可以从共享的类库103中调用与该第一待处理业务对应的第一业务功能,通过该第一业务功能将从业务设备处获取的第一初始业务数据进行标准化处理,并将标准化处理后的第一目标业务数据传输给第二装置102。其中,标准化处理的内容包括但不限于对业务数据进行信息扩充、压缩、打包以及对接收到压缩数据进行解压等。经过标准化处理后的第一目标业务数据相比第一初始业务数据来说,所携带的信息内容更多。此时,第二装置102可以对接收到的标准化处理后的数据进行解压,将其还原为业务实例,并需要基于外部系统的需求信息,对该业务实例进行重组以及格式转换后传输给外部系统。例如,假设第一待处理业务为报警业务,相应地,第一初始业务数据为报警数据,第一装置101从业务设备处获取的报警数据仅包括报警标识,第一装置101通过从类库103中调用与报警业务对应的报警报告方法,对初始报警数据进行标准化处理,使得得到的目标报警数据携带的报警信息更多。此时,第二装置102仅需要基于外部系统所需求的报警信息、数据格式以及协议格式,对目标报警数据进行重组以及格式转换,并将重组以及格式转换后的目标报警数据传输给外部系统。
同样的,当外部系统需要向第一装置101发送业务数据时,即当外部系统存在第二待处理业务时,外部系统也是通过第二装置102与第一装置101进行交互。具体的,第二装置102接收外部系统发送的第二初始业务数据,从共享的类库103中调用与第二待处理业务对应的第二业务功能,通过该第二业务功能对第二初始业务数据进行标准化处理,并将标准化处理后的第二目标业务数据传输给第一装置101。其中,第二目标业务数据为第一装置101所需要的业务数据。可选的,在接收到第二初始业务数据后,第二装置102还可以对第二初始业务数据进行解构以及挑选等处理。例如,假设第二待处理业务为对时业务,相应地,第二初始业务数据为对时数据,第二装置102接收外部系统发送的初始对时数据,从类库103中调用与对时业务对应的对时方法,对初始对时数据进行标准化处理,将其处理为第一装置101需要的目标对时数据并传输给第一装置101。第一装置101便可以根据目标对时数据对相应的业务设备进行时间调整。
就第一装置101和第二装置102之间交互的范畴内而言,通过不断的完善,可以达成规范化和高可传承性,这样,第一装置101无需再考虑外部CIMS业务内容的多变性。
本申请实施例提供的业务处理系统,包括至少一个用于控制业务设备运行的第一装置、与第一装置电连接第二装置以及预先封装的含有多种业务功能的类库。各第一装置通过第二装置与客户的外部系统进行对接,使得各第一装置不需要与外部系统直接对接,即由第二装置来整合各第一装置的业务;并且第一装置和第二装置均可以共享该用于将待传输的业务数据进行标准化处理的类库,使得第一装置和第二装置之间的交互流程是标准的,且所交互的业务数据也是标准化的以及饱和的。这样,当外部系统发生改变时,第二装置仅需要基于外部系统的需求信息对标准化的业务数据进行相应处理即可,不需要基于外部系统重复对各第一装置进行定制化开发,大大缩短了项目开发周期。
在该业务处理系统中,第一装置101通过第二装置102与外部系统进行对接。为了第二装置102能够与不同的外部系统进行对接,在上述实施例的基础上,可选的,如图2所示,第二装置102包括多个接口1021。
其中,不同的接口1021对应不同的外部系统。在实际应用中,可以根据应用场景启用对应的接口。在具体实现时,可以将业界常用的跨系统交互接口封装到第二装置102中。当外部系统由主控可编程逻辑控制器(Programmable Logic Controller,PLC)工作站作为统筹平台时,第二装置102将会启用对应的内部适配器,在重组或解析业务数据时,将按照对应的协议格式转换;当外部系统由SECS/GEM(Semiconductor Equipment CommunicationStandard/Generic Equipment Model)driver组成并以HSMS(High Speed MessageServices)通信时,第二装置102将启用解析HSMS以及转换HSMS的模块,根据与外部系统所律定的规则,将外部HSMS解构或者将内部业务数据重组并转换;当外部系统提供企业级消息中间件(Enterprise Message Service,EMS)作为交互通道时,第二装置102将创建出对应的适配器,以达成与外部系统间的信息交互。
继续参见图2,可选的,第二装置102还包括接口切换模块1022;所述接口切换模块1022用于根据接口配置文件确定所述第二装置102与所述外部系统进行通信的目标接口,并与所述目标接口建立连接。
其中,第二装置102将不同的通信协议、不同的通信接口组合起来。当外部系统发生变化时,仅需要基于外部系统的接口情况对接口配置文件进行修改并重新下发至第二装置102中。在获取到该接口配置文件之后,接口切换模块1022便可以根据该接口配置文件确定需要切换的目标接口,并执行目标接口的切换,从而实现与外部系统的对接。通过上述设置,第一装置101也无需再考虑外部系统通信协议和通信接口的多样化,进一步缩短了项目的开发周期。
在本实施例中,第二装置封装有多个接口,同时,第二装置还包括接口切换模块。当外部系统发生变化时,只需要修改接口配置文件并通过接口切换模块基于接口配置文件对第二装置的当前接口进行切换,就可以实现第二装置与外部系统的对接。这样,在后续开发时,研发人员只需要将重心放在业务的处理和重组上,大大提高了系统的稳定性,同时也进一步缩短了项目的开发周期。
在实际应用中,为了进一步缩短项目的开发周期,还可以预先对第一装置101和第二装置102之间的底层Socket进行单独封装。在上述实施例的基础上,可选的,如图3所示,该系统还包括:预先封装的通信模块104。
其中,第一装置101和第二装置102共享该通信模块104,该通信模块104用于第一装置101和第二装置102之间的数据传输。这样,在研发人员需要开发新的第一装置101时,由于该系统包括预先封装的、用于第一装置101和第二装置102间数据传输的通信模块104,因此,研发人员无需重新编写新的第一装置101的通信部分,仅需要关注新的第一装置101中的内部处理逻辑。新的第一装置101仅需要订阅消息接收事件即可实现通过该通信模块104完成数据的接收,仅需要调用相应的业务功能即可实现通过该通信模块104完成数据的发送。当然,也可以将上述通信模块104设置到类库103中,在调用类库103中的业务功能对业务数据进行标准化处理后,直接通过通信模块104发送标准化处理后的业务数据。
可选的,上述通信模块104通过异步套接字操作类对象来实现,且异步套接字操作类对象可回收。在实际应用中,通信模块104通过“标记接入套接字会话的令牌类”子模块标记异步套接字操作类对象,由于异步套接字操作类对象是可回收再利用的,因此,在每次使用时,需要对其进行快捷标记。当数据传输完毕断开连接时,通信模块104可以将异步套接字操作类对象自动回收进接收管理池或发送管理池中。这样,当与第二装置102电连接的第一装置101较多且频繁进行断开再连接操作时,第二装置102不会频繁创建及销毁套接字实例,从而避免了大量资源消耗。
继续参见图3,在上述实施例的基础上,可选的,上述通信模块104可以包括解码子模块1041;其中,解码子模块1041采用防止数据粘包机制进行数据的解码。
具体的,数据粘包是指当发送端在极短的时间内发送多个数据包给接收端,这时接收端在接收数据的时候可能会发生连包问题,导致所接收的数据包都粘连在一起。为此,作为一种可选的防止数据粘包机制,通信模块104在进行数据打包封装时,将数据的长度封装在数据包的包头,从而接收端根据包头中的数据的长度进行数据接收并解码。当然,还可以采用其它防止数据粘包机制,本实施例对此不做限定。
进一步的,为了提高网络数据的高吞吐量,该通信模块104中还设置有线程安全的缓冲区,该缓冲区用于各第一装置101与第二装置102之间进行通信。通过该缓冲区集中分配资源,可有效避免频繁分配内存空间所造成的大量碎片。可选的,该通信模块104中还集成了断线重连机制以及心跳机制。通过上述设置,大大提高了高并发模式下的系统性能,同时也提高了系统自动清障的能力。
图4为本申请实施例提供的通信模块的一种结构示意图。如图4所示,该通信模块104的模块主体由封装的服务器端(该服务器端可以为上述第二装置102)、客户端(该客户端可以为上述第一装置101)以及开放的适配器组成,服务器端和客户端继承自同一个C#语言接口(即图4中的异步套接字功能集接口,包括套接字服务器端和套接字客户端),该接口集合了通讯所涉及的功能。其中,该功能包括标记接入套接字会话的令牌类、管理线程安全的数据缓冲区类、管理用于接收的异步套接字操作类对象池、管理用于发送的异步套接字操作类对象池以及处理套接字粘包、解码的类。同时,该通信模块104通过异步套接字实例创建工厂来创建套接字服务器端实例和套接字客户端实例。
为了使第一装置101能够直接面向业务、服务于业务,进一步缩短项目的开发周期,在上述实施例的基础上,可选的,继续参见图3,该业务处理系统还包括:预先封装的序列化反序列化功能集105。
其中,第一装置101和第二装置102共享该序列化反序列化功能集105;该序列化反序列化功能集105用于对待传输的业务数据进行序列化处理或者反序列化处理。待传输的业务数据可以为上述第一目标业务数据或者上述第二目标业务数据。可选的,该序列化反序列化功能集105中集成有异常处理机制。当对待传输的业务数据进行序列化或者反序列化处理过程中,若出现异常转化情况,还可以基于异常处理机制进行相应的处理,使序列化或者反序列化转化恢复正常。
图5为本申请实施例提供的业务处理系统的一种工作原理示意图。该业务处理系统中包括预先封装的类库103、通信模块104以及序列化反序列化功能集105,且第一装置101和第二装置102共享上述类库103、通信模块104以及序列化反序列化功能集105。因此,第一装置101只需引入上述类库103、通信模块104以及序列化反序列化功能集105后创建一个适配器并控制开始结束,第一装置101便可以直接通过通信模块104接收第二装置102发送的业务消息文本,并通过序列化反序列化功能集105将业务消息文本进行反序列化处理,得到对应的业务类实例,基于该业务类实例直接进入业务分析处理环节。在处理业务的环节中,如要发送业务请求或报告,第一装置101也只需从类库103中调用该业务对应的业务功能,通过所调用的业务功能对该业务的业务数据进行标准化处理。在得到该业务功能输出的业务类实例后,第一装置101通过序列化反序列化功能集105将业务类实例进行序列化处理,得到对应的业务消息文本并传输给通信模块104,并通过通信模块104传输给第二装置102。对于该业务处理系统中的第二装置102创建适配器,以及业务请求发送部分以及业务数据接收部分与第一装置101同理,可以参照第一装置101的处理过程,本实施例在此不再赘述。另外,第一装置101接收业务数据可以通过订阅消息接收事件来完成,发送业务数据可以通过调用发送方法来完成,使得通信模块104对于第一装置101来说是不可见的,大大提高业务处理系统的稳定性。同时,由于第二装置102可以同时与多个第一装置101进行通信,考虑到第二装置102接收部分的并发程度,第二装置102中还可以集成队列管理机制。
在本实施例中,该业务处理系统还可以包括预先封装的通信模块,规范化地约束数据打包发送机制,和接收数据后的解码机制,使得移植系统时,无需重复开发通信模块,大大缩短了项目的开发周期。同时,通信模块中集成有防止数据粘包机制以及套接字操作类对象回收机制,通过上述设置,大大提高了高并发模式下的系统性能,同时也提高了系统自动清障的能力。
在一个实施例中,第二装置102还可以基于实际使用需求,提供一些资料维护功能以及集中化管理功能。具体的,该功能可以包括警报信息管理、生产配方管理、权限管理、制品管理、设备埠位管理、日志管理、履历查询功能、外部系统连线/离线管理以及数据收集等。
针对数据收集功能,在上述实施例的基础上,可选的,第二装置102还用于向第一装置101下发业务数据的采集模式。该采集模式可以包括无条件的按频率上报数据、特定事件触发的一个时间周期内按频率上报数据以及特定事件触发的单次上报数据中的至少一种。
其中,第一种采集模式(无条件的按频率上报数据)适合设备点检类数据上报的应用场景。在第一装置101与第二装置102成功建立连接后,第二装置102根据第一种采集模式的配置下达命令(该命令包括需要上报的项次,上报的频率等),则第一装置101将一直持续地上报数据直到连接断开;第二种模式(特定事件触发的一个时间周期内按频率上报数据)适合采集产品进入特定工位进行生产时所关注的实时数据,当产品进入工位后,触发开始事件,第二装置102根据第二种模式的配置下达开始上报命令(该命令包括需要上报的项次,上报的频率等),则第一装置101将在每例产品进入该特定工位后的作业周期内持续上报数据;当产品离开工位后,第二装置102下达结束上报命令,第一装置101结束数据上报;第三种模式(特定事件触发的单次上报数据)适合产品本身生产数据的上报,每个产品生产完成后,触发事件上报该产品的相关生产资料。
在本实施例中,第二装置还提供了部分业务管理功能,如配方管理、警报管理以及数据收集等功能,充分考虑了多场景下的诉求,使得该部分业务模块也能够高效管理与移植。
在一个实施例中,还提供了一种业务处理方法,该方法应用于上述任一实施例所述的业务处理系统,如图6所示,该方法可以包括:
S601、当第一装置存在第一待处理业务时,所述第一装置从所述类库中调用与所述第一待处理业务对应的第一业务方法,通过所述第一业务方法对所述第一待处理业务的第一初始业务数据进行标准化处理,并将标准化处理后的第一目标业务数据传输给第二装置;所述第二装置基于外部系统的需求信息,对所述第一目标业务数据进行处理后传输给所述外部系统;
S602、当外部系统存在第二待处理业务时,第二装置接收所述外部系统发送的所述第二待处理业务的第二初始业务数据,并从所述类库中调用与所述第二待处理业务对应的第二业务方法,通过所述第二业务方法对所述第二初始业务数据进行标准化处理,并将标准化处理后的第二目标业务数据传输给第一装置,以使所述第一装置基于所述第二目标业务数据对业务设备进行控制。
本申请实施例提供的业务处理方法,在业务处理过程中,各第一装置均通过第二装置与客户的外部系统进行对接,使得各第一装置不需要与外部系统直接对接,即由第二装置来整合各第一装置的业务;并且第一装置和第二装置均可以通过调用预先封装的类库,来实现待传输的业务数据的标准化处理,使得第一装置和第二装置之间的交互流程是标准的,且所交互的业务数据也是标准化的以及饱和的。这样,当外部系统发生改变时,第二装置仅需要基于外部系统的需求信息对标准化的业务数据进行相应处理即可,不需要基于外部系统重复对各第一装置进行定制化开发,大大缩短了项目开发周期。
以上所述实施例的各技术特征可以进行任意的组合,为使描述简洁,未对上述实施例中的各个技术特征所有可能的组合都进行描述,然而,只要这些技术特征的组合不存在矛盾,都应当认为是本说明书记载的范围。
以上所述实施例仅表达了本申请的几种实施方式,其描述较为具体和详细,但并不能因此而理解为对本申请专利范围的限制。应当指出的是,对于本领域的普通技术人员来说,在不脱离本申请构思的前提下,还可以做出若干变形和改进,这些都属于本申请的保护范围。因此,本申请专利的保护范围应以所附权利要求为准。
Claims (10)
1.一种业务处理系统,其特征在于,包括:至少一个用于控制业务设备运行的第一装置、与所述第一装置通过局域网连接的第二装置以及预先封装的含有多种业务功能的类库,其中,所述第一装置和所述第二装置共享所述类库,所述第一装置通过所述第二装置与外部系统进行对接,所述业务功能用于将所述业务的业务数据进行标准化处理,或将接收到的标准化处理后的数据还原成业务实例;
当所述第一装置存在第一待处理业务时,所述第一装置从所述类库中调用与所述第一待处理业务对应的第一业务功能,通过所述第一业务功能对所述第一待处理业务的第一初始业务数据进行标准化处理,并将标准化处理后的第一目标业务数据传输给所述第二装置;所述第二装置对所述接收到的第一目标业务数据进行解压,将其还原为业务实例,并基于所述外部系统的需求信息,对所述业务实例进行重组以及格式转换后传输给所述外部系统;
当所述外部系统存在第二待处理业务时,所述第二装置接收所述外部系统发送的所述第二待处理业务的第二初始业务数据,并从所述类库中调用与所述第二待处理业务对应的第二业务功能,通过所述第二业务功能对所述第二初始业务数据进行标准化处理,并将标准化处理后的第二目标业务数据传输给所述第一装置,以使所述第一装置基于所述第二目标业务数据对所述业务设备进行控制。
2.根据权利要求1所述的系统,其特征在于,所述系统还包括:预先封装的通信模块;
其中,所述第一装置和所述第二装置共享所述通信模块,所述通信模块用于所述第一装置和所述第二装置之间的数据传输。
3.根据权利要求2所述的系统,其特征在于,所述系统还包括:预先封装的序列化反序列化功能集;
其中,所述第一装置和所述第二装置共享所述序列化反序列化功能集;所述序列化反序列化功能集用于对待传输的业务数据进行序列化处理或者反序列化处理。
4.根据权利要求2所述的系统,其特征在于,所述通信模块包括解码子模块;其中,所述解码子模块采用防止数据粘包机制进行数据的解码。
5.根据权利要求2所述的系统,其特征在于,所述通信模块通过异步套接字操作类对象来实现,且所述异步套接字操作类对象可回收。
6.根据权利要求4所述的系统,其特征在于,所述通信模块还包括用于所述第一装置和第二装置之间进行通信的缓冲区;
所述通信模块还集成有断线重连机制以及心跳机制。
7.根据权利要求1所述的系统,其特征在于,所述第二装置包括多个接口;其中,不同的接口对应不同的外部系统。
8.根据权利要求7所述的系统,其特征在于,所述第二装置还包括接口切换模块;
所述接口切换模块用于根据接口配置文件确定所述第二装置与所述外部系统进行通信的目标接口,并与所述目标接口建立连接。
9.根据权利要求1至8中任一项所述的系统,其特征在于,所述第二装置还用于向所述第一装置下发业务数据的采集模式。
10.根据权利要求9所述的系统,其特征在于,所述采集模式包括以下至少一种:
无条件的按频率上报数据、特定事件触发的一个时间周期内按频率上报数据以及特定事件触发的单次上报数据。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202011474832.9A CN112506485B (zh) | 2020-12-14 | 2020-12-14 | 业务处理系统 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202011474832.9A CN112506485B (zh) | 2020-12-14 | 2020-12-14 | 业务处理系统 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN112506485A CN112506485A (zh) | 2021-03-16 |
CN112506485B true CN112506485B (zh) | 2024-07-02 |
Family
ID=74972204
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202011474832.9A Active CN112506485B (zh) | 2020-12-14 | 2020-12-14 | 业务处理系统 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN112506485B (zh) |
Families Citing this family (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113377448A (zh) * | 2021-06-08 | 2021-09-10 | 展讯通信(天津)有限公司 | 业务功能执行方法和电子设备 |
Citations (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN110825539A (zh) * | 2019-11-07 | 2020-02-21 | 中国联合网络通信集团有限公司 | 业务处理方法及装置 |
Family Cites Families (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
US8027922B2 (en) * | 2003-07-14 | 2011-09-27 | Sprint Communications Company L.P. | Integration infrastructure |
CN104778087B (zh) * | 2014-01-09 | 2019-04-12 | 中国移动通信集团山东有限公司 | 一种信息处理方法以及信息处理装置 |
CN110245110A (zh) * | 2019-05-20 | 2019-09-17 | 深圳壹账通智能科技有限公司 | 数据处理方法、装置及存储介质 |
CN111464608A (zh) * | 2020-03-30 | 2020-07-28 | 山东浪潮通软信息科技有限公司 | 报文处理方法及装置 |
CN111708515B (zh) * | 2020-04-28 | 2023-08-01 | 山东鲁软数字科技有限公司 | 基于分布式共享微模块的数据处理方法及薪档积分系统 |
CN111930365B (zh) * | 2020-09-18 | 2021-02-26 | 季华实验室 | 基于Qt的应用程序快速开发框架、开发方法及运行方法 |
-
2020
- 2020-12-14 CN CN202011474832.9A patent/CN112506485B/zh active Active
Patent Citations (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN110825539A (zh) * | 2019-11-07 | 2020-02-21 | 中国联合网络通信集团有限公司 | 业务处理方法及装置 |
Also Published As
Publication number | Publication date |
---|---|
CN112506485A (zh) | 2021-03-16 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
US10795737B2 (en) | Generic distributed processing for multi-agent systems | |
US5790809A (en) | Registry communications middleware | |
CN112799789A (zh) | 一种节点集群管理方法、装置、设备及存储介质 | |
CN111294235A (zh) | 数据处理方法、装置、网关及可读存储介质 | |
CN113703997A (zh) | 集成多种消息代理的双向异步通信中间件系统及实现方法 | |
CN112506485B (zh) | 业务处理系统 | |
CN108306866A (zh) | 一种企业服务总线平台及数据分析方法 | |
KR100510068B1 (ko) | 반도체 라인관리용 통합 자동화시스템의 감시 시스템 및 방법 | |
CN101022364A (zh) | Trap报文上报方法及系统、告警信息源/告警代理服务装置 | |
CN117420779A (zh) | 一种基于半导体物流设备数据采集控制方法 | |
CN107483384B (zh) | 一种网络数据交互方法及装置 | |
CN111510362B (zh) | 一种基于ModBus数据服务功能的通信方法及系统 | |
CN113848834A (zh) | 一种基于边云协同的车间设备接入系统及方法 | |
KR20170127348A (ko) | 반도체 제조 설비와 외부 분석 시스템 간의 데이터 연결 시스템 및 방법 | |
CN114301956B (zh) | 一种基于java语言开发的电力系统用通讯数据处理系统及方法 | |
KR20080000856A (ko) | 반도체 설비장치 네트워크를 위한 데이터 변환장치 | |
CN113535413B (zh) | 交易请求的处理方法及半导体生产系统 | |
CN115988087B (zh) | 基于总线的服务调用方法、装置、电子设备和存储介质 | |
CN111159103B (zh) | 一种企业服务总线系统 | |
CN114500646B (zh) | 一种去中心化的esb云平台系统及其服务调用方法 | |
CN111209162B (zh) | 分层建模的系统监控方法及装置 | |
CN113852651B (zh) | 一种基于边缘网关的fanuc代理服务实现系统及其方法 | |
KR101830105B1 (ko) | 에너지 통합관리를 위한 프로토콜 어댑터 | |
CN113568885A (zh) | 业务驱动式数据管理方法及其软件系统 | |
CN115664886A (zh) | 一种基于esb技术的教育信息数据整合系统及方法 |
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 |