《邮件系统割接的三个C语言小程序》

2008-01-31 12:24:24 / 个人分类：C语言编程

/*程序名：conversion
* 作用：将亚信信息转换成SQLLDR导入的格式
*          中间用，点分隔
*          各字段说明信息请参考亚信割接方案
*操作流程：在程序的当前目录下，准备好亚信提供的信息文件，文件名必需是sour.txt
            运行程序，会生成一个dest.txt的结果文件
*
* mail    :kchen@ceno.cn
*/

# include <stdio.h>
# include <stdlib.h>
# include <string.h>

int main (int argc,char *argv[])
{
    FILE *fp, *wfp;
    char mobile[13];               /*定义用户名*/
    char email[24];                /*定义邮箱等信息*/
    char nextmonth[24];            /*定义下月邮箱信息*/
    char area[4];                  /*定义地区*/
    int count = 0;
    int init = 0;
    int ch;
    int flag;
    int loop;

    if ((fp = fopen("sour.txt", "rt")) == NULL) /*以只读方式打开sour.txt文件,返回文件描述符*/
    {
        printf("open sour.txt file failed\n");
        exit(EXIT_FAILURE);
    }

    if ((wfp = fopen("dest.txt", "wt")) == NULL) /*以读写方式打开dest.txt文件，返回文件描述符*/
    {
        printf("open dest.txt file failed\n");
        exit(EXIT_FAILURE);
    }

    ch = fgetc(fp);             /*读取字符*/
    while (ch != EOF)           /*判断是否到文件尾(EOF)，是文件尾退出*/
    {
      while(1)                  /*循环处理用户名字段信息*/
      {
         if(ch == '\n')
         {
            init = 0;           /*遇到回车符，则处理用户名完毕*/
            flag = 1;
            mobile[11]=',';
            mobile[12]='\0';
            fputs(mobile, wfp); /*写用户名到dest.txt*/
            break;
         }
         else
         {
            mobile[init] = ch; /*循环读取字符到mobile数组*/
            init++;
            ch = fgetc(fp);     /*读文件字符到ch*/
         }
      }
      while(1)                    /*处理当月邮件信息*/
      {
          ch = fgetc(fp);         /*读取字符到ch*/
          if(ch == '\n')
          {
              init = 0;
              flag = 1;
              email[23] = '\0';
              fputs(email, wfp);
              break;
          }
          else
          {
              email[init] = ch;
              flag++;
              init++;
              if(init == 7)       /*如果读到第8个字符,则要固定输出UM信息*/
              {
                fgetc(fp);        /*用UM信息替换...*/
                fgetc(fp);
                fgetc(fp);
                email[7] = ',';
                email[8] = 'U';
                email[9] = 'M';
                email[10] = ',';
                init = init + 3;
              }

              if(flag == 4)
              {
                email[init] = ',';
                init++;
                flag = 1;
              }
          }
      }
      while(1)                  /*循环处理邮件的下月信息*/
      {
          ch = fgetc(fp);
          if(ch == '\n')
          {
               init = 0;
               flag = 1;
               nextmonth[23] = '\0';
               fputs(nextmonth, wfp);
               break;
          }
          else
          {
               nextmonth[init] = ch;
               init++;
               flag++;
               if(init == 7)
               {
                fgetc(fp);
                fgetc(fp);
                fgetc(fp);
                nextmonth[7] = ',';
                nextmonth[8] = 'U';
                nextmonth[9] = 'M';
                nextmonth[10] = ',';
                init = init + 3;
               }

               if(flag == 4)
               {
                  nextmonth[init] = ',';
                  init++;
                  flag = 1;
               }
           }
       }
       for(count = 0;count < 7;count++) /*循环读取地区信息*/
            fgetc(fp);
       while(1)
       {
          ch = fgetc(fp);
          if(ch == '\n')
          {
               init = 0;
               area[3] = '\0';
               fgetc(fp);
               fputs(area, wfp);
               fputc('\n', wfp);
               break;
          }
          else
          {
               area[init] = ch;
               init++;
          }
       }
     ch = fgetc(fp);
     }
     fclose(wfp);
     exit(EXIT_SUCCESS);
}

/********************************************************/

/*程序名   :freeze
* 作用    ：排除冻结用户
* 操作流程:将dest.txt（通过conversion程序转换后）与freeze.txt文件（冻结用户文件)放置程序的当前目录下,执行程序
*          此时会在当前目录下产生一个asia17288.txt的结果文件，即排除冻结用户的结果文件
* mail    :kchen@ceno.cn
* */

# include <stdio.h>
# include <stdlib.h>
# include <fcntl.h>
# include <unistd.h>
# include <sys/stat.h>
# include <string.h>

