/*
 95.go: Qfuhi Tsuchi

 Last Change: 2020-09-11 金 10:42:16.
*/

package main

/*
#cgo LDFLAGS: -L. -lxdwapi -static
##### C_SOURCE #####
*/
import "C"

import (
	"bufio"
	"regexp"
	"encoding/json"
	"flag"
    "fmt"
	"io/ioutil"
	"log"
	"os"
	"path/filepath"
	"sort"
	"strings"

	"golang.org/x/text/encoding/japanese"
	"golang.org/x/text/transform"
)

type Hhs struct {
	No     string
	Name   string
	Page   int	// sinsei page
	Tsuchi bool
	Kaigo  string
	Xdw    []string
}

func(h *Hhs) AppendXdw(xdw string) {
	h.Xdw = append(h.Xdw, xdw)
}

func(h *Hhs) CsvString() string {
	q := ""
	if h.Tsuchi {
		q = "○"
	}
	k := strings.Split(h.Kaigo, "")
	return strings.Join([]string{h.No, h.Name, q, k[1] + k[3]}, ",")
}

func(h *Hhs) Dump() string {
	q := "false"
	if h.Tsuchi {
		q = "true"
	}
	p := fmt.Sprintf("%05d", h.Page)
	x := strings.Join(h.Xdw, ",")
	return strings.Join([]string{h.No, h.Name, q, h.Kaigo, p, x}, ",")
}

type Config struct {
	Indir string
	Outdir string
	Workdir string
	Hhsdb string
	Atnfile[] string
}

var (
    ver = "0.1"
	conf Config
	confjson = "95.json"
	logfile = "95.log"
	osirase = "KBPA316G.xdw"
	sinsei = "KBPA406G.xdw"
	rule_s = "rules.ann"

	out_o = "o.xdw"
	out_s = "s.xdw"
	out_q = "q.xdw"
	out_l = "l.csv"

	re_hhsno, re_name, re_kaigo *regexp.Regexp

	// option parameters
	version bool
)

func init() {
    /* コンフィグファイルは JSON */
    content, err := ioutil.ReadFile(confjson)
    if err != nil {
        log.Fatal(err)
    }
	if err := json.Unmarshal(content, &conf); err != nil {
        log.Fatal(err)
	}

	osirase = filepath.Join(conf.Indir, osirase)
	sinsei = filepath.Join(conf.Indir, sinsei)

	out_o = filepath.Join(conf.Outdir, out_o)
	out_s = filepath.Join(conf.Outdir, out_s)
	out_q = filepath.Join(conf.Outdir, out_q)
	out_l = filepath.Join(conf.Outdir, out_l)

	logfile = filepath.Join(conf.Workdir, logfile)

	/* 一時ファイル消去 */
	os.RemoveAll(conf.Outdir)
	os.RemoveAll(conf.Workdir)
	os.Mkdir(conf.Outdir, 0755)
	os.Mkdir(conf.Workdir, 0755)

	/* 変数初期化 */
	re_hhsno = regexp.MustCompile(`0[1238]00\d{6}`)
	re_name  = regexp.MustCompile(`日.{30}`)
	re_kaigo = regexp.MustCompile(`要((介護)|(支援)).`)

	flag.BoolVar(&version, "v", false, "print version")
}

