From bae4af47f77a195a12a0437584d667465e826e12 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期一, 17 八月 2020 16:09:28 +0800
Subject: [PATCH] add log
---
controllers/car.go | 114 +++++++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 98 insertions(+), 16 deletions(-)
diff --git a/controllers/car.go b/controllers/car.go
index 11ce19b..732fcff 100644
--- a/controllers/car.go
+++ b/controllers/car.go
@@ -17,29 +17,81 @@
}
//瀹炴椂璁＄畻鍓╀綑杞︿綅鏁伴噺锛岃揪鍒版潯浠跺氨鎺ㄩ��
+//瑕佹眰锛�
+//1.鍋滆溅鏁伴噺灏忎簬绛変簬5涓帹閫侊紝5涓互涓嬬殑鏁伴噺鍙樺寲閮芥帹閫侊紝鎺ㄩ�佺粰宸叉敞鍐屾墜鏈哄彿鐨勭敤鎴凤紝鏈敞鍐岀殑涓嶆帹
+//2.婊¤冻涓婁竴鏉★紝濡傛灉姝よ溅杈嗗凡缁忚繘鍏ュ鏍″仠杞﹀満浜嗭紝灏变笉鍐嶇粰杩欎釜杞︾墝瀵瑰簲鐨勬墜鏈哄彿鎺ㄩ�佺┖浣欒溅浣嶆秷鎭�
+//3.鏅氫笂10鐐瑰埌10鐐瑰崐锛屾瘡闂撮殧10鍒嗛挓锛岀粰鍋滆溅鍦哄唴鐨勮溅杈嗘帹閫佹秷鎭細璇峰敖蹇┒鍑哄仠杞﹀満
func ComputeSpaceLeftRealTime() {
ticker := time.NewTicker(3 * time.Second)
prePushLeft := 0
+ sv := service.NewCarService()
+ initCacheM := false
+ lowerLimit,_ := beego.AppConfig.Int("pushLowerLimit") //[0,5]
+ nightPushTimes := 0
for {
select {
case <-ticker.C:
- m := time.Now().Minute()
- i := m % 10
- left := 80
- if i == 0 {
- left = 10
+ hikSta, flag := sv.Statistic()
+ if flag {
+ left := hikSta.Left
+ if !initCacheM {
+ models.SetSpaceNo(hikSta.TotalPlace)
+ initCacheM = true
+ }
+
+ if left <=lowerLimit && left != prePushLeft {
+ go func() {
+ message := fmt.Sprintf("%s 鍓╀綑杞︿綅锛�%d涓�", time.Now().Format("2006-01-02 15:04:05"), left)
+ b, e := service.PushByAlias("鑲茶嫳涓鍋滆溅", message)
+
+ prePushLeft = left
+
+ fmt.Println("b:", b,"e:",e, "message:", message)
+ }()
+ }
+ updateSpaceLeft(left)
}
- if m == 40 {
- left = 5
+ //鍒ゆ柇褰撳墠鏄惁鍦�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++
+ }
+ } else if now.Minute() == 10 {
+ if nightPushTimes == 1 {
+ go nightPush()
+ nightPushTimes++
+ }
+ } else if now.Minute() == 20 {
+ if nightPushTimes == 2{
+ go nightPush()
+ nightPushTimes++
+ }
+ } else if now.Minute() == 30 {
+ if nightPushTimes == 3{
+ go nightPush()
+ nightPushTimes++
+ }
+ }
+ } else {
+ nightPushTimes = 0
}
- if left <=10 && left != prePushLeft {
- go service.Push("鑲茶嫳鏅烘収鍋滆溅", fmt.Sprintf("褰撳墠鍓╀綑杞︿綅锛�%d涓�", left))
- }
- updateSpaceLeft(left)
+
default:
time.Sleep(500 * time.Millisecond)
}
}
+}
+
+func nightPush(){
+
+ message := fmt.Sprintf("%s 璇峰敖蹇┒鍑哄仠杞﹀満", time.Now().Format("2006-01-02 15:04:05"))
+ b, e := service.NightPush("鑲茶嫳涓鍋滆溅", message)
+
+ fmt.Println("b:", b,"e:",e, "message:", message)
+
}
var cacheSpaceLeft int
@@ -61,8 +113,6 @@
// @Failure 403 {string} json ""
// @router /statistic [get]
func (c *CarController) Statistic() {
- //sv := service.NewCarService()
- //sta := sv.Statistic()
left := getSpaceLeft()
sta := models.CarStatistic{
Left: left,
@@ -91,8 +141,9 @@
// @Failure 403 {string} json ""
// @router /spaceNo [get]
func (c *CarController) SpaceNo() {
+ userId := c.GetString("userId")
sv := service.NewCarService()
- spaceNos := sv.FindSpaceNo()
+ spaceNos := sv.FindSpaceNo(userId)
sort.Sort(spaceNos)
resp := code.Code{
Success: true,
@@ -103,11 +154,42 @@
c.ServeJSON()
}
+
func (c *CarController) BindCarSpace() {
- sv := service.NewCarService()
- if sv.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 := service.PushByAlias("鑲茶嫳涓鍋滆溅", message)
+
+ 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 /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()
}
\ No newline at end of file
--
Gitblit v1.8.0