pg电子平台网站

　　获取的所述待办服务数据在更新时设置为新增待办消息，并进行逻辑判断后删除重复

　　当服务器系统的数据库宕机时，通过实时消息通知并触发执行下一任务，任务执行完

　　毕后反馈通知至服务器系统，按照新增待办消息的队列将待办服务数据保存到数据库。

　　2.根据权利要求1所述的待办服务数据安全加固方法，其特征在于，所述推送的待办服

　　务数据为第三方系统的待监控接口发送的待办服务数据；在服务器系统中根据各个待监控

　　接口配制的重要性级别，对每个待监控接口推送的待办服务数据划分等级并生成每个待监

　　3.根据权利要求2所述的待办服务数据安全加固方法，其特征在于，进行逻辑判断后删

　　将新增待办消息按MQ消息队列的方式进行排序，并遍历服务器系统的数据库中数据进

　　行对比，若新增待办消息与数据库中数据不一致，则保存为待阅消息；若新增待办消息与数

　　据库中数据一致，则删除重复的新增待办消息，更新所述缓存池中的待办消息状态。

　　4.根据权利要求3所述的待办服务数据安全加固方法，其特征在于，当服务器系统的数

　　5.根据权利要求4所述的待办服务数据安全加固方法，其特征在于，通过消息中间件触

　　发下一段任务时，通过实时消息通知下一段任务开始执行，执行完毕后的消息回发通知至

　　6.根据权利要求1所述的待办服务数据安全加固方法，其特征在于，所述待办服务数据

　　安全加固方法在将待办服务数据更新至服务器系统的数据库时，还包括MQ定时任务消息补

　　偿机制，所述MQ定时任务消息补偿机制为异步处理消息补偿机制，当采集到异步处理消息

　　将异步处理消息进行添加，添加时，若更新失败，返回失败，MQ定时任务消息消费不成

　　功，等待下次消费，若删除失败，返回失败，MQ定时任务消息消费不成功，等待下次消费；

　　若在设定时间阈值添加消息未送达，则放入异常日志，基于服务器系统的控制台查看。

　　7.根据权利要求6所述的待办服务数据安全加固方法，其特征在于，MQ定时任务消息补

　　偿机制还包括配制各待监控接口推送的待办服务数据的预警数据，根据监控的待办服务数

　　据的监控等级进行不同的预警方式配制，根据时间间隔进行MQ定时任务消息补偿，配制预

　　推送数据获取模块，用于获取推送的待办服务数据，并更新至服务器系统的数据库；

　　待办消息处理模块，用于获取的所述待办服务数据在更新时设置为新增待办消息，并

　　宕机处理模块，用于在服务器系统的数据库宕机时，通过实时消息通知并触发执行下

　　一任务，任务执行完毕后反馈通知至服务器系统，按照新增待办消息的队列将待办服务数

　　9.一种电子设备，其特征在于，所述电子设备包括多个电子设备，各电子设备包括存储

　　器、处理器以及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述多个

　　电子设备的处理器执行所述计算机程序时共同实现权利要求1‑7任一所述待办服务数据安

　　10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，所述存储介质存

　　储的所述计算机程序被处理器执行时实现权利要求1‑7任一所述待办服务数据安全加固方

　　推送过程中，待办平台可能会出现数据库服务宕机，导致消息缺失无法保存到数据库，用户

　　止数据丢失，需要针对待办服务数据提供安全加固方法和系统，进行备份数据，以针对日后

　　鉴于此，本申请实施例提供一种待办服务数据安全加固方法、系统、电子设备及存

　　储介质，为待办服务数据设计安全加固方案，进行备份数据，防止数据丢失，并设计定时任

　　行完毕后反馈通知至服务器系统，按照新增待办消息的队列将待办服务数据保存到数据

　　发送的待办服务数据；在服务器系统中根据各个待监控接口配制的重要性级别，对每个待

　　作为本发明的进一步方案，进行逻辑判断后删除重复消息，更新待办消息状态，包