# define DEST_FILE      "asia17288.txt"         /*定义目标文件*/
# define SOUR_FILE      "dest.txt"              /*定义源文件*/
# define URSIZE         (sizeof(struct userstr))/*定义userstr结构的大小*/
# define NRECS          16                      /*一次读取16条记录*/
# define NULLUT         ((struct userstr *)NULL)/*定义userstr结构的为空*/
# define TABKEY         ","                     /*定义逗号*/
# define DESTMODE       0644                    /*定义dest.txt文件的mode为0644*/
# define FREEZE_FILE    "freeze.txt"
# define BUFNUM         10240
# define BUFLEN         81

struct userstr
{
    char Mobile[11];                            /*定义手机用户名*/
    char Mobile_TABKEY;                         /*定义手机用户尾部的回车符*/
    char MobileType_Email[4];                   /*定义用户的类型*/
    char MobileType_Billing[4];                 /*定义用户的计费类型*/
    char MobileType_UM[3];                      /*定义用户是否用UM,仅用字符串UM填充*/
    char MobileType_Null[4];                    /*定义用户的000列，此列无任何意义*/
    char MobileType_WFS[4];                     /*定义用户是否启用WFS*/
    char MobileType_Pushmail[4];                /*定义用户是否启用PUSHMAIL*/
    char NMobileType_Email[4];                  /*定义下月用户的类型*/
    char NMobileType_Billing[4];                /*定义下月用户的计费类型*/
    char NMobileType_UM[3];                     /*定义下月用户是否用UM，公用字符串UM填充*/
    char NMobileType_Null[4];                   /*定义下月用户的000列，此列无任何意义*/
    char NMobileType_WFS[4];                    /*定义下月用户是否启用WFS*/
    char NMobileType_Pushmail[4];               /*定义下月用户是否启用PUSHMAIL*/
    char Area[3];                               /*用户所属地区*/
    char Enter;                                 /*最后的回车符，丢弃不用*/
}user_info;

int             fd_user    = -1;                /*定义亚信提供的原始文件的文件句柄*/
int             fd_dest    = -1;                /*定义转换后的临时表文件句柄*/
int             fd_freeze = -1;
struct userstr *curuser;                       /*一个用户的结构体指针*/
int             cur_rec;                        /*定义16个用户的结构体计数变量，做累加*/
int             num_recs;                       /*定义16个用户一次实际读取的用户数*/
int             rec_total = 0;
char            Enter[2]   = "\n";
char            area[11];
char            mobile[30];
char            userbuf[URSIZE * NRECS];
char            buffer[BUFNUM * BUFLEN];
int             flag;

struct userstr *user_next()
{
    struct userstr *user_recp;
    while(1)
    {
        if(cur_rec == num_recs && user_reload() == 0)
            return NULLUT;

        user_recp = (struct userstr *)&userbuf[cur_rec * URSIZE];
        cur_rec++;
        rec_total++;
        return user_recp;
    }
}

int user_reload()
{
    int amt_read;
    amt_read = read(fd_user, userbuf, URSIZE * NRECS);
    num_recs = amt_read/URSIZE;
    cur_rec = 0;
    return num_recs;
}

int
main (void)
{
    int size_bytes;
    cur_rec = num_recs = 0;            /*初始化累加记录为0*/

    curuser = (struct userstr *)malloc(URSIZE);

    if ((fd_user = open(SOUR_FILE, O_RDWR)) == -1)
    {
        perror(SOUR_FILE);
    }

    if ((fd_dest = open(DEST_FILE, O_CREAT|O_RDWR|O_TRUNC, DESTMODE)) == -1)
    {
        perror(DEST_FILE);
    }

    if ((fd_freeze = open(FREEZE_FILE, O_RDWR)) == -1)
    {
        perror(FREEZE_FILE);
    }

    while((curuser = user_next() )!= NULLUT)
    {
       flag = 0;
       strncpy(mobile, curuser->Mobile, 11);

       while ((size_bytes = read(fd_freeze, buffer, BUFNUM * BUFLEN)) > 0)
       {
           if(strstr (buffer, mobile) != NULL)
           flag = 1;
       }

       if (flag == 0)
       {
           write(fd_dest, curuser, URSIZE);
       }
       lseek(fd_freeze, 0, SEEK_SET);
    }

    close(fd_user);
    close(fd_dest);
    close(fd_freeze);
    exit(EXIT_SUCCESS);
}

/*****************************************************/

# include <stdio.h>
# include <stdlib.h>
# include <fcntl.h>
# include <unistd.h>
# include <sys/stat.h>
# include <string.h>

