Chinaunix首页 | 论坛 | 博客

随心飞旋的ChinaUnix博客

首页　| 　博文目录　| 　关于我

随心飞旋

  • 博客访问： 7039
  • 博文数量： 5
  • 博客积分： 195
  • 博客等级： 入伍新兵
  • 技术积分： 75
  • 用 户 组： 普通用户
  • 注册时间： 2012-07-16 11:02
文章分类

全部博文（5）

文章存档

2012年（5）

我的朋友
最近访客
推荐博文
相关博文
对日C客服端SOCKET通讯——小试牛刀

分类： C/C++

2012-08-02 09:25:41


点击(此处)折叠或打开

  1. #include <sys/types.h>
  2. #include <sys/socket.h>
  3. #include <stdio.h>
  4. #include <stdlib.h>
  5. #include <netinet/in.h>
  6. #include <arpa/inet.h>
  7. #include <unistd.h>
  8. #include <errno.h>
  9. #include <stdarg.h>
  10. #include <syslog.h>
  11. #include <string.h>
  12. #include <time.h>
  13. #include <sys/timeb.h>
  14. #include <netdb.h>

  16. /*************/
  17. /* 定数宣言 */
  18. /*************/
  19. #define BUFFER_SIZE 1024
  20. #define MAILTXT_SIZE 1024
  21. #define NAME_SIZE 100
  22. #define TIME_SIZE 30
  23. #define DESTSERV "localhost"

  25. /*******************/
  26. /* グローバル変数 */
  27. /*******************/

  29. /* プログラム名 */
  30. char *prgname = NULL;
  31. /* ログメッセージファイルパス */
  32. char *logmsgfiledir = NULL;
  33. /* 吖堀弗绁芝庭氓菼D */
  34. char *jobnetid = NULL;
  35. /* 吖堀弗绁諭D */
  36. char *jobid = NULL;
  37. /* 最上位吖堀弗绁芝庭氓菼D */
  38. char *topjobnetid = NULL;

  40. /**************************************************************************************/
  41. /* 関数名：main */
  42. /* 関数名称：メイン関数 */
  43. /* 機能概要：業務アプリケーション起動 */
  44. /* 引数 ：(1)ログ+メッセージファイルパス */
  45. /* (2)ポート番号 */
  46. /* (3)送信電文（1個以上） */
  47. /* 戻り値 ：(0)正常終了 */
  48. /* (1)異常終了 */
  49. /**************************************************************************************/
  50. int main(int argc, char *argv[])
  51. {
  52.     /* ソケット作成戻り値を格?span style="color:#0000CC;">{する変数 */
  53.     int sockfd ;
  54.     /* 送信電文の文字列長 */
  55.     int lenmail ;
  56.     /* ポート番号 */
  57.     int hostno ;
  58.     /* 戻り値を格?span style="color:#0000CC;">{する変数 */
  59.     int result ;
  60.     /* ソケットアドレス */
  61.     struct sockaddr_in address ;
  62.     /* アドレス*/
  63.     struct hostent *hostent;
  64.     /* 送信電文の8文字の数字文字列長*/
  65.     char strlenmail[8];
  66.     /* エラーログ出力関数に置換文字列 */
  67.     char *vaparmeter[10];
  68.     /* 送信電文 */
  69.     char mailtxt[MAILTXT_SIZE];
  70.     /* 要求電文送信 */
  71.     char tomailtxt[MAILTXT_SIZE];
  72.     /* 受信電文 */
  73.     char remailbuff[MAILTXT_SIZE];
  74.     /* 受信の戻り値 */
  75.     char remailcode[1];
  76.     /* メッセージ本文バッファ*/
  77.     char msgtxtbuff[BUFFER_SIZE];
  78.     /* メッセージ本文*/
  79.     char msgtxt[BUFFER_SIZE];
  80.     /* ホスト名*/
  81.     char hostname[NAME_SIZE];
  82.     /* ローカル変数の文字列*/
  83.     char strNo[NAME_SIZE];
  84.     /* エラー番号の文字列*/
  85.     char strerrNo[NAME_SIZE];

  87.     /* システム時間を取得する*/
  88.     time_t rawtime;
  89.     struct tm * timeinfo;
  90.     time ( &rawtime );
  91.     timeinfo = localtime ( &rawtime );
  92.     struct timeb tp;
  93.     ftime(&tp);
  94.     char strtime[TIME_SIZE];
  95.     /* システム時間がフォーマット「yyyy/MM/dd HH:mm:ss.SSS」に変換する*/
  96.     strftime ( strtime,TIME_SIZE,"%Y/%m/%d %H:%M:%S",timeinfo);
  97.     sprintf(strtime,"%s.%03d\n",strtime,tp.millitm);

  99.     /* 起動パラメタの0個目からプログラム名を取得する。 */
  100.     /* 取得したプログラム名をグローバル変数に設定する。*/
  101.     prgname=argv[0];

  103.     /* パラメタ取得 */
  104.     /* 起動パラメタ数が3以上であること*/
  105.     /* 上記でない場合*/
  106.     if ( 3>=argc ){

  108.        /* メッセージレベルが"ERR"固定*/
  109.        strcat(msgtxtbuff , "ERR");
  110.        strcat(msgtxtbuff , " ");

  112.        /* センタ情報が環境変数よりセンタ情報を取得する*/
  113.       strcat(msgtxtbuff , getenv("CENTER"));
  114.        strcat(msgtxtbuff , " ");

  116.        /* ホスト名が標準関数よりホスト名を取得する*/
  117.        gethostname(hostname, sizeof(hostname));
  118.        strcat(msgtxtbuff , hostname);
  119.        strcat(msgtxtbuff , " ");

  121.        /* 吖堀弗绁芝庭氓菼Dが環境変数より吖堀弗绁芝庭氓菼D情報を取得する*/
  122.        strcat(msgtxtbuff , getenv("JOBSCH_JOBNET"));
  123.        strcat(msgtxtbuff , "/");

  125.        /* 吖堀弗绁諭Dが環境変数より吖堀弗绁諭D情報を取得する*/
  126.        strcat(msgtxtbuff , getenv("JC_JOBID"));
  127.        strcat(msgtxtbuff , " ");

  129.        /* 出力日時がシステム時間を取得する*/
  130.        strcat(msgtxtbuff , strtime);
  131.        strcat(msgtxtbuff , " : ");
  132.     
  133.        /* メッセージカテゴリが"IFR"固定*/
  134.        strcat(msgtxtbuff , "IFR");
  135.        strcat(msgtxtbuff , " : : ");

  137.        /* メソッド名が関数名*/
  138.        strcat(msgtxtbuff , __func__);
  139.        strcat(msgtxtbuff , " : ");

  141.        /* メッセージIDが"BALCCBA803E"固定*/
  142.        strcat(msgtxtbuff , "BALCCBA803E");
  143.        strcat(msgtxtbuff , " : ");

  145.        /* メッセージ本文を作成する*/
  146.        sprintf(msgtxt,"The program will exit for the number of parameters is incorrect.(Number :%d)",argc-1);
  147.        /* メッセージ本文バッファを作成する*/
  148.        strcat(msgtxtbuff , msgtxt);
  149.        /* 作成したエラーログメッセージをパラメタとしエラーログ出力関数（内部）を呼び出*/
  150.        outputSysLog(msgtxtbuff);
  151.        /* リターンコード：1 */
  152.        exit(1);
  153.     }

  155.     /* 起動パラメタの1個目からログメッセージファイルパスを取得する。*/
  156.     /* 取得したログメッセージファイルパスをグローバル変数に設定する。*/
  157.     logmsgfiledir=argv[1];

  159.     /* 起動パラメタの2個目からポート番号を取得する。*/
  160.     hostno = atoi(argv[2]);
  161.     /* ポート番号が数値に変換できなかった場合 */
  162.     if ( hostno<=0 || hostno>65535 ) {

  164.       /* エラーログ出力関数に置換文字列 */
  165.       vaparmeter[0] = argv[2];
  166.       /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  167.       outputErrLog(__func__,"BALCCBA804E",(char*)vaparmeter);
  168.       /* リターンコード：1 */
  169.       exit(1);
  170.     }

  172.     /* 送信電文作成*/
  173.     /* 空の送信電文バッファを用意する*/
  174.     memset(mailtxt , '\0' , MAILTXT_SIZE);

  176.     int i;
  177.     /* 起動パラメタの 3個目から最後のパラメタまで、次の処理を繰り返す*/
  178.     for(i=3;i<argc;i++)
  179.     {

  181.        /* パラメタが「JOBSCH_JOBNET=」で始ま*/
  182.        if( strncmp(argv[i],"JOBSCH_JOBNET=",14) == 0){

  184.           /* 既に吖堀弗绁芝庭氓菼D が NULLの場合*/
  185.           if( NULL == jobnetid ){
  186.               /* 当該項目の"="以降の値を取得する */
  187.               jobnetid=strtok(argv[i],"JOBSCH_JOBNET=");
  188.           }
  189.           else
  190.           /* 既に吖堀弗绁芝庭氓菼D が NULL ではなかった場合*/
  191.           {
  192.              /* エラーログ出力関数に置換文字列 */
  193.              vaparmeter[0] = "JOBSCH_JOBNET";
  194.              /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  195.              outputErrLog(__func__,"BALCCBA805E",(char*)vaparmeter);
  196.              /* リターンコード：1 */
  197.              exit(1);
  198.           }
  199.        }

  201.        /* パラメタが「JC_JOBID=」で始ま*/
  202.        if( strncmp(argv[i],"JC_JOBID=",9) == 0){
  203.           /* 既に吖堀弗绁諭D が NULLの場合*/
  204.           if( NULL == jobid ){
  205.              /* 当該項目の"="以降の値を取得する */
  206.              jobid=strtok(argv[i],"JC_JOBID=");
  207.           }else
  208.           /* 既に吖堀弗绁諭D が NULL ではなかった場合*/
  209.           {
  210.              /* エラーログ出力関数に置換文字列 */
  211.              vaparmeter[0] = "JC_JOBID";
  212.              /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  213.              outputErrLog(__func__,"BALCCBA805E",(char*)vaparmeter);
  214.              /* リターンコード：1 */
  215.              exit(1);
  216.           }
  217.        }

  219.        /* パラメタが「TOP_JOBSCH_JOBNET=」で始ま*/
  220.        if(strncmp(argv[i],"TOP_JOBSCH_JOBNET=",18) == 0){
  221.           /* 既に吖堀弗绁諭D が NULLの場合*/
  222.           if( NULL == topjobnetid ){
  223.              /* 当該項目の"="以降の値を取得する */
  224.              topjobnetid=strtok(argv[i],"TOP_JOBSCH_JOBNET=");
  225.           }else
  226.           /* 既に吖堀弗绁諭D が NULL ではなかった場合*/
  227.           {
  228.              /* エラーログ出力関数に置換文字列 */
  229.              vaparmeter[0] = "TOP_JOBSCH_JOBNET";
  230.              /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  231.              outputErrLog(__func__,"BALCCBA805E",(char*)vaparmeter);
  232.              /* リターンコード：1 */
  233.              exit(1);
  234.           }
  235.        }

  237.        /* パラメタに "=" が含まれていない場合*/
  238.        if(strstr(argv[i],"=") == 0){
  239.           /* エラーログ出力関数に置換文字列 */
  240.           sprintf(strNo,"%d", i);
  241.           vaparmeter[0] = strNo;
  242.           vaparmeter[1] = argv[i];
  243.           /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  244.           outputErrLog(__func__,"BALCCBA806E",(char*)vaparmeter);
  245.           /* リターンコード：1 */
  246.           exit(1);
  247.        }
  248.        /* 送信電文が NULL ではなかった場合*/
  249.        if( strlen(mailtxt) != 0 ){
  250.           strcat(mailtxt,"&");
  251.        }
  252.        /* 送信電文バッファにパラメタを追記する*/
  253.        strcat(mailtxt,argv[i]);
  254.     }

  256.     /*吖堀弗绁芝庭氓菼D または吖堀弗绁諭D または最上位吖堀弗绁芝庭氓菼DのいずれかがNULL だった場合*/
  257.     if( ( NULL == jobnetid ) || ( NULL == jobid ) || ( NULL == topjobnetid ) ){
  258.        /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  259.        outputErrLog(__func__,"BALCCBA807E",(char*)vaparmeter);
  260.        /* リターンコード：1 */
  261.        exit(1);
  262.     }

  264.     /* ソケット作成（socket）*/
  265.     /* ソケット作成に失敗した場合*/
  266.     if (( sockfd = socket(AF_INET,SOCK_STREAM,0) ) <0 ) {

  268.       /* エラーログ出力関数に置換文字列 */
  269.       sprintf(strerrNo,"%d", errno);
  270.       vaparmeter[0] = strerrNo;
  271.       vaparmeter[1] = strerror(errno);
  272.       /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  273.       outputErrLog(__func__ , "BALCCBA808E" , (char*)vaparmeter);
  274.       /* リターンコード：1 */
  275.       exit(1);
  276.     }

  278.     /* ソケットアドレス作成（sockaddr_in）*/
  279.     /* ソケットアドレスを0x00で初期化する */
  280.     memset( &address , 0x00 , sizeof(address) );
  281.     /* アドレスファミリー：AF_INET */
  282.     address.sin_family = AF_INET;
  283.     /* アドレス："localhost"を指定して取得したIPアドレス*/
  284.     hostent = gethostbyname(DESTSERV);
  285.     bcopy(hostent->h_addr, &address.sin_addr, hostent->h_length);

  287.     /* ポート番号*/
  288.     address.sin_port = htons(hostno);

  290.     /* ソケットの接続（connect）*/
  291.     /* ソケットを接続する */
  292.     result = connect(sockfd , (struct sockaddr *)&address , sizeof(address));

  294.     /* ソケット接続に失敗した場合*/
  295.     if ( result == -1 ) {
  296.       /* エラーログ出力関数に置換文字列 */
  297.       vaparmeter[0] = argv[2];
  298.       sprintf(strerrNo,"%d", errno);
  299.       vaparmeter[1] = strerrNo;
  300.       vaparmeter[2] = strerror(errno);
  301.       /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  302.       outputErrLog(__func__,"BALCCBA809E",(char*)vaparmeter);

  304.       /* リターンコード：1 */
  305.       exit(1);
  306.     }

  308.     /* 送信電文の文字列長を取得する */
  309.     lenmail=strlen(mailtxt);
  310.     /* 8文字の数字文字列にしたもの（%08d に相当）*/
  311.     sprintf(strlenmail,"%08d",lenmail);

  313.     /* 要求電文送信を作成*/
  314.     /* 空の送信電文バッファを用意する*/
  315.     memset(tomailtxt,0x00,sizeof(tomailtxt));
  316.     strcat(tomailtxt,strlenmail);
  317.     strcat(tomailtxt,mailtxt);
  318.     /* 要求電文送信（write）*/
  319.     result = write(sockfd,tomailtxt,strlen(tomailtxt));

  321.     /* 要求電文送信に失敗した場合*/
  322.     if ( result == -1 ) {
  323.       /* エラーログ出力関数に置換文字列 */
  324.       vaparmeter[0] = argv[2];
  325.       sprintf(strerrNo,"%d", errno);
  326.       vaparmeter[1] = strerrNo;
  327.       vaparmeter[2] = strerror(errno);
  328.       /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  329.       outputErrLog(__func__,"BALCCBA810E",(char*)vaparmeter);
  330.       /* リターンコード：1 */
  331.       exit(1);
  332.     }

  334.     /* 応答電文受信（read）*/
  335.     result = read(sockfd,remailbuff,sizeof(remailbuff));
  336.     /* 応答電文受信に失敗した場合*/
  337.     if ( result == -1 ) {
  338.       /* エラーログ出力関数に置換文字列 */
  339.       vaparmeter[0] = argv[2];
  340.       sprintf(strerrNo,"%d", errno);
  341.       vaparmeter[1] = strerrNo;
  342.       vaparmeter[2] = strerror(errno);
  343.       /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  344.       outputErrLog(__func__,"BALCCBA811E",(char*)vaparmeter);
  345.       /* リターンコード：1 */
  346.       exit(1);
  347.     }

  349.     /* データが数値文字列ではない場合*/
  350.     if( ((char*)remailbuff == '\0') || (strlen(remailbuff) != 8) ){
  351.         /* エラーログ出力関数に置換文字列 */
  352.         vaparmeter[0] = argv[2];
  353.         vaparmeter[1] = remailbuff;
  354.        /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  355.        outputErrLog(__func__,"BALCCBA812E",(char*)vaparmeter);
  356.        /* リターンコード：1 */
  357.        exit(1);
  358.     }

  360.     /* ソケットクローズ（close）*/
  361.     close(sockfd);
  362.     /* 応答電文解析 */
  363.     /* 応答電文から"status="文字列を検索する */
  364.     if(strstr(remailbuff,"status=") == 0)
  365.     {
  366.       /* エラーログ出力関数に置換文字列 */
  367.       vaparmeter[0] = argv[2];
  368.       vaparmeter[1] = remailbuff;
  369.       /* エラーログ出力関数呼び出しエラーログを出力し終了する。*/
  370.       outputErrLog(__func__ , "BALCCBA812E" , (char*)vaparmeter);
  371.       /* リターンコード：1 */
  372.       exit(1);
  373.     }

  375.     /* 検索した位置から"status="の文字列サイズ後方の1文字を取得する */
  376.     strncpy( remailcode, strtok(remailbuff,"status="), 1);
  377.     result = atoi(remailcode);
  378.     /*exitコード返却（exit）*/
  379.     exit(result);
  380. }

  382. /**************************************************************************************/
  383. /* 関数名：outputErrLog */
  384. /* 関数名称：エラーログ出力関数 */
  385. /* 機能概要：syslogにエラーメッセージを出力する。 */
  386. /* 引数 ：(1)関数名 */
  387. /* (2)メッセージID */
  388. /* (3)置換文字列（可変パラメタ） */
  389. /* 戻り値 ：(0)正常終了 */
  390. /* (1)異常終了 */
  391. /**************************************************************************************/
  392. int outputErrLog (const char *funname,const char *msgid,char *vaparmeter)
  393. {

  395.     /* 戻り値を格?span style="color:#0000CC;">{する変数 */
  396.     int result ;
  397.     /* ログメッセージバッファ*/
  398.     char errorlogmsgbuff[BUFFER_SIZE ];

  400.     /* エラーログメッセージ作成*/
  401.     result = makeErrMsg(errorlogmsgbuff , funname , msgid , (char*)vaparmeter);
  402.     /* エラーログメッセージ作成の結果が「正常」の場合*/
  403.     if ( result == 0 ) {
  404.        /* エラーログ出力関数（内部）を呼び出し、エラーログを出力する*/
  405.        outputSysLog(errorlogmsgbuff);
  406.        /* 処理結果「正常」を返す*/
  407.        return 0;
  408.     }else
  409.     {
  410.        /* 処理結果「異常」を返す*/
  411.        return 1;
  412.        
  413.     }

  415. }

  417. /**************************************************************************************/
  418. /* 関数名：outputSysLog */
  419. /* 関数名称：エラーログ出力関数（内部） */
  420. /* 機能概要：syslogにエラーメッセージを出力する。 */
  421. /* 引数 ：(1)エラーログメッセージ */
  422. /* 戻り値 ：(0)正常終了 */
  423. /* (1)異常終了 */
  424. /**************************************************************************************/
  425. int outputSysLog(char *errorlogmsgbuff)
  426. {

  428.     /* オープン（openlog） */
  429.     openlog(prgname, LOG_CONS | LOG_PID, LOG_USER);
  430.     /* 書き込み（syslog）*/
  431.     syslog(LOG_ERR, errorlogmsgbuff);
  432.     /* クローズ（closelog）*/
  433.     closelog();
  434. }

  436. /**************************************************************************************/
  437. /* 関数名：makeErrMsg */
  438. /* 関数名称：エラーログメッセージ作成関数 */
  439. /* 機能概要：メッセージIDからメッセージ本文を取得し置換文字列を置き換える。 */
  440. /* また、システム情報を付加しエラーログメッセージ作成し返却する。 */
  441. /* 引数 ：(1)ログメッセージバッファ */
  442. /* (2)関数名 */
  443. /* (3)メッセージID */
  444. /* (4)置換文字列（可変パラメタ） */
  445. /* 戻り値 ：(0)正常終了 */
  446. /* (1)異常終了 */
  447. /**************************************************************************************/
  448. int makeErrMsg(char *errorlogmsgbuff , const char *funname,const char *msgid,char *vaparmeter)
  449. {

  451.     /* ログメッセージ本文バッファ*/
  452.     char logmsgtxtbuff[BUFFER_SIZE];
  453.     /* ホスト名*/
  454.     char hostname[NAME_SIZE];
  455.     /* 戻り値を格?span style="color:#0000CC;">{する変数 */
  456.     int result ;

  458.     /* システム時間を取得する*/
  459.     time_t rawtime;
  460.     struct tm * timeinfo;
  461.     time ( &rawtime );
  462.     timeinfo = localtime ( &rawtime );
  463.     struct timeb tp;
  464.     ftime(&tp);
  465.     char strtime[TIME_SIZE];
  466.     /* システム時間がフォーマット「yyyy/MM/dd HH:mm:ss.SSS」に変換する*/
  467.     strftime ( strtime,TIME_SIZE,"%Y/%m/%d %H:%M:%S",timeinfo);
  468.     sprintf(strtime,"%s.%03d\n",strtime,tp.millitm);

  470.     /* メッセージ本文作成*/
  471.     /* メッセージレベルが"ERR"固定*/
  472.     strcat(errorlogmsgbuff , "ERR");
  473.     strcat(errorlogmsgbuff , " ");
  474.     
  475.     /* センタ情報が環境変数よりセンタ情報を取得する*/
  476.     strcat(errorlogmsgbuff , getenv("CENTER"));
  477.     strcat(errorlogmsgbuff , " ");

  479.     /* ホスト名が標準関数よりホスト名を取得する*/
  480.     gethostname(hostname, sizeof(hostname));
  481.     strcat(errorlogmsgbuff , hostname);
  482.     strcat(errorlogmsgbuff , " ");

  484.     /* 吖堀弗绁芝庭氓菼Dが環境変数より吖堀弗绁芝庭氓菼D情報を取得する*/
  485.     strcat(errorlogmsgbuff , getenv("JOBSCH_JOBNET"));
  486.     strcat(errorlogmsgbuff , "/");

  488.     /* 吖堀弗绁諭Dが環境変数より吖堀弗绁諭D情報を取得する*/
  489.     strcat(errorlogmsgbuff , getenv("JC_JOBID"));
  490.     strcat(errorlogmsgbuff , " ");

  492.     /* 出力日時がシステム時間を取得する*/
  493.     strcat(errorlogmsgbuff ,strtime);
  494.     strcat(errorlogmsgbuff , " : ");

  496.     /* メッセージカテゴリが"IFR"固定*/
  497.     strcat(errorlogmsgbuff , "IFR");
  498.     strcat(errorlogmsgbuff , " : : ");

  500.     /* メソッド名がパラメタの関数名*/
  501.     strcat(errorlogmsgbuff , funname);
  502.     strcat(errorlogmsgbuff , " : ");

  504.     /* メッセージIDがパラメタのメッセージID*/
  505.     strcat(errorlogmsgbuff , msgid);
  506.     strcat(errorlogmsgbuff , " : ");

  508.     /* メッセージ本文取得を呼び出し、メッセージ本文を取得する*/
  509.     result = getMsg(logmsgtxtbuff,msgid,(char*)vaparmeter);
  510.     
  511.     /* 取得に失敗した場合*/
  512.     if ( result == 1 )
  513.     {
  514.       /* 処理結果「異常」を返す*/
  515.       return 1;
  516.     }else
  517.     {
  518.       /* ログメッセージバッファ（errorlogmsgbuff）を作成する*/
  519.       strcat(errorlogmsgbuff , logmsgtxtbuff);
  520.       /* 処理結果「正常」を返す*/
  521.       return 0;
  522.     }

  524. }
  525. /**************************************************************************************/
  526. /* 関数名：getMsg */
  527. /* 関数名称：メッセージ本文取得関数 */
  528. /* 機能概要：メッセージ本文構造体から指定されたメッセージ本文を取得し、 */
  529. /* 置換文字列を置き換えた結果のメッセージ本文を返す。 */
  530. /* 引数 ：(1)メッセージ本文バッファ */
  531. /* (2)メッセージID */
  532. /* (3)置換文字列（可変パラメタ） */
  533. /* 戻り値 ：(0)正常終了 */
  534. /* (1)異常終了 */
  535. /**************************************************************************************/
  536. int getMsg(char *logmsgtxtbuff ,const char *msgid,char *vaparmeter)
  537. {

  539.    /* メッセージ本文バッファ*/
  540.    char msgtxtbuff[BUFFER_SIZE ];
  541.    /* 戻り値を格?span style="color:#0000CC;">{する変数 */
  542.    int result ;

  544.    /* エラーログメッセージファイル読み込みからパラメタのメッセージIDに一致する*/
  545.    /* メッセージ本文を取得する*/
  546.    result = readErrMsgFile(msgtxtbuff,msgid);
  547.    
  548.    /* 取得に失敗した場合*/
  549.    if ( result == 1 )
  550.    {
  551.       /* 処理結果「異常」を返す*/
  552.       return 1;
  553.    }else
  554.    {
  555.       /* メッセージ本文に置換文字列を埋め込む*/
  556.       /* オーバーフローを防止する実装とすること（vsnprintfの利用など）*/
  557.       vsnprintf(logmsgtxtbuff, BUFFER_SIZE, msgtxtbuff, (char*)vaparmeter);
  558.       /* 処理結果「正常」を返す*/
  559.       return 0;
  560.    }
  561. }

  563. /**************************************************************************************/
  564. /* 関数名：readErrMsgFile */
  565. /* 関数名称：エラーログメッセージファイル読み込み関数 */
  566. /* 機能概要：エラーログメッセージファイルを読み込みメッセージ本文を返す。、 */
  567. /* 引数 ：(1)メッセージ本文バッファ */
  568. /* (2)メッセージID */
  569. /* 戻り値 ：(0)正常終了 */
  570. /* (1)異常終了 */
  571. /**************************************************************************************/
  572. int readErrMsgFile(char *msgtxtbuff ,const char *msgid)
  573. {

  575.    /* ホスト名*/
  576.    char hostname[NAME_SIZE];
  577.    /* エラーログメッセージファイル*/
  578.    FILE *msgfile;
  579.    char filelinetxt[BUFFER_SIZE];
  580.    char *tomsgid;
  581.    char msgtxt[BUFFER_SIZE];

  583.    /* システム時間を取得する*/
  584.    time_t rawtime;
  585.    struct tm * timeinfo;
  586.    time ( &rawtime );
  587.    timeinfo = localtime ( &rawtime );
  588.    struct timeb tp;
  589.    ftime(&tp);
  590.    char strtime[TIME_SIZE];
  591.    /* システム時間がフォーマット「yyyy/MM/dd HH:mm:ss.SSS」に変換する*/
  592.    strftime ( strtime,TIME_SIZE,"%Y/%m/%d %H:%M:%S",timeinfo);
  593.    sprintf(strtime,"%s.%03d\n",strtime,tp.millitm);

  595.    /* エラーログメッセージファイルを読み込みモードでオープンする*/
  596.    /* オープンに失敗した場合*/
  597.    if((msgfile=fopen(logmsgfiledir,"r"))==NULL)
  598.     {
  599.        /* メッセージレベルが"ERR"固定*/
  600.        strcat(msgtxtbuff , "ERR");
  601.        strcat(msgtxtbuff , " ");

  603.        /* センタ情報が環境変数よりセンタ情報を取得する*/
  604.        strcat(msgtxtbuff , getenv("CENTER"));
  605.        strcat(msgtxtbuff , " ");

  607.        /* ホスト名が標準関数よりホスト名を取得する*/
  608.        gethostname(hostname, sizeof(hostname));
  609.        strcat(msgtxtbuff , hostname);
  610.        strcat(msgtxtbuff , " ");

  612.        /* 吖堀弗绁芝庭氓菼Dが環境変数より吖堀弗绁芝庭氓菼D情報を取得する*/
  613.        strcat(msgtxtbuff , getenv("JOBSCH_JOBNET"));
  614.        strcat(msgtxtbuff , "/");

  616.        /* 吖堀弗绁諭Dが環境変数より吖堀弗绁諭D情報を取得する*/
  617.        strcat(msgtxtbuff , getenv("JC_JOBID"));
  618.        strcat(msgtxtbuff , " ");

  620.        /* 出力日時がシステム時間を取得する*/
  621.        strcat(msgtxtbuff , strtime);
  622.        strcat(msgtxtbuff , " : ");
  623.     
  624.        /* メッセージカテゴリが"IFR"固定*/
  625.        strcat(msgtxtbuff , "IFR");
  626.        strcat(msgtxtbuff , " : : ");

  628.        /* メソッド名が関数名*/
  629.        strcat(msgtxtbuff , __func__);
  630.        strcat(msgtxtbuff , " : ");

  632.        /* メッセージIDが"BALCCBA801E"固定*/
  633.        strcat(msgtxtbuff , "BALCCBA801E");
  634.        strcat(msgtxtbuff , " : ");

  636.        /* メッセージ本文を作成する*/
  637.        sprintf(msgtxt,"Message File is not found.(%s)",logmsgfiledir);
  638.        strcat(msgtxtbuff , msgtxt);
  639.        /* 作成したエラーログメッセージをパラメタとしエラーログ出力関数（内部）を呼び出*/
  640.        outputSysLog(msgtxtbuff);
  641.        /* 処理結果「異常」を返す*/
  642.        return 1;
  643.     }

  645.     /* 読み込み行数取得 */
  646.     while(!feof(msgfile))
  647.     {
  648.         /* 1行読み込む。*/
  649.         if(fgets(filelinetxt, BUFFER_SIZE, msgfile) != NULL)
  650.         {
  651.             /* 先頭文字が"#"で無い場合*/
  652.             if(strncmp(filelinetxt,"#",1) != 0)
  653.             {
  654.                 /* メッセージIDを取得する*/
  655.                 tomsgid = strtok(filelinetxt,",");
  656.                 /* メッセージIDがパラメタのメッセージIDと等しい場合*/
  657.                 if( 0 == strcmp(tomsgid , msgid) )
  658.                 {
  659.                     /* メッセージ本文バッファに取得したメッセージ本文を設定し呼び出し元に返す。*/
  660.                     strcat(msgtxtbuff,strtok(NULL,""));
  661.                     /* 処理結果「正常」を返す*/
  662.                     return 0;
  663.                 }
  664.             }
  665.         }
  666.     }

  668.     /* 最終行まで読み込み、メッセージ本文が取得できなかった場合*/
  669.     /* メッセージレベルが"ERR"固定*/
  670.     strcat(msgtxtbuff , "ERR");
  671.     strcat(msgtxtbuff , " ");

  673.     /* センタ情報が環境変数よりセンタ情報を取得する*/
  674.     strcat(msgtxtbuff , getenv("CENTER"));
  675.     strcat(msgtxtbuff , " ");

  677.     /* 吖堀弗绁芝庭氓菼Dが環境変数より吖堀弗绁芝庭氓菼D情報を取得する*/
  678.     strcat(msgtxtbuff , getenv("JOBSCH_JOBNET"));
  679.     strcat(msgtxtbuff , "/");

  681.     /* 吖堀弗绁諭Dが環境変数より吖堀弗绁諭D情報を取得する*/
  682.     strcat(msgtxtbuff , getenv("JC_JOBID"));
  683.     strcat(msgtxtbuff , " ");

  685.     /* ホスト名が標準関数よりホスト名を取得する*/
  686.     gethostname(hostname, sizeof(hostname));
  687.     strcat(msgtxtbuff , hostname);
  688.     strcat(msgtxtbuff , " ");

  690.     /* 出力日時がシステム時間を取得する*/
  691.     strcat(msgtxtbuff , strtime);
  692.     strcat(msgtxtbuff , " : ");

  694.     /* メッセージカテゴリが"IFR"固定*/
  695.     strcat(msgtxtbuff , "IFR");
  696.     strcat(msgtxtbuff , " : : ");

  698.     /* メソッド名が関数名*/
  699.     strcat(msgtxtbuff , __func__);
  700.     strcat(msgtxtbuff , " : ");

  702.     /* メッセージIDが"BALCCBA802E"固定*/
  703.     strcat(msgtxtbuff , "BALCCBA802E");
  704.     strcat(msgtxtbuff , " : ");

  706.     /* メッセージ本文を作成する*/
  707.     sprintf(msgtxt,"Message ID is not found.(%s)",(char*)msgid);
  708.     strcat(msgtxtbuff , msgtxt);

  710.     /* 作成したエラーログメッセージをパラメタとしエラーログ出力関数（内部）を呼び出*/
  711.     outputSysLog(msgtxtbuff);
  712.     /* 処理結果「異常」を返す*/
  713.     return 1;
  714. }

阅读(364) | 评论(0) | 转发(0) |
0

上一篇：$*和$@取带空格参数的区别

下一篇：对日java服务端SOCKET通讯

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6