package main

import (
	"database/sql"
	"encoding/json"
	_ "github.com/mattn/go-sqlite3"
	"log"
	"os"
	"strconv"
	"time"
	"sync"
)

type Traffic struct {
	TRAFFIC uint16 `json:"traffic"`
}

type Satisfaction struct {
	SATISFACTION float64 `json:"satisfaction"`
}

type Conf struct {
	GATEWAY_INFO     Gateway_info            `json:"gateway_info"`
	DEVICES_LIST     [][]string              `json:"devices_list`
	SERIALPORTS_LIST map[string]Serialconf   `json:"serialports_list"`
	RS485DEVICES     map[string]Rs485devices `json:"rs485devices"`
	ICONURL          string                  `json:"iconurl`
	WEBSOCKETURL     []string                `json:"websocketurl"`
	POST_TO_SERVER   string                  `json:"post_to_server"`
	DEBUG            bool                    `json:"debug"`
	//是否初始化时打开串口
	OPENSERIAL bool `json:"openserial"`
	//无线 设备
	WIRELESSSLAVEDEVICES []WirelessSlaveDevice `json:"wireless_slave_devices"`
	//是否启动tcpserver
	OPENTCPSETVER bool `json:"open_tcp_server"`
	CHECKSERIAL   bool `json:"check_serial"`
	LORANODES						[]LoraNode								`json:"lora_nodes"`
	DPARKLOCATION		string									`json:"dpark_location"`
	TCPPORT				int		`json:"tcp_port"`
	APIPORT				int		`json:"api_port"`
}

//无线 下位机
type WirelessSlaveDevice struct {
	ADRH    int    `json:"adrh"`
	ADRL    int    `json:"adrl"`
	TYPE    int    `json:"type"`
	VERSION string `json:"version"`
	FLIP    bool   `json:"flip"`
	ID      string `json:"id"`
}

type Gateway_info struct {
	ID       string    `json:"id"`
	VERSION  string    `json:"version"`
	LOCATION []float64 `json:"location"`
	UNITNAME string    `json:"单位"`
	CONFIG   []Config  `json:"config"`
}

type Config struct {
	ID      string          `json:"id"`
	VERAION string          `json:"version"`
	DATA    [][]interface{} `json:"data"`
}

type Rs485devices struct {
	VERSION string   `json:"version"`
	NUM     string   `json:"num"`
	COMMAND [][]byte `json:"command"`
}

type Serialconf struct {
	COM         string `json:"com"`
	BAUDS       int    `json:"bauds"`
	SIZE        uint16 `json:"size"`
	PARITY      string `json:"parity"`
	STOPBITS    int    `json:"stopbits"`
	READTIMEOUT int    `json:"readtimeout"`
	NOTE        string `json:"note"`
}

type LoraNode struct{
	ADR					string `json:"adr"`
	LOCATION_TYPE		string `json:"location_type"`
	LOCATION_CODE		string `json:"location_code"`
	LOCATION_DATA		string	`json:"location_data"`
	TIME					time.Time			`json:"time"`
	CURRENT_DATA		int 		`json:"current_data"`
	CHECK_TIME			bool 		`json:"check_time"`
	DEVICE 					string	`json:"device"`
}

var conf Conf
var DEVICEDATAS Devicedatas
var demoDevice Device


var airDevice Device

var femaledemoDevice Device
var maledemoDevice Device


var db, _ = sql.Open("sqlite3", "./db/gateway.db")

var loraNodeMap sync.Map

