diff --git a/consumers/consumerESraw2http.go b/consumers/consumerESraw2http.go index 262675c..b3e74b4 100644 --- a/consumers/consumerESraw2http.go +++ b/consumers/consumerESraw2http.go @@ -250,13 +250,23 @@ func ChangeEsValueToHttpBody(hit models.HitRaw) models.PostThings { postThings.Online = hit.Source.Data["value"].(float64) postThings.Lng = 116.1508654 postThings.Lat = 23.00236479 + } else if hit.Source.IotaDevice == "a119015f-534f-41a7-83ca-18d8cd23d93a" { //往汕头方向信号灯距桥160米 + postThings.EquipCode = "000065A2" + postThings.Online = hit.Source.Data["value"].(float64) + postThings.Lng = 116.1508654 + postThings.Lat = 23.00236479 + } else if hit.Source.IotaDevice == "2870bc36-93b4-414a-92d5-3aaf70099fda" { //往深圳方向信号灯距桥160米 + postThings.EquipCode = "000065A3" + postThings.Online = hit.Source.Data["value"].(float64) + postThings.Lng = 116.1508654 + postThings.Lat = 23.00236479 } else if hit.Source.IotaDevice == "21812630-404e-4946-9aaf-42e529db923a" { //往深圳方向信号灯 - postThings.EquipCode = "8678960778883801" + postThings.EquipCode = "0000677a" postThings.Online = hit.Source.Data["value"].(float64) postThings.Lng = 116.1508654 postThings.Lat = 23.00236479 } else if hit.Source.IotaDevice == "61aea690-e544-4717-aaf9-dd346e7465c0" { //往汕头方向信号灯 - postThings.EquipCode = "8678960778883802" + postThings.EquipCode = "0000677b" postThings.Online = hit.Source.Data["value"].(float64) postThings.Lng = 116.1508654 postThings.Lat = 23.00236479