# define DEST_FILE_FREE   "asia_free.txt"         /*定义目标文件*/
# define DEST_FILE_UPDATE "asia_update.txt"
# define DEST_FILE_NOUP   "asia_noupdate.txt"
# define SOUR_FILE        "asia17288.txt"         /*定义源文件*/
# define ANYS_FILE        "1.txt"
# define DEST_FILE_REPEAT "asia_repeat.txt"
# define URSIZE           (sizeof(struct userstr))/*定义userstr结构的大小*/
# define F1SIZE           (sizeof(struct freestr1))
# define F2SIZE           (sizeof(struct freestr2))
# define NRECS            16                      /*一次读取16条记录*/
# define NULLUT           ((struct userstr *)NULL)/*定义userstr结构的为空*/
# define TABKEY           ","                     /*定义逗号*/
# define DESTMODE         0644                    /*定义dest.txt文件的mode为0644*/
# define BUFNUM           10240
# define BUFLEN           14

struct userstr
{
    char Mobile[11];                            /*定义手机用户名*/
    char Mobile_TABKEY;                         /*定义手机用户尾部的回车符*/
    char MobileType_Email[4];                   /*定义用户的类型*/
    char MobileType_Billing[4];                 /*定义用户的计费类型*/
    char MobileType_UM[3];                      /*定义用户是否用UM,仅用字符串UM填充*/
    char MobileType_Null[4];                    /*定义用户的000列，此列无任何意义*/
    char MobileType_WFS[4];                     /*定义用户是否启用WFS*/
    char MobileType_Pushmail[4];                /*定义用户是否启用PUSHMAIL*/
    char NMobileType_Email[4];                  /*定义下月用户的类型*/
    char NMobileType_Billing[4];                /*定义下月用户的计费类型*/
    char NMobileType_UM[3];                     /*定义下月用户是否用UM，公用字符串UM填充*/
    char NMobileType_Null[4];                   /*定义下月用户的000列，此列无任何意义*/
    char NMobileType_WFS[4];                    /*定义下月用户是否启用WFS*/
    char NMobileType_Pushmail[4];               /*定义下月用户是否启用PUSHMAIL*/
    char Area[3];                               /*用户所属地区*/
    char Enter;                                 /*最后的回车符，丢弃不用*/
}user_info;

struct freestr1
{
    char Mobile[11];
    char Mobile_TABKEY1;
    char MobileTemplate_OLD[3];
    char Mobile_TABKEY2;
    char MobileTemplate_NEW[3];
    char Mobile_TABKEY3;
    char MOD;
    char Enter;
};
struct freestr2
{
    char Mobile[11];
    char Mobile_TABKEY1;
    char MobileTemplate_OLD[3];
    char Mobile_TABKEY2;
    char MobileTemplate_FIN[3];
    char Mobile_TABKEY3;
    char MOD1;
    char Mobile_TABKEY4;
    char MOD2;
    char Mobile_TABKEY5;
    char MobileTemplate_P[3];
    char Enter;
};

int             fd_user           = -1;             /*定义亚信提供的原始文件的文件句柄*/
int             fd_dest_free      = -1;             /*定义转换后的临时表文件句柄*/
int             fd_anys           = -1;
int             fd_dest_update    = -1;
int             fd_dest_noupdate = -1;
struct userstr *curuser;                           /*一个用户的结构体指针*/
int             cur_rec;                            /*定义16个用户的结构体计数变量，做累加*/
int             num_recs;                           /*定义16个用户一次实际读取的用户数*/
int             rec_total     = 0;
char            Enter[2]      = "\n";
char            area[11];
char            userbuf[URSIZE * NRECS];
char            buffer[BUFNUM * BUFLEN];
int             flag;
int             size_bytes;
char            mobile[11];
struct freestr1 *user_freestr;
struct freestr2 *user_updatestr;
char            ch;
char            *mtype;
char            ctemplate[3]      = {0,0,0};

struct userstr *user_next()
{
    struct userstr *user_recp;
    while(1)
    {
        if(cur_rec == num_recs && user_reload() == 0)
            return NULLUT;

        user_recp = (struct userstr *)&userbuf[cur_rec * URSIZE];
        cur_rec++;
        rec_total++;
        return user_recp;
    }
}

int user_reload()
{
    int amt_read;
    amt_read = read(fd_user, userbuf, URSIZE * NRECS);
    num_recs = amt_read/URSIZE;
    cur_rec = 0;
    return num_recs;
}

void write_flag_n()
{
    strncpy(user_freestr->Mobile, curuser->Mobile, 11);
    user_freestr->Mobile_TABKEY1 = ',';
    user_freestr->Mobile_TABKEY3 = ',';
    user_freestr->Mobile_TABKEY2 = ',';

    strncpy(user_freestr->MobileTemplate_OLD, curuser->MobileType_Email, 3);
    user_freestr->MOD = 'N';
    strncpy(user_freestr->MobileTemplate_NEW, curuser->MobileType_Email, 3);
    user_freestr->Enter = '\n';
    write(fd_dest_free, user_freestr, sizeof(struct freestr1));
}

