package controllers

import (
	"car-service/extend/code"
	"car-service/models"
	"car-service/service"
	"fmt"
	"github.com/astaxie/beego"
	"net/http"
	"sort"
	"sync"
	"time"
)

type CarController struct {
	beego.Controller
}

//实时计算剩余车位数量，达到条件就推送
func ComputeSpaceLeftRealTime() {
	ticker := time.NewTicker(3 * time.Second)
	prePushLeft := 0
	sv := service.NewCarService()
	initCacheM := false
	for {
		select {
			case <-ticker.C:
				hikSta, flag := sv.Statistic()
				if flag {
					left := hikSta.Left
					if !initCacheM {
						models.SetSpaceNo(hikSta.TotalPermPlace)
						initCacheM = true
					}
					if left <=5 && left != prePushLeft {
						go func() {
							message := fmt.Sprintf("%s 剩余车位：%d个", time.Now().Format("2006-01-02 15:04:05"), left)
							b, e := service.Push("育英智慧停车", message)

							prePushLeft = left

							fmt.Println("b:", b,"e:",e, "message:", message)
						}()
					}
					updateSpaceLeft(left)
				}

		default:
			time.Sleep(500 * time.Millisecond)
		}
	}
}

var cacheSpaceLeft int
var cLock sync.RWMutex
func updateSpaceLeft(num int) {
	cLock.Lock()
	defer cLock.Unlock()
	cacheSpaceLeft = num
}
func getSpaceLeft() int {
	cLock.Lock()
	defer cLock.Unlock()
	return cacheSpaceLeft
}

// @Title 统计剩余车位
// @Description 统计剩余车位
// @Success 200 {object} models.CarStatistic
// @Failure 403 {string} json ""
// @router /statistic [get]
func (c *CarController) Statistic() {
	//sv := service.NewCarService()
	//hikStc := sv.Statistic()
	//left := hikStc.Left
	left := getSpaceLeft()
	sta := models.CarStatistic{
		Left: left,
	}
	resp := code.Code{
		Success: true,
		Status: http.StatusOK,
		Data: sta,
	}
	c.Data["json"] = resp
	c.ServeJSON()
}

// @Title 根据车牌号查找车位信息
// @Description 根据车牌号查找车位信息
// @Success 200 {object} models.CarPos
// @Failure 403 {string} json ""
// @router /carPos [get]
func (c *CarController) findCar() {

}

// @Title 车位占用情况
// @Description 车位占用情况
// @Success 200 {object} models.PosResult
// @Failure 403 {string} json ""
// @router /spaceNo [get]
func (c *CarController) SpaceNo() {
	userId := c.GetString("userId")
	sv := service.NewCarService()
	spaceNos := sv.FindSpaceNo(userId)
	sort.Sort(spaceNos)
	resp := code.Code{
		Success: true,
		Status: http.StatusOK,
		Data: spaceNos,
	}
	c.Data["json"] = resp
	c.ServeJSON()
}


func (c *CarController) BindCarSpace() {

	c.ServeJSON()
}

// @router /crossRecord [get]
func (c *CarController) CrossRecord() {
	sv := service.NewCarService()
	records := sv.CrossRecords()
	resp := code.Code{
		Success: true,
		Status:  http.StatusOK,
		Data:    records,
	}
	c.Data["json"] = resp
	c.ServeJSON()
}