// 加载配置文件
func init() {

	time.Now()

	configfile, err := os.Open("conf/gateway.conf")
	check(err)
	defer configfile.Close()
	err = json.NewDecoder(configfile).Decode(&conf)
	check(err)
	var device Device

	// log.Println("slaveDevices:", conf.WIRELESSSLAVEDEVICES)

	for _,v := range conf.LORANODES {
			v.CURRENT_DATA = -1
			// log.Println("&&&&&&&&&&&&&&&&&&&",v)
			v.TIME = time.Now()
			loraNodeMap.Store(v.ADR,v)
	}

	DEVICEDATAS.Lock()
	DEVICEDATAS.DATA = make(map[string]Device)

	//校验是否有设置重复串口
	//var serialPort = make(map[string]int)

	//初始化设备，目前conf.DEVICES_LIST
	for _, i := range conf.DEVICES_LIST {

		//if _, c := serialPort[i[1]]; c {
		//	log.Println("repeatd serial port:", i[1])
		//	os.Exit(3)
		//} else {
		//	serialPort[i[1]] = 0
		//}

		device.DATA = make(map[string]interface{})
		device.ID = i[0]
		device.VERSION = i[2]
		//版本号+编号
		DEVICEDATAS.DATA[i[2]+"_"+i[3]] = device
	}

	DEVICEDATAS.Unlock()

	demoDevice.ID = "deb03e28-ddcb-4e5d-aa31-d870a1f0f09b"
	demoDevice.VERSION = "yunhorn_kgl_c8_v1"
	demoDevice.DATA = make(map[string]interface{})
	for a := 0; a < 8; a++ {
		demoDevice.DATA["data"+strconv.Itoa(a+1)] = 0
	}

	demoDevice.ONLINE = true
	log.Println("init demoDevice success:", demoDevice)

	airDevice.DATA = make(map[string]interface{})
	airDevice.DATA["data"] = 0

	var device2 Device
	device2.Lock()
	device2.ID = demoDevice.ID
	device2.VERSION = demoDevice.VERSION
	device2.ONLINE = demoDevice.ONLINE
	device2.DATA = make(map[string]interface{})

	device2.DATA["data7"] = 0
	device2.DATA["data8"] = 0

	device2.Unlock()
	//DEVICEDATAS.DATA[demoDevice.VERSION+"_1"] = device2

	femaledemoDevice.ID = "8E146028-E1B1-4AC9-8F47-01376A22CB35"
	femaledemoDevice.VERSION = "yunhorn_kgl_c8_v1"
	femaledemoDevice.DATA = make(map[string]interface{})
	femaledemoDevice.ONLINE = true
	femaledemoDevice.DATA["data1"] = 0

	//3是男厕
	DEVICEDATAS.DATA[demoDevice.VERSION+"_3"] = femaledemoDevice

	//2是女厕  配置演示使用
	maledemoDevice.ID = "7BB22E6A-ED0D-4161-8370-6B722D3683B7"
	maledemoDevice.VERSION = "yunhorn_kgl_c8_v1"
	maledemoDevice.DATA = make(map[string]interface{})
	maledemoDevice.ONLINE = true
	maledemoDevice.DATA["data1"] = 0
	maledemoDevice.DATA["data2"] = 0
	//3是男厕
	DEVICEDATAS.DATA[demoDevice.VERSION+"_2"] = maledemoDevice


	go dbdata_init()

}

var good, bad float64
var traffic_data Traffic
var satisfaction_data Satisfaction

// 初始化评价数据和人流量数据
func dbdata_init() {
	rows, err := db.Query("SELECT good, bad FROM satisfaction order by id DESC limit 1")
	if err != nil {
		good = 1
		bad = 0

	} else {
		rows.Next()
		rows.Scan(&good, &bad)
		rows.Close()
	}
	//在原本没有db文件的情况下调用 会报错
	// rows.Close()
	rows, err = db.Query("SELECT traffic FROM traffic t where datetime(t.create_time) > datetime('now','start of day','-1 day') order by id DESC limit 1 ")
	if err != nil {
		traffic_data.TRAFFIC = 0
	} else {
		rows.Next()
		rows.Scan(&traffic_data.TRAFFIC)
		rows.Close()
	}
	//在原本没有db文件的情况下调用 会报错
	//  rows.Close()
}

// 定时更新评价数据和人流数据
func savedata_cron() {
	T := time.Now().Format("2006-01-02")
	stmt, err := db.Prepare("UPDATE satisfaction set  good=?, bad=? ,create_time=? where id=(SELECT max(id) FROM satisfaction)")
	check(err)
	stmt.Exec(&good, &bad, &T)
	stmt, err = db.Prepare("UPDATE traffic set traffic=?, create_time=? where id=(SELECT max(id) FROM traffic)")
	check(err)
	stmt.Exec(&traffic_data.TRAFFIC, &T)
}

// 每天0点插入一条数据
//TODO 刚好有人流量数据
func insertdata() {
	T := time.Now().Format("2006-01-02")
	stmt, _ := db.Prepare(`INSERT INTO traffic (traffic, create_time) values (?, ?)`)
	stmt.Exec(&traffic_data.TRAFFIC, &T)
	traffic_data.TRAFFIC = 0
}