func main() {
	flag.Parse()

	if version {
		fmt.Println("95 - version", ver)
		os.Exit(0)
	}

	hash_Hhs := make(map[string]Hhs)

	/* 申請書を漁り，構造体を初期化 */
	for p, t := range xdw2txt(sinsei) {
		hno := re_hhsno.FindString(t)
		name := re_name.FindString(t)
		name = strings.Replace(name, "日", "", 1)
		kaigo := re_kaigo.FindString(t)
		o := fmt.Sprintf("o_%05d.xdw", p + 1)
		s := fmt.Sprintf("s_%05d.xdw", p + 1)
		h := Hhs{No: hno, Name: name, Kaigo: kaigo, Page:p + 1, Xdw: []string{o, s}}
		hash_Hhs[hno] = h
	}

	/* バックグラウンドで給付費通知から勧奨対象者を抽出 */
	ch := make(chan int)
	go func() {
		files, err := ioutil.ReadDir(conf.Indir)
		if err != nil {
			log.Fatal(err)
		}

		qn := 1
		for _, file := range files {
			if !strings.HasSuffix(file.Name(), ".xdw") {
				continue
			}
			if strings.HasPrefix(file.Name(), "KDPK016G") || strings.HasPrefix(file.Name(), "KDPK126G") {
				qtsuchi := filepath.Join(conf.Indir, file.Name())
				tmptxt := filepath.Join(conf.Workdir, "tmp95.txt")
				for p, t := range xdw2txtb(qtsuchi, tmptxt) {
					hno := re_hhsno.FindString(t)
					if h, ok := hash_Hhs[hno]; ok {
						h.Tsuchi = true
						q := fmt.Sprintf("q_%05d.xdw", qn)
						h.AppendXdw(q)
						hash_Hhs[hno] = h
						q = filepath.Join(conf.Workdir, q)
						C.xdwextpage(C.CString(qtsuchi), C.int(p + 1), C.CString(q))
						qn++
						//fmt.Println(qtsuchi, p, hno, h.Kaigo, h.Xdw)
					}
				}
			}
		}

		ch <- 1
	}()

	/* そのあいだにバラす */
	C.xdwsplit1(C.CString(osirase), C.CString(conf.Workdir), C.CString("o_"))
	C.xdwsplit1(C.CString(sinsei), C.CString(conf.Workdir), C.CString("s_"))
	<-ch

	/* ソート & マージ */
	var slice_Hhs []Hhs
	for _, h := range hash_Hhs {
		slice_Hhs = append(slice_Hhs, h)
	}
	sort.Slice(slice_Hhs, func(i, j int) bool {
		if slice_Hhs[i].Tsuchi != slice_Hhs[j].Tsuchi {
			return slice_Hhs[i].Tsuchi
		}
		if slice_Hhs[i].Kaigo != slice_Hhs[j].Kaigo {
			return slice_Hhs[i].Kaigo < slice_Hhs[j].Kaigo
		}
		if slice_Hhs[i].Page != slice_Hhs[j].Page {
			return slice_Hhs[i].Page < slice_Hhs[j].Page
		}
		return false
	})

	var list_o, list_s, list_q []string
	for _, h := range slice_Hhs {
		list_o = append(list_o, filepath.Join(conf.Workdir, h.Xdw[0]))
		list_s = append(list_s, filepath.Join(conf.Workdir, h.Xdw[1]))
		if h.Tsuchi {
			for i, x := range h.Xdw {
				if i > 1 {
					buf := filepath.Join(conf.Workdir, x)
					list_q = append(list_q, buf)
				}
			}
		}
	}
	xdwmerge(list_o, out_o)
	xdwmerge(list_s, out_s)
	xdwmerge(list_q, out_q)

	/* リスト出力 & ログダンプ */
	csvtxt := ""
	logtxt := ""
	for _, h := range slice_Hhs {
		csvtxt += h.CsvString() + "\n"
		logtxt += h.Dump() + "\n"
	}
	csvtxt, _, _ = transform.String(japanese.ShiftJIS.NewEncoder(), csvtxt)
	if err := ioutil.WriteFile(out_l, []byte(csvtxt), 0644); err != nil {
		log.Fatal(err)
	}
	if err := ioutil.WriteFile(logfile, []byte(logtxt), 0644); err != nil {
		log.Fatal(err)
	}

	/* バックグラウンドで給付費通知を校正 */
	ch2 := make(chan int)
	go func() {
		for _, a := range conf.Atnfile {
			xdwaddatn(out_q, a)
		}
		ch2 <- 1
	} ()

	/* そのあいだに申請書に枠付け */
	xdwaddatntool(out_s, rule_s, 2, 1497, 803)
	<-ch2
}

func xdw2txt(file string) (txt []string) {
	s := C.GoString(C.xdw2txt(C.CString(file)))
	r := strings.NewReader(s)
	tr := transform.NewReader(r, japanese.ShiftJIS.NewDecoder())
	buf := bufio.NewScanner(tr)
	for buf.Scan() {
		txt = append(txt, buf.Text())
	}
	return
}

func xdw2txtb(xdwfile, txtfile string) (txt []string) {
	if _, err := os.Stat(txtfile); os.IsExist(err) {
		os.Remove(txtfile)
	}

	C.xdw2txtb(C.CString(xdwfile), C.CString(txtfile))
    content, err := ioutil.ReadFile(txtfile)
    if err != nil {
		return nil
    }

	r := strings.NewReader(string(content))
	tr := transform.NewReader(r, japanese.ShiftJIS.NewDecoder())
	buf := bufio.NewScanner(tr)
	for buf.Scan() {
		txt = append(txt, buf.Text())
	}
	return
}

func xdwmerge(list []string, outfile string) (err error) {
	order := strings.Join(list, "\n")
	order, _, _ = transform.String(japanese.ShiftJIS.NewEncoder(), order)
	orderfile := filepath.Join(conf.Workdir, "order95.txt")
	if err := ioutil.WriteFile(orderfile, []byte(order), 0644); err != nil {
		return err
	}
	C.xdwmerge(C.CString(orderfile), C.CString(outfile))
	return nil
}

func xdwaddatn(xdwfile, atnfile string) (err error) {
	C.xdwaddatn(C.CString(xdwfile), C.CString(atnfile))
	return nil
}

func xdwaddatntool(xdwfile, toolfile string, n, x, y int) (err error) {
	C.xdwaddatntool(C.CString(xdwfile), C.CString(toolfile), C.int(n), C.int(x), C.int(y))
	return nil
}