Mercurial > mercurial > hgweb_golang.cgi
comparison src/kaigo/qtuti/95y/95.go @ 65:0369656be06c default tip
many changes.
author | pyon@macmini |
---|---|
date | Fri, 20 May 2022 06:30:34 +0900 |
parents | |
children |
comparison
equal
deleted
inserted
replaced
64:ad5c30ee5cf1 | 65:0369656be06c |
---|---|
1 /* | |
2 95.go: Qfuhi Tsuchi | |
3 | |
4 Last Change: 2020-09-11 金 10:42:16. | |
5 */ | |
6 | |
7 package main | |
8 | |
9 /* | |
10 #cgo LDFLAGS: -L. -lxdwapi -static | |
11 // | |
12 // 95.cpp: Qfuhi Tsuchi | |
13 // Last Change: 2020-09-08 火 15:20:43. | |
14 // | |
15 | |
16 #include <stdio.h> | |
17 #include <stdlib.h> | |
18 #include <string.h> | |
19 #include <io.h> | |
20 #include <windows.h> | |
21 #include <xdw_api.h> | |
22 #include <xdwapian.h> | |
23 | |
24 #define MAXCOL 1024 | |
25 #define MAXLINE 9999 | |
26 #define BLOCKSZ 128 | |
27 #define ATN_N 20 | |
28 | |
29 char* xdw2txt(const char* file) { | |
30 char in_path[_MAX_PATH]; | |
31 _fullpath(in_path, file, _MAX_PATH); | |
32 | |
33 XDW_DOCUMENT_HANDLE h = NULL; // 文書ハンドルを開く | |
34 XDW_OPEN_MODE_EX mode = {sizeof(XDW_OPEN_MODE_EX), XDW_OPEN_READONLY, XDW_AUTH_NODIALOGUE}; | |
35 if (XDW_OpenDocumentHandle(in_path, &h, (XDW_OPEN_MODE*)&mode)) { | |
36 fprintf(stderr, "Error: cannot open %s\n", file); | |
37 return NULL; | |
38 } | |
39 | |
40 XDW_DOCUMENT_INFO info = {sizeof(XDW_DOCUMENT_INFO), 0, 0, 0}; // 総ページ数を得る | |
41 XDW_GetDocumentInformation(h, &info); | |
42 int nPage = info.nPages; | |
43 | |
44 // メイン処理 | |
45 char *lpszvalue, *all_lpszvalue; | |
46 long datasize[9999]; | |
47 for (int i=1; i<=nPage; i++) { | |
48 datasize[i] = XDW_GetPageTextToMemory(h, i, NULL, 0, NULL); | |
49 datasize[0] += datasize[i]; | |
50 } | |
51 datasize[0] += nPage - 1; // for "\n" | |
52 all_lpszvalue = (char*)malloc(sizeof(char)*datasize[0]); | |
53 all_lpszvalue[0] = '\0'; | |
54 for (int i = 1; i <= nPage; i++) { | |
55 if (i < nPage) datasize[i]++; // for "\n" | |
56 lpszvalue = (char*)malloc(sizeof(char)*(datasize[i])); | |
57 XDW_GetPageTextToMemory(h, i, lpszvalue, datasize[i], NULL); | |
58 strcat(all_lpszvalue, lpszvalue); | |
59 if (i < nPage) strcat(all_lpszvalue, "\n"); | |
60 free(lpszvalue); | |
61 } | |
62 | |
63 XDW_CloseDocumentHandle(h, NULL); // 文書ハンドルを閉じる | |
64 return all_lpszvalue; | |
65 } | |
66 | |
67 void xdw2txtb(const char* xdwfile, const char* txtfile) { | |
68 char in_path[_MAX_PATH], out_path[_MAX_PATH]; | |
69 _fullpath(in_path, xdwfile, _MAX_PATH); | |
70 _fullpath(out_path, txtfile, _MAX_PATH); | |
71 | |
72 XDW_DOCUMENT_HANDLE h = NULL; // 文書ハンドルを開く | |
73 XDW_OPEN_MODE_EX mode = {sizeof(XDW_OPEN_MODE_EX), XDW_OPEN_READONLY, XDW_AUTH_NODIALOGUE}; | |
74 if (XDW_OpenDocumentHandle(in_path, &h, (XDW_OPEN_MODE*)&mode)) { | |
75 fprintf(stderr, "Error: cannot open %s\n", xdwfile); | |
76 return; | |
77 } | |
78 | |
79 XDW_DOCUMENT_INFO info = {sizeof(XDW_DOCUMENT_INFO), 0, 0, 0}; // 総ページ数を得る | |
80 XDW_GetDocumentInformation(h, &info); | |
81 int nPage = info.nPages; | |
82 | |
83 FILE *fp; | |
84 if ((fp = fopen(out_path, "w")) == NULL) { | |
85 fprintf(stderr, "Error: cannot open %s\n", out_path); | |
86 return; | |
87 } | |
88 | |
89 long datasize; | |
90 char* lpszvalue; | |
91 | |
92 for (int i = 1; i <= nPage; i++) { | |
93 datasize = XDW_GetPageTextToMemory(h, i, NULL, 0, NULL); | |
94 lpszvalue = (char*)malloc(sizeof(char)*datasize); | |
95 XDW_GetPageTextToMemory(h, i, lpszvalue, datasize, NULL); | |
96 fprintf(fp, "%s\n", lpszvalue); | |
97 free(lpszvalue); | |
98 } | |
99 | |
100 fclose(fp); | |
101 XDW_CloseDocumentHandle(h, NULL); // 文書ハンドルを閉じる | |
102 return; | |
103 } | |
104 | |
105 int xdwsplit1(const char* file, const char* workdir, const char* prefix) { | |
106 char file_path[_MAX_PATH]; | |
107 _fullpath(file_path, file, _MAX_PATH); | |
108 | |
109 XDW_DOCUMENT_HANDLE h = NULL; | |
110 XDW_OPEN_MODE_EX mode = {sizeof(XDW_OPEN_MODE_EX), XDW_OPEN_READONLY, XDW_AUTH_NODIALOGUE}; | |
111 if (XDW_OpenDocumentHandle(file_path, &h, (XDW_OPEN_MODE*)&mode)) { | |
112 fprintf(stderr, "Error: cannot open %s\n", file); | |
113 return -1; | |
114 } | |
115 | |
116 XDW_DOCUMENT_INFO info = {sizeof(XDW_DOCUMENT_INFO), 0, 0, 0}; | |
117 XDW_GetDocumentInformation(h, &info); | |
118 int nPage = info.nPages; | |
119 | |
120 char buf[_MAX_PATH]; | |
121 for (int i = 1; i <= nPage; i++) { | |
122 sprintf(buf, "%s/%s%05d.xdw", workdir, prefix, i); | |
123 //sprintf(buf, "%s_%05d.xdw", prefix, i); | |
124 _fullpath(file_path, buf, _MAX_PATH); | |
125 | |
126 int api_result = XDW_GetPage(h, i, file_path, NULL); | |
127 if (api_result < 0) { | |
128 fprintf(stderr, "XDW Error: cannot get page (%s p=%d)\n", file, i); | |
129 return -1; | |
130 } | |
131 } | |
132 | |
133 XDW_CloseDocumentHandle(h, NULL); | |
134 return 0; | |
135 } | |
136 | |
137 int xdwextpage(const char* infile, const int p, const char* outfile) { | |
138 char file_path[_MAX_PATH]; | |
139 _fullpath(file_path, infile, _MAX_PATH); | |
140 | |
141 XDW_DOCUMENT_HANDLE h = NULL; | |
142 XDW_OPEN_MODE_EX mode = {sizeof(XDW_OPEN_MODE_EX), XDW_OPEN_READONLY, XDW_AUTH_NODIALOGUE}; | |
143 if (XDW_OpenDocumentHandle(file_path, &h, (XDW_OPEN_MODE*)&mode)) { | |
144 fprintf(stderr, "Error: cannot open %s\n", infile); | |
145 return -1; | |
146 } | |
147 | |
148 XDW_DOCUMENT_INFO info = {sizeof(XDW_DOCUMENT_INFO), 0, 0, 0}; | |
149 XDW_GetDocumentInformation(h, &info); | |
150 int nPage = info.nPages; | |
151 | |
152 char buf[_MAX_PATH]; | |
153 _fullpath(file_path, outfile, _MAX_PATH); | |
154 | |
155 int api_result = XDW_GetPage(h, p, file_path, NULL); | |
156 if (api_result < 0) { | |
157 fprintf(stderr, "XDW Error: cannot get page (%s p=%d)\n", infile, p); | |
158 return -1; | |
159 } | |
160 | |
161 XDW_CloseDocumentHandle(h, NULL); | |
162 return 0; | |
163 } | |
164 | |
165 void xdwmerge(const char* list, const char* output) { | |
166 FILE *fp; | |
167 | |
168 if ((fp = fopen(list, "r")) == NULL) { | |
169 fprintf(stderr, "XDW Error: can't open file [%s]\n", list); | |
170 exit(1); | |
171 } | |
172 | |
173 char *all_path = (char*)malloc(MAXLINE * sizeof(char) * _MAX_PATH); | |
174 | |
175 if (all_path == NULL) { | |
176 fprintf(stderr, "XDW Error: can't allocate memory\n"); | |
177 exit(1); | |
178 } | |
179 | |
180 int n = 0; | |
181 char *q; | |
182 char buf[_MAX_PATH]; | |
183 | |
184 while (fgets(buf, sizeof buf, fp)) { | |
185 if ((q = strchr(buf, '\n')) != NULL) { | |
186 *q = '\0'; | |
187 } | |
188 _fullpath(buf, buf, _MAX_PATH); | |
189 strncpy(&all_path[n * _MAX_PATH], buf, _MAX_PATH); | |
190 n++; | |
191 } | |
192 fclose(fp); | |
193 | |
194 char *blk_path = (char*)malloc(BLOCKSZ * sizeof(char) * _MAX_PATH); | |
195 const char **blk_path_addr = (const char**)malloc((n / BLOCKSZ + 1) * sizeof(char*) * _MAX_PATH); | |
196 if (blk_path == NULL || blk_path_addr == NULL) { | |
197 fprintf(stderr, "XDW Error: can't allocate memory\n"); | |
198 exit(1); | |
199 } | |
200 | |
201 // process by block | |
202 int api_result; | |
203 int bn = 0; | |
204 for (int p = 0, m = 0; p < n; p++) { | |
205 m = p % BLOCKSZ; | |
206 if (m == 0 && p > 0) { | |
207 sprintf(buf, "tmp_b%04d.xdw", ++bn); | |
208 _fullpath(buf, buf, _MAX_PATH); | |
209 api_result = XDW_MergeXdwFiles(blk_path_addr, BLOCKSZ, buf, NULL); | |
210 if (api_result < 0) { | |
211 fprintf(stderr, "XDW Error: can't merge [1] (p = %d, m = %d)\n", p, m); | |
212 exit(1); | |
213 } | |
214 } | |
215 strncpy(&blk_path[m * _MAX_PATH], &all_path[p * _MAX_PATH], _MAX_PATH); | |
216 blk_path_addr[m] = &blk_path[m * _MAX_PATH]; | |
217 } | |
218 | |
219 sprintf(buf, "tmp_b%04d.xdw", ++bn); | |
220 _fullpath(buf, buf, _MAX_PATH); | |
221 | |
222 int mod = n % BLOCKSZ; | |
223 if (mod == 0) mod = BLOCKSZ; | |
224 api_result = XDW_MergeXdwFiles(blk_path_addr, mod, buf, NULL); | |
225 | |
226 if (api_result < 0) { | |
227 fprintf(stderr, "XDW Error: can't merge [2]\n"); | |
228 exit(1); | |
229 } | |
230 | |
231 // merge blocks | |
232 for (int b = 0; b < bn; b++) { | |
233 sprintf(buf, "tmp_b%04d.xdw", b + 1); | |
234 _fullpath(buf, buf, _MAX_PATH); | |
235 strncpy(&blk_path[b * _MAX_PATH], buf, _MAX_PATH); | |
236 blk_path_addr[b] = &blk_path[b * _MAX_PATH]; | |
237 } | |
238 | |
239 _fullpath(buf, output, _MAX_PATH ); | |
240 api_result = XDW_MergeXdwFiles(blk_path_addr, bn, buf, NULL); | |
241 | |
242 if (api_result < 0) { | |
243 fprintf(stderr, "XDW Error: can't merge [3]\n"); | |
244 exit(1); | |
245 } | |
246 | |
247 free(all_path); | |
248 free(blk_path); | |
249 free(blk_path_addr); | |
250 | |
251 for (int b = 0; b < bn; b++) { | |
252 sprintf(buf, "tmp_b%04d.xdw", b + 1); | |
253 _fullpath(buf, buf, _MAX_PATH); | |
254 remove(buf); | |
255 } | |
256 } | |
257 | |
258 int xdwaddatn(const char* xdwfile, const char* atnfile) { | |
259 FILE *fp; | |
260 char filepath[_MAX_PATH]; | |
261 _fullpath(filepath, atnfile, _MAX_PATH); | |
262 | |
263 if ((fp = fopen(filepath, "r")) == NULL) { | |
264 fprintf(stderr, "Error: cannot open %s\n", filepath); | |
265 return -1; | |
266 } | |
267 | |
268 char keyword[128]; | |
269 char *q; | |
270 fgets(keyword, sizeof keyword, fp); | |
271 if ((q = strchr(keyword, '\n')) != NULL) { | |
272 *q = '\0'; | |
273 } | |
274 | |
275 char buf[_MAX_PATH]; | |
276 int x[ATN_N], y[ATN_N], sz[ATN_N], tr[ATN_N]; | |
277 char txt[ATN_N][256]; | |
278 int an = 0; | |
279 while (fgets(buf, sizeof buf, fp)) { | |
280 if ((q = strchr(buf, '\n')) != NULL) { | |
281 *q = '\0'; | |
282 } | |
283 | |
284 x[an] = atoi(strtok(buf, ",")); | |
285 y[an] = atoi(strtok(NULL, ",")); | |
286 sz[an] = atoi(strtok(NULL, ",")); | |
287 tr[an] = atoi(strtok(NULL, ",")); | |
288 strcpy(txt[an], strtok(NULL, ",")); | |
289 an++; | |
290 //printf("x=%d y=%d txt=%s sz=%d tr=%d\n", x[an], y[an], txt[an], sz[an], tr[an]); | |
291 } | |
292 fclose(fp); | |
293 | |
294 | |
295 XDW_DOCUMENT_HANDLE h = NULL; | |
296 XDW_OPEN_MODE_EX mode = {sizeof(XDW_OPEN_MODE_EX), XDW_OPEN_UPDATE, XDW_AUTH_NODIALOGUE}; | |
297 | |
298 _fullpath(filepath, xdwfile, _MAX_PATH); | |
299 int api_result = XDW_OpenDocumentHandle(filepath, &h, (XDW_OPEN_MODE*)&mode); | |
300 if (api_result < 0) return api_result; | |
301 | |
302 XDW_DOCUMENT_INFO info = {sizeof(XDW_DOCUMENT_INFO), 0, 0, 0}; | |
303 XDW_GetDocumentInformation(h, &info); | |
304 XDW_FOUND_HANDLE pFoundHandle = NULL; | |
305 for (int i = 0; i < info.nPages; i++) { | |
306 if (keyword[0] != '\0') { | |
307 api_result = XDW_FindTextInPage(h, i + 1, keyword, NULL, &pFoundHandle, NULL); | |
308 if (!pFoundHandle) { | |
309 XDW_CloseFoundHandle(pFoundHandle); | |
310 continue; | |
311 } | |
312 XDW_CloseFoundHandle(pFoundHandle); | |
313 } | |
314 for (int j = 0; j < an; j++ ) { | |
315 XDW_ANNOTATION_HANDLE annoation; | |
316 int api_result = XDW_AddAnnotation(h, XDW_AID_TEXT, i + 1, x[j], y[j], NULL, &annoation, NULL); | |
317 if (api_result < 0) return api_result; | |
318 | |
319 api_result = XDW_SetAnnotationAttribute(h, annoation, XDW_ATN_Text, XDW_ATYPE_STRING, txt[j], 0, NULL); | |
320 api_result = XDW_SetAnnotationAttribute(h, annoation, XDW_ATN_FontSize, XDW_ATYPE_INT, (char*)&sz[j], 0, NULL); | |
321 | |
322 int color = XDW_COLOR_WHITE; | |
323 if (tr[j]) { | |
324 color = XDW_COLOR_NONE; | |
325 } | |
326 api_result = XDW_SetAnnotationAttribute(h, annoation, XDW_ATN_BackColor, XDW_ATYPE_INT, (char*)&color, 0, NULL); | |
327 } | |
328 } | |
329 | |
330 XDW_SaveDocument(h, NULL); | |
331 XDW_CloseDocumentHandle(h, NULL); | |
332 | |
333 return 0; | |
334 } | |
335 | |
336 int xdwaddatntool(const char* xdwfile, const char* toolfile, int n, int x, int y) { | |
337 char filepath[_MAX_PATH]; | |
338 _fullpath(filepath, xdwfile, _MAX_PATH); | |
339 | |
340 XDW_DOCUMENT_HANDLE h = NULL; | |
341 XDW_OPEN_MODE_EX mode = {sizeof(XDW_OPEN_MODE_EX), XDW_OPEN_UPDATE, XDW_AUTH_NODIALOGUE}; | |
342 | |
343 int api_result = XDW_OpenDocumentHandle(filepath, &h, (XDW_OPEN_MODE*)&mode); | |
344 if (api_result < 0) return api_result; | |
345 | |
346 XDW_DOCUMENT_INFO info = {sizeof(XDW_DOCUMENT_INFO), 0, 0, 0}; | |
347 XDW_GetDocumentInformation(h, &info); | |
348 | |
349 _fullpath(filepath, toolfile, _MAX_PATH); | |
350 for (int i = 0; i < info.nPages; i++) { | |
351 XDW_ANNOTATION_HANDLE annoation; | |
352 int api_result = XDW_AddAnnotationFromAnnFile(h, filepath, n, i + 1, NULL, x, y, &annoation, NULL); | |
353 } | |
354 | |
355 XDW_SaveDocument(h, NULL); | |
356 XDW_CloseDocumentHandle(h, NULL); | |
357 | |
358 return 0; | |
359 } | |
360 | |
361 | |
362 */ | |
363 import "C" | |
364 | |
365 import ( | |
366 "bufio" | |
367 "regexp" | |
368 "encoding/json" | |
369 "flag" | |
370 "fmt" | |
371 "io/ioutil" | |
372 "log" | |
373 "os" | |
374 "path/filepath" | |
375 "sort" | |
376 "strings" | |
377 | |
378 "golang.org/x/text/encoding/japanese" | |
379 "golang.org/x/text/transform" | |
380 ) | |
381 | |
382 type Hhs struct { | |
383 No string | |
384 Name string | |
385 Page int // sinsei page | |
386 Tsuchi bool | |
387 Kaigo string | |
388 Xdw []string | |
389 } | |
390 | |
391 func(h *Hhs) AppendXdw(xdw string) { | |
392 h.Xdw = append(h.Xdw, xdw) | |
393 } | |
394 | |
395 func(h *Hhs) CsvString() string { | |
396 q := "" | |
397 if h.Tsuchi { | |
398 q = "○" | |
399 } | |
400 k := strings.Split(h.Kaigo, "") | |
401 return strings.Join([]string{h.No, h.Name, q, k[1] + k[3]}, ",") | |
402 } | |
403 | |
404 func(h *Hhs) Dump() string { | |
405 q := "false" | |
406 if h.Tsuchi { | |
407 q = "true" | |
408 } | |
409 p := fmt.Sprintf("%05d", h.Page) | |
410 x := strings.Join(h.Xdw, ",") | |
411 return strings.Join([]string{h.No, h.Name, q, h.Kaigo, p, x}, ",") | |
412 } | |
413 | |
414 type Config struct { | |
415 Indir string | |
416 Outdir string | |
417 Workdir string | |
418 Hhsdb string | |
419 Atnfile[] string | |
420 } | |
421 | |
422 var ( | |
423 ver = "0.1" | |
424 conf Config | |
425 confjson = "95.json" | |
426 logfile = "95.log" | |
427 osirase = "KBPA316G.xdw" | |
428 sinsei = "KBPA406G.xdw" | |
429 rule_s = "rules.ann" | |
430 | |
431 out_o = "o.xdw" | |
432 out_s = "s.xdw" | |
433 out_q = "q.xdw" | |
434 out_l = "l.csv" | |
435 | |
436 re_hhsno, re_name, re_kaigo *regexp.Regexp | |
437 | |
438 // option parameters | |
439 version bool | |
440 ) | |
441 | |
442 func init() { | |
443 /* コンフィグファイルは JSON */ | |
444 content, err := ioutil.ReadFile(confjson) | |
445 if err != nil { | |
446 log.Fatal(err) | |
447 } | |
448 if err := json.Unmarshal(content, &conf); err != nil { | |
449 log.Fatal(err) | |
450 } | |
451 | |
452 osirase = filepath.Join(conf.Indir, osirase) | |
453 sinsei = filepath.Join(conf.Indir, sinsei) | |
454 | |
455 out_o = filepath.Join(conf.Outdir, out_o) | |
456 out_s = filepath.Join(conf.Outdir, out_s) | |
457 out_q = filepath.Join(conf.Outdir, out_q) | |
458 out_l = filepath.Join(conf.Outdir, out_l) | |
459 | |
460 logfile = filepath.Join(conf.Workdir, logfile) | |
461 | |
462 /* 一時ファイル消去 */ | |
463 os.RemoveAll(conf.Outdir) | |
464 os.RemoveAll(conf.Workdir) | |
465 os.Mkdir(conf.Outdir, 0755) | |
466 os.Mkdir(conf.Workdir, 0755) | |
467 | |
468 /* 変数初期化 */ | |
469 re_hhsno = regexp.MustCompile(`0[1238]00\d{6}`) | |
470 re_name = regexp.MustCompile(`日.{30}`) | |
471 re_kaigo = regexp.MustCompile(`要((介護)|(支援)).`) | |
472 | |
473 flag.BoolVar(&version, "v", false, "print version") | |
474 } | |
475 | |
476 func main() { | |
477 flag.Parse() | |
478 | |
479 if version { | |
480 fmt.Println("95 - version", ver) | |
481 os.Exit(0) | |
482 } | |
483 | |
484 hash_Hhs := make(map[string]Hhs) | |
485 | |
486 /* 申請書を漁り,構造体を初期化 */ | |
487 for p, t := range xdw2txt(sinsei) { | |
488 hno := re_hhsno.FindString(t) | |
489 name := re_name.FindString(t) | |
490 name = strings.Replace(name, "日", "", 1) | |
491 kaigo := re_kaigo.FindString(t) | |
492 o := fmt.Sprintf("o_%05d.xdw", p + 1) | |
493 s := fmt.Sprintf("s_%05d.xdw", p + 1) | |
494 h := Hhs{No: hno, Name: name, Kaigo: kaigo, Page:p + 1, Xdw: []string{o, s}} | |
495 hash_Hhs[hno] = h | |
496 } | |
497 | |
498 /* バックグラウンドで給付費通知から勧奨対象者を抽出 */ | |
499 ch := make(chan int) | |
500 go func() { | |
501 files, err := ioutil.ReadDir(conf.Indir) | |
502 if err != nil { | |
503 log.Fatal(err) | |
504 } | |
505 | |
506 qn := 1 | |
507 for _, file := range files { | |
508 if !strings.HasSuffix(file.Name(), ".xdw") { | |
509 continue | |
510 } | |
511 if strings.HasPrefix(file.Name(), "KDPK016G") || strings.HasPrefix(file.Name(), "KDPK126G") { | |
512 qtsuchi := filepath.Join(conf.Indir, file.Name()) | |
513 tmptxt := filepath.Join(conf.Workdir, "tmp95.txt") | |
514 for p, t := range xdw2txtb(qtsuchi, tmptxt) { | |
515 hno := re_hhsno.FindString(t) | |
516 if h, ok := hash_Hhs[hno]; ok { | |
517 h.Tsuchi = true | |
518 q := fmt.Sprintf("q_%05d.xdw", qn) | |
519 h.AppendXdw(q) | |
520 hash_Hhs[hno] = h | |
521 q = filepath.Join(conf.Workdir, q) | |
522 C.xdwextpage(C.CString(qtsuchi), C.int(p + 1), C.CString(q)) | |
523 qn++ | |
524 //fmt.Println(qtsuchi, p, hno, h.Kaigo, h.Xdw) | |
525 } | |
526 } | |
527 } | |
528 } | |
529 | |
530 ch <- 1 | |
531 }() | |
532 | |
533 /* そのあいだにバラす */ | |
534 C.xdwsplit1(C.CString(osirase), C.CString(conf.Workdir), C.CString("o_")) | |
535 C.xdwsplit1(C.CString(sinsei), C.CString(conf.Workdir), C.CString("s_")) | |
536 <-ch | |
537 | |
538 /* ソート & マージ */ | |
539 var slice_Hhs []Hhs | |
540 for _, h := range hash_Hhs { | |
541 slice_Hhs = append(slice_Hhs, h) | |
542 } | |
543 sort.Slice(slice_Hhs, func(i, j int) bool { | |
544 if slice_Hhs[i].Tsuchi != slice_Hhs[j].Tsuchi { | |
545 return slice_Hhs[i].Tsuchi | |
546 } | |
547 if slice_Hhs[i].Kaigo != slice_Hhs[j].Kaigo { | |
548 return slice_Hhs[i].Kaigo < slice_Hhs[j].Kaigo | |
549 } | |
550 if slice_Hhs[i].Page != slice_Hhs[j].Page { | |
551 return slice_Hhs[i].Page < slice_Hhs[j].Page | |
552 } | |
553 return false | |
554 }) | |
555 | |
556 var list_o, list_s, list_q []string | |
557 for _, h := range slice_Hhs { | |
558 list_o = append(list_o, filepath.Join(conf.Workdir, h.Xdw[0])) | |
559 list_s = append(list_s, filepath.Join(conf.Workdir, h.Xdw[1])) | |
560 if h.Tsuchi { | |
561 for i, x := range h.Xdw { | |
562 if i > 1 { | |
563 buf := filepath.Join(conf.Workdir, x) | |
564 list_q = append(list_q, buf) | |
565 } | |
566 } | |
567 } | |
568 } | |
569 xdwmerge(list_o, out_o) | |
570 xdwmerge(list_s, out_s) | |
571 xdwmerge(list_q, out_q) | |
572 | |
573 /* リスト出力 & ログダンプ */ | |
574 csvtxt := "" | |
575 logtxt := "" | |
576 for _, h := range slice_Hhs { | |
577 csvtxt += h.CsvString() + "\n" | |
578 logtxt += h.Dump() + "\n" | |
579 } | |
580 csvtxt, _, _ = transform.String(japanese.ShiftJIS.NewEncoder(), csvtxt) | |
581 if err := ioutil.WriteFile(out_l, []byte(csvtxt), 0644); err != nil { | |
582 log.Fatal(err) | |
583 } | |
584 if err := ioutil.WriteFile(logfile, []byte(logtxt), 0644); err != nil { | |
585 log.Fatal(err) | |
586 } | |
587 | |
588 /* バックグラウンドで給付費通知を校正 */ | |
589 ch2 := make(chan int) | |
590 go func() { | |
591 for _, a := range conf.Atnfile { | |
592 xdwaddatn(out_q, a) | |
593 } | |
594 ch2 <- 1 | |
595 } () | |
596 | |
597 /* そのあいだに申請書に枠付け */ | |
598 xdwaddatntool(out_s, rule_s, 2, 1497, 803) | |
599 <-ch2 | |
600 } | |
601 | |
602 func xdw2txt(file string) (txt []string) { | |
603 s := C.GoString(C.xdw2txt(C.CString(file))) | |
604 r := strings.NewReader(s) | |
605 tr := transform.NewReader(r, japanese.ShiftJIS.NewDecoder()) | |
606 buf := bufio.NewScanner(tr) | |
607 for buf.Scan() { | |
608 txt = append(txt, buf.Text()) | |
609 } | |
610 return | |
611 } | |
612 | |
613 func xdw2txtb(xdwfile, txtfile string) (txt []string) { | |
614 if _, err := os.Stat(txtfile); os.IsExist(err) { | |
615 os.Remove(txtfile) | |
616 } | |
617 | |
618 C.xdw2txtb(C.CString(xdwfile), C.CString(txtfile)) | |
619 content, err := ioutil.ReadFile(txtfile) | |
620 if err != nil { | |
621 return nil | |
622 } | |
623 | |
624 r := strings.NewReader(string(content)) | |
625 tr := transform.NewReader(r, japanese.ShiftJIS.NewDecoder()) | |
626 buf := bufio.NewScanner(tr) | |
627 for buf.Scan() { | |
628 txt = append(txt, buf.Text()) | |
629 } | |
630 return | |
631 } | |
632 | |
633 func xdwmerge(list []string, outfile string) (err error) { | |
634 order := strings.Join(list, "\n") | |
635 order, _, _ = transform.String(japanese.ShiftJIS.NewEncoder(), order) | |
636 orderfile := filepath.Join(conf.Workdir, "order95.txt") | |
637 if err := ioutil.WriteFile(orderfile, []byte(order), 0644); err != nil { | |
638 return err | |
639 } | |
640 C.xdwmerge(C.CString(orderfile), C.CString(outfile)) | |
641 return nil | |
642 } | |
643 | |
644 func xdwaddatn(xdwfile, atnfile string) (err error) { | |
645 C.xdwaddatn(C.CString(xdwfile), C.CString(atnfile)) | |
646 return nil | |
647 } | |
648 | |
649 func xdwaddatntool(xdwfile, toolfile string, n, x, y int) (err error) { | |
650 C.xdwaddatntool(C.CString(xdwfile), C.CString(toolfile), C.int(n), C.int(x), C.int(y)) | |
651 return nil | |
652 } | |
653 |