package controllers
|
|
import (
|
"car-service/extend/code"
|
"car-service/models"
|
"car-service/service"
|
"fmt"
|
"github.com/astaxie/beego"
|
"github.com/satori/go.uuid"
|
"net/http"
|
"sort"
|
"strings"
|
"sync"
|
"time"
|
)
|
|
type CarController struct {
|
beego.Controller
|
}
|
|
//实时计算剩余车位数量，达到条件就推送
|
//要求：
|
//1.停车数量小于等于5个推送，5个以下的数量变化都推送，推送给已注册手机号的用户，未注册的不推
|
//2.满足上一条，如果此车辆已经进入学校停车场了，就不再给这个车牌对应的手机号推送空余车位消息
|
//3.晚上10点到10点半，每间隔10分钟，给停车场内的车辆推送消息：请尽快驶出停车场
|
func ComputeSpaceLeftRealTime() {
|
ticker := time.NewTicker(3 * time.Second)
|
prePushLeft, _ := beego.AppConfig.Int("initPushLeft") //初始剩余数量，上线后不能每次启动都推送消息
|
sv := service.NewCarService()
|
initCacheM := false
|
lowerLimit,_ := beego.AppConfig.Int("pushLowerLimit") //[0,5]
|
nightPushTimes := 0
|
for {
|
select {
|
case <-ticker.C:
|
hikSta, flag := sv.Statistic()
|
if flag {
|
left := hikSta.Left
|
if !initCacheM {
|
models.SetSpaceNo(hikSta.TotalPlace)
|
initCacheM = true
|
}
|
|
if left <=lowerLimit && left != prePushLeft {
|
go func() {
|
t := time.Now().Format("2006-01-02 15:04:05")
|
message := fmt.Sprintf("%s 剩余车位：%d个", t, left)
|
b, e, aliasArr := service.PushByAlias("剩余车位提醒", message, false)
|
//记录推送日志
|
logE := models.Log{
|
Id: uuid.NewV4().String(),
|
CreateTime: t,
|
Result: b,
|
Phones: strings.Join(aliasArr, ","),
|
}
|
if e != nil {
|
logE.Content = e.Error()
|
} else {
|
logE.Content = message
|
}
|
logE.Insert()
|
prePushLeft = left
|
|
fmt.Println("b:", b,"e:",e, "message:", message)
|
}()
|
}
|
updateSpaceLeft(left)
|
}
|
//判断当前是否在22:00-22:30之间
|
now := time.Now()
|
if now.Hour() == 22 && now.Minute()>=0 && now.Minute() <=30{
|
if now.Minute() == 0 {
|
if nightPushTimes ==0 {
|
go nightPush(nightPushTimes)
|
nightPushTimes++
|
}
|
} else if now.Minute() == 10 {
|
if nightPushTimes == 1 {
|
go nightPush(nightPushTimes)
|
nightPushTimes++
|
}
|
} else if now.Minute() == 20 {
|
if nightPushTimes == 2{
|
go nightPush(nightPushTimes)
|
nightPushTimes++
|
}
|
} else if now.Minute() == 30 {
|
if nightPushTimes == 3{
|
go nightPush(nightPushTimes)
|
nightPushTimes++
|
}
|
}
|
} else {
|
nightPushTimes = 0
|
}
|
|
default:
|
time.Sleep(500 * time.Millisecond)
|
}
|
}
|
}
|
|
func nightPush(curTimes int){
|
|
message := fmt.Sprintf("%s 请尽快驶出停车场", time.Now().Format("2006-01-02 15:04:05"))
|
b, e, aliasArr,carOwnNames := service.NightPush("温馨提示", message)
|
//记录推送日志
|
logE := models.Log{
|
Id: uuid.NewV4().String(),
|
CreateTime: time.Now().Format("2006-01-02 15:04:05"),
|
Result: b,
|
Phones: strings.Join(aliasArr, ","),
|
}
|
if e != nil {
|
logE.Content = e.Error()
|
} else {
|
logE.Content = message
|
}
|
logE.Insert()
|
fmt.Println("b:", b,"e:",e, "message:", message)
|
|
if curTimes == 3 { //只给管理员推送一次这个消息
|
//将具体的车主信息推送给管理员
|
if carOwnNames != nil && len(carOwnNames) >0 {
|
//获取车主姓名
|
managerMsg := strings.Join(carOwnNames, ",")
|
mb,me, managerArr := service.Push2Manager(fmt.Sprintf("%s 未驶离车辆", time.Now().Format("2006-01-02 15:04:05")), managerMsg, false)
|
mLogE := models.Log{
|
Id: uuid.NewV4().String(),
|
CreateTime: time.Now().Format("2006-01-02 15:04:05"),
|
Result: mb,
|
Phones: strings.Join(managerArr, ","),
|
}
|
if me != nil {
|
mLogE.Content = me.Error()
|
} else {
|
mLogE.Content = managerMsg
|
}
|
mLogE.Insert()
|
fmt.Println("mb:", mb, "me:", me, "message:", managerMsg)
|
}
|
}
|
|
}
|
|
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() {
|
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 /testPush [get]
|
func (c *CarController) TestPush() {
|
left := getSpaceLeft()
|
message := fmt.Sprintf("%s 剩余车位：%d个", time.Now().Format("2006-01-02 15:04:05"), left)
|
b, e, aliasArr := service.PushByAlias("剩余车位提醒", message, true)
|
//记录推送日志
|
logE := models.Log{
|
Id: uuid.NewV4().String(),
|
CreateTime: time.Now().Format("2006-01-02 15:04:05"),
|
Result: b,
|
Phones: strings.Join(aliasArr, ","),
|
}
|
if e != nil {
|
logE.Content = e.Error()
|
} else {
|
logE.Content = message
|
}
|
logE.Insert()
|
|
fmt.Println("b:", b,"e:",e, "message:", message)
|
resp := code.Code{}
|
if b {
|
resp.Success = true
|
resp.Status = http.StatusOK
|
resp.Data = "推送成功"
|
} else {
|
resp.Success = false
|
resp.Status = http.StatusInternalServerError
|
resp.Data = e.Error()
|
}
|
c.Data["json"] = resp
|
c.ServeJSON()
|
}
|
|
// @router /testNightPush [get]
|
func (c *CarController) TestNightPush() {
|
carOwnNames := service.GetLeftCarOwners()
|
|
//将具体的车主信息推送给管理员
|
if carOwnNames != nil && len(carOwnNames) >0 {
|
//获取车主姓名
|
managerMsg := strings.Join(carOwnNames, ",")
|
mb,me, managerArr := service.Push2Manager(fmt.Sprintf("%s 未驶离车辆", time.Now().Format("2006-01-02 15:04:05")), managerMsg, true)
|
mLogE := models.Log{
|
Id: uuid.NewV4().String(),
|
CreateTime: time.Now().Format("2006-01-02 15:04:05"),
|
Result: mb,
|
Phones: strings.Join(managerArr, ","),
|
}
|
if me != nil {
|
mLogE.Content = me.Error()
|
} else {
|
mLogE.Content = managerMsg
|
}
|
mLogE.Insert()
|
fmt.Println("mb:", mb, "me:", me, "message:", managerMsg)
|
|
c.Data["json"] = code.Code{
|
Success: true,
|
Status: http.StatusOK,
|
Message: "推送完成",
|
Data: managerMsg,
|
}
|
} else {
|
c.Data["json"] = code.Code{
|
Success: true,
|
Status: http.StatusOK,
|
Message: "无需推送，当前停留车辆信息为空",
|
}
|
}
|
|
c.ServeJSON()
|
}
|
// @router /spaceInfo [get]
|
func (c *CarController) SpaceInfo() {
|
userId := c.GetString("userId")
|
sv := service.NewCarService()
|
spaceInfo := sv.FindHikSpaceInfo(userId)
|
c.Data["json"] = code.Code{
|
Success: true,
|
Status: http.StatusOK,
|
Data: spaceInfo,
|
}
|
c.ServeJSON()
|
}
|
|
// @router /spaceUser [get]
|
func (c *CarController) SpaceUser() {
|
userId := c.GetString("userId")
|
sv := service.NewCarService()
|
spaceUser := sv.FindHikSpaceUser(userId)
|
c.Data["json"] = code.Code{
|
Success: true,
|
Status: http.StatusOK,
|
Data: spaceUser,
|
}
|
c.ServeJSON()
|
}
|
|
// @router /pushLog [get]
|
func (c *CarController) PushLog() {
|
st := c.GetString("startTime")
|
et := c.GetString("endTime")
|
if st == "" {
|
st = time.Now().Format("2006-01-02")
|
}
|
if et == "" {
|
et = time.Now().AddDate(0,0,1).Format("2006-01-02")
|
}
|
curPage, err := c.GetInt("curPage")
|
if err != nil {
|
curPage = 1
|
}
|
pageSize, err := c.GetInt("pageSize")
|
if err != nil {
|
pageSize = 20
|
}
|
var l models.Log
|
total, logs := l.Find(curPage, pageSize, st, et)
|
var rl []models.Log
|
for _,le := range logs {
|
rl = append(rl, *le)
|
}
|
resp := code.Code{
|
Success: true,
|
Status: http.StatusOK,
|
Data: map[string]interface{}{
|
"total": total,
|
"list": rl,
|
},
|
}
|
c.Data["json"] = resp
|
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()
|
}
|
