[發(fā)明專利]任務(wù)調(diào)度方法、裝置、系統(tǒng)、介質(zhì)和電子設(shè)備

在審

• 申請?zhí)枺?/td>: 201810681211.4
• 申請日: 2018-06-27
• 公開（公告）號: CN108829503A
• 公開（公告）日: 2018-11-16
• 發(fā)明（設(shè)計(jì)）人: 張海濱
• 申請（專利權(quán)）人: 泰康保險(xiǎn)集團(tuán)股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;H04L29/08
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

本發(fā)明實(shí)施例提供一種任務(wù)調(diào)度方法、裝置、系統(tǒng)、介質(zhì)和電子設(shè)備。方法包括：接收需要調(diào)度的任務(wù)的任務(wù)信息，并為任務(wù)生成任務(wù)ID，且設(shè)置任務(wù)的任務(wù)狀態(tài)為待執(zhí)行狀態(tài)；定時(shí)掃描任務(wù)狀態(tài)為待執(zhí)行狀態(tài)的各任務(wù)的任務(wù)信息，依據(jù)各任務(wù)的任務(wù)信息中的corn表達(dá)式中的執(zhí)行時(shí)間，確定需要執(zhí)行的目標(biāo)任務(wù)；對于需要執(zhí)行的目標(biāo)任務(wù)，在目標(biāo)任務(wù)的任務(wù)執(zhí)行消息體上填寫消息頭信息，并依據(jù)目標(biāo)任務(wù)的執(zhí)行域名稱編碼，確定目標(biāo)業(yè)務(wù)域，將目標(biāo)任務(wù)發(fā)送至對應(yīng)的目標(biāo)業(yè)務(wù)域中的消息交換機(jī)；待目標(biāo)任務(wù)發(fā)送完成后，依據(jù)目標(biāo)任務(wù)的任務(wù)類型，按照與任務(wù)類型相對應(yīng)的預(yù)設(shè)處理方法，更新目標(biāo)任務(wù)。本發(fā)明實(shí)施例降低了開發(fā)人員的開發(fā)工作量。

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度方法、裝置、系統(tǒng)、介質(zhì)和電子設(shè)備。

背景技術(shù)

根據(jù)任務(wù)的執(zhí)行屬性可將任務(wù)分為單次型任務(wù)和重復(fù)型任務(wù)。單次型任務(wù)指的是只需執(zhí)行一次的任務(wù)，比如用戶A在某個(gè)時(shí)刻給用戶B發(fā)了一條祝福短信，短信發(fā)送成功，任務(wù)完成結(jié)束。重復(fù)型任務(wù)指的是根據(jù)預(yù)先設(shè)定的規(guī)則，重復(fù)多次執(zhí)行某個(gè)任務(wù)，比如對于任務(wù)“體檢中心每天早8點(diǎn)準(zhǔn)時(shí)向其注冊的會員發(fā)送健康養(yǎng)生信息”來說，該任務(wù)本身是一個(gè)重復(fù)型任務(wù)，但是系統(tǒng)會將該重復(fù)型任務(wù)自動拆解成多個(gè)單一任務(wù)來執(zhí)行，如第一天創(chuàng)建任務(wù)(1)，該任務(wù)(1)的執(zhí)行時(shí)間為2018-5-22早上8點(diǎn)，執(zhí)行間隔為24小時(shí)，那么在2018-5-22早上8點(diǎn)體檢中心會向其注冊的會員發(fā)送健康養(yǎng)生信息。該任務(wù)(1)完成之后，系統(tǒng)又會自動生成任務(wù)(2)，該任務(wù)(2)的執(zhí)行時(shí)間為2018-5-23早上8點(diǎn)，執(zhí)行間隔為24小時(shí)，那么在2018-5-23早上8點(diǎn)體檢中心會向其注冊的會員發(fā)送健康養(yǎng)生信息。該任務(wù)(2)完成之后，系統(tǒng)又會自動生成任務(wù)(3)，該任務(wù)(3)的執(zhí)行時(shí)間為2018-5-24早上8點(diǎn)，執(zhí)行間隔為24小時(shí)，以此類推。

目前的任務(wù)調(diào)度方法，針對不同業(yè)務(wù)場景下的不同任務(wù)，都需要由開發(fā)人員創(chuàng)建相應(yīng)的任務(wù)開發(fā)代碼，比如任務(wù)一：體檢中心每天早8點(diǎn)準(zhǔn)時(shí)向其注冊的會員發(fā)送健康養(yǎng)生信息，任務(wù)二：每天下午3點(diǎn)準(zhǔn)時(shí)向其注冊的會員發(fā)送會員優(yōu)惠活動信息，雖然任務(wù)一和任務(wù)二的不同點(diǎn)僅在于任務(wù)觸發(fā)時(shí)間和任務(wù)具體內(nèi)容不同，但卻需要開發(fā)人員分別創(chuàng)建兩套任務(wù)開發(fā)代碼來分別執(zhí)行任務(wù)一和任務(wù)二。而隨著任務(wù)的增多，開發(fā)人員的工作量會越來越大。

發(fā)明內(nèi)容

有鑒于此，本發(fā)明實(shí)施例提供一種任務(wù)調(diào)度方法、裝置、系統(tǒng)、介質(zhì)和電子設(shè)備，以降低開發(fā)人員的開發(fā)工作量。技術(shù)方案如下：

基于本發(fā)明實(shí)施例的一方面，本發(fā)明實(shí)施例提供一種任務(wù)調(diào)度方法，應(yīng)用于任務(wù)調(diào)度裝置，方法包括：

接收需要調(diào)度的任務(wù)的任務(wù)信息，并為所述任務(wù)生成任務(wù)ID，且設(shè)置所述任務(wù)的任務(wù)狀態(tài)為待執(zhí)行狀態(tài)；其中，所述任務(wù)信息包括任務(wù)類型、corn表達(dá)式、執(zhí)行域名稱編碼和任務(wù)執(zhí)行消息體；

定時(shí)掃描任務(wù)狀態(tài)為待執(zhí)行狀態(tài)的各任務(wù)的任務(wù)信息，依據(jù)各任務(wù)的任務(wù)信息中的corn表達(dá)式中的執(zhí)行時(shí)間，確定需要執(zhí)行的目標(biāo)任務(wù)；

對于確定的需要執(zhí)行的目標(biāo)任務(wù)，在所述目標(biāo)任務(wù)的任務(wù)執(zhí)行消息體上填寫消息頭信息，并依據(jù)所述目標(biāo)任務(wù)的執(zhí)行域名稱編碼，確定目標(biāo)業(yè)務(wù)域，將所述目標(biāo)任務(wù)發(fā)送至對應(yīng)的目標(biāo)業(yè)務(wù)域中的消息交換機(jī)；

待所述目標(biāo)任務(wù)發(fā)送完成后，依據(jù)所述目標(biāo)任務(wù)的任務(wù)類型，按照與所述任務(wù)類型相對應(yīng)的預(yù)設(shè)處理方法，更新所述目標(biāo)任務(wù)。

可選地，所述按照與所述任務(wù)類型相對應(yīng)的預(yù)設(shè)處理方法，更新所述目標(biāo)任務(wù)包括：

當(dāng)所述目標(biāo)任務(wù)確定為單次型任務(wù)時(shí)，將所述目標(biāo)任務(wù)的任務(wù)狀態(tài)更新為已執(zhí)行狀態(tài)，并記錄所述目標(biāo)任務(wù)的執(zhí)行時(shí)間；

當(dāng)所述目標(biāo)任務(wù)確定為重復(fù)型任務(wù)時(shí)，將所述目標(biāo)任務(wù)的任務(wù)狀態(tài)更新為已執(zhí)行狀態(tài)，記錄所述目標(biāo)任務(wù)的執(zhí)行時(shí)間，并依據(jù)所述目標(biāo)任務(wù)的任務(wù)信息中的corn表達(dá)式，生成新的待執(zhí)行任務(wù)，所述新的待執(zhí)行任務(wù)的任務(wù)ID與所述目標(biāo)任務(wù)的任務(wù)ID相同。