　　将新增待办消息按MQ消息队列的方式进行排序，并遍历服务器系统的数据库中数

　　据进行对比，若新增待办消息与数据库中数据不一致，则保存为待阅消息；若新增待办消息

　　与数据库中数据一致，则删除重复的新增待办消息，更新所述缓存池中的待办消息状态。

　　作为本发明的进一步方案，当服务器系统的数据库宕机时，还包括：通过消息中间

　　知下一段任务开始执行，执行完毕后的消息回发通知至服务器系统用于保证业务最终完

　　新至服务器系统的数据库时，还包括MQ定时任务消息补偿机制，所述MQ定时任务消息补偿

　　将异步处理消息进行添加，添加时，若更新失败，返回失败，MQ定时任务消息消费

　　不成功，等待下次消费，若删除失败，返回失败，MQ定时任务消息消费不成功，等待下次消

　　作为本发明的进一步方案，当采集到异步处理消息时，添加完成后，异步处理消息

　　的状态被修改一次，若进行更新，则进行修改状态，显示正常，若进行删除，服务器系统是逻

　　作为本发明的进一步方案，异步处理消息更新时，通过幂等位时间确定时序，修改

　　状态之外的字段，若完成先到，修改消息，正常；若删除先到，服务器系统是逻辑删除，并找

　　出修改状态，显示正常；更新之间的时序，若当前幂等位时间大于上次时间，允许被修改，否

　　则，加载日志表数据，删除小于当前幂等位时间的数据的字段更新，做增量更新。

　　作为本发明的进一步方案，异步处理消息删除时，若先完成，逻辑删除，若先更新，

　　作为本发明的进一步方案，MQ定时任务消息补偿机制还包括配制各待监控接口推

　　送的待办服务数据的预警数据，根据监控的待办服务数据的监控等级进行不同的预警方式

　　行下一任务，任务执行完毕后反馈通知至服务器系统，按照新增待办消息的队列将待办服

　　第三方面，本发明提供了一种电子设备，包括存储器、处理器及存在处理器上运行

　　第四方面，本发明还提供了一种计算机可读存储介质，其上存储有计算机程序，该

　　本申请提供的一种待办服务数据安全加固方法、系统、电子设备及存储介质，获取

　　推送的待办服务数据，并更新至服务器系统的数据库，通过新增待办、待阅消息，逻辑删除

　　消息，更新待办消息状态。当数据库服务停机时，通过消息中间件触发下一段任务，既通过

　　实时消息通知下一段任务开始执行，执行完毕后的消息回发通知以此来保证业务最终完

　　成；保证数据最终的完整性、一致性，方便为日后系统升级、数据库迁移等情况做准备。

　　的是，以上的一般描述和后文的细节描述仅是示例性和解释性的，并不能限制本申请。

　　中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本申请的一些

　　图2为本申请实施例提供的一种待办服务数据安全加固方法中MQ定时任务消息补

　　下面，结合附图以及具体实施方式，对本申请做进一步描述，需要说明的是，在不

　　相冲突的前提下，以下描述的各实施例之间或各技术特征之间可以任意组合形成新的实施

　　应当理解，此处所描述的具体实施例仅仅用以解释本申请，并不用于限定本申请。

　　整地描述，显然，所描述的实施例是本申请一部分实施例，而不是全部的实施例。基于本申

　　请中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施

　　述的具体实施例仅仅用于解释本申请，而非对本申请的限定。另外还需要说明的是，为了便

　　序性，防止数据丢失，需要针对待办服务数据提供安全加固方法和系统，进行备份数据，以

　　针对日后系统升级、数据库迁移等情况做准备。本申请提供了一种待办服务数据安全加固

　　方法、系统、电子设备及存储介质，为待办服务数据设计安全加固方案，进行备份数据，防止

　　数据丢失，并设计定时任务消息补偿机制，以针对日后系统升级、数据库迁移等情况做准

　　本申请的一些实施例中，参见图1所示，本发明实施例提供了一种待办服务数据安

　　步骤S20、获取的所述待办服务数据在更新时设置为新增待办消息，并进行逻辑判

