package main

import (
   "database/sql"
   "fmt"
   _ "github.com/mattn/go-oci8"
   "html/template"
   "log"
   "net/http"
   "os"
   "os/exec"
   "path/filepath"
   "time"
)

type Items struct {
   ROW_NUM       string
   PART_CODE     string
   PART_NAME     string
   PART_MODEL_NO sql.NullString
   PART_PLATFORM string
   PART_ABB      string
   RESERVE07     string
}

var DB *sql.DB

func DBconnect() {
   var err error
   //go连接mysql实例
   //数据库源信息
   dsn := "隐藏"
   //连接数据库
   DB, err = sql.Open("oci8", dsn) //不会校验用户名和密码是否正确
   if err != nil {
      log.Fatal(err)
   }
   err = DB.Ping()

   if err != nil {
      time.Sleep(5 * time.Minute)
      DBconnect()
   }
   return
}

t := template.Must(template.ParseFiles("template.html"))

// FileServer返回一个使用FileSystem接口root提供文件访问服务的HTTP处理器
file, _ := exec.LookPath(os.Args[0])
//得到全路径，比如在windows下E:\\golang\\test\\a.exe
path, _ := filepath.Abs(file)
rst := filepath.Dir(path)
http.Handle("/", http.FileServer(http.Dir(rst)))

t := template.Must(template.ParseFiles("template.html"))
//检索所有
http.HandleFunc("/CheckPart", func(writer http.ResponseWriter, request *http.Request) {
   DBconnect()
   s := make([]Items, 0)
   if DB == nil {
      fmt.Fprintln(writer, "sry , please try again ...")
      return
   }
   rows, err2 := DB.Query("select ROWNUM, PART_CODE ,PART_NAME ,PART_MODEL_NO,PART_PLATFORM ,PART_ABB ,case RESERVE07 when '是' then '默认规则' when '否' then '不解析' else Reserve07 end RESERVE07 from part where PART_NAME like '%AQJ%'")
   if err2 != nil {
      fmt.Fprintln(writer, "sry , please try again ...")
      return
   }
   for rows.Next() {
      i := new(Items)
      rows.Scan(&i.ROW_NUM, &i.PART_CODE, &i.PART_NAME, &i.PART_MODEL_NO, &i.PART_PLATFORM, &i.PART_ABB, &i.RESERVE07)
      s = append(s, *i)
   }
   err2 = t.Execute(writer, s)
   if err2 != nil {
      panic(err2)
   }
})

//查询
http.HandleFunc("/Search", func(writer http.ResponseWriter, request *http.Request) {
		m := make(map[string]string)
		m["默认规则"] = "是"
		m["不解析"] = "否"
		request.ParseForm()
		value := request.FormValue("keyword")
		if v, ok := m[value]; ok {
			value = v
		}
		value = "%" + value + "%"
		DBconnect()
		s := make([]Items, 0)
		query, err := DB.Query("select ROWNUM, PART_CODE ,PART_NAME ,PART_MODEL_NO,PART_PLATFORM ,PART_ABB ,case RESERVE07 when '是' then '默认规则' when '否' then '不解析' else Reserve07 end RESERVE07 from part where PART_NAME like '%AQJ%' and (part_code like :1 or part_name like :2 or part_model_no like :3 or part_platform like :4 or part_abb like :5 or reserve07 like :6)", value, value, value, value, value, value)
		if err != nil {
			panic(err)
			return
		}
		for query.Next() {
			i := new(Items)
			query.Scan(&i.ROW_NUM, &i.PART_CODE, &i.PART_NAME, &i.PART_MODEL_NO, &i.PART_PLATFORM, &i.PART_ABB, &i.RESERVE07)
			s = append(s, *i)
		}
		err2 := t.Execute(writer, s)
		if err2 != nil {
			panic(err2)
		}
	})

//监听端口 发布服务
server := http.Server{
		Addr:              ":8081",
		Handler:           nil,
		TLSConfig:         nil,
		ReadTimeout:       0,
		ReadHeaderTimeout: 0,
		WriteTimeout:      0,
		IdleTimeout:       0,
		MaxHeaderBytes:    0,
		TLSNextProto:      nil,
		ConnState:         nil,
		ErrorLog:          nil,
		BaseContext:       nil,
		ConnContext:       nil,
	}
	log.Println(server.ListenAndServe())