]> andersk Git - moira.git/blob - regtape/students.dc
d0a69cadc73e12278cb028d64958bd083b440616
[moira.git] / regtape / students.dc
1 /* $Header$
2  */
3
4 #include <stdio.h>
5 #include <strings.h>
6 #include <ctype.h>
7 #include <sys/time.h>
8 #include <moira.h>
9 #include <moira_site.h>
10 EXEC SQL INCLUDE sqlca;
11
12
13 #define WHO 11859               /* root */
14 #define PROG "stu-tape"
15
16 #define MAX_ID_VALUE    31999
17 #define MIN_ID_VALUE    101
18
19 /* File format is:
20
21 0-29    name
22 30-38   id number
23 50-54   school code
24 55-79   year
25 80-109  address
26 110-124 room
27 125-144 city
28 145-158 state
29 159-168 dorm phone
30 169-212 home address
31 213-232 home city
32 243-251 mit phone (?)
33 */
34
35 #define LOC_NAME 0
36 #define LOC_ID 30
37 #define LOC_COURSE 50
38 #define LOC_YEAR 55
39 #define LOC_ADDRESS 80
40 #define LOC_DORM_ROOM 110
41 #define LOC_CITY 125
42 #define LOC_STATE 145
43 #define LOC_DPHONE 155
44 #define LOC_MPHONE 243
45
46 #define LEN_NAME 30
47 #define LEN_ID 9
48 #define LEN_COURSE 5
49 #define LEN_YEAR 25
50 #define LEN_ADDRESS 30
51 #define LEN_DORM_ROOM 15
52 #define LEN_CITY 20
53 #define LEN_STATE 10
54 #define LEN_DPHONE 12
55 #define LEN_MPHONE 12
56
57 struct entry {
58     char *name;
59     char *last;
60     char *first;
61     char *middle;
62     char *title;
63     char *id;
64     char *eid;
65     char *course;
66     char *year;
67     char *address;
68     char *dorm;
69     char *city;
70     char *state;
71     char *dphone;
72     char *mphone;
73     char *class;
74 };
75
76
77 char *whoami;
78 int newfinger = 0;
79
80 #define sqlfail() (sqlca.sqlcode && sqlca.sqlcode != 100)
81 #define SQL_DUPLICATE -40100
82
83 main(argc, argv)
84 int argc;
85 char **argv;
86 {
87     FILE *in;
88     struct entry *e, *get_next_entry();
89     int i, wait = 0;
90     char buf[BUFSIZ], *file = NULL;
91
92     whoami = rindex(argv[0], '/');
93     if (whoami)
94       whoami++;
95     else
96       whoami = argv[0];
97
98     for (i = 1; i < argc; i++) {
99         if (!strcmp(argv[i], "-w"))
100           wait++;
101         else if (!strcmp(argv[i], "-D"))
102           setenv("ING_SET", "set printqry");
103         else if (!strcmp(argv[i], "-n"))
104           newfinger++;
105         else if (file != NULL)
106           fprintf(stderr, "Usage: %s [-w] [-D] [-n] inputfile\n", whoami);
107         else
108           file = argv[i];
109     }
110
111     in = fopen(file, "r");
112     if (in == NULL) {
113         fprintf(stderr, "Unable to open %s for input\n", file);
114         exit(1);
115     }
116
117     setlinebuf(stdout);
118     setlinebuf(stderr);
119
120     EXEC SQL CONNECT moira;
121     if (sqlca.sqlcode != 0) {
122         com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
123         exit(1);
124     }
125
126     while (e = get_next_entry(in)) {
127         process_entry(e);
128         EXEC SQL COMMIT WORK;
129         if (sqlca.sqlcode != 0) {
130             com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
131             exit(1);
132         }
133         if (wait) {
134             printf("Next");
135             fflush(stdout);
136             gets(buf);
137         }
138     }
139
140     exit(0);
141 }
142
143
144 struct entry *get_next_entry(in)
145 FILE *in;
146 {
147     static struct entry e;
148     static char buf[BUFSIZ], eid[16], classbuf[10], titlebuf[12];
149     static char name[LEN_NAME+1], id[LEN_ID+1], course[LEN_COURSE+1];
150     static char year[LEN_YEAR+1], address[LEN_ADDRESS+1];
151     static char dorm_room[LEN_DORM_ROOM+1], city[LEN_CITY+1];
152     static char state[LEN_STATE+1], dphone[LEN_DPHONE+1], mphone[LEN_MPHONE+1];
153     static char sname[LEN_NAME+1], title[128];
154     static int nyear = 0;
155     int ends_jr, ends_iii, ends_iv, ends_sr, ends_ii, ends_v;
156     char *p;
157
158     if (nyear == 0) {
159         struct tm *tm;
160         struct timeval tv;
161
162         gettimeofday(&tv, NULL);
163         tm = localtime(&tv.tv_sec);
164         nyear = tm->tm_year;
165         if (tm->tm_mon > 5)
166           nyear++;
167     }
168
169     if (fgets(buf, sizeof(buf), in) == NULL)
170       return((struct entry *)NULL);
171
172     strncpy(name, &buf[LOC_NAME], LEN_NAME); name[LEN_NAME] = 0;
173     strncpy(id, &buf[LOC_ID], LEN_ID); id[LEN_ID] = 0;
174     strncpy(course, &buf[LOC_COURSE], LEN_COURSE); course[LEN_COURSE] = 0;
175     strncpy(year, &buf[LOC_YEAR], LEN_YEAR); year[LEN_YEAR] = 0;
176     strncpy(address, &buf[LOC_ADDRESS], LEN_ADDRESS); address[LEN_ADDRESS] = 0;
177     strncpy(dorm_room, &buf[LOC_DORM_ROOM], LEN_DORM_ROOM); dorm_room[LEN_DORM_ROOM] = 0;
178     strncpy(city, &buf[LOC_CITY], LEN_CITY); city[LEN_CITY] = 0;
179     strncpy(state, &buf[LOC_STATE], LEN_STATE); state[LEN_STATE] = 0;
180     strncpy(dphone, &buf[LOC_DPHONE], LEN_DPHONE); dphone[LEN_DPHONE] = 0;
181     strncpy(mphone, &buf[LOC_MPHONE], LEN_MPHONE); mphone[LEN_MPHONE] = 0;
182
183     strcpy(sname, name);
184     e.name = strtrim(sname);
185     p = index(name, ',');
186     if (p)
187       *p = 0;
188     e.last = strtrim(name);
189     if (p) {
190         p++;
191         while (isspace(*p))
192           p++;
193         e.first = p;    
194         if (p = index(e.first, ' ')) {
195             *p = 0;
196             e.first = strtrim(e.first);
197             e.middle = strtrim(p + 1);
198         } else {
199             e.first = strtrim(e.first);
200             e.middle = "";
201         }
202     } else {
203         e.first = "";
204         e.middle = "";
205     }
206     ends_jr = ends_iii = ends_iv = ends_sr = ends_ii = ends_v = 0;
207     LookForSt(e.last);
208     LookForO(e.last);
209     LookForJrAndIII(e.last, &ends_sr, &ends_jr, &ends_iii, &ends_iv,
210                     &ends_ii, &ends_v);
211     LookForJrAndIII(e.first, &ends_sr, &ends_jr, &ends_iii, &ends_iv,
212                     &ends_ii, &ends_v);
213     FixCase(e.last);
214     FixCase(e.first);
215     FixCase(e.middle);
216
217     e.id = id;
218     e.id[LEN_ID] = 0;
219     e.eid = eid;
220     EncryptID(e.eid, e.id, e.first, e.last);
221
222     e.year = strtrim(year);
223     e.title = title;
224     if (e.year[0] == 'G') {
225         e.class = "G";
226         sprintf(title, "Grad Student");
227     } else {
228         e.class = classbuf;
229         sprintf(classbuf, "%d", nyear + 4 - atoi(e.year) + 1900);
230         sprintf(title, "Undergrad (class of %s)", classbuf);
231     }
232
233     e.course = strtrim(course);
234     e.address = strtrim(address);
235     e.dorm = strtrim(dorm_room);
236     e.city = strtrim(city);
237     e.state = strtrim(state);
238     e.dphone = strtrim(dphone);
239     e.mphone = strtrim(mphone);
240     return(&e);
241 }
242
243
244 process_entry(e)
245 struct entry *e;
246 {
247     int changed, nochange, encrypted;
248     char buf[BUFSIZ], *from, *to;
249     EXEC SQL BEGIN DECLARE SECTION;
250     char *first, *last, *middle, *eid, *title, *sid, *name, *rname, *rdept, *rtitle;
251     char *rophone, *rhphone, *prog;
252     char class[9], haddr[128], hphone[33], ophone[33], dept[33], raddr[128];
253     char dfirst[17], dlast[17], dmiddle[17];
254     int id, status, who;
255     EXEC SQL END DECLARE SECTION;
256
257     who = WHO;
258     prog = PROG;
259     first = e->first;
260     if (strlen(first) > 16)
261       first[16] = 0;
262     last = e->last;
263     if (strlen(last) > 16)
264       last[16] = 0;
265     middle = e->middle;
266     eid = e->eid;
267     sid = e->id;
268     id = 0;
269     encrypted = 0;
270
271     /* Get user info */
272     EXEC SQL REPEATED SELECT users_id, first, last, middle, type, home_addr, home_phone, office_phone, status, department
273       INTO :id, :dfirst, :dlast, :dmiddle, :class, :haddr, :hphone, :ophone, :status, :dept
274       FROM users
275       WHERE clearid = :sid;
276     if (sqlfail()) {
277         if (sqlca.sqlcode == SQL_DUPLICATE) {
278             com_err(whoami, 0, "duplicate ID number %s on user %s %s", sid, first, last);
279             return;
280         } else
281           sqlexit();
282     }
283     if (id == 0) {
284         EXEC SQL REPEATED SELECT users_id, first, last, middle, type, home_addr, home_phone, office_phone, status, department
285           INTO :id, :dfirst, :dlast, :dmiddle, :class, :haddr, :hphone, :ophone, :status, :dept
286           FROM users
287           WHERE last = :last and first = :first and clearid = :eid;
288         if (sqlfail() && sqlca.sqlcode != SQL_DUPLICATE) sqlexit();
289         encrypted++;
290         if (id == 0) {
291             newuser(e);
292             return;
293         }
294     }
295
296     /* See if class changed: if it's different, and the value in the database
297      * is not STAFF or SIPB, then update the database.  Since they were on the
298      * students tape, make the account usable.
299      */
300     if (strcmp(e->class, strtrim(class)) &&
301         strcmp(class, "STAFF") && strcmp(class, "SIPB")) {
302         com_err(whoami, 0, "updating class for user %s %s from %s to %s",
303                 first, last, class, e->class);
304         if (status == US_NOT_ALLOWED) status = US_NO_LOGIN_YET;
305         if (status == US_ENROLL_NOT_ALLOWED) status = US_ENROLLED;
306         strcpy(class, e->class);
307         EXEC SQL REPEATED UPDATE users
308           SET type = :class, status = :status, modtime = 'now',
309             modby = :who, modwith = :prog
310           WHERE users_id = :id;   
311         if (sqlca.sqlcode != 0) {
312             com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
313             exit(1);
314         }
315     }
316
317     /* Update name if necessary */
318     if (strcmp(first, strtrim(dfirst)) ||
319         strcmp(last, strtrim(dlast)) ||
320         strcmp(middle, strtrim(dmiddle))) {
321         com_err(whoami, 0, "updating real name for %s %s", first, last);
322         EXEC SQL UPDATE users
323           SET first = :first, last = :last, middle = :middle,
324                 modby = :who, modwith = :prog, modtime = 'now'
325           WHERE users_id = :id;
326         if (sqlca.sqlcode != 0) {
327             com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
328             exit(1);
329         }
330     }
331
332     /* Deal with updating the finger info if necessary */
333     changed = nochange = 0;
334     if (encrypted) changed++;
335     strcpy(buf, e->address);
336     if (*e->dorm) {
337         strcat(buf, " ");
338         strcat(buf, e->dorm);
339     }
340     if (*e->city) {
341         strcat(buf, " ");
342         strcat(buf, e->city);
343     }
344     FixCase(buf);
345     if (*e->state) {
346         strcat(buf, " ");
347         strcat(buf, e->state);
348     }
349     while (to = index(buf, ','))
350       *to = ';';
351     while (to = index(buf, ':'))
352       *to = ';';
353     if (newfinger) {
354         if (haddr[0] == ' ') {
355             strncpy(haddr, buf, 80);
356             haddr[80] = 0;
357             changed++;
358         } else if (strncmp(strtrim(haddr), buf, 80))
359           nochange++;
360     } else {
361         if (strncmp(strtrim(haddr), buf, 80))
362           changed++;
363         strncpy(haddr, buf, 80);
364         haddr[80] = 0;
365     }
366     from = e->dphone;
367     to = buf;
368     while (*from) {
369         if (isdigit(*from))
370           *to++ = *from;
371         from++;
372     }
373     *to = 0;
374     if (newfinger) {
375         if (hphone[0] == ' ') {
376             strncpy(hphone, buf, 16);
377             hphone[16] = 0;
378         } else if (strncmp(strtrim(hphone), buf, 16))
379           nochange++;
380     } else {
381         if (strncmp(strtrim(hphone), buf, 16))
382           changed++;
383         strncpy(hphone, buf, 16);
384         hphone[16] = 0;
385     }
386     from = e->mphone;
387     to = buf;
388     while (*from) {
389         if (isdigit(*from))
390           *to++ = *from;
391         from++;
392     }
393     *to = 0;
394     if (newfinger) {
395         if (ophone[0] == ' ') {
396             strncpy(ophone, buf, 12);
397             ophone[12] = 0;
398         } else if (strncmp(strtrim(ophone), buf, 12))
399           nochange++;
400     } else {
401         if (strncmp(strtrim(ophone), buf, 12))
402           changed++;
403         strncpy(ophone, buf, 12);
404         ophone[12] = 0;
405     }
406     e->course = e->course;
407     if (newfinger) {
408         if (dept[0] == ' ') {
409             strncpy(dept, e->course, 12);
410             dept[12] = 0;
411         } else if (strncmp(strtrim(dept), e->course, 11))
412           nochange++;
413     } else {
414         if (strncmp(strtrim(dept), e->course, 11))
415           changed++;
416         strncpy(dept, e->course, 12);
417         dept[12] = 0;
418     }
419     sid = e->id;
420     name = e->name;
421     rdept = e->course;
422     rtitle = e->title;
423     rophone = e->mphone;
424     rhphone = e->dphone;
425     strcpy(raddr, e->address);
426     if (*e->dorm) {
427         strcat(raddr, " ");
428         strcat(raddr, e->dorm);
429     }
430     strcat(raddr, "|");
431     if (*e->city) {
432         strcat(raddr, e->city);
433         FixCase(raddr);
434         if (*e->state) {
435             strcat(raddr, " ");
436             if (isupper(e->state[0]) && isupper(e->state[1]) &&
437                 isdigit(e->state[2]) && isdigit(e->state[3]) &&
438                 isdigit(e->state[4]) && isdigit(e->state[5]) &&
439                 isdigit(e->state[6])) {
440                 sprintf(buf, "%c%c  %s", e->state[0],e->state[1],
441                         &(e->state[2]));
442                 strcat(raddr, buf);
443             } else
444               strcat(raddr, e->state);
445         }
446     } else {
447         FixCase(raddr);
448         strcat(raddr, "MIT INTERDEPARTMENTAL MAIL");
449     }
450     if (changed) {
451         com_err(whoami, 0, "updating finger for %s %s", first, last);
452         EXEC SQL REPEATED UPDATE users
453           SET home_addr = :haddr, home_phone = :hphone,
454             office_phone = :ophone, department = :dept,
455             fmodtime = 'now', fmodby = :who, fmodwith = :prog,
456             xname = :name, xdept = :rdept, xtitle = :rtitle,
457             xaddress = :raddr, xphone1 = :rhphone, xphone2 = :rophone,
458             xmodtime = date('now'), clearid = :sid
459           WHERE users_id = :id;
460         if (sqlca.sqlcode != 0) {
461             com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
462             exit(1);
463         }
464     }  else {
465         EXEC SQL REPEATED UPDATE users
466           SET xname = :name, xdept = :rdept, xtitle = :rtitle,
467             xaddress = :raddr, xphone1 = :rhphone, xphone2 = :rophone,
468             xmodtime = date('now'), clearid = :sid
469           WHERE users_id = :id;
470         if (sqlca.sqlcode != 0) {
471             com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
472             exit(1);
473         }
474     }
475 }
476
477
478 newuser(e)
479 struct entry *e;
480 {
481     char buf[512], *from, *to;
482     EXEC SQL BEGIN DECLARE SECTION;
483     int id, uid, who;
484     char *last, *first, *class, *middle, login[9], *sid, fullname[65], *prog;
485     char haddr[81], hphone[17], ophone[13], dept[24], *title, raddr[81], *name;
486     EXEC SQL END DECLARE SECTION;
487
488     who = WHO;
489     prog = PROG;
490     strcpy(buf, e->address);
491     if (*e->dorm) {
492         strcat(buf, " ");
493         strcat(buf, e->dorm);
494     }
495     if (*e->city) {
496         strcat(buf, " ");
497         strcat(buf, e->city);
498     }
499     if (*e->state) {
500         strcat(buf, " ");
501         strcat(buf, e->state);
502     }
503     strncpy(haddr, buf, 80);
504     from = e->dphone;
505     to = buf;
506     while (*from) {
507         if (isdigit(*from))
508           *to++ = *from;
509         from++;
510     }
511     *to = 0;
512     strncpy(hphone, buf, 16);
513     from = e->mphone;
514     to = buf;
515     while (*from) {
516         if (isdigit(*from))
517           *to++ = *from;
518         from++;
519     }
520     *to = 0;
521     strncpy(ophone, buf, 12);
522     strncpy(dept, e->course, 12);
523     
524     id = set_next_users_id(0);
525     uid = set_next_uid(1);
526     sprintf(login, "#%d", uid);
527     last = e->last;
528     first = e->first;
529     middle = e->middle;
530     sid = e->id;
531     class = e->class;
532     title = e->title;
533     if (*middle)
534       sprintf(fullname, "%s %s %s", first, middle, last);
535     else
536       sprintf(fullname, "%s %s", first, last);
537     name = e->name;
538     strcpy(raddr, e->address);
539     if (*e->dorm) {
540         strcat(raddr, " ");
541         strcat(raddr, e->dorm);
542     }
543     strcat(raddr, "|");
544     if (*e->city) {
545         strcat(raddr, e->city);
546         FixCase(raddr);
547         if (*e->state) {
548             strcat(raddr, " ");
549             if (isupper(e->state[0]) && isupper(e->state[1]) &&
550                 isdigit(e->state[2]) && isdigit(e->state[3]) &&
551                 isdigit(e->state[4]) && isdigit(e->state[5]) &&
552                 isdigit(e->state[6])) {
553                 sprintf(buf, "%c%c  %s", e->state[0],e->state[1],
554                         &(e->state[2]));
555                 strcat(raddr, buf);
556             } else
557               strcat(raddr, e->state);
558         }
559     } else {
560         FixCase(raddr);
561         strcat(raddr, "MIT INTERDEPARTMENTAL MAIL");
562     }
563     EXEC SQL REPEATED INSERT INTO users
564       (login, users_id, uid, shell, last, first, middle, status,
565        clearid, type, modtime, modby, modwith, fullname, home_addr,
566        home_phone, office_phone, department, fmodtime, fmodby, fmodwith,
567        potype, xname, xdept, xtitle, xaddress, xphone1, xphone2, xmodtime)
568       VALUES (:login, :id, :uid, '/bin/csh', :last, :first, :middle, 0,
569               :sid, :class, 'now', :who, :prog, :fullname, :haddr, :hphone,
570               :ophone, :dept, 'now', :who, :prog, 'NONE', :name, :dept,
571               :title, :raddr, :hphone, :ophone, date('now'));
572     if (sqlca.sqlcode != 0) {
573         com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
574         exit(1);
575     } else
576       com_err(whoami, 0, "adding user %s %s", e->first, e->last);
577 }
578
579
580
581 set_next_users_id(limit)
582     int limit;
583 {
584     EXEC SQL BEGIN DECLARE SECTION;
585     int rowcount, flag, value, retval;
586     EXEC SQL END DECLARE SECTION;
587
588     EXEC SQL REPEATED SELECT value INTO :value FROM numvalues 
589       WHERE name = 'users_id';
590     if (sqlfail()) sqlexit();
591     if (sqlca.sqlerrd[2] != 1) {
592         EXEC SQL ROLLBACK;
593         com_err(whoami, MR_INTERNAL, "values table inconsistancy");
594         exit(1);
595     }
596
597     flag = 0;
598     EXEC SQL REPEATED SELECT users_id INTO :flag FROM users
599       WHERE users_id = :value;
600     if (sqlfail()) sqlexit();
601     if (sqlca.sqlerrd[2] == 0)
602       flag = 0;
603     while (flag) {
604         value++;
605         if (limit && value > MAX_ID_VALUE)
606             value = MIN_ID_VALUE;
607         flag = 0;
608         EXEC SQL REPEATED SELECT users_id INTO :flag FROM users 
609           WHERE users_id = :value;
610         if (sqlfail()) sqlexit();
611         if (sqlca.sqlerrd[2] == 0)
612           flag = 0;
613     }
614
615     retval = value++;
616     if (limit && value > MAX_ID_VALUE)
617       value = MIN_ID_VALUE;
618     EXEC SQL REPEATED UPDATE numvalues SET value = :value
619       WHERE name = 'users_id';
620     if (sqlca.sqlcode != 0) {
621         com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
622         exit(1);
623     }
624     return(retval);
625 }
626
627 set_next_uid(limit)
628     int limit;
629 {
630     EXEC SQL BEGIN DECLARE SECTION;
631     int rowcount, flag, value, retval;
632     EXEC SQL END DECLARE SECTION;
633
634     EXEC SQL REPEATED SELECT value INTO :value FROM numvalues 
635       WHERE name = 'uid';
636     if (sqlfail()) sqlexit();
637     if (sqlca.sqlerrd[2] != 1) {
638         EXEC SQL ROLLBACK;
639         com_err(whoami, MR_INTERNAL, "values table inconsistancy");
640         exit(1);
641     }
642
643     flag = 0;
644     EXEC SQL REPEATED SELECT uid INTO :flag FROM users WHERE uid = :value;
645     if (sqlfail()) sqlexit();
646     if (sqlca.sqlerrd[2] == 0)
647       flag = 0;
648     while (flag) {
649         value++;
650         if (limit && value > MAX_ID_VALUE)
651             value = MIN_ID_VALUE;
652         flag = 0;
653         EXEC SQL REPEATED SELECT uid INTO :flag FROM users WHERE uid = :value;
654         if (sqlfail()) sqlexit();
655         if (sqlca.sqlerrd[2] == 0)
656           flag = 0;
657     }
658
659     retval = value++;
660     if (limit && value > MAX_ID_VALUE)
661       value = MIN_ID_VALUE;
662     EXEC SQL REPEATED UPDATE numvalues SET value = :value WHERE name = 'uid';
663     if (sqlca.sqlcode != 0) {
664         com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
665         exit(1);
666     }
667     return(retval);
668 }
669
670
671 sqlexit()
672 {
673     com_err(whoami, 0, "ingres error %d", sqlca.sqlcode);
674     EXEC SQL ROLLBACK WORK;
675     exit(1);
676 }
This page took 0.087451 seconds and 3 git commands to generate.