优化2.0

server/config.yaml

@@ -125,7 +125,7 @@ mysql:
     config: charset=utf8mb4&parseTime=True&loc=Local
     db-name: smart_intersection2.0
     username: root
-    password: root
+    password: 123456
     path: 127.0.0.1
     engine: ""
     log-mode: error

server/dao/dev_event.go

@@ -33,3 +33,7 @@ func QueryEventByUserId(userId int) (data interface{}, err error) {
 	}
 	return results, err
 }
+
+func (e Event) AddEvent() error {
+	return global.GVA_DB.Model(&Event{}).Create(&e).Error
+}

server/service/devices/mqtt.go

@@ -88,9 +88,17 @@ func (o *MqttHandler) Handler() interface{} {
 
 		switch topic {
 		case TopicHighSpeed: //存储超速事件
-
+			event := dao.Event{Sn: sn, Type: "超速", Time: m.PayloadString()}
+			err := event.AddEvent()
+			if err != nil {
+				global.GVA_LOG.Error(fmt.Sprintf("添加事件失败:%s", err.Error()))
+			}
 		case TopicLowSpeed: //存储低速时间
-
+			event := dao.Event{Sn: sn, Type: "低速", Time: m.PayloadString()}
+			err := event.AddEvent()
+			if err != nil {
+				global.GVA_LOG.Error(fmt.Sprintf("添加事件失败:%s", err.Error()))
+			}
 		case TopicChanStatus: //修改屏幕状态
 			status, _ := strconv.Atoi(m.PayloadString())
 			err := dao.UpdateScreensStatusBySn(sn, status)