　　步骤S30、当服务器系统的数据库宕机时，通过实时消息通知并触发执行下一任

　　务，任务执行完毕后反馈通知至服务器系统，按照新增待办消息的队列将待办服务数据保

　　服务数据；在服务器系统中根据各个待监控接口配制的重要性级别，对每个待监控接口推

　　待办服务数据划分等级并生成每个待监控接口的MQ消息队列时，各个待监控接口配制的重

　　将新增待办消息按MQ消息队列的方式进行排序，并遍历服务器系统的数据库中数

　　据进行对比，若新增待办消息与数据库中数据不一致，则保存为待阅消息；若新增待办消息

　　与数据库中数据一致，则删除重复的新增待办消息，更新所述缓存池中的待办消息状态。

　　在本实施例中，当服务器系统的数据库宕机时，还包括：通过消息中间件触发下一

　　段任务。具体的，通过消息中间件触发下一段任务时，通过实时消息通知下一段任务开始执

　　在本实施例中，参见图2所示，所述待办服务数据安全加固方法在将待办服务数据

　　更新至服务器系统的数据库时，还包括MQ定时任务消息补偿机制，所述MQ定时任务消息补

　　偿机制为异步处理消息补偿机制，当采集到异步处理消息时，包括步骤S101‑步骤S103：

　　步骤S101、将异步处理消息进行添加，添加时，若更新失败，返回失败，MQ定时任务

　　步骤S102、若删除失败，返回失败，MQ定时任务消息消费不成功，等待下次消费；

　　步骤S103、若在设定时间阈值添加消息未送达，则放入异常日志，基于服务器系统

　　其中，当采集到异步处理消息时，添加完成后，异步处理消息的状态被修改一次，

　　若进行更新，则进行修改状态，显示正常，若进行删除，服务器系统是逻辑删除，并找出修改

　　在本实施例中，异步处理消息更新时，通过幂等位时间确定时序，修改状态之外的

　　字段，若完成先到，修改消息，正常；若删除先到，服务器系统是逻辑删除，并找出修改状态，

　　显示正常；更新之间的时序，若当前幂等位时间大于上次时间，允许被修改，否则，加载日志

　　在本实施例中，异步处理消息删除时，若先完成，逻辑删除，若先更新，逻辑删除正

　　在异步处理消息补偿机制中，MQ的失败重试中设置重试的时间间隔，示例性的，可

　　以设置10s、30s、1min、2min…30min、1h等等，还可以设置失败重试次数，超过次数后进入死

　　其次，在异步处理消息补偿机制中，预计一天修改完成，生成消息消费代码案例。

　　在本发明的进一步方案中，MQ定时任务消息补偿机制还包括配制各待监控接口推

　　送的待办服务数据的预警数据，根据监控的待办服务数据的监控等级进行不同的预警方式

　　示例性的，预警方式包括：手机短信提醒、OA邮件提醒、门户待办提醒和控制台提

　　上述顺序依次执行。除非本文中有明确的说明，这些步骤的执行并没有严格的顺序限制，这

　　些步骤可以以其它的顺序执行。而且，本实施例的一部分步骤可以包括多个步骤或者多个

　　阶段，这些步骤或者阶段并不必然是在同一时刻执行完成，而是可以在不同的时刻执行，这

　　些步骤或者阶段的执行顺序也不必然是依次进行，而是可以与其它步骤或者其它步骤中的

　　器系统的数据库，通过新增待办、待阅消息，逻辑删除消息，更新待办消息状态。当数据库服

　　务停机时，通过消息中间件触发下一段任务，既通过实时消息通知下一段任务开始执行，执

　　行完毕后的消息回发通知以此来保证业务最终完成；保证数据最终的完整性、一致性，方便

　　推送数据获取模块100，用于获取推送的待办服务数据，并更新至服务器系统的数

　　据库。其中，推送数据获取模块100在获取推送的待办服务数据时，推送的待办服务数据为