void write_flag_w(char ctemplate)
{
    ch        = curuser->MobileType_Email[2];
    user_updatestr->Mobile_TABKEY1 = ',';
    user_updatestr->Mobile_TABKEY3 = ',';
    user_updatestr->Mobile_TABKEY2 = ',';
    user_updatestr->Mobile_TABKEY5 = ',';
    user_updatestr->Mobile_TABKEY4 = ',';

    switch(ch)
    {
        case '7':{
                   strncpy(user_updatestr->Mobile, curuser->Mobile, 11);
                   user_updatestr->Mobile_TABKEY1 = ',';
                   user_updatestr->Mobile_TABKEY3 = ',';
                   user_updatestr->Mobile_TABKEY2 = ',';
                   user_updatestr->MobileTemplate_P[0] = '0';
                   user_updatestr->MobileTemplate_P[1] = '0';
                   user_updatestr->MobileTemplate_P[2] = ctemplate;
                   user_updatestr->MOD1 = 'R';
                   strncpy(user_updatestr->MobileTemplate_OLD, curuser->MobileType_Email, 3);
                   strncpy(user_updatestr->MobileTemplate_FIN, curuser->MobileType_Email, 3);
                   user_updatestr->MOD2 = 'C';
                   user_updatestr->Enter = '\n';
                   write(fd_dest_update, user_updatestr, sizeof(struct freestr2));
                   break;}
        default:{
                   strncpy(user_updatestr->Mobile, curuser->Mobile, 11);
                   user_updatestr->Mobile_TABKEY1 = ',';
                   user_updatestr->Mobile_TABKEY3 = ',';
                   user_updatestr->Mobile_TABKEY2 = ',';
                   strncpy(user_updatestr->MobileTemplate_OLD, curuser->MobileType_Email, 3);
                   user_updatestr->MOD1 = 'R';
                   user_updatestr->MobileTemplate_FIN[0] = '0';
                   user_updatestr->MobileTemplate_FIN[1] = '0';
                   user_updatestr->MobileTemplate_FIN[2] = ctemplate;
                   user_updatestr->MobileTemplate_P[0] = '0';
                   user_updatestr->MobileTemplate_P[1] = '0';
                   user_updatestr->MobileTemplate_P[2] = ctemplate;
                   user_updatestr->MOD2 = 'X';
                   user_updatestr->Enter = '\n';
                   write(fd_dest_noupdate, user_updatestr, sizeof(struct freestr2));
                   break;}

    }
}

int
main (void)
{
    char ch;
    cur_rec = num_recs = 0;            /*初始化累加记录为0*/

    curuser = (struct userstr *)malloc(URSIZE);
    user_freestr   = (struct freestr1 *)malloc(F1SIZE);
    user_updatestr = (struct freestr2 *)malloc(F2SIZE);

    mtype   = (char*) malloc(255);

    if ((fd_user = open(SOUR_FILE, O_RDWR)) == -1)
    {
        perror(SOUR_FILE);
    }

    if ((fd_dest_free = open(DEST_FILE_FREE, O_CREAT|O_RDWR|O_TRUNC, DESTMODE)) == -1)
    {
        perror(DEST_FILE_FREE);
    }

    if ((fd_anys = open(ANYS_FILE, O_RDWR)) == -1)
    {
        perror(ANYS_FILE);
    }

    if ((fd_dest_update = open(DEST_FILE_UPDATE, O_CREAT|O_RDWR|O_TRUNC, DESTMODE)) == -1)
    {
        perror(DEST_FILE_UPDATE);
    }

    if ((fd_dest_noupdate = open(DEST_FILE_NOUP, O_CREAT|O_RDWR|O_TRUNC, DESTMODE)) == -1)
    {
        perror(DEST_FILE_NOUP);
    }


    while((curuser = user_next() )!= NULLUT)
    {
       flag = 0;
       strncpy(mobile, curuser->Mobile, 11);

       while ((size_bytes = read(fd_anys, buffer, BUFNUM * BUFLEN)) > 0)
       {
           if((mtype = strstr (buffer, mobile)) != NULL)
           {
             flag++;
             mtype = mtype + 12;
             ch = *mtype;
           }
       }
       switch (flag)
       {
         case 0:write_flag_n();break;
         case 1:write_flag_w(ch);break;
         default :write_flag_w(ch);
       }

       lseek(fd_anys, 0, SEEK_SET);
    }

    close(fd_user);
    close(fd_anys);
    close(fd_dest_free);
    close(fd_dest_update);
    close(fd_dest_noupdate);
    exit(EXIT_SUCCESS);
}

用户菜单

日历

存档

我的栏目

搜索标题

RSS订阅

《邮件系统割接的三个C语言小程序》

相关阅读: