|
@ -27,6 +27,11 @@ func (the Adaptor_AXY_LastRAW) raw2es(iotaData models.IotaData) *models.EsRaw { |
|
|
if len(iotaData.Data.Data) == 0 { |
|
|
if len(iotaData.Data.Data) == 0 { |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if !iotaData.Data.Success() { |
|
|
|
|
|
msg, _ := json.Marshal(iotaData.Data.Result) |
|
|
|
|
|
iotaData.Data.Data["errMsg"] = string(msg) |
|
|
|
|
|
} |
|
|
//log.Printf("设备[%s] 数据时间 %s", iotaData.DeviceId, iotaData.TriggerTime)
|
|
|
//log.Printf("设备[%s] 数据时间 %s", iotaData.DeviceId, iotaData.TriggerTime)
|
|
|
deviceInfo := the.GetDeviceInfo(iotaData.DeviceId) |
|
|
deviceInfo := the.GetDeviceInfo(iotaData.DeviceId) |
|
|
|
|
|
|
|
|