　　第三方系统的待监控接口发送的待办服务数据；在服务器系统中根据各个待监控接口配制

　　的重要性级别，对每个待监控接口推送的待办服务数据划分等级并生成每个待监控接口的

　　待办消息处理模块200，用于获取的所述待办服务数据在更新时设置为新增待办

　　消息，并进行逻辑判断后删除重复消息，更新待办消息状态；其中，待办消息处理模块200通

　　过将获取的待办服务数据设置为新增待办消息并加入消息中间件控制的缓存池，将新增待

　　办消息按MQ消息队列的方式进行排序，并遍历服务器系统的数据库中数据进行对比，若新

　　增待办消息与数据库中数据不一致，则保存为待阅消息；若新增待办消息与数据库中数据

　　宕机处理模块300，用于在服务器系统的数据库宕机时，通过实时消息通知并触发

　　执行下一任务，任务执行完毕后反馈通知至服务器系统，按照新增待办消息的队列将待办

　　意性说明，而不是限制目的。易于理解，上述附图所示的处理并不表明或限制这些处理的时

　　间顺序。另外，也易于理解，这些处理可以是例如在多个模块中同步或异步执行的。

　　元，但是这种划分并非强制性的。实际上，根据本发明的实施方式，上文描述的两个或更多

　　模块或者单元的特征和功能可以在一个模块或者单元中具体化。反之，上文描述的一个模

　　本实施例还提供一种电子设备，如图4所示，该电子设备包括多个电子设备1000，

　　在实施例中待办服务数据安全加固系统的组成部分可分散于不同的电子设备1000中，电子

　　设备1000可以是执行程序的智能手机、平板电脑、笔记本电脑、台式计算机、机架式服务器、

　　刀片式服务器、塔式服务器或机柜式服务器(包括独立的服务器，或者多个服务器所组成的

　　服务器集群)等。本实施例的电子设备1000至少包括但不限于：可通过系统总线相互通信连

　　接的存储器1001、处理器1002。需要指出的是，图4仅示出了具有组件存储器1001和处理器

　　1002的电子设备1000，但是应理解的是，并不要求实施所有示出的组件，可以替代的实施更

　　本实施例中，存储器1001(即可读存储介质)包括闪存、硬盘、多媒体卡、卡型存储

　　器(例如，SD或DX存储器等)、随机访问存储器(RAM)、静态随机访问存储器(SRAM)、只读存储

　　器(ROM)、电可擦除可编程只读存储器(EEPROM)、可编程只读存储器(PROM)、磁性存储器、磁

　　盘、光盘等。在一些实施例中，存储器1001可以是电子设备1000的内部存储单元，例如该电

　　子设备1000的硬盘或内存。在另一些实施例中，存储器1001也可以是电子设备1000的外部

　　存储设备，例如该电子设备1000上配备的插接式硬盘，智能存储卡(SmartMedia  Card ,

　　包括电子设备1000的内部存储单元也包括其外部存储设备。本实施例中，存储器1001通常

　　用于存储安装于电子设备设备的操作系统和各类应用软件，例如实施例的待办服务数据安

　　全加固系统等。此外，存储器1001还可以用于暂时地存储已经输出或者将要输出的各类数

　　控制器、微控制器、微处理器、或其他数据处理芯片。该处理器1002通常用于控制电子设备

　　1000的总体操作。本实施例中，处理器1002用于运行存储器1001中存储的程序代码或者处

　　理数据。本实施例电子设备的多个电子设备1000的处理器1002共同执行计算机程序时实现

　　行完毕后反馈通知至服务器系统，按照新增待办消息的队列将待办服务数据保存到数据

　　据；在服务器系统中根据各个待监控接口配制的重要性级别，对每个待监控接口推送的待

　　系统的数据库时，还包括MQ定时任务消息补偿机制，所述MQ定时任务消息补偿机制为异步

　　将异步处理消息进行添加，添加时，若更新失败，返回失败，MQ定时任务消息消费

　　不成功，等待下次消费，若删除失败，返回失败，MQ定时任务消息消费不成功，等待下次消