【正文】 當(dāng)提交時就把對任務(wù)/任務(wù)的維護結(jié)果寫到后臺數(shù)據(jù)庫。結(jié)果：當(dāng)增加任務(wù)/任務(wù)組時，在數(shù)據(jù)庫的任務(wù)/任務(wù)組表應(yīng)該增加一條記錄。當(dāng)修改任務(wù)/任務(wù)組時，在那條相應(yīng)的記錄要做相應(yīng)的修改。同樣，刪除任務(wù)/任務(wù)組就要求把那條記錄從表中刪除。216。 任務(wù)實例監(jiān)控功能：對在運行的任務(wù)實例進行監(jiān)控，可以查詢?nèi)蝿?wù)實例的狀態(tài)。過程：在點擊了查詢按鈕以后，前臺訪問數(shù)據(jù)庫的任務(wù)實例表，取出正在運行的任務(wù)實例紀(jì)錄。結(jié)果：前臺將這些正在運行的任務(wù)實例紀(jì)錄返回到界面。216。 任務(wù)實例狀態(tài)修改功能：對任務(wù)組實例中的任務(wù)實例運行狀態(tài)進行修改。過程：前臺按照用戶指定的條件查詢數(shù)據(jù)庫的任務(wù)實例表，并找到相應(yīng)的記錄。前臺根據(jù)用戶所選擇任務(wù)實例及修改后的狀態(tài)更新數(shù)據(jù)的任務(wù)實例表。結(jié)果：返回用戶查詢的任務(wù)實例的各種狀態(tài)。對數(shù)據(jù)庫的任務(wù)實例的各狀態(tài)字段進行更新。返回更新后的任務(wù)實例狀態(tài)結(jié)果給用戶。216。 日志查詢功能：對任務(wù)實例日志的過程日志進行查詢。過程：前臺根據(jù)用戶指定的查詢條件查詢數(shù)據(jù)庫的任務(wù)實例日志表。結(jié)果：將查詢后找到的記錄返回到前臺界面。216。 任務(wù)組/任務(wù)實例生成功能：掃描任務(wù)組表，實例化符合啟動條件的任務(wù)組，將任務(wù)組寫入任務(wù)組實例表。過程：當(dāng)程序剛啟動，掃描任務(wù)實例表結(jié)束正在運行的任務(wù)。然后掃描任務(wù)組，取出所有屬于自己但是未實例化的任務(wù)組。接著判斷任務(wù)組中的每個任務(wù)有沒有約束條件；如果有則判斷所依賴的任務(wù)組是否完成；如果沒有完成則從要實例化的任務(wù)組里面取出下一個任務(wù)進行判斷。如果沒有約束條件，則根據(jù)任務(wù)組啟動的時間信息，判斷是否可以實例化該任務(wù)組；如果時間信息不滿足條件，則從要實例化的任務(wù)組里面取出下一個任務(wù)進行判斷。如果時間信息滿足實例化條件，則判斷該任務(wù)組在該時間點有沒有實例化過；如果有被實例化，則從要實例化的任務(wù)組里面取出下一個任務(wù)進行判斷。如果沒有被實例化，則實例化該任務(wù)組。當(dāng)任務(wù)組被實例化后，則根據(jù)該任務(wù)組的組成生成每個任務(wù)實例。結(jié)果：殺掉在程序剛啟動時正在運行的任務(wù)實例、生成任務(wù)組實例和任務(wù)實例。216。 任務(wù)實例調(diào)度功能：掃描任務(wù)實例表，調(diào)度尚沒有啟動的任務(wù)實例。過程：掃描任務(wù)實例表取出所有未運行、回滾、待刪除的任務(wù)實例，根據(jù)任務(wù)的狀態(tài)進行相應(yīng)的處理：如果任務(wù)實例的狀態(tài)是待刪除，則終止該任務(wù)實例，并修改任務(wù)實例狀態(tài)為異常運行結(jié)束，并從符合條件的任務(wù)實例中取下一條記錄來判斷。如果任務(wù)實例的狀態(tài)為回滾，則首先判斷該任務(wù)實例所屬的任務(wù)組是否有依賴條件，如果有依賴條件，則判斷該依賴條件是否已經(jīng)運行完成，如果沒有完成，則從符合條件的任務(wù)實例中取下一條記錄來判斷。如果該任務(wù)實例有依賴條件，并且所依賴的任務(wù)組已經(jīng)完成，或者任務(wù)實例沒有依賴條件，則與任務(wù)實例狀態(tài)為未運行的處理方式一樣。如果任務(wù)實例的狀態(tài)為未運行，則先判斷任務(wù)實例中是否有相同的任務(wù)，如果有相同的任務(wù)并且任務(wù)的狀態(tài)為正在運行、待刪除、異常結(jié)束，則從符合條件的任務(wù)實例中取下一條記錄來判斷。如果已經(jīng)完成，則判斷該任務(wù)實例的后置任務(wù)是否已經(jīng)完成，如果后置任務(wù)的實例狀態(tài)為為正在運行、待刪除、異常結(jié)束，則從符合條件的任務(wù)實例中取下一條記錄來判斷。否則，關(guān)聯(lián)該任務(wù)實例的依賴條件，判斷能否啟動該任務(wù)實例。當(dāng)掃描出來的任務(wù)實例都遍歷完成后，判斷任務(wù)實例中有無僵死進程，如果有，則終止所有的僵死進程。否則，掃描任務(wù)實例表，如果任務(wù)組中的任務(wù)實例都運行完成，則更新任務(wù)組實例的狀態(tài)。結(jié)果：修改任務(wù)組實例狀態(tài)，修改任務(wù)實例狀態(tài)，啟動符合條件的任務(wù)實例和殺掉所有僵死進程。 ETL任務(wù)調(diào)度概述所謂ETL任務(wù)調(diào)度，就是考慮到ETL任務(wù)的處理的多樣性和復(fù)雜性，引入了job的概念，把ETL處理過程分成為一個一個的job。job可能是抽取、清洗、轉(zhuǎn)換或加載，也可能是PI加工。為了對復(fù)雜的ETL處理過程更好的調(diào)度和監(jiān)控，為了在多用戶多任務(wù)的環(huán)境下處理好各種任務(wù)請求，專門設(shè)計的一個ETL調(diào)度功能模塊。通過ETL高度系統(tǒng)的開發(fā)使用，不僅可以快速準(zhǔn)確有效地處理ETL過程，還能提供更彈性的擴展空間。 任務(wù)/任務(wù)組實例化： 任務(wù)實例調(diào)度： 調(diào)度流程圖通過設(shè)置校驗參數(shù)（校驗名稱、校驗邏輯、校驗指標(biāo)等信息）和校驗?zāi)_本（包括：SQL、DB函數(shù)、SHELL腳本、存儲過程）來對流里面配置的節(jié)點進行校驗，根據(jù)不同的校驗?zāi)_本執(zhí)行返回值以及校驗邏輯來確定改任務(wù)的返回值，由此來確定該節(jié)點的狀態(tài)。 數(shù)據(jù)結(jié)構(gòu)無 流程： 校驗流程ID流程步驟內(nèi)容概述1根據(jù)“校驗信息表”在內(nèi)存中生成需要校驗的“節(jié)點校驗記錄“查詢“校驗信息表（META_STEP_INDI_REL）”，得到該節(jié)點的所有校驗信息。查詢條件為：tep_task_id = :g_nStepTaskID。得到的數(shù)據(jù)包括下列字段的值：STEP_INDI_REL_SEQ，AUDIT_CATG_IDINDI_SCRIPT_ID，NVL(SUCC_MSG,39。 39。)NVL(FAIL_MSG,39。 39。)，AUDIT_LEVELSTEP_INDI_REL_ID2準(zhǔn)備處理上一步產(chǎn)生的第一條“校驗信息”記錄申明并打開游標(biāo)，提取記錄信息。3根據(jù)“腳本ID”記錄查詢“meta_indi_script表”取得腳本類型和腳本內(nèi)容SELECT script_type rule_script //腳本內(nèi)容FROM meta_indi_scriptwhere indi_script_id = :g_nIndiScriptID。4是否可以查到是走6，否走55程序退出提示沒有查詢到第%d條script_type, rule_script記錄%s,g_nStepTaskID=%d\。退出6判斷腳本類型是否合法腳本類型要在（1~4）之間7刪除該節(jié)點該帳期該指標(biāo)過去的所有校驗信息刪除META_STEP_INDI_REL_INST表META_STEP_INDI_LOG_DETAIL表META_STEP_INDI_AUDIT_DTL表的相關(guān)信息Where條件為： = :g_nBillingCycle)and ( = :g_nStepTaskID)and ( = ) and( = :g_nStepIndiRelID))。8進行宏替換用實際值替換腳本中的宏9判斷腳本類型并調(diào)度腳本根據(jù)腳本類型調(diào)度腳本，并根據(jù)腳本返回值確定g_nAuditState的值10調(diào)用setAuditState()根據(jù)校驗邏輯和腳本返回值確定校驗返回狀態(tài)nAuditState11調(diào)用updAuditState()修改meta_step_indi_rel_inst表中校驗狀態(tài)UPDATE meta_step_indi_rel_inst SET audit_state = :g_nAuditState where ((billing_cycle = :g_nBillingCycle) AND (step_indi_rel_id = :g_nStepIndiRelID) AND (exec_counts = :g_nExecCounts))。12根據(jù)nAuditState確定程序返回值根據(jù)nAudit的值確定g_nReturnValue的值13關(guān)閉日志文件，程序退出fclose( fLog )。return g_return_value。： 校驗流程圖AllocDescriptors()功能：為描述區(qū)SQLDA分配空間，設(shè)置最大的列數(shù)，或最大的變量數(shù)，給存放指示符變量值和存放數(shù)據(jù)的變量申請空間。： 參數(shù)表參數(shù)名稱參數(shù)類型方向參數(shù)描述sizeint輸入第一個參數(shù)是SQL語句的最大列數(shù)或輸入宿主變量的最大個數(shù)max_vnameint輸入第二個參數(shù)，是指列名的最大長度，或參數(shù)名的最大長度max_iname_lenint輸入第三個參數(shù)，是指指示符變量名的最大長度。： 返回值返回值返回值類型描述0int函數(shù)執(zhí)行成功－1int函數(shù)執(zhí)行失敗函數(shù)流程：216。 為SQLDA需要輸入的動態(tài)參數(shù)分配空間。216。 為SQLDA動態(tài)查詢的變量分配空間。216。 設(shè)置最大列數(shù)和最大變量數(shù)。216。 給存放指示符變量值和存放數(shù)據(jù)的變量申請空間。異常處理：1) 當(dāng)給綁定變量分配空間出錯時：TRACE( [ERROR]Cannot allocate memory for bind descriptor.)。return 1。2) 當(dāng)給選擇變量分配空間失敗時：TRACE([ERROR]Cannot allocate memory for select descriptor.)。return 1。ProcessSelectList()功能：在sql動態(tài)方法4中，專門處理選擇區(qū)變量，如果不是查詢語句，則設(shè)置F（即返回的列數(shù)）為0，如果是SELECT語句，則通過DESCRIBE函數(shù)返回列名、數(shù)據(jù)類型、長度和是否為NULL標(biāo)志，調(diào)用InsertAuditDtl（）函數(shù)保存校驗數(shù)據(jù)。無參數(shù)和返回值。函數(shù)流程：216。 判斷sql語句是否為select語句，如果不是則設(shè)置F（即返回的列數(shù)）為0。216。 如果是SELECT語句，則通過DESCRIBE函數(shù)返回列名、數(shù)據(jù)類型、長度和是否為NULL標(biāo)志。216。 設(shè)置最大列數(shù)為實際列數(shù)。216。 根據(jù)不同的數(shù)據(jù)類型給選擇變量確定L值。216。 執(zhí)行select語句，并將取出的數(shù)據(jù)循環(huán)處理，調(diào)用InsertAuditDtl函數(shù)將數(shù)據(jù)結(jié)果保存到META_STEP_INDI_AUDIT_DTL表中。異常處理：1) 如果sql語句不是select語句時：select_dpF = 0。 //設(shè)置實際選擇的變量數(shù)為0return 。2) 當(dāng)bind_dpF 0（實際的參數(shù)超出了預(yù)算的最大值)：printf(\nToo many selectlist items (%d), maximum is %d\n, (select_dpF), MAX_ITEMS)。return。3) 當(dāng)變量的實際長度大于設(shè)定的綁定便利的最大長度時：TRACE( select_dpV[i]長度為%d,超過g_stIndiNodeValue值最大長度%d,從該字段起取數(shù)據(jù)失敗!\n, strlen(select_dpV[i]), sizeof(g_stIndiNodeValue))。bIsContinue = false。break。SetBindVariables()功能：在sql動態(tài)方法4中，專門處理綁定區(qū)變量，通過DESCRIBE語句，將處理語句的參數(shù)名、數(shù)據(jù)類型等信息存放在bind_dp中。無參數(shù)和返回值。函數(shù)流程：216。 設(shè)定綁定區(qū)變量的最大個數(shù)。216。 判斷戰(zhàn)位符的正確性，并設(shè)置占位符的個數(shù)為實際應(yīng)用的個數(shù)。216。 根據(jù)不同的數(shù)據(jù)類型給綁定變量確定L值。異常處理：當(dāng)bind_dpF 0（實際的參數(shù)超出了預(yù)算的最大值）：TRACE(\nToo many bind variables (%d), maximum is %d.\n, bind_dpF, MAX_ITEMS)。return。ProcessScript（）功能：用于處理SQL腳本，調(diào)用AllocDescriptors（）為描述區(qū)分配空間，調(diào)用Proces