- 論壇徽章:
- 5
|
*面向?qū)ο髮?shí)現(xiàn)
在核心系統(tǒng)這樣大型的軟件系統(tǒng)設(shè)計(jì)中，面向?qū)ο蟮脑O(shè)計(jì)方法，有助于分解復(fù)雜度，既保持抽象統(tǒng)一，又有靈活性。這里說的面向?qū)ο笤O(shè)計(jì)方法，不是指使用面向?qū)ο蟮木幊陶Z言就可以，而是指設(shè)計(jì)系統(tǒng)的思想。系統(tǒng)架構(gòu)不進(jìn)化，即使用Java這樣的面向?qū)ο缶幊陶Z言，也一樣只會(huì)寫出流水賬似的程序。
面向?qū)ο蟮脑O(shè)計(jì)，主要體現(xiàn)在封裝、繼承、多態(tài)。封裝表現(xiàn)為，系統(tǒng)應(yīng)當(dāng)進(jìn)行合理的層次劃分和粒度劃分，識(shí)別出哪些是對(duì)象，并綁定對(duì)象的功能和屬性。對(duì)照來看，產(chǎn)品工廠就是一種面向?qū)ο笤O(shè)計(jì)的典型場(chǎng)景。存貸等產(chǎn)品，對(duì)應(yīng)編程語言的類，是一種抽象封裝。用這個(gè)產(chǎn)品開立的具體賬戶，就是這個(gè)類的實(shí)例。產(chǎn)品可以定義各種使用功能，這個(gè)對(duì)應(yīng)類的成員函數(shù)。產(chǎn)品的功能用到各種參數(shù)做邏輯控制，這個(gè)對(duì)應(yīng)類的成員變量。最簡單的基本產(chǎn)品，可以組合成組合產(chǎn)品，這個(gè)類似于多個(gè)類組合成新的類。產(chǎn)品的定義有層次關(guān)系，例如存款產(chǎn)品--定期存款產(chǎn)品--整存整取--人民幣整存整取--人民幣一年期整存整取，這個(gè)就像類的繼承關(guān)系。上層產(chǎn)品的參數(shù)和功能會(huì)繼承到下層產(chǎn)品中。如果在產(chǎn)品繼承時(shí)，下層產(chǎn)品差異化了功能的實(shí)現(xiàn)行為，這就是多態(tài)。產(chǎn)品工廠在RPGLE中的實(shí)現(xiàn)方法并不復(fù)雜。將參數(shù)按記錄方式保存，取產(chǎn)品參數(shù)后，如果有賬戶層定制，讀取賬戶參數(shù)值覆蓋掉產(chǎn)品參數(shù)值，就實(shí)現(xiàn)了參數(shù)的繼承。通過產(chǎn)品號(hào)的規(guī)則，可以體現(xiàn)產(chǎn)品層次關(guān)系，方便判斷具體產(chǎn)品是否歸屬于某一類。產(chǎn)品的功能實(shí)現(xiàn)多態(tài)，可以按字符串方式保存組件名字，動(dòng)態(tài)調(diào)用即可。
不過在Firebird中通過技術(shù)寫法體現(xiàn)面向?qū)ο蠖鄳B(tài)實(shí)現(xiàn)，在聯(lián)機(jī)交易主控流程中更為明顯。核心系統(tǒng)的聯(lián)機(jī)交易，有一些步驟是所有交易共有的，如獲取交易日期時(shí)間，獲取流水號(hào)，機(jī)構(gòu)柜員檢查等等。因此，有必要定義通用的交易流程，簡化交易應(yīng)用程序的編寫。一方面避免交易應(yīng)用程序的處理遺漏，另一方面當(dāng)需要新增或改動(dòng)共有處理時(shí)，防止出現(xiàn)所有交易全面修改的情況。以前的系統(tǒng)，通常很少有共有交易流程，依賴于每個(gè)交易應(yīng)用程序本身的檢查處理完備性。在Firebird的主控中，細(xì)分出交易流程層，引入面向?qū)ο缶幊谭椒�，將每個(gè)交易公共的步驟集中處理。交易主流程中，由兩種類型的方法組成，一種是非覆蓋方法，各交易不能取代重寫，程序名為PPLMNN1到PPLMNN9，另一種是覆蓋方法，默認(rèn)程序名為SPLMNV1到SPLMNV9，可以由交易根據(jù)情況單獨(dú)定制（根據(jù)程序名實(shí)現(xiàn)對(duì)應(yīng)）。例如020001交易，交易處理程序名為T020001A，則交易主流程中可覆蓋的多態(tài)方法名字則為T020001A1到T020001A9，分別覆蓋SPLMNV1到SPLMNV9，如果未生成對(duì)應(yīng)的多態(tài)程序，主控會(huì)調(diào)用默認(rèn)程序，一旦生成了多態(tài)程序，無需進(jìn)行配置，主控就會(huì)識(shí)別并調(diào)用交易自定義的多態(tài)程序。
下面展示在主控中如何組織交易主流程，實(shí)現(xiàn)識(shí)別覆蓋方法。
- /*BEGIN***************************************************************/
- /*程序名稱：TRANFUNC_H */
- /*功能描述：通用交易聲明 */
- /* */
- /*設(shè)計(jì)人員：PACMAN 開發(fā)人員：PACMAN */
- /*設(shè)計(jì)日期：2011-11-11 開發(fā)日期：2011-11-11 */
- /*-------------------------------------------------------------------*/
- /*維護(hù)人員： */
- /*維護(hù)日期： */
- /*維護(hù)內(nèi)容： */
- /* */
- /*END*****************************************************************/
- #ifndef TRANFUNC_H
- #define TRANFUNC_H
- #include "msginfo_h"
- typedef void (Tran1)(rpg_msg_info* msg, char* in, char* out);
- #pragma linkage(Tran1, OS)
- typedef void (Tran2)(rpg_msg_info* msg, char* in, char* out, char* fe);
- #pragma linkage(Tran2, OS)
- #endif
- /*BEGIN***************************************************************/
- /*程序名稱：TRANFUNC */
- /*功能描述：調(diào)度交易主流程程序 */
- /* */
- /*設(shè)計(jì)人員：PACMAN 開發(fā)人員：PACMAN */
- /*設(shè)計(jì)日期：2011-11-11 開發(fā)日期：2011-11-11 */
- /*-------------------------------------------------------------------*/
- /*維護(hù)人員： */
- /*維護(hù)日期： */
- /*維護(hù)內(nèi)容： */
- /* */
- /*END*****************************************************************/
- #include <stdlib.h>
- #include <stdio.h>
- #include <string.h>
- #include <except.h>
- #include <mih/triml.h>
- #include <mih/rslvsp.h>
- #include "dscppgm/cpyrgt_h"
- #include "config_h"
- #include "tranfunc_h"
- #include "msginfo_h"
- extern void DBCTL(char*);
- extern int trim_str(char *buf, const char *str, int len);
- extern void get_msginfo(msg_info *, const rpg_msg_info *);
- extern msg_info msginfo;
- static int rsl_flag;
- static char rsl_pgm[FILENM_LEN+1];
- void RSLVSP_PGM_HDLR(_INTRPT_Hndlr_Parms_T *errmsg)
- {
- if(strncmp(errmsg->Msg_Id, "MCH3401", 7) == 0)
- {
- strcpy(msginfo.msgid, "EPLMNPGNF ");
- sprintf(msginfo.msgtext, "調(diào)用程序%s未找到", rsl_pgm);
- rsl_flag = 1;
- }
- else
- {
- strcpy(msginfo.msgid, "EPLMNPGER ");
- sprintf(msginfo.msgtext, "查找程序%s時(shí)出錯(cuò)%7.7s",
- rsl_pgm, errmsg->Msg_Id);
- rsl_flag = 2;
- }
- }
- int execute_rslvsp(char* pgm_nm, int type, Tran1** pt1, Tran2** pt2)
- {
- rsl_flag = 0;
- strcpy(rsl_pgm, pgm_nm);
- #pragma exception_handler (RSLVSP_PGM_HDLR,rsl_flag,0,_C2_MH_ESCAPE,\
- _CTLA_HANDLE_NO_MSG)
- if(type == 1)
- *pt1 = rslvsp(_Program, pgm_nm, "*LIBL", _AUTH_OBJ_MGMT);
- else
- *pt2 = rslvsp(_Program, pgm_nm, "*LIBL", _AUTH_OBJ_MGMT);
- #pragma disable_handler
- return rsl_flag;
- }
- void clear_msg(void)
- {
- msginfo.msgid[0]='\0';
- msginfo.msgtext[0]='\0';
- }
- int check_msgid(void)
- {
- if (triml(msginfo.msgid, ' ')!=0)
- {
- if (strncmp(msginfo.msgid, "EPLMNREST", 9)==0)
- return 1;
- else
- return -1;
- }
- return 0;
- }
- int execute_overpgm(char* overwt, char* dft, int type,
- char* in, char* out, char* fe)
- {
- Tran1 *tran1;
- Tran2 *tran2;
- rpg_msg_info rpginfo;
- int ret;
- memset(&rpginfo, ' ', sizeof(rpginfo));
- if (type==1)
- {
- ret=execute_rslvsp(overwt, 1, &tran1, &tran2);
- if (ret==1)
- {
- clear_msg();
- ret=execute_rslvsp(dft, 1, &tran1, &tran2);
- }
- if (ret!=0)
- return -2;
- tran1(&rpginfo, in, out);
- }
- else
- {
- ret=execute_rslvsp(overwt, 2, &tran1, &tran2);
- if (ret==1)
- {
- clear_msg();
- ret=execute_rslvsp(dft, 2, &tran1, &tran2);
- }
- if (ret!=0)
- return -2;
- tran2(&rpginfo, in, out, fe);
- }
- get_msginfo(&msginfo, &rpginfo);
- return check_msgid();
- }
- int execute_pgm(char* pgm_nm, int type, char* in, char* out, char* fe)
- {
- Tran1 *tran1;
- Tran2 *tran2;
- rpg_msg_info rpginfo;
- int ret;
- memset(&rpginfo, ' ', sizeof(rpginfo));
- if (type == 1)
- {
- ret=execute_rslvsp(pgm_nm, 1, &tran1, &tran2);
- if (ret!=0)
- return -2;
- tran1(&rpginfo, in, out);
- }
- else
- {
- ret=execute_rslvsp(pgm_nm, 2, &tran1, &tran2);
- if (ret!=0)
- return -2;
- tran2(&rpginfo, in, out, fe);
- }
- get_msginfo(&msginfo, &rpginfo);
- return check_msgid();
- }
- int process_tran(const char* tr_cd, char* tr_pgm,
- char* in, char* out, char* fe, char flg)
- {
- char pgms[9][FILENM_LEN+1];
- char trpgm[FILENM_LEN+1];
- int ret=0, i;
- if (trim_str(trpgm, tr_pgm, FILENM_LEN) > FILENM_LEN-1)
- {
- strcpy(msginfo.msgid, "EPLMNPGTL ");
- sprintf(msginfo.msgtext, "交易程序名%s太長", trpgm);
- return -2;
- }
- /*給該交易的每個(gè)覆蓋方法賦值*/
- for (i=0; i<9; i++)
- sprintf(pgms[i], "%s%1d", trpgm, i+1);
- for (;;)
- {
- /* 交易初始化*/
- if (ret==0)
- ret = execute_pgm("PPLMNN1", 1, in, out, fe);
- /* 覆蓋方法1交易預(yù)處理 */
- if (ret==0)
- ret = execute_overpgm(pgms[0], "SPLMNV1", 1, in, out, fe);
- /* 柜員歸屬檢查 */
- if (ret==0)
- ret = execute_pgm("PPLMNN2", 1, in, out, fe);
- /* 覆蓋方法2交易機(jī)構(gòu)柜員檢查*/
- if (ret==0)
- ret = execute_overpgm(pgms[1], "SPLMNV2", 1, in, out, fe);
- /* 生成交易流水號(hào)*/
- if (ret==0)
- ret = execute_pgm("PPLMNN3", 1, in, out, fe);
- /* 覆蓋方法3交易收費(fèi)計(jì)算*/
- if (ret==0)
- ret = execute_overpgm(pgms[2], "SPLMNV3", 2, in, out, fe);
- /* 費(fèi)用核對(duì)*/
- if (ret==0)
- ret = execute_pgm("PPLMNN4", 2, in, out, fe);
- /* 調(diào)用交易程序*/
- if (ret==0)
- ret = execute_pgm(trpgm, 1, in, out, fe);
- /* 調(diào)用費(fèi)用收費(fèi)并進(jìn)行傳票重整服務(wù)*/
- if (ret==0)
- ret = execute_pgm("PPLMNN5", 1, in, out, fe);
- /* 覆蓋方法4寫輸出接口*/
- if (ret==0)
- ret = execute_overpgm(pgms[3], "SPLMNV4", 1, in, out, fe);
- /* 返回處理*/
- if (ret==0)
- ret = execute_pgm("PPLMNN6", 1, in, out, fe);
- if (ret==0 && flg==DEBUG_NO)
- DBCTL(DB_COMMIT);
- else
- DBCTL(DB_ROLLBACK);
- if (ret!=1)
- break;
- clear_msg();
- }
- return ret;
- }
注意交易主流程中，識(shí)別是否出現(xiàn)交易重新執(zhí)行的特殊錯(cuò)誤代碼EPLMNREST，如果出現(xiàn)則原事務(wù)回滾并重新開始執(zhí)行整個(gè)交易流程。這能解決一些特定場(chǎng)景，例如第三方來賬如果入賬不成功，需要直接掛待銷賬。通過修改輸入結(jié)構(gòu)的某些字段值，并返回EPLMNREST錯(cuò)誤代碼，這樣在核心系統(tǒng)一次交易即可實(shí)現(xiàn)入賬或掛賬功能。
|
|
免費(fèi)注冊(cè)
發(fā)表于 2016-04-11 01:50
;
PLMNN1", 1, in